2025-11-11T14:17:14.697224Z :GRPC_SERVER NOTICE: grpc_request_proxy.cpp:369: Grpc request proxy started, nodeid# 2, serve as static node
2025-11-11T14:17:14.697286Z :GRPC_SERVER CRIT: grpc_request_proxy.cpp:429: Failed to deliver subscription request to config dispatcher
2025-11-11T14:17:14.697291Z :GRPC_SERVER NOTICE: grpc_request_proxy.cpp:369: Grpc request proxy started, nodeid# 2, serve as static node
2025-11-11T14:17:14.697306Z :GRPC_SERVER CRIT: grpc_request_proxy.cpp:429: Failed to deliver subscription request to config dispatcher
2025-11-11T14:17:14.697496Z :FQ_LOG_UPDATER DEBUG: log.cpp:93: Updated YQL logs priority: 8
2025-11-11T14:17:14.697500Z :FQ_LOG_UPDATER CRIT: log.cpp:55: Failed to deliver subscription request to config dispatcher.
2025-11-11T14:17:14.697539Z :YQ_RATE_LIMITER INFO: quoter_service.cpp:124: Bootstraping with config: { Enabled: true DataPlaneEnabled: true Database { Endpoint: "localhost:21280" Database: "local" TablePrefix: "RateLimiter_1dfa93e9-7ae7-41be-8d4a-a0eaa08e4eb5" } Limiters { CoordinationNodePath: "rate_limiter" } }
2025-11-11T14:17:14.697590Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:188: Bootstrap
2025-11-11T14:17:14.697594Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:191: Create sdk ydb connection
2025-11-11T14:17:14.697909Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:534: RowDispatcher: Successfully bootstrapped row dispatcher, id [2:7571471723215440358:2063], tenant /compute
2025-11-11T14:17:14.698018Z :YQL_NODES_MANAGER INFO: nodes_manager.cpp:88: Bootstrap, InstanceId: 430d501d-414c9834-14d304ab-6ca2123d
2025-11-11T14:17:14.698020Z :YQL_NODES_MANAGER DEBUG: nodes_manager.cpp:310: TNodesManagerActor::ResolveSelfAddress
2025-11-11T14:17:14.698034Z :YQ_TEST_CONNECTION DEBUG: test_connection.cpp:142: Starting yandex query test connection. Actor id: [2:7571471723215440363:2068]
2025-11-11T14:17:14.698074Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: ce7c8944-b9fd8a69-ddce038c-d38dc91a1, Host: ghrun-vb3yoermsa, Tenant: /compute
2025-11-11T14:17:14.698106Z :FQ_QUOTA_PROXY INFO: quota_proxy.cpp:90: STARTED
2025-11-11T14:17:14.699222Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:267: Coordinator: Successfully bootstrapped coordinator, id [2:7571471723215440396:2082], NodesManagerId [0:4705493345362661702:78]
2025-11-11T14:17:14.699233Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:232: TLeaderElection [2:7571471723215440397:2083] Successfully bootstrapped, local coordinator id [2:7571471723215440396:2082], tenant id compute, local mode 0, coordination node path local/row_dispatcher/compute, endpoint localhost:21280
2025-11-11T14:17:14.699649Z :FQ_QUOTA_SERVICE INFO: quota_manager.cpp:196: STARTED
2025-11-11T14:17:14.699890Z :STREAMS_STORAGE_SERVICE TRACE: storage_proxy.cpp:213: Initialize
2025-11-11T14:17:14.700001Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:209: Successfully bootstrapped TStorageProxy [2:7571471723215440357:2062] with connection to localhost:21280:local
2025-11-11T14:17:14.700011Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:627: RowDispatcher: TEvCoordinatorChangesSubscribe from [2:7571471723215440396:2082]
2025-11-11T14:17:14.700136Z :MEMORY_PROFILER NOTICE: monitor.cpp:332: Bootstrapped
2025-11-11T14:17:14.700189Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-11-11T14:17:14.701118Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:71: Run create coordination node "local/row_dispatcher/compute" actor
2025-11-11T14:17:14.701130Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:113: Call create coordination node "local/row_dispatcher/compute"
2025-11-11T14:17:14.701133Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:411: Call create coordination node "local/row_dispatcher/compute"
2025-11-11T14:17:14.701266Z :SCHEME_BOARD_SUBSCRIBER NOTICE: subscriber.cpp:849: [main][2:7571471723215440377:2077][/Root] Set up state: owner# [2:7571471723215440337:2052], state# { Deleted: 1 Strong: 0 Version: <Invalid> DomainId: <Invalid> AbandonedSchemeShards: there are 0 elements }
2025-11-11T14:17:14.701273Z :SCHEME_BOARD_SUBSCRIBER NOTICE: subscriber.cpp:849: [main][2:7571471723215440378:2078][/compute] Set up state: owner# [2:7571471723215440337:2052], state# { Deleted: 1 Strong: 0 Version: <Invalid> DomainId: <Invalid> AbandonedSchemeShards: there are 0 elements }
2025-11-11T14:17:14.701296Z :GRPC_SERVER WARN: grpc_request_proxy.cpp:572: SchemeBoardDelete /Root Strong=0
2025-11-11T14:17:14.701297Z :SCHEME_BOARD_SUBSCRIBER NOTICE: subscriber.cpp:849: [main][2:7571471723215440380:2080][/compute] Set up state: owner# [2:7571471723215440338:2053], state# { Deleted: 1 Strong: 0 Version: <Invalid> DomainId: <Invalid> AbandonedSchemeShards: there are 0 elements }
2025-11-11T14:17:14.701298Z :GRPC_SERVER WARN: grpc_request_proxy.cpp:572: SchemeBoardDelete /compute Strong=0
2025-11-11T14:17:14.701302Z :GRPC_SERVER WARN: grpc_request_proxy.cpp:572: SchemeBoardDelete /compute Strong=0
2025-11-11T14:17:14.701306Z :SCHEME_BOARD_SUBSCRIBER NOTICE: subscriber.cpp:849: [main][2:7571471723215440379:2079][/Root] Set up state: owner# [2:7571471723215440338:2053], state# { Deleted: 1 Strong: 0 Version: <Invalid> DomainId: <Invalid> AbandonedSchemeShards: there are 0 elements }
2025-11-11T14:17:14.701316Z :GRPC_SERVER WARN: grpc_request_proxy.cpp:572: SchemeBoardDelete /Root Strong=0
2025-11-11T14:17:14.708554Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:155: Successfully created coordination node "local/row_dispatcher/compute"
2025-11-11T14:17:14.708573Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:122: Reply for create coordination node "local/row_dispatcher/compute": { <main>: Error: Check failed: path: '/local/row_dispatcher/compute', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 29], type: EPathTypeKesus, state: EPathStateNoChanges), source_location: ydb/core/tx/schemeshard/schemeshard__operation_create_kesus.cpp:339 }
2025-11-11T14:17:14.708588Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:345: TLeaderElection [2:7571471723215440397:2083] Coordination node successfully created
2025-11-11T14:17:14.708591Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:323: TLeaderElection [2:7571471723215440397:2083] Start session
2025-11-11T14:17:14.709393Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-11T14:17:14.709404Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-11T14:17:14.710062Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:499: Checkpoint storage and state storage were successfully inited
2025-11-11T14:17:14.710679Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:359: TLeaderElection [2:7571471723215440397:2083] Session successfully created
2025-11-11T14:17:14.711752Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:372: TLeaderElection [2:7571471723215440397:2083] Semaphore successfully created
2025-11-11T14:17:14.711760Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:304: TLeaderElection [2:7571471723215440397:2083] Try to acquire semaphore
2025-11-11T14:17:14.711841Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:420: TLeaderElection [2:7571471723215440397:2083] Describe semaphore
2025-11-11T14:17:14.712466Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:389: Send NodeInfo with size: 1 to DynamicNameserver
2025-11-11T14:17:14.712728Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:469: TLeaderElection [2:7571471723215440397:2083] Semaphore successfully described: coordinator id [1:7571471682112226299:2082] generation 1
2025-11-11T14:17:14.712736Z :FQ_ROW_DISPATCHER INFO: leader_election.cpp:471: TLeaderElection [2:7571471723215440397:2083] Send TEvCoordinatorChanged to [2:7571471723215440358:2063], new coordinator id [1:7571471682112226299:2082], previous coordinator id [0:0:0]
2025-11-11T14:17:14.712752Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:559: RowDispatcher: Coordinator changed, old leader (empty maybe), new [1:7571471682112226299:2082] generation 1
2025-11-11T14:17:14.712775Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:386: Coordinator: New leader [1:7571471682112226299:2082], SelfId [2:7571471723215440396:2082]
2025-11-11T14:17:14.712788Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:597: RowDispatcher: TEvUndelivered, from [1:7571471682112226299:2082], reason Disconnected
2025-11-11T14:17:14.776218Z :INTERCONNECT WARN: interconnect_handshake.cpp:543: Handshake [2:7571471723215440501:2052] [node 1] ICH09 Neither CompatibilityInfo nor VersionTag of the peer can be validated, accepting by default
2025-11-11T14:17:15.199143Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ce7c8944-b9fd8a69-ddce038c-d38dc91a 2025-11-11 14:17:15.199 DEBUG ydbd(pid=985965, tid=0x00007F9C77E71640) [DQ] local_worker_manager.cpp:416: TEvFreeWorkersNotify 562954248388609
2025-11-11T14:17:15.199161Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ce7c8944-b9fd8a69-ddce038c-d38dc91a 2025-11-11 14:17:15.199 DEBUG ydbd(pid=985965, tid=0x00007F9C77E71640) [DQ] local_worker_manager.cpp:440: Free Group 562954248388609
2025-11-11T14:17:15.696868Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: ce7c8944-b9fd8a69-ddce038c-d38dc91a2, Host: ghrun-vb3yoermsa, Tenant: /compute
2025-11-11T14:17:15.696873Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:542: Coordinator: Send TEvGetNodesRequest to NodesManager
2025-11-11T14:17:15.696883Z :YQL_NODES_MANAGER DEBUG: nodes_manager.cpp:300: TNodesManagerActor::TEvGetNodesRequest
2025-11-11T14:17:15.696890Z :FQ_ROW_DISPATCHER INFO: coordinator.cpp:573: Coordinator: Updated node info, node count: 2
2025-11-11T14:17:15.696962Z :FQ_QUOTA_SERVICE DEBUG: quota_manager.cpp:230: IC Peers[1]: [1]
2025-11-11T14:17:15.709612Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-11T14:17:15.709624Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 1
2025-11-11T14:17:15.709635Z :FQ_PENDING_FETCHER DEBUG: pending_fetcher.cpp:361: NewTask: Scope: yandexcloud://my_folder Id: ptqudslmp4acltli4k5i UserId: root@builtin AuthToken: **** (B6C6F477)
2025-11-11T14:17:15.709768Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: ce7c8944-b9fd8a69-ddce038c-d38dc91a3, Host: ghrun-vb3yoermsa, Tenant: /compute
2025-11-11T14:17:15.709771Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:375: QueryId: ptqudslmp4acltli4k5i Start run actor. Compute state: RUNNING
2025-11-11T14:17:15.709774Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:469: QueryId: ptqudslmp4acltli4k5i FillConnections
2025-11-11T14:17:15.709809Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:2333: QueryId: ptqudslmp4acltli4k5i Run actors params: { QueryId: ptqudslmp4acltli4k5i CloudId: mock_cloud UserId: root@builtin Owner: ce7c8944-b9fd8a69-ddce038c-d38dc91a2 PreviousQueryRevision: 2 Connections: 1 Bindings: 0 AccountIdSignatures: 0 QueryType: STREAMING ExecuteMode: RUN ResultId: ptrudslmovieopao97tk StateLoadMode: FROM_LAST_CHECKPOINT StreamingDisposition: { from_last_checkpoint { } } Status: RUNNING DqGraphs: 1 DqGraphIndex: 0 Resource.TopicConsumers: 1 }
2025-11-11T14:17:15.709840Z :FQ_PINGER TRACE: pinger.cpp:171: QueryId: ptqudslmp4acltli4k5i, Owner: ce7c8944-b9fd8a69-ddce038c-d38dc91a2 Start Pinger
2025-11-11T14:17:15.709887Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:911: QueryId: ptqudslmp4acltli4k5i Overall dq tasks: 2
2025-11-11T14:17:15.710005Z :FQ_PINGER TRACE: pinger.cpp:250: QueryId: ptqudslmp4acltli4k5i, Owner: ce7c8944-b9fd8a69-ddce038c-d38dc91a2 Forward ping request: { resources { rate_limiter: READY compilation: READY topic_consumers_state: READY rate_limiter_path: "local/RateLimiter_1dfa93e9-7ae7-41be-8d4a-a0eaa08e4eb5/rate_limiter" topic_consumers { database: "local" topic_path: "program_state_recovery_input" consumer_name: "ptqudslmp4acltli4k5i" cluster_endpoint: "localhost:21280" token_name: "cluster:default_myyds" add_bearer_to_token: true } } }
2025-11-11T14:17:15.710012Z :FQ_PINGER TRACE: pinger.cpp:393: QueryId: ptqudslmp4acltli4k5i, Owner: ce7c8944-b9fd8a69-ddce038c-d38dc91a2 Forward request Private::PingTask
2025-11-11T14:17:15.710034Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:1599: QueryId: ptqudslmp4acltli4k5i ResultWriter was NOT CREATED since ResultType is empty
2025-11-11T14:17:15.710106Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudslmp4acltli4k5i 2025-11-11 14:17:15.710 DEBUG ydbd(pid=985965, tid=0x00007F9C7666E640) [DQ] task_controller_impl.h:86: _RowsLimitPerWrite = 0
2025-11-11T14:17:15.710166Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:1653: QueryId: ptqudslmp4acltli4k5i Executer: [2:7571471727510407929:2276], Controller: [2:7571471727510407931:2278], ResultIdActor: [2:7571471727510407929:2276]
2025-11-11T14:17:15.710194Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudslmp4acltli4k5i 2025-11-11 14:17:15.710 DEBUG ydbd(pid=985965, tid=0x00007F9C7566C640) [DQ] executer_actor.cpp:140: {ptqudslmp4acltli4k5i} TDqExecuter::OnGraph
2025-11-11T14:17:15.710218Z :YQL_PROXY INFO: log.cpp:64: SessionId: ptqudslmp4acltli4k5i 2025-11-11 14:17:15.710 INFO  ydbd(pid=985965, tid=0x00007F9C7566C640) [DQ] executer_actor.cpp:157: {ptqudslmp4acltli4k5i} Trying to allocate 2 workers [EnableComputeActor=1]
2025-11-11T14:17:15.711031Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudslmp4acltli4k5i 2025-11-11 14:17:15.711 DEBUG ydbd(pid=985965, tid=0x00007F9C7566C640) [DQ] executer_actor.cpp:247: {ptqudslmp4acltli4k5i} Dq timeouts are set to: 0.000000s (global), 600.000000s (workers allocation fail), 30.000000s (workers allocation warn) 
2025-11-11T14:17:15.711628Z :YQL_NODES_MANAGER DEBUG: nodes_manager.cpp:125: TEvAllocateWorkersResponse Nodes {
  ResourceId: 4294967298
  Worker {
    NodeId: 2
    Guid: "430d501d-414c9834-14d304ab-6ca2123d,ghrun-vb3yoermsa"
  }
  Worker {
    NodeId: 1
    Guid: "bebb7d07-42b6cf18-ad2228aa-d732a0d7,ghrun-vb3yoermsa"
  }
}
2025-11-11T14:17:15.711789Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ce7c8944-b9fd8a69-ddce038c-d38dc91a 2025-11-11 14:17:15.711 DEBUG ydbd(pid=985965, tid=0x00007F9C77E71640) [DQ] local_worker_manager.cpp:316: {ptqudslmp4acltli4k5i} TLocalWorkerManager::TEvAllocateWorkersRequest 281479271677954
2025-11-11T14:17:15.711813Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ce7c8944-b9fd8a69-ddce038c-d38dc91a 2025-11-11 14:17:15.711 DEBUG ydbd(pid=985965, tid=0x00007F9C77E71640) [DQ] local_worker_manager.cpp:376: {ptqudslmp4acltli4k5i} Create compute actor: async
2025-11-11T14:17:15.713667Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-11T14:17:15.713675Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-11T14:17:15.720316Z :FQ_PINGER TRACE: pinger.cpp:338: QueryId: ptqudslmp4acltli4k5i, Owner: ce7c8944-b9fd8a69-ddce038c-d38dc91a2 Ping response success: { expired_at { seconds: 1762870655 nanos: 714000000 } }
2025-11-11T14:17:15.720350Z :FQ_RUN_ACTOR TRACE: run_actor.cpp:861: QueryId: ptqudslmp4acltli4k5i Forward ping response. Success: 1. Cookie: 0
2025-11-11T14:17:15.743415Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:134: SelfId: [2:7571471727510407933:2280], TxId: ptqudslmp4acltli4k5i, task: 1. Ctx: {}. Start compute actor [2:7571471727510407933:2280], task: 1
2025-11-11T14:17:15.743452Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:113: SelfId: [2:7571471727510407933:2280], TxId: ptqudslmp4acltli4k5i, task: 1. Ctx: {}. Use CPU quota: 1. Rate limiter resource: { "local/RateLimiter_1dfa93e9-7ae7-41be-8d4a-a0eaa08e4eb5/rate_limiter", "mock_cloud/my_folder/ptqudslmp4acltli4k5i" }
2025-11-11T14:17:15.743501Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudslmp4acltli4k5i 2025-11-11 14:17:15.743 DEBUG ydbd(pid=985965, tid=0x00007F9C7566C640) [DQ] executer_actor.cpp:358: {ptqudslmp4acltli4k5i} TDqExecuter::TEvAllocateWorkersResponse
2025-11-11T14:17:15.743521Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudslmp4acltli4k5i 2025-11-11 14:17:15.743 DEBUG ydbd(pid=985965, tid=0x00007F9C7566C640) [DQ] executer_actor.cpp:384: {ptqudslmp4acltli4k5i} Allocated resource 4294967298
2025-11-11T14:17:15.743552Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudslmp4acltli4k5i 2025-11-11 14:17:15.743 DEBUG ydbd(pid=985965, tid=0x00007F9C7566C640) [DQ] executer_actor.cpp:401: {ptqudslmp4acltli4k5i} WorkerInfo: Id:430d501d-414c9834-14d304ab-6ca2123d,ghrun-vb3yoermsa,NodeId:2,StageId:212165
2025-11-11T14:17:15.743556Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudslmp4acltli4k5i 2025-11-11 14:17:15.743 DEBUG ydbd(pid=985965, tid=0x00007F9C7566C640) [DQ] executer_actor.cpp:402: {ptqudslmp4acltli4k5i} TaskInfo: 0/1
2025-11-11T14:17:15.743560Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudslmp4acltli4k5i 2025-11-11 14:17:15.743 DEBUG ydbd(pid=985965, tid=0x00007F9C7566C640) [DQ] executer_actor.cpp:404: {ptqudslmp4acltli4k5i}  ObjectId: 8d73c3b672aec01e659c446142c7a17d47fb7b86, dq_vanilla_job.lite, 
2025-11-11T14:17:15.743576Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudslmp4acltli4k5i 2025-11-11 14:17:15.743 DEBUG ydbd(pid=985965, tid=0x00007F9C7566C640) [DQ] executer_actor.cpp:401: {ptqudslmp4acltli4k5i} WorkerInfo: Id:bebb7d07-42b6cf18-ad2228aa-d732a0d7,ghrun-vb3yoermsa,NodeId:1,StageId:212182
2025-11-11T14:17:15.743580Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudslmp4acltli4k5i 2025-11-11 14:17:15.743 DEBUG ydbd(pid=985965, tid=0x00007F9C7566C640) [DQ] executer_actor.cpp:402: {ptqudslmp4acltli4k5i} TaskInfo: 1/2
2025-11-11T14:17:15.743584Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudslmp4acltli4k5i 2025-11-11 14:17:15.743 DEBUG ydbd(pid=985965, tid=0x00007F9C7566C640) [DQ] executer_actor.cpp:404: {ptqudslmp4acltli4k5i}  ObjectId: 8d73c3b672aec01e659c446142c7a17d47fb7b86, dq_vanilla_job.lite, 
2025-11-11T14:17:15.743590Z :YQL_PROXY INFO: log.cpp:64: SessionId: ptqudslmp4acltli4k5i 2025-11-11 14:17:15.743 INFO  ydbd(pid=985965, tid=0x00007F9C7566C640) [DQ] executer_actor.cpp:415: {ptqudslmp4acltli4k5i} 2 workers allocated
2025-11-11T14:17:15.743702Z :YQL_PROXY TRACE: log.cpp:64: SessionId:  2025-11-11 14:17:15.743 TRACE ydbd(pid=985965, tid=0x00007F9C7566C640) [DQ] task_controller_impl.h:271:  [2:7571471727510407931:2278] ExportStats Summary
2025-11-11T14:17:15.743751Z :YQL_PROXY DEBUG: log.cpp:64: SessionId:  2025-11-11 14:17:15.743 DEBUG ydbd(pid=985965, tid=0x00007F9C7566C640) [DQ] task_controller_impl.h:526: Ready State: [2:7571471727510407931:2278]
2025-11-11T14:17:15.743757Z :YQL_PROXY DEBUG: log.cpp:64: SessionId:  2025-11-11 14:17:15.743 DEBUG ydbd(pid=985965, tid=0x00007F9C7566C640) [DQ] task_controller_impl.h:537: Forward: [2:7571471727510407931:2278] to [2:7571471727510407930:2277]
2025-11-11T14:17:15.743785Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:70: [ptqudslmp4acltli4k5i-0.2] TEvReadyState, streaming disposition { from_last_checkpoint { } }, state load mode FROM_LAST_CHECKPOINT, checkpointing period 1.000000s
2025-11-11T14:17:15.743797Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:104: [ptqudslmp4acltli4k5i-0.2] AllActors count: 2, ActorsToTrigger count: 1, ActorsToNotify count: 2, ActorsToWaitFor count: 2
2025-11-11T14:17:15.743800Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:114: [ptqudslmp4acltli4k5i-0.2] Send TEvRegisterCoordinatorRequest
2025-11-11T14:17:15.743807Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:229: [ptqudslmp4acltli4k5i-0.2] Got TEvRegisterCoordinatorRequest
2025-11-11T14:17:15.765146Z :YQL_PROXY TRACE: log.cpp:64: SessionId:  2025-11-11 14:17:15.765 TRACE ydbd(pid=985965, tid=0x00007F9C77E71640) [DQ] task_controller_impl.h:160: [2:7571471727510407931:2278] EvState TaskId: 2 State: 2 PingCookie: 0 StatusCode: UNSPECIFIED
2025-11-11T14:17:15.765167Z :YQL_PROXY TRACE: log.cpp:64: SessionId:  2025-11-11 14:17:15.765 TRACE ydbd(pid=985965, tid=0x00007F9C77E71640) [DQ] task_controller_impl.h:201:  [2:7571471727510407931:2278] Executing TaskId: 2
2025-11-11T14:17:15.765960Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:243: [ptqudslmp4acltli4k5i-0.2] Graph registered
2025-11-11T14:17:15.765969Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:245: [ptqudslmp4acltli4k5i-0.2] Send TEvRegisterCoordinatorResponse
2025-11-11T14:17:15.765999Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:131: [ptqudslmp4acltli4k5i-0.2] Got TEvRegisterCoordinatorResponse; issues: 
2025-11-11T14:17:15.766002Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:140: [ptqudslmp4acltli4k5i-0.2] Successfully registered in storage
2025-11-11T14:17:15.766004Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:141: [ptqudslmp4acltli4k5i-0.2] Send TEvNewCheckpointCoordinator to 2 actor(s)
2025-11-11T14:17:15.766016Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:149: [ptqudslmp4acltli4k5i-0.2] Send TEvGetCheckpointsMetadataRequest; state load mode: FROM_LAST_CHECKPOINT; load graph: 0
2025-11-11T14:17:15.766031Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:387: [ptqudslmp4acltli4k5i-0] Got TEvGetCheckpointsMetadataRequest
2025-11-11T14:17:15.766520Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:622: [ptqudslmp4acltli4k5i-0.2] Handle connected node 1
2025-11-11T14:17:15.814314Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:400: [ptqudslmp4acltli4k5i-0] Send TEvGetCheckpointsMetadataResponse
2025-11-11T14:17:15.814350Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:186: [ptqudslmp4acltli4k5i-0.2] Got TEvGetCheckpointsMetadataResponse
2025-11-11T14:17:15.814354Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:219: [ptqudslmp4acltli4k5i-0.2] Will restore from checkpoint 1:2
2025-11-11T14:17:15.824864Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:197: [] Task: 1. Got TEvNewCheckpointCoordinator event: generation 2, actorId: [2:7571471727510407930:2277]
2025-11-11T14:17:15.824874Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:208: [] Task: 1. Assign checkpoint coordinator (generation = 2)
2025-11-11T14:17:15.825499Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1370: SelfId: [2:7571471727510407933:2280], TxId: ptqudslmp4acltli4k5i, task: 1. Ctx: {}. Create source for input 0 { Source { Type: "PqSource" Settings { type_url: "type.googleapis.com/NYql.NPq.NProto.TDqPqTopicSource" value: "\n\034program_state_recovery_input\022\024ptqudslmp4acltli4k5i\032\017localhost:21280\"\027\n\025cluster:default_myyds*\005local0\002@\001b\004Dataj\025[\"DataType\";\"String\"]\222\001\024ptcudslmp4jgd3rf2kne\232\001\003raw\242\001/[\"StructType\";[[\"Data\";[\"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-11-11T14:17:15.825791Z :KQP_COMPUTE DEBUG: dq_pq_read_actor_base.cpp:153: SelfId: [0:0:0], TxId: ptqudslmp4acltli4k5i, task: 1. PQ source. SessionId: empty Watermarks enabled: 0 granularity: 0.000000s late arrival delay: 0.000000s idle: 0 idle delay: 0.000000s
2025-11-11T14:17:15.825854Z :YQL_PROXY TRACE: log.cpp:64: SessionId:  2025-11-11 14:17:15.825 TRACE ydbd(pid=985965, tid=0x00007F9C77E71640) [DQ] task_controller_impl.h:160: [2:7571471727510407931:2278] EvState TaskId: 1 State: 2 PingCookie: 0 StatusCode: UNSPECIFIED
2025-11-11T14:17:15.825872Z :YQL_PROXY TRACE: log.cpp:64: SessionId:  2025-11-11 14:17:15.825 TRACE ydbd(pid=985965, tid=0x00007F9C77E71640) [DQ] task_controller_impl.h:201:  [2:7571471727510407931:2278] Executing TaskId: 1
2025-11-11T14:17:15.825889Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:265: [ptqudslmp4acltli4k5i-0] Task: 1. [Checkpoint 1.2] TEvRestoreFromCheckpoint, StateLoadPlan = { StateType: STATE_TYPE_OWN }
2025-11-11T14:17:15.825899Z :YQL_PROXY DEBUG: log.cpp:64: SessionId:  2025-11-11 14:17:15.825 DEBUG ydbd(pid=985965, tid=0x00007F9C77E71640) [DQ] task_controller_impl.h:561: Update channels
2025-11-11T14:17:15.825911Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:457: [ptqudslmp4acltli4k5i-0] [1:2] Got TEvGetTaskState: tasks {1}
2025-11-11T14:17:15.825920Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:519: [ptqudslmp4acltli4k5i-0] [1:2] GetState, tasks: 1
2025-11-11T14:17:15.826575Z :YQL_PROXY TRACE: log.cpp:64: SessionId:  2025-11-11 14:17:15.825 TRACE ydbd(pid=985965, tid=0x00007F9C77E71640) [DQ] task_controller_impl.h:577: 1 Update { Id: 1 TransportVersion: DATA_TRANSPORT_UV_PICKLE_1_0 SrcTaskId: 1 DstTaskId: 2 SrcEndpoint { ActorId { RawX1: 7571471727510407933 RawX2: 4503608217307368 } } DstEndpoint { ActorId { RawX1: 7571471725061901339 RawX2: 4503603922341825 } } SrcStageId: 212165 DstStageId: 212182 }
2025-11-11T14:17:15.826613Z :YQL_PROXY TRACE: log.cpp:64: SessionId:  2025-11-11 14:17:15.826 TRACE ydbd(pid=985965, tid=0x00007F9C77E71640) [DQ] task_controller_impl.h:577: 2 Update { Id: 1 TransportVersion: DATA_TRANSPORT_UV_PICKLE_1_0 SrcTaskId: 1 DstTaskId: 2 SrcEndpoint { ActorId { RawX1: 7571471727510407933 RawX2: 4503608217307368 } } DstEndpoint { ActorId { RawX1: 7571471725061901339 RawX2: 4503603922341825 } } SrcStageId: 212165 DstStageId: 212182 }
2025-11-11T14:17:15.826639Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1074: SelfId: [2:7571471727510407933:2280], TxId: ptqudslmp4acltli4k5i, task: 1. Ctx: {}. Received channels info: Update { Id: 1 TransportVersion: DATA_TRANSPORT_UV_PICKLE_1_0 SrcTaskId: 1 DstTaskId: 2 SrcEndpoint { ActorId { RawX1: 7571471727510407933 RawX2: 4503608217307368 } } DstEndpoint { ActorId { RawX1: 7571471725061901339 RawX2: 4503603922341825 } } SrcStageId: 212165 DstStageId: 212182 }
2025-11-11T14:17:15.826642Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1093: SelfId: [2:7571471727510407933:2280], TxId: ptqudslmp4acltli4k5i, task: 1. Ctx: {}. Update output channelId: 1, peer: [1:7571471725061901339:4033]
2025-11-11T14:17:15.878450Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:654: [ptqudslmp4acltli4k5i-0] [1:2] ListOfStates results:
2025-11-11T14:17:15.878475Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:675: [ptqudslmp4acltli4k5i-0] [1:2] taskId 1 checkpoint id: 1:3, rows count: 1
2025-11-11T14:17:15.878478Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:675: [ptqudslmp4acltli4k5i-0] [1:2] taskId 1 checkpoint id: 1:2, rows count: 1
2025-11-11T14:17:15.878480Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:675: [ptqudslmp4acltli4k5i-0] [1:2] taskId 1 checkpoint id: 1:1, rows count: 1
2025-11-11T14:17:15.878488Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:901: [ptqudslmp4acltli4k5i-0] [1:2] SkipStatesInFuture, skip 1 checkpoints
2025-11-11T14:17:15.878542Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:796: [ptqudslmp4acltli4k5i-0] [1:2] SelectState: task_id 1, seq_no 2, blob_seq_num 0
2025-11-11T14:17:15.929741Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:410: [ptqudslmp4acltli4k5i-0] [1:2] DeserializeState, task id 1, blob size 122
2025-11-11T14:17:15.929772Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:960: [ptqudslmp4acltli4k5i-0] [1:2] ApplyIncrements
2025-11-11T14:17:15.929901Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:476: [ptqudslmp4acltli4k5i-0] [{ Id: 2 Generation: 1 }] Send TEvGetTaskStateResult: tasks: {1}
2025-11-11T14:17:15.929941Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:336: [ptqudslmp4acltli4k5i-0] Task: 1. [Checkpoint 1.2] TEvGetTaskStateResult: restoring state
2025-11-11T14:17:15.929953Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:792: SelfId: [2:7571471727510407933:2280], TxId: ptqudslmp4acltli4k5i, task: 1. Ctx: {}. Load state
2025-11-11T14:17:15.929969Z :KQP_COMPUTE DEBUG: dq_pq_read_actor_base.cpp:153: SelfId: [0:0:0], TxId: ptqudslmp4acltli4k5i, task: 1. PQ source. SessionId: empty Watermarks enabled: 0 granularity: 0.000000s late arrival delay: 0.000000s idle: 0 idle delay: 0.000000s
2025-11-11T14:17:15.929994Z :KQP_COMPUTE DEBUG: dq_pq_read_actor_base.cpp:133: SelfId: [0:0:0], TxId: ptqudslmp4acltli4k5i, task: 1. PQ source. SessionId: empty StartingMessageTs 2025-11-11T14:17:11.665000Z Restoring offset: {0@,8},
2025-11-11T14:17:15.930012Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:362: [ptqudslmp4acltli4k5i-0] Task: 1. [Checkpoint 1.2] Checkpoint state restored
2025-11-11T14:17:15.930039Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:297: [ptqudslmp4acltli4k5i-0.2] [1:2] Got TEvRestoreFromCheckpointResult; taskId: 1, checkpoint: 1:2, status: OK, issues: 
2025-11-11T14:17:15.930050Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:320: [ptqudslmp4acltli4k5i-0.2] [1:2] Task state restored, need 1 more acks
2025-11-11T14:17:15.930427Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:297: [ptqudslmp4acltli4k5i-0.2] [1:2] Got TEvRestoreFromCheckpointResult; taskId: 2, checkpoint: 1:2, status: OK, issues: 
2025-11-11T14:17:15.930441Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:320: [ptqudslmp4acltli4k5i-0.2] [1:2] Task state restored, need 0 more acks
2025-11-11T14:17:15.930445Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:445: [ptqudslmp4acltli4k5i-0.2] Send TEvRun to all actors
2025-11-11T14:17:15.930470Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1174: SelfId: [2:7571471727510407933:2280], TxId: ptqudslmp4acltli4k5i, task: 1. Ctx: {}. Got TEvRun from actor [2:7571471727510407930:2277]
2025-11-11T14:17:15.930480Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1491: SelfId: [2:7571471727510407933:2280], TxId: ptqudslmp4acltli4k5i, task: 1. Ctx: {}. Poll inputs
2025-11-11T14:17:15.930483Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1506: SelfId: [2:7571471727510407933:2280], TxId: ptqudslmp4acltli4k5i, task: 1. Ctx: {}. Poll sources
2025-11-11T14:17:15.930489Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:533: SelfId: [0:0:0], TxId: ptqudslmp4acltli4k5i, task: 1. PQ source. SessionId: empty GetAsyncInputData freeSpace = 1
2025-11-11T14:17:15.930527Z :KQP_COMPUTE DEBUG: dq_pq_read_actor.cpp:635: SelfId: [0:0:0], TxId: ptqudslmp4acltli4k5i, task: 1. PQ source. SessionId: empty PartitionsToRead: 0
2025-11-11T14:17:15.930564Z :YDB_SDK INFO: actor.cpp:37: 2025-11-11T14:17:15.930559Z :INFO: [local] [local] [d653b33c-801bd0e2-e1c6fe2-e1ff53c4] Starting read session
2025-11-11T14:17:15.930574Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:17:15.930571Z :DEBUG: [local] [local] [d653b33c-801bd0e2-e1c6fe2-e1ff53c4] Starting single session
2025-11-11T14:17:15.930613Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:17:15.930610Z :DEBUG: [local] [local] [d653b33c-801bd0e2-e1c6fe2-e1ff53c4] [] In Reconnect, ReadSizeBudget = 8388608, ReadSizeServerDelta = 0
2025-11-11T14:17:15.930623Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:17:15.930621Z :DEBUG: [local] [local] [d653b33c-801bd0e2-e1c6fe2-e1ff53c4] [] New values: ReadSizeBudget = 8388608, ReadSizeServerDelta = 0
2025-11-11T14:17:15.930627Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:17:15.930626Z :DEBUG: [local] [local] [d653b33c-801bd0e2-e1c6fe2-e1ff53c4] [] Reconnecting session to cluster  in 0.000000s
2025-11-11T14:17:15.930885Z :KQP_COMPUTE INFO: dq_pq_read_actor.cpp:306: SelfId: [0:0:0], TxId: ptqudslmp4acltli4k5i, task: 1. PQ source. SessionId: d653b33c-801bd0e2-e1c6fe2-e1ff53c4 CreateReadSession
2025-11-11T14:17:15.930912Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:77: SelfId: [2:7571471727510407933:2280], TxId: ptqudslmp4acltli4k5i, task: 1. Ctx: {}. Poll async input 0. Buffer free space: 1, read from async input: 0 bytes, 0 rows, finished: 0
2025-11-11T14:17:15.930916Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:17:15.930898Z :DEBUG: [local] [local] [d653b33c-801bd0e2-e1c6fe2-e1ff53c4] [] Successfully connected. Initializing session
2025-11-11T14:17:15.930938Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [2:7571471727510407933:2280], TxId: ptqudslmp4acltli4k5i, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-11-11T14:17:15.930982Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ce7c8944-b9fd8a69-ddce038c-d38dc91a 2025-11-11 14:17:15.930 DEBUG ydbd(pid=985965, tid=0x00007F9C77E71640) [DQ] tasks_runner_local.cpp:267: {TODO/1} Run task: 1
2025-11-11T14:17:15.931009Z :KQP_COMPUTE TRACE: dq_compute_memory_quota.h:97: TxId: ptqudslmp4acltli4k5i, task: 1. Peak memory usage: 2031616
2025-11-11T14:17:15.931019Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [2:7571471727510407933:2280], TxId: ptqudslmp4acltli4k5i, task: 1. Ctx: {}. update task runner stats
2025-11-11T14:17:15.931039Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [2:7571471727510407933:2280], TxId: ptqudslmp4acltli4k5i, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-11T14:17:15.931046Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [2:7571471727510407933:2280], TxId: ptqudslmp4acltli4k5i, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-11T14:17:15.931051Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:532: SelfId: [2:7571471727510407933:2280], TxId: ptqudslmp4acltli4k5i, task: 1. Ctx: {}. About to drain channelId: 1, hasPeer: 1, peerState:(freeSpace:1000000;inFlightBytes:0;inFlightCount:0;)
2025-11-11T14:17:15.931055Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1105: SelfId: [2:7571471727510407933:2280], TxId: ptqudslmp4acltli4k5i, task: 1. Ctx: {}. Ask CPU quota: 84ms
2025-11-11T14:17:15.931808Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1162: SelfId: [2:7571471727510407933:2280], TxId: ptqudslmp4acltli4k5i, task: 1. Ctx: {}. CPU quota delay: 0ms
2025-11-11T14:17:15.931847Z :YDB_SDK INFO: actor.cpp:37: 2025-11-11T14:17:15.931839Z :INFO: [local] [local] [d653b33c-801bd0e2-e1c6fe2-e1ff53c4] [] Got InitResponse. ReadSessionId: ptqudslmp4acltli4k5i_1_3_17852496350339982129_v1
2025-11-11T14:17:15.931859Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:17:15.931857Z :DEBUG: [local] [local] [d653b33c-801bd0e2-e1c6fe2-e1ff53c4] [] In ContinueReadingDataImpl, ReadSizeBudget = 8388608, ReadSizeServerDelta = 0
2025-11-11T14:17:15.931914Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:17:15.931911Z :DEBUG: [local] [local] [d653b33c-801bd0e2-e1c6fe2-e1ff53c4] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 8388608
2025-11-11T14:17:15.933575Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:354: SelfId: [0:0:0], TxId: ptqudslmp4acltli4k5i, task: 1. PQ source. SessionId: d653b33c-801bd0e2-e1c6fe2-e1ff53c4 Source data ready
2025-11-11T14:17:15.933595Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1491: SelfId: [2:7571471727510407933:2280], TxId: ptqudslmp4acltli4k5i, task: 1. Ctx: {}. Poll inputs
2025-11-11T14:17:15.933599Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1506: SelfId: [2:7571471727510407933:2280], TxId: ptqudslmp4acltli4k5i, task: 1. Ctx: {}. Poll sources
2025-11-11T14:17:15.933604Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:533: SelfId: [0:0:0], TxId: ptqudslmp4acltli4k5i, task: 1. PQ source. SessionId: d653b33c-801bd0e2-e1c6fe2-e1ff53c4 GetAsyncInputData freeSpace = 1000000
2025-11-11T14:17:15.933621Z :KQP_COMPUTE DEBUG: dq_pq_read_actor.cpp:807: SelfId: [0:0:0], TxId: ptqudslmp4acltli4k5i, task: 1. PQ source. SessionId: d653b33c-801bd0e2-e1c6fe2-e1ff53c4 Key: 0@ StartPartitionSessionEvent received
2025-11-11T14:17:15.933625Z :KQP_COMPUTE DEBUG: dq_pq_read_actor.cpp:814: SelfId: [0:0:0], TxId: ptqudslmp4acltli4k5i, task: 1. PQ source. SessionId: d653b33c-801bd0e2-e1c6fe2-e1ff53c4 Key: 0@ Confirm StartPartitionSession with offset 8
2025-11-11T14:17:15.933635Z :YDB_SDK INFO: actor.cpp:37: 2025-11-11T14:17:15.933631Z :INFO: [local] [local] [d653b33c-801bd0e2-e1c6fe2-e1ff53c4] [] Confirm partition stream create. Partition stream id: 1. Cluster: "-". Topic: "program_state_recovery_input". Partition: 0. Read offset: 8
2025-11-11T14:17:15.933736Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:77: SelfId: [2:7571471727510407933:2280], TxId: ptqudslmp4acltli4k5i, task: 1. Ctx: {}. Poll async input 0. Buffer free space: 1000000, read from async input: 0 bytes, 0 rows, finished: 0
2025-11-11T14:17:15.933757Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:354: SelfId: [0:0:0], TxId: ptqudslmp4acltli4k5i, task: 1. PQ source. SessionId: d653b33c-801bd0e2-e1c6fe2-e1ff53c4 Source data ready
2025-11-11T14:17:15.933776Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [2:7571471727510407933:2280], TxId: ptqudslmp4acltli4k5i, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-11-11T14:17:15.933815Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ce7c8944-b9fd8a69-ddce038c-d38dc91a 2025-11-11 14:17:15.933 DEBUG ydbd(pid=985965, tid=0x00007F9C77E71640) [DQ] tasks_runner_local.cpp:267: {TODO/1} Run task: 1
2025-11-11T14:17:15.933840Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1491: SelfId: [2:7571471727510407933:2280], TxId: ptqudslmp4acltli4k5i, task: 1. Ctx: {}. Poll inputs
2025-11-11T14:17:15.933846Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1506: SelfId: [2:7571471727510407933:2280], TxId: ptqudslmp4acltli4k5i, task: 1. Ctx: {}. Poll sources
2025-11-11T14:17:15.933850Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:533: SelfId: [0:0:0], TxId: ptqudslmp4acltli4k5i, task: 1. PQ source. SessionId: d653b33c-801bd0e2-e1c6fe2-e1ff53c4 GetAsyncInputData freeSpace = 1000000
2025-11-11T14:17:15.933858Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:77: SelfId: [2:7571471727510407933:2280], TxId: ptqudslmp4acltli4k5i, task: 1. Ctx: {}. Poll async input 0. Buffer free space: 1000000, read from async input: 0 bytes, 0 rows, finished: 0
2025-11-11T14:17:15.933863Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [2:7571471727510407933:2280], TxId: ptqudslmp4acltli4k5i, task: 1. Ctx: {}. update task runner stats
2025-11-11T14:17:15.933889Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [2:7571471727510407933:2280], TxId: ptqudslmp4acltli4k5i, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-11T14:17:15.933896Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [2:7571471727510407933:2280], TxId: ptqudslmp4acltli4k5i, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-11T14:17:15.933902Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:532: SelfId: [2:7571471727510407933:2280], TxId: ptqudslmp4acltli4k5i, task: 1. Ctx: {}. About to drain channelId: 1, hasPeer: 1, peerState:(freeSpace:1000000;inFlightBytes:0;inFlightCount:0;)
2025-11-11T14:17:15.933906Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [2:7571471727510407933:2280], TxId: ptqudslmp4acltli4k5i, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-11-11T14:17:15.933925Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ce7c8944-b9fd8a69-ddce038c-d38dc91a 2025-11-11 14:17:15.933 DEBUG ydbd(pid=985965, tid=0x00007F9C77E71640) [DQ] tasks_runner_local.cpp:267: {TODO/1} Run task: 1
2025-11-11T14:17:15.933938Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [2:7571471727510407933:2280], TxId: ptqudslmp4acltli4k5i, task: 1. Ctx: {}. update task runner stats
2025-11-11T14:17:15.933946Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [2:7571471727510407933:2280], TxId: ptqudslmp4acltli4k5i, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-11T14:17:15.933948Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [2:7571471727510407933:2280], TxId: ptqudslmp4acltli4k5i, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-11T14:17:15.933950Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:532: SelfId: [2:7571471727510407933:2280], TxId: ptqudslmp4acltli4k5i, task: 1. Ctx: {}. About to drain channelId: 1, hasPeer: 1, peerState:(freeSpace:1000000;inFlightBytes:0;inFlightCount:0;)
2025-11-11T14:17:15.934334Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:17:15.934329Z :DEBUG: [local] [local] [d653b33c-801bd0e2-e1c6fe2-e1ff53c4] [] Got ReadResponse, serverBytesSize = 549, now ReadSizeBudget = 0, ReadSizeServerDelta = 8388059
2025-11-11T14:17:15.934358Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:17:15.934357Z :DEBUG: [local] [local] [d653b33c-801bd0e2-e1c6fe2-e1ff53c4] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 8388059
2025-11-11T14:17:15.934408Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:17:15.934406Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (8-21)
2025-11-11T14:17:15.934418Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:17:15.934416Z :DEBUG: [local] [local] [d653b33c-801bd0e2-e1c6fe2-e1ff53c4] [] Returning serverBytesSize = 549 to budget
2025-11-11T14:17:15.934421Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:17:15.934420Z :DEBUG: [local] [local] [d653b33c-801bd0e2-e1c6fe2-e1ff53c4] [] In ContinueReadingDataImpl, ReadSizeBudget = 549, ReadSizeServerDelta = 8388059
2025-11-11T14:17:15.934463Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:17:15.934462Z :DEBUG: [local] [local] [d653b33c-801bd0e2-e1c6fe2-e1ff53c4] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 8388608
2025-11-11T14:17:15.934499Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:354: SelfId: [0:0:0], TxId: ptqudslmp4acltli4k5i, task: 1. PQ source. SessionId: d653b33c-801bd0e2-e1c6fe2-e1ff53c4 Source data ready
2025-11-11T14:17:15.934510Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1491: SelfId: [2:7571471727510407933:2280], TxId: ptqudslmp4acltli4k5i, task: 1. Ctx: {}. Poll inputs
2025-11-11T14:17:15.934511Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1506: SelfId: [2:7571471727510407933:2280], TxId: ptqudslmp4acltli4k5i, task: 1. Ctx: {}. Poll sources
2025-11-11T14:17:15.934516Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:533: SelfId: [0:0:0], TxId: ptqudslmp4acltli4k5i, task: 1. PQ source. SessionId: d653b33c-801bd0e2-e1c6fe2-e1ff53c4 GetAsyncInputData freeSpace = 1000000
2025-11-11T14:17:15.934535Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:17:15.934532Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (8-8)
2025-11-11T14:17:15.934542Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:17:15.934540Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 1} (9-9)
2025-11-11T14:17:15.934547Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:17:15.934545Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 2} (10-10)
2025-11-11T14:17:15.934551Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:17:15.934549Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 3} (11-11)
2025-11-11T14:17:15.934556Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:17:15.934555Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 4} (12-12)
2025-11-11T14:17:15.934560Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:17:15.934559Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 5} (13-13)
2025-11-11T14:17:15.934564Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:17:15.934562Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 6} (14-14)
2025-11-11T14:17:15.934568Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:17:15.934566Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 7} (15-15)
2025-11-11T14:17:15.934574Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:17:15.934572Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 8} (16-16)
2025-11-11T14:17:15.934578Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:17:15.934576Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 9} (17-17)
2025-11-11T14:17:15.934582Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:17:15.934581Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 10} (18-18)
2025-11-11T14:17:15.934586Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:17:15.934584Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 11} (19-19)
2025-11-11T14:17:15.934590Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:17:15.934588Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 12} (20-20)
2025-11-11T14:17:15.934593Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:17:15.934592Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 13} (21-21)
2025-11-11T14:17:15.934603Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:17:15.934601Z :DEBUG: [local] [local] [d653b33c-801bd0e2-e1c6fe2-e1ff53c4] [] The application data is transferred to the client. Number of messages 14, size 210 bytes
2025-11-11T14:17:15.934610Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:17:15.934608Z :DEBUG: [local] [local] [d653b33c-801bd0e2-e1c6fe2-e1ff53c4] [] Returning serverBytesSize = 0 to budget
2025-11-11T14:17:15.934629Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:748: SelfId: [0:0:0], TxId: ptqudslmp4acltli4k5i, task: 1. PQ source. SessionId: d653b33c-801bd0e2-e1c6fe2-e1ff53c4 Key: 0@ Data received: Message { Data: "{"time" = 116;}" Information: { Offset: 8 ProducerId: "" SeqNo: 0 CreateTime: 2025-11-11T14:17:15.725000Z WriteTime: 2025-11-11T14:17:15.725000Z MessageGroupId: "" Meta: { } MessageMeta: { } } Partition session id: 1 Topic: "program_state_recovery_input" Partition: 0 }
2025-11-11T14:17:15.934651Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:748: SelfId: [0:0:0], TxId: ptqudslmp4acltli4k5i, task: 1. PQ source. SessionId: d653b33c-801bd0e2-e1c6fe2-e1ff53c4 Key: 0@ Data received: Message { Data: "{"time" = 118;}" Information: { Offset: 9 ProducerId: "" SeqNo: 0 CreateTime: 2025-11-11T14:17:15.725000Z WriteTime: 2025-11-11T14:17:15.725000Z MessageGroupId: "" Meta: { } MessageMeta: { } } Partition session id: 1 Topic: "program_state_recovery_input" Partition: 0 }
2025-11-11T14:17:15.934664Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:748: SelfId: [0:0:0], TxId: ptqudslmp4acltli4k5i, task: 1. PQ source. SessionId: d653b33c-801bd0e2-e1c6fe2-e1ff53c4 Key: 0@ Data received: Message { Data: "{"time" = 120;}" Information: { Offset: 10 ProducerId: "" SeqNo: 0 CreateTime: 2025-11-11T14:17:15.725000Z WriteTime: 2025-11-11T14:17:15.725000Z MessageGroupId: "" Meta: { } MessageMeta: { } } Partition session id: 1 Topic: "program_state_recovery_input" Partition: 0 }
2025-11-11T14:17:15.934668Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:748: SelfId: [0:0:0], TxId: ptqudslmp4acltli4k5i, task: 1. PQ source. SessionId: d653b33c-801bd0e2-e1c6fe2-e1ff53c4 Key: 0@ Data received: Message { Data: "{"time" = 122;}" Information: { Offset: 11 ProducerId: "" SeqNo: 0 CreateTime: 2025-11-11T14:17:15.725000Z WriteTime: 2025-11-11T14:17:15.725000Z MessageGroupId: "" Meta: { } MessageMeta: { } } Partition session id: 1 Topic: "program_state_recovery_input" Partition: 0 }
2025-11-11T14:17:15.934672Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:748: SelfId: [0:0:0], TxId: ptqudslmp4acltli4k5i, task: 1. PQ source. SessionId: d653b33c-801bd0e2-e1c6fe2-e1ff53c4 Key: 0@ Data received: Message { Data: "{"time" = 124;}" Information: { Offset: 12 ProducerId: "" SeqNo: 0 CreateTime: 2025-11-11T14:17:15.725000Z WriteTime: 2025-11-11T14:17:15.725000Z MessageGroupId: "" Meta: { } MessageMeta: { } } Partition session id: 1 Topic: "program_state_recovery_input" Partition: 0 }
2025-11-11T14:17:15.934675Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:748: SelfId: [0:0:0], TxId: ptqudslmp4acltli4k5i, task: 1. PQ source. SessionId: d653b33c-801bd0e2-e1c6fe2-e1ff53c4 Key: 0@ Data received: Message { Data: "{"time" = 126;}" Information: { Offset: 13 ProducerId: "" SeqNo: 0 CreateTime: 2025-11-11T14:17:15.725000Z WriteTime: 2025-11-11T14:17:15.725000Z MessageGroupId: "" Meta: { } MessageMeta: { } } Partition session id: 1 Topic: "program_state_recovery_input" Partition: 0 }
2025-11-11T14:17:15.934679Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:748: SelfId: [0:0:0], TxId: ptqudslmp4acltli4k5i, task: 1. PQ source. SessionId: d653b33c-801bd0e2-e1c6fe2-e1ff53c4 Key: 0@ Data received: Message { Data: "{"time" = 128;}" Information: { Offset: 14 ProducerId: "" SeqNo: 0 CreateTime: 2025-11-11T14:17:15.725000Z WriteTime: 2025-11-11T14:17:15.725000Z MessageGroupId: "" Meta: { } MessageMeta: { } } Partition session id: 1 Topic: "program_state_recovery_input" Partition: 0 }
2025-11-11T14:17:15.934683Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:748: SelfId: [0:0:0], TxId: ptqudslmp4acltli4k5i, task: 1. PQ source. SessionId: d653b33c-801bd0e2-e1c6fe2-e1ff53c4 Key: 0@ Data received: Message { Data: "{"time" = 130;}" Information: { Offset: 15 ProducerId: "" SeqNo: 0 CreateTime: 2025-11-11T14:17:15.725000Z WriteTime: 2025-11-11T14:17:15.725000Z MessageGroupId: "" Meta: { } MessageMeta: { } } Partition session id: 1 Topic: "program_state_recovery_input" Partition: 0 }
2025-11-11T14:17:15.934687Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:748: SelfId: [0:0:0], TxId: ptqudslmp4acltli4k5i, task: 1. PQ source. SessionId: d653b33c-801bd0e2-e1c6fe2-e1ff53c4 Key: 0@ Data received: Message { Data: "{"time" = 132;}" Information: { Offset: 16 ProducerId: "" SeqNo: 0 CreateTime: 2025-11-11T14:17:15.725000Z WriteTime: 2025-11-11T14:17:15.725000Z MessageGroupId: "" Meta: { } MessageMeta: { } } Partition session id: 1 Topic: "program_state_recovery_input" Partition: 0 }
2025-11-11T14:17:15.934690Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:748: SelfId: [0:0:0], TxId: ptqudslmp4acltli4k5i, task: 1. PQ source. SessionId: d653b33c-801bd0e2-e1c6fe2-e1ff53c4 Key: 0@ Data received: Message { Data: "{"time" = 134;}" Information: { Offset: 17 ProducerId: "" SeqNo: 0 CreateTime: 2025-11-11T14:17:15.725000Z WriteTime: 2025-11-11T14:17:15.725000Z MessageGroupId: "" Meta: { } MessageMeta: { } } Partition session id: 1 Topic: "program_state_recovery_input" Partition: 0 }
2025-11-11T14:17:15.934693Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:748: SelfId: [0:0:0], TxId: ptqudslmp4acltli4k5i, task: 1. PQ source. SessionId: d653b33c-801bd0e2-e1c6fe2-e1ff53c4 Key: 0@ Data received: Message { Data: "{"time" = 136;}" Information: { Offset: 18 ProducerId: "" SeqNo: 0 CreateTime: 2025-11-11T14:17:15.725000Z WriteTime: 2025-11-11T14:17:15.725000Z MessageGroupId: "" Meta: { } MessageMeta: { } } Partition session id: 1 Topic: "program_state_recovery_input" Partition: 0 }
2025-11-11T14:17:15.934697Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:748: SelfId: [0:0:0], TxId: ptqudslmp4acltli4k5i, task: 1. PQ source. SessionId: d653b33c-801bd0e2-e1c6fe2-e1ff53c4 Key: 0@ Data received: Message { Data: "{"time" = 138;}" Information: { Offset: 19 ProducerId: "" SeqNo: 0 CreateTime: 2025-11-11T14:17:15.725000Z WriteTime: 2025-11-11T14:17:15.725000Z MessageGroupId: "" Meta: { } MessageMeta: { } } Partition session id: 1 Topic: "program_state_recovery_input" Partition: 0 }
2025-11-11T14:17:15.934701Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:748: SelfId: [0:0:0], TxId: ptqudslmp4acltli4k5i, task: 1. PQ source. SessionId: d653b33c-801bd0e2-e1c6fe2-e1ff53c4 Key: 0@ Data received: Message { Data: "{"time" = 140;}" Information: { Offset: 20 ProducerId: "" SeqNo: 0 CreateTime: 2025-11-11T14:17:15.725000Z WriteTime: 2025-11-11T14:17:15.725000Z MessageGroupId: "" Meta: { } MessageMeta: { } } Partition session id: 1 Topic: "program_state_recovery_input" Partition: 0 }
2025-11-11T14:17:15.934711Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:748: SelfId: [0:0:0], TxId: ptqudslmp4acltli4k5i, task: 1. PQ source. SessionId: d653b33c-801bd0e2-e1c6fe2-e1ff53c4 Key: 0@ Data received: Message { Data: "{"time" = 142;}" Information: { Offset: 21 ProducerId: "" SeqNo: 0 CreateTime: 2025-11-11T14:17:15.725000Z WriteTime: 2025-11-11T14:17:15.725000Z MessageGroupId: "" Meta: { } MessageMeta: { } } Partition session id: 1 Topic: "program_state_recovery_input" Partition: 0 }
2025-11-11T14:17:15.934735Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:724: SelfId: [0:0:0], TxId: ptqudslmp4acltli4k5i, task: 1. PQ source. SessionId: d653b33c-801bd0e2-e1c6fe2-e1ff53c4 Return ready batch. DataCount = 14 Watermark = none Used space = 210
2025-11-11T14:17:15.934738Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:77: SelfId: [2:7571471727510407933:2280], TxId: ptqudslmp4acltli4k5i, task: 1. Ctx: {}. Poll async input 0. Buffer free space: 1000000, read from async input: 210 bytes, 14 rows, finished: 0
2025-11-11T14:17:15.934753Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:354: SelfId: [0:0:0], TxId: ptqudslmp4acltli4k5i, task: 1. PQ source. SessionId: d653b33c-801bd0e2-e1c6fe2-e1ff53c4 Source data ready
2025-11-11T14:17:15.934756Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [2:7571471727510407933:2280], TxId: ptqudslmp4acltli4k5i, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-11-11T14:17:15.934760Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1491: SelfId: [2:7571471727510407933:2280], TxId: ptqudslmp4acltli4k5i, task: 1. Ctx: {}. Poll inputs
2025-11-11T14:17:15.934772Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1506: SelfId: [2:7571471727510407933:2280], TxId: ptqudslmp4acltli4k5i, task: 1. Ctx: {}. Poll sources
2025-11-11T14:17:15.934774Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:533: SelfId: [0:0:0], TxId: ptqudslmp4acltli4k5i, task: 1. PQ source. SessionId: d653b33c-801bd0e2-e1c6fe2-e1ff53c4 GetAsyncInputData freeSpace = 999790
2025-11-11T14:17:15.934777Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:77: SelfId: [2:7571471727510407933:2280], TxId: ptqudslmp4acltli4k5i, task: 1. Ctx: {}. Poll async input 0. Buffer free space: 999790, read from async input: 0 bytes, 0 rows, finished: 0
2025-11-11T14:17:15.934803Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ce7c8944-b9fd8a69-ddce038c-d38dc91a 2025-11-11 14:17:15.934 DEBUG ydbd(pid=985965, tid=0x00007F9C77E71640) [DQ] tasks_runner_local.cpp:267: {TODO/1} Run task: 1
2025-11-11T14:17:15.934961Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [2:7571471727510407933:2280], TxId: ptqudslmp4acltli4k5i, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-11-11T14:17:15.934971Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1491: SelfId: [2:7571471727510407933:2280], TxId: ptqudslmp4acltli4k5i, task: 1. Ctx: {}. Poll inputs
2025-11-11T14:17:15.934972Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1506: SelfId: [2:7571471727510407933:2280], TxId: ptqudslmp4acltli4k5i, task: 1. Ctx: {}. Poll sources
2025-11-11T14:17:15.934975Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:533: SelfId: [0:0:0], TxId: ptqudslmp4acltli4k5i, task: 1. PQ source. SessionId: d653b33c-801bd0e2-e1c6fe2-e1ff53c4 GetAsyncInputData freeSpace = 999790
2025-11-11T14:17:15.934978Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:77: SelfId: [2:7571471727510407933:2280], TxId: ptqudslmp4acltli4k5i, task: 1. Ctx: {}. Poll async input 0. Buffer free space: 999790, read from async input: 0 bytes, 0 rows, finished: 0
2025-11-11T14:17:15.934982Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [2:7571471727510407933:2280], TxId: ptqudslmp4acltli4k5i, task: 1. Ctx: {}. update task runner stats
2025-11-11T14:17:15.934998Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [2:7571471727510407933:2280], TxId: ptqudslmp4acltli4k5i, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-11T14:17:15.935000Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [2:7571471727510407933:2280], TxId: ptqudslmp4acltli4k5i, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-11T14:17:15.935004Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:532: SelfId: [2:7571471727510407933:2280], TxId: ptqudslmp4acltli4k5i, task: 1. Ctx: {}. About to drain channelId: 1, hasPeer: 1, peerState:(freeSpace:1000000;inFlightBytes:0;inFlightCount:0;)
2025-11-11T14:17:15.935007Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [2:7571471727510407933:2280], TxId: ptqudslmp4acltli4k5i, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-11-11T14:17:15.935027Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ce7c8944-b9fd8a69-ddce038c-d38dc91a 2025-11-11 14:17:15.935 DEBUG ydbd(pid=985965, tid=0x00007F9C77E71640) [DQ] tasks_runner_local.cpp:267: {TODO/1} channelId: 1. Took 14 rows
2025-11-11T14:17:15.935039Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ce7c8944-b9fd8a69-ddce038c-d38dc91a 2025-11-11 14:17:15.935 DEBUG ydbd(pid=985965, tid=0x00007F9C77E71640) [DQ] tasks_runner_local.cpp:267: {TODO/1} Run task: 1
2025-11-11T14:17:15.935052Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:566: TxId: ptqudslmp4acltli4k5i, task: 1. SendChannelData, channelId: 1, peer: [1:7571471725061901339:4033], chunks: 14, bytes: 28, watermark: 0, checkpoint: 0, seqNo: 1, finished: 0
2025-11-11T14:17:15.935079Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [2:7571471727510407933:2280], TxId: ptqudslmp4acltli4k5i, task: 1. Ctx: {}. update task runner stats
2025-11-11T14:17:15.935090Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [2:7571471727510407933:2280], TxId: ptqudslmp4acltli4k5i, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-11T14:17:15.935091Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [2:7571471727510407933:2280], TxId: ptqudslmp4acltli4k5i, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-11T14:17:15.935093Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:532: SelfId: [2:7571471727510407933:2280], TxId: ptqudslmp4acltli4k5i, task: 1. Ctx: {}. About to drain channelId: 1, hasPeer: 1, peerState:(freeSpace:1000000;inFlightBytes:124;inFlightCount:1;)
2025-11-11T14:17:15.935096Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1491: SelfId: [2:7571471727510407933:2280], TxId: ptqudslmp4acltli4k5i, task: 1. Ctx: {}. Poll inputs
2025-11-11T14:17:15.935098Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1506: SelfId: [2:7571471727510407933:2280], TxId: ptqudslmp4acltli4k5i, task: 1. Ctx: {}. Poll sources
2025-11-11T14:17:15.935100Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:533: SelfId: [0:0:0], TxId: ptqudslmp4acltli4k5i, task: 1. PQ source. SessionId: d653b33c-801bd0e2-e1c6fe2-e1ff53c4 GetAsyncInputData freeSpace = 1000000
2025-11-11T14:17:15.935102Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:77: SelfId: [2:7571471727510407933:2280], TxId: ptqudslmp4acltli4k5i, task: 1. Ctx: {}. Poll async input 0. Buffer free space: 1000000, read from async input: 0 bytes, 0 rows, finished: 0
2025-11-11T14:17:15.935114Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ce7c8944-b9fd8a69-ddce038c-d38dc91a 2025-11-11 14:17:15.935 DEBUG ydbd(pid=985965, tid=0x00007F9C77E71640) [DQ] tasks_runner_local.cpp:267: {TODO/1} Run task: 1
2025-11-11T14:17:15.935118Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [2:7571471727510407933:2280], TxId: ptqudslmp4acltli4k5i, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-11-11T14:17:15.935120Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [2:7571471727510407933:2280], TxId: ptqudslmp4acltli4k5i, task: 1. Ctx: {}. update task runner stats
2025-11-11T14:17:15.935125Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [2:7571471727510407933:2280], TxId: ptqudslmp4acltli4k5i, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-11T14:17:15.935125Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [2:7571471727510407933:2280], TxId: ptqudslmp4acltli4k5i, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-11T14:17:15.935127Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:532: SelfId: [2:7571471727510407933:2280], TxId: ptqudslmp4acltli4k5i, task: 1. Ctx: {}. About to drain channelId: 1, hasPeer: 1, peerState:(freeSpace:1000000;inFlightBytes:124;inFlightCount:1;)
2025-11-11T14:17:15.935134Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ce7c8944-b9fd8a69-ddce038c-d38dc91a 2025-11-11 14:17:15.935 DEBUG ydbd(pid=985965, tid=0x00007F9C77E71640) [DQ] tasks_runner_local.cpp:267: {TODO/1} Run task: 1
2025-11-11T14:17:15.935138Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [2:7571471727510407933:2280], TxId: ptqudslmp4acltli4k5i, task: 1. Ctx: {}. update task runner stats
2025-11-11T14:17:15.935142Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [2:7571471727510407933:2280], TxId: ptqudslmp4acltli4k5i, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-11T14:17:15.935143Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [2:7571471727510407933:2280], TxId: ptqudslmp4acltli4k5i, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-11T14:17:15.935145Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:532: SelfId: [2:7571471727510407933:2280], TxId: ptqudslmp4acltli4k5i, task: 1. Ctx: {}. About to drain channelId: 1, hasPeer: 1, peerState:(freeSpace:1000000;inFlightBytes:124;inFlightCount:1;)
2025-11-11T14:17:15.935475Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:179: TxId: ptqudslmp4acltli4k5i, task: 1. Received channel data ack for channelId: 1, seqNo: 1, lastSentSeqNo: 1, freeSpace: 999972, early finish: 0
2025-11-11T14:17:15.935487Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:207: TxId: ptqudslmp4acltli4k5i, task: 1. PeerState, peerState:(freeSpace:999972;inFlightBytes:0;inFlightCount:0;), sentSeqNo: 1, ackSeqNo: 1
2025-11-11T14:17:15.935488Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:220: TxId: ptqudslmp4acltli4k5i, task: 1. Resume compute actor
2025-11-11T14:17:15.935495Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1491: SelfId: [2:7571471727510407933:2280], TxId: ptqudslmp4acltli4k5i, task: 1. Ctx: {}. Poll inputs
2025-11-11T14:17:15.935496Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1506: SelfId: [2:7571471727510407933:2280], TxId: ptqudslmp4acltli4k5i, task: 1. Ctx: {}. Poll sources
2025-11-11T14:17:15.935501Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:533: SelfId: [0:0:0], TxId: ptqudslmp4acltli4k5i, task: 1. PQ source. SessionId: d653b33c-801bd0e2-e1c6fe2-e1ff53c4 GetAsyncInputData freeSpace = 1000000
2025-11-11T14:17:15.935505Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:77: SelfId: [2:7571471727510407933:2280], TxId: ptqudslmp4acltli4k5i, task: 1. Ctx: {}. Poll async input 0. Buffer free space: 1000000, read from async input: 0 bytes, 0 rows, finished: 0
2025-11-11T14:17:15.935514Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [2:7571471727510407933:2280], TxId: ptqudslmp4acltli4k5i, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-11-11T14:17:15.935538Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ce7c8944-b9fd8a69-ddce038c-d38dc91a 2025-11-11 14:17:15.935 DEBUG ydbd(pid=985965, tid=0x00007F9C77E71640) [DQ] tasks_runner_local.cpp:267: {TODO/1} Run task: 1
2025-11-11T14:17:15.935552Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [2:7571471727510407933:2280], TxId: ptqudslmp4acltli4k5i, task: 1. Ctx: {}. update task runner stats
2025-11-11T14:17:15.935567Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [2:7571471727510407933:2280], TxId: ptqudslmp4acltli4k5i, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-11T14:17:15.935569Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [2:7571471727510407933:2280], TxId: ptqudslmp4acltli4k5i, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-11T14:17:15.935572Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:532: SelfId: [2:7571471727510407933:2280], TxId: ptqudslmp4acltli4k5i, task: 1. Ctx: {}. About to drain channelId: 1, hasPeer: 1, peerState:(freeSpace:999972;inFlightBytes:0;inFlightCount:0;)
2025-11-11T14:17:15.935826Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:179: TxId: ptqudslmp4acltli4k5i, task: 1. Received channel data ack for channelId: 1, seqNo: 1, lastSentSeqNo: 1, freeSpace: 1000000, early finish: 0
2025-11-11T14:17:15.935838Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:207: TxId: ptqudslmp4acltli4k5i, task: 1. PeerState, peerState:(freeSpace:1000000;inFlightBytes:0;inFlightCount:0;), sentSeqNo: 1, ackSeqNo: 1
2025-11-11T14:17:15.935840Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:220: TxId: ptqudslmp4acltli4k5i, task: 1. Resume compute actor
2025-11-11T14:17:15.935847Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1491: SelfId: [2:7571471727510407933:2280], TxId: ptqudslmp4acltli4k5i, task: 1. Ctx: {}. Poll inputs
2025-11-11T14:17:15.935849Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1506: SelfId: [2:7571471727510407933:2280], TxId: ptqudslmp4acltli4k5i, task: 1. Ctx: {}. Poll sources
2025-11-11T14:17:15.935854Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:533: SelfId: [0:0:0], TxId: ptqudslmp4acltli4k5i, task: 1. PQ source. SessionId: d653b33c-801bd0e2-e1c6fe2-e1ff53c4 GetAsyncInputData freeSpace = 1000000
2025-11-11T14:17:15.935858Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:77: SelfId: [2:7571471727510407933:2280], TxId: ptqudslmp4acltli4k5i, task: 1. Ctx: {}. Poll async input 0. Buffer free space: 1000000, read from async input: 0 bytes, 0 rows, finished: 0
2025-11-11T14:17:15.935867Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [2:7571471727510407933:2280], TxId: ptqudslmp4acltli4k5i, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-11-11T14:17:15.935889Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ce7c8944-b9fd8a69-ddce038c-d38dc91a 2025-11-11 14:17:15.935 DEBUG ydbd(pid=985965, tid=0x00007F9C77E71640) [DQ] tasks_runner_local.cpp:267: {TODO/1} Run task: 1
2025-11-11T14:17:15.935901Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [2:7571471727510407933:2280], TxId: ptqudslmp4acltli4k5i, task: 1. Ctx: {}. update task runner stats
2025-11-11T14:17:15.935921Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [2:7571471727510407933:2280], TxId: ptqudslmp4acltli4k5i, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-11T14:17:15.935926Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [2:7571471727510407933:2280], TxId: ptqudslmp4acltli4k5i, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-11T14:17:15.935929Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:532: SelfId: [2:7571471727510407933:2280], TxId: ptqudslmp4acltli4k5i, task: 1. Ctx: {}. About to drain channelId: 1, hasPeer: 1, peerState:(freeSpace:1000000;inFlightBytes:0;inFlightCount:0;)
2025-11-11T14:17:16.697265Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:617: RowDispatcher: Send ping to [1:7571471682112226299:2082]
2025-11-11T14:17:16.697293Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: ce7c8944-b9fd8a69-ddce038c-d38dc91a4, Host: ghrun-vb3yoermsa, Tenant: /compute
2025-11-11T14:17:16.697299Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1161: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-11-11T14:17:16.697672Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:623: RowDispatcher: NActors::TEvents::TEvPong
2025-11-11T14:17:16.701495Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-11T14:17:16.701506Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-11T14:17:16.743444Z :YQL_PROXY TRACE: log.cpp:64: SessionId:  2025-11-11 14:17:16.743 TRACE ydbd(pid=985965, tid=0x00007F9C77E71640) [DQ] task_controller_impl.h:271:  [2:7571471727510407931:2278] ExportStats Summary
2025-11-11T14:17:16.743690Z :FQ_PINGER TRACE: pinger.cpp:250: QueryId: ptqudslmp4acltli4k5i, Owner: ce7c8944-b9fd8a69-ddce038c-d38dc91a2 Forward ping request: { statistics: "{\"Graph=0\":{\"TaskRunner\":{\"Stage=212165\":{\"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=212182\":{\"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-11-11T14:17:16.743700Z :FQ_PINGER TRACE: pinger.cpp:393: QueryId: ptqudslmp4acltli4k5i, Owner: ce7c8944-b9fd8a69-ddce038c-d38dc91a2 Forward request Private::PingTask
2025-11-11T14:17:16.754167Z :FQ_PINGER TRACE: pinger.cpp:338: QueryId: ptqudslmp4acltli4k5i, Owner: ce7c8944-b9fd8a69-ddce038c-d38dc91a2 Ping response success: { action: ABORT expired_at { seconds: 1762870656 nanos: 748000000 } }
2025-11-11T14:17:16.754181Z :FQ_PINGER DEBUG: pinger.cpp:342: QueryId: ptqudslmp4acltli4k5i, Owner: ce7c8944-b9fd8a69-ddce038c-d38dc91a2 Query action: ABORT
2025-11-11T14:17:16.754214Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:690: QueryId: ptqudslmp4acltli4k5i New query action received: ABORT
2025-11-11T14:17:16.754219Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:1827: QueryId: ptqudslmp4acltli4k5i Is about to finish query with status ABORTED_BY_USER
2025-11-11T14:17:16.754221Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:1820: QueryId: ptqudslmp4acltli4k5i Write finalizing status: ABORTING_BY_USER
2025-11-11T14:17:16.754231Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:528: QueryId: ptqudslmp4acltli4k5i Cancel running query
2025-11-11T14:17:16.754253Z :FQ_RUN_ACTOR TRACE: run_actor.cpp:880: QueryId: ptqudslmp4acltli4k5i Forward ping response. Success: 1. Cookie: 6
2025-11-11T14:17:16.754282Z :FQ_PINGER TRACE: pinger.cpp:250: QueryId: ptqudslmp4acltli4k5i, Owner: ce7c8944-b9fd8a69-ddce038c-d38dc91a2 Forward ping request: { status: ABORTING_BY_USER }
2025-11-11T14:17:16.754291Z :FQ_PINGER TRACE: pinger.cpp:393: QueryId: ptqudslmp4acltli4k5i, Owner: ce7c8944-b9fd8a69-ddce038c-d38dc91a2 Forward request Private::PingTask
2025-11-11T14:17:16.754360Z :YQL_PROXY DEBUG: log.cpp:64: SessionId:  2025-11-11 14:17:16.754 DEBUG ydbd(pid=985965, tid=0x00007F9C7666E640) [DQ] task_controller_impl.h:130: AbortExecution from [2:7571471727510407927:2274]:ABORTED { <main>: Error: ABORTED_BY_USER }
2025-11-11T14:17:16.754376Z :YQL_PROXY DEBUG: log.cpp:64: SessionId:  2025-11-11 14:17:16.754 DEBUG ydbd(pid=985965, tid=0x00007F9C7666E640) [DQ] task_controller_impl.h:598: OnError { <main>: Error: ABORTED_BY_USER } ABORTED
2025-11-11T14:17:16.754439Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudslmp4acltli4k5i 2025-11-11 14:17:16.754 DEBUG ydbd(pid=985965, tid=0x00007F9C7666E640) [DQ] executer_actor.cpp:304: {ptqudslmp4acltli4k5i} OnFailure, status=4, issues size=1, sender=[2:7571471727510407931:2278]
2025-11-11T14:17:16.754454Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudslmp4acltli4k5i 2025-11-11 14:17:16.754 DEBUG ydbd(pid=985965, tid=0x00007F9C7666E640) [DQ] executer_actor.cpp:315: {ptqudslmp4acltli4k5i} Issues: <main>: Error: ABORTED_BY_USER

2025-11-11T14:17:16.754460Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudslmp4acltli4k5i 2025-11-11 14:17:16.754 DEBUG ydbd(pid=985965, tid=0x00007F9C7666E640) [DQ] executer_actor.cpp:284: {ptqudslmp4acltli4k5i} Finish with status=4 issues=<main>: Error: ABORTED_BY_USER

2025-11-11T14:17:16.754493Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudslmp4acltli4k5i 2025-11-11 14:17:16.754 DEBUG ydbd(pid=985965, tid=0x00007F9C7666E640) [DQ] executer_actor.cpp:341: {ptqudslmp4acltli4k5i} OnQueryResponse status=4 issuses_size=1
2025-11-11T14:17:16.754509Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:1397: QueryId: ptqudslmp4acltli4k5i TEvQueryResponse received on finish
2025-11-11T14:17:16.754520Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:1234: QueryId: ptqudslmp4acltli4k5i Query response CANCELLED. Result set index: 0. Issues count: 1. Rows count: 0
2025-11-11T14:17:16.754623Z :KQP_COMPUTE ERROR: dq_compute_actor_impl.h:1215: SelfId: [2:7571471727510407933:2280], TxId: ptqudslmp4acltli4k5i, task: 1. Ctx: {}. Handle abort execution event from: [2:7571471723215440359:2064], status: UNAVAILABLE, reason: { <main>: Error: Aborted by LWM }
2025-11-11T14:17:16.754655Z :KQP_COMPUTE DEBUG: dq_compute_actor_channels.cpp:494: TxId: ptqudslmp4acltli4k5i, task: 1. pass away
2025-11-11T14:17:16.754664Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:657: [ptqudslmp4acltli4k5i-0.2] PassAway
2025-11-11T14:17:16.754675Z :YDB_SDK INFO: actor.cpp:37: 2025-11-11T14:17:16.754672Z :INFO: [local] [local] [d653b33c-801bd0e2-e1c6fe2-e1ff53c4] Closing read session. Close timeout: 0.000000s
2025-11-11T14:17:16.754686Z :YDB_SDK INFO: actor.cpp:37: 2025-11-11T14:17:16.754683Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:program_state_recovery_input:0:1:21:8
2025-11-11T14:17:16.754706Z :YDB_SDK INFO: actor.cpp:37: 2025-11-11T14:17:16.754704Z :INFO: [local] [local] [d653b33c-801bd0e2-e1c6fe2-e1ff53c4] Counters: { Errors: 0 CurrentSessionLifetimeMs: 824 BytesRead: 210 MessagesRead: 14 BytesReadCompressed: 210 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:17:16.754726Z :YDB_SDK NOTICE: actor.cpp:37: 2025-11-11T14:17:16.754724Z :NOTICE: [local] [local] [d653b33c-801bd0e2-e1c6fe2-e1ff53c4] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Close with zero timeout " }
2025-11-11T14:17:16.754738Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:17:16.754736Z :DEBUG: [local] [local] [d653b33c-801bd0e2-e1c6fe2-e1ff53c4] [] Abort session to cluster
2025-11-11T14:17:16.754877Z :YDB_SDK INFO: actor.cpp:37: 2025-11-11T14:17:16.754874Z :INFO: [local] [local] [d653b33c-801bd0e2-e1c6fe2-e1ff53c4] Closing read session. Close timeout: 0.000000s
2025-11-11T14:17:16.754886Z :YDB_SDK INFO: actor.cpp:37: 2025-11-11T14:17:16.754885Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:program_state_recovery_input:0:1:21:8
2025-11-11T14:17:16.754891Z :YDB_SDK INFO: actor.cpp:37: 2025-11-11T14:17:16.754888Z :INFO: [local] [local] [d653b33c-801bd0e2-e1c6fe2-e1ff53c4] Counters: { Errors: 0 CurrentSessionLifetimeMs: 824 BytesRead: 210 MessagesRead: 14 BytesReadCompressed: 210 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:17:16.754899Z :YDB_SDK NOTICE: actor.cpp:37: 2025-11-11T14:17:16.754897Z :NOTICE: [local] [local] [d653b33c-801bd0e2-e1c6fe2-e1ff53c4] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:17:16.766583Z :FQ_PINGER TRACE: pinger.cpp:338: QueryId: ptqudslmp4acltli4k5i, Owner: ce7c8944-b9fd8a69-ddce038c-d38dc91a2 Ping response success: { action: ABORT expired_at { seconds: 1762870656 nanos: 759000000 } }
2025-11-11T14:17:16.766595Z :FQ_PINGER DEBUG: pinger.cpp:342: QueryId: ptqudslmp4acltli4k5i, Owner: ce7c8944-b9fd8a69-ddce038c-d38dc91a2 Query action: ABORT
2025-11-11T14:17:16.766627Z :FQ_RUN_ACTOR TRACE: run_actor.cpp:880: QueryId: ptqudslmp4acltli4k5i Forward ping response. Success: 1. Cookie: 3
2025-11-11T14:17:16.766630Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:887: QueryId: ptqudslmp4acltli4k5i Finalizing status is saved
2025-11-11T14:17:16.766668Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:1508: QueryId: ptqudslmp4acltli4k5i Start rate limiter resource deleter
2025-11-11T14:17:16.766697Z :STREAMS DEBUG: read_rule_deleter.cpp:214: ptqudslmp4acltli4k5i: Create read rule deleter actor for `program_state_recovery_input` [0]
2025-11-11T14:17:16.766731Z :STREAMS DEBUG: read_rule_deleter.cpp:106: ptqudslmp4acltli4k5i: Make request for read rule deletion for topic `program_state_recovery_input` [0]
2025-11-11T14:17:16.806580Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:1499: QueryId: ptqudslmp4acltli4k5i Rate limiter resource deletion finished. Success: 1. Issues: 
2025-11-11T14:17:16.806592Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:1919: QueryId: ptqudslmp4acltli4k5i SendPingAndPassAway, FinalQueryStatus ABORTED_BY_USER
2025-11-11T14:17:16.806618Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:536: QueryId: ptqudslmp4acltli4k5i PassAway
2025-11-11T14:17:16.806729Z :FQ_PINGER TRACE: pinger.cpp:250: QueryId: ptqudslmp4acltli4k5i, Owner: ce7c8944-b9fd8a69-ddce038c-d38dc91a2 Forward ping request: { result_id { value: "ptrudslmovieopao97tk" } status: ABORTED_BY_USER issues { message: "ABORTED_BY_USER" severity: 1 } statistics: "{\"Graph=0\":{\"Actor\":{\"ActorCreateTimeUs\":{\"sum\":\"32ms\",\"count\":2,\"avg\":\"16ms\",\"max\":\"31ms\",\"min\":\"575us\"}},\"AllocateWorkersUs\":{\"sum\":\"32ms\",\"count\":1,\"avg\":\"32ms\",\"max\":\"32ms\",\"min\":\"32ms\"},\"ExecutionTimeUs\":{\"sum\":\"1.01s\",\"count\":1,\"avg\":\"1.01s\",\"max\":\"1.01s\",\"min\":\"1.01s\"},\"TaskRunner\":{\"Stage=212165\":{\"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=212182\":{\"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}}},\"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_1dfa93e9-7ae7-41be-8d4a-a0eaa08e4eb5/rate_limiter" topic_consumers { database: "local" topic_path: "program_state_recovery_input" consumer_name: "ptqudslmp4acltli4k5i" cluster_endpoint: "localhost:21280" token_name: "cluster:default_myyds" add_bearer_to_token: true } } finished_at { seconds: 1762870636 nanos: 754000000 } }
2025-11-11T14:17:16.806740Z :FQ_PINGER TRACE: pinger.cpp:393: QueryId: ptqudslmp4acltli4k5i, Owner: ce7c8944-b9fd8a69-ddce038c-d38dc91a2 Forward request Private::PingTask
2025-11-11T14:17:16.888131Z :FQ_PINGER TRACE: pinger.cpp:338: QueryId: ptqudslmp4acltli4k5i, Owner: ce7c8944-b9fd8a69-ddce038c-d38dc91a2 Ping response success: { action: ABORT }
2025-11-11T14:17:16.888155Z :FQ_PINGER DEBUG: pinger.cpp:379: QueryId: ptqudslmp4acltli4k5i, Owner: ce7c8944-b9fd8a69-ddce038c-d38dc91a2 Query finished
2025-11-11T14:17:16.888158Z :FQ_PINGER TRACE: pinger.cpp:187: QueryId: ptqudslmp4acltli4k5i, Owner: ce7c8944-b9fd8a69-ddce038c-d38dc91a2 Stop Pinger
2025-11-11T14:17:17.697740Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: ce7c8944-b9fd8a69-ddce038c-d38dc91a5, Host: ghrun-vb3yoermsa, Tenant: /compute
2025-11-11T14:17:17.701527Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-11T14:17:17.701539Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-11T14:17:18.698207Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:617: RowDispatcher: Send ping to [1:7571471682112226299:2082]
2025-11-11T14:17:18.698226Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: ce7c8944-b9fd8a69-ddce038c-d38dc91a6, Host: ghrun-vb3yoermsa, Tenant: /compute
2025-11-11T14:17:18.698244Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1161: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-11-11T14:17:18.698589Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:623: RowDispatcher: NActors::TEvents::TEvPong
2025-11-11T14:17:18.702800Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-11T14:17:18.702814Z :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:62288: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-vb3yoermsa.auto.internal:62288
2025-11-11T14:17:19.696593Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-11-11T14:17:19.698650Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: ce7c8944-b9fd8a69-ddce038c-d38dc91a7, Host: ghrun-vb3yoermsa, Tenant: /compute
2025-11-11T14:17:19.701625Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-11T14:17:19.701647Z :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:62288: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-vb3yoermsa.auto.internal:62288
2025-11-11T14:17:19.701705Z :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:62288: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-vb3yoermsa.auto.internal:62288
2025-11-11T14:17:20.699106Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:617: RowDispatcher: Send ping to [1:7571471682112226299:2082]
2025-11-11T14:17:20.699135Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1161: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-11-11T14:17:20.699136Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: ce7c8944-b9fd8a69-ddce038c-d38dc91a8, Host: ghrun-vb3yoermsa, Tenant: /compute
2025-11-11T14:17:20.699567Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:623: RowDispatcher: NActors::TEvents::TEvPong
2025-11-11T14:17:20.705801Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-11T14:17:20.705823Z :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:62288: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-vb3yoermsa.auto.internal:62288
2025-11-11T14:17:20.771412Z :INTERCONNECT_NETWORK NOTICE: interconnect_tcp_input_session.cpp:715: [2 <-> 1] connection closed by peer
2025-11-11T14:17:20.772027Z :INTERCONNECT_NETWORK NOTICE: interconnect_handshake.cpp:1581: [2 <-> 1] network-related error occured on handshake: outgoing handshake Peer# ghrun-vb3yoermsa(127.0.1.1:10398) Couldn't connect to any resolved address
2025-11-11T14:17:20.801957Z :INTERCONNECT_NETWORK NOTICE: interconnect_handshake.cpp:1581: [2 <-> 1] network-related error occured on handshake: outgoing handshake Peer# ghrun-vb3yoermsa(127.0.1.1:10398) Couldn't connect to any resolved address
