2025-11-11T14:16:08.234971Z :GRPC_SERVER NOTICE: grpc_request_proxy.cpp:369: Grpc request proxy started, nodeid# 1, serve as static node
2025-11-11T14:16:08.235040Z :GRPC_SERVER CRIT: grpc_request_proxy.cpp:429: Failed to deliver subscription request to config dispatcher
2025-11-11T14:16:08.235045Z :GRPC_SERVER NOTICE: grpc_request_proxy.cpp:369: Grpc request proxy started, nodeid# 1, serve as static node
2025-11-11T14:16:08.235060Z :GRPC_SERVER CRIT: grpc_request_proxy.cpp:429: Failed to deliver subscription request to config dispatcher
2025-11-11T14:16:08.235316Z :FQ_LOG_UPDATER DEBUG: log.cpp:93: Updated YQL logs priority: 8
2025-11-11T14:16:08.235320Z :FQ_LOG_UPDATER CRIT: log.cpp:55: Failed to deliver subscription request to config dispatcher.
2025-11-11T14:16:08.235360Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:188: Bootstrap
2025-11-11T14:16:08.235367Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:191: Create sdk ydb connection
2025-11-11T14:16:08.235369Z :YQ_RATE_LIMITER INFO: quoter_service.cpp:124: Bootstraping with config: { Enabled: true DataPlaneEnabled: true Database { Endpoint: "localhost:18945" Database: "local" TablePrefix: "RateLimiter_9fe90ee6-9f4b-469c-892e-6241e97d1618" } Limiters { CoordinationNodePath: "rate_limiter" } }
2025-11-11T14:16:08.235859Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:534: RowDispatcher: Successfully bootstrapped row dispatcher, id [1:7571471438992074979:2063], tenant /compute
2025-11-11T14:16:08.236967Z :YQL_NODES_MANAGER INFO: nodes_manager.cpp:88: Bootstrap, InstanceId: b2bb2793-4e4af71d-67b551a7-39bfcd03
2025-11-11T14:16:08.236971Z :YQL_NODES_MANAGER DEBUG: nodes_manager.cpp:310: TNodesManagerActor::ResolveSelfAddress
2025-11-11T14:16:08.237020Z :YQ_TEST_CONNECTION DEBUG: test_connection.cpp:142: Starting yandex query test connection. Actor id: [1:7571471438992074984:2068]
2025-11-11T14:16:08.237320Z :STREAMS_STORAGE_SERVICE TRACE: storage_proxy.cpp:213: Initialize
2025-11-11T14:16:08.250104Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: dc8c4f03-e6403fb7-5183aafd-31e8b0931, Host: ghrun-vb3yoermsa, Tenant: /compute
2025-11-11T14:16:08.251384Z :FQ_QUOTA_SERVICE INFO: quota_manager.cpp:196: STARTED
2025-11-11T14:16:08.251393Z :FQ_QUOTA_PROXY INFO: quota_proxy.cpp:90: STARTED
2025-11-11T14:16:08.251461Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:267: Coordinator: Successfully bootstrapped coordinator, id [1:7571471438992075017:2082], NodesManagerId [0:4705493345362661702:78]
2025-11-11T14:16:08.251474Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:232: TLeaderElection [1:7571471438992075018:2083] Successfully bootstrapped, local coordinator id [1:7571471438992075017:2082], tenant id compute, local mode 0, coordination node path local/row_dispatcher/compute, endpoint localhost:18945
2025-11-11T14:16:08.252024Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:209: Successfully bootstrapped TStorageProxy [1:7571471438992074978:2062] with connection to localhost:18945:local
2025-11-11T14:16:08.253253Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:627: RowDispatcher: TEvCoordinatorChangesSubscribe from [1:7571471438992075017:2082]
2025-11-11T14:16:08.254554Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-11-11T14:16:08.255171Z :MEMORY_PROFILER NOTICE: monitor.cpp:332: Bootstrapped
2025-11-11T14:16:08.257710Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:71: Run create coordination node "local/row_dispatcher/compute" actor
2025-11-11T14:16:08.257719Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:113: Call create coordination node "local/row_dispatcher/compute"
2025-11-11T14:16:08.257721Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:411: Call create coordination node "local/row_dispatcher/compute"
2025-11-11T14:16:08.261101Z :SCHEME_BOARD_SUBSCRIBER NOTICE: subscriber.cpp:849: [main][1:7571471438992075009:2077][/Root] Set up state: owner# [1:7571471438992074958:2052], state# { Deleted: 1 Strong: 0 Version: <Invalid> DomainId: <Invalid> AbandonedSchemeShards: there are 0 elements }
2025-11-11T14:16:08.261106Z :SCHEME_BOARD_SUBSCRIBER NOTICE: subscriber.cpp:849: [main][1:7571471438992075010:2078][/compute] Set up state: owner# [1:7571471438992074958:2052], state# { Deleted: 1 Strong: 0 Version: <Invalid> DomainId: <Invalid> AbandonedSchemeShards: there are 0 elements }
2025-11-11T14:16:08.261121Z :SCHEME_BOARD_SUBSCRIBER NOTICE: subscriber.cpp:849: [main][1:7571471438992075011:2079][/Root] Set up state: owner# [1:7571471438992074959:2053], state# { Deleted: 1 Strong: 0 Version: <Invalid> DomainId: <Invalid> AbandonedSchemeShards: there are 0 elements }
2025-11-11T14:16:08.261127Z :GRPC_SERVER WARN: grpc_request_proxy.cpp:572: SchemeBoardDelete /compute Strong=0
2025-11-11T14:16:08.261129Z :GRPC_SERVER WARN: grpc_request_proxy.cpp:572: SchemeBoardDelete /Root Strong=0
2025-11-11T14:16:08.261131Z :GRPC_SERVER WARN: grpc_request_proxy.cpp:572: SchemeBoardDelete /Root Strong=0
2025-11-11T14:16:08.261138Z :SCHEME_BOARD_SUBSCRIBER NOTICE: subscriber.cpp:849: [main][1:7571471438992075012:2080][/compute] Set up state: owner# [1:7571471438992074959:2053], state# { Deleted: 1 Strong: 0 Version: <Invalid> DomainId: <Invalid> AbandonedSchemeShards: there are 0 elements }
2025-11-11T14:16:08.261160Z :GRPC_SERVER WARN: grpc_request_proxy.cpp:572: SchemeBoardDelete /compute Strong=0
2025-11-11T14:16:08.284347Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:155: Successfully created coordination node "local/row_dispatcher/compute"
2025-11-11T14:16:08.284365Z :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:16:08.284383Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:345: TLeaderElection [1:7571471438992075018:2083] Coordination node successfully created
2025-11-11T14:16:08.284387Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:323: TLeaderElection [1:7571471438992075018:2083] Start session
2025-11-11T14:16:08.286525Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:359: TLeaderElection [1:7571471438992075018:2083] Session successfully created
2025-11-11T14:16:08.288051Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:372: TLeaderElection [1:7571471438992075018:2083] Semaphore successfully created
2025-11-11T14:16:08.288072Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:304: TLeaderElection [1:7571471438992075018:2083] Try to acquire semaphore
2025-11-11T14:16:08.288158Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:420: TLeaderElection [1:7571471438992075018:2083] Describe semaphore
2025-11-11T14:16:08.289044Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:469: TLeaderElection [1:7571471438992075018:2083] Semaphore successfully described: coordinator id [2:7571471408376654102:2082] generation 3
2025-11-11T14:16:08.289058Z :FQ_ROW_DISPATCHER INFO: leader_election.cpp:471: TLeaderElection [1:7571471438992075018:2083] Send TEvCoordinatorChanged to [1:7571471438992074979:2063], new coordinator id [2:7571471408376654102:2082], previous coordinator id [0:0:0]
2025-11-11T14:16:08.289077Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:559: RowDispatcher: Coordinator changed, old leader (empty maybe), new [2:7571471408376654102:2082] generation 3
2025-11-11T14:16:08.289099Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:386: Coordinator: New leader [2:7571471408376654102:2082], SelfId [1:7571471438992075017:2082]
2025-11-11T14:16:08.289124Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:597: RowDispatcher: TEvUndelivered, from [2:7571471408376654102:2082], reason Disconnected
2025-11-11T14:16:08.298368Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:389: Send NodeInfo with size: 1 to DynamicNameserver
2025-11-11T14:16:08.298391Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-11T14:16:08.298395Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 1
2025-11-11T14:16:08.298404Z :FQ_PENDING_FETCHER DEBUG: pending_fetcher.cpp:361: NewTask: Scope: yandexcloud://my_folder Id: ptqudslmrdgp1dc4lsfk UserId: root@builtin AuthToken: **** (B6C6F477)
2025-11-11T14:16:08.298591Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:375: QueryId: ptqudslmrdgp1dc4lsfk Start run actor. Compute state: RUNNING
2025-11-11T14:16:08.298597Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: dc8c4f03-e6403fb7-5183aafd-31e8b0932, Host: ghrun-vb3yoermsa, Tenant: /compute
2025-11-11T14:16:08.298600Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:469: QueryId: ptqudslmrdgp1dc4lsfk FillConnections
2025-11-11T14:16:08.298637Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:2333: QueryId: ptqudslmrdgp1dc4lsfk Run actors params: { QueryId: ptqudslmrdgp1dc4lsfk CloudId: mock_cloud UserId: root@builtin Owner: dc8c4f03-e6403fb7-5183aafd-31e8b0931 PreviousQueryRevision: 3 Connections: 1 Bindings: 0 AccountIdSignatures: 0 QueryType: STREAMING ExecuteMode: RUN ResultId: ptrudslmqvrm11rqlc8m StateLoadMode: FROM_LAST_CHECKPOINT StreamingDisposition: { from_last_checkpoint { } } Status: RUNNING DqGraphs: 1 DqGraphIndex: 0 Resource.TopicConsumers: 1 }
2025-11-11T14:16:08.298725Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:911: QueryId: ptqudslmrdgp1dc4lsfk Overall dq tasks: 2
2025-11-11T14:16:08.298791Z :FQ_PINGER TRACE: pinger.cpp:171: QueryId: ptqudslmrdgp1dc4lsfk, Owner: dc8c4f03-e6403fb7-5183aafd-31e8b0931 Start Pinger
2025-11-11T14:16:08.298893Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:1599: QueryId: ptqudslmrdgp1dc4lsfk ResultWriter was NOT CREATED since ResultType is empty
2025-11-11T14:16:08.298985Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudslmrdgp1dc4lsfk 2025-11-11 14:16:08.298 DEBUG ydbd(pid=938393, tid=0x00007F21092AB640) [DQ] task_controller_impl.h:86: _RowsLimitPerWrite = 0
2025-11-11T14:16:08.299043Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:1653: QueryId: ptqudslmrdgp1dc4lsfk Executer: [1:7571471438992075113:2144], Controller: [1:7571471438992075115:2146], ResultIdActor: [1:7571471438992075113:2144]
2025-11-11T14:16:08.299071Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudslmrdgp1dc4lsfk 2025-11-11 14:16:08.299 DEBUG ydbd(pid=938393, tid=0x00007F21092AB640) [DQ] executer_actor.cpp:140: {ptqudslmrdgp1dc4lsfk} TDqExecuter::OnGraph
2025-11-11T14:16:08.299086Z :YQL_PROXY INFO: log.cpp:64: SessionId: ptqudslmrdgp1dc4lsfk 2025-11-11 14:16:08.299 INFO  ydbd(pid=938393, tid=0x00007F21092AB640) [DQ] executer_actor.cpp:157: {ptqudslmrdgp1dc4lsfk} Trying to allocate 2 workers [EnableComputeActor=1]
2025-11-11T14:16:08.299217Z :INTERCONNECT WARN: interconnect_handshake.cpp:543: Handshake [1:7571471438992075090:2052] [node 2] ICH09 Neither CompatibilityInfo nor VersionTag of the peer can be validated, accepting by default
2025-11-11T14:16:08.300294Z :FQ_PINGER TRACE: pinger.cpp:250: QueryId: ptqudslmrdgp1dc4lsfk, Owner: dc8c4f03-e6403fb7-5183aafd-31e8b0931 Forward ping request: { resources { rate_limiter: READY compilation: READY topic_consumers_state: READY rate_limiter_path: "local/RateLimiter_9fe90ee6-9f4b-469c-892e-6241e97d1618/rate_limiter" topic_consumers { database: "local" topic_path: "recovery_input" consumer_name: "ptqudslmrdgp1dc4lsfk" cluster_endpoint: "localhost:18945" token_name: "cluster:default_myyds" add_bearer_to_token: true } } }
2025-11-11T14:16:08.300310Z :FQ_PINGER TRACE: pinger.cpp:393: QueryId: ptqudslmrdgp1dc4lsfk, Owner: dc8c4f03-e6403fb7-5183aafd-31e8b0931 Forward request Private::PingTask
2025-11-11T14:16:08.300381Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:499: Checkpoint storage and state storage were successfully inited
2025-11-11T14:16:08.300384Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudslmrdgp1dc4lsfk 2025-11-11 14:16:08.300 DEBUG ydbd(pid=938393, tid=0x00007F21092AB640) [DQ] executer_actor.cpp:247: {ptqudslmrdgp1dc4lsfk} Dq timeouts are set to: 0.000000s (global), 600.000000s (workers allocation fail), 30.000000s (workers allocation warn) 
2025-11-11T14:16:08.301134Z :YQL_NODES_MANAGER DEBUG: nodes_manager.cpp:125: TEvAllocateWorkersResponse Nodes {
  ResourceId: 4294967297
  Worker {
    NodeId: 1
    Guid: "b2bb2793-4e4af71d-67b551a7-39bfcd03,ghrun-vb3yoermsa"
  }
  Worker {
    NodeId: 2
    Guid: "88804874-4663e11b-869ce985-4d5db3a8,ghrun-vb3yoermsa"
  }
}
2025-11-11T14:16:08.321533Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-11T14:16:08.321547Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-11T14:16:08.321668Z :FQ_PINGER TRACE: pinger.cpp:338: QueryId: ptqudslmrdgp1dc4lsfk, Owner: dc8c4f03-e6403fb7-5183aafd-31e8b0931 Ping response success: { expired_at { seconds: 1762870588 nanos: 304000000 } }
2025-11-11T14:16:08.321689Z :FQ_RUN_ACTOR TRACE: run_actor.cpp:861: QueryId: ptqudslmrdgp1dc4lsfk Forward ping response. Success: 1. Cookie: 0
2025-11-11T14:16:08.363447Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:134: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Start compute actor [1:7571471438992075131:2154], task: 1
2025-11-11T14:16:08.363503Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudslmrdgp1dc4lsfk 2025-11-11 14:16:08.363 DEBUG ydbd(pid=938393, tid=0x00007F2107AA8640) [DQ] executer_actor.cpp:358: {ptqudslmrdgp1dc4lsfk} TDqExecuter::TEvAllocateWorkersResponse
2025-11-11T14:16:08.363516Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudslmrdgp1dc4lsfk 2025-11-11 14:16:08.363 DEBUG ydbd(pid=938393, tid=0x00007F2107AA8640) [DQ] executer_actor.cpp:384: {ptqudslmrdgp1dc4lsfk} Allocated resource 4294967297
2025-11-11T14:16:08.363550Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:113: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Use CPU quota: 1. Rate limiter resource: { "local/RateLimiter_9fe90ee6-9f4b-469c-892e-6241e97d1618/rate_limiter", "mock_cloud/my_folder/ptqudslmrdgp1dc4lsfk" }
2025-11-11T14:16:08.363568Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudslmrdgp1dc4lsfk 2025-11-11 14:16:08.363 DEBUG ydbd(pid=938393, tid=0x00007F2107AA8640) [DQ] executer_actor.cpp:401: {ptqudslmrdgp1dc4lsfk} WorkerInfo: Id:b2bb2793-4e4af71d-67b551a7-39bfcd03,ghrun-vb3yoermsa,NodeId:1,StageId:209442
2025-11-11T14:16:08.363576Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudslmrdgp1dc4lsfk 2025-11-11 14:16:08.363 DEBUG ydbd(pid=938393, tid=0x00007F2107AA8640) [DQ] executer_actor.cpp:402: {ptqudslmrdgp1dc4lsfk} TaskInfo: 0/1
2025-11-11T14:16:08.363583Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudslmrdgp1dc4lsfk 2025-11-11 14:16:08.363 DEBUG ydbd(pid=938393, tid=0x00007F2107AA8640) [DQ] executer_actor.cpp:404: {ptqudslmrdgp1dc4lsfk}  ObjectId: 8d73c3b672aec01e659c446142c7a17d47fb7b86, dq_vanilla_job.lite, 
2025-11-11T14:16:08.363607Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudslmrdgp1dc4lsfk 2025-11-11 14:16:08.363 DEBUG ydbd(pid=938393, tid=0x00007F2107AA8640) [DQ] executer_actor.cpp:401: {ptqudslmrdgp1dc4lsfk} WorkerInfo: Id:88804874-4663e11b-869ce985-4d5db3a8,ghrun-vb3yoermsa,NodeId:2,StageId:209442
2025-11-11T14:16:08.363620Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudslmrdgp1dc4lsfk 2025-11-11 14:16:08.363 DEBUG ydbd(pid=938393, tid=0x00007F2107AA8640) [DQ] executer_actor.cpp:402: {ptqudslmrdgp1dc4lsfk} TaskInfo: 1/2
2025-11-11T14:16:08.363626Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudslmrdgp1dc4lsfk 2025-11-11 14:16:08.363 DEBUG ydbd(pid=938393, tid=0x00007F2107AA8640) [DQ] executer_actor.cpp:404: {ptqudslmrdgp1dc4lsfk}  ObjectId: 8d73c3b672aec01e659c446142c7a17d47fb7b86, dq_vanilla_job.lite, 
2025-11-11T14:16:08.363639Z :YQL_PROXY INFO: log.cpp:64: SessionId: ptqudslmrdgp1dc4lsfk 2025-11-11 14:16:08.363 INFO  ydbd(pid=938393, tid=0x00007F2107AA8640) [DQ] executer_actor.cpp:415: {ptqudslmrdgp1dc4lsfk} 2 workers allocated
2025-11-11T14:16:08.363764Z :YQL_PROXY TRACE: log.cpp:64: SessionId:  2025-11-11 14:16:08.363 TRACE ydbd(pid=938393, tid=0x00007F2107AA8640) [DQ] task_controller_impl.h:271:  [1:7571471438992075115:2146] ExportStats Summary
2025-11-11T14:16:08.363765Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: dc8c4f03-e6403fb7-5183aafd-31e8b093 2025-11-11 14:16:08.363 DEBUG ydbd(pid=938393, tid=0x00007F2106AA6640) [DQ] tasks_runner_local.cpp:267: {TODO/1} Build task: 1
2025-11-11T14:16:08.363795Z :YQL_PROXY DEBUG: log.cpp:64: SessionId:  2025-11-11 14:16:08.363 DEBUG ydbd(pid=938393, tid=0x00007F2107AA8640) [DQ] task_controller_impl.h:526: Ready State: [1:7571471438992075115:2146]
2025-11-11T14:16:08.363806Z :YQL_PROXY DEBUG: log.cpp:64: SessionId:  2025-11-11 14:16:08.363 DEBUG ydbd(pid=938393, tid=0x00007F2107AA8640) [DQ] task_controller_impl.h:537: Forward: [1:7571471438992075115:2146] to [1:7571471438992075114:2145]
2025-11-11T14:16:08.363840Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:70: [ptqudslmrdgp1dc4lsfk-0.3] TEvReadyState, streaming disposition { from_last_checkpoint { } }, state load mode FROM_LAST_CHECKPOINT, checkpointing period 1.000000s
2025-11-11T14:16:08.363855Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:104: [ptqudslmrdgp1dc4lsfk-0.3] AllActors count: 2, ActorsToTrigger count: 2, ActorsToNotify count: 2, ActorsToWaitFor count: 2
2025-11-11T14:16:08.363858Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:114: [ptqudslmrdgp1dc4lsfk-0.3] Send TEvRegisterCoordinatorRequest
2025-11-11T14:16:08.363871Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:229: [ptqudslmrdgp1dc4lsfk-0.3] Got TEvRegisterCoordinatorRequest
2025-11-11T14:16:08.363899Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: dc8c4f03-e6403fb7-5183aafd-31e8b093 2025-11-11 14:16:08.363 DEBUG ydbd(pid=938393, tid=0x00007F2106AA6640) [DQ] tasks_runner_local.cpp:267: {TODO/1} task: 1, program size: 36, llvm: ``.
2025-11-11T14:16:08.376375Z :YQL_PROXY TRACE: log.cpp:64: SessionId:  2025-11-11 14:16:08.366 TRACE ydbd(pid=938393, tid=0x00007F21092AB640) [DQ] task_controller_impl.h:160: [1:7571471438992075115:2146] EvState TaskId: 2 State: 2 PingCookie: 0 StatusCode: UNSPECIFIED
2025-11-11T14:16:08.376417Z :YQL_PROXY TRACE: log.cpp:64: SessionId:  2025-11-11 14:16:08.376 TRACE ydbd(pid=938393, tid=0x00007F21092AB640) [DQ] task_controller_impl.h:201:  [1:7571471438992075115:2146] Executing TaskId: 2
2025-11-11T14:16:08.407714Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:243: [ptqudslmrdgp1dc4lsfk-0.3] Graph registered
2025-11-11T14:16:08.407730Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:245: [ptqudslmrdgp1dc4lsfk-0.3] Send TEvRegisterCoordinatorResponse
2025-11-11T14:16:08.407798Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:131: [ptqudslmrdgp1dc4lsfk-0.3] Got TEvRegisterCoordinatorResponse; issues: 
2025-11-11T14:16:08.407800Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:140: [ptqudslmrdgp1dc4lsfk-0.3] Successfully registered in storage
2025-11-11T14:16:08.407802Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:141: [ptqudslmrdgp1dc4lsfk-0.3] Send TEvNewCheckpointCoordinator to 2 actor(s)
2025-11-11T14:16:08.407812Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:149: [ptqudslmrdgp1dc4lsfk-0.3] Send TEvGetCheckpointsMetadataRequest; state load mode: FROM_LAST_CHECKPOINT; load graph: 0
2025-11-11T14:16:08.407825Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:387: [ptqudslmrdgp1dc4lsfk-0] Got TEvGetCheckpointsMetadataRequest
2025-11-11T14:16:08.408789Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:622: [ptqudslmrdgp1dc4lsfk-0.3] Handle connected node 2
2025-11-11T14:16:08.410477Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:400: [ptqudslmrdgp1dc4lsfk-0] Send TEvGetCheckpointsMetadataResponse
2025-11-11T14:16:08.410517Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:186: [ptqudslmrdgp1dc4lsfk-0.3] Got TEvGetCheckpointsMetadataResponse
2025-11-11T14:16:08.410521Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:219: [ptqudslmrdgp1dc4lsfk-0.3] Will restore from checkpoint 1:1
2025-11-11T14:16:08.420148Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:297: [ptqudslmrdgp1dc4lsfk-0.3] [1:1] Got TEvRestoreFromCheckpointResult; taskId: 2, checkpoint: 1:1, status: OK, issues: 
2025-11-11T14:16:08.420161Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:320: [ptqudslmrdgp1dc4lsfk-0.3] [1:1] Task state restored, need 1 more acks
2025-11-11T14:16:08.448636Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: dc8c4f03-e6403fb7-5183aafd-31e8b093 2025-11-11 14:16:08.448 DEBUG ydbd(pid=938393, tid=0x00007F2106AA6640) [DQ] tasks_runner_local.cpp:267: {TODO/1} Build task: 1 takes 84827 us
2025-11-11T14:16:08.448657Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: dc8c4f03-e6403fb7-5183aafd-31e8b093 2025-11-11 14:16:08.448 DEBUG ydbd(pid=938393, tid=0x00007F2106AA6640) [DQ] tasks_runner_local.cpp:267: {TODO/1} Prepare task: 1
2025-11-11T14:16:08.448680Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: dc8c4f03-e6403fb7-5183aafd-31e8b093 2025-11-11 14:16:08.448 DEBUG ydbd(pid=938393, tid=0x00007F2106AA6640) [DQ] tasks_runner_local.cpp:267: {TODO/1} Prepare task: 1, takes 16 us
2025-11-11T14:16:08.448769Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:197: [] Task: 1. Got TEvNewCheckpointCoordinator event: generation 3, actorId: [1:7571471438992075114:2145]
2025-11-11T14:16:08.448778Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:208: [] Task: 1. Assign checkpoint coordinator (generation = 3)
2025-11-11T14:16:08.449378Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1370: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Create source for input 0 { Source { Type: "PqSource" Settings { type_url: "type.googleapis.com/NYql.NPq.NProto.TDqPqTopicSource" value: "\n\016recovery_input\022\024ptqudslmrdgp1dc4lsfk\032\017localhost:18945\"\027\n\025cluster:default_myyds*\005local0\002@\001b\004Dataj\025[\"DataType\";\"String\"]\222\001\024ptcudslmrdofq71q8onb\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:16:08.475927Z :KQP_COMPUTE DEBUG: dq_pq_read_actor_base.cpp:153: SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, 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:16:08.475983Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1457: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Create sink for output 0 { Sink { Type: "PqSink" Settings { type_url: "type.googleapis.com/NYql.NPq.NProto.TDqPqTopicSink" value: "\n\017recovery_output\022\017localhost:18945\032\027\n\025cluster:default_myyds\"\005local0\0018\002" } } }
2025-11-11T14:16:08.476089Z :YQL_PROXY TRACE: log.cpp:64: SessionId:  2025-11-11 14:16:08.476 TRACE ydbd(pid=938393, tid=0x00007F2107AA8640) [DQ] task_controller_impl.h:160: [1:7571471438992075115:2146] EvState TaskId: 1 State: 2 PingCookie: 0 StatusCode: UNSPECIFIED
2025-11-11T14:16:08.476113Z :YQL_PROXY TRACE: log.cpp:64: SessionId:  2025-11-11 14:16:08.476 TRACE ydbd(pid=938393, tid=0x00007F2107AA8640) [DQ] task_controller_impl.h:201:  [1:7571471438992075115:2146] Executing TaskId: 1
2025-11-11T14:16:08.476142Z :YQL_PROXY DEBUG: log.cpp:64: SessionId:  2025-11-11 14:16:08.476 DEBUG ydbd(pid=938393, tid=0x00007F2107AA8640) [DQ] task_controller_impl.h:561: Update channels
2025-11-11T14:16:08.476174Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:265: [ptqudslmrdgp1dc4lsfk-0] Task: 1. [Checkpoint 1.1] TEvRestoreFromCheckpoint, StateLoadPlan = { StateType: STATE_TYPE_OWN }
2025-11-11T14:16:08.476186Z :YQL_PROXY TRACE: log.cpp:64: SessionId:  2025-11-11 14:16:08.476 TRACE ydbd(pid=938393, tid=0x00007F2107AA8640) [DQ] task_controller_impl.h:577: 1 
2025-11-11T14:16:08.476196Z :YQL_PROXY TRACE: log.cpp:64: SessionId:  2025-11-11 14:16:08.476 TRACE ydbd(pid=938393, tid=0x00007F2107AA8640) [DQ] task_controller_impl.h:577: 2 
2025-11-11T14:16:08.476204Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:457: [ptqudslmrdgp1dc4lsfk-0] [1:1] Got TEvGetTaskState: tasks {1}
2025-11-11T14:16:08.476208Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1074: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Received channels info: 
2025-11-11T14:16:08.476214Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:519: [ptqudslmrdgp1dc4lsfk-0] [1:1] GetState, tasks: 1
2025-11-11T14:16:08.479504Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:654: [ptqudslmrdgp1dc4lsfk-0] [1:1] ListOfStates results:
2025-11-11T14:16:08.479524Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:675: [ptqudslmrdgp1dc4lsfk-0] [1:1] taskId 1 checkpoint id: 2:1, rows count: 1
2025-11-11T14:16:08.479529Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:675: [ptqudslmrdgp1dc4lsfk-0] [1:1] taskId 1 checkpoint id: 1:2, rows count: 1
2025-11-11T14:16:08.479531Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:675: [ptqudslmrdgp1dc4lsfk-0] [1:1] taskId 1 checkpoint id: 1:1, rows count: 1
2025-11-11T14:16:08.479538Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:901: [ptqudslmrdgp1dc4lsfk-0] [1:1] SkipStatesInFuture, skip 2 checkpoints
2025-11-11T14:16:08.479576Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:796: [ptqudslmrdgp1dc4lsfk-0] [1:1] SelectState: task_id 1, seq_no 1, blob_seq_num 0
2025-11-11T14:16:08.482013Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:410: [ptqudslmrdgp1dc4lsfk-0] [1:1] DeserializeState, task id 1, blob size 158
2025-11-11T14:16:08.492756Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:960: [ptqudslmrdgp1dc4lsfk-0] [1:1] ApplyIncrements
2025-11-11T14:16:08.492865Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:476: [ptqudslmrdgp1dc4lsfk-0] [{ Id: 1 Generation: 1 }] Send TEvGetTaskStateResult: tasks: {1}
2025-11-11T14:16:08.492906Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:336: [ptqudslmrdgp1dc4lsfk-0] Task: 1. [Checkpoint 1.1] TEvGetTaskStateResult: restoring state
2025-11-11T14:16:08.492913Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:792: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Load state
2025-11-11T14:16:08.492995Z :KQP_COMPUTE DEBUG: dq_pq_read_actor_base.cpp:153: SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, 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:16:08.493012Z :KQP_COMPUTE DEBUG: dq_pq_read_actor_base.cpp:133: SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, task: 1. PQ source. SessionId: empty StartingMessageTs 2025-11-11T14:15:54.979000Z Restoring offset: 
2025-11-11T14:16:08.493180Z :KQP_COMPUTE DEBUG: dq_pq_write_actor.cpp:261: SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. Load state: { SourceId: "4099ced-84888ba2-f13e9171-e3b8baec" }
2025-11-11T14:16:08.493201Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:362: [ptqudslmrdgp1dc4lsfk-0] Task: 1. [Checkpoint 1.1] Checkpoint state restored
2025-11-11T14:16:08.493227Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:297: [ptqudslmrdgp1dc4lsfk-0.3] [1:1] Got TEvRestoreFromCheckpointResult; taskId: 1, checkpoint: 1:1, status: OK, issues: 
2025-11-11T14:16:08.493234Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:320: [ptqudslmrdgp1dc4lsfk-0.3] [1:1] Task state restored, need 0 more acks
2025-11-11T14:16:08.493238Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:445: [ptqudslmrdgp1dc4lsfk-0.3] Send TEvRun to all actors
2025-11-11T14:16:08.493262Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1174: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Got TEvRun from actor [1:7571471438992075114:2145]
2025-11-11T14:16:08.493272Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1491: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Poll inputs
2025-11-11T14:16:08.493275Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1506: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Poll sources
2025-11-11T14:16:08.493279Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:533: SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, task: 1. PQ source. SessionId: empty GetAsyncInputData freeSpace = 1
2025-11-11T14:16:08.493297Z :KQP_COMPUTE DEBUG: dq_pq_read_actor.cpp:635: SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, task: 1. PQ source. SessionId: empty PartitionsToRead: 0
2025-11-11T14:16:08.493346Z :YDB_SDK INFO: actor.cpp:37: 2025-11-11T14:16:08.493341Z :INFO: [local] [local] [947d54ec-62bd4fc7-2cecea62-e73c4d1e] Starting read session
2025-11-11T14:16:08.493355Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:08.493353Z :DEBUG: [local] [local] [947d54ec-62bd4fc7-2cecea62-e73c4d1e] Starting single session
2025-11-11T14:16:08.493385Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:08.493383Z :DEBUG: [local] [local] [947d54ec-62bd4fc7-2cecea62-e73c4d1e] [] In Reconnect, ReadSizeBudget = 8388608, ReadSizeServerDelta = 0
2025-11-11T14:16:08.493393Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:08.493391Z :DEBUG: [local] [local] [947d54ec-62bd4fc7-2cecea62-e73c4d1e] [] New values: ReadSizeBudget = 8388608, ReadSizeServerDelta = 0
2025-11-11T14:16:08.493397Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:08.493395Z :DEBUG: [local] [local] [947d54ec-62bd4fc7-2cecea62-e73c4d1e] [] Reconnecting session to cluster  in 0.000000s
2025-11-11T14:16:08.493608Z :KQP_COMPUTE INFO: dq_pq_read_actor.cpp:306: SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, task: 1. PQ source. SessionId: 947d54ec-62bd4fc7-2cecea62-e73c4d1e CreateReadSession
2025-11-11T14:16:08.493622Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:77: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Poll async input 0. Buffer free space: 1, read from async input: 0 bytes, 0 rows, finished: 0
2025-11-11T14:16:08.493646Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-11-11T14:16:08.493661Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:08.493645Z :DEBUG: [local] [local] [947d54ec-62bd4fc7-2cecea62-e73c4d1e] [] Successfully connected. Initializing session
2025-11-11T14:16:08.493717Z :KQP_COMPUTE TRACE: dq_compute_memory_quota.h:97: TxId: ptqudslmrdgp1dc4lsfk, task: 1. Peak memory usage: 2031616
2025-11-11T14:16:08.493729Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. update task runner stats
2025-11-11T14:16:08.493748Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-11T14:16:08.493751Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-11T14:16:08.493755Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:571: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-11-11T14:16:08.493758Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1105: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Ask CPU quota: 140ms
2025-11-11T14:16:08.493768Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:188: SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-11-11T14:16:08.493826Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1023: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-11-11T14:16:08.493827Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1027: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-11-11T14:16:08.494735Z :YDB_SDK INFO: actor.cpp:37: 2025-11-11T14:16:08.494727Z :INFO: [local] [local] [947d54ec-62bd4fc7-2cecea62-e73c4d1e] [] Got InitResponse. ReadSessionId: ptqudslmrdgp1dc4lsfk_1_7_14062134106085950078_v1
2025-11-11T14:16:08.494742Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:08.494740Z :DEBUG: [local] [local] [947d54ec-62bd4fc7-2cecea62-e73c4d1e] [] In ContinueReadingDataImpl, ReadSizeBudget = 8388608, ReadSizeServerDelta = 0
2025-11-11T14:16:08.494818Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:08.494816Z :DEBUG: [local] [local] [947d54ec-62bd4fc7-2cecea62-e73c4d1e] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 8388608
2025-11-11T14:16:08.497469Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1162: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. CPU quota delay: 3ms
2025-11-11T14:16:08.497637Z :YDB_SDK INFO: actor.cpp:37: 2025-11-11T14:16:08.497628Z :INFO: [local] OnFederationDiscovery fall back to single mode, database=local
2025-11-11T14:16:08.497809Z :YDB_SDK INFO: actor.cpp:37: [] [] Start federated write session to database '' (previous was <empty>) FederationState: { Status: SUCCESS SelfLocation: "" DbInfos: [ { path: "local" endpoint: "localhost:18945" status: AVAILABLE weight: 100 } ] ControlPlaneEndpoint: localhost:18945 }
2025-11-11T14:16:08.497867Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:08.497865Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId []  MessageGroupId [4099ced-84888ba2-f13e9171-e3b8baec] Write session: try to update token
2025-11-11T14:16:08.498064Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:354: SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, task: 1. PQ source. SessionId: 947d54ec-62bd4fc7-2cecea62-e73c4d1e Source data ready
2025-11-11T14:16:08.498079Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1491: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Poll inputs
2025-11-11T14:16:08.498083Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1506: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Poll sources
2025-11-11T14:16:08.498087Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:533: SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, task: 1. PQ source. SessionId: 947d54ec-62bd4fc7-2cecea62-e73c4d1e GetAsyncInputData freeSpace = 1000000
2025-11-11T14:16:08.498097Z :KQP_COMPUTE DEBUG: dq_pq_read_actor.cpp:807: SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, task: 1. PQ source. SessionId: 947d54ec-62bd4fc7-2cecea62-e73c4d1e Key: 0@ StartPartitionSessionEvent received
2025-11-11T14:16:08.498100Z :KQP_COMPUTE DEBUG: dq_pq_read_actor.cpp:814: SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, task: 1. PQ source. SessionId: 947d54ec-62bd4fc7-2cecea62-e73c4d1e Key: 0@ Confirm StartPartitionSession with offset (NULL)
2025-11-11T14:16:08.498125Z :YDB_SDK INFO: actor.cpp:37: 2025-11-11T14:16:08.498107Z :INFO: [local] [local] [947d54ec-62bd4fc7-2cecea62-e73c4d1e] [] Confirm partition stream create. Partition stream id: 1. Cluster: "-". Topic: "recovery_input". Partition: 0. Read offset: (NULL)
2025-11-11T14:16:08.498159Z :YDB_SDK INFO: actor.cpp:37: 2025-11-11T14:16:08.498156Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId []  MessageGroupId [4099ced-84888ba2-f13e9171-e3b8baec] Start write session. Will connect to nodeId: 0
2025-11-11T14:16:08.498205Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:77: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Poll async input 0. Buffer free space: 1000000, read from async input: 0 bytes, 0 rows, finished: 0
2025-11-11T14:16:08.498218Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:354: SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, task: 1. PQ source. SessionId: 947d54ec-62bd4fc7-2cecea62-e73c4d1e Source data ready
2025-11-11T14:16:08.498221Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-11-11T14:16:08.498269Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1491: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Poll inputs
2025-11-11T14:16:08.498270Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1506: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Poll sources
2025-11-11T14:16:08.498274Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:533: SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, task: 1. PQ source. SessionId: 947d54ec-62bd4fc7-2cecea62-e73c4d1e GetAsyncInputData freeSpace = 1000000
2025-11-11T14:16:08.498277Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:77: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Poll async input 0. Buffer free space: 1000000, read from async input: 0 bytes, 0 rows, finished: 0
2025-11-11T14:16:08.498280Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. update task runner stats
2025-11-11T14:16:08.498303Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-11T14:16:08.498305Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-11T14:16:08.498307Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:571: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-11-11T14:16:08.498310Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-11-11T14:16:08.498314Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:188: SelfId: [1:7571471438992075144:2154], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-11-11T14:16:08.498320Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1023: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-11-11T14:16:08.498321Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1027: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-11-11T14:16:08.498345Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. update task runner stats
2025-11-11T14:16:08.498351Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-11T14:16:08.498352Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-11T14:16:08.498353Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:571: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-11-11T14:16:08.498356Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:188: SelfId: [1:7571471438992075144:2154], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-11-11T14:16:08.498357Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1023: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-11-11T14:16:08.498358Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1027: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-11-11T14:16:08.498665Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:08.498659Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId []  MessageGroupId [4099ced-84888ba2-f13e9171-e3b8baec] Write session: write to message_group: 4099ced-84888ba2-f13e9171-e3b8baec
2025-11-11T14:16:08.535843Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:08.535834Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId []  MessageGroupId [4099ced-84888ba2-f13e9171-e3b8baec] Write session: send init request: init_request { path: "recovery_output" producer_id: "4099ced-84888ba2-f13e9171-e3b8baec" message_group_id: "4099ced-84888ba2-f13e9171-e3b8baec" }
2025-11-11T14:16:08.535858Z :YDB_SDK TRACE: actor.cpp:37: 2025-11-11T14:16:08.535856Z :TRACE: [local] TRACE_EVENT InitRequest 
2025-11-11T14:16:08.535993Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:08.535989Z :DEBUG: [local] [local] [947d54ec-62bd4fc7-2cecea62-e73c4d1e] [] Got ReadResponse, serverBytesSize = 206, now ReadSizeBudget = 0, ReadSizeServerDelta = 8388402
2025-11-11T14:16:08.536016Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:08.536014Z :DEBUG: [local] [local] [947d54ec-62bd4fc7-2cecea62-e73c4d1e] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 8388402
2025-11-11T14:16:08.536033Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:08.536031Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (0-5)
2025-11-11T14:16:08.536041Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:08.536039Z :DEBUG: [local] [local] [947d54ec-62bd4fc7-2cecea62-e73c4d1e] [] Returning serverBytesSize = 206 to budget
2025-11-11T14:16:08.536044Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:08.536042Z :DEBUG: [local] [local] [947d54ec-62bd4fc7-2cecea62-e73c4d1e] [] In ContinueReadingDataImpl, ReadSizeBudget = 206, ReadSizeServerDelta = 8388402
2025-11-11T14:16:08.536080Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:08.536079Z :DEBUG: [local] [local] [947d54ec-62bd4fc7-2cecea62-e73c4d1e] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 8388608
2025-11-11T14:16:08.536115Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:08.536113Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId []  MessageGroupId [4099ced-84888ba2-f13e9171-e3b8baec] Write session: OnWriteDone gRpcStatusCode: 0
2025-11-11T14:16:08.536142Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:354: SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, task: 1. PQ source. SessionId: 947d54ec-62bd4fc7-2cecea62-e73c4d1e Source data ready
2025-11-11T14:16:08.536168Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1491: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Poll inputs
2025-11-11T14:16:08.536170Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1506: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Poll sources
2025-11-11T14:16:08.536175Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:533: SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, task: 1. PQ source. SessionId: 947d54ec-62bd4fc7-2cecea62-e73c4d1e GetAsyncInputData freeSpace = 1000000
2025-11-11T14:16:08.536203Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:08.536198Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-11-11T14:16:08.536210Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:08.536208Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 1} (1-1)
2025-11-11T14:16:08.536216Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:08.536215Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (2-2)
2025-11-11T14:16:08.536220Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:08.536219Z :DEBUG: [local] Take Data. Partition 0. Read: {2, 0} (3-3)
2025-11-11T14:16:08.536226Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:08.536224Z :DEBUG: [local] Take Data. Partition 0. Read: {2, 1} (4-4)
2025-11-11T14:16:08.536230Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:08.536228Z :DEBUG: [local] Take Data. Partition 0. Read: {2, 2} (5-5)
2025-11-11T14:16:08.536250Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:08.536248Z :DEBUG: [local] [local] [947d54ec-62bd4fc7-2cecea62-e73c4d1e] [] The application data is transferred to the client. Number of messages 6, size 10 bytes
2025-11-11T14:16:08.536258Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:08.536257Z :DEBUG: [local] [local] [947d54ec-62bd4fc7-2cecea62-e73c4d1e] [] Returning serverBytesSize = 0 to budget
2025-11-11T14:16:08.536280Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:748: SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, task: 1. PQ source. SessionId: 947d54ec-62bd4fc7-2cecea62-e73c4d1e Key: 0@ Data received: Message { Data: "6" Information: { Offset: 0 ProducerId: "" SeqNo: 0 CreateTime: 2025-11-11T14:15:55.705000Z WriteTime: 2025-11-11T14:15:55.705000Z MessageGroupId: "" Meta: { } MessageMeta: { } } Partition session id: 1 Topic: "recovery_input" Partition: 0 }
2025-11-11T14:16:08.536290Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:748: SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, task: 1. PQ source. SessionId: 947d54ec-62bd4fc7-2cecea62-e73c4d1e Key: 0@ Data received: Message { Data: "9" Information: { Offset: 1 ProducerId: "" SeqNo: 0 CreateTime: 2025-11-11T14:15:55.705000Z WriteTime: 2025-11-11T14:15:55.705000Z MessageGroupId: "" Meta: { } MessageMeta: { } } Partition session id: 1 Topic: "recovery_input" Partition: 0 }
2025-11-11T14:16:08.536293Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:748: SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, task: 1. PQ source. SessionId: 947d54ec-62bd4fc7-2cecea62-e73c4d1e Key: 0@ Data received: Message { Data: "11" Information: { Offset: 2 ProducerId: "" SeqNo: 0 CreateTime: 2025-11-11T14:16:02.717000Z WriteTime: 2025-11-11T14:16:02.717000Z MessageGroupId: "" Meta: { } MessageMeta: { } } Partition session id: 1 Topic: "recovery_input" Partition: 0 }
2025-11-11T14:16:08.536297Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:748: SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, task: 1. PQ source. SessionId: 947d54ec-62bd4fc7-2cecea62-e73c4d1e Key: 0@ Data received: Message { Data: "17" Information: { Offset: 3 ProducerId: "" SeqNo: 0 CreateTime: 2025-11-11T14:16:02.717000Z WriteTime: 2025-11-11T14:16:02.723000Z MessageGroupId: "" Meta: { } MessageMeta: { } } Partition session id: 1 Topic: "recovery_input" Partition: 0 }
2025-11-11T14:16:08.536301Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:748: SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, task: 1. PQ source. SessionId: 947d54ec-62bd4fc7-2cecea62-e73c4d1e Key: 0@ Data received: Message { Data: "18" Information: { Offset: 4 ProducerId: "" SeqNo: 0 CreateTime: 2025-11-11T14:16:02.717000Z WriteTime: 2025-11-11T14:16:02.723000Z MessageGroupId: "" Meta: { } MessageMeta: { } } Partition session id: 1 Topic: "recovery_input" Partition: 0 }
2025-11-11T14:16:08.536304Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:748: SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, task: 1. PQ source. SessionId: 947d54ec-62bd4fc7-2cecea62-e73c4d1e Key: 0@ Data received: Message { Data: "19" Information: { Offset: 5 ProducerId: "" SeqNo: 0 CreateTime: 2025-11-11T14:16:02.717000Z WriteTime: 2025-11-11T14:16:02.723000Z MessageGroupId: "" Meta: { } MessageMeta: { } } Partition session id: 1 Topic: "recovery_input" Partition: 0 }
2025-11-11T14:16:08.536316Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:724: SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, task: 1. PQ source. SessionId: 947d54ec-62bd4fc7-2cecea62-e73c4d1e Return ready batch. DataCount = 6 Watermark = none Used space = 10
2025-11-11T14:16:08.536319Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:77: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Poll async input 0. Buffer free space: 1000000, read from async input: 10 bytes, 6 rows, finished: 0
2025-11-11T14:16:08.536344Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:354: SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, task: 1. PQ source. SessionId: 947d54ec-62bd4fc7-2cecea62-e73c4d1e Source data ready
2025-11-11T14:16:08.536348Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-11-11T14:16:08.536354Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1491: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Poll inputs
2025-11-11T14:16:08.536355Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1506: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Poll sources
2025-11-11T14:16:08.536357Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:533: SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, task: 1. PQ source. SessionId: 947d54ec-62bd4fc7-2cecea62-e73c4d1e GetAsyncInputData freeSpace = 999990
2025-11-11T14:16:08.536362Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:77: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Poll async input 0. Buffer free space: 999990, read from async input: 0 bytes, 0 rows, finished: 0
2025-11-11T14:16:08.536443Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-11-11T14:16:08.536446Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1491: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Poll inputs
2025-11-11T14:16:08.536447Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1506: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Poll sources
2025-11-11T14:16:08.536449Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:533: SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, task: 1. PQ source. SessionId: 947d54ec-62bd4fc7-2cecea62-e73c4d1e GetAsyncInputData freeSpace = 999990
2025-11-11T14:16:08.536452Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:77: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Poll async input 0. Buffer free space: 999990, read from async input: 0 bytes, 0 rows, finished: 0
2025-11-11T14:16:08.536455Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. update task runner stats
2025-11-11T14:16:08.536485Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-11T14:16:08.536488Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-11T14:16:08.536491Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:571: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-11-11T14:16:08.536495Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-11-11T14:16:08.536502Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:188: SelfId: [1:7571471438992075144:2154], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. SendData. Batch: 6. Checkpoint: 0. Finished: 0
2025-11-11T14:16:08.536505Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:214: SelfId: [1:7571471438992075144:2154], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. Received data for sending: 6
2025-11-11T14:16:08.536507Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:214: SelfId: [1:7571471438992075144:2154], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. Received data for sending: 9
2025-11-11T14:16:08.536510Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:214: SelfId: [1:7571471438992075144:2154], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. Received data for sending: 11
2025-11-11T14:16:08.536511Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:214: SelfId: [1:7571471438992075144:2154], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. Received data for sending: 17
2025-11-11T14:16:08.536512Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:214: SelfId: [1:7571471438992075144:2154], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. Received data for sending: 18
2025-11-11T14:16:08.536513Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:214: SelfId: [1:7571471438992075144:2154], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. Received data for sending: 19
2025-11-11T14:16:08.536538Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1023: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Sink 0: sent 30 bytes of data and 0 bytes of checkpoint barrier
2025-11-11T14:16:08.536540Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1027: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Drain sink 0. Free space decreased: 10, sent data from buffer: 30
2025-11-11T14:16:08.536559Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1491: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Poll inputs
2025-11-11T14:16:08.536560Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1506: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Poll sources
2025-11-11T14:16:08.536562Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:533: SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, task: 1. PQ source. SessionId: 947d54ec-62bd4fc7-2cecea62-e73c4d1e GetAsyncInputData freeSpace = 1000000
2025-11-11T14:16:08.536564Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:77: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Poll async input 0. Buffer free space: 1000000, read from async input: 0 bytes, 0 rows, finished: 0
2025-11-11T14:16:08.536567Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. update task runner stats
2025-11-11T14:16:08.536574Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-11T14:16:08.536576Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-11T14:16:08.536579Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:571: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. About to drain sink 0. FreeSpace: 16777206, allowedOvercommit: 500000, toSend: 17277206
2025-11-11T14:16:08.536581Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-11-11T14:16:08.536584Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:188: SelfId: [1:7571471438992075144:2154], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-11-11T14:16:08.536585Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1023: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-11-11T14:16:08.536587Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1027: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-11-11T14:16:08.536602Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. update task runner stats
2025-11-11T14:16:08.536607Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-11T14:16:08.536608Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-11T14:16:08.536609Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:571: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. About to drain sink 0. FreeSpace: 16777206, allowedOvercommit: 500000, toSend: 17277206
2025-11-11T14:16:08.536612Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:188: SelfId: [1:7571471438992075144:2154], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-11-11T14:16:08.536614Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1023: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-11-11T14:16:08.536615Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1027: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-11-11T14:16:08.536625Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. update task runner stats
2025-11-11T14:16:08.536630Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-11T14:16:08.536632Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-11T14:16:08.536634Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:571: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. About to drain sink 0. FreeSpace: 16777206, allowedOvercommit: 500000, toSend: 17277206
2025-11-11T14:16:08.536637Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:188: SelfId: [1:7571471438992075144:2154], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-11-11T14:16:08.536638Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1023: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-11-11T14:16:08.536639Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1027: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-11-11T14:16:08.541776Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:08.541768Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId []  MessageGroupId [4099ced-84888ba2-f13e9171-e3b8baec] Write session: OnReadDone gRpcStatusCode: 0
2025-11-11T14:16:08.541799Z :YDB_SDK INFO: actor.cpp:37: 2025-11-11T14:16:08.541796Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId []  MessageGroupId [4099ced-84888ba2-f13e9171-e3b8baec] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1762870568541 BytesWritten: 0 MessagesWritten: 0 BytesWrittenCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:16:08.541816Z :YDB_SDK INFO: actor.cpp:37: 2025-11-11T14:16:08.541814Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId []  MessageGroupId [4099ced-84888ba2-f13e9171-e3b8baec] Write session established. Init response: last_seq_no: 6 session_id: "4099ced-84888ba2-f13e9171-e3b8baec|1a66e246-ca5603b8-a5b5653a-1d6095de_0"
2025-11-11T14:16:08.541821Z :YDB_SDK TRACE: actor.cpp:37: 2025-11-11T14:16:08.541819Z :TRACE: [local] TRACE_EVENT InitResponse  partition_id=0 session_id=4099ced-84888ba2-f13e9171-e3b8baec|1a66e246-ca5603b8-a5b5653a-1d6095de_0
2025-11-11T14:16:08.541826Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:08.541823Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|1a66e246-ca5603b8-a5b5653a-1d6095de_0]  MessageGroupId [4099ced-84888ba2-f13e9171-e3b8baec] Write session: set DirectWriteToPartitionId 0
2025-11-11T14:16:08.541896Z :YDB_SDK INFO: actor.cpp:37: 2025-11-11T14:16:08.541894Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|1a66e246-ca5603b8-a5b5653a-1d6095de_0]  PartitionId [0]  Generation [0] Get partition location async, partition 0, delay 0.000000s
2025-11-11T14:16:08.541907Z :YDB_SDK TRACE: actor.cpp:37: 2025-11-11T14:16:08.541906Z :TRACE: [local] TRACE_EVENT DescribePartitionRequest  path=local/recovery_output partition_id=0
2025-11-11T14:16:08.541935Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:08.541931Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|1a66e246-ca5603b8-a5b5653a-1d6095de_0]  PartitionId [0]  Generation [0]  Getting partition location, partition 0
2025-11-11T14:16:08.543205Z :YDB_SDK INFO: actor.cpp:37: 2025-11-11T14:16:08.543198Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|1a66e246-ca5603b8-a5b5653a-1d6095de_0]  PartitionId [0]  Generation [0] Got PartitionLocation response. Status SUCCESS, proto:
partition {
  active: true
  partition_location {
    node_id: 1
    generation: 1
  }
}

2025-11-11T14:16:08.543220Z :YDB_SDK TRACE: actor.cpp:37: 2025-11-11T14:16:08.543217Z :TRACE: [local] TRACE_EVENT DescribePartitionResponse  partition_id=0 active=1 pl_node_id=1 pl_generation=1
2025-11-11T14:16:08.543227Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:08.543224Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|1a66e246-ca5603b8-a5b5653a-1d6095de_0]  PartitionId [0]  Generation [0] GetPreferredEndpoint: partitionId 0, partitionNodeId 1 exists in the endpoint pool.
2025-11-11T14:16:08.543233Z :YDB_SDK TRACE: actor.cpp:37: 2025-11-11T14:16:08.543231Z :TRACE: [local] TRACE_EVENT PreferredPartitionLocation  Endpoint= NodeId=1 Generation=1
2025-11-11T14:16:08.543238Z :YDB_SDK INFO: actor.cpp:37: 2025-11-11T14:16:08.543236Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|1a66e246-ca5603b8-a5b5653a-1d6095de_0]  PartitionId [0]  Generation [1] Start write session. Will connect to nodeId: 1
2025-11-11T14:16:08.543507Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:08.543499Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|1a66e246-ca5603b8-a5b5653a-1d6095de_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 1, Msg: CANCELLED, Details: , InternalError: 0
2025-11-11T14:16:08.543603Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:08.543600Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|1a66e246-ca5603b8-a5b5653a-1d6095de_0]  PartitionId [0]  Generation [1] Write session: direct write to partition: 0, generation 1
2025-11-11T14:16:08.543625Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:08.543623Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|1a66e246-ca5603b8-a5b5653a-1d6095de_0]  PartitionId [0]  Generation [1] Write session: send init request: init_request { path: "recovery_output" producer_id: "4099ced-84888ba2-f13e9171-e3b8baec" partition_with_generation { generation: 1 } }
2025-11-11T14:16:08.543629Z :YDB_SDK TRACE: actor.cpp:37: 2025-11-11T14:16:08.543628Z :TRACE: [local] TRACE_EVENT InitRequest  pwg_partition_id=0 pwg_generation=1
2025-11-11T14:16:08.543717Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:08.543714Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|1a66e246-ca5603b8-a5b5653a-1d6095de_0]  PartitionId [0]  Generation [1] Write session: OnWriteDone gRpcStatusCode: 0
2025-11-11T14:16:08.550303Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:08.550295Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|1a66e246-ca5603b8-a5b5653a-1d6095de_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-11-11T14:16:08.550331Z :YDB_SDK INFO: actor.cpp:37: 2025-11-11T14:16:08.550329Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|1a66e246-ca5603b8-a5b5653a-1d6095de_0]  PartitionId [0]  Generation [1] Write session established. Init response: last_seq_no: 6 session_id: "4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0"
2025-11-11T14:16:08.550336Z :YDB_SDK TRACE: actor.cpp:37: 2025-11-11T14:16:08.550334Z :TRACE: [local] TRACE_EVENT InitResponse  partition_id=0 session_id=4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0
2025-11-11T14:16:08.550339Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:08.550338Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] Write session: set DirectWriteToPartitionId 0
2025-11-11T14:16:08.604281Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:08.604263Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 1 to 1
2025-11-11T14:16:08.604305Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:08.604303Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-11-11T14:16:08.604327Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:08.604324Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 1
2025-11-11T14:16:08.604447Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:08.604444Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 2 to 2
2025-11-11T14:16:08.604457Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:08.604455Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-11-11T14:16:08.604461Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:08.604459Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 2
2025-11-11T14:16:08.604527Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:08.604525Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 3 to 3
2025-11-11T14:16:08.604536Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:08.604535Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-11-11T14:16:08.604539Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:08.604538Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 3
2025-11-11T14:16:08.604576Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:08.604574Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 4 to 4
2025-11-11T14:16:08.604587Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:08.604585Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-11-11T14:16:08.604600Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:08.604589Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 4
2025-11-11T14:16:08.604636Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:08.604634Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 5 to 5
2025-11-11T14:16:08.604644Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:08.604642Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-11-11T14:16:08.604647Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:08.604645Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 5
2025-11-11T14:16:08.604680Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:08.604678Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 6 to 6
2025-11-11T14:16:08.604689Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:08.604687Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-11-11T14:16:08.604692Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:08.604690Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 6
2025-11-11T14:16:08.605517Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:08.605510Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-11-11T14:16:08.605569Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:08.605566Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 1 skipped { reason: REASON_ALREADY_WRITTEN } } write_statistics { persisting_time { } min_queue_wait_time { } max_queue_wait_time { } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-11-11T14:16:08.605574Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:08.605572Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] OnAck: seqNo=1, txId=?
2025-11-11T14:16:08.605578Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:08.605577Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 1
2025-11-11T14:16:08.605731Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:08.605727Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-11-11T14:16:08.605765Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:08.605763Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 2 skipped { reason: REASON_ALREADY_WRITTEN } } write_statistics { persisting_time { } min_queue_wait_time { } max_queue_wait_time { } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-11-11T14:16:08.605769Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:08.605768Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] OnAck: seqNo=2, txId=?
2025-11-11T14:16:08.605773Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:08.605771Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 2
2025-11-11T14:16:08.605877Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:447: SelfId: [1:7571471438992075144:2154], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. Ack seq no 1
2025-11-11T14:16:08.605886Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:447: SelfId: [1:7571471438992075144:2154], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. Ack seq no 2
2025-11-11T14:16:08.605925Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:08.605920Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-11-11T14:16:08.605957Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:08.605955Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 3 skipped { reason: REASON_ALREADY_WRITTEN } } write_statistics { persisting_time { } min_queue_wait_time { } max_queue_wait_time { } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-11-11T14:16:08.605965Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:08.605963Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] OnAck: seqNo=3, txId=?
2025-11-11T14:16:08.605969Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:08.605967Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 3
2025-11-11T14:16:08.606246Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:447: SelfId: [1:7571471438992075144:2154], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. Ack seq no 3
2025-11-11T14:16:08.606260Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:08.606252Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-11-11T14:16:08.606286Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:08.606284Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 4 skipped { reason: REASON_ALREADY_WRITTEN } } write_statistics { persisting_time { } min_queue_wait_time { } max_queue_wait_time { } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-11-11T14:16:08.606306Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:08.606304Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] OnAck: seqNo=4, txId=?
2025-11-11T14:16:08.606313Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:08.606311Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 4
2025-11-11T14:16:08.606368Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:08.606366Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-11-11T14:16:08.606384Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:08.606382Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 5 skipped { reason: REASON_ALREADY_WRITTEN } } write_statistics { persisting_time { } min_queue_wait_time { } max_queue_wait_time { } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-11-11T14:16:08.606392Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:08.606390Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] OnAck: seqNo=5, txId=?
2025-11-11T14:16:08.606394Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:08.606393Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 5
2025-11-11T14:16:08.606533Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:08.606526Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-11-11T14:16:08.606567Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:08.606565Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 6 skipped { reason: REASON_ALREADY_WRITTEN } } write_statistics { persisting_time { } min_queue_wait_time { } max_queue_wait_time { } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-11-11T14:16:08.606575Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:08.606574Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] OnAck: seqNo=6, txId=?
2025-11-11T14:16:08.606579Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:08.606577Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 6
2025-11-11T14:16:08.606649Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:447: SelfId: [1:7571471438992075144:2154], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. Ack seq no 4
2025-11-11T14:16:08.606659Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:447: SelfId: [1:7571471438992075144:2154], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. Ack seq no 5
2025-11-11T14:16:08.606661Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:447: SelfId: [1:7571471438992075144:2154], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. Ack seq no 6
2025-11-11T14:16:09.234004Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: dc8c4f03-e6403fb7-5183aafd-31e8b0933, Host: ghrun-vb3yoermsa, Tenant: /compute
2025-11-11T14:16:09.234008Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:542: Coordinator: Send TEvGetNodesRequest to NodesManager
2025-11-11T14:16:09.234019Z :YQL_NODES_MANAGER DEBUG: nodes_manager.cpp:300: TNodesManagerActor::TEvGetNodesRequest
2025-11-11T14:16:09.234035Z :FQ_ROW_DISPATCHER INFO: coordinator.cpp:573: Coordinator: Updated node info, node count: 2
2025-11-11T14:16:09.234224Z :FQ_QUOTA_SERVICE DEBUG: quota_manager.cpp:230: IC Peers[1]: [2]
2025-11-11T14:16:09.244622Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-11T14:16:09.244634Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-11T14:16:09.364269Z :YQL_PROXY TRACE: log.cpp:64: SessionId:  2025-11-11 14:16:09.364 TRACE ydbd(pid=938393, tid=0x00007F21092AB640) [DQ] task_controller_impl.h:271:  [1:7571471438992075115:2146] ExportStats Summary
2025-11-11T14:16:09.364466Z :FQ_PINGER TRACE: pinger.cpp:250: QueryId: ptqudslmrdgp1dc4lsfk, Owner: dc8c4f03-e6403fb7-5183aafd-31e8b0931 Forward ping request: { statistics: "{\"Graph=0\":{\"TaskRunner\":{\"Stage=209442\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":2,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":2,\"count\":1,\"avg\":2,\"max\":2,\"min\":2}},\"Stage=Total\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":2,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":2,\"count\":1,\"avg\":2,\"max\":2,\"min\":2}}}}}" }
2025-11-11T14:16:09.364476Z :FQ_PINGER TRACE: pinger.cpp:393: QueryId: ptqudslmrdgp1dc4lsfk, Owner: dc8c4f03-e6403fb7-5183aafd-31e8b0931 Forward request Private::PingTask
2025-11-11T14:16:09.383454Z :FQ_PINGER TRACE: pinger.cpp:338: QueryId: ptqudslmrdgp1dc4lsfk, Owner: dc8c4f03-e6403fb7-5183aafd-31e8b0931 Ping response success: { expired_at { seconds: 1762870589 nanos: 371000000 } }
2025-11-11T14:16:09.383493Z :FQ_RUN_ACTOR TRACE: run_actor.cpp:861: QueryId: ptqudslmrdgp1dc4lsfk Forward ping response. Success: 1. Cookie: 6
2025-11-11T14:16:09.421781Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:09.421772Z :DEBUG: [local] [local] [947d54ec-62bd4fc7-2cecea62-e73c4d1e] [] Got ReadResponse, serverBytesSize = 223, now ReadSizeBudget = 0, ReadSizeServerDelta = 8388385
2025-11-11T14:16:09.421818Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:09.421816Z :DEBUG: [local] [local] [947d54ec-62bd4fc7-2cecea62-e73c4d1e] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 8388385
2025-11-11T14:16:09.421845Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:09.421842Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (6-13)
2025-11-11T14:16:09.421850Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:09.421848Z :DEBUG: [local] [local] [947d54ec-62bd4fc7-2cecea62-e73c4d1e] [] Returning serverBytesSize = 223 to budget
2025-11-11T14:16:09.421861Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:09.421857Z :DEBUG: [local] [local] [947d54ec-62bd4fc7-2cecea62-e73c4d1e] [] In ContinueReadingDataImpl, ReadSizeBudget = 223, ReadSizeServerDelta = 8388385
2025-11-11T14:16:09.421913Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:09.421911Z :DEBUG: [local] [local] [947d54ec-62bd4fc7-2cecea62-e73c4d1e] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 8388608
2025-11-11T14:16:09.421990Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:354: SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, task: 1. PQ source. SessionId: 947d54ec-62bd4fc7-2cecea62-e73c4d1e Source data ready
2025-11-11T14:16:09.422017Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1491: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Poll inputs
2025-11-11T14:16:09.422019Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1506: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Poll sources
2025-11-11T14:16:09.422024Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:533: SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, task: 1. PQ source. SessionId: 947d54ec-62bd4fc7-2cecea62-e73c4d1e GetAsyncInputData freeSpace = 1000000
2025-11-11T14:16:09.422042Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:09.422038Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (6-6)
2025-11-11T14:16:09.422047Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:09.422046Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 1} (7-7)
2025-11-11T14:16:09.422051Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:09.422050Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 2} (8-8)
2025-11-11T14:16:09.422054Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:09.422053Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 3} (9-9)
2025-11-11T14:16:09.422059Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:09.422058Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 4} (10-10)
2025-11-11T14:16:09.422063Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:09.422062Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 5} (11-11)
2025-11-11T14:16:09.422074Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:09.422065Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 6} (12-12)
2025-11-11T14:16:09.422077Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:09.422076Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 7} (13-13)
2025-11-11T14:16:09.422086Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:09.422084Z :DEBUG: [local] [local] [947d54ec-62bd4fc7-2cecea62-e73c4d1e] [] The application data is transferred to the client. Number of messages 8, size 16 bytes
2025-11-11T14:16:09.422095Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:09.422093Z :DEBUG: [local] [local] [947d54ec-62bd4fc7-2cecea62-e73c4d1e] [] Returning serverBytesSize = 0 to budget
2025-11-11T14:16:09.422109Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:748: SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, task: 1. PQ source. SessionId: 947d54ec-62bd4fc7-2cecea62-e73c4d1e Key: 0@ Data received: Message { Data: "21" Information: { Offset: 6 ProducerId: "" SeqNo: 0 CreateTime: 2025-11-11T14:16:09.418000Z WriteTime: 2025-11-11T14:16:09.417000Z MessageGroupId: "" Meta: { } MessageMeta: { } } Partition session id: 1 Topic: "recovery_input" Partition: 0 }
2025-11-11T14:16:09.422125Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:748: SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, task: 1. PQ source. SessionId: 947d54ec-62bd4fc7-2cecea62-e73c4d1e Key: 0@ Data received: Message { Data: "23" Information: { Offset: 7 ProducerId: "" SeqNo: 0 CreateTime: 2025-11-11T14:16:09.418000Z WriteTime: 2025-11-11T14:16:09.417000Z MessageGroupId: "" Meta: { } MessageMeta: { } } Partition session id: 1 Topic: "recovery_input" Partition: 0 }
2025-11-11T14:16:09.422129Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:748: SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, task: 1. PQ source. SessionId: 947d54ec-62bd4fc7-2cecea62-e73c4d1e Key: 0@ Data received: Message { Data: "24" Information: { Offset: 8 ProducerId: "" SeqNo: 0 CreateTime: 2025-11-11T14:16:09.418000Z WriteTime: 2025-11-11T14:16:09.417000Z MessageGroupId: "" Meta: { } MessageMeta: { } } Partition session id: 1 Topic: "recovery_input" Partition: 0 }
2025-11-11T14:16:09.422132Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:748: SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, task: 1. PQ source. SessionId: 947d54ec-62bd4fc7-2cecea62-e73c4d1e Key: 0@ Data received: Message { Data: "26" Information: { Offset: 9 ProducerId: "" SeqNo: 0 CreateTime: 2025-11-11T14:16:09.418000Z WriteTime: 2025-11-11T14:16:09.417000Z MessageGroupId: "" Meta: { } MessageMeta: { } } Partition session id: 1 Topic: "recovery_input" Partition: 0 }
2025-11-11T14:16:09.422140Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:748: SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, task: 1. PQ source. SessionId: 947d54ec-62bd4fc7-2cecea62-e73c4d1e Key: 0@ Data received: Message { Data: "27" Information: { Offset: 10 ProducerId: "" SeqNo: 0 CreateTime: 2025-11-11T14:16:09.418000Z WriteTime: 2025-11-11T14:16:09.417000Z MessageGroupId: "" Meta: { } MessageMeta: { } } Partition session id: 1 Topic: "recovery_input" Partition: 0 }
2025-11-11T14:16:09.422143Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:748: SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, task: 1. PQ source. SessionId: 947d54ec-62bd4fc7-2cecea62-e73c4d1e Key: 0@ Data received: Message { Data: "28" Information: { Offset: 11 ProducerId: "" SeqNo: 0 CreateTime: 2025-11-11T14:16:09.418000Z WriteTime: 2025-11-11T14:16:09.417000Z MessageGroupId: "" Meta: { } MessageMeta: { } } Partition session id: 1 Topic: "recovery_input" Partition: 0 }
2025-11-11T14:16:09.422146Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:748: SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, task: 1. PQ source. SessionId: 947d54ec-62bd4fc7-2cecea62-e73c4d1e Key: 0@ Data received: Message { Data: "29" Information: { Offset: 12 ProducerId: "" SeqNo: 0 CreateTime: 2025-11-11T14:16:09.418000Z WriteTime: 2025-11-11T14:16:09.417000Z MessageGroupId: "" Meta: { } MessageMeta: { } } Partition session id: 1 Topic: "recovery_input" Partition: 0 }
2025-11-11T14:16:09.422149Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:748: SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, task: 1. PQ source. SessionId: 947d54ec-62bd4fc7-2cecea62-e73c4d1e Key: 0@ Data received: Message { Data: "30" Information: { Offset: 13 ProducerId: "" SeqNo: 0 CreateTime: 2025-11-11T14:16:09.418000Z WriteTime: 2025-11-11T14:16:09.417000Z MessageGroupId: "" Meta: { } MessageMeta: { } } Partition session id: 1 Topic: "recovery_input" Partition: 0 }
2025-11-11T14:16:09.422170Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:724: SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, task: 1. PQ source. SessionId: 947d54ec-62bd4fc7-2cecea62-e73c4d1e Return ready batch. DataCount = 8 Watermark = none Used space = 16
2025-11-11T14:16:09.422172Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:77: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Poll async input 0. Buffer free space: 1000000, read from async input: 16 bytes, 8 rows, finished: 0
2025-11-11T14:16:09.422189Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:354: SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, task: 1. PQ source. SessionId: 947d54ec-62bd4fc7-2cecea62-e73c4d1e Source data ready
2025-11-11T14:16:09.422192Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-11-11T14:16:09.422199Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1491: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Poll inputs
2025-11-11T14:16:09.422200Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1506: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Poll sources
2025-11-11T14:16:09.422202Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:533: SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, task: 1. PQ source. SessionId: 947d54ec-62bd4fc7-2cecea62-e73c4d1e GetAsyncInputData freeSpace = 999984
2025-11-11T14:16:09.422204Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:77: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Poll async input 0. Buffer free space: 999984, read from async input: 0 bytes, 0 rows, finished: 0
2025-11-11T14:16:09.422270Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-11-11T14:16:09.422285Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1491: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Poll inputs
2025-11-11T14:16:09.422287Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1506: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Poll sources
2025-11-11T14:16:09.422288Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:533: SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, task: 1. PQ source. SessionId: 947d54ec-62bd4fc7-2cecea62-e73c4d1e GetAsyncInputData freeSpace = 999984
2025-11-11T14:16:09.422291Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:77: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Poll async input 0. Buffer free space: 999984, read from async input: 0 bytes, 0 rows, finished: 0
2025-11-11T14:16:09.422295Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. update task runner stats
2025-11-11T14:16:09.422319Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-11T14:16:09.422326Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-11T14:16:09.422328Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:571: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-11-11T14:16:09.422333Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-11-11T14:16:09.422339Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:188: SelfId: [1:7571471438992075144:2154], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. SendData. Batch: 8. Checkpoint: 0. Finished: 0
2025-11-11T14:16:09.422341Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:214: SelfId: [1:7571471438992075144:2154], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. Received data for sending: 21
2025-11-11T14:16:09.422343Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:214: SelfId: [1:7571471438992075144:2154], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. Received data for sending: 23
2025-11-11T14:16:09.422344Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:214: SelfId: [1:7571471438992075144:2154], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. Received data for sending: 24
2025-11-11T14:16:09.422345Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:214: SelfId: [1:7571471438992075144:2154], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. Received data for sending: 26
2025-11-11T14:16:09.422345Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:214: SelfId: [1:7571471438992075144:2154], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. Received data for sending: 27
2025-11-11T14:16:09.422346Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:214: SelfId: [1:7571471438992075144:2154], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. Received data for sending: 28
2025-11-11T14:16:09.422347Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:214: SelfId: [1:7571471438992075144:2154], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. Received data for sending: 29
2025-11-11T14:16:09.422348Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:214: SelfId: [1:7571471438992075144:2154], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. Received data for sending: 30
2025-11-11T14:16:09.422362Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:09.422360Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 7 to 7
2025-11-11T14:16:09.422380Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:09.422378Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-11-11T14:16:09.422384Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:09.422382Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 7
2025-11-11T14:16:09.422488Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1023: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Sink 0: sent 40 bytes of data and 0 bytes of checkpoint barrier
2025-11-11T14:16:09.422494Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1027: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Drain sink 0. Free space decreased: 16, sent data from buffer: 40
2025-11-11T14:16:09.422515Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1491: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Poll inputs
2025-11-11T14:16:09.422520Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1506: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Poll sources
2025-11-11T14:16:09.422523Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:533: SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, task: 1. PQ source. SessionId: 947d54ec-62bd4fc7-2cecea62-e73c4d1e GetAsyncInputData freeSpace = 1000000
2025-11-11T14:16:09.422525Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:77: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Poll async input 0. Buffer free space: 1000000, read from async input: 0 bytes, 0 rows, finished: 0
2025-11-11T14:16:09.422529Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. update task runner stats
2025-11-11T14:16:09.422537Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-11T14:16:09.422539Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-11T14:16:09.422540Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:571: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. About to drain sink 0. FreeSpace: 16777200, allowedOvercommit: 500000, toSend: 17277200
2025-11-11T14:16:09.422543Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-11-11T14:16:09.422545Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:188: SelfId: [1:7571471438992075144:2154], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-11-11T14:16:09.422547Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1023: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-11-11T14:16:09.422548Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1027: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-11-11T14:16:09.422557Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. update task runner stats
2025-11-11T14:16:09.422562Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-11T14:16:09.422564Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-11T14:16:09.422565Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:571: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. About to drain sink 0. FreeSpace: 16777200, allowedOvercommit: 500000, toSend: 17277200
2025-11-11T14:16:09.422567Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:188: SelfId: [1:7571471438992075144:2154], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-11-11T14:16:09.422569Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1023: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-11-11T14:16:09.422570Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1027: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-11-11T14:16:09.422578Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. update task runner stats
2025-11-11T14:16:09.422582Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-11T14:16:09.422583Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-11T14:16:09.422584Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:571: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. About to drain sink 0. FreeSpace: 16777200, allowedOvercommit: 500000, toSend: 17277200
2025-11-11T14:16:09.422586Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:188: SelfId: [1:7571471438992075144:2154], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-11-11T14:16:09.422587Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1023: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-11-11T14:16:09.422588Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1027: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-11-11T14:16:09.425468Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:09.425461Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 8 to 8
2025-11-11T14:16:09.425492Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:09.425489Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-11-11T14:16:09.425497Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:09.425494Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 8
2025-11-11T14:16:09.425602Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:09.425600Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 9 to 9
2025-11-11T14:16:09.425613Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:09.425611Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-11-11T14:16:09.425616Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:09.425614Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 9
2025-11-11T14:16:09.425661Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:09.425660Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 10 to 10
2025-11-11T14:16:09.425672Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:09.425670Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-11-11T14:16:09.425674Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:09.425673Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 10
2025-11-11T14:16:09.425707Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:09.425705Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 11 to 11
2025-11-11T14:16:09.425714Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:09.425713Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-11-11T14:16:09.425717Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:09.425716Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 11
2025-11-11T14:16:09.425753Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:09.425751Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 12 to 12
2025-11-11T14:16:09.425762Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:09.425761Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-11-11T14:16:09.425764Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:09.425763Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 12
2025-11-11T14:16:09.425790Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:09.425789Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 13 to 13
2025-11-11T14:16:09.425794Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:09.425792Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-11-11T14:16:09.425797Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:09.425795Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 13
2025-11-11T14:16:09.425825Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:09.425824Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 14 to 14
2025-11-11T14:16:09.425833Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:09.425831Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-11-11T14:16:09.425835Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:09.425834Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 14
2025-11-11T14:16:09.428448Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:09.428442Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-11-11T14:16:09.428486Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:09.428483Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 7 written { offset: 22 } } write_statistics { persisting_time { nanos: 1000000 } min_queue_wait_time { nanos: 1000000 } max_queue_wait_time { nanos: 1000000 } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-11-11T14:16:09.428495Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:09.428492Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] OnAck: seqNo=7, txId=?
2025-11-11T14:16:09.428498Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:09.428497Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 7
2025-11-11T14:16:09.428555Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:09.428553Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-11-11T14:16:09.428570Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:09.428569Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 8 written { offset: 23 } } write_statistics { persisting_time { nanos: 1000000 } min_queue_wait_time { nanos: 1000000 } max_queue_wait_time { nanos: 1000000 } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-11-11T14:16:09.428576Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:09.428575Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] OnAck: seqNo=8, txId=?
2025-11-11T14:16:09.428579Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:09.428578Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 8
2025-11-11T14:16:09.428610Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:09.428609Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-11-11T14:16:09.428626Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:09.428624Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 9 written { offset: 24 } } write_statistics { persisting_time { nanos: 1000000 } min_queue_wait_time { nanos: 1000000 } max_queue_wait_time { nanos: 1000000 } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-11-11T14:16:09.428633Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:09.428632Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] OnAck: seqNo=9, txId=?
2025-11-11T14:16:09.428635Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:09.428634Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 9
2025-11-11T14:16:09.428652Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:09.428650Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-11-11T14:16:09.428666Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:09.428664Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 10 written { offset: 25 } } write_statistics { persisting_time { nanos: 1000000 } min_queue_wait_time { nanos: 1000000 } max_queue_wait_time { nanos: 1000000 } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-11-11T14:16:09.428672Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:09.428670Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] OnAck: seqNo=10, txId=?
2025-11-11T14:16:09.428675Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:09.428673Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 10
2025-11-11T14:16:09.428692Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:09.428690Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-11-11T14:16:09.428706Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:09.428705Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 11 written { offset: 26 } } write_statistics { persisting_time { nanos: 1000000 } min_queue_wait_time { nanos: 1000000 } max_queue_wait_time { nanos: 1000000 } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-11-11T14:16:09.428712Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:09.428711Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] OnAck: seqNo=11, txId=?
2025-11-11T14:16:09.428714Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:09.428713Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 11
2025-11-11T14:16:09.428731Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:09.428730Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-11-11T14:16:09.428740Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:09.428739Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 12 written { offset: 27 } } write_statistics { persisting_time { nanos: 1000000 } min_queue_wait_time { nanos: 1000000 } max_queue_wait_time { nanos: 1000000 } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-11-11T14:16:09.428742Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:09.428741Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] OnAck: seqNo=12, txId=?
2025-11-11T14:16:09.428755Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:09.428744Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 12
2025-11-11T14:16:09.428771Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:09.428768Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-11-11T14:16:09.428781Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:09.428780Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 13 written { offset: 28 } } write_statistics { persisting_time { nanos: 1000000 } min_queue_wait_time { nanos: 1000000 } max_queue_wait_time { nanos: 1000000 } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-11-11T14:16:09.428783Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:09.428782Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] OnAck: seqNo=13, txId=?
2025-11-11T14:16:09.428785Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:09.428784Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 13
2025-11-11T14:16:09.428800Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:09.428799Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-11-11T14:16:09.428810Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:09.428808Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 14 written { offset: 29 } } write_statistics { persisting_time { nanos: 1000000 } min_queue_wait_time { nanos: 1000000 } max_queue_wait_time { nanos: 1000000 } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-11-11T14:16:09.428813Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:09.428811Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] OnAck: seqNo=14, txId=?
2025-11-11T14:16:09.428815Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:09.428814Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 14
2025-11-11T14:16:09.429496Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:447: SelfId: [1:7571471438992075144:2154], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. Ack seq no 7
2025-11-11T14:16:09.429507Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:447: SelfId: [1:7571471438992075144:2154], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. Ack seq no 8
2025-11-11T14:16:09.429508Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:447: SelfId: [1:7571471438992075144:2154], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. Ack seq no 9
2025-11-11T14:16:09.429509Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:447: SelfId: [1:7571471438992075144:2154], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. Ack seq no 10
2025-11-11T14:16:09.429513Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:447: SelfId: [1:7571471438992075144:2154], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. Ack seq no 11
2025-11-11T14:16:09.429514Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:447: SelfId: [1:7571471438992075144:2154], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. Ack seq no 12
2025-11-11T14:16:09.429515Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:447: SelfId: [1:7571471438992075144:2154], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. Ack seq no 13
2025-11-11T14:16:09.429516Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:447: SelfId: [1:7571471438992075144:2154], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. Ack seq no 14
2025-11-11T14:16:09.493069Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:373: [ptqudslmrdgp1dc4lsfk-0.3] Got TEvScheduleCheckpointing
2025-11-11T14:16:09.493081Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:349: [ptqudslmrdgp1dc4lsfk-0.3] [3:1] Registering new checkpoint in storage
2025-11-11T14:16:09.493170Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:253: [ptqudslmrdgp1dc4lsfk-0.3] [3:1] Got TEvCreateCheckpointRequest
2025-11-11T14:16:09.496859Z :YDB_SDK INFO: actor.cpp:37: 2025-11-11T14:16:09.496850Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:recovery_input:0:1:13:0
2025-11-11T14:16:09.496875Z :YDB_SDK INFO: actor.cpp:37: 2025-11-11T14:16:09.496873Z :INFO: [local] [local] [947d54ec-62bd4fc7-2cecea62-e73c4d1e] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1003 BytesRead: 26 MessagesRead: 14 BytesReadCompressed: 26 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:16:09.522000Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:295: [ptqudslmrdgp1dc4lsfk-0.3] [3:1] Checkpoint created
2025-11-11T14:16:09.522012Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:297: [ptqudslmrdgp1dc4lsfk-0.3] [3:1] Send TEvCreateCheckpointResponse
2025-11-11T14:16:09.522153Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:389: [ptqudslmrdgp1dc4lsfk-0.3] [3:1] Got TEvCreateCheckpointResponse
2025-11-11T14:16:09.522163Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:435: [ptqudslmrdgp1dc4lsfk-0.3] [3:1] Checkpoint successfully created, going to inject barriers to 2 actor(s)
2025-11-11T14:16:09.522201Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:239: [ptqudslmrdgp1dc4lsfk-0] Task: 1. [Checkpoint 3.1] TEvInjectCheckpoint
2025-11-11T14:16:09.522214Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1491: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Poll inputs
2025-11-11T14:16:09.522216Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1502: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Skip polling sources because of pending checkpoint
2025-11-11T14:16:09.522219Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. DoExecuteImpl: 1
2025-11-11T14:16:09.522287Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:510: SelfId: [1:7571471438992075133:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Pending 1 checkpoints to be sent
2025-11-11T14:16:09.522296Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. update task runner stats
2025-11-11T14:16:09.522331Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 1 watermark injected: (empty maybe)
2025-11-11T14:16:09.522335Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:447: [ptqudslmrdgp1dc4lsfk-0] Task: 1. [Checkpoint 3.1] Performing task checkpoint
2025-11-11T14:16:09.522337Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:822: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Save state
2025-11-11T14:16:09.522349Z :KQP_COMPUTE DEBUG: dq_pq_read_actor_base.cpp:94: SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, task: 1. PQ source. SessionId: 947d54ec-62bd4fc7-2cecea62-e73c4d1e SaveState, offsets: {0,14},
2025-11-11T14:16:09.522361Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:474: [ptqudslmrdgp1dc4lsfk-0] Task: 1. [Checkpoint 3.1] CA state saved
2025-11-11T14:16:09.522364Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:449: [ptqudslmrdgp1dc4lsfk-0] Task: 1. [Checkpoint 3.1] Injecting checkpoint barrier to outputs
2025-11-11T14:16:09.522368Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-11T14:16:09.522372Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:571: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-11-11T14:16:09.522380Z :KQP_COMPUTE INFO: dq_async_compute_actor.cpp:1008: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Resume inputs
2025-11-11T14:16:09.522385Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:188: SelfId: [1:7571471438992075144:2154], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. SendData. Batch: 0. Checkpoint: 1. Finished: 0
2025-11-11T14:16:09.522388Z :KQP_COMPUTE DEBUG: dq_pq_write_actor.cpp:233: SelfId: [1:7571471438992075144:2154], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. [Checkpoint 3.1] Send checkpoint state immediately
2025-11-11T14:16:09.522416Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:411: SelfId: [1:7571471438992075144:2154], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. Save checkpoint { Id: 1 Generation: 3 Type: CHECKPOINT_TYPE_SNAPSHOT } state: { SourceId: "4099ced-84888ba2-f13e9171-e3b8baec" ConfirmedSeqNo: 14 EgressBytes: 26 }
2025-11-11T14:16:09.522419Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:524: [ptqudslmrdgp1dc4lsfk-0] Task: 1. Sink[0] state saved
2025-11-11T14:16:09.522439Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:536: [ptqudslmrdgp1dc4lsfk-0] Task: 1. [Checkpoint 3.1] Task checkpoint is done. Send to storage
2025-11-11T14:16:09.522447Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1023: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Sink 0: sent 0 bytes of data and 6 bytes of checkpoint barrier
2025-11-11T14:16:09.522450Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1027: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-11-11T14:16:09.522454Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1491: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Poll inputs
2025-11-11T14:16:09.522455Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1506: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Poll sources
2025-11-11T14:16:09.522459Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:533: SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, task: 1. PQ source. SessionId: 947d54ec-62bd4fc7-2cecea62-e73c4d1e GetAsyncInputData freeSpace = 1000000
2025-11-11T14:16:09.522461Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:409: [ptqudslmrdgp1dc4lsfk-0] [3:1] Got TEvSaveTaskState: task 1
2025-11-11T14:16:09.522476Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:77: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Poll async input 0. Buffer free space: 1000000, read from async input: 0 bytes, 0 rows, finished: 0
2025-11-11T14:16:09.522486Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-11-11T14:16:09.522500Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. update task runner stats
2025-11-11T14:16:09.522507Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-11T14:16:09.522510Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-11T14:16:09.522512Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:571: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-11-11T14:16:09.522515Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:188: SelfId: [1:7571471438992075144:2154], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-11-11T14:16:09.522517Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1023: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-11-11T14:16:09.522518Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1027: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-11-11T14:16:09.526291Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:433: [ptqudslmrdgp1dc4lsfk-0] [3:1] TEvSaveTaskState Apply: task: 1
2025-11-11T14:16:09.526302Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:448: [ptqudslmrdgp1dc4lsfk-0] [3:1] Send TEvSaveTaskStateResult: task: 1
2025-11-11T14:16:09.526378Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:466: [ptqudslmrdgp1dc4lsfk-0.3] [3:1] Got TEvSaveTaskStateResult; task 1, status: OK, size: 168
2025-11-11T14:16:09.526384Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:476: [ptqudslmrdgp1dc4lsfk-0.3] [3:1] Task state saved, need 1 more acks
2025-11-11T14:16:09.529427Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:466: [ptqudslmrdgp1dc4lsfk-0.3] [3:1] Got TEvSaveTaskStateResult; task 2, status: OK, size: 171
2025-11-11T14:16:09.529436Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:476: [ptqudslmrdgp1dc4lsfk-0.3] [3:1] Task state saved, need 0 more acks
2025-11-11T14:16:09.529438Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:489: [ptqudslmrdgp1dc4lsfk-0.3] [3:1] Got all acks, changing checkpoint status to 'PendingCommit'
2025-11-11T14:16:09.529452Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:305: [ptqudslmrdgp1dc4lsfk-0.3] [3:1] Got TEvSetCheckpointPendingCommitStatusRequest
2025-11-11T14:16:09.556290Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:320: [ptqudslmrdgp1dc4lsfk-0.3] [3:1] Status updated to 'PendingCommit'
2025-11-11T14:16:09.556301Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:322: [ptqudslmrdgp1dc4lsfk-0.3] [3:1] Send TEvSetCheckpointPendingCommitStatusResponse
2025-11-11T14:16:09.556322Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:501: [ptqudslmrdgp1dc4lsfk-0.3] [3:1] Got TEvSetCheckpointPendingCommitStatusResponse
2025-11-11T14:16:09.556327Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:516: [ptqudslmrdgp1dc4lsfk-0.3] [3:1] Checkpoint status changed to 'PendingCommit', committing states to 2 actor(s)
2025-11-11T14:16:09.556372Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:746: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Commit state
2025-11-11T14:16:09.556392Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:09.556388Z :DEBUG: [local] [local] [947d54ec-62bd4fc7-2cecea62-e73c4d1e] [] Commit offsets [0, 14). Partition stream id: 1
2025-11-11T14:16:09.556502Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:532: [ptqudslmrdgp1dc4lsfk-0.3] [3:1] Got TEvStateCommitted; task: 1
2025-11-11T14:16:09.556511Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:541: [ptqudslmrdgp1dc4lsfk-0.3] [3:1] State committed [1:7571471438992075131:2154], need 1 more acks
2025-11-11T14:16:09.556817Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:532: [ptqudslmrdgp1dc4lsfk-0.3] [3:1] Got TEvStateCommitted; task: 2
2025-11-11T14:16:09.556827Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:541: [ptqudslmrdgp1dc4lsfk-0.3] [3:1] State committed [2:7571471438441425389:2181], need 0 more acks
2025-11-11T14:16:09.556830Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:543: [ptqudslmrdgp1dc4lsfk-0.3] [3:1] Got all acks, changing checkpoint status to 'Completed'
2025-11-11T14:16:09.556845Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:330: [ptqudslmrdgp1dc4lsfk-0.3] [3:1] Got TEvCompleteCheckpointRequest
2025-11-11T14:16:09.561518Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:09.561509Z :DEBUG: [local] [local] [947d54ec-62bd4fc7-2cecea62-e73c4d1e] [] Committed response: { partitions_committed_offsets { partition_session_id: 1 committed_offset: 14 } }
2025-11-11T14:16:09.561639Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:354: SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, task: 1. PQ source. SessionId: 947d54ec-62bd4fc7-2cecea62-e73c4d1e Source data ready
2025-11-11T14:16:09.561659Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1491: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Poll inputs
2025-11-11T14:16:09.561662Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1506: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Poll sources
2025-11-11T14:16:09.561668Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:533: SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, task: 1. PQ source. SessionId: 947d54ec-62bd4fc7-2cecea62-e73c4d1e GetAsyncInputData freeSpace = 1000000
2025-11-11T14:16:09.561680Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:77: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Poll async input 0. Buffer free space: 1000000, read from async input: 0 bytes, 0 rows, finished: 0
2025-11-11T14:16:09.561695Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:354: SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, task: 1. PQ source. SessionId: 947d54ec-62bd4fc7-2cecea62-e73c4d1e Source data ready
2025-11-11T14:16:09.561704Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-11-11T14:16:09.561776Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1491: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Poll inputs
2025-11-11T14:16:09.561783Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1506: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Poll sources
2025-11-11T14:16:09.561791Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:533: SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, task: 1. PQ source. SessionId: 947d54ec-62bd4fc7-2cecea62-e73c4d1e GetAsyncInputData freeSpace = 1000000
2025-11-11T14:16:09.561795Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:77: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Poll async input 0. Buffer free space: 1000000, read from async input: 0 bytes, 0 rows, finished: 0
2025-11-11T14:16:09.561800Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. update task runner stats
2025-11-11T14:16:09.561833Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-11T14:16:09.561847Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-11T14:16:09.561853Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:571: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-11-11T14:16:09.561857Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-11-11T14:16:09.561864Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:188: SelfId: [1:7571471438992075144:2154], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-11-11T14:16:09.561869Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1023: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-11-11T14:16:09.561871Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1027: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-11-11T14:16:09.561888Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. update task runner stats
2025-11-11T14:16:09.561894Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-11T14:16:09.561896Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-11T14:16:09.561898Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:571: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-11-11T14:16:09.561902Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:188: SelfId: [1:7571471438992075144:2154], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-11-11T14:16:09.561904Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1023: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-11-11T14:16:09.561905Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1027: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-11-11T14:16:09.599025Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:348: [ptqudslmrdgp1dc4lsfk-0.3] [3:1] Status updated to 'Completed'
2025-11-11T14:16:09.599029Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:355: [ptqudslmrdgp1dc4lsfk-0.3] [3:1] Send TEvCompleteCheckpointResponse
2025-11-11T14:16:09.599078Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:564: [ptqudslmrdgp1dc4lsfk-0.3] [3:1] Got TEvCompleteCheckpointResponse
2025-11-11T14:16:09.599084Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:579: [ptqudslmrdgp1dc4lsfk-0.3] [3:1] Checkpoint completed
2025-11-11T14:16:10.233386Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:617: RowDispatcher: Send ping to [2:7571471408376654102:2082]
2025-11-11T14:16:10.233445Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1161: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-11-11T14:16:10.233813Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:623: RowDispatcher: NActors::TEvents::TEvPong
2025-11-11T14:16:10.234519Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: dc8c4f03-e6403fb7-5183aafd-31e8b0934, Host: ghrun-vb3yoermsa, Tenant: /compute
2025-11-11T14:16:10.242364Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-11T14:16:10.242376Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-11T14:16:10.365081Z :YQL_PROXY TRACE: log.cpp:64: SessionId:  2025-11-11 14:16:10.365 TRACE ydbd(pid=938393, tid=0x00007F21092AB640) [DQ] task_controller_impl.h:271:  [1:7571471438992075115:2146] ExportStats Summary
2025-11-11T14:16:10.365281Z :FQ_PINGER TRACE: pinger.cpp:250: QueryId: ptqudslmrdgp1dc4lsfk, Owner: dc8c4f03-e6403fb7-5183aafd-31e8b0931 Forward ping request: { statistics: "{\"Graph=0\":{\"TaskRunner\":{\"Stage=209442\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":2,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":2,\"count\":1,\"avg\":2,\"max\":2,\"min\":2}},\"Stage=Total\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":2,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":2,\"count\":1,\"avg\":2,\"max\":2,\"min\":2}}}}}" }
2025-11-11T14:16:10.365292Z :FQ_PINGER TRACE: pinger.cpp:393: QueryId: ptqudslmrdgp1dc4lsfk, Owner: dc8c4f03-e6403fb7-5183aafd-31e8b0931 Forward request Private::PingTask
2025-11-11T14:16:10.384706Z :FQ_PINGER TRACE: pinger.cpp:338: QueryId: ptqudslmrdgp1dc4lsfk, Owner: dc8c4f03-e6403fb7-5183aafd-31e8b0931 Ping response success: { action: ABORT expired_at { seconds: 1762870590 nanos: 374000000 } }
2025-11-11T14:16:10.384722Z :FQ_PINGER DEBUG: pinger.cpp:342: QueryId: ptqudslmrdgp1dc4lsfk, Owner: dc8c4f03-e6403fb7-5183aafd-31e8b0931 Query action: ABORT
2025-11-11T14:16:10.384744Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:690: QueryId: ptqudslmrdgp1dc4lsfk New query action received: ABORT
2025-11-11T14:16:10.384748Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:1827: QueryId: ptqudslmrdgp1dc4lsfk Is about to finish query with status ABORTED_BY_USER
2025-11-11T14:16:10.384753Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:1820: QueryId: ptqudslmrdgp1dc4lsfk Write finalizing status: ABORTING_BY_USER
2025-11-11T14:16:10.384763Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:528: QueryId: ptqudslmrdgp1dc4lsfk Cancel running query
2025-11-11T14:16:10.384777Z :FQ_RUN_ACTOR TRACE: run_actor.cpp:880: QueryId: ptqudslmrdgp1dc4lsfk Forward ping response. Success: 1. Cookie: 6
2025-11-11T14:16:10.384790Z :FQ_PINGER TRACE: pinger.cpp:250: QueryId: ptqudslmrdgp1dc4lsfk, Owner: dc8c4f03-e6403fb7-5183aafd-31e8b0931 Forward ping request: { status: ABORTING_BY_USER }
2025-11-11T14:16:10.384793Z :FQ_PINGER TRACE: pinger.cpp:393: QueryId: ptqudslmrdgp1dc4lsfk, Owner: dc8c4f03-e6403fb7-5183aafd-31e8b0931 Forward request Private::PingTask
2025-11-11T14:16:10.384917Z :YQL_PROXY DEBUG: log.cpp:64: SessionId:  2025-11-11 14:16:10.384 DEBUG ydbd(pid=938393, tid=0x00007F21092AB640) [DQ] task_controller_impl.h:130: AbortExecution from [1:7571471438992075111:2142]:ABORTED { <main>: Error: ABORTED_BY_USER }
2025-11-11T14:16:10.384933Z :YQL_PROXY DEBUG: log.cpp:64: SessionId:  2025-11-11 14:16:10.384 DEBUG ydbd(pid=938393, tid=0x00007F21092AB640) [DQ] task_controller_impl.h:598: OnError { <main>: Error: ABORTED_BY_USER } ABORTED
2025-11-11T14:16:10.385132Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudslmrdgp1dc4lsfk 2025-11-11 14:16:10.385 DEBUG ydbd(pid=938393, tid=0x00007F21092AB640) [DQ] executer_actor.cpp:304: {ptqudslmrdgp1dc4lsfk} OnFailure, status=4, issues size=1, sender=[1:7571471438992075115:2146]
2025-11-11T14:16:10.385150Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudslmrdgp1dc4lsfk 2025-11-11 14:16:10.385 DEBUG ydbd(pid=938393, tid=0x00007F21092AB640) [DQ] executer_actor.cpp:315: {ptqudslmrdgp1dc4lsfk} Issues: <main>: Error: ABORTED_BY_USER

2025-11-11T14:16:10.385159Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudslmrdgp1dc4lsfk 2025-11-11 14:16:10.385 DEBUG ydbd(pid=938393, tid=0x00007F21092AB640) [DQ] executer_actor.cpp:284: {ptqudslmrdgp1dc4lsfk} Finish with status=4 issues=<main>: Error: ABORTED_BY_USER

2025-11-11T14:16:10.385191Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudslmrdgp1dc4lsfk 2025-11-11 14:16:10.385 DEBUG ydbd(pid=938393, tid=0x00007F21092AB640) [DQ] executer_actor.cpp:341: {ptqudslmrdgp1dc4lsfk} OnQueryResponse status=4 issuses_size=1
2025-11-11T14:16:10.385240Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:1397: QueryId: ptqudslmrdgp1dc4lsfk TEvQueryResponse received on finish
2025-11-11T14:16:10.385246Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:1234: QueryId: ptqudslmrdgp1dc4lsfk Query response CANCELLED. Result set index: 0. Issues count: 1. Rows count: 0
2025-11-11T14:16:10.385533Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:657: [ptqudslmrdgp1dc4lsfk-0.3] PassAway
2025-11-11T14:16:10.385614Z :KQP_COMPUTE ERROR: dq_compute_actor_impl.h:1215: SelfId: [1:7571471438992075131:2154], TxId: ptqudslmrdgp1dc4lsfk, task: 1. Ctx: {}. Handle abort execution event from: [1:7571471438992074980:2064], status: UNAVAILABLE, reason: { <main>: Error: Aborted by LWM }
2025-11-11T14:16:10.385661Z :KQP_COMPUTE DEBUG: dq_compute_actor_channels.cpp:494: TxId: ptqudslmrdgp1dc4lsfk, task: 1. pass away
2025-11-11T14:16:10.385679Z :YDB_SDK INFO: actor.cpp:37: 2025-11-11T14:16:10.385676Z :INFO: [local] [local] [947d54ec-62bd4fc7-2cecea62-e73c4d1e] Closing read session. Close timeout: 0.000000s
2025-11-11T14:16:10.385695Z :YDB_SDK INFO: actor.cpp:37: 2025-11-11T14:16:10.385693Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:recovery_input:0:1:13:14
2025-11-11T14:16:10.385702Z :YDB_SDK INFO: actor.cpp:37: 2025-11-11T14:16:10.385701Z :INFO: [local] [local] [947d54ec-62bd4fc7-2cecea62-e73c4d1e] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1892 BytesRead: 26 MessagesRead: 14 BytesReadCompressed: 26 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:16:10.385713Z :YDB_SDK NOTICE: actor.cpp:37: 2025-11-11T14:16:10.385712Z :NOTICE: [local] [local] [947d54ec-62bd4fc7-2cecea62-e73c4d1e] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Close with zero timeout " }
2025-11-11T14:16:10.385720Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:10.385718Z :DEBUG: [local] [local] [947d54ec-62bd4fc7-2cecea62-e73c4d1e] [] Abort session to cluster
2025-11-11T14:16:10.385825Z :YDB_SDK INFO: actor.cpp:37: 2025-11-11T14:16:10.385823Z :INFO: [local] [local] [947d54ec-62bd4fc7-2cecea62-e73c4d1e] Closing read session. Close timeout: 0.000000s
2025-11-11T14:16:10.385836Z :YDB_SDK INFO: actor.cpp:37: 2025-11-11T14:16:10.385834Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:recovery_input:0:1:13:14
2025-11-11T14:16:10.385839Z :YDB_SDK INFO: actor.cpp:37: 2025-11-11T14:16:10.385838Z :INFO: [local] [local] [947d54ec-62bd4fc7-2cecea62-e73c4d1e] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1892 BytesRead: 26 MessagesRead: 14 BytesReadCompressed: 26 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:16:10.385845Z :YDB_SDK NOTICE: actor.cpp:37: 2025-11-11T14:16:10.385843Z :NOTICE: [local] [local] [947d54ec-62bd4fc7-2cecea62-e73c4d1e] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:16:10.386758Z :YDB_SDK INFO: actor.cpp:37: 2025-11-11T14:16:10.386753Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] Write session: close. Timeout 0.000000s
2025-11-11T14:16:10.386765Z :YDB_SDK INFO: actor.cpp:37: 2025-11-11T14:16:10.386764Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] Write session will now close
2025-11-11T14:16:10.386779Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:10.386778Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] Write session: aborting
2025-11-11T14:16:10.386855Z :YDB_SDK INFO: actor.cpp:37: 2025-11-11T14:16:10.386853Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] Write session: gracefully shut down, all writes complete
2025-11-11T14:16:10.386862Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:10.386861Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmrdgp1dc4lsfk, TaskId: 1, PQ sink. ]  SessionId [4099ced-84888ba2-f13e9171-e3b8baec|6cae5ad0-47b354-cb3f41f3-204ca7bc_0]  PartitionId [0]  Generation [1] Write session: destroy
2025-11-11T14:16:10.404783Z :FQ_PINGER TRACE: pinger.cpp:338: QueryId: ptqudslmrdgp1dc4lsfk, Owner: dc8c4f03-e6403fb7-5183aafd-31e8b0931 Ping response success: { action: ABORT expired_at { seconds: 1762870590 nanos: 392000000 } }
2025-11-11T14:16:10.404792Z :FQ_PINGER DEBUG: pinger.cpp:342: QueryId: ptqudslmrdgp1dc4lsfk, Owner: dc8c4f03-e6403fb7-5183aafd-31e8b0931 Query action: ABORT
2025-11-11T14:16:10.404814Z :FQ_RUN_ACTOR TRACE: run_actor.cpp:880: QueryId: ptqudslmrdgp1dc4lsfk Forward ping response. Success: 1. Cookie: 3
2025-11-11T14:16:10.404815Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:887: QueryId: ptqudslmrdgp1dc4lsfk Finalizing status is saved
2025-11-11T14:16:10.404850Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:1508: QueryId: ptqudslmrdgp1dc4lsfk Start rate limiter resource deleter
2025-11-11T14:16:10.404864Z :STREAMS DEBUG: read_rule_deleter.cpp:214: ptqudslmrdgp1dc4lsfk: Create read rule deleter actor for `recovery_input` [0]
2025-11-11T14:16:10.404880Z :STREAMS DEBUG: read_rule_deleter.cpp:106: ptqudslmrdgp1dc4lsfk: Make request for read rule deletion for topic `recovery_input` [0]
2025-11-11T14:16:10.455749Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:1499: QueryId: ptqudslmrdgp1dc4lsfk Rate limiter resource deletion finished. Success: 1. Issues: 
2025-11-11T14:16:10.455760Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:1919: QueryId: ptqudslmrdgp1dc4lsfk SendPingAndPassAway, FinalQueryStatus ABORTED_BY_USER
2025-11-11T14:16:10.455782Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:536: QueryId: ptqudslmrdgp1dc4lsfk PassAway
2025-11-11T14:16:10.455958Z :FQ_PINGER TRACE: pinger.cpp:250: QueryId: ptqudslmrdgp1dc4lsfk, Owner: dc8c4f03-e6403fb7-5183aafd-31e8b0931 Forward ping request: { result_id { value: "ptrudslmqvrm11rqlc8m" } status: ABORTED_BY_USER issues { message: "ABORTED_BY_USER" severity: 1 } statistics: "{\"Graph=0\":{\"Actor\":{\"ActorCreateTimeUs\":{\"sum\":\"83ms\",\"count\":2,\"avg\":\"41ms\",\"max\":\"62ms\",\"min\":\"21ms\"}},\"AllocateWorkersUs\":{\"sum\":\"63ms\",\"count\":1,\"avg\":\"63ms\",\"max\":\"63ms\",\"min\":\"63ms\"},\"ExecutionTimeUs\":{\"sum\":\"2.02s\",\"count\":1,\"avg\":\"2.02s\",\"max\":\"2.02s\",\"min\":\"2.02s\"},\"TaskRunner\":{\"Stage=209442\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":2,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":2,\"count\":1,\"avg\":2,\"max\":2,\"min\":2}},\"Stage=Total\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":2,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":2,\"count\":1,\"avg\":2,\"max\":2,\"min\":2}}},\"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_9fe90ee6-9f4b-469c-892e-6241e97d1618/rate_limiter" topic_consumers { database: "local" topic_path: "recovery_input" consumer_name: "ptqudslmrdgp1dc4lsfk" cluster_endpoint: "localhost:18945" token_name: "cluster:default_myyds" add_bearer_to_token: true } } finished_at { seconds: 1762870570 nanos: 384000000 } }
2025-11-11T14:16:10.455961Z :FQ_PINGER TRACE: pinger.cpp:393: QueryId: ptqudslmrdgp1dc4lsfk, Owner: dc8c4f03-e6403fb7-5183aafd-31e8b0931 Forward request Private::PingTask
2025-11-11T14:16:10.536167Z :FQ_PINGER TRACE: pinger.cpp:338: QueryId: ptqudslmrdgp1dc4lsfk, Owner: dc8c4f03-e6403fb7-5183aafd-31e8b0931 Ping response success: { action: ABORT }
2025-11-11T14:16:10.536194Z :FQ_PINGER DEBUG: pinger.cpp:379: QueryId: ptqudslmrdgp1dc4lsfk, Owner: dc8c4f03-e6403fb7-5183aafd-31e8b0931 Query finished
2025-11-11T14:16:10.536196Z :FQ_PINGER TRACE: pinger.cpp:187: QueryId: ptqudslmrdgp1dc4lsfk, Owner: dc8c4f03-e6403fb7-5183aafd-31e8b0931 Stop Pinger
2025-11-11T14:16:11.238229Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: dc8c4f03-e6403fb7-5183aafd-31e8b0935, Host: ghrun-vb3yoermsa, Tenant: /compute
2025-11-11T14:16:11.273657Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-11T14:16:11.273671Z :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:15257: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-vb3yoermsa.auto.internal:15257
2025-11-11T14:16:12.234305Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:617: RowDispatcher: Send ping to [2:7571471408376654102:2082]
2025-11-11T14:16:12.234321Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1161: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-11-11T14:16:12.234672Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:623: RowDispatcher: NActors::TEvents::TEvPong
2025-11-11T14:16:12.238442Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: dc8c4f03-e6403fb7-5183aafd-31e8b0936, Host: ghrun-vb3yoermsa, Tenant: /compute
2025-11-11T14:16:12.253175Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-11T14:16:12.253187Z :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:15257: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-vb3yoermsa.auto.internal:15257
2025-11-11T14:16:13.234820Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-11-11T14:16:13.239130Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: dc8c4f03-e6403fb7-5183aafd-31e8b0937, Host: ghrun-vb3yoermsa, Tenant: /compute
2025-11-11T14:16:13.241660Z :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:15257: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-vb3yoermsa.auto.internal:15257
2025-11-11T14:16:13.241676Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-11T14:16:13.241680Z :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:15257: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-vb3yoermsa.auto.internal:15257
2025-11-11T14:16:14.235231Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:617: RowDispatcher: Send ping to [2:7571471408376654102:2082]
2025-11-11T14:16:14.235257Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1161: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-11-11T14:16:14.239739Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: dc8c4f03-e6403fb7-5183aafd-31e8b0938, Host: ghrun-vb3yoermsa, Tenant: /compute
2025-11-11T14:16:14.241875Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:623: RowDispatcher: NActors::TEvents::TEvPong
2025-11-11T14:16:14.333687Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-11T14:16:14.333706Z :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:15257: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-vb3yoermsa.auto.internal:15257
2025-11-11T14:16:15.242425Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: dc8c4f03-e6403fb7-5183aafd-31e8b0939, Host: ghrun-vb3yoermsa, Tenant: /compute
2025-11-11T14:16:15.253762Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-11T14:16:15.253781Z :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:15257: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-vb3yoermsa.auto.internal:15257
2025-11-11T14:16:16.236112Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:617: RowDispatcher: Send ping to [2:7571471408376654102:2082]
2025-11-11T14:16:16.236141Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1161: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-11-11T14:16:16.236687Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:623: RowDispatcher: NActors::TEvents::TEvPong
2025-11-11T14:16:16.243281Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: dc8c4f03-e6403fb7-5183aafd-31e8b09310, Host: ghrun-vb3yoermsa, Tenant: /compute
2025-11-11T14:16:16.256221Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-11T14:16:16.256242Z :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:15257: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-vb3yoermsa.auto.internal:15257
2025-11-11T14:16:17.243724Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: dc8c4f03-e6403fb7-5183aafd-31e8b09311, Host: ghrun-vb3yoermsa, Tenant: /compute
2025-11-11T14:16:17.250470Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-11T14:16:17.250488Z :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:15257: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-vb3yoermsa.auto.internal:15257
