2025-12-12T12:28:07.536159Z :GRPC_SERVER NOTICE: grpc_request_proxy.cpp:380: Grpc request proxy started, nodeid# 1, serve as static node
2025-12-12T12:28:07.536214Z :GRPC_SERVER CRIT: grpc_request_proxy.cpp:440: Failed to deliver subscription request to config dispatcher
2025-12-12T12:28:07.536220Z :GRPC_SERVER NOTICE: grpc_request_proxy.cpp:380: Grpc request proxy started, nodeid# 1, serve as static node
2025-12-12T12:28:07.536236Z :GRPC_SERVER CRIT: grpc_request_proxy.cpp:440: Failed to deliver subscription request to config dispatcher
2025-12-12T12:28:07.536412Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:214: Bootstrap
2025-12-12T12:28:07.536414Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:217: Create sdk ydb connection
2025-12-12T12:28:07.537404Z :FQ_QUOTA_SERVICE INFO: quota_manager.cpp:196: STARTED
2025-12-12T12:28:07.537420Z :FQ_QUOTA_PROXY INFO: quota_proxy.cpp:90: STARTED
2025-12-12T12:28:07.537474Z :FQ_LOG_UPDATER DEBUG: log.cpp:93: Updated YQL logs priority: 8
2025-12-12T12:28:07.537478Z :FQ_LOG_UPDATER CRIT: log.cpp:55: Failed to deliver subscription request to config dispatcher.
2025-12-12T12:28:07.537518Z :YQ_RATE_LIMITER INFO: quoter_service.cpp:124: Bootstraping with config: { Enabled: true DataPlaneEnabled: true Database { Endpoint: "localhost:12106" Database: "local" TablePrefix: "RateLimiter_9b331a50-95d3-410c-8655-8751485d9199" } Limiters { CoordinationNodePath: "rate_limiter" } }
2025-12-12T12:28:07.537655Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:544: RowDispatcher: Successfully bootstrapped row dispatcher, id [1:7582947245656270488:2063], tenant /compute
2025-12-12T12:28:07.537673Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582947245656270488:2063]
2025-12-12T12:28:07.537675Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:329: Coordinator: Add new row dispatcher to map (state 1)
2025-12-12T12:28:07.537704Z :YQL_NODES_MANAGER INFO: nodes_manager.cpp:88: Bootstrap, InstanceId: e133ef36-44b0cc2f-9ee48686-5232768b
2025-12-12T12:28:07.537716Z :YQL_NODES_MANAGER DEBUG: nodes_manager.cpp:310: TNodesManagerActor::ResolveSelfAddress
2025-12-12T12:28:07.537736Z :YQ_TEST_CONNECTION DEBUG: test_connection.cpp:142: Starting yandex query test connection. Actor id: [1:7582947245656270493:2068]
2025-12-12T12:28:07.537813Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 85753069-84ac59d2-c006a4dd-96a2c7a61, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:28:07.537827Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:293: Coordinator: Successfully bootstrapped coordinator, id [1:7582947245656270544:2092], NodesManagerId [0:4705493345362661702:78], rebalancing timeout 5.000000s
2025-12-12T12:28:07.537838Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:232: TLeaderElection [1:7582947245656270545:2093] Successfully bootstrapped, local coordinator id [1:7582947245656270544:2092], tenant id compute, local mode 0, coordination node path local/compute, endpoint localhost:12106
2025-12-12T12:28:07.537876Z :MEMORY_PROFILER NOTICE: monitor.cpp:332: Bootstrapped
2025-12-12T12:28:07.538050Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:239: Successfully bootstrapped TStorageProxy [1:7582947245656270487:2062] with connection to localhost:12106:local
2025-12-12T12:28:07.538100Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:637: RowDispatcher: TEvCoordinatorChangesSubscribe from [1:7582947245656270544:2092]
2025-12-12T12:28:07.539231Z :SCHEME_BOARD_SUBSCRIBER NOTICE: subscriber.cpp:849: [main][1:7582947245656270508:2078][/compute] Set up state: owner# [1:7582947245656270467:2052], state# { Deleted: 1 Strong: 0 Version: <Invalid> DomainId: <Invalid> AbandonedSchemeShards: there are 0 elements }
2025-12-12T12:28:07.539240Z :SCHEME_BOARD_SUBSCRIBER NOTICE: subscriber.cpp:849: [main][1:7582947245656270507:2077][/Root] Set up state: owner# [1:7582947245656270467:2052], state# { Deleted: 1 Strong: 0 Version: <Invalid> DomainId: <Invalid> AbandonedSchemeShards: there are 0 elements }
2025-12-12T12:28:07.539255Z :SCHEME_BOARD_SUBSCRIBER NOTICE: subscriber.cpp:849: [main][1:7582947245656270509:2079][/Root] Set up state: owner# [1:7582947245656270468:2053], state# { Deleted: 1 Strong: 0 Version: <Invalid> DomainId: <Invalid> AbandonedSchemeShards: there are 0 elements }
2025-12-12T12:28:07.539257Z :SCHEME_BOARD_SUBSCRIBER NOTICE: subscriber.cpp:849: [main][1:7582947245656270510:2080][/compute] Set up state: owner# [1:7582947245656270468:2053], state# { Deleted: 1 Strong: 0 Version: <Invalid> DomainId: <Invalid> AbandonedSchemeShards: there are 0 elements }
2025-12-12T12:28:07.539261Z :GRPC_SERVER WARN: grpc_request_proxy.cpp:583: SchemeBoardDelete /compute Strong=0
2025-12-12T12:28:07.539262Z :GRPC_SERVER WARN: grpc_request_proxy.cpp:583: SchemeBoardDelete /Root Strong=0
2025-12-12T12:28:07.539264Z :GRPC_SERVER WARN: grpc_request_proxy.cpp:583: SchemeBoardDelete /compute Strong=0
2025-12-12T12:28:07.539264Z :GRPC_SERVER WARN: grpc_request_proxy.cpp:583: SchemeBoardDelete /Root Strong=0
2025-12-12T12:28:07.539936Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-12-12T12:28:07.540494Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:71: Run create coordination node "local/compute" actor
2025-12-12T12:28:07.540503Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:113: Call create coordination node "local/compute"
2025-12-12T12:28:07.540506Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:411: Call create coordination node "local/compute"
2025-12-12T12:28:07.552565Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:155: Successfully created coordination node "local/compute"
2025-12-12T12:28:07.552588Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:122: Reply for create coordination node "local/compute": { <main>: Error: Check failed: path: '/local/compute', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 19], type: EPathTypeKesus, state: EPathStateNoChanges), source_location: ydb/core/tx/schemeshard/schemeshard__operation_create_kesus.cpp:339 }
2025-12-12T12:28:07.552603Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:345: TLeaderElection [1:7582947245656270545:2093] Coordination node successfully created
2025-12-12T12:28:07.552607Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:323: TLeaderElection [1:7582947245656270545:2093] Start session
2025-12-12T12:28:07.560701Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:359: TLeaderElection [1:7582947245656270545:2093] Session successfully created
2025-12-12T12:28:07.564569Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:372: TLeaderElection [1:7582947245656270545:2093] Semaphore successfully created
2025-12-12T12:28:07.564584Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:304: TLeaderElection [1:7582947245656270545:2093] Try to acquire semaphore
2025-12-12T12:28:07.564697Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:420: TLeaderElection [1:7582947245656270545:2093] Describe semaphore
2025-12-12T12:28:07.566601Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:386: TLeaderElection [1:7582947245656270545:2093] Semaphore successfully acquired
2025-12-12T12:28:07.566738Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:469: TLeaderElection [1:7582947245656270545:2093] Semaphore successfully described: coordinator id [1:7582947245656270544:2092] generation 4
2025-12-12T12:28:07.566742Z :FQ_ROW_DISPATCHER INFO: leader_election.cpp:471: TLeaderElection [1:7582947245656270545:2093] Send TEvCoordinatorChanged to [1:7582947245656270488:2063], new coordinator id [1:7582947245656270544:2092], previous coordinator id [0:0:0]
2025-12-12T12:28:07.566762Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:569: RowDispatcher: Coordinator changed, old leader (empty maybe), new [1:7582947245656270544:2092] generation 4
2025-12-12T12:28:07.566777Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582947245656270488:2063]
2025-12-12T12:28:07.566780Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582947245656270488:2063]
2025-12-12T12:28:07.566783Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582947245656270488:2063]
2025-12-12T12:28:07.566793Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:440: Coordinator: New leader [1:7582947245656270544:2092], SelfId [1:7582947245656270544:2092]
2025-12-12T12:28:07.566796Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:28:07.608806Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:28:07.608826Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:28:07.623200Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:389: Send NodeInfo with size: 0 to DynamicNameserver
2025-12-12T12:28:08.246826Z :INTERCONNECT ERROR: interconnect_nameserver_dynamic.cpp:62:  ICN06 Unknown nodeId: 2
2025-12-12T12:28:08.509985Z :INTERCONNECT ERROR: interconnect_nameserver_dynamic.cpp:62:  ICN06 Unknown nodeId: 2
2025-12-12T12:28:08.534599Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 85753069-84ac59d2-c006a4dd-96a2c7a62, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:28:08.538761Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:28:08.538774Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:28:08.753703Z :INTERCONNECT ERROR: interconnect_nameserver_dynamic.cpp:62:  ICN06 Unknown nodeId: 3
2025-12-12T12:28:08.753723Z :INTERCONNECT ERROR: interconnect_nameserver_dynamic.cpp:62:  ICN06 Unknown nodeId: 2
2025-12-12T12:28:09.196076Z :INTERCONNECT ERROR: interconnect_nameserver_dynamic.cpp:62:  ICN06 Unknown nodeId: 3
2025-12-12T12:28:09.533999Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582947245656270544:2092]
2025-12-12T12:28:09.534023Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:28:09.534032Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582947245656270488:2063]
2025-12-12T12:28:09.534039Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582947245656270488:2063]
2025-12-12T12:28:09.534042Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582947245656270488:2063]
2025-12-12T12:28:09.534048Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:28:09.535041Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 85753069-84ac59d2-c006a4dd-96a2c7a63, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:28:09.597086Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:28:09.597101Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:28:09.916977Z :INTERCONNECT ERROR: interconnect_nameserver_dynamic.cpp:62:  ICN06 Unknown nodeId: 2
2025-12-12T12:28:10.359340Z :INTERCONNECT ERROR: interconnect_nameserver_dynamic.cpp:62:  ICN06 Unknown nodeId: 3
2025-12-12T12:28:10.536137Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 85753069-84ac59d2-c006a4dd-96a2c7a64, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:28:10.541706Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:28:10.541725Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:28:11.401771Z :INTERCONNECT ERROR: interconnect_nameserver_dynamic.cpp:62:  ICN06 Unknown nodeId: 2
2025-12-12T12:28:11.401797Z :INTERCONNECT ERROR: interconnect_nameserver_dynamic.cpp:62:  ICN06 Unknown nodeId: 3
2025-12-12T12:28:11.534878Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582947245656270544:2092]
2025-12-12T12:28:11.534907Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:28:11.534916Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582947245656270488:2063]
2025-12-12T12:28:11.534919Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582947245656270488:2063]
2025-12-12T12:28:11.534922Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582947245656270488:2063]
2025-12-12T12:28:11.534934Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:28:11.535916Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 85753069-84ac59d2-c006a4dd-96a2c7a65, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:28:11.545579Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:28:11.545598Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:28:12.534312Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:665: Coordinator: Change global state to Started (by timeout)
2025-12-12T12:28:12.536401Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 85753069-84ac59d2-c006a4dd-96a2c7a66, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:28:12.539472Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-12-12T12:28:12.543186Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:28:12.543197Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:28:12.547366Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:389: Send NodeInfo with size: 2 to DynamicNameserver
2025-12-12T12:28:12.548897Z :INTERCONNECT WARN: interconnect_handshake.cpp:501: Handshake [1:7582947267131107181:2062] [node 2] ICH09 Neither CompatibilityInfo nor VersionTag of the peer can be validated, accepting by default
2025-12-12T12:28:12.550818Z :FQ_ROW_DISPATCHER INFO: coordinator.cpp:507: Coordinator: TEvCoordinatorRequest from [2:7582947261999340665:2154], test_3_session_input, partIds: 0
2025-12-12T12:28:12.550854Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:562: Coordinator: Send TEvCoordinatorResult to [2:7582947261999340665:2154]
2025-12-12T12:28:12.550871Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:392: Coordinator: EvNodeConnected 2
2025-12-12T12:28:12.551132Z :INTERCONNECT WARN: interconnect_handshake.cpp:501: Handshake [1:7582947267131107182:2063] [node 3] ICH09 Neither CompatibilityInfo nor VersionTag of the peer can be validated, accepting by default
2025-12-12T12:28:12.552260Z :FQ_ROW_DISPATCHER INFO: coordinator.cpp:507: Coordinator: TEvCoordinatorRequest from [3:7582947251119949753:2150], test_3_session_input, partIds: 0
2025-12-12T12:28:12.552280Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:562: Coordinator: Send TEvCoordinatorResult to [3:7582947251119949753:2150]
2025-12-12T12:28:12.552307Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [3:7582947246824982252:2063]
2025-12-12T12:28:12.552310Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [3:7582947246824982252:2063]
2025-12-12T12:28:12.552312Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:329: Coordinator: Add new row dispatcher to map (state 0)
2025-12-12T12:28:12.552317Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:334: Coordinator: Schedule TEvRebalancing
2025-12-12T12:28:12.552320Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [3:7582947246824982252:2063]
2025-12-12T12:28:12.552324Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:392: Coordinator: EvNodeConnected 3
2025-12-12T12:28:12.553437Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:853: RowDispatcher: Received TEvStartSession from [2:7582947261999340665:2154], read group ptcudq7udianfb5k0f2l, topicPath test_3_session_input part id 0 query id ptqudq7udfu8nrrist3a cookie 1
2025-12-12T12:28:12.553489Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:892: RowDispatcher: Create new session: read group ptcudq7udianfb5k0f2l topic test_3_session_input part id 0
2025-12-12T12:28:12.553569Z :FQ_ROW_DISPATCHER DEBUG: topic_session.cpp:443: TopicSession [1:7582947267131107193:2150] Bootstrap test_3_session_input/0, Timeout 5.000000s sec
2025-12-12T12:28:12.553575Z :FQ_ROW_DISPATCHER INFO: topic_session.cpp:799: TopicSession [1:7582947267131107193:2150] New client: read actor id [2:7582947261999340665:2154], predicate: , watermark expr: , offset: (empty maybe)
2025-12-12T12:28:12.553619Z :FQ_ROW_DISPATCHER DEBUG: format_handler.cpp:440: TTopicFormatHandler [json_each_row]: Add client with id [2:7582947261999340665:2154]
2025-12-12T12:28:12.553774Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1052: RowDispatcher: TEvTryConnect to node id 2
2025-12-12T12:28:12.554370Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:853: RowDispatcher: Received TEvStartSession from [3:7582947251119949753:2150], read group ptcudq7udianfb5k0f2l, topicPath test_3_session_input part id 0 query id ptqudq7udhp59svrf658 cookie 1
2025-12-12T12:28:12.554437Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:587: RowDispatcher: EvNodeConnected, node id 2
2025-12-12T12:28:12.555766Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1052: RowDispatcher: TEvTryConnect to node id 3
2025-12-12T12:28:12.555832Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:587: RowDispatcher: EvNodeConnected, node id 3
2025-12-12T12:28:12.591548Z :FQ_ROW_DISPATCHER DEBUG: format_handler.cpp:559: TTopicFormatHandler [json_each_row]: UpdateParser to new schema with size 1
2025-12-12T12:28:12.592534Z :FQ_ROW_DISPATCHER INFO: json_parser.cpp:355: TJsonParser: Simdjson active implementation icelake (Intel/AMD AVX512), error skip mode: 0
2025-12-12T12:28:12.592603Z :FQ_ROW_DISPATCHER DEBUG: format_handler.cpp:570: TTopicFormatHandler [json_each_row]: Parser was created on schema with 1 columns
2025-12-12T12:28:12.592614Z :FQ_ROW_DISPATCHER TRACE: purecalc_filter.cpp:439: GenerateSql: No sql was generated
2025-12-12T12:28:12.592621Z :FQ_ROW_DISPATCHER TRACE: filters_set.cpp:116: TTopicFilters: Create program with client id [2:7582947261999340665:2154]
2025-12-12T12:28:12.592630Z :FQ_ROW_DISPATCHER TRACE: filters_set.cpp:110: TTopicFilters: Start program with client id [2:7582947261999340665:2154]
2025-12-12T12:28:12.592638Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:952: TopicSession [1:7582947267131107193:2150] SendStatistics
2025-12-12T12:28:12.592678Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1234: RowDispatcher: TEvSessionStatistic from [1:7582947267131107193:2150]
2025-12-12T12:28:12.592691Z :FQ_ROW_DISPATCHER INFO: topic_session.cpp:799: TopicSession [1:7582947267131107193:2150] New client: read actor id [3:7582947251119949753:2150], predicate: , watermark expr: , offset: (empty maybe)
2025-12-12T12:28:12.592713Z :FQ_ROW_DISPATCHER DEBUG: format_handler.cpp:440: TTopicFormatHandler [json_each_row]: Add client with id [3:7582947251119949753:2150]
2025-12-12T12:28:12.592734Z :FQ_ROW_DISPATCHER TRACE: purecalc_filter.cpp:439: GenerateSql: No sql was generated
2025-12-12T12:28:12.592740Z :FQ_ROW_DISPATCHER TRACE: filters_set.cpp:116: TTopicFilters: Create program with client id [3:7582947251119949753:2150]
2025-12-12T12:28:12.592743Z :FQ_ROW_DISPATCHER TRACE: filters_set.cpp:110: TTopicFilters: Start program with client id [3:7582947251119949753:2150]
2025-12-12T12:28:12.592745Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:952: TopicSession [1:7582947267131107193:2150] SendStatistics
2025-12-12T12:28:12.592764Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1234: RowDispatcher: TEvSessionStatistic from [1:7582947267131107193:2150]
2025-12-12T12:28:13.099164Z :FQ_ROW_DISPATCHER INFO: coordinator.cpp:507: Coordinator: TEvCoordinatorRequest from [2:7582947270589275284:2161], test_3_session_input, partIds: 0
2025-12-12T12:28:13.099184Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:562: Coordinator: Send TEvCoordinatorResult to [2:7582947270589275284:2161]
2025-12-12T12:28:13.100078Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:853: RowDispatcher: Received TEvStartSession from [2:7582947270589275284:2161], read group ptcudq7udianfb5k0f2l, topicPath test_3_session_input part id 0 query id ptqudq7udfcpbb5tnuo6 cookie 1
2025-12-12T12:28:13.100161Z :FQ_ROW_DISPATCHER INFO: topic_session.cpp:799: TopicSession [1:7582947267131107193:2150] New client: read actor id [2:7582947270589275284:2161], predicate: , watermark expr: , offset: (empty maybe)
2025-12-12T12:28:13.100178Z :FQ_ROW_DISPATCHER DEBUG: format_handler.cpp:440: TTopicFormatHandler [json_each_row]: Add client with id [2:7582947270589275284:2161]
2025-12-12T12:28:13.100223Z :FQ_ROW_DISPATCHER TRACE: purecalc_filter.cpp:439: GenerateSql: No sql was generated
2025-12-12T12:28:13.100229Z :FQ_ROW_DISPATCHER TRACE: filters_set.cpp:116: TTopicFilters: Create program with client id [2:7582947270589275284:2161]
2025-12-12T12:28:13.100235Z :FQ_ROW_DISPATCHER TRACE: filters_set.cpp:110: TTopicFilters: Start program with client id [2:7582947270589275284:2161]
2025-12-12T12:28:13.100239Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:952: TopicSession [1:7582947267131107193:2150] SendStatistics
2025-12-12T12:28:13.100259Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1234: RowDispatcher: TEvSessionStatistic from [1:7582947267131107193:2150]
2025-12-12T12:28:13.535796Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582947245656270544:2092]
2025-12-12T12:28:13.535814Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:28:13.535847Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582947245656270488:2063]
2025-12-12T12:28:13.535852Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582947245656270488:2063]
2025-12-12T12:28:13.535855Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582947245656270488:2063]
2025-12-12T12:28:13.535859Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:28:13.536964Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 85753069-84ac59d2-c006a4dd-96a2c7a67, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:28:13.539054Z :FQ_QUOTA_SERVICE DEBUG: quota_manager.cpp:230: IC Peers[2]: [2, 3]
2025-12-12T12:28:13.543133Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:28:13.543148Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:28:14.006413Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [2:7582947249114438546:2063]
2025-12-12T12:28:14.006431Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [2:7582947249114438546:2063]
2025-12-12T12:28:14.006434Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:329: Coordinator: Add new row dispatcher to map (state 0)
2025-12-12T12:28:14.006438Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [2:7582947249114438546:2063]
2025-12-12T12:28:14.482072Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [3:7582947246824982252:2063]
2025-12-12T12:28:14.482094Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [3:7582947246824982252:2063]
2025-12-12T12:28:14.482097Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [3:7582947246824982252:2063]
2025-12-12T12:28:14.537253Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 85753069-84ac59d2-c006a4dd-96a2c7a68, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:28:14.541569Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:28:14.541598Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:28:14.553637Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:952: TopicSession [1:7582947267131107193:2150] SendStatistics
2025-12-12T12:28:14.553688Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1234: RowDispatcher: TEvSessionStatistic from [1:7582947267131107193:2150]
2025-12-12T12:28:14.554226Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:962: RowDispatcher: Received TEvHeartbeat from [2:7582947261999340665:2154], part id 0 query id ptqudq7udfu8nrrist3a
2025-12-12T12:28:14.554623Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:962: RowDispatcher: Received TEvHeartbeat from [3:7582947251119949753:2150], part id 0 query id ptqudq7udhp59svrf658
2025-12-12T12:28:15.101258Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1067: RowDispatcher: Send TEvHeartbeat to [2:7582947270589275284:2161] query id ptqudq7udfcpbb5tnuo6
2025-12-12T12:28:15.101828Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:962: RowDispatcher: Received TEvHeartbeat from [2:7582947270589275284:2161], part id 0 query id ptqudq7udfcpbb5tnuo6
2025-12-12T12:28:15.536690Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582947245656270544:2092]
2025-12-12T12:28:15.536716Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:28:15.536756Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582947245656270488:2063]
2025-12-12T12:28:15.536760Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582947245656270488:2063]
2025-12-12T12:28:15.536765Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582947245656270488:2063]
2025-12-12T12:28:15.536777Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:28:15.537726Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 85753069-84ac59d2-c006a4dd-96a2c7a69, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:28:15.542267Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:28:15.542281Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:28:16.007277Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [2:7582947249114438546:2063]
2025-12-12T12:28:16.007294Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [2:7582947249114438546:2063]
2025-12-12T12:28:16.007297Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [2:7582947249114438546:2063]
2025-12-12T12:28:16.482892Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [3:7582947246824982252:2063]
2025-12-12T12:28:16.482913Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [3:7582947246824982252:2063]
2025-12-12T12:28:16.482916Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [3:7582947246824982252:2063]
2025-12-12T12:28:16.538129Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 85753069-84ac59d2-c006a4dd-96a2c7a610, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:28:16.542288Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:28:16.542306Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:28:16.554544Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:952: TopicSession [1:7582947267131107193:2150] SendStatistics
2025-12-12T12:28:16.554586Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1234: RowDispatcher: TEvSessionStatistic from [1:7582947267131107193:2150]
2025-12-12T12:28:16.555161Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:962: RowDispatcher: Received TEvHeartbeat from [2:7582947261999340665:2154], part id 0 query id ptqudq7udfu8nrrist3a
2025-12-12T12:28:16.555510Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:962: RowDispatcher: Received TEvHeartbeat from [3:7582947251119949753:2150], part id 0 query id ptqudq7udhp59svrf658
2025-12-12T12:28:17.102978Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:962: RowDispatcher: Received TEvHeartbeat from [2:7582947270589275284:2161], part id 0 query id ptqudq7udfcpbb5tnuo6
2025-12-12T12:28:17.534886Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:599: Coordinator: Send TEvGetNodesRequest to NodesManager
2025-12-12T12:28:17.534916Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:300: Received TNodesManagerActor::TEvGetNodesRequest
2025-12-12T12:28:17.534944Z :FQ_ROW_DISPATCHER INFO: coordinator.cpp:690: Coordinator: Updated node info, node count: 3
2025-12-12T12:28:17.537567Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582947245656270544:2092]
2025-12-12T12:28:17.537587Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:28:17.537606Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582947245656270488:2063]
2025-12-12T12:28:17.537612Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582947245656270488:2063]
2025-12-12T12:28:17.537615Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582947245656270488:2063]
2025-12-12T12:28:17.537630Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:28:17.538612Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 85753069-84ac59d2-c006a4dd-96a2c7a611, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:28:17.539612Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-12-12T12:28:17.544631Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:28:17.544646Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:28:17.549702Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:389: Send NodeInfo with size: 2 to DynamicNameserver
2025-12-12T12:28:17.552927Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:608: Coordinator: Rebalancing...
2025-12-12T12:28:17.552940Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:615: Coordinator: Current state (rebalancing):
2025-12-12T12:28:17.552947Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:617: Coordinator:   node 1 ([1:7582947245656270488:2063]) state Started connected 1 partitions count 1
2025-12-12T12:28:17.552951Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:617: Coordinator:   node 3 ([3:7582947246824982252:2063]) state Initializing connected 1 partitions count 0
2025-12-12T12:28:17.552955Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:617: Coordinator:   node 2 ([2:7582947249114438546:2063]) state Initializing connected 1 partitions count 0
2025-12-12T12:28:17.552967Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:648: Coordinator: Send TEvCoordinatorDistributionReset to [3:7582947251119949753:2150]
2025-12-12T12:28:17.552978Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:648: Coordinator: Send TEvCoordinatorDistributionReset to [2:7582947270589275284:2161]
2025-12-12T12:28:17.552982Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:648: Coordinator: Send TEvCoordinatorDistributionReset to [2:7582947261999340665:2154]
2025-12-12T12:28:17.552991Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:615: Coordinator: Current state (after rebalancing):
2025-12-12T12:28:17.552993Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:617: Coordinator:   node 1 ([1:7582947245656270488:2063]) state Started connected 1 partitions count 0
2025-12-12T12:28:17.552995Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:617: Coordinator:   node 3 ([3:7582947246824982252:2063]) state Started connected 1 partitions count 0
2025-12-12T12:28:17.552997Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:617: Coordinator:   node 2 ([2:7582947249114438546:2063]) state Started connected 1 partitions count 0
2025-12-12T12:28:17.594021Z :FQ_ROW_DISPATCHER INFO: topic_session.cpp:516: TopicSession [1:7582947267131107193:2150] Create topic session, Path test_3_session_input/0, StartingMessageTimestamp 2025-12-12T12:28:09.997000Z, BufferSize 16000000, GetConsumerMode Without
2025-12-12T12:28:17.594069Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:28:17.594063Z :INFO: [local] [local] [b2d6cc01-dbf5c36d-455b5d21-34c9dfb5] Starting read session
2025-12-12T12:28:17.594076Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:28:17.594073Z :DEBUG: [local] [local] [b2d6cc01-dbf5c36d-455b5d21-34c9dfb5] Starting single session
2025-12-12T12:28:17.594130Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:28:17.594125Z :DEBUG: [local] [local] [b2d6cc01-dbf5c36d-455b5d21-34c9dfb5] [] In Reconnect, ReadSizeBudget = 8000000, ReadSizeServerDelta = 0
2025-12-12T12:28:17.594136Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:28:17.594135Z :DEBUG: [local] [local] [b2d6cc01-dbf5c36d-455b5d21-34c9dfb5] [] New values: ReadSizeBudget = 8000000, ReadSizeServerDelta = 0
2025-12-12T12:28:17.594141Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:28:17.594140Z :DEBUG: [local] [local] [b2d6cc01-dbf5c36d-455b5d21-34c9dfb5] [] Reconnecting session to cluster  in 0.000000s
2025-12-12T12:28:17.594870Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:466: TopicSession [1:7582947267131107193:2150] SubscribeOnNextEvent
2025-12-12T12:28:17.598916Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:28:17.598897Z :DEBUG: [local] [local] [b2d6cc01-dbf5c36d-455b5d21-34c9dfb5] [] Successfully connected. Initializing session
2025-12-12T12:28:17.600161Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:28:17.600153Z :INFO: [local] [local] [b2d6cc01-dbf5c36d-455b5d21-34c9dfb5] [] Got InitResponse. ReadSessionId: _1_7_15998983730198269979_v1
2025-12-12T12:28:17.600175Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:28:17.600173Z :DEBUG: [local] [local] [b2d6cc01-dbf5c36d-455b5d21-34c9dfb5] [] In ContinueReadingDataImpl, ReadSizeBudget = 8000000, ReadSizeServerDelta = 0
2025-12-12T12:28:17.600254Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:28:17.600250Z :DEBUG: [local] [local] [b2d6cc01-dbf5c36d-455b5d21-34c9dfb5] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 8000000
2025-12-12T12:28:17.601648Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:559: TopicSession [1:7582947267131107193:2150] TEvPqEventsReady
2025-12-12T12:28:17.601674Z :FQ_ROW_DISPATCHER DEBUG: topic_session.cpp:677: TopicSession [1:7582947267131107193:2150] StartPartitionSessionEvent received
2025-12-12T12:28:17.601678Z :FQ_ROW_DISPATCHER DEBUG: topic_session.cpp:685: TopicSession [1:7582947267131107193:2150] Confirm StartPartitionSession with offset (NULL)
2025-12-12T12:28:17.601691Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:28:17.601686Z :INFO: [local] [local] [b2d6cc01-dbf5c36d-455b5d21-34c9dfb5] [] Confirm partition stream create. Partition stream id: 1. Cluster: "-". Topic: "test_3_session_input". Partition: 0. Read offset: (NULL)
2025-12-12T12:28:17.601757Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:466: TopicSession [1:7582947267131107193:2150] SubscribeOnNextEvent
2025-12-12T12:28:17.602415Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:28:17.602409Z :DEBUG: [local] [local] [b2d6cc01-dbf5c36d-455b5d21-34c9dfb5] [] Got ReadResponse, serverBytesSize = 112, now ReadSizeBudget = 0, ReadSizeServerDelta = 7999888
2025-12-12T12:28:17.602446Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:28:17.602443Z :DEBUG: [local] [local] [b2d6cc01-dbf5c36d-455b5d21-34c9dfb5] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 7999888
2025-12-12T12:28:17.602501Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:28:17.602499Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (0-1)
2025-12-12T12:28:17.602512Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:28:17.602510Z :DEBUG: [local] [local] [b2d6cc01-dbf5c36d-455b5d21-34c9dfb5] [] Returning serverBytesSize = 112 to budget
2025-12-12T12:28:17.602515Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:28:17.602514Z :DEBUG: [local] [local] [b2d6cc01-dbf5c36d-455b5d21-34c9dfb5] [] In ContinueReadingDataImpl, ReadSizeBudget = 112, ReadSizeServerDelta = 7999888
2025-12-12T12:28:17.602555Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:28:17.602554Z :DEBUG: [local] [local] [b2d6cc01-dbf5c36d-455b5d21-34c9dfb5] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 8000000
2025-12-12T12:28:17.602589Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:559: TopicSession [1:7582947267131107193:2150] TEvPqEventsReady
2025-12-12T12:28:17.602610Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:28:17.602607Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-12-12T12:28:17.602617Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:28:17.602615Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (1-1)
2025-12-12T12:28:17.602628Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:28:17.602625Z :DEBUG: [local] [local] [b2d6cc01-dbf5c36d-455b5d21-34c9dfb5] [] The application data is transferred to the client. Number of messages 2, size 24 bytes
2025-12-12T12:28:17.602636Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:28:17.602634Z :DEBUG: [local] [local] [b2d6cc01-dbf5c36d-455b5d21-34c9dfb5] [] Returning serverBytesSize = 0 to budget
2025-12-12T12:28:17.602651Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:654: TopicSession [1:7582947267131107193:2150] Data received: Message { Data: "{"time":101}" Information: { Offset: 0 ProducerId: "" SeqNo: 0 CreateTime: 2025-12-12T12:28:13.587000Z WriteTime: 2025-12-12T12:28:13.587000Z MessageGroupId: "" Meta: { } MessageMeta: { } } Partition session id: 1 Topic: "test_3_session_input" Partition: 0 }
2025-12-12T12:28:17.602654Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:654: TopicSession [1:7582947267131107193:2150] Data received: Message { Data: "{"time":102}" Information: { Offset: 1 ProducerId: "" SeqNo: 0 CreateTime: 2025-12-12T12:28:13.587000Z WriteTime: 2025-12-12T12:28:13.592000Z MessageGroupId: "" Meta: { } MessageMeta: { } } Partition session id: 1 Topic: "test_3_session_input" Partition: 0 }
2025-12-12T12:28:17.602655Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:707: TopicSession [1:7582947267131107193:2150] SendToParsing, messages: 2
2025-12-12T12:28:17.602660Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:417: TTopicFormatHandler [json_each_row]: Send 2 messages to parser
2025-12-12T12:28:17.602664Z :FQ_ROW_DISPATCHER TRACE: json_parser.cpp:388: TJsonParser: Add 2 messages to parse
2025-12-12T12:28:17.602673Z :FQ_ROW_DISPATCHER TRACE: json_parser.cpp:454: TJsonParser: Do parsing, first offset: 0, values:
{"time":101}{"time":102}                                                                
2025-12-12T12:28:17.602678Z :FQ_ROW_DISPATCHER TRACE: json_parser.cpp:590: TJsonParser: Init parser, skipped 0, outputRowId 0 size 88
2025-12-12T12:28:17.602696Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:77: TTopicFormatHandler [json_each_row]: TParserHandler: Got parsed data, number rows: 2
2025-12-12T12:28:17.602699Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:614: TTopicFormatHandler [json_each_row]: Send 2 messages to programs, first offset: 0, last offset: 1
2025-12-12T12:28:17.602702Z :FQ_ROW_DISPATCHER TRACE: filters_set.cpp:34: TTopicFilters: ProcessData for 3 clients, number rows: 2
2025-12-12T12:28:17.602709Z :FQ_ROW_DISPATCHER TRACE: filters_set.cpp:223: TTopicFilters: Pass 2 rows to purecalc filter (client id: [3:7582947251119949753:2150])
2025-12-12T12:28:17.602712Z :FQ_ROW_DISPATCHER TRACE: purecalc_filter.cpp:408: TProgramRunHandler: ProcessData for 2 rows
2025-12-12T12:28:17.602715Z :FQ_ROW_DISPATCHER TRACE: purecalc_filter.cpp:411: TProgramRunHandler: Add 2 rows to client [3:7582947251119949753:2150] without processing
2025-12-12T12:28:17.602725Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:292: TTopicFormatHandler [json_each_row]: TClientHandler [3:7582947251119949753:2150]: OnBatchFinish, offset: 0, number rows: 1, row size: 12, watermark: (empty maybe)
2025-12-12T12:28:17.602729Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:198: TopicSession [1:7582947267131107193:2150] AddDataToClient to [3:7582947251119949753:2150], offset: 0, number rows: 1, row size: 12, watermark: (empty maybe)
2025-12-12T12:28:17.602731Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:936: TopicSession [1:7582947267131107193:2150] Send TEvNewDataArrived to [3:7582947251119949753:2150]
2025-12-12T12:28:17.602747Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:292: TTopicFormatHandler [json_each_row]: TClientHandler [3:7582947251119949753:2150]: OnBatchFinish, offset: 1, number rows: 1, row size: 4, watermark: (empty maybe)
2025-12-12T12:28:17.602749Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:198: TopicSession [1:7582947267131107193:2150] AddDataToClient to [3:7582947251119949753:2150], offset: 1, number rows: 1, row size: 4, watermark: (empty maybe)
2025-12-12T12:28:17.602754Z :FQ_ROW_DISPATCHER TRACE: filters_set.cpp:223: TTopicFilters: Pass 2 rows to purecalc filter (client id: [2:7582947270589275284:2161])
2025-12-12T12:28:17.602755Z :FQ_ROW_DISPATCHER TRACE: purecalc_filter.cpp:408: TProgramRunHandler: ProcessData for 2 rows
2025-12-12T12:28:17.602758Z :FQ_ROW_DISPATCHER TRACE: purecalc_filter.cpp:411: TProgramRunHandler: Add 2 rows to client [2:7582947270589275284:2161] without processing
2025-12-12T12:28:17.602775Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:292: TTopicFormatHandler [json_each_row]: TClientHandler [2:7582947270589275284:2161]: OnBatchFinish, offset: 0, number rows: 1, row size: 12, watermark: (empty maybe)
2025-12-12T12:28:17.602778Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:198: TopicSession [1:7582947267131107193:2150] AddDataToClient to [2:7582947270589275284:2161], offset: 0, number rows: 1, row size: 12, watermark: (empty maybe)
2025-12-12T12:28:17.602780Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:936: TopicSession [1:7582947267131107193:2150] Send TEvNewDataArrived to [2:7582947270589275284:2161]
2025-12-12T12:28:17.602781Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1081: RowDispatcher: Forward TEvNewDataArrived from [1:7582947267131107193:2150] to [3:7582947251119949753:2150] query id ptqudq7udhp59svrf658
2025-12-12T12:28:17.602783Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:292: TTopicFormatHandler [json_each_row]: TClientHandler [2:7582947270589275284:2161]: OnBatchFinish, offset: 1, number rows: 1, row size: 4, watermark: (empty maybe)
2025-12-12T12:28:17.602785Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:198: TopicSession [1:7582947267131107193:2150] AddDataToClient to [2:7582947270589275284:2161], offset: 1, number rows: 1, row size: 4, watermark: (empty maybe)
2025-12-12T12:28:17.602789Z :FQ_ROW_DISPATCHER TRACE: filters_set.cpp:223: TTopicFilters: Pass 2 rows to purecalc filter (client id: [2:7582947261999340665:2154])
2025-12-12T12:28:17.602790Z :FQ_ROW_DISPATCHER TRACE: purecalc_filter.cpp:408: TProgramRunHandler: ProcessData for 2 rows
2025-12-12T12:28:17.602792Z :FQ_ROW_DISPATCHER TRACE: purecalc_filter.cpp:411: TProgramRunHandler: Add 2 rows to client [2:7582947261999340665:2154] without processing
2025-12-12T12:28:17.602795Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:292: TTopicFormatHandler [json_each_row]: TClientHandler [2:7582947261999340665:2154]: OnBatchFinish, offset: 0, number rows: 1, row size: 12, watermark: (empty maybe)
2025-12-12T12:28:17.602797Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:198: TopicSession [1:7582947267131107193:2150] AddDataToClient to [2:7582947261999340665:2154], offset: 0, number rows: 1, row size: 12, watermark: (empty maybe)
2025-12-12T12:28:17.602798Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:936: TopicSession [1:7582947267131107193:2150] Send TEvNewDataArrived to [2:7582947261999340665:2154]
2025-12-12T12:28:17.602801Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:292: TTopicFormatHandler [json_each_row]: TClientHandler [2:7582947261999340665:2154]: OnBatchFinish, offset: 1, number rows: 1, row size: 4, watermark: (empty maybe)
2025-12-12T12:28:17.602803Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:198: TopicSession [1:7582947267131107193:2150] AddDataToClient to [2:7582947261999340665:2154], offset: 1, number rows: 1, row size: 4, watermark: (empty maybe)
2025-12-12T12:28:17.602807Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:622: TTopicFormatHandler [json_each_row]: Commit client [3:7582947251119949753:2150] offset 1
2025-12-12T12:28:17.602809Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:210: TopicSession [1:7582947267131107193:2150] UpdateClientOffset for [3:7582947251119949753:2150], new offset: 1
2025-12-12T12:28:17.602810Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:622: TTopicFormatHandler [json_each_row]: Commit client [2:7582947270589275284:2161] offset 1
2025-12-12T12:28:17.602812Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:210: TopicSession [1:7582947267131107193:2150] UpdateClientOffset for [2:7582947270589275284:2161], new offset: 1
2025-12-12T12:28:17.602814Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:622: TTopicFormatHandler [json_each_row]: Commit client [2:7582947261999340665:2154] offset 1
2025-12-12T12:28:17.602815Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1081: RowDispatcher: Forward TEvNewDataArrived from [1:7582947267131107193:2150] to [2:7582947270589275284:2161] query id ptqudq7udfcpbb5tnuo6
2025-12-12T12:28:17.602816Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:210: TopicSession [1:7582947267131107193:2150] UpdateClientOffset for [2:7582947261999340665:2154], new offset: 1
2025-12-12T12:28:17.602822Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:466: TopicSession [1:7582947267131107193:2150] SubscribeOnNextEvent
2025-12-12T12:28:17.602823Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1081: RowDispatcher: Forward TEvNewDataArrived from [1:7582947267131107193:2150] to [2:7582947261999340665:2154] query id ptqudq7udfu8nrrist3a
2025-12-12T12:28:17.607223Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:940: RowDispatcher: Received TEvGetNextBatch from [3:7582947251119949753:2150] part id 0 query id ptqudq7udhp59svrf658
2025-12-12T12:28:17.607266Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:940: RowDispatcher: Received TEvGetNextBatch from [2:7582947270589275284:2161] part id 0 query id ptqudq7udfcpbb5tnuo6
2025-12-12T12:28:17.607275Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:940: RowDispatcher: Received TEvGetNextBatch from [2:7582947261999340665:2154] part id 0 query id ptqudq7udfu8nrrist3a
2025-12-12T12:28:17.607287Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:588: TopicSession [1:7582947267131107193:2150] TEvGetNextBatch from [3:7582947251119949753:2150]
2025-12-12T12:28:17.607307Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:324: TTopicFormatHandler [json_each_row]: TClientHandler [3:7582947251119949753:2150]: FinishPacking, batch size: 16, number rows: 2
2025-12-12T12:28:17.607322Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:174: TTopicFormatHandler [json_each_row]: TClientHandler [3:7582947251119949753:2150]: ExtractClientData, number batches: 1
2025-12-12T12:28:17.607341Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:764: TopicSession [1:7582947267131107193:2150] SendData to [3:7582947251119949753:2150], batch size 1
2025-12-12T12:28:17.607356Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:457: TopicSession [1:7582947267131107193:2150] Skip SubscribeOnNextEvent, has ReadSession: true, IsWaitingEvents: 1
2025-12-12T12:28:17.607375Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:588: TopicSession [1:7582947267131107193:2150] TEvGetNextBatch from [2:7582947270589275284:2161]
2025-12-12T12:28:17.607379Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:324: TTopicFormatHandler [json_each_row]: TClientHandler [2:7582947270589275284:2161]: FinishPacking, batch size: 16, number rows: 2
2025-12-12T12:28:17.607384Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:174: TTopicFormatHandler [json_each_row]: TClientHandler [2:7582947270589275284:2161]: ExtractClientData, number batches: 1
2025-12-12T12:28:17.607389Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:764: TopicSession [1:7582947267131107193:2150] SendData to [2:7582947270589275284:2161], batch size 1
2025-12-12T12:28:17.607389Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1100: RowDispatcher: Forward TEvMessageBatch from [1:7582947267131107193:2150] to [3:7582947251119949753:2150] query id ptqudq7udhp59svrf658
2025-12-12T12:28:17.607393Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:457: TopicSession [1:7582947267131107193:2150] Skip SubscribeOnNextEvent, has ReadSession: true, IsWaitingEvents: 1
2025-12-12T12:28:17.607397Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:588: TopicSession [1:7582947267131107193:2150] TEvGetNextBatch from [2:7582947261999340665:2154]
2025-12-12T12:28:17.607402Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:324: TTopicFormatHandler [json_each_row]: TClientHandler [2:7582947261999340665:2154]: FinishPacking, batch size: 16, number rows: 2
2025-12-12T12:28:17.607405Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:174: TTopicFormatHandler [json_each_row]: TClientHandler [2:7582947261999340665:2154]: ExtractClientData, number batches: 1
2025-12-12T12:28:17.607408Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:764: TopicSession [1:7582947267131107193:2150] SendData to [2:7582947261999340665:2154], batch size 1
2025-12-12T12:28:17.607411Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:457: TopicSession [1:7582947267131107193:2150] Skip SubscribeOnNextEvent, has ReadSession: true, IsWaitingEvents: 1
2025-12-12T12:28:17.607416Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1100: RowDispatcher: Forward TEvMessageBatch from [1:7582947267131107193:2150] to [2:7582947270589275284:2161] query id ptqudq7udfcpbb5tnuo6
2025-12-12T12:28:17.607425Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1100: RowDispatcher: Forward TEvMessageBatch from [1:7582947267131107193:2150] to [2:7582947261999340665:2154] query id ptqudq7udfu8nrrist3a
2025-12-12T12:28:18.008187Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [2:7582947249114438546:2063]
2025-12-12T12:28:18.008208Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [2:7582947249114438546:2063]
2025-12-12T12:28:18.008212Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [2:7582947249114438546:2063]
2025-12-12T12:28:18.483834Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [3:7582947246824982252:2063]
2025-12-12T12:28:18.483851Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [3:7582947246824982252:2063]
2025-12-12T12:28:18.483855Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [3:7582947246824982252:2063]
2025-12-12T12:28:18.539090Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 85753069-84ac59d2-c006a4dd-96a2c7a612, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:28:18.543117Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:28:18.543125Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:28:18.553013Z :FQ_ROW_DISPATCHER INFO: coordinator.cpp:507: Coordinator: TEvCoordinatorRequest from [2:7582947270589275284:2161], test_3_session_input, partIds: 0
2025-12-12T12:28:18.553052Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:562: Coordinator: Send TEvCoordinatorResult to [2:7582947270589275284:2161]
2025-12-12T12:28:18.553102Z :FQ_ROW_DISPATCHER INFO: coordinator.cpp:507: Coordinator: TEvCoordinatorRequest from [2:7582947261999340665:2154], test_3_session_input, partIds: 0
2025-12-12T12:28:18.553114Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:562: Coordinator: Send TEvCoordinatorResult to [2:7582947261999340665:2154]
2025-12-12T12:28:18.553415Z :FQ_ROW_DISPATCHER INFO: coordinator.cpp:507: Coordinator: TEvCoordinatorRequest from [3:7582947251119949753:2150], test_3_session_input, partIds: 0
2025-12-12T12:28:18.553447Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:562: Coordinator: Send TEvCoordinatorResult to [3:7582947251119949753:2150]
2025-12-12T12:28:18.555415Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:952: TopicSession [1:7582947267131107193:2150] SendStatistics
2025-12-12T12:28:18.555449Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1234: RowDispatcher: TEvSessionStatistic from [1:7582947267131107193:2150]
2025-12-12T12:28:18.595166Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:28:18.595151Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:test_3_session_input:0:1:1:0
2025-12-12T12:28:18.595190Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:28:18.595188Z :INFO: [local] [local] [b2d6cc01-dbf5c36d-455b5d21-34c9dfb5] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1001 BytesRead: 24 MessagesRead: 2 BytesReadCompressed: 24 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:28:19.538629Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582947245656270544:2092]
2025-12-12T12:28:19.538660Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:28:19.538696Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582947245656270488:2063]
2025-12-12T12:28:19.538704Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582947245656270488:2063]
2025-12-12T12:28:19.538707Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582947245656270488:2063]
2025-12-12T12:28:19.538723Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:28:19.539504Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 85753069-84ac59d2-c006a4dd-96a2c7a613, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:28:19.544006Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:28:19.544020Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:28:19.917936Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:1001: RowDispatcher: Received TEvStopSession from [3:7582947251119949753:2150] topic test_3_session_input query id ptqudq7udhp59svrf658
2025-12-12T12:28:19.917969Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:1016: RowDispatcher: DeleteConsumer, readActorId [3:7582947251119949753:2150] query id ptqudq7udhp59svrf658, partitions size 1
2025-12-12T12:28:19.918012Z :FQ_ROW_DISPATCHER DEBUG: topic_session.cpp:831: TopicSession [1:7582947267131107193:2150] TEvStopSession from [3:7582947251119949753:2150] topicPath test_3_session_input clients count 3
2025-12-12T12:28:19.918019Z :FQ_ROW_DISPATCHER DEBUG: format_handler.cpp:477: TTopicFormatHandler [json_each_row]: Remove client with id [3:7582947251119949753:2150]
2025-12-12T12:28:19.918023Z :FQ_ROW_DISPATCHER TRACE: filters_set.cpp:94: TTopicFilters: Remove program with client id [3:7582947251119949753:2150]
2025-12-12T12:28:19.918044Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:457: TopicSession [1:7582947267131107193:2150] Skip SubscribeOnNextEvent, has ReadSession: true, IsWaitingEvents: 1
2025-12-12T12:28:20.009055Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [2:7582947249114438546:2063]
2025-12-12T12:28:20.009071Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [2:7582947249114438546:2063]
2025-12-12T12:28:20.009075Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [2:7582947249114438546:2063]
2025-12-12T12:28:20.357507Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:28:20.357495Z :DEBUG: [local] [local] [b2d6cc01-dbf5c36d-455b5d21-34c9dfb5] [] Got ReadResponse, serverBytesSize = 96, now ReadSizeBudget = 0, ReadSizeServerDelta = 7999904
2025-12-12T12:28:20.357554Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:28:20.357552Z :DEBUG: [local] [local] [b2d6cc01-dbf5c36d-455b5d21-34c9dfb5] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 7999904
2025-12-12T12:28:20.357598Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:28:20.357595Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (2-3)
2025-12-12T12:28:20.357604Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:28:20.357601Z :DEBUG: [local] [local] [b2d6cc01-dbf5c36d-455b5d21-34c9dfb5] [] Returning serverBytesSize = 96 to budget
2025-12-12T12:28:20.357609Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:28:20.357607Z :DEBUG: [local] [local] [b2d6cc01-dbf5c36d-455b5d21-34c9dfb5] [] In ContinueReadingDataImpl, ReadSizeBudget = 96, ReadSizeServerDelta = 7999904
2025-12-12T12:28:20.357678Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:28:20.357676Z :DEBUG: [local] [local] [b2d6cc01-dbf5c36d-455b5d21-34c9dfb5] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 8000000
2025-12-12T12:28:20.357849Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:559: TopicSession [1:7582947267131107193:2150] TEvPqEventsReady
2025-12-12T12:28:20.357892Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:28:20.357886Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (2-2)
2025-12-12T12:28:20.357901Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:28:20.357899Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 1} (3-3)
2025-12-12T12:28:20.357913Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:28:20.357910Z :DEBUG: [local] [local] [b2d6cc01-dbf5c36d-455b5d21-34c9dfb5] [] The application data is transferred to the client. Number of messages 2, size 24 bytes
2025-12-12T12:28:20.357924Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:28:20.357922Z :DEBUG: [local] [local] [b2d6cc01-dbf5c36d-455b5d21-34c9dfb5] [] Returning serverBytesSize = 0 to budget
2025-12-12T12:28:20.357942Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:654: TopicSession [1:7582947267131107193:2150] Data received: Message { Data: "{"time":103}" Information: { Offset: 2 ProducerId: "" SeqNo: 0 CreateTime: 2025-12-12T12:28:20.355000Z WriteTime: 2025-12-12T12:28:20.355000Z MessageGroupId: "" Meta: { } MessageMeta: { } } Partition session id: 1 Topic: "test_3_session_input" Partition: 0 }
2025-12-12T12:28:20.357952Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:654: TopicSession [1:7582947267131107193:2150] Data received: Message { Data: "{"time":104}" Information: { Offset: 3 ProducerId: "" SeqNo: 0 CreateTime: 2025-12-12T12:28:20.355000Z WriteTime: 2025-12-12T12:28:20.355000Z MessageGroupId: "" Meta: { } MessageMeta: { } } Partition session id: 1 Topic: "test_3_session_input" Partition: 0 }
2025-12-12T12:28:20.357954Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:707: TopicSession [1:7582947267131107193:2150] SendToParsing, messages: 2
2025-12-12T12:28:20.357958Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:417: TTopicFormatHandler [json_each_row]: Send 2 messages to parser
2025-12-12T12:28:20.357962Z :FQ_ROW_DISPATCHER TRACE: json_parser.cpp:388: TJsonParser: Add 2 messages to parse
2025-12-12T12:28:20.357970Z :FQ_ROW_DISPATCHER TRACE: json_parser.cpp:454: TJsonParser: Do parsing, first offset: 2, values:
{"time":103}{"time":104}                                                                
2025-12-12T12:28:20.357973Z :FQ_ROW_DISPATCHER TRACE: json_parser.cpp:590: TJsonParser: Init parser, skipped 0, outputRowId 0 size 88
2025-12-12T12:28:20.357987Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:77: TTopicFormatHandler [json_each_row]: TParserHandler: Got parsed data, number rows: 2
2025-12-12T12:28:20.357994Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:614: TTopicFormatHandler [json_each_row]: Send 2 messages to programs, first offset: 2, last offset: 3
2025-12-12T12:28:20.357999Z :FQ_ROW_DISPATCHER TRACE: filters_set.cpp:34: TTopicFilters: ProcessData for 2 clients, number rows: 2
2025-12-12T12:28:20.358005Z :FQ_ROW_DISPATCHER TRACE: filters_set.cpp:223: TTopicFilters: Pass 2 rows to purecalc filter (client id: [2:7582947270589275284:2161])
2025-12-12T12:28:20.358008Z :FQ_ROW_DISPATCHER TRACE: purecalc_filter.cpp:408: TProgramRunHandler: ProcessData for 2 rows
2025-12-12T12:28:20.358010Z :FQ_ROW_DISPATCHER TRACE: purecalc_filter.cpp:411: TProgramRunHandler: Add 2 rows to client [2:7582947270589275284:2161] without processing
2025-12-12T12:28:20.358036Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:292: TTopicFormatHandler [json_each_row]: TClientHandler [2:7582947270589275284:2161]: OnBatchFinish, offset: 2, number rows: 1, row size: 12, watermark: (empty maybe)
2025-12-12T12:28:20.358044Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:198: TopicSession [1:7582947267131107193:2150] AddDataToClient to [2:7582947270589275284:2161], offset: 2, number rows: 1, row size: 12, watermark: (empty maybe)
2025-12-12T12:28:20.358047Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:936: TopicSession [1:7582947267131107193:2150] Send TEvNewDataArrived to [2:7582947270589275284:2161]
2025-12-12T12:28:20.358059Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:292: TTopicFormatHandler [json_each_row]: TClientHandler [2:7582947270589275284:2161]: OnBatchFinish, offset: 3, number rows: 1, row size: 4, watermark: (empty maybe)
2025-12-12T12:28:20.358066Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:198: TopicSession [1:7582947267131107193:2150] AddDataToClient to [2:7582947270589275284:2161], offset: 3, number rows: 1, row size: 4, watermark: (empty maybe)
2025-12-12T12:28:20.358069Z :FQ_ROW_DISPATCHER TRACE: filters_set.cpp:223: TTopicFilters: Pass 2 rows to purecalc filter (client id: [2:7582947261999340665:2154])
2025-12-12T12:28:20.358070Z :FQ_ROW_DISPATCHER TRACE: purecalc_filter.cpp:408: TProgramRunHandler: ProcessData for 2 rows
2025-12-12T12:28:20.358072Z :FQ_ROW_DISPATCHER TRACE: purecalc_filter.cpp:411: TProgramRunHandler: Add 2 rows to client [2:7582947261999340665:2154] without processing
2025-12-12T12:28:20.358082Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:292: TTopicFormatHandler [json_each_row]: TClientHandler [2:7582947261999340665:2154]: OnBatchFinish, offset: 2, number rows: 1, row size: 12, watermark: (empty maybe)
2025-12-12T12:28:20.358085Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:198: TopicSession [1:7582947267131107193:2150] AddDataToClient to [2:7582947261999340665:2154], offset: 2, number rows: 1, row size: 12, watermark: (empty maybe)
2025-12-12T12:28:20.358083Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1081: RowDispatcher: Forward TEvNewDataArrived from [1:7582947267131107193:2150] to [2:7582947270589275284:2161] query id ptqudq7udfcpbb5tnuo6
2025-12-12T12:28:20.358086Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:936: TopicSession [1:7582947267131107193:2150] Send TEvNewDataArrived to [2:7582947261999340665:2154]
2025-12-12T12:28:20.358089Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:292: TTopicFormatHandler [json_each_row]: TClientHandler [2:7582947261999340665:2154]: OnBatchFinish, offset: 3, number rows: 1, row size: 4, watermark: (empty maybe)
2025-12-12T12:28:20.358091Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:198: TopicSession [1:7582947267131107193:2150] AddDataToClient to [2:7582947261999340665:2154], offset: 3, number rows: 1, row size: 4, watermark: (empty maybe)
2025-12-12T12:28:20.358094Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:622: TTopicFormatHandler [json_each_row]: Commit client [2:7582947270589275284:2161] offset 3
2025-12-12T12:28:20.358097Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:210: TopicSession [1:7582947267131107193:2150] UpdateClientOffset for [2:7582947270589275284:2161], new offset: 3
2025-12-12T12:28:20.358099Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:622: TTopicFormatHandler [json_each_row]: Commit client [2:7582947261999340665:2154] offset 3
2025-12-12T12:28:20.358101Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:210: TopicSession [1:7582947267131107193:2150] UpdateClientOffset for [2:7582947261999340665:2154], new offset: 3
2025-12-12T12:28:20.358107Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:466: TopicSession [1:7582947267131107193:2150] SubscribeOnNextEvent
2025-12-12T12:28:20.358108Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1081: RowDispatcher: Forward TEvNewDataArrived from [1:7582947267131107193:2150] to [2:7582947261999340665:2154] query id ptqudq7udfu8nrrist3a
2025-12-12T12:28:20.358502Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:940: RowDispatcher: Received TEvGetNextBatch from [2:7582947270589275284:2161] part id 0 query id ptqudq7udfcpbb5tnuo6
2025-12-12T12:28:20.358546Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:940: RowDispatcher: Received TEvGetNextBatch from [2:7582947261999340665:2154] part id 0 query id ptqudq7udfu8nrrist3a
2025-12-12T12:28:20.358563Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:588: TopicSession [1:7582947267131107193:2150] TEvGetNextBatch from [2:7582947270589275284:2161]
2025-12-12T12:28:20.358572Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:324: TTopicFormatHandler [json_each_row]: TClientHandler [2:7582947270589275284:2161]: FinishPacking, batch size: 16, number rows: 2
2025-12-12T12:28:20.358582Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:174: TTopicFormatHandler [json_each_row]: TClientHandler [2:7582947270589275284:2161]: ExtractClientData, number batches: 1
2025-12-12T12:28:20.358589Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:764: TopicSession [1:7582947267131107193:2150] SendData to [2:7582947270589275284:2161], batch size 1
2025-12-12T12:28:20.358598Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:457: TopicSession [1:7582947267131107193:2150] Skip SubscribeOnNextEvent, has ReadSession: true, IsWaitingEvents: 1
2025-12-12T12:28:20.358602Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:588: TopicSession [1:7582947267131107193:2150] TEvGetNextBatch from [2:7582947261999340665:2154]
2025-12-12T12:28:20.358604Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:324: TTopicFormatHandler [json_each_row]: TClientHandler [2:7582947261999340665:2154]: FinishPacking, batch size: 16, number rows: 2
2025-12-12T12:28:20.358607Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:174: TTopicFormatHandler [json_each_row]: TClientHandler [2:7582947261999340665:2154]: ExtractClientData, number batches: 1
2025-12-12T12:28:20.358611Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:764: TopicSession [1:7582947267131107193:2150] SendData to [2:7582947261999340665:2154], batch size 1
2025-12-12T12:28:20.358611Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1100: RowDispatcher: Forward TEvMessageBatch from [1:7582947267131107193:2150] to [2:7582947270589275284:2161] query id ptqudq7udfcpbb5tnuo6
2025-12-12T12:28:20.358613Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:457: TopicSession [1:7582947267131107193:2150] Skip SubscribeOnNextEvent, has ReadSession: true, IsWaitingEvents: 1
2025-12-12T12:28:20.358624Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1100: RowDispatcher: Forward TEvMessageBatch from [1:7582947267131107193:2150] to [2:7582947261999340665:2154] query id ptqudq7udfu8nrrist3a
2025-12-12T12:28:20.484823Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [3:7582947246824982252:2063]
2025-12-12T12:28:20.484843Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [3:7582947246824982252:2063]
2025-12-12T12:28:20.484851Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [3:7582947246824982252:2063]
2025-12-12T12:28:20.539953Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 85753069-84ac59d2-c006a4dd-96a2c7a614, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:28:20.544113Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:28:20.544137Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:28:20.556332Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:952: TopicSession [1:7582947267131107193:2150] SendStatistics
2025-12-12T12:28:20.556368Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1234: RowDispatcher: TEvSessionStatistic from [1:7582947267131107193:2150]
2025-12-12T12:28:20.559378Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1059: RowDispatcher: No consumer with EventQueueId = 1
2025-12-12T12:28:21.539383Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582947245656270544:2092]
2025-12-12T12:28:21.539405Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:28:21.539441Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582947245656270488:2063]
2025-12-12T12:28:21.539445Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582947245656270488:2063]
2025-12-12T12:28:21.539449Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582947245656270488:2063]
2025-12-12T12:28:21.539461Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:28:21.540409Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 85753069-84ac59d2-c006a4dd-96a2c7a615, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:28:21.548282Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:28:21.548294Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:28:22.010746Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [2:7582947249114438546:2063]
2025-12-12T12:28:22.010762Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [2:7582947249114438546:2063]
2025-12-12T12:28:22.010766Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [2:7582947249114438546:2063]
2025-12-12T12:28:22.487097Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [3:7582947246824982252:2063]
2025-12-12T12:28:22.487115Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [3:7582947246824982252:2063]
2025-12-12T12:28:22.487119Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [3:7582947246824982252:2063]
2025-12-12T12:28:22.543144Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-12-12T12:28:22.543291Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 85753069-84ac59d2-c006a4dd-96a2c7a616, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:28:22.551143Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:28:22.551173Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:28:22.551772Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:389: Send NodeInfo with size: 2 to DynamicNameserver
2025-12-12T12:28:22.557880Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:952: TopicSession [1:7582947267131107193:2150] SendStatistics
2025-12-12T12:28:22.557929Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1234: RowDispatcher: TEvSessionStatistic from [1:7582947267131107193:2150]
2025-12-12T12:28:22.558238Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1067: RowDispatcher: Send TEvHeartbeat to [2:7582947261999340665:2154] query id ptqudq7udfu8nrrist3a
2025-12-12T12:28:22.559643Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:962: RowDispatcher: Received TEvHeartbeat from [2:7582947261999340665:2154], part id 0 query id ptqudq7udfu8nrrist3a
2025-12-12T12:28:22.920744Z :FQ_ROW_DISPATCHER INFO: coordinator.cpp:507: Coordinator: TEvCoordinatorRequest from [3:7582947306954524710:2204], test_3_session_input, partIds: 0
2025-12-12T12:28:22.920772Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:562: Coordinator: Send TEvCoordinatorResult to [3:7582947306954524710:2204]
2025-12-12T12:28:22.921833Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:853: RowDispatcher: Received TEvStartSession from [3:7582947306954524710:2204], read group ptcudq7udianfb5k0f2l, topicPath test_3_session_input part id 0 query id ptqudq7udhp59svrf658 cookie 1
2025-12-12T12:28:22.921909Z :FQ_ROW_DISPATCHER INFO: topic_session.cpp:799: TopicSession [1:7582947267131107193:2150] New client: read actor id [3:7582947306954524710:2204], predicate: , watermark expr: , offset: 2
2025-12-12T12:28:22.921924Z :FQ_ROW_DISPATCHER DEBUG: format_handler.cpp:440: TTopicFormatHandler [json_each_row]: Add client with id [3:7582947306954524710:2204]
2025-12-12T12:28:22.921927Z :FQ_ROW_DISPATCHER DEBUG: format_handler.cpp:444: TTopicFormatHandler [json_each_row]: Parser was flushed due to new historical offset 2 (previous parser offset: 3)
2025-12-12T12:28:22.921981Z :FQ_ROW_DISPATCHER TRACE: purecalc_filter.cpp:439: GenerateSql: No sql was generated
2025-12-12T12:28:22.921985Z :FQ_ROW_DISPATCHER TRACE: filters_set.cpp:116: TTopicFilters: Create program with client id [3:7582947306954524710:2204]
2025-12-12T12:28:22.921990Z :FQ_ROW_DISPATCHER TRACE: filters_set.cpp:110: TTopicFilters: Start program with client id [3:7582947306954524710:2204]
2025-12-12T12:28:22.921993Z :FQ_ROW_DISPATCHER INFO: topic_session.cpp:783: TopicSession [1:7582947267131107193:2150] New client has less offset (2) than the last message (3), stop (restart) topic session
2025-12-12T12:28:22.921994Z :FQ_ROW_DISPATCHER DEBUG: topic_session.cpp:924: TopicSession [1:7582947267131107193:2150] Close read session
2025-12-12T12:28:22.922009Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:28:22.922003Z :INFO: [local] [local] [b2d6cc01-dbf5c36d-455b5d21-34c9dfb5] Closing read session. Close timeout: 0.000000s
2025-12-12T12:28:22.922021Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:28:22.922019Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:test_3_session_input:0:1:3:0
2025-12-12T12:28:22.922029Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:28:22.922028Z :INFO: [local] [local] [b2d6cc01-dbf5c36d-455b5d21-34c9dfb5] Counters: { Errors: 0 CurrentSessionLifetimeMs: 5327 BytesRead: 48 MessagesRead: 4 BytesReadCompressed: 48 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:28:22.922047Z :YDB_SDK NOTICE: actor.cpp:37: 2025-12-12T12:28:22.922043Z :NOTICE: [local] [local] [b2d6cc01-dbf5c36d-455b5d21-34c9dfb5] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Close with zero timeout " }
2025-12-12T12:28:22.922055Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:28:22.922053Z :DEBUG: [local] [local] [b2d6cc01-dbf5c36d-455b5d21-34c9dfb5] [] Abort session to cluster
2025-12-12T12:28:22.922257Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:28:22.922254Z :INFO: [local] [local] [b2d6cc01-dbf5c36d-455b5d21-34c9dfb5] Closing read session. Close timeout: 0.000000s
2025-12-12T12:28:22.922271Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:28:22.922270Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:test_3_session_input:0:1:3:0
2025-12-12T12:28:22.922275Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:28:22.922274Z :INFO: [local] [local] [b2d6cc01-dbf5c36d-455b5d21-34c9dfb5] Counters: { Errors: 0 CurrentSessionLifetimeMs: 5328 BytesRead: 48 MessagesRead: 4 BytesReadCompressed: 48 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:28:22.922285Z :YDB_SDK NOTICE: actor.cpp:37: 2025-12-12T12:28:22.922282Z :NOTICE: [local] [local] [b2d6cc01-dbf5c36d-455b5d21-34c9dfb5] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T12:28:22.922314Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:952: TopicSession [1:7582947267131107193:2150] SendStatistics
2025-12-12T12:28:22.922345Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:559: TopicSession [1:7582947267131107193:2150] TEvPqEventsReady
2025-12-12T12:28:22.922348Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:457: TopicSession [1:7582947267131107193:2150] Skip SubscribeOnNextEvent, has ReadSession: false, IsWaitingEvents: 0
2025-12-12T12:28:22.922356Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1234: RowDispatcher: TEvSessionStatistic from [1:7582947267131107193:2150]
2025-12-12T12:28:23.104064Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1067: RowDispatcher: Send TEvHeartbeat to [2:7582947270589275284:2161] query id ptqudq7udfcpbb5tnuo6
2025-12-12T12:28:23.105569Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:962: RowDispatcher: Received TEvHeartbeat from [2:7582947270589275284:2161], part id 0 query id ptqudq7udfcpbb5tnuo6
2025-12-12T12:28:23.540257Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582947245656270544:2092]
2025-12-12T12:28:23.540281Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:28:23.540301Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582947245656270488:2063]
2025-12-12T12:28:23.540307Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582947245656270488:2063]
2025-12-12T12:28:23.540311Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582947245656270488:2063]
2025-12-12T12:28:23.540327Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:28:23.543378Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 85753069-84ac59d2-c006a4dd-96a2c7a617, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:28:23.547586Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:28:23.547597Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:28:24.010899Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [2:7582947249114438546:2063]
2025-12-12T12:28:24.010921Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [2:7582947249114438546:2063]
2025-12-12T12:28:24.010925Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [2:7582947249114438546:2063]
2025-12-12T12:28:24.486473Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [3:7582947246824982252:2063]
2025-12-12T12:28:24.486491Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [3:7582947246824982252:2063]
2025-12-12T12:28:24.486494Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [3:7582947246824982252:2063]
2025-12-12T12:28:24.543791Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 85753069-84ac59d2-c006a4dd-96a2c7a618, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:28:24.552064Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:28:24.552080Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:28:24.558107Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:952: TopicSession [1:7582947267131107193:2150] SendStatistics
2025-12-12T12:28:24.558142Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1234: RowDispatcher: TEvSessionStatistic from [1:7582947267131107193:2150]
2025-12-12T12:28:24.559115Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:962: RowDispatcher: Received TEvHeartbeat from [2:7582947261999340665:2154], part id 0 query id ptqudq7udfu8nrrist3a
2025-12-12T12:28:24.922710Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:962: RowDispatcher: Received TEvHeartbeat from [3:7582947306954524710:2204], part id 0 query id ptqudq7udhp59svrf658
2025-12-12T12:28:25.108409Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:962: RowDispatcher: Received TEvHeartbeat from [2:7582947270589275284:2161], part id 0 query id ptqudq7udfcpbb5tnuo6
2025-12-12T12:28:25.541155Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582947245656270544:2092]
2025-12-12T12:28:25.541184Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:28:25.541195Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582947245656270488:2063]
2025-12-12T12:28:25.541200Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582947245656270488:2063]
2025-12-12T12:28:25.541203Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582947245656270488:2063]
2025-12-12T12:28:25.541214Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:28:25.544225Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 85753069-84ac59d2-c006a4dd-96a2c7a619, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:28:25.550732Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:28:25.550746Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:28:26.015484Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [2:7582947249114438546:2063]
2025-12-12T12:28:26.015499Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [2:7582947249114438546:2063]
2025-12-12T12:28:26.015503Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [2:7582947249114438546:2063]
2025-12-12T12:28:26.490934Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [3:7582947246824982252:2063]
2025-12-12T12:28:26.490952Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [3:7582947246824982252:2063]
2025-12-12T12:28:26.490955Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [3:7582947246824982252:2063]
2025-12-12T12:28:26.544712Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 85753069-84ac59d2-c006a4dd-96a2c7a620, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:28:26.549320Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:28:26.549334Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:28:26.559024Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:952: TopicSession [1:7582947267131107193:2150] SendStatistics
2025-12-12T12:28:26.559073Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1234: RowDispatcher: TEvSessionStatistic from [1:7582947267131107193:2150]
2025-12-12T12:28:26.559602Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:962: RowDispatcher: Received TEvHeartbeat from [2:7582947261999340665:2154], part id 0 query id ptqudq7udfu8nrrist3a
2025-12-12T12:28:26.923621Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1067: RowDispatcher: Send TEvHeartbeat to [3:7582947306954524710:2204] query id ptqudq7udhp59svrf658
2025-12-12T12:28:26.923949Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:962: RowDispatcher: Received TEvHeartbeat from [3:7582947306954524710:2204], part id 0 query id ptqudq7udhp59svrf658
2025-12-12T12:28:27.107564Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:962: RowDispatcher: Received TEvHeartbeat from [2:7582947270589275284:2161], part id 0 query id ptqudq7udfcpbb5tnuo6
2025-12-12T12:28:27.542287Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582947245656270544:2092]
2025-12-12T12:28:27.542303Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:28:27.542341Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582947245656270488:2063]
2025-12-12T12:28:27.542344Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582947245656270488:2063]
2025-12-12T12:28:27.542348Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582947245656270488:2063]
2025-12-12T12:28:27.542358Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:28:27.547087Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-12-12T12:28:27.547668Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 85753069-84ac59d2-c006a4dd-96a2c7a621, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:28:27.567201Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:28:27.567216Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:28:27.570222Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:389: Send NodeInfo with size: 2 to DynamicNameserver
2025-12-12T12:28:27.922120Z :FQ_ROW_DISPATCHER INFO: topic_session.cpp:516: TopicSession [1:7582947267131107193:2150] Create topic session, Path test_3_session_input/0, StartingMessageTimestamp 2025-12-12T12:28:09.997000Z, BufferSize 16000000, GetConsumerMode Without
2025-12-12T12:28:27.922170Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:28:27.922165Z :INFO: [local] [local] [b5c90217-98887956-5062db00-b0594cfd] Starting read session
2025-12-12T12:28:27.922177Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:28:27.922174Z :DEBUG: [local] [local] [b5c90217-98887956-5062db00-b0594cfd] Starting single session
2025-12-12T12:28:27.922234Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:28:27.922231Z :DEBUG: [local] [local] [b5c90217-98887956-5062db00-b0594cfd] [] In Reconnect, ReadSizeBudget = 8000000, ReadSizeServerDelta = 0
2025-12-12T12:28:27.922244Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:28:27.922240Z :DEBUG: [local] [local] [b5c90217-98887956-5062db00-b0594cfd] [] New values: ReadSizeBudget = 8000000, ReadSizeServerDelta = 0
2025-12-12T12:28:27.922249Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:28:27.922247Z :DEBUG: [local] [local] [b5c90217-98887956-5062db00-b0594cfd] [] Reconnecting session to cluster  in 0.000000s
2025-12-12T12:28:27.922533Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:466: TopicSession [1:7582947267131107193:2150] SubscribeOnNextEvent
2025-12-12T12:28:27.923085Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:28:27.923071Z :DEBUG: [local] [local] [b5c90217-98887956-5062db00-b0594cfd] [] Successfully connected. Initializing session
2025-12-12T12:28:27.931190Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:28:27.931179Z :INFO: [local] [local] [b5c90217-98887956-5062db00-b0594cfd] [] Got InitResponse. ReadSessionId: _1_14_16300523726865717540_v1
2025-12-12T12:28:27.931201Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:28:27.931198Z :DEBUG: [local] [local] [b5c90217-98887956-5062db00-b0594cfd] [] In ContinueReadingDataImpl, ReadSizeBudget = 8000000, ReadSizeServerDelta = 0
2025-12-12T12:28:27.931280Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:28:27.931277Z :DEBUG: [local] [local] [b5c90217-98887956-5062db00-b0594cfd] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 8000000
2025-12-12T12:28:27.938377Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:559: TopicSession [1:7582947267131107193:2150] TEvPqEventsReady
2025-12-12T12:28:27.938396Z :FQ_ROW_DISPATCHER DEBUG: topic_session.cpp:677: TopicSession [1:7582947267131107193:2150] StartPartitionSessionEvent received
2025-12-12T12:28:27.938400Z :FQ_ROW_DISPATCHER DEBUG: topic_session.cpp:685: TopicSession [1:7582947267131107193:2150] Confirm StartPartitionSession with offset 2
2025-12-12T12:28:27.938415Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:28:27.938410Z :INFO: [local] [local] [b5c90217-98887956-5062db00-b0594cfd] [] Confirm partition stream create. Partition stream id: 1. Cluster: "-". Topic: "test_3_session_input". Partition: 0. Read offset: 2
2025-12-12T12:28:27.938462Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:466: TopicSession [1:7582947267131107193:2150] SubscribeOnNextEvent
2025-12-12T12:28:27.940573Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:28:27.940565Z :DEBUG: [local] [local] [b5c90217-98887956-5062db00-b0594cfd] [] Got ReadResponse, serverBytesSize = 96, now ReadSizeBudget = 0, ReadSizeServerDelta = 7999904
2025-12-12T12:28:27.940611Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:28:27.940609Z :DEBUG: [local] [local] [b5c90217-98887956-5062db00-b0594cfd] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 7999904
2025-12-12T12:28:27.940665Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:28:27.940663Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (2-3)
2025-12-12T12:28:27.940677Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:28:27.940673Z :DEBUG: [local] [local] [b5c90217-98887956-5062db00-b0594cfd] [] Returning serverBytesSize = 96 to budget
2025-12-12T12:28:27.940681Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:28:27.940679Z :DEBUG: [local] [local] [b5c90217-98887956-5062db00-b0594cfd] [] In ContinueReadingDataImpl, ReadSizeBudget = 96, ReadSizeServerDelta = 7999904
2025-12-12T12:28:27.940715Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:28:27.940712Z :DEBUG: [local] [local] [b5c90217-98887956-5062db00-b0594cfd] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 8000000
2025-12-12T12:28:27.940814Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:559: TopicSession [1:7582947267131107193:2150] TEvPqEventsReady
2025-12-12T12:28:27.940828Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:28:27.940826Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (2-2)
2025-12-12T12:28:27.940835Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:28:27.940833Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 1} (3-3)
2025-12-12T12:28:27.940844Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:28:27.940842Z :DEBUG: [local] [local] [b5c90217-98887956-5062db00-b0594cfd] [] The application data is transferred to the client. Number of messages 2, size 24 bytes
2025-12-12T12:28:27.940849Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:28:27.940847Z :DEBUG: [local] [local] [b5c90217-98887956-5062db00-b0594cfd] [] Returning serverBytesSize = 0 to budget
2025-12-12T12:28:27.940864Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:654: TopicSession [1:7582947267131107193:2150] Data received: Message { Data: "{"time":103}" Information: { Offset: 2 ProducerId: "" SeqNo: 0 CreateTime: 2025-12-12T12:28:20.355000Z WriteTime: 2025-12-12T12:28:20.355000Z MessageGroupId: "" Meta: { } MessageMeta: { } } Partition session id: 1 Topic: "test_3_session_input" Partition: 0 }
2025-12-12T12:28:27.940867Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:654: TopicSession [1:7582947267131107193:2150] Data received: Message { Data: "{"time":104}" Information: { Offset: 3 ProducerId: "" SeqNo: 0 CreateTime: 2025-12-12T12:28:20.355000Z WriteTime: 2025-12-12T12:28:20.355000Z MessageGroupId: "" Meta: { } MessageMeta: { } } Partition session id: 1 Topic: "test_3_session_input" Partition: 0 }
2025-12-12T12:28:27.940869Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:707: TopicSession [1:7582947267131107193:2150] SendToParsing, messages: 2
2025-12-12T12:28:27.940873Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:417: TTopicFormatHandler [json_each_row]: Send 2 messages to parser
2025-12-12T12:28:27.940877Z :FQ_ROW_DISPATCHER TRACE: json_parser.cpp:388: TJsonParser: Add 2 messages to parse
2025-12-12T12:28:27.940886Z :FQ_ROW_DISPATCHER TRACE: json_parser.cpp:454: TJsonParser: Do parsing, first offset: 2, values:
{"time":103}{"time":104}                                                                
2025-12-12T12:28:27.940889Z :FQ_ROW_DISPATCHER TRACE: json_parser.cpp:590: TJsonParser: Init parser, skipped 0, outputRowId 0 size 88
2025-12-12T12:28:27.940918Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:77: TTopicFormatHandler [json_each_row]: TParserHandler: Got parsed data, number rows: 2
2025-12-12T12:28:27.940922Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:614: TTopicFormatHandler [json_each_row]: Send 2 messages to programs, first offset: 2, last offset: 3
2025-12-12T12:28:27.940925Z :FQ_ROW_DISPATCHER TRACE: filters_set.cpp:34: TTopicFilters: ProcessData for 3 clients, number rows: 2
2025-12-12T12:28:27.940931Z :FQ_ROW_DISPATCHER TRACE: filters_set.cpp:223: TTopicFilters: Pass 2 rows to purecalc filter (client id: [3:7582947306954524710:2204])
2025-12-12T12:28:27.940933Z :FQ_ROW_DISPATCHER TRACE: purecalc_filter.cpp:408: TProgramRunHandler: ProcessData for 2 rows
2025-12-12T12:28:27.940935Z :FQ_ROW_DISPATCHER TRACE: purecalc_filter.cpp:411: TProgramRunHandler: Add 2 rows to client [3:7582947306954524710:2204] without processing
2025-12-12T12:28:27.940946Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:292: TTopicFormatHandler [json_each_row]: TClientHandler [3:7582947306954524710:2204]: OnBatchFinish, offset: 2, number rows: 1, row size: 12, watermark: (empty maybe)
2025-12-12T12:28:27.940948Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:198: TopicSession [1:7582947267131107193:2150] AddDataToClient to [3:7582947306954524710:2204], offset: 2, number rows: 1, row size: 12, watermark: (empty maybe)
2025-12-12T12:28:27.940951Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:936: TopicSession [1:7582947267131107193:2150] Send TEvNewDataArrived to [3:7582947306954524710:2204]
2025-12-12T12:28:27.940979Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:292: TTopicFormatHandler [json_each_row]: TClientHandler [3:7582947306954524710:2204]: OnBatchFinish, offset: 3, number rows: 1, row size: 4, watermark: (empty maybe)
2025-12-12T12:28:27.940982Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:198: TopicSession [1:7582947267131107193:2150] AddDataToClient to [3:7582947306954524710:2204], offset: 3, number rows: 1, row size: 4, watermark: (empty maybe)
2025-12-12T12:28:27.940986Z :FQ_ROW_DISPATCHER TRACE: filters_set.cpp:47: TTopicFilters: Ignore processing for [2:7582947270589275284:2161], historical offset
2025-12-12T12:28:27.940989Z :FQ_ROW_DISPATCHER TRACE: filters_set.cpp:47: TTopicFilters: Ignore processing for [2:7582947261999340665:2154], historical offset
2025-12-12T12:28:27.940992Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:622: TTopicFormatHandler [json_each_row]: Commit client [3:7582947306954524710:2204] offset 3
2025-12-12T12:28:27.940994Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:210: TopicSession [1:7582947267131107193:2150] UpdateClientOffset for [3:7582947306954524710:2204], new offset: 3
2025-12-12T12:28:27.940996Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:622: TTopicFormatHandler [json_each_row]: Commit client [2:7582947270589275284:2161] offset 3
2025-12-12T12:28:27.940998Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:210: TopicSession [1:7582947267131107193:2150] UpdateClientOffset for [2:7582947270589275284:2161], new offset: 3
2025-12-12T12:28:27.940999Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:622: TTopicFormatHandler [json_each_row]: Commit client [2:7582947261999340665:2154] offset 3
2025-12-12T12:28:27.941001Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:210: TopicSession [1:7582947267131107193:2150] UpdateClientOffset for [2:7582947261999340665:2154], new offset: 3
2025-12-12T12:28:27.941007Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:466: TopicSession [1:7582947267131107193:2150] SubscribeOnNextEvent
2025-12-12T12:28:27.941014Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1081: RowDispatcher: Forward TEvNewDataArrived from [1:7582947267131107193:2150] to [3:7582947306954524710:2204] query id ptqudq7udhp59svrf658
2025-12-12T12:28:27.941520Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:940: RowDispatcher: Received TEvGetNextBatch from [3:7582947306954524710:2204] part id 0 query id ptqudq7udhp59svrf658
2025-12-12T12:28:27.941563Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:588: TopicSession [1:7582947267131107193:2150] TEvGetNextBatch from [3:7582947306954524710:2204]
2025-12-12T12:28:27.941578Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:324: TTopicFormatHandler [json_each_row]: TClientHandler [3:7582947306954524710:2204]: FinishPacking, batch size: 16, number rows: 2
2025-12-12T12:28:27.941591Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:174: TTopicFormatHandler [json_each_row]: TClientHandler [3:7582947306954524710:2204]: ExtractClientData, number batches: 1
2025-12-12T12:28:27.941599Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:764: TopicSession [1:7582947267131107193:2150] SendData to [3:7582947306954524710:2204], batch size 1
2025-12-12T12:28:27.941607Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:457: TopicSession [1:7582947267131107193:2150] Skip SubscribeOnNextEvent, has ReadSession: true, IsWaitingEvents: 1
2025-12-12T12:28:27.941612Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1100: RowDispatcher: Forward TEvMessageBatch from [1:7582947267131107193:2150] to [3:7582947306954524710:2204] query id ptqudq7udhp59svrf658
2025-12-12T12:28:28.014725Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [2:7582947249114438546:2063]
2025-12-12T12:28:28.014743Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [2:7582947249114438546:2063]
2025-12-12T12:28:28.014761Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [2:7582947249114438546:2063]
2025-12-12T12:28:28.087184Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:28:28.087173Z :DEBUG: [local] [local] [b5c90217-98887956-5062db00-b0594cfd] [] Got ReadResponse, serverBytesSize = 93, now ReadSizeBudget = 0, ReadSizeServerDelta = 7999907
2025-12-12T12:28:28.087224Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:28:28.087221Z :DEBUG: [local] [local] [b5c90217-98887956-5062db00-b0594cfd] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 7999907
2025-12-12T12:28:28.087290Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:28:28.087287Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (4-5)
2025-12-12T12:28:28.087302Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:28:28.087300Z :DEBUG: [local] [local] [b5c90217-98887956-5062db00-b0594cfd] [] Returning serverBytesSize = 93 to budget
2025-12-12T12:28:28.087306Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:28:28.087304Z :DEBUG: [local] [local] [b5c90217-98887956-5062db00-b0594cfd] [] In ContinueReadingDataImpl, ReadSizeBudget = 93, ReadSizeServerDelta = 7999907
2025-12-12T12:28:28.087347Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:28:28.087343Z :DEBUG: [local] [local] [b5c90217-98887956-5062db00-b0594cfd] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 8000000
2025-12-12T12:28:28.087415Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:559: TopicSession [1:7582947267131107193:2150] TEvPqEventsReady
2025-12-12T12:28:28.087446Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:28:28.087442Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (4-4)
2025-12-12T12:28:28.087458Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:28:28.087456Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 1} (5-5)
2025-12-12T12:28:28.087469Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:28:28.087467Z :DEBUG: [local] [local] [b5c90217-98887956-5062db00-b0594cfd] [] The application data is transferred to the client. Number of messages 2, size 24 bytes
2025-12-12T12:28:28.087482Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:28:28.087480Z :DEBUG: [local] [local] [b5c90217-98887956-5062db00-b0594cfd] [] Returning serverBytesSize = 0 to budget
2025-12-12T12:28:28.087500Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:654: TopicSession [1:7582947267131107193:2150] Data received: Message { Data: "{"time":105}" Information: { Offset: 4 ProducerId: "" SeqNo: 0 CreateTime: 2025-12-12T12:28:28.079000Z WriteTime: 2025-12-12T12:28:28.079000Z MessageGroupId: "" Meta: { } MessageMeta: { } } Partition session id: 1 Topic: "test_3_session_input" Partition: 0 }
2025-12-12T12:28:28.087510Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:654: TopicSession [1:7582947267131107193:2150] Data received: Message { Data: "{"time":106}" Information: { Offset: 5 ProducerId: "" SeqNo: 0 CreateTime: 2025-12-12T12:28:28.079000Z WriteTime: 2025-12-12T12:28:28.079000Z MessageGroupId: "" Meta: { } MessageMeta: { } } Partition session id: 1 Topic: "test_3_session_input" Partition: 0 }
2025-12-12T12:28:28.087512Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:707: TopicSession [1:7582947267131107193:2150] SendToParsing, messages: 2
2025-12-12T12:28:28.087516Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:417: TTopicFormatHandler [json_each_row]: Send 2 messages to parser
2025-12-12T12:28:28.087520Z :FQ_ROW_DISPATCHER TRACE: json_parser.cpp:388: TJsonParser: Add 2 messages to parse
2025-12-12T12:28:28.087529Z :FQ_ROW_DISPATCHER TRACE: json_parser.cpp:454: TJsonParser: Do parsing, first offset: 4, values:
{"time":105}{"time":106}                                                                
2025-12-12T12:28:28.087532Z :FQ_ROW_DISPATCHER TRACE: json_parser.cpp:590: TJsonParser: Init parser, skipped 0, outputRowId 0 size 88
2025-12-12T12:28:28.087547Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:77: TTopicFormatHandler [json_each_row]: TParserHandler: Got parsed data, number rows: 2
2025-12-12T12:28:28.087555Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:614: TTopicFormatHandler [json_each_row]: Send 2 messages to programs, first offset: 4, last offset: 5
2025-12-12T12:28:28.087559Z :FQ_ROW_DISPATCHER TRACE: filters_set.cpp:34: TTopicFilters: ProcessData for 3 clients, number rows: 2
2025-12-12T12:28:28.087564Z :FQ_ROW_DISPATCHER TRACE: filters_set.cpp:223: TTopicFilters: Pass 2 rows to purecalc filter (client id: [3:7582947306954524710:2204])
2025-12-12T12:28:28.087567Z :FQ_ROW_DISPATCHER TRACE: purecalc_filter.cpp:408: TProgramRunHandler: ProcessData for 2 rows
2025-12-12T12:28:28.087570Z :FQ_ROW_DISPATCHER TRACE: purecalc_filter.cpp:411: TProgramRunHandler: Add 2 rows to client [3:7582947306954524710:2204] without processing
2025-12-12T12:28:28.087592Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:292: TTopicFormatHandler [json_each_row]: TClientHandler [3:7582947306954524710:2204]: OnBatchFinish, offset: 4, number rows: 1, row size: 12, watermark: (empty maybe)
2025-12-12T12:28:28.087605Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:198: TopicSession [1:7582947267131107193:2150] AddDataToClient to [3:7582947306954524710:2204], offset: 4, number rows: 1, row size: 12, watermark: (empty maybe)
2025-12-12T12:28:28.087607Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:936: TopicSession [1:7582947267131107193:2150] Send TEvNewDataArrived to [3:7582947306954524710:2204]
2025-12-12T12:28:28.087621Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:292: TTopicFormatHandler [json_each_row]: TClientHandler [3:7582947306954524710:2204]: OnBatchFinish, offset: 5, number rows: 1, row size: 4, watermark: (empty maybe)
2025-12-12T12:28:28.087624Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:198: TopicSession [1:7582947267131107193:2150] AddDataToClient to [3:7582947306954524710:2204], offset: 5, number rows: 1, row size: 4, watermark: (empty maybe)
2025-12-12T12:28:28.087627Z :FQ_ROW_DISPATCHER TRACE: filters_set.cpp:223: TTopicFilters: Pass 2 rows to purecalc filter (client id: [2:7582947270589275284:2161])
2025-12-12T12:28:28.087628Z :FQ_ROW_DISPATCHER TRACE: purecalc_filter.cpp:408: TProgramRunHandler: ProcessData for 2 rows
2025-12-12T12:28:28.087631Z :FQ_ROW_DISPATCHER TRACE: purecalc_filter.cpp:411: TProgramRunHandler: Add 2 rows to client [2:7582947270589275284:2161] without processing
2025-12-12T12:28:28.087634Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:292: TTopicFormatHandler [json_each_row]: TClientHandler [2:7582947270589275284:2161]: OnBatchFinish, offset: 4, number rows: 1, row size: 12, watermark: (empty maybe)
2025-12-12T12:28:28.087636Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:198: TopicSession [1:7582947267131107193:2150] AddDataToClient to [2:7582947270589275284:2161], offset: 4, number rows: 1, row size: 12, watermark: (empty maybe)
2025-12-12T12:28:28.087639Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:936: TopicSession [1:7582947267131107193:2150] Send TEvNewDataArrived to [2:7582947270589275284:2161]
2025-12-12T12:28:28.087641Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:292: TTopicFormatHandler [json_each_row]: TClientHandler [2:7582947270589275284:2161]: OnBatchFinish, offset: 5, number rows: 1, row size: 4, watermark: (empty maybe)
2025-12-12T12:28:28.087643Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:198: TopicSession [1:7582947267131107193:2150] AddDataToClient to [2:7582947270589275284:2161], offset: 5, number rows: 1, row size: 4, watermark: (empty maybe)
2025-12-12T12:28:28.087647Z :FQ_ROW_DISPATCHER TRACE: filters_set.cpp:223: TTopicFilters: Pass 2 rows to purecalc filter (client id: [2:7582947261999340665:2154])
2025-12-12T12:28:28.087648Z :FQ_ROW_DISPATCHER TRACE: purecalc_filter.cpp:408: TProgramRunHandler: ProcessData for 2 rows
2025-12-12T12:28:28.087649Z :FQ_ROW_DISPATCHER TRACE: purecalc_filter.cpp:411: TProgramRunHandler: Add 2 rows to client [2:7582947261999340665:2154] without processing
2025-12-12T12:28:28.087652Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:292: TTopicFormatHandler [json_each_row]: TClientHandler [2:7582947261999340665:2154]: OnBatchFinish, offset: 4, number rows: 1, row size: 12, watermark: (empty maybe)
2025-12-12T12:28:28.087654Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:198: TopicSession [1:7582947267131107193:2150] AddDataToClient to [2:7582947261999340665:2154], offset: 4, number rows: 1, row size: 12, watermark: (empty maybe)
2025-12-12T12:28:28.087656Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:936: TopicSession [1:7582947267131107193:2150] Send TEvNewDataArrived to [2:7582947261999340665:2154]
2025-12-12T12:28:28.087656Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1081: RowDispatcher: Forward TEvNewDataArrived from [1:7582947267131107193:2150] to [3:7582947306954524710:2204] query id ptqudq7udhp59svrf658
2025-12-12T12:28:28.087659Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:292: TTopicFormatHandler [json_each_row]: TClientHandler [2:7582947261999340665:2154]: OnBatchFinish, offset: 5, number rows: 1, row size: 4, watermark: (empty maybe)
2025-12-12T12:28:28.087660Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:198: TopicSession [1:7582947267131107193:2150] AddDataToClient to [2:7582947261999340665:2154], offset: 5, number rows: 1, row size: 4, watermark: (empty maybe)
2025-12-12T12:28:28.087664Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:622: TTopicFormatHandler [json_each_row]: Commit client [3:7582947306954524710:2204] offset 5
2025-12-12T12:28:28.087667Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:210: TopicSession [1:7582947267131107193:2150] UpdateClientOffset for [3:7582947306954524710:2204], new offset: 5
2025-12-12T12:28:28.087669Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:622: TTopicFormatHandler [json_each_row]: Commit client [2:7582947270589275284:2161] offset 5
2025-12-12T12:28:28.087671Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:210: TopicSession [1:7582947267131107193:2150] UpdateClientOffset for [2:7582947270589275284:2161], new offset: 5
2025-12-12T12:28:28.087672Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:622: TTopicFormatHandler [json_each_row]: Commit client [2:7582947261999340665:2154] offset 5
2025-12-12T12:28:28.087674Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:210: TopicSession [1:7582947267131107193:2150] UpdateClientOffset for [2:7582947261999340665:2154], new offset: 5
2025-12-12T12:28:28.087680Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:466: TopicSession [1:7582947267131107193:2150] SubscribeOnNextEvent
2025-12-12T12:28:28.087683Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1081: RowDispatcher: Forward TEvNewDataArrived from [1:7582947267131107193:2150] to [2:7582947270589275284:2161] query id ptqudq7udfcpbb5tnuo6
2025-12-12T12:28:28.087694Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1081: RowDispatcher: Forward TEvNewDataArrived from [1:7582947267131107193:2150] to [2:7582947261999340665:2154] query id ptqudq7udfu8nrrist3a
2025-12-12T12:28:28.088207Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:940: RowDispatcher: Received TEvGetNextBatch from [3:7582947306954524710:2204] part id 0 query id ptqudq7udhp59svrf658
2025-12-12T12:28:28.088244Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:588: TopicSession [1:7582947267131107193:2150] TEvGetNextBatch from [3:7582947306954524710:2204]
2025-12-12T12:28:28.088255Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:324: TTopicFormatHandler [json_each_row]: TClientHandler [3:7582947306954524710:2204]: FinishPacking, batch size: 16, number rows: 2
2025-12-12T12:28:28.088266Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:174: TTopicFormatHandler [json_each_row]: TClientHandler [3:7582947306954524710:2204]: ExtractClientData, number batches: 1
2025-12-12T12:28:28.088272Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:764: TopicSession [1:7582947267131107193:2150] SendData to [3:7582947306954524710:2204], batch size 1
2025-12-12T12:28:28.088286Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:457: TopicSession [1:7582947267131107193:2150] Skip SubscribeOnNextEvent, has ReadSession: true, IsWaitingEvents: 1
2025-12-12T12:28:28.088292Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1100: RowDispatcher: Forward TEvMessageBatch from [1:7582947267131107193:2150] to [3:7582947306954524710:2204] query id ptqudq7udhp59svrf658
2025-12-12T12:28:28.088430Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:940: RowDispatcher: Received TEvGetNextBatch from [2:7582947270589275284:2161] part id 0 query id ptqudq7udfcpbb5tnuo6
2025-12-12T12:28:28.088453Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:940: RowDispatcher: Received TEvGetNextBatch from [2:7582947261999340665:2154] part id 0 query id ptqudq7udfu8nrrist3a
2025-12-12T12:28:28.088463Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:588: TopicSession [1:7582947267131107193:2150] TEvGetNextBatch from [2:7582947270589275284:2161]
2025-12-12T12:28:28.088470Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:324: TTopicFormatHandler [json_each_row]: TClientHandler [2:7582947270589275284:2161]: FinishPacking, batch size: 16, number rows: 2
2025-12-12T12:28:28.088477Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:174: TTopicFormatHandler [json_each_row]: TClientHandler [2:7582947270589275284:2161]: ExtractClientData, number batches: 1
2025-12-12T12:28:28.088484Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:764: TopicSession [1:7582947267131107193:2150] SendData to [2:7582947270589275284:2161], batch size 1
2025-12-12T12:28:28.088492Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:457: TopicSession [1:7582947267131107193:2150] Skip SubscribeOnNextEvent, has ReadSession: true, IsWaitingEvents: 1
2025-12-12T12:28:28.088496Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:588: TopicSession [1:7582947267131107193:2150] TEvGetNextBatch from [2:7582947261999340665:2154]
2025-12-12T12:28:28.088497Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1100: RowDispatcher: Forward TEvMessageBatch from [1:7582947267131107193:2150] to [2:7582947270589275284:2161] query id ptqudq7udfcpbb5tnuo6
2025-12-12T12:28:28.088499Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:324: TTopicFormatHandler [json_each_row]: TClientHandler [2:7582947261999340665:2154]: FinishPacking, batch size: 16, number rows: 2
2025-12-12T12:28:28.088503Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:174: TTopicFormatHandler [json_each_row]: TClientHandler [2:7582947261999340665:2154]: ExtractClientData, number batches: 1
2025-12-12T12:28:28.088508Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:764: TopicSession [1:7582947267131107193:2150] SendData to [2:7582947261999340665:2154], batch size 1
2025-12-12T12:28:28.088513Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:457: TopicSession [1:7582947267131107193:2150] Skip SubscribeOnNextEvent, has ReadSession: true, IsWaitingEvents: 1
2025-12-12T12:28:28.088520Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1100: RowDispatcher: Forward TEvMessageBatch from [1:7582947267131107193:2150] to [2:7582947261999340665:2154] query id ptqudq7udfu8nrrist3a
2025-12-12T12:28:28.491433Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [3:7582947246824982252:2063]
2025-12-12T12:28:28.491449Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [3:7582947246824982252:2063]
2025-12-12T12:28:28.491452Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [3:7582947246824982252:2063]
2025-12-12T12:28:28.547694Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 85753069-84ac59d2-c006a4dd-96a2c7a622, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:28:28.557097Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:28:28.557113Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:28:28.559865Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:952: TopicSession [1:7582947267131107193:2150] SendStatistics
2025-12-12T12:28:28.559900Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1234: RowDispatcher: TEvSessionStatistic from [1:7582947267131107193:2150]
2025-12-12T12:28:28.637204Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:1001: RowDispatcher: Received TEvStopSession from [3:7582947306954524710:2204] topic test_3_session_input query id ptqudq7udhp59svrf658
2025-12-12T12:28:28.637231Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:1016: RowDispatcher: DeleteConsumer, readActorId [3:7582947306954524710:2204] query id ptqudq7udhp59svrf658, partitions size 1
2025-12-12T12:28:28.637278Z :FQ_ROW_DISPATCHER DEBUG: topic_session.cpp:831: TopicSession [1:7582947267131107193:2150] TEvStopSession from [3:7582947306954524710:2204] topicPath test_3_session_input clients count 3
2025-12-12T12:28:28.637287Z :FQ_ROW_DISPATCHER DEBUG: format_handler.cpp:477: TTopicFormatHandler [json_each_row]: Remove client with id [3:7582947306954524710:2204]
2025-12-12T12:28:28.637291Z :FQ_ROW_DISPATCHER TRACE: filters_set.cpp:94: TTopicFilters: Remove program with client id [3:7582947306954524710:2204]
2025-12-12T12:28:28.637316Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:457: TopicSession [1:7582947267131107193:2150] Skip SubscribeOnNextEvent, has ReadSession: true, IsWaitingEvents: 1
2025-12-12T12:28:28.924239Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:28:28.924224Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:test_3_session_input:0:1:5:0
2025-12-12T12:28:28.924266Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:28:28.924264Z :INFO: [local] [local] [b5c90217-98887956-5062db00-b0594cfd] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1002 BytesRead: 48 MessagesRead: 4 BytesReadCompressed: 48 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:28:28.924405Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1059: RowDispatcher: No consumer with EventQueueId = 3
2025-12-12T12:28:29.264499Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:1001: RowDispatcher: Received TEvStopSession from [2:7582947261999340665:2154] topic test_3_session_input query id ptqudq7udfu8nrrist3a
2025-12-12T12:28:29.264524Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:1016: RowDispatcher: DeleteConsumer, readActorId [2:7582947261999340665:2154] query id ptqudq7udfu8nrrist3a, partitions size 1
2025-12-12T12:28:29.264567Z :FQ_ROW_DISPATCHER DEBUG: topic_session.cpp:831: TopicSession [1:7582947267131107193:2150] TEvStopSession from [2:7582947261999340665:2154] topicPath test_3_session_input clients count 2
2025-12-12T12:28:29.264573Z :FQ_ROW_DISPATCHER DEBUG: format_handler.cpp:477: TTopicFormatHandler [json_each_row]: Remove client with id [2:7582947261999340665:2154]
2025-12-12T12:28:29.264577Z :FQ_ROW_DISPATCHER TRACE: filters_set.cpp:94: TTopicFilters: Remove program with client id [2:7582947261999340665:2154]
2025-12-12T12:28:29.264596Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:457: TopicSession [1:7582947267131107193:2150] Skip SubscribeOnNextEvent, has ReadSession: true, IsWaitingEvents: 1
2025-12-12T12:28:29.542950Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582947245656270544:2092]
2025-12-12T12:28:29.542968Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:28:29.543014Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582947245656270488:2063]
2025-12-12T12:28:29.543019Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582947245656270488:2063]
2025-12-12T12:28:29.543022Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582947245656270488:2063]
2025-12-12T12:28:29.543034Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:28:29.548769Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 85753069-84ac59d2-c006a4dd-96a2c7a623, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:28:29.559159Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:28:29.559186Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:28:30.015702Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [2:7582947249114438546:2063]
2025-12-12T12:28:30.015722Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [2:7582947249114438546:2063]
2025-12-12T12:28:30.015729Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [2:7582947249114438546:2063]
2025-12-12T12:28:30.062431Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:1001: RowDispatcher: Received TEvStopSession from [2:7582947270589275284:2161] topic test_3_session_input query id ptqudq7udfcpbb5tnuo6
2025-12-12T12:28:30.062460Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:1016: RowDispatcher: DeleteConsumer, readActorId [2:7582947270589275284:2161] query id ptqudq7udfcpbb5tnuo6, partitions size 1
2025-12-12T12:28:30.062482Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:1036: RowDispatcher: Session is not used, sent TEvPoisonPill to [1:7582947267131107193:2150]
2025-12-12T12:28:30.062532Z :FQ_ROW_DISPATCHER DEBUG: topic_session.cpp:831: TopicSession [1:7582947267131107193:2150] TEvStopSession from [2:7582947270589275284:2161] topicPath test_3_session_input clients count 1
2025-12-12T12:28:30.062554Z :FQ_ROW_DISPATCHER DEBUG: format_handler.cpp:477: TTopicFormatHandler [json_each_row]: Remove client with id [2:7582947270589275284:2161]
2025-12-12T12:28:30.062569Z :FQ_ROW_DISPATCHER TRACE: filters_set.cpp:94: TTopicFilters: Remove program with client id [2:7582947270589275284:2161]
2025-12-12T12:28:30.062589Z :FQ_ROW_DISPATCHER DEBUG: format_handler.cpp:559: TTopicFormatHandler [json_each_row]: UpdateParser to new schema with size 0
2025-12-12T12:28:30.062591Z :FQ_ROW_DISPATCHER INFO: format_handler.cpp:584: TTopicFormatHandler [json_each_row]: No columns to parse, reset parser
2025-12-12T12:28:30.062738Z :FQ_ROW_DISPATCHER DEBUG: topic_session.cpp:924: TopicSession [1:7582947267131107193:2150] Close read session
2025-12-12T12:28:30.062760Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:28:30.062754Z :INFO: [local] [local] [b5c90217-98887956-5062db00-b0594cfd] Closing read session. Close timeout: 0.000000s
2025-12-12T12:28:30.062774Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:28:30.062772Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:test_3_session_input:0:1:5:0
2025-12-12T12:28:30.062790Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:28:30.062788Z :INFO: [local] [local] [b5c90217-98887956-5062db00-b0594cfd] Counters: { Errors: 0 CurrentSessionLifetimeMs: 2140 BytesRead: 48 MessagesRead: 4 BytesReadCompressed: 48 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:28:30.062817Z :YDB_SDK NOTICE: actor.cpp:37: 2025-12-12T12:28:30.062806Z :NOTICE: [local] [local] [b5c90217-98887956-5062db00-b0594cfd] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Close with zero timeout " }
2025-12-12T12:28:30.062832Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:28:30.062830Z :DEBUG: [local] [local] [b5c90217-98887956-5062db00-b0594cfd] [] Abort session to cluster
2025-12-12T12:28:30.063018Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:28:30.063016Z :INFO: [local] [local] [b5c90217-98887956-5062db00-b0594cfd] Closing read session. Close timeout: 0.000000s
2025-12-12T12:28:30.063031Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:28:30.063029Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:test_3_session_input:0:1:5:0
2025-12-12T12:28:30.063035Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:28:30.063033Z :INFO: [local] [local] [b5c90217-98887956-5062db00-b0594cfd] Counters: { Errors: 0 CurrentSessionLifetimeMs: 2140 BytesRead: 48 MessagesRead: 4 BytesReadCompressed: 48 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:28:30.063042Z :YDB_SDK NOTICE: actor.cpp:37: 2025-12-12T12:28:30.063040Z :NOTICE: [local] [local] [b5c90217-98887956-5062db00-b0594cfd] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T12:28:30.063071Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:457: TopicSession [1:7582947267131107193:2150] Skip SubscribeOnNextEvent, has ReadSession: false, IsWaitingEvents: 1
2025-12-12T12:28:30.063088Z :FQ_ROW_DISPATCHER DEBUG: topic_session.cpp:449: TopicSession [1:7582947267131107193:2150] PassAway
2025-12-12T12:28:30.492667Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [3:7582947246824982252:2063]
2025-12-12T12:28:30.492686Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [3:7582947246824982252:2063]
2025-12-12T12:28:30.492689Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [3:7582947246824982252:2063]
2025-12-12T12:28:30.548540Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 85753069-84ac59d2-c006a4dd-96a2c7a624, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:28:30.561838Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1059: RowDispatcher: No consumer with EventQueueId = 0
2025-12-12T12:28:30.563100Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:28:30.563112Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:28:31.107598Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1059: RowDispatcher: No consumer with EventQueueId = 2
2025-12-12T12:28:31.543860Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582947245656270544:2092]
2025-12-12T12:28:31.543888Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:28:31.543897Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582947245656270488:2063]
2025-12-12T12:28:31.543902Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582947245656270488:2063]
2025-12-12T12:28:31.543908Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582947245656270488:2063]
2025-12-12T12:28:31.543920Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:28:31.549004Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 85753069-84ac59d2-c006a4dd-96a2c7a625, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:28:31.559165Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:28:31.559209Z :FQ_PENDING_FETCHER ERROR: pending_fetcher.cpp:259: Error with GetTask: <main>: Error: GRpc error: (14): connections to all backends failing; last error: UNKNOWN: ipv4:127.0.1.1:5954: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-fhkyrtz6p4.auto.internal:5954
2025-12-12T12:28:32.017582Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [2:7582947249114438546:2063]
2025-12-12T12:28:32.017598Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [2:7582947249114438546:2063]
2025-12-12T12:28:32.017601Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [2:7582947249114438546:2063]
2025-12-12T12:28:32.494087Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [3:7582947246824982252:2063]
2025-12-12T12:28:32.494103Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [3:7582947246824982252:2063]
2025-12-12T12:28:32.494106Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [3:7582947246824982252:2063]
2025-12-12T12:28:32.547374Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-12-12T12:28:32.549468Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 85753069-84ac59d2-c006a4dd-96a2c7a626, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:28:32.555450Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:28:32.555467Z :YQL_NODES_MANAGER ERROR: nodes_manager.cpp:395: ydb/core/fq/libs/actors/nodes_manager.cpp:353: TRANSPORT_UNAVAILABLE
<main>: Error: GRpc error: (14): connections to all backends failing; last error: UNKNOWN: ipv4:127.0.1.1:5954: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-fhkyrtz6p4.auto.internal:5954
2025-12-12T12:28:32.555474Z :FQ_PENDING_FETCHER ERROR: pending_fetcher.cpp:259: Error with GetTask: <main>: Error: GRpc error: (14): connections to all backends failing; last error: UNKNOWN: ipv4:127.0.1.1:5954: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-fhkyrtz6p4.auto.internal:5954
2025-12-12T12:28:33.544742Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582947245656270544:2092]
2025-12-12T12:28:33.544763Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:28:33.544772Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582947245656270488:2063]
2025-12-12T12:28:33.544776Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582947245656270488:2063]
2025-12-12T12:28:33.544780Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582947245656270488:2063]
2025-12-12T12:28:33.544789Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:28:33.549887Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 85753069-84ac59d2-c006a4dd-96a2c7a627, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:28:33.555310Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:28:33.555341Z :FQ_PENDING_FETCHER ERROR: pending_fetcher.cpp:259: Error with GetTask: <main>: Error: GRpc error: (14): connections to all backends failing; last error: UNKNOWN: ipv4:127.0.1.1:5954: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-fhkyrtz6p4.auto.internal:5954
2025-12-12T12:28:33.617521Z :INTERCONNECT_NETWORK NOTICE: interconnect_tcp_input_session.cpp:712: [1 <-> 3] connection closed by peer
2025-12-12T12:28:33.617785Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:398: Coordinator: TEvNodeDisconnected, node id 3
2025-12-12T12:28:33.617789Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:408: Coordinator: Schedule TEvRebalancing
2025-12-12T12:28:33.617807Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:597: RowDispatcher: TEvNodeDisconnected, node id 3
2025-12-12T12:28:33.618387Z :INTERCONNECT_NETWORK NOTICE: interconnect_handshake.cpp:1262: [1 <-> 3] network-related error occured on handshake: outgoing handshake Peer# ghrun-fhkyrtz6p4(127.0.1.1:26800) Couldn't connect to any resolved address
2025-12-12T12:28:33.618471Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1052: RowDispatcher: TEvTryConnect to node id 3
2025-12-12T12:28:33.618518Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:597: RowDispatcher: TEvNodeDisconnected, node id 3
2025-12-12T12:28:33.619992Z :INTERCONNECT_NETWORK NOTICE: interconnect_tcp_input_session.cpp:712: [1 <-> 2] connection closed by peer
2025-12-12T12:28:33.620189Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:597: RowDispatcher: TEvNodeDisconnected, node id 2
2025-12-12T12:28:33.620194Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:398: Coordinator: TEvNodeDisconnected, node id 2
2025-12-12T12:28:33.620512Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1052: RowDispatcher: TEvTryConnect to node id 2
2025-12-12T12:28:33.620592Z :INTERCONNECT_NETWORK NOTICE: interconnect_handshake.cpp:1262: [1 <-> 2] network-related error occured on handshake: outgoing handshake Peer# ghrun-fhkyrtz6p4(127.0.1.1:26336) Couldn't connect to any resolved address
2025-12-12T12:28:33.620692Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:597: RowDispatcher: TEvNodeDisconnected, node id 2
2025-12-12T12:28:33.700369Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1052: RowDispatcher: TEvTryConnect to node id 3
2025-12-12T12:28:33.700455Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:597: RowDispatcher: TEvNodeDisconnected, node id 3
