2025-12-12T12:27:15.179630Z :GRPC_SERVER NOTICE: grpc_request_proxy.cpp:380: Grpc request proxy started, nodeid# 1, serve as static node
2025-12-12T12:27:15.179686Z :GRPC_SERVER CRIT: grpc_request_proxy.cpp:440: Failed to deliver subscription request to config dispatcher
2025-12-12T12:27:15.179691Z :GRPC_SERVER NOTICE: grpc_request_proxy.cpp:380: Grpc request proxy started, nodeid# 1, serve as static node
2025-12-12T12:27:15.179707Z :GRPC_SERVER CRIT: grpc_request_proxy.cpp:440: Failed to deliver subscription request to config dispatcher
2025-12-12T12:27:15.179986Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:214: Bootstrap
2025-12-12T12:27:15.179990Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:217: Create sdk ydb connection
2025-12-12T12:27:15.180666Z :FQ_QUOTA_PROXY INFO: quota_proxy.cpp:90: STARTED
2025-12-12T12:27:15.180724Z :FQ_LOG_UPDATER DEBUG: log.cpp:93: Updated YQL logs priority: 8
2025-12-12T12:27:15.180729Z :FQ_LOG_UPDATER CRIT: log.cpp:55: Failed to deliver subscription request to config dispatcher.
2025-12-12T12:27:15.180762Z :FQ_QUOTA_SERVICE INFO: quota_manager.cpp:196: STARTED
2025-12-12T12:27:15.180780Z :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:15.180813Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:544: RowDispatcher: Successfully bootstrapped row dispatcher, id [1:7582947022284904054:2063], tenant /compute
2025-12-12T12:27:15.180827Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582947022284904054:2063]
2025-12-12T12:27:15.180829Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:329: Coordinator: Add new row dispatcher to map (state 1)
2025-12-12T12:27:15.180983Z :YQL_NODES_MANAGER INFO: nodes_manager.cpp:88: Bootstrap, InstanceId: 6d282ecc-4b4adc6f-ce2b0797-27f46cf1
2025-12-12T12:27:15.180985Z :YQL_NODES_MANAGER DEBUG: nodes_manager.cpp:310: TNodesManagerActor::ResolveSelfAddress
2025-12-12T12:27:15.180995Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:293: Coordinator: Successfully bootstrapped coordinator, id [1:7582947022284904099:2092], NodesManagerId [0:4705493345362661702:78], rebalancing timeout 5.000000s
2025-12-12T12:27:15.181010Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:232: TLeaderElection [1:7582947022284904103:2093] Successfully bootstrapped, local coordinator id [1:7582947022284904099:2092], tenant id compute, local mode 0, coordination node path local/compute, endpoint localhost:23627
2025-12-12T12:27:15.181107Z :YQ_TEST_CONNECTION DEBUG: test_connection.cpp:142: Starting yandex query test connection. Actor id: [1:7582947022284904059:2068]
2025-12-12T12:27:15.181160Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 6734039d-3c6d3147-8d4aa390-5370ecbe1, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:15.181395Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:637: RowDispatcher: TEvCoordinatorChangesSubscribe from [1:7582947022284904099:2092]
2025-12-12T12:27:15.181414Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:239: Successfully bootstrapped TStorageProxy [1:7582947022284904053:2062] with connection to localhost:23627:local
2025-12-12T12:27:15.182840Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:71: Run create coordination node "local/compute" actor
2025-12-12T12:27:15.182844Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:113: Call create coordination node "local/compute"
2025-12-12T12:27:15.182847Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:411: Call create coordination node "local/compute"
2025-12-12T12:27:15.183054Z :MEMORY_PROFILER NOTICE: monitor.cpp:332: Bootstrapped
2025-12-12T12:27:15.183467Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-12-12T12:27:15.184340Z :SCHEME_BOARD_SUBSCRIBER NOTICE: subscriber.cpp:849: [main][1:7582947022284904074:2078][/compute] Set up state: owner# [1:7582947022284904033:2052], state# { Deleted: 1 Strong: 0 Version: <Invalid> DomainId: <Invalid> AbandonedSchemeShards: there are 0 elements }
2025-12-12T12:27:15.184361Z :SCHEME_BOARD_SUBSCRIBER NOTICE: subscriber.cpp:849: [main][1:7582947022284904075:2079][/Root] Set up state: owner# [1:7582947022284904034:2053], state# { Deleted: 1 Strong: 0 Version: <Invalid> DomainId: <Invalid> AbandonedSchemeShards: there are 0 elements }
2025-12-12T12:27:15.184361Z :SCHEME_BOARD_SUBSCRIBER NOTICE: subscriber.cpp:849: [main][1:7582947022284904073:2077][/Root] Set up state: owner# [1:7582947022284904033:2052], state# { Deleted: 1 Strong: 0 Version: <Invalid> DomainId: <Invalid> AbandonedSchemeShards: there are 0 elements }
2025-12-12T12:27:15.184372Z :GRPC_SERVER WARN: grpc_request_proxy.cpp:583: SchemeBoardDelete /compute Strong=0
2025-12-12T12:27:15.184373Z :SCHEME_BOARD_SUBSCRIBER NOTICE: subscriber.cpp:849: [main][1:7582947022284904076:2080][/compute] Set up state: owner# [1:7582947022284904034:2053], state# { Deleted: 1 Strong: 0 Version: <Invalid> DomainId: <Invalid> AbandonedSchemeShards: there are 0 elements }
2025-12-12T12:27:15.184374Z :GRPC_SERVER WARN: grpc_request_proxy.cpp:583: SchemeBoardDelete /Root Strong=0
2025-12-12T12:27:15.184379Z :GRPC_SERVER WARN: grpc_request_proxy.cpp:583: SchemeBoardDelete /Root Strong=0
2025-12-12T12:27:15.184381Z :GRPC_SERVER WARN: grpc_request_proxy.cpp:583: SchemeBoardDelete /compute Strong=0
2025-12-12T12:27:15.198935Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:155: Successfully created coordination node "local/compute"
2025-12-12T12:27:15.198956Z :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:15.198974Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:345: TLeaderElection [1:7582947022284904103:2093] Coordination node successfully created
2025-12-12T12:27:15.198977Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:323: TLeaderElection [1:7582947022284904103:2093] Start session
2025-12-12T12:27:15.202906Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:359: TLeaderElection [1:7582947022284904103:2093] Session successfully created
2025-12-12T12:27:15.204806Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:372: TLeaderElection [1:7582947022284904103:2093] Semaphore successfully created
2025-12-12T12:27:15.204818Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:304: TLeaderElection [1:7582947022284904103:2093] Try to acquire semaphore
2025-12-12T12:27:15.204907Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:420: TLeaderElection [1:7582947022284904103:2093] Describe semaphore
2025-12-12T12:27:15.205774Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:15.205788Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:15.207642Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:389: Send NodeInfo with size: 2 to DynamicNameserver
2025-12-12T12:27:15.209965Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:469: TLeaderElection [1:7582947022284904103:2093] Semaphore successfully described: coordinator id [2:7582946963833380804:2115] generation 2
2025-12-12T12:27:15.209979Z :FQ_ROW_DISPATCHER INFO: leader_election.cpp:471: TLeaderElection [1:7582947022284904103:2093] Send TEvCoordinatorChanged to [1:7582947022284904054:2063], new coordinator id [2:7582946963833380804:2115], previous coordinator id [0:0:0]
2025-12-12T12:27:15.210002Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:569: RowDispatcher: Coordinator changed, old leader (empty maybe), new [2:7582946963833380804:2115] generation 2
2025-12-12T12:27:15.210032Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:440: Coordinator: New leader [2:7582946963833380804:2115], SelfId [1:7582947022284904099:2092]
2025-12-12T12:27:15.210038Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:607: RowDispatcher: TEvUndelivered, from [2:7582946963833380804:2115], reason Disconnected
2025-12-12T12:27:15.264460Z :INTERCONNECT WARN: interconnect_handshake.cpp:501: Handshake [1:7582947022284904220:2053] [node 2] ICH09 Neither CompatibilityInfo nor VersionTag of the peer can be validated, accepting by default
2025-12-12T12:27:15.264844Z :INTERCONNECT WARN: interconnect_handshake.cpp:501: Handshake [1:7582947022284904223:2054] [node 3] ICH09 Neither CompatibilityInfo nor VersionTag of the peer can be validated, accepting by default
2025-12-12T12:27:16.178811Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 6734039d-3c6d3147-8d4aa390-5370ecbe2, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:16.186206Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:16.186224Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:16.194354Z :FQ_QUOTA_SERVICE DEBUG: quota_manager.cpp:230: IC Peers[2]: [2, 3]
2025-12-12T12:27:17.177678Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [2:7582946963833380804:2115]
2025-12-12T12:27:17.177696Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:17.178442Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:17.179717Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 6734039d-3c6d3147-8d4aa390-5370ecbe3, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:17.212868Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:17.212886Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:18.179919Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 6734039d-3c6d3147-8d4aa390-5370ecbe4, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:18.186456Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:18.186467Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:19.178305Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [2:7582946963833380804:2115]
2025-12-12T12:27:19.178320Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:19.178924Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:19.180325Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 6734039d-3c6d3147-8d4aa390-5370ecbe5, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:19.186618Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:19.186636Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:20.177709Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:665: Coordinator: Change global state to Started (by timeout)
2025-12-12T12:27:20.177713Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-12-12T12:27:20.180783Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 6734039d-3c6d3147-8d4aa390-5370ecbe6, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:20.184390Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:20.184406Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:20.185424Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:389: Send NodeInfo with size: 2 to DynamicNameserver
2025-12-12T12:27:21.179195Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [2:7582946963833380804:2115]
2025-12-12T12:27:21.179221Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:21.179684Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:21.181230Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 6734039d-3c6d3147-8d4aa390-5370ecbe7, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:21.184974Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:21.184990Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:22.181696Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 6734039d-3c6d3147-8d4aa390-5370ecbe8, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:22.185794Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:22.185809Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:23.180098Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [2:7582946963833380804:2115]
2025-12-12T12:27:23.180121Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:23.180579Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:23.182285Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 6734039d-3c6d3147-8d4aa390-5370ecbe9, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:23.195111Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:23.195125Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:24.182598Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 6734039d-3c6d3147-8d4aa390-5370ecbe10, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:24.201381Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:24.201399Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:25.177925Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:599: Coordinator: Send TEvGetNodesRequest to NodesManager
2025-12-12T12:27:25.177951Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-12-12T12:27:25.178205Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:300: Received TNodesManagerActor::TEvGetNodesRequest
2025-12-12T12:27:25.178228Z :FQ_ROW_DISPATCHER INFO: coordinator.cpp:690: Coordinator: Updated node info, node count: 3
2025-12-12T12:27:25.181000Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [2:7582946963833380804:2115]
2025-12-12T12:27:25.181017Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:25.181528Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:25.183035Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 6734039d-3c6d3147-8d4aa390-5370ecbe11, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:25.188310Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:25.188326Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:25.192971Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:389: Send NodeInfo with size: 2 to DynamicNameserver
2025-12-12T12:27:26.183465Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 6734039d-3c6d3147-8d4aa390-5370ecbe12, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:26.187937Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:26.187950Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:27.181873Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [2:7582946963833380804:2115]
2025-12-12T12:27:27.181934Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:27.183153Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:27.183924Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 6734039d-3c6d3147-8d4aa390-5370ecbe13, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:27.187933Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:27.187945Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:28.184413Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 6734039d-3c6d3147-8d4aa390-5370ecbe14, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:28.188616Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:28.188629Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:29.182752Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [2:7582946963833380804:2115]
2025-12-12T12:27:29.182777Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:29.183204Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:29.184867Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 6734039d-3c6d3147-8d4aa390-5370ecbe15, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:29.188781Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:29.188796Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:30.178115Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-12-12T12:27:30.185265Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 6734039d-3c6d3147-8d4aa390-5370ecbe16, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:30.187041Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:389: Send NodeInfo with size: 2 to DynamicNameserver
2025-12-12T12:27:30.188859Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:30.188873Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:31.183663Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [2:7582946963833380804:2115]
2025-12-12T12:27:31.183690Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:31.184032Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:31.185708Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 6734039d-3c6d3147-8d4aa390-5370ecbe17, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:31.189723Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:31.189741Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:32.186135Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 6734039d-3c6d3147-8d4aa390-5370ecbe18, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:32.189875Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:32.189892Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:33.184548Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [2:7582946963833380804:2115]
2025-12-12T12:27:33.184590Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:33.185048Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:33.186607Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 6734039d-3c6d3147-8d4aa390-5370ecbe19, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:33.199116Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:33.199135Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 1
2025-12-12T12:27:33.199169Z :FQ_PENDING_FETCHER DEBUG: pending_fetcher.cpp:361: NewTask: Scope: yandexcloud://my_folder Id: ptqudq7uffpn58fsu002 UserId: root@builtin AuthToken: **** (B6C6F477)
2025-12-12T12:27:33.199365Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:375: QueryId: ptqudq7uffpn58fsu002 Start run actor. Compute state: RUNNING
2025-12-12T12:27:33.199368Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:469: QueryId: ptqudq7uffpn58fsu002 FillConnections
2025-12-12T12:27:33.199370Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 6734039d-3c6d3147-8d4aa390-5370ecbe20, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:33.199403Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:2333: QueryId: ptqudq7uffpn58fsu002 Run actors params: { QueryId: ptqudq7uffpn58fsu002 CloudId: mock_cloud UserId: root@builtin Owner: 6734039d-3c6d3147-8d4aa390-5370ecbe19 PreviousQueryRevision: 2 Connections: 1 Bindings: 0 AccountIdSignatures: 0 QueryType: STREAMING ExecuteMode: RUN ResultId: ptrudq7uejrfk61o469o StateLoadMode: FROM_LAST_CHECKPOINT StreamingDisposition: { from_last_checkpoint { } } Status: RUNNING DqGraphs: 1 DqGraphIndex: 0 Resource.TopicConsumers: 1 }
2025-12-12T12:27:33.199427Z :FQ_PINGER TRACE: pinger.cpp:171: QueryId: ptqudq7uffpn58fsu002, Owner: 6734039d-3c6d3147-8d4aa390-5370ecbe19 Start Pinger
2025-12-12T12:27:33.199492Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:911: QueryId: ptqudq7uffpn58fsu002 Overall dq tasks: 2
2025-12-12T12:27:33.199651Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:1598: QueryId: ptqudq7uffpn58fsu002 ResultWriter was NOT CREATED since ResultType is empty
2025-12-12T12:27:33.199733Z :FQ_PINGER TRACE: pinger.cpp:250: QueryId: ptqudq7uffpn58fsu002, Owner: 6734039d-3c6d3147-8d4aa390-5370ecbe19 Forward ping request: { resources { rate_limiter: READY compilation: READY topic_consumers_state: READY rate_limiter_path: "local/RateLimiter_755dc3ae-6741-4057-8e98-960aa5272d3f/rate_limiter" topic_consumers { database: "local" topic_path: "test_group_by_hop_restart_node_input" consumer_name: "ptqudq7uffpn58fsu002" cluster_endpoint: "localhost:23627" token_name: "cluster:default_yds" add_bearer_to_token: true } } }
2025-12-12T12:27:33.199739Z :FQ_PINGER TRACE: pinger.cpp:393: QueryId: ptqudq7uffpn58fsu002, Owner: 6734039d-3c6d3147-8d4aa390-5370ecbe19 Forward request Private::PingTask
2025-12-12T12:27:33.199753Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudq7uffpn58fsu002 2025-12-12 12:27:33.199 DEBUG ydbd(pid=1201569, tid=0x00007F114705A640) [DQ] task_controller_impl.h:86: _RowsLimitPerWrite = 0
2025-12-12T12:27:33.199808Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:1652: QueryId: ptqudq7uffpn58fsu002 Executer: [1:7582947099594315657:2246], Controller: [1:7582947099594315659:2248], ResultIdActor: [1:7582947099594315657:2246]
2025-12-12T12:27:33.199832Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudq7uffpn58fsu002 2025-12-12 12:27:33.199 DEBUG ydbd(pid=1201569, tid=0x00007F114705A640) [DQ] executer_actor.cpp:140: {ptqudq7uffpn58fsu002} TDqExecuter::OnGraph
2025-12-12T12:27:33.199846Z :YQL_PROXY INFO: log.cpp:64: SessionId: ptqudq7uffpn58fsu002 2025-12-12 12:27:33.199 INFO  ydbd(pid=1201569, tid=0x00007F114705A640) [DQ] executer_actor.cpp:157: {ptqudq7uffpn58fsu002} Trying to allocate 2 workers [EnableComputeActor=1]
2025-12-12T12:27:33.200924Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudq7uffpn58fsu002 2025-12-12 12:27:33.200 DEBUG ydbd(pid=1201569, tid=0x00007F114705A640) [DQ] executer_actor.cpp:247: {ptqudq7uffpn58fsu002} Dq timeouts are set to: 0.000000s (global), 600.000000s (workers allocation fail), 30.000000s (workers allocation warn) 
2025-12-12T12:27:33.201701Z :YQL_NODES_MANAGER DEBUG: nodes_manager.cpp:125: TEvAllocateWorkersResponse Nodes {
  ResourceId: 4294967297
  Worker {
    NodeId: 1
    Guid: "6d282ecc-4b4adc6f-ce2b0797-27f46cf1,ghrun-fhkyrtz6p4"
  }
  Worker {
    NodeId: 2
    Guid: "41f02fa8-4f6579b8-b65bb5b4-e6e247cf,ghrun-fhkyrtz6p4"
  }
}
2025-12-12T12:27:33.202667Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:33.202679Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:33.211513Z :FQ_PINGER TRACE: pinger.cpp:338: QueryId: ptqudq7uffpn58fsu002, Owner: 6734039d-3c6d3147-8d4aa390-5370ecbe19 Ping response success: { expired_at { seconds: 1765542473 nanos: 205000000 } }
2025-12-12T12:27:33.211555Z :FQ_RUN_ACTOR TRACE: run_actor.cpp:861: QueryId: ptqudq7uffpn58fsu002 Forward ping response. Success: 1. Cookie: 0
2025-12-12T12:27:33.232355Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:144: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Start compute actor [1:7582947099594315661:2250], task: 1
2025-12-12T12:27:33.232408Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:114: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. 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.232607Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: 6734039d-3c6d3147-8d4aa390-5370ecbe 2025-12-12 12:27:33.232 DEBUG ydbd(pid=1201569, tid=0x00007F1145857640) [DQ] tasks_runner_local.cpp:267: {TODO/1} Build task: 1
2025-12-12T12:27:33.232737Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: 6734039d-3c6d3147-8d4aa390-5370ecbe 2025-12-12 12:27:33.232 DEBUG ydbd(pid=1201569, tid=0x00007F1145857640) [DQ] tasks_runner_local.cpp:267: {TODO/1} task: 1, program size: 35, llvm: ``.
2025-12-12T12:27:33.237612Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudq7uffpn58fsu002 2025-12-12 12:27:33.237 DEBUG ydbd(pid=1201569, tid=0x00007F114805C640) [DQ] executer_actor.cpp:358: {ptqudq7uffpn58fsu002} TDqExecuter::TEvAllocateWorkersResponse
2025-12-12T12:27:33.237639Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudq7uffpn58fsu002 2025-12-12 12:27:33.237 DEBUG ydbd(pid=1201569, tid=0x00007F114805C640) [DQ] executer_actor.cpp:384: {ptqudq7uffpn58fsu002} Allocated resource 4294967297
2025-12-12T12:27:33.237705Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudq7uffpn58fsu002 2025-12-12 12:27:33.237 DEBUG ydbd(pid=1201569, tid=0x00007F114805C640) [DQ] executer_actor.cpp:401: {ptqudq7uffpn58fsu002} WorkerInfo: Id:6d282ecc-4b4adc6f-ce2b0797-27f46cf1,ghrun-fhkyrtz6p4,NodeId:1,StageId:201976
2025-12-12T12:27:33.237718Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudq7uffpn58fsu002 2025-12-12 12:27:33.237 DEBUG ydbd(pid=1201569, tid=0x00007F114805C640) [DQ] executer_actor.cpp:402: {ptqudq7uffpn58fsu002} TaskInfo: 0/1
2025-12-12T12:27:33.237727Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudq7uffpn58fsu002 2025-12-12 12:27:33.237 DEBUG ydbd(pid=1201569, tid=0x00007F114805C640) [DQ] executer_actor.cpp:404: {ptqudq7uffpn58fsu002}  ObjectId: 88a034dc314301cb1522a933e690a4c49a7591e8, dq_vanilla_job.lite, 
2025-12-12T12:27:33.237759Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudq7uffpn58fsu002 2025-12-12 12:27:33.237 DEBUG ydbd(pid=1201569, tid=0x00007F114805C640) [DQ] executer_actor.cpp:401: {ptqudq7uffpn58fsu002} WorkerInfo: Id:41f02fa8-4f6579b8-b65bb5b4-e6e247cf,ghrun-fhkyrtz6p4,NodeId:2,StageId:201993
2025-12-12T12:27:33.237780Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudq7uffpn58fsu002 2025-12-12 12:27:33.237 DEBUG ydbd(pid=1201569, tid=0x00007F114805C640) [DQ] executer_actor.cpp:402: {ptqudq7uffpn58fsu002} TaskInfo: 1/2
2025-12-12T12:27:33.237787Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudq7uffpn58fsu002 2025-12-12 12:27:33.237 DEBUG ydbd(pid=1201569, tid=0x00007F114805C640) [DQ] executer_actor.cpp:404: {ptqudq7uffpn58fsu002}  ObjectId: 88a034dc314301cb1522a933e690a4c49a7591e8, dq_vanilla_job.lite, 
2025-12-12T12:27:33.237810Z :YQL_PROXY INFO: log.cpp:64: SessionId: ptqudq7uffpn58fsu002 2025-12-12 12:27:33.237 INFO  ydbd(pid=1201569, tid=0x00007F114805C640) [DQ] executer_actor.cpp:415: {ptqudq7uffpn58fsu002} 2 workers allocated
2025-12-12T12:27:33.237978Z :YQL_PROXY TRACE: log.cpp:64: SessionId:  2025-12-12 12:27:33.237 TRACE ydbd(pid=1201569, tid=0x00007F114705A640) [DQ] task_controller_impl.h:271:  [1:7582947099594315659:2248] ExportStats Summary
2025-12-12T12:27:33.238018Z :YQL_PROXY DEBUG: log.cpp:64: SessionId:  2025-12-12 12:27:33.238 DEBUG ydbd(pid=1201569, tid=0x00007F114705A640) [DQ] task_controller_impl.h:526: Ready State: [1:7582947099594315659:2248]
2025-12-12T12:27:33.238031Z :YQL_PROXY DEBUG: log.cpp:64: SessionId:  2025-12-12 12:27:33.238 DEBUG ydbd(pid=1201569, tid=0x00007F114705A640) [DQ] task_controller_impl.h:537: Forward: [1:7582947099594315659:2248] to [1:7582947099594315658:2247]
2025-12-12T12:27:33.238077Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:70: [ptqudq7uffpn58fsu002-0.2] TEvReadyState, streaming disposition { from_last_checkpoint { } }, state load mode FROM_LAST_CHECKPOINT, checkpointing period 1.000000s
2025-12-12T12:27:33.238107Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:104: [ptqudq7uffpn58fsu002-0.2] AllActors count: 2, ActorsToTrigger count: 1, ActorsToNotify count: 2, ActorsToWaitFor count: 2
2025-12-12T12:27:33.238109Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:114: [ptqudq7uffpn58fsu002-0.2] Send TEvRegisterCoordinatorRequest
2025-12-12T12:27:33.238122Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:261: [ptqudq7uffpn58fsu002-0.2] Got TEvRegisterCoordinatorRequest
2025-12-12T12:27:33.238124Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:243: StartInitialization, EnableSecureScriptExecutions: 0
2025-12-12T12:27:33.238996Z :STREAMS_STORAGE_SERVICE NOTICE: storage_proxy.cpp:585: Add to delayed
2025-12-12T12:27:33.249359Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:557: Checkpoint storage and state storage were successfully initted
2025-12-12T12:27:33.249376Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:261: [ptqudq7uffpn58fsu002-0.2] Got TEvRegisterCoordinatorRequest
2025-12-12T12:27:33.275802Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:279: [ptqudq7uffpn58fsu002-0.2] Graph registered
2025-12-12T12:27:33.275818Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:281: [ptqudq7uffpn58fsu002-0.2] Send TEvRegisterCoordinatorResponse
2025-12-12T12:27:33.275860Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:131: [ptqudq7uffpn58fsu002-0.2] Got TEvRegisterCoordinatorResponse; issues: 
2025-12-12T12:27:33.275864Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:140: [ptqudq7uffpn58fsu002-0.2] Successfully registered in storage
2025-12-12T12:27:33.275866Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:141: [ptqudq7uffpn58fsu002-0.2] Send TEvNewCheckpointCoordinator to 2 actor(s)
2025-12-12T12:27:33.275879Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:149: [ptqudq7uffpn58fsu002-0.2] Send TEvGetCheckpointsMetadataRequest; state load mode: FROM_LAST_CHECKPOINT; load graph: 0
2025-12-12T12:27:33.275901Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:434: [ptqudq7uffpn58fsu002-0] Got TEvGetCheckpointsMetadataRequest
2025-12-12T12:27:33.276781Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:622: [ptqudq7uffpn58fsu002-0.2] Handle connected node 2
2025-12-12T12:27:33.285547Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: 6734039d-3c6d3147-8d4aa390-5370ecbe 2025-12-12 12:27:33.285 DEBUG ydbd(pid=1201569, tid=0x00007F1145857640) [DQ] tasks_runner_local.cpp:267: {TODO/1} Build task: 1 takes 52896 us
2025-12-12T12:27:33.285572Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: 6734039d-3c6d3147-8d4aa390-5370ecbe 2025-12-12 12:27:33.285 DEBUG ydbd(pid=1201569, tid=0x00007F1145857640) [DQ] tasks_runner_local.cpp:267: {TODO/1} Prepare task: 1
2025-12-12T12:27:33.285610Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: 6734039d-3c6d3147-8d4aa390-5370ecbe 2025-12-12 12:27:33.285 DEBUG ydbd(pid=1201569, tid=0x00007F1145857640) [DQ] tasks_runner_local.cpp:267: {TODO/1} Prepare task: 1, takes 29 us
2025-12-12T12:27:33.285690Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:197: [] Task: 1. Got TEvNewCheckpointCoordinator event: generation 2, actorId: [1:7582947099594315658:2247]
2025-12-12T12:27:33.285691Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:208: [] Task: 1. Assign checkpoint coordinator (generation = 2)
2025-12-12T12:27:33.286487Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1360: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Create source for input 0 { Source { Type: "PqSource" Settings { type_url: "type.googleapis.com/NYql.NPq.NProto.TDqPqTopicSource" value: "\n$test_group_by_hop_restart_node_input\022\024ptqudq7uffpn58fsu002\032\017localhost:23627\"\025\n\023cluster:default_yds*\005local0\002@\001b\007projectb\004timej\025[\"DataType\";\"String\"]j\025[\"DataType\";\"String\"]x\001\222\001\024ptcudq7ufg88kfhtto4t\232\001\rjson_each_row\242\001Q[\"StructType\";[[\"project\";[\"DataType\";\"String\"]];[\"time\";[\"DataType\";\"String\"]]]]\262\001\002\022\000\272\001\026\n\010cloud_id\022\nmock_cloud\272\001 \n\005scope\022\027yandexcloud://my_folder" } WatermarksMode: WATERMARKS_MODE_DISABLED } }
2025-12-12T12:27:33.286839Z :KQP_COMPUTE INFO: dq_pq_rd_read_actor.cpp:557: SelfId: [0:0:0], TxId: ptqudq7uffpn58fsu002, task: 1. PQ source. Start read actor, local row dispatcher [0:5788050504107380562:5260383], metadatafields: , partitions: 0, skip json errors: 0
2025-12-12T12:27:33.286896Z :KQP_COMPUTE DEBUG: dq_pq_read_actor_base.cpp:153: SelfId: [0:0:0], TxId: ptqudq7uffpn58fsu002, task: 1. PQ source. SessionId: empty Watermarks enabled: 0 granularity: 0.000000s late arrival delay: 0.000000s idle: 0 idle timeout: 0.000000s
2025-12-12T12:27:33.286983Z :YQL_PROXY TRACE: log.cpp:64: SessionId:  2025-12-12 12:27:33.286 TRACE ydbd(pid=1201569, tid=0x00007F114805C640) [DQ] task_controller_impl.h:160: [1:7582947099594315659:2248] EvState TaskId: 1 State: 2 PingCookie: 0 StatusCode: UNSPECIFIED
2025-12-12T12:27:33.286995Z :YQL_PROXY TRACE: log.cpp:64: SessionId:  2025-12-12 12:27:33.286 TRACE ydbd(pid=1201569, tid=0x00007F114805C640) [DQ] task_controller_impl.h:201:  [1:7582947099594315659:2248] Executing TaskId: 1
2025-12-12T12:27:33.327465Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:451: [ptqudq7uffpn58fsu002-0] Send TEvGetCheckpointsMetadataResponse
2025-12-12T12:27:33.327525Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:186: [ptqudq7uffpn58fsu002-0.2] Got TEvGetCheckpointsMetadataResponse
2025-12-12T12:27:33.327531Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:219: [ptqudq7uffpn58fsu002-0.2] Will restore from checkpoint 1:9
2025-12-12T12:27:33.327776Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:265: [ptqudq7uffpn58fsu002-0] Task: 1. [Checkpoint 1.9] TEvRestoreFromCheckpoint, StateLoadPlan = { StateType: STATE_TYPE_OWN }
2025-12-12T12:27:33.327808Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:508: [ptqudq7uffpn58fsu002-0] [1:9] Got TEvGetTaskState: tasks {1}
2025-12-12T12:27:33.327815Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:519: [ptqudq7uffpn58fsu002-0] [1:9] GetState, tasks: 1
2025-12-12T12:27:33.329766Z :YQL_PROXY TRACE: log.cpp:64: SessionId:  2025-12-12 12:27:33.329 TRACE ydbd(pid=1201569, tid=0x00007F114805C640) [DQ] task_controller_impl.h:160: [1:7582947099594315659:2248] EvState TaskId: 2 State: 2 PingCookie: 0 StatusCode: UNSPECIFIED
2025-12-12T12:27:33.329786Z :YQL_PROXY TRACE: log.cpp:64: SessionId:  2025-12-12 12:27:33.329 TRACE ydbd(pid=1201569, tid=0x00007F114805C640) [DQ] task_controller_impl.h:201:  [1:7582947099594315659:2248] Executing TaskId: 2
2025-12-12T12:27:33.329807Z :YQL_PROXY DEBUG: log.cpp:64: SessionId:  2025-12-12 12:27:33.329 DEBUG ydbd(pid=1201569, tid=0x00007F114805C640) [DQ] task_controller_impl.h:561: Update channels
2025-12-12T12:27:33.330536Z :YQL_PROXY TRACE: log.cpp:64: SessionId:  2025-12-12 12:27:33.329 TRACE ydbd(pid=1201569, tid=0x00007F114805C640) [DQ] task_controller_impl.h:577: 1 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.330589Z :YQL_PROXY TRACE: log.cpp:64: SessionId:  2025-12-12 12:27:33.330 TRACE ydbd(pid=1201569, tid=0x00007F114805C640) [DQ] task_controller_impl.h:577: 2 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.330624Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1064: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. 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.330633Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1083: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Update output channelId: 1, peer: [2:7582947096977367208:2158]
2025-12-12T12:27:33.407364Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:654: [ptqudq7uffpn58fsu002-0] [1:9] ListOfStates results:
2025-12-12T12:27:33.407389Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:675: [ptqudq7uffpn58fsu002-0] [1:9] taskId 1 checkpoint id: 1:9, rows count: 1
2025-12-12T12:27:33.407390Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:675: [ptqudq7uffpn58fsu002-0] [1:9] taskId 1 checkpoint id: 1:8, rows count: 1
2025-12-12T12:27:33.407391Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:675: [ptqudq7uffpn58fsu002-0] [1:9] taskId 1 checkpoint id: 1:7, rows count: 1
2025-12-12T12:27:33.407393Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:675: [ptqudq7uffpn58fsu002-0] [1:9] taskId 1 checkpoint id: 1:6, rows count: 1
2025-12-12T12:27:33.407394Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:675: [ptqudq7uffpn58fsu002-0] [1:9] taskId 1 checkpoint id: 1:5, rows count: 1
2025-12-12T12:27:33.407395Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:675: [ptqudq7uffpn58fsu002-0] [1:9] taskId 1 checkpoint id: 1:4, rows count: 1
2025-12-12T12:27:33.407396Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:675: [ptqudq7uffpn58fsu002-0] [1:9] taskId 1 checkpoint id: 1:3, rows count: 1
2025-12-12T12:27:33.407398Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:675: [ptqudq7uffpn58fsu002-0] [1:9] taskId 1 checkpoint id: 1:2, rows count: 1
2025-12-12T12:27:33.407399Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:675: [ptqudq7uffpn58fsu002-0] [1:9] taskId 1 checkpoint id: 1:1, rows count: 1
2025-12-12T12:27:33.407405Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:901: [ptqudq7uffpn58fsu002-0] [1:9] SkipStatesInFuture, skip 0 checkpoints
2025-12-12T12:27:33.407449Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:796: [ptqudq7uffpn58fsu002-0] [1:9] SelectState: task_id 1, seq_no 9, blob_seq_num 0
2025-12-12T12:27:33.461563Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:410: [ptqudq7uffpn58fsu002-0] [1:9] DeserializeState, task id 1, blob size 128
2025-12-12T12:27:33.461599Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:960: [ptqudq7uffpn58fsu002-0] [1:9] ApplyIncrements
2025-12-12T12:27:33.461710Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:527: [ptqudq7uffpn58fsu002-0] [{ Id: 9 Generation: 1 }] Send TEvGetTaskStateResult: tasks: {1}
2025-12-12T12:27:33.461765Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:336: [ptqudq7uffpn58fsu002-0] Task: 1. [Checkpoint 1.9] TEvGetTaskStateResult: restoring state
2025-12-12T12:27:33.461781Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:793: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Load state
2025-12-12T12:27:33.461906Z :KQP_COMPUTE DEBUG: dq_pq_read_actor_base.cpp:153: SelfId: [0:0:0], TxId: ptqudq7uffpn58fsu002, task: 1. PQ source. SessionId: empty Watermarks enabled: 0 granularity: 0.000000s late arrival delay: 0.000000s idle: 0 idle timeout: 0.000000s
2025-12-12T12:27:33.461932Z :KQP_COMPUTE DEBUG: dq_pq_read_actor_base.cpp:133: SelfId: [0:0:0], TxId: ptqudq7uffpn58fsu002, task: 1. PQ source. SessionId: empty StartingMessageTs 2025-12-12T12:27:05.094000Z Restoring offset: {0@,5},
2025-12-12T12:27:33.461964Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:362: [ptqudq7uffpn58fsu002-0] Task: 1. [Checkpoint 1.9] Checkpoint state restored
2025-12-12T12:27:33.461996Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:297: [ptqudq7uffpn58fsu002-0.2] [1:9] Got TEvRestoreFromCheckpointResult; taskId: 1, checkpoint: 1:9, status: OK, issues: 
2025-12-12T12:27:33.462018Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:320: [ptqudq7uffpn58fsu002-0.2] [1:9] Task state restored, need 1 more acks
2025-12-12T12:27:33.463103Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:297: [ptqudq7uffpn58fsu002-0.2] [1:9] Got TEvRestoreFromCheckpointResult; taskId: 2, checkpoint: 1:9, status: OK, issues: 
2025-12-12T12:27:33.463114Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:320: [ptqudq7uffpn58fsu002-0.2] [1:9] Task state restored, need 0 more acks
2025-12-12T12:27:33.463120Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:445: [ptqudq7uffpn58fsu002-0.2] Send TEvRun to all actors
2025-12-12T12:27:33.463149Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1164: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Got TEvRun from actor [1:7582947099594315658:2247]
2025-12-12T12:27:33.463161Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Poll inputs
2025-12-12T12:27:33.463163Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Poll sources
2025-12-12T12:27:33.463169Z :KQP_COMPUTE TRACE: dq_pq_rd_read_actor.cpp:767: SelfId: [0:0:0], TxId: ptqudq7uffpn58fsu002, task: 1. PQ source. GetAsyncInputData freeSpace = 1
2025-12-12T12:27:33.463190Z :KQP_COMPUTE DEBUG: dq_pq_rd_read_actor.cpp:1515: SelfId: [1:7582947099594315665:2250], TxId: ptqudq7uffpn58fsu002, task: 1, Cluster: . PQ source. Switch to single-cluster mode
2025-12-12T12:27:33.463195Z :KQP_COMPUTE INFO: dq_pq_rd_read_actor.cpp:608: SelfId: [1:7582947099594315665:2250], TxId: ptqudq7uffpn58fsu002, task: 1, Cluster: . PQ source. Send TEvCoordinatorChangesSubscribe to local RD ([0:5788050504107380562:5260383])
2025-12-12T12:27:33.463208Z :KQP_COMPUTE INFO: dq_pq_rd_read_actor.cpp:635: SelfId: [1:7582947099594315665:2250], TxId: ptqudq7uffpn58fsu002, task: 1, Cluster: . PQ source. Send TEvCoordinatorChangesSubscribe to local row dispatcher, self id [1:7582947099594315665:2250]
2025-12-12T12:27:33.463216Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:81: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Poll async input 0. Buffer free space: 1, read from async input: 0 bytes, 0 rows, finished: 0
2025-12-12T12:27:33.463237Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:637: RowDispatcher: TEvCoordinatorChangesSubscribe from [1:7582947099594315665:2250]
2025-12-12T12:27:33.463240Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-12-12T12:27:33.463247Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:637: RowDispatcher: TEvCoordinatorChangesSubscribe from [1:7582947099594315665:2250]
2025-12-12T12:27:33.463248Z :KQP_COMPUTE DEBUG: dq_pq_rd_read_actor.cpp:1009: SelfId: [1:7582947099594315665:2250], TxId: ptqudq7uffpn58fsu002, task: 1, Cluster: . PQ source. TEvCoordinatorChanged, new coordinator [2:7582946963833380804:2115]
2025-12-12T12:27:33.463253Z :KQP_COMPUTE INFO: dq_pq_rd_read_actor.cpp:655: SelfId: [1:7582947099594315665:2250], TxId: ptqudq7uffpn58fsu002, task: 1, Cluster: . PQ source. Send TEvCoordinatorRequest to coordinator [2:7582946963833380804:2115], partIds: 0 cookie 1
2025-12-12T12:27:33.463351Z :KQP_COMPUTE TRACE: dq_compute_memory_quota.h:97: TxId: ptqudq7uffpn58fsu002, task: 1. Peak memory usage: 2031616
2025-12-12T12:27:33.463358Z :KQP_COMPUTE DEBUG: dq_pq_rd_read_actor.cpp:1009: SelfId: [1:7582947099594315665:2250], TxId: ptqudq7uffpn58fsu002, task: 1, Cluster: . PQ source. TEvCoordinatorChanged, new coordinator [2:7582946963833380804:2115]
2025-12-12T12:27:33.463361Z :KQP_COMPUTE DEBUG: dq_pq_rd_read_actor.cpp:1078: SelfId: [1:7582947099594315665:2250], TxId: ptqudq7uffpn58fsu002, task: 1, Cluster: . PQ source. EvNodeConnected 2
2025-12-12T12:27:33.463364Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. update task runner stats
2025-12-12T12:27:33.463398Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-12T12:27:33.463401Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:27:33.463406Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:534: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. About to drain channelId: 1, hasPeer: 1, peerState:(freeSpace:1000000;inFlightBytes:0;inFlightCount:0;)
2025-12-12T12:27:33.463410Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1107: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Ask CPU quota: 54ms
2025-12-12T12:27:33.463572Z :KQP_COMPUTE INFO: dq_pq_rd_read_actor.cpp:1053: SelfId: [1:7582947099594315665:2250], TxId: ptqudq7uffpn58fsu002, task: 1, Cluster: . PQ source. Received TEvCoordinatorResult from [2:7582946963833380804:2115], cookie 1
2025-12-12T12:27:33.463584Z :KQP_COMPUTE INFO: dq_pq_rd_read_actor.cpp:1352: SelfId: [1:7582947099594315665:2250], TxId: ptqudq7uffpn58fsu002, task: 1, Cluster: . PQ source. UpdateSessions, Sessions size 0
2025-12-12T12:27:33.463594Z :KQP_COMPUTE INFO: dq_pq_rd_read_actor.cpp:1355: SelfId: [1:7582947099594315665:2250], TxId: ptqudq7uffpn58fsu002, task: 1, Cluster: . PQ source. Distribution is changed, remove sessions
2025-12-12T12:27:33.463602Z :KQP_COMPUTE INFO: dq_pq_rd_read_actor.cpp:1374: SelfId: [1:7582947099594315665:2250], TxId: ptqudq7uffpn58fsu002, task: 1, Cluster: . PQ source. Create session to [2:7582946963833380727:2063], generation 1
2025-12-12T12:27:33.463614Z :KQP_COMPUTE INFO: dq_pq_rd_read_actor.cpp:719: SelfId: [1:7582947099594315665:2250], TxId: ptqudq7uffpn58fsu002, task: 1, Cluster: . PQ source. Send TEvStartSession to [2:7582946963833380727:2063], connection id 1 partitions offsets (0 / 5),
2025-12-12T12:27:33.464113Z :KQP_COMPUTE TRACE: dq_pq_rd_read_actor.cpp:963: SelfId: [1:7582947099594315665:2250], TxId: ptqudq7uffpn58fsu002, task: 1, Cluster: . PQ source. Received TEvRetry, EventQueueId 1
2025-12-12T12:27:33.464176Z :KQP_COMPUTE DEBUG: dq_pq_rd_read_actor.cpp:1078: SelfId: [1:7582947099594315665:2250], TxId: ptqudq7uffpn58fsu002, task: 1, Cluster: . PQ source. EvNodeConnected 2
2025-12-12T12:27:33.464783Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1165: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. CPU quota delay: 1ms
2025-12-12T12:27:33.473101Z :KQP_COMPUTE INFO: dq_pq_rd_read_actor.cpp:864: SelfId: [1:7582947099594315665:2250], TxId: ptqudq7uffpn58fsu002, task: 1, Cluster: . PQ source. Received TEvStartSessionAck from [2:7582946963833380727:2063], seqNo 1, ConfirmedSeqNo 1, generation 1
2025-12-12T12:27:34.187059Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 6734039d-3c6d3147-8d4aa390-5370ecbe21, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:34.191142Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:34.191158Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:34.238340Z :YQL_PROXY TRACE: log.cpp:64: SessionId:  2025-12-12 12:27:34.238 TRACE ydbd(pid=1201569, tid=0x00007F114805C640) [DQ] task_controller_impl.h:271:  [1:7582947099594315659:2248] ExportStats Summary
2025-12-12T12:27:34.238558Z :FQ_PINGER TRACE: pinger.cpp:250: QueryId: ptqudq7uffpn58fsu002, Owner: 6734039d-3c6d3147-8d4aa390-5370ecbe19 Forward ping request: { statistics: "{\"Graph=0\":{\"TaskRunner\":{\"Stage=201976\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":1,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":1,\"count\":1,\"avg\":1,\"max\":1,\"min\":1}},\"Stage=201993\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":1,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":1,\"count\":1,\"avg\":1,\"max\":1,\"min\":1}},\"Stage=Total\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":2,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":2,\"count\":2,\"avg\":1,\"max\":1,\"min\":1}}}}}" }
2025-12-12T12:27:34.238567Z :FQ_PINGER TRACE: pinger.cpp:393: QueryId: ptqudq7uffpn58fsu002, Owner: 6734039d-3c6d3147-8d4aa390-5370ecbe19 Forward request Private::PingTask
2025-12-12T12:27:34.257103Z :FQ_PINGER TRACE: pinger.cpp:338: QueryId: ptqudq7uffpn58fsu002, Owner: 6734039d-3c6d3147-8d4aa390-5370ecbe19 Ping response success: { expired_at { seconds: 1765542474 nanos: 248000000 } }
2025-12-12T12:27:34.257141Z :FQ_RUN_ACTOR TRACE: run_actor.cpp:861: QueryId: ptqudq7uffpn58fsu002 Forward ping response. Success: 1. Cookie: 6
2025-12-12T12:27:34.463542Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:373: [ptqudq7uffpn58fsu002-0.2] Got TEvScheduleCheckpointing
2025-12-12T12:27:34.463559Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:349: [ptqudq7uffpn58fsu002-0.2] [2:1] Registering new checkpoint in storage
2025-12-12T12:27:34.463649Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:288: [ptqudq7uffpn58fsu002-0.2] [2:1] Got TEvCreateCheckpointRequest
2025-12-12T12:27:34.492785Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:334: [ptqudq7uffpn58fsu002-0.2] [2:1] Checkpoint created
2025-12-12T12:27:34.492797Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:336: [ptqudq7uffpn58fsu002-0.2] [2:1] Send TEvCreateCheckpointResponse
2025-12-12T12:27:34.492838Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:389: [ptqudq7uffpn58fsu002-0.2] [2:1] Got TEvCreateCheckpointResponse
2025-12-12T12:27:34.492845Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:435: [ptqudq7uffpn58fsu002-0.2] [2:1] Checkpoint successfully created, going to inject barriers to 1 actor(s)
2025-12-12T12:27:34.492873Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:239: [ptqudq7uffpn58fsu002-0] Task: 1. [Checkpoint 2.1] TEvInjectCheckpoint
2025-12-12T12:27:34.492886Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Poll inputs
2025-12-12T12:27:34.492888Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1494: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Skip polling sources because of pending checkpoint
2025-12-12T12:27:34.492891Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. DoExecuteImpl: 1
2025-12-12T12:27:34.492979Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:462: SelfId: [1:7582947099594315663:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Pending 1 checkpoints to be sent
2025-12-12T12:27:34.492989Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. update task runner stats
2025-12-12T12:27:34.493047Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 1 watermark injected: (empty maybe)
2025-12-12T12:27:34.493057Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:447: [ptqudq7uffpn58fsu002-0] Task: 1. [Checkpoint 2.1] Performing task checkpoint
2025-12-12T12:27:34.493060Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:816: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Save state
2025-12-12T12:27:34.493068Z :KQP_COMPUTE DEBUG: dq_pq_read_actor_base.cpp:94: SelfId: [1:7582947099594315665:2250], TxId: ptqudq7uffpn58fsu002, task: 1, Cluster: . PQ source. SessionId: empty SaveState, offsets: {0,5},
2025-12-12T12:27:34.493078Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:474: [ptqudq7uffpn58fsu002-0] Task: 1. [Checkpoint 2.1] CA state saved
2025-12-12T12:27:34.493080Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:449: [ptqudq7uffpn58fsu002-0] Task: 1. [Checkpoint 2.1] Injecting checkpoint barrier to outputs
2025-12-12T12:27:34.493100Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:536: [ptqudq7uffpn58fsu002-0] Task: 1. [Checkpoint 2.1] Task checkpoint is done. Send to storage
2025-12-12T12:27:34.493103Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:27:34.493109Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:534: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. About to drain channelId: 1, hasPeer: 1, peerState:(freeSpace:1000000;inFlightBytes:0;inFlightCount:0;)
2025-12-12T12:27:34.493117Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:460: [ptqudq7uffpn58fsu002-0] [2:1] Got TEvSaveTaskState: task 1
2025-12-12T12:27:34.493129Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:566: TxId: ptqudq7uffpn58fsu002, task: 1. SendChannelData, channelId: 1, peer: [2:7582947096977367208:2158], chunks: 0, bytes: 0, watermark: 0, checkpoint: 1, seqNo: 1, finished: 0
2025-12-12T12:27:34.493145Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Poll inputs
2025-12-12T12:27:34.493146Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Poll sources
2025-12-12T12:27:34.493150Z :KQP_COMPUTE TRACE: dq_pq_rd_read_actor.cpp:767: SelfId: [1:7582947099594315665:2250], TxId: ptqudq7uffpn58fsu002, task: 1, Cluster: . PQ source. GetAsyncInputData freeSpace = 1000000
2025-12-12T12:27:34.493166Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:81: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Poll async input 0. Buffer free space: 1000000, read from async input: 0 bytes, 0 rows, finished: 0
2025-12-12T12:27:34.493177Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-12-12T12:27:34.493200Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. update task runner stats
2025-12-12T12:27:34.493214Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-12T12:27:34.493215Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:27:34.493218Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:534: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. About to drain channelId: 1, hasPeer: 1, peerState:(freeSpace:1000000;inFlightBytes:96;inFlightCount:1;)
2025-12-12T12:27:34.493643Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:179: TxId: ptqudq7uffpn58fsu002, task: 1. Received channel data ack for channelId: 1, seqNo: 1, lastSentSeqNo: 1, freeSpace: 1000000, early finish: 0
2025-12-12T12:27:34.493655Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:207: TxId: ptqudq7uffpn58fsu002, task: 1. PeerState, peerState:(freeSpace:1000000;inFlightBytes:0;inFlightCount:0;), sentSeqNo: 1, ackSeqNo: 1
2025-12-12T12:27:34.493657Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:220: TxId: ptqudq7uffpn58fsu002, task: 1. Resume compute actor
2025-12-12T12:27:34.493663Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Poll inputs
2025-12-12T12:27:34.493665Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Poll sources
2025-12-12T12:27:34.493668Z :KQP_COMPUTE TRACE: dq_pq_rd_read_actor.cpp:767: SelfId: [1:7582947099594315665:2250], TxId: ptqudq7uffpn58fsu002, task: 1, Cluster: . PQ source. GetAsyncInputData freeSpace = 1000000
2025-12-12T12:27:34.493671Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:81: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Poll async input 0. Buffer free space: 1000000, read from async input: 0 bytes, 0 rows, finished: 0
2025-12-12T12:27:34.493689Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-12-12T12:27:34.493726Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. update task runner stats
2025-12-12T12:27:34.493746Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-12T12:27:34.493753Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:27:34.493756Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:534: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. About to drain channelId: 1, hasPeer: 1, peerState:(freeSpace:1000000;inFlightBytes:0;inFlightCount:0;)
2025-12-12T12:27:34.496180Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:484: [ptqudq7uffpn58fsu002-0] [2:1] TEvSaveTaskState Apply: task: 1
2025-12-12T12:27:34.496208Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:499: [ptqudq7uffpn58fsu002-0] [2:1] Send TEvSaveTaskStateResult: task: 1
2025-12-12T12:27:34.496251Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:466: [ptqudq7uffpn58fsu002-0.2] [2:1] Got TEvSaveTaskStateResult; task 1, status: OK, size: 128
2025-12-12T12:27:34.496257Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:476: [ptqudq7uffpn58fsu002-0.2] [2:1] Task state saved, need 1 more acks
2025-12-12T12:27:34.496630Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:466: [ptqudq7uffpn58fsu002-0.2] [2:1] Got TEvSaveTaskStateResult; task 2, status: OK, size: 139
2025-12-12T12:27:34.496653Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:476: [ptqudq7uffpn58fsu002-0.2] [2:1] Task state saved, need 0 more acks
2025-12-12T12:27:34.496655Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:489: [ptqudq7uffpn58fsu002-0.2] [2:1] Got all acks, changing checkpoint status to 'PendingCommit'
2025-12-12T12:27:34.496671Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:343: [ptqudq7uffpn58fsu002-0.2] [2:1] Got TEvSetCheckpointPendingCommitStatusRequest
2025-12-12T12:27:34.519698Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:362: [ptqudq7uffpn58fsu002-0.2] [2:1] Status updated to 'PendingCommit'
2025-12-12T12:27:34.519714Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:364: [ptqudq7uffpn58fsu002-0.2] [2:1] Send TEvSetCheckpointPendingCommitStatusResponse
2025-12-12T12:27:34.519752Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:501: [ptqudq7uffpn58fsu002-0.2] [2:1] Got TEvSetCheckpointPendingCommitStatusResponse
2025-12-12T12:27:34.519758Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:516: [ptqudq7uffpn58fsu002-0.2] [2:1] Checkpoint status changed to 'PendingCommit', committing states to 2 actor(s)
2025-12-12T12:27:34.519812Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:759: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Commit state
2025-12-12T12:27:34.519830Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:532: [ptqudq7uffpn58fsu002-0.2] [2:1] Got TEvStateCommitted; task: 1
2025-12-12T12:27:34.519835Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:541: [ptqudq7uffpn58fsu002-0.2] [2:1] State committed [1:7582947099594315661:2250], need 1 more acks
2025-12-12T12:27:34.520233Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:532: [ptqudq7uffpn58fsu002-0.2] [2:1] Got TEvStateCommitted; task: 2
2025-12-12T12:27:34.520247Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:541: [ptqudq7uffpn58fsu002-0.2] [2:1] State committed [2:7582947096977367208:2158], need 0 more acks
2025-12-12T12:27:34.520249Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:543: [ptqudq7uffpn58fsu002-0.2] [2:1] Got all acks, changing checkpoint status to 'Completed'
2025-12-12T12:27:34.520267Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:371: [ptqudq7uffpn58fsu002-0.2] [2:1] Got TEvCompleteCheckpointRequest
2025-12-12T12:27:34.544700Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:393: [ptqudq7uffpn58fsu002-0.2] [2:1] Status updated to 'Completed'
2025-12-12T12:27:34.544716Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:400: [ptqudq7uffpn58fsu002-0.2] [2:1] Send TEvCompleteCheckpointResponse
2025-12-12T12:27:34.544760Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:564: [ptqudq7uffpn58fsu002-0.2] [2:1] Got TEvCompleteCheckpointResponse
2025-12-12T12:27:34.544767Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:579: [ptqudq7uffpn58fsu002-0.2] [2:1] Checkpoint completed
2025-12-12T12:27:34.743567Z :KQP_COMPUTE TRACE: dq_pq_rd_read_actor.cpp:890: SelfId: [1:7582947099594315665:2250], TxId: ptqudq7uffpn58fsu002, task: 1, Cluster: . PQ source. Received TEvStatistics from [2:7582946963833380727:2063], seqNo 2, ConfirmedSeqNo 1 generation 1
2025-12-12T12:27:35.178298Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-12-12T12:27:35.185417Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [2:7582946963833380804:2115]
2025-12-12T12:27:35.185443Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:35.185823Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:35.185918Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:389: Send NodeInfo with size: 2 to DynamicNameserver
2025-12-12T12:27:35.187493Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 6734039d-3c6d3147-8d4aa390-5370ecbe22, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:35.191330Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:35.191345Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:35.238787Z :YQL_PROXY TRACE: log.cpp:64: SessionId:  2025-12-12 12:27:35.238 TRACE ydbd(pid=1201569, tid=0x00007F114805C640) [DQ] task_controller_impl.h:271:  [1:7582947099594315659:2248] ExportStats Summary
2025-12-12T12:27:35.239050Z :FQ_PINGER TRACE: pinger.cpp:250: QueryId: ptqudq7uffpn58fsu002, Owner: 6734039d-3c6d3147-8d4aa390-5370ecbe19 Forward ping request: { statistics: "{\"Graph=0\":{\"TaskRunner\":{\"Stage=201976\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":1,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":1,\"count\":1,\"avg\":1,\"max\":1,\"min\":1}},\"Stage=201993\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":1,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":1,\"count\":1,\"avg\":1,\"max\":1,\"min\":1}},\"Stage=Total\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":2,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":2,\"count\":2,\"avg\":1,\"max\":1,\"min\":1}}}}}" }
2025-12-12T12:27:35.239062Z :FQ_PINGER TRACE: pinger.cpp:393: QueryId: ptqudq7uffpn58fsu002, Owner: 6734039d-3c6d3147-8d4aa390-5370ecbe19 Forward request Private::PingTask
2025-12-12T12:27:35.251324Z :FQ_PINGER TRACE: pinger.cpp:338: QueryId: ptqudq7uffpn58fsu002, Owner: 6734039d-3c6d3147-8d4aa390-5370ecbe19 Ping response success: { expired_at { seconds: 1765542475 nanos: 245000000 } }
2025-12-12T12:27:35.251365Z :FQ_RUN_ACTOR TRACE: run_actor.cpp:861: QueryId: ptqudq7uffpn58fsu002 Forward ping response. Success: 1. Cookie: 6
2025-12-12T12:27:35.463994Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:373: [ptqudq7uffpn58fsu002-0.2] Got TEvScheduleCheckpointing
2025-12-12T12:27:35.464017Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:349: [ptqudq7uffpn58fsu002-0.2] [2:2] Registering new checkpoint in storage
2025-12-12T12:27:35.464049Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:288: [ptqudq7uffpn58fsu002-0.2] [2:2] Got TEvCreateCheckpointRequest
2025-12-12T12:27:35.464998Z :KQP_COMPUTE TRACE: dq_pq_rd_read_actor.cpp:981: SelfId: [1:7582947099594315665:2250], TxId: ptqudq7uffpn58fsu002, task: 1, Cluster: . PQ source. TEvRetryQueuePrivate::TEvEvHeartbeat
2025-12-12T12:27:35.465017Z :KQP_COMPUTE TRACE: dq_pq_rd_read_actor.cpp:997: SelfId: [1:7582947099594315665:2250], TxId: ptqudq7uffpn58fsu002, task: 1, Cluster: . PQ source. Send TEvEvHeartbeat
2025-12-12T12:27:35.492847Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:334: [ptqudq7uffpn58fsu002-0.2] [2:2] Checkpoint created
2025-12-12T12:27:35.492857Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:336: [ptqudq7uffpn58fsu002-0.2] [2:2] Send TEvCreateCheckpointResponse
2025-12-12T12:27:35.492900Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:389: [ptqudq7uffpn58fsu002-0.2] [2:2] Got TEvCreateCheckpointResponse
2025-12-12T12:27:35.492906Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:435: [ptqudq7uffpn58fsu002-0.2] [2:2] Checkpoint successfully created, going to inject barriers to 1 actor(s)
2025-12-12T12:27:35.492931Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:239: [ptqudq7uffpn58fsu002-0] Task: 1. [Checkpoint 2.2] TEvInjectCheckpoint
2025-12-12T12:27:35.492950Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Poll inputs
2025-12-12T12:27:35.492956Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1494: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Skip polling sources because of pending checkpoint
2025-12-12T12:27:35.492961Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. DoExecuteImpl: 1
2025-12-12T12:27:35.493038Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:462: SelfId: [1:7582947099594315663:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Pending 1 checkpoints to be sent
2025-12-12T12:27:35.493051Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. update task runner stats
2025-12-12T12:27:35.493087Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 1 watermark injected: (empty maybe)
2025-12-12T12:27:35.493094Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:447: [ptqudq7uffpn58fsu002-0] Task: 1. [Checkpoint 2.2] Performing task checkpoint
2025-12-12T12:27:35.493096Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:816: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Save state
2025-12-12T12:27:35.493105Z :KQP_COMPUTE DEBUG: dq_pq_read_actor_base.cpp:94: SelfId: [1:7582947099594315665:2250], TxId: ptqudq7uffpn58fsu002, task: 1, Cluster: . PQ source. SessionId: empty SaveState, offsets: {0,5},
2025-12-12T12:27:35.493113Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:474: [ptqudq7uffpn58fsu002-0] Task: 1. [Checkpoint 2.2] CA state saved
2025-12-12T12:27:35.493116Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:449: [ptqudq7uffpn58fsu002-0] Task: 1. [Checkpoint 2.2] Injecting checkpoint barrier to outputs
2025-12-12T12:27:35.493126Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:536: [ptqudq7uffpn58fsu002-0] Task: 1. [Checkpoint 2.2] Task checkpoint is done. Send to storage
2025-12-12T12:27:35.493128Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:27:35.493134Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:534: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. About to drain channelId: 1, hasPeer: 1, peerState:(freeSpace:1000000;inFlightBytes:0;inFlightCount:0;)
2025-12-12T12:27:35.493142Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:460: [ptqudq7uffpn58fsu002-0] [2:2] Got TEvSaveTaskState: task 1
2025-12-12T12:27:35.493151Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:566: TxId: ptqudq7uffpn58fsu002, task: 1. SendChannelData, channelId: 1, peer: [2:7582947096977367208:2158], chunks: 0, bytes: 0, watermark: 0, checkpoint: 1, seqNo: 2, finished: 0
2025-12-12T12:27:35.493168Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Poll inputs
2025-12-12T12:27:35.493169Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Poll sources
2025-12-12T12:27:35.493172Z :KQP_COMPUTE TRACE: dq_pq_rd_read_actor.cpp:767: SelfId: [1:7582947099594315665:2250], TxId: ptqudq7uffpn58fsu002, task: 1, Cluster: . PQ source. GetAsyncInputData freeSpace = 1000000
2025-12-12T12:27:35.493181Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:81: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Poll async input 0. Buffer free space: 1000000, read from async input: 0 bytes, 0 rows, finished: 0
2025-12-12T12:27:35.493191Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-12-12T12:27:35.493225Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. update task runner stats
2025-12-12T12:27:35.493236Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-12T12:27:35.493238Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:27:35.493241Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:534: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. About to drain channelId: 1, hasPeer: 1, peerState:(freeSpace:1000000;inFlightBytes:96;inFlightCount:1;)
2025-12-12T12:27:35.493725Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:179: TxId: ptqudq7uffpn58fsu002, task: 1. Received channel data ack for channelId: 1, seqNo: 2, lastSentSeqNo: 2, freeSpace: 1000000, early finish: 0
2025-12-12T12:27:35.493738Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:207: TxId: ptqudq7uffpn58fsu002, task: 1. PeerState, peerState:(freeSpace:1000000;inFlightBytes:0;inFlightCount:0;), sentSeqNo: 2, ackSeqNo: 2
2025-12-12T12:27:35.493739Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:220: TxId: ptqudq7uffpn58fsu002, task: 1. Resume compute actor
2025-12-12T12:27:35.493745Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Poll inputs
2025-12-12T12:27:35.493746Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Poll sources
2025-12-12T12:27:35.493749Z :KQP_COMPUTE TRACE: dq_pq_rd_read_actor.cpp:767: SelfId: [1:7582947099594315665:2250], TxId: ptqudq7uffpn58fsu002, task: 1, Cluster: . PQ source. GetAsyncInputData freeSpace = 1000000
2025-12-12T12:27:35.493754Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:81: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Poll async input 0. Buffer free space: 1000000, read from async input: 0 bytes, 0 rows, finished: 0
2025-12-12T12:27:35.493763Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-12-12T12:27:35.493810Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. update task runner stats
2025-12-12T12:27:35.493826Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-12T12:27:35.493828Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:27:35.493831Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:534: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. About to drain channelId: 1, hasPeer: 1, peerState:(freeSpace:1000000;inFlightBytes:0;inFlightCount:0;)
2025-12-12T12:27:35.496627Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:484: [ptqudq7uffpn58fsu002-0] [2:2] TEvSaveTaskState Apply: task: 1
2025-12-12T12:27:35.496638Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:499: [ptqudq7uffpn58fsu002-0] [2:2] Send TEvSaveTaskStateResult: task: 1
2025-12-12T12:27:35.496683Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:466: [ptqudq7uffpn58fsu002-0.2] [2:2] Got TEvSaveTaskStateResult; task 1, status: OK, size: 128
2025-12-12T12:27:35.496688Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:476: [ptqudq7uffpn58fsu002-0.2] [2:2] Task state saved, need 1 more acks
2025-12-12T12:27:35.496938Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:466: [ptqudq7uffpn58fsu002-0.2] [2:2] Got TEvSaveTaskStateResult; task 2, status: OK, size: 139
2025-12-12T12:27:35.496948Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:476: [ptqudq7uffpn58fsu002-0.2] [2:2] Task state saved, need 0 more acks
2025-12-12T12:27:35.496950Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:489: [ptqudq7uffpn58fsu002-0.2] [2:2] Got all acks, changing checkpoint status to 'PendingCommit'
2025-12-12T12:27:35.496965Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:343: [ptqudq7uffpn58fsu002-0.2] [2:2] Got TEvSetCheckpointPendingCommitStatusRequest
2025-12-12T12:27:35.519316Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:362: [ptqudq7uffpn58fsu002-0.2] [2:2] Status updated to 'PendingCommit'
2025-12-12T12:27:35.519330Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:364: [ptqudq7uffpn58fsu002-0.2] [2:2] Send TEvSetCheckpointPendingCommitStatusResponse
2025-12-12T12:27:35.519365Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:501: [ptqudq7uffpn58fsu002-0.2] [2:2] Got TEvSetCheckpointPendingCommitStatusResponse
2025-12-12T12:27:35.519372Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:516: [ptqudq7uffpn58fsu002-0.2] [2:2] Checkpoint status changed to 'PendingCommit', committing states to 2 actor(s)
2025-12-12T12:27:35.519419Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:759: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Commit state
2025-12-12T12:27:35.519435Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:532: [ptqudq7uffpn58fsu002-0.2] [2:2] Got TEvStateCommitted; task: 1
2025-12-12T12:27:35.519440Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:541: [ptqudq7uffpn58fsu002-0.2] [2:2] State committed [1:7582947099594315661:2250], need 1 more acks
2025-12-12T12:27:35.519744Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:532: [ptqudq7uffpn58fsu002-0.2] [2:2] Got TEvStateCommitted; task: 2
2025-12-12T12:27:35.519755Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:541: [ptqudq7uffpn58fsu002-0.2] [2:2] State committed [2:7582947096977367208:2158], need 0 more acks
2025-12-12T12:27:35.519758Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:543: [ptqudq7uffpn58fsu002-0.2] [2:2] Got all acks, changing checkpoint status to 'Completed'
2025-12-12T12:27:35.519775Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:371: [ptqudq7uffpn58fsu002-0.2] [2:2] Got TEvCompleteCheckpointRequest
2025-12-12T12:27:35.544089Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:393: [ptqudq7uffpn58fsu002-0.2] [2:2] Status updated to 'Completed'
2025-12-12T12:27:35.544104Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:400: [ptqudq7uffpn58fsu002-0.2] [2:2] Send TEvCompleteCheckpointResponse
2025-12-12T12:27:35.544154Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:564: [ptqudq7uffpn58fsu002-0.2] [2:2] Got TEvCompleteCheckpointResponse
2025-12-12T12:27:35.544163Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:579: [ptqudq7uffpn58fsu002-0.2] [2:2] Checkpoint completed
2025-12-12T12:27:36.187979Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 6734039d-3c6d3147-8d4aa390-5370ecbe23, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:36.192017Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:36.192031Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:36.239221Z :YQL_PROXY TRACE: log.cpp:64: SessionId:  2025-12-12 12:27:36.239 TRACE ydbd(pid=1201569, tid=0x00007F114805C640) [DQ] task_controller_impl.h:271:  [1:7582947099594315659:2248] ExportStats Summary
2025-12-12T12:27:36.239461Z :FQ_PINGER TRACE: pinger.cpp:250: QueryId: ptqudq7uffpn58fsu002, Owner: 6734039d-3c6d3147-8d4aa390-5370ecbe19 Forward ping request: { statistics: "{\"Graph=0\":{\"TaskRunner\":{\"Stage=201976\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":1,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":1,\"count\":1,\"avg\":1,\"max\":1,\"min\":1}},\"Stage=201993\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":1,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":1,\"count\":1,\"avg\":1,\"max\":1,\"min\":1}},\"Stage=Total\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":2,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":2,\"count\":2,\"avg\":1,\"max\":1,\"min\":1}}}}}" }
2025-12-12T12:27:36.239470Z :FQ_PINGER TRACE: pinger.cpp:393: QueryId: ptqudq7uffpn58fsu002, Owner: 6734039d-3c6d3147-8d4aa390-5370ecbe19 Forward request Private::PingTask
2025-12-12T12:27:36.250384Z :FQ_PINGER TRACE: pinger.cpp:338: QueryId: ptqudq7uffpn58fsu002, Owner: 6734039d-3c6d3147-8d4aa390-5370ecbe19 Ping response success: { expired_at { seconds: 1765542476 nanos: 244000000 } }
2025-12-12T12:27:36.250420Z :FQ_RUN_ACTOR TRACE: run_actor.cpp:861: QueryId: ptqudq7uffpn58fsu002 Forward ping response. Success: 1. Cookie: 6
2025-12-12T12:27:36.464450Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:373: [ptqudq7uffpn58fsu002-0.2] Got TEvScheduleCheckpointing
2025-12-12T12:27:36.464472Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:349: [ptqudq7uffpn58fsu002-0.2] [2:3] Registering new checkpoint in storage
2025-12-12T12:27:36.464502Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:288: [ptqudq7uffpn58fsu002-0.2] [2:3] Got TEvCreateCheckpointRequest
2025-12-12T12:27:36.494349Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:334: [ptqudq7uffpn58fsu002-0.2] [2:3] Checkpoint created
2025-12-12T12:27:36.494362Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:336: [ptqudq7uffpn58fsu002-0.2] [2:3] Send TEvCreateCheckpointResponse
2025-12-12T12:27:36.494519Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:389: [ptqudq7uffpn58fsu002-0.2] [2:3] Got TEvCreateCheckpointResponse
2025-12-12T12:27:36.494532Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:435: [ptqudq7uffpn58fsu002-0.2] [2:3] Checkpoint successfully created, going to inject barriers to 1 actor(s)
2025-12-12T12:27:36.494566Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:239: [ptqudq7uffpn58fsu002-0] Task: 1. [Checkpoint 2.3] TEvInjectCheckpoint
2025-12-12T12:27:36.494586Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Poll inputs
2025-12-12T12:27:36.494593Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1494: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Skip polling sources because of pending checkpoint
2025-12-12T12:27:36.494595Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. DoExecuteImpl: 1
2025-12-12T12:27:36.494687Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:462: SelfId: [1:7582947099594315663:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Pending 1 checkpoints to be sent
2025-12-12T12:27:36.494698Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. update task runner stats
2025-12-12T12:27:36.494734Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 1 watermark injected: (empty maybe)
2025-12-12T12:27:36.494737Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:447: [ptqudq7uffpn58fsu002-0] Task: 1. [Checkpoint 2.3] Performing task checkpoint
2025-12-12T12:27:36.494739Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:816: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Save state
2025-12-12T12:27:36.494748Z :KQP_COMPUTE DEBUG: dq_pq_read_actor_base.cpp:94: SelfId: [1:7582947099594315665:2250], TxId: ptqudq7uffpn58fsu002, task: 1, Cluster: . PQ source. SessionId: empty SaveState, offsets: {0,5},
2025-12-12T12:27:36.494756Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:474: [ptqudq7uffpn58fsu002-0] Task: 1. [Checkpoint 2.3] CA state saved
2025-12-12T12:27:36.494758Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:449: [ptqudq7uffpn58fsu002-0] Task: 1. [Checkpoint 2.3] Injecting checkpoint barrier to outputs
2025-12-12T12:27:36.494778Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:536: [ptqudq7uffpn58fsu002-0] Task: 1. [Checkpoint 2.3] Task checkpoint is done. Send to storage
2025-12-12T12:27:36.494780Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:27:36.494787Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:534: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. About to drain channelId: 1, hasPeer: 1, peerState:(freeSpace:1000000;inFlightBytes:0;inFlightCount:0;)
2025-12-12T12:27:36.494802Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:566: TxId: ptqudq7uffpn58fsu002, task: 1. SendChannelData, channelId: 1, peer: [2:7582947096977367208:2158], chunks: 0, bytes: 0, watermark: 0, checkpoint: 1, seqNo: 3, finished: 0
2025-12-12T12:27:36.494807Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:460: [ptqudq7uffpn58fsu002-0] [2:3] Got TEvSaveTaskState: task 1
2025-12-12T12:27:36.494817Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Poll inputs
2025-12-12T12:27:36.494819Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Poll sources
2025-12-12T12:27:36.494823Z :KQP_COMPUTE TRACE: dq_pq_rd_read_actor.cpp:767: SelfId: [1:7582947099594315665:2250], TxId: ptqudq7uffpn58fsu002, task: 1, Cluster: . PQ source. GetAsyncInputData freeSpace = 1000000
2025-12-12T12:27:36.494828Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:81: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Poll async input 0. Buffer free space: 1000000, read from async input: 0 bytes, 0 rows, finished: 0
2025-12-12T12:27:36.494847Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-12-12T12:27:36.494862Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. update task runner stats
2025-12-12T12:27:36.494869Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-12T12:27:36.494870Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:27:36.494873Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:534: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. About to drain channelId: 1, hasPeer: 1, peerState:(freeSpace:1000000;inFlightBytes:96;inFlightCount:1;)
2025-12-12T12:27:36.495820Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:179: TxId: ptqudq7uffpn58fsu002, task: 1. Received channel data ack for channelId: 1, seqNo: 3, lastSentSeqNo: 3, freeSpace: 1000000, early finish: 0
2025-12-12T12:27:36.495829Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:207: TxId: ptqudq7uffpn58fsu002, task: 1. PeerState, peerState:(freeSpace:1000000;inFlightBytes:0;inFlightCount:0;), sentSeqNo: 3, ackSeqNo: 3
2025-12-12T12:27:36.495830Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:220: TxId: ptqudq7uffpn58fsu002, task: 1. Resume compute actor
2025-12-12T12:27:36.495839Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Poll inputs
2025-12-12T12:27:36.495842Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Poll sources
2025-12-12T12:27:36.495846Z :KQP_COMPUTE TRACE: dq_pq_rd_read_actor.cpp:767: SelfId: [1:7582947099594315665:2250], TxId: ptqudq7uffpn58fsu002, task: 1, Cluster: . PQ source. GetAsyncInputData freeSpace = 1000000
2025-12-12T12:27:36.495851Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:81: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Poll async input 0. Buffer free space: 1000000, read from async input: 0 bytes, 0 rows, finished: 0
2025-12-12T12:27:36.495863Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-12-12T12:27:36.495911Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. update task runner stats
2025-12-12T12:27:36.495932Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-12T12:27:36.495935Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:27:36.495939Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:534: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. About to drain channelId: 1, hasPeer: 1, peerState:(freeSpace:1000000;inFlightBytes:0;inFlightCount:0;)
2025-12-12T12:27:36.498145Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:484: [ptqudq7uffpn58fsu002-0] [2:3] TEvSaveTaskState Apply: task: 1
2025-12-12T12:27:36.498159Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:499: [ptqudq7uffpn58fsu002-0] [2:3] Send TEvSaveTaskStateResult: task: 1
2025-12-12T12:27:36.498227Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:466: [ptqudq7uffpn58fsu002-0.2] [2:3] Got TEvSaveTaskStateResult; task 1, status: OK, size: 128
2025-12-12T12:27:36.498235Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:476: [ptqudq7uffpn58fsu002-0.2] [2:3] Task state saved, need 1 more acks
2025-12-12T12:27:36.498487Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:466: [ptqudq7uffpn58fsu002-0.2] [2:3] Got TEvSaveTaskStateResult; task 2, status: OK, size: 139
2025-12-12T12:27:36.498493Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:476: [ptqudq7uffpn58fsu002-0.2] [2:3] Task state saved, need 0 more acks
2025-12-12T12:27:36.498495Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:489: [ptqudq7uffpn58fsu002-0.2] [2:3] Got all acks, changing checkpoint status to 'PendingCommit'
2025-12-12T12:27:36.498523Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:343: [ptqudq7uffpn58fsu002-0.2] [2:3] Got TEvSetCheckpointPendingCommitStatusRequest
2025-12-12T12:27:36.522028Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:362: [ptqudq7uffpn58fsu002-0.2] [2:3] Status updated to 'PendingCommit'
2025-12-12T12:27:36.522045Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:364: [ptqudq7uffpn58fsu002-0.2] [2:3] Send TEvSetCheckpointPendingCommitStatusResponse
2025-12-12T12:27:36.522078Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:501: [ptqudq7uffpn58fsu002-0.2] [2:3] Got TEvSetCheckpointPendingCommitStatusResponse
2025-12-12T12:27:36.522084Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:516: [ptqudq7uffpn58fsu002-0.2] [2:3] Checkpoint status changed to 'PendingCommit', committing states to 2 actor(s)
2025-12-12T12:27:36.522126Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:759: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Commit state
2025-12-12T12:27:36.522144Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:532: [ptqudq7uffpn58fsu002-0.2] [2:3] Got TEvStateCommitted; task: 1
2025-12-12T12:27:36.522163Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:541: [ptqudq7uffpn58fsu002-0.2] [2:3] State committed [1:7582947099594315661:2250], need 1 more acks
2025-12-12T12:27:36.522474Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:532: [ptqudq7uffpn58fsu002-0.2] [2:3] Got TEvStateCommitted; task: 2
2025-12-12T12:27:36.522486Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:541: [ptqudq7uffpn58fsu002-0.2] [2:3] State committed [2:7582947096977367208:2158], need 0 more acks
2025-12-12T12:27:36.522489Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:543: [ptqudq7uffpn58fsu002-0.2] [2:3] Got all acks, changing checkpoint status to 'Completed'
2025-12-12T12:27:36.522507Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:371: [ptqudq7uffpn58fsu002-0.2] [2:3] Got TEvCompleteCheckpointRequest
2025-12-12T12:27:36.546691Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:393: [ptqudq7uffpn58fsu002-0.2] [2:3] Status updated to 'Completed'
2025-12-12T12:27:36.546706Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:400: [ptqudq7uffpn58fsu002-0.2] [2:3] Send TEvCompleteCheckpointResponse
2025-12-12T12:27:36.546756Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:564: [ptqudq7uffpn58fsu002-0.2] [2:3] Got TEvCompleteCheckpointResponse
2025-12-12T12:27:36.546765Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:579: [ptqudq7uffpn58fsu002-0.2] [2:3] Checkpoint completed
2025-12-12T12:27:36.744460Z :KQP_COMPUTE TRACE: dq_pq_rd_read_actor.cpp:890: SelfId: [1:7582947099594315665:2250], TxId: ptqudq7uffpn58fsu002, task: 1, Cluster: . PQ source. Received TEvStatistics from [2:7582946963833380727:2063], seqNo 3, ConfirmedSeqNo 2 generation 1
2025-12-12T12:27:37.186373Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [2:7582946963833380804:2115]
2025-12-12T12:27:37.186400Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:37.188442Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 6734039d-3c6d3147-8d4aa390-5370ecbe24, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:37.191161Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:37.192730Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:37.192743Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:37.239675Z :YQL_PROXY TRACE: log.cpp:64: SessionId:  2025-12-12 12:27:37.239 TRACE ydbd(pid=1201569, tid=0x00007F114805C640) [DQ] task_controller_impl.h:271:  [1:7582947099594315659:2248] ExportStats Summary
2025-12-12T12:27:37.239917Z :FQ_PINGER TRACE: pinger.cpp:250: QueryId: ptqudq7uffpn58fsu002, Owner: 6734039d-3c6d3147-8d4aa390-5370ecbe19 Forward ping request: { statistics: "{\"Graph=0\":{\"TaskRunner\":{\"Stage=201976\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":1,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":1,\"count\":1,\"avg\":1,\"max\":1,\"min\":1}},\"Stage=201993\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":1,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":1,\"count\":1,\"avg\":1,\"max\":1,\"min\":1}},\"Stage=Total\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":2,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":2,\"count\":2,\"avg\":1,\"max\":1,\"min\":1}}}}}" }
2025-12-12T12:27:37.239927Z :FQ_PINGER TRACE: pinger.cpp:393: QueryId: ptqudq7uffpn58fsu002, Owner: 6734039d-3c6d3147-8d4aa390-5370ecbe19 Forward request Private::PingTask
2025-12-12T12:27:37.251052Z :FQ_PINGER TRACE: pinger.cpp:338: QueryId: ptqudq7uffpn58fsu002, Owner: 6734039d-3c6d3147-8d4aa390-5370ecbe19 Ping response success: { expired_at { seconds: 1765542477 nanos: 246000000 } }
2025-12-12T12:27:37.251087Z :FQ_RUN_ACTOR TRACE: run_actor.cpp:861: QueryId: ptqudq7uffpn58fsu002 Forward ping response. Success: 1. Cookie: 6
2025-12-12T12:27:37.464875Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:373: [ptqudq7uffpn58fsu002-0.2] Got TEvScheduleCheckpointing
2025-12-12T12:27:37.464889Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:349: [ptqudq7uffpn58fsu002-0.2] [2:4] Registering new checkpoint in storage
2025-12-12T12:27:37.464921Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:288: [ptqudq7uffpn58fsu002-0.2] [2:4] Got TEvCreateCheckpointRequest
2025-12-12T12:27:37.465887Z :KQP_COMPUTE TRACE: dq_pq_rd_read_actor.cpp:981: SelfId: [1:7582947099594315665:2250], TxId: ptqudq7uffpn58fsu002, task: 1, Cluster: . PQ source. TEvRetryQueuePrivate::TEvEvHeartbeat
2025-12-12T12:27:37.465904Z :KQP_COMPUTE TRACE: dq_pq_rd_read_actor.cpp:997: SelfId: [1:7582947099594315665:2250], TxId: ptqudq7uffpn58fsu002, task: 1, Cluster: . PQ source. Send TEvEvHeartbeat
2025-12-12T12:27:37.492865Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:334: [ptqudq7uffpn58fsu002-0.2] [2:4] Checkpoint created
2025-12-12T12:27:37.492880Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:336: [ptqudq7uffpn58fsu002-0.2] [2:4] Send TEvCreateCheckpointResponse
2025-12-12T12:27:37.492923Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:389: [ptqudq7uffpn58fsu002-0.2] [2:4] Got TEvCreateCheckpointResponse
2025-12-12T12:27:37.492930Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:435: [ptqudq7uffpn58fsu002-0.2] [2:4] Checkpoint successfully created, going to inject barriers to 1 actor(s)
2025-12-12T12:27:37.492959Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:239: [ptqudq7uffpn58fsu002-0] Task: 1. [Checkpoint 2.4] TEvInjectCheckpoint
2025-12-12T12:27:37.492977Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Poll inputs
2025-12-12T12:27:37.492983Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1494: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Skip polling sources because of pending checkpoint
2025-12-12T12:27:37.492986Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. DoExecuteImpl: 1
2025-12-12T12:27:37.493055Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:462: SelfId: [1:7582947099594315663:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Pending 1 checkpoints to be sent
2025-12-12T12:27:37.493069Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. update task runner stats
2025-12-12T12:27:37.493103Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 1 watermark injected: (empty maybe)
2025-12-12T12:27:37.493106Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:447: [ptqudq7uffpn58fsu002-0] Task: 1. [Checkpoint 2.4] Performing task checkpoint
2025-12-12T12:27:37.493108Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:816: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Save state
2025-12-12T12:27:37.493116Z :KQP_COMPUTE DEBUG: dq_pq_read_actor_base.cpp:94: SelfId: [1:7582947099594315665:2250], TxId: ptqudq7uffpn58fsu002, task: 1, Cluster: . PQ source. SessionId: empty SaveState, offsets: {0,5},
2025-12-12T12:27:37.493124Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:474: [ptqudq7uffpn58fsu002-0] Task: 1. [Checkpoint 2.4] CA state saved
2025-12-12T12:27:37.493127Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:449: [ptqudq7uffpn58fsu002-0] Task: 1. [Checkpoint 2.4] Injecting checkpoint barrier to outputs
2025-12-12T12:27:37.493138Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:536: [ptqudq7uffpn58fsu002-0] Task: 1. [Checkpoint 2.4] Task checkpoint is done. Send to storage
2025-12-12T12:27:37.493140Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:27:37.493146Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:534: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. About to drain channelId: 1, hasPeer: 1, peerState:(freeSpace:1000000;inFlightBytes:0;inFlightCount:0;)
2025-12-12T12:27:37.493152Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:460: [ptqudq7uffpn58fsu002-0] [2:4] Got TEvSaveTaskState: task 1
2025-12-12T12:27:37.493161Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:566: TxId: ptqudq7uffpn58fsu002, task: 1. SendChannelData, channelId: 1, peer: [2:7582947096977367208:2158], chunks: 0, bytes: 0, watermark: 0, checkpoint: 1, seqNo: 4, finished: 0
2025-12-12T12:27:37.493178Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Poll inputs
2025-12-12T12:27:37.493182Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Poll sources
2025-12-12T12:27:37.493186Z :KQP_COMPUTE TRACE: dq_pq_rd_read_actor.cpp:767: SelfId: [1:7582947099594315665:2250], TxId: ptqudq7uffpn58fsu002, task: 1, Cluster: . PQ source. GetAsyncInputData freeSpace = 1000000
2025-12-12T12:27:37.493192Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:81: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Poll async input 0. Buffer free space: 1000000, read from async input: 0 bytes, 0 rows, finished: 0
2025-12-12T12:27:37.493201Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-12-12T12:27:37.493216Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. update task runner stats
2025-12-12T12:27:37.493223Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-12T12:27:37.493224Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:27:37.493226Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:534: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. About to drain channelId: 1, hasPeer: 1, peerState:(freeSpace:1000000;inFlightBytes:96;inFlightCount:1;)
2025-12-12T12:27:37.494004Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:179: TxId: ptqudq7uffpn58fsu002, task: 1. Received channel data ack for channelId: 1, seqNo: 4, lastSentSeqNo: 4, freeSpace: 1000000, early finish: 0
2025-12-12T12:27:37.494017Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:207: TxId: ptqudq7uffpn58fsu002, task: 1. PeerState, peerState:(freeSpace:1000000;inFlightBytes:0;inFlightCount:0;), sentSeqNo: 4, ackSeqNo: 4
2025-12-12T12:27:37.494018Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:220: TxId: ptqudq7uffpn58fsu002, task: 1. Resume compute actor
2025-12-12T12:27:37.494024Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Poll inputs
2025-12-12T12:27:37.494025Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Poll sources
2025-12-12T12:27:37.494028Z :KQP_COMPUTE TRACE: dq_pq_rd_read_actor.cpp:767: SelfId: [1:7582947099594315665:2250], TxId: ptqudq7uffpn58fsu002, task: 1, Cluster: . PQ source. GetAsyncInputData freeSpace = 1000000
2025-12-12T12:27:37.494032Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:81: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Poll async input 0. Buffer free space: 1000000, read from async input: 0 bytes, 0 rows, finished: 0
2025-12-12T12:27:37.494042Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-12-12T12:27:37.494079Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. update task runner stats
2025-12-12T12:27:37.494110Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-12T12:27:37.494118Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:27:37.494122Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:534: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. About to drain channelId: 1, hasPeer: 1, peerState:(freeSpace:1000000;inFlightBytes:0;inFlightCount:0;)
2025-12-12T12:27:37.496262Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:484: [ptqudq7uffpn58fsu002-0] [2:4] TEvSaveTaskState Apply: task: 1
2025-12-12T12:27:37.496272Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:499: [ptqudq7uffpn58fsu002-0] [2:4] Send TEvSaveTaskStateResult: task: 1
2025-12-12T12:27:37.496315Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:466: [ptqudq7uffpn58fsu002-0.2] [2:4] Got TEvSaveTaskStateResult; task 1, status: OK, size: 128
2025-12-12T12:27:37.496324Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:476: [ptqudq7uffpn58fsu002-0.2] [2:4] Task state saved, need 1 more acks
2025-12-12T12:27:37.497802Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:466: [ptqudq7uffpn58fsu002-0.2] [2:4] Got TEvSaveTaskStateResult; task 2, status: OK, size: 139
2025-12-12T12:27:37.497811Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:476: [ptqudq7uffpn58fsu002-0.2] [2:4] Task state saved, need 0 more acks
2025-12-12T12:27:37.497814Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:489: [ptqudq7uffpn58fsu002-0.2] [2:4] Got all acks, changing checkpoint status to 'PendingCommit'
2025-12-12T12:27:37.497830Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:343: [ptqudq7uffpn58fsu002-0.2] [2:4] Got TEvSetCheckpointPendingCommitStatusRequest
2025-12-12T12:27:37.521311Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:362: [ptqudq7uffpn58fsu002-0.2] [2:4] Status updated to 'PendingCommit'
2025-12-12T12:27:37.521324Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:364: [ptqudq7uffpn58fsu002-0.2] [2:4] Send TEvSetCheckpointPendingCommitStatusResponse
2025-12-12T12:27:37.521369Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:501: [ptqudq7uffpn58fsu002-0.2] [2:4] Got TEvSetCheckpointPendingCommitStatusResponse
2025-12-12T12:27:37.521376Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:516: [ptqudq7uffpn58fsu002-0.2] [2:4] Checkpoint status changed to 'PendingCommit', committing states to 2 actor(s)
2025-12-12T12:27:37.521420Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:759: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Commit state
2025-12-12T12:27:37.521439Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:532: [ptqudq7uffpn58fsu002-0.2] [2:4] Got TEvStateCommitted; task: 1
2025-12-12T12:27:37.521447Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:541: [ptqudq7uffpn58fsu002-0.2] [2:4] State committed [1:7582947099594315661:2250], need 1 more acks
2025-12-12T12:27:37.521783Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:532: [ptqudq7uffpn58fsu002-0.2] [2:4] Got TEvStateCommitted; task: 2
2025-12-12T12:27:37.521791Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:541: [ptqudq7uffpn58fsu002-0.2] [2:4] State committed [2:7582947096977367208:2158], need 0 more acks
2025-12-12T12:27:37.521793Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:543: [ptqudq7uffpn58fsu002-0.2] [2:4] Got all acks, changing checkpoint status to 'Completed'
2025-12-12T12:27:37.521808Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:371: [ptqudq7uffpn58fsu002-0.2] [2:4] Got TEvCompleteCheckpointRequest
2025-12-12T12:27:37.542575Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:393: [ptqudq7uffpn58fsu002-0.2] [2:4] Status updated to 'Completed'
2025-12-12T12:27:37.542586Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:400: [ptqudq7uffpn58fsu002-0.2] [2:4] Send TEvCompleteCheckpointResponse
2025-12-12T12:27:37.542626Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:564: [ptqudq7uffpn58fsu002-0.2] [2:4] Got TEvCompleteCheckpointResponse
2025-12-12T12:27:37.542636Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:579: [ptqudq7uffpn58fsu002-0.2] [2:4] Checkpoint completed
2025-12-12T12:27:38.188944Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 6734039d-3c6d3147-8d4aa390-5370ecbe25, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:38.194612Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:38.194629Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:38.199073Z :FQ_PINGER TRACE: pinger.cpp:400: QueryId: ptqudq7uffpn58fsu002, Owner: 6734039d-3c6d3147-8d4aa390-5370ecbe19 Request Private::PingTask
2025-12-12T12:27:38.210249Z :FQ_PINGER TRACE: pinger.cpp:338: QueryId: ptqudq7uffpn58fsu002, Owner: 6734039d-3c6d3147-8d4aa390-5370ecbe19 Ping response success: { expired_at { seconds: 1765542478 nanos: 203000000 } }
2025-12-12T12:27:38.240110Z :YQL_PROXY TRACE: log.cpp:64: SessionId:  2025-12-12 12:27:38.240 TRACE ydbd(pid=1201569, tid=0x00007F114805C640) [DQ] task_controller_impl.h:271:  [1:7582947099594315659:2248] ExportStats Summary
2025-12-12T12:27:38.240358Z :FQ_PINGER TRACE: pinger.cpp:250: QueryId: ptqudq7uffpn58fsu002, Owner: 6734039d-3c6d3147-8d4aa390-5370ecbe19 Forward ping request: { statistics: "{\"Graph=0\":{\"TaskRunner\":{\"Stage=201976\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":1,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":1,\"count\":1,\"avg\":1,\"max\":1,\"min\":1}},\"Stage=201993\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":1,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":1,\"count\":1,\"avg\":1,\"max\":1,\"min\":1}},\"Stage=Total\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":2,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":2,\"count\":2,\"avg\":1,\"max\":1,\"min\":1}}}}}" }
2025-12-12T12:27:38.240367Z :FQ_PINGER TRACE: pinger.cpp:393: QueryId: ptqudq7uffpn58fsu002, Owner: 6734039d-3c6d3147-8d4aa390-5370ecbe19 Forward request Private::PingTask
2025-12-12T12:27:38.253735Z :FQ_PINGER TRACE: pinger.cpp:338: QueryId: ptqudq7uffpn58fsu002, Owner: 6734039d-3c6d3147-8d4aa390-5370ecbe19 Ping response success: { expired_at { seconds: 1765542478 nanos: 247000000 } }
2025-12-12T12:27:38.253773Z :FQ_RUN_ACTOR TRACE: run_actor.cpp:861: QueryId: ptqudq7uffpn58fsu002 Forward ping response. Success: 1. Cookie: 6
2025-12-12T12:27:38.356822Z :YQL_PROXY TRACE: log.cpp:64: SessionId:  2025-12-12 12:27:38.356 TRACE ydbd(pid=1201569, tid=0x00007F114805C640) [DQ] task_controller_impl.h:229:  Ping TaskId: 1, Compute ActorId: [1:7582947099594315661:2250], PingCookie: 1
2025-12-12T12:27:38.356871Z :YQL_PROXY TRACE: log.cpp:64: SessionId:  2025-12-12 12:27:38.356 TRACE ydbd(pid=1201569, tid=0x00007F114805C640) [DQ] task_controller_impl.h:229:  Ping TaskId: 2, Compute ActorId: [2:7582947096977367208:2158], PingCookie: 2
2025-12-12T12:27:38.356893Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:453: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Got TEvStateRequest from actor [1:7582947099594315659:2248] PingCookie: 1
2025-12-12T12:27:38.356907Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. update task runner stats
2025-12-12T12:27:38.356985Z :YQL_PROXY TRACE: log.cpp:64: SessionId:  2025-12-12 12:27:38.356 TRACE ydbd(pid=1201569, tid=0x00007F114805C640) [DQ] task_controller_impl.h:160: [1:7582947099594315659:2248] EvState TaskId: 1 State: 2 PingCookie: 1 StatusCode: SUCCESS
2025-12-12T12:27:38.356995Z :YQL_PROXY TRACE: log.cpp:64: SessionId:  2025-12-12 12:27:38.356 TRACE ydbd(pid=1201569, tid=0x00007F114805C640) [DQ] task_controller_impl.h:174:  [1:7582947099594315659:2248] AddStats 1
2025-12-12T12:27:38.357063Z :YQL_PROXY TRACE: log.cpp:64: SessionId:  2025-12-12 12:27:38.357 TRACE ydbd(pid=1201569, tid=0x00007F114805C640) [DQ] task_controller_impl.h:201:  [1:7582947099594315659:2248] Executing TaskId: 1
2025-12-12T12:27:38.357277Z :YQL_PROXY TRACE: log.cpp:64: SessionId:  2025-12-12 12:27:38.357 TRACE ydbd(pid=1201569, tid=0x00007F114805C640) [DQ] task_controller_impl.h:160: [1:7582947099594315659:2248] EvState TaskId: 2 State: 2 PingCookie: 2 StatusCode: SUCCESS
2025-12-12T12:27:38.357285Z :YQL_PROXY TRACE: log.cpp:64: SessionId:  2025-12-12 12:27:38.357 TRACE ydbd(pid=1201569, tid=0x00007F114805C640) [DQ] task_controller_impl.h:174:  [1:7582947099594315659:2248] AddStats 2
2025-12-12T12:27:38.357346Z :YQL_PROXY TRACE: log.cpp:64: SessionId:  2025-12-12 12:27:38.357 TRACE ydbd(pid=1201569, tid=0x00007F114805C640) [DQ] task_controller_impl.h:201:  [1:7582947099594315659:2248] Executing TaskId: 2
2025-12-12T12:27:38.465343Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:373: [ptqudq7uffpn58fsu002-0.2] Got TEvScheduleCheckpointing
2025-12-12T12:27:38.465359Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:349: [ptqudq7uffpn58fsu002-0.2] [2:5] Registering new checkpoint in storage
2025-12-12T12:27:38.465387Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:288: [ptqudq7uffpn58fsu002-0.2] [2:5] Got TEvCreateCheckpointRequest
2025-12-12T12:27:38.477652Z :KQP_COMPUTE TRACE: dq_pq_rd_read_actor.cpp:945: SelfId: [1:7582947099594315665:2250], TxId: ptqudq7uffpn58fsu002, task: 1, Cluster: . PQ source. Received TEvNewDataArrived from [2:7582946963833380727:2063], partition 0, seqNo 4, ConfirmedSeqNo 3 generation 1
2025-12-12T12:27:38.478074Z :KQP_COMPUTE TRACE: dq_pq_rd_read_actor.cpp:1123: SelfId: [1:7582947099594315665:2250], TxId: ptqudq7uffpn58fsu002, task: 1, Cluster: . PQ source. Received TEvMessageBatch from [2:7582946963833380727:2063], seqNo 5, ConfirmedSeqNo 4 generation 1
2025-12-12T12:27:38.478087Z :KQP_COMPUTE TRACE: dq_pq_rd_read_actor.cpp:1171: SelfId: [1:7582947099594315665:2250], TxId: ptqudq7uffpn58fsu002, task: 1, Cluster: . PQ source. TEvMessageBatch NextOffset 9
2025-12-12T12:27:38.478113Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Poll inputs
2025-12-12T12:27:38.478116Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Poll sources
2025-12-12T12:27:38.478121Z :KQP_COMPUTE TRACE: dq_pq_rd_read_actor.cpp:767: SelfId: [1:7582947099594315665:2250], TxId: ptqudq7uffpn58fsu002, task: 1, Cluster: . PQ source. GetAsyncInputData freeSpace = 1000000
2025-12-12T12:27:38.478170Z :KQP_COMPUTE TRACE: dq_pq_rd_read_actor.cpp:807: SelfId: [1:7582947099594315665:2250], TxId: ptqudq7uffpn58fsu002, task: 1, Cluster: . PQ source. NextOffset 9
2025-12-12T12:27:38.478175Z :KQP_COMPUTE TRACE: dq_pq_rd_read_actor.cpp:811: SelfId: [1:7582947099594315665:2250], TxId: ptqudq7uffpn58fsu002, task: 1, Cluster: . PQ source. Return 4 rows, watermark (empty maybe), buffer size 0, free space 999820, result size 180
2025-12-12T12:27:38.478180Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:81: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Poll async input 0. Buffer free space: 1000000, read from async input: 180 bytes, 4 rows, finished: 0
2025-12-12T12:27:38.478206Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-12-12T12:27:38.478213Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Poll inputs
2025-12-12T12:27:38.478214Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Poll sources
2025-12-12T12:27:38.478216Z :KQP_COMPUTE TRACE: dq_pq_rd_read_actor.cpp:767: SelfId: [1:7582947099594315665:2250], TxId: ptqudq7uffpn58fsu002, task: 1, Cluster: . PQ source. GetAsyncInputData freeSpace = 999820
2025-12-12T12:27:38.478218Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:81: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Poll async input 0. Buffer free space: 999820, read from async input: 0 bytes, 0 rows, finished: 0
2025-12-12T12:27:38.478307Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-12-12T12:27:38.478311Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. update task runner stats
2025-12-12T12:27:38.478344Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-12T12:27:38.478346Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:27:38.478353Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:534: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. About to drain channelId: 1, hasPeer: 1, peerState:(freeSpace:1000000;inFlightBytes:0;inFlightCount:0;)
2025-12-12T12:27:38.478357Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1107: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Ask CPU quota: 19ms
2025-12-12T12:27:38.478404Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:566: TxId: ptqudq7uffpn58fsu002, task: 1. SendChannelData, channelId: 1, peer: [2:7582947096977367208:2158], chunks: 4, bytes: 153, watermark: 0, checkpoint: 0, seqNo: 5, finished: 0
2025-12-12T12:27:38.478423Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Poll inputs
2025-12-12T12:27:38.478425Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Poll sources
2025-12-12T12:27:38.478427Z :KQP_COMPUTE TRACE: dq_pq_rd_read_actor.cpp:767: SelfId: [1:7582947099594315665:2250], TxId: ptqudq7uffpn58fsu002, task: 1, Cluster: . PQ source. GetAsyncInputData freeSpace = 1000000
2025-12-12T12:27:38.478430Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:81: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Poll async input 0. Buffer free space: 1000000, read from async input: 0 bytes, 0 rows, finished: 0
2025-12-12T12:27:38.478435Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-12-12T12:27:38.478729Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:179: TxId: ptqudq7uffpn58fsu002, task: 1. Received channel data ack for channelId: 1, seqNo: 5, lastSentSeqNo: 5, freeSpace: 999847, early finish: 0
2025-12-12T12:27:38.478736Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:207: TxId: ptqudq7uffpn58fsu002, task: 1. PeerState, peerState:(freeSpace:999847;inFlightBytes:0;inFlightCount:0;), sentSeqNo: 5, ackSeqNo: 5
2025-12-12T12:27:38.478738Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:220: TxId: ptqudq7uffpn58fsu002, task: 1. Resume compute actor
2025-12-12T12:27:38.478744Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Poll inputs
2025-12-12T12:27:38.478746Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Poll sources
2025-12-12T12:27:38.478749Z :KQP_COMPUTE TRACE: dq_pq_rd_read_actor.cpp:767: SelfId: [1:7582947099594315665:2250], TxId: ptqudq7uffpn58fsu002, task: 1, Cluster: . PQ source. GetAsyncInputData freeSpace = 1000000
2025-12-12T12:27:38.478752Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:81: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Poll async input 0. Buffer free space: 1000000, read from async input: 0 bytes, 0 rows, finished: 0
2025-12-12T12:27:38.478759Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-12-12T12:27:38.479373Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1165: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. CPU quota delay: 0ms
2025-12-12T12:27:38.479424Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. update task runner stats
2025-12-12T12:27:38.479452Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-12T12:27:38.479454Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:27:38.479460Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:534: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. About to drain channelId: 1, hasPeer: 1, peerState:(freeSpace:999847;inFlightBytes:0;inFlightCount:0;)
2025-12-12T12:27:38.483123Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:179: TxId: ptqudq7uffpn58fsu002, task: 1. Received channel data ack for channelId: 1, seqNo: 5, lastSentSeqNo: 5, freeSpace: 1000000, early finish: 0
2025-12-12T12:27:38.483133Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:207: TxId: ptqudq7uffpn58fsu002, task: 1. PeerState, peerState:(freeSpace:1000000;inFlightBytes:0;inFlightCount:0;), sentSeqNo: 5, ackSeqNo: 5
2025-12-12T12:27:38.483134Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:220: TxId: ptqudq7uffpn58fsu002, task: 1. Resume compute actor
2025-12-12T12:27:38.483144Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Poll inputs
2025-12-12T12:27:38.483147Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Poll sources
2025-12-12T12:27:38.483152Z :KQP_COMPUTE TRACE: dq_pq_rd_read_actor.cpp:767: SelfId: [1:7582947099594315665:2250], TxId: ptqudq7uffpn58fsu002, task: 1, Cluster: . PQ source. GetAsyncInputData freeSpace = 1000000
2025-12-12T12:27:38.483156Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:81: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Poll async input 0. Buffer free space: 1000000, read from async input: 0 bytes, 0 rows, finished: 0
2025-12-12T12:27:38.483170Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-12-12T12:27:38.483216Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. update task runner stats
2025-12-12T12:27:38.483238Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-12T12:27:38.483240Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:27:38.483244Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:534: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. About to drain channelId: 1, hasPeer: 1, peerState:(freeSpace:1000000;inFlightBytes:0;inFlightCount:0;)
2025-12-12T12:27:38.503521Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:334: [ptqudq7uffpn58fsu002-0.2] [2:5] Checkpoint created
2025-12-12T12:27:38.503536Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:336: [ptqudq7uffpn58fsu002-0.2] [2:5] Send TEvCreateCheckpointResponse
2025-12-12T12:27:38.503577Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:389: [ptqudq7uffpn58fsu002-0.2] [2:5] Got TEvCreateCheckpointResponse
2025-12-12T12:27:38.503601Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:435: [ptqudq7uffpn58fsu002-0.2] [2:5] Checkpoint successfully created, going to inject barriers to 1 actor(s)
2025-12-12T12:27:38.503628Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:239: [ptqudq7uffpn58fsu002-0] Task: 1. [Checkpoint 2.5] TEvInjectCheckpoint
2025-12-12T12:27:38.503647Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Poll inputs
2025-12-12T12:27:38.503650Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1494: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Skip polling sources because of pending checkpoint
2025-12-12T12:27:38.503653Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. DoExecuteImpl: 1
2025-12-12T12:27:38.503737Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:462: SelfId: [1:7582947099594315663:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Pending 1 checkpoints to be sent
2025-12-12T12:27:38.503754Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. update task runner stats
2025-12-12T12:27:38.503804Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 1 watermark injected: (empty maybe)
2025-12-12T12:27:38.503812Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:447: [ptqudq7uffpn58fsu002-0] Task: 1. [Checkpoint 2.5] Performing task checkpoint
2025-12-12T12:27:38.503815Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:816: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Save state
2025-12-12T12:27:38.503822Z :KQP_COMPUTE DEBUG: dq_pq_read_actor_base.cpp:94: SelfId: [1:7582947099594315665:2250], TxId: ptqudq7uffpn58fsu002, task: 1, Cluster: . PQ source. SessionId: empty SaveState, offsets: {0,9},
2025-12-12T12:27:38.503832Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:474: [ptqudq7uffpn58fsu002-0] Task: 1. [Checkpoint 2.5] CA state saved
2025-12-12T12:27:38.503835Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:449: [ptqudq7uffpn58fsu002-0] Task: 1. [Checkpoint 2.5] Injecting checkpoint barrier to outputs
2025-12-12T12:27:38.503846Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:536: [ptqudq7uffpn58fsu002-0] Task: 1. [Checkpoint 2.5] Task checkpoint is done. Send to storage
2025-12-12T12:27:38.503859Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:27:38.503865Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:534: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. About to drain channelId: 1, hasPeer: 1, peerState:(freeSpace:1000000;inFlightBytes:0;inFlightCount:0;)
2025-12-12T12:27:38.503871Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:460: [ptqudq7uffpn58fsu002-0] [2:5] Got TEvSaveTaskState: task 1
2025-12-12T12:27:38.503883Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:566: TxId: ptqudq7uffpn58fsu002, task: 1. SendChannelData, channelId: 1, peer: [2:7582947096977367208:2158], chunks: 0, bytes: 0, watermark: 0, checkpoint: 1, seqNo: 6, finished: 0
2025-12-12T12:27:38.503900Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Poll inputs
2025-12-12T12:27:38.503906Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Poll sources
2025-12-12T12:27:38.503910Z :KQP_COMPUTE TRACE: dq_pq_rd_read_actor.cpp:767: SelfId: [1:7582947099594315665:2250], TxId: ptqudq7uffpn58fsu002, task: 1, Cluster: . PQ source. GetAsyncInputData freeSpace = 1000000
2025-12-12T12:27:38.503915Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:81: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Poll async input 0. Buffer free space: 1000000, read from async input: 0 bytes, 0 rows, finished: 0
2025-12-12T12:27:38.503926Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-12-12T12:27:38.503964Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. update task runner stats
2025-12-12T12:27:38.503977Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-12T12:27:38.503979Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:27:38.503983Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:534: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. About to drain channelId: 1, hasPeer: 1, peerState:(freeSpace:1000000;inFlightBytes:96;inFlightCount:1;)
2025-12-12T12:27:38.504371Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:179: TxId: ptqudq7uffpn58fsu002, task: 1. Received channel data ack for channelId: 1, seqNo: 6, lastSentSeqNo: 6, freeSpace: 1000000, early finish: 0
2025-12-12T12:27:38.504381Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:207: TxId: ptqudq7uffpn58fsu002, task: 1. PeerState, peerState:(freeSpace:1000000;inFlightBytes:0;inFlightCount:0;), sentSeqNo: 6, ackSeqNo: 6
2025-12-12T12:27:38.504382Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:220: TxId: ptqudq7uffpn58fsu002, task: 1. Resume compute actor
2025-12-12T12:27:38.504389Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Poll inputs
2025-12-12T12:27:38.504390Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Poll sources
2025-12-12T12:27:38.504393Z :KQP_COMPUTE TRACE: dq_pq_rd_read_actor.cpp:767: SelfId: [1:7582947099594315665:2250], TxId: ptqudq7uffpn58fsu002, task: 1, Cluster: . PQ source. GetAsyncInputData freeSpace = 1000000
2025-12-12T12:27:38.504397Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:81: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Poll async input 0. Buffer free space: 1000000, read from async input: 0 bytes, 0 rows, finished: 0
2025-12-12T12:27:38.504405Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-12-12T12:27:38.504445Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. update task runner stats
2025-12-12T12:27:38.504465Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-12T12:27:38.504472Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:27:38.504475Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:534: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. About to drain channelId: 1, hasPeer: 1, peerState:(freeSpace:1000000;inFlightBytes:0;inFlightCount:0;)
2025-12-12T12:27:38.507148Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:484: [ptqudq7uffpn58fsu002-0] [2:5] TEvSaveTaskState Apply: task: 1
2025-12-12T12:27:38.507159Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:499: [ptqudq7uffpn58fsu002-0] [2:5] Send TEvSaveTaskStateResult: task: 1
2025-12-12T12:27:38.507229Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:466: [ptqudq7uffpn58fsu002-0.2] [2:5] Got TEvSaveTaskStateResult; task 1, status: OK, size: 128
2025-12-12T12:27:38.507240Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:476: [ptqudq7uffpn58fsu002-0.2] [2:5] Task state saved, need 1 more acks
2025-12-12T12:27:38.507540Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:466: [ptqudq7uffpn58fsu002-0.2] [2:5] Got TEvSaveTaskStateResult; task 2, status: OK, size: 140
2025-12-12T12:27:38.507550Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:476: [ptqudq7uffpn58fsu002-0.2] [2:5] Task state saved, need 0 more acks
2025-12-12T12:27:38.507552Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:489: [ptqudq7uffpn58fsu002-0.2] [2:5] Got all acks, changing checkpoint status to 'PendingCommit'
2025-12-12T12:27:38.507567Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:343: [ptqudq7uffpn58fsu002-0.2] [2:5] Got TEvSetCheckpointPendingCommitStatusRequest
2025-12-12T12:27:38.529813Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:362: [ptqudq7uffpn58fsu002-0.2] [2:5] Status updated to 'PendingCommit'
2025-12-12T12:27:38.529825Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:364: [ptqudq7uffpn58fsu002-0.2] [2:5] Send TEvSetCheckpointPendingCommitStatusResponse
2025-12-12T12:27:38.529858Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:501: [ptqudq7uffpn58fsu002-0.2] [2:5] Got TEvSetCheckpointPendingCommitStatusResponse
2025-12-12T12:27:38.529864Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:516: [ptqudq7uffpn58fsu002-0.2] [2:5] Checkpoint status changed to 'PendingCommit', committing states to 2 actor(s)
2025-12-12T12:27:38.529906Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:759: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Commit state
2025-12-12T12:27:38.529919Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:532: [ptqudq7uffpn58fsu002-0.2] [2:5] Got TEvStateCommitted; task: 1
2025-12-12T12:27:38.529924Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:541: [ptqudq7uffpn58fsu002-0.2] [2:5] State committed [1:7582947099594315661:2250], need 1 more acks
2025-12-12T12:27:38.530299Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:532: [ptqudq7uffpn58fsu002-0.2] [2:5] Got TEvStateCommitted; task: 2
2025-12-12T12:27:38.530305Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:541: [ptqudq7uffpn58fsu002-0.2] [2:5] State committed [2:7582947096977367208:2158], need 0 more acks
2025-12-12T12:27:38.530307Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:543: [ptqudq7uffpn58fsu002-0.2] [2:5] Got all acks, changing checkpoint status to 'Completed'
2025-12-12T12:27:38.530322Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:371: [ptqudq7uffpn58fsu002-0.2] [2:5] Got TEvCompleteCheckpointRequest
2025-12-12T12:27:38.554381Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:393: [ptqudq7uffpn58fsu002-0.2] [2:5] Status updated to 'Completed'
2025-12-12T12:27:38.554394Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:400: [ptqudq7uffpn58fsu002-0.2] [2:5] Send TEvCompleteCheckpointResponse
2025-12-12T12:27:38.554421Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:564: [ptqudq7uffpn58fsu002-0.2] [2:5] Got TEvCompleteCheckpointResponse
2025-12-12T12:27:38.554433Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:579: [ptqudq7uffpn58fsu002-0.2] [2:5] Checkpoint completed
2025-12-12T12:27:38.745369Z :KQP_COMPUTE TRACE: dq_pq_rd_read_actor.cpp:890: SelfId: [1:7582947099594315665:2250], TxId: ptqudq7uffpn58fsu002, task: 1, Cluster: . PQ source. Received TEvStatistics from [2:7582946963833380727:2063], seqNo 6, ConfirmedSeqNo 4 generation 1
2025-12-12T12:27:39.187265Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [2:7582946963833380804:2115]
2025-12-12T12:27:39.187304Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:39.187835Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:39.189315Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 6734039d-3c6d3147-8d4aa390-5370ecbe26, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:39.199104Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:39.199120Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:39.240840Z :YQL_PROXY TRACE: log.cpp:64: SessionId:  2025-12-12 12:27:39.240 TRACE ydbd(pid=1201569, tid=0x00007F114805C640) [DQ] task_controller_impl.h:271:  [1:7582947099594315659:2248] ExportStats Summary
2025-12-12T12:27:39.242563Z :FQ_PINGER TRACE: pinger.cpp:250: QueryId: ptqudq7uffpn58fsu002, Owner: 6734039d-3c6d3147-8d4aa390-5370ecbe19 Forward ping request: { statistics: "{\"Graph=0\":{\"EgressBytes\":{\"sum\":124,\"count\":1,\"avg\":124,\"max\":124,\"min\":124},\"TaskRunner\":{\"Input=201976\":{\"Stage=201993\":{\"PopQueuedBytes\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"PopQueuedRows\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"PushQueuedBytes\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"PushQueuedRows\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"PushWaitTimeUs\":{\"sum\":\"4.03s\",\"count\":1,\"avg\":\"4.03s\",\"max\":\"4.03s\",\"min\":\"4.03s\"}}},\"Input=Total\":{\"Stage=201993\":{\"ChannelCount\":{\"sum\":1,\"count\":1,\"avg\":1,\"max\":1,\"min\":1},\"PopQueuedBytes\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"PopQueuedRows\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"PushQueuedBytes\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"PushQueuedRows\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"PushWaitTimeUs\":{\"sum\":\"4.03s\",\"count\":1,\"avg\":\"4.03s\",\"max\":\"4.03s\",\"min\":\"4.03s\"}},\"Stage=Total\":{\"ChannelCount\":{\"sum\":1,\"count\":1,\"avg\":1,\"max\":1,\"min\":1},\"PopQueuedBytes\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"PopQueuedRows\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"PushQueuedBytes\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"PushQueuedRows\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"PushWaitTimeUs\":{\"sum\":\"4.03s\",\"count\":1,\"avg\":\"4.03s\",\"max\":\"4.03s\",\"min\":\"4.03s\"}}},\"Output=201993\":{\"Stage=201976\":{\"PopQueuedBytes\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"PopQueuedRows\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"PushQueuedBytes\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"PushQueuedRows\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"PushWaitTimeUs\":{\"sum\":\"4.03s\",\"count\":1,\"avg\":\"4.03s\",\"max\":\"4.03s\",\"min\":\"4.03s\"}}},\"Output=Total\":{\"Stage=201976\":{\"ChannelCount\":{\"sum\":1,\"count\":1,\"avg\":1,\"max\":1,\"min\":1},\"PopQueuedBytes\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"PopQueuedRows\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"PushQueuedBytes\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"PushQueuedRows\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"PushWaitTimeUs\":{\"sum\":\"4.03s\",\"count\":1,\"avg\":\"4.03s\",\"max\":\"4.03s\",\"min\":\"4.03s\"}},\"Stage=Total\":{\"ChannelCount\":{\"sum\":1,\"count\":1,\"avg\":1,\"max\":1,\"min\":1},\"PopQueuedBytes\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"PopQueuedRows\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"PushQueuedBytes\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"PushQueuedRows\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"PushWaitTimeUs\":{\"sum\":\"4.03s\",\"count\":1,\"avg\":\"4.03s\",\"max\":\"4.03s\",\"min\":\"4.03s\"}}},\"Sink=0\":{\"Stage=201993\":{\"EgressBytes\":{\"sum\":124,\"count\":1,\"avg\":124,\"max\":124,\"min\":124},\"EgressQueuedBytes\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"EgressQueuedRows\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"PopActiveTimeUs\":{\"sum\":\"3.00s\",\"count\":1,\"avg\":\"3.00s\",\"max\":\"3.00s\",\"min\":\"3.00s\"},\"PopBytes\":{\"sum\":24,\"count\":1,\"avg\":24,\"max\":24,\"min\":24},\"PopChunks\":{\"sum\":8,\"count\":1,\"avg\":8,\"max\":8,\"min\":8},\"PopFirstMessageMs\":{\"sum\":\"N/A\",\"count\":1,\"avg\":\"12:27:34.49s\",\"max\":\"12:27:34.49s\",\"min\":\"12:27:34.49s\"},\"PopLastMessageMs\":{\"sum\":\"N/A\",\"count\":1,\"avg\":\"12:27:37.49s\",\"max\":\"12:27:37.49s\",\"min\":\"12:27:37.49s\"},\"PopQueuedBytes\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"PopQueuedRows\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"PopRows\":{\"sum\":4,\"count\":1,\"avg\":4,\"max\":4,\"min\":4},\"PushActiveTimeUs\":{\"sum\":\"3.00s\",\"count\":1,\"avg\":\"3.00s\",\"max\":\"3.00s\",\"min\":\"3.00s\"},\"PushBytes\":{\"sum\":24,\"count\":1,\"avg\":24,\"max\":24,\"min\":24},\"PushChunks\":{\"sum\":4,\"count\":1,\"avg\":4,\"max\":4,\"min\":4},\"PushFirstMessageMs\":{\"sum\":\"N/A\",\"count\":1,\"avg\":\"12:27:34.49s\",\"max\":\"12:27:34.49s\",\"min\":\"12:27:34.49s\"},\"PushLastMessageMs\":{\"sum\":\"N/A\",\"count\":1,\"avg\":\"12:27:37.49s\",\"max\":\"12:27:37.49s\",\"min\":\"12:27:37.49s\"},\"PushPauseMessageMs\":{\"sum\":\"N/A\",\"count\":1,\"avg\":\"12:27:33.46s\",\"max\":\"12:27:33.46s\",\"min\":\"12:27:33.46s\"},\"PushQueuedBytes\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"PushQueuedRows\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"PushResumeMessageMs\":{\"sum\":\"N/A\",\"count\":1,\"avg\":\"12:27:37.49s\",\"max\":\"12:27:37.49s\",\"min\":\"12:27:37.49s\"},\"PushRows\":{\"sum\":4,\"count\":1,\"avg\":4,\"max\":4,\"min\":4},\"PushWaitPeriods\":{\"sum\":4,\"count\":1,\"avg\":4,\"max\":4,\"min\":4},\"PushWaitTimeUs\":{\"sum\":\"4.02s\",\"count\":1,\"avg\":\"4.02s\",\"max\":\"4.02s\",\"min\":\"4.02s\"}},\"Stage=Total\":{\"EgressBytes\":{\"sum\":124,\"count\":1,\"avg\":124,\"max\":124,\"min\":124},\"EgressQueuedBytes\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"EgressQueuedRows\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"PopActiveTimeUs\":{\"sum\":\"3.00s\",\"count\":1,\"avg\":\"3.00s\",\"max\":\"3.00s\",\"min\":\"3.00s\"},\"PopBytes\":{\"sum\":24,\"count\":1,\"avg\":24,\"max\":24,\"min\":24},\"PopChunks\":{\"sum\":8,\"count\":1,\"avg\":8,\"max\":8,\"min\":8},\"PopFirstMessageMs\":{\"sum\":\"N/A\",\"count\":1,\"avg\":\"12:27:34.49s\",\"max\":\"12:27:34.49s\",\"min\":\"12:27:34.49s\"},\"PopLastMessageMs\":{\"sum\":\"N/A\",\"count\":1,\"avg\":\"12:27:37.49s\",\"max\":\"12:27:37.49s\",\"min\":\"12:27:37.49s\"},\"PopQueuedBytes\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"PopQueuedRows\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"PopRows\":{\"sum\":4,\"count\":1,\"avg\":4,\"max\":4,\"min\":4},\"PushActiveTimeUs\":{\"sum\":\"3.00s\",\"count\":1,\"avg\":\"3.00s\",\"max\":\"3.00s\",\"min\":\"3.00s\"},\"PushBytes\":{\"sum\":24,\"count\":1,\"avg\":24,\"max\":24,\"min\":24},\"PushChunks\":{\"sum\":4,\"count\":1,\"avg\":4,\"max\":4,\"min\":4},\"PushFirstMessageMs\":{\"sum\":\"N/A\",\"count\":1,\"avg\":\"12:27:34.49s\",\"max\":\"12:27:34.49s\",\"min\":\"12:27:34.49s\"},\"PushLastMessageMs\":{\"sum\":\"N/A\",\"count\":1,\"avg\":\"12:27:37.49s\",\"max\":\"12:27:37.49s\",\"min\":\"12:27:37.49s\"},\"PushPauseMessageMs\":{\"sum\":\"N/A\",\"count\":1,\"avg\":\"12:27:33.46s\",\"max\":\"12:27:33.46s\",\"min\":\"12:27:33.46s\"},\"PushQueuedBytes\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"PushQueuedRows\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"PushResumeMessageMs\":{\"sum\":\"N/A\",\"count\":1,\"avg\":\"12:27:37.49s\",\"max\":\"12:27:37.49s\",\"min\":\"12:27:37.49s\"},\"PushRows\":{\"sum\":4,\"count\":1,\"avg\":4,\"max\":4,\"min\":4},\"PushWaitPeriods\":{\"sum\":4,\"count\":1,\"avg\":4,\"max\":4,\"min\":4},\"PushWaitTimeUs\":{\"sum\":\"4.02s\",\"count\":1,\"avg\":\"4.02s\",\"max\":\"4.02s\",\"min\":\"4.02s\"}}},\"Source=PqSource\":{\"Stage=201976\":{\"IngressChunks\":{\"sum\":1,\"count\":1,\"avg\":1,\"max\":1,\"min\":1},\"IngressQueuedBytes\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"IngressQueuedRows\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"PopQueuedBytes\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"PopQueuedRows\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"PushQueuedBytes\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"PushQueuedRows\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"PushWaitTimeUs\":{\"sum\":\"4.03s\",\"count\":1,\"avg\":\"4.03s\",\"max\":\"4.03s\",\"min\":\"4.03s\"}},\"Stage=Total\":{\"IngressChunks\":{\"sum\":1,\"count\":1,\"avg\":1,\"max\":1,\"min\":1},\"IngressQueuedBytes\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"IngressQueuedRows\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"PopQueuedBytes\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"PopQueuedRows\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"PushQueuedBytes\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"PushQueuedRows\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"PushWaitTimeUs\":{\"sum\":\"4.03s\",\"count\":1,\"avg\":\"4.03s\",\"max\":\"4.03s\",\"min\":\"4.03s\"}}},\"Stage=201976\":{\"BuildCpuTimeUs\":{\"sum\":\"52ms\",\"count\":1,\"avg\":\"52ms\",\"max\":\"52ms\",\"min\":\"52ms\"},\"ComputeCpuTimeUs\":{\"sum\":\"50us\",\"count\":1,\"avg\":\"50us\",\"max\":\"50us\",\"min\":\"50us\"},\"CpuTimeUs\":{\"sum\":\"57ms\",\"count\":1,\"avg\":\"57ms\",\"max\":\"57ms\",\"min\":\"57ms\"},\"IngressQueuedBytes\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"IngressQueuedRows\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"MkqlMaxMemoryUsage\":{\"sum\":2031616,\"count\":1,\"avg\":2031616,\"max\":2031616,\"min\":2031616},\"MultiHop_EarlyThrownEventsCount\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"MultiHop_LateThrownEventsCount\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"Tasks\":{\"sum\":1,\"count\":1,\"avg\":1,\"max\":1,\"min\":1}},\"Stage=201993\":{\"BuildCpuTimeUs\":{\"sum\":\"88ms\",\"count\":1,\"avg\":\"88ms\",\"max\":\"88ms\",\"min\":\"88ms\"},\"ComputeCpuTimeUs\":{\"sum\":\"64us\",\"count\":1,\"avg\":\"64us\",\"max\":\"64us\",\"min\":\"64us\"},\"CpuTimeUs\":{\"sum\":\"97ms\",\"count\":1,\"avg\":\"97ms\",\"max\":\"97ms\",\"min\":\"97ms\"},\"EgressBytes\":{\"sum\":124,\"count\":1,\"avg\":124,\"max\":124,\"min\":124},\"EgressRows\":{\"sum\":4,\"count\":1,\"avg\":4,\"max\":4,\"min\":4},\"IngressQueuedBytes\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"IngressQueuedRows\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"MkqlMaxMemoryUsage\":{\"sum\":2031616,\"count\":1,\"avg\":2031616,\"max\":2031616,\"min\":2031616},\"MultiHop_EarlyThrownEventsCount\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"MultiHop_LateThrownEventsCount\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"Tasks\":{\"sum\":1,\"count\":1,\"avg\":1,\"max\":1,\"min\":1}},\"Stage=Total\":{\"BuildCpuTimeUs\":{\"sum\":\"0.14s\",\"count\":2,\"avg\":\"70ms\",\"max\":\"88ms\",\"min\":\"52ms\"},\"ComputeCpuTimeUs\":{\"sum\":\"114us\",\"count\":2,\"avg\":\"57us\",\"max\":\"64us\",\"min\":\"50us\"},\"CpuTimeUs\":{\"sum\":\"0.15s\",\"count\":2,\"avg\":\"77ms\",\"max\":\"97ms\",\"min\":\"57ms\"},\"EgressBytes\":{\"sum\":124,\"count\":1,\"avg\":124,\"max\":124,\"min\":124},\"EgressRows\":{\"sum\":4,\"count\":1,\"avg\":4,\"max\":4,\"min\":4},\"IngressQueuedBytes\":{\"sum\":0,\"count\":2,\"avg\":0,\"max\":0,\"min\":0},\"IngressQueuedRows\":{\"sum\":0,\"count\":2,\"avg\":0,\"max\":0,\"min\":0},\"MkqlMaxMemoryUsage\":{\"sum\":4063232,\"count\":2,\"avg\":2031616,\"max\":2031616,\"min\":2031616},\"MultiHop_EarlyThrownEventsCount\":{\"sum\":0,\"count\":2,\"avg\":0,\"max\":0,\"min\":0},\"MultiHop_LateThrownEventsCount\":{\"sum\":0,\"count\":2,\"avg\":0,\"max\":0,\"min\":0},\"Tasks\":{\"sum\":2,\"count\":2,\"avg\":1,\"max\":1,\"min\":1}}}}}" }
2025-12-12T12:27:39.242574Z :FQ_PINGER TRACE: pinger.cpp:393: QueryId: ptqudq7uffpn58fsu002, Owner: 6734039d-3c6d3147-8d4aa390-5370ecbe19 Forward request Private::PingTask
2025-12-12T12:27:39.263135Z :FQ_PINGER TRACE: pinger.cpp:338: QueryId: ptqudq7uffpn58fsu002, Owner: 6734039d-3c6d3147-8d4aa390-5370ecbe19 Ping response success: { action: ABORT expired_at { seconds: 1765542479 nanos: 252000000 } }
2025-12-12T12:27:39.263162Z :FQ_PINGER DEBUG: pinger.cpp:342: QueryId: ptqudq7uffpn58fsu002, Owner: 6734039d-3c6d3147-8d4aa390-5370ecbe19 Query action: ABORT
2025-12-12T12:27:39.263192Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:690: QueryId: ptqudq7uffpn58fsu002 New query action received: ABORT
2025-12-12T12:27:39.263197Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:1827: QueryId: ptqudq7uffpn58fsu002 Is about to finish query with status ABORTED_BY_USER
2025-12-12T12:27:39.263200Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:1820: QueryId: ptqudq7uffpn58fsu002 Write finalizing status: ABORTING_BY_USER
2025-12-12T12:27:39.263214Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:528: QueryId: ptqudq7uffpn58fsu002 Cancel running query
2025-12-12T12:27:39.263236Z :FQ_RUN_ACTOR TRACE: run_actor.cpp:880: QueryId: ptqudq7uffpn58fsu002 Forward ping response. Success: 1. Cookie: 6
2025-12-12T12:27:39.263262Z :FQ_PINGER TRACE: pinger.cpp:250: QueryId: ptqudq7uffpn58fsu002, Owner: 6734039d-3c6d3147-8d4aa390-5370ecbe19 Forward ping request: { status: ABORTING_BY_USER }
2025-12-12T12:27:39.263273Z :FQ_PINGER TRACE: pinger.cpp:393: QueryId: ptqudq7uffpn58fsu002, Owner: 6734039d-3c6d3147-8d4aa390-5370ecbe19 Forward request Private::PingTask
2025-12-12T12:27:39.263390Z :YQL_PROXY DEBUG: log.cpp:64: SessionId:  2025-12-12 12:27:39.263 DEBUG ydbd(pid=1201569, tid=0x00007F114805C640) [DQ] task_controller_impl.h:130: AbortExecution from [1:7582947099594315655:2244]:ABORTED { <main>: Error: ABORTED_BY_USER }
2025-12-12T12:27:39.263408Z :YQL_PROXY DEBUG: log.cpp:64: SessionId:  2025-12-12 12:27:39.263 DEBUG ydbd(pid=1201569, tid=0x00007F114805C640) [DQ] task_controller_impl.h:598: OnError { <main>: Error: ABORTED_BY_USER } ABORTED
2025-12-12T12:27:39.263781Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudq7uffpn58fsu002 2025-12-12 12:27:39.263 DEBUG ydbd(pid=1201569, tid=0x00007F114805C640) [DQ] executer_actor.cpp:304: {ptqudq7uffpn58fsu002} OnFailure, status=4, issues size=1, sender=[1:7582947099594315659:2248]
2025-12-12T12:27:39.263832Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudq7uffpn58fsu002 2025-12-12 12:27:39.263 DEBUG ydbd(pid=1201569, tid=0x00007F114805C640) [DQ] executer_actor.cpp:315: {ptqudq7uffpn58fsu002} Issues: <main>: Error: ABORTED_BY_USER

2025-12-12T12:27:39.263840Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudq7uffpn58fsu002 2025-12-12 12:27:39.263 DEBUG ydbd(pid=1201569, tid=0x00007F114805C640) [DQ] executer_actor.cpp:284: {ptqudq7uffpn58fsu002} Finish with status=4 issues=<main>: Error: ABORTED_BY_USER

2025-12-12T12:27:39.264278Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudq7uffpn58fsu002 2025-12-12 12:27:39.264 DEBUG ydbd(pid=1201569, tid=0x00007F114705A640) [DQ] executer_actor.cpp:341: {ptqudq7uffpn58fsu002} OnQueryResponse status=4 issuses_size=1
2025-12-12T12:27:39.264299Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:1396: QueryId: ptqudq7uffpn58fsu002 TEvQueryResponse received on finish
2025-12-12T12:27:39.264306Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:1233: QueryId: ptqudq7uffpn58fsu002 Query response CANCELLED. Result set index: 0. Issues count: 1. Rows count: 0
2025-12-12T12:27:39.265275Z :KQP_COMPUTE ERROR: dq_compute_actor_impl.h:1205: SelfId: [1:7582947099594315661:2250], TxId: ptqudq7uffpn58fsu002, task: 1. Ctx: {}. Handle abort execution event from: [1:7582947022284904055:2064], status: UNAVAILABLE, reason: { <main>: Error: Aborted by LWM }
2025-12-12T12:27:39.265313Z :KQP_COMPUTE DEBUG: dq_compute_actor_channels.cpp:494: TxId: ptqudq7uffpn58fsu002, task: 1. pass away
2025-12-12T12:27:39.265331Z :KQP_COMPUTE INFO: dq_pq_rd_read_actor.cpp:744: SelfId: [1:7582947099594315665:2250], TxId: ptqudq7uffpn58fsu002, task: 1, Cluster: . PQ source. PassAway
2025-12-12T12:27:39.265352Z :KQP_COMPUTE INFO: dq_pq_rd_read_actor.cpp:1242: SelfId: [1:7582947099594315665:2250], TxId: ptqudq7uffpn58fsu002, task: 1, Cluster: . PQ source. SelfId: [1:7582947099594315665:2250], TxId: ptqudq7uffpn58fsu002, task: 1, Cluster: . PQ source. State: used buffer size 0 ready buffer event size 0 state 5 InFlyAsyncInputData 0
Counters: CoordinatorChanged 2 CoordinatorResult 1 MessageBatch 1 StartSessionAck 1 NewDataArrived 1 SessionError 0 Statistics 3 NodeDisconnected 0 NodeConnected 2 Undelivered 0 Retry 1 PrivateHeartbeat 2 SessionClosed 0 Pong 0 Heartbeat 0 PrintState 0 ProcessState 0 GetAsyncInputData 16 NotifyCA 1
 [2:7582946963833380727:2063] status 2 is waiting ack 0 connection id 1 id 1, NextSeqNo 5, MyConfSeqNo 6, SeqNos 0, events size 0, connected 1, heartbeat shed 1, last received 2025-12-12T12:27:38.745381Z, last sent 2025-12-12T12:27:38.477674Z
 partitions 0 offsets 0=9 has pending data
2025-12-12T12:27:39.265355Z :KQP_COMPUTE INFO: dq_pq_rd_read_actor.cpp:736: SelfId: [1:7582947099594315665:2250], TxId: ptqudq7uffpn58fsu002, task: 1, Cluster: . PQ source. Send StopSession to [2:7582946963833380727:2063] generation 1
2025-12-12T12:27:39.265543Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:657: [ptqudq7uffpn58fsu002-0.2] PassAway
2025-12-12T12:27:39.277586Z :FQ_PINGER TRACE: pinger.cpp:338: QueryId: ptqudq7uffpn58fsu002, Owner: 6734039d-3c6d3147-8d4aa390-5370ecbe19 Ping response success: { action: ABORT expired_at { seconds: 1765542479 nanos: 271000000 } }
2025-12-12T12:27:39.277595Z :FQ_PINGER DEBUG: pinger.cpp:342: QueryId: ptqudq7uffpn58fsu002, Owner: 6734039d-3c6d3147-8d4aa390-5370ecbe19 Query action: ABORT
2025-12-12T12:27:39.277625Z :FQ_RUN_ACTOR TRACE: run_actor.cpp:880: QueryId: ptqudq7uffpn58fsu002 Forward ping response. Success: 1. Cookie: 3
2025-12-12T12:27:39.277627Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:887: QueryId: ptqudq7uffpn58fsu002 Finalizing status is saved
2025-12-12T12:27:39.277669Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:1507: QueryId: ptqudq7uffpn58fsu002 Start rate limiter resource deleter
2025-12-12T12:27:39.277683Z :STREAMS DEBUG: read_rule_deleter.cpp:214: ptqudq7uffpn58fsu002: Create read rule deleter actor for `test_group_by_hop_restart_node_input` [0]
2025-12-12T12:27:39.277711Z :STREAMS DEBUG: read_rule_deleter.cpp:106: ptqudq7uffpn58fsu002: Make request for read rule deletion for topic `test_group_by_hop_restart_node_input` [0]
2025-12-12T12:27:39.318633Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:1498: QueryId: ptqudq7uffpn58fsu002 Rate limiter resource deletion finished. Success: 1. Issues: 
2025-12-12T12:27:39.318648Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:1919: QueryId: ptqudq7uffpn58fsu002 SendPingAndPassAway, FinalQueryStatus ABORTED_BY_USER
2025-12-12T12:27:39.318675Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:536: QueryId: ptqudq7uffpn58fsu002 PassAway
2025-12-12T12:27:39.318918Z :FQ_PINGER TRACE: pinger.cpp:250: QueryId: ptqudq7uffpn58fsu002, Owner: 6734039d-3c6d3147-8d4aa390-5370ecbe19 Forward ping request: { result_id { value: "ptrudq7uejrfk61o469o" } status: ABORTED_BY_USER issues { message: "ABORTED_BY_USER" severity: 1 } statistics: "{\"Graph=0\":{\"Actor\":{\"ActorCreateTimeUs\":{\"sum\":\"66ms\",\"count\":2,\"avg\":\"33ms\",\"max\":\"35ms\",\"min\":\"30ms\"}},\"AllocateWorkersUs\":{\"sum\":\"36ms\",\"count\":1,\"avg\":\"36ms\",\"max\":\"36ms\",\"min\":\"36ms\"},\"EgressBytes\":{\"sum\":124,\"count\":1,\"avg\":124,\"max\":124,\"min\":124},\"ExecutionTimeUs\":{\"sum\":\"6.02s\",\"count\":1,\"avg\":\"6.02s\",\"max\":\"6.02s\",\"min\":\"6.02s\"},\"TaskRunner\":{\"Input=201976\":{\"Stage=201993\":{\"PopQueuedBytes\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"PopQueuedRows\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"PushQueuedBytes\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"PushQueuedRows\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"PushWaitTimeUs\":{\"sum\":\"4.03s\",\"count\":1,\"avg\":\"4.03s\",\"max\":\"4.03s\",\"min\":\"4.03s\"}}},\"Input=Total\":{\"Stage=201993\":{\"ChannelCount\":{\"sum\":1,\"count\":1,\"avg\":1,\"max\":1,\"min\":1},\"PopQueuedBytes\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"PopQueuedRows\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"PushQueuedBytes\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"PushQueuedRows\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"PushWaitTimeUs\":{\"sum\":\"4.03s\",\"count\":1,\"avg\":\"4.03s\",\"max\":\"4.03s\",\"min\":\"4.03s\"}},\"Stage=Total\":{\"ChannelCount\":{\"sum\":1,\"count\":1,\"avg\":1,\"max\":1,\"min\":1},\"PopQueuedBytes\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"PopQueuedRows\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"PushQueuedBytes\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"PushQueuedRows\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"PushWaitTimeUs\":{\"sum\":\"4.03s\",\"count\":1,\"avg\":\"4.03s\",\"max\":\"4.03s\",\"min\":\"4.03s\"}}},\"Output=201993\":{\"Stage=201976\":{\"PopQueuedBytes\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"PopQueuedRows\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"PushQueuedBytes\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"PushQueuedRows\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"PushWaitTimeUs\":{\"sum\":\"4.03s\",\"count\":1,\"avg\":\"4.03s\",\"max\":\"4.03s\",\"min\":\"4.03s\"}}},\"Output=Total\":{\"Stage=201976\":{\"ChannelCount\":{\"sum\":1,\"count\":1,\"avg\":1,\"max\":1,\"min\":1},\"PopQueuedBytes\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"PopQueuedRows\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"PushQueuedBytes\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"PushQueuedRows\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"PushWaitTimeUs\":{\"sum\":\"4.03s\",\"count\":1,\"avg\":\"4.03s\",\"max\":\"4.03s\",\"min\":\"4.03s\"}},\"Stage=Total\":{\"ChannelCount\":{\"sum\":1,\"count\":1,\"avg\":1,\"max\":1,\"min\":1},\"PopQueuedBytes\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"PopQueuedRows\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"PushQueuedBytes\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"PushQueuedRows\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"PushWaitTimeUs\":{\"sum\":\"4.03s\",\"count\":1,\"avg\":\"4.03s\",\"max\":\"4.03s\",\"min\":\"4.03s\"}}},\"Sink=0\":{\"Stage=201993\":{\"EgressBytes\":{\"sum\":124,\"count\":1,\"avg\":124,\"max\":124,\"min\":124},\"EgressQueuedBytes\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"EgressQueuedRows\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"PopActiveTimeUs\":{\"sum\":\"3.00s\",\"count\":1,\"avg\":\"3.00s\",\"max\":\"3.00s\",\"min\":\"3.00s\"},\"PopBytes\":{\"sum\":24,\"count\":1,\"avg\":24,\"max\":24,\"min\":24},\"PopChunks\":{\"sum\":8,\"count\":1,\"avg\":8,\"max\":8,\"min\":8},\"PopFirstMessageMs\":{\"sum\":\"N/A\",\"count\":1,\"avg\":\"12:27:34.49s\",\"max\":\"12:27:34.49s\",\"min\":\"12:27:34.49s\"},\"PopLastMessageMs\":{\"sum\":\"N/A\",\"count\":1,\"avg\":\"12:27:37.49s\",\"max\":\"12:27:37.49s\",\"min\":\"12:27:37.49s\"},\"PopQueuedBytes\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"PopQueuedRows\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"PopRows\":{\"sum\":4,\"count\":1,\"avg\":4,\"max\":4,\"min\":4},\"PushActiveTimeUs\":{\"sum\":\"3.00s\",\"count\":1,\"avg\":\"3.00s\",\"max\":\"3.00s\",\"min\":\"3.00s\"},\"PushBytes\":{\"sum\":24,\"count\":1,\"avg\":24,\"max\":24,\"min\":24},\"PushChunks\":{\"sum\":4,\"count\":1,\"avg\":4,\"max\":4,\"min\":4},\"PushFirstMessageMs\":{\"sum\":\"N/A\",\"count\":1,\"avg\":\"12:27:34.49s\",\"max\":\"12:27:34.49s\",\"min\":\"12:27:34.49s\"},\"PushLastMessageMs\":{\"sum\":\"N/A\",\"count\":1,\"avg\":\"12:27:37.49s\",\"max\":\"12:27:37.49s\",\"min\":\"12:27:37.49s\"},\"PushPauseMessageMs\":{\"sum\":\"N/A\",\"count\":1,\"avg\":\"12:27:33.46s\",\"max\":\"12:27:33.46s\",\"min\":\"12:27:33.46s\"},\"PushQueuedBytes\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"PushQueuedRows\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"PushResumeMessageMs\":{\"sum\":\"N/A\",\"count\":1,\"avg\":\"12:27:37.49s\",\"max\":\"12:27:37.49s\",\"min\":\"12:27:37.49s\"},\"PushRows\":{\"sum\":4,\"count\":1,\"avg\":4,\"max\":4,\"min\":4},\"PushWaitPeriods\":{\"sum\":4,\"count\":1,\"avg\":4,\"max\":4,\"min\":4},\"PushWaitTimeUs\":{\"sum\":\"4.02s\",\"count\":1,\"avg\":\"4.02s\",\"max\":\"4.02s\",\"min\":\"4.02s\"}},\"Stage=Total\":{\"EgressBytes\":{\"sum\":124,\"count\":1,\"avg\":124,\"max\":124,\"min\":124},\"EgressQueuedBytes\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"EgressQueuedRows\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"PopActiveTimeUs\":{\"sum\":\"3.00s\",\"count\":1,\"avg\":\"3.00s\",\"max\":\"3.00s\",\"min\":\"3.00s\"},\"PopBytes\":{\"sum\":24,\"count\":1,\"avg\":24,\"max\":24,\"min\":24},\"PopChunks\":{\"sum\":8,\"count\":1,\"avg\":8,\"max\":8,\"min\":8},\"PopFirstMessageMs\":{\"sum\":\"N/A\",\"count\":1,\"avg\":\"12:27:34.49s\",\"max\":\"12:27:34.49s\",\"min\":\"12:27:34.49s\"},\"PopLastMessageMs\":{\"sum\":\"N/A\",\"count\":1,\"avg\":\"12:27:37.49s\",\"max\":\"12:27:37.49s\",\"min\":\"12:27:37.49s\"},\"PopQueuedBytes\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"PopQueuedRows\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"PopRows\":{\"sum\":4,\"count\":1,\"avg\":4,\"max\":4,\"min\":4},\"PushActiveTimeUs\":{\"sum\":\"3.00s\",\"count\":1,\"avg\":\"3.00s\",\"max\":\"3.00s\",\"min\":\"3.00s\"},\"PushBytes\":{\"sum\":24,\"count\":1,\"avg\":24,\"max\":24,\"min\":24},\"PushChunks\":{\"sum\":4,\"count\":1,\"avg\":4,\"max\":4,\"min\":4},\"PushFirstMessageMs\":{\"sum\":\"N/A\",\"count\":1,\"avg\":\"12:27:34.49s\",\"max\":\"12:27:34.49s\",\"min\":\"12:27:34.49s\"},\"PushLastMessageMs\":{\"sum\":\"N/A\",\"count\":1,\"avg\":\"12:27:37.49s\",\"max\":\"12:27:37.49s\",\"min\":\"12:27:37.49s\"},\"PushPauseMessageMs\":{\"sum\":\"N/A\",\"count\":1,\"avg\":\"12:27:33.46s\",\"max\":\"12:27:33.46s\",\"min\":\"12:27:33.46s\"},\"PushQueuedBytes\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"PushQueuedRows\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"PushResumeMessageMs\":{\"sum\":\"N/A\",\"count\":1,\"avg\":\"12:27:37.49s\",\"max\":\"12:27:37.49s\",\"min\":\"12:27:37.49s\"},\"PushRows\":{\"sum\":4,\"count\":1,\"avg\":4,\"max\":4,\"min\":4},\"PushWaitPeriods\":{\"sum\":4,\"count\":1,\"avg\":4,\"max\":4,\"min\":4},\"PushWaitTimeUs\":{\"sum\":\"4.02s\",\"count\":1,\"avg\":\"4.02s\",\"max\":\"4.02s\",\"min\":\"4.02s\"}}},\"Source=PqSource\":{\"Stage=201976\":{\"IngressChunks\":{\"sum\":1,\"count\":1,\"avg\":1,\"max\":1,\"min\":1},\"IngressQueuedBytes\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"IngressQueuedRows\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"PopQueuedBytes\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"PopQueuedRows\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"PushQueuedBytes\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"PushQueuedRows\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"PushWaitTimeUs\":{\"sum\":\"4.03s\",\"count\":1,\"avg\":\"4.03s\",\"max\":\"4.03s\",\"min\":\"4.03s\"}},\"Stage=Total\":{\"IngressChunks\":{\"sum\":1,\"count\":1,\"avg\":1,\"max\":1,\"min\":1},\"IngressQueuedBytes\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"IngressQueuedRows\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"PopQueuedBytes\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"PopQueuedRows\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"PushQueuedBytes\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"PushQueuedRows\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"PushWaitTimeUs\":{\"sum\":\"4.03s\",\"count\":1,\"avg\":\"4.03s\",\"max\":\"4.03s\",\"min\":\"4.03s\"}}},\"Stage=201976\":{\"BuildCpuTimeUs\":{\"sum\":\"52ms\",\"count\":1,\"avg\":\"52ms\",\"max\":\"52ms\",\"min\":\"52ms\"},\"ComputeCpuTimeUs\":{\"sum\":\"50us\",\"count\":1,\"avg\":\"50us\",\"max\":\"50us\",\"min\":\"50us\"},\"CpuTimeUs\":{\"sum\":\"57ms\",\"count\":1,\"avg\":\"57ms\",\"max\":\"57ms\",\"min\":\"57ms\"},\"IngressQueuedBytes\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"IngressQueuedRows\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"MkqlMaxMemoryUsage\":{\"sum\":2031616,\"count\":1,\"avg\":2031616,\"max\":2031616,\"min\":2031616},\"MultiHop_EarlyThrownEventsCount\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"MultiHop_LateThrownEventsCount\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"Tasks\":{\"sum\":1,\"count\":1,\"avg\":1,\"max\":1,\"min\":1}},\"Stage=201993\":{\"BuildCpuTimeUs\":{\"sum\":\"88ms\",\"count\":1,\"avg\":\"88ms\",\"max\":\"88ms\",\"min\":\"88ms\"},\"ComputeCpuTimeUs\":{\"sum\":\"64us\",\"count\":1,\"avg\":\"64us\",\"max\":\"64us\",\"min\":\"64us\"},\"CpuTimeUs\":{\"sum\":\"97ms\",\"count\":1,\"avg\":\"97ms\",\"max\":\"97ms\",\"min\":\"97ms\"},\"EgressBytes\":{\"sum\":124,\"count\":1,\"avg\":124,\"max\":124,\"min\":124},\"EgressRows\":{\"sum\":4,\"count\":1,\"avg\":4,\"max\":4,\"min\":4},\"IngressQueuedBytes\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"IngressQueuedRows\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"MkqlMaxMemoryUsage\":{\"sum\":2031616,\"count\":1,\"avg\":2031616,\"max\":2031616,\"min\":2031616},\"MultiHop_EarlyThrownEventsCount\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"MultiHop_LateThrownEventsCount\":{\"sum\":0,\"count\":1,\"avg\":0,\"max\":0,\"min\":0},\"Tasks\":{\"sum\":1,\"count\":1,\"avg\":1,\"max\":1,\"min\":1}},\"Stage=Total\":{\"BuildCpuTimeUs\":{\"sum\":\"0.14s\",\"count\":2,\"avg\":\"70ms\",\"max\":\"88ms\",\"min\":\"52ms\"},\"ComputeCpuTimeUs\":{\"sum\":\"114us\",\"count\":2,\"avg\":\"57us\",\"max\":\"64us\",\"min\":\"50us\"},\"CpuTimeUs\":{\"sum\":\"0.15s\",\"count\":2,\"avg\":\"77ms\",\"max\":\"97ms\",\"min\":\"57ms\"},\"EgressBytes\":{\"sum\":124,\"count\":1,\"avg\":124,\"max\":124,\"min\":124},\"EgressRows\":{\"sum\":4,\"count\":1,\"avg\":4,\"max\":4,\"min\":4},\"IngressQueuedBytes\":{\"sum\":0,\"count\":2,\"avg\":0,\"max\":0,\"min\":0},\"IngressQueuedRows\":{\"sum\":0,\"count\":2,\"avg\":0,\"max\":0,\"min\":0},\"MkqlMaxMemoryUsage\":{\"sum\":4063232,\"count\":2,\"avg\":2031616,\"max\":2031616,\"min\":2031616},\"MultiHop_EarlyThrownEventsCount\":{\"sum\":0,\"count\":2,\"avg\":0,\"max\":0,\"min\":0},\"MultiHop_LateThrownEventsCount\":{\"sum\":0,\"count\":2,\"avg\":0,\"max\":0,\"min\":0},\"Tasks\":{\"sum\":2,\"count\":2,\"avg\":1,\"max\":1,\"min\":1}}},\"UniqueWorkers\":{\"sum\":2,\"count\":1,\"avg\":2,\"max\":2,\"min\":2}}}" resources { rate_limiter: READY compilation: READY topic_consumers_state: READY rate_limiter_path: "local/RateLimiter_755dc3ae-6741-4057-8e98-960aa5272d3f/rate_limiter" topic_consumers { database: "local" topic_path: "test_group_by_hop_restart_node_input" consumer_name: "ptqudq7uffpn58fsu002" cluster_endpoint: "localhost:23627" token_name: "cluster:default_yds" add_bearer_to_token: true } } finished_at { seconds: 1765542459 nanos: 263000000 } }
2025-12-12T12:27:39.318930Z :FQ_PINGER TRACE: pinger.cpp:393: QueryId: ptqudq7uffpn58fsu002, Owner: 6734039d-3c6d3147-8d4aa390-5370ecbe19 Forward request Private::PingTask
2025-12-12T12:27:39.407273Z :FQ_PINGER TRACE: pinger.cpp:338: QueryId: ptqudq7uffpn58fsu002, Owner: 6734039d-3c6d3147-8d4aa390-5370ecbe19 Ping response success: { action: ABORT }
2025-12-12T12:27:39.407310Z :FQ_PINGER DEBUG: pinger.cpp:379: QueryId: ptqudq7uffpn58fsu002, Owner: 6734039d-3c6d3147-8d4aa390-5370ecbe19 Query finished
2025-12-12T12:27:39.407315Z :FQ_PINGER TRACE: pinger.cpp:187: QueryId: ptqudq7uffpn58fsu002, Owner: 6734039d-3c6d3147-8d4aa390-5370ecbe19 Stop Pinger
2025-12-12T12:27:40.178492Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-12-12T12:27:40.183834Z :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:40.189729Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 6734039d-3c6d3147-8d4aa390-5370ecbe27, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:40.195261Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:40.195285Z :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.189839Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [2:7582946963833380804:2115]
2025-12-12T12:27:41.189875Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:41.190188Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 6734039d-3c6d3147-8d4aa390-5370ecbe28, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:41.190654Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:41.201081Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:41.201108Z :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.190628Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 6734039d-3c6d3147-8d4aa390-5370ecbe29, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:42.207166Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:42.207191Z :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.190179Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [2:7582946963833380804:2115]
2025-12-12T12:27:43.190205Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:43.190675Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:43.191053Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 6734039d-3c6d3147-8d4aa390-5370ecbe30, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:43.196944Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:43.196978Z :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.191528Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 6734039d-3c6d3147-8d4aa390-5370ecbe31, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:44.199494Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:44.199523Z :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.178641Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-12-12T12:27:45.185084Z :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:45.190985Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [2:7582946963833380804:2115]
2025-12-12T12:27:45.191022Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:45.191591Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:45.192031Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 6734039d-3c6d3147-8d4aa390-5370ecbe32, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:45.198699Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:45.198720Z :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.192451Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 6734039d-3c6d3147-8d4aa390-5370ecbe33, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:46.204474Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:46.204506Z :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.883550Z :INTERCONNECT_NETWORK NOTICE: interconnect_tcp_input_session.cpp:712: [1 <-> 2] connection closed by peer
2025-12-12T12:27:46.884818Z :INTERCONNECT_NETWORK NOTICE: interconnect_handshake.cpp:1262: [1 <-> 2] network-related error occured on handshake: outgoing handshake Peer# ghrun-fhkyrtz6p4(127.0.1.1:20011) Socket error# Connection reset by peer state# ReceiveResponse processed# 0 remain# 52
2025-12-12T12:27:46.891951Z :INTERCONNECT_NETWORK NOTICE: interconnect_tcp_input_session.cpp:712: [1 <-> 3] connection closed by peer
2025-12-12T12:27:46.892789Z :INTERCONNECT_NETWORK NOTICE: interconnect_handshake.cpp:1262: [1 <-> 3] network-related error occured on handshake: outgoing handshake Peer# ghrun-fhkyrtz6p4(127.0.1.1:10641) Couldn't connect to any resolved address
2025-12-12T12:27:46.893266Z :INTERCONNECT_NETWORK NOTICE: interconnect_handshake.cpp:1262: [1 <-> 2] network-related error occured on handshake: outgoing handshake Peer# ghrun-fhkyrtz6p4(127.0.1.1:20011) Couldn't connect to any resolved address
