2025-11-11T14:20:06.622666Z :MEMORY_PROFILER NOTICE: monitor.cpp:332: Bootstrapped
2025-11-11T14:20:06.622919Z :GRPC_SERVER NOTICE: grpc_request_proxy.cpp:369: Grpc request proxy started, nodeid# 1, serve as static node
2025-11-11T14:20:06.624626Z :GRPC_SERVER CRIT: grpc_request_proxy.cpp:429: Failed to deliver subscription request to config dispatcher
2025-11-11T14:20:06.624655Z :GRPC_SERVER NOTICE: grpc_request_proxy.cpp:369: Grpc request proxy started, nodeid# 1, serve as static node
2025-11-11T14:20:06.624679Z :GRPC_SERVER CRIT: grpc_request_proxy.cpp:429: Failed to deliver subscription request to config dispatcher
2025-11-11T14:20:06.624703Z :FQ_LOG_UPDATER DEBUG: log.cpp:93: Updated YQL logs priority: 8
2025-11-11T14:20:06.624706Z :FQ_LOG_UPDATER CRIT: log.cpp:55: Failed to deliver subscription request to config dispatcher.
2025-11-11T14:20:06.624740Z :YQ_RATE_LIMITER INFO: quoter_service.cpp:124: Bootstraping with config: { Enabled: true DataPlaneEnabled: true Database { Endpoint: "localhost:11255" Database: "local" TablePrefix: "RateLimiter_0daf70c6-4121-4158-87c6-13d85e7af04f" } Limiters { CoordinationNodePath: "rate_limiter" } }
2025-11-11T14:20:06.624878Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:188: Bootstrap
2025-11-11T14:20:06.624886Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:191: Create sdk ydb connection
2025-11-11T14:20:06.624927Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:534: RowDispatcher: Successfully bootstrapped row dispatcher, id [1:7571472462215529981:2063], tenant /compute
2025-11-11T14:20:06.641389Z :STREAMS_STORAGE_SERVICE TRACE: storage_proxy.cpp:213: Initialize
2025-11-11T14:20:06.641532Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:209: Successfully bootstrapped TStorageProxy [1:7571472462215529980:2062] with connection to localhost:11255:local
2025-11-11T14:20:06.641548Z :YQL_NODES_MANAGER INFO: nodes_manager.cpp:88: Bootstrap, InstanceId: 7a7f8644-44a35376-af251c93-ddc6c317
2025-11-11T14:20:06.641549Z :YQL_NODES_MANAGER DEBUG: nodes_manager.cpp:310: TNodesManagerActor::ResolveSelfAddress
2025-11-11T14:20:06.641572Z :YQ_TEST_CONNECTION DEBUG: test_connection.cpp:142: Starting yandex query test connection. Actor id: [1:7571472462215529986:2068]
2025-11-11T14:20:06.641609Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: e5a3975a-b7eef2a6-3c07e33-a1b7b5e01, Host: ghrun-vb3yoermsa, Tenant: /compute
2025-11-11T14:20:06.641620Z :FQ_QUOTA_PROXY INFO: quota_proxy.cpp:90: STARTED
2025-11-11T14:20:06.641679Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:267: Coordinator: Successfully bootstrapped coordinator, id [1:7571472462215530021:2082], NodesManagerId [0:4705493345362661702:78]
2025-11-11T14:20:06.641692Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:232: TLeaderElection [1:7571472462215530022:2083] Successfully bootstrapped, local coordinator id [1:7571472462215530021:2082], tenant id compute, local mode 0, coordination node path local/row_dispatcher/compute, endpoint localhost:11255
2025-11-11T14:20:06.643492Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:627: RowDispatcher: TEvCoordinatorChangesSubscribe from [1:7571472462215530021:2082]
2025-11-11T14:20:06.643728Z :SCHEME_BOARD_SUBSCRIBER NOTICE: subscriber.cpp:849: [main][1:7571472462215530015:2076][/compute] Set up state: owner# [1:7571472462215529960:2052], state# { Deleted: 1 Strong: 0 Version: <Invalid> DomainId: <Invalid> AbandonedSchemeShards: there are 0 elements }
2025-11-11T14:20:06.643885Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:71: Run create coordination node "local/row_dispatcher/compute" actor
2025-11-11T14:20:06.643894Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:113: Call create coordination node "local/row_dispatcher/compute"
2025-11-11T14:20:06.643896Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:411: Call create coordination node "local/row_dispatcher/compute"
2025-11-11T14:20:06.643978Z :SCHEME_BOARD_SUBSCRIBER NOTICE: subscriber.cpp:849: [main][1:7571472462215530014:2075][/Root] Set up state: owner# [1:7571472462215529960:2052], state# { Deleted: 1 Strong: 0 Version: <Invalid> DomainId: <Invalid> AbandonedSchemeShards: there are 0 elements }
2025-11-11T14:20:06.643995Z :GRPC_SERVER WARN: grpc_request_proxy.cpp:572: SchemeBoardDelete /compute Strong=0
2025-11-11T14:20:06.643997Z :GRPC_SERVER WARN: grpc_request_proxy.cpp:572: SchemeBoardDelete /Root Strong=0
2025-11-11T14:20:06.644024Z :SCHEME_BOARD_SUBSCRIBER NOTICE: subscriber.cpp:849: [main][1:7571472462215530017:2078][/Root] Set up state: owner# [1:7571472462215529961:2053], state# { Deleted: 1 Strong: 0 Version: <Invalid> DomainId: <Invalid> AbandonedSchemeShards: there are 0 elements }
2025-11-11T14:20:06.644056Z :SCHEME_BOARD_SUBSCRIBER NOTICE: subscriber.cpp:849: [main][1:7571472462215530018:2079][/compute] Set up state: owner# [1:7571472462215529961:2053], state# { Deleted: 1 Strong: 0 Version: <Invalid> DomainId: <Invalid> AbandonedSchemeShards: there are 0 elements }
2025-11-11T14:20:06.644085Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-11-11T14:20:06.644335Z :GRPC_SERVER WARN: grpc_request_proxy.cpp:572: SchemeBoardDelete /Root Strong=0
2025-11-11T14:20:06.644345Z :GRPC_SERVER WARN: grpc_request_proxy.cpp:572: SchemeBoardDelete /compute Strong=0
2025-11-11T14:20:06.650827Z :FQ_QUOTA_SERVICE INFO: quota_manager.cpp:196: STARTED
2025-11-11T14:20:06.672101Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:155: Successfully created coordination node "local/row_dispatcher/compute"
2025-11-11T14:20:06.672123Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:122: Reply for create coordination node "local/row_dispatcher/compute": { <main>: Error: Check failed: path: '/local/row_dispatcher/compute', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 29], type: EPathTypeKesus, state: EPathStateNoChanges), source_location: ydb/core/tx/schemeshard/schemeshard__operation_create_kesus.cpp:339 }
2025-11-11T14:20:06.672138Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:345: TLeaderElection [1:7571472462215530022:2083] Coordination node successfully created
2025-11-11T14:20:06.672140Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:323: TLeaderElection [1:7571472462215530022:2083] Start session
2025-11-11T14:20:06.672929Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-11T14:20:06.672936Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-11T14:20:06.678052Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:389: Send NodeInfo with size: 2 to DynamicNameserver
2025-11-11T14:20:06.678786Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:359: TLeaderElection [1:7571472462215530022:2083] Session successfully created
2025-11-11T14:20:06.681648Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:499: Checkpoint storage and state storage were successfully inited
2025-11-11T14:20:06.681893Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:372: TLeaderElection [1:7571472462215530022:2083] Semaphore successfully created
2025-11-11T14:20:06.681898Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:304: TLeaderElection [1:7571472462215530022:2083] Try to acquire semaphore
2025-11-11T14:20:06.682046Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:420: TLeaderElection [1:7571472462215530022:2083] Describe semaphore
2025-11-11T14:20:06.682140Z :INTERCONNECT WARN: interconnect_handshake.cpp:543: Handshake [1:7571472462215530067:2053] [node 3] ICH09 Neither CompatibilityInfo nor VersionTag of the peer can be validated, accepting by default
2025-11-11T14:20:06.683993Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:469: TLeaderElection [1:7571472462215530022:2083] Semaphore successfully described: coordinator id [2:7571472399481445439:2113] generation 5
2025-11-11T14:20:06.684003Z :FQ_ROW_DISPATCHER INFO: leader_election.cpp:471: TLeaderElection [1:7571472462215530022:2083] Send TEvCoordinatorChanged to [1:7571472462215529981:2063], new coordinator id [2:7571472399481445439:2113], previous coordinator id [0:0:0]
2025-11-11T14:20:06.684017Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:559: RowDispatcher: Coordinator changed, old leader (empty maybe), new [2:7571472399481445439:2113] generation 5
2025-11-11T14:20:06.684027Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:386: Coordinator: New leader [2:7571472399481445439:2113], SelfId [1:7571472462215530021:2082]
2025-11-11T14:20:06.684032Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:597: RowDispatcher: TEvUndelivered, from [2:7571472399481445439:2113], reason Disconnected
2025-11-11T14:20:06.697983Z :INTERCONNECT WARN: interconnect_handshake.cpp:543: Handshake [1:7571472462215530138:2054] [node 2] ICH09 Neither CompatibilityInfo nor VersionTag of the peer can be validated, accepting by default
2025-11-11T14:20:07.286444Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:134: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Start compute actor [1:7571472466510497521:2217], task: 2
2025-11-11T14:20:07.286490Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:113: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Use CPU quota: 1. Rate limiter resource: { "local/RateLimiter_0daf70c6-4121-4158-87c6-13d85e7af04f/rate_limiter", "mock_cloud/my_folder/ptqudslmk6ath0mgbk4q" }
2025-11-11T14:20:07.381592Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:197: [] Task: 2. Got TEvNewCheckpointCoordinator event: generation 2, actorId: [3:7571472466549446798:2164]
2025-11-11T14:20:07.381603Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:208: [] Task: 2. Assign checkpoint coordinator (generation = 2)
2025-11-11T14:20:07.382070Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1457: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Create sink for output 0 { Sink { Type: "PqSink" Settings { type_url: "type.googleapis.com/NYql.NPq.NProto.TDqPqTopicSink" value: "\n%test_group_by_hop_restart_node_output\022\017localhost:11255\032\025\n\023cluster:default_yds\"\005local0\0018\002" } } }
2025-11-11T14:20:07.382338Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:265: [ptqudslmk6ath0mgbk4q-0] Task: 2. [Checkpoint 1.8] TEvRestoreFromCheckpoint, StateLoadPlan = { StateType: STATE_TYPE_OWN }
2025-11-11T14:20:07.382358Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:457: [ptqudslmk6ath0mgbk4q-0] [1:8] Got TEvGetTaskState: tasks {2}
2025-11-11T14:20:07.382363Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:519: [ptqudslmk6ath0mgbk4q-0] [1:8] GetState, tasks: 2
2025-11-11T14:20:07.382402Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:395: [ptqudslmk6ath0mgbk4q-0] Task: 2. Handle connected node 3
2025-11-11T14:20:07.384135Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1074: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Received channels info: Update { Id: 1 TransportVersion: DATA_TRANSPORT_UV_PICKLE_1_0 SrcTaskId: 1 DstTaskId: 2 SrcEndpoint { ActorId { RawX1: 7571472466549446801 RawX2: 4503612512274551 } } DstEndpoint { ActorId { RawX1: 7571472466510497521 RawX2: 4503603922340009 } } SrcStageId: 211130 DstStageId: 211147 }
2025-11-11T14:20:07.384147Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1081: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Update input channelId: 1, peer: [3:7571472466549446801:2167]
2025-11-11T14:20:07.455497Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:654: [ptqudslmk6ath0mgbk4q-0] [1:8] ListOfStates results:
2025-11-11T14:20:07.455528Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:675: [ptqudslmk6ath0mgbk4q-0] [1:8] taskId 2 checkpoint id: 1:8, rows count: 1
2025-11-11T14:20:07.455531Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:675: [ptqudslmk6ath0mgbk4q-0] [1:8] taskId 2 checkpoint id: 1:7, rows count: 1
2025-11-11T14:20:07.455533Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:675: [ptqudslmk6ath0mgbk4q-0] [1:8] taskId 2 checkpoint id: 1:6, rows count: 1
2025-11-11T14:20:07.455535Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:675: [ptqudslmk6ath0mgbk4q-0] [1:8] taskId 2 checkpoint id: 1:5, rows count: 1
2025-11-11T14:20:07.455537Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:675: [ptqudslmk6ath0mgbk4q-0] [1:8] taskId 2 checkpoint id: 1:4, rows count: 1
2025-11-11T14:20:07.455539Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:675: [ptqudslmk6ath0mgbk4q-0] [1:8] taskId 2 checkpoint id: 1:3, rows count: 1
2025-11-11T14:20:07.455542Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:675: [ptqudslmk6ath0mgbk4q-0] [1:8] taskId 2 checkpoint id: 1:2, rows count: 1
2025-11-11T14:20:07.455544Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:675: [ptqudslmk6ath0mgbk4q-0] [1:8] taskId 2 checkpoint id: 1:1, rows count: 1
2025-11-11T14:20:07.455553Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:901: [ptqudslmk6ath0mgbk4q-0] [1:8] SkipStatesInFuture, skip 0 checkpoints
2025-11-11T14:20:07.455609Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:796: [ptqudslmk6ath0mgbk4q-0] [1:8] SelectState: task_id 2, seq_no 8, blob_seq_num 0
2025-11-11T14:20:07.522660Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:410: [ptqudslmk6ath0mgbk4q-0] [1:8] DeserializeState, task id 2, blob size 139
2025-11-11T14:20:07.522705Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:960: [ptqudslmk6ath0mgbk4q-0] [1:8] ApplyIncrements
2025-11-11T14:20:07.522811Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:476: [ptqudslmk6ath0mgbk4q-0] [{ Id: 8 Generation: 1 }] Send TEvGetTaskStateResult: tasks: {2}
2025-11-11T14:20:07.522875Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:336: [ptqudslmk6ath0mgbk4q-0] Task: 2. [Checkpoint 1.8] TEvGetTaskStateResult: restoring state
2025-11-11T14:20:07.522884Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:792: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Load state
2025-11-11T14:20:07.523056Z :KQP_COMPUTE DEBUG: dq_pq_write_actor.cpp:261: SelfId: [0:0:0], TxId: ptqudslmk6ath0mgbk4q, TaskId: 2, PQ sink. Load state: { SourceId: "47589779-63cb41f4-6a997322-28977d44" ConfirmedSeqNo: 2 EgressBytes: 124 }
2025-11-11T14:20:07.523068Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:820: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. State size: 49
2025-11-11T14:20:07.523123Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:362: [ptqudslmk6ath0mgbk4q-0] Task: 2. [Checkpoint 1.8] Checkpoint state restored
2025-11-11T14:20:07.523598Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1174: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Got TEvRun from actor [3:7571472466549446798:2164]
2025-11-11T14:20:07.523623Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1491: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Poll inputs
2025-11-11T14:20:07.523625Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1506: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Poll sources
2025-11-11T14:20:07.523626Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-11-11T14:20:07.523751Z :KQP_COMPUTE TRACE: dq_compute_memory_quota.h:97: TxId: ptqudslmk6ath0mgbk4q, task: 2. Peak memory usage: 2031616
2025-11-11T14:20:07.523764Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. update task runner stats
2025-11-11T14:20:07.523784Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-11T14:20:07.523786Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-11T14:20:07.523790Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:571: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-11-11T14:20:07.523793Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1105: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Ask CPU quota: 97ms
2025-11-11T14:20:07.523821Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:188: SelfId: [0:0:0], TxId: ptqudslmk6ath0mgbk4q, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-11-11T14:20:07.523924Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1023: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-11-11T14:20:07.523933Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1027: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-11-11T14:20:07.523939Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:605: TxId: ptqudslmk6ath0mgbk4q, task: 2. no poll, channelId: 1, hasPeer: 1, finished: 0, retry: 0, lastSeqNo: 0, freeSpace: 1000000
2025-11-11T14:20:07.526858Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1162: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. CPU quota delay: 3ms
2025-11-11T14:20:07.529793Z :YDB_SDK INFO: actor.cpp:37: 2025-11-11T14:20:07.529784Z :INFO: [local] OnFederationDiscovery fall back to single mode, database=local
2025-11-11T14:20:07.529982Z :YDB_SDK INFO: actor.cpp:37: [] [] Start federated write session to database '' (previous was <empty>) FederationState: { Status: SUCCESS SelfLocation: "" DbInfos: [ { path: "local" endpoint: "localhost:11255" status: AVAILABLE weight: 100 } ] ControlPlaneEndpoint: localhost:11255 }
2025-11-11T14:20:07.530062Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:20:07.530059Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmk6ath0mgbk4q, TaskId: 2, PQ sink. ]  SessionId []  MessageGroupId [47589779-63cb41f4-6a997322-28977d44] Write session: try to update token
2025-11-11T14:20:07.530351Z :YDB_SDK INFO: actor.cpp:37: 2025-11-11T14:20:07.530347Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmk6ath0mgbk4q, TaskId: 2, PQ sink. ]  SessionId []  MessageGroupId [47589779-63cb41f4-6a997322-28977d44] Start write session. Will connect to nodeId: 0
2025-11-11T14:20:07.533516Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:20:07.533493Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmk6ath0mgbk4q, TaskId: 2, PQ sink. ]  SessionId []  MessageGroupId [47589779-63cb41f4-6a997322-28977d44] Write session: write to message_group: 47589779-63cb41f4-6a997322-28977d44
2025-11-11T14:20:07.533559Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:20:07.533556Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmk6ath0mgbk4q, TaskId: 2, PQ sink. ]  SessionId []  MessageGroupId [47589779-63cb41f4-6a997322-28977d44] Write session: send init request: init_request { path: "test_group_by_hop_restart_node_output" producer_id: "47589779-63cb41f4-6a997322-28977d44" message_group_id: "47589779-63cb41f4-6a997322-28977d44" }
2025-11-11T14:20:07.533563Z :YDB_SDK TRACE: actor.cpp:37: 2025-11-11T14:20:07.533560Z :TRACE: [local] TRACE_EVENT InitRequest 
2025-11-11T14:20:07.533690Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:20:07.533687Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmk6ath0mgbk4q, TaskId: 2, PQ sink. ]  SessionId []  MessageGroupId [47589779-63cb41f4-6a997322-28977d44] Write session: OnWriteDone gRpcStatusCode: 0
2025-11-11T14:20:07.546805Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:20:07.546794Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmk6ath0mgbk4q, TaskId: 2, PQ sink. ]  SessionId []  MessageGroupId [47589779-63cb41f4-6a997322-28977d44] Write session: OnReadDone gRpcStatusCode: 0
2025-11-11T14:20:07.546833Z :YDB_SDK INFO: actor.cpp:37: 2025-11-11T14:20:07.546829Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmk6ath0mgbk4q, TaskId: 2, PQ sink. ]  SessionId []  MessageGroupId [47589779-63cb41f4-6a997322-28977d44] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1762870807546 BytesWritten: 0 MessagesWritten: 0 BytesWrittenCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:20:07.546857Z :YDB_SDK INFO: actor.cpp:37: 2025-11-11T14:20:07.546855Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmk6ath0mgbk4q, TaskId: 2, PQ sink. ]  SessionId []  MessageGroupId [47589779-63cb41f4-6a997322-28977d44] Write session established. Init response: last_seq_no: 2 session_id: "47589779-63cb41f4-6a997322-28977d44|1a6a77fa-cbf4189-d582f87b-191d1f57_0"
2025-11-11T14:20:07.546862Z :YDB_SDK TRACE: actor.cpp:37: 2025-11-11T14:20:07.546859Z :TRACE: [local] TRACE_EVENT InitResponse  partition_id=0 session_id=47589779-63cb41f4-6a997322-28977d44|1a6a77fa-cbf4189-d582f87b-191d1f57_0
2025-11-11T14:20:07.546865Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:20:07.546864Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmk6ath0mgbk4q, TaskId: 2, PQ sink. ]  SessionId [47589779-63cb41f4-6a997322-28977d44|1a6a77fa-cbf4189-d582f87b-191d1f57_0]  MessageGroupId [47589779-63cb41f4-6a997322-28977d44] Write session: set DirectWriteToPartitionId 0
2025-11-11T14:20:07.546924Z :YDB_SDK INFO: actor.cpp:37: 2025-11-11T14:20:07.546922Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmk6ath0mgbk4q, TaskId: 2, PQ sink. ]  SessionId [47589779-63cb41f4-6a997322-28977d44|1a6a77fa-cbf4189-d582f87b-191d1f57_0]  PartitionId [0]  Generation [0] Get partition location async, partition 0, delay 0.000000s
2025-11-11T14:20:07.546947Z :YDB_SDK TRACE: actor.cpp:37: 2025-11-11T14:20:07.546945Z :TRACE: [local] TRACE_EVENT DescribePartitionRequest  path=local/test_group_by_hop_restart_node_output partition_id=0
2025-11-11T14:20:07.547708Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:20:07.547698Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmk6ath0mgbk4q, TaskId: 2, PQ sink. ]  SessionId [47589779-63cb41f4-6a997322-28977d44|1a6a77fa-cbf4189-d582f87b-191d1f57_0]  PartitionId [0]  Generation [0]  Getting partition location, partition 0
2025-11-11T14:20:07.551182Z :YDB_SDK INFO: actor.cpp:37: 2025-11-11T14:20:07.551170Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmk6ath0mgbk4q, TaskId: 2, PQ sink. ]  SessionId [47589779-63cb41f4-6a997322-28977d44|1a6a77fa-cbf4189-d582f87b-191d1f57_0]  PartitionId [0]  Generation [0] Got PartitionLocation response. Status SUCCESS, proto:
partition {
  active: true
  partition_location {
    node_id: 1
    generation: 1
  }
}

2025-11-11T14:20:07.551211Z :YDB_SDK TRACE: actor.cpp:37: 2025-11-11T14:20:07.551208Z :TRACE: [local] TRACE_EVENT DescribePartitionResponse  partition_id=0 active=1 pl_node_id=1 pl_generation=1
2025-11-11T14:20:07.551220Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:20:07.551216Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmk6ath0mgbk4q, TaskId: 2, PQ sink. ]  SessionId [47589779-63cb41f4-6a997322-28977d44|1a6a77fa-cbf4189-d582f87b-191d1f57_0]  PartitionId [0]  Generation [0] GetPreferredEndpoint: partitionId 0, partitionNodeId 1 exists in the endpoint pool.
2025-11-11T14:20:07.551227Z :YDB_SDK TRACE: actor.cpp:37: 2025-11-11T14:20:07.551225Z :TRACE: [local] TRACE_EVENT PreferredPartitionLocation  Endpoint= NodeId=1 Generation=1
2025-11-11T14:20:07.551234Z :YDB_SDK INFO: actor.cpp:37: 2025-11-11T14:20:07.551230Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmk6ath0mgbk4q, TaskId: 2, PQ sink. ]  SessionId [47589779-63cb41f4-6a997322-28977d44|1a6a77fa-cbf4189-d582f87b-191d1f57_0]  PartitionId [0]  Generation [1] Start write session. Will connect to nodeId: 1
2025-11-11T14:20:07.553576Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:20:07.553565Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmk6ath0mgbk4q, TaskId: 2, PQ sink. ]  SessionId [47589779-63cb41f4-6a997322-28977d44|1a6a77fa-cbf4189-d582f87b-191d1f57_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 1, Msg: CANCELLED, Details: , InternalError: 0
2025-11-11T14:20:07.553711Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:20:07.553707Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmk6ath0mgbk4q, TaskId: 2, PQ sink. ]  SessionId [47589779-63cb41f4-6a997322-28977d44|1a6a77fa-cbf4189-d582f87b-191d1f57_0]  PartitionId [0]  Generation [1] Write session: direct write to partition: 0, generation 1
2025-11-11T14:20:07.553740Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:20:07.553738Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmk6ath0mgbk4q, TaskId: 2, PQ sink. ]  SessionId [47589779-63cb41f4-6a997322-28977d44|1a6a77fa-cbf4189-d582f87b-191d1f57_0]  PartitionId [0]  Generation [1] Write session: send init request: init_request { path: "test_group_by_hop_restart_node_output" producer_id: "47589779-63cb41f4-6a997322-28977d44" partition_with_generation { generation: 1 } }
2025-11-11T14:20:07.553746Z :YDB_SDK TRACE: actor.cpp:37: 2025-11-11T14:20:07.553744Z :TRACE: [local] TRACE_EVENT InitRequest  pwg_partition_id=0 pwg_generation=1
2025-11-11T14:20:07.553838Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:20:07.553835Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmk6ath0mgbk4q, TaskId: 2, PQ sink. ]  SessionId [47589779-63cb41f4-6a997322-28977d44|1a6a77fa-cbf4189-d582f87b-191d1f57_0]  PartitionId [0]  Generation [1] Write session: OnWriteDone gRpcStatusCode: 0
2025-11-11T14:20:07.562918Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:20:07.562904Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmk6ath0mgbk4q, TaskId: 2, PQ sink. ]  SessionId [47589779-63cb41f4-6a997322-28977d44|1a6a77fa-cbf4189-d582f87b-191d1f57_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-11-11T14:20:07.562973Z :YDB_SDK INFO: actor.cpp:37: 2025-11-11T14:20:07.562970Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmk6ath0mgbk4q, TaskId: 2, PQ sink. ]  SessionId [47589779-63cb41f4-6a997322-28977d44|1a6a77fa-cbf4189-d582f87b-191d1f57_0]  PartitionId [0]  Generation [1] Write session established. Init response: last_seq_no: 2 session_id: "47589779-63cb41f4-6a997322-28977d44|f23dfdc4-bf9b0d5-a36c8a91-224fceb9_0"
2025-11-11T14:20:07.562980Z :YDB_SDK TRACE: actor.cpp:37: 2025-11-11T14:20:07.562977Z :TRACE: [local] TRACE_EVENT InitResponse  partition_id=0 session_id=47589779-63cb41f4-6a997322-28977d44|f23dfdc4-bf9b0d5-a36c8a91-224fceb9_0
2025-11-11T14:20:07.562985Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:20:07.562982Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmk6ath0mgbk4q, TaskId: 2, PQ sink. ]  SessionId [47589779-63cb41f4-6a997322-28977d44|f23dfdc4-bf9b0d5-a36c8a91-224fceb9_0]  PartitionId [0]  Generation [1] Write session: set DirectWriteToPartitionId 0
2025-11-11T14:20:07.619954Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: e5a3975a-b7eef2a6-3c07e33-a1b7b5e02, Host: ghrun-vb3yoermsa, Tenant: /compute
2025-11-11T14:20:07.619975Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:542: Coordinator: Send TEvGetNodesRequest to NodesManager
2025-11-11T14:20:07.620053Z :YQL_NODES_MANAGER DEBUG: nodes_manager.cpp:300: TNodesManagerActor::TEvGetNodesRequest
2025-11-11T14:20:07.620074Z :FQ_ROW_DISPATCHER INFO: coordinator.cpp:573: Coordinator: Updated node info, node count: 3
2025-11-11T14:20:07.625634Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-11T14:20:07.625648Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-11T14:20:07.650720Z :FQ_QUOTA_SERVICE DEBUG: quota_manager.cpp:230: IC Peers[2]: [2, 3]
2025-11-11T14:20:08.556117Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:129: TxId: ptqudslmk6ath0mgbk4q, task: 2. Received input for channelId: 1, seqNo: 1, size: 0, chunks: 0, watermark: 0, checkpoint: 1, finished: 0, from: [3:7571472466549446802:2167], expected seqNo: 1
2025-11-11T14:20:08.556128Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:609: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. took input
2025-11-11T14:20:08.556147Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:485: [ptqudslmk6ath0mgbk4q-0] Task: 2. [Checkpoint 2.1] Got checkpoint barrier from channel 1
2025-11-11T14:20:08.556165Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:395: SelfId: [1:7571472466510497523:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. No watermark 
2025-11-11T14:20:08.556169Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1491: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Poll inputs
2025-11-11T14:20:08.556172Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1502: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-11-11T14:20:08.556174Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. DoExecuteImpl: 1
2025-11-11T14:20:08.556182Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:965: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Input data push finished. Cookie: 0 Watermark: (empty maybe) Ack: 1 TakeInputChannelDataRequests: 1
2025-11-11T14:20:08.556187Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:738: TxId: ptqudslmk6ath0mgbk4q, task: 2. Sending channel data ack to channelId: 1, peer: [3:7571472466549446801:2167], from: [1:7571472466510497521:2217], freeSpace: 1000000, seqNo: 1, finished: 0
2025-11-11T14:20:08.556288Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:510: SelfId: [1:7571472466510497523:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Pending 1 checkpoints to be sent
2025-11-11T14:20:08.556294Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1491: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Poll inputs
2025-11-11T14:20:08.556298Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1502: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-11-11T14:20:08.556300Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-11-11T14:20:08.556303Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. update task runner stats
2025-11-11T14:20:08.556329Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 1 watermark injected: (empty maybe)
2025-11-11T14:20:08.556332Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:447: [ptqudslmk6ath0mgbk4q-0] Task: 2. [Checkpoint 2.1] Performing task checkpoint
2025-11-11T14:20:08.556334Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:822: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Save state
2025-11-11T14:20:08.556336Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:474: [ptqudslmk6ath0mgbk4q-0] Task: 2. [Checkpoint 2.1] CA state saved
2025-11-11T14:20:08.556338Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:449: [ptqudslmk6ath0mgbk4q-0] Task: 2. [Checkpoint 2.1] Injecting checkpoint barrier to outputs
2025-11-11T14:20:08.556340Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-11T14:20:08.556343Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:571: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-11-11T14:20:08.556351Z :KQP_COMPUTE INFO: dq_async_compute_actor.cpp:1008: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Resume inputs
2025-11-11T14:20:08.556354Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:188: SelfId: [1:7571472466510497535:2217], TxId: ptqudslmk6ath0mgbk4q, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 1. Finished: 0
2025-11-11T14:20:08.556358Z :KQP_COMPUTE DEBUG: dq_pq_write_actor.cpp:233: SelfId: [1:7571472466510497535:2217], TxId: ptqudslmk6ath0mgbk4q, TaskId: 2, PQ sink. [Checkpoint 2.1] Send checkpoint state immediately
2025-11-11T14:20:08.556406Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:411: SelfId: [1:7571472466510497535:2217], TxId: ptqudslmk6ath0mgbk4q, TaskId: 2, PQ sink. Save checkpoint { Id: 1 Generation: 2 Type: CHECKPOINT_TYPE_SNAPSHOT } state: { SourceId: "47589779-63cb41f4-6a997322-28977d44" ConfirmedSeqNo: 2 EgressBytes: 124 }
2025-11-11T14:20:08.556410Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:524: [ptqudslmk6ath0mgbk4q-0] Task: 2. Sink[0] state saved
2025-11-11T14:20:08.556423Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:536: [ptqudslmk6ath0mgbk4q-0] Task: 2. [Checkpoint 2.1] Task checkpoint is done. Send to storage
2025-11-11T14:20:08.556429Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1023: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 6 bytes of checkpoint barrier
2025-11-11T14:20:08.556432Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1027: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-11-11T14:20:08.556441Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudslmk6ath0mgbk4q, task: 2. no poll, channelId: 1, has inflight messages: [1], last with freeSpace: 1000000, current freeSpace: 1000000
2025-11-11T14:20:08.556463Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1491: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Poll inputs
2025-11-11T14:20:08.556465Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1506: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Poll sources
2025-11-11T14:20:08.556466Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-11-11T14:20:08.556468Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. update task runner stats
2025-11-11T14:20:08.556476Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-11T14:20:08.556477Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-11T14:20:08.556479Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:571: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-11-11T14:20:08.556483Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:188: SelfId: [1:7571472466510497535:2217], TxId: ptqudslmk6ath0mgbk4q, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-11-11T14:20:08.556485Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1023: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-11-11T14:20:08.556486Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1027: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-11-11T14:20:08.556489Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudslmk6ath0mgbk4q, task: 2. no poll, channelId: 1, has inflight messages: [1], last with freeSpace: 1000000, current freeSpace: 1000000
2025-11-11T14:20:08.556505Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. update task runner stats
2025-11-11T14:20:08.556510Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-11T14:20:08.556511Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-11T14:20:08.556513Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:571: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-11-11T14:20:08.556516Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:188: SelfId: [1:7571472466510497535:2217], TxId: ptqudslmk6ath0mgbk4q, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-11-11T14:20:08.556518Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1023: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-11-11T14:20:08.556520Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1027: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-11-11T14:20:08.556522Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudslmk6ath0mgbk4q, task: 2. no poll, channelId: 1, has inflight messages: [1], last with freeSpace: 1000000, current freeSpace: 1000000
2025-11-11T14:20:08.556528Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:409: [ptqudslmk6ath0mgbk4q-0] [2:1] Got TEvSaveTaskState: task 2
2025-11-11T14:20:08.559572Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:433: [ptqudslmk6ath0mgbk4q-0] [2:1] TEvSaveTaskState Apply: task: 2
2025-11-11T14:20:08.559590Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:448: [ptqudslmk6ath0mgbk4q-0] [2:1] Send TEvSaveTaskStateResult: task: 2
2025-11-11T14:20:08.585601Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:746: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Commit state
2025-11-11T14:20:08.620356Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:617: RowDispatcher: Send ping to [2:7571472399481445439:2113]
2025-11-11T14:20:08.620387Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1161: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-11-11T14:20:08.620405Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: e5a3975a-b7eef2a6-3c07e33-a1b7b5e03, Host: ghrun-vb3yoermsa, Tenant: /compute
2025-11-11T14:20:08.621472Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:623: RowDispatcher: NActors::TEvents::TEvPong
2025-11-11T14:20:08.624417Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-11T14:20:08.624427Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-11T14:20:09.552164Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:129: TxId: ptqudslmk6ath0mgbk4q, task: 2. Received input for channelId: 1, seqNo: 2, size: 0, chunks: 0, watermark: 0, checkpoint: 1, finished: 0, from: [3:7571472466549446802:2167], expected seqNo: 2
2025-11-11T14:20:09.552177Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:609: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. took input
2025-11-11T14:20:09.552191Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:485: [ptqudslmk6ath0mgbk4q-0] Task: 2. [Checkpoint 2.2] Got checkpoint barrier from channel 1
2025-11-11T14:20:09.552208Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:395: SelfId: [1:7571472466510497523:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. No watermark 
2025-11-11T14:20:09.552213Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1491: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Poll inputs
2025-11-11T14:20:09.552214Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1502: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-11-11T14:20:09.552216Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. DoExecuteImpl: 1
2025-11-11T14:20:09.552225Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:965: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Input data push finished. Cookie: 1 Watermark: (empty maybe) Ack: 1 TakeInputChannelDataRequests: 1
2025-11-11T14:20:09.552229Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:738: TxId: ptqudslmk6ath0mgbk4q, task: 2. Sending channel data ack to channelId: 1, peer: [3:7571472466549446801:2167], from: [1:7571472466510497521:2217], freeSpace: 1000000, seqNo: 2, finished: 0
2025-11-11T14:20:09.552313Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:510: SelfId: [1:7571472466510497523:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Pending 1 checkpoints to be sent
2025-11-11T14:20:09.552319Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1491: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Poll inputs
2025-11-11T14:20:09.552321Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1502: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-11-11T14:20:09.552322Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-11-11T14:20:09.552324Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. update task runner stats
2025-11-11T14:20:09.552349Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 1 watermark injected: (empty maybe)
2025-11-11T14:20:09.552351Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:447: [ptqudslmk6ath0mgbk4q-0] Task: 2. [Checkpoint 2.2] Performing task checkpoint
2025-11-11T14:20:09.552355Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:822: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Save state
2025-11-11T14:20:09.552357Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:474: [ptqudslmk6ath0mgbk4q-0] Task: 2. [Checkpoint 2.2] CA state saved
2025-11-11T14:20:09.552359Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:449: [ptqudslmk6ath0mgbk4q-0] Task: 2. [Checkpoint 2.2] Injecting checkpoint barrier to outputs
2025-11-11T14:20:09.552361Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-11T14:20:09.552364Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:571: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-11-11T14:20:09.552371Z :KQP_COMPUTE INFO: dq_async_compute_actor.cpp:1008: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Resume inputs
2025-11-11T14:20:09.552375Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:188: SelfId: [1:7571472466510497535:2217], TxId: ptqudslmk6ath0mgbk4q, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 1. Finished: 0
2025-11-11T14:20:09.552379Z :KQP_COMPUTE DEBUG: dq_pq_write_actor.cpp:233: SelfId: [1:7571472466510497535:2217], TxId: ptqudslmk6ath0mgbk4q, TaskId: 2, PQ sink. [Checkpoint 2.2] Send checkpoint state immediately
2025-11-11T14:20:09.552404Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:411: SelfId: [1:7571472466510497535:2217], TxId: ptqudslmk6ath0mgbk4q, TaskId: 2, PQ sink. Save checkpoint { Id: 2 Generation: 2 Type: CHECKPOINT_TYPE_SNAPSHOT } state: { SourceId: "47589779-63cb41f4-6a997322-28977d44" ConfirmedSeqNo: 2 EgressBytes: 124 }
2025-11-11T14:20:09.552408Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:524: [ptqudslmk6ath0mgbk4q-0] Task: 2. Sink[0] state saved
2025-11-11T14:20:09.552420Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:536: [ptqudslmk6ath0mgbk4q-0] Task: 2. [Checkpoint 2.2] Task checkpoint is done. Send to storage
2025-11-11T14:20:09.552428Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1023: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 6 bytes of checkpoint barrier
2025-11-11T14:20:09.552430Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1027: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-11-11T14:20:09.552437Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:409: [ptqudslmk6ath0mgbk4q-0] [2:2] Got TEvSaveTaskState: task 2
2025-11-11T14:20:09.552439Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudslmk6ath0mgbk4q, task: 2. no poll, channelId: 1, has inflight messages: [2], last with freeSpace: 1000000, current freeSpace: 1000000
2025-11-11T14:20:09.552458Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1491: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Poll inputs
2025-11-11T14:20:09.552459Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1506: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Poll sources
2025-11-11T14:20:09.552461Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-11-11T14:20:09.552464Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. update task runner stats
2025-11-11T14:20:09.552472Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-11T14:20:09.552474Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-11T14:20:09.552476Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:571: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-11-11T14:20:09.552480Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:188: SelfId: [1:7571472466510497535:2217], TxId: ptqudslmk6ath0mgbk4q, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-11-11T14:20:09.552482Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1023: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-11-11T14:20:09.552483Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1027: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-11-11T14:20:09.552485Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudslmk6ath0mgbk4q, task: 2. no poll, channelId: 1, has inflight messages: [2], last with freeSpace: 1000000, current freeSpace: 1000000
2025-11-11T14:20:09.552498Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. update task runner stats
2025-11-11T14:20:09.552503Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-11T14:20:09.552504Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-11T14:20:09.552505Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:571: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-11-11T14:20:09.552508Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:188: SelfId: [1:7571472466510497535:2217], TxId: ptqudslmk6ath0mgbk4q, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-11-11T14:20:09.552509Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1023: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-11-11T14:20:09.552510Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1027: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-11-11T14:20:09.552512Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudslmk6ath0mgbk4q, task: 2. no poll, channelId: 1, has inflight messages: [2], last with freeSpace: 1000000, current freeSpace: 1000000
2025-11-11T14:20:09.555975Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:433: [ptqudslmk6ath0mgbk4q-0] [2:2] TEvSaveTaskState Apply: task: 2
2025-11-11T14:20:09.555986Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:448: [ptqudslmk6ath0mgbk4q-0] [2:2] Send TEvSaveTaskStateResult: task: 2
2025-11-11T14:20:09.583399Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:746: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Commit state
2025-11-11T14:20:09.620842Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: e5a3975a-b7eef2a6-3c07e33-a1b7b5e04, Host: ghrun-vb3yoermsa, Tenant: /compute
2025-11-11T14:20:09.624417Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-11T14:20:09.624434Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-11T14:20:10.556775Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:129: TxId: ptqudslmk6ath0mgbk4q, task: 2. Received input for channelId: 1, seqNo: 3, size: 0, chunks: 0, watermark: 0, checkpoint: 1, finished: 0, from: [3:7571472466549446802:2167], expected seqNo: 3
2025-11-11T14:20:10.556785Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:609: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. took input
2025-11-11T14:20:10.556804Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:485: [ptqudslmk6ath0mgbk4q-0] Task: 2. [Checkpoint 2.3] Got checkpoint barrier from channel 1
2025-11-11T14:20:10.556826Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:395: SelfId: [1:7571472466510497523:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. No watermark 
2025-11-11T14:20:10.556832Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1491: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Poll inputs
2025-11-11T14:20:10.556834Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1502: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-11-11T14:20:10.556836Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. DoExecuteImpl: 1
2025-11-11T14:20:10.556845Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:965: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Input data push finished. Cookie: 2 Watermark: (empty maybe) Ack: 1 TakeInputChannelDataRequests: 1
2025-11-11T14:20:10.556850Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:738: TxId: ptqudslmk6ath0mgbk4q, task: 2. Sending channel data ack to channelId: 1, peer: [3:7571472466549446801:2167], from: [1:7571472466510497521:2217], freeSpace: 1000000, seqNo: 3, finished: 0
2025-11-11T14:20:10.556943Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:510: SelfId: [1:7571472466510497523:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Pending 1 checkpoints to be sent
2025-11-11T14:20:10.556952Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1491: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Poll inputs
2025-11-11T14:20:10.556953Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1502: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-11-11T14:20:10.556954Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-11-11T14:20:10.556958Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. update task runner stats
2025-11-11T14:20:10.556986Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 1 watermark injected: (empty maybe)
2025-11-11T14:20:10.556989Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:447: [ptqudslmk6ath0mgbk4q-0] Task: 2. [Checkpoint 2.3] Performing task checkpoint
2025-11-11T14:20:10.556991Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:822: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Save state
2025-11-11T14:20:10.556993Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:474: [ptqudslmk6ath0mgbk4q-0] Task: 2. [Checkpoint 2.3] CA state saved
2025-11-11T14:20:10.556995Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:449: [ptqudslmk6ath0mgbk4q-0] Task: 2. [Checkpoint 2.3] Injecting checkpoint barrier to outputs
2025-11-11T14:20:10.556997Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-11T14:20:10.557000Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:571: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-11-11T14:20:10.557009Z :KQP_COMPUTE INFO: dq_async_compute_actor.cpp:1008: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Resume inputs
2025-11-11T14:20:10.557012Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:188: SelfId: [1:7571472466510497535:2217], TxId: ptqudslmk6ath0mgbk4q, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 1. Finished: 0
2025-11-11T14:20:10.557016Z :KQP_COMPUTE DEBUG: dq_pq_write_actor.cpp:233: SelfId: [1:7571472466510497535:2217], TxId: ptqudslmk6ath0mgbk4q, TaskId: 2, PQ sink. [Checkpoint 2.3] Send checkpoint state immediately
2025-11-11T14:20:10.557061Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:411: SelfId: [1:7571472466510497535:2217], TxId: ptqudslmk6ath0mgbk4q, TaskId: 2, PQ sink. Save checkpoint { Id: 3 Generation: 2 Type: CHECKPOINT_TYPE_SNAPSHOT } state: { SourceId: "47589779-63cb41f4-6a997322-28977d44" ConfirmedSeqNo: 2 EgressBytes: 124 }
2025-11-11T14:20:10.557064Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:524: [ptqudslmk6ath0mgbk4q-0] Task: 2. Sink[0] state saved
2025-11-11T14:20:10.557080Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:536: [ptqudslmk6ath0mgbk4q-0] Task: 2. [Checkpoint 2.3] Task checkpoint is done. Send to storage
2025-11-11T14:20:10.557088Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1023: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 6 bytes of checkpoint barrier
2025-11-11T14:20:10.557090Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1027: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-11-11T14:20:10.557097Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudslmk6ath0mgbk4q, task: 2. no poll, channelId: 1, has inflight messages: [3], last with freeSpace: 1000000, current freeSpace: 1000000
2025-11-11T14:20:10.557105Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:409: [ptqudslmk6ath0mgbk4q-0] [2:3] Got TEvSaveTaskState: task 2
2025-11-11T14:20:10.557121Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1491: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Poll inputs
2025-11-11T14:20:10.557123Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1506: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Poll sources
2025-11-11T14:20:10.557124Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-11-11T14:20:10.557126Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. update task runner stats
2025-11-11T14:20:10.557134Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-11T14:20:10.557136Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-11T14:20:10.557137Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:571: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-11-11T14:20:10.557141Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:188: SelfId: [1:7571472466510497535:2217], TxId: ptqudslmk6ath0mgbk4q, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-11-11T14:20:10.557145Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1023: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-11-11T14:20:10.557146Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1027: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-11-11T14:20:10.557149Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudslmk6ath0mgbk4q, task: 2. no poll, channelId: 1, has inflight messages: [3], last with freeSpace: 1000000, current freeSpace: 1000000
2025-11-11T14:20:10.557163Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. update task runner stats
2025-11-11T14:20:10.557169Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-11T14:20:10.557171Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-11T14:20:10.557172Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:571: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-11-11T14:20:10.557175Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:188: SelfId: [1:7571472466510497535:2217], TxId: ptqudslmk6ath0mgbk4q, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-11-11T14:20:10.557177Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1023: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-11-11T14:20:10.557178Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1027: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-11-11T14:20:10.557180Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudslmk6ath0mgbk4q, task: 2. no poll, channelId: 1, has inflight messages: [3], last with freeSpace: 1000000, current freeSpace: 1000000
2025-11-11T14:20:10.561515Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:433: [ptqudslmk6ath0mgbk4q-0] [2:3] TEvSaveTaskState Apply: task: 2
2025-11-11T14:20:10.561530Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:448: [ptqudslmk6ath0mgbk4q-0] [2:3] Send TEvSaveTaskStateResult: task: 2
2025-11-11T14:20:10.585655Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:746: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Commit state
2025-11-11T14:20:10.621239Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:617: RowDispatcher: Send ping to [2:7571472399481445439:2113]
2025-11-11T14:20:10.621266Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1161: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-11-11T14:20:10.621279Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: e5a3975a-b7eef2a6-3c07e33-a1b7b5e05, Host: ghrun-vb3yoermsa, Tenant: /compute
2025-11-11T14:20:10.621849Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:623: RowDispatcher: NActors::TEvents::TEvPong
2025-11-11T14:20:10.627504Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-11T14:20:10.627519Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-11T14:20:11.556818Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:129: TxId: ptqudslmk6ath0mgbk4q, task: 2. Received input for channelId: 1, seqNo: 4, size: 0, chunks: 0, watermark: 0, checkpoint: 1, finished: 0, from: [3:7571472466549446802:2167], expected seqNo: 4
2025-11-11T14:20:11.556836Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:609: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. took input
2025-11-11T14:20:11.556863Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:485: [ptqudslmk6ath0mgbk4q-0] Task: 2. [Checkpoint 2.4] Got checkpoint barrier from channel 1
2025-11-11T14:20:11.556882Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:395: SelfId: [1:7571472466510497523:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. No watermark 
2025-11-11T14:20:11.556887Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1491: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Poll inputs
2025-11-11T14:20:11.556892Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1502: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-11-11T14:20:11.556894Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. DoExecuteImpl: 1
2025-11-11T14:20:11.556910Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:965: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Input data push finished. Cookie: 3 Watermark: (empty maybe) Ack: 1 TakeInputChannelDataRequests: 1
2025-11-11T14:20:11.556918Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:738: TxId: ptqudslmk6ath0mgbk4q, task: 2. Sending channel data ack to channelId: 1, peer: [3:7571472466549446801:2167], from: [1:7571472466510497521:2217], freeSpace: 1000000, seqNo: 4, finished: 0
2025-11-11T14:20:11.557014Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:510: SelfId: [1:7571472466510497523:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Pending 1 checkpoints to be sent
2025-11-11T14:20:11.557024Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1491: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Poll inputs
2025-11-11T14:20:11.557025Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1502: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-11-11T14:20:11.557026Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-11-11T14:20:11.557029Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. update task runner stats
2025-11-11T14:20:11.557058Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 1 watermark injected: (empty maybe)
2025-11-11T14:20:11.557062Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:447: [ptqudslmk6ath0mgbk4q-0] Task: 2. [Checkpoint 2.4] Performing task checkpoint
2025-11-11T14:20:11.557064Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:822: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Save state
2025-11-11T14:20:11.557066Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:474: [ptqudslmk6ath0mgbk4q-0] Task: 2. [Checkpoint 2.4] CA state saved
2025-11-11T14:20:11.557068Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:449: [ptqudslmk6ath0mgbk4q-0] Task: 2. [Checkpoint 2.4] Injecting checkpoint barrier to outputs
2025-11-11T14:20:11.557071Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-11T14:20:11.557074Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:571: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-11-11T14:20:11.557081Z :KQP_COMPUTE INFO: dq_async_compute_actor.cpp:1008: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Resume inputs
2025-11-11T14:20:11.557084Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:188: SelfId: [1:7571472466510497535:2217], TxId: ptqudslmk6ath0mgbk4q, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 1. Finished: 0
2025-11-11T14:20:11.557088Z :KQP_COMPUTE DEBUG: dq_pq_write_actor.cpp:233: SelfId: [1:7571472466510497535:2217], TxId: ptqudslmk6ath0mgbk4q, TaskId: 2, PQ sink. [Checkpoint 2.4] Send checkpoint state immediately
2025-11-11T14:20:11.557128Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:411: SelfId: [1:7571472466510497535:2217], TxId: ptqudslmk6ath0mgbk4q, TaskId: 2, PQ sink. Save checkpoint { Id: 4 Generation: 2 Type: CHECKPOINT_TYPE_SNAPSHOT } state: { SourceId: "47589779-63cb41f4-6a997322-28977d44" ConfirmedSeqNo: 2 EgressBytes: 124 }
2025-11-11T14:20:11.557131Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:524: [ptqudslmk6ath0mgbk4q-0] Task: 2. Sink[0] state saved
2025-11-11T14:20:11.557143Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:536: [ptqudslmk6ath0mgbk4q-0] Task: 2. [Checkpoint 2.4] Task checkpoint is done. Send to storage
2025-11-11T14:20:11.557150Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1023: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 6 bytes of checkpoint barrier
2025-11-11T14:20:11.557152Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1027: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-11-11T14:20:11.557159Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudslmk6ath0mgbk4q, task: 2. no poll, channelId: 1, has inflight messages: [4], last with freeSpace: 1000000, current freeSpace: 1000000
2025-11-11T14:20:11.557188Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1491: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Poll inputs
2025-11-11T14:20:11.557190Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1506: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Poll sources
2025-11-11T14:20:11.557191Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-11-11T14:20:11.557193Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. update task runner stats
2025-11-11T14:20:11.557199Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-11T14:20:11.557200Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-11T14:20:11.557202Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:571: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-11-11T14:20:11.557205Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:188: SelfId: [1:7571472466510497535:2217], TxId: ptqudslmk6ath0mgbk4q, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-11-11T14:20:11.557207Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1023: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-11-11T14:20:11.557208Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1027: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-11-11T14:20:11.557210Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudslmk6ath0mgbk4q, task: 2. no poll, channelId: 1, has inflight messages: [4], last with freeSpace: 1000000, current freeSpace: 1000000
2025-11-11T14:20:11.557224Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. update task runner stats
2025-11-11T14:20:11.557228Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-11T14:20:11.557229Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-11T14:20:11.557230Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:571: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-11-11T14:20:11.557253Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:188: SelfId: [1:7571472466510497535:2217], TxId: ptqudslmk6ath0mgbk4q, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-11-11T14:20:11.557255Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1023: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-11-11T14:20:11.557256Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1027: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-11-11T14:20:11.557259Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudslmk6ath0mgbk4q, task: 2. no poll, channelId: 1, has inflight messages: [4], last with freeSpace: 1000000, current freeSpace: 1000000
2025-11-11T14:20:11.557269Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:409: [ptqudslmk6ath0mgbk4q-0] [2:4] Got TEvSaveTaskState: task 2
2025-11-11T14:20:11.561000Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:433: [ptqudslmk6ath0mgbk4q-0] [2:4] TEvSaveTaskState Apply: task: 2
2025-11-11T14:20:11.561014Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:448: [ptqudslmk6ath0mgbk4q-0] [2:4] Send TEvSaveTaskStateResult: task: 2
2025-11-11T14:20:11.590016Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:746: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Commit state
2025-11-11T14:20:11.621697Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: e5a3975a-b7eef2a6-3c07e33-a1b7b5e06, Host: ghrun-vb3yoermsa, Tenant: /compute
2025-11-11T14:20:11.627395Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-11T14:20:11.627410Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-11T14:20:11.644206Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-11-11T14:20:11.656294Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:389: Send NodeInfo with size: 2 to DynamicNameserver
2025-11-11T14:20:12.418314Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:451: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Got TEvStateRequest from actor [3:7571472466549446799:2165] PingCookie: 2
2025-11-11T14:20:12.418341Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. update task runner stats
2025-11-11T14:20:12.539657Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:129: TxId: ptqudslmk6ath0mgbk4q, task: 2. Received input for channelId: 1, seqNo: 5, size: 153, chunks: 4, watermark: 0, checkpoint: 0, finished: 0, from: [3:7571472466549446802:2167], expected seqNo: 5
2025-11-11T14:20:12.539673Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:609: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. took input
2025-11-11T14:20:12.539700Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:395: SelfId: [1:7571472466510497523:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. No watermark 
2025-11-11T14:20:12.539706Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:965: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Input data push finished. Cookie: 4 Watermark: (empty maybe) Ack: 1 TakeInputChannelDataRequests: 1
2025-11-11T14:20:12.539711Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:738: TxId: ptqudslmk6ath0mgbk4q, task: 2. Sending channel data ack to channelId: 1, peer: [3:7571472466549446801:2167], from: [1:7571472466510497521:2217], freeSpace: 999847, seqNo: 5, finished: 0
2025-11-11T14:20:12.539727Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1491: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Poll inputs
2025-11-11T14:20:12.539747Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1506: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Poll sources
2025-11-11T14:20:12.539754Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-11-11T14:20:12.545180Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. update task runner stats
2025-11-11T14:20:12.545229Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-11T14:20:12.545234Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-11T14:20:12.545239Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:571: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-11-11T14:20:12.545254Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:188: SelfId: [1:7571472466510497535:2217], TxId: ptqudslmk6ath0mgbk4q, TaskId: 2, PQ sink. SendData. Batch: 2. Checkpoint: 0. Finished: 0
2025-11-11T14:20:12.545259Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:214: SelfId: [1:7571472466510497535:2217], TxId: ptqudslmk6ath0mgbk4q, TaskId: 2, PQ sink. Received data for sending: {"count":2,"project":"project1","time":"2025-04-23T09:00:20Z"}
2025-11-11T14:20:12.545262Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:214: SelfId: [1:7571472466510497535:2217], TxId: ptqudslmk6ath0mgbk4q, TaskId: 2, PQ sink. Received data for sending: {"count":2,"project":"project2","time":"2025-04-23T09:00:20Z"}
2025-11-11T14:20:12.545395Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:20:12.545389Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmk6ath0mgbk4q, TaskId: 2, PQ sink. ]  SessionId [47589779-63cb41f4-6a997322-28977d44|f23dfdc4-bf9b0d5-a36c8a91-224fceb9_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 3 to 3
2025-11-11T14:20:12.545701Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:20:12.545697Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmk6ath0mgbk4q, TaskId: 2, PQ sink. ]  SessionId [47589779-63cb41f4-6a997322-28977d44|f23dfdc4-bf9b0d5-a36c8a91-224fceb9_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-11-11T14:20:12.545715Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:20:12.545713Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmk6ath0mgbk4q, TaskId: 2, PQ sink. ]  SessionId [47589779-63cb41f4-6a997322-28977d44|f23dfdc4-bf9b0d5-a36c8a91-224fceb9_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 3
2025-11-11T14:20:12.545868Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1023: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Sink 0: sent 132 bytes of data and 0 bytes of checkpoint barrier
2025-11-11T14:20:12.545875Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1027: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 124, sent data from buffer: 132
2025-11-11T14:20:12.545884Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:629: TxId: ptqudslmk6ath0mgbk4q, task: 2. do poll, channelId: 1, last freeSpace: 999847, current freeSpace: 1000000, seqNo: 5
2025-11-11T14:20:12.545889Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:639: TxId: ptqudslmk6ath0mgbk4q, task: 2. Poll input channelId: 1, from: [3:7571472466549446801:2167], seqNo: 5, freeSpace: 1000000
2025-11-11T14:20:12.545894Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:738: TxId: ptqudslmk6ath0mgbk4q, task: 2. Sending channel data ack to channelId: 1, peer: [3:7571472466549446801:2167], from: [1:7571472466510497521:2217], freeSpace: 1000000, seqNo: 5, finished: 0
2025-11-11T14:20:12.545946Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:20:12.545923Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmk6ath0mgbk4q, TaskId: 2, PQ sink. ]  SessionId [47589779-63cb41f4-6a997322-28977d44|f23dfdc4-bf9b0d5-a36c8a91-224fceb9_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 4 to 4
2025-11-11T14:20:12.545982Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:20:12.545979Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmk6ath0mgbk4q, TaskId: 2, PQ sink. ]  SessionId [47589779-63cb41f4-6a997322-28977d44|f23dfdc4-bf9b0d5-a36c8a91-224fceb9_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-11-11T14:20:12.545987Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:20:12.545985Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmk6ath0mgbk4q, TaskId: 2, PQ sink. ]  SessionId [47589779-63cb41f4-6a997322-28977d44|f23dfdc4-bf9b0d5-a36c8a91-224fceb9_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 4
2025-11-11T14:20:12.552855Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:20:12.552841Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmk6ath0mgbk4q, TaskId: 2, PQ sink. ]  SessionId [47589779-63cb41f4-6a997322-28977d44|f23dfdc4-bf9b0d5-a36c8a91-224fceb9_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-11-11T14:20:12.552927Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:20:12.552925Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmk6ath0mgbk4q, TaskId: 2, PQ sink. ]  SessionId [47589779-63cb41f4-6a997322-28977d44|f23dfdc4-bf9b0d5-a36c8a91-224fceb9_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 { } max_queue_wait_time { } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-11-11T14:20:12.552939Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:20:12.552937Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmk6ath0mgbk4q, TaskId: 2, PQ sink. ]  SessionId [47589779-63cb41f4-6a997322-28977d44|f23dfdc4-bf9b0d5-a36c8a91-224fceb9_0]  PartitionId [0]  Generation [1] OnAck: seqNo=3, txId=?
2025-11-11T14:20:12.552944Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:20:12.552943Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmk6ath0mgbk4q, TaskId: 2, PQ sink. ]  SessionId [47589779-63cb41f4-6a997322-28977d44|f23dfdc4-bf9b0d5-a36c8a91-224fceb9_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 3
2025-11-11T14:20:12.553010Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:20:12.553008Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmk6ath0mgbk4q, TaskId: 2, PQ sink. ]  SessionId [47589779-63cb41f4-6a997322-28977d44|f23dfdc4-bf9b0d5-a36c8a91-224fceb9_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-11-11T14:20:12.553036Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:20:12.553033Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmk6ath0mgbk4q, TaskId: 2, PQ sink. ]  SessionId [47589779-63cb41f4-6a997322-28977d44|f23dfdc4-bf9b0d5-a36c8a91-224fceb9_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 4 written { offset: 3 } } write_statistics { persisting_time { } min_queue_wait_time { nanos: 1000000 } max_queue_wait_time { nanos: 1000000 } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-11-11T14:20:12.553048Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:20:12.553045Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmk6ath0mgbk4q, TaskId: 2, PQ sink. ]  SessionId [47589779-63cb41f4-6a997322-28977d44|f23dfdc4-bf9b0d5-a36c8a91-224fceb9_0]  PartitionId [0]  Generation [1] OnAck: seqNo=4, txId=?
2025-11-11T14:20:12.553051Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:20:12.553050Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmk6ath0mgbk4q, TaskId: 2, PQ sink. ]  SessionId [47589779-63cb41f4-6a997322-28977d44|f23dfdc4-bf9b0d5-a36c8a91-224fceb9_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 4
2025-11-11T14:20:12.553188Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:447: SelfId: [1:7571472466510497535:2217], TxId: ptqudslmk6ath0mgbk4q, TaskId: 2, PQ sink. Ack seq no 3
2025-11-11T14:20:12.553200Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:447: SelfId: [1:7571472466510497535:2217], TxId: ptqudslmk6ath0mgbk4q, TaskId: 2, PQ sink. Ack seq no 4
2025-11-11T14:20:12.557907Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:129: TxId: ptqudslmk6ath0mgbk4q, task: 2. Received input for channelId: 1, seqNo: 6, size: 0, chunks: 0, watermark: 0, checkpoint: 1, finished: 0, from: [3:7571472466549446802:2167], expected seqNo: 6
2025-11-11T14:20:12.557925Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:609: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. took input
2025-11-11T14:20:12.557940Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:485: [ptqudslmk6ath0mgbk4q-0] Task: 2. [Checkpoint 2.5] Got checkpoint barrier from channel 1
2025-11-11T14:20:12.557970Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:395: SelfId: [1:7571472466510497523:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. No watermark 
2025-11-11T14:20:12.557980Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1491: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Poll inputs
2025-11-11T14:20:12.557982Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1502: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-11-11T14:20:12.557983Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. DoExecuteImpl: 1
2025-11-11T14:20:12.557992Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:965: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Input data push finished. Cookie: 5 Watermark: (empty maybe) Ack: 1 TakeInputChannelDataRequests: 1
2025-11-11T14:20:12.557997Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:738: TxId: ptqudslmk6ath0mgbk4q, task: 2. Sending channel data ack to channelId: 1, peer: [3:7571472466549446801:2167], from: [1:7571472466510497521:2217], freeSpace: 1000000, seqNo: 6, finished: 0
2025-11-11T14:20:12.558101Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:510: SelfId: [1:7571472466510497523:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Pending 1 checkpoints to be sent
2025-11-11T14:20:12.558112Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1491: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Poll inputs
2025-11-11T14:20:12.558113Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1502: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-11-11T14:20:12.558115Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-11-11T14:20:12.558118Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. update task runner stats
2025-11-11T14:20:12.558147Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 1 watermark injected: (empty maybe)
2025-11-11T14:20:12.558154Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:447: [ptqudslmk6ath0mgbk4q-0] Task: 2. [Checkpoint 2.5] Performing task checkpoint
2025-11-11T14:20:12.558156Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:822: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Save state
2025-11-11T14:20:12.558158Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:474: [ptqudslmk6ath0mgbk4q-0] Task: 2. [Checkpoint 2.5] CA state saved
2025-11-11T14:20:12.558160Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:449: [ptqudslmk6ath0mgbk4q-0] Task: 2. [Checkpoint 2.5] Injecting checkpoint barrier to outputs
2025-11-11T14:20:12.558162Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-11T14:20:12.558166Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:571: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-11-11T14:20:12.558174Z :KQP_COMPUTE INFO: dq_async_compute_actor.cpp:1008: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Resume inputs
2025-11-11T14:20:12.558177Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:188: SelfId: [1:7571472466510497535:2217], TxId: ptqudslmk6ath0mgbk4q, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 1. Finished: 0
2025-11-11T14:20:12.558180Z :KQP_COMPUTE DEBUG: dq_pq_write_actor.cpp:233: SelfId: [1:7571472466510497535:2217], TxId: ptqudslmk6ath0mgbk4q, TaskId: 2, PQ sink. [Checkpoint 2.5] Send checkpoint state immediately
2025-11-11T14:20:12.558210Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:411: SelfId: [1:7571472466510497535:2217], TxId: ptqudslmk6ath0mgbk4q, TaskId: 2, PQ sink. Save checkpoint { Id: 5 Generation: 2 Type: CHECKPOINT_TYPE_SNAPSHOT } state: { SourceId: "47589779-63cb41f4-6a997322-28977d44" ConfirmedSeqNo: 4 EgressBytes: 248 }
2025-11-11T14:20:12.558215Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:524: [ptqudslmk6ath0mgbk4q-0] Task: 2. Sink[0] state saved
2025-11-11T14:20:12.558240Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:536: [ptqudslmk6ath0mgbk4q-0] Task: 2. [Checkpoint 2.5] Task checkpoint is done. Send to storage
2025-11-11T14:20:12.558251Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1023: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 6 bytes of checkpoint barrier
2025-11-11T14:20:12.558253Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1027: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-11-11T14:20:12.558260Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudslmk6ath0mgbk4q, task: 2. no poll, channelId: 1, has inflight messages: [6], last with freeSpace: 1000000, current freeSpace: 1000000
2025-11-11T14:20:12.558278Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:409: [ptqudslmk6ath0mgbk4q-0] [2:5] Got TEvSaveTaskState: task 2
2025-11-11T14:20:12.558281Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1491: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Poll inputs
2025-11-11T14:20:12.558283Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1506: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Poll sources
2025-11-11T14:20:12.558284Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-11-11T14:20:12.558286Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. update task runner stats
2025-11-11T14:20:12.558292Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-11T14:20:12.558293Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-11T14:20:12.558295Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:571: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-11-11T14:20:12.558299Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:188: SelfId: [1:7571472466510497535:2217], TxId: ptqudslmk6ath0mgbk4q, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-11-11T14:20:12.558301Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1023: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-11-11T14:20:12.558302Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1027: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-11-11T14:20:12.558304Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudslmk6ath0mgbk4q, task: 2. no poll, channelId: 1, has inflight messages: [6], last with freeSpace: 1000000, current freeSpace: 1000000
2025-11-11T14:20:12.558315Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. update task runner stats
2025-11-11T14:20:12.558319Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-11T14:20:12.558321Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-11T14:20:12.558322Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:571: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-11-11T14:20:12.558324Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:188: SelfId: [1:7571472466510497535:2217], TxId: ptqudslmk6ath0mgbk4q, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-11-11T14:20:12.558325Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1023: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-11-11T14:20:12.558326Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1027: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-11-11T14:20:12.558328Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudslmk6ath0mgbk4q, task: 2. no poll, channelId: 1, has inflight messages: [6], last with freeSpace: 1000000, current freeSpace: 1000000
2025-11-11T14:20:12.561803Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:433: [ptqudslmk6ath0mgbk4q-0] [2:5] TEvSaveTaskState Apply: task: 2
2025-11-11T14:20:12.561818Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:448: [ptqudslmk6ath0mgbk4q-0] [2:5] Send TEvSaveTaskStateResult: task: 2
2025-11-11T14:20:12.589550Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:746: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Commit state
2025-11-11T14:20:12.622124Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:617: RowDispatcher: Send ping to [2:7571472399481445439:2113]
2025-11-11T14:20:12.622149Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: e5a3975a-b7eef2a6-3c07e33-a1b7b5e07, Host: ghrun-vb3yoermsa, Tenant: /compute
2025-11-11T14:20:12.622154Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1161: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-11-11T14:20:12.622539Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:623: RowDispatcher: NActors::TEvents::TEvPong
2025-11-11T14:20:12.628664Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-11T14:20:12.628678Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-11T14:20:13.307046Z :KQP_COMPUTE ERROR: dq_compute_actor_impl.h:1215: SelfId: [1:7571472466510497521:2217], TxId: ptqudslmk6ath0mgbk4q, task: 2. Ctx: {}. Handle abort execution event from: [1:7571472462215529982:2064], status: UNAVAILABLE, reason: { <main>: Error: Aborted by LWM }
2025-11-11T14:20:13.307096Z :KQP_COMPUTE DEBUG: dq_compute_actor_channels.cpp:494: TxId: ptqudslmk6ath0mgbk4q, task: 2. pass away
2025-11-11T14:20:13.308434Z :YDB_SDK INFO: actor.cpp:37: 2025-11-11T14:20:13.308426Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmk6ath0mgbk4q, TaskId: 2, PQ sink. ]  SessionId [47589779-63cb41f4-6a997322-28977d44|f23dfdc4-bf9b0d5-a36c8a91-224fceb9_0]  PartitionId [0]  Generation [1] Write session: close. Timeout 0.000000s
2025-11-11T14:20:13.308447Z :YDB_SDK INFO: actor.cpp:37: 2025-11-11T14:20:13.308445Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmk6ath0mgbk4q, TaskId: 2, PQ sink. ]  SessionId [47589779-63cb41f4-6a997322-28977d44|f23dfdc4-bf9b0d5-a36c8a91-224fceb9_0]  PartitionId [0]  Generation [1] Write session will now close
2025-11-11T14:20:13.308466Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:20:13.308465Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmk6ath0mgbk4q, TaskId: 2, PQ sink. ]  SessionId [47589779-63cb41f4-6a997322-28977d44|f23dfdc4-bf9b0d5-a36c8a91-224fceb9_0]  PartitionId [0]  Generation [1] Write session: aborting
2025-11-11T14:20:13.308759Z :YDB_SDK INFO: actor.cpp:37: 2025-11-11T14:20:13.308747Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmk6ath0mgbk4q, TaskId: 2, PQ sink. ]  SessionId [47589779-63cb41f4-6a997322-28977d44|f23dfdc4-bf9b0d5-a36c8a91-224fceb9_0]  PartitionId [0]  Generation [1] Write session: gracefully shut down, all writes complete
2025-11-11T14:20:13.308825Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:20:13.308819Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmk6ath0mgbk4q, TaskId: 2, PQ sink. ]  SessionId [47589779-63cb41f4-6a997322-28977d44|f23dfdc4-bf9b0d5-a36c8a91-224fceb9_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 1, Msg: CANCELLED, Details: , InternalError: 0
2025-11-11T14:20:13.308839Z :YDB_SDK TRACE: actor.cpp:37: 2025-11-11T14:20:13.308836Z :TRACE: [local] TRACE_EVENT Error  status=CLIENT_CANCELLED
2025-11-11T14:20:13.308844Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:20:13.308842Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmk6ath0mgbk4q, TaskId: 2, PQ sink. ]  SessionId [47589779-63cb41f4-6a997322-28977d44|f23dfdc4-bf9b0d5-a36c8a91-224fceb9_0]  PartitionId [0]  Generation [1] Write session is aborting and will not restart
2025-11-11T14:20:13.308898Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:20:13.308895Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmk6ath0mgbk4q, TaskId: 2, PQ sink. ]  SessionId [47589779-63cb41f4-6a997322-28977d44|f23dfdc4-bf9b0d5-a36c8a91-224fceb9_0]  PartitionId [0]  Generation [1] Write session: destroy
2025-11-11T14:20:13.622606Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: e5a3975a-b7eef2a6-3c07e33-a1b7b5e08, Host: ghrun-vb3yoermsa, Tenant: /compute
2025-11-11T14:20:13.626354Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-11T14:20:13.626372Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-11T14:20:14.623013Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:617: RowDispatcher: Send ping to [2:7571472399481445439:2113]
2025-11-11T14:20:14.623040Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: e5a3975a-b7eef2a6-3c07e33-a1b7b5e09, Host: ghrun-vb3yoermsa, Tenant: /compute
2025-11-11T14:20:14.623041Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1161: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-11-11T14:20:14.623338Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:623: RowDispatcher: NActors::TEvents::TEvPong
2025-11-11T14:20:14.628198Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-11T14:20:14.628218Z :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:5653: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-vb3yoermsa.auto.internal:5653
2025-11-11T14:20:15.624327Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: e5a3975a-b7eef2a6-3c07e33-a1b7b5e010, Host: ghrun-vb3yoermsa, Tenant: /compute
2025-11-11T14:20:15.630000Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-11T14:20:15.630027Z :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:5653: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-vb3yoermsa.auto.internal:5653
2025-11-11T14:20:16.623906Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:617: RowDispatcher: Send ping to [2:7571472399481445439:2113]
2025-11-11T14:20:16.623926Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1161: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-11-11T14:20:16.624244Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:623: RowDispatcher: NActors::TEvents::TEvPong
2025-11-11T14:20:16.624940Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: e5a3975a-b7eef2a6-3c07e33-a1b7b5e011, Host: ghrun-vb3yoermsa, Tenant: /compute
2025-11-11T14:20:16.633321Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-11T14:20:16.633341Z :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:5653: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-vb3yoermsa.auto.internal:5653
2025-11-11T14:20:16.644405Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-11-11T14:20:16.649727Z :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:5653: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-vb3yoermsa.auto.internal:5653
2025-11-11T14:20:17.065867Z :INTERCONNECT_NETWORK NOTICE: interconnect_tcp_input_session.cpp:715: [1 <-> 3] connection closed by peer
2025-11-11T14:20:17.066177Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: e5a3975a-b7eef2a6-3c07e33-a1b7b5e0 2025-11-11 14:20:17.066 DEBUG ydbd(pid=1084867, tid=0x00007F7222960640) [DQ] local_worker_manager.cpp:257: Disconnected 3
2025-11-11T14:20:17.066215Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: e5a3975a-b7eef2a6-3c07e33-a1b7b5e0 2025-11-11 14:20:17.066 DEBUG ydbd(pid=1084867, tid=0x00007F7222960640) [DQ] local_worker_manager.cpp:228: Deallocate 3
2025-11-11T14:20:17.067342Z :INTERCONNECT_NETWORK NOTICE: interconnect_handshake.cpp:1581: [1 <-> 3] network-related error occured on handshake: outgoing handshake Peer# ghrun-vb3yoermsa(127.0.1.1:5874) Couldn't connect to any resolved address
2025-11-11T14:20:17.077236Z :INTERCONNECT_NETWORK NOTICE: interconnect_handshake.cpp:1581: [1 <-> 3] network-related error occured on handshake: outgoing handshake Peer# ghrun-vb3yoermsa(127.0.1.1:5874) Couldn't connect to any resolved address
