|
fq
|
ydb/library/yql/providers/pq/gateway/ut/TCompositeTopicReadSessionTest.AdvancePartitionTimeAfterGetEvent
SANITIZER
Test crashed (return code: 100)
WARNING: ThreadSanitizer: data race (pid=9742)
Write of size 8 at 0x724c0000e078 by thread T2:
[[c:red]]#0 [[c:cyan]]NKikimr::NOlap::NCounters::TIntCounter::Set(long) /-S/ydb/library/signals/signal_utils.cpp:20:18 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x11882cc4) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#1 UpdateMetrics /-S/ydb/library/yql/providers/pq/gateway/clients/composite/[[c:cyan]]yql_pq_composite_read_session.cpp:985:42 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x118816f1) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#2 [[c:cyan]]NYql::(anonymous namespace)::TCompositeTopicReadSession::RefreshPartitionsState(std::__y1::optional<TInstant>) /-S/ydb/library/yql/providers/pq/gateway/clients/composite/yql_pq_composite_read_session.cpp:896:9 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x118816f1)
[[c:red]]#3 [[c:cyan]]NYql::(anonymous namespace)::TCompositeTopicReadSession::GetReadTime() /-S/ydb/library/yql/providers/pq/gateway/clients/composite/yql_pq_composite_read_session.cpp:794:9 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x1187b7a8) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#4 non-virtual thunk to [[c:cyan]]NYql::(anonymous namespace)::TCompositeTopicReadSession::GetReadTime() /-S/ydb/library/yql/providers/pq/gateway/clients/composite/yql_pq_composite_read_session.cpp (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x1187c6fd) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#5 [[c:cyan]]NYql::(anonymous namespace)::TDqPqReadBalancerActor::SendValues() /-S/ydb/library/yql/providers/pq/gateway/clients/composite/yql_pq_composite_read_session.cpp:350:49 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x1186fc60) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#6 Bootstrap /-S/ydb/library/yql/providers/pq/gateway/clients/composite/[[c:cyan]]yql_pq_composite_read_session.cpp:252:9 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x1186d71b) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#7 NActors::TActorBootstrapped<[[c:cyan]]NYql::(anonymous namespace)::TDqPqReadBalancerActor>::StateBootstrap(TAutoPtr<NActors::IEventHandle, TDelete>&) /-S/ydb/library/actors/core/actor_bootstrapped.h:26:22 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x1186d71b)
[[c:red]]#8 [[c:cyan]]NActors::IActor::Receive(TAutoPtr<NActors::IEventHandle, TDelete>&) /-S/ydb/library/actors/core/actor.cpp:354:17 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xbbc967a) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#9 [[c:cyan]]NActors::TExecutorThread::Execute(NActors::TMailbox*, bool) /-S/ydb/library/actors/core/executor_thread.cpp:267:28 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xbc4a84f) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#10 [[c:cyan]]NActors::TExecutorThread::ProcessExecutorPool()::$_0::operator()(NActors::TMailbox*, bool) const /-S/ydb/library/actors/core/executor_thread.cpp:455:39 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xbc5053f) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#11 [[c:cyan]]NActors::TExecutorThread::ProcessExecutorPool() /-S/ydb/library/actors/core/executor_thread.cpp:507:13 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xbc4feec) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#12 [[c:cyan]]NActors::TExecutorThread::ThreadProc() /-S/ydb/library/actors/core/executor_thread.cpp:533:9 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xbc51272) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#13 void* (anonymous namespace)::ThreadProcWrapper<ISimpleThread>(void*) /-S/util/system/[[c:cyan]]thread.cpp:386:45 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xb0b6dc2) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#14 (anonymous namespace)[[c:cyan]]::TPosixThread::ThreadProxy(void*) /-S/util/system/thread.cpp:245:20 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xb0ba730) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
Previous write of size 8 at 0x724c0000e078 by main thread:
[[c:red]]#0 [[c:cyan]]NKikimr::NOlap::NCounters::TIntCounter::Set(long) /-S/ydb/library/signals/signal_utils.cpp:20:18 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x11882cc4) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#1 UpdateMetrics /-S/ydb/library/yql/providers/pq/gateway/clients/composite/[[c:cyan]]yql_pq_composite_read_session.cpp:985:42 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x1187d650) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#2 [[c:cyan]]NYql::(anonymous namespace)::TCompositeTopicReadSession::RefreshReadyPartitions() /-S/ydb/library/yql/providers/pq/gateway/clients/composite/yql_pq_composite_read_session.cpp:981:9 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x1187d650)
[[c:red]]#3 [[c:cyan]]NYql::(anonymous namespace)::TCompositeTopicReadSession::WaitEvent() /-S/ydb/library/yql/providers/pq/gateway/clients/composite/yql_pq_composite_read_session.cpp:639:9 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x11878a85) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#4 [[c:cyan]]NYql::NTestSuiteTCompositeTopicReadSessionTest::TTestCaseAdvancePartitionTimeAfterGetEvent::Execute_(NUnitTest::T
..[snippet truncated]..
with_actor_system.cpp:24:13 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x1c19e614) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#9 [[c:cyan]]NYql::(anonymous namespace)::TCompositeClientTestFixture::SetUp(NUnitTest::TTestContext&) /-S/ydb/library/yql/providers/pq/gateway/ut/composite_client_ut.cpp:92:16 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xae2218b) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#10 [[c:cyan]]operator() /-S/ydb/library/yql/providers/pq/gateway/ut/composite_client_ut.cpp:149:1 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xae2461f) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#11 __invoke<(lambda at /-S/ydb/library/yql/providers/pq/gateway/ut/composite_client_ut.cpp:149:1) &> /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/[[c:cyan]]invoke.h:179:25 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xae2461f)
[[c:red]]#12 __call<(lambda at /-S/ydb/library/yql/providers/pq/gateway/ut/composite_client_ut.cpp:149:1) &> /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/[[c:cyan]]invoke.h:251:5 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xae2461f)
[[c:red]]#13 __invoke_r<void, (lambda at /-S/ydb/library/yql/providers/pq/gateway/ut/composite_client_ut.cpp:149:1) &> /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/[[c:cyan]]invoke.h:273:10 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xae2461f)
[[c:red]]#14 [[c:cyan]]operator() /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:167:12 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xae2461f)
[[c:red]]#15 std::__y1::__function::__func<[[c:cyan]]NYql::NTestSuiteTCompositeTopicReadSessionTest::TCurrentTest::Execute()::'lambda'(), std::__y1::allocator<NYql::NTestSuiteTCompositeTopicReadSessionTest::TCurrentTest::Execute()::'lambda'()>, void ()>::operator()() /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:319:10 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xae2461f)
[[c:red]]#16 [[c:cyan]]operator() /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:436:12 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xb2fa051) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#17 [[c:cyan]]operator() /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:995:10 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xb2fa051)
[[c:red]]#18 [[c:cyan]]TColoredProcessor::Run(std::__y1::function<void ()>, TBasicString<char, std::__y1::char_traits<char>> const&, char const*, bool) /-S/library/cpp/testing/unittest/utmain.cpp:527:20 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xb2fa051)
[[c:red]]#19 [[c:cyan]]NUnitTest::TTestBase::Run(std::__y1::function<void ()>, TBasicString<char, std::__y1::char_traits<char>> const&, char const*, bool) /-S/library/cpp/testing/unittest/registar.cpp:378:18 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xb2e04e9) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#20 [[c:cyan]]NYql::NTestSuiteTCompositeTopicReadSessionTest::TCurrentTest::Execute() /-S/ydb/library/yql/providers/pq/gateway/ut/composite_client_ut.cpp:149:1 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xae23c40) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#21 [[c:cyan]]NUnitTest::TTestFactory::Execute() /-S/library/cpp/testing/unittest/registar.cpp:499:19 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xb2e1225) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#22 [[c:cyan]]NUnitTest::RunMain(int, char**) /-S/library/cpp/testing/unittest/utmain.cpp:899:44 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xb2f655c) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#23 main /-S/library/cpp/testing/unittest_main/[[c:cyan]]main.cpp:4:12 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xb2f5390) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
SUMMARY: ThreadSanitizer: data race /-S/ydb/library/signals/signal_utils.cpp:20:18 in NKikimr::NOlap::NCounters::TIntCounter::Set(long)
==================
2026-03-05T05:57:51.443949Z node 4 :KQP_COMPUTE INFO: yql_pq_composite_read_session.cpp:833: [TCompositeTopicReadSession] TxId: test_tx, TaskId: 1, Cluster: cluster, TopicPath: topic. Clear balancer actor: [4:7613646737551127302:2051]
2026-03-05T05:57:51.444201Z node 4 :KQP_COMPUTE INFO: yql_pq_composite_read_session.cpp:307: [DQ_PQ_READ_BALANCER_ACTOR] TxId: test_tx, TaskId: 1, Cluster: cluster, TopicPath: topic, SelfId: [4:7613646737551127302:2051]. Received TEvPoison
2026-03-05T05:57:51.444384Z node 4 :KQP_COMPUTE DEBUG: dq_pq_info_aggregation_actor.cpp:250: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [4:7613646737551127299:2049]. Received TEvUpdateCounter from: [4:7613646737551127302:2051], counter: group=distributed_topic_read_session;input_index=0;counter=read_time
2026-03-05T05:57:51.444447Z node 4 :KQP_COMPUTE TRACE: dq_pq_info_aggregation_actor.cpp:251: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [4:7613646737551127299:2049]. Received TEvUpdateCounter from: [4:7613646737551127302:2051], data: CounterId: "group=distributed_topic_read_session;input_index=0;counter=read_time" Settings { ReportPeriod { seconds: 1 } ScalarAggDeltaThreshold: 1000 } SeqNo: 1
2026-03-05T05:57:51.444477Z node 4 :KQP_COMPUTE INFO: dq_pq_info_aggregation_actor.cpp:308: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [4:7613646737551127299:2049]. Received removing counters for sender: [4:7613646737551127302:2051]
|
3.1s |
FAIL
|
logsdir |
stdout |
stderr
|
|
fq
|
ydb/library/yql/providers/pq/gateway/ut/TCompositeTopicReadSessionTest.AdvancePartitionTimeNoOpWhenTimeNotAdvanced
SANITIZER
Test crashed (return code: 100)
WARNING: ThreadSanitizer: data race (pid=9742)
Write of size 8 at 0x724c0001c078 by thread T32:
[[c:red]]#0 [[c:cyan]]NKikimr::NOlap::NCounters::TIntCounter::Set(long) /-S/ydb/library/signals/signal_utils.cpp:20:18 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x11882cc4) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#1 UpdateMetrics /-S/ydb/library/yql/providers/pq/gateway/clients/composite/[[c:cyan]]yql_pq_composite_read_session.cpp:985:42 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x118816f1) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#2 [[c:cyan]]NYql::(anonymous namespace)::TCompositeTopicReadSession::RefreshPartitionsState(std::__y1::optional<TInstant>) /-S/ydb/library/yql/providers/pq/gateway/clients/composite/yql_pq_composite_read_session.cpp:896:9 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x118816f1)
[[c:red]]#3 [[c:cyan]]NYql::(anonymous namespace)::TCompositeTopicReadSession::GetReadTime() /-S/ydb/library/yql/providers/pq/gateway/clients/composite/yql_pq_composite_read_session.cpp:794:9 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x1187b7a8) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#4 non-virtual thunk to [[c:cyan]]NYql::(anonymous namespace)::TCompositeTopicReadSession::GetReadTime() /-S/ydb/library/yql/providers/pq/gateway/clients/composite/yql_pq_composite_read_session.cpp (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x1187c6fd) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#5 [[c:cyan]]NYql::(anonymous namespace)::TDqPqReadBalancerActor::SendValues() /-S/ydb/library/yql/providers/pq/gateway/clients/composite/yql_pq_composite_read_session.cpp:350:49 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x1186fc60) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#6 Handle /-S/ydb/library/yql/providers/pq/gateway/clients/composite/[[c:cyan]]yql_pq_composite_read_session.cpp:327:9 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x1186ebf0) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#7 [[c:cyan]]NYql::(anonymous namespace)::TDqPqReadBalancerActor::StateFunc(TAutoPtr<NActors::IEventHandle, TDelete>&) /-S/ydb/library/yql/providers/pq/gateway/clients/composite/yql_pq_composite_read_session.cpp:255:5 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x1186ebf0)
[[c:red]]#8 [[c:cyan]]NActors::IActor::Receive(TAutoPtr<NActors::IEventHandle, TDelete>&) /-S/ydb/library/actors/core/actor.cpp:354:17 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xbbc967a) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#9 [[c:cyan]]NActors::TExecutorThread::Execute(NActors::TMailbox*, bool) /-S/ydb/library/actors/core/executor_thread.cpp:267:28 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xbc4a84f) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#10 [[c:cyan]]NActors::TExecutorThread::ProcessExecutorPool()::$_0::operator()(NActors::TMailbox*, bool) const /-S/ydb/library/actors/core/executor_thread.cpp:455:39 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xbc5053f) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#11 [[c:cyan]]NActors::TExecutorThread::ProcessExecutorPool() /-S/ydb/library/actors/core/executor_thread.cpp:507:13 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xbc4feec) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#12 [[c:cyan]]NActors::TExecutorThread::ThreadProc() /-S/ydb/library/actors/core/executor_thread.cpp:533:9 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xbc51272) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#13 void* (anonymous namespace)::ThreadProcWrapper<ISimpleThread>(void*) /-S/util/system/[[c:cyan]]thread.cpp:386:45 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xb0b6dc2) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#14 (anonymous namespace)[[c:cyan]]::TPosixThread::ThreadProxy(void*) /-S/util/system/thread.cpp:245:20 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xb0ba730) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
Previous write of size 8 at 0x724c0001c078 by main thread:
[[c:red]]#0 [[c:cyan]]NKikimr::NOlap::NCounters::TIntCounter::Set(long) /-S/ydb/library/signals/signal_utils.cpp:20:18 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x11882cc4) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#1 UpdateMetrics /-S/ydb/library/yql/providers/pq/gateway/clients/composite/[[c:cyan]]yql_pq_composite_read_session.cpp:985:42 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x1187d650) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#2 [[c:cyan]]NYql::(anonymous namespace)::TCompositeTopicReadSession::RefreshReadyPartitions() /-S/ydb/library/yql/providers/pq/gateway/clients/composite/yql_pq_composite_read_session.cpp:981:9 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x1187d650)
[[c:red]]#3 [[c:cyan]]NYql::(anonymous namespace)::TCompositeTopicReadSession::WaitEvent() /-S/ydb/library/yql/providers/pq/gateway/clients/composite/yql_pq_composite_read_session.cpp:639:9 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x11878a85) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#4 [[c:cyan]]NYql::NTestSuiteTCompositeTopicReadSessionTest::TTestCaseAdvancePartitionTimeNoOpWhenTimeNotAdvanced::Execute_
..[snippet truncated]..
imeBase::TNodeDataBase*) /-S/ydb/library/actors/testlib/test_runtime.cpp:1871:28 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x10c6a39b) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#7 [[c:cyan]]NActors::TTestActorRuntime::Initialize(NActors::TTestActorRuntime::TEgg) /-S/ydb/core/testlib/actors/test_runtime.cpp:250:13 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x10dbd35b) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#8 [[c:cyan]]NTestUtils::TTestWithActorSystemFixture::SetUp(NUnitTest::TTestContext&) /-S/ydb/library/testlib/common/test_with_actor_system.cpp:24:13 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x1c19e614) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#9 [[c:cyan]]NYql::(anonymous namespace)::TCompositeClientTestFixture::SetUp(NUnitTest::TTestContext&) /-S/ydb/library/yql/providers/pq/gateway/ut/composite_client_ut.cpp:92:16 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xae2218b) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#10 [[c:cyan]]operator() /-S/ydb/library/yql/providers/pq/gateway/ut/composite_client_ut.cpp:149:1 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xae2461f) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#11 __invoke<(lambda at /-S/ydb/library/yql/providers/pq/gateway/ut/composite_client_ut.cpp:149:1) &> /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/[[c:cyan]]invoke.h:179:25 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xae2461f)
[[c:red]]#12 __call<(lambda at /-S/ydb/library/yql/providers/pq/gateway/ut/composite_client_ut.cpp:149:1) &> /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/[[c:cyan]]invoke.h:251:5 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xae2461f)
[[c:red]]#13 __invoke_r<void, (lambda at /-S/ydb/library/yql/providers/pq/gateway/ut/composite_client_ut.cpp:149:1) &> /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/[[c:cyan]]invoke.h:273:10 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xae2461f)
[[c:red]]#14 [[c:cyan]]operator() /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:167:12 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xae2461f)
[[c:red]]#15 std::__y1::__function::__func<[[c:cyan]]NYql::NTestSuiteTCompositeTopicReadSessionTest::TCurrentTest::Execute()::'lambda'(), std::__y1::allocator<NYql::NTestSuiteTCompositeTopicReadSessionTest::TCurrentTest::Execute()::'lambda'()>, void ()>::operator()() /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:319:10 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xae2461f)
[[c:red]]#16 [[c:cyan]]operator() /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:436:12 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xb2fa051) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#17 [[c:cyan]]operator() /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:995:10 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xb2fa051)
[[c:red]]#18 [[c:cyan]]TColoredProcessor::Run(std::__y1::function<void ()>, TBasicString<char, std::__y1::char_traits<char>> const&, char const*, bool) /-S/library/cpp/testing/unittest/utmain.cpp:527:20 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xb2fa051)
[[c:red]]#19 [[c:cyan]]NUnitTest::TTestBase::Run(std::__y1::function<void ()>, TBasicString<char, std::__y1::char_traits<char>> const&, char const*, bool) /-S/library/cpp/testing/unittest/registar.cpp:378:18 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xb2e04e9) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#20 [[c:cyan]]NYql::NTestSuiteTCompositeTopicReadSessionTest::TCurrentTest::Execute() /-S/ydb/library/yql/providers/pq/gateway/ut/composite_client_ut.cpp:149:1 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xae23c40) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#21 [[c:cyan]]NUnitTest::TTestFactory::Execute() /-S/library/cpp/testing/unittest/registar.cpp:499:19 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xb2e1225) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#22 [[c:cyan]]NUnitTest::RunMain(int, char**) /-S/library/cpp/testing/unittest/utmain.cpp:899:44 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xb2f655c) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#23 main /-S/library/cpp/testing/unittest_main/[[c:cyan]]main.cpp:4:12 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xb2f5390) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
SUMMARY: ThreadSanitizer: data race /-S/ydb/library/signals/signal_utils.cpp:20:18 in NKikimr::NOlap::NCounters::TIntCounter::Set(long)
==================
2026-03-05T05:57:54.320966Z node 8 :KQP_COMPUTE INFO: yql_pq_composite_read_session.cpp:833: [TCompositeTopicReadSession] TxId: test_tx, TaskId: 1, Cluster: cluster, TopicPath: topic. Clear balancer actor: [8:7613646756874924770:2051]
2026-03-05T05:57:54.321206Z node 8 :KQP_COMPUTE INFO: yql_pq_composite_read_session.cpp:307: [DQ_PQ_READ_BALANCER_ACTOR] TxId: test_tx, TaskId: 1, Cluster: cluster, TopicPath: topic, SelfId: [8:7613646756874924770:2051]. Received TEvPoison
2026-03-05T05:57:54.321363Z node 8 :KQP_COMPUTE DEBUG: dq_pq_info_aggregation_actor.cpp:250: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [8:7613646756874924767:2049]. Received TEvUpdateCounter from: [8:7613646756874924770:2051], counter: group=distributed_topic_read_session;input_index=0;counter=read_time
|
1.2s |
FAIL
|
logsdir |
stdout |
stderr
|
|
fq
|
ydb/library/yql/providers/pq/gateway/ut/TCompositeTopicReadSessionTest.GetEventsReturnsBatch
SANITIZER
Test crashed (return code: 100)
WARNING: ThreadSanitizer: data race (pid=9742)
Read of size 1 at 0x724c0000e188 by thread T17:
[[c:red]]#0 has_value /-S/contrib/libs/cxxsupp/libcxx/include/[[c:cyan]]optional:360:82 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x1188304b) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#1 operator bool /-S/contrib/libs/cxxsupp/libcxx/include/[[c:cyan]]optional:823:84 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x1188304b)
[[c:red]]#2 [[c:cyan]]NKikimr::NOlap::NCounters::TSignalWrapper::GetFuture() /-S/ydb/library/signals/signal_utils.cpp:29:10 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x1188304b)
[[c:red]]#3 SubscribeOnUpdate /-S/ydb/library/yql/providers/pq/gateway/clients/composite/[[c:cyan]]yql_pq_composite_read_session.cpp:801:41 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x1187c747) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#4 non-virtual thunk to [[c:cyan]]NYql::(anonymous namespace)::TCompositeTopicReadSession::SubscribeOnUpdate() /-S/ydb/library/yql/providers/pq/gateway/clients/composite/yql_pq_composite_read_session.cpp (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x1187c747)
[[c:red]]#5 [[c:cyan]]NYql::(anonymous namespace)::TDqPqReadBalancerActor::ScheduleWakeup() /-S/ydb/library/yql/providers/pq/gateway/clients/composite/yql_pq_composite_read_session.cpp:338:31 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x1186f521) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#6 Handle /-S/ydb/library/yql/providers/pq/gateway/clients/composite/[[c:cyan]]yql_pq_composite_read_session.cpp:326:9 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x1186ebe7) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#7 [[c:cyan]]NYql::(anonymous namespace)::TDqPqReadBalancerActor::StateFunc(TAutoPtr<NActors::IEventHandle, TDelete>&) /-S/ydb/library/yql/providers/pq/gateway/clients/composite/yql_pq_composite_read_session.cpp:255:5 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x1186ebe7)
[[c:red]]#8 [[c:cyan]]NActors::IActor::Receive(TAutoPtr<NActors::IEventHandle, TDelete>&) /-S/ydb/library/actors/core/actor.cpp:354:17 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xbbc967a) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#9 [[c:cyan]]NActors::TExecutorThread::Execute(NActors::TMailbox*, bool) /-S/ydb/library/actors/core/executor_thread.cpp:267:28 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xbc4a84f) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#10 [[c:cyan]]NActors::TExecutorThread::ProcessExecutorPool()::$_0::operator()(NActors::TMailbox*, bool) const /-S/ydb/library/actors/core/executor_thread.cpp:455:39 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xbc5053f) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#11 [[c:cyan]]NActors::TExecutorThread::ProcessExecutorPool() /-S/ydb/library/actors/core/executor_thread.cpp:507:13 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xbc4feec) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#12 [[c:cyan]]NActors::TExecutorThread::ThreadProc() /-S/ydb/library/actors/core/executor_thread.cpp:533:9 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xbc51272) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#13 void* (anonymous namespace)::ThreadProcWrapper<ISimpleThread>(void*) /-S/util/system/[[c:cyan]]thread.cpp:386:45 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xb0b6dc2) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#14 (anonymous namespace)[[c:cyan]]::TPosixThread::ThreadProxy(void*) /-S/util/system/thread.cpp:245:20 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xb0ba730) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
Previous write of size 1 at 0x724c0000e188 by main thread:
[[c:red]]#0 std::__y1::__optional_destruct_base<NThreading::TPromise<void>, false>::reset[abi:fe210000]() /-S/contrib/libs/cxxsupp/libcxx/include/[[c:cyan]]optional:319:18 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x11883bf4) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#1 [[c:cyan]]NKikimr::NOlap::NCounters::TSignalWrapper::Signal() /-S/ydb/library/signals/signal_utils.cpp:43:17 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x11883a19) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#2 [[c:cyan]]NYql::(anonymous namespace)::TCompositeTopicReadSession::RefreshPartitionsState(std::__y1::optional<TInstant>) /-S/ydb/library/yql/providers/pq/gateway/clients/composite/yql_pq_composite_read_session.cpp:893:38 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x118816d5) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#3 [[c:cyan]]NYql::(anonymous namespace)::TCompositeTopicReadSession::AdvancePartitionTime(unsigned long, TInstant) /-S/ydb/library/yql/providers/pq/gateway/clients/composite/yql_pq_composite_read_session.cpp:784:9 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x1187ad96) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#4 [[c:cyan]]NYql::(anonymous namespace)::TCompositeTopicReadSession::ReadEventFromReadyPartitions(NYdb::Dev::NTopic::TReadSessionGetEventSettings const&) /-S/ydb/library/yql/providers/pq/gateway/clients/composite/yql_pq_composite_read_session.cpp:948:13 (ydb-library-yql-providers-pq-gateway-u
..[snippet truncated]..
[[c:cyan]]nvoke.h:273:10 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xae2461f)
[[c:red]]#14 [[c:cyan]]operator() /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:167:12 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xae2461f)
[[c:red]]#15 std::__y1::__function::__func<[[c:cyan]]NYql::NTestSuiteTCompositeTopicReadSessionTest::TCurrentTest::Execute()::'lambda'(), std::__y1::allocator<NYql::NTestSuiteTCompositeTopicReadSessionTest::TCurrentTest::Execute()::'lambda'()>, void ()>::operator()() /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:319:10 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xae2461f)
[[c:red]]#16 [[c:cyan]]operator() /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:436:12 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xb2fa051) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#17 [[c:cyan]]operator() /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:995:10 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xb2fa051)
[[c:red]]#18 [[c:cyan]]TColoredProcessor::Run(std::__y1::function<void ()>, TBasicString<char, std::__y1::char_traits<char>> const&, char const*, bool) /-S/library/cpp/testing/unittest/utmain.cpp:527:20 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xb2fa051)
[[c:red]]#19 [[c:cyan]]NUnitTest::TTestBase::Run(std::__y1::function<void ()>, TBasicString<char, std::__y1::char_traits<char>> const&, char const*, bool) /-S/library/cpp/testing/unittest/registar.cpp:378:18 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xb2e04e9) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#20 [[c:cyan]]NYql::NTestSuiteTCompositeTopicReadSessionTest::TCurrentTest::Execute() /-S/ydb/library/yql/providers/pq/gateway/ut/composite_client_ut.cpp:149:1 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xae23c40) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#21 [[c:cyan]]NUnitTest::TTestFactory::Execute() /-S/library/cpp/testing/unittest/registar.cpp:499:19 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xb2e1225) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#22 [[c:cyan]]NUnitTest::RunMain(int, char**) /-S/library/cpp/testing/unittest/utmain.cpp:899:44 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xb2f655c) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#23 main /-S/library/cpp/testing/unittest_main/[[c:cyan]]main.cpp:4:12 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xb2f5390) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
SUMMARY: ThreadSanitizer: data race /-S/ydb/library/signals/signal_utils.cpp:20:18 in NKikimr::NOlap::NCounters::TIntCounter::Set(long)
==================
2026-03-05T05:57:53.150297Z node 5 :KQP_COMPUTE INFO: yql_pq_composite_read_session.cpp:833: [TCompositeTopicReadSession] TxId: test_tx, TaskId: 1, Cluster: cluster, TopicPath: topic. Clear balancer actor: [5:7613646752022956769:2051]
2026-03-05T05:57:53.150408Z node 5 :KQP_COMPUTE INFO: yql_pq_composite_read_session.cpp:307: [DQ_PQ_READ_BALANCER_ACTOR] TxId: test_tx, TaskId: 1, Cluster: cluster, TopicPath: topic, SelfId: [5:7613646752022956769:2051]. Received TEvPoison
2026-03-05T05:57:53.150551Z node 5 :KQP_COMPUTE DEBUG: dq_pq_info_aggregation_actor.cpp:250: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [5:7613646752022956766:2049]. Received TEvUpdateCounter from: [5:7613646752022956769:2051], counter: group=distributed_topic_read_session;input_index=0;counter=read_time
2026-03-05T05:57:53.150643Z node 5 :KQP_COMPUTE TRACE: dq_pq_info_aggregation_actor.cpp:251: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [5:7613646752022956766:2049]. Received TEvUpdateCounter from: [5:7613646752022956769:2051], data: CounterId: "group=distributed_topic_read_session;input_index=0;counter=read_time" Settings { ReportPeriod { seconds: 1 } ScalarAggDeltaThreshold: 1000 } SeqNo: 2
2026-03-05T05:57:53.150678Z node 5 :KQP_COMPUTE INFO: dq_pq_info_aggregation_actor.cpp:308: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [5:7613646752022956766:2049]. Received removing counters for sender: [5:7613646752022956769:2051]
2026-03-05T05:57:53.150710Z node 5 :KQP_COMPUTE DEBUG: dq_pq_info_aggregation_actor.cpp:143: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [5:7613646752022956766:2049]. [TSumAggregator] CounterId: group=distributed_topic_read_session;input_index=0;counter=partition_counter. Agg value: 0, LastSentValue: 1
2026-03-05T05:57:53.150737Z node 5 :KQP_COMPUTE DEBUG: dq_pq_info_aggregation_actor.cpp:115: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [5:7613646752022956766:2049]. [TSumAggregator] CounterId: group=distributed_topic_read_session;input_index=0;counter=partition_counter. Send value: 0, seq no: 2
2026-03-05T05:57:53.150751Z node 5 :KQP_COMPUTE INFO: dq_pq_info_aggregation_actor.cpp:320: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [5:7613646752022956766:2049]. Aggregate value removed: group=distributed_topic_read_session;input_index=0;counter=partition_counter
2026-03-05T05:57:53.150771Z node 5 :KQP_COMPUTE INFO: dq_pq_info_aggregation_actor.cpp:320: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [5:7613646752022956766:2049]. Aggregate value removed: group=distributed_topic_read_session;input_index=0;counter=read_time
2026-03-05T05:57:53.150804Z node 5 :KQP_COMPUTE DEBUG: dq_pq_info_aggregation_actor.cpp:250: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [5:7613646752022956766:2049]. Received TEvUpdateCounter from: [5:7613646752022956769:2051], counter: group=distributed_topic_read_session;input_index=0;counter=partition_counter
|
1.8s |
FAIL
|
logsdir |
stdout |
stderr
|
|
fq
|
ydb/library/yql/providers/pq/gateway/ut/TCompositeTopicReadSessionTest.IdleTimeoutPartitionStillReceivesData
SANITIZER
Test crashed (return code: 100)
WARNING: ThreadSanitizer: data race (pid=9742)
Read of size 8 at 0x724c0002a2c0 by main thread:
[[c:red]]#0 GetMinimalLocalReadTime /-S/ydb/library/yql/providers/pq/gateway/clients/composite/[[c:cyan]]yql_pq_composite_read_session.cpp:917:9 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x1187d524) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#1 [[c:cyan]]NYql::(anonymous namespace)::TCompositeTopicReadSession::RefreshReadyPartitions() /-S/ydb/library/yql/providers/pq/gateway/clients/composite/yql_pq_composite_read_session.cpp:961:64 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x1187d524)
[[c:red]]#2 [[c:cyan]]NYql::(anonymous namespace)::TCompositeTopicReadSession::WaitEvent() /-S/ydb/library/yql/providers/pq/gateway/clients/composite/yql_pq_composite_read_session.cpp:639:9 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x11878a85) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#3 [[c:cyan]]NYql::NTestSuiteTCompositeTopicReadSessionTest::TTestCaseIdleTimeoutPartitionStillReceivesData::Execute_(NUnitTest::TTestContext&) /-S/ydb/library/yql/providers/pq/gateway/ut/composite_client_ut.cpp:405:18 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xae076a9) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#4 [[c:cyan]]operator() /-S/ydb/library/yql/providers/pq/gateway/ut/composite_client_ut.cpp:149:1 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xae24654) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#5 __invoke<(lambda at /-S/ydb/library/yql/providers/pq/gateway/ut/composite_client_ut.cpp:149:1) &> /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/[[c:cyan]]invoke.h:179:25 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xae24654)
[[c:red]]#6 __call<(lambda at /-S/ydb/library/yql/providers/pq/gateway/ut/composite_client_ut.cpp:149:1) &> /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/[[c:cyan]]invoke.h:251:5 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xae24654)
[[c:red]]#7 __invoke_r<void, (lambda at /-S/ydb/library/yql/providers/pq/gateway/ut/composite_client_ut.cpp:149:1) &> /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/[[c:cyan]]invoke.h:273:10 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xae24654)
[[c:red]]#8 [[c:cyan]]operator() /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:167:12 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xae24654)
[[c:red]]#9 std::__y1::__function::__func<[[c:cyan]]NYql::NTestSuiteTCompositeTopicReadSessionTest::TCurrentTest::Execute()::'lambda'(), std::__y1::allocator<NYql::NTestSuiteTCompositeTopicReadSessionTest::TCurrentTest::Execute()::'lambda'()>, void ()>::operator()() /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:319:10 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xae24654)
[[c:red]]#10 [[c:cyan]]operator() /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:436:12 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xb2fa051) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#11 [[c:cyan]]operator() /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:995:10 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xb2fa051)
[[c:red]]#12 [[c:cyan]]TColoredProcessor::Run(std::__y1::function<void ()>, TBasicString<char, std::__y1::char_traits<char>> const&, char const*, bool) /-S/library/cpp/testing/unittest/utmain.cpp:527:20 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xb2fa051)
[[c:red]]#13 [[c:cyan]]NUnitTest::TTestBase::Run(std::__y1::function<void ()>, TBasicString<char, std::__y1::char_traits<char>> const&, char const*, bool) /-S/library/cpp/testing/unittest/registar.cpp:378:18 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xb2e04e9) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#14 [[c:cyan]]NYql::NTestSuiteTCompositeTopicReadSessionTest::TCurrentTest::Execute() /-S/ydb/library/yql/providers/pq/gateway/ut/composite_client_ut.cpp:149:1 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xae23c40) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#15 [[c:cyan]]NUnitTest::TTestFactory::Execute() /-S/library/cpp/testing/unittest/registar.cpp:499:19 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xb2e1225) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#16 [[c:cyan]]NUnitTest::RunMain(int, char**) /-S/library/cpp/testing/unittest/utmain.cpp:899:44 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xb2f655c) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#17 main /-S/library/cpp/testing/unittest_main/[[c:cyan]]main.cpp:4:12 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xb2f5390) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
Previous write of size 8 at 0x724c0002a2c0 by thread T62:
[[c:red]]#0 __remove_node_pointer /-S/contrib/libs/cxxsupp/libcxx/include/[[c:cyan]]__tree:1921:3 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x1188121d) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#1 erase /-S/contrib/libs/cxxsupp/libcxx/include/[[c:cyan]]__tree:2048:28 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x1188121d)
[[c:red]]#2 erase /-S/contrib/libs/cxxsupp/libcxx/include/[[c:cyan]]set:778:77 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x1188121d
..[snippet truncated]..
composite_client_ut.cpp:92:16 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xae2218b) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#10 [[c:cyan]]operator() /-S/ydb/library/yql/providers/pq/gateway/ut/composite_client_ut.cpp:149:1 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xae2461f) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#11 __invoke<(lambda at /-S/ydb/library/yql/providers/pq/gateway/ut/composite_client_ut.cpp:149:1) &> /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/[[c:cyan]]invoke.h:179:25 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xae2461f)
[[c:red]]#12 __call<(lambda at /-S/ydb/library/yql/providers/pq/gateway/ut/composite_client_ut.cpp:149:1) &> /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/[[c:cyan]]invoke.h:251:5 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xae2461f)
[[c:red]]#13 __invoke_r<void, (lambda at /-S/ydb/library/yql/providers/pq/gateway/ut/composite_client_ut.cpp:149:1) &> /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/[[c:cyan]]invoke.h:273:10 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xae2461f)
[[c:red]]#14 [[c:cyan]]operator() /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:167:12 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xae2461f)
[[c:red]]#15 std::__y1::__function::__func<[[c:cyan]]NYql::NTestSuiteTCompositeTopicReadSessionTest::TCurrentTest::Execute()::'lambda'(), std::__y1::allocator<NYql::NTestSuiteTCompositeTopicReadSessionTest::TCurrentTest::Execute()::'lambda'()>, void ()>::operator()() /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:319:10 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xae2461f)
[[c:red]]#16 [[c:cyan]]operator() /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:436:12 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xb2fa051) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#17 [[c:cyan]]operator() /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:995:10 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xb2fa051)
[[c:red]]#18 [[c:cyan]]TColoredProcessor::Run(std::__y1::function<void ()>, TBasicString<char, std::__y1::char_traits<char>> const&, char const*, bool) /-S/library/cpp/testing/unittest/utmain.cpp:527:20 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xb2fa051)
[[c:red]]#19 [[c:cyan]]NUnitTest::TTestBase::Run(std::__y1::function<void ()>, TBasicString<char, std::__y1::char_traits<char>> const&, char const*, bool) /-S/library/cpp/testing/unittest/registar.cpp:378:18 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xb2e04e9) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#20 [[c:cyan]]NYql::NTestSuiteTCompositeTopicReadSessionTest::TCurrentTest::Execute() /-S/ydb/library/yql/providers/pq/gateway/ut/composite_client_ut.cpp:149:1 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xae23c40) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#21 [[c:cyan]]NUnitTest::TTestFactory::Execute() /-S/library/cpp/testing/unittest/registar.cpp:499:19 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xb2e1225) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#22 [[c:cyan]]NUnitTest::RunMain(int, char**) /-S/library/cpp/testing/unittest/utmain.cpp:899:44 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xb2f655c) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#23 main /-S/library/cpp/testing/unittest_main/[[c:cyan]]main.cpp:4:12 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xb2f5390) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
SUMMARY: ThreadSanitizer: data race /-S/ydb/library/signals/signal_utils.cpp:20:18 in NKikimr::NOlap::NCounters::TIntCounter::Set(long)
==================
2026-03-05T05:57:56.885236Z node 11 :KQP_COMPUTE INFO: yql_pq_composite_read_session.cpp:833: [TCompositeTopicReadSession] TxId: test_tx, TaskId: 1, Cluster: cluster, TopicPath: topic. Clear balancer actor: [11:7613646761930195745:2051]
2026-03-05T05:57:56.885514Z node 11 :KQP_COMPUTE INFO: yql_pq_composite_read_session.cpp:307: [DQ_PQ_READ_BALANCER_ACTOR] TxId: test_tx, TaskId: 1, Cluster: cluster, TopicPath: topic, SelfId: [11:7613646761930195745:2051]. Received TEvPoison
2026-03-05T05:57:56.885721Z node 11 :KQP_COMPUTE DEBUG: dq_pq_info_aggregation_actor.cpp:250: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [11:7613646761930195742:2049]. Received TEvUpdateCounter from: [11:7613646761930195745:2051], counter: group=distributed_topic_read_session;input_index=0;counter=read_time
2026-03-05T05:57:56.885809Z node 11 :KQP_COMPUTE TRACE: dq_pq_info_aggregation_actor.cpp:251: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [11:7613646761930195742:2049]. Received TEvUpdateCounter from: [11:7613646761930195745:2051], data: CounterId: "group=distributed_topic_read_session;input_index=0;counter=read_time" Settings { ReportPeriod { seconds: 1 } ScalarAggDeltaThreshold: 1000 } SeqNo: 2
2026-03-05T05:57:56.885832Z node 11 :KQP_COMPUTE INFO: dq_pq_info_aggregation_actor.cpp:308: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [11:7613646761930195742:2049]. Received removing counters for sender: [11:7613646761930195745:2051]
2026-03-05T05:57:56.885866Z node 11 :KQP_COMPUTE DEBUG: dq_pq_info_aggregation_actor.cpp:143: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [11:7613646761930195742:2049]. [TSumAggregator] CounterId: group=distributed_topic_read_session;input_index=0;counter=partition_counter. Agg value: 0, LastSentValue: 2
|
1.4s |
FAIL
|
logsdir |
stdout |
stderr
|
|
fq
|
ydb/library/yql/providers/pq/gateway/ut/TCompositeTopicReadSessionTest.PartitionBalancingInsideOneSession
SANITIZER
Test crashed (return code: 100)
WARNING: ThreadSanitizer: data race (pid=9742)
Read of size 1 at 0x724c0001c888 by main thread:
[[c:red]]#0 has_value /-S/contrib/libs/cxxsupp/libcxx/include/[[c:cyan]]optional:360:82 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x1188304b) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#1 operator bool /-S/contrib/libs/cxxsupp/libcxx/include/[[c:cyan]]optional:823:84 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x1188304b)
[[c:red]]#2 [[c:cyan]]NKikimr::NOlap::NCounters::TSignalWrapper::GetFuture() /-S/ydb/library/signals/signal_utils.cpp:29:10 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x1188304b)
[[c:red]]#3 [[c:cyan]]NYql::(anonymous namespace)::TCompositeTopicReadSession::GetInternalState() /-S/ydb/library/yql/providers/pq/gateway/clients/composite/yql_pq_composite_read_session.cpp:822:79 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x1187c1a5) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#4 non-virtual thunk to [[c:cyan]]NYql::(anonymous namespace)::TCompositeTopicReadSession::GetInternalState() /-S/ydb/library/yql/providers/pq/gateway/clients/composite/yql_pq_composite_read_session.cpp (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x1187c674) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#5 [[c:cyan]]NYql::NTestSuiteTCompositeTopicReadSessionTest::TTestCasePartitionBalancingInsideOneSession::Execute_(NUnitTest::TTestContext&) /-S/ydb/library/yql/providers/pq/gateway/ut/composite_client_ut.cpp:458:34 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xae0da21) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#6 [[c:cyan]]operator() /-S/ydb/library/yql/providers/pq/gateway/ut/composite_client_ut.cpp:149:1 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xae24654) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#7 __invoke<(lambda at /-S/ydb/library/yql/providers/pq/gateway/ut/composite_client_ut.cpp:149:1) &> /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/[[c:cyan]]invoke.h:179:25 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xae24654)
[[c:red]]#8 __call<(lambda at /-S/ydb/library/yql/providers/pq/gateway/ut/composite_client_ut.cpp:149:1) &> /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/[[c:cyan]]invoke.h:251:5 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xae24654)
[[c:red]]#9 __invoke_r<void, (lambda at /-S/ydb/library/yql/providers/pq/gateway/ut/composite_client_ut.cpp:149:1) &> /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/[[c:cyan]]invoke.h:273:10 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xae24654)
[[c:red]]#10 [[c:cyan]]operator() /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:167:12 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xae24654)
[[c:red]]#11 std::__y1::__function::__func<[[c:cyan]]NYql::NTestSuiteTCompositeTopicReadSessionTest::TCurrentTest::Execute()::'lambda'(), std::__y1::allocator<NYql::NTestSuiteTCompositeTopicReadSessionTest::TCurrentTest::Execute()::'lambda'()>, void ()>::operator()() /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:319:10 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xae24654)
[[c:red]]#12 [[c:cyan]]operator() /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:436:12 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xb2fa051) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#13 [[c:cyan]]operator() /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:995:10 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xb2fa051)
[[c:red]]#14 [[c:cyan]]TColoredProcessor::Run(std::__y1::function<void ()>, TBasicString<char, std::__y1::char_traits<char>> const&, char const*, bool) /-S/library/cpp/testing/unittest/utmain.cpp:527:20 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xb2fa051)
[[c:red]]#15 [[c:cyan]]NUnitTest::TTestBase::Run(std::__y1::function<void ()>, TBasicString<char, std::__y1::char_traits<char>> const&, char const*, bool) /-S/library/cpp/testing/unittest/registar.cpp:378:18 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xb2e04e9) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#16 [[c:cyan]]NYql::NTestSuiteTCompositeTopicReadSessionTest::TCurrentTest::Execute() /-S/ydb/library/yql/providers/pq/gateway/ut/composite_client_ut.cpp:149:1 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xae23c40) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#17 [[c:cyan]]NUnitTest::TTestFactory::Execute() /-S/library/cpp/testing/unittest/registar.cpp:499:19 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xb2e1225) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#18 [[c:cyan]]NUnitTest::RunMain(int, char**) /-S/library/cpp/testing/unittest/utmain.cpp:899:44 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xb2f655c) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#19 main /-S/library/cpp/testing/unittest_main/[[c:cyan]]main.cpp:4:12 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xb2f5390) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
Previous write of size 1 at 0x724c0001c888 by thread T77:
[[c:red]]#0 __construct<NThreading::TPromise<void> > /-S/contrib/libs/cxxsupp/libcxx/include/[[c:cyan]]optional:371:22 (ydb-library-yql-providers-pq-gatewa
..[snippet truncated]..
(ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xae2461f)
[[c:red]]#14 [[c:cyan]]operator() /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:167:12 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xae2461f)
[[c:red]]#15 std::__y1::__function::__func<[[c:cyan]]NYql::NTestSuiteTCompositeTopicReadSessionTest::TCurrentTest::Execute()::'lambda'(), std::__y1::allocator<NYql::NTestSuiteTCompositeTopicReadSessionTest::TCurrentTest::Execute()::'lambda'()>, void ()>::operator()() /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:319:10 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xae2461f)
[[c:red]]#16 [[c:cyan]]operator() /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:436:12 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xb2fa051) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#17 [[c:cyan]]operator() /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:995:10 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xb2fa051)
[[c:red]]#18 [[c:cyan]]TColoredProcessor::Run(std::__y1::function<void ()>, TBasicString<char, std::__y1::char_traits<char>> const&, char const*, bool) /-S/library/cpp/testing/unittest/utmain.cpp:527:20 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xb2fa051)
[[c:red]]#19 [[c:cyan]]NUnitTest::TTestBase::Run(std::__y1::function<void ()>, TBasicString<char, std::__y1::char_traits<char>> const&, char const*, bool) /-S/library/cpp/testing/unittest/registar.cpp:378:18 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xb2e04e9) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#20 [[c:cyan]]NYql::NTestSuiteTCompositeTopicReadSessionTest::TCurrentTest::Execute() /-S/ydb/library/yql/providers/pq/gateway/ut/composite_client_ut.cpp:149:1 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xae23c40) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#21 [[c:cyan]]NUnitTest::TTestFactory::Execute() /-S/library/cpp/testing/unittest/registar.cpp:499:19 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xb2e1225) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#22 [[c:cyan]]NUnitTest::RunMain(int, char**) /-S/library/cpp/testing/unittest/utmain.cpp:899:44 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xb2f655c) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#23 main /-S/library/cpp/testing/unittest_main/[[c:cyan]]main.cpp:4:12 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xb2f5390) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
SUMMARY: ThreadSanitizer: data race /-S/ydb/library/signals/signal_utils.cpp:20:18 in NKikimr::NOlap::NCounters::TIntCounter::Set(long)
==================
2026-03-05T05:57:58.161085Z node 12 :KQP_COMPUTE INFO: yql_pq_composite_read_session.cpp:833: [TCompositeTopicReadSession] TxId: test_tx, TaskId: 1, Cluster: cluster, TopicPath: topic. Clear balancer actor: [12:7613646771841460337:2051]
2026-03-05T05:57:58.161179Z node 12 :KQP_COMPUTE INFO: yql_pq_composite_read_session.cpp:307: [DQ_PQ_READ_BALANCER_ACTOR] TxId: test_tx, TaskId: 1, Cluster: cluster, TopicPath: topic, SelfId: [12:7613646771841460337:2051]. Received TEvPoison
2026-03-05T05:57:58.161383Z node 12 :KQP_COMPUTE DEBUG: dq_pq_info_aggregation_actor.cpp:250: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [12:7613646771841460334:2049]. Received TEvUpdateCounter from: [12:7613646771841460337:2051], counter: group=distributed_topic_read_session;input_index=0;counter=read_time
2026-03-05T05:57:58.161451Z node 12 :KQP_COMPUTE TRACE: dq_pq_info_aggregation_actor.cpp:251: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [12:7613646771841460334:2049]. Received TEvUpdateCounter from: [12:7613646771841460337:2051], data: CounterId: "group=distributed_topic_read_session;input_index=0;counter=read_time" Settings { ReportPeriod { seconds: 1 } ScalarAggDeltaThreshold: 1000 } SeqNo: 2
2026-03-05T05:57:58.161480Z node 12 :KQP_COMPUTE INFO: dq_pq_info_aggregation_actor.cpp:308: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [12:7613646771841460334:2049]. Received removing counters for sender: [12:7613646771841460337:2051]
2026-03-05T05:57:58.161512Z node 12 :KQP_COMPUTE DEBUG: dq_pq_info_aggregation_actor.cpp:143: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [12:7613646771841460334:2049]. [TSumAggregator] CounterId: group=distributed_topic_read_session;input_index=0;counter=partition_counter. Agg value: 0, LastSentValue: 2
2026-03-05T05:57:58.161538Z node 12 :KQP_COMPUTE DEBUG: dq_pq_info_aggregation_actor.cpp:115: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [12:7613646771841460334:2049]. [TSumAggregator] CounterId: group=distributed_topic_read_session;input_index=0;counter=partition_counter. Send value: 0, seq no: 2
2026-03-05T05:57:58.161550Z node 12 :KQP_COMPUTE INFO: dq_pq_info_aggregation_actor.cpp:320: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [12:7613646771841460334:2049]. Aggregate value removed: group=distributed_topic_read_session;input_index=0;counter=partition_counter
2026-03-05T05:57:58.161571Z node 12 :KQP_COMPUTE INFO: dq_pq_info_aggregation_actor.cpp:320: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [12:7613646771841460334:2049]. Aggregate value removed: group=distributed_topic_read_session;input_index=0;counter=read_time
2026-03-05T05:57:58.161594Z node 12 :KQP_COMPUTE DEBUG: dq_pq_info_aggregation_actor.cpp:250: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [12:7613646771841460334:2049]. Received TEvUpdateCounter from: [12:7613646771841460337:2051], counter: group=distributed_topic_read_session;input_index=0;counter=partition_counter
|
1.3s |
FAIL
|
logsdir |
stdout |
stderr
|
|
fq
|
ydb/library/yql/providers/pq/gateway/ut/TCompositeTopicReadSessionTest.StartSessionEventThenDataDelivered
SANITIZER
Test crashed (return code: 100)
WARNING: ThreadSanitizer: data race (pid=9742)
Write of size 8 at 0x724c0000e238 by thread T47:
[[c:red]]#0 [[c:cyan]]NKikimr::NOlap::NCounters::TIntCounter::Set(long) /-S/ydb/library/signals/signal_utils.cpp:20:18 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x11882cc4) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#1 UpdateMetrics /-S/ydb/library/yql/providers/pq/gateway/clients/composite/[[c:cyan]]yql_pq_composite_read_session.cpp:985:42 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x118816f1) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#2 [[c:cyan]]NYql::(anonymous namespace)::TCompositeTopicReadSession::RefreshPartitionsState(std::__y1::optional<TInstant>) /-S/ydb/library/yql/providers/pq/gateway/clients/composite/yql_pq_composite_read_session.cpp:896:9 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x118816f1)
[[c:red]]#3 [[c:cyan]]NYql::(anonymous namespace)::TCompositeTopicReadSession::GetReadTime() /-S/ydb/library/yql/providers/pq/gateway/clients/composite/yql_pq_composite_read_session.cpp:794:9 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x1187b7a8) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#4 non-virtual thunk to [[c:cyan]]NYql::(anonymous namespace)::TCompositeTopicReadSession::GetReadTime() /-S/ydb/library/yql/providers/pq/gateway/clients/composite/yql_pq_composite_read_session.cpp (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x1187c6fd) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#5 [[c:cyan]]NYql::(anonymous namespace)::TDqPqReadBalancerActor::SendValues() /-S/ydb/library/yql/providers/pq/gateway/clients/composite/yql_pq_composite_read_session.cpp:350:49 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x1186fc60) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#6 Handle /-S/ydb/library/yql/providers/pq/gateway/clients/composite/[[c:cyan]]yql_pq_composite_read_session.cpp:327:9 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x1186ebf0) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#7 [[c:cyan]]NYql::(anonymous namespace)::TDqPqReadBalancerActor::StateFunc(TAutoPtr<NActors::IEventHandle, TDelete>&) /-S/ydb/library/yql/providers/pq/gateway/clients/composite/yql_pq_composite_read_session.cpp:255:5 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x1186ebf0)
[[c:red]]#8 [[c:cyan]]NActors::IActor::Receive(TAutoPtr<NActors::IEventHandle, TDelete>&) /-S/ydb/library/actors/core/actor.cpp:354:17 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xbbc967a) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#9 [[c:cyan]]NActors::TExecutorThread::Execute(NActors::TMailbox*, bool) /-S/ydb/library/actors/core/executor_thread.cpp:267:28 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xbc4a84f) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#10 [[c:cyan]]NActors::TExecutorThread::ProcessExecutorPool()::$_0::operator()(NActors::TMailbox*, bool) const /-S/ydb/library/actors/core/executor_thread.cpp:455:39 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xbc5053f) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#11 [[c:cyan]]NActors::TExecutorThread::ProcessExecutorPool() /-S/ydb/library/actors/core/executor_thread.cpp:507:13 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xbc4feec) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#12 [[c:cyan]]NActors::TExecutorThread::ThreadProc() /-S/ydb/library/actors/core/executor_thread.cpp:533:9 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xbc51272) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#13 void* (anonymous namespace)::ThreadProcWrapper<ISimpleThread>(void*) /-S/util/system/[[c:cyan]]thread.cpp:386:45 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xb0b6dc2) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#14 (anonymous namespace)[[c:cyan]]::TPosixThread::ThreadProxy(void*) /-S/util/system/thread.cpp:245:20 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xb0ba730) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
Previous write of size 8 at 0x724c0000e238 by main thread:
[[c:red]]#0 [[c:cyan]]NKikimr::NOlap::NCounters::TIntCounter::Set(long) /-S/ydb/library/signals/signal_utils.cpp:20:18 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x11882cc4) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#1 UpdateMetrics /-S/ydb/library/yql/providers/pq/gateway/clients/composite/[[c:cyan]]yql_pq_composite_read_session.cpp:985:42 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x1187d650) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#2 [[c:cyan]]NYql::(anonymous namespace)::TCompositeTopicReadSession::RefreshReadyPartitions() /-S/ydb/library/yql/providers/pq/gateway/clients/composite/yql_pq_composite_read_session.cpp:981:9 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x1187d650)
[[c:red]]#3 [[c:cyan]]NYql::(anonymous namespace)::TCompositeTopicReadSession::WaitEvent() /-S/ydb/library/yql/providers/pq/gateway/clients/composite/yql_pq_composite_read_session.cpp:639:9 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x11878a85) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#4 [[c:cyan]]NYql::NTestSuiteTCompositeTopicReadSessionTest::TTestCaseStartSessionEventThenDataDelivered::Execute_(NUn
..[snippet truncated]..
::TNodeDataBase*) /-S/ydb/library/actors/testlib/test_runtime.cpp:1871:28 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x10c6a39b) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#7 [[c:cyan]]NActors::TTestActorRuntime::Initialize(NActors::TTestActorRuntime::TEgg) /-S/ydb/core/testlib/actors/test_runtime.cpp:250:13 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x10dbd35b) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#8 [[c:cyan]]NTestUtils::TTestWithActorSystemFixture::SetUp(NUnitTest::TTestContext&) /-S/ydb/library/testlib/common/test_with_actor_system.cpp:24:13 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x1c19e614) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#9 [[c:cyan]]NYql::(anonymous namespace)::TCompositeClientTestFixture::SetUp(NUnitTest::TTestContext&) /-S/ydb/library/yql/providers/pq/gateway/ut/composite_client_ut.cpp:92:16 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xae2218b) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#10 [[c:cyan]]operator() /-S/ydb/library/yql/providers/pq/gateway/ut/composite_client_ut.cpp:149:1 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xae2461f) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#11 __invoke<(lambda at /-S/ydb/library/yql/providers/pq/gateway/ut/composite_client_ut.cpp:149:1) &> /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/[[c:cyan]]invoke.h:179:25 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xae2461f)
[[c:red]]#12 __call<(lambda at /-S/ydb/library/yql/providers/pq/gateway/ut/composite_client_ut.cpp:149:1) &> /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/[[c:cyan]]invoke.h:251:5 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xae2461f)
[[c:red]]#13 __invoke_r<void, (lambda at /-S/ydb/library/yql/providers/pq/gateway/ut/composite_client_ut.cpp:149:1) &> /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/[[c:cyan]]invoke.h:273:10 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xae2461f)
[[c:red]]#14 [[c:cyan]]operator() /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:167:12 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xae2461f)
[[c:red]]#15 std::__y1::__function::__func<[[c:cyan]]NYql::NTestSuiteTCompositeTopicReadSessionTest::TCurrentTest::Execute()::'lambda'(), std::__y1::allocator<NYql::NTestSuiteTCompositeTopicReadSessionTest::TCurrentTest::Execute()::'lambda'()>, void ()>::operator()() /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:319:10 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xae2461f)
[[c:red]]#16 [[c:cyan]]operator() /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:436:12 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xb2fa051) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#17 [[c:cyan]]operator() /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:995:10 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xb2fa051)
[[c:red]]#18 [[c:cyan]]TColoredProcessor::Run(std::__y1::function<void ()>, TBasicString<char, std::__y1::char_traits<char>> const&, char const*, bool) /-S/library/cpp/testing/unittest/utmain.cpp:527:20 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xb2fa051)
[[c:red]]#19 [[c:cyan]]NUnitTest::TTestBase::Run(std::__y1::function<void ()>, TBasicString<char, std::__y1::char_traits<char>> const&, char const*, bool) /-S/library/cpp/testing/unittest/registar.cpp:378:18 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xb2e04e9) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#20 [[c:cyan]]NYql::NTestSuiteTCompositeTopicReadSessionTest::TCurrentTest::Execute() /-S/ydb/library/yql/providers/pq/gateway/ut/composite_client_ut.cpp:149:1 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xae23c40) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#21 [[c:cyan]]NUnitTest::TTestFactory::Execute() /-S/library/cpp/testing/unittest/registar.cpp:499:19 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xb2e1225) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#22 [[c:cyan]]NUnitTest::RunMain(int, char**) /-S/library/cpp/testing/unittest/utmain.cpp:899:44 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xb2f655c) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#23 main /-S/library/cpp/testing/unittest_main/[[c:cyan]]main.cpp:4:12 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xb2f5390) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
SUMMARY: ThreadSanitizer: data race /-S/ydb/library/signals/signal_utils.cpp:20:18 in NKikimr::NOlap::NCounters::TIntCounter::Set(long)
==================
2026-03-05T05:57:55.512728Z node 10 :KQP_COMPUTE INFO: yql_pq_composite_read_session.cpp:833: [TCompositeTopicReadSession] TxId: test_tx, TaskId: 1, Cluster: cluster, TopicPath: topic. Clear balancer actor: [10:7613646759629730196:2051]
2026-03-05T05:57:55.513002Z node 10 :KQP_COMPUTE INFO: yql_pq_composite_read_session.cpp:307: [DQ_PQ_READ_BALANCER_ACTOR] TxId: test_tx, TaskId: 1, Cluster: cluster, TopicPath: topic, SelfId: [10:7613646759629730196:2051]. Received TEvPoison
2026-03-05T05:57:55.513181Z node 10 :KQP_COMPUTE DEBUG: dq_pq_info_aggregation_actor.cpp:250: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [10:7613646759629730193:2049]. Received TEvUpdateCounter from: [10:7613646759629730196:2051], counter: group=distributed_topic_read_session;input_index=0;counter=read_time
|
1.2s |
FAIL
|
logsdir |
stdout |
stderr
|
|
fq
|
ydb/library/yql/providers/pq/gateway/ut/TCompositeTopicReadSessionTest.TwoSessionsSameAggregatorBothWork
SANITIZER
Test crashed (return code: 100)
WARNING: ThreadSanitizer: data race (pid=9742)
Write of size 8 at 0x724c0000f160 by thread T91:
[[c:red]]#0 [[c:cyan]]NYql::(anonymous namespace)::TCompositeTopicReadSession::AdvanceExternalTime(TInstant) /-S/ydb/library/yql/providers/pq/gateway/clients/composite/yql_pq_composite_read_session.cpp:789:26 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x1187b72d) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#1 non-virtual thunk to [[c:cyan]]NYql::(anonymous namespace)::TCompositeTopicReadSession::AdvanceExternalTime(TInstant) /-S/ydb/library/yql/providers/pq/gateway/clients/composite/yql_pq_composite_read_session.cpp (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x1187c6c4) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#2 Handle /-S/ydb/library/yql/providers/pq/gateway/clients/composite/[[c:cyan]]yql_pq_composite_read_session.cpp:302:31 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x1186f0a5) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#3 [[c:cyan]]NYql::(anonymous namespace)::TDqPqReadBalancerActor::StateFunc(TAutoPtr<NActors::IEventHandle, TDelete>&) /-S/ydb/library/yql/providers/pq/gateway/clients/composite/yql_pq_composite_read_session.cpp:255:5 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x1186f0a5)
[[c:red]]#4 [[c:cyan]]NActors::IActor::Receive(TAutoPtr<NActors::IEventHandle, TDelete>&) /-S/ydb/library/actors/core/actor.cpp:354:17 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xbbc967a) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#5 [[c:cyan]]NActors::TExecutorThread::Execute(NActors::TMailbox*, bool) /-S/ydb/library/actors/core/executor_thread.cpp:267:28 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xbc4a84f) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#6 [[c:cyan]]NActors::TExecutorThread::ProcessExecutorPool()::$_0::operator()(NActors::TMailbox*, bool) const /-S/ydb/library/actors/core/executor_thread.cpp:455:39 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xbc5053f) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#7 [[c:cyan]]NActors::TExecutorThread::ProcessExecutorPool() /-S/ydb/library/actors/core/executor_thread.cpp:507:13 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xbc4feec) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#8 [[c:cyan]]NActors::TExecutorThread::ThreadProc() /-S/ydb/library/actors/core/executor_thread.cpp:533:9 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xbc51272) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#9 void* (anonymous namespace)::ThreadProcWrapper<ISimpleThread>(void*) /-S/util/system/[[c:cyan]]thread.cpp:386:45 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xb0b6dc2) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#10 (anonymous namespace)[[c:cyan]]::TPosixThread::ThreadProxy(void*) /-S/util/system/thread.cpp:245:20 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xb0ba730) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
Previous read of size 8 at 0x724c0000f160 by main thread:
[[c:red]]#0 [[c:cyan]]operator()<TInstant, TInstant> /-S/contrib/libs/cxxsupp/libcxx/include/__algorithm/comp.h:41:18 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x11881099) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#1 min<TInstant, std::__y1::__less<void, void> > /-S/contrib/libs/cxxsupp/libcxx/include/__algorithm/[[c:cyan]]min.h:30:10 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x11881099)
[[c:red]]#2 min<TInstant> /-S/contrib/libs/cxxsupp/libcxx/include/__algorithm/[[c:cyan]]min.h:36:10 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x11881099)
[[c:red]]#3 [[c:cyan]]NYql::(anonymous namespace)::TCompositeTopicReadSession::RefreshPartitionsState(std::__y1::optional<TInstant>) /-S/ydb/library/yql/providers/pq/gateway/clients/composite/yql_pq_composite_read_session.cpp:859:37 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x11881099)
[[c:red]]#4 [[c:cyan]]NYql::(anonymous namespace)::TCompositeTopicReadSession::AdvancePartitionTime(unsigned long, TInstant) /-S/ydb/library/yql/providers/pq/gateway/clients/composite/yql_pq_composite_read_session.cpp:784:9 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x1187ad96) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#5 [[c:cyan]]NYql::(anonymous namespace)::TCompositeTopicReadSession::ReadEventFromReadyPartitions(NYdb::Dev::NTopic::TReadSessionGetEventSettings const&) /-S/ydb/library/yql/providers/pq/gateway/clients/composite/yql_pq_composite_read_session.cpp:948:13 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x1187f4a6) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#6 [[c:cyan]]NYql::(anonymous namespace)::TCompositeTopicReadSession::GetEvent(NYdb::Dev::NTopic::TReadSessionGetEventSettings const&) /-S/ydb/library/yql/providers/pq/gateway/clients/composite/yql_pq_composite_read_session.cpp:723:26 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x11879c9c) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#7 [[c:cyan]]NYql::NTestSuiteTCompositeTopicReadSessionTest::TTestCaseTwoSessionsSameAggregatorBothWork::Execute_(NUnitTest::TTestContext&) /-S/ydb/library/yql/providers/pq/gateway/ut/composite_client_ut.cpp:495:30 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xae124c6) (Buil
..[snippet truncated]..
[[c:cyan]]operator() /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:995:10 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xb2fa051)
[[c:red]]#18 [[c:cyan]]TColoredProcessor::Run(std::__y1::function<void ()>, TBasicString<char, std::__y1::char_traits<char>> const&, char const*, bool) /-S/library/cpp/testing/unittest/utmain.cpp:527:20 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xb2fa051)
[[c:red]]#19 [[c:cyan]]NUnitTest::TTestBase::Run(std::__y1::function<void ()>, TBasicString<char, std::__y1::char_traits<char>> const&, char const*, bool) /-S/library/cpp/testing/unittest/registar.cpp:378:18 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xb2e04e9) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#20 [[c:cyan]]NYql::NTestSuiteTCompositeTopicReadSessionTest::TCurrentTest::Execute() /-S/ydb/library/yql/providers/pq/gateway/ut/composite_client_ut.cpp:149:1 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xae23c40) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#21 [[c:cyan]]NUnitTest::TTestFactory::Execute() /-S/library/cpp/testing/unittest/registar.cpp:499:19 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xb2e1225) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#22 [[c:cyan]]NUnitTest::RunMain(int, char**) /-S/library/cpp/testing/unittest/utmain.cpp:899:44 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xb2f655c) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
[[c:red]]#23 main /-S/library/cpp/testing/unittest_main/[[c:cyan]]main.cpp:4:12 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xb2f5390) (BuildId: 2229051a3689d72b5a7af1ca34b332a5e18ca888)
SUMMARY: ThreadSanitizer: data race /-S/ydb/library/signals/signal_utils.cpp:20:18 in NKikimr::NOlap::NCounters::TIntCounter::Set(long)
==================
2026-03-05T05:57:59.438275Z node 13 :KQP_COMPUTE TRACE: yql_pq_composite_read_session.cpp:796: [TCompositeTopicReadSession] TxId: test_tx, TaskId: 1, Cluster: cluster, TopicPath: topic_b. GetReadTime result: 1970-01-01T00:00:10.000000Z
2026-03-05T05:57:59.450379Z node 13 :KQP_COMPUTE DEBUG: yql_pq_composite_read_session.cpp:355: [DQ_PQ_READ_BALANCER_ACTOR] TxId: test_tx, TaskId: 1, Cluster: cluster, TopicPath: topic_b, SelfId: [13:7613646776505254610:2053]. Send values, local ReadTime: 1970-01-01T00:00:10.000000Z, PartitionCountReported: 0, AllPartitionsStarted: 0, ExternalReadTime: 1970-01-01T00:00:00.000000Z
2026-03-05T05:57:59.450383Z node 13 :KQP_COMPUTE INFO: yql_pq_composite_read_session.cpp:833: [TCompositeTopicReadSession] TxId: test_tx, TaskId: 1, Cluster: cluster, TopicPath: topic_a. Clear balancer actor: [13:7613646776505254607:2051]
2026-03-05T05:57:59.450418Z node 13 :KQP_COMPUTE INFO: yql_pq_composite_read_session.cpp:833: [TCompositeTopicReadSession] TxId: test_tx, TaskId: 1, Cluster: cluster, TopicPath: topic_b. Clear balancer actor: [13:7613646776505254610:2053]
2026-03-05T05:57:59.450486Z node 13 :KQP_COMPUTE INFO: yql_pq_composite_read_session.cpp:307: [DQ_PQ_READ_BALANCER_ACTOR] TxId: test_tx, TaskId: 1, Cluster: cluster, TopicPath: topic_a, SelfId: [13:7613646776505254607:2051]. Received TEvPoison
2026-03-05T05:57:59.450616Z node 13 :KQP_COMPUTE TRACE: yql_pq_composite_read_session.cpp:313: [DQ_PQ_READ_BALANCER_ACTOR] TxId: test_tx, TaskId: 1, Cluster: cluster, TopicPath: topic_b, SelfId: [13:7613646776505254610:2053]. Received TEvWakeup, tag: 1
2026-03-05T05:57:59.450623Z node 13 :KQP_COMPUTE DEBUG: dq_pq_info_aggregation_actor.cpp:250: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [13:7613646776505254604:2049]. Received TEvUpdateCounter from: [13:7613646776505254610:2053], counter: group=distributed_topic_read_session;input_index=1;counter=read_time
2026-03-05T05:57:59.450634Z node 13 :KQP_COMPUTE INFO: yql_pq_composite_read_session.cpp:307: [DQ_PQ_READ_BALANCER_ACTOR] TxId: test_tx, TaskId: 1, Cluster: cluster, TopicPath: topic_b, SelfId: [13:7613646776505254610:2053]. Received TEvPoison
2026-03-05T05:57:59.450700Z node 13 :KQP_COMPUTE TRACE: dq_pq_info_aggregation_actor.cpp:251: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [13:7613646776505254604:2049]. Received TEvUpdateCounter from: [13:7613646776505254610:2053], data: CounterId: "group=distributed_topic_read_session;input_index=1;counter=read_time" Settings { ReportPeriod { seconds: 1 } ScalarAggDeltaThreshold: 1000 } AggMin: 10000 SeqNo: 1
2026-03-05T05:57:59.450776Z node 13 :KQP_COMPUTE DEBUG: dq_pq_info_aggregation_actor.cpp:67: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [13:7613646776505254604:2049]. [TMinAggregator] CounterId: group=distributed_topic_read_session;input_index=1;counter=read_time. Created new counter, SendPeriod: 1.000000s, DeltaThreshold: 1000
2026-03-05T05:57:59.450801Z node 13 :KQP_COMPUTE DEBUG: dq_pq_info_aggregation_actor.cpp:89: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [13:7613646776505254604:2049]. [TMinAggregator] CounterId: group=distributed_topic_read_session;input_index=1;counter=read_time. Update counter, sender: [13:7613646776505254610:2053], seq no: 1, new value: 10000, old value: 10000, is new: 1
2026-03-05T05:57:59.450822Z node 13 :KQP_COMPUTE DEBUG: dq_pq_info_aggregation_actor.cpp:115: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [13:7613646776505254604:2049]. [TMinAggregator] CounterId: group=distributed_topic_read_session;input_index=1;counter=read_time. Send value: 10000, seq no: 1
2026-03-05T05:57:59.450863Z node 13 :KQP_COMPUTE DEBUG: dq_pq_info_aggregation_actor.cpp:250: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [13:7613646776505254604:2049]. Received TEvUpdateCounter from: [13:7613646776505254607:2051], counter: group=distributed_topic_read_session;input_index=0;counter=read_time
|
1.3s |
FAIL
|
logsdir |
stdout |
stderr
|