|
fq
|
ydb/library/yql/providers/pq/gateway/ut/TCompositeTopicReadSessionTest.AdvancePartitionTimeAfterGetEvent
SANITIZER
Test crashed (return code: 100)
WARNING: ThreadSanitizer: data race (pid=8946)
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]..
[[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:08.898285Z 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:7613646551049912242:2051]
2026-03-05T05:57:08.898408Z 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:7613646551049912242:2051]. Received TEvPoison
2026-03-05T05:57:08.898622Z node 4 :KQP_COMPUTE DEBUG: dq_pq_info_aggregation_actor.cpp:250: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [4:7613646551049912239:2049]. Received TEvUpdateCounter from: [4:7613646551049912242:2051], counter: group=distributed_topic_read_session;input_index=0;counter=read_time
2026-03-05T05:57:08.898707Z node 4 :KQP_COMPUTE TRACE: dq_pq_info_aggregation_actor.cpp:251: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [4:7613646551049912239:2049]. Received TEvUpdateCounter from: [4:7613646551049912242: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:08.898749Z node 4 :KQP_COMPUTE INFO: dq_pq_info_aggregation_actor.cpp:308: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [4:7613646551049912239:2049]. Received removing counters for sender: [4:7613646551049912242:2051]
2026-03-05T05:57:08.898809Z node 4 :KQP_COMPUTE DEBUG: dq_pq_info_aggregation_actor.cpp:143: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [4:7613646551049912239:2049]. [TSumAggregator] CounterId: group=distributed_topic_read_session;input_index=0;counter=partition_counter. Agg value: 0, LastSentValue: 1
2026-03-05T05:57:08.898848Z node 4 :KQP_COMPUTE DEBUG: dq_pq_info_aggregation_actor.cpp:115: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [4:7613646551049912239:2049]. [TSumAggregator] CounterId: group=distributed_topic_read_session;input_index=0;counter=partition_counter. Send value: 0, seq no: 2
2026-03-05T05:57:08.898865Z node 4 :KQP_COMPUTE INFO: dq_pq_info_aggregation_actor.cpp:320: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [4:7613646551049912239:2049]. Aggregate value removed: group=distributed_topic_read_session;input_index=0;counter=partition_counter
2026-03-05T05:57:08.898888Z node 4 :KQP_COMPUTE INFO: dq_pq_info_aggregation_actor.cpp:320: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [4:7613646551049912239:2049]. Aggregate value removed: group=distributed_topic_read_session;input_index=0;counter=read_time
2026-03-05T05:57:08.898922Z node 4 :KQP_COMPUTE DEBUG: dq_pq_info_aggregation_actor.cpp:250: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [4:7613646551049912239:2049]. Received TEvUpdateCounter from: [4:7613646551049912242:2051], counter: group=distributed_topic_read_session;input_index=0;counter=partition_counter
|
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=8946)
Read of size 1 at 0x724c0000e188 by thread T32:
[[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:11.788927Z 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:7613646568984151302:2051]
2026-03-05T05:57:11.789002Z 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:7613646568984151302:2051]. Received TEvPoison
2026-03-05T05:57:11.789165Z node 8 :KQP_COMPUTE DEBUG: dq_pq_info_aggregation_actor.cpp:250: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [8:7613646568984151299:2049]. Received TEvUpdateCounter from: [8:7613646568984151302:2051], counter: group=distributed_topic_read_session;input_index=0;counter=read_time
2026-03-05T05:57:11.789234Z node 8 :KQP_COMPUTE TRACE: dq_pq_info_aggregation_actor.cpp:251: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [8:7613646568984151299:2049]. Received TEvUpdateCounter from: [8:7613646568984151302: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:11.789263Z node 8 :KQP_COMPUTE INFO: dq_pq_info_aggregation_actor.cpp:308: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [8:7613646568984151299:2049]. Received removing counters for sender: [8:7613646568984151302:2051]
2026-03-05T05:57:11.789296Z node 8 :KQP_COMPUTE DEBUG: dq_pq_info_aggregation_actor.cpp:143: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [8:7613646568984151299:2049]. [TSumAggregator] CounterId: group=distributed_topic_read_session;input_index=0;counter=partition_counter. Agg value: 0, LastSentValue: 1
2026-03-05T05:57:11.789315Z node 8 :KQP_COMPUTE DEBUG: dq_pq_info_aggregation_actor.cpp:115: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [8:7613646568984151299:2049]. [TSumAggregator] CounterId: group=distributed_topic_read_session;input_index=0;counter=partition_counter. Send value: 0, seq no: 2
2026-03-05T05:57:11.789327Z node 8 :KQP_COMPUTE INFO: dq_pq_info_aggregation_actor.cpp:320: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [8:7613646568984151299:2049]. Aggregate value removed: group=distributed_topic_read_session;input_index=0;counter=partition_counter
2026-03-05T05:57:11.789349Z node 8 :KQP_COMPUTE INFO: dq_pq_info_aggregation_actor.cpp:320: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [8:7613646568984151299:2049]. Aggregate value removed: group=distributed_topic_read_session;input_index=0;counter=read_time
2026-03-05T05:57:11.789382Z node 8 :KQP_COMPUTE DEBUG: dq_pq_info_aggregation_actor.cpp:250: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [8:7613646568984151299:2049]. Received TEvUpdateCounter from: [8:7613646568984151302:2051], counter: group=distributed_topic_read_session;input_index=0;counter=partition_counter
|
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=8946)
Write of size 8 at 0x724c0000e078 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]]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 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::TTestCaseGetEventsReturnsBatch::Execute_(NUnitTest::TTest
..[snippet truncated]..
cxx/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:10.610477Z 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:7613646566049264330:2051]
2026-03-05T05:57:10.610590Z 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:7613646566049264330:2051]. Received TEvPoison
2026-03-05T05:57:10.610765Z node 5 :KQP_COMPUTE DEBUG: dq_pq_info_aggregation_actor.cpp:250: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [5:7613646566049264327:2049]. Received TEvUpdateCounter from: [5:7613646566049264330:2051], counter: group=distributed_topic_read_session;input_index=0;counter=read_time
2026-03-05T05:57:10.610852Z node 5 :KQP_COMPUTE TRACE: dq_pq_info_aggregation_actor.cpp:251: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [5:7613646566049264327:2049]. Received TEvUpdateCounter from: [5:7613646566049264330: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:10.610879Z node 5 :KQP_COMPUTE INFO: dq_pq_info_aggregation_actor.cpp:308: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [5:7613646566049264327:2049]. Received removing counters for sender: [5:7613646566049264330:2051]
2026-03-05T05:57:10.610908Z node 5 :KQP_COMPUTE DEBUG: dq_pq_info_aggregation_actor.cpp:143: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [5:7613646566049264327:2049]. [TSumAggregator] CounterId: group=distributed_topic_read_session;input_index=0;counter=partition_counter. Agg value: 0, LastSentValue: 1
2026-03-05T05:57:10.610928Z node 5 :KQP_COMPUTE DEBUG: dq_pq_info_aggregation_actor.cpp:115: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [5:7613646566049264327:2049]. [TSumAggregator] CounterId: group=distributed_topic_read_session;input_index=0;counter=partition_counter. Send value: 0, seq no: 2
2026-03-05T05:57:10.610947Z node 5 :KQP_COMPUTE INFO: dq_pq_info_aggregation_actor.cpp:320: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [5:7613646566049264327:2049]. Aggregate value removed: group=distributed_topic_read_session;input_index=0;counter=partition_counter
2026-03-05T05:57:10.610965Z node 5 :KQP_COMPUTE INFO: dq_pq_info_aggregation_actor.cpp:320: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [5:7613646566049264327:2049]. Aggregate value removed: group=distributed_topic_read_session;input_index=0;counter=read_time
|
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=8946)
Read of size 1 at 0x724c0001c6c8 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::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]]0xae06f55) (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 0x724c0001c6c8 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-gat
..[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:14.348282Z 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:7613646583451063323:2051]
2026-03-05T05:57:14.348516Z 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:7613646583451063323:2051]. Received TEvPoison
2026-03-05T05:57:14.348705Z node 11 :KQP_COMPUTE DEBUG: dq_pq_info_aggregation_actor.cpp:250: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [11:7613646583451063320:2049]. Received TEvUpdateCounter from: [11:7613646583451063323:2051], counter: group=distributed_topic_read_session;input_index=0;counter=read_time
2026-03-05T05:57:14.348796Z node 11 :KQP_COMPUTE TRACE: dq_pq_info_aggregation_actor.cpp:251: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [11:7613646583451063320:2049]. Received TEvUpdateCounter from: [11:7613646583451063323: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:14.348821Z node 11 :KQP_COMPUTE INFO: dq_pq_info_aggregation_actor.cpp:308: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [11:7613646583451063320:2049]. Received removing counters for sender: [11:7613646583451063323:2051]
2026-03-05T05:57:14.348862Z node 11 :KQP_COMPUTE DEBUG: dq_pq_info_aggregation_actor.cpp:143: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [11:7613646583451063320: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=8946)
Read of size 1 at 0x724c0000edc8 by thread T77:
[[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 0x724c0000edc8 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]]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:15.652440Z 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:7613646588933877229:2051]
2026-03-05T05:57:15.652715Z 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:7613646588933877229:2051]. Received TEvPoison
2026-03-05T05:57:15.652913Z node 12 :KQP_COMPUTE DEBUG: dq_pq_info_aggregation_actor.cpp:250: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [12:7613646588933877226:2049]. Received TEvUpdateCounter from: [12:7613646588933877229:2051], counter: group=distributed_topic_read_session;input_index=0;counter=read_time
2026-03-05T05:57:15.653003Z node 12 :KQP_COMPUTE TRACE: dq_pq_info_aggregation_actor.cpp:251: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [12:7613646588933877226:2049]. Received TEvUpdateCounter from: [12:7613646588933877229: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:15.653025Z node 12 :KQP_COMPUTE INFO: dq_pq_info_aggregation_actor.cpp:308: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [12:7613646588933877226:2049]. Received removing counters for sender: [12:7613646588933877229:2051]
2026-03-05T05:57:15.653060Z node 12 :KQP_COMPUTE DEBUG: dq_pq_info_aggregation_actor.cpp:143: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [12:7613646588933877226:2049]. [TSumAggregator] CounterId: group=distributed_topic_read_session;input_index=0;counter=partition_counter. Agg value: 0, LastSentValue: 2
2026-03-05T05:57:15.653089Z node 12 :KQP_COMPUTE DEBUG: dq_pq_info_aggregation_actor.cpp:115: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [12:7613646588933877226:2049]. [TSumAggregator] CounterId: group=distributed_topic_read_session;input_index=0;counter=partition_counter. Send value: 0, seq no: 2
2026-03-05T05:57:15.653108Z node 12 :KQP_COMPUTE INFO: dq_pq_info_aggregation_actor.cpp:320: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [12:7613646588933877226:2049]. Aggregate value removed: group=distributed_topic_read_session;input_index=0;counter=partition_counter
|
1.4s |
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=8946)
Write of size 8 at 0x724c0001c078 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 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::TTestCaseStartSessionEventThenDataDelivered::Execute_(NUn
..[snippet truncated]..
aits/[[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:12.979627Z 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:7613646572925316917:2051]
2026-03-05T05:57:12.979749Z 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:7613646572925316917:2051]. Received TEvPoison
2026-03-05T05:57:12.979884Z node 10 :KQP_COMPUTE DEBUG: dq_pq_info_aggregation_actor.cpp:250: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [10:7613646572925316914:2049]. Received TEvUpdateCounter from: [10:7613646572925316917:2051], counter: group=distributed_topic_read_session;input_index=0;counter=read_time
2026-03-05T05:57:12.979960Z node 10 :KQP_COMPUTE TRACE: dq_pq_info_aggregation_actor.cpp:251: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [10:7613646572925316914:2049]. Received TEvUpdateCounter from: [10:7613646572925316917: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:12.979993Z node 10 :KQP_COMPUTE INFO: dq_pq_info_aggregation_actor.cpp:308: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [10:7613646572925316914:2049]. Received removing counters for sender: [10:7613646572925316917:2051]
2026-03-05T05:57:12.980027Z node 10 :KQP_COMPUTE DEBUG: dq_pq_info_aggregation_actor.cpp:143: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [10:7613646572925316914:2049]. [TSumAggregator] CounterId: group=distributed_topic_read_session;input_index=0;counter=partition_counter. Agg value: 0, LastSentValue: 1
2026-03-05T05:57:12.980042Z node 10 :KQP_COMPUTE DEBUG: dq_pq_info_aggregation_actor.cpp:115: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [10:7613646572925316914:2049]. [TSumAggregator] CounterId: group=distributed_topic_read_session;input_index=0;counter=partition_counter. Send value: 0, seq no: 2
2026-03-05T05:57:12.980053Z node 10 :KQP_COMPUTE INFO: dq_pq_info_aggregation_actor.cpp:320: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [10:7613646572925316914:2049]. Aggregate value removed: group=distributed_topic_read_session;input_index=0;counter=partition_counter
2026-03-05T05:57:12.980071Z node 10 :KQP_COMPUTE INFO: dq_pq_info_aggregation_actor.cpp:320: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [10:7613646572925316914:2049]. Aggregate value removed: 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=8946)
Read of size 1 at 0x724c0002ba08 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]]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 0x724c0002ba08 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]..
7af1ca34b332a5e18ca888)
[[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/util/generic/utility.h:79:15 in Swap
==================
2026-03-05T05:57:16.813328Z node 13 :KQP_COMPUTE TRACE: yql_pq_composite_read_session.cpp:867: [TCompositeTopicReadSession] TxId: test_tx, TaskId: 1, Cluster: cluster, TopicPath: topic_a. Unsuspended partitions count: 0
2026-03-05T05:57:16.813340Z 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:7613646591579898683:2053]
2026-03-05T05:57:16.813366Z node 13 :KQP_COMPUTE TRACE: yql_pq_composite_read_session.cpp:796: [TCompositeTopicReadSession] TxId: test_tx, TaskId: 1, Cluster: cluster, TopicPath: topic_a. GetReadTime result: 1970-01-01T00:00:10.000000Z
2026-03-05T05:57:16.813385Z 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_a, SelfId: [13:7613646591579898680:2051]. Send values, local ReadTime: 1970-01-01T00:00:10.000000Z, PartitionCountReported: 1, AllPartitionsStarted: 1, ExternalReadTime: 586524-01-19T08:01:49.551000Z
2026-03-05T05:57:16.813433Z 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:7613646591579898680:2051]
2026-03-05T05:57:16.813563Z node 13 :KQP_COMPUTE DEBUG: dq_pq_info_aggregation_actor.cpp:250: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [13:7613646591579898677:2049]. Received TEvUpdateCounter from: [13:7613646591579898680:2051], counter: group=distributed_topic_read_session;input_index=0;counter=read_time
2026-03-05T05:57:16.813680Z node 13 :KQP_COMPUTE TRACE: dq_pq_info_aggregation_actor.cpp:251: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [13:7613646591579898677:2049]. Received TEvUpdateCounter from: [13:7613646591579898680: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-05T05:57:16.813730Z node 13 :KQP_COMPUTE DEBUG: dq_pq_info_aggregation_actor.cpp:89: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [13:7613646591579898677:2049]. [TMinAggregator] CounterId: group=distributed_topic_read_session;input_index=0;counter=read_time. Update counter, sender: [13:7613646591579898680:2051], seq no: 2, new value: 10000, old value: 18446744073709551, is new: 0
2026-03-05T05:57:16.813775Z node 13 :KQP_COMPUTE DEBUG: dq_pq_info_aggregation_actor.cpp:143: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [13:7613646591579898677:2049]. [TMinAggregator] CounterId: group=distributed_topic_read_session;input_index=0;counter=read_time. Agg value: 10000, LastSentValue: 18446744073709551
2026-03-05T05:57:16.813809Z node 13 :KQP_COMPUTE DEBUG: dq_pq_info_aggregation_actor.cpp:115: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [13:7613646591579898677:2049]. [TMinAggregator] CounterId: group=distributed_topic_read_session;input_index=0;counter=read_time. Send value: 10000, seq no: 2
2026-03-05T05:57:16.813835Z node 13 :KQP_COMPUTE DEBUG: dq_pq_info_aggregation_actor.cpp:250: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [13:7613646591579898677:2049]. Received TEvUpdateCounter from: [13:7613646591579898680:2051], counter: group=distributed_topic_read_session;input_index=0;counter=partition_counter
2026-03-05T05:57:16.813890Z node 13 :KQP_COMPUTE TRACE: dq_pq_info_aggregation_actor.cpp:251: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [13:7613646591579898677:2049]. Received TEvUpdateCounter from: [13:7613646591579898680: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-05T05:57:16.813926Z node 13 :KQP_COMPUTE DEBUG: dq_pq_info_aggregation_actor.cpp:89: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [13:7613646591579898677:2049]. [TSumAggregator] CounterId: group=distributed_topic_read_session;input_index=0;counter=partition_counter. Update counter, sender: [13:7613646591579898680:2051], seq no: 2, new value: 1, old value: 1, is new: 0
2026-03-05T05:57:16.813944Z node 13 :KQP_COMPUTE DEBUG: dq_pq_info_aggregation_actor.cpp:143: [DQ_PQ_INFO_AGGREGATION_ACTOR] TxId: test_tx, SelfId: [13:7613646591579898677:2049]. [TSumAggregator] CounterId: group=distributed_topic_read_session;input_index=0;counter=partition_counter. Agg value: 1, LastSentValue: 1
2026-03-05T05:57:16.813956Z 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:7613646591579898680:2051]. Received TEvPoison
|
1.2s |
FAIL
|
logsdir |
stdout |
stderr
|