2025-12-09T03:42:24.275573Z :GRPC_SERVER NOTICE: grpc_request_proxy.cpp:380: Grpc request proxy started, nodeid# 1, serve as static node
2025-12-09T03:42:24.275635Z :GRPC_SERVER CRIT: grpc_request_proxy.cpp:440: Failed to deliver subscription request to config dispatcher
2025-12-09T03:42:24.275640Z :GRPC_SERVER NOTICE: grpc_request_proxy.cpp:380: Grpc request proxy started, nodeid# 1, serve as static node
2025-12-09T03:42:24.275658Z :GRPC_SERVER CRIT: grpc_request_proxy.cpp:440: Failed to deliver subscription request to config dispatcher
2025-12-09T03:42:24.275939Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:214: Bootstrap
2025-12-09T03:42:24.275942Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:217: Create sdk ydb connection
2025-12-09T03:42:24.276390Z :FQ_QUOTA_SERVICE INFO: quota_manager.cpp:196: STARTED
2025-12-09T03:42:24.276402Z :FQ_QUOTA_PROXY INFO: quota_proxy.cpp:90: STARTED
2025-12-09T03:42:24.276434Z :FQ_LOG_UPDATER DEBUG: log.cpp:93: Updated YQL logs priority: 8
2025-12-09T03:42:24.276437Z :FQ_LOG_UPDATER CRIT: log.cpp:55: Failed to deliver subscription request to config dispatcher.
2025-12-09T03:42:24.276469Z :YQ_RATE_LIMITER INFO: quoter_service.cpp:124: Bootstraping with config: { Enabled: true DataPlaneEnabled: true Database { Endpoint: "localhost:6559" Database: "local" TablePrefix: "RateLimiter_3ee83a57-9d99-4602-bd4d-451cf025ba67" } Limiters { CoordinationNodePath: "rate_limiter" } }
2025-12-09T03:42:24.276931Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:544: RowDispatcher: Successfully bootstrapped row dispatcher, id [1:7581698511821804664:2063], tenant /compute
2025-12-09T03:42:24.276947Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7581698511821804664:2063]
2025-12-09T03:42:24.276949Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:329: Coordinator: Add new row dispatcher to map (state 1)
2025-12-09T03:42:24.277076Z :YQL_NODES_MANAGER INFO: nodes_manager.cpp:88: Bootstrap, InstanceId: 8ed7ea97-4c736df7-1cdc0a8a-dc293944
2025-12-09T03:42:24.277077Z :YQL_NODES_MANAGER DEBUG: nodes_manager.cpp:310: TNodesManagerActor::ResolveSelfAddress
2025-12-09T03:42:24.277093Z :YQ_TEST_CONNECTION DEBUG: test_connection.cpp:142: Starting yandex query test connection. Actor id: [1:7581698511821804669:2068]
2025-12-09T03:42:24.277132Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 5049041a-f725b96d-2eecd124-9e57595e1, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:42:24.277172Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:293: Coordinator: Successfully bootstrapped coordinator, id [1:7581698511821804716:2092], NodesManagerId [0:4705493345362661702:78], rebalancing timeout 5.000000s
2025-12-09T03:42:24.277640Z :MEMORY_PROFILER NOTICE: monitor.cpp:332: Bootstrapped
2025-12-09T03:42:24.277867Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:239: Successfully bootstrapped TStorageProxy [1:7581698511821804663:2062] with connection to localhost:6559:local
2025-12-09T03:42:24.277910Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:232: TLeaderElection [1:7581698511821804717:2093] Successfully bootstrapped, local coordinator id [1:7581698511821804716:2092], tenant id compute, local mode 0, coordination node path local/compute, endpoint localhost:6559
2025-12-09T03:42:24.278396Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:637: RowDispatcher: TEvCoordinatorChangesSubscribe from [1:7581698511821804716:2092]
2025-12-09T03:42:24.279077Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-12-09T03:42:24.280052Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:71: Run create coordination node "local/compute" actor
2025-12-09T03:42:24.280062Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:113: Call create coordination node "local/compute"
2025-12-09T03:42:24.280064Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:411: Call create coordination node "local/compute"
2025-12-09T03:42:24.297691Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:42:24.297703Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-09T03:42:24.298150Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:155: Successfully created coordination node "local/compute"
2025-12-09T03:42:24.298167Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:122: Reply for create coordination node "local/compute": { <main>: Error: Check failed: path: '/local/compute', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 19], type: EPathTypeKesus, state: EPathStateNoChanges), source_location: ydb/core/tx/schemeshard/schemeshard__operation_create_kesus.cpp:339 }
2025-12-09T03:42:24.298179Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:345: TLeaderElection [1:7581698511821804717:2093] Coordination node successfully created
2025-12-09T03:42:24.298183Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:323: TLeaderElection [1:7581698511821804717:2093] Start session
2025-12-09T03:42:24.298407Z :SCHEME_BOARD_SUBSCRIBER NOTICE: subscriber.cpp:849: [main][1:7581698511821804684:2078][/compute] Set up state: owner# [1:7581698511821804643:2052], state# { Deleted: 1 Strong: 0 Version: <Invalid> DomainId: <Invalid> AbandonedSchemeShards: there are 0 elements }
2025-12-09T03:42:24.298409Z :SCHEME_BOARD_SUBSCRIBER NOTICE: subscriber.cpp:849: [main][1:7581698511821804683:2077][/Root] Set up state: owner# [1:7581698511821804643:2052], state# { Deleted: 1 Strong: 0 Version: <Invalid> DomainId: <Invalid> AbandonedSchemeShards: there are 0 elements }
2025-12-09T03:42:24.298422Z :SCHEME_BOARD_SUBSCRIBER NOTICE: subscriber.cpp:849: [main][1:7581698511821804686:2080][/compute] Set up state: owner# [1:7581698511821804644:2053], state# { Deleted: 1 Strong: 0 Version: <Invalid> DomainId: <Invalid> AbandonedSchemeShards: there are 0 elements }
2025-12-09T03:42:24.298434Z :SCHEME_BOARD_SUBSCRIBER NOTICE: subscriber.cpp:849: [main][1:7581698511821804685:2079][/Root] Set up state: owner# [1:7581698511821804644:2053], state# { Deleted: 1 Strong: 0 Version: <Invalid> DomainId: <Invalid> AbandonedSchemeShards: there are 0 elements }
2025-12-09T03:42:24.298439Z :GRPC_SERVER WARN: grpc_request_proxy.cpp:583: SchemeBoardDelete /compute Strong=0
2025-12-09T03:42:24.298441Z :GRPC_SERVER WARN: grpc_request_proxy.cpp:583: SchemeBoardDelete /Root Strong=0
2025-12-09T03:42:24.298442Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:389: Send NodeInfo with size: 1 to DynamicNameserver
2025-12-09T03:42:24.298444Z :GRPC_SERVER WARN: grpc_request_proxy.cpp:583: SchemeBoardDelete /compute Strong=0
2025-12-09T03:42:24.298446Z :GRPC_SERVER WARN: grpc_request_proxy.cpp:583: SchemeBoardDelete /Root Strong=0
2025-12-09T03:42:24.300836Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:359: TLeaderElection [1:7581698511821804717:2093] Session successfully created
2025-12-09T03:42:24.303373Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:372: TLeaderElection [1:7581698511821804717:2093] Semaphore successfully created
2025-12-09T03:42:24.303385Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:304: TLeaderElection [1:7581698511821804717:2093] Try to acquire semaphore
2025-12-09T03:42:24.303435Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:420: TLeaderElection [1:7581698511821804717:2093] Describe semaphore
2025-12-09T03:42:24.304839Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:469: TLeaderElection [1:7581698511821804717:2093] Semaphore successfully described: coordinator id [2:7581698493781249395:2092] generation 3
2025-12-09T03:42:24.304849Z :FQ_ROW_DISPATCHER INFO: leader_election.cpp:471: TLeaderElection [1:7581698511821804717:2093] Send TEvCoordinatorChanged to [1:7581698511821804664:2063], new coordinator id [2:7581698493781249395:2092], previous coordinator id [0:0:0]
2025-12-09T03:42:24.304866Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:569: RowDispatcher: Coordinator changed, old leader (empty maybe), new [2:7581698493781249395:2092] generation 3
2025-12-09T03:42:24.304891Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:440: Coordinator: New leader [2:7581698493781249395:2092], SelfId [1:7581698511821804716:2092]
2025-12-09T03:42:24.305169Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:607: RowDispatcher: TEvUndelivered, from [2:7581698493781249395:2092], reason Disconnected
2025-12-09T03:42:24.312201Z :INTERCONNECT WARN: interconnect_handshake.cpp:501: Handshake [1:7581698511821804792:2052] [node 2] ICH09 Neither CompatibilityInfo nor VersionTag of the peer can be validated, accepting by default
2025-12-09T03:42:25.273756Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 5049041a-f725b96d-2eecd124-9e57595e2, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:42:25.273855Z :FQ_QUOTA_SERVICE DEBUG: quota_manager.cpp:230: IC Peers[1]: [2]
2025-12-09T03:42:25.278217Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:42:25.278229Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-09T03:42:26.274408Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [2:7581698493781249395:2092]
2025-12-09T03:42:26.274429Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 5049041a-f725b96d-2eecd124-9e57595e3, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:42:26.274432Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-09T03:42:26.275733Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-09T03:42:26.291107Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:42:26.291118Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 1
2025-12-09T03:42:26.291129Z :FQ_PENDING_FETCHER DEBUG: pending_fetcher.cpp:361: NewTask: Scope: yandexcloud://my_folder Id: ptqudqgd6kvcs9idrfdt UserId: root@builtin AuthToken: **** (B6C6F477)
2025-12-09T03:42:26.291274Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:375: QueryId: ptqudqgd6kvcs9idrfdt Start run actor. Compute state: RUNNING
2025-12-09T03:42:26.291283Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 5049041a-f725b96d-2eecd124-9e57595e4, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:42:26.291291Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:469: QueryId: ptqudqgd6kvcs9idrfdt FillConnections
2025-12-09T03:42:26.291328Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:2333: QueryId: ptqudqgd6kvcs9idrfdt Run actors params: { QueryId: ptqudqgd6kvcs9idrfdt CloudId: mock_cloud UserId: root@builtin Owner: 5049041a-f725b96d-2eecd124-9e57595e3 PreviousQueryRevision: 3 Connections: 1 Bindings: 0 AccountIdSignatures: 0 QueryType: STREAMING ExecuteMode: RUN ResultId: ptrudqgd6bi8h0vih6mq StateLoadMode: FROM_LAST_CHECKPOINT StreamingDisposition: { from_last_checkpoint { } } Status: RUNNING DqGraphs: 1 DqGraphIndex: 0 Resource.TopicConsumers: 1 }
2025-12-09T03:42:26.291416Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:911: QueryId: ptqudqgd6kvcs9idrfdt Overall dq tasks: 2
2025-12-09T03:42:26.291497Z :FQ_PINGER TRACE: pinger.cpp:171: QueryId: ptqudqgd6kvcs9idrfdt, Owner: 5049041a-f725b96d-2eecd124-9e57595e3 Start Pinger
2025-12-09T03:42:26.291602Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:1598: QueryId: ptqudqgd6kvcs9idrfdt ResultWriter was NOT CREATED since ResultType is empty
2025-12-09T03:42:26.291668Z :FQ_PINGER TRACE: pinger.cpp:250: QueryId: ptqudqgd6kvcs9idrfdt, Owner: 5049041a-f725b96d-2eecd124-9e57595e3 Forward ping request: { resources { rate_limiter: READY compilation: READY topic_consumers_state: READY rate_limiter_path: "local/RateLimiter_3ee83a57-9d99-4602-bd4d-451cf025ba67/rate_limiter" topic_consumers { database: "local" topic_path: "pq_kikimr_streaming_v1_input" consumer_name: "ptqudqgd6kvcs9idrfdt" cluster_endpoint: "localhost:6559" token_name: "cluster:default_myyds" add_bearer_to_token: true } } }
2025-12-09T03:42:26.291679Z :FQ_PINGER TRACE: pinger.cpp:393: QueryId: ptqudqgd6kvcs9idrfdt, Owner: 5049041a-f725b96d-2eecd124-9e57595e3 Forward request Private::PingTask
2025-12-09T03:42:26.291681Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudqgd6kvcs9idrfdt 2025-12-09 03:42:26.291 DEBUG ydbd(pid=1612752, tid=0x00007F97642FE640) [DQ] task_controller_impl.h:86: _RowsLimitPerWrite = 0
2025-12-09T03:42:26.291731Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:1652: QueryId: ptqudqgd6kvcs9idrfdt Executer: [1:7581698520411739553:2307], Controller: [1:7581698520411739555:2309], ResultIdActor: [1:7581698520411739553:2307]
2025-12-09T03:42:26.291763Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudqgd6kvcs9idrfdt 2025-12-09 03:42:26.291 DEBUG ydbd(pid=1612752, tid=0x00007F97642FE640) [DQ] executer_actor.cpp:140: {ptqudqgd6kvcs9idrfdt} TDqExecuter::OnGraph
2025-12-09T03:42:26.291781Z :YQL_PROXY INFO: log.cpp:64: SessionId: ptqudqgd6kvcs9idrfdt 2025-12-09 03:42:26.291 INFO  ydbd(pid=1612752, tid=0x00007F97642FE640) [DQ] executer_actor.cpp:157: {ptqudqgd6kvcs9idrfdt} Trying to allocate 2 workers [EnableComputeActor=1]
2025-12-09T03:42:26.292902Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudqgd6kvcs9idrfdt 2025-12-09 03:42:26.292 DEBUG ydbd(pid=1612752, tid=0x00007F97642FE640) [DQ] executer_actor.cpp:247: {ptqudqgd6kvcs9idrfdt} Dq timeouts are set to: 0.000000s (global), 600.000000s (workers allocation fail), 30.000000s (workers allocation warn) 
2025-12-09T03:42:26.293483Z :YQL_NODES_MANAGER DEBUG: nodes_manager.cpp:125: TEvAllocateWorkersResponse Nodes {
  ResourceId: 4294967297
  Worker {
    NodeId: 1
    Guid: "8ed7ea97-4c736df7-1cdc0a8a-dc293944,ghrun-syjwtgwtdu"
  }
  Worker {
    NodeId: 2
    Guid: "e3b2b081-402d8731-234d19b-5bd840,ghrun-syjwtgwtdu"
  }
}
2025-12-09T03:42:26.294364Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:42:26.294375Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-09T03:42:26.301808Z :FQ_PINGER TRACE: pinger.cpp:338: QueryId: ptqudqgd6kvcs9idrfdt, Owner: 5049041a-f725b96d-2eecd124-9e57595e3 Ping response success: { expired_at { seconds: 1765251749 nanos: 296000000 } }
2025-12-09T03:42:26.301852Z :FQ_RUN_ACTOR TRACE: run_actor.cpp:861: QueryId: ptqudqgd6kvcs9idrfdt Forward ping response. Success: 1. Cookie: 0
2025-12-09T03:42:26.324405Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:144: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Start compute actor [1:7581698520411739558:2311], task: 1
2025-12-09T03:42:26.324451Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:114: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Use CPU quota: 1. Rate limiter resource: { "local/RateLimiter_3ee83a57-9d99-4602-bd4d-451cf025ba67/rate_limiter", "mock_cloud/my_folder/ptqudqgd6kvcs9idrfdt" }
2025-12-09T03:42:26.324486Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudqgd6kvcs9idrfdt 2025-12-09 03:42:26.324 DEBUG ydbd(pid=1612752, tid=0x00007F97642FE640) [DQ] executer_actor.cpp:358: {ptqudqgd6kvcs9idrfdt} TDqExecuter::TEvAllocateWorkersResponse
2025-12-09T03:42:26.324506Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudqgd6kvcs9idrfdt 2025-12-09 03:42:26.324 DEBUG ydbd(pid=1612752, tid=0x00007F97642FE640) [DQ] executer_actor.cpp:384: {ptqudqgd6kvcs9idrfdt} Allocated resource 4294967297
2025-12-09T03:42:26.324551Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudqgd6kvcs9idrfdt 2025-12-09 03:42:26.324 DEBUG ydbd(pid=1612752, tid=0x00007F97642FE640) [DQ] executer_actor.cpp:401: {ptqudqgd6kvcs9idrfdt} WorkerInfo: Id:8ed7ea97-4c736df7-1cdc0a8a-dc293944,ghrun-syjwtgwtdu,NodeId:1,StageId:200289
2025-12-09T03:42:26.324564Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudqgd6kvcs9idrfdt 2025-12-09 03:42:26.324 DEBUG ydbd(pid=1612752, tid=0x00007F97642FE640) [DQ] executer_actor.cpp:402: {ptqudqgd6kvcs9idrfdt} TaskInfo: 0/1
2025-12-09T03:42:26.324573Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudqgd6kvcs9idrfdt 2025-12-09 03:42:26.324 DEBUG ydbd(pid=1612752, tid=0x00007F97642FE640) [DQ] executer_actor.cpp:404: {ptqudqgd6kvcs9idrfdt}  ObjectId: 2ad8a0198ac871ab3cd73b3e9d43a8d7c87aa707, dq_vanilla_job.lite, 
2025-12-09T03:42:26.324595Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudqgd6kvcs9idrfdt 2025-12-09 03:42:26.324 DEBUG ydbd(pid=1612752, tid=0x00007F97642FE640) [DQ] executer_actor.cpp:401: {ptqudqgd6kvcs9idrfdt} WorkerInfo: Id:e3b2b081-402d8731-234d19b-5bd840,ghrun-syjwtgwtdu,NodeId:2,StageId:200289
2025-12-09T03:42:26.324600Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudqgd6kvcs9idrfdt 2025-12-09 03:42:26.324 DEBUG ydbd(pid=1612752, tid=0x00007F97642FE640) [DQ] executer_actor.cpp:402: {ptqudqgd6kvcs9idrfdt} TaskInfo: 1/2
2025-12-09T03:42:26.324606Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudqgd6kvcs9idrfdt 2025-12-09 03:42:26.324 DEBUG ydbd(pid=1612752, tid=0x00007F97642FE640) [DQ] executer_actor.cpp:404: {ptqudqgd6kvcs9idrfdt}  ObjectId: 2ad8a0198ac871ab3cd73b3e9d43a8d7c87aa707, dq_vanilla_job.lite, 
2025-12-09T03:42:26.324618Z :YQL_PROXY INFO: log.cpp:64: SessionId: ptqudqgd6kvcs9idrfdt 2025-12-09 03:42:26.324 INFO  ydbd(pid=1612752, tid=0x00007F97642FE640) [DQ] executer_actor.cpp:415: {ptqudqgd6kvcs9idrfdt} 2 workers allocated
2025-12-09T03:42:26.324802Z :YQL_PROXY TRACE: log.cpp:64: SessionId:  2025-12-09 03:42:26.324 TRACE ydbd(pid=1612752, tid=0x00007F9762AFB640) [DQ] task_controller_impl.h:271:  [1:7581698520411739555:2309] ExportStats Summary
2025-12-09T03:42:26.324842Z :YQL_PROXY DEBUG: log.cpp:64: SessionId:  2025-12-09 03:42:26.324 DEBUG ydbd(pid=1612752, tid=0x00007F9762AFB640) [DQ] task_controller_impl.h:526: Ready State: [1:7581698520411739555:2309]
2025-12-09T03:42:26.324859Z :YQL_PROXY DEBUG: log.cpp:64: SessionId:  2025-12-09 03:42:26.324 DEBUG ydbd(pid=1612752, tid=0x00007F9762AFB640) [DQ] task_controller_impl.h:537: Forward: [1:7581698520411739555:2309] to [1:7581698520411739554:2308]
2025-12-09T03:42:26.324905Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:70: [ptqudqgd6kvcs9idrfdt-0.3] TEvReadyState, streaming disposition { from_last_checkpoint { } }, state load mode FROM_LAST_CHECKPOINT, checkpointing period 1.000000s
2025-12-09T03:42:26.324922Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:104: [ptqudqgd6kvcs9idrfdt-0.3] AllActors count: 2, ActorsToTrigger count: 2, ActorsToNotify count: 2, ActorsToWaitFor count: 2
2025-12-09T03:42:26.324924Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:114: [ptqudqgd6kvcs9idrfdt-0.3] Send TEvRegisterCoordinatorRequest
2025-12-09T03:42:26.324935Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:261: [ptqudqgd6kvcs9idrfdt-0.3] Got TEvRegisterCoordinatorRequest
2025-12-09T03:42:26.324937Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:243: StartInitialization, EnableSecureScriptExecutions: 0
2025-12-09T03:42:26.325762Z :STREAMS_STORAGE_SERVICE NOTICE: storage_proxy.cpp:585: Add to delayed
2025-12-09T03:42:26.334357Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:557: Checkpoint storage and state storage were successfully initted
2025-12-09T03:42:26.334373Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:261: [ptqudqgd6kvcs9idrfdt-0.3] Got TEvRegisterCoordinatorRequest
2025-12-09T03:42:26.343666Z :YQL_PROXY TRACE: log.cpp:64: SessionId:  2025-12-09 03:42:26.343 TRACE ydbd(pid=1612752, tid=0x00007F97642FE640) [DQ] task_controller_impl.h:160: [1:7581698520411739555:2309] EvState TaskId: 2 State: 2 PingCookie: 0 StatusCode: UNSPECIFIED
2025-12-09T03:42:26.343690Z :YQL_PROXY TRACE: log.cpp:64: SessionId:  2025-12-09 03:42:26.343 TRACE ydbd(pid=1612752, tid=0x00007F97642FE640) [DQ] task_controller_impl.h:201:  [1:7581698520411739555:2309] Executing TaskId: 2
2025-12-09T03:42:26.359627Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:279: [ptqudqgd6kvcs9idrfdt-0.3] Graph registered
2025-12-09T03:42:26.359653Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:281: [ptqudqgd6kvcs9idrfdt-0.3] Send TEvRegisterCoordinatorResponse
2025-12-09T03:42:26.359692Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:131: [ptqudqgd6kvcs9idrfdt-0.3] Got TEvRegisterCoordinatorResponse; issues: 
2025-12-09T03:42:26.359696Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:140: [ptqudqgd6kvcs9idrfdt-0.3] Successfully registered in storage
2025-12-09T03:42:26.359700Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:141: [ptqudqgd6kvcs9idrfdt-0.3] Send TEvNewCheckpointCoordinator to 2 actor(s)
2025-12-09T03:42:26.359711Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:149: [ptqudqgd6kvcs9idrfdt-0.3] Send TEvGetCheckpointsMetadataRequest; state load mode: FROM_LAST_CHECKPOINT; load graph: 0
2025-12-09T03:42:26.359741Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:434: [ptqudqgd6kvcs9idrfdt-0] Got TEvGetCheckpointsMetadataRequest
2025-12-09T03:42:26.360238Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:622: [ptqudqgd6kvcs9idrfdt-0.3] Handle connected node 2
2025-12-09T03:42:26.362470Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:451: [ptqudqgd6kvcs9idrfdt-0] Send TEvGetCheckpointsMetadataResponse
2025-12-09T03:42:26.362506Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:186: [ptqudqgd6kvcs9idrfdt-0.3] Got TEvGetCheckpointsMetadataResponse
2025-12-09T03:42:26.362511Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:219: [ptqudqgd6kvcs9idrfdt-0.3] Will restore from checkpoint 1:1
2025-12-09T03:42:26.368843Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:297: [ptqudqgd6kvcs9idrfdt-0.3] [1:1] Got TEvRestoreFromCheckpointResult; taskId: 2, checkpoint: 1:1, status: OK, issues: 
2025-12-09T03:42:26.368866Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:320: [ptqudqgd6kvcs9idrfdt-0.3] [1:1] Task state restored, need 1 more acks
2025-12-09T03:42:26.383260Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:197: [] Task: 1. Got TEvNewCheckpointCoordinator event: generation 3, actorId: [1:7581698520411739554:2308]
2025-12-09T03:42:26.383272Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:208: [] Task: 1. Assign checkpoint coordinator (generation = 3)
2025-12-09T03:42:26.384026Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1360: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Create source for input 0 { Source { Type: "PqSource" Settings { type_url: "type.googleapis.com/NYql.NPq.NProto.TDqPqTopicSource" value: "\n\034pq_kikimr_streaming_v1_input\022\024ptqudqgd6kvcs9idrfdt\032\016localhost:6559\"\027\n\025cluster:default_myyds*\005local0\002@\001b\004Dataj\025[\"DataType\";\"String\"]\222\001\024ptcudqgd6lad1jvhcnkd\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-12-09T03:42:26.384410Z :KQP_COMPUTE DEBUG: dq_pq_read_actor_base.cpp:153: SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, task: 1. PQ source. SessionId: empty Watermarks enabled: 0 granularity: 0.000000s late arrival delay: 0.000000s idle: 0 idle timeout: 0.000000s
2025-12-09T03:42:26.384458Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1447: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Create sink for output 0 { Sink { Type: "PqSink" Settings { type_url: "type.googleapis.com/NYql.NPq.NProto.TDqPqTopicSink" value: "\n\035pq_kikimr_streaming_v1_output\022\016localhost:6559\032\027\n\025cluster:default_myyds\"\005local0\0018\002" } } }
2025-12-09T03:42:26.384548Z :YQL_PROXY TRACE: log.cpp:64: SessionId:  2025-12-09 03:42:26.384 TRACE ydbd(pid=1612752, tid=0x00007F97642FE640) [DQ] task_controller_impl.h:160: [1:7581698520411739555:2309] EvState TaskId: 1 State: 2 PingCookie: 0 StatusCode: UNSPECIFIED
2025-12-09T03:42:26.384567Z :YQL_PROXY TRACE: log.cpp:64: SessionId:  2025-12-09 03:42:26.384 TRACE ydbd(pid=1612752, tid=0x00007F97642FE640) [DQ] task_controller_impl.h:201:  [1:7581698520411739555:2309] Executing TaskId: 1
2025-12-09T03:42:26.384586Z :YQL_PROXY DEBUG: log.cpp:64: SessionId:  2025-12-09 03:42:26.384 DEBUG ydbd(pid=1612752, tid=0x00007F97642FE640) [DQ] task_controller_impl.h:561: Update channels
2025-12-09T03:42:26.384654Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:265: [ptqudqgd6kvcs9idrfdt-0] Task: 1. [Checkpoint 1.1] TEvRestoreFromCheckpoint, StateLoadPlan = { StateType: STATE_TYPE_OWN }
2025-12-09T03:42:26.384674Z :YQL_PROXY TRACE: log.cpp:64: SessionId:  2025-12-09 03:42:26.384 TRACE ydbd(pid=1612752, tid=0x00007F97642FE640) [DQ] task_controller_impl.h:577: 1 
2025-12-09T03:42:26.384691Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1064: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Received channels info: 
2025-12-09T03:42:26.384696Z :YQL_PROXY TRACE: log.cpp:64: SessionId:  2025-12-09 03:42:26.384 TRACE ydbd(pid=1612752, tid=0x00007F97642FE640) [DQ] task_controller_impl.h:577: 2 
2025-12-09T03:42:26.384711Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:508: [ptqudqgd6kvcs9idrfdt-0] [1:1] Got TEvGetTaskState: tasks {1}
2025-12-09T03:42:26.384719Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:519: [ptqudqgd6kvcs9idrfdt-0] [1:1] GetState, tasks: 1
2025-12-09T03:42:26.387180Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:654: [ptqudqgd6kvcs9idrfdt-0] [1:1] ListOfStates results:
2025-12-09T03:42:26.387220Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:675: [ptqudqgd6kvcs9idrfdt-0] [1:1] taskId 1 checkpoint id: 2:1, rows count: 1
2025-12-09T03:42:26.387223Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:675: [ptqudqgd6kvcs9idrfdt-0] [1:1] taskId 1 checkpoint id: 1:2, rows count: 1
2025-12-09T03:42:26.387225Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:675: [ptqudqgd6kvcs9idrfdt-0] [1:1] taskId 1 checkpoint id: 1:1, rows count: 1
2025-12-09T03:42:26.387233Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:901: [ptqudqgd6kvcs9idrfdt-0] [1:1] SkipStatesInFuture, skip 2 checkpoints
2025-12-09T03:42:26.387291Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:796: [ptqudqgd6kvcs9idrfdt-0] [1:1] SelectState: task_id 1, seq_no 1, blob_seq_num 0
2025-12-09T03:42:26.389771Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:410: [ptqudqgd6kvcs9idrfdt-0] [1:1] DeserializeState, task id 1, blob size 172
2025-12-09T03:42:26.389799Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:960: [ptqudqgd6kvcs9idrfdt-0] [1:1] ApplyIncrements
2025-12-09T03:42:26.389958Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:527: [ptqudqgd6kvcs9idrfdt-0] [{ Id: 1 Generation: 1 }] Send TEvGetTaskStateResult: tasks: {1}
2025-12-09T03:42:26.390312Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:336: [ptqudqgd6kvcs9idrfdt-0] Task: 1. [Checkpoint 1.1] TEvGetTaskStateResult: restoring state
2025-12-09T03:42:26.390324Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:793: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Load state
2025-12-09T03:42:26.390338Z :KQP_COMPUTE DEBUG: dq_pq_read_actor_base.cpp:153: SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, task: 1. PQ source. SessionId: empty Watermarks enabled: 0 granularity: 0.000000s late arrival delay: 0.000000s idle: 0 idle timeout: 0.000000s
2025-12-09T03:42:26.390351Z :KQP_COMPUTE DEBUG: dq_pq_read_actor_base.cpp:133: SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, task: 1. PQ source. SessionId: empty StartingMessageTs 2025-12-09T03:42:17.483000Z Restoring offset: 
2025-12-09T03:42:26.390568Z :KQP_COMPUTE DEBUG: dq_pq_write_actor.cpp:268: SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. Load state: { SourceId: "2847d55f-b7bee33c-5807f910-b751220d" }
2025-12-09T03:42:26.390586Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:362: [ptqudqgd6kvcs9idrfdt-0] Task: 1. [Checkpoint 1.1] Checkpoint state restored
2025-12-09T03:42:26.390625Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:297: [ptqudqgd6kvcs9idrfdt-0.3] [1:1] Got TEvRestoreFromCheckpointResult; taskId: 1, checkpoint: 1:1, status: OK, issues: 
2025-12-09T03:42:26.390640Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:320: [ptqudqgd6kvcs9idrfdt-0.3] [1:1] Task state restored, need 0 more acks
2025-12-09T03:42:26.390644Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:445: [ptqudqgd6kvcs9idrfdt-0.3] Send TEvRun to all actors
2025-12-09T03:42:26.390666Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1164: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Got TEvRun from actor [1:7581698520411739554:2308]
2025-12-09T03:42:26.390676Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Poll inputs
2025-12-09T03:42:26.390678Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Poll sources
2025-12-09T03:42:26.390682Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:542: SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, task: 1. PQ source. SessionId: empty GetAsyncInputData freeSpace = 1
2025-12-09T03:42:26.390702Z :KQP_COMPUTE DEBUG: dq_pq_read_actor.cpp:648: SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, task: 1. PQ source. SessionId: empty PartitionsToRead: 0
2025-12-09T03:42:26.390736Z :YDB_SDK INFO: actor.cpp:37: 2025-12-09T03:42:26.390731Z :INFO: [local] [local] [32b54056-90cb1c67-b81f37fa-1c26c988] Starting read session
2025-12-09T03:42:26.390748Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:26.390746Z :DEBUG: [local] [local] [32b54056-90cb1c67-b81f37fa-1c26c988] Starting single session
2025-12-09T03:42:26.390778Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:26.390776Z :DEBUG: [local] [local] [32b54056-90cb1c67-b81f37fa-1c26c988] [] In Reconnect, ReadSizeBudget = 8388608, ReadSizeServerDelta = 0
2025-12-09T03:42:26.390782Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:26.390780Z :DEBUG: [local] [local] [32b54056-90cb1c67-b81f37fa-1c26c988] [] New values: ReadSizeBudget = 8388608, ReadSizeServerDelta = 0
2025-12-09T03:42:26.390787Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:26.390785Z :DEBUG: [local] [local] [32b54056-90cb1c67-b81f37fa-1c26c988] [] Reconnecting session to cluster  in 0.000000s
2025-12-09T03:42:26.390976Z :KQP_COMPUTE INFO: dq_pq_read_actor.cpp:315: SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, task: 1. PQ source. SessionId: 32b54056-90cb1c67-b81f37fa-1c26c988 CreateReadSession
2025-12-09T03:42:26.390990Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:81: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Poll async input 0. Buffer free space: 1, read from async input: 0 bytes, 0 rows, finished: 0
2025-12-09T03:42:26.391018Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:26.391003Z :DEBUG: [local] [local] [32b54056-90cb1c67-b81f37fa-1c26c988] [] Successfully connected. Initializing session
2025-12-09T03:42:26.391026Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-12-09T03:42:26.391100Z :KQP_COMPUTE TRACE: dq_compute_memory_quota.h:97: TxId: ptqudqgd6kvcs9idrfdt, task: 1. Peak memory usage: 2031616
2025-12-09T03:42:26.391113Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. update task runner stats
2025-12-09T03:42:26.391137Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-09T03:42:26.391140Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-09T03:42:26.391144Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-09T03:42:26.391148Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1107: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Ask CPU quota: 62ms
2025-12-09T03:42:26.391165Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-12-09T03:42:26.391223Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-12-09T03:42:26.391230Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-09T03:42:26.391792Z :YDB_SDK INFO: actor.cpp:37: 2025-12-09T03:42:26.391786Z :INFO: [local] [local] [32b54056-90cb1c67-b81f37fa-1c26c988] [] Got InitResponse. ReadSessionId: ptqudqgd6kvcs9idrfdt_1_7_9762899223411840837_v1
2025-12-09T03:42:26.391804Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:26.391802Z :DEBUG: [local] [local] [32b54056-90cb1c67-b81f37fa-1c26c988] [] In ContinueReadingDataImpl, ReadSizeBudget = 8388608, ReadSizeServerDelta = 0
2025-12-09T03:42:26.391855Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:26.391853Z :DEBUG: [local] [local] [32b54056-90cb1c67-b81f37fa-1c26c988] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 8388608
2025-12-09T03:42:26.392019Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1165: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. CPU quota delay: 0ms
2025-12-09T03:42:26.392940Z :YDB_SDK INFO: actor.cpp:37: 2025-12-09T03:42:26.392934Z :INFO: [local] OnFederationDiscovery fall back to single mode, database=local
2025-12-09T03:42:26.393116Z :YDB_SDK INFO: actor.cpp:37: [] [] Start federated write session to database '' (previous was <empty>) FederationState: { Status: SUCCESS SelfLocation: "" DbInfos: [ { path: "local" endpoint: "localhost:6559" status: AVAILABLE weight: 100 } ] ControlPlaneEndpoint: localhost:6559 }
2025-12-09T03:42:26.393179Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:26.393177Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId []  MessageGroupId [2847d55f-b7bee33c-5807f910-b751220d] Write session: try to update token
2025-12-09T03:42:26.393467Z :YDB_SDK INFO: actor.cpp:37: 2025-12-09T03:42:26.393463Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId []  MessageGroupId [2847d55f-b7bee33c-5807f910-b751220d] Start write session. Will connect to nodeId: 0
2025-12-09T03:42:26.393878Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:363: SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, task: 1. PQ source. SessionId: 32b54056-90cb1c67-b81f37fa-1c26c988 Source data ready
2025-12-09T03:42:26.393885Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:26.393877Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId []  MessageGroupId [2847d55f-b7bee33c-5807f910-b751220d] Write session: write to message_group: 2847d55f-b7bee33c-5807f910-b751220d
2025-12-09T03:42:26.393907Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Poll inputs
2025-12-09T03:42:26.393909Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:26.393907Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId []  MessageGroupId [2847d55f-b7bee33c-5807f910-b751220d] Write session: send init request: init_request { path: "pq_kikimr_streaming_v1_output" producer_id: "2847d55f-b7bee33c-5807f910-b751220d" message_group_id: "2847d55f-b7bee33c-5807f910-b751220d" }
2025-12-09T03:42:26.393910Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Poll sources
2025-12-09T03:42:26.393912Z :YDB_SDK TRACE: actor.cpp:37: 2025-12-09T03:42:26.393910Z :TRACE: [local] TRACE_EVENT InitRequest 
2025-12-09T03:42:26.393916Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:542: SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, task: 1. PQ source. SessionId: 32b54056-90cb1c67-b81f37fa-1c26c988 GetAsyncInputData freeSpace = 1000000
2025-12-09T03:42:26.393945Z :KQP_COMPUTE DEBUG: dq_pq_read_actor.cpp:820: SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, task: 1. PQ source. SessionId: 32b54056-90cb1c67-b81f37fa-1c26c988 Key: 0@ StartPartitionSessionEvent received
2025-12-09T03:42:26.393951Z :KQP_COMPUTE DEBUG: dq_pq_read_actor.cpp:827: SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, task: 1. PQ source. SessionId: 32b54056-90cb1c67-b81f37fa-1c26c988 Key: 0@ Confirm StartPartitionSession with offset (NULL)
2025-12-09T03:42:26.393964Z :YDB_SDK INFO: actor.cpp:37: 2025-12-09T03:42:26.393960Z :INFO: [local] [local] [32b54056-90cb1c67-b81f37fa-1c26c988] [] Confirm partition stream create. Partition stream id: 1. Cluster: "-". Topic: "pq_kikimr_streaming_v1_input". Partition: 0. Read offset: (NULL)
2025-12-09T03:42:26.394071Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:81: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Poll async input 0. Buffer free space: 1000000, read from async input: 0 bytes, 0 rows, finished: 0
2025-12-09T03:42:26.394100Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:26.394097Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId []  MessageGroupId [2847d55f-b7bee33c-5807f910-b751220d] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-09T03:42:26.394105Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:363: SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, task: 1. PQ source. SessionId: 32b54056-90cb1c67-b81f37fa-1c26c988 Source data ready
2025-12-09T03:42:26.394110Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-12-09T03:42:26.394167Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Poll inputs
2025-12-09T03:42:26.394176Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Poll sources
2025-12-09T03:42:26.394183Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:542: SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, task: 1. PQ source. SessionId: 32b54056-90cb1c67-b81f37fa-1c26c988 GetAsyncInputData freeSpace = 1000000
2025-12-09T03:42:26.394188Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:81: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Poll async input 0. Buffer free space: 1000000, read from async input: 0 bytes, 0 rows, finished: 0
2025-12-09T03:42:26.394192Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. update task runner stats
2025-12-09T03:42:26.394226Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-09T03:42:26.394229Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-09T03:42:26.394233Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-09T03:42:26.394238Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-12-09T03:42:26.394245Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [1:7581698520411739567:2311], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-12-09T03:42:26.394252Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-12-09T03:42:26.394277Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-09T03:42:26.394297Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. update task runner stats
2025-12-09T03:42:26.394305Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-09T03:42:26.394307Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-09T03:42:26.394309Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-09T03:42:26.394313Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [1:7581698520411739567:2311], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-12-09T03:42:26.394315Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-12-09T03:42:26.394317Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-09T03:42:26.394862Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:26.394856Z :DEBUG: [local] [local] [32b54056-90cb1c67-b81f37fa-1c26c988] [] Got ReadResponse, serverBytesSize = 206, now ReadSizeBudget = 0, ReadSizeServerDelta = 8388402
2025-12-09T03:42:26.394896Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:26.394893Z :DEBUG: [local] [local] [32b54056-90cb1c67-b81f37fa-1c26c988] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 8388402
2025-12-09T03:42:26.394951Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:26.394946Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (0-5)
2025-12-09T03:42:26.394965Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:26.394963Z :DEBUG: [local] [local] [32b54056-90cb1c67-b81f37fa-1c26c988] [] Returning serverBytesSize = 206 to budget
2025-12-09T03:42:26.394969Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:26.394967Z :DEBUG: [local] [local] [32b54056-90cb1c67-b81f37fa-1c26c988] [] In ContinueReadingDataImpl, ReadSizeBudget = 206, ReadSizeServerDelta = 8388402
2025-12-09T03:42:26.395013Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:26.395010Z :DEBUG: [local] [local] [32b54056-90cb1c67-b81f37fa-1c26c988] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 8388608
2025-12-09T03:42:26.395086Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:363: SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, task: 1. PQ source. SessionId: 32b54056-90cb1c67-b81f37fa-1c26c988 Source data ready
2025-12-09T03:42:26.395107Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Poll inputs
2025-12-09T03:42:26.395110Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Poll sources
2025-12-09T03:42:26.395114Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:542: SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, task: 1. PQ source. SessionId: 32b54056-90cb1c67-b81f37fa-1c26c988 GetAsyncInputData freeSpace = 1000000
2025-12-09T03:42:26.395133Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:26.395129Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-12-09T03:42:26.395139Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:26.395138Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 1} (1-1)
2025-12-09T03:42:26.395143Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:26.395142Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (2-2)
2025-12-09T03:42:26.395148Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:26.395146Z :DEBUG: [local] Take Data. Partition 0. Read: {2, 0} (3-3)
2025-12-09T03:42:26.395153Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:26.395151Z :DEBUG: [local] Take Data. Partition 0. Read: {2, 1} (4-4)
2025-12-09T03:42:26.395156Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:26.395155Z :DEBUG: [local] Take Data. Partition 0. Read: {2, 2} (5-5)
2025-12-09T03:42:26.395166Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:26.395164Z :DEBUG: [local] [local] [32b54056-90cb1c67-b81f37fa-1c26c988] [] The application data is transferred to the client. Number of messages 6, size 10 bytes
2025-12-09T03:42:26.395173Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:26.395172Z :DEBUG: [local] [local] [32b54056-90cb1c67-b81f37fa-1c26c988] [] Returning serverBytesSize = 0 to budget
2025-12-09T03:42:26.395193Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:761: SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, task: 1. PQ source. SessionId: 32b54056-90cb1c67-b81f37fa-1c26c988 Key: 0@ Data received: Message { Data: "6" Information: { Offset: 0 ProducerId: "" SeqNo: 0 CreateTime: 2025-12-09T03:42:18.299000Z WriteTime: 2025-12-09T03:42:18.299000Z MessageGroupId: "" Meta: { } MessageMeta: { } } Partition session id: 1 Topic: "pq_kikimr_streaming_v1_input" Partition: 0 }
2025-12-09T03:42:26.395203Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:761: SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, task: 1. PQ source. SessionId: 32b54056-90cb1c67-b81f37fa-1c26c988 Key: 0@ Data received: Message { Data: "9" Information: { Offset: 1 ProducerId: "" SeqNo: 0 CreateTime: 2025-12-09T03:42:18.299000Z WriteTime: 2025-12-09T03:42:18.299000Z MessageGroupId: "" Meta: { } MessageMeta: { } } Partition session id: 1 Topic: "pq_kikimr_streaming_v1_input" Partition: 0 }
2025-12-09T03:42:26.395206Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:761: SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, task: 1. PQ source. SessionId: 32b54056-90cb1c67-b81f37fa-1c26c988 Key: 0@ Data received: Message { Data: "11" Information: { Offset: 2 ProducerId: "" SeqNo: 0 CreateTime: 2025-12-09T03:42:22.388000Z WriteTime: 2025-12-09T03:42:22.389000Z MessageGroupId: "" Meta: { } MessageMeta: { } } Partition session id: 1 Topic: "pq_kikimr_streaming_v1_input" Partition: 0 }
2025-12-09T03:42:26.395210Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:761: SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, task: 1. PQ source. SessionId: 32b54056-90cb1c67-b81f37fa-1c26c988 Key: 0@ Data received: Message { Data: "17" Information: { Offset: 3 ProducerId: "" SeqNo: 0 CreateTime: 2025-12-09T03:42:22.388000Z WriteTime: 2025-12-09T03:42:22.399000Z MessageGroupId: "" Meta: { } MessageMeta: { } } Partition session id: 1 Topic: "pq_kikimr_streaming_v1_input" Partition: 0 }
2025-12-09T03:42:26.395213Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:761: SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, task: 1. PQ source. SessionId: 32b54056-90cb1c67-b81f37fa-1c26c988 Key: 0@ Data received: Message { Data: "18" Information: { Offset: 4 ProducerId: "" SeqNo: 0 CreateTime: 2025-12-09T03:42:22.388000Z WriteTime: 2025-12-09T03:42:22.399000Z MessageGroupId: "" Meta: { } MessageMeta: { } } Partition session id: 1 Topic: "pq_kikimr_streaming_v1_input" Partition: 0 }
2025-12-09T03:42:26.395216Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:761: SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, task: 1. PQ source. SessionId: 32b54056-90cb1c67-b81f37fa-1c26c988 Key: 0@ Data received: Message { Data: "19" Information: { Offset: 5 ProducerId: "" SeqNo: 0 CreateTime: 2025-12-09T03:42:22.388000Z WriteTime: 2025-12-09T03:42:22.399000Z MessageGroupId: "" Meta: { } MessageMeta: { } } Partition session id: 1 Topic: "pq_kikimr_streaming_v1_input" Partition: 0 }
2025-12-09T03:42:26.395230Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:737: SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, task: 1. PQ source. SessionId: 32b54056-90cb1c67-b81f37fa-1c26c988 Return ready batch. DataCount = 6 Watermark = none Used space = 10
2025-12-09T03:42:26.395232Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:81: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Poll async input 0. Buffer free space: 1000000, read from async input: 10 bytes, 6 rows, finished: 0
2025-12-09T03:42:26.395258Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:363: SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, task: 1. PQ source. SessionId: 32b54056-90cb1c67-b81f37fa-1c26c988 Source data ready
2025-12-09T03:42:26.395261Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-12-09T03:42:26.395265Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Poll inputs
2025-12-09T03:42:26.395266Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Poll sources
2025-12-09T03:42:26.395269Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:542: SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, task: 1. PQ source. SessionId: 32b54056-90cb1c67-b81f37fa-1c26c988 GetAsyncInputData freeSpace = 999990
2025-12-09T03:42:26.395271Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:81: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Poll async input 0. Buffer free space: 999990, read from async input: 0 bytes, 0 rows, finished: 0
2025-12-09T03:42:26.395330Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-12-09T03:42:26.395333Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Poll inputs
2025-12-09T03:42:26.395335Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Poll sources
2025-12-09T03:42:26.395337Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:542: SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, task: 1. PQ source. SessionId: 32b54056-90cb1c67-b81f37fa-1c26c988 GetAsyncInputData freeSpace = 999990
2025-12-09T03:42:26.395340Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:81: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Poll async input 0. Buffer free space: 999990, read from async input: 0 bytes, 0 rows, finished: 0
2025-12-09T03:42:26.395343Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. update task runner stats
2025-12-09T03:42:26.395364Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-09T03:42:26.395367Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-09T03:42:26.395370Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-09T03:42:26.395373Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-12-09T03:42:26.395398Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [1:7581698520411739567:2311], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. SendData. Batch: 6. Checkpoint: 0. Finished: 0
2025-12-09T03:42:26.395400Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:221: SelfId: [1:7581698520411739567:2311], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. Received data for sending: 6
2025-12-09T03:42:26.395403Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:221: SelfId: [1:7581698520411739567:2311], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. Received data for sending: 9
2025-12-09T03:42:26.395404Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:221: SelfId: [1:7581698520411739567:2311], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. Received data for sending: 11
2025-12-09T03:42:26.395405Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:221: SelfId: [1:7581698520411739567:2311], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. Received data for sending: 17
2025-12-09T03:42:26.395406Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:221: SelfId: [1:7581698520411739567:2311], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. Received data for sending: 18
2025-12-09T03:42:26.395407Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:221: SelfId: [1:7581698520411739567:2311], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. Received data for sending: 19
2025-12-09T03:42:26.395431Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Sink 0: sent 30 bytes of data and 0 bytes of checkpoint barrier
2025-12-09T03:42:26.395433Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Drain sink 0. Free space decreased: 10, sent data from buffer: 30
2025-12-09T03:42:26.395457Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Poll inputs
2025-12-09T03:42:26.395459Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Poll sources
2025-12-09T03:42:26.395461Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:542: SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, task: 1. PQ source. SessionId: 32b54056-90cb1c67-b81f37fa-1c26c988 GetAsyncInputData freeSpace = 1000000
2025-12-09T03:42:26.395466Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:81: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Poll async input 0. Buffer free space: 1000000, read from async input: 0 bytes, 0 rows, finished: 0
2025-12-09T03:42:26.395471Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. update task runner stats
2025-12-09T03:42:26.395479Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-09T03:42:26.395481Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-09T03:42:26.395482Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. About to drain sink 0. FreeSpace: 16777206, allowedOvercommit: 500000, toSend: 17277206
2025-12-09T03:42:26.395485Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-12-09T03:42:26.395487Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [1:7581698520411739567:2311], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-12-09T03:42:26.395489Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-12-09T03:42:26.395490Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-09T03:42:26.395518Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. update task runner stats
2025-12-09T03:42:26.395525Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-09T03:42:26.395526Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-09T03:42:26.395527Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. About to drain sink 0. FreeSpace: 16777206, allowedOvercommit: 500000, toSend: 17277206
2025-12-09T03:42:26.395530Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [1:7581698520411739567:2311], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-12-09T03:42:26.395532Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-12-09T03:42:26.395533Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-09T03:42:26.395542Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. update task runner stats
2025-12-09T03:42:26.395547Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-09T03:42:26.395549Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-09T03:42:26.395550Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. About to drain sink 0. FreeSpace: 16777206, allowedOvercommit: 500000, toSend: 17277206
2025-12-09T03:42:26.395552Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [1:7581698520411739567:2311], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-12-09T03:42:26.395553Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-12-09T03:42:26.395554Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-09T03:42:26.400743Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:26.400734Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId []  MessageGroupId [2847d55f-b7bee33c-5807f910-b751220d] Write session: OnReadDone gRpcStatusCode: 0
2025-12-09T03:42:26.400769Z :YDB_SDK INFO: actor.cpp:37: 2025-12-09T03:42:26.400765Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId []  MessageGroupId [2847d55f-b7bee33c-5807f910-b751220d] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1765251746400 BytesWritten: 0 MessagesWritten: 0 BytesWrittenCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:42:26.400799Z :YDB_SDK INFO: actor.cpp:37: 2025-12-09T03:42:26.400796Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId []  MessageGroupId [2847d55f-b7bee33c-5807f910-b751220d] Write session established. Init response: last_seq_no: 6 session_id: "2847d55f-b7bee33c-5807f910-b751220d|78f35ae0-fd0b1555-a4f96de8-5ce41392_0" partition_id: 1
2025-12-09T03:42:26.400805Z :YDB_SDK TRACE: actor.cpp:37: 2025-12-09T03:42:26.400802Z :TRACE: [local] TRACE_EVENT InitResponse  partition_id=1 session_id=2847d55f-b7bee33c-5807f910-b751220d|78f35ae0-fd0b1555-a4f96de8-5ce41392_0
2025-12-09T03:42:26.400811Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:26.400809Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|78f35ae0-fd0b1555-a4f96de8-5ce41392_0]  MessageGroupId [2847d55f-b7bee33c-5807f910-b751220d] Write session: set DirectWriteToPartitionId 1
2025-12-09T03:42:26.400906Z :YDB_SDK INFO: actor.cpp:37: 2025-12-09T03:42:26.400903Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|78f35ae0-fd0b1555-a4f96de8-5ce41392_0]  PartitionId [1]  Generation [0] Get partition location async, partition 1, delay 0.000000s
2025-12-09T03:42:26.400915Z :YDB_SDK TRACE: actor.cpp:37: 2025-12-09T03:42:26.400914Z :TRACE: [local] TRACE_EVENT DescribePartitionRequest  path=local/pq_kikimr_streaming_v1_output partition_id=1
2025-12-09T03:42:26.400980Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:26.400968Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|78f35ae0-fd0b1555-a4f96de8-5ce41392_0]  PartitionId [1]  Generation [0]  Getting partition location, partition 1
2025-12-09T03:42:26.401968Z :YDB_SDK INFO: actor.cpp:37: 2025-12-09T03:42:26.401960Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|78f35ae0-fd0b1555-a4f96de8-5ce41392_0]  PartitionId [1]  Generation [0] Got PartitionLocation response. Status SUCCESS, proto:
partition {
  partition_id: 1
  active: true
  partition_location {
    node_id: 1
    generation: 1
  }
}

2025-12-09T03:42:26.402007Z :YDB_SDK TRACE: actor.cpp:37: 2025-12-09T03:42:26.401984Z :TRACE: [local] TRACE_EVENT DescribePartitionResponse  partition_id=1 active=1 pl_node_id=1 pl_generation=1
2025-12-09T03:42:26.402015Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:26.402012Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|78f35ae0-fd0b1555-a4f96de8-5ce41392_0]  PartitionId [1]  Generation [0] GetPreferredEndpoint: partitionId 1, partitionNodeId 1 exists in the endpoint pool.
2025-12-09T03:42:26.402020Z :YDB_SDK TRACE: actor.cpp:37: 2025-12-09T03:42:26.402018Z :TRACE: [local] TRACE_EVENT PreferredPartitionLocation  Endpoint= NodeId=1 Generation=1
2025-12-09T03:42:26.402025Z :YDB_SDK INFO: actor.cpp:37: 2025-12-09T03:42:26.402023Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|78f35ae0-fd0b1555-a4f96de8-5ce41392_0]  PartitionId [1]  Generation [1] Start write session. Will connect to nodeId: 1
2025-12-09T03:42:26.402274Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:26.402259Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|78f35ae0-fd0b1555-a4f96de8-5ce41392_0]  PartitionId [1]  Generation [1] Write session: OnReadDone gRpcStatusCode: 1, Msg: CANCELLED, Details: , InternalError: 0
2025-12-09T03:42:26.402345Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:26.402343Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|78f35ae0-fd0b1555-a4f96de8-5ce41392_0]  PartitionId [1]  Generation [1] Write session: direct write to partition: 1, generation 1
2025-12-09T03:42:26.402372Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:26.402370Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|78f35ae0-fd0b1555-a4f96de8-5ce41392_0]  PartitionId [1]  Generation [1] Write session: send init request: init_request { path: "pq_kikimr_streaming_v1_output" producer_id: "2847d55f-b7bee33c-5807f910-b751220d" partition_with_generation { partition_id: 1 generation: 1 } }
2025-12-09T03:42:26.402380Z :YDB_SDK TRACE: actor.cpp:37: 2025-12-09T03:42:26.402378Z :TRACE: [local] TRACE_EVENT InitRequest  pwg_partition_id=1 pwg_generation=1
2025-12-09T03:42:26.402441Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:26.402439Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|78f35ae0-fd0b1555-a4f96de8-5ce41392_0]  PartitionId [1]  Generation [1] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-09T03:42:26.408980Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:26.408968Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|78f35ae0-fd0b1555-a4f96de8-5ce41392_0]  PartitionId [1]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-09T03:42:26.409030Z :YDB_SDK INFO: actor.cpp:37: 2025-12-09T03:42:26.409027Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|78f35ae0-fd0b1555-a4f96de8-5ce41392_0]  PartitionId [1]  Generation [1] Write session established. Init response: last_seq_no: 6 session_id: "2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0" partition_id: 1
2025-12-09T03:42:26.409035Z :YDB_SDK TRACE: actor.cpp:37: 2025-12-09T03:42:26.409033Z :TRACE: [local] TRACE_EVENT InitResponse  partition_id=1 session_id=2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0
2025-12-09T03:42:26.409039Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:26.409037Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] Write session: set DirectWriteToPartitionId 1
2025-12-09T03:42:26.409114Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:26.409094Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] Write 1 messages with Id from 1 to 1
2025-12-09T03:42:26.409139Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:26.409137Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] Write session: try to update token
2025-12-09T03:42:26.409151Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:26.409148Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] Send 1 message(s) (0 left), first sequence number is 1
2025-12-09T03:42:26.409250Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:26.409248Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] Write 1 messages with Id from 2 to 2
2025-12-09T03:42:26.409261Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:26.409259Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] Write session: try to update token
2025-12-09T03:42:26.409265Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:26.409262Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] Send 1 message(s) (0 left), first sequence number is 2
2025-12-09T03:42:26.409272Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:26.409270Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] Write 1 messages with Id from 3 to 3
2025-12-09T03:42:26.409276Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:26.409274Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] Write session: try to update token
2025-12-09T03:42:26.409279Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:26.409277Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] Send 1 message(s) (0 left), first sequence number is 3
2025-12-09T03:42:26.409285Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:26.409283Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] Write 1 messages with Id from 4 to 4
2025-12-09T03:42:26.409290Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:26.409289Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] Write session: try to update token
2025-12-09T03:42:26.409293Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:26.409292Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] Send 1 message(s) (0 left), first sequence number is 4
2025-12-09T03:42:26.409298Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:26.409297Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] Write 1 messages with Id from 5 to 5
2025-12-09T03:42:26.409301Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:26.409300Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] Write session: try to update token
2025-12-09T03:42:26.409304Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:26.409303Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] Send 1 message(s) (0 left), first sequence number is 5
2025-12-09T03:42:26.409310Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:26.409309Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] Write 1 messages with Id from 6 to 6
2025-12-09T03:42:26.409315Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:26.409313Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] Write session: try to update token
2025-12-09T03:42:26.409318Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:26.409316Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] Send 1 message(s) (0 left), first sequence number is 6
2025-12-09T03:42:26.409829Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:26.409823Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-09T03:42:26.409891Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:26.409888Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] Write session got write response: acks { seq_no: 1 skipped { reason: REASON_ALREADY_WRITTEN } } partition_id: 1 write_statistics { persisting_time { } min_queue_wait_time { } max_queue_wait_time { } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-09T03:42:26.409899Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:26.409897Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] OnAck: seqNo=1, txId=?
2025-12-09T03:42:26.409903Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:26.409901Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] Write session: acknoledged message 1
2025-12-09T03:42:26.409984Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:454: SelfId: [1:7581698520411739567:2311], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. Ack seq no 1
2025-12-09T03:42:26.410256Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:26.410249Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-09T03:42:26.410301Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:26.410298Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] Write session got write response: acks { seq_no: 2 skipped { reason: REASON_ALREADY_WRITTEN } } partition_id: 1 write_statistics { persisting_time { } min_queue_wait_time { } max_queue_wait_time { } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-09T03:42:26.410305Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:26.410303Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] OnAck: seqNo=2, txId=?
2025-12-09T03:42:26.410308Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:26.410306Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] Write session: acknoledged message 2
2025-12-09T03:42:26.410373Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:454: SelfId: [1:7581698520411739567:2311], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. Ack seq no 2
2025-12-09T03:42:26.410702Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:26.410698Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-09T03:42:26.410728Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:26.410726Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] Write session got write response: acks { seq_no: 3 skipped { reason: REASON_ALREADY_WRITTEN } } partition_id: 1 write_statistics { persisting_time { } min_queue_wait_time { } max_queue_wait_time { } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-09T03:42:26.410732Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:26.410730Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] OnAck: seqNo=3, txId=?
2025-12-09T03:42:26.410736Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:26.410733Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] Write session: acknoledged message 3
2025-12-09T03:42:26.410790Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:454: SelfId: [1:7581698520411739567:2311], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. Ack seq no 3
2025-12-09T03:42:26.411463Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:26.411457Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-09T03:42:26.411494Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:26.411491Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] Write session got write response: acks { seq_no: 4 skipped { reason: REASON_ALREADY_WRITTEN } } partition_id: 1 write_statistics { persisting_time { } min_queue_wait_time { } max_queue_wait_time { } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-09T03:42:26.411498Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:26.411496Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] OnAck: seqNo=4, txId=?
2025-12-09T03:42:26.411502Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:26.411500Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] Write session: acknoledged message 4
2025-12-09T03:42:26.411613Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:454: SelfId: [1:7581698520411739567:2311], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. Ack seq no 4
2025-12-09T03:42:26.411651Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:26.411636Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-09T03:42:26.411681Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:26.411679Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] Write session got write response: acks { seq_no: 5 skipped { reason: REASON_ALREADY_WRITTEN } } partition_id: 1 write_statistics { persisting_time { } min_queue_wait_time { } max_queue_wait_time { } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-09T03:42:26.411685Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:26.411683Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] OnAck: seqNo=5, txId=?
2025-12-09T03:42:26.411688Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:26.411687Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] Write session: acknoledged message 5
2025-12-09T03:42:26.411717Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:26.411715Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-09T03:42:26.411733Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:26.411732Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] Write session got write response: acks { seq_no: 6 skipped { reason: REASON_ALREADY_WRITTEN } } partition_id: 1 write_statistics { persisting_time { } min_queue_wait_time { } max_queue_wait_time { } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-09T03:42:26.411736Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:26.411735Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] OnAck: seqNo=6, txId=?
2025-12-09T03:42:26.411738Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:26.411737Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] Write session: acknoledged message 6
2025-12-09T03:42:26.411812Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:454: SelfId: [1:7581698520411739567:2311], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. Ack seq no 5
2025-12-09T03:42:26.411814Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:454: SelfId: [1:7581698520411739567:2311], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. Ack seq no 6
2025-12-09T03:42:27.274652Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 5049041a-f725b96d-2eecd124-9e57595e5, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:42:27.278129Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:42:27.278146Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-09T03:42:27.291017Z :FQ_PINGER TRACE: pinger.cpp:400: QueryId: ptqudqgd6kvcs9idrfdt, Owner: 5049041a-f725b96d-2eecd124-9e57595e3 Request Private::PingTask
2025-12-09T03:42:27.299908Z :FQ_PINGER TRACE: pinger.cpp:338: QueryId: ptqudqgd6kvcs9idrfdt, Owner: 5049041a-f725b96d-2eecd124-9e57595e3 Ping response success: { expired_at { seconds: 1765251750 nanos: 294000000 } }
2025-12-09T03:42:27.324825Z :YQL_PROXY TRACE: log.cpp:64: SessionId:  2025-12-09 03:42:27.324 TRACE ydbd(pid=1612752, tid=0x00007F97642FE640) [DQ] task_controller_impl.h:271:  [1:7581698520411739555:2309] ExportStats Summary
2025-12-09T03:42:27.325011Z :FQ_PINGER TRACE: pinger.cpp:250: QueryId: ptqudqgd6kvcs9idrfdt, Owner: 5049041a-f725b96d-2eecd124-9e57595e3 Forward ping request: { statistics: "{\"Graph=0\":{\"TaskRunner\":{\"Stage=200289\":{\"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-12-09T03:42:27.325022Z :FQ_PINGER TRACE: pinger.cpp:393: QueryId: ptqudqgd6kvcs9idrfdt, Owner: 5049041a-f725b96d-2eecd124-9e57595e3 Forward request Private::PingTask
2025-12-09T03:42:27.336154Z :FQ_PINGER TRACE: pinger.cpp:338: QueryId: ptqudqgd6kvcs9idrfdt, Owner: 5049041a-f725b96d-2eecd124-9e57595e3 Ping response success: { expired_at { seconds: 1765251750 nanos: 331000000 } }
2025-12-09T03:42:27.336200Z :FQ_RUN_ACTOR TRACE: run_actor.cpp:861: QueryId: ptqudqgd6kvcs9idrfdt Forward ping response. Success: 1. Cookie: 6
2025-12-09T03:42:27.384410Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:27.384398Z :DEBUG: [local] [local] [32b54056-90cb1c67-b81f37fa-1c26c988] [] Got ReadResponse, serverBytesSize = 223, now ReadSizeBudget = 0, ReadSizeServerDelta = 8388385
2025-12-09T03:42:27.384451Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:27.384449Z :DEBUG: [local] [local] [32b54056-90cb1c67-b81f37fa-1c26c988] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 8388385
2025-12-09T03:42:27.384472Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:27.384470Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (6-13)
2025-12-09T03:42:27.384478Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:27.384476Z :DEBUG: [local] [local] [32b54056-90cb1c67-b81f37fa-1c26c988] [] Returning serverBytesSize = 223 to budget
2025-12-09T03:42:27.384482Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:27.384480Z :DEBUG: [local] [local] [32b54056-90cb1c67-b81f37fa-1c26c988] [] In ContinueReadingDataImpl, ReadSizeBudget = 223, ReadSizeServerDelta = 8388385
2025-12-09T03:42:27.384529Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:27.384526Z :DEBUG: [local] [local] [32b54056-90cb1c67-b81f37fa-1c26c988] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 8388608
2025-12-09T03:42:27.384604Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:363: SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, task: 1. PQ source. SessionId: 32b54056-90cb1c67-b81f37fa-1c26c988 Source data ready
2025-12-09T03:42:27.384632Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Poll inputs
2025-12-09T03:42:27.384635Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Poll sources
2025-12-09T03:42:27.384643Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:542: SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, task: 1. PQ source. SessionId: 32b54056-90cb1c67-b81f37fa-1c26c988 GetAsyncInputData freeSpace = 1000000
2025-12-09T03:42:27.384670Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:27.384665Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (6-6)
2025-12-09T03:42:27.384678Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:27.384676Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 1} (7-7)
2025-12-09T03:42:27.384695Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:27.384693Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 2} (8-8)
2025-12-09T03:42:27.384708Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:27.384706Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 3} (9-9)
2025-12-09T03:42:27.384715Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:27.384713Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 4} (10-10)
2025-12-09T03:42:27.384719Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:27.384718Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 5} (11-11)
2025-12-09T03:42:27.384724Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:27.384722Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 6} (12-12)
2025-12-09T03:42:27.384728Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:27.384727Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 7} (13-13)
2025-12-09T03:42:27.384739Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:27.384735Z :DEBUG: [local] [local] [32b54056-90cb1c67-b81f37fa-1c26c988] [] The application data is transferred to the client. Number of messages 8, size 16 bytes
2025-12-09T03:42:27.384750Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:27.384748Z :DEBUG: [local] [local] [32b54056-90cb1c67-b81f37fa-1c26c988] [] Returning serverBytesSize = 0 to budget
2025-12-09T03:42:27.384771Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:761: SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, task: 1. PQ source. SessionId: 32b54056-90cb1c67-b81f37fa-1c26c988 Key: 0@ Data received: Message { Data: "21" Information: { Offset: 6 ProducerId: "" SeqNo: 0 CreateTime: 2025-12-09T03:42:27.382000Z WriteTime: 2025-12-09T03:42:27.382000Z MessageGroupId: "" Meta: { } MessageMeta: { } } Partition session id: 1 Topic: "pq_kikimr_streaming_v1_input" Partition: 0 }
2025-12-09T03:42:27.384788Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:761: SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, task: 1. PQ source. SessionId: 32b54056-90cb1c67-b81f37fa-1c26c988 Key: 0@ Data received: Message { Data: "23" Information: { Offset: 7 ProducerId: "" SeqNo: 0 CreateTime: 2025-12-09T03:42:27.382000Z WriteTime: 2025-12-09T03:42:27.382000Z MessageGroupId: "" Meta: { } MessageMeta: { } } Partition session id: 1 Topic: "pq_kikimr_streaming_v1_input" Partition: 0 }
2025-12-09T03:42:27.384793Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:761: SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, task: 1. PQ source. SessionId: 32b54056-90cb1c67-b81f37fa-1c26c988 Key: 0@ Data received: Message { Data: "24" Information: { Offset: 8 ProducerId: "" SeqNo: 0 CreateTime: 2025-12-09T03:42:27.382000Z WriteTime: 2025-12-09T03:42:27.382000Z MessageGroupId: "" Meta: { } MessageMeta: { } } Partition session id: 1 Topic: "pq_kikimr_streaming_v1_input" Partition: 0 }
2025-12-09T03:42:27.384798Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:761: SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, task: 1. PQ source. SessionId: 32b54056-90cb1c67-b81f37fa-1c26c988 Key: 0@ Data received: Message { Data: "26" Information: { Offset: 9 ProducerId: "" SeqNo: 0 CreateTime: 2025-12-09T03:42:27.382000Z WriteTime: 2025-12-09T03:42:27.382000Z MessageGroupId: "" Meta: { } MessageMeta: { } } Partition session id: 1 Topic: "pq_kikimr_streaming_v1_input" Partition: 0 }
2025-12-09T03:42:27.384802Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:761: SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, task: 1. PQ source. SessionId: 32b54056-90cb1c67-b81f37fa-1c26c988 Key: 0@ Data received: Message { Data: "27" Information: { Offset: 10 ProducerId: "" SeqNo: 0 CreateTime: 2025-12-09T03:42:27.382000Z WriteTime: 2025-12-09T03:42:27.382000Z MessageGroupId: "" Meta: { } MessageMeta: { } } Partition session id: 1 Topic: "pq_kikimr_streaming_v1_input" Partition: 0 }
2025-12-09T03:42:27.384806Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:761: SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, task: 1. PQ source. SessionId: 32b54056-90cb1c67-b81f37fa-1c26c988 Key: 0@ Data received: Message { Data: "28" Information: { Offset: 11 ProducerId: "" SeqNo: 0 CreateTime: 2025-12-09T03:42:27.382000Z WriteTime: 2025-12-09T03:42:27.382000Z MessageGroupId: "" Meta: { } MessageMeta: { } } Partition session id: 1 Topic: "pq_kikimr_streaming_v1_input" Partition: 0 }
2025-12-09T03:42:27.384810Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:761: SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, task: 1. PQ source. SessionId: 32b54056-90cb1c67-b81f37fa-1c26c988 Key: 0@ Data received: Message { Data: "29" Information: { Offset: 12 ProducerId: "" SeqNo: 0 CreateTime: 2025-12-09T03:42:27.382000Z WriteTime: 2025-12-09T03:42:27.382000Z MessageGroupId: "" Meta: { } MessageMeta: { } } Partition session id: 1 Topic: "pq_kikimr_streaming_v1_input" Partition: 0 }
2025-12-09T03:42:27.384814Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:761: SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, task: 1. PQ source. SessionId: 32b54056-90cb1c67-b81f37fa-1c26c988 Key: 0@ Data received: Message { Data: "30" Information: { Offset: 13 ProducerId: "" SeqNo: 0 CreateTime: 2025-12-09T03:42:27.382000Z WriteTime: 2025-12-09T03:42:27.382000Z MessageGroupId: "" Meta: { } MessageMeta: { } } Partition session id: 1 Topic: "pq_kikimr_streaming_v1_input" Partition: 0 }
2025-12-09T03:42:27.384840Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:737: SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, task: 1. PQ source. SessionId: 32b54056-90cb1c67-b81f37fa-1c26c988 Return ready batch. DataCount = 8 Watermark = none Used space = 16
2025-12-09T03:42:27.384843Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:81: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Poll async input 0. Buffer free space: 1000000, read from async input: 16 bytes, 8 rows, finished: 0
2025-12-09T03:42:27.384864Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:363: SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, task: 1. PQ source. SessionId: 32b54056-90cb1c67-b81f37fa-1c26c988 Source data ready
2025-12-09T03:42:27.384867Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-12-09T03:42:27.384874Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Poll inputs
2025-12-09T03:42:27.384875Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Poll sources
2025-12-09T03:42:27.384879Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:542: SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, task: 1. PQ source. SessionId: 32b54056-90cb1c67-b81f37fa-1c26c988 GetAsyncInputData freeSpace = 999984
2025-12-09T03:42:27.384882Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:81: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Poll async input 0. Buffer free space: 999984, read from async input: 0 bytes, 0 rows, finished: 0
2025-12-09T03:42:27.384963Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-12-09T03:42:27.384970Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Poll inputs
2025-12-09T03:42:27.384971Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Poll sources
2025-12-09T03:42:27.384974Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:542: SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, task: 1. PQ source. SessionId: 32b54056-90cb1c67-b81f37fa-1c26c988 GetAsyncInputData freeSpace = 999984
2025-12-09T03:42:27.384977Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:81: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Poll async input 0. Buffer free space: 999984, read from async input: 0 bytes, 0 rows, finished: 0
2025-12-09T03:42:27.384981Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. update task runner stats
2025-12-09T03:42:27.385007Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-09T03:42:27.385009Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-09T03:42:27.385020Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-09T03:42:27.385024Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-12-09T03:42:27.385030Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [1:7581698520411739567:2311], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. SendData. Batch: 8. Checkpoint: 0. Finished: 0
2025-12-09T03:42:27.385032Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:221: SelfId: [1:7581698520411739567:2311], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. Received data for sending: 21
2025-12-09T03:42:27.385034Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:221: SelfId: [1:7581698520411739567:2311], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. Received data for sending: 23
2025-12-09T03:42:27.385036Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:221: SelfId: [1:7581698520411739567:2311], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. Received data for sending: 24
2025-12-09T03:42:27.385037Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:221: SelfId: [1:7581698520411739567:2311], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. Received data for sending: 26
2025-12-09T03:42:27.385038Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:221: SelfId: [1:7581698520411739567:2311], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. Received data for sending: 27
2025-12-09T03:42:27.385039Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:221: SelfId: [1:7581698520411739567:2311], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. Received data for sending: 28
2025-12-09T03:42:27.385041Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:221: SelfId: [1:7581698520411739567:2311], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. Received data for sending: 29
2025-12-09T03:42:27.385043Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:221: SelfId: [1:7581698520411739567:2311], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. Received data for sending: 30
2025-12-09T03:42:27.385056Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:27.385054Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] Write 1 messages with Id from 7 to 7
2025-12-09T03:42:27.385067Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:27.385066Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] Write session: try to update token
2025-12-09T03:42:27.385073Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:27.385072Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] Send 1 message(s) (0 left), first sequence number is 7
2025-12-09T03:42:27.385216Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Sink 0: sent 40 bytes of data and 0 bytes of checkpoint barrier
2025-12-09T03:42:27.385222Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Drain sink 0. Free space decreased: 16, sent data from buffer: 40
2025-12-09T03:42:27.385233Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:27.385226Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] Write 1 messages with Id from 8 to 8
2025-12-09T03:42:27.385252Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:27.385250Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] Write session: try to update token
2025-12-09T03:42:27.385258Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Poll inputs
2025-12-09T03:42:27.385259Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Poll sources
2025-12-09T03:42:27.385261Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:27.385256Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] Send 1 message(s) (0 left), first sequence number is 8
2025-12-09T03:42:27.385262Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:542: SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, task: 1. PQ source. SessionId: 32b54056-90cb1c67-b81f37fa-1c26c988 GetAsyncInputData freeSpace = 1000000
2025-12-09T03:42:27.385265Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:81: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Poll async input 0. Buffer free space: 1000000, read from async input: 0 bytes, 0 rows, finished: 0
2025-12-09T03:42:27.385269Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. update task runner stats
2025-12-09T03:42:27.385279Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-09T03:42:27.385281Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-09T03:42:27.385283Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. About to drain sink 0. FreeSpace: 16777200, allowedOvercommit: 500000, toSend: 17277200
2025-12-09T03:42:27.385286Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-12-09T03:42:27.385291Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [1:7581698520411739567:2311], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-12-09T03:42:27.385293Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-12-09T03:42:27.385295Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-09T03:42:27.385309Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. update task runner stats
2025-12-09T03:42:27.385315Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-09T03:42:27.385316Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-09T03:42:27.385317Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. About to drain sink 0. FreeSpace: 16777200, allowedOvercommit: 500000, toSend: 17277200
2025-12-09T03:42:27.385320Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [1:7581698520411739567:2311], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-12-09T03:42:27.385322Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-12-09T03:42:27.385323Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-09T03:42:27.385335Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. update task runner stats
2025-12-09T03:42:27.385341Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-09T03:42:27.385342Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-09T03:42:27.385344Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. About to drain sink 0. FreeSpace: 16777200, allowedOvercommit: 500000, toSend: 17277200
2025-12-09T03:42:27.385346Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [1:7581698520411739567:2311], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-12-09T03:42:27.385348Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-12-09T03:42:27.385349Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-09T03:42:27.385355Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:27.385353Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] Write 1 messages with Id from 9 to 9
2025-12-09T03:42:27.385362Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:27.385361Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] Write session: try to update token
2025-12-09T03:42:27.385366Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:27.385365Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] Send 1 message(s) (0 left), first sequence number is 9
2025-12-09T03:42:27.385407Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:27.385405Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] Write 1 messages with Id from 10 to 10
2025-12-09T03:42:27.385413Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:27.385412Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] Write session: try to update token
2025-12-09T03:42:27.385417Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:27.385416Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] Send 1 message(s) (0 left), first sequence number is 10
2025-12-09T03:42:27.385425Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:27.385423Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] Write 1 messages with Id from 11 to 11
2025-12-09T03:42:27.385431Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:27.385428Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] Write session: try to update token
2025-12-09T03:42:27.385434Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:27.385433Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] Send 1 message(s) (0 left), first sequence number is 11
2025-12-09T03:42:27.385440Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:27.385438Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] Write 1 messages with Id from 12 to 12
2025-12-09T03:42:27.385446Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:27.385444Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] Write session: try to update token
2025-12-09T03:42:27.385449Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:27.385448Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] Send 1 message(s) (0 left), first sequence number is 12
2025-12-09T03:42:27.385657Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:27.385650Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] Write 1 messages with Id from 13 to 13
2025-12-09T03:42:27.385675Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:27.385673Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] Write session: try to update token
2025-12-09T03:42:27.385680Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:27.385678Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] Send 1 message(s) (0 left), first sequence number is 13
2025-12-09T03:42:27.385741Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:27.385739Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] Write 1 messages with Id from 14 to 14
2025-12-09T03:42:27.385752Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:27.385750Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] Write session: try to update token
2025-12-09T03:42:27.385755Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:27.385754Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] Send 1 message(s) (0 left), first sequence number is 14
2025-12-09T03:42:27.386869Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:27.386862Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-09T03:42:27.386919Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:27.386916Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] Write session got write response: acks { seq_no: 7 written { offset: 6 } } partition_id: 1 write_statistics { persisting_time { nanos: 1000000 } min_queue_wait_time { } max_queue_wait_time { } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-09T03:42:27.386925Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:27.386923Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] OnAck: seqNo=7, txId=?
2025-12-09T03:42:27.386928Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:27.386927Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] Write session: acknoledged message 7
2025-12-09T03:42:27.386996Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:454: SelfId: [1:7581698520411739567:2311], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. Ack seq no 7
2025-12-09T03:42:27.387700Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:27.387694Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-09T03:42:27.387741Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:27.387739Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] Write session got write response: acks { seq_no: 8 written { offset: 7 } } partition_id: 1 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-12-09T03:42:27.387746Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:27.387743Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] OnAck: seqNo=8, txId=?
2025-12-09T03:42:27.387750Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:27.387748Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] Write session: acknoledged message 8
2025-12-09T03:42:27.387792Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:27.387790Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-09T03:42:27.387812Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:27.387810Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] Write session got write response: acks { seq_no: 9 written { offset: 8 } } partition_id: 1 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-12-09T03:42:27.387815Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:27.387813Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] OnAck: seqNo=9, txId=?
2025-12-09T03:42:27.387818Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:27.387816Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] Write session: acknoledged message 9
2025-12-09T03:42:27.387851Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:27.387839Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-09T03:42:27.387864Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:27.387861Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] Write session got write response: acks { seq_no: 10 written { offset: 9 } } partition_id: 1 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-12-09T03:42:27.387867Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:27.387866Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] OnAck: seqNo=10, txId=?
2025-12-09T03:42:27.387871Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:27.387869Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] Write session: acknoledged message 10
2025-12-09T03:42:27.387880Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:454: SelfId: [1:7581698520411739567:2311], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. Ack seq no 8
2025-12-09T03:42:27.387884Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:454: SelfId: [1:7581698520411739567:2311], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. Ack seq no 9
2025-12-09T03:42:27.387889Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:454: SelfId: [1:7581698520411739567:2311], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. Ack seq no 10
2025-12-09T03:42:27.387891Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:27.387889Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-09T03:42:27.387902Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:27.387901Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] Write session got write response: acks { seq_no: 11 written { offset: 10 } } partition_id: 1 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-12-09T03:42:27.387905Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:27.387904Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] OnAck: seqNo=11, txId=?
2025-12-09T03:42:27.387908Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:27.387907Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] Write session: acknoledged message 11
2025-12-09T03:42:27.387928Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:27.387926Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-09T03:42:27.387938Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:27.387937Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] Write session got write response: acks { seq_no: 12 written { offset: 11 } } partition_id: 1 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-12-09T03:42:27.387941Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:27.387940Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] OnAck: seqNo=12, txId=?
2025-12-09T03:42:27.387944Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:27.387943Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] Write session: acknoledged message 12
2025-12-09T03:42:27.387956Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:454: SelfId: [1:7581698520411739567:2311], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. Ack seq no 11
2025-12-09T03:42:27.387963Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:27.387961Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-09T03:42:27.387974Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:27.387972Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] Write session got write response: acks { seq_no: 13 written { offset: 12 } } partition_id: 1 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-12-09T03:42:27.387976Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:27.387975Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] OnAck: seqNo=13, txId=?
2025-12-09T03:42:27.387979Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:27.387978Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] Write session: acknoledged message 13
2025-12-09T03:42:27.387993Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:27.387992Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-09T03:42:27.388002Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:27.388001Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] Write session got write response: acks { seq_no: 14 written { offset: 13 } } partition_id: 1 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-12-09T03:42:27.388004Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:27.388003Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] OnAck: seqNo=14, txId=?
2025-12-09T03:42:27.388007Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:27.388005Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] Write session: acknoledged message 14
2025-12-09T03:42:27.388012Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:454: SelfId: [1:7581698520411739567:2311], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. Ack seq no 12
2025-12-09T03:42:27.388015Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:454: SelfId: [1:7581698520411739567:2311], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. Ack seq no 13
2025-12-09T03:42:27.388031Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:454: SelfId: [1:7581698520411739567:2311], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. Ack seq no 14
2025-12-09T03:42:27.390321Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:373: [ptqudqgd6kvcs9idrfdt-0.3] Got TEvScheduleCheckpointing
2025-12-09T03:42:27.390336Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:349: [ptqudqgd6kvcs9idrfdt-0.3] [3:1] Registering new checkpoint in storage
2025-12-09T03:42:27.390434Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:288: [ptqudqgd6kvcs9idrfdt-0.3] [3:1] Got TEvCreateCheckpointRequest
2025-12-09T03:42:27.391124Z :YDB_SDK INFO: actor.cpp:37: 2025-12-09T03:42:27.391117Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:pq_kikimr_streaming_v1_input:0:1:13:0
2025-12-09T03:42:27.391147Z :YDB_SDK INFO: actor.cpp:37: 2025-12-09T03:42:27.391145Z :INFO: [local] [local] [32b54056-90cb1c67-b81f37fa-1c26c988] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1000 BytesRead: 26 MessagesRead: 14 BytesReadCompressed: 26 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:42:27.417592Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:334: [ptqudqgd6kvcs9idrfdt-0.3] [3:1] Checkpoint created
2025-12-09T03:42:27.417610Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:336: [ptqudqgd6kvcs9idrfdt-0.3] [3:1] Send TEvCreateCheckpointResponse
2025-12-09T03:42:27.417650Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:389: [ptqudqgd6kvcs9idrfdt-0.3] [3:1] Got TEvCreateCheckpointResponse
2025-12-09T03:42:27.417657Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:435: [ptqudqgd6kvcs9idrfdt-0.3] [3:1] Checkpoint successfully created, going to inject barriers to 2 actor(s)
2025-12-09T03:42:27.417692Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:239: [ptqudqgd6kvcs9idrfdt-0] Task: 1. [Checkpoint 3.1] TEvInjectCheckpoint
2025-12-09T03:42:27.417707Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Poll inputs
2025-12-09T03:42:27.417716Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1494: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Skip polling sources because of pending checkpoint
2025-12-09T03:42:27.417719Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. DoExecuteImpl: 1
2025-12-09T03:42:27.417791Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:462: SelfId: [1:7581698520411739560:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Pending 1 checkpoints to be sent
2025-12-09T03:42:27.417805Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. update task runner stats
2025-12-09T03:42:27.417839Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 1 watermark injected: (empty maybe)
2025-12-09T03:42:27.417848Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:447: [ptqudqgd6kvcs9idrfdt-0] Task: 1. [Checkpoint 3.1] Performing task checkpoint
2025-12-09T03:42:27.417851Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:816: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Save state
2025-12-09T03:42:27.417862Z :KQP_COMPUTE DEBUG: dq_pq_read_actor_base.cpp:94: SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, task: 1. PQ source. SessionId: 32b54056-90cb1c67-b81f37fa-1c26c988 SaveState, offsets: {0,14},
2025-12-09T03:42:27.417884Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:474: [ptqudqgd6kvcs9idrfdt-0] Task: 1. [Checkpoint 3.1] CA state saved
2025-12-09T03:42:27.417887Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:449: [ptqudqgd6kvcs9idrfdt-0] Task: 1. [Checkpoint 3.1] Injecting checkpoint barrier to outputs
2025-12-09T03:42:27.417890Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-09T03:42:27.417895Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-09T03:42:27.417904Z :KQP_COMPUTE INFO: dq_async_compute_actor.cpp:1010: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Resume inputs
2025-12-09T03:42:27.417907Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [1:7581698520411739567:2311], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. SendData. Batch: 0. Checkpoint: 1. Finished: 0
2025-12-09T03:42:27.417911Z :KQP_COMPUTE DEBUG: dq_pq_write_actor.cpp:240: SelfId: [1:7581698520411739567:2311], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. [Checkpoint 3.1] Send checkpoint state immediately
2025-12-09T03:42:27.417943Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:418: SelfId: [1:7581698520411739567:2311], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. Save checkpoint { Id: 1 Generation: 3 Type: CHECKPOINT_TYPE_SNAPSHOT } state: { SourceId: "2847d55f-b7bee33c-5807f910-b751220d" ConfirmedSeqNo: 14 EgressBytes: 26 }
2025-12-09T03:42:27.417948Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:524: [ptqudqgd6kvcs9idrfdt-0] Task: 1. Sink[0] state saved
2025-12-09T03:42:27.417957Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:536: [ptqudqgd6kvcs9idrfdt-0] Task: 1. [Checkpoint 3.1] Task checkpoint is done. Send to storage
2025-12-09T03:42:27.417965Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Sink 0: sent 0 bytes of data and 6 bytes of checkpoint barrier
2025-12-09T03:42:27.417967Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-09T03:42:27.417968Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:460: [ptqudqgd6kvcs9idrfdt-0] [3:1] Got TEvSaveTaskState: task 1
2025-12-09T03:42:27.417970Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Poll inputs
2025-12-09T03:42:27.417972Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Poll sources
2025-12-09T03:42:27.417976Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:542: SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, task: 1. PQ source. SessionId: 32b54056-90cb1c67-b81f37fa-1c26c988 GetAsyncInputData freeSpace = 1000000
2025-12-09T03:42:27.417984Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:81: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Poll async input 0. Buffer free space: 1000000, read from async input: 0 bytes, 0 rows, finished: 0
2025-12-09T03:42:27.418008Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-12-09T03:42:27.418030Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. update task runner stats
2025-12-09T03:42:27.418040Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-09T03:42:27.418042Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-09T03:42:27.418044Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-09T03:42:27.418048Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [1:7581698520411739567:2311], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-12-09T03:42:27.418050Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-12-09T03:42:27.418051Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-09T03:42:27.421049Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:484: [ptqudqgd6kvcs9idrfdt-0] [3:1] TEvSaveTaskState Apply: task: 1
2025-12-09T03:42:27.421063Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:499: [ptqudqgd6kvcs9idrfdt-0] [3:1] Send TEvSaveTaskStateResult: task: 1
2025-12-09T03:42:27.421121Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:466: [ptqudqgd6kvcs9idrfdt-0.3] [3:1] Got TEvSaveTaskStateResult; task 1, status: OK, size: 182
2025-12-09T03:42:27.421134Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:476: [ptqudqgd6kvcs9idrfdt-0.3] [3:1] Task state saved, need 1 more acks
2025-12-09T03:42:27.421412Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:466: [ptqudqgd6kvcs9idrfdt-0.3] [3:1] Got TEvSaveTaskStateResult; task 2, status: OK, size: 184
2025-12-09T03:42:27.421422Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:476: [ptqudqgd6kvcs9idrfdt-0.3] [3:1] Task state saved, need 0 more acks
2025-12-09T03:42:27.421425Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:489: [ptqudqgd6kvcs9idrfdt-0.3] [3:1] Got all acks, changing checkpoint status to 'PendingCommit'
2025-12-09T03:42:27.421441Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:343: [ptqudqgd6kvcs9idrfdt-0.3] [3:1] Got TEvSetCheckpointPendingCommitStatusRequest
2025-12-09T03:42:27.442968Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:362: [ptqudqgd6kvcs9idrfdt-0.3] [3:1] Status updated to 'PendingCommit'
2025-12-09T03:42:27.443003Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:364: [ptqudqgd6kvcs9idrfdt-0.3] [3:1] Send TEvSetCheckpointPendingCommitStatusResponse
2025-12-09T03:42:27.443061Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:501: [ptqudqgd6kvcs9idrfdt-0.3] [3:1] Got TEvSetCheckpointPendingCommitStatusResponse
2025-12-09T03:42:27.443077Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:516: [ptqudqgd6kvcs9idrfdt-0.3] [3:1] Checkpoint status changed to 'PendingCommit', committing states to 2 actor(s)
2025-12-09T03:42:27.443129Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:759: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Commit state
2025-12-09T03:42:27.443159Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:27.443154Z :DEBUG: [local] [local] [32b54056-90cb1c67-b81f37fa-1c26c988] [] Commit offsets [0, 14). Partition stream id: 1
2025-12-09T03:42:27.443315Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:532: [ptqudqgd6kvcs9idrfdt-0.3] [3:1] Got TEvStateCommitted; task: 1
2025-12-09T03:42:27.443324Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:541: [ptqudqgd6kvcs9idrfdt-0.3] [3:1] State committed [1:7581698520411739558:2311], need 1 more acks
2025-12-09T03:42:27.443626Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:532: [ptqudqgd6kvcs9idrfdt-0.3] [3:1] Got TEvStateCommitted; task: 2
2025-12-09T03:42:27.443637Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:541: [ptqudqgd6kvcs9idrfdt-0.3] [3:1] State committed [2:7581698519551053543:2364], need 0 more acks
2025-12-09T03:42:27.443639Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:543: [ptqudqgd6kvcs9idrfdt-0.3] [3:1] Got all acks, changing checkpoint status to 'Completed'
2025-12-09T03:42:27.443656Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:371: [ptqudqgd6kvcs9idrfdt-0.3] [3:1] Got TEvCompleteCheckpointRequest
2025-12-09T03:42:27.444555Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:27.444548Z :DEBUG: [local] [local] [32b54056-90cb1c67-b81f37fa-1c26c988] [] Committed response: { partitions_committed_offsets { partition_session_id: 1 committed_offset: 14 } }
2025-12-09T03:42:27.444661Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:363: SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, task: 1. PQ source. SessionId: 32b54056-90cb1c67-b81f37fa-1c26c988 Source data ready
2025-12-09T03:42:27.444687Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Poll inputs
2025-12-09T03:42:27.444689Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Poll sources
2025-12-09T03:42:27.444695Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:542: SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, task: 1. PQ source. SessionId: 32b54056-90cb1c67-b81f37fa-1c26c988 GetAsyncInputData freeSpace = 1000000
2025-12-09T03:42:27.444715Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:81: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Poll async input 0. Buffer free space: 1000000, read from async input: 0 bytes, 0 rows, finished: 0
2025-12-09T03:42:27.444730Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:363: SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, task: 1. PQ source. SessionId: 32b54056-90cb1c67-b81f37fa-1c26c988 Source data ready
2025-12-09T03:42:27.444738Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-12-09T03:42:27.444797Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Poll inputs
2025-12-09T03:42:27.444801Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Poll sources
2025-12-09T03:42:27.444804Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:542: SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, task: 1. PQ source. SessionId: 32b54056-90cb1c67-b81f37fa-1c26c988 GetAsyncInputData freeSpace = 1000000
2025-12-09T03:42:27.444808Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:81: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Poll async input 0. Buffer free space: 1000000, read from async input: 0 bytes, 0 rows, finished: 0
2025-12-09T03:42:27.444812Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. update task runner stats
2025-12-09T03:42:27.444847Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-09T03:42:27.444855Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-09T03:42:27.444860Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-09T03:42:27.444864Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-12-09T03:42:27.444872Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [1:7581698520411739567:2311], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-12-09T03:42:27.444880Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-12-09T03:42:27.444882Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-09T03:42:27.444896Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. update task runner stats
2025-12-09T03:42:27.444901Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-09T03:42:27.444902Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-09T03:42:27.444904Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-09T03:42:27.444907Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [1:7581698520411739567:2311], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-12-09T03:42:27.444909Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-12-09T03:42:27.444910Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-09T03:42:27.465481Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:393: [ptqudqgd6kvcs9idrfdt-0.3] [3:1] Status updated to 'Completed'
2025-12-09T03:42:27.465501Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:400: [ptqudqgd6kvcs9idrfdt-0.3] [3:1] Send TEvCompleteCheckpointResponse
2025-12-09T03:42:27.465544Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:564: [ptqudqgd6kvcs9idrfdt-0.3] [3:1] Got TEvCompleteCheckpointResponse
2025-12-09T03:42:27.465552Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:579: [ptqudqgd6kvcs9idrfdt-0.3] [3:1] Checkpoint completed
2025-12-09T03:42:28.275046Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [2:7581698493781249395:2092]
2025-12-09T03:42:28.275048Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 5049041a-f725b96d-2eecd124-9e57595e6, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:42:28.275080Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-09T03:42:28.275393Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-09T03:42:28.278144Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:42:28.278158Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-09T03:42:28.299657Z :FQ_PINGER TRACE: pinger.cpp:400: QueryId: ptqudqgd6kvcs9idrfdt, Owner: 5049041a-f725b96d-2eecd124-9e57595e3 Request Private::PingTask
2025-12-09T03:42:28.307524Z :FQ_PINGER TRACE: pinger.cpp:338: QueryId: ptqudqgd6kvcs9idrfdt, Owner: 5049041a-f725b96d-2eecd124-9e57595e3 Ping response success: { action: ABORT expired_at { seconds: 1765251751 nanos: 303000000 } }
2025-12-09T03:42:28.307545Z :FQ_PINGER DEBUG: pinger.cpp:342: QueryId: ptqudqgd6kvcs9idrfdt, Owner: 5049041a-f725b96d-2eecd124-9e57595e3 Query action: ABORT
2025-12-09T03:42:28.307566Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:690: QueryId: ptqudqgd6kvcs9idrfdt New query action received: ABORT
2025-12-09T03:42:28.307572Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:1827: QueryId: ptqudqgd6kvcs9idrfdt Is about to finish query with status ABORTED_BY_USER
2025-12-09T03:42:28.307575Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:1820: QueryId: ptqudqgd6kvcs9idrfdt Write finalizing status: ABORTING_BY_USER
2025-12-09T03:42:28.307587Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:528: QueryId: ptqudqgd6kvcs9idrfdt Cancel running query
2025-12-09T03:42:28.307633Z :FQ_PINGER TRACE: pinger.cpp:250: QueryId: ptqudqgd6kvcs9idrfdt, Owner: 5049041a-f725b96d-2eecd124-9e57595e3 Forward ping request: { status: ABORTING_BY_USER }
2025-12-09T03:42:28.307640Z :FQ_PINGER TRACE: pinger.cpp:393: QueryId: ptqudqgd6kvcs9idrfdt, Owner: 5049041a-f725b96d-2eecd124-9e57595e3 Forward request Private::PingTask
2025-12-09T03:42:28.307761Z :YQL_PROXY DEBUG: log.cpp:64: SessionId:  2025-12-09 03:42:28.307 DEBUG ydbd(pid=1612752, tid=0x00007F9765300640) [DQ] task_controller_impl.h:130: AbortExecution from [1:7581698520411739551:2305]:ABORTED { <main>: Error: ABORTED_BY_USER }
2025-12-09T03:42:28.307782Z :YQL_PROXY DEBUG: log.cpp:64: SessionId:  2025-12-09 03:42:28.307 DEBUG ydbd(pid=1612752, tid=0x00007F9765300640) [DQ] task_controller_impl.h:598: OnError { <main>: Error: ABORTED_BY_USER } ABORTED
2025-12-09T03:42:28.307837Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudqgd6kvcs9idrfdt 2025-12-09 03:42:28.307 DEBUG ydbd(pid=1612752, tid=0x00007F9765300640) [DQ] executer_actor.cpp:304: {ptqudqgd6kvcs9idrfdt} OnFailure, status=4, issues size=1, sender=[1:7581698520411739555:2309]
2025-12-09T03:42:28.307868Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudqgd6kvcs9idrfdt 2025-12-09 03:42:28.307 DEBUG ydbd(pid=1612752, tid=0x00007F9765300640) [DQ] executer_actor.cpp:315: {ptqudqgd6kvcs9idrfdt} Issues: <main>: Error: ABORTED_BY_USER

2025-12-09T03:42:28.307882Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudqgd6kvcs9idrfdt 2025-12-09 03:42:28.307 DEBUG ydbd(pid=1612752, tid=0x00007F9765300640) [DQ] executer_actor.cpp:284: {ptqudqgd6kvcs9idrfdt} Finish with status=4 issues=<main>: Error: ABORTED_BY_USER

2025-12-09T03:42:28.307975Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudqgd6kvcs9idrfdt 2025-12-09 03:42:28.307 DEBUG ydbd(pid=1612752, tid=0x00007F97642FE640) [DQ] executer_actor.cpp:341: {ptqudqgd6kvcs9idrfdt} OnQueryResponse status=4 issuses_size=1
2025-12-09T03:42:28.308011Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:1396: QueryId: ptqudqgd6kvcs9idrfdt TEvQueryResponse received on finish
2025-12-09T03:42:28.308027Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:1233: QueryId: ptqudqgd6kvcs9idrfdt Query response CANCELLED. Result set index: 0. Issues count: 1. Rows count: 0
2025-12-09T03:42:28.308132Z :KQP_COMPUTE ERROR: dq_compute_actor_impl.h:1205: SelfId: [1:7581698520411739558:2311], TxId: ptqudqgd6kvcs9idrfdt, task: 1. Ctx: {}. Handle abort execution event from: [1:7581698511821804665:2064], status: UNAVAILABLE, reason: { <main>: Error: Aborted by LWM }
2025-12-09T03:42:28.308166Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:657: [ptqudqgd6kvcs9idrfdt-0.3] PassAway
2025-12-09T03:42:28.308179Z :KQP_COMPUTE DEBUG: dq_compute_actor_channels.cpp:494: TxId: ptqudqgd6kvcs9idrfdt, task: 1. pass away
2025-12-09T03:42:28.308199Z :YDB_SDK INFO: actor.cpp:37: 2025-12-09T03:42:28.308195Z :INFO: [local] [local] [32b54056-90cb1c67-b81f37fa-1c26c988] Closing read session. Close timeout: 0.000000s
2025-12-09T03:42:28.308212Z :YDB_SDK INFO: actor.cpp:37: 2025-12-09T03:42:28.308210Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:pq_kikimr_streaming_v1_input:0:1:13:14
2025-12-09T03:42:28.308220Z :YDB_SDK INFO: actor.cpp:37: 2025-12-09T03:42:28.308218Z :INFO: [local] [local] [32b54056-90cb1c67-b81f37fa-1c26c988] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1917 BytesRead: 26 MessagesRead: 14 BytesReadCompressed: 26 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:42:28.308232Z :YDB_SDK NOTICE: actor.cpp:37: 2025-12-09T03:42:28.308231Z :NOTICE: [local] [local] [32b54056-90cb1c67-b81f37fa-1c26c988] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Close with zero timeout " }
2025-12-09T03:42:28.308250Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:28.308248Z :DEBUG: [local] [local] [32b54056-90cb1c67-b81f37fa-1c26c988] [] Abort session to cluster
2025-12-09T03:42:28.308412Z :YDB_SDK INFO: actor.cpp:37: 2025-12-09T03:42:28.308410Z :INFO: [local] [local] [32b54056-90cb1c67-b81f37fa-1c26c988] Closing read session. Close timeout: 0.000000s
2025-12-09T03:42:28.308424Z :YDB_SDK INFO: actor.cpp:37: 2025-12-09T03:42:28.308423Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:pq_kikimr_streaming_v1_input:0:1:13:14
2025-12-09T03:42:28.308428Z :YDB_SDK INFO: actor.cpp:37: 2025-12-09T03:42:28.308427Z :INFO: [local] [local] [32b54056-90cb1c67-b81f37fa-1c26c988] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1917 BytesRead: 26 MessagesRead: 14 BytesReadCompressed: 26 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:42:28.308436Z :YDB_SDK NOTICE: actor.cpp:37: 2025-12-09T03:42:28.308434Z :NOTICE: [local] [local] [32b54056-90cb1c67-b81f37fa-1c26c988] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-09T03:42:28.309403Z :YDB_SDK INFO: actor.cpp:37: 2025-12-09T03:42:28.309397Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] Write session: close. Timeout 0.000000s
2025-12-09T03:42:28.309414Z :YDB_SDK INFO: actor.cpp:37: 2025-12-09T03:42:28.309412Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] Write session will now close
2025-12-09T03:42:28.309433Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:28.309431Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] Write session: aborting
2025-12-09T03:42:28.309537Z :YDB_SDK INFO: actor.cpp:37: 2025-12-09T03:42:28.309534Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] Write session: gracefully shut down, all writes complete
2025-12-09T03:42:28.309546Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:28.309544Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd6kvcs9idrfdt, TaskId: 1, PQ sink. ]  SessionId [2847d55f-b7bee33c-5807f910-b751220d|b3fc2767-89d0db42-d1b68c23-950091c2_0]  PartitionId [1]  Generation [1] Write session: destroy
2025-12-09T03:42:28.316902Z :FQ_PINGER TRACE: pinger.cpp:338: QueryId: ptqudqgd6kvcs9idrfdt, Owner: 5049041a-f725b96d-2eecd124-9e57595e3 Ping response success: { action: ABORT expired_at { seconds: 1765251751 nanos: 311000000 } }
2025-12-09T03:42:28.316913Z :FQ_PINGER DEBUG: pinger.cpp:342: QueryId: ptqudqgd6kvcs9idrfdt, Owner: 5049041a-f725b96d-2eecd124-9e57595e3 Query action: ABORT
2025-12-09T03:42:28.316949Z :FQ_RUN_ACTOR TRACE: run_actor.cpp:880: QueryId: ptqudqgd6kvcs9idrfdt Forward ping response. Success: 1. Cookie: 3
2025-12-09T03:42:28.316952Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:887: QueryId: ptqudqgd6kvcs9idrfdt Finalizing status is saved
2025-12-09T03:42:28.316990Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:1507: QueryId: ptqudqgd6kvcs9idrfdt Start rate limiter resource deleter
2025-12-09T03:42:28.316998Z :STREAMS DEBUG: read_rule_deleter.cpp:214: ptqudqgd6kvcs9idrfdt: Create read rule deleter actor for `pq_kikimr_streaming_v1_input` [0]
2025-12-09T03:42:28.317026Z :STREAMS DEBUG: read_rule_deleter.cpp:106: ptqudqgd6kvcs9idrfdt: Make request for read rule deletion for topic `pq_kikimr_streaming_v1_input` [0]
2025-12-09T03:42:28.357496Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:1498: QueryId: ptqudqgd6kvcs9idrfdt Rate limiter resource deletion finished. Success: 1. Issues: 
2025-12-09T03:42:28.357511Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:1919: QueryId: ptqudqgd6kvcs9idrfdt SendPingAndPassAway, FinalQueryStatus ABORTED_BY_USER
2025-12-09T03:42:28.357541Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:536: QueryId: ptqudqgd6kvcs9idrfdt PassAway
2025-12-09T03:42:28.357661Z :FQ_PINGER TRACE: pinger.cpp:250: QueryId: ptqudqgd6kvcs9idrfdt, Owner: 5049041a-f725b96d-2eecd124-9e57595e3 Forward ping request: { result_id { value: "ptrudqgd6bi8h0vih6mq" } status: ABORTED_BY_USER issues { message: "ABORTED_BY_USER" severity: 1 } statistics: "{\"Graph=0\":{\"Actor\":{\"ActorCreateTimeUs\":{\"sum\":\"31ms\",\"count\":2,\"avg\":\"15ms\",\"max\":\"30ms\",\"min\":\"749us\"}},\"AllocateWorkersUs\":{\"sum\":\"31ms\",\"count\":1,\"avg\":\"31ms\",\"max\":\"31ms\",\"min\":\"31ms\"},\"ExecutionTimeUs\":{\"sum\":\"1.98s\",\"count\":1,\"avg\":\"1.98s\",\"max\":\"1.98s\",\"min\":\"1.98s\"},\"TaskRunner\":{\"Stage=200289\":{\"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_3ee83a57-9d99-4602-bd4d-451cf025ba67/rate_limiter" topic_consumers { database: "local" topic_path: "pq_kikimr_streaming_v1_input" consumer_name: "ptqudqgd6kvcs9idrfdt" cluster_endpoint: "localhost:6559" token_name: "cluster:default_myyds" add_bearer_to_token: true } } finished_at { seconds: 1765251748 nanos: 307000000 } }
2025-12-09T03:42:28.357687Z :FQ_PINGER TRACE: pinger.cpp:393: QueryId: ptqudqgd6kvcs9idrfdt, Owner: 5049041a-f725b96d-2eecd124-9e57595e3 Forward request Private::PingTask
2025-12-09T03:42:28.439125Z :FQ_PINGER TRACE: pinger.cpp:338: QueryId: ptqudqgd6kvcs9idrfdt, Owner: 5049041a-f725b96d-2eecd124-9e57595e3 Ping response success: { action: ABORT }
2025-12-09T03:42:28.439165Z :FQ_PINGER DEBUG: pinger.cpp:379: QueryId: ptqudqgd6kvcs9idrfdt, Owner: 5049041a-f725b96d-2eecd124-9e57595e3 Query finished
2025-12-09T03:42:28.439169Z :FQ_PINGER TRACE: pinger.cpp:187: QueryId: ptqudqgd6kvcs9idrfdt, Owner: 5049041a-f725b96d-2eecd124-9e57595e3 Stop Pinger
2025-12-09T03:42:29.273482Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-12-09T03:42:29.273574Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:665: Coordinator: Change global state to Started (by timeout)
2025-12-09T03:42:29.275538Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 5049041a-f725b96d-2eecd124-9e57595e7, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:42:29.279521Z :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:3599: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-syjwtgwtdu.auto.internal:3599
2025-12-09T03:42:29.279533Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:42:29.279549Z :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:3599: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-syjwtgwtdu.auto.internal:3599
2025-12-09T03:42:29.771085Z :INTERCONNECT_NETWORK NOTICE: interconnect_tcp_input_session.cpp:712: [1 <-> 2] connection closed by peer
2025-12-09T03:42:29.771955Z :INTERCONNECT_NETWORK NOTICE: interconnect_handshake.cpp:1262: [1 <-> 2] network-related error occured on handshake: outgoing handshake Peer# ghrun-syjwtgwtdu(127.0.1.1:28285) Couldn't connect to any resolved address
