|
fq
|
ydb/library/yql/providers/pq/gateway/ut/TCompositeTopicReadSessionTest.AdvancePartitionTimeAfterGetEvent
SANITIZER
Test crashed (return code: 100)
WARNING: ThreadSanitizer: data race (pid=1149482)
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]]0x11884fd4) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[c:red]]#1 UpdateMetrics /-S/ydb/library/yql/providers/pq/gateway/clients/composite/[[c:cyan]]yql_pq_composite_read_session.cpp:982:42 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x11883a76) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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:894:9 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x11883a76)
[[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]]0x1187db98) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0x1187eaed) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0x11872050) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0x1186fb0b) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0x1186fb0b)
[[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: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0xbc4a88f) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0xbc5057f) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0xbc4ff2c) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0xbc512b2) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0xb0b66b2) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0xb0ba020) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
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]]0x11884fd4) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[c:red]]#1 UpdateMetrics /-S/ydb/library/yql/providers/pq/gateway/clients/composite/[[c:cyan]]yql_pq_composite_read_session.cpp:982:42 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x1187fa40) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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:978:9 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x1187fa40)
[[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]]0x1187ae75) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[c:red]]#4 [[c:cyan]]NYql::NTestSuiteTCompositeTopicReadSessionTest::TTestCaseAdvancePartitionTimeAfterGetEvent::Execute_(NUnitTest
..[snippet truncated]..
cxx/include/__type_traits/[[c:cyan]]invoke.h:251:5 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xae2234f)
[[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]]0xae2234f)
[[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]]0xae2234f)
[[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]]0xae2234f)
[[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]]0xb2f9941) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0xb2f9941)
[[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]]0xb2f9941)
[[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]]0xb2dfdd9) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0xae21970) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0xb2e0b15) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0xb2f5e4c) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0xb2f4c80) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
SUMMARY: ThreadSanitizer: data race /-S/ydb/library/signals/signal_utils.cpp:20:18 in NKikimr::NOlap::NCounters::TIntCounter::Set(long)
==================
2026-03-05T07:32:09.871171Z 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:7613671037278180136:2051]
2026-03-05T07:32:09.871305Z 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:7613671037278180136:2051]. Received TEvPoison
2026-03-05T07:32:09.871494Z node 4 :KQP_COMPUTE DEBUG: dq_pq_info_aggregation_actor.cpp:250: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [4:7613671037278180133:2049]. Received TEvUpdateCounter from: [4:7613671037278180136:2051], counter: group=distributed_topic_read_session;input_index=0;counter=read_time
2026-03-05T07:32:09.871599Z node 4 :KQP_COMPUTE TRACE: dq_pq_info_aggregation_actor.cpp:251: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [4:7613671037278180133:2049]. Received TEvUpdateCounter from: [4:7613671037278180136:2051], data: CounterId: "group=distributed_topic_read_session;input_index=0;counter=read_time" Settings { ReportPeriod { seconds: 1 } ScalarAggDeltaThreshold: 1000 } SeqNo: 1
2026-03-05T07:32:09.871641Z node 4 :KQP_COMPUTE INFO: dq_pq_info_aggregation_actor.cpp:308: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [4:7613671037278180133:2049]. Received removing counters for sender: [4:7613671037278180136:2051]
2026-03-05T07:32:09.871688Z node 4 :KQP_COMPUTE DEBUG: dq_pq_info_aggregation_actor.cpp:143: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [4:7613671037278180133:2049]. [TSumAggregator] CounterId: group=distributed_topic_read_session;input_index=0;counter=partition_counter. Agg value: 0, LastSentValue: 1
2026-03-05T07:32:09.871747Z node 4 :KQP_COMPUTE DEBUG: dq_pq_info_aggregation_actor.cpp:115: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [4:7613671037278180133:2049]. [TSumAggregator] CounterId: group=distributed_topic_read_session;input_index=0;counter=partition_counter. Send value: 0, seq no: 2
2026-03-05T07:32:09.871784Z node 4 :KQP_COMPUTE INFO: dq_pq_info_aggregation_actor.cpp:320: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [4:7613671037278180133:2049]. Aggregate value removed: group=distributed_topic_read_session;input_index=0;counter=partition_counter
2026-03-05T07:32:09.871811Z node 4 :KQP_COMPUTE INFO: dq_pq_info_aggregation_actor.cpp:320: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [4:7613671037278180133:2049]. Aggregate value removed: group=distributed_topic_read_session;input_index=0;counter=read_time
|
3.4s |
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=1149482)
Write of size 8 at 0x724c0001c238 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]]0x11884fd4) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[c:red]]#1 UpdateMetrics /-S/ydb/library/yql/providers/pq/gateway/clients/composite/[[c:cyan]]yql_pq_composite_read_session.cpp:982:42 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x11883a76) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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:894:9 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x11883a76)
[[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]]0x1187db98) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0x1187eaed) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0x11872050) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0x11870fe0) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0x11870fe0)
[[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: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0xbc4a88f) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0xbc5057f) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0xbc4ff2c) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0xbc512b2) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0xb0b66b2) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0xb0ba020) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
Previous write of size 8 at 0x724c0001c238 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]]0x11884fd4) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[c:red]]#1 UpdateMetrics /-S/ydb/library/yql/providers/pq/gateway/clients/composite/[[c:cyan]]yql_pq_composite_read_session.cpp:982:42 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x1187fa40) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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:978:9 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x1187fa40)
[[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]]0x1187ae75) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[c:red]]#4 [[c:cyan]]NYql::NTestSuiteTCompositeTopicReadSessionTest::TTestCaseAdvancePartitionTimeNoOpWhenTimeNotAdvanced::Execute
..[snippet truncated]..
t+[[c:light-grey]]0xb2f9941) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0xb2f9941)
[[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]]0xb2f9941)
[[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]]0xb2dfdd9) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0xae21970) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0xb2e0b15) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0xb2f5e4c) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0xb2f4c80) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
SUMMARY: ThreadSanitizer: data race /-S/ydb/library/signals/signal_utils.cpp:20:18 in NKikimr::NOlap::NCounters::TIntCounter::Set(long)
==================
2026-03-05T07:32:13.073929Z 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:7613671058712639014:2051]
2026-03-05T07:32:13.074000Z 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:7613671058712639014:2051]. Received TEvPoison
2026-03-05T07:32:13.074122Z node 8 :KQP_COMPUTE DEBUG: dq_pq_info_aggregation_actor.cpp:250: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [8:7613671058712639011:2049]. Received TEvUpdateCounter from: [8:7613671058712639014:2051], counter: group=distributed_topic_read_session;input_index=0;counter=read_time
2026-03-05T07:32:13.074206Z node 8 :KQP_COMPUTE TRACE: dq_pq_info_aggregation_actor.cpp:251: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [8:7613671058712639011:2049]. Received TEvUpdateCounter from: [8:7613671058712639014:2051], data: CounterId: "group=distributed_topic_read_session;input_index=0;counter=read_time" Settings { ReportPeriod { seconds: 1 } ScalarAggDeltaThreshold: 1000 } SeqNo: 2
2026-03-05T07:32:13.074243Z node 8 :KQP_COMPUTE INFO: dq_pq_info_aggregation_actor.cpp:308: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [8:7613671058712639011:2049]. Received removing counters for sender: [8:7613671058712639014:2051]
2026-03-05T07:32:13.074300Z node 8 :KQP_COMPUTE DEBUG: dq_pq_info_aggregation_actor.cpp:143: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [8:7613671058712639011:2049]. [TSumAggregator] CounterId: group=distributed_topic_read_session;input_index=0;counter=partition_counter. Agg value: 0, LastSentValue: 1
2026-03-05T07:32:13.074328Z node 8 :KQP_COMPUTE DEBUG: dq_pq_info_aggregation_actor.cpp:115: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [8:7613671058712639011:2049]. [TSumAggregator] CounterId: group=distributed_topic_read_session;input_index=0;counter=partition_counter. Send value: 0, seq no: 2
2026-03-05T07:32:13.074341Z node 8 :KQP_COMPUTE INFO: dq_pq_info_aggregation_actor.cpp:320: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [8:7613671058712639011:2049]. Aggregate value removed: group=distributed_topic_read_session;input_index=0;counter=partition_counter
2026-03-05T07:32:13.074361Z node 8 :KQP_COMPUTE INFO: dq_pq_info_aggregation_actor.cpp:320: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [8:7613671058712639011:2049]. Aggregate value removed: group=distributed_topic_read_session;input_index=0;counter=read_time
2026-03-05T07:32:13.074389Z node 8 :KQP_COMPUTE DEBUG: dq_pq_info_aggregation_actor.cpp:250: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [8:7613671058712639011:2049]. Received TEvUpdateCounter from: [8:7613671058712639014:2051], counter: group=distributed_topic_read_session;input_index=0;counter=partition_counter
2026-03-05T07:32:13.074434Z node 8 :KQP_COMPUTE TRACE: dq_pq_info_aggregation_actor.cpp:251: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [8:7613671058712639011:2049]. Received TEvUpdateCounter from: [8:7613671058712639014:2051], data: CounterId: "group=distributed_topic_read_session;input_index=0;counter=partition_counter" Settings { ReportPeriod { seconds: 1 } ScalarAggDeltaThreshold: 0 } SeqNo: 2
2026-03-05T07:32:13.074451Z node 8 :KQP_COMPUTE INFO: dq_pq_info_aggregation_actor.cpp:308: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [8:7613671058712639011:2049]. Received removing counters for sender: [8:7613671058712639014:2051]
2026-03-05T07:32:13.074464Z node 8 :KQP_COMPUTE INFO: dq_pq_info_aggregation_actor.cpp:311: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [8:7613671058712639011:2049]. Sender not found for removing: [8:7613671058712639014:2051]
|
1.3s |
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=1149482)
Write of size 8 at 0x724c0001c078 by thread T17:
[[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]]0x11884fd4) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[c:red]]#1 UpdateMetrics /-S/ydb/library/yql/providers/pq/gateway/clients/composite/[[c:cyan]]yql_pq_composite_read_session.cpp:982:42 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x11883a76) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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:894:9 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x11883a76)
[[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]]0x1187db98) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0x1187eaed) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0x11872050) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0x11870fe0) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0x11870fe0)
[[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: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0xbc4a88f) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0xbc5057f) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0xbc4ff2c) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0xbc512b2) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0xb0b66b2) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0xb0ba020) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
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]]0x11884fd4) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[c:red]]#1 UpdateMetrics /-S/ydb/library/yql/providers/pq/gateway/clients/composite/[[c:cyan]]yql_pq_composite_read_session.cpp:982:42 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x1187fa40) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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:978:9 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x1187fa40)
[[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]]0x1187ae75) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[c:red]]#4 [[c:cyan]]NYql::NTestSuiteTCompositeTopicReadSessionTest::TTestCaseGetEventsReturnsBatch::Execute_(NUnitTest::TT
..[snippet truncated]..
cxx/include/__type_traits/[[c:cyan]]invoke.h:251:5 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xae2234f)
[[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]]0xae2234f)
[[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]]0xae2234f)
[[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]]0xae2234f)
[[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]]0xb2f9941) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0xb2f9941)
[[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]]0xb2f9941)
[[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]]0xb2dfdd9) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0xae21970) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0xb2e0b15) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0xb2f5e4c) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0xb2f4c80) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
SUMMARY: ThreadSanitizer: data race /-S/ydb/library/signals/signal_utils.cpp:20:18 in NKikimr::NOlap::NCounters::TIntCounter::Set(long)
==================
2026-03-05T07:32:11.801536Z 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:7613671049788270317:2051]
2026-03-05T07:32:11.801616Z 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:7613671049788270317:2051]. Received TEvPoison
2026-03-05T07:32:11.801791Z node 5 :KQP_COMPUTE DEBUG: dq_pq_info_aggregation_actor.cpp:250: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [5:7613671049788270314:2049]. Received TEvUpdateCounter from: [5:7613671049788270317:2051], counter: group=distributed_topic_read_session;input_index=0;counter=read_time
2026-03-05T07:32:11.801863Z node 5 :KQP_COMPUTE TRACE: dq_pq_info_aggregation_actor.cpp:251: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [5:7613671049788270314:2049]. Received TEvUpdateCounter from: [5:7613671049788270317:2051], data: CounterId: "group=distributed_topic_read_session;input_index=0;counter=read_time" Settings { ReportPeriod { seconds: 1 } ScalarAggDeltaThreshold: 1000 } SeqNo: 2
2026-03-05T07:32:11.801907Z node 5 :KQP_COMPUTE INFO: dq_pq_info_aggregation_actor.cpp:308: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [5:7613671049788270314:2049]. Received removing counters for sender: [5:7613671049788270317:2051]
2026-03-05T07:32:11.801933Z node 5 :KQP_COMPUTE DEBUG: dq_pq_info_aggregation_actor.cpp:143: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [5:7613671049788270314:2049]. [TSumAggregator] CounterId: group=distributed_topic_read_session;input_index=0;counter=partition_counter. Agg value: 0, LastSentValue: 1
2026-03-05T07:32:11.801962Z node 5 :KQP_COMPUTE DEBUG: dq_pq_info_aggregation_actor.cpp:115: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [5:7613671049788270314:2049]. [TSumAggregator] CounterId: group=distributed_topic_read_session;input_index=0;counter=partition_counter. Send value: 0, seq no: 2
2026-03-05T07:32:11.801981Z node 5 :KQP_COMPUTE INFO: dq_pq_info_aggregation_actor.cpp:320: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [5:7613671049788270314:2049]. Aggregate value removed: group=distributed_topic_read_session;input_index=0;counter=partition_counter
2026-03-05T07:32:11.801999Z node 5 :KQP_COMPUTE INFO: dq_pq_info_aggregation_actor.cpp:320: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [5:7613671049788270314:2049]. Aggregate value removed: group=distributed_topic_read_session;input_index=0;counter=read_time
|
2.0s |
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=1149482)
Read of size 1 at 0x724c0002ac08 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]]0x1188535b) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0x1188535b)
[[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]]0x1188535b)
[[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]]0x1187e595) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0x1187ea64) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[c:red]]#5 [[c:cyan]]NYql::NTestSuiteTCompositeTopicReadSessionTest::TTestCaseIdleTimeoutPartitionStillReceivesData::Execute_(NUnitTest::TTestContext&) /-S/ydb/library/yql/providers/pq/gateway/ut/composite_client_ut.cpp:398:34 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xae04c85) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0xae22384) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0xae22384)
[[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]]0xae22384)
[[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]]0xae22384)
[[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]]0xae22384)
[[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]]0xae22384)
[[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]]0xb2f9941) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0xb2f9941)
[[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]]0xb2f9941)
[[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]]0xb2dfdd9) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0xae21970) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0xb2e0b15) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0xb2f5e4c) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0xb2f4c80) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
Previous write of size 1 at 0x724c0002ac08 by thread T62:
[[c:red]]#0 __construct<NThreading::TPromise<void> > /-S/contrib/libs/cxxsupp/libcxx/include/[[c:cyan]]optional:371:22 (ydb-library-yql-providers-pq-
..[snippet truncated]..
aits/[[c:cyan]]invoke.h:251:5 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xae2234f)
[[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]]0xae2234f)
[[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]]0xae2234f)
[[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]]0xae2234f)
[[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]]0xb2f9941) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0xb2f9941)
[[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]]0xb2f9941)
[[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]]0xb2dfdd9) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0xae21970) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0xb2e0b15) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0xb2f5e4c) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0xb2f4c80) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
SUMMARY: ThreadSanitizer: data race /-S/ydb/library/signals/signal_utils.cpp:20:18 in NKikimr::NOlap::NCounters::TIntCounter::Set(long)
==================
2026-03-05T07:32:15.856339Z 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:7613671070607754852:2051]
2026-03-05T07:32:15.856486Z 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:7613671070607754852:2051]. Received TEvPoison
2026-03-05T07:32:15.856705Z node 11 :KQP_COMPUTE DEBUG: dq_pq_info_aggregation_actor.cpp:250: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [11:7613671070607754849:2049]. Received TEvUpdateCounter from: [11:7613671070607754852:2051], counter: group=distributed_topic_read_session;input_index=0;counter=read_time
2026-03-05T07:32:15.856812Z node 11 :KQP_COMPUTE TRACE: dq_pq_info_aggregation_actor.cpp:251: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [11:7613671070607754849:2049]. Received TEvUpdateCounter from: [11:7613671070607754852:2051], data: CounterId: "group=distributed_topic_read_session;input_index=0;counter=read_time" Settings { ReportPeriod { seconds: 1 } ScalarAggDeltaThreshold: 1000 } SeqNo: 2
2026-03-05T07:32:15.856856Z node 11 :KQP_COMPUTE INFO: dq_pq_info_aggregation_actor.cpp:308: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [11:7613671070607754849:2049]. Received removing counters for sender: [11:7613671070607754852:2051]
2026-03-05T07:32:15.856896Z node 11 :KQP_COMPUTE DEBUG: dq_pq_info_aggregation_actor.cpp:143: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [11:7613671070607754849:2049]. [TSumAggregator] CounterId: group=distributed_topic_read_session;input_index=0;counter=partition_counter. Agg value: 0, LastSentValue: 2
2026-03-05T07:32:15.856926Z node 11 :KQP_COMPUTE DEBUG: dq_pq_info_aggregation_actor.cpp:115: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [11:7613671070607754849:2049]. [TSumAggregator] CounterId: group=distributed_topic_read_session;input_index=0;counter=partition_counter. Send value: 0, seq no: 2
2026-03-05T07:32:15.856937Z node 11 :KQP_COMPUTE INFO: dq_pq_info_aggregation_actor.cpp:320: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [11:7613671070607754849:2049]. Aggregate value removed: group=distributed_topic_read_session;input_index=0;counter=partition_counter
2026-03-05T07:32:15.856960Z node 11 :KQP_COMPUTE INFO: dq_pq_info_aggregation_actor.cpp:320: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [11:7613671070607754849:2049]. Aggregate value removed: group=distributed_topic_read_session;input_index=0;counter=read_time
|
1.5s |
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=1149482)
Write of size 1 at 0x724c0000e6c8 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-gateway-ut+[[c:light-grey]]0x118854aa) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[c:red]]#1 [[c:green]]operator=<NThreading::TPromise<void>, 0> /-S/contrib/libs/cxxsupp/libcxx/include/[[c:cyan]]optional:742:13 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x118854aa)
[[c:red]]#2 [[c:cyan]]NKikimr::NOlap::NCounters::TSignalWrapper::GetFuture() /-S/ydb/library/signals/signal_utils.cpp:30:17 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x118854aa)
[[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]]0x1187eb37) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0x1187eb37)
[[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]]0x11871911) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0x11870fd7) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0x11870fd7)
[[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: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0xbc4a88f) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0xbc5057f) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0xbc4ff2c) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0xbc512b2) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0xb0b66b2) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0xb0ba020) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
Previous read of size 1 at 0x724c0000e6c8 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]]0x11885cc4) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0x11885cc4)
[[c:red]]#2 [[c:cyan]]NKikimr::NOlap::NCounters::TSignalWrapper::Signal() /-S/ydb/library/signals/signal_utils.cpp:40:9 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x11885cc4)
[[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:891:38 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x11883a5b) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0x1187d186) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[c:red]]#5 [[c:cyan]]NYql::(anonymous namespace)::TCompositeTopicReadSession::ReadEventFromReadyPartitions(NYdb::Dev::NTopic::TReadSessionGetEventSettings const&) /-S/ydb/lib
..[snippet truncated]..
aits/[[c:cyan]]invoke.h:251:5 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0xae2234f)
[[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]]0xae2234f)
[[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]]0xae2234f)
[[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]]0xae2234f)
[[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]]0xb2f9941) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0xb2f9941)
[[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]]0xb2f9941)
[[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]]0xb2dfdd9) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0xae21970) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0xb2e0b15) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0xb2f5e4c) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0xb2f4c80) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
SUMMARY: ThreadSanitizer: data race /-S/ydb/library/signals/signal_utils.cpp:20:18 in NKikimr::NOlap::NCounters::TIntCounter::Set(long)
==================
2026-03-05T07:32:17.285199Z 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:7613671075824390113:2051]
2026-03-05T07:32:17.285430Z 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:7613671075824390113:2051]. Received TEvPoison
2026-03-05T07:32:17.285558Z node 12 :KQP_COMPUTE DEBUG: dq_pq_info_aggregation_actor.cpp:250: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [12:7613671075824390110:2049]. Received TEvUpdateCounter from: [12:7613671075824390113:2051], counter: group=distributed_topic_read_session;input_index=0;counter=read_time
2026-03-05T07:32:17.285651Z node 12 :KQP_COMPUTE TRACE: dq_pq_info_aggregation_actor.cpp:251: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [12:7613671075824390110:2049]. Received TEvUpdateCounter from: [12:7613671075824390113:2051], data: CounterId: "group=distributed_topic_read_session;input_index=0;counter=read_time" Settings { ReportPeriod { seconds: 1 } ScalarAggDeltaThreshold: 1000 } SeqNo: 2
2026-03-05T07:32:17.285693Z node 12 :KQP_COMPUTE INFO: dq_pq_info_aggregation_actor.cpp:308: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [12:7613671075824390110:2049]. Received removing counters for sender: [12:7613671075824390113:2051]
2026-03-05T07:32:17.285723Z node 12 :KQP_COMPUTE DEBUG: dq_pq_info_aggregation_actor.cpp:143: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [12:7613671075824390110:2049]. [TSumAggregator] CounterId: group=distributed_topic_read_session;input_index=0;counter=partition_counter. Agg value: 0, LastSentValue: 2
2026-03-05T07:32:17.285744Z node 12 :KQP_COMPUTE DEBUG: dq_pq_info_aggregation_actor.cpp:115: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [12:7613671075824390110:2049]. [TSumAggregator] CounterId: group=distributed_topic_read_session;input_index=0;counter=partition_counter. Send value: 0, seq no: 2
2026-03-05T07:32:17.285753Z node 12 :KQP_COMPUTE INFO: dq_pq_info_aggregation_actor.cpp:320: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [12:7613671075824390110:2049]. Aggregate value removed: group=distributed_topic_read_session;input_index=0;counter=partition_counter
2026-03-05T07:32:17.285770Z node 12 :KQP_COMPUTE INFO: dq_pq_info_aggregation_actor.cpp:320: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [12:7613671075824390110:2049]. Aggregate value removed: group=distributed_topic_read_session;input_index=0;counter=read_time
|
1.5s |
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=1149482)
Write of size 8 at 0x724c0000e078 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]]0x11884fd4) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[c:red]]#1 UpdateMetrics /-S/ydb/library/yql/providers/pq/gateway/clients/composite/[[c:cyan]]yql_pq_composite_read_session.cpp:982:42 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x11883a76) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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:894:9 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x11883a76)
[[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]]0x1187db98) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0x1187eaed) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0x11872050) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0x11870fe0) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0x11870fe0)
[[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: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0xbc4a88f) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0xbc5057f) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0xbc4ff2c) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0xbc512b2) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0xb0b66b2) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0xb0ba020) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
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]]0x11884fd4) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[c:red]]#1 UpdateMetrics /-S/ydb/library/yql/providers/pq/gateway/clients/composite/[[c:cyan]]yql_pq_composite_read_session.cpp:982:42 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x1187fa40) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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:978:9 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x1187fa40)
[[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]]0x1187ae75) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[c:red]]#4 [[c:cyan]]NYql::NTestSuiteTCompositeTopicReadSessionTest::TTestCaseStartSessionEventThenDataDelivered::Execute_(
..[snippet truncated]..
stem.cpp:24:13 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x1c1b5014) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0xae1febb) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0xae2234f) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0xae2234f)
[[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]]0xae2234f)
[[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]]0xae2234f)
[[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]]0xae2234f)
[[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]]0xae2234f)
[[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]]0xb2f9941) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0xb2f9941)
[[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]]0xb2f9941)
[[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]]0xb2dfdd9) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0xae21970) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0xb2e0b15) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0xb2f5e4c) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0xb2f4c80) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
SUMMARY: ThreadSanitizer: data race /-S/ydb/library/signals/signal_utils.cpp:20:18 in NKikimr::NOlap::NCounters::TIntCounter::Set(long)
==================
2026-03-05T07:32:14.392210Z 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:7613671063152542545:2051]
2026-03-05T07:32:14.392423Z 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:7613671063152542545:2051]. Received TEvPoison
2026-03-05T07:32:14.392596Z node 10 :KQP_COMPUTE DEBUG: dq_pq_info_aggregation_actor.cpp:250: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [10:7613671063152542542:2049]. Received TEvUpdateCounter from: [10:7613671063152542545:2051], counter: group=distributed_topic_read_session;input_index=0;counter=read_time
2026-03-05T07:32:14.392661Z node 10 :KQP_COMPUTE TRACE: dq_pq_info_aggregation_actor.cpp:251: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [10:7613671063152542542:2049]. Received TEvUpdateCounter from: [10:7613671063152542545:2051], data: CounterId: "group=distributed_topic_read_session;input_index=0;counter=read_time" Settings { ReportPeriod { seconds: 1 } ScalarAggDeltaThreshold: 1000 } SeqNo: 2
2026-03-05T07:32:14.392698Z node 10 :KQP_COMPUTE INFO: dq_pq_info_aggregation_actor.cpp:308: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [10:7613671063152542542:2049]. Received removing counters for sender: [10:7613671063152542545:2051]
|
1.4s |
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=1149482)
Read of size 1 at 0x724c0000f308 by thread T91:
[[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]]0x1188535b) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0x1188535b)
[[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]]0x1188535b)
[[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]]0x1187eb37) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0x1187eb37)
[[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]]0x11871911) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0x11870fd7) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0x11870fd7)
[[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: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0xbc4a88f) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0xbc5057f) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0xbc4ff2c) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0xbc512b2) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0xb0b66b2) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0xb0ba020) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
Previous write of size 1 at 0x724c0000f308 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]]0x11885f04) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0x11885d29) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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:891:38 (ydb-library-yql-providers-pq-gateway-ut+[[c:light-grey]]0x11883a5b) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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]]0x1187d186) (BuildId: 3d1c0b43cfb437fef4205fe3ae951d9692844b6a)
[[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:946:13 (ydb-library-yql-providers-pq-gatewa
..[snippet truncated]..
roup=distributed_topic_read_session;input_index=0;counter=read_time
2026-03-05T07:32:18.574042Z node 13 :KQP_COMPUTE DEBUG: yql_pq_composite_read_session.cpp:249: [DQ_PQ_READ_BALANCER_ACTOR] TxId: test_tx, TaskId: 1, Cluster: cluster, TopicPath: topic_b, SelfId: [13:7613671079935887988:2053]. Start, AmountPartitionsCount: 1
2026-03-05T07:32:18.574063Z 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:7613671079935887988:2053]. Received TEvPoison
2026-03-05T07:32:18.574091Z node 13 :KQP_COMPUTE TRACE: dq_pq_info_aggregation_actor.cpp:251: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [13:7613671079935887982:2049]. Received TEvUpdateCounter from: [13:7613671079935887985:2051], data: CounterId: "group=distributed_topic_read_session;input_index=0;counter=read_time" Settings { ReportPeriod { seconds: 1 } ScalarAggDeltaThreshold: 1000 } AggMin: 10000 SeqNo: 2
2026-03-05T07:32:18.574119Z node 13 :KQP_COMPUTE DEBUG: dq_pq_info_aggregation_actor.cpp:89: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [13:7613671079935887982:2049]. [TMinAggregator] CounterId: group=distributed_topic_read_session;input_index=0;counter=read_time. Update counter, sender: [13:7613671079935887985:2051], seq no: 2, new value: 10000, old value: 18446744073709551, is new: 0
2026-03-05T07:32:18.574137Z node 13 :KQP_COMPUTE DEBUG: dq_pq_info_aggregation_actor.cpp:143: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [13:7613671079935887982:2049]. [TMinAggregator] CounterId: group=distributed_topic_read_session;input_index=0;counter=read_time. Agg value: 10000, LastSentValue: 18446744073709551
2026-03-05T07:32:18.574160Z node 13 :KQP_COMPUTE DEBUG: dq_pq_info_aggregation_actor.cpp:115: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [13:7613671079935887982:2049]. [TMinAggregator] CounterId: group=distributed_topic_read_session;input_index=0;counter=read_time. Send value: 10000, seq no: 2
2026-03-05T07:32:18.574200Z node 13 :KQP_COMPUTE DEBUG: dq_pq_info_aggregation_actor.cpp:250: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [13:7613671079935887982:2049]. Received TEvUpdateCounter from: [13:7613671079935887985:2051], counter: group=distributed_topic_read_session;input_index=0;counter=partition_counter
2026-03-05T07:32:18.574240Z node 13 :KQP_COMPUTE TRACE: dq_pq_info_aggregation_actor.cpp:251: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [13:7613671079935887982:2049]. Received TEvUpdateCounter from: [13:7613671079935887985:2051], data: CounterId: "group=distributed_topic_read_session;input_index=0;counter=partition_counter" Settings { ReportPeriod { seconds: 1 } ScalarAggDeltaThreshold: 0 } AggSum: 1 SeqNo: 2
2026-03-05T07:32:18.574262Z node 13 :KQP_COMPUTE DEBUG: dq_pq_info_aggregation_actor.cpp:89: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [13:7613671079935887982:2049]. [TSumAggregator] CounterId: group=distributed_topic_read_session;input_index=0;counter=partition_counter. Update counter, sender: [13:7613671079935887985:2051], seq no: 2, new value: 1, old value: 1, is new: 0
2026-03-05T07:32:18.574274Z node 13 :KQP_COMPUTE DEBUG: dq_pq_info_aggregation_actor.cpp:143: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [13:7613671079935887982:2049]. [TSumAggregator] CounterId: group=distributed_topic_read_session;input_index=0;counter=partition_counter. Agg value: 1, LastSentValue: 1
2026-03-05T07:32:18.574290Z node 13 :KQP_COMPUTE DEBUG: dq_pq_info_aggregation_actor.cpp:250: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [13:7613671079935887982:2049]. Received TEvUpdateCounter from: [13:7613671079935887985:2051], counter: group=distributed_topic_read_session;input_index=0;counter=read_time
2026-03-05T07:32:18.574327Z node 13 :KQP_COMPUTE TRACE: dq_pq_info_aggregation_actor.cpp:251: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [13:7613671079935887982:2049]. Received TEvUpdateCounter from: [13:7613671079935887985:2051], data: CounterId: "group=distributed_topic_read_session;input_index=0;counter=read_time" Settings { ReportPeriod { seconds: 1 } ScalarAggDeltaThreshold: 1000 } SeqNo: 2
2026-03-05T07:32:18.574350Z node 13 :KQP_COMPUTE INFO: dq_pq_info_aggregation_actor.cpp:308: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [13:7613671079935887982:2049]. Received removing counters for sender: [13:7613671079935887985:2051]
2026-03-05T07:32:18.574372Z node 13 :KQP_COMPUTE DEBUG: dq_pq_info_aggregation_actor.cpp:143: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [13:7613671079935887982:2049]. [TSumAggregator] CounterId: group=distributed_topic_read_session;input_index=0;counter=partition_counter. Agg value: 0, LastSentValue: 1
2026-03-05T07:32:18.574385Z node 13 :KQP_COMPUTE DEBUG: dq_pq_info_aggregation_actor.cpp:115: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [13:7613671079935887982:2049]. [TSumAggregator] CounterId: group=distributed_topic_read_session;input_index=0;counter=partition_counter. Send value: 0, seq no: 2
2026-03-05T07:32:18.574395Z node 13 :KQP_COMPUTE INFO: dq_pq_info_aggregation_actor.cpp:320: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [13:7613671079935887982:2049]. Aggregate value removed: group=distributed_topic_read_session;input_index=0;counter=partition_counter
2026-03-05T07:32:18.574417Z node 13 :KQP_COMPUTE INFO: dq_pq_info_aggregation_actor.cpp:320: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [13:7613671079935887982:2049]. Aggregate value removed: group=distributed_topic_read_session;input_index=0;counter=read_time
2026-03-05T07:32:18.574440Z node 13 :KQP_COMPUTE DEBUG: dq_pq_info_aggregation_actor.cpp:250: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [13:7613671079935887982:2049]. Received TEvUpdateCounter from: [13:7613671079935887985:2051], counter: group=distributed_topic_read_session;input_index=0;counter=partition_counter
|
1.3s |
FAIL
|
logsdir |
stdout |
stderr
|