2025-12-12T12:27:04.477349Z :GRPC_SERVER NOTICE: grpc_request_proxy.cpp:380: Grpc request proxy started, nodeid# 1, serve as static node
2025-12-12T12:27:04.477396Z :GRPC_SERVER CRIT: grpc_request_proxy.cpp:440: Failed to deliver subscription request to config dispatcher
2025-12-12T12:27:04.477400Z :GRPC_SERVER NOTICE: grpc_request_proxy.cpp:380: Grpc request proxy started, nodeid# 1, serve as static node
2025-12-12T12:27:04.477415Z :GRPC_SERVER CRIT: grpc_request_proxy.cpp:440: Failed to deliver subscription request to config dispatcher
2025-12-12T12:27:04.478396Z :FQ_QUOTA_PROXY INFO: quota_proxy.cpp:90: STARTED
2025-12-12T12:27:04.478445Z :FQ_LOG_UPDATER DEBUG: log.cpp:93: Updated YQL logs priority: 8
2025-12-12T12:27:04.478456Z :FQ_LOG_UPDATER CRIT: log.cpp:55: Failed to deliver subscription request to config dispatcher.
2025-12-12T12:27:04.478493Z :YQ_RATE_LIMITER INFO: quoter_service.cpp:124: Bootstraping with config: { Enabled: true DataPlaneEnabled: true Database { Endpoint: "localhost:13655" Database: "local" TablePrefix: "RateLimiter_829782e7-2881-47d5-a54c-8ce4157e0ddd" } Limiters { CoordinationNodePath: "rate_limiter" } }
2025-12-12T12:27:04.478537Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:214: Bootstrap
2025-12-12T12:27:04.478547Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:217: Create sdk ydb connection
2025-12-12T12:27:04.478612Z :MEMORY_PROFILER NOTICE: monitor.cpp:332: Bootstrapped
2025-12-12T12:27:04.483366Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:239: Successfully bootstrapped TStorageProxy [1:7582946974645719878:2062] with connection to localhost:13655:local
2025-12-12T12:27:04.483390Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:544: RowDispatcher: Successfully bootstrapped row dispatcher, id [1:7582946974645719879:2063], tenant /compute
2025-12-12T12:27:04.483401Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582946974645719879:2063]
2025-12-12T12:27:04.483403Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:329: Coordinator: Add new row dispatcher to map (state 1)
2025-12-12T12:27:04.483515Z :YQL_NODES_MANAGER INFO: nodes_manager.cpp:88: Bootstrap, InstanceId: 7ed409da-4c529833-8badcb81-cd2c8d94
2025-12-12T12:27:04.483517Z :YQL_NODES_MANAGER DEBUG: nodes_manager.cpp:310: TNodesManagerActor::ResolveSelfAddress
2025-12-12T12:27:04.483616Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:293: Coordinator: Successfully bootstrapped coordinator, id [1:7582946974645719903:2082], NodesManagerId [0:4705493345362661702:78], rebalancing timeout 5.000000s
2025-12-12T12:27:04.483624Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:232: TLeaderElection [1:7582946974645719904:2083] Successfully bootstrapped, local coordinator id [1:7582946974645719903:2082], tenant id compute, local mode 0, coordination node path local/compute, endpoint localhost:13655
2025-12-12T12:27:04.483781Z :FQ_QUOTA_SERVICE INFO: quota_manager.cpp:196: STARTED
2025-12-12T12:27:04.483790Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:637: RowDispatcher: TEvCoordinatorChangesSubscribe from [1:7582946974645719903:2082]
2025-12-12T12:27:04.483797Z :YQ_TEST_CONNECTION DEBUG: test_connection.cpp:142: Starting yandex query test connection. Actor id: [1:7582946974645719884:2068]
2025-12-12T12:27:04.483844Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 366b0d58-25b100c1-ed8e19d9-eb291c111, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:04.496956Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:71: Run create coordination node "local/compute" actor
2025-12-12T12:27:04.496968Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:113: Call create coordination node "local/compute"
2025-12-12T12:27:04.496970Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:411: Call create coordination node "local/compute"
2025-12-12T12:27:04.497018Z :SCHEME_BOARD_SUBSCRIBER NOTICE: subscriber.cpp:849: [main][1:7582946974645719899:2078][/compute] Set up state: owner# [1:7582946974645719858:2052], state# { Deleted: 1 Strong: 0 Version: <Invalid> DomainId: <Invalid> AbandonedSchemeShards: there are 0 elements }
2025-12-12T12:27:04.497032Z :SCHEME_BOARD_SUBSCRIBER NOTICE: subscriber.cpp:849: [main][1:7582946974645719901:2080][/compute] Set up state: owner# [1:7582946974645719859:2053], state# { Deleted: 1 Strong: 0 Version: <Invalid> DomainId: <Invalid> AbandonedSchemeShards: there are 0 elements }
2025-12-12T12:27:04.497041Z :SCHEME_BOARD_SUBSCRIBER NOTICE: subscriber.cpp:849: [main][1:7582946974645719898:2077][/Root] Set up state: owner# [1:7582946974645719858:2052], state# { Deleted: 1 Strong: 0 Version: <Invalid> DomainId: <Invalid> AbandonedSchemeShards: there are 0 elements }
2025-12-12T12:27:04.497048Z :SCHEME_BOARD_SUBSCRIBER NOTICE: subscriber.cpp:849: [main][1:7582946974645719900:2079][/Root] Set up state: owner# [1:7582946974645719859:2053], state# { Deleted: 1 Strong: 0 Version: <Invalid> DomainId: <Invalid> AbandonedSchemeShards: there are 0 elements }
2025-12-12T12:27:04.497051Z :GRPC_SERVER WARN: grpc_request_proxy.cpp:583: SchemeBoardDelete /compute Strong=0
2025-12-12T12:27:04.497053Z :GRPC_SERVER WARN: grpc_request_proxy.cpp:583: SchemeBoardDelete /Root Strong=0
2025-12-12T12:27:04.497055Z :GRPC_SERVER WARN: grpc_request_proxy.cpp:583: SchemeBoardDelete /compute Strong=0
2025-12-12T12:27:04.497056Z :GRPC_SERVER WARN: grpc_request_proxy.cpp:583: SchemeBoardDelete /Root Strong=0
2025-12-12T12:27:04.497738Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-12-12T12:27:04.527613Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:04.527623Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:04.527645Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:389: Send NodeInfo with size: 1 to DynamicNameserver
2025-12-12T12:27:04.531083Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:155: Successfully created coordination node "local/compute"
2025-12-12T12:27:04.531105Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:122: Reply for create coordination node "local/compute": { <main>: Error: Check failed: path: '/local/compute', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 19], type: EPathTypeKesus, state: EPathStateNoChanges), source_location: ydb/core/tx/schemeshard/schemeshard__operation_create_kesus.cpp:339 }
2025-12-12T12:27:04.531125Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:345: TLeaderElection [1:7582946974645719904:2083] Coordination node successfully created
2025-12-12T12:27:04.531129Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:323: TLeaderElection [1:7582946974645719904:2083] Start session
2025-12-12T12:27:04.539423Z :INTERCONNECT WARN: interconnect_handshake.cpp:501: Handshake [1:7582946974645719990:2052] [node 2] ICH09 Neither CompatibilityInfo nor VersionTag of the peer can be validated, accepting by default
2025-12-12T12:27:04.539807Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:359: TLeaderElection [1:7582946974645719904:2083] Session successfully created
2025-12-12T12:27:04.551044Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:372: TLeaderElection [1:7582946974645719904:2083] Semaphore successfully created
2025-12-12T12:27:04.551065Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:304: TLeaderElection [1:7582946974645719904:2083] Try to acquire semaphore
2025-12-12T12:27:04.551187Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:420: TLeaderElection [1:7582946974645719904:2083] Describe semaphore
2025-12-12T12:27:04.560050Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:469: TLeaderElection [1:7582946974645719904:2083] Semaphore successfully described: coordinator id [2:7582946919645746286:2082] generation 2
2025-12-12T12:27:04.560065Z :FQ_ROW_DISPATCHER INFO: leader_election.cpp:471: TLeaderElection [1:7582946974645719904:2083] Send TEvCoordinatorChanged to [1:7582946974645719879:2063], new coordinator id [2:7582946919645746286:2082], previous coordinator id [0:0:0]
2025-12-12T12:27:04.560088Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:569: RowDispatcher: Coordinator changed, old leader (empty maybe), new [2:7582946919645746286:2082] generation 2
2025-12-12T12:27:04.560106Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:440: Coordinator: New leader [2:7582946919645746286:2082], SelfId [1:7582946974645719903:2082]
2025-12-12T12:27:04.561576Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:04.584473Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:144: SelfId: [1:7582946974645720021:2145], TxId: ptqudq7uflp0v84ecdkj, task: 2. Ctx: {}. Start compute actor [1:7582946974645720021:2145], task: 2
2025-12-12T12:27:04.584520Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:114: SelfId: [1:7582946974645720021:2145], TxId: ptqudq7uflp0v84ecdkj, task: 2. Ctx: {}. Use CPU quota: 1. Rate limiter resource: { "local/RateLimiter_829782e7-2881-47d5-a54c-8ce4157e0ddd/rate_limiter", "mock_cloud/my_folder/ptqudq7uflp0v84ecdkj" }
2025-12-12T12:27:04.585547Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: 366b0d58-25b100c1-ed8e19d9-eb291c11 2025-12-12 12:27:04.585 DEBUG ydbd(pid=1194347, tid=0x00007F01EE8A6640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Build task: 2
2025-12-12T12:27:04.587301Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: 366b0d58-25b100c1-ed8e19d9-eb291c11 2025-12-12 12:27:04.587 DEBUG ydbd(pid=1194347, tid=0x00007F01EE8A6640) [DQ] tasks_runner_local.cpp:267: {TODO/2} task: 2, program size: 229, llvm: ``.
2025-12-12T12:27:04.647774Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: 366b0d58-25b100c1-ed8e19d9-eb291c11 2025-12-12 12:27:04.647 DEBUG ydbd(pid=1194347, tid=0x00007F01EE8A6640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Build task: 2 takes 62189 us
2025-12-12T12:27:04.647791Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: 366b0d58-25b100c1-ed8e19d9-eb291c11 2025-12-12 12:27:04.647 DEBUG ydbd(pid=1194347, tid=0x00007F01EE8A6640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Prepare task: 2
2025-12-12T12:27:04.647810Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: 366b0d58-25b100c1-ed8e19d9-eb291c11 2025-12-12 12:27:04.647 DEBUG ydbd(pid=1194347, tid=0x00007F01EE8A6640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Prepare task: 2, takes 11 us
2025-12-12T12:27:04.647902Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:197: [] Task: 2. Got TEvNewCheckpointCoordinator event: generation 2, actorId: [2:7582946971185354094:2205]
2025-12-12T12:27:04.647905Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:208: [] Task: 2. Assign checkpoint coordinator (generation = 2)
2025-12-12T12:27:04.649627Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1447: SelfId: [1:7582946974645720021:2145], TxId: ptqudq7uflp0v84ecdkj, task: 2. Ctx: {}. Create sink for output 0 { Sink { Type: "PqSink" Settings { type_url: "type.googleapis.com/NYql.NPq.NProto.TDqPqTopicSink" value: "\n\035program_state_recovery_output\022\017localhost:13655\032\027\n\025cluster:default_myyds\"\005local0\0018\002" } } }
2025-12-12T12:27:04.650000Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:395: [ptqudq7uflp0v84ecdkj-0] Task: 2. Handle connected node 2
2025-12-12T12:27:04.653619Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1064: SelfId: [1:7582946974645720021:2145], TxId: ptqudq7uflp0v84ecdkj, task: 2. Ctx: {}. Received channels info: Update { Id: 1 TransportVersion: DATA_TRANSPORT_UV_PICKLE_1_0 SrcTaskId: 1 DstTaskId: 2 SrcEndpoint { ActorId { RawX1: 7582946971185354097 RawX2: 4503608217307296 } } DstEndpoint { ActorId { RawX1: 7582946974645720021 RawX2: 4503603922339937 } } WatermarksMode: WATERMARKS_MODE_DISABLED SrcStageId: 203011 DstStageId: 203028 }
2025-12-12T12:27:04.653638Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1071: SelfId: [1:7582946974645720021:2145], TxId: ptqudq7uflp0v84ecdkj, task: 2. Ctx: {}. Update input channelId: 1, peer: [2:7582946971185354097:2208]
2025-12-12T12:27:04.694486Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:265: [ptqudq7uflp0v84ecdkj-0] Task: 2. [Checkpoint 1.2] TEvRestoreFromCheckpoint, StateLoadPlan = { StateType: STATE_TYPE_OWN }
2025-12-12T12:27:04.694510Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:508: [ptqudq7uflp0v84ecdkj-0] [1:2] Got TEvGetTaskState: tasks {2}
2025-12-12T12:27:04.694515Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:519: [ptqudq7uflp0v84ecdkj-0] [1:2] GetState, tasks: 2
2025-12-12T12:27:04.803417Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:654: [ptqudq7uflp0v84ecdkj-0] [1:2] ListOfStates results:
2025-12-12T12:27:04.803451Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:675: [ptqudq7uflp0v84ecdkj-0] [1:2] taskId 2 checkpoint id: 1:2, rows count: 1
2025-12-12T12:27:04.803453Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:675: [ptqudq7uflp0v84ecdkj-0] [1:2] taskId 2 checkpoint id: 1:1, rows count: 1
2025-12-12T12:27:04.803459Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:901: [ptqudq7uflp0v84ecdkj-0] [1:2] SkipStatesInFuture, skip 0 checkpoints
2025-12-12T12:27:04.805121Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:796: [ptqudq7uflp0v84ecdkj-0] [1:2] SelectState: task_id 2, seq_no 2, blob_seq_num 0
2025-12-12T12:27:04.898192Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:410: [ptqudq7uflp0v84ecdkj-0] [1:2] DeserializeState, task id 2, blob size 108
2025-12-12T12:27:04.898223Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:960: [ptqudq7uflp0v84ecdkj-0] [1:2] ApplyIncrements
2025-12-12T12:27:04.898351Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:527: [ptqudq7uflp0v84ecdkj-0] [{ Id: 2 Generation: 1 }] Send TEvGetTaskStateResult: tasks: {2}
2025-12-12T12:27:04.898386Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:336: [ptqudq7uflp0v84ecdkj-0] Task: 2. [Checkpoint 1.2] TEvGetTaskStateResult: restoring state
2025-12-12T12:27:04.898393Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:793: SelfId: [1:7582946974645720021:2145], TxId: ptqudq7uflp0v84ecdkj, task: 2. Ctx: {}. Load state
2025-12-12T12:27:04.898584Z :KQP_COMPUTE DEBUG: dq_pq_write_actor.cpp:268: SelfId: [0:0:0], TxId: ptqudq7uflp0v84ecdkj, TaskId: 2, PQ sink. Load state: { SourceId: "9197fabd-f9ddd8f4-889abc05-f456aaf4" }
2025-12-12T12:27:04.898586Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:821: SelfId: [1:7582946974645720021:2145], TxId: ptqudq7uflp0v84ecdkj, task: 2. Ctx: {}. State size: 22
2025-12-12T12:27:04.898638Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:362: [ptqudq7uflp0v84ecdkj-0] Task: 2. [Checkpoint 1.2] Checkpoint state restored
2025-12-12T12:27:04.908930Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1164: SelfId: [1:7582946974645720021:2145], TxId: ptqudq7uflp0v84ecdkj, task: 2. Ctx: {}. Got TEvRun from actor [2:7582946971185354094:2205]
2025-12-12T12:27:04.908972Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7582946974645720021:2145], TxId: ptqudq7uflp0v84ecdkj, task: 2. Ctx: {}. Poll inputs
2025-12-12T12:27:04.908975Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [1:7582946974645720021:2145], TxId: ptqudq7uflp0v84ecdkj, task: 2. Ctx: {}. Poll sources
2025-12-12T12:27:04.908977Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [1:7582946974645720021:2145], TxId: ptqudq7uflp0v84ecdkj, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-12-12T12:27:04.909038Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: 366b0d58-25b100c1-ed8e19d9-eb291c11 2025-12-12 12:27:04.909 DEBUG ydbd(pid=1194347, tid=0x00007F01EE8A6640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Run task: 2
2025-12-12T12:27:04.909119Z :KQP_COMPUTE TRACE: dq_compute_memory_quota.h:97: TxId: ptqudq7uflp0v84ecdkj, task: 2. Peak memory usage: 2031616
2025-12-12T12:27:04.909128Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7582946974645720021:2145], TxId: ptqudq7uflp0v84ecdkj, task: 2. Ctx: {}. update task runner stats
2025-12-12T12:27:04.909154Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7582946974645720021:2145], TxId: ptqudq7uflp0v84ecdkj, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-12T12:27:04.909157Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7582946974645720021:2145], TxId: ptqudq7uflp0v84ecdkj, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:27:04.909161Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [1:7582946974645720021:2145], TxId: ptqudq7uflp0v84ecdkj, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-12T12:27:04.909165Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1107: SelfId: [1:7582946974645720021:2145], TxId: ptqudq7uflp0v84ecdkj, task: 2. Ctx: {}. Ask CPU quota: 66ms
2025-12-12T12:27:04.909184Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [0:0:0], TxId: ptqudq7uflp0v84ecdkj, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-12-12T12:27:04.909286Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [1:7582946974645720021:2145], TxId: ptqudq7uflp0v84ecdkj, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-12-12T12:27:04.909288Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [1:7582946974645720021:2145], TxId: ptqudq7uflp0v84ecdkj, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-12T12:27:04.909295Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:605: TxId: ptqudq7uflp0v84ecdkj, task: 2. no poll, channelId: 1, hasPeer: 1, finished: 0, retry: 0, lastSeqNo: 0, freeSpace: 1000000
2025-12-12T12:27:04.911803Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1165: SelfId: [1:7582946974645720021:2145], TxId: ptqudq7uflp0v84ecdkj, task: 2. Ctx: {}. CPU quota delay: 2ms
2025-12-12T12:27:04.911926Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:27:04.911920Z :INFO: [local] OnFederationDiscovery fall back to single mode, database=local
2025-12-12T12:27:04.912132Z :YDB_SDK INFO: actor.cpp:37: [] [] Start federated write session to database '' (previous was <empty>) FederationState: { Status: SUCCESS SelfLocation: "" DbInfos: [ { path: "local" endpoint: "localhost:13655" status: AVAILABLE weight: 100 } ] ControlPlaneEndpoint: localhost:13655 }
2025-12-12T12:27:04.912192Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:04.912189Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uflp0v84ecdkj, TaskId: 2, PQ sink. ]  SessionId []  MessageGroupId [9197fabd-f9ddd8f4-889abc05-f456aaf4] Write session: try to update token
2025-12-12T12:27:04.912498Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:27:04.912496Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uflp0v84ecdkj, TaskId: 2, PQ sink. ]  SessionId []  MessageGroupId [9197fabd-f9ddd8f4-889abc05-f456aaf4] Start write session. Will connect to nodeId: 0
2025-12-12T12:27:04.912708Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:04.912691Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uflp0v84ecdkj, TaskId: 2, PQ sink. ]  SessionId []  MessageGroupId [9197fabd-f9ddd8f4-889abc05-f456aaf4] Write session: write to message_group: 9197fabd-f9ddd8f4-889abc05-f456aaf4
2025-12-12T12:27:04.912732Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:04.912729Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uflp0v84ecdkj, TaskId: 2, PQ sink. ]  SessionId []  MessageGroupId [9197fabd-f9ddd8f4-889abc05-f456aaf4] Write session: send init request: init_request { path: "program_state_recovery_output" producer_id: "9197fabd-f9ddd8f4-889abc05-f456aaf4" message_group_id: "9197fabd-f9ddd8f4-889abc05-f456aaf4" }
2025-12-12T12:27:04.912736Z :YDB_SDK TRACE: actor.cpp:37: 2025-12-12T12:27:04.912733Z :TRACE: [local] TRACE_EVENT InitRequest 
2025-12-12T12:27:04.912846Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:04.912844Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uflp0v84ecdkj, TaskId: 2, PQ sink. ]  SessionId []  MessageGroupId [9197fabd-f9ddd8f4-889abc05-f456aaf4] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T12:27:04.920558Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:04.920549Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uflp0v84ecdkj, TaskId: 2, PQ sink. ]  SessionId []  MessageGroupId [9197fabd-f9ddd8f4-889abc05-f456aaf4] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T12:27:04.920582Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:27:04.920579Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uflp0v84ecdkj, TaskId: 2, PQ sink. ]  SessionId []  MessageGroupId [9197fabd-f9ddd8f4-889abc05-f456aaf4] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1765542424920 BytesWritten: 0 MessagesWritten: 0 BytesWrittenCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:27:04.920601Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:27:04.920599Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uflp0v84ecdkj, TaskId: 2, PQ sink. ]  SessionId []  MessageGroupId [9197fabd-f9ddd8f4-889abc05-f456aaf4] Write session established. Init response: session_id: "9197fabd-f9ddd8f4-889abc05-f456aaf4|943fb056-3868d9e2-eda30063-62baaa6_0"
2025-12-12T12:27:04.920607Z :YDB_SDK TRACE: actor.cpp:37: 2025-12-12T12:27:04.920605Z :TRACE: [local] TRACE_EVENT InitResponse  partition_id=0 session_id=9197fabd-f9ddd8f4-889abc05-f456aaf4|943fb056-3868d9e2-eda30063-62baaa6_0
2025-12-12T12:27:04.920611Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:04.920609Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uflp0v84ecdkj, TaskId: 2, PQ sink. ]  SessionId [9197fabd-f9ddd8f4-889abc05-f456aaf4|943fb056-3868d9e2-eda30063-62baaa6_0]  MessageGroupId [9197fabd-f9ddd8f4-889abc05-f456aaf4] Write session: set DirectWriteToPartitionId 0
2025-12-12T12:27:04.920676Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:27:04.920673Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uflp0v84ecdkj, TaskId: 2, PQ sink. ]  SessionId [9197fabd-f9ddd8f4-889abc05-f456aaf4|943fb056-3868d9e2-eda30063-62baaa6_0]  PartitionId [0]  Generation [0] Get partition location async, partition 0, delay 0.000000s
2025-12-12T12:27:04.920693Z :YDB_SDK TRACE: actor.cpp:37: 2025-12-12T12:27:04.920692Z :TRACE: [local] TRACE_EVENT DescribePartitionRequest  path=local/program_state_recovery_output partition_id=0
2025-12-12T12:27:04.920741Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:04.920730Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uflp0v84ecdkj, TaskId: 2, PQ sink. ]  SessionId [9197fabd-f9ddd8f4-889abc05-f456aaf4|943fb056-3868d9e2-eda30063-62baaa6_0]  PartitionId [0]  Generation [0]  Getting partition location, partition 0
2025-12-12T12:27:04.921871Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:27:04.921864Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uflp0v84ecdkj, TaskId: 2, PQ sink. ]  SessionId [9197fabd-f9ddd8f4-889abc05-f456aaf4|943fb056-3868d9e2-eda30063-62baaa6_0]  PartitionId [0]  Generation [0] Got PartitionLocation response. Status SUCCESS, proto:
partition {
  active: true
  partition_location {
    node_id: 1
    generation: 1
  }
}

2025-12-12T12:27:04.921889Z :YDB_SDK TRACE: actor.cpp:37: 2025-12-12T12:27:04.921887Z :TRACE: [local] TRACE_EVENT DescribePartitionResponse  partition_id=0 active=1 pl_node_id=1 pl_generation=1
2025-12-12T12:27:04.921896Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:04.921894Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uflp0v84ecdkj, TaskId: 2, PQ sink. ]  SessionId [9197fabd-f9ddd8f4-889abc05-f456aaf4|943fb056-3868d9e2-eda30063-62baaa6_0]  PartitionId [0]  Generation [0] GetPreferredEndpoint: partitionId 0, partitionNodeId 1 exists in the endpoint pool.
2025-12-12T12:27:04.921904Z :YDB_SDK TRACE: actor.cpp:37: 2025-12-12T12:27:04.921902Z :TRACE: [local] TRACE_EVENT PreferredPartitionLocation  Endpoint= NodeId=1 Generation=1
2025-12-12T12:27:04.921908Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:27:04.921906Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uflp0v84ecdkj, TaskId: 2, PQ sink. ]  SessionId [9197fabd-f9ddd8f4-889abc05-f456aaf4|943fb056-3868d9e2-eda30063-62baaa6_0]  PartitionId [0]  Generation [1] Start write session. Will connect to nodeId: 1
2025-12-12T12:27:04.922246Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:04.922238Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uflp0v84ecdkj, TaskId: 2, PQ sink. ]  SessionId [9197fabd-f9ddd8f4-889abc05-f456aaf4|943fb056-3868d9e2-eda30063-62baaa6_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 1, Msg: CANCELLED, Details: , InternalError: 0
2025-12-12T12:27:04.922361Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:04.922358Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uflp0v84ecdkj, TaskId: 2, PQ sink. ]  SessionId [9197fabd-f9ddd8f4-889abc05-f456aaf4|943fb056-3868d9e2-eda30063-62baaa6_0]  PartitionId [0]  Generation [1] Write session: direct write to partition: 0, generation 1
2025-12-12T12:27:04.922391Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:04.922388Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uflp0v84ecdkj, TaskId: 2, PQ sink. ]  SessionId [9197fabd-f9ddd8f4-889abc05-f456aaf4|943fb056-3868d9e2-eda30063-62baaa6_0]  PartitionId [0]  Generation [1] Write session: send init request: init_request { path: "program_state_recovery_output" producer_id: "9197fabd-f9ddd8f4-889abc05-f456aaf4" partition_with_generation { generation: 1 } }
2025-12-12T12:27:04.922396Z :YDB_SDK TRACE: actor.cpp:37: 2025-12-12T12:27:04.922394Z :TRACE: [local] TRACE_EVENT InitRequest  pwg_partition_id=0 pwg_generation=1
2025-12-12T12:27:04.922485Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:04.922481Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uflp0v84ecdkj, TaskId: 2, PQ sink. ]  SessionId [9197fabd-f9ddd8f4-889abc05-f456aaf4|943fb056-3868d9e2-eda30063-62baaa6_0]  PartitionId [0]  Generation [1] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T12:27:04.930213Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:04.930194Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uflp0v84ecdkj, TaskId: 2, PQ sink. ]  SessionId [9197fabd-f9ddd8f4-889abc05-f456aaf4|943fb056-3868d9e2-eda30063-62baaa6_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T12:27:04.930244Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:27:04.930241Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uflp0v84ecdkj, TaskId: 2, PQ sink. ]  SessionId [9197fabd-f9ddd8f4-889abc05-f456aaf4|943fb056-3868d9e2-eda30063-62baaa6_0]  PartitionId [0]  Generation [1] Write session established. Init response: session_id: "9197fabd-f9ddd8f4-889abc05-f456aaf4|3019cf04-8d236cfa-787c5b3-132ee2b9_0"
2025-12-12T12:27:04.930250Z :YDB_SDK TRACE: actor.cpp:37: 2025-12-12T12:27:04.930247Z :TRACE: [local] TRACE_EVENT InitResponse  partition_id=0 session_id=9197fabd-f9ddd8f4-889abc05-f456aaf4|3019cf04-8d236cfa-787c5b3-132ee2b9_0
2025-12-12T12:27:04.930253Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:04.930252Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uflp0v84ecdkj, TaskId: 2, PQ sink. ]  SessionId [9197fabd-f9ddd8f4-889abc05-f456aaf4|3019cf04-8d236cfa-787c5b3-132ee2b9_0]  PartitionId [0]  Generation [1] Write session: set DirectWriteToPartitionId 0
2025-12-12T12:27:05.476387Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 366b0d58-25b100c1-ed8e19d9-eb291c112, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:05.487402Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:05.487418Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:05.493743Z :FQ_QUOTA_SERVICE DEBUG: quota_manager.cpp:230: IC Peers[1]: [2]
2025-12-12T12:27:05.552211Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:129: TxId: ptqudq7uflp0v84ecdkj, task: 2. Received input for channelId: 1, seqNo: 1, size: 28, chunks: 14, watermark: 0, checkpoint: 0, finished: 0, from: [2:7582946971185354098:2208], expected seqNo: 1
2025-12-12T12:27:05.552232Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:611: SelfId: [1:7582946974645720021:2145], TxId: ptqudq7uflp0v84ecdkj, task: 2. Ctx: {}. took input
2025-12-12T12:27:05.552274Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:356: SelfId: [1:7582946974645720023:2145], TxId: ptqudq7uflp0v84ecdkj, task: 2. No watermark 
2025-12-12T12:27:05.552280Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:965: SelfId: [1:7582946974645720021:2145], TxId: ptqudq7uflp0v84ecdkj, task: 2. Ctx: {}. Input data push finished. Cookie: 0 Watermark: (empty maybe) Ack: 1 TakeInputChannelDataRequests: 1
2025-12-12T12:27:05.552284Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:738: TxId: ptqudq7uflp0v84ecdkj, task: 2. Sending channel data ack to channelId: 1, peer: [2:7582946971185354097:2208], from: [1:7582946974645720021:2145], freeSpace: 999972, seqNo: 1, finished: 0
2025-12-12T12:27:05.552296Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7582946974645720021:2145], TxId: ptqudq7uflp0v84ecdkj, task: 2. Ctx: {}. Poll inputs
2025-12-12T12:27:05.552299Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [1:7582946974645720021:2145], TxId: ptqudq7uflp0v84ecdkj, task: 2. Ctx: {}. Poll sources
2025-12-12T12:27:05.552301Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [1:7582946974645720021:2145], TxId: ptqudq7uflp0v84ecdkj, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-12-12T12:27:05.552629Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7582946974645720021:2145], TxId: ptqudq7uflp0v84ecdkj, task: 2. Ctx: {}. update task runner stats
2025-12-12T12:27:05.552671Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7582946974645720021:2145], TxId: ptqudq7uflp0v84ecdkj, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-12T12:27:05.552681Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7582946974645720021:2145], TxId: ptqudq7uflp0v84ecdkj, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:27:05.552685Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [1:7582946974645720021:2145], TxId: ptqudq7uflp0v84ecdkj, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-12T12:27:05.552697Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [1:7582946974645720031:2145], TxId: ptqudq7uflp0v84ecdkj, TaskId: 2, PQ sink. SendData. Batch: 3. Checkpoint: 0. Finished: 0
2025-12-12T12:27:05.552701Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:221: SelfId: [1:7582946974645720031:2145], TxId: ptqudq7uflp0v84ecdkj, TaskId: 2, PQ sink. Received data for sending: {"sum" = 520u}
2025-12-12T12:27:05.552704Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:221: SelfId: [1:7582946974645720031:2145], TxId: ptqudq7uflp0v84ecdkj, TaskId: 2, PQ sink. Received data for sending: {"sum" = 570u}
2025-12-12T12:27:05.552705Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:221: SelfId: [1:7582946974645720031:2145], TxId: ptqudq7uflp0v84ecdkj, TaskId: 2, PQ sink. Received data for sending: {"sum" = 620u}
2025-12-12T12:27:05.552730Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:05.552724Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uflp0v84ecdkj, TaskId: 2, PQ sink. ]  SessionId [9197fabd-f9ddd8f4-889abc05-f456aaf4|3019cf04-8d236cfa-787c5b3-132ee2b9_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 1 to 1
2025-12-12T12:27:05.552750Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:05.552748Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uflp0v84ecdkj, TaskId: 2, PQ sink. ]  SessionId [9197fabd-f9ddd8f4-889abc05-f456aaf4|3019cf04-8d236cfa-787c5b3-132ee2b9_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T12:27:05.552756Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:05.552754Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uflp0v84ecdkj, TaskId: 2, PQ sink. ]  SessionId [9197fabd-f9ddd8f4-889abc05-f456aaf4|3019cf04-8d236cfa-787c5b3-132ee2b9_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 1
2025-12-12T12:27:05.552897Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [1:7582946974645720021:2145], TxId: ptqudq7uflp0v84ecdkj, task: 2. Ctx: {}. Sink 0: sent 54 bytes of data and 0 bytes of checkpoint barrier
2025-12-12T12:27:05.552907Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [1:7582946974645720021:2145], TxId: ptqudq7uflp0v84ecdkj, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 42, sent data from buffer: 54
2025-12-12T12:27:05.552914Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:629: TxId: ptqudq7uflp0v84ecdkj, task: 2. do poll, channelId: 1, last freeSpace: 999972, current freeSpace: 1000000, seqNo: 1
2025-12-12T12:27:05.552918Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:639: TxId: ptqudq7uflp0v84ecdkj, task: 2. Poll input channelId: 1, from: [2:7582946971185354097:2208], seqNo: 1, freeSpace: 1000000
2025-12-12T12:27:05.552921Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:738: TxId: ptqudq7uflp0v84ecdkj, task: 2. Sending channel data ack to channelId: 1, peer: [2:7582946971185354097:2208], from: [1:7582946974645720021:2145], freeSpace: 1000000, seqNo: 1, finished: 0
2025-12-12T12:27:05.553300Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:05.553274Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uflp0v84ecdkj, TaskId: 2, PQ sink. ]  SessionId [9197fabd-f9ddd8f4-889abc05-f456aaf4|3019cf04-8d236cfa-787c5b3-132ee2b9_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 2 to 2
2025-12-12T12:27:05.553317Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:05.553315Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uflp0v84ecdkj, TaskId: 2, PQ sink. ]  SessionId [9197fabd-f9ddd8f4-889abc05-f456aaf4|3019cf04-8d236cfa-787c5b3-132ee2b9_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T12:27:05.553323Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:05.553321Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uflp0v84ecdkj, TaskId: 2, PQ sink. ]  SessionId [9197fabd-f9ddd8f4-889abc05-f456aaf4|3019cf04-8d236cfa-787c5b3-132ee2b9_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 2
2025-12-12T12:27:05.553451Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:05.553448Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uflp0v84ecdkj, TaskId: 2, PQ sink. ]  SessionId [9197fabd-f9ddd8f4-889abc05-f456aaf4|3019cf04-8d236cfa-787c5b3-132ee2b9_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 3 to 3
2025-12-12T12:27:05.553457Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:05.553455Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uflp0v84ecdkj, TaskId: 2, PQ sink. ]  SessionId [9197fabd-f9ddd8f4-889abc05-f456aaf4|3019cf04-8d236cfa-787c5b3-132ee2b9_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T12:27:05.553460Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:05.553458Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uflp0v84ecdkj, TaskId: 2, PQ sink. ]  SessionId [9197fabd-f9ddd8f4-889abc05-f456aaf4|3019cf04-8d236cfa-787c5b3-132ee2b9_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 3
2025-12-12T12:27:05.557249Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:05.557239Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uflp0v84ecdkj, TaskId: 2, PQ sink. ]  SessionId [9197fabd-f9ddd8f4-889abc05-f456aaf4|3019cf04-8d236cfa-787c5b3-132ee2b9_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T12:27:05.557297Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:05.557292Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uflp0v84ecdkj, TaskId: 2, PQ sink. ]  SessionId [9197fabd-f9ddd8f4-889abc05-f456aaf4|3019cf04-8d236cfa-787c5b3-132ee2b9_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 1 written { } } write_statistics { persisting_time { nanos: 3000000 } min_queue_wait_time { } max_queue_wait_time { } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T12:27:05.557314Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:05.557302Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uflp0v84ecdkj, TaskId: 2, PQ sink. ]  SessionId [9197fabd-f9ddd8f4-889abc05-f456aaf4|3019cf04-8d236cfa-787c5b3-132ee2b9_0]  PartitionId [0]  Generation [1] OnAck: seqNo=1, txId=?
2025-12-12T12:27:05.557324Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:05.557322Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uflp0v84ecdkj, TaskId: 2, PQ sink. ]  SessionId [9197fabd-f9ddd8f4-889abc05-f456aaf4|3019cf04-8d236cfa-787c5b3-132ee2b9_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 1
2025-12-12T12:27:05.557488Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:454: SelfId: [1:7582946974645720031:2145], TxId: ptqudq7uflp0v84ecdkj, TaskId: 2, PQ sink. Ack seq no 1
2025-12-12T12:27:05.560936Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:05.560926Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uflp0v84ecdkj, TaskId: 2, PQ sink. ]  SessionId [9197fabd-f9ddd8f4-889abc05-f456aaf4|3019cf04-8d236cfa-787c5b3-132ee2b9_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T12:27:05.560996Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:05.560994Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uflp0v84ecdkj, TaskId: 2, PQ sink. ]  SessionId [9197fabd-f9ddd8f4-889abc05-f456aaf4|3019cf04-8d236cfa-787c5b3-132ee2b9_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 2 written { offset: 1 } } write_statistics { persisting_time { nanos: 1000000 } min_queue_wait_time { nanos: 3000000 } max_queue_wait_time { nanos: 3000000 } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T12:27:05.561018Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:05.561015Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uflp0v84ecdkj, TaskId: 2, PQ sink. ]  SessionId [9197fabd-f9ddd8f4-889abc05-f456aaf4|3019cf04-8d236cfa-787c5b3-132ee2b9_0]  PartitionId [0]  Generation [1] OnAck: seqNo=2, txId=?
2025-12-12T12:27:05.561027Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:05.561026Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uflp0v84ecdkj, TaskId: 2, PQ sink. ]  SessionId [9197fabd-f9ddd8f4-889abc05-f456aaf4|3019cf04-8d236cfa-787c5b3-132ee2b9_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 2
2025-12-12T12:27:05.561084Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:05.561082Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uflp0v84ecdkj, TaskId: 2, PQ sink. ]  SessionId [9197fabd-f9ddd8f4-889abc05-f456aaf4|3019cf04-8d236cfa-787c5b3-132ee2b9_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T12:27:05.561101Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:05.561100Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uflp0v84ecdkj, TaskId: 2, PQ sink. ]  SessionId [9197fabd-f9ddd8f4-889abc05-f456aaf4|3019cf04-8d236cfa-787c5b3-132ee2b9_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 3 written { offset: 2 } } write_statistics { persisting_time { nanos: 1000000 } min_queue_wait_time { nanos: 3000000 } max_queue_wait_time { nanos: 3000000 } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T12:27:05.561108Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:05.561107Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uflp0v84ecdkj, TaskId: 2, PQ sink. ]  SessionId [9197fabd-f9ddd8f4-889abc05-f456aaf4|3019cf04-8d236cfa-787c5b3-132ee2b9_0]  PartitionId [0]  Generation [1] OnAck: seqNo=3, txId=?
2025-12-12T12:27:05.561111Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:05.561110Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uflp0v84ecdkj, TaskId: 2, PQ sink. ]  SessionId [9197fabd-f9ddd8f4-889abc05-f456aaf4|3019cf04-8d236cfa-787c5b3-132ee2b9_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 3
2025-12-12T12:27:05.561218Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:454: SelfId: [1:7582946974645720031:2145], TxId: ptqudq7uflp0v84ecdkj, TaskId: 2, PQ sink. Ack seq no 2
2025-12-12T12:27:05.561227Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:454: SelfId: [1:7582946974645720031:2145], TxId: ptqudq7uflp0v84ecdkj, TaskId: 2, PQ sink. Ack seq no 3
2025-12-12T12:27:05.956595Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:129: TxId: ptqudq7uflp0v84ecdkj, task: 2. Received input for channelId: 1, seqNo: 2, size: 0, chunks: 0, watermark: 0, checkpoint: 1, finished: 0, from: [2:7582946971185354098:2208], expected seqNo: 2
2025-12-12T12:27:05.956616Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:611: SelfId: [1:7582946974645720021:2145], TxId: ptqudq7uflp0v84ecdkj, task: 2. Ctx: {}. took input
2025-12-12T12:27:05.956633Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:485: [ptqudq7uflp0v84ecdkj-0] Task: 2. [Checkpoint 2.1] Got checkpoint barrier from channel 1
2025-12-12T12:27:05.956659Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:356: SelfId: [1:7582946974645720023:2145], TxId: ptqudq7uflp0v84ecdkj, task: 2. No watermark 
2025-12-12T12:27:05.956664Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7582946974645720021:2145], TxId: ptqudq7uflp0v84ecdkj, task: 2. Ctx: {}. Poll inputs
2025-12-12T12:27:05.956666Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1494: SelfId: [1:7582946974645720021:2145], TxId: ptqudq7uflp0v84ecdkj, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-12-12T12:27:05.956668Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [1:7582946974645720021:2145], TxId: ptqudq7uflp0v84ecdkj, task: 2. Ctx: {}. DoExecuteImpl: 1
2025-12-12T12:27:05.956680Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:965: SelfId: [1:7582946974645720021:2145], TxId: ptqudq7uflp0v84ecdkj, task: 2. Ctx: {}. Input data push finished. Cookie: 1 Watermark: (empty maybe) Ack: 1 TakeInputChannelDataRequests: 1
2025-12-12T12:27:05.956685Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:738: TxId: ptqudq7uflp0v84ecdkj, task: 2. Sending channel data ack to channelId: 1, peer: [2:7582946971185354097:2208], from: [1:7582946974645720021:2145], freeSpace: 1000000, seqNo: 2, finished: 0
2025-12-12T12:27:05.956788Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:462: SelfId: [1:7582946974645720023:2145], TxId: ptqudq7uflp0v84ecdkj, task: 2. Pending 1 checkpoints to be sent
2025-12-12T12:27:05.956800Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7582946974645720021:2145], TxId: ptqudq7uflp0v84ecdkj, task: 2. Ctx: {}. Poll inputs
2025-12-12T12:27:05.956803Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1494: SelfId: [1:7582946974645720021:2145], TxId: ptqudq7uflp0v84ecdkj, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-12-12T12:27:05.956804Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [1:7582946974645720021:2145], TxId: ptqudq7uflp0v84ecdkj, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-12-12T12:27:05.956806Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7582946974645720021:2145], TxId: ptqudq7uflp0v84ecdkj, task: 2. Ctx: {}. update task runner stats
2025-12-12T12:27:05.956836Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7582946974645720021:2145], TxId: ptqudq7uflp0v84ecdkj, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 1 watermark injected: (empty maybe)
2025-12-12T12:27:05.956839Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:447: [ptqudq7uflp0v84ecdkj-0] Task: 2. [Checkpoint 2.1] Performing task checkpoint
2025-12-12T12:27:05.956840Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:816: SelfId: [1:7582946974645720021:2145], TxId: ptqudq7uflp0v84ecdkj, task: 2. Ctx: {}. Save state
2025-12-12T12:27:05.956842Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:474: [ptqudq7uflp0v84ecdkj-0] Task: 2. [Checkpoint 2.1] CA state saved
2025-12-12T12:27:05.956843Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:449: [ptqudq7uflp0v84ecdkj-0] Task: 2. [Checkpoint 2.1] Injecting checkpoint barrier to outputs
2025-12-12T12:27:05.956845Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7582946974645720021:2145], TxId: ptqudq7uflp0v84ecdkj, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:27:05.956849Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [1:7582946974645720021:2145], TxId: ptqudq7uflp0v84ecdkj, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-12T12:27:05.956855Z :KQP_COMPUTE INFO: dq_async_compute_actor.cpp:1010: SelfId: [1:7582946974645720021:2145], TxId: ptqudq7uflp0v84ecdkj, task: 2. Ctx: {}. Resume inputs
2025-12-12T12:27:05.956858Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [1:7582946974645720031:2145], TxId: ptqudq7uflp0v84ecdkj, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 1. Finished: 0
2025-12-12T12:27:05.956861Z :KQP_COMPUTE DEBUG: dq_pq_write_actor.cpp:240: SelfId: [1:7582946974645720031:2145], TxId: ptqudq7uflp0v84ecdkj, TaskId: 2, PQ sink. [Checkpoint 2.1] Send checkpoint state immediately
2025-12-12T12:27:05.956910Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:418: SelfId: [1:7582946974645720031:2145], TxId: ptqudq7uflp0v84ecdkj, TaskId: 2, PQ sink. Save checkpoint { Id: 1 Generation: 2 Type: CHECKPOINT_TYPE_SNAPSHOT } state: { SourceId: "9197fabd-f9ddd8f4-889abc05-f456aaf4" ConfirmedSeqNo: 3 EgressBytes: 42 }
2025-12-12T12:27:05.956913Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:524: [ptqudq7uflp0v84ecdkj-0] Task: 2. Sink[0] state saved
2025-12-12T12:27:05.956925Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:536: [ptqudq7uflp0v84ecdkj-0] Task: 2. [Checkpoint 2.1] Task checkpoint is done. Send to storage
2025-12-12T12:27:05.956933Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [1:7582946974645720021:2145], TxId: ptqudq7uflp0v84ecdkj, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 6 bytes of checkpoint barrier
2025-12-12T12:27:05.956935Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [1:7582946974645720021:2145], TxId: ptqudq7uflp0v84ecdkj, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-12T12:27:05.956943Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudq7uflp0v84ecdkj, task: 2. no poll, channelId: 1, has inflight messages: [2], last with freeSpace: 1000000, current freeSpace: 1000000
2025-12-12T12:27:05.956963Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7582946974645720021:2145], TxId: ptqudq7uflp0v84ecdkj, task: 2. Ctx: {}. Poll inputs
2025-12-12T12:27:05.956971Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [1:7582946974645720021:2145], TxId: ptqudq7uflp0v84ecdkj, task: 2. Ctx: {}. Poll sources
2025-12-12T12:27:05.956972Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [1:7582946974645720021:2145], TxId: ptqudq7uflp0v84ecdkj, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-12-12T12:27:05.956974Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7582946974645720021:2145], TxId: ptqudq7uflp0v84ecdkj, task: 2. Ctx: {}. update task runner stats
2025-12-12T12:27:05.956980Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7582946974645720021:2145], TxId: ptqudq7uflp0v84ecdkj, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-12T12:27:05.956981Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7582946974645720021:2145], TxId: ptqudq7uflp0v84ecdkj, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:27:05.956982Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [1:7582946974645720021:2145], TxId: ptqudq7uflp0v84ecdkj, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-12T12:27:05.956987Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [1:7582946974645720031:2145], TxId: ptqudq7uflp0v84ecdkj, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-12-12T12:27:05.956989Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [1:7582946974645720021:2145], TxId: ptqudq7uflp0v84ecdkj, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-12-12T12:27:05.956990Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [1:7582946974645720021:2145], TxId: ptqudq7uflp0v84ecdkj, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-12T12:27:05.956992Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudq7uflp0v84ecdkj, task: 2. no poll, channelId: 1, has inflight messages: [2], last with freeSpace: 1000000, current freeSpace: 1000000
2025-12-12T12:27:05.957001Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7582946974645720021:2145], TxId: ptqudq7uflp0v84ecdkj, task: 2. Ctx: {}. update task runner stats
2025-12-12T12:27:05.957006Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7582946974645720021:2145], TxId: ptqudq7uflp0v84ecdkj, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-12T12:27:05.957007Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7582946974645720021:2145], TxId: ptqudq7uflp0v84ecdkj, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:27:05.957008Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [1:7582946974645720021:2145], TxId: ptqudq7uflp0v84ecdkj, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-12T12:27:05.957010Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [1:7582946974645720031:2145], TxId: ptqudq7uflp0v84ecdkj, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-12-12T12:27:05.957011Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [1:7582946974645720021:2145], TxId: ptqudq7uflp0v84ecdkj, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-12-12T12:27:05.957011Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [1:7582946974645720021:2145], TxId: ptqudq7uflp0v84ecdkj, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-12T12:27:05.957013Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudq7uflp0v84ecdkj, task: 2. no poll, channelId: 1, has inflight messages: [2], last with freeSpace: 1000000, current freeSpace: 1000000
2025-12-12T12:27:05.957021Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:460: [ptqudq7uflp0v84ecdkj-0] [2:1] Got TEvSaveTaskState: task 2
2025-12-12T12:27:05.960872Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:484: [ptqudq7uflp0v84ecdkj-0] [2:1] TEvSaveTaskState Apply: task: 2
2025-12-12T12:27:05.960889Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:499: [ptqudq7uflp0v84ecdkj-0] [2:1] Send TEvSaveTaskStateResult: task: 2
2025-12-12T12:27:05.992388Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:759: SelfId: [1:7582946974645720021:2145], TxId: ptqudq7uflp0v84ecdkj, task: 2. Ctx: {}. Commit state
2025-12-12T12:27:06.476417Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [2:7582946919645746286:2082]
2025-12-12T12:27:06.476440Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:06.477048Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 366b0d58-25b100c1-ed8e19d9-eb291c113, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:06.482662Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:06.484676Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:06.484689Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:06.598023Z :KQP_COMPUTE ERROR: dq_compute_actor_impl.h:1205: SelfId: [1:7582946974645720021:2145], TxId: ptqudq7uflp0v84ecdkj, task: 2. Ctx: {}. Handle abort execution event from: [1:7582946974645719880:2064], status: UNAVAILABLE, reason: { <main>: Error: Aborted by LWM }
2025-12-12T12:27:06.598086Z :KQP_COMPUTE DEBUG: dq_compute_actor_channels.cpp:494: TxId: ptqudq7uflp0v84ecdkj, task: 2. pass away
2025-12-12T12:27:06.599023Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:27:06.599015Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uflp0v84ecdkj, TaskId: 2, PQ sink. ]  SessionId [9197fabd-f9ddd8f4-889abc05-f456aaf4|3019cf04-8d236cfa-787c5b3-132ee2b9_0]  PartitionId [0]  Generation [1] Write session: close. Timeout 0.000000s
2025-12-12T12:27:06.599035Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:27:06.599033Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uflp0v84ecdkj, TaskId: 2, PQ sink. ]  SessionId [9197fabd-f9ddd8f4-889abc05-f456aaf4|3019cf04-8d236cfa-787c5b3-132ee2b9_0]  PartitionId [0]  Generation [1] Write session will now close
2025-12-12T12:27:06.599051Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:06.599050Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uflp0v84ecdkj, TaskId: 2, PQ sink. ]  SessionId [9197fabd-f9ddd8f4-889abc05-f456aaf4|3019cf04-8d236cfa-787c5b3-132ee2b9_0]  PartitionId [0]  Generation [1] Write session: aborting
2025-12-12T12:27:06.599167Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:27:06.599164Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uflp0v84ecdkj, TaskId: 2, PQ sink. ]  SessionId [9197fabd-f9ddd8f4-889abc05-f456aaf4|3019cf04-8d236cfa-787c5b3-132ee2b9_0]  PartitionId [0]  Generation [1] Write session: gracefully shut down, all writes complete
2025-12-12T12:27:06.599174Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:06.599172Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uflp0v84ecdkj, TaskId: 2, PQ sink. ]  SessionId [9197fabd-f9ddd8f4-889abc05-f456aaf4|3019cf04-8d236cfa-787c5b3-132ee2b9_0]  PartitionId [0]  Generation [1] Write session: destroy
2025-12-12T12:27:07.479054Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 366b0d58-25b100c1-ed8e19d9-eb291c114, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:07.487566Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:07.487583Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:08.479235Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [2:7582946919645746286:2082]
2025-12-12T12:27:08.479275Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:08.479685Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 366b0d58-25b100c1-ed8e19d9-eb291c115, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:08.483498Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:08.491440Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:08.491459Z :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:25979: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-fhkyrtz6p4.auto.internal:25979
2025-12-12T12:27:09.476059Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:665: Coordinator: Change global state to Started (by timeout)
2025-12-12T12:27:09.480687Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 366b0d58-25b100c1-ed8e19d9-eb291c116, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:09.486445Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:09.486469Z :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:25979: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-fhkyrtz6p4.auto.internal:25979
2025-12-12T12:27:09.498481Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-12-12T12:27:09.504579Z :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:25979: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-fhkyrtz6p4.auto.internal:25979
2025-12-12T12:27:10.479595Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [2:7582946919645746286:2082]
2025-12-12T12:27:10.479620Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:10.480041Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:10.481644Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 366b0d58-25b100c1-ed8e19d9-eb291c117, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:10.491373Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:10.491394Z :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:25979: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-fhkyrtz6p4.auto.internal:25979
2025-12-12T12:27:10.637926Z :INTERCONNECT_NETWORK NOTICE: interconnect_tcp_input_session.cpp:712: [1 <-> 2] connection closed by peer
2025-12-12T12:27:10.638754Z :INTERCONNECT_NETWORK NOTICE: interconnect_handshake.cpp:1262: [1 <-> 2] network-related error occured on handshake: outgoing handshake Peer# ghrun-fhkyrtz6p4(127.0.1.1:10834) Couldn't connect to any resolved address
