2025-12-09T03:41:34.635628Z :GRPC_SERVER NOTICE: grpc_request_proxy.cpp:380: Grpc request proxy started, nodeid# 3, serve as static node
2025-12-09T03:41:34.635697Z :GRPC_SERVER CRIT: grpc_request_proxy.cpp:440: Failed to deliver subscription request to config dispatcher
2025-12-09T03:41:34.635702Z :GRPC_SERVER NOTICE: grpc_request_proxy.cpp:380: Grpc request proxy started, nodeid# 3, serve as static node
2025-12-09T03:41:34.635718Z :GRPC_SERVER CRIT: grpc_request_proxy.cpp:440: Failed to deliver subscription request to config dispatcher
2025-12-09T03:41:34.635921Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:214: Bootstrap
2025-12-09T03:41:34.635924Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:217: Create sdk ydb connection
2025-12-09T03:41:34.636328Z :FQ_QUOTA_SERVICE INFO: quota_manager.cpp:196: STARTED
2025-12-09T03:41:34.636339Z :FQ_QUOTA_PROXY INFO: quota_proxy.cpp:90: STARTED
2025-12-09T03:41:34.636384Z :FQ_LOG_UPDATER DEBUG: log.cpp:93: Updated YQL logs priority: 8
2025-12-09T03:41:34.636388Z :FQ_LOG_UPDATER CRIT: log.cpp:55: Failed to deliver subscription request to config dispatcher.
2025-12-09T03:41:34.636429Z :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.636578Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:544: RowDispatcher: Successfully bootstrapped row dispatcher, id [3:7581698299143919834:2063], tenant /compute
2025-12-09T03:41:34.636592Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [3:7581698299143919834:2063]
2025-12-09T03:41:34.636595Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:329: Coordinator: Add new row dispatcher to map (state 1)
2025-12-09T03:41:34.636634Z :YQL_NODES_MANAGER INFO: nodes_manager.cpp:88: Bootstrap, InstanceId: a6d8c1c9-4841a6ed-c969f8a2-11a3bb1b
2025-12-09T03:41:34.636637Z :YQL_NODES_MANAGER DEBUG: nodes_manager.cpp:310: TNodesManagerActor::ResolveSelfAddress
2025-12-09T03:41:34.636654Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:293: Coordinator: Successfully bootstrapped coordinator, id [3:7581698299143919890:2092], NodesManagerId [0:4705493345362661702:78], rebalancing timeout 5.000000s
2025-12-09T03:41:34.636659Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:637: RowDispatcher: TEvCoordinatorChangesSubscribe from [3:7581698299143919890:2092]
2025-12-09T03:41:34.636666Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:232: TLeaderElection [3:7581698299143919891:2093] Successfully bootstrapped, local coordinator id [3:7581698299143919890:2092], tenant id compute, local mode 0, coordination node path local/compute, endpoint localhost:5893
2025-12-09T03:41:34.636668Z :YQ_TEST_CONNECTION DEBUG: test_connection.cpp:142: Starting yandex query test connection. Actor id: [3:7581698299143919839:2068]
2025-12-09T03:41:34.636703Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 83c8c316-aa5ebd67-5e333905-3178c6f91, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:41:34.637152Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:239: Successfully bootstrapped TStorageProxy [3:7581698299143919833:2062] with connection to localhost:5893:local
2025-12-09T03:41:34.637470Z :MEMORY_PROFILER NOTICE: monitor.cpp:332: Bootstrapped
2025-12-09T03:41:34.637906Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-12-09T03:41:34.638675Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:71: Run create coordination node "local/compute" actor
2025-12-09T03:41:34.638683Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:113: Call create coordination node "local/compute"
2025-12-09T03:41:34.638686Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:411: Call create coordination node "local/compute"
2025-12-09T03:41:34.639025Z :SCHEME_BOARD_SUBSCRIBER NOTICE: subscriber.cpp:849: [main][3:7581698299143919855:2079][/Root] Set up state: owner# [3:7581698299143919814:2053], state# { Deleted: 1 Strong: 0 Version: <Invalid> DomainId: <Invalid> AbandonedSchemeShards: there are 0 elements }
2025-12-09T03:41:34.639074Z :SCHEME_BOARD_SUBSCRIBER NOTICE: subscriber.cpp:849: [main][3:7581698299143919856:2080][/compute] Set up state: owner# [3:7581698299143919814:2053], state# { Deleted: 1 Strong: 0 Version: <Invalid> DomainId: <Invalid> AbandonedSchemeShards: there are 0 elements }
2025-12-09T03:41:34.639086Z :GRPC_SERVER WARN: grpc_request_proxy.cpp:583: SchemeBoardDelete /Root Strong=0
2025-12-09T03:41:34.639106Z :GRPC_SERVER WARN: grpc_request_proxy.cpp:583: SchemeBoardDelete /compute Strong=0
2025-12-09T03:41:34.639129Z :SCHEME_BOARD_SUBSCRIBER NOTICE: subscriber.cpp:849: [main][3:7581698299143919854:2078][/compute] Set up state: owner# [3:7581698299143919813:2052], state# { Deleted: 1 Strong: 0 Version: <Invalid> DomainId: <Invalid> AbandonedSchemeShards: there are 0 elements }
2025-12-09T03:41:34.639156Z :SCHEME_BOARD_SUBSCRIBER NOTICE: subscriber.cpp:849: [main][3:7581698299143919853:2077][/Root] Set up state: owner# [3:7581698299143919813:2052], state# { Deleted: 1 Strong: 0 Version: <Invalid> DomainId: <Invalid> AbandonedSchemeShards: there are 0 elements }
2025-12-09T03:41:34.639169Z :GRPC_SERVER WARN: grpc_request_proxy.cpp:583: SchemeBoardDelete /compute Strong=0
2025-12-09T03:41:34.639171Z :GRPC_SERVER WARN: grpc_request_proxy.cpp:583: SchemeBoardDelete /Root Strong=0
2025-12-09T03:41:34.651232Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:155: Successfully created coordination node "local/compute"
2025-12-09T03:41:34.651254Z :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.651278Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:345: TLeaderElection [3:7581698299143919891:2093] Coordination node successfully created
2025-12-09T03:41:34.651282Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:323: TLeaderElection [3:7581698299143919891:2093] Start session
2025-12-09T03:41:34.655369Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:359: TLeaderElection [3:7581698299143919891:2093] Session successfully created
2025-12-09T03:41:34.662459Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:372: TLeaderElection [3:7581698299143919891:2093] Semaphore successfully created
2025-12-09T03:41:34.662475Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:304: TLeaderElection [3:7581698299143919891:2093] Try to acquire semaphore
2025-12-09T03:41:34.662589Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:420: TLeaderElection [3:7581698299143919891:2093] Describe semaphore
2025-12-09T03:41:34.664962Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:41:34.664972Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-09T03:41:34.664993Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:389: Send NodeInfo with size: 2 to DynamicNameserver
2025-12-09T03:41:34.666919Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:469: TLeaderElection [3:7581698299143919891:2093] Semaphore successfully described: coordinator id [1:7581698290936410633:2082] generation 1
2025-12-09T03:41:34.666932Z :FQ_ROW_DISPATCHER INFO: leader_election.cpp:471: TLeaderElection [3:7581698299143919891:2093] Send TEvCoordinatorChanged to [3:7581698299143919834:2063], new coordinator id [1:7581698290936410633:2082], previous coordinator id [0:0:0]
2025-12-09T03:41:34.666949Z :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.666968Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:440: Coordinator: New leader [1:7581698290936410633:2082], SelfId [3:7581698299143919890:2092]
2025-12-09T03:41:34.666996Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:607: RowDispatcher: TEvUndelivered, from [1:7581698290936410633:2082], reason Disconnected
2025-12-09T03:41:35.634410Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 83c8c316-aa5ebd67-5e333905-3178c6f92, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:41:35.641199Z :FQ_QUOTA_SERVICE DEBUG: quota_manager.cpp:230: IC Peers[2]: [1, 2]
2025-12-09T03:41:35.642284Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:41:35.642291Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-09T03:41:36.634567Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7581698290936410633:2082]
2025-12-09T03:41:36.634586Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-09T03:41:36.634599Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 83c8c316-aa5ebd67-5e333905-3178c6f93, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:41:36.734219Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:41:36.734233Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-09T03:41:37.638240Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 83c8c316-aa5ebd67-5e333905-3178c6f94, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:41:37.661541Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:41:37.661555Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-09T03:41:38.635328Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7581698290936410633:2082]
2025-12-09T03:41:38.635353Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-09T03:41:38.638948Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 83c8c316-aa5ebd67-5e333905-3178c6f95, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:41:38.647203Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:41:38.647216Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-09T03:41:38.779676Z :INTERCONNECT WARN: interconnect_handshake.cpp:501: Handshake [3:7581698316323789247:2061] [node 1] ICH09 Neither CompatibilityInfo nor VersionTag of the peer can be validated, accepting by default
2025-12-09T03:41:39.316901Z :INTERCONNECT WARN: interconnect_handshake.cpp:501: Handshake [3:7581698320618756550:2062] [node 2] ICH09 Neither CompatibilityInfo nor VersionTag of the peer can be validated, accepting by default
2025-12-09T03:41:39.633703Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:665: Coordinator: Change global state to Started (by timeout)
2025-12-09T03:41:39.633704Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-12-09T03:41:39.638867Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 83c8c316-aa5ebd67-5e333905-3178c6f96, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:41:39.643141Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:41:39.643147Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-09T03:41:39.653231Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:389: Send NodeInfo with size: 2 to DynamicNameserver
2025-12-09T03:41:40.636272Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7581698290936410633:2082]
2025-12-09T03:41:40.636311Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-09T03:41:40.636792Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-09T03:41:40.639985Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 83c8c316-aa5ebd67-5e333905-3178c6f97, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:41:40.650530Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:41:40.650543Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-09T03:41:41.642480Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 83c8c316-aa5ebd67-5e333905-3178c6f98, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:41:41.790703Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:41:41.790718Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-09T03:41:42.509018Z :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 1
2025-12-09T03:41:42.509084Z :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:42.509151Z :FQ_ROW_DISPATCHER DEBUG: topic_session.cpp:443: TopicSession [3:7581698333503658455:2154] Bootstrap redistribute_input/1, Timeout 5.000000s sec
2025-12-09T03:41:42.509165Z :FQ_ROW_DISPATCHER INFO: topic_session.cpp:799: TopicSession [3:7581698333503658455:2154] New client: read actor id [1:7581698329591116519:2164], predicate: , watermark expr: , offset: (empty maybe)
2025-12-09T03:41:42.509206Z :FQ_ROW_DISPATCHER DEBUG: format_handler.cpp:440: TTopicFormatHandler [json_each_row]: Add client with id [1:7581698329591116519:2164]
2025-12-09T03:41:42.512913Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1052: RowDispatcher: TEvTryConnect to node id 1
2025-12-09T03:41:42.513254Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:587: RowDispatcher: EvNodeConnected, node id 1
2025-12-09T03:41:42.593948Z :FQ_ROW_DISPATCHER DEBUG: format_handler.cpp:559: TTopicFormatHandler [json_each_row]: UpdateParser to new schema with size 1
2025-12-09T03:41:42.597280Z :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.597356Z :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.597366Z :FQ_ROW_DISPATCHER TRACE: purecalc_filter.cpp:439: GenerateSql: No sql was generated
2025-12-09T03:41:42.597371Z :FQ_ROW_DISPATCHER TRACE: filters_set.cpp:116: TTopicFilters: Create program with client id [1:7581698329591116519:2164]
2025-12-09T03:41:42.597381Z :FQ_ROW_DISPATCHER TRACE: filters_set.cpp:110: TTopicFilters: Start program with client id [1:7581698329591116519:2164]
2025-12-09T03:41:42.597388Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:952: TopicSession [3:7581698333503658455:2154] SendStatistics
2025-12-09T03:41:42.597448Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1234: RowDispatcher: TEvSessionStatistic from [3:7581698333503658455:2154]
2025-12-09T03:41:42.639827Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7581698290936410633:2082]
2025-12-09T03:41:42.639861Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-09T03:41:42.643125Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-09T03:41:42.643229Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 83c8c316-aa5ebd67-5e333905-3178c6f99, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:41:42.680043Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:41:42.680063Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-09T03:41:43.643714Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 83c8c316-aa5ebd67-5e333905-3178c6f910, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:41:43.649646Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:41:43.649669Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-09T03:41:44.508914Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:952: TopicSession [3:7581698333503658455:2154] SendStatistics
2025-12-09T03:41:44.508951Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1234: RowDispatcher: TEvSessionStatistic from [3:7581698333503658455:2154]
2025-12-09T03:41:44.513006Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1067: RowDispatcher: Send TEvHeartbeat to [1:7581698329591116519:2164] query id ptqudqgd7mnjklkpk65p
2025-12-09T03:41:44.634158Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:599: Coordinator: Send TEvGetNodesRequest to NodesManager
2025-12-09T03:41:44.634187Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-12-09T03:41:44.634379Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:300: Received TNodesManagerActor::TEvGetNodesRequest
2025-12-09T03:41:44.634401Z :FQ_ROW_DISPATCHER INFO: coordinator.cpp:690: Coordinator: Updated node info, node count: 3
2025-12-09T03:41:44.642107Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7581698290936410633:2082]
2025-12-09T03:41:44.642132Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-09T03:41:44.644227Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 83c8c316-aa5ebd67-5e333905-3178c6f911, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:41:44.645807Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-09T03:41:44.650238Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:389: Send NodeInfo with size: 2 to DynamicNameserver
2025-12-09T03:41:44.664569Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:41:44.664579Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-09T03:41:45.644606Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 83c8c316-aa5ebd67-5e333905-3178c6f912, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:41:45.650909Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:41:45.650925Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-09T03:41:46.509860Z :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:46.509861Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:952: TopicSession [3:7581698333503658455:2154] SendStatistics
2025-12-09T03:41:46.509903Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1234: RowDispatcher: TEvSessionStatistic from [3:7581698333503658455:2154]
2025-12-09T03:41:46.642974Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7581698290936410633:2082]
2025-12-09T03:41:46.642995Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-09T03:41:46.643697Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-09T03:41:46.645226Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 83c8c316-aa5ebd67-5e333905-3178c6f913, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:41:46.654085Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:41:46.654106Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-09T03:41:47.599793Z :FQ_ROW_DISPATCHER INFO: topic_session.cpp:516: TopicSession [3:7581698333503658455:2154] Create topic session, Path redistribute_input/1, StartingMessageTimestamp 2025-12-09T03:41:42.267000Z, BufferSize 16000000, GetConsumerMode Without
2025-12-09T03:41:47.599830Z :YDB_SDK INFO: actor.cpp:37: 2025-12-09T03:41:47.599825Z :INFO: [local] [local] [79a3dc22-dd56ec8f-9547cb7c-1f443165] Starting read session
2025-12-09T03:41:47.599837Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:41:47.599834Z :DEBUG: [local] [local] [79a3dc22-dd56ec8f-9547cb7c-1f443165] Starting single session
2025-12-09T03:41:47.599884Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:41:47.599881Z :DEBUG: [local] [local] [79a3dc22-dd56ec8f-9547cb7c-1f443165] [] In Reconnect, ReadSizeBudget = 8000000, ReadSizeServerDelta = 0
2025-12-09T03:41:47.599887Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:41:47.599886Z :DEBUG: [local] [local] [79a3dc22-dd56ec8f-9547cb7c-1f443165] [] New values: ReadSizeBudget = 8000000, ReadSizeServerDelta = 0
2025-12-09T03:41:47.599892Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:41:47.599890Z :DEBUG: [local] [local] [79a3dc22-dd56ec8f-9547cb7c-1f443165] [] Reconnecting session to cluster  in 0.000000s
2025-12-09T03:41:47.600802Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:466: TopicSession [3:7581698333503658455:2154] SubscribeOnNextEvent
2025-12-09T03:41:47.608772Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:41:47.608751Z :DEBUG: [local] [local] [79a3dc22-dd56ec8f-9547cb7c-1f443165] [] Successfully connected. Initializing session
2025-12-09T03:41:47.612411Z :YDB_SDK INFO: actor.cpp:37: 2025-12-09T03:41:47.612398Z :INFO: [local] [local] [79a3dc22-dd56ec8f-9547cb7c-1f443165] [] Got InitResponse. ReadSessionId: _1_4_1901062193949589461_v1
2025-12-09T03:41:47.612426Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:41:47.612424Z :DEBUG: [local] [local] [79a3dc22-dd56ec8f-9547cb7c-1f443165] [] In ContinueReadingDataImpl, ReadSizeBudget = 8000000, ReadSizeServerDelta = 0
2025-12-09T03:41:47.612504Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:41:47.612502Z :DEBUG: [local] [local] [79a3dc22-dd56ec8f-9547cb7c-1f443165] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 8000000
2025-12-09T03:41:47.613928Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:559: TopicSession [3:7581698333503658455:2154] TEvPqEventsReady
2025-12-09T03:41:47.613958Z :FQ_ROW_DISPATCHER DEBUG: topic_session.cpp:677: TopicSession [3:7581698333503658455:2154] StartPartitionSessionEvent received
2025-12-09T03:41:47.613961Z :FQ_ROW_DISPATCHER DEBUG: topic_session.cpp:685: TopicSession [3:7581698333503658455:2154] Confirm StartPartitionSession with offset (NULL)
2025-12-09T03:41:47.613977Z :YDB_SDK INFO: actor.cpp:37: 2025-12-09T03:41:47.613972Z :INFO: [local] [local] [79a3dc22-dd56ec8f-9547cb7c-1f443165] [] Confirm partition stream create. Partition stream id: 1. Cluster: "-". Topic: "redistribute_input". Partition: 1. Read offset: (NULL)
2025-12-09T03:41:47.614083Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:466: TopicSession [3:7581698333503658455:2154] SubscribeOnNextEvent
2025-12-09T03:41:47.620013Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:41:47.620002Z :DEBUG: [local] [local] [79a3dc22-dd56ec8f-9547cb7c-1f443165] [] Got ReadResponse, serverBytesSize = 150, now ReadSizeBudget = 0, ReadSizeServerDelta = 7999850
2025-12-09T03:41:47.620056Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:41:47.620054Z :DEBUG: [local] [local] [79a3dc22-dd56ec8f-9547cb7c-1f443165] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 7999850
2025-12-09T03:41:47.620110Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:41:47.620107Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (0-1)
2025-12-09T03:41:47.620118Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:41:47.620115Z :DEBUG: [local] [local] [79a3dc22-dd56ec8f-9547cb7c-1f443165] [] Returning serverBytesSize = 150 to budget
2025-12-09T03:41:47.620122Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:41:47.620120Z :DEBUG: [local] [local] [79a3dc22-dd56ec8f-9547cb7c-1f443165] [] In ContinueReadingDataImpl, ReadSizeBudget = 150, ReadSizeServerDelta = 7999850
2025-12-09T03:41:47.620164Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:41:47.620162Z :DEBUG: [local] [local] [79a3dc22-dd56ec8f-9547cb7c-1f443165] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 8000000
2025-12-09T03:41:47.620220Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:559: TopicSession [3:7581698333503658455:2154] TEvPqEventsReady
2025-12-09T03:41:47.620241Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:41:47.620238Z :DEBUG: [local] Take Data. Partition 1. Read: {0, 0} (0-0)
2025-12-09T03:41:47.620248Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:41:47.620247Z :DEBUG: [local] Take Data. Partition 1. Read: {1, 0} (1-1)
2025-12-09T03:41:47.620260Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:41:47.620257Z :DEBUG: [local] [local] [79a3dc22-dd56ec8f-9547cb7c-1f443165] [] The application data is transferred to the client. Number of messages 2, size 60 bytes
2025-12-09T03:41:47.620265Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:41:47.620263Z :DEBUG: [local] [local] [79a3dc22-dd56ec8f-9547cb7c-1f443165] [] Returning serverBytesSize = 0 to budget
2025-12-09T03:41:47.620284Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:654: TopicSession [3:7581698333503658455:2154] Data received: Message { Data: "{"time": 100, "data": "hello"}" Information: { Offset: 0 ProducerId: "" SeqNo: 0 CreateTime: 2025-12-09T03:41:45.935000Z WriteTime: 2025-12-09T03:41:45.934000Z MessageGroupId: "" Meta: { } MessageMeta: { } } Partition session id: 1 Topic: "redistribute_input" Partition: 1 }
2025-12-09T03:41:47.620288Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:654: TopicSession [3:7581698333503658455:2154] Data received: Message { Data: "{"time": 100, "data": "hello"}" Information: { Offset: 1 ProducerId: "" SeqNo: 0 CreateTime: 2025-12-09T03:41:45.979000Z WriteTime: 2025-12-09T03:41:45.977000Z MessageGroupId: "" Meta: { } MessageMeta: { } } Partition session id: 1 Topic: "redistribute_input" Partition: 1 }
2025-12-09T03:41:47.620290Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:707: TopicSession [3:7581698333503658455:2154] SendToParsing, messages: 2
2025-12-09T03:41:47.620295Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:417: TTopicFormatHandler [json_each_row]: Send 2 messages to parser
2025-12-09T03:41:47.620299Z :FQ_ROW_DISPATCHER TRACE: json_parser.cpp:388: TJsonParser: Add 2 messages to parse
2025-12-09T03:41:47.620309Z :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.620312Z :FQ_ROW_DISPATCHER TRACE: json_parser.cpp:590: TJsonParser: Init parser, skipped 0, outputRowId 0 size 124
2025-12-09T03:41:47.620332Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:77: TTopicFormatHandler [json_each_row]: TParserHandler: Got parsed data, number rows: 2
2025-12-09T03:41:47.620338Z :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.620341Z :FQ_ROW_DISPATCHER TRACE: filters_set.cpp:34: TTopicFilters: ProcessData for 1 clients, number rows: 2
2025-12-09T03:41:47.620347Z :FQ_ROW_DISPATCHER TRACE: filters_set.cpp:223: TTopicFilters: Pass 2 rows to purecalc filter (client id: [1:7581698329591116519:2164])
2025-12-09T03:41:47.620349Z :FQ_ROW_DISPATCHER TRACE: purecalc_filter.cpp:408: TProgramRunHandler: ProcessData for 2 rows
2025-12-09T03:41:47.620353Z :FQ_ROW_DISPATCHER TRACE: purecalc_filter.cpp:411: TProgramRunHandler: Add 2 rows to client [1:7581698329591116519:2164] without processing
2025-12-09T03:41:47.620365Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:292: TTopicFormatHandler [json_each_row]: TClientHandler [1:7581698329591116519:2164]: OnBatchFinish, offset: 0, number rows: 1, row size: 17, watermark: (empty maybe)
2025-12-09T03:41:47.620369Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:198: TopicSession [3:7581698333503658455:2154] AddDataToClient to [1:7581698329591116519:2164], offset: 0, number rows: 1, row size: 17, watermark: (empty maybe)
2025-12-09T03:41:47.620372Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:936: TopicSession [3:7581698333503658455:2154] Send TEvNewDataArrived to [1:7581698329591116519:2164]
2025-12-09T03:41:47.620384Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:292: TTopicFormatHandler [json_each_row]: TClientHandler [1:7581698329591116519:2164]: OnBatchFinish, offset: 1, number rows: 1, row size: 9, watermark: (empty maybe)
2025-12-09T03:41:47.620386Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:198: TopicSession [3:7581698333503658455:2154] AddDataToClient to [1:7581698329591116519:2164], offset: 1, number rows: 1, row size: 9, watermark: (empty maybe)
2025-12-09T03:41:47.620389Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:622: TTopicFormatHandler [json_each_row]: Commit client [1:7581698329591116519:2164] offset 1
2025-12-09T03:41:47.620391Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:210: TopicSession [3:7581698333503658455:2154] UpdateClientOffset for [1:7581698329591116519:2164], new offset: 1
2025-12-09T03:41:47.620397Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:466: TopicSession [3:7581698333503658455:2154] SubscribeOnNextEvent
2025-12-09T03:41:47.620428Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1081: RowDispatcher: Forward TEvNewDataArrived from [3:7581698333503658455:2154] to [1:7581698329591116519:2164] query id ptqudqgd7mnjklkpk65p
2025-12-09T03:41:47.620880Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:940: RowDispatcher: Received TEvGetNextBatch from [1:7581698329591116519:2164] part id 1 query id ptqudqgd7mnjklkpk65p
2025-12-09T03:41:47.620905Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:588: TopicSession [3:7581698333503658455:2154] TEvGetNextBatch from [1:7581698329591116519:2164]
2025-12-09T03:41:47.620915Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:324: TTopicFormatHandler [json_each_row]: TClientHandler [1:7581698329591116519:2164]: FinishPacking, batch size: 26, number rows: 2
2025-12-09T03:41:47.620925Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:174: TTopicFormatHandler [json_each_row]: TClientHandler [1:7581698329591116519:2164]: ExtractClientData, number batches: 1
2025-12-09T03:41:47.620943Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:764: TopicSession [3:7581698333503658455:2154] SendData to [1:7581698329591116519:2164], batch size 1
2025-12-09T03:41:47.620954Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:457: TopicSession [3:7581698333503658455:2154] Skip SubscribeOnNextEvent, has ReadSession: true, IsWaitingEvents: 1
2025-12-09T03:41:47.620963Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1100: RowDispatcher: Forward TEvMessageBatch from [3:7581698333503658455:2154] to [1:7581698329591116519:2164] query id ptqudqgd7mnjklkpk65p
2025-12-09T03:41:47.645518Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 83c8c316-aa5ebd67-5e333905-3178c6f914, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:41:47.653566Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:41:47.653579Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-09T03:41:48.510740Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:952: TopicSession [3:7581698333503658455:2154] SendStatistics
2025-12-09T03:41:48.510774Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1234: RowDispatcher: TEvSessionStatistic from [3:7581698333503658455:2154]
2025-12-09T03:41:48.600193Z :YDB_SDK INFO: actor.cpp:37: 2025-12-09T03:41:48.600169Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:redistribute_input:1:1:1:0
2025-12-09T03:41:48.600212Z :YDB_SDK INFO: actor.cpp:37: 2025-12-09T03:41:48.600209Z :INFO: [local] [local] [79a3dc22-dd56ec8f-9547cb7c-1f443165] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1000 BytesRead: 60 MessagesRead: 2 BytesReadCompressed: 60 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:41:48.643875Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7581698290936410633:2082]
2025-12-09T03:41:48.643906Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-09T03:41:48.645927Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 83c8c316-aa5ebd67-5e333905-3178c6f915, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:41:48.646312Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-09T03:41:48.654185Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:41:48.654200Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-09T03:41:49.634078Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-12-09T03:41:49.644541Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:389: Send NodeInfo with size: 2 to DynamicNameserver
2025-12-09T03:41:49.646386Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 83c8c316-aa5ebd67-5e333905-3178c6f916, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:41:49.654169Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:41:49.654184Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-09T03:41:49.865698Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:597: RowDispatcher: TEvNodeDisconnected, node id 1
2025-12-09T03:41:49.867022Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1052: RowDispatcher: TEvTryConnect to node id 1
2025-12-09T03:41:49.869390Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:597: RowDispatcher: TEvNodeDisconnected, node id 1
2025-12-09T03:41:49.925938Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1052: RowDispatcher: TEvTryConnect to node id 1
2025-12-09T03:41:49.926005Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:597: RowDispatcher: TEvNodeDisconnected, node id 1
