2025-12-09T03:41:34.182296Z :GRPC_SERVER NOTICE: grpc_request_proxy.cpp:380: Grpc request proxy started, nodeid# 2, serve as static node
2025-12-09T03:41:34.182344Z :GRPC_SERVER CRIT: grpc_request_proxy.cpp:440: Failed to deliver subscription request to config dispatcher
2025-12-09T03:41:34.182348Z :GRPC_SERVER NOTICE: grpc_request_proxy.cpp:380: Grpc request proxy started, nodeid# 2, serve as static node
2025-12-09T03:41:34.182362Z :GRPC_SERVER CRIT: grpc_request_proxy.cpp:440: Failed to deliver subscription request to config dispatcher
2025-12-09T03:41:34.182509Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:214: Bootstrap
2025-12-09T03:41:34.182511Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:217: Create sdk ydb connection
2025-12-09T03:41:34.183396Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:239: Successfully bootstrapped TStorageProxy [2:7581698295192403360:2062] with connection to localhost:5893:local
2025-12-09T03:41:34.183407Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:544: RowDispatcher: Successfully bootstrapped row dispatcher, id [2:7581698295192403361:2063], tenant /compute
2025-12-09T03:41:34.183415Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [2:7581698295192403361:2063]
2025-12-09T03:41:34.183417Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:329: Coordinator: Add new row dispatcher to map (state 1)
2025-12-09T03:41:34.183486Z :YQL_NODES_MANAGER INFO: nodes_manager.cpp:88: Bootstrap, InstanceId: 250e5776-4dec1397-ba1dceab-14fff927
2025-12-09T03:41:34.183487Z :YQL_NODES_MANAGER DEBUG: nodes_manager.cpp:310: TNodesManagerActor::ResolveSelfAddress
2025-12-09T03:41:34.183711Z :FQ_QUOTA_PROXY INFO: quota_proxy.cpp:90: STARTED
2025-12-09T03:41:34.183750Z :FQ_LOG_UPDATER DEBUG: log.cpp:93: Updated YQL logs priority: 8
2025-12-09T03:41:34.183753Z :FQ_LOG_UPDATER CRIT: log.cpp:55: Failed to deliver subscription request to config dispatcher.
2025-12-09T03:41:34.183791Z :YQ_RATE_LIMITER INFO: quoter_service.cpp:124: Bootstraping with config: { Enabled: true DataPlaneEnabled: true Database { Endpoint: "localhost:5893" Database: "local" TablePrefix: "RateLimiter_c2bfb506-2e5d-4557-b205-6b2ea9bc4634" } Limiters { CoordinationNodePath: "rate_limiter" } }
2025-12-09T03:41:34.184009Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:293: Coordinator: Successfully bootstrapped coordinator, id [2:7581698295192403401:2082], NodesManagerId [0:4705493345362661702:78], rebalancing timeout 5.000000s
2025-12-09T03:41:34.184023Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:232: TLeaderElection [2:7581698295192403402:2083] Successfully bootstrapped, local coordinator id [2:7581698295192403401:2082], tenant id compute, local mode 0, coordination node path local/compute, endpoint localhost:5893
2025-12-09T03:41:34.184251Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:637: RowDispatcher: TEvCoordinatorChangesSubscribe from [2:7581698295192403401:2082]
2025-12-09T03:41:34.184270Z :YQ_TEST_CONNECTION DEBUG: test_connection.cpp:142: Starting yandex query test connection. Actor id: [2:7581698295192403366:2068]
2025-12-09T03:41:34.184320Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 4704978-d2d9dbd5-9fd4ff6e-873ef64b1, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:41:34.185061Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-12-09T03:41:34.185611Z :MEMORY_PROFILER NOTICE: monitor.cpp:332: Bootstrapped
2025-12-09T03:41:34.186030Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:71: Run create coordination node "local/compute" actor
2025-12-09T03:41:34.186033Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:113: Call create coordination node "local/compute"
2025-12-09T03:41:34.186035Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:411: Call create coordination node "local/compute"
2025-12-09T03:41:34.186979Z :FQ_QUOTA_SERVICE INFO: quota_manager.cpp:196: STARTED
2025-12-09T03:41:34.188669Z :SCHEME_BOARD_SUBSCRIBER NOTICE: subscriber.cpp:849: [main][2:7581698295192403383:2080][/compute] Set up state: owner# [2:7581698295192403341:2053], state# { Deleted: 1 Strong: 0 Version: <Invalid> DomainId: <Invalid> AbandonedSchemeShards: there are 0 elements }
2025-12-09T03:41:34.188669Z :SCHEME_BOARD_SUBSCRIBER NOTICE: subscriber.cpp:849: [main][2:7581698295192403380:2077][/Root] Set up state: owner# [2:7581698295192403340:2052], state# { Deleted: 1 Strong: 0 Version: <Invalid> DomainId: <Invalid> AbandonedSchemeShards: there are 0 elements }
2025-12-09T03:41:34.188672Z :SCHEME_BOARD_SUBSCRIBER NOTICE: subscriber.cpp:849: [main][2:7581698295192403381:2078][/compute] Set up state: owner# [2:7581698295192403340:2052], state# { Deleted: 1 Strong: 0 Version: <Invalid> DomainId: <Invalid> AbandonedSchemeShards: there are 0 elements }
2025-12-09T03:41:34.188681Z :GRPC_SERVER WARN: grpc_request_proxy.cpp:583: SchemeBoardDelete /Root Strong=0
2025-12-09T03:41:34.188681Z :GRPC_SERVER WARN: grpc_request_proxy.cpp:583: SchemeBoardDelete /compute Strong=0
2025-12-09T03:41:34.188682Z :SCHEME_BOARD_SUBSCRIBER NOTICE: subscriber.cpp:849: [main][2:7581698295192403382:2079][/Root] Set up state: owner# [2:7581698295192403341:2053], state# { Deleted: 1 Strong: 0 Version: <Invalid> DomainId: <Invalid> AbandonedSchemeShards: there are 0 elements }
2025-12-09T03:41:34.188684Z :GRPC_SERVER WARN: grpc_request_proxy.cpp:583: SchemeBoardDelete /compute Strong=0
2025-12-09T03:41:34.188687Z :GRPC_SERVER WARN: grpc_request_proxy.cpp:583: SchemeBoardDelete /Root Strong=0
2025-12-09T03:41:34.208844Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:41:34.208856Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-09T03:41:34.222040Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:155: Successfully created coordination node "local/compute"
2025-12-09T03:41:34.222059Z :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-09T03:41:34.222074Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:345: TLeaderElection [2:7581698295192403402:2083] Coordination node successfully created
2025-12-09T03:41:34.222078Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:323: TLeaderElection [2:7581698295192403402:2083] Start session
2025-12-09T03:41:34.226725Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:389: Send NodeInfo with size: 1 to DynamicNameserver
2025-12-09T03:41:34.230066Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:359: TLeaderElection [2:7581698295192403402:2083] Session successfully created
2025-12-09T03:41:34.232026Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:372: TLeaderElection [2:7581698295192403402:2083] Semaphore successfully created
2025-12-09T03:41:34.232036Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:304: TLeaderElection [2:7581698295192403402:2083] Try to acquire semaphore
2025-12-09T03:41:34.232145Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:420: TLeaderElection [2:7581698295192403402:2083] Describe semaphore
2025-12-09T03:41:34.236548Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:469: TLeaderElection [2:7581698295192403402:2083] Semaphore successfully described: coordinator id [1:7581698290936410633:2082] generation 1
2025-12-09T03:41:34.236557Z :FQ_ROW_DISPATCHER INFO: leader_election.cpp:471: TLeaderElection [2:7581698295192403402:2083] Send TEvCoordinatorChanged to [2:7581698295192403361:2063], new coordinator id [1:7581698290936410633:2082], previous coordinator id [0:0:0]
2025-12-09T03:41:34.236574Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:569: RowDispatcher: Coordinator changed, old leader (empty maybe), new [1:7581698290936410633:2082] generation 1
2025-12-09T03:41:34.236596Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:440: Coordinator: New leader [1:7581698290936410633:2082], SelfId [2:7581698295192403401:2082]
2025-12-09T03:41:34.236685Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:607: RowDispatcher: TEvUndelivered, from [1:7581698290936410633:2082], reason Disconnected
2025-12-09T03:41:34.918063Z :INTERCONNECT ERROR: interconnect_nameserver_dynamic.cpp:62:  ICN06 Unknown nodeId: 3
2025-12-09T03:41:35.181224Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 4704978-d2d9dbd5-9fd4ff6e-873ef64b2, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:41:35.187865Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:41:35.187880Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-09T03:41:35.187936Z :FQ_QUOTA_SERVICE DEBUG: quota_manager.cpp:230: IC Peers[1]: [1]
2025-12-09T03:41:35.360382Z :INTERCONNECT ERROR: interconnect_nameserver_dynamic.cpp:62:  ICN06 Unknown nodeId: 3
2025-12-09T03:41:36.182262Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7581698290936410633:2082]
2025-12-09T03:41:36.182285Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-09T03:41:36.182833Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 4704978-d2d9dbd5-9fd4ff6e-873ef64b3, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:41:36.194200Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:41:36.194216Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-09T03:41:36.534093Z :INTERCONNECT ERROR: interconnect_nameserver_dynamic.cpp:62:  ICN06 Unknown nodeId: 3
2025-12-09T03:41:37.183310Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 4704978-d2d9dbd5-9fd4ff6e-873ef64b4, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:41:37.188776Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:41:37.188791Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-09T03:41:38.026114Z :INTERCONNECT ERROR: interconnect_nameserver_dynamic.cpp:62:  ICN06 Unknown nodeId: 3
2025-12-09T03:41:38.183431Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7581698290936410633:2082]
2025-12-09T03:41:38.183459Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-09T03:41:38.183570Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 4704978-d2d9dbd5-9fd4ff6e-873ef64b5, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:41:38.192737Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:41:38.192753Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-09T03:41:38.779434Z :INTERCONNECT WARN: interconnect_handshake.cpp:501: Handshake [2:7581698312372272764:2061] [node 1] ICH09 Neither CompatibilityInfo nor VersionTag of the peer can be validated, accepting by default
2025-12-09T03:41:39.182882Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-12-09T03:41:39.183736Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:665: Coordinator: Change global state to Started (by timeout)
2025-12-09T03:41:39.184438Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 4704978-d2d9dbd5-9fd4ff6e-873ef64b6, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:41:39.197477Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:41:39.197488Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-09T03:41:39.212672Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:389: Send NodeInfo with size: 2 to DynamicNameserver
2025-12-09T03:41:39.317260Z :INTERCONNECT WARN: interconnect_handshake.cpp:501: Handshake [2:7581698316667240073:2062] [node 3] ICH09 Neither CompatibilityInfo nor VersionTag of the peer can be validated, accepting by default
2025-12-09T03:41:40.184527Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7581698290936410633:2082]
2025-12-09T03:41:40.184555Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-09T03:41:40.185458Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 4704978-d2d9dbd5-9fd4ff6e-873ef64b7, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:41:40.186441Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-09T03:41:40.187533Z :FQ_QUOTA_SERVICE DEBUG: quota_manager.cpp:230: IC Peers[2]: [1, 3]
2025-12-09T03:41:40.190373Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:41:40.190384Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-09T03:41:41.187129Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 4704978-d2d9dbd5-9fd4ff6e-873ef64b8, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:41:41.209255Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:41:41.209273Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-09T03:41:42.189778Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7581698290936410633:2082]
2025-12-09T03:41:42.189805Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-09T03:41:42.190082Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 4704978-d2d9dbd5-9fd4ff6e-873ef64b9, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:41:42.206073Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:41:42.206086Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-09T03:41:42.255514Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-09T03:41:42.508972Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:853: RowDispatcher: Received TEvStartSession from [1:7581698329591116515:2166], read group ptcudqgd7t3kddj98rti, topicPath redistribute_input part id 0 query id ptqudqgd7mnjklkpk65p cookie 1
2025-12-09T03:41:42.509021Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:892: RowDispatcher: Create new session: read group ptcudqgd7t3kddj98rti topic redistribute_input part id 0
2025-12-09T03:41:42.509104Z :FQ_ROW_DISPATCHER DEBUG: topic_session.cpp:443: TopicSession [2:7581698329552141975:2154] Bootstrap redistribute_input/0, Timeout 5.000000s sec
2025-12-09T03:41:42.509111Z :FQ_ROW_DISPATCHER INFO: topic_session.cpp:799: TopicSession [2:7581698329552141975:2154] New client: read actor id [1:7581698329591116515:2166], predicate: , watermark expr: , offset: (empty maybe)
2025-12-09T03:41:42.509157Z :FQ_ROW_DISPATCHER DEBUG: format_handler.cpp:440: TTopicFormatHandler [json_each_row]: Add client with id [1:7581698329591116515:2166]
2025-12-09T03:41:42.510325Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1052: RowDispatcher: TEvTryConnect to node id 1
2025-12-09T03:41:42.510400Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:587: RowDispatcher: EvNodeConnected, node id 1
2025-12-09T03:41:42.585470Z :FQ_ROW_DISPATCHER DEBUG: format_handler.cpp:559: TTopicFormatHandler [json_each_row]: UpdateParser to new schema with size 1
2025-12-09T03:41:42.588831Z :FQ_ROW_DISPATCHER INFO: json_parser.cpp:355: TJsonParser: Simdjson active implementation icelake (Intel/AMD AVX512), error skip mode: 0
2025-12-09T03:41:42.588889Z :FQ_ROW_DISPATCHER DEBUG: format_handler.cpp:570: TTopicFormatHandler [json_each_row]: Parser was created on schema with 1 columns
2025-12-09T03:41:42.588896Z :FQ_ROW_DISPATCHER TRACE: purecalc_filter.cpp:439: GenerateSql: No sql was generated
2025-12-09T03:41:42.588900Z :FQ_ROW_DISPATCHER TRACE: filters_set.cpp:116: TTopicFilters: Create program with client id [1:7581698329591116515:2166]
2025-12-09T03:41:42.588912Z :FQ_ROW_DISPATCHER TRACE: filters_set.cpp:110: TTopicFilters: Start program with client id [1:7581698329591116515:2166]
2025-12-09T03:41:42.588922Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:952: TopicSession [2:7581698329552141975:2154] SendStatistics
2025-12-09T03:41:42.588982Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1234: RowDispatcher: TEvSessionStatistic from [2:7581698329552141975:2154]
2025-12-09T03:41:43.189900Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 4704978-d2d9dbd5-9fd4ff6e-873ef64b10, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:41:43.270934Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:41:43.270950Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-09T03:41:44.181090Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:599: Coordinator: Send TEvGetNodesRequest to NodesManager
2025-12-09T03:41:44.181118Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:300: Received TNodesManagerActor::TEvGetNodesRequest
2025-12-09T03:41:44.181141Z :FQ_ROW_DISPATCHER INFO: coordinator.cpp:690: Coordinator: Updated node info, node count: 3
2025-12-09T03:41:44.183367Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-12-09T03:41:44.190331Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7581698290936410633:2082]
2025-12-09T03:41:44.190359Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 4704978-d2d9dbd5-9fd4ff6e-873ef64b11, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:41:44.190367Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-09T03:41:44.192339Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:389: Send NodeInfo with size: 2 to DynamicNameserver
2025-12-09T03:41:44.193255Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-09T03:41:44.193611Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:41:44.193624Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-09T03:41:44.506715Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:952: TopicSession [2:7581698329552141975:2154] SendStatistics
2025-12-09T03:41:44.506767Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1234: RowDispatcher: TEvSessionStatistic from [2:7581698329552141975:2154]
2025-12-09T03:41:44.511369Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1067: RowDispatcher: Send TEvHeartbeat to [1:7581698329591116515:2166] query id ptqudqgd7mnjklkpk65p
2025-12-09T03:41:45.190788Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 4704978-d2d9dbd5-9fd4ff6e-873ef64b12, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:41:45.202075Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:41:45.202100Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-09T03:41:46.191243Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7581698290936410633:2082]
2025-12-09T03:41:46.191283Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-09T03:41:46.191289Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 4704978-d2d9dbd5-9fd4ff6e-873ef64b13, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:41:46.192120Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-09T03:41:46.198192Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:41:46.198203Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-09T03:41:46.507641Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:952: TopicSession [2:7581698329552141975:2154] SendStatistics
2025-12-09T03:41:46.507685Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1234: RowDispatcher: TEvSessionStatistic from [2:7581698329552141975:2154]
2025-12-09T03:41:46.509794Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:962: RowDispatcher: Received TEvHeartbeat from [1:7581698329591116515:2166], part id 0 query id ptqudqgd7mnjklkpk65p
2025-12-09T03:41:47.194165Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 4704978-d2d9dbd5-9fd4ff6e-873ef64b14, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:41:47.205021Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:41:47.205036Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-09T03:41:47.589301Z :FQ_ROW_DISPATCHER INFO: topic_session.cpp:516: TopicSession [2:7581698329552141975:2154] Create topic session, Path redistribute_input/0, StartingMessageTimestamp 2025-12-09T03:41:42.255000Z, BufferSize 16000000, GetConsumerMode Without
2025-12-09T03:41:47.589345Z :YDB_SDK INFO: actor.cpp:37: 2025-12-09T03:41:47.589340Z :INFO: [local] [local] [95c37ecd-1585fe7f-b2987e9c-214d7618] Starting read session
2025-12-09T03:41:47.589351Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:41:47.589348Z :DEBUG: [local] [local] [95c37ecd-1585fe7f-b2987e9c-214d7618] Starting single session
2025-12-09T03:41:47.589396Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:41:47.589393Z :DEBUG: [local] [local] [95c37ecd-1585fe7f-b2987e9c-214d7618] [] In Reconnect, ReadSizeBudget = 8000000, ReadSizeServerDelta = 0
2025-12-09T03:41:47.589404Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:41:47.589402Z :DEBUG: [local] [local] [95c37ecd-1585fe7f-b2987e9c-214d7618] [] New values: ReadSizeBudget = 8000000, ReadSizeServerDelta = 0
2025-12-09T03:41:47.589408Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:41:47.589406Z :DEBUG: [local] [local] [95c37ecd-1585fe7f-b2987e9c-214d7618] [] Reconnecting session to cluster  in 0.000000s
2025-12-09T03:41:47.590124Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:466: TopicSession [2:7581698329552141975:2154] SubscribeOnNextEvent
2025-12-09T03:41:47.598233Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:41:47.598214Z :DEBUG: [local] [local] [95c37ecd-1585fe7f-b2987e9c-214d7618] [] Successfully connected. Initializing session
2025-12-09T03:41:47.602881Z :YDB_SDK INFO: actor.cpp:37: 2025-12-09T03:41:47.602869Z :INFO: [local] [local] [95c37ecd-1585fe7f-b2987e9c-214d7618] [] Got InitResponse. ReadSessionId: _1_3_14482827706191628921_v1
2025-12-09T03:41:47.602914Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:41:47.602910Z :DEBUG: [local] [local] [95c37ecd-1585fe7f-b2987e9c-214d7618] [] In ContinueReadingDataImpl, ReadSizeBudget = 8000000, ReadSizeServerDelta = 0
2025-12-09T03:41:47.602972Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:41:47.602969Z :DEBUG: [local] [local] [95c37ecd-1585fe7f-b2987e9c-214d7618] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 8000000
2025-12-09T03:41:47.605182Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:559: TopicSession [2:7581698329552141975:2154] TEvPqEventsReady
2025-12-09T03:41:47.605204Z :FQ_ROW_DISPATCHER DEBUG: topic_session.cpp:677: TopicSession [2:7581698329552141975:2154] StartPartitionSessionEvent received
2025-12-09T03:41:47.605209Z :FQ_ROW_DISPATCHER DEBUG: topic_session.cpp:685: TopicSession [2:7581698329552141975:2154] Confirm StartPartitionSession with offset (NULL)
2025-12-09T03:41:47.605223Z :YDB_SDK INFO: actor.cpp:37: 2025-12-09T03:41:47.605218Z :INFO: [local] [local] [95c37ecd-1585fe7f-b2987e9c-214d7618] [] Confirm partition stream create. Partition stream id: 1. Cluster: "-". Topic: "redistribute_input". Partition: 0. Read offset: (NULL)
2025-12-09T03:41:47.605332Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:466: TopicSession [2:7581698329552141975:2154] SubscribeOnNextEvent
2025-12-09T03:41:47.606242Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:41:47.606236Z :DEBUG: [local] [local] [95c37ecd-1585fe7f-b2987e9c-214d7618] [] Got ReadResponse, serverBytesSize = 146, now ReadSizeBudget = 0, ReadSizeServerDelta = 7999854
2025-12-09T03:41:47.606266Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:41:47.606264Z :DEBUG: [local] [local] [95c37ecd-1585fe7f-b2987e9c-214d7618] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 7999854
2025-12-09T03:41:47.606323Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:41:47.606321Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (0-1)
2025-12-09T03:41:47.606332Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:41:47.606329Z :DEBUG: [local] [local] [95c37ecd-1585fe7f-b2987e9c-214d7618] [] Returning serverBytesSize = 146 to budget
2025-12-09T03:41:47.606336Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:41:47.606334Z :DEBUG: [local] [local] [95c37ecd-1585fe7f-b2987e9c-214d7618] [] In ContinueReadingDataImpl, ReadSizeBudget = 146, ReadSizeServerDelta = 7999854
2025-12-09T03:41:47.606369Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:41:47.606368Z :DEBUG: [local] [local] [95c37ecd-1585fe7f-b2987e9c-214d7618] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 8000000
2025-12-09T03:41:47.606401Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:559: TopicSession [2:7581698329552141975:2154] TEvPqEventsReady
2025-12-09T03:41:47.606423Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:41:47.606419Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-12-09T03:41:47.606429Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:41:47.606428Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (1-1)
2025-12-09T03:41:47.606437Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:41:47.606436Z :DEBUG: [local] [local] [95c37ecd-1585fe7f-b2987e9c-214d7618] [] The application data is transferred to the client. Number of messages 2, size 60 bytes
2025-12-09T03:41:47.606445Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:41:47.606443Z :DEBUG: [local] [local] [95c37ecd-1585fe7f-b2987e9c-214d7618] [] Returning serverBytesSize = 0 to budget
2025-12-09T03:41:47.606461Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:654: TopicSession [2:7581698329552141975:2154] Data received: Message { Data: "{"time": 100, "data": "hello"}" Information: { Offset: 0 ProducerId: "" SeqNo: 0 CreateTime: 2025-12-09T03:41:45.956000Z WriteTime: 2025-12-09T03:41:45.956000Z MessageGroupId: "" Meta: { } MessageMeta: { } } Partition session id: 1 Topic: "redistribute_input" Partition: 0 }
2025-12-09T03:41:47.606465Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:654: TopicSession [2:7581698329552141975:2154] Data received: Message { Data: "{"time": 100, "data": "hello"}" Information: { Offset: 1 ProducerId: "" SeqNo: 0 CreateTime: 2025-12-09T03:41:46.002000Z WriteTime: 2025-12-09T03:41:46.002000Z MessageGroupId: "" Meta: { } MessageMeta: { } } Partition session id: 1 Topic: "redistribute_input" Partition: 0 }
2025-12-09T03:41:47.606466Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:707: TopicSession [2:7581698329552141975:2154] SendToParsing, messages: 2
2025-12-09T03:41:47.606470Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:417: TTopicFormatHandler [json_each_row]: Send 2 messages to parser
2025-12-09T03:41:47.606474Z :FQ_ROW_DISPATCHER TRACE: json_parser.cpp:388: TJsonParser: Add 2 messages to parse
2025-12-09T03:41:47.606482Z :FQ_ROW_DISPATCHER TRACE: json_parser.cpp:454: TJsonParser: Do parsing, first offset: 0, values:
{"time": 100, "data": "hello"}{"time": 100, "data": "hello"}                                                                
2025-12-09T03:41:47.606486Z :FQ_ROW_DISPATCHER TRACE: json_parser.cpp:590: TJsonParser: Init parser, skipped 0, outputRowId 0 size 124
2025-12-09T03:41:47.606500Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:77: TTopicFormatHandler [json_each_row]: TParserHandler: Got parsed data, number rows: 2
2025-12-09T03:41:47.606503Z :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-09T03:41:47.606506Z :FQ_ROW_DISPATCHER TRACE: filters_set.cpp:34: TTopicFilters: ProcessData for 1 clients, number rows: 2
2025-12-09T03:41:47.606511Z :FQ_ROW_DISPATCHER TRACE: filters_set.cpp:223: TTopicFilters: Pass 2 rows to purecalc filter (client id: [1:7581698329591116515:2166])
2025-12-09T03:41:47.606514Z :FQ_ROW_DISPATCHER TRACE: purecalc_filter.cpp:408: TProgramRunHandler: ProcessData for 2 rows
2025-12-09T03:41:47.606516Z :FQ_ROW_DISPATCHER TRACE: purecalc_filter.cpp:411: TProgramRunHandler: Add 2 rows to client [1:7581698329591116515:2166] without processing
2025-12-09T03:41:47.606526Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:292: TTopicFormatHandler [json_each_row]: TClientHandler [1:7581698329591116515:2166]: OnBatchFinish, offset: 0, number rows: 1, row size: 17, watermark: (empty maybe)
2025-12-09T03:41:47.606530Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:198: TopicSession [2:7581698329552141975:2154] AddDataToClient to [1:7581698329591116515:2166], offset: 0, number rows: 1, row size: 17, watermark: (empty maybe)
2025-12-09T03:41:47.606532Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:936: TopicSession [2:7581698329552141975:2154] Send TEvNewDataArrived to [1:7581698329591116515:2166]
2025-12-09T03:41:47.606543Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:292: TTopicFormatHandler [json_each_row]: TClientHandler [1:7581698329591116515:2166]: OnBatchFinish, offset: 1, number rows: 1, row size: 9, watermark: (empty maybe)
2025-12-09T03:41:47.606545Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:198: TopicSession [2:7581698329552141975:2154] AddDataToClient to [1:7581698329591116515:2166], offset: 1, number rows: 1, row size: 9, watermark: (empty maybe)
2025-12-09T03:41:47.606548Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:622: TTopicFormatHandler [json_each_row]: Commit client [1:7581698329591116515:2166] offset 1
2025-12-09T03:41:47.606550Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:210: TopicSession [2:7581698329552141975:2154] UpdateClientOffset for [1:7581698329591116515:2166], new offset: 1
2025-12-09T03:41:47.606554Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:466: TopicSession [2:7581698329552141975:2154] SubscribeOnNextEvent
2025-12-09T03:41:47.606566Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1081: RowDispatcher: Forward TEvNewDataArrived from [2:7581698329552141975:2154] to [1:7581698329591116515:2166] query id ptqudqgd7mnjklkpk65p
2025-12-09T03:41:47.606987Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:940: RowDispatcher: Received TEvGetNextBatch from [1:7581698329591116515:2166] part id 0 query id ptqudqgd7mnjklkpk65p
2025-12-09T03:41:47.607012Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:588: TopicSession [2:7581698329552141975:2154] TEvGetNextBatch from [1:7581698329591116515:2166]
2025-12-09T03:41:47.607019Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:324: TTopicFormatHandler [json_each_row]: TClientHandler [1:7581698329591116515:2166]: FinishPacking, batch size: 26, number rows: 2
2025-12-09T03:41:47.607026Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:174: TTopicFormatHandler [json_each_row]: TClientHandler [1:7581698329591116515:2166]: ExtractClientData, number batches: 1
2025-12-09T03:41:47.607032Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:764: TopicSession [2:7581698329552141975:2154] SendData to [1:7581698329591116515:2166], batch size 1
2025-12-09T03:41:47.607040Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:457: TopicSession [2:7581698329552141975:2154] Skip SubscribeOnNextEvent, has ReadSession: true, IsWaitingEvents: 1
2025-12-09T03:41:47.607045Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1100: RowDispatcher: Forward TEvMessageBatch from [2:7581698329552141975:2154] to [1:7581698329591116515:2166] query id ptqudqgd7mnjklkpk65p
2025-12-09T03:41:48.192146Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7581698290936410633:2082]
2025-12-09T03:41:48.192164Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-09T03:41:48.194609Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-09T03:41:48.195199Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 4704978-d2d9dbd5-9fd4ff6e-873ef64b15, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:41:48.199581Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:41:48.199593Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-09T03:41:48.508620Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:952: TopicSession [2:7581698329552141975:2154] SendStatistics
2025-12-09T03:41:48.508662Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1234: RowDispatcher: TEvSessionStatistic from [2:7581698329552141975:2154]
2025-12-09T03:41:48.590133Z :YDB_SDK INFO: actor.cpp:37: 2025-12-09T03:41:48.590121Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:redistribute_input:0:1:1:0
2025-12-09T03:41:48.590155Z :YDB_SDK INFO: actor.cpp:37: 2025-12-09T03:41:48.590154Z :INFO: [local] [local] [95c37ecd-1585fe7f-b2987e9c-214d7618] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1000 BytesRead: 60 MessagesRead: 2 BytesReadCompressed: 60 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:41:49.185614Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-12-09T03:41:49.195650Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 4704978-d2d9dbd5-9fd4ff6e-873ef64b16, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:41:49.196728Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:389: Send NodeInfo with size: 2 to DynamicNameserver
2025-12-09T03:41:49.200738Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:41:49.200748Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-09T03:41:49.869611Z :INTERCONNECT_NETWORK NOTICE: interconnect_tcp_input_session.cpp:712: [2 <-> 3] connection closed by peer
2025-12-09T03:41:49.870783Z :INTERCONNECT_NETWORK NOTICE: interconnect_handshake.cpp:1262: [2 <-> 3] network-related error occured on handshake: outgoing handshake Peer# ghrun-syjwtgwtdu(127.0.1.1:18078) Couldn't connect to any resolved address
2025-12-09T03:41:49.882604Z :INTERCONNECT_NETWORK NOTICE: interconnect_handshake.cpp:1262: [2 <-> 3] network-related error occured on handshake: outgoing handshake Peer# ghrun-syjwtgwtdu(127.0.1.1:18078) Couldn't connect to any resolved address
2025-12-09T03:41:49.951149Z :INTERCONNECT_NETWORK NOTICE: interconnect_handshake.cpp:1262: [2 <-> 3] network-related error occured on handshake: outgoing handshake Peer# ghrun-syjwtgwtdu(127.0.1.1:18078) Couldn't connect to any resolved address
2025-12-09T03:41:50.192519Z :INTERCONNECT_NETWORK NOTICE: interconnect_handshake.cpp:1262: [2 <-> 3] network-related error occured on handshake: outgoing handshake Peer# ghrun-syjwtgwtdu(127.0.1.1:18078) Couldn't connect to any resolved address
2025-12-09T03:41:50.193007Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7581698290936410633:2082]
2025-12-09T03:41:50.193033Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-09T03:41:50.193454Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-09T03:41:50.196114Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 4704978-d2d9dbd5-9fd4ff6e-873ef64b17, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:41:50.202200Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:41:50.202220Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-09T03:41:50.509412Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:952: TopicSession [2:7581698329552141975:2154] SendStatistics
2025-12-09T03:41:50.509449Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1234: RowDispatcher: TEvSessionStatistic from [2:7581698329552141975:2154]
2025-12-09T03:41:50.511397Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:962: RowDispatcher: Received TEvHeartbeat from [1:7581698329591116515:2166], part id 0 query id ptqudqgd7mnjklkpk65p
2025-12-09T03:41:50.998219Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:41:50.998210Z :DEBUG: [local] [local] [95c37ecd-1585fe7f-b2987e9c-214d7618] [] Got ReadResponse, serverBytesSize = 95, now ReadSizeBudget = 0, ReadSizeServerDelta = 7999905
2025-12-09T03:41:50.998249Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:41:50.998247Z :DEBUG: [local] [local] [95c37ecd-1585fe7f-b2987e9c-214d7618] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 7999905
2025-12-09T03:41:50.998280Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:41:50.998278Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (2-2)
2025-12-09T03:41:50.998287Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:41:50.998284Z :DEBUG: [local] [local] [95c37ecd-1585fe7f-b2987e9c-214d7618] [] Returning serverBytesSize = 95 to budget
2025-12-09T03:41:50.998292Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:41:50.998289Z :DEBUG: [local] [local] [95c37ecd-1585fe7f-b2987e9c-214d7618] [] In ContinueReadingDataImpl, ReadSizeBudget = 95, ReadSizeServerDelta = 7999905
2025-12-09T03:41:50.998359Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:41:50.998355Z :DEBUG: [local] [local] [95c37ecd-1585fe7f-b2987e9c-214d7618] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 8000000
2025-12-09T03:41:50.998576Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:559: TopicSession [2:7581698329552141975:2154] TEvPqEventsReady
2025-12-09T03:41:50.998595Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:41:50.998592Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (2-2)
2025-12-09T03:41:50.998605Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:41:50.998603Z :DEBUG: [local] [local] [95c37ecd-1585fe7f-b2987e9c-214d7618] [] The application data is transferred to the client. Number of messages 1, size 45 bytes
2025-12-09T03:41:50.998610Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:41:50.998609Z :DEBUG: [local] [local] [95c37ecd-1585fe7f-b2987e9c-214d7618] [] Returning serverBytesSize = 0 to budget
2025-12-09T03:41:50.998626Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:654: TopicSession [2:7581698329552141975:2154] Data received: Message { Data: "{"time": 101, "data": "Relativitätstheorie"}" Information: { Offset: 2 ProducerId: "" SeqNo: 0 CreateTime: 2025-12-09T03:41:50.990000Z WriteTime: 2025-12-09T03:41:50.990000Z MessageGroupId: "" Meta: { } MessageMeta: { } } Partition session id: 1 Topic: "redistribute_input" Partition: 0 }
2025-12-09T03:41:50.998627Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:707: TopicSession [2:7581698329552141975:2154] SendToParsing, messages: 1
2025-12-09T03:41:50.998631Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:417: TTopicFormatHandler [json_each_row]: Send 1 messages to parser
2025-12-09T03:41:50.998634Z :FQ_ROW_DISPATCHER TRACE: json_parser.cpp:388: TJsonParser: Add 1 messages to parse
2025-12-09T03:41:50.998642Z :FQ_ROW_DISPATCHER TRACE: json_parser.cpp:454: TJsonParser: Do parsing, first offset: 2, values:
{"time": 101, "data": "Relativitätstheorie"}                                                                
2025-12-09T03:41:50.998644Z :FQ_ROW_DISPATCHER TRACE: json_parser.cpp:590: TJsonParser: Init parser, skipped 0, outputRowId 0 size 109
2025-12-09T03:41:50.998673Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:77: TTopicFormatHandler [json_each_row]: TParserHandler: Got parsed data, number rows: 1
2025-12-09T03:41:50.998675Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:614: TTopicFormatHandler [json_each_row]: Send 1 messages to programs, first offset: 2, last offset: 2
2025-12-09T03:41:50.998678Z :FQ_ROW_DISPATCHER TRACE: filters_set.cpp:34: TTopicFilters: ProcessData for 1 clients, number rows: 1
2025-12-09T03:41:50.998683Z :FQ_ROW_DISPATCHER TRACE: filters_set.cpp:223: TTopicFilters: Pass 1 rows to purecalc filter (client id: [1:7581698329591116515:2166])
2025-12-09T03:41:50.998686Z :FQ_ROW_DISPATCHER TRACE: purecalc_filter.cpp:408: TProgramRunHandler: ProcessData for 1 rows
2025-12-09T03:41:50.998688Z :FQ_ROW_DISPATCHER TRACE: purecalc_filter.cpp:411: TProgramRunHandler: Add 1 rows to client [1:7581698329591116515:2166] without processing
2025-12-09T03:41:50.998696Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:292: TTopicFormatHandler [json_each_row]: TClientHandler [1:7581698329591116515:2166]: OnBatchFinish, offset: 2, number rows: 1, row size: 32, watermark: (empty maybe)
2025-12-09T03:41:50.998699Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:198: TopicSession [2:7581698329552141975:2154] AddDataToClient to [1:7581698329591116515:2166], offset: 2, number rows: 1, row size: 32, watermark: (empty maybe)
2025-12-09T03:41:50.998700Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:936: TopicSession [2:7581698329552141975:2154] Send TEvNewDataArrived to [1:7581698329591116515:2166]
2025-12-09T03:41:50.998715Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:622: TTopicFormatHandler [json_each_row]: Commit client [1:7581698329591116515:2166] offset 2
2025-12-09T03:41:50.998718Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:210: TopicSession [2:7581698329552141975:2154] UpdateClientOffset for [1:7581698329591116515:2166], new offset: 2
2025-12-09T03:41:50.998724Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:466: TopicSession [2:7581698329552141975:2154] SubscribeOnNextEvent
2025-12-09T03:41:50.998735Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1081: RowDispatcher: Forward TEvNewDataArrived from [2:7581698329552141975:2154] to [1:7581698329591116515:2166] query id ptqudqgd7mnjklkpk65p
2025-12-09T03:41:51.002133Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:940: RowDispatcher: Received TEvGetNextBatch from [1:7581698329591116515:2166] part id 0 query id ptqudqgd7mnjklkpk65p
2025-12-09T03:41:51.002166Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:588: TopicSession [2:7581698329552141975:2154] TEvGetNextBatch from [1:7581698329591116515:2166]
2025-12-09T03:41:51.002177Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:324: TTopicFormatHandler [json_each_row]: TClientHandler [1:7581698329591116515:2166]: FinishPacking, batch size: 32, number rows: 1
2025-12-09T03:41:51.002186Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:174: TTopicFormatHandler [json_each_row]: TClientHandler [1:7581698329591116515:2166]: ExtractClientData, number batches: 1
2025-12-09T03:41:51.002192Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:764: TopicSession [2:7581698329552141975:2154] SendData to [1:7581698329591116515:2166], batch size 1
2025-12-09T03:41:51.002202Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:457: TopicSession [2:7581698329552141975:2154] Skip SubscribeOnNextEvent, has ReadSession: true, IsWaitingEvents: 1
2025-12-09T03:41:51.002207Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1100: RowDispatcher: Forward TEvMessageBatch from [2:7581698329552141975:2154] to [1:7581698329591116515:2166] query id ptqudqgd7mnjklkpk65p
2025-12-09T03:41:51.038684Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:41:51.038674Z :DEBUG: [local] [local] [95c37ecd-1585fe7f-b2987e9c-214d7618] [] Got ReadResponse, serverBytesSize = 93, now ReadSizeBudget = 0, ReadSizeServerDelta = 7999907
2025-12-09T03:41:51.038716Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:41:51.038713Z :DEBUG: [local] [local] [95c37ecd-1585fe7f-b2987e9c-214d7618] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 7999907
2025-12-09T03:41:51.038797Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:41:51.038794Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (3-3)
2025-12-09T03:41:51.038803Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:41:51.038800Z :DEBUG: [local] [local] [95c37ecd-1585fe7f-b2987e9c-214d7618] [] Returning serverBytesSize = 93 to budget
2025-12-09T03:41:51.038807Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:41:51.038805Z :DEBUG: [local] [local] [95c37ecd-1585fe7f-b2987e9c-214d7618] [] In ContinueReadingDataImpl, ReadSizeBudget = 93, ReadSizeServerDelta = 7999907
2025-12-09T03:41:51.038850Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:41:51.038847Z :DEBUG: [local] [local] [95c37ecd-1585fe7f-b2987e9c-214d7618] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 8000000
2025-12-09T03:41:51.039042Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:559: TopicSession [2:7581698329552141975:2154] TEvPqEventsReady
2025-12-09T03:41:51.039062Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:41:51.039059Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (3-3)
2025-12-09T03:41:51.039074Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:41:51.039070Z :DEBUG: [local] [local] [95c37ecd-1585fe7f-b2987e9c-214d7618] [] The application data is transferred to the client. Number of messages 1, size 45 bytes
2025-12-09T03:41:51.039080Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:41:51.039078Z :DEBUG: [local] [local] [95c37ecd-1585fe7f-b2987e9c-214d7618] [] Returning serverBytesSize = 0 to budget
2025-12-09T03:41:51.039095Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:654: TopicSession [2:7581698329552141975:2154] Data received: Message { Data: "{"time": 101, "data": "Relativitätstheorie"}" Information: { Offset: 3 ProducerId: "" SeqNo: 0 CreateTime: 2025-12-09T03:41:51.032000Z WriteTime: 2025-12-09T03:41:51.032000Z MessageGroupId: "" Meta: { } MessageMeta: { } } Partition session id: 1 Topic: "redistribute_input" Partition: 0 }
2025-12-09T03:41:51.039097Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:707: TopicSession [2:7581698329552141975:2154] SendToParsing, messages: 1
2025-12-09T03:41:51.039101Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:417: TTopicFormatHandler [json_each_row]: Send 1 messages to parser
2025-12-09T03:41:51.039104Z :FQ_ROW_DISPATCHER TRACE: json_parser.cpp:388: TJsonParser: Add 1 messages to parse
2025-12-09T03:41:51.039111Z :FQ_ROW_DISPATCHER TRACE: json_parser.cpp:454: TJsonParser: Do parsing, first offset: 3, values:
{"time": 101, "data": "Relativitätstheorie"}                                                                
2025-12-09T03:41:51.039113Z :FQ_ROW_DISPATCHER TRACE: json_parser.cpp:590: TJsonParser: Init parser, skipped 0, outputRowId 0 size 109
2025-12-09T03:41:51.039128Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:77: TTopicFormatHandler [json_each_row]: TParserHandler: Got parsed data, number rows: 1
2025-12-09T03:41:51.039131Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:614: TTopicFormatHandler [json_each_row]: Send 1 messages to programs, first offset: 3, last offset: 3
2025-12-09T03:41:51.039134Z :FQ_ROW_DISPATCHER TRACE: filters_set.cpp:34: TTopicFilters: ProcessData for 1 clients, number rows: 1
2025-12-09T03:41:51.039138Z :FQ_ROW_DISPATCHER TRACE: filters_set.cpp:223: TTopicFilters: Pass 1 rows to purecalc filter (client id: [1:7581698329591116515:2166])
2025-12-09T03:41:51.039141Z :FQ_ROW_DISPATCHER TRACE: purecalc_filter.cpp:408: TProgramRunHandler: ProcessData for 1 rows
2025-12-09T03:41:51.039144Z :FQ_ROW_DISPATCHER TRACE: purecalc_filter.cpp:411: TProgramRunHandler: Add 1 rows to client [1:7581698329591116515:2166] without processing
2025-12-09T03:41:51.039161Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:292: TTopicFormatHandler [json_each_row]: TClientHandler [1:7581698329591116515:2166]: OnBatchFinish, offset: 3, number rows: 1, row size: 32, watermark: (empty maybe)
2025-12-09T03:41:51.039165Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:198: TopicSession [2:7581698329552141975:2154] AddDataToClient to [1:7581698329591116515:2166], offset: 3, number rows: 1, row size: 32, watermark: (empty maybe)
2025-12-09T03:41:51.039166Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:936: TopicSession [2:7581698329552141975:2154] Send TEvNewDataArrived to [1:7581698329591116515:2166]
2025-12-09T03:41:51.039179Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:622: TTopicFormatHandler [json_each_row]: Commit client [1:7581698329591116515:2166] offset 3
2025-12-09T03:41:51.039181Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:210: TopicSession [2:7581698329552141975:2154] UpdateClientOffset for [1:7581698329591116515:2166], new offset: 3
2025-12-09T03:41:51.039188Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:466: TopicSession [2:7581698329552141975:2154] SubscribeOnNextEvent
2025-12-09T03:41:51.039199Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1081: RowDispatcher: Forward TEvNewDataArrived from [2:7581698329552141975:2154] to [1:7581698329591116515:2166] query id ptqudqgd7mnjklkpk65p
2025-12-09T03:41:51.040556Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:940: RowDispatcher: Received TEvGetNextBatch from [1:7581698329591116515:2166] part id 0 query id ptqudqgd7mnjklkpk65p
2025-12-09T03:41:51.040590Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:588: TopicSession [2:7581698329552141975:2154] TEvGetNextBatch from [1:7581698329591116515:2166]
2025-12-09T03:41:51.040597Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:324: TTopicFormatHandler [json_each_row]: TClientHandler [1:7581698329591116515:2166]: FinishPacking, batch size: 32, number rows: 1
2025-12-09T03:41:51.040605Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:174: TTopicFormatHandler [json_each_row]: TClientHandler [1:7581698329591116515:2166]: ExtractClientData, number batches: 1
2025-12-09T03:41:51.040612Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:764: TopicSession [2:7581698329552141975:2154] SendData to [1:7581698329591116515:2166], batch size 1
2025-12-09T03:41:51.040618Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:457: TopicSession [2:7581698329552141975:2154] Skip SubscribeOnNextEvent, has ReadSession: true, IsWaitingEvents: 1
2025-12-09T03:41:51.040623Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1100: RowDispatcher: Forward TEvMessageBatch from [2:7581698329552141975:2154] to [1:7581698329591116515:2166] query id ptqudqgd7mnjklkpk65p
2025-12-09T03:41:51.155453Z :INTERCONNECT_NETWORK NOTICE: interconnect_handshake.cpp:1262: [2 <-> 3] network-related error occured on handshake: outgoing handshake Peer# ghrun-syjwtgwtdu(127.0.1.1:18078) Couldn't connect to any resolved address
2025-12-09T03:41:51.196546Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 4704978-d2d9dbd5-9fd4ff6e-873ef64b18, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:41:51.206165Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:41:51.206181Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-09T03:41:52.193926Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7581698290936410633:2082]
2025-12-09T03:41:52.193948Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-09T03:41:52.194859Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-09T03:41:52.196989Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 4704978-d2d9dbd5-9fd4ff6e-873ef64b19, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:41:52.202512Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:41:52.202522Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-09T03:41:52.437172Z :INTERCONNECT_NETWORK NOTICE: interconnect_handshake.cpp:1262: [2 <-> 3] network-related error occured on handshake: outgoing handshake Peer# ghrun-syjwtgwtdu(127.0.1.1:18078) Couldn't connect to any resolved address
2025-12-09T03:41:52.514225Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:952: TopicSession [2:7581698329552141975:2154] SendStatistics
2025-12-09T03:41:52.514250Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1234: RowDispatcher: TEvSessionStatistic from [2:7581698329552141975:2154]
2025-12-09T03:41:53.197468Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 4704978-d2d9dbd5-9fd4ff6e-873ef64b20, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:41:53.210408Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:41:53.210431Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-09T03:41:53.675105Z :INTERCONNECT_NETWORK NOTICE: interconnect_handshake.cpp:1262: [2 <-> 3] network-related error occured on handshake: outgoing handshake Peer# ghrun-syjwtgwtdu(127.0.1.1:18078) Couldn't connect to any resolved address
2025-12-09T03:41:54.186815Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-12-09T03:41:54.194806Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7581698290936410633:2082]
2025-12-09T03:41:54.194830Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-09T03:41:54.197895Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 4704978-d2d9dbd5-9fd4ff6e-873ef64b21, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:41:54.200552Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-09T03:41:54.207538Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:389: Send NodeInfo with size: 2 to DynamicNameserver
2025-12-09T03:41:54.211118Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:41:54.211131Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-09T03:41:54.516056Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:952: TopicSession [2:7581698329552141975:2154] SendStatistics
2025-12-09T03:41:54.516102Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1234: RowDispatcher: TEvSessionStatistic from [2:7581698329552141975:2154]
2025-12-09T03:41:54.516741Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:962: RowDispatcher: Received TEvHeartbeat from [1:7581698329591116515:2166], part id 0 query id ptqudqgd7mnjklkpk65p
2025-12-09T03:41:54.998084Z :INTERCONNECT_NETWORK NOTICE: interconnect_handshake.cpp:1262: [2 <-> 3] network-related error occured on handshake: outgoing handshake Peer# ghrun-syjwtgwtdu(127.0.1.1:18078) Couldn't connect to any resolved address
2025-12-09T03:41:55.198942Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 4704978-d2d9dbd5-9fd4ff6e-873ef64b22, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:41:55.209699Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:41:55.209712Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-09T03:41:55.870031Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:1001: RowDispatcher: Received TEvStopSession from [1:7581698329591116515:2166] topic redistribute_input query id ptqudqgd7mnjklkpk65p
2025-12-09T03:41:55.870057Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:1016: RowDispatcher: DeleteConsumer, readActorId [1:7581698329591116515:2166] query id ptqudqgd7mnjklkpk65p, partitions size 1
2025-12-09T03:41:55.870078Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:1036: RowDispatcher: Session is not used, sent TEvPoisonPill to [2:7581698329552141975:2154]
2025-12-09T03:41:55.870100Z :FQ_ROW_DISPATCHER DEBUG: topic_session.cpp:831: TopicSession [2:7581698329552141975:2154] TEvStopSession from [1:7581698329591116515:2166] topicPath redistribute_input clients count 1
2025-12-09T03:41:55.870105Z :FQ_ROW_DISPATCHER DEBUG: format_handler.cpp:477: TTopicFormatHandler [json_each_row]: Remove client with id [1:7581698329591116515:2166]
2025-12-09T03:41:55.870107Z :FQ_ROW_DISPATCHER TRACE: filters_set.cpp:94: TTopicFilters: Remove program with client id [1:7581698329591116515:2166]
2025-12-09T03:41:55.870121Z :FQ_ROW_DISPATCHER DEBUG: format_handler.cpp:559: TTopicFormatHandler [json_each_row]: UpdateParser to new schema with size 0
2025-12-09T03:41:55.870124Z :FQ_ROW_DISPATCHER INFO: format_handler.cpp:584: TTopicFormatHandler [json_each_row]: No columns to parse, reset parser
2025-12-09T03:41:55.870182Z :FQ_ROW_DISPATCHER DEBUG: topic_session.cpp:924: TopicSession [2:7581698329552141975:2154] Close read session
2025-12-09T03:41:55.870194Z :YDB_SDK INFO: actor.cpp:37: 2025-12-09T03:41:55.870189Z :INFO: [local] [local] [95c37ecd-1585fe7f-b2987e9c-214d7618] Closing read session. Close timeout: 0.000000s
2025-12-09T03:41:55.870206Z :YDB_SDK INFO: actor.cpp:37: 2025-12-09T03:41:55.870204Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:redistribute_input:0:1:3:0
2025-12-09T03:41:55.870213Z :YDB_SDK INFO: actor.cpp:37: 2025-12-09T03:41:55.870212Z :INFO: [local] [local] [95c37ecd-1585fe7f-b2987e9c-214d7618] Counters: { Errors: 0 CurrentSessionLifetimeMs: 8280 BytesRead: 150 MessagesRead: 4 BytesReadCompressed: 150 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:41:55.870228Z :YDB_SDK NOTICE: actor.cpp:37: 2025-12-09T03:41:55.870226Z :NOTICE: [local] [local] [95c37ecd-1585fe7f-b2987e9c-214d7618] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Close with zero timeout " }
2025-12-09T03:41:55.870234Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:41:55.870233Z :DEBUG: [local] [local] [95c37ecd-1585fe7f-b2987e9c-214d7618] [] Abort session to cluster
2025-12-09T03:41:55.870379Z :YDB_SDK INFO: actor.cpp:37: 2025-12-09T03:41:55.870367Z :INFO: [local] [local] [95c37ecd-1585fe7f-b2987e9c-214d7618] Closing read session. Close timeout: 0.000000s
2025-12-09T03:41:55.870384Z :YDB_SDK INFO: actor.cpp:37: 2025-12-09T03:41:55.870383Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:redistribute_input:0:1:3:0
2025-12-09T03:41:55.870387Z :YDB_SDK INFO: actor.cpp:37: 2025-12-09T03:41:55.870386Z :INFO: [local] [local] [95c37ecd-1585fe7f-b2987e9c-214d7618] Counters: { Errors: 0 CurrentSessionLifetimeMs: 8281 BytesRead: 150 MessagesRead: 4 BytesReadCompressed: 150 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:41:55.870394Z :YDB_SDK NOTICE: actor.cpp:37: 2025-12-09T03:41:55.870393Z :NOTICE: [local] [local] [95c37ecd-1585fe7f-b2987e9c-214d7618] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-09T03:41:55.870417Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:853: RowDispatcher: Received TEvStartSession from [1:7581698329591116519:2164], read group ptcudqgd7t3kddj98rti, topicPath redistribute_input part id 1 query id ptqudqgd7mnjklkpk65p cookie 2
2025-12-09T03:41:55.870442Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:892: RowDispatcher: Create new session: read group ptcudqgd7t3kddj98rti topic redistribute_input part id 1
2025-12-09T03:41:55.870455Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:457: TopicSession [2:7581698329552141975:2154] Skip SubscribeOnNextEvent, has ReadSession: false, IsWaitingEvents: 1
2025-12-09T03:41:55.870465Z :FQ_ROW_DISPATCHER DEBUG: topic_session.cpp:449: TopicSession [2:7581698329552141975:2154] PassAway
2025-12-09T03:41:55.870507Z :FQ_ROW_DISPATCHER DEBUG: topic_session.cpp:443: TopicSession [2:7581698385386716916:2185] Bootstrap redistribute_input/1, Timeout 5.000000s sec
2025-12-09T03:41:55.870520Z :FQ_ROW_DISPATCHER INFO: topic_session.cpp:799: TopicSession [2:7581698385386716916:2185] New client: read actor id [1:7581698329591116519:2164], predicate: , watermark expr: , offset: 2
2025-12-09T03:41:55.870550Z :FQ_ROW_DISPATCHER DEBUG: format_handler.cpp:440: TTopicFormatHandler [json_each_row]: Add client with id [1:7581698329591116519:2164]
2025-12-09T03:41:55.870659Z :FQ_ROW_DISPATCHER DEBUG: format_handler.cpp:559: TTopicFormatHandler [json_each_row]: UpdateParser to new schema with size 1
2025-12-09T03:41:55.870688Z :FQ_ROW_DISPATCHER INFO: json_parser.cpp:355: TJsonParser: Simdjson active implementation icelake (Intel/AMD AVX512), error skip mode: 0
2025-12-09T03:41:55.870700Z :FQ_ROW_DISPATCHER DEBUG: format_handler.cpp:570: TTopicFormatHandler [json_each_row]: Parser was created on schema with 1 columns
2025-12-09T03:41:55.870703Z :FQ_ROW_DISPATCHER TRACE: purecalc_filter.cpp:439: GenerateSql: No sql was generated
2025-12-09T03:41:55.870707Z :FQ_ROW_DISPATCHER TRACE: filters_set.cpp:116: TTopicFilters: Create program with client id [1:7581698329591116519:2164]
2025-12-09T03:41:55.870713Z :FQ_ROW_DISPATCHER TRACE: filters_set.cpp:110: TTopicFilters: Start program with client id [1:7581698329591116519:2164]
2025-12-09T03:41:55.870717Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:952: TopicSession [2:7581698385386716916:2185] SendStatistics
2025-12-09T03:41:55.870738Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1234: RowDispatcher: TEvSessionStatistic from [2:7581698385386716916:2185]
2025-12-09T03:41:56.195695Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7581698290936410633:2082]
2025-12-09T03:41:56.195721Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-09T03:41:56.196180Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-09T03:41:56.198871Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 4704978-d2d9dbd5-9fd4ff6e-873ef64b23, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:41:56.218086Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:41:56.218104Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-09T03:41:56.519922Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1059: RowDispatcher: No consumer with EventQueueId = 0
2025-12-09T03:41:57.199350Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 4704978-d2d9dbd5-9fd4ff6e-873ef64b24, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:41:57.205929Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:41:57.205951Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-09T03:41:57.871201Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1067: RowDispatcher: Send TEvHeartbeat to [1:7581698329591116519:2164] query id ptqudqgd7mnjklkpk65p
2025-12-09T03:41:57.871201Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:952: TopicSession [2:7581698385386716916:2185] SendStatistics
2025-12-09T03:41:57.871220Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1234: RowDispatcher: TEvSessionStatistic from [2:7581698385386716916:2185]
2025-12-09T03:41:57.873710Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:962: RowDispatcher: Received TEvHeartbeat from [1:7581698329591116519:2164], part id 0 query id ptqudqgd7mnjklkpk65p
2025-12-09T03:41:58.196952Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7581698290936410633:2082]
2025-12-09T03:41:58.196977Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-09T03:41:58.200142Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 4704978-d2d9dbd5-9fd4ff6e-873ef64b25, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:41:58.201722Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-09T03:41:58.220567Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:41:58.220588Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-09T03:41:59.188873Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-12-09T03:41:59.201314Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 4704978-d2d9dbd5-9fd4ff6e-873ef64b26, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:41:59.210077Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:41:59.210095Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-09T03:41:59.222129Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:389: Send NodeInfo with size: 2 to DynamicNameserver
2025-12-09T03:41:59.871884Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:952: TopicSession [2:7581698385386716916:2185] SendStatistics
2025-12-09T03:41:59.871916Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1234: RowDispatcher: TEvSessionStatistic from [2:7581698385386716916:2185]
2025-12-09T03:41:59.872644Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:962: RowDispatcher: Received TEvHeartbeat from [1:7581698329591116519:2164], part id 0 query id ptqudqgd7mnjklkpk65p
2025-12-09T03:42:00.002308Z :INTERCONNECT_NETWORK NOTICE: interconnect_handshake.cpp:1262: [2 <-> 3] network-related error occured on handshake: outgoing handshake Peer# ghrun-syjwtgwtdu(127.0.1.1:18078) Couldn't connect to any resolved address
2025-12-09T03:42:00.201040Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7581698290936410633:2082]
2025-12-09T03:42:00.201057Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-09T03:42:00.202687Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-09T03:42:00.204805Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 4704978-d2d9dbd5-9fd4ff6e-873ef64b27, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:42:00.215675Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:42:00.215696Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-09T03:42:00.870514Z :FQ_ROW_DISPATCHER INFO: topic_session.cpp:516: TopicSession [2:7581698385386716916:2185] Create topic session, Path redistribute_input/1, StartingMessageTimestamp 2025-12-09T03:41:42.267000Z, BufferSize 16000000, GetConsumerMode Without
2025-12-09T03:42:00.870563Z :YDB_SDK INFO: actor.cpp:37: 2025-12-09T03:42:00.870546Z :INFO: [local] [local] [bbd68ba9-a4edaeed-59f9eebc-8f983e4f] Starting read session
2025-12-09T03:42:00.870568Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:00.870565Z :DEBUG: [local] [local] [bbd68ba9-a4edaeed-59f9eebc-8f983e4f] Starting single session
2025-12-09T03:42:00.870603Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:00.870600Z :DEBUG: [local] [local] [bbd68ba9-a4edaeed-59f9eebc-8f983e4f] [] In Reconnect, ReadSizeBudget = 8000000, ReadSizeServerDelta = 0
2025-12-09T03:42:00.870613Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:00.870609Z :DEBUG: [local] [local] [bbd68ba9-a4edaeed-59f9eebc-8f983e4f] [] New values: ReadSizeBudget = 8000000, ReadSizeServerDelta = 0
2025-12-09T03:42:00.870617Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:00.870615Z :DEBUG: [local] [local] [bbd68ba9-a4edaeed-59f9eebc-8f983e4f] [] Reconnecting session to cluster  in 0.000000s
2025-12-09T03:42:00.870790Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:466: TopicSession [2:7581698385386716916:2185] SubscribeOnNextEvent
2025-12-09T03:42:00.871515Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:00.871507Z :DEBUG: [local] [local] [bbd68ba9-a4edaeed-59f9eebc-8f983e4f] [] Successfully connected. Initializing session
2025-12-09T03:42:00.880050Z :YDB_SDK INFO: actor.cpp:37: 2025-12-09T03:42:00.880035Z :INFO: [local] [local] [bbd68ba9-a4edaeed-59f9eebc-8f983e4f] [] Got InitResponse. ReadSessionId: _1_7_10591500965298813600_v1
2025-12-09T03:42:00.880073Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:00.880069Z :DEBUG: [local] [local] [bbd68ba9-a4edaeed-59f9eebc-8f983e4f] [] In ContinueReadingDataImpl, ReadSizeBudget = 8000000, ReadSizeServerDelta = 0
2025-12-09T03:42:00.880200Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:00.880196Z :DEBUG: [local] [local] [bbd68ba9-a4edaeed-59f9eebc-8f983e4f] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 8000000
2025-12-09T03:42:00.883239Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:559: TopicSession [2:7581698385386716916:2185] TEvPqEventsReady
2025-12-09T03:42:00.883261Z :FQ_ROW_DISPATCHER DEBUG: topic_session.cpp:677: TopicSession [2:7581698385386716916:2185] StartPartitionSessionEvent received
2025-12-09T03:42:00.883268Z :FQ_ROW_DISPATCHER DEBUG: topic_session.cpp:685: TopicSession [2:7581698385386716916:2185] Confirm StartPartitionSession with offset 2
2025-12-09T03:42:00.883285Z :YDB_SDK INFO: actor.cpp:37: 2025-12-09T03:42:00.883279Z :INFO: [local] [local] [bbd68ba9-a4edaeed-59f9eebc-8f983e4f] [] Confirm partition stream create. Partition stream id: 1. Cluster: "-". Topic: "redistribute_input". Partition: 1. Read offset: 2
2025-12-09T03:42:00.883346Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:466: TopicSession [2:7581698385386716916:2185] SubscribeOnNextEvent
2025-12-09T03:42:00.884138Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:00.884131Z :DEBUG: [local] [local] [bbd68ba9-a4edaeed-59f9eebc-8f983e4f] [] Got ReadResponse, serverBytesSize = 180, now ReadSizeBudget = 0, ReadSizeServerDelta = 7999820
2025-12-09T03:42:00.884174Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:00.884171Z :DEBUG: [local] [local] [bbd68ba9-a4edaeed-59f9eebc-8f983e4f] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 7999820
2025-12-09T03:42:00.884249Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:00.884230Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (2-3)
2025-12-09T03:42:00.884262Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:00.884259Z :DEBUG: [local] [local] [bbd68ba9-a4edaeed-59f9eebc-8f983e4f] [] Returning serverBytesSize = 180 to budget
2025-12-09T03:42:00.884268Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:00.884264Z :DEBUG: [local] [local] [bbd68ba9-a4edaeed-59f9eebc-8f983e4f] [] In ContinueReadingDataImpl, ReadSizeBudget = 180, ReadSizeServerDelta = 7999820
2025-12-09T03:42:00.884310Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:00.884307Z :DEBUG: [local] [local] [bbd68ba9-a4edaeed-59f9eebc-8f983e4f] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 8000000
2025-12-09T03:42:00.886533Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:559: TopicSession [2:7581698385386716916:2185] TEvPqEventsReady
2025-12-09T03:42:00.886569Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:00.886564Z :DEBUG: [local] Take Data. Partition 1. Read: {0, 0} (2-2)
2025-12-09T03:42:00.886579Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:00.886577Z :DEBUG: [local] Take Data. Partition 1. Read: {1, 0} (3-3)
2025-12-09T03:42:00.886590Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:00.886588Z :DEBUG: [local] [local] [bbd68ba9-a4edaeed-59f9eebc-8f983e4f] [] The application data is transferred to the client. Number of messages 2, size 90 bytes
2025-12-09T03:42:00.886599Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:00.886597Z :DEBUG: [local] [local] [bbd68ba9-a4edaeed-59f9eebc-8f983e4f] [] Returning serverBytesSize = 0 to budget
2025-12-09T03:42:00.886620Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:654: TopicSession [2:7581698385386716916:2185] Data received: Message { Data: "{"time": 101, "data": "Relativitätstheorie"}" Information: { Offset: 2 ProducerId: "" SeqNo: 0 CreateTime: 2025-12-09T03:41:50.958000Z WriteTime: 2025-12-09T03:41:50.957000Z MessageGroupId: "" Meta: { } MessageMeta: { } } Partition session id: 1 Topic: "redistribute_input" Partition: 1 }
2025-12-09T03:42:00.886624Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:654: TopicSession [2:7581698385386716916:2185] Data received: Message { Data: "{"time": 101, "data": "Relativitätstheorie"}" Information: { Offset: 3 ProducerId: "" SeqNo: 0 CreateTime: 2025-12-09T03:41:51.004000Z WriteTime: 2025-12-09T03:41:51.004000Z MessageGroupId: "" Meta: { } MessageMeta: { } } Partition session id: 1 Topic: "redistribute_input" Partition: 1 }
2025-12-09T03:42:00.886626Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:707: TopicSession [2:7581698385386716916:2185] SendToParsing, messages: 2
2025-12-09T03:42:00.886631Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:417: TTopicFormatHandler [json_each_row]: Send 2 messages to parser
2025-12-09T03:42:00.886635Z :FQ_ROW_DISPATCHER TRACE: json_parser.cpp:388: TJsonParser: Add 2 messages to parse
2025-12-09T03:42:00.886644Z :FQ_ROW_DISPATCHER TRACE: json_parser.cpp:454: TJsonParser: Do parsing, first offset: 2, values:
{"time": 101, "data": "Relativitätstheorie"}{"time": 101, "data": "Relativitätstheorie"}                                                                
2025-12-09T03:42:00.886647Z :FQ_ROW_DISPATCHER TRACE: json_parser.cpp:590: TJsonParser: Init parser, skipped 0, outputRowId 0 size 154
2025-12-09T03:42:00.886686Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:77: TTopicFormatHandler [json_each_row]: TParserHandler: Got parsed data, number rows: 2
2025-12-09T03:42:00.886694Z :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-09T03:42:00.886699Z :FQ_ROW_DISPATCHER TRACE: filters_set.cpp:34: TTopicFilters: ProcessData for 1 clients, number rows: 2
2025-12-09T03:42:00.886706Z :FQ_ROW_DISPATCHER TRACE: filters_set.cpp:223: TTopicFilters: Pass 2 rows to purecalc filter (client id: [1:7581698329591116519:2164])
2025-12-09T03:42:00.886709Z :FQ_ROW_DISPATCHER TRACE: purecalc_filter.cpp:408: TProgramRunHandler: ProcessData for 2 rows
2025-12-09T03:42:00.886712Z :FQ_ROW_DISPATCHER TRACE: purecalc_filter.cpp:411: TProgramRunHandler: Add 2 rows to client [1:7581698329591116519:2164] without processing
2025-12-09T03:42:00.886725Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:292: TTopicFormatHandler [json_each_row]: TClientHandler [1:7581698329591116519:2164]: OnBatchFinish, offset: 2, number rows: 1, row size: 32, watermark: (empty maybe)
2025-12-09T03:42:00.886729Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:198: TopicSession [2:7581698385386716916:2185] AddDataToClient to [1:7581698329591116519:2164], offset: 2, number rows: 1, row size: 32, watermark: (empty maybe)
2025-12-09T03:42:00.886732Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:936: TopicSession [2:7581698385386716916:2185] Send TEvNewDataArrived to [1:7581698329591116519:2164]
2025-12-09T03:42:00.886748Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:292: TTopicFormatHandler [json_each_row]: TClientHandler [1:7581698329591116519:2164]: OnBatchFinish, offset: 3, number rows: 1, row size: 24, watermark: (empty maybe)
2025-12-09T03:42:00.886749Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:198: TopicSession [2:7581698385386716916:2185] AddDataToClient to [1:7581698329591116519:2164], offset: 3, number rows: 1, row size: 24, watermark: (empty maybe)
2025-12-09T03:42:00.886753Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:622: TTopicFormatHandler [json_each_row]: Commit client [1:7581698329591116519:2164] offset 3
2025-12-09T03:42:00.886758Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:210: TopicSession [2:7581698385386716916:2185] UpdateClientOffset for [1:7581698329591116519:2164], new offset: 3
2025-12-09T03:42:00.886768Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:466: TopicSession [2:7581698385386716916:2185] SubscribeOnNextEvent
2025-12-09T03:42:00.886783Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1081: RowDispatcher: Forward TEvNewDataArrived from [2:7581698385386716916:2185] to [1:7581698329591116519:2164] query id ptqudqgd7mnjklkpk65p
2025-12-09T03:42:00.887692Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:940: RowDispatcher: Received TEvGetNextBatch from [1:7581698329591116519:2164] part id 1 query id ptqudqgd7mnjklkpk65p
2025-12-09T03:42:00.887734Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:588: TopicSession [2:7581698385386716916:2185] TEvGetNextBatch from [1:7581698329591116519:2164]
2025-12-09T03:42:00.887742Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:324: TTopicFormatHandler [json_each_row]: TClientHandler [1:7581698329591116519:2164]: FinishPacking, batch size: 56, number rows: 2
2025-12-09T03:42:00.887752Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:174: TTopicFormatHandler [json_each_row]: TClientHandler [1:7581698329591116519:2164]: ExtractClientData, number batches: 1
2025-12-09T03:42:00.887763Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:764: TopicSession [2:7581698385386716916:2185] SendData to [1:7581698329591116519:2164], batch size 1
2025-12-09T03:42:00.887774Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:457: TopicSession [2:7581698385386716916:2185] Skip SubscribeOnNextEvent, has ReadSession: true, IsWaitingEvents: 1
2025-12-09T03:42:00.887784Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1100: RowDispatcher: Forward TEvMessageBatch from [2:7581698385386716916:2185] to [1:7581698329591116519:2164] query id ptqudqgd7mnjklkpk65p
2025-12-09T03:42:01.205150Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 4704978-d2d9dbd5-9fd4ff6e-873ef64b28, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:42:01.214514Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:42:01.214537Z :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:3732: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-syjwtgwtdu.auto.internal:3732
2025-12-09T03:42:01.871153Z :YDB_SDK INFO: actor.cpp:37: 2025-12-09T03:42:01.871131Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:redistribute_input:1:1:3:0
2025-12-09T03:42:01.871177Z :YDB_SDK INFO: actor.cpp:37: 2025-12-09T03:42:01.871175Z :INFO: [local] [local] [bbd68ba9-a4edaeed-59f9eebc-8f983e4f] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1000 BytesRead: 90 MessagesRead: 2 BytesReadCompressed: 90 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:42:01.874094Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:952: TopicSession [2:7581698385386716916:2185] SendStatistics
2025-12-09T03:42:01.874138Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1234: RowDispatcher: TEvSessionStatistic from [2:7581698385386716916:2185]
2025-12-09T03:42:02.204334Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7581698290936410633:2082]
2025-12-09T03:42:02.204366Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-09T03:42:02.208345Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 4704978-d2d9dbd5-9fd4ff6e-873ef64b29, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:42:02.210338Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-09T03:42:02.225474Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:42:02.225496Z :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:3732: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-syjwtgwtdu.auto.internal:3732
2025-12-09T03:42:02.470222Z :INTERCONNECT_NETWORK NOTICE: interconnect_handshake.cpp:1262: [2 <-> 3] network-related error occured on handshake: outgoing handshake Peer# ghrun-syjwtgwtdu(127.0.1.1:18078) Couldn't connect to any resolved address
2025-12-09T03:42:03.210044Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 4704978-d2d9dbd5-9fd4ff6e-873ef64b30, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:42:03.226486Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:42:03.226517Z :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:3732: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-syjwtgwtdu.auto.internal:3732
2025-12-09T03:42:03.571354Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:1001: RowDispatcher: Received TEvStopSession from [1:7581698329591116519:2164] topic redistribute_input query id ptqudqgd7mnjklkpk65p
2025-12-09T03:42:03.571382Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:1016: RowDispatcher: DeleteConsumer, readActorId [1:7581698329591116519:2164] query id ptqudqgd7mnjklkpk65p, partitions size 1
2025-12-09T03:42:03.571407Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:1036: RowDispatcher: Session is not used, sent TEvPoisonPill to [2:7581698385386716916:2185]
2025-12-09T03:42:03.571431Z :FQ_ROW_DISPATCHER DEBUG: topic_session.cpp:831: TopicSession [2:7581698385386716916:2185] TEvStopSession from [1:7581698329591116519:2164] topicPath redistribute_input clients count 1
2025-12-09T03:42:03.571436Z :FQ_ROW_DISPATCHER DEBUG: format_handler.cpp:477: TTopicFormatHandler [json_each_row]: Remove client with id [1:7581698329591116519:2164]
2025-12-09T03:42:03.571439Z :FQ_ROW_DISPATCHER TRACE: filters_set.cpp:94: TTopicFilters: Remove program with client id [1:7581698329591116519:2164]
2025-12-09T03:42:03.571453Z :FQ_ROW_DISPATCHER DEBUG: format_handler.cpp:559: TTopicFormatHandler [json_each_row]: UpdateParser to new schema with size 0
2025-12-09T03:42:03.571456Z :FQ_ROW_DISPATCHER INFO: format_handler.cpp:584: TTopicFormatHandler [json_each_row]: No columns to parse, reset parser
2025-12-09T03:42:03.571491Z :FQ_ROW_DISPATCHER DEBUG: topic_session.cpp:924: TopicSession [2:7581698385386716916:2185] Close read session
2025-12-09T03:42:03.571501Z :YDB_SDK INFO: actor.cpp:37: 2025-12-09T03:42:03.571497Z :INFO: [local] [local] [bbd68ba9-a4edaeed-59f9eebc-8f983e4f] Closing read session. Close timeout: 0.000000s
2025-12-09T03:42:03.571513Z :YDB_SDK INFO: actor.cpp:37: 2025-12-09T03:42:03.571511Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:redistribute_input:1:1:3:0
2025-12-09T03:42:03.571521Z :YDB_SDK INFO: actor.cpp:37: 2025-12-09T03:42:03.571520Z :INFO: [local] [local] [bbd68ba9-a4edaeed-59f9eebc-8f983e4f] Counters: { Errors: 0 CurrentSessionLifetimeMs: 2700 BytesRead: 90 MessagesRead: 2 BytesReadCompressed: 90 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:42:03.571537Z :YDB_SDK NOTICE: actor.cpp:37: 2025-12-09T03:42:03.571533Z :NOTICE: [local] [local] [bbd68ba9-a4edaeed-59f9eebc-8f983e4f] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Close with zero timeout " }
2025-12-09T03:42:03.571544Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:03.571543Z :DEBUG: [local] [local] [bbd68ba9-a4edaeed-59f9eebc-8f983e4f] [] Abort session to cluster
2025-12-09T03:42:03.574953Z :YDB_SDK INFO: actor.cpp:37: 2025-12-09T03:42:03.574945Z :INFO: [local] [local] [bbd68ba9-a4edaeed-59f9eebc-8f983e4f] Closing read session. Close timeout: 0.000000s
2025-12-09T03:42:03.574975Z :YDB_SDK INFO: actor.cpp:37: 2025-12-09T03:42:03.574972Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:redistribute_input:1:1:3:0
2025-12-09T03:42:03.574984Z :YDB_SDK INFO: actor.cpp:37: 2025-12-09T03:42:03.574981Z :INFO: [local] [local] [bbd68ba9-a4edaeed-59f9eebc-8f983e4f] Counters: { Errors: 0 CurrentSessionLifetimeMs: 2704 BytesRead: 90 MessagesRead: 2 BytesReadCompressed: 90 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:42:03.574995Z :YDB_SDK NOTICE: actor.cpp:37: 2025-12-09T03:42:03.574993Z :NOTICE: [local] [local] [bbd68ba9-a4edaeed-59f9eebc-8f983e4f] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-09T03:42:03.575086Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:457: TopicSession [2:7581698385386716916:2185] Skip SubscribeOnNextEvent, has ReadSession: false, IsWaitingEvents: 1
2025-12-09T03:42:03.575107Z :FQ_ROW_DISPATCHER DEBUG: topic_session.cpp:449: TopicSession [2:7581698385386716916:2185] PassAway
2025-12-09T03:42:03.873640Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1059: RowDispatcher: No consumer with EventQueueId = 1
2025-12-09T03:42:03.980691Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:597: RowDispatcher: TEvNodeDisconnected, node id 1
2025-12-09T03:42:03.981171Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1052: RowDispatcher: TEvTryConnect to node id 1
2025-12-09T03:42:03.981220Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:597: RowDispatcher: TEvNodeDisconnected, node id 1
