2025-12-12T12:27:02.707796Z :GRPC_SERVER NOTICE: grpc_request_proxy.cpp:380: Grpc request proxy started, nodeid# 2, serve as static node
2025-12-12T12:27:02.707863Z :GRPC_SERVER CRIT: grpc_request_proxy.cpp:440: Failed to deliver subscription request to config dispatcher
2025-12-12T12:27:02.707868Z :GRPC_SERVER NOTICE: grpc_request_proxy.cpp:380: Grpc request proxy started, nodeid# 2, serve as static node
2025-12-12T12:27:02.707885Z :GRPC_SERVER CRIT: grpc_request_proxy.cpp:440: Failed to deliver subscription request to config dispatcher
2025-12-12T12:27:02.708069Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:214: Bootstrap
2025-12-12T12:27:02.708071Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:217: Create sdk ydb connection
2025-12-12T12:27:02.708382Z :MEMORY_PROFILER NOTICE: monitor.cpp:332: Bootstrapped
2025-12-12T12:27:02.710082Z :FQ_QUOTA_PROXY INFO: quota_proxy.cpp:90: STARTED
2025-12-12T12:27:02.710127Z :FQ_LOG_UPDATER DEBUG: log.cpp:93: Updated YQL logs priority: 8
2025-12-12T12:27:02.710131Z :FQ_LOG_UPDATER CRIT: log.cpp:55: Failed to deliver subscription request to config dispatcher.
2025-12-12T12:27:02.710175Z :YQ_RATE_LIMITER INFO: quoter_service.cpp:124: Bootstraping with config: { Enabled: true DataPlaneEnabled: true Database { Endpoint: "localhost:23627" Database: "local" TablePrefix: "RateLimiter_755dc3ae-6741-4057-8e98-960aa5272d3f" } Limiters { CoordinationNodePath: "rate_limiter" } }
2025-12-12T12:27:02.724549Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:544: RowDispatcher: Successfully bootstrapped row dispatcher, id [2:7582946963833380727:2063], tenant /compute
2025-12-12T12:27:02.724575Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [2:7582946963833380727:2063]
2025-12-12T12:27:02.724577Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:329: Coordinator: Add new row dispatcher to map (state 1)
2025-12-12T12:27:02.724747Z :YQL_NODES_MANAGER INFO: nodes_manager.cpp:88: Bootstrap, InstanceId: 41f02fa8-4f6579b8-b65bb5b4-e6e247cf
2025-12-12T12:27:02.724748Z :YQL_NODES_MANAGER DEBUG: nodes_manager.cpp:310: TNodesManagerActor::ResolveSelfAddress
2025-12-12T12:27:02.724778Z :YQ_TEST_CONNECTION DEBUG: test_connection.cpp:142: Starting yandex query test connection. Actor id: [2:7582946963833380732:2068]
2025-12-12T12:27:02.724879Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:232: TLeaderElection [2:7582946963833380805:2116] Successfully bootstrapped, local coordinator id [2:7582946963833380804:2115], tenant id compute, local mode 0, coordination node path local/compute, endpoint localhost:23627
2025-12-12T12:27:02.725551Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:239: Successfully bootstrapped TStorageProxy [2:7582946963833380726:2062] with connection to localhost:23627:local
2025-12-12T12:27:02.725594Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 1491b042-dfeb4c70-9fdeb3bd-5494e95c1, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:02.726175Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:71: Run create coordination node "local/compute" actor
2025-12-12T12:27:02.726178Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:113: Call create coordination node "local/compute"
2025-12-12T12:27:02.726180Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:411: Call create coordination node "local/compute"
2025-12-12T12:27:02.726217Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:293: Coordinator: Successfully bootstrapped coordinator, id [2:7582946963833380804:2115], NodesManagerId [0:4705493345362661702:78], rebalancing timeout 5.000000s
2025-12-12T12:27:02.726225Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:637: RowDispatcher: TEvCoordinatorChangesSubscribe from [2:7582946963833380804:2115]
2025-12-12T12:27:02.726606Z :SCHEME_BOARD_SUBSCRIBER NOTICE: subscriber.cpp:849: [main][2:7582946963833380747:2078][/compute] Set up state: owner# [2:7582946963833380706:2052], state# { Deleted: 1 Strong: 0 Version: <Invalid> DomainId: <Invalid> AbandonedSchemeShards: there are 0 elements }
2025-12-12T12:27:02.726736Z :SCHEME_BOARD_SUBSCRIBER NOTICE: subscriber.cpp:849: [main][2:7582946963833380748:2079][/Root] Set up state: owner# [2:7582946963833380707:2053], state# { Deleted: 1 Strong: 0 Version: <Invalid> DomainId: <Invalid> AbandonedSchemeShards: there are 0 elements }
2025-12-12T12:27:02.726801Z :GRPC_SERVER WARN: grpc_request_proxy.cpp:583: SchemeBoardDelete /compute Strong=0
2025-12-12T12:27:02.726848Z :SCHEME_BOARD_SUBSCRIBER NOTICE: subscriber.cpp:849: [main][2:7582946963833380746:2077][/Root] Set up state: owner# [2:7582946963833380706:2052], state# { Deleted: 1 Strong: 0 Version: <Invalid> DomainId: <Invalid> AbandonedSchemeShards: there are 0 elements }
2025-12-12T12:27:02.726853Z :GRPC_SERVER WARN: grpc_request_proxy.cpp:583: SchemeBoardDelete /Root Strong=0
2025-12-12T12:27:02.726855Z :GRPC_SERVER WARN: grpc_request_proxy.cpp:583: SchemeBoardDelete /Root Strong=0
2025-12-12T12:27:02.729940Z :SCHEME_BOARD_SUBSCRIBER NOTICE: subscriber.cpp:849: [main][2:7582946963833380749:2080][/compute] Set up state: owner# [2:7582946963833380707:2053], state# { Deleted: 1 Strong: 0 Version: <Invalid> DomainId: <Invalid> AbandonedSchemeShards: there are 0 elements }
2025-12-12T12:27:02.729987Z :GRPC_SERVER WARN: grpc_request_proxy.cpp:583: SchemeBoardDelete /compute Strong=0
2025-12-12T12:27:02.735104Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-12-12T12:27:02.747409Z :FQ_QUOTA_SERVICE INFO: quota_manager.cpp:196: STARTED
2025-12-12T12:27:02.759943Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:155: Successfully created coordination node "local/compute"
2025-12-12T12:27:02.759965Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:122: Reply for create coordination node "local/compute": { <main>: Error: Check failed: path: '/local/compute', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 19], type: EPathTypeKesus, state: EPathStateNoChanges), source_location: ydb/core/tx/schemeshard/schemeshard__operation_create_kesus.cpp:339 }
2025-12-12T12:27:02.759981Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:345: TLeaderElection [2:7582946963833380805:2116] Coordination node successfully created
2025-12-12T12:27:02.759985Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:323: TLeaderElection [2:7582946963833380805:2116] Start session
2025-12-12T12:27:02.767076Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:359: TLeaderElection [2:7582946963833380805:2116] Session successfully created
2025-12-12T12:27:02.770536Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:372: TLeaderElection [2:7582946963833380805:2116] Semaphore successfully created
2025-12-12T12:27:02.770552Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:304: TLeaderElection [2:7582946963833380805:2116] Try to acquire semaphore
2025-12-12T12:27:02.770657Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:420: TLeaderElection [2:7582946963833380805:2116] Describe semaphore
2025-12-12T12:27:02.772936Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:469: TLeaderElection [2:7582946963833380805:2116] Semaphore successfully described: coordinator id [1:7582946961519061550:2092] generation 1
2025-12-12T12:27:02.772953Z :FQ_ROW_DISPATCHER INFO: leader_election.cpp:471: TLeaderElection [2:7582946963833380805:2116] Send TEvCoordinatorChanged to [2:7582946963833380727:2063], new coordinator id [1:7582946961519061550:2092], previous coordinator id [0:0:0]
2025-12-12T12:27:02.772974Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:569: RowDispatcher: Coordinator changed, old leader (empty maybe), new [1:7582946961519061550:2092] generation 1
2025-12-12T12:27:02.772999Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:440: Coordinator: New leader [1:7582946961519061550:2092], SelfId [2:7582946963833380804:2115]
2025-12-12T12:27:02.775092Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:607: RowDispatcher: TEvUndelivered, from [1:7582946961519061550:2092], reason Disconnected
2025-12-12T12:27:02.775659Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:02.775673Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:02.775694Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:389: Send NodeInfo with size: 1 to DynamicNameserver
2025-12-12T12:27:03.724254Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 1491b042-dfeb4c70-9fdeb3bd-5494e95c2, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:03.727934Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:03.727957Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:03.747849Z :FQ_QUOTA_SERVICE DEBUG: quota_manager.cpp:230: IC Peers[1]: [1]
2025-12-12T12:27:03.871758Z :INTERCONNECT ERROR: interconnect_nameserver_dynamic.cpp:62:  ICN06 Unknown nodeId: 3
2025-12-12T12:27:04.323323Z :INTERCONNECT ERROR: interconnect_nameserver_dynamic.cpp:62:  ICN06 Unknown nodeId: 3
2025-12-12T12:27:04.727224Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582946961519061550:2092]
2025-12-12T12:27:04.727238Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 1491b042-dfeb4c70-9fdeb3bd-5494e95c3, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:04.727257Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:04.738188Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:04.738206Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:05.495836Z :INTERCONNECT ERROR: interconnect_nameserver_dynamic.cpp:62:  ICN06 Unknown nodeId: 3
2025-12-12T12:27:05.728270Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 1491b042-dfeb4c70-9fdeb3bd-5494e95c4, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:05.732874Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:05.732889Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:06.639491Z :INTERCONNECT WARN: interconnect_handshake.cpp:501: Handshake [2:7582946981013250125:2059] [node 1] ICH09 Neither CompatibilityInfo nor VersionTag of the peer can be validated, accepting by default
2025-12-12T12:27:06.727705Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582946961519061550:2092]
2025-12-12T12:27:06.727731Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:06.728285Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:06.728726Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 1491b042-dfeb4c70-9fdeb3bd-5494e95c5, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:06.734494Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:06.734523Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:06.976490Z :INTERCONNECT ERROR: interconnect_nameserver_dynamic.cpp:62:  ICN06 Unknown nodeId: 3
2025-12-12T12:27:07.724036Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:665: Coordinator: Change global state to Started (by timeout)
2025-12-12T12:27:07.729166Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 1491b042-dfeb4c70-9fdeb3bd-5494e95c6, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:07.733437Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:07.733455Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:07.735274Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-12-12T12:27:07.745387Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:389: Send NodeInfo with size: 2 to DynamicNameserver
2025-12-12T12:27:07.861209Z :INTERCONNECT WARN: interconnect_handshake.cpp:501: Handshake [2:7582946985308217435:2061] [node 3] ICH09 Neither CompatibilityInfo nor VersionTag of the peer can be validated, accepting by default
2025-12-12T12:27:08.731361Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582946961519061550:2092]
2025-12-12T12:27:08.731371Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:08.731384Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 1491b042-dfeb4c70-9fdeb3bd-5494e95c7, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:08.735100Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:08.735113Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:08.735550Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:08.748056Z :FQ_QUOTA_SERVICE DEBUG: quota_manager.cpp:230: IC Peers[2]: [1, 3]
2025-12-12T12:27:09.732112Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 1491b042-dfeb4c70-9fdeb3bd-5494e95c8, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:09.735646Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:09.735663Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:10.731548Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582946961519061550:2092]
2025-12-12T12:27:10.731577Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:10.732543Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 1491b042-dfeb4c70-9fdeb3bd-5494e95c9, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:10.733655Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:10.739119Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:10.739132Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:11.732988Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 1491b042-dfeb4c70-9fdeb3bd-5494e95c10, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:11.739249Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:11.739263Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:12.724840Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:599: Coordinator: Send TEvGetNodesRequest to NodesManager
2025-12-12T12:27:12.724869Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:300: Received TNodesManagerActor::TEvGetNodesRequest
2025-12-12T12:27:12.724885Z :FQ_ROW_DISPATCHER INFO: coordinator.cpp:690: Coordinator: Updated node info, node count: 3
2025-12-12T12:27:12.732379Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582946961519061550:2092]
2025-12-12T12:27:12.732404Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:12.732801Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:12.733433Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 1491b042-dfeb4c70-9fdeb3bd-5494e95c11, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:12.735528Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-12-12T12:27:12.737406Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:12.737415Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:12.741780Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:389: Send NodeInfo with size: 2 to DynamicNameserver
2025-12-12T12:27:13.430135Z :INTERCONNECT_NETWORK NOTICE: interconnect_tcp_input_session.cpp:712: [2 <-> 1] connection closed by peer
2025-12-12T12:27:13.430917Z :INTERCONNECT_NETWORK NOTICE: interconnect_handshake.cpp:1262: [2 <-> 1] network-related error occured on handshake: outgoing handshake Peer# ghrun-fhkyrtz6p4(127.0.1.1:15069) Socket error# Connection reset by peer state# ReceiveResponse processed# 0 remain# 52
2025-12-12T12:27:13.440294Z :INTERCONNECT_NETWORK NOTICE: interconnect_handshake.cpp:1262: [2 <-> 1] network-related error occured on handshake: outgoing handshake Peer# ghrun-fhkyrtz6p4(127.0.1.1:15069) Couldn't connect to any resolved address
2025-12-12T12:27:13.461026Z :INTERCONNECT_NETWORK NOTICE: interconnect_handshake.cpp:1262: [2 <-> 1] network-related error occured on handshake: outgoing handshake Peer# ghrun-fhkyrtz6p4(127.0.1.1:15069) Couldn't connect to any resolved address
2025-12-12T12:27:13.501784Z :INTERCONNECT_NETWORK NOTICE: interconnect_handshake.cpp:1262: [2 <-> 1] network-related error occured on handshake: outgoing handshake Peer# ghrun-fhkyrtz6p4(127.0.1.1:15069) Couldn't connect to any resolved address
2025-12-12T12:27:13.572055Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:386: TLeaderElection [2:7582946963833380805:2116] Semaphore successfully acquired
2025-12-12T12:27:13.572110Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:438: TLeaderElection [2:7582946963833380805:2116] Semaphore changed
2025-12-12T12:27:13.572114Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:304: TLeaderElection [2:7582946963833380805:2116] Try to acquire semaphore
2025-12-12T12:27:13.572295Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:420: TLeaderElection [2:7582946963833380805:2116] Describe semaphore
2025-12-12T12:27:13.573071Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [3:7582946968842489002:2063]
2025-12-12T12:27:13.573085Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [3:7582946968842489002:2063]
2025-12-12T12:27:13.573087Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:329: Coordinator: Add new row dispatcher to map (state 1)
2025-12-12T12:27:13.573092Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [3:7582946968842489002:2063]
2025-12-12T12:27:13.573098Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:392: Coordinator: EvNodeConnected 3
2025-12-12T12:27:13.574339Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:386: TLeaderElection [2:7582946963833380805:2116] Semaphore successfully acquired
2025-12-12T12:27:13.574426Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:469: TLeaderElection [2:7582946963833380805:2116] Semaphore successfully described: coordinator id [2:7582946963833380804:2115] generation 2
2025-12-12T12:27:13.574430Z :FQ_ROW_DISPATCHER INFO: leader_election.cpp:471: TLeaderElection [2:7582946963833380805:2116] Send TEvCoordinatorChanged to [2:7582946963833380727:2063], new coordinator id [2:7582946963833380804:2115], previous coordinator id [1:7582946961519061550:2092]
2025-12-12T12:27:13.574455Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:569: RowDispatcher: Coordinator changed, old leader [1:7582946961519061550:2092], new [2:7582946963833380804:2115] generation 2
2025-12-12T12:27:13.574468Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [2:7582946963833380727:2063]
2025-12-12T12:27:13.574472Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [2:7582946963833380727:2063]
2025-12-12T12:27:13.574474Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [2:7582946963833380727:2063]
2025-12-12T12:27:13.574483Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:440: Coordinator: New leader [2:7582946963833380804:2115], SelfId [2:7582946963833380804:2115]
2025-12-12T12:27:13.574492Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:13.583289Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [3:7582946968842489002:2063]
2025-12-12T12:27:13.583305Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [3:7582946968842489002:2063]
2025-12-12T12:27:13.583308Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [3:7582946968842489002:2063]
2025-12-12T12:27:13.733893Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 1491b042-dfeb4c70-9fdeb3bd-5494e95c12, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:13.737637Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:13.737649Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:13.743509Z :INTERCONNECT_NETWORK NOTICE: interconnect_handshake.cpp:1262: [2 <-> 1] network-related error occured on handshake: outgoing handshake Peer# ghrun-fhkyrtz6p4(127.0.1.1:15069) Couldn't connect to any resolved address
2025-12-12T12:27:14.705044Z :INTERCONNECT_NETWORK NOTICE: interconnect_handshake.cpp:1262: [2 <-> 1] network-related error occured on handshake: outgoing handshake Peer# ghrun-fhkyrtz6p4(127.0.1.1:15069) Couldn't connect to any resolved address
2025-12-12T12:27:14.733301Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [2:7582946963833380804:2115]
2025-12-12T12:27:14.733325Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:14.733332Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [2:7582946963833380727:2063]
2025-12-12T12:27:14.733336Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [2:7582946963833380727:2063]
2025-12-12T12:27:14.733340Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [2:7582946963833380727:2063]
2025-12-12T12:27:14.733349Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:14.734318Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 1491b042-dfeb4c70-9fdeb3bd-5494e95c13, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:14.738112Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:14.738123Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:15.264111Z :INTERCONNECT WARN: interconnect_handshake.cpp:501: Handshake [2:7582947019667955870:2069] [node 1] ICH09 Neither CompatibilityInfo nor VersionTag of the peer can be validated, accepting by default
2025-12-12T12:27:15.584551Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [3:7582946968842489002:2063]
2025-12-12T12:27:15.584566Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [3:7582946968842489002:2063]
2025-12-12T12:27:15.584570Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [3:7582946968842489002:2063]
2025-12-12T12:27:15.734752Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 1491b042-dfeb4c70-9fdeb3bd-5494e95c14, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:15.739502Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:15.739518Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:16.734222Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [2:7582946963833380804:2115]
2025-12-12T12:27:16.734276Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:16.734285Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [2:7582946963833380727:2063]
2025-12-12T12:27:16.734305Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [2:7582946963833380727:2063]
2025-12-12T12:27:16.734309Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [2:7582946963833380727:2063]
2025-12-12T12:27:16.734330Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:16.735234Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 1491b042-dfeb4c70-9fdeb3bd-5494e95c15, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:16.741790Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:16.741809Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:17.178036Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582947022284904054:2063]
2025-12-12T12:27:17.178068Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582947022284904054:2063]
2025-12-12T12:27:17.178072Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:329: Coordinator: Add new row dispatcher to map (state 1)
2025-12-12T12:27:17.178078Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582947022284904054:2063]
2025-12-12T12:27:17.178089Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:392: Coordinator: EvNodeConnected 1
2025-12-12T12:27:17.586328Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [3:7582946968842489002:2063]
2025-12-12T12:27:17.586405Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [3:7582946968842489002:2063]
2025-12-12T12:27:17.586412Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [3:7582946968842489002:2063]
2025-12-12T12:27:17.736738Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 1491b042-dfeb4c70-9fdeb3bd-5494e95c16, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:17.736738Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-12-12T12:27:17.740905Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:17.740923Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:17.751938Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:389: Send NodeInfo with size: 2 to DynamicNameserver
2025-12-12T12:27:18.735110Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [2:7582946963833380804:2115]
2025-12-12T12:27:18.735132Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:18.735140Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [2:7582946963833380727:2063]
2025-12-12T12:27:18.735143Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [2:7582946963833380727:2063]
2025-12-12T12:27:18.735161Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [2:7582946963833380727:2063]
2025-12-12T12:27:18.735171Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:18.737143Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 1491b042-dfeb4c70-9fdeb3bd-5494e95c17, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:18.740673Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:18.740685Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:19.178507Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582947022284904054:2063]
2025-12-12T12:27:19.178528Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582947022284904054:2063]
2025-12-12T12:27:19.178532Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582947022284904054:2063]
2025-12-12T12:27:19.586130Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [3:7582946968842489002:2063]
2025-12-12T12:27:19.586153Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [3:7582946968842489002:2063]
2025-12-12T12:27:19.586158Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [3:7582946968842489002:2063]
2025-12-12T12:27:19.737561Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 1491b042-dfeb4c70-9fdeb3bd-5494e95c18, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:19.741262Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:19.741281Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:20.736028Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [2:7582946963833380804:2115]
2025-12-12T12:27:20.736052Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:20.736060Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [2:7582946963833380727:2063]
2025-12-12T12:27:20.736063Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [2:7582946963833380727:2063]
2025-12-12T12:27:20.736067Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [2:7582946963833380727:2063]
2025-12-12T12:27:20.736077Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:20.738061Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 1491b042-dfeb4c70-9fdeb3bd-5494e95c19, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:20.741849Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:20.741866Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:21.179464Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582947022284904054:2063]
2025-12-12T12:27:21.179486Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582947022284904054:2063]
2025-12-12T12:27:21.179489Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582947022284904054:2063]
2025-12-12T12:27:21.586928Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [3:7582946968842489002:2063]
2025-12-12T12:27:21.586946Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [3:7582946968842489002:2063]
2025-12-12T12:27:21.586949Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [3:7582946968842489002:2063]
2025-12-12T12:27:21.738515Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 1491b042-dfeb4c70-9fdeb3bd-5494e95c20, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:21.754714Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:21.754734Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:22.736873Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-12-12T12:27:22.737177Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [2:7582946963833380804:2115]
2025-12-12T12:27:22.737188Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:22.737194Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [2:7582946963833380727:2063]
2025-12-12T12:27:22.737199Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [2:7582946963833380727:2063]
2025-12-12T12:27:22.737203Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [2:7582946963833380727:2063]
2025-12-12T12:27:22.737207Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:22.738916Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 1491b042-dfeb4c70-9fdeb3bd-5494e95c21, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:22.742554Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:22.742561Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:22.749797Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:389: Send NodeInfo with size: 2 to DynamicNameserver
2025-12-12T12:27:23.180430Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582947022284904054:2063]
2025-12-12T12:27:23.180450Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582947022284904054:2063]
2025-12-12T12:27:23.180455Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582947022284904054:2063]
2025-12-12T12:27:23.591147Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [3:7582946968842489002:2063]
2025-12-12T12:27:23.591165Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [3:7582946968842489002:2063]
2025-12-12T12:27:23.591168Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [3:7582946968842489002:2063]
2025-12-12T12:27:23.743545Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 1491b042-dfeb4c70-9fdeb3bd-5494e95c22, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:23.751133Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:23.751150Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:24.739464Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [2:7582946963833380804:2115]
2025-12-12T12:27:24.739488Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:24.739496Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [2:7582946963833380727:2063]
2025-12-12T12:27:24.739500Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [2:7582946963833380727:2063]
2025-12-12T12:27:24.739505Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [2:7582946963833380727:2063]
2025-12-12T12:27:24.739516Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:24.743949Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 1491b042-dfeb4c70-9fdeb3bd-5494e95c23, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:24.747809Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:24.747827Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:25.181284Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582947022284904054:2063]
2025-12-12T12:27:25.181310Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582947022284904054:2063]
2025-12-12T12:27:25.181315Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582947022284904054:2063]
2025-12-12T12:27:25.588749Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [3:7582946968842489002:2063]
2025-12-12T12:27:25.588765Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [3:7582946968842489002:2063]
2025-12-12T12:27:25.588769Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [3:7582946968842489002:2063]
2025-12-12T12:27:25.744382Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 1491b042-dfeb4c70-9fdeb3bd-5494e95c24, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:25.748106Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:25.748124Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:26.739724Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [2:7582946963833380804:2115]
2025-12-12T12:27:26.739744Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:26.739751Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [2:7582946963833380727:2063]
2025-12-12T12:27:26.739757Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [2:7582946963833380727:2063]
2025-12-12T12:27:26.739760Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [2:7582946963833380727:2063]
2025-12-12T12:27:26.739770Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:26.744846Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 1491b042-dfeb4c70-9fdeb3bd-5494e95c25, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:26.748775Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:26.748790Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:27.182234Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582947022284904054:2063]
2025-12-12T12:27:27.182264Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582947022284904054:2063]
2025-12-12T12:27:27.182268Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582947022284904054:2063]
2025-12-12T12:27:27.589601Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [3:7582946968842489002:2063]
2025-12-12T12:27:27.589618Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [3:7582946968842489002:2063]
2025-12-12T12:27:27.589622Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [3:7582946968842489002:2063]
2025-12-12T12:27:27.737092Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-12-12T12:27:27.745502Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 1491b042-dfeb4c70-9fdeb3bd-5494e95c26, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:27.745822Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:389: Send NodeInfo with size: 2 to DynamicNameserver
2025-12-12T12:27:27.750157Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:27.750170Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:28.740648Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [2:7582946963833380804:2115]
2025-12-12T12:27:28.740672Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:28.740688Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [2:7582946963833380727:2063]
2025-12-12T12:27:28.740693Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [2:7582946963833380727:2063]
2025-12-12T12:27:28.740695Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [2:7582946963833380727:2063]
2025-12-12T12:27:28.740708Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:28.745747Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 1491b042-dfeb4c70-9fdeb3bd-5494e95c27, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:28.749796Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:28.749808Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:29.183015Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582947022284904054:2063]
2025-12-12T12:27:29.183032Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582947022284904054:2063]
2025-12-12T12:27:29.183035Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582947022284904054:2063]
2025-12-12T12:27:29.595292Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [3:7582946968842489002:2063]
2025-12-12T12:27:29.595310Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [3:7582946968842489002:2063]
2025-12-12T12:27:29.595314Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [3:7582946968842489002:2063]
2025-12-12T12:27:29.746174Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 1491b042-dfeb4c70-9fdeb3bd-5494e95c28, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:29.750514Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:29.750527Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:30.741549Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [2:7582946963833380804:2115]
2025-12-12T12:27:30.741573Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:30.741589Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [2:7582946963833380727:2063]
2025-12-12T12:27:30.741597Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [2:7582946963833380727:2063]
2025-12-12T12:27:30.741600Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [2:7582946963833380727:2063]
2025-12-12T12:27:30.741609Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:30.747442Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 1491b042-dfeb4c70-9fdeb3bd-5494e95c29, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:30.751740Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:30.751758Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:31.183903Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582947022284904054:2063]
2025-12-12T12:27:31.183924Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582947022284904054:2063]
2025-12-12T12:27:31.183928Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582947022284904054:2063]
2025-12-12T12:27:31.593464Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [3:7582946968842489002:2063]
2025-12-12T12:27:31.593482Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [3:7582946968842489002:2063]
2025-12-12T12:27:31.593486Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [3:7582946968842489002:2063]
2025-12-12T12:27:31.748059Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 1491b042-dfeb4c70-9fdeb3bd-5494e95c30, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:31.751845Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:31.751858Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:32.737247Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-12-12T12:27:32.742400Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [2:7582946963833380804:2115]
2025-12-12T12:27:32.742422Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:32.742430Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [2:7582946963833380727:2063]
2025-12-12T12:27:32.742434Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [2:7582946963833380727:2063]
2025-12-12T12:27:32.742438Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [2:7582946963833380727:2063]
2025-12-12T12:27:32.742449Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:32.747106Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:389: Send NodeInfo with size: 2 to DynamicNameserver
2025-12-12T12:27:32.748558Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 1491b042-dfeb4c70-9fdeb3bd-5494e95c31, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:32.752108Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:32.752127Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:33.184851Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582947022284904054:2063]
2025-12-12T12:27:33.184870Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582947022284904054:2063]
2025-12-12T12:27:33.184874Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582947022284904054:2063]
2025-12-12T12:27:33.202215Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: 1491b042-dfeb4c70-9fdeb3bd-5494e95c 2025-12-12 12:27:33.202 DEBUG ydbd(pid=1192649, tid=0x00007F4166DDD640) [DQ] local_worker_manager.cpp:316: {ptqudq7uffpn58fsu002} TLocalWorkerManager::TEvAllocateWorkersRequest 562954248388609
2025-12-12T12:27:33.202284Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: 1491b042-dfeb4c70-9fdeb3bd-5494e95c 2025-12-12 12:27:33.202 DEBUG ydbd(pid=1192649, tid=0x00007F4166DDD640) [DQ] local_worker_manager.cpp:376: {ptqudq7uffpn58fsu002} Create compute actor: async
2025-12-12T12:27:33.237295Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:144: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Start compute actor [2:7582947096977367208:2158], task: 2
2025-12-12T12:27:33.237343Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:114: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Use CPU quota: 1. Rate limiter resource: { "local/RateLimiter_755dc3ae-6741-4057-8e98-960aa5272d3f/rate_limiter", "mock_cloud/my_folder/ptqudq7uffpn58fsu002" }
2025-12-12T12:27:33.328232Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:197: [] Task: 2. Got TEvNewCheckpointCoordinator event: generation 2, actorId: [1:7582947099594315658:2247]
2025-12-12T12:27:33.328250Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:208: [] Task: 2. Assign checkpoint coordinator (generation = 2)
2025-12-12T12:27:33.329014Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1447: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Create sink for output 0 { Sink { Type: "PqSink" Settings { type_url: "type.googleapis.com/NYql.NPq.NProto.TDqPqTopicSink" value: "\n%test_group_by_hop_restart_node_output\022\017localhost:23627\032\025\n\023cluster:default_yds\"\005local0\0018\002" } } }
2025-12-12T12:27:33.329649Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:265: [ptqudq7uffpn58fsu002-0] Task: 2. [Checkpoint 1.9] TEvRestoreFromCheckpoint, StateLoadPlan = { StateType: STATE_TYPE_OWN }
2025-12-12T12:27:33.329713Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:508: [ptqudq7uffpn58fsu002-0] [1:9] Got TEvGetTaskState: tasks {2}
2025-12-12T12:27:33.329738Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:519: [ptqudq7uffpn58fsu002-0] [1:9] GetState, tasks: 2
2025-12-12T12:27:33.329777Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:395: [ptqudq7uffpn58fsu002-0] Task: 2. Handle connected node 1
2025-12-12T12:27:33.331397Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1064: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Received channels info: Update { Id: 1 TransportVersion: DATA_TRANSPORT_UV_PICKLE_1_0 SrcTaskId: 1 DstTaskId: 2 SrcEndpoint { ActorId { RawX1: 7582947099594315661 RawX2: 4503603922340042 } } DstEndpoint { ActorId { RawX1: 7582947096977367208 RawX2: 4503608217307246 } } WatermarksMode: WATERMARKS_MODE_DISABLED SrcStageId: 201976 DstStageId: 201993 }
2025-12-12T12:27:33.331409Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1071: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Update input channelId: 1, peer: [1:7582947099594315661:2250]
2025-12-12T12:27:33.405411Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:654: [ptqudq7uffpn58fsu002-0] [1:9] ListOfStates results:
2025-12-12T12:27:33.405442Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:675: [ptqudq7uffpn58fsu002-0] [1:9] taskId 2 checkpoint id: 1:9, rows count: 1
2025-12-12T12:27:33.405444Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:675: [ptqudq7uffpn58fsu002-0] [1:9] taskId 2 checkpoint id: 1:8, rows count: 1
2025-12-12T12:27:33.405446Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:675: [ptqudq7uffpn58fsu002-0] [1:9] taskId 2 checkpoint id: 1:7, rows count: 1
2025-12-12T12:27:33.405450Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:675: [ptqudq7uffpn58fsu002-0] [1:9] taskId 2 checkpoint id: 1:6, rows count: 1
2025-12-12T12:27:33.405452Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:675: [ptqudq7uffpn58fsu002-0] [1:9] taskId 2 checkpoint id: 1:5, rows count: 1
2025-12-12T12:27:33.405454Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:675: [ptqudq7uffpn58fsu002-0] [1:9] taskId 2 checkpoint id: 1:4, rows count: 1
2025-12-12T12:27:33.405456Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:675: [ptqudq7uffpn58fsu002-0] [1:9] taskId 2 checkpoint id: 1:3, rows count: 1
2025-12-12T12:27:33.405458Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:675: [ptqudq7uffpn58fsu002-0] [1:9] taskId 2 checkpoint id: 1:2, rows count: 1
2025-12-12T12:27:33.405460Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:675: [ptqudq7uffpn58fsu002-0] [1:9] taskId 2 checkpoint id: 1:1, rows count: 1
2025-12-12T12:27:33.405468Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:901: [ptqudq7uffpn58fsu002-0] [1:9] SkipStatesInFuture, skip 0 checkpoints
2025-12-12T12:27:33.406864Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:796: [ptqudq7uffpn58fsu002-0] [1:9] SelectState: task_id 2, seq_no 9, blob_seq_num 0
2025-12-12T12:27:33.461951Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:410: [ptqudq7uffpn58fsu002-0] [1:9] DeserializeState, task id 2, blob size 139
2025-12-12T12:27:33.461987Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:960: [ptqudq7uffpn58fsu002-0] [1:9] ApplyIncrements
2025-12-12T12:27:33.462545Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:527: [ptqudq7uffpn58fsu002-0] [{ Id: 9 Generation: 1 }] Send TEvGetTaskStateResult: tasks: {2}
2025-12-12T12:27:33.462604Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:336: [ptqudq7uffpn58fsu002-0] Task: 2. [Checkpoint 1.9] TEvGetTaskStateResult: restoring state
2025-12-12T12:27:33.462616Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:793: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Load state
2025-12-12T12:27:33.462808Z :KQP_COMPUTE DEBUG: dq_pq_write_actor.cpp:268: SelfId: [0:0:0], TxId: ptqudq7uffpn58fsu002, TaskId: 2, PQ sink. Load state: { SourceId: "1c92a47f-cd3e48b0-b9339377-f0c17b3b" ConfirmedSeqNo: 2 EgressBytes: 124 }
2025-12-12T12:27:33.462815Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:821: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. State size: 49
2025-12-12T12:27:33.462847Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:362: [ptqudq7uffpn58fsu002-0] Task: 2. [Checkpoint 1.9] Checkpoint state restored
2025-12-12T12:27:33.463282Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1164: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Got TEvRun from actor [1:7582947099594315658:2247]
2025-12-12T12:27:33.463306Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Poll inputs
2025-12-12T12:27:33.463308Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Poll sources
2025-12-12T12:27:33.463310Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-12-12T12:27:33.463360Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: 1491b042-dfeb4c70-9fdeb3bd-5494e95c 2025-12-12 12:27:33.463 DEBUG ydbd(pid=1192649, tid=0x00007F4166DDD640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Run task: 2
2025-12-12T12:27:33.463417Z :FQ_ROW_DISPATCHER INFO: coordinator.cpp:507: Coordinator: TEvCoordinatorRequest from [1:7582947099594315665:2250], test_group_by_hop_restart_node_input, partIds: 0
2025-12-12T12:27:33.463443Z :KQP_COMPUTE TRACE: dq_compute_memory_quota.h:97: TxId: ptqudq7uffpn58fsu002, task: 2. Peak memory usage: 2031616
2025-12-12T12:27:33.463445Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:562: Coordinator: Send TEvCoordinatorResult to [1:7582947099594315665:2250]
2025-12-12T12:27:33.463457Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. update task runner stats
2025-12-12T12:27:33.463486Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-12T12:27:33.463493Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:27:33.463496Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-12T12:27:33.463500Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1107: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Ask CPU quota: 94ms
2025-12-12T12:27:33.463532Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [0:0:0], TxId: ptqudq7uffpn58fsu002, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-12-12T12:27:33.463648Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-12-12T12:27:33.463656Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-12T12:27:33.463662Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:605: TxId: ptqudq7uffpn58fsu002, task: 2. no poll, channelId: 1, hasPeer: 1, finished: 0, retry: 0, lastSeqNo: 0, freeSpace: 1000000
2025-12-12T12:27:33.464504Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:853: RowDispatcher: Received TEvStartSession from [1:7582947099594315665:2250], read group ptcudq7ufg88kfhtto4t, topicPath test_group_by_hop_restart_node_input part id 0 query id ptqudq7uffpn58fsu002 cookie 1
2025-12-12T12:27:33.464556Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:892: RowDispatcher: Create new session: read group ptcudq7ufg88kfhtto4t topic test_group_by_hop_restart_node_input part id 0
2025-12-12T12:27:33.464629Z :FQ_ROW_DISPATCHER DEBUG: topic_session.cpp:443: TopicSession [2:7582947096977367213:2159] Bootstrap test_group_by_hop_restart_node_input/0, Timeout 5.000000s sec
2025-12-12T12:27:33.464638Z :FQ_ROW_DISPATCHER INFO: topic_session.cpp:799: TopicSession [2:7582947096977367213:2159] New client: read actor id [1:7582947099594315665:2250], predicate: , watermark expr: , offset: 5
2025-12-12T12:27:33.464708Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1165: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. CPU quota delay: 1ms
2025-12-12T12:27:33.464711Z :FQ_ROW_DISPATCHER DEBUG: format_handler.cpp:440: TTopicFormatHandler [json_each_row]: Add client with id [1:7582947099594315665:2250]
2025-12-12T12:27:33.464784Z :FQ_ROW_DISPATCHER DEBUG: format_handler.cpp:559: TTopicFormatHandler [json_each_row]: UpdateParser to new schema with size 2
2025-12-12T12:27:33.472651Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1052: RowDispatcher: TEvTryConnect to node id 1
2025-12-12T12:27:33.472664Z :FQ_ROW_DISPATCHER INFO: json_parser.cpp:355: TJsonParser: Simdjson active implementation icelake (Intel/AMD AVX512), error skip mode: 0
2025-12-12T12:27:33.472805Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:587: RowDispatcher: EvNodeConnected, node id 1
2025-12-12T12:27:33.472828Z :FQ_ROW_DISPATCHER DEBUG: format_handler.cpp:570: TTopicFormatHandler [json_each_row]: Parser was created on schema with 2 columns
2025-12-12T12:27:33.472833Z :FQ_ROW_DISPATCHER TRACE: purecalc_filter.cpp:439: GenerateSql: No sql was generated
2025-12-12T12:27:33.472836Z :FQ_ROW_DISPATCHER TRACE: filters_set.cpp:116: TTopicFilters: Create program with client id [1:7582947099594315665:2250]
2025-12-12T12:27:33.472845Z :FQ_ROW_DISPATCHER TRACE: filters_set.cpp:110: TTopicFilters: Start program with client id [1:7582947099594315665:2250]
2025-12-12T12:27:33.472850Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:952: TopicSession [2:7582947096977367213:2159] SendStatistics
2025-12-12T12:27:33.472871Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1234: RowDispatcher: TEvSessionStatistic from [2:7582947096977367213:2159]
2025-12-12T12:27:33.473187Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:27:33.473177Z :INFO: [local] OnFederationDiscovery fall back to single mode, database=local
2025-12-12T12:27:33.473535Z :YDB_SDK INFO: actor.cpp:37: [] [] Start federated write session to database '' (previous was <empty>) FederationState: { Status: SUCCESS SelfLocation: "" DbInfos: [ { path: "local" endpoint: "localhost:23627" status: AVAILABLE weight: 100 } ] ControlPlaneEndpoint: localhost:23627 }
2025-12-12T12:27:33.473638Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:33.473635Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uffpn58fsu002, TaskId: 2, PQ sink. ]  SessionId []  MessageGroupId [1c92a47f-cd3e48b0-b9339377-f0c17b3b] Write session: try to update token
2025-12-12T12:27:33.474003Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:27:33.473998Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uffpn58fsu002, TaskId: 2, PQ sink. ]  SessionId []  MessageGroupId [1c92a47f-cd3e48b0-b9339377-f0c17b3b] Start write session. Will connect to nodeId: 0
2025-12-12T12:27:33.474373Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:33.474358Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uffpn58fsu002, TaskId: 2, PQ sink. ]  SessionId []  MessageGroupId [1c92a47f-cd3e48b0-b9339377-f0c17b3b] Write session: write to message_group: 1c92a47f-cd3e48b0-b9339377-f0c17b3b
2025-12-12T12:27:33.474615Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:33.474612Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uffpn58fsu002, TaskId: 2, PQ sink. ]  SessionId []  MessageGroupId [1c92a47f-cd3e48b0-b9339377-f0c17b3b] Write session: send init request: init_request { path: "test_group_by_hop_restart_node_output" producer_id: "1c92a47f-cd3e48b0-b9339377-f0c17b3b" message_group_id: "1c92a47f-cd3e48b0-b9339377-f0c17b3b" }
2025-12-12T12:27:33.474627Z :YDB_SDK TRACE: actor.cpp:37: 2025-12-12T12:27:33.474625Z :TRACE: [local] TRACE_EVENT InitRequest 
2025-12-12T12:27:33.474734Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:33.474731Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uffpn58fsu002, TaskId: 2, PQ sink. ]  SessionId []  MessageGroupId [1c92a47f-cd3e48b0-b9339377-f0c17b3b] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T12:27:33.481752Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:33.481739Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uffpn58fsu002, TaskId: 2, PQ sink. ]  SessionId []  MessageGroupId [1c92a47f-cd3e48b0-b9339377-f0c17b3b] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T12:27:33.481785Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:27:33.481780Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uffpn58fsu002, TaskId: 2, PQ sink. ]  SessionId []  MessageGroupId [1c92a47f-cd3e48b0-b9339377-f0c17b3b] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1765542453481 BytesWritten: 0 MessagesWritten: 0 BytesWrittenCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:27:33.481808Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:27:33.481806Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uffpn58fsu002, TaskId: 2, PQ sink. ]  SessionId []  MessageGroupId [1c92a47f-cd3e48b0-b9339377-f0c17b3b] Write session established. Init response: last_seq_no: 2 session_id: "1c92a47f-cd3e48b0-b9339377-f0c17b3b|3b34b8ff-996dff7a-737672a9-302dd307_0"
2025-12-12T12:27:33.481815Z :YDB_SDK TRACE: actor.cpp:37: 2025-12-12T12:27:33.481813Z :TRACE: [local] TRACE_EVENT InitResponse  partition_id=0 session_id=1c92a47f-cd3e48b0-b9339377-f0c17b3b|3b34b8ff-996dff7a-737672a9-302dd307_0
2025-12-12T12:27:33.481820Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:33.481818Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uffpn58fsu002, TaskId: 2, PQ sink. ]  SessionId [1c92a47f-cd3e48b0-b9339377-f0c17b3b|3b34b8ff-996dff7a-737672a9-302dd307_0]  MessageGroupId [1c92a47f-cd3e48b0-b9339377-f0c17b3b] Write session: set DirectWriteToPartitionId 0
2025-12-12T12:27:33.481902Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:27:33.481899Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uffpn58fsu002, TaskId: 2, PQ sink. ]  SessionId [1c92a47f-cd3e48b0-b9339377-f0c17b3b|3b34b8ff-996dff7a-737672a9-302dd307_0]  PartitionId [0]  Generation [0] Get partition location async, partition 0, delay 0.000000s
2025-12-12T12:27:33.481919Z :YDB_SDK TRACE: actor.cpp:37: 2025-12-12T12:27:33.481917Z :TRACE: [local] TRACE_EVENT DescribePartitionRequest  path=local/test_group_by_hop_restart_node_output partition_id=0
2025-12-12T12:27:33.481963Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:33.481955Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uffpn58fsu002, TaskId: 2, PQ sink. ]  SessionId [1c92a47f-cd3e48b0-b9339377-f0c17b3b|3b34b8ff-996dff7a-737672a9-302dd307_0]  PartitionId [0]  Generation [0]  Getting partition location, partition 0
2025-12-12T12:27:33.483311Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:27:33.483303Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uffpn58fsu002, TaskId: 2, PQ sink. ]  SessionId [1c92a47f-cd3e48b0-b9339377-f0c17b3b|3b34b8ff-996dff7a-737672a9-302dd307_0]  PartitionId [0]  Generation [0] Got PartitionLocation response. Status SUCCESS, proto:
partition {
  active: true
  partition_location {
    node_id: 1
    generation: 1
  }
}

2025-12-12T12:27:33.483330Z :YDB_SDK TRACE: actor.cpp:37: 2025-12-12T12:27:33.483326Z :TRACE: [local] TRACE_EVENT DescribePartitionResponse  partition_id=0 active=1 pl_node_id=1 pl_generation=1
2025-12-12T12:27:33.483338Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:33.483336Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uffpn58fsu002, TaskId: 2, PQ sink. ]  SessionId [1c92a47f-cd3e48b0-b9339377-f0c17b3b|3b34b8ff-996dff7a-737672a9-302dd307_0]  PartitionId [0]  Generation [0] GetPreferredEndpoint: partitionId 0, partitionNodeId 1 exists in the endpoint pool.
2025-12-12T12:27:33.483345Z :YDB_SDK TRACE: actor.cpp:37: 2025-12-12T12:27:33.483343Z :TRACE: [local] TRACE_EVENT PreferredPartitionLocation  Endpoint= NodeId=1 Generation=1
2025-12-12T12:27:33.483353Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:27:33.483348Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uffpn58fsu002, TaskId: 2, PQ sink. ]  SessionId [1c92a47f-cd3e48b0-b9339377-f0c17b3b|3b34b8ff-996dff7a-737672a9-302dd307_0]  PartitionId [0]  Generation [1] Start write session. Will connect to nodeId: 1
2025-12-12T12:27:33.483558Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:33.483552Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uffpn58fsu002, TaskId: 2, PQ sink. ]  SessionId [1c92a47f-cd3e48b0-b9339377-f0c17b3b|3b34b8ff-996dff7a-737672a9-302dd307_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 1, Msg: CANCELLED, Details: , InternalError: 0
2025-12-12T12:27:33.483797Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:33.483794Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uffpn58fsu002, TaskId: 2, PQ sink. ]  SessionId [1c92a47f-cd3e48b0-b9339377-f0c17b3b|3b34b8ff-996dff7a-737672a9-302dd307_0]  PartitionId [0]  Generation [1] Write session: direct write to partition: 0, generation 1
2025-12-12T12:27:33.483869Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:33.483867Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uffpn58fsu002, TaskId: 2, PQ sink. ]  SessionId [1c92a47f-cd3e48b0-b9339377-f0c17b3b|3b34b8ff-996dff7a-737672a9-302dd307_0]  PartitionId [0]  Generation [1] Write session: send init request: init_request { path: "test_group_by_hop_restart_node_output" producer_id: "1c92a47f-cd3e48b0-b9339377-f0c17b3b" partition_with_generation { generation: 1 } }
2025-12-12T12:27:33.483879Z :YDB_SDK TRACE: actor.cpp:37: 2025-12-12T12:27:33.483877Z :TRACE: [local] TRACE_EVENT InitRequest  pwg_partition_id=0 pwg_generation=1
2025-12-12T12:27:33.483997Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:33.483995Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uffpn58fsu002, TaskId: 2, PQ sink. ]  SessionId [1c92a47f-cd3e48b0-b9339377-f0c17b3b|3b34b8ff-996dff7a-737672a9-302dd307_0]  PartitionId [0]  Generation [1] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T12:27:33.488965Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:33.488957Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uffpn58fsu002, TaskId: 2, PQ sink. ]  SessionId [1c92a47f-cd3e48b0-b9339377-f0c17b3b|3b34b8ff-996dff7a-737672a9-302dd307_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T12:27:33.489008Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:27:33.489005Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uffpn58fsu002, TaskId: 2, PQ sink. ]  SessionId [1c92a47f-cd3e48b0-b9339377-f0c17b3b|3b34b8ff-996dff7a-737672a9-302dd307_0]  PartitionId [0]  Generation [1] Write session established. Init response: last_seq_no: 2 session_id: "1c92a47f-cd3e48b0-b9339377-f0c17b3b|1656f20d-186e37f7-5fcc467a-af07c739_0"
2025-12-12T12:27:33.489013Z :YDB_SDK TRACE: actor.cpp:37: 2025-12-12T12:27:33.489011Z :TRACE: [local] TRACE_EVENT InitResponse  partition_id=0 session_id=1c92a47f-cd3e48b0-b9339377-f0c17b3b|1656f20d-186e37f7-5fcc467a-af07c739_0
2025-12-12T12:27:33.489017Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:33.489015Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uffpn58fsu002, TaskId: 2, PQ sink. ]  SessionId [1c92a47f-cd3e48b0-b9339377-f0c17b3b|1656f20d-186e37f7-5fcc467a-af07c739_0]  PartitionId [0]  Generation [1] Write session: set DirectWriteToPartitionId 0
2025-12-12T12:27:33.594442Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [3:7582946968842489002:2063]
2025-12-12T12:27:33.594464Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [3:7582946968842489002:2063]
2025-12-12T12:27:33.594466Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [3:7582946968842489002:2063]
2025-12-12T12:27:33.748990Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 1491b042-dfeb4c70-9fdeb3bd-5494e95c32, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:33.752646Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:33.752667Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:34.493371Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:129: TxId: ptqudq7uffpn58fsu002, task: 2. Received input for channelId: 1, seqNo: 1, size: 0, chunks: 0, watermark: 0, checkpoint: 1, finished: 0, from: [1:7582947099594315662:2250], expected seqNo: 1
2025-12-12T12:27:34.493390Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:611: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. took input
2025-12-12T12:27:34.493411Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:485: [ptqudq7uffpn58fsu002-0] Task: 2. [Checkpoint 2.1] Got checkpoint barrier from channel 1
2025-12-12T12:27:34.493442Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:356: SelfId: [2:7582947096977367210:2158], TxId: ptqudq7uffpn58fsu002, task: 2. No watermark 
2025-12-12T12:27:34.493448Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Poll inputs
2025-12-12T12:27:34.493450Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1494: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-12-12T12:27:34.493454Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. DoExecuteImpl: 1
2025-12-12T12:27:34.493464Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:965: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Input data push finished. Cookie: 0 Watermark: (empty maybe) Ack: 1 TakeInputChannelDataRequests: 1
2025-12-12T12:27:34.493468Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:738: TxId: ptqudq7uffpn58fsu002, task: 2. Sending channel data ack to channelId: 1, peer: [1:7582947099594315661:2250], from: [2:7582947096977367208:2158], freeSpace: 1000000, seqNo: 1, finished: 0
2025-12-12T12:27:34.493521Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: 1491b042-dfeb4c70-9fdeb3bd-5494e95c 2025-12-12 12:27:34.493 DEBUG ydbd(pid=1192649, tid=0x00007F4166DDD640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Run task: 2
2025-12-12T12:27:34.493591Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:462: SelfId: [2:7582947096977367210:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Pending 1 checkpoints to be sent
2025-12-12T12:27:34.493599Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Poll inputs
2025-12-12T12:27:34.493601Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1494: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-12-12T12:27:34.493603Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-12-12T12:27:34.493607Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. update task runner stats
2025-12-12T12:27:34.493637Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 1 watermark injected: (empty maybe)
2025-12-12T12:27:34.493641Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:447: [ptqudq7uffpn58fsu002-0] Task: 2. [Checkpoint 2.1] Performing task checkpoint
2025-12-12T12:27:34.493643Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:816: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Save state
2025-12-12T12:27:34.493645Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:474: [ptqudq7uffpn58fsu002-0] Task: 2. [Checkpoint 2.1] CA state saved
2025-12-12T12:27:34.493647Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:449: [ptqudq7uffpn58fsu002-0] Task: 2. [Checkpoint 2.1] Injecting checkpoint barrier to outputs
2025-12-12T12:27:34.493649Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:27:34.493654Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-12T12:27:34.493671Z :KQP_COMPUTE INFO: dq_async_compute_actor.cpp:1010: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Resume inputs
2025-12-12T12:27:34.493674Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [2:7582947096977367212:2158], TxId: ptqudq7uffpn58fsu002, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 1. Finished: 0
2025-12-12T12:27:34.493677Z :KQP_COMPUTE DEBUG: dq_pq_write_actor.cpp:240: SelfId: [2:7582947096977367212:2158], TxId: ptqudq7uffpn58fsu002, TaskId: 2, PQ sink. [Checkpoint 2.1] Send checkpoint state immediately
2025-12-12T12:27:34.493704Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:418: SelfId: [2:7582947096977367212:2158], TxId: ptqudq7uffpn58fsu002, TaskId: 2, PQ sink. Save checkpoint { Id: 1 Generation: 2 Type: CHECKPOINT_TYPE_SNAPSHOT } state: { SourceId: "1c92a47f-cd3e48b0-b9339377-f0c17b3b" ConfirmedSeqNo: 2 EgressBytes: 124 }
2025-12-12T12:27:34.493715Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:524: [ptqudq7uffpn58fsu002-0] Task: 2. Sink[0] state saved
2025-12-12T12:27:34.493725Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:536: [ptqudq7uffpn58fsu002-0] Task: 2. [Checkpoint 2.1] Task checkpoint is done. Send to storage
2025-12-12T12:27:34.493732Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 6 bytes of checkpoint barrier
2025-12-12T12:27:34.493734Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-12T12:27:34.493753Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudq7uffpn58fsu002, task: 2. no poll, channelId: 1, has inflight messages: [1], last with freeSpace: 1000000, current freeSpace: 1000000
2025-12-12T12:27:34.493753Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:460: [ptqudq7uffpn58fsu002-0] [2:1] Got TEvSaveTaskState: task 2
2025-12-12T12:27:34.493768Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: 1491b042-dfeb4c70-9fdeb3bd-5494e95c 2025-12-12 12:27:34.493 DEBUG ydbd(pid=1192649, tid=0x00007F4166DDD640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Run task: 2
2025-12-12T12:27:34.493775Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Poll inputs
2025-12-12T12:27:34.493777Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Poll sources
2025-12-12T12:27:34.493779Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-12-12T12:27:34.493780Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. update task runner stats
2025-12-12T12:27:34.493788Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-12T12:27:34.493789Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:27:34.493791Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-12T12:27:34.493795Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [2:7582947096977367212:2158], TxId: ptqudq7uffpn58fsu002, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-12-12T12:27:34.493797Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-12-12T12:27:34.493798Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-12T12:27:34.493801Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudq7uffpn58fsu002, task: 2. no poll, channelId: 1, has inflight messages: [1], last with freeSpace: 1000000, current freeSpace: 1000000
2025-12-12T12:27:34.493819Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: 1491b042-dfeb4c70-9fdeb3bd-5494e95c 2025-12-12 12:27:34.493 DEBUG ydbd(pid=1192649, tid=0x00007F4166DDD640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Run task: 2
2025-12-12T12:27:34.493824Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. update task runner stats
2025-12-12T12:27:34.493829Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-12T12:27:34.493831Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:27:34.493832Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-12T12:27:34.493834Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [2:7582947096977367212:2158], TxId: ptqudq7uffpn58fsu002, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-12-12T12:27:34.493836Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-12-12T12:27:34.493837Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-12T12:27:34.493838Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudq7uffpn58fsu002, task: 2. no poll, channelId: 1, has inflight messages: [1], last with freeSpace: 1000000, current freeSpace: 1000000
2025-12-12T12:27:34.496385Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:484: [ptqudq7uffpn58fsu002-0] [2:1] TEvSaveTaskState Apply: task: 2
2025-12-12T12:27:34.496408Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:499: [ptqudq7uffpn58fsu002-0] [2:1] Send TEvSaveTaskStateResult: task: 2
2025-12-12T12:27:34.520018Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:759: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Commit state
2025-12-12T12:27:34.743293Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [2:7582946963833380804:2115]
2025-12-12T12:27:34.743328Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:34.743345Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [2:7582946963833380727:2063]
2025-12-12T12:27:34.743350Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [2:7582946963833380727:2063]
2025-12-12T12:27:34.743353Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [2:7582946963833380727:2063]
2025-12-12T12:27:34.743366Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:34.749437Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 1491b042-dfeb4c70-9fdeb3bd-5494e95c33, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:34.753202Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:34.753224Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:35.185665Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582947022284904054:2063]
2025-12-12T12:27:35.185684Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582947022284904054:2063]
2025-12-12T12:27:35.185687Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582947022284904054:2063]
2025-12-12T12:27:35.465177Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:952: TopicSession [2:7582947096977367213:2159] SendStatistics
2025-12-12T12:27:35.465222Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:962: RowDispatcher: Received TEvHeartbeat from [1:7582947099594315665:2250], part id 0 query id ptqudq7uffpn58fsu002
2025-12-12T12:27:35.465245Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1234: RowDispatcher: TEvSessionStatistic from [2:7582947096977367213:2159]
2025-12-12T12:27:35.493488Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:129: TxId: ptqudq7uffpn58fsu002, task: 2. Received input for channelId: 1, seqNo: 2, size: 0, chunks: 0, watermark: 0, checkpoint: 1, finished: 0, from: [1:7582947099594315662:2250], expected seqNo: 2
2025-12-12T12:27:35.493505Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:611: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. took input
2025-12-12T12:27:35.493519Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:485: [ptqudq7uffpn58fsu002-0] Task: 2. [Checkpoint 2.2] Got checkpoint barrier from channel 1
2025-12-12T12:27:35.493536Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:356: SelfId: [2:7582947096977367210:2158], TxId: ptqudq7uffpn58fsu002, task: 2. No watermark 
2025-12-12T12:27:35.493541Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Poll inputs
2025-12-12T12:27:35.493543Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1494: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-12-12T12:27:35.493545Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. DoExecuteImpl: 1
2025-12-12T12:27:35.493553Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:965: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Input data push finished. Cookie: 1 Watermark: (empty maybe) Ack: 1 TakeInputChannelDataRequests: 1
2025-12-12T12:27:35.493557Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:738: TxId: ptqudq7uffpn58fsu002, task: 2. Sending channel data ack to channelId: 1, peer: [1:7582947099594315661:2250], from: [2:7582947096977367208:2158], freeSpace: 1000000, seqNo: 2, finished: 0
2025-12-12T12:27:35.493603Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: 1491b042-dfeb4c70-9fdeb3bd-5494e95c 2025-12-12 12:27:35.493 DEBUG ydbd(pid=1192649, tid=0x00007F4166DDD640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Run task: 2
2025-12-12T12:27:35.493648Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:462: SelfId: [2:7582947096977367210:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Pending 1 checkpoints to be sent
2025-12-12T12:27:35.493669Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Poll inputs
2025-12-12T12:27:35.493675Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1494: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-12-12T12:27:35.493676Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-12-12T12:27:35.493679Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. update task runner stats
2025-12-12T12:27:35.493703Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 1 watermark injected: (empty maybe)
2025-12-12T12:27:35.493711Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:447: [ptqudq7uffpn58fsu002-0] Task: 2. [Checkpoint 2.2] Performing task checkpoint
2025-12-12T12:27:35.493714Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:816: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Save state
2025-12-12T12:27:35.493715Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:474: [ptqudq7uffpn58fsu002-0] Task: 2. [Checkpoint 2.2] CA state saved
2025-12-12T12:27:35.493717Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:449: [ptqudq7uffpn58fsu002-0] Task: 2. [Checkpoint 2.2] Injecting checkpoint barrier to outputs
2025-12-12T12:27:35.493719Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:27:35.493722Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-12T12:27:35.493729Z :KQP_COMPUTE INFO: dq_async_compute_actor.cpp:1010: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Resume inputs
2025-12-12T12:27:35.493732Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [2:7582947096977367212:2158], TxId: ptqudq7uffpn58fsu002, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 1. Finished: 0
2025-12-12T12:27:35.493735Z :KQP_COMPUTE DEBUG: dq_pq_write_actor.cpp:240: SelfId: [2:7582947096977367212:2158], TxId: ptqudq7uffpn58fsu002, TaskId: 2, PQ sink. [Checkpoint 2.2] Send checkpoint state immediately
2025-12-12T12:27:35.493764Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:418: SelfId: [2:7582947096977367212:2158], TxId: ptqudq7uffpn58fsu002, TaskId: 2, PQ sink. Save checkpoint { Id: 2 Generation: 2 Type: CHECKPOINT_TYPE_SNAPSHOT } state: { SourceId: "1c92a47f-cd3e48b0-b9339377-f0c17b3b" ConfirmedSeqNo: 2 EgressBytes: 124 }
2025-12-12T12:27:35.493767Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:524: [ptqudq7uffpn58fsu002-0] Task: 2. Sink[0] state saved
2025-12-12T12:27:35.493780Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:536: [ptqudq7uffpn58fsu002-0] Task: 2. [Checkpoint 2.2] Task checkpoint is done. Send to storage
2025-12-12T12:27:35.493787Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 6 bytes of checkpoint barrier
2025-12-12T12:27:35.493789Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-12T12:27:35.493795Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudq7uffpn58fsu002, task: 2. no poll, channelId: 1, has inflight messages: [2], last with freeSpace: 1000000, current freeSpace: 1000000
2025-12-12T12:27:35.493803Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:460: [ptqudq7uffpn58fsu002-0] [2:2] Got TEvSaveTaskState: task 2
2025-12-12T12:27:35.493810Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: 1491b042-dfeb4c70-9fdeb3bd-5494e95c 2025-12-12 12:27:35.493 DEBUG ydbd(pid=1192649, tid=0x00007F4166DDD640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Run task: 2
2025-12-12T12:27:35.493819Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Poll inputs
2025-12-12T12:27:35.493820Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Poll sources
2025-12-12T12:27:35.493822Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-12-12T12:27:35.493824Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. update task runner stats
2025-12-12T12:27:35.493831Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-12T12:27:35.493832Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:27:35.493833Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-12T12:27:35.493836Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [2:7582947096977367212:2158], TxId: ptqudq7uffpn58fsu002, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-12-12T12:27:35.493838Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-12-12T12:27:35.493839Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-12T12:27:35.493841Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudq7uffpn58fsu002, task: 2. no poll, channelId: 1, has inflight messages: [2], last with freeSpace: 1000000, current freeSpace: 1000000
2025-12-12T12:27:35.493851Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: 1491b042-dfeb4c70-9fdeb3bd-5494e95c 2025-12-12 12:27:35.493 DEBUG ydbd(pid=1192649, tid=0x00007F4166DDD640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Run task: 2
2025-12-12T12:27:35.493856Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. update task runner stats
2025-12-12T12:27:35.493861Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-12T12:27:35.493862Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:27:35.493863Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-12T12:27:35.493865Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [2:7582947096977367212:2158], TxId: ptqudq7uffpn58fsu002, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-12-12T12:27:35.493867Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-12-12T12:27:35.493867Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-12T12:27:35.493870Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudq7uffpn58fsu002, task: 2. no poll, channelId: 1, has inflight messages: [2], last with freeSpace: 1000000, current freeSpace: 1000000
2025-12-12T12:27:35.496707Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:484: [ptqudq7uffpn58fsu002-0] [2:2] TEvSaveTaskState Apply: task: 2
2025-12-12T12:27:35.496725Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:499: [ptqudq7uffpn58fsu002-0] [2:2] Send TEvSaveTaskStateResult: task: 2
2025-12-12T12:27:35.519593Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:759: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Commit state
2025-12-12T12:27:35.595304Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [3:7582946968842489002:2063]
2025-12-12T12:27:35.595331Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [3:7582946968842489002:2063]
2025-12-12T12:27:35.595336Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [3:7582946968842489002:2063]
2025-12-12T12:27:35.749902Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 1491b042-dfeb4c70-9fdeb3bd-5494e95c34, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:35.753883Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:35.753898Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:36.495210Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:129: TxId: ptqudq7uffpn58fsu002, task: 2. Received input for channelId: 1, seqNo: 3, size: 0, chunks: 0, watermark: 0, checkpoint: 1, finished: 0, from: [1:7582947099594315662:2250], expected seqNo: 3
2025-12-12T12:27:36.495229Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:611: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. took input
2025-12-12T12:27:36.495242Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:485: [ptqudq7uffpn58fsu002-0] Task: 2. [Checkpoint 2.3] Got checkpoint barrier from channel 1
2025-12-12T12:27:36.495260Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:356: SelfId: [2:7582947096977367210:2158], TxId: ptqudq7uffpn58fsu002, task: 2. No watermark 
2025-12-12T12:27:36.495265Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Poll inputs
2025-12-12T12:27:36.495267Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1494: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-12-12T12:27:36.495269Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. DoExecuteImpl: 1
2025-12-12T12:27:36.495277Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:965: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Input data push finished. Cookie: 2 Watermark: (empty maybe) Ack: 1 TakeInputChannelDataRequests: 1
2025-12-12T12:27:36.495281Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:738: TxId: ptqudq7uffpn58fsu002, task: 2. Sending channel data ack to channelId: 1, peer: [1:7582947099594315661:2250], from: [2:7582947096977367208:2158], freeSpace: 1000000, seqNo: 3, finished: 0
2025-12-12T12:27:36.495323Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: 1491b042-dfeb4c70-9fdeb3bd-5494e95c 2025-12-12 12:27:36.495 DEBUG ydbd(pid=1192649, tid=0x00007F4166DDD640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Run task: 2
2025-12-12T12:27:36.495372Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:462: SelfId: [2:7582947096977367210:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Pending 1 checkpoints to be sent
2025-12-12T12:27:36.495379Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Poll inputs
2025-12-12T12:27:36.495381Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1494: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-12-12T12:27:36.495382Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-12-12T12:27:36.495384Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. update task runner stats
2025-12-12T12:27:36.495413Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 1 watermark injected: (empty maybe)
2025-12-12T12:27:36.495417Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:447: [ptqudq7uffpn58fsu002-0] Task: 2. [Checkpoint 2.3] Performing task checkpoint
2025-12-12T12:27:36.495418Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:816: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Save state
2025-12-12T12:27:36.495420Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:474: [ptqudq7uffpn58fsu002-0] Task: 2. [Checkpoint 2.3] CA state saved
2025-12-12T12:27:36.495422Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:449: [ptqudq7uffpn58fsu002-0] Task: 2. [Checkpoint 2.3] Injecting checkpoint barrier to outputs
2025-12-12T12:27:36.495424Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:27:36.495427Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-12T12:27:36.495433Z :KQP_COMPUTE INFO: dq_async_compute_actor.cpp:1010: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Resume inputs
2025-12-12T12:27:36.495436Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [2:7582947096977367212:2158], TxId: ptqudq7uffpn58fsu002, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 1. Finished: 0
2025-12-12T12:27:36.495439Z :KQP_COMPUTE DEBUG: dq_pq_write_actor.cpp:240: SelfId: [2:7582947096977367212:2158], TxId: ptqudq7uffpn58fsu002, TaskId: 2, PQ sink. [Checkpoint 2.3] Send checkpoint state immediately
2025-12-12T12:27:36.495463Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:418: SelfId: [2:7582947096977367212:2158], TxId: ptqudq7uffpn58fsu002, TaskId: 2, PQ sink. Save checkpoint { Id: 3 Generation: 2 Type: CHECKPOINT_TYPE_SNAPSHOT } state: { SourceId: "1c92a47f-cd3e48b0-b9339377-f0c17b3b" ConfirmedSeqNo: 2 EgressBytes: 124 }
2025-12-12T12:27:36.495466Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:524: [ptqudq7uffpn58fsu002-0] Task: 2. Sink[0] state saved
2025-12-12T12:27:36.495477Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:536: [ptqudq7uffpn58fsu002-0] Task: 2. [Checkpoint 2.3] Task checkpoint is done. Send to storage
2025-12-12T12:27:36.495483Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 6 bytes of checkpoint barrier
2025-12-12T12:27:36.495485Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-12T12:27:36.495491Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudq7uffpn58fsu002, task: 2. no poll, channelId: 1, has inflight messages: [3], last with freeSpace: 1000000, current freeSpace: 1000000
2025-12-12T12:27:36.495492Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:460: [ptqudq7uffpn58fsu002-0] [2:3] Got TEvSaveTaskState: task 2
2025-12-12T12:27:36.495502Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: 1491b042-dfeb4c70-9fdeb3bd-5494e95c 2025-12-12 12:27:36.495 DEBUG ydbd(pid=1192649, tid=0x00007F4166DDD640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Run task: 2
2025-12-12T12:27:36.495519Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Poll inputs
2025-12-12T12:27:36.495536Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Poll sources
2025-12-12T12:27:36.495537Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-12-12T12:27:36.495539Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. update task runner stats
2025-12-12T12:27:36.495546Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-12T12:27:36.495547Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:27:36.495550Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-12T12:27:36.495554Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [2:7582947096977367212:2158], TxId: ptqudq7uffpn58fsu002, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-12-12T12:27:36.495555Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-12-12T12:27:36.495556Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-12T12:27:36.495559Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudq7uffpn58fsu002, task: 2. no poll, channelId: 1, has inflight messages: [3], last with freeSpace: 1000000, current freeSpace: 1000000
2025-12-12T12:27:36.495567Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: 1491b042-dfeb4c70-9fdeb3bd-5494e95c 2025-12-12 12:27:36.495 DEBUG ydbd(pid=1192649, tid=0x00007F4166DDD640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Run task: 2
2025-12-12T12:27:36.495573Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. update task runner stats
2025-12-12T12:27:36.495577Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-12T12:27:36.495578Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:27:36.495580Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-12T12:27:36.495582Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [2:7582947096977367212:2158], TxId: ptqudq7uffpn58fsu002, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-12-12T12:27:36.495583Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-12-12T12:27:36.495585Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-12T12:27:36.495586Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudq7uffpn58fsu002, task: 2. no poll, channelId: 1, has inflight messages: [3], last with freeSpace: 1000000, current freeSpace: 1000000
2025-12-12T12:27:36.498188Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:484: [ptqudq7uffpn58fsu002-0] [2:3] TEvSaveTaskState Apply: task: 2
2025-12-12T12:27:36.498204Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:499: [ptqudq7uffpn58fsu002-0] [2:3] Send TEvSaveTaskStateResult: task: 2
2025-12-12T12:27:36.522326Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:759: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Commit state
2025-12-12T12:27:36.744197Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [2:7582946963833380804:2115]
2025-12-12T12:27:36.744216Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:36.744232Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [2:7582946963833380727:2063]
2025-12-12T12:27:36.744236Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [2:7582946963833380727:2063]
2025-12-12T12:27:36.744239Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [2:7582946963833380727:2063]
2025-12-12T12:27:36.744252Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:36.750340Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 1491b042-dfeb4c70-9fdeb3bd-5494e95c35, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:36.753899Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:36.753911Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:37.187039Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582947022284904054:2063]
2025-12-12T12:27:37.187060Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582947022284904054:2063]
2025-12-12T12:27:37.187063Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582947022284904054:2063]
2025-12-12T12:27:37.466311Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:952: TopicSession [2:7582947096977367213:2159] SendStatistics
2025-12-12T12:27:37.466401Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:962: RowDispatcher: Received TEvHeartbeat from [1:7582947099594315665:2250], part id 0 query id ptqudq7uffpn58fsu002
2025-12-12T12:27:37.466421Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1234: RowDispatcher: TEvSessionStatistic from [2:7582947096977367213:2159]
2025-12-12T12:27:37.493562Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:129: TxId: ptqudq7uffpn58fsu002, task: 2. Received input for channelId: 1, seqNo: 4, size: 0, chunks: 0, watermark: 0, checkpoint: 1, finished: 0, from: [1:7582947099594315662:2250], expected seqNo: 4
2025-12-12T12:27:37.493584Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:611: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. took input
2025-12-12T12:27:37.493603Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:485: [ptqudq7uffpn58fsu002-0] Task: 2. [Checkpoint 2.4] Got checkpoint barrier from channel 1
2025-12-12T12:27:37.493640Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:356: SelfId: [2:7582947096977367210:2158], TxId: ptqudq7uffpn58fsu002, task: 2. No watermark 
2025-12-12T12:27:37.493656Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Poll inputs
2025-12-12T12:27:37.493658Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1494: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-12-12T12:27:37.493661Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. DoExecuteImpl: 1
2025-12-12T12:27:37.493684Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:965: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Input data push finished. Cookie: 3 Watermark: (empty maybe) Ack: 1 TakeInputChannelDataRequests: 1
2025-12-12T12:27:37.493699Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:738: TxId: ptqudq7uffpn58fsu002, task: 2. Sending channel data ack to channelId: 1, peer: [1:7582947099594315661:2250], from: [2:7582947096977367208:2158], freeSpace: 1000000, seqNo: 4, finished: 0
2025-12-12T12:27:37.493794Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: 1491b042-dfeb4c70-9fdeb3bd-5494e95c 2025-12-12 12:27:37.493 DEBUG ydbd(pid=1192649, tid=0x00007F4166DDD640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Run task: 2
2025-12-12T12:27:37.493899Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:462: SelfId: [2:7582947096977367210:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Pending 1 checkpoints to be sent
2025-12-12T12:27:37.493921Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Poll inputs
2025-12-12T12:27:37.493923Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1494: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-12-12T12:27:37.493924Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-12-12T12:27:37.493927Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. update task runner stats
2025-12-12T12:27:37.493976Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 1 watermark injected: (empty maybe)
2025-12-12T12:27:37.493993Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:447: [ptqudq7uffpn58fsu002-0] Task: 2. [Checkpoint 2.4] Performing task checkpoint
2025-12-12T12:27:37.493995Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:816: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Save state
2025-12-12T12:27:37.493997Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:474: [ptqudq7uffpn58fsu002-0] Task: 2. [Checkpoint 2.4] CA state saved
2025-12-12T12:27:37.493999Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:449: [ptqudq7uffpn58fsu002-0] Task: 2. [Checkpoint 2.4] Injecting checkpoint barrier to outputs
2025-12-12T12:27:37.494000Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:27:37.494006Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-12T12:27:37.494014Z :KQP_COMPUTE INFO: dq_async_compute_actor.cpp:1010: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Resume inputs
2025-12-12T12:27:37.494017Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [2:7582947096977367212:2158], TxId: ptqudq7uffpn58fsu002, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 1. Finished: 0
2025-12-12T12:27:37.494019Z :KQP_COMPUTE DEBUG: dq_pq_write_actor.cpp:240: SelfId: [2:7582947096977367212:2158], TxId: ptqudq7uffpn58fsu002, TaskId: 2, PQ sink. [Checkpoint 2.4] Send checkpoint state immediately
2025-12-12T12:27:37.494061Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:418: SelfId: [2:7582947096977367212:2158], TxId: ptqudq7uffpn58fsu002, TaskId: 2, PQ sink. Save checkpoint { Id: 4 Generation: 2 Type: CHECKPOINT_TYPE_SNAPSHOT } state: { SourceId: "1c92a47f-cd3e48b0-b9339377-f0c17b3b" ConfirmedSeqNo: 2 EgressBytes: 124 }
2025-12-12T12:27:37.494069Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:524: [ptqudq7uffpn58fsu002-0] Task: 2. Sink[0] state saved
2025-12-12T12:27:37.494082Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:536: [ptqudq7uffpn58fsu002-0] Task: 2. [Checkpoint 2.4] Task checkpoint is done. Send to storage
2025-12-12T12:27:37.494104Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 6 bytes of checkpoint barrier
2025-12-12T12:27:37.494113Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-12T12:27:37.494119Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudq7uffpn58fsu002, task: 2. no poll, channelId: 1, has inflight messages: [4], last with freeSpace: 1000000, current freeSpace: 1000000
2025-12-12T12:27:37.494137Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: 1491b042-dfeb4c70-9fdeb3bd-5494e95c 2025-12-12 12:27:37.494 DEBUG ydbd(pid=1192649, tid=0x00007F4166DDD640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Run task: 2
2025-12-12T12:27:37.494148Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:460: [ptqudq7uffpn58fsu002-0] [2:4] Got TEvSaveTaskState: task 2
2025-12-12T12:27:37.494157Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Poll inputs
2025-12-12T12:27:37.494159Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Poll sources
2025-12-12T12:27:37.494160Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-12-12T12:27:37.494162Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. update task runner stats
2025-12-12T12:27:37.494171Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-12T12:27:37.494172Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:27:37.494174Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-12T12:27:37.494177Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [2:7582947096977367212:2158], TxId: ptqudq7uffpn58fsu002, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-12-12T12:27:37.494179Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-12-12T12:27:37.494181Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-12T12:27:37.494184Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudq7uffpn58fsu002, task: 2. no poll, channelId: 1, has inflight messages: [4], last with freeSpace: 1000000, current freeSpace: 1000000
2025-12-12T12:27:37.494192Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: 1491b042-dfeb4c70-9fdeb3bd-5494e95c 2025-12-12 12:27:37.494 DEBUG ydbd(pid=1192649, tid=0x00007F4166DDD640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Run task: 2
2025-12-12T12:27:37.494198Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. update task runner stats
2025-12-12T12:27:37.494202Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-12T12:27:37.494204Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:27:37.494205Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-12T12:27:37.494208Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [2:7582947096977367212:2158], TxId: ptqudq7uffpn58fsu002, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-12-12T12:27:37.494209Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-12-12T12:27:37.494210Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-12T12:27:37.494212Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudq7uffpn58fsu002, task: 2. no poll, channelId: 1, has inflight messages: [4], last with freeSpace: 1000000, current freeSpace: 1000000
2025-12-12T12:27:37.497555Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:484: [ptqudq7uffpn58fsu002-0] [2:4] TEvSaveTaskState Apply: task: 2
2025-12-12T12:27:37.497583Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:499: [ptqudq7uffpn58fsu002-0] [2:4] Send TEvSaveTaskStateResult: task: 2
2025-12-12T12:27:37.521620Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:759: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Commit state
2025-12-12T12:27:37.596132Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [3:7582946968842489002:2063]
2025-12-12T12:27:37.596162Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [3:7582946968842489002:2063]
2025-12-12T12:27:37.596167Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [3:7582946968842489002:2063]
2025-12-12T12:27:37.737490Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-12-12T12:27:37.747378Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:389: Send NodeInfo with size: 2 to DynamicNameserver
2025-12-12T12:27:37.750743Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 1491b042-dfeb4c70-9fdeb3bd-5494e95c36, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:37.754766Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:37.754781Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:38.357097Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:453: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Got TEvStateRequest from actor [1:7582947099594315659:2248] PingCookie: 2
2025-12-12T12:27:38.357119Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. update task runner stats
2025-12-12T12:27:38.472726Z :FQ_ROW_DISPATCHER INFO: topic_session.cpp:516: TopicSession [2:7582947096977367213:2159] Create topic session, Path test_group_by_hop_restart_node_input/0, StartingMessageTimestamp 2025-12-12T12:27:05.094000Z, BufferSize 16000000, GetConsumerMode Without
2025-12-12T12:27:38.472772Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:27:38.472767Z :INFO: [local] [local] [f0fabeee-75001020-c8df4478-c9ad3b5b] Starting read session
2025-12-12T12:27:38.472776Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:38.472775Z :DEBUG: [local] [local] [f0fabeee-75001020-c8df4478-c9ad3b5b] Starting single session
2025-12-12T12:27:38.472811Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:38.472808Z :DEBUG: [local] [local] [f0fabeee-75001020-c8df4478-c9ad3b5b] [] In Reconnect, ReadSizeBudget = 8000000, ReadSizeServerDelta = 0
2025-12-12T12:27:38.472814Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:38.472813Z :DEBUG: [local] [local] [f0fabeee-75001020-c8df4478-c9ad3b5b] [] New values: ReadSizeBudget = 8000000, ReadSizeServerDelta = 0
2025-12-12T12:27:38.472819Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:38.472817Z :DEBUG: [local] [local] [f0fabeee-75001020-c8df4478-c9ad3b5b] [] Reconnecting session to cluster  in 0.000000s
2025-12-12T12:27:38.472989Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:466: TopicSession [2:7582947096977367213:2159] SubscribeOnNextEvent
2025-12-12T12:27:38.473034Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:38.473025Z :DEBUG: [local] [local] [f0fabeee-75001020-c8df4478-c9ad3b5b] [] Successfully connected. Initializing session
2025-12-12T12:27:38.473969Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:27:38.473956Z :INFO: [local] [local] [f0fabeee-75001020-c8df4478-c9ad3b5b] [] Got InitResponse. ReadSessionId: _1_4_5234236917040682047_v1
2025-12-12T12:27:38.473990Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:38.473988Z :DEBUG: [local] [local] [f0fabeee-75001020-c8df4478-c9ad3b5b] [] In ContinueReadingDataImpl, ReadSizeBudget = 8000000, ReadSizeServerDelta = 0
2025-12-12T12:27:38.474077Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:38.474075Z :DEBUG: [local] [local] [f0fabeee-75001020-c8df4478-c9ad3b5b] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 8000000
2025-12-12T12:27:38.475362Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:559: TopicSession [2:7582947096977367213:2159] TEvPqEventsReady
2025-12-12T12:27:38.475443Z :FQ_ROW_DISPATCHER DEBUG: topic_session.cpp:677: TopicSession [2:7582947096977367213:2159] StartPartitionSessionEvent received
2025-12-12T12:27:38.475455Z :FQ_ROW_DISPATCHER DEBUG: topic_session.cpp:685: TopicSession [2:7582947096977367213:2159] Confirm StartPartitionSession with offset 5
2025-12-12T12:27:38.475498Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:27:38.475481Z :INFO: [local] [local] [f0fabeee-75001020-c8df4478-c9ad3b5b] [] Confirm partition stream create. Partition stream id: 1. Cluster: "-". Topic: "test_group_by_hop_restart_node_input". Partition: 0. Read offset: 5
2025-12-12T12:27:38.475593Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:466: TopicSession [2:7582947096977367213:2159] SubscribeOnNextEvent
2025-12-12T12:27:38.476591Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:38.476584Z :DEBUG: [local] [local] [f0fabeee-75001020-c8df4478-c9ad3b5b] [] Got ReadResponse, serverBytesSize = 367, now ReadSizeBudget = 0, ReadSizeServerDelta = 7999633
2025-12-12T12:27:38.476632Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:38.476629Z :DEBUG: [local] [local] [f0fabeee-75001020-c8df4478-c9ad3b5b] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 7999633
2025-12-12T12:27:38.476694Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:38.476692Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (5-8)
2025-12-12T12:27:38.476701Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:38.476699Z :DEBUG: [local] [local] [f0fabeee-75001020-c8df4478-c9ad3b5b] [] Returning serverBytesSize = 367 to budget
2025-12-12T12:27:38.476705Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:38.476703Z :DEBUG: [local] [local] [f0fabeee-75001020-c8df4478-c9ad3b5b] [] In ContinueReadingDataImpl, ReadSizeBudget = 367, ReadSizeServerDelta = 7999633
2025-12-12T12:27:38.476758Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:38.476757Z :DEBUG: [local] [local] [f0fabeee-75001020-c8df4478-c9ad3b5b] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 8000000
2025-12-12T12:27:38.476796Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:559: TopicSession [2:7582947096977367213:2159] TEvPqEventsReady
2025-12-12T12:27:38.476838Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:38.476835Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (5-5)
2025-12-12T12:27:38.476847Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:38.476845Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 1} (6-6)
2025-12-12T12:27:38.476870Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:38.476867Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 2} (7-7)
2025-12-12T12:27:38.476886Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:38.476884Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 3} (8-8)
2025-12-12T12:27:38.476898Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:38.476895Z :DEBUG: [local] [local] [f0fabeee-75001020-c8df4478-c9ad3b5b] [] The application data is transferred to the client. Number of messages 4, size 248 bytes
2025-12-12T12:27:38.476905Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:38.476902Z :DEBUG: [local] [local] [f0fabeee-75001020-c8df4478-c9ad3b5b] [] Returning serverBytesSize = 0 to budget
2025-12-12T12:27:38.476976Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:654: TopicSession [2:7582947096977367213:2159] Data received: Message { Data: "{"time": "2025-04-23T09:00:17.000000Z", "project": "project1"}" Information: { Offset: 5 ProducerId: "" SeqNo: 0 CreateTime: 2025-12-12T12:27:14.429000Z WriteTime: 2025-12-12T12:27:14.428000Z MessageGroupId: "" Meta: { } MessageMeta: { } } Partition session id: 1 Topic: "test_group_by_hop_restart_node_input" Partition: 0 }
2025-12-12T12:27:38.477045Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:654: TopicSession [2:7582947096977367213:2159] Data received: Message { Data: "{"time": "2025-04-23T09:00:18.000000Z", "project": "project2"}" Information: { Offset: 6 ProducerId: "" SeqNo: 0 CreateTime: 2025-12-12T12:27:14.429000Z WriteTime: 2025-12-12T12:27:14.428000Z MessageGroupId: "" Meta: { } MessageMeta: { } } Partition session id: 1 Topic: "test_group_by_hop_restart_node_input" Partition: 0 }
2025-12-12T12:27:38.477049Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:654: TopicSession [2:7582947096977367213:2159] Data received: Message { Data: "{"time": "2025-04-23T09:00:21.000000Z", "project": "project1"}" Information: { Offset: 7 ProducerId: "" SeqNo: 0 CreateTime: 2025-12-12T12:27:14.429000Z WriteTime: 2025-12-12T12:27:14.428000Z MessageGroupId: "" Meta: { } MessageMeta: { } } Partition session id: 1 Topic: "test_group_by_hop_restart_node_input" Partition: 0 }
2025-12-12T12:27:38.477052Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:654: TopicSession [2:7582947096977367213:2159] Data received: Message { Data: "{"time": "2025-04-23T09:00:25.000000Z", "project": "project2"}" Information: { Offset: 8 ProducerId: "" SeqNo: 0 CreateTime: 2025-12-12T12:27:14.429000Z WriteTime: 2025-12-12T12:27:14.428000Z MessageGroupId: "" Meta: { } MessageMeta: { } } Partition session id: 1 Topic: "test_group_by_hop_restart_node_input" Partition: 0 }
2025-12-12T12:27:38.477066Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:707: TopicSession [2:7582947096977367213:2159] SendToParsing, messages: 4
2025-12-12T12:27:38.477071Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:417: TTopicFormatHandler [json_each_row]: Send 4 messages to parser
2025-12-12T12:27:38.477076Z :FQ_ROW_DISPATCHER TRACE: json_parser.cpp:388: TJsonParser: Add 4 messages to parse
2025-12-12T12:27:38.477134Z :FQ_ROW_DISPATCHER TRACE: json_parser.cpp:454: TJsonParser: Do parsing, first offset: 5, values:
{"time": "2025-04-23T09:00:17.000000Z", "project": "project1"}{"time": "2025-04-23T09:00:18.000000Z", "project": "project2"}{"time": "2025-04-23T09:00:21.000000Z", "project": "project1"}{"time": "2025-04-23T09:00:25.000000Z", "project": "project2"}                                                                
2025-12-12T12:27:38.477138Z :FQ_ROW_DISPATCHER TRACE: json_parser.cpp:590: TJsonParser: Init parser, skipped 0, outputRowId 0 size 312
2025-12-12T12:27:38.477225Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:77: TTopicFormatHandler [json_each_row]: TParserHandler: Got parsed data, number rows: 4
2025-12-12T12:27:38.477229Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:614: TTopicFormatHandler [json_each_row]: Send 4 messages to programs, first offset: 5, last offset: 8
2025-12-12T12:27:38.477233Z :FQ_ROW_DISPATCHER TRACE: filters_set.cpp:34: TTopicFilters: ProcessData for 1 clients, number rows: 4
2025-12-12T12:27:38.477248Z :FQ_ROW_DISPATCHER TRACE: filters_set.cpp:223: TTopicFilters: Pass 4 rows to purecalc filter (client id: [1:7582947099594315665:2250])
2025-12-12T12:27:38.477250Z :FQ_ROW_DISPATCHER TRACE: purecalc_filter.cpp:408: TProgramRunHandler: ProcessData for 4 rows
2025-12-12T12:27:38.477253Z :FQ_ROW_DISPATCHER TRACE: purecalc_filter.cpp:411: TProgramRunHandler: Add 4 rows to client [1:7582947099594315665:2250] without processing
2025-12-12T12:27:38.477312Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:292: TTopicFormatHandler [json_each_row]: TClientHandler [1:7582947099594315665:2250]: OnBatchFinish, offset: 5, number rows: 1, row size: 51, watermark: (empty maybe)
2025-12-12T12:27:38.477316Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:198: TopicSession [2:7582947096977367213:2159] AddDataToClient to [1:7582947099594315665:2250], offset: 5, number rows: 1, row size: 51, watermark: (empty maybe)
2025-12-12T12:27:38.477331Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:936: TopicSession [2:7582947096977367213:2159] Send TEvNewDataArrived to [1:7582947099594315665:2250]
2025-12-12T12:27:38.477370Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:292: TTopicFormatHandler [json_each_row]: TClientHandler [1:7582947099594315665:2250]: OnBatchFinish, offset: 6, number rows: 1, row size: 43, watermark: (empty maybe)
2025-12-12T12:27:38.477372Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:198: TopicSession [2:7582947096977367213:2159] AddDataToClient to [1:7582947099594315665:2250], offset: 6, number rows: 1, row size: 43, watermark: (empty maybe)
2025-12-12T12:27:38.477374Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:292: TTopicFormatHandler [json_each_row]: TClientHandler [1:7582947099594315665:2250]: OnBatchFinish, offset: 7, number rows: 1, row size: 43, watermark: (empty maybe)
2025-12-12T12:27:38.477378Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:198: TopicSession [2:7582947096977367213:2159] AddDataToClient to [1:7582947099594315665:2250], offset: 7, number rows: 1, row size: 43, watermark: (empty maybe)
2025-12-12T12:27:38.477380Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:292: TTopicFormatHandler [json_each_row]: TClientHandler [1:7582947099594315665:2250]: OnBatchFinish, offset: 8, number rows: 1, row size: 43, watermark: (empty maybe)
2025-12-12T12:27:38.477382Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:198: TopicSession [2:7582947096977367213:2159] AddDataToClient to [1:7582947099594315665:2250], offset: 8, number rows: 1, row size: 43, watermark: (empty maybe)
2025-12-12T12:27:38.477385Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:622: TTopicFormatHandler [json_each_row]: Commit client [1:7582947099594315665:2250] offset 8
2025-12-12T12:27:38.477400Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:210: TopicSession [2:7582947096977367213:2159] UpdateClientOffset for [1:7582947099594315665:2250], new offset: 8
2025-12-12T12:27:38.477403Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1081: RowDispatcher: Forward TEvNewDataArrived from [2:7582947096977367213:2159] to [1:7582947099594315665:2250] query id ptqudq7uffpn58fsu002
2025-12-12T12:27:38.477412Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:466: TopicSession [2:7582947096977367213:2159] SubscribeOnNextEvent
2025-12-12T12:27:38.477850Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:940: RowDispatcher: Received TEvGetNextBatch from [1:7582947099594315665:2250] part id 0 query id ptqudq7uffpn58fsu002
2025-12-12T12:27:38.477868Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:588: TopicSession [2:7582947096977367213:2159] TEvGetNextBatch from [1:7582947099594315665:2250]
2025-12-12T12:27:38.477876Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:324: TTopicFormatHandler [json_each_row]: TClientHandler [1:7582947099594315665:2250]: FinishPacking, batch size: 180, number rows: 4
2025-12-12T12:27:38.477885Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:174: TTopicFormatHandler [json_each_row]: TClientHandler [1:7582947099594315665:2250]: ExtractClientData, number batches: 1
2025-12-12T12:27:38.477890Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:764: TopicSession [2:7582947096977367213:2159] SendData to [1:7582947099594315665:2250], batch size 1
2025-12-12T12:27:38.477896Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:457: TopicSession [2:7582947096977367213:2159] Skip SubscribeOnNextEvent, has ReadSession: true, IsWaitingEvents: 1
2025-12-12T12:27:38.477920Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1100: RowDispatcher: Forward TEvMessageBatch from [2:7582947096977367213:2159] to [1:7582947099594315665:2250] query id ptqudq7uffpn58fsu002
2025-12-12T12:27:38.478548Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:129: TxId: ptqudq7uffpn58fsu002, task: 2. Received input for channelId: 1, seqNo: 5, size: 153, chunks: 4, watermark: 0, checkpoint: 0, finished: 0, from: [1:7582947099594315662:2250], expected seqNo: 5
2025-12-12T12:27:38.478554Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:611: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. took input
2025-12-12T12:27:38.478576Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:356: SelfId: [2:7582947096977367210:2158], TxId: ptqudq7uffpn58fsu002, task: 2. No watermark 
2025-12-12T12:27:38.478583Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:965: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Input data push finished. Cookie: 4 Watermark: (empty maybe) Ack: 1 TakeInputChannelDataRequests: 1
2025-12-12T12:27:38.478587Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:738: TxId: ptqudq7uffpn58fsu002, task: 2. Sending channel data ack to channelId: 1, peer: [1:7582947099594315661:2250], from: [2:7582947096977367208:2158], freeSpace: 999847, seqNo: 5, finished: 0
2025-12-12T12:27:38.478601Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Poll inputs
2025-12-12T12:27:38.478605Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Poll sources
2025-12-12T12:27:38.478608Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-12-12T12:27:38.478642Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: 1491b042-dfeb4c70-9fdeb3bd-5494e95c 2025-12-12 12:27:38.478 DEBUG ydbd(pid=1192649, tid=0x00007F4166DDD640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Run task: 2
2025-12-12T12:27:38.482571Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. update task runner stats
2025-12-12T12:27:38.482604Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-12T12:27:38.482607Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:27:38.482622Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-12T12:27:38.482638Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [2:7582947096977367212:2158], TxId: ptqudq7uffpn58fsu002, TaskId: 2, PQ sink. SendData. Batch: 2. Checkpoint: 0. Finished: 0
2025-12-12T12:27:38.482642Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:221: SelfId: [2:7582947096977367212:2158], TxId: ptqudq7uffpn58fsu002, TaskId: 2, PQ sink. Received data for sending: {"count":2,"project":"project1","time":"2025-04-23T09:00:20Z"}
2025-12-12T12:27:38.482646Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:221: SelfId: [2:7582947096977367212:2158], TxId: ptqudq7uffpn58fsu002, TaskId: 2, PQ sink. Received data for sending: {"count":2,"project":"project2","time":"2025-04-23T09:00:20Z"}
2025-12-12T12:27:38.482680Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:38.482673Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uffpn58fsu002, TaskId: 2, PQ sink. ]  SessionId [1c92a47f-cd3e48b0-b9339377-f0c17b3b|1656f20d-186e37f7-5fcc467a-af07c739_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 3 to 3
2025-12-12T12:27:38.482697Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:38.482694Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uffpn58fsu002, TaskId: 2, PQ sink. ]  SessionId [1c92a47f-cd3e48b0-b9339377-f0c17b3b|1656f20d-186e37f7-5fcc467a-af07c739_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T12:27:38.482703Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:38.482701Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uffpn58fsu002, TaskId: 2, PQ sink. ]  SessionId [1c92a47f-cd3e48b0-b9339377-f0c17b3b|1656f20d-186e37f7-5fcc467a-af07c739_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 3
2025-12-12T12:27:38.482881Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Sink 0: sent 132 bytes of data and 0 bytes of checkpoint barrier
2025-12-12T12:27:38.482884Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 124, sent data from buffer: 132
2025-12-12T12:27:38.482893Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:629: TxId: ptqudq7uffpn58fsu002, task: 2. do poll, channelId: 1, last freeSpace: 999847, current freeSpace: 1000000, seqNo: 5
2025-12-12T12:27:38.482897Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:639: TxId: ptqudq7uffpn58fsu002, task: 2. Poll input channelId: 1, from: [1:7582947099594315661:2250], seqNo: 5, freeSpace: 1000000
2025-12-12T12:27:38.482902Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:738: TxId: ptqudq7uffpn58fsu002, task: 2. Sending channel data ack to channelId: 1, peer: [1:7582947099594315661:2250], from: [2:7582947096977367208:2158], freeSpace: 1000000, seqNo: 5, finished: 0
2025-12-12T12:27:38.482942Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:38.482923Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uffpn58fsu002, TaskId: 2, PQ sink. ]  SessionId [1c92a47f-cd3e48b0-b9339377-f0c17b3b|1656f20d-186e37f7-5fcc467a-af07c739_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 4 to 4
2025-12-12T12:27:38.482984Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:38.482982Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uffpn58fsu002, TaskId: 2, PQ sink. ]  SessionId [1c92a47f-cd3e48b0-b9339377-f0c17b3b|1656f20d-186e37f7-5fcc467a-af07c739_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T12:27:38.482991Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:38.482989Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uffpn58fsu002, TaskId: 2, PQ sink. ]  SessionId [1c92a47f-cd3e48b0-b9339377-f0c17b3b|1656f20d-186e37f7-5fcc467a-af07c739_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 4
2025-12-12T12:27:38.491664Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:38.491652Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uffpn58fsu002, TaskId: 2, PQ sink. ]  SessionId [1c92a47f-cd3e48b0-b9339377-f0c17b3b|1656f20d-186e37f7-5fcc467a-af07c739_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T12:27:38.491796Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:38.491792Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uffpn58fsu002, TaskId: 2, PQ sink. ]  SessionId [1c92a47f-cd3e48b0-b9339377-f0c17b3b|1656f20d-186e37f7-5fcc467a-af07c739_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 3 written { offset: 2 } } write_statistics { persisting_time { nanos: 1000000 } min_queue_wait_time { nanos: 7000000 } max_queue_wait_time { nanos: 7000000 } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T12:27:38.491803Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:38.491800Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uffpn58fsu002, TaskId: 2, PQ sink. ]  SessionId [1c92a47f-cd3e48b0-b9339377-f0c17b3b|1656f20d-186e37f7-5fcc467a-af07c739_0]  PartitionId [0]  Generation [1] OnAck: seqNo=3, txId=?
2025-12-12T12:27:38.491808Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:38.491805Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uffpn58fsu002, TaskId: 2, PQ sink. ]  SessionId [1c92a47f-cd3e48b0-b9339377-f0c17b3b|1656f20d-186e37f7-5fcc467a-af07c739_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 3
2025-12-12T12:27:38.491908Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:454: SelfId: [2:7582947096977367212:2158], TxId: ptqudq7uffpn58fsu002, TaskId: 2, PQ sink. Ack seq no 3
2025-12-12T12:27:38.492158Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:38.492153Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uffpn58fsu002, TaskId: 2, PQ sink. ]  SessionId [1c92a47f-cd3e48b0-b9339377-f0c17b3b|1656f20d-186e37f7-5fcc467a-af07c739_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T12:27:38.492206Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:38.492203Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uffpn58fsu002, TaskId: 2, PQ sink. ]  SessionId [1c92a47f-cd3e48b0-b9339377-f0c17b3b|1656f20d-186e37f7-5fcc467a-af07c739_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 4 written { offset: 3 } } write_statistics { persisting_time { } min_queue_wait_time { nanos: 1000000 } max_queue_wait_time { nanos: 1000000 } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T12:27:38.492210Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:38.492208Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uffpn58fsu002, TaskId: 2, PQ sink. ]  SessionId [1c92a47f-cd3e48b0-b9339377-f0c17b3b|1656f20d-186e37f7-5fcc467a-af07c739_0]  PartitionId [0]  Generation [1] OnAck: seqNo=4, txId=?
2025-12-12T12:27:38.492214Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:38.492212Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uffpn58fsu002, TaskId: 2, PQ sink. ]  SessionId [1c92a47f-cd3e48b0-b9339377-f0c17b3b|1656f20d-186e37f7-5fcc467a-af07c739_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 4
2025-12-12T12:27:38.492331Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:454: SelfId: [2:7582947096977367212:2158], TxId: ptqudq7uffpn58fsu002, TaskId: 2, PQ sink. Ack seq no 4
2025-12-12T12:27:38.504120Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:129: TxId: ptqudq7uffpn58fsu002, task: 2. Received input for channelId: 1, seqNo: 6, size: 0, chunks: 0, watermark: 0, checkpoint: 1, finished: 0, from: [1:7582947099594315662:2250], expected seqNo: 6
2025-12-12T12:27:38.504135Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:611: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. took input
2025-12-12T12:27:38.504146Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:485: [ptqudq7uffpn58fsu002-0] Task: 2. [Checkpoint 2.5] Got checkpoint barrier from channel 1
2025-12-12T12:27:38.504161Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:356: SelfId: [2:7582947096977367210:2158], TxId: ptqudq7uffpn58fsu002, task: 2. No watermark 
2025-12-12T12:27:38.504165Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Poll inputs
2025-12-12T12:27:38.504166Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1494: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-12-12T12:27:38.504168Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. DoExecuteImpl: 1
2025-12-12T12:27:38.504174Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:965: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Input data push finished. Cookie: 5 Watermark: (empty maybe) Ack: 1 TakeInputChannelDataRequests: 1
2025-12-12T12:27:38.504180Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:738: TxId: ptqudq7uffpn58fsu002, task: 2. Sending channel data ack to channelId: 1, peer: [1:7582947099594315661:2250], from: [2:7582947096977367208:2158], freeSpace: 1000000, seqNo: 6, finished: 0
2025-12-12T12:27:38.504225Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: 1491b042-dfeb4c70-9fdeb3bd-5494e95c 2025-12-12 12:27:38.504 DEBUG ydbd(pid=1192649, tid=0x00007F4166DDD640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Run task: 2
2025-12-12T12:27:38.504276Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:462: SelfId: [2:7582947096977367210:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Pending 1 checkpoints to be sent
2025-12-12T12:27:38.504288Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Poll inputs
2025-12-12T12:27:38.504289Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1494: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-12-12T12:27:38.504291Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-12-12T12:27:38.504293Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. update task runner stats
2025-12-12T12:27:38.504316Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 1 watermark injected: (empty maybe)
2025-12-12T12:27:38.504318Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:447: [ptqudq7uffpn58fsu002-0] Task: 2. [Checkpoint 2.5] Performing task checkpoint
2025-12-12T12:27:38.504321Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:816: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Save state
2025-12-12T12:27:38.504323Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:474: [ptqudq7uffpn58fsu002-0] Task: 2. [Checkpoint 2.5] CA state saved
2025-12-12T12:27:38.504325Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:449: [ptqudq7uffpn58fsu002-0] Task: 2. [Checkpoint 2.5] Injecting checkpoint barrier to outputs
2025-12-12T12:27:38.504327Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:27:38.504332Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-12T12:27:38.504338Z :KQP_COMPUTE INFO: dq_async_compute_actor.cpp:1010: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Resume inputs
2025-12-12T12:27:38.504341Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [2:7582947096977367212:2158], TxId: ptqudq7uffpn58fsu002, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 1. Finished: 0
2025-12-12T12:27:38.504343Z :KQP_COMPUTE DEBUG: dq_pq_write_actor.cpp:240: SelfId: [2:7582947096977367212:2158], TxId: ptqudq7uffpn58fsu002, TaskId: 2, PQ sink. [Checkpoint 2.5] Send checkpoint state immediately
2025-12-12T12:27:38.504369Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:418: SelfId: [2:7582947096977367212:2158], TxId: ptqudq7uffpn58fsu002, TaskId: 2, PQ sink. Save checkpoint { Id: 5 Generation: 2 Type: CHECKPOINT_TYPE_SNAPSHOT } state: { SourceId: "1c92a47f-cd3e48b0-b9339377-f0c17b3b" ConfirmedSeqNo: 4 EgressBytes: 248 }
2025-12-12T12:27:38.504372Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:524: [ptqudq7uffpn58fsu002-0] Task: 2. Sink[0] state saved
2025-12-12T12:27:38.504383Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:536: [ptqudq7uffpn58fsu002-0] Task: 2. [Checkpoint 2.5] Task checkpoint is done. Send to storage
2025-12-12T12:27:38.504392Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 6 bytes of checkpoint barrier
2025-12-12T12:27:38.504403Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-12T12:27:38.504410Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudq7uffpn58fsu002, task: 2. no poll, channelId: 1, has inflight messages: [6], last with freeSpace: 1000000, current freeSpace: 1000000
2025-12-12T12:27:38.504425Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: 1491b042-dfeb4c70-9fdeb3bd-5494e95c 2025-12-12 12:27:38.504 DEBUG ydbd(pid=1192649, tid=0x00007F4166DDD640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Run task: 2
2025-12-12T12:27:38.504435Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Poll inputs
2025-12-12T12:27:38.504436Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Poll sources
2025-12-12T12:27:38.504438Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-12-12T12:27:38.504439Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. update task runner stats
2025-12-12T12:27:38.504447Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-12T12:27:38.504448Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:27:38.504450Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-12T12:27:38.504454Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [2:7582947096977367212:2158], TxId: ptqudq7uffpn58fsu002, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-12-12T12:27:38.504455Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-12-12T12:27:38.504457Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-12T12:27:38.504460Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudq7uffpn58fsu002, task: 2. no poll, channelId: 1, has inflight messages: [6], last with freeSpace: 1000000, current freeSpace: 1000000
2025-12-12T12:27:38.504469Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: 1491b042-dfeb4c70-9fdeb3bd-5494e95c 2025-12-12 12:27:38.504 DEBUG ydbd(pid=1192649, tid=0x00007F4166DDD640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Run task: 2
2025-12-12T12:27:38.504475Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. update task runner stats
2025-12-12T12:27:38.504480Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-12T12:27:38.504482Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:27:38.504483Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-12T12:27:38.504486Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [2:7582947096977367212:2158], TxId: ptqudq7uffpn58fsu002, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-12-12T12:27:38.504487Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-12-12T12:27:38.504489Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-12T12:27:38.504492Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudq7uffpn58fsu002, task: 2. no poll, channelId: 1, has inflight messages: [6], last with freeSpace: 1000000, current freeSpace: 1000000
2025-12-12T12:27:38.504503Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:460: [ptqudq7uffpn58fsu002-0] [2:5] Got TEvSaveTaskState: task 2
2025-12-12T12:27:38.507277Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:484: [ptqudq7uffpn58fsu002-0] [2:5] TEvSaveTaskState Apply: task: 2
2025-12-12T12:27:38.507291Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:499: [ptqudq7uffpn58fsu002-0] [2:5] Send TEvSaveTaskStateResult: task: 2
2025-12-12T12:27:38.530122Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:759: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Commit state
2025-12-12T12:27:38.745093Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [2:7582946963833380804:2115]
2025-12-12T12:27:38.745114Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:38.745124Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [2:7582946963833380727:2063]
2025-12-12T12:27:38.745128Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [2:7582946963833380727:2063]
2025-12-12T12:27:38.745131Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [2:7582946963833380727:2063]
2025-12-12T12:27:38.745141Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:38.751242Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 1491b042-dfeb4c70-9fdeb3bd-5494e95c37, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:38.754947Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:38.754962Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:39.187637Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582947022284904054:2063]
2025-12-12T12:27:39.187674Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582947022284904054:2063]
2025-12-12T12:27:39.187677Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582947022284904054:2063]
2025-12-12T12:27:39.264728Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: 1491b042-dfeb4c70-9fdeb3bd-5494e95c 2025-12-12 12:27:39.264 DEBUG ydbd(pid=1192649, tid=0x00007F4166DDD640) [DQ] local_worker_manager.cpp:416: TEvFreeWorkersNotify 562954248388609
2025-12-12T12:27:39.264752Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: 1491b042-dfeb4c70-9fdeb3bd-5494e95c 2025-12-12 12:27:39.264 DEBUG ydbd(pid=1192649, tid=0x00007F4166DDD640) [DQ] local_worker_manager.cpp:440: Free Group 562954248388609
2025-12-12T12:27:39.264976Z :KQP_COMPUTE ERROR: dq_compute_actor_impl.h:1205: SelfId: [2:7582947096977367208:2158], TxId: ptqudq7uffpn58fsu002, task: 2. Ctx: {}. Handle abort execution event from: [2:7582946963833380728:2064], status: UNAVAILABLE, reason: { <main>: Error: Aborted by LWM }
2025-12-12T12:27:39.265028Z :KQP_COMPUTE DEBUG: dq_compute_actor_channels.cpp:494: TxId: ptqudq7uffpn58fsu002, task: 2. pass away
2025-12-12T12:27:39.265592Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:1001: RowDispatcher: Received TEvStopSession from [1:7582947099594315665:2250] topic test_group_by_hop_restart_node_input query id ptqudq7uffpn58fsu002
2025-12-12T12:27:39.265607Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:1016: RowDispatcher: DeleteConsumer, readActorId [1:7582947099594315665:2250] query id ptqudq7uffpn58fsu002, partitions size 1
2025-12-12T12:27:39.265627Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:1036: RowDispatcher: Session is not used, sent TEvPoisonPill to [2:7582947096977367213:2159]
2025-12-12T12:27:39.265682Z :FQ_ROW_DISPATCHER DEBUG: topic_session.cpp:831: TopicSession [2:7582947096977367213:2159] TEvStopSession from [1:7582947099594315665:2250] topicPath test_group_by_hop_restart_node_input clients count 1
2025-12-12T12:27:39.265691Z :FQ_ROW_DISPATCHER DEBUG: format_handler.cpp:477: TTopicFormatHandler [json_each_row]: Remove client with id [1:7582947099594315665:2250]
2025-12-12T12:27:39.265697Z :FQ_ROW_DISPATCHER TRACE: filters_set.cpp:94: TTopicFilters: Remove program with client id [1:7582947099594315665:2250]
2025-12-12T12:27:39.265714Z :FQ_ROW_DISPATCHER DEBUG: format_handler.cpp:559: TTopicFormatHandler [json_each_row]: UpdateParser to new schema with size 0
2025-12-12T12:27:39.265717Z :FQ_ROW_DISPATCHER INFO: format_handler.cpp:584: TTopicFormatHandler [json_each_row]: No columns to parse, reset parser
2025-12-12T12:27:39.266058Z :FQ_ROW_DISPATCHER DEBUG: topic_session.cpp:924: TopicSession [2:7582947096977367213:2159] Close read session
2025-12-12T12:27:39.266072Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:27:39.266066Z :INFO: [local] [local] [f0fabeee-75001020-c8df4478-c9ad3b5b] Closing read session. Close timeout: 0.000000s
2025-12-12T12:27:39.266098Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:27:39.266097Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:test_group_by_hop_restart_node_input:0:1:8:0
2025-12-12T12:27:39.266116Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:27:39.266114Z :INFO: [local] [local] [f0fabeee-75001020-c8df4478-c9ad3b5b] Counters: { Errors: 0 CurrentSessionLifetimeMs: 793 BytesRead: 248 MessagesRead: 4 BytesReadCompressed: 248 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:27:39.266134Z :YDB_SDK NOTICE: actor.cpp:37: 2025-12-12T12:27:39.266132Z :NOTICE: [local] [local] [f0fabeee-75001020-c8df4478-c9ad3b5b] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Close with zero timeout " }
2025-12-12T12:27:39.266142Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:39.266140Z :DEBUG: [local] [local] [f0fabeee-75001020-c8df4478-c9ad3b5b] [] Abort session to cluster
2025-12-12T12:27:39.266301Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:27:39.266299Z :INFO: [local] [local] [f0fabeee-75001020-c8df4478-c9ad3b5b] Closing read session. Close timeout: 0.000000s
2025-12-12T12:27:39.266306Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:27:39.266304Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:test_group_by_hop_restart_node_input:0:1:8:0
2025-12-12T12:27:39.266309Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:27:39.266308Z :INFO: [local] [local] [f0fabeee-75001020-c8df4478-c9ad3b5b] Counters: { Errors: 0 CurrentSessionLifetimeMs: 793 BytesRead: 248 MessagesRead: 4 BytesReadCompressed: 248 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:27:39.266316Z :YDB_SDK NOTICE: actor.cpp:37: 2025-12-12T12:27:39.266314Z :NOTICE: [local] [local] [f0fabeee-75001020-c8df4478-c9ad3b5b] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T12:27:39.266342Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:457: TopicSession [2:7582947096977367213:2159] Skip SubscribeOnNextEvent, has ReadSession: false, IsWaitingEvents: 1
2025-12-12T12:27:39.266357Z :FQ_ROW_DISPATCHER DEBUG: topic_session.cpp:449: TopicSession [2:7582947096977367213:2159] PassAway
2025-12-12T12:27:39.266557Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:27:39.266551Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uffpn58fsu002, TaskId: 2, PQ sink. ]  SessionId [1c92a47f-cd3e48b0-b9339377-f0c17b3b|1656f20d-186e37f7-5fcc467a-af07c739_0]  PartitionId [0]  Generation [1] Write session: close. Timeout 0.000000s
2025-12-12T12:27:39.266562Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:27:39.266560Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uffpn58fsu002, TaskId: 2, PQ sink. ]  SessionId [1c92a47f-cd3e48b0-b9339377-f0c17b3b|1656f20d-186e37f7-5fcc467a-af07c739_0]  PartitionId [0]  Generation [1] Write session will now close
2025-12-12T12:27:39.266582Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:39.266580Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uffpn58fsu002, TaskId: 2, PQ sink. ]  SessionId [1c92a47f-cd3e48b0-b9339377-f0c17b3b|1656f20d-186e37f7-5fcc467a-af07c739_0]  PartitionId [0]  Generation [1] Write session: aborting
2025-12-12T12:27:39.266623Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:27:39.266621Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uffpn58fsu002, TaskId: 2, PQ sink. ]  SessionId [1c92a47f-cd3e48b0-b9339377-f0c17b3b|1656f20d-186e37f7-5fcc467a-af07c739_0]  PartitionId [0]  Generation [1] Write session: gracefully shut down, all writes complete
2025-12-12T12:27:39.266627Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:39.266626Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uffpn58fsu002, TaskId: 2, PQ sink. ]  SessionId [1c92a47f-cd3e48b0-b9339377-f0c17b3b|1656f20d-186e37f7-5fcc467a-af07c739_0]  PartitionId [0]  Generation [1] Write session: destroy
2025-12-12T12:27:39.475204Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1059: RowDispatcher: No consumer with EventQueueId = 0
2025-12-12T12:27:39.599419Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [3:7582946968842489002:2063]
2025-12-12T12:27:39.599436Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [3:7582946968842489002:2063]
2025-12-12T12:27:39.599439Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [3:7582946968842489002:2063]
2025-12-12T12:27:39.751659Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 1491b042-dfeb4c70-9fdeb3bd-5494e95c38, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:39.755332Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:39.755357Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:40.745976Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [2:7582946963833380804:2115]
2025-12-12T12:27:40.746001Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:40.746007Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [2:7582946963833380727:2063]
2025-12-12T12:27:40.746011Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [2:7582946963833380727:2063]
2025-12-12T12:27:40.746014Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [2:7582946963833380727:2063]
2025-12-12T12:27:40.746035Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:40.752136Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 1491b042-dfeb4c70-9fdeb3bd-5494e95c39, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:40.756850Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:40.756872Z :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:63438: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-fhkyrtz6p4.auto.internal:63438
2025-12-12T12:27:41.190564Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582947022284904054:2063]
2025-12-12T12:27:41.190576Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582947022284904054:2063]
2025-12-12T12:27:41.190579Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582947022284904054:2063]
2025-12-12T12:27:41.599969Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [3:7582946968842489002:2063]
2025-12-12T12:27:41.599986Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [3:7582946968842489002:2063]
2025-12-12T12:27:41.599989Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [3:7582946968842489002:2063]
2025-12-12T12:27:41.752536Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 1491b042-dfeb4c70-9fdeb3bd-5494e95c40, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:41.759273Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:41.759302Z :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:63438: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-fhkyrtz6p4.auto.internal:63438
2025-12-12T12:27:42.737692Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-12-12T12:27:42.743571Z :YQL_NODES_MANAGER ERROR: nodes_manager.cpp:395: ydb/core/fq/libs/actors/nodes_manager.cpp:353: TRANSPORT_UNAVAILABLE
<main>: Error: GRpc error: (14): connections to all backends failing; last error: UNKNOWN: ipv4:127.0.1.1:63438: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-fhkyrtz6p4.auto.internal:63438
2025-12-12T12:27:42.746890Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [2:7582946963833380804:2115]
2025-12-12T12:27:42.746911Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:42.746918Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [2:7582946963833380727:2063]
2025-12-12T12:27:42.746922Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [2:7582946963833380727:2063]
2025-12-12T12:27:42.746925Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [2:7582946963833380727:2063]
2025-12-12T12:27:42.746933Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:42.753028Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 1491b042-dfeb4c70-9fdeb3bd-5494e95c41, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:42.757859Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:42.757884Z :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:63438: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-fhkyrtz6p4.auto.internal:63438
2025-12-12T12:27:43.190446Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582947022284904054:2063]
2025-12-12T12:27:43.190465Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582947022284904054:2063]
2025-12-12T12:27:43.190469Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582947022284904054:2063]
2025-12-12T12:27:43.600863Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [3:7582946968842489002:2063]
2025-12-12T12:27:43.600878Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [3:7582946968842489002:2063]
2025-12-12T12:27:43.600882Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [3:7582946968842489002:2063]
2025-12-12T12:27:43.753471Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 1491b042-dfeb4c70-9fdeb3bd-5494e95c42, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:43.758990Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:43.759031Z :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:63438: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-fhkyrtz6p4.auto.internal:63438
2025-12-12T12:27:44.747794Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [2:7582946963833380804:2115]
2025-12-12T12:27:44.747818Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:44.747827Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [2:7582946963833380727:2063]
2025-12-12T12:27:44.747830Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [2:7582946963833380727:2063]
2025-12-12T12:27:44.747832Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [2:7582946963833380727:2063]
2025-12-12T12:27:44.747842Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:44.753917Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 1491b042-dfeb4c70-9fdeb3bd-5494e95c43, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:44.758748Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:44.758770Z :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:63438: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-fhkyrtz6p4.auto.internal:63438
2025-12-12T12:27:45.191290Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582947022284904054:2063]
2025-12-12T12:27:45.191306Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582947022284904054:2063]
2025-12-12T12:27:45.191309Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582947022284904054:2063]
2025-12-12T12:27:45.601773Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [3:7582946968842489002:2063]
2025-12-12T12:27:45.601789Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [3:7582946968842489002:2063]
2025-12-12T12:27:45.601792Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [3:7582946968842489002:2063]
2025-12-12T12:27:45.754365Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 1491b042-dfeb4c70-9fdeb3bd-5494e95c44, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:45.760168Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:45.760189Z :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:63438: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-fhkyrtz6p4.auto.internal:63438
2025-12-12T12:27:46.750174Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [2:7582946963833380804:2115]
2025-12-12T12:27:46.750194Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:46.750201Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [2:7582946963833380727:2063]
2025-12-12T12:27:46.750205Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [2:7582946963833380727:2063]
2025-12-12T12:27:46.750208Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [2:7582946963833380727:2063]
2025-12-12T12:27:46.750220Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:46.754821Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 1491b042-dfeb4c70-9fdeb3bd-5494e95c45, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:46.763590Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:46.763614Z :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:63438: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-fhkyrtz6p4.auto.internal:63438
2025-12-12T12:27:46.883582Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:597: RowDispatcher: TEvNodeDisconnected, node id 1
2025-12-12T12:27:46.883660Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:398: Coordinator: TEvNodeDisconnected, node id 1
2025-12-12T12:27:46.883669Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:408: Coordinator: Schedule TEvRebalancing
2025-12-12T12:27:46.883672Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:398: Coordinator: TEvNodeDisconnected, node id 3
2025-12-12T12:27:46.884161Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1052: RowDispatcher: TEvTryConnect to node id 1
2025-12-12T12:27:46.884858Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:597: RowDispatcher: TEvNodeDisconnected, node id 1
