2025-11-11T14:16:15.470709Z :GRPC_SERVER NOTICE: grpc_request_proxy.cpp:369: Grpc request proxy started, nodeid# 1, serve as static node
2025-11-11T14:16:15.470785Z :GRPC_SERVER CRIT: grpc_request_proxy.cpp:429: Failed to deliver subscription request to config dispatcher
2025-11-11T14:16:15.470790Z :GRPC_SERVER NOTICE: grpc_request_proxy.cpp:369: Grpc request proxy started, nodeid# 1, serve as static node
2025-11-11T14:16:15.470815Z :GRPC_SERVER CRIT: grpc_request_proxy.cpp:429: Failed to deliver subscription request to config dispatcher
2025-11-11T14:16:15.471133Z :FQ_LOG_UPDATER DEBUG: log.cpp:93: Updated YQL logs priority: 8
2025-11-11T14:16:15.471139Z :FQ_LOG_UPDATER CRIT: log.cpp:55: Failed to deliver subscription request to config dispatcher.
2025-11-11T14:16:15.471181Z :YQ_RATE_LIMITER INFO: quoter_service.cpp:124: Bootstraping with config: { Enabled: true DataPlaneEnabled: true Database { Endpoint: "localhost:11957" Database: "local" TablePrefix: "RateLimiter_21e807b4-7e3f-4d8c-a5e6-0326e77d6bc9" } Limiters { CoordinationNodePath: "rate_limiter" } }
2025-11-11T14:16:15.471947Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:188: Bootstrap
2025-11-11T14:16:15.471950Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:191: Create sdk ydb connection
2025-11-11T14:16:15.472137Z :STREAMS_STORAGE_SERVICE TRACE: storage_proxy.cpp:213: Initialize
2025-11-11T14:16:15.472241Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:209: Successfully bootstrapped TStorageProxy [1:7571471469808169543:2062] with connection to localhost:11957:local
2025-11-11T14:16:15.472247Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:534: RowDispatcher: Successfully bootstrapped row dispatcher, id [1:7571471469808169544:2063], tenant /compute
2025-11-11T14:16:15.472383Z :YQL_NODES_MANAGER INFO: nodes_manager.cpp:88: Bootstrap, InstanceId: 8f970bed-4fee6c02-dff93cb6-f1c5900
2025-11-11T14:16:15.472384Z :YQL_NODES_MANAGER DEBUG: nodes_manager.cpp:310: TNodesManagerActor::ResolveSelfAddress
2025-11-11T14:16:15.472395Z :YQ_TEST_CONNECTION DEBUG: test_connection.cpp:142: Starting yandex query test connection. Actor id: [1:7571471469808169549:2068]
2025-11-11T14:16:15.472451Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: eddcb26f-38d004a5-9471148-3a628dd91, Host: ghrun-vb3yoermsa, Tenant: /compute
2025-11-11T14:16:15.472871Z :FQ_QUOTA_PROXY INFO: quota_proxy.cpp:90: STARTED
2025-11-11T14:16:15.472926Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:267: Coordinator: Successfully bootstrapped coordinator, id [1:7571471469808169584:2082], NodesManagerId [0:4705493345362661702:78]
2025-11-11T14:16:15.472937Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:232: TLeaderElection [1:7571471469808169585:2083] Successfully bootstrapped, local coordinator id [1:7571471469808169584:2082], tenant id compute, local mode 0, coordination node path local/row_dispatcher/compute, endpoint localhost:11957
2025-11-11T14:16:15.478754Z :FQ_QUOTA_SERVICE INFO: quota_manager.cpp:196: STARTED
2025-11-11T14:16:15.478763Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:627: RowDispatcher: TEvCoordinatorChangesSubscribe from [1:7571471469808169584:2082]
2025-11-11T14:16:15.484296Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-11-11T14:16:15.485182Z :MEMORY_PROFILER NOTICE: monitor.cpp:332: Bootstrapped
2025-11-11T14:16:15.511173Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:71: Run create coordination node "local/row_dispatcher/compute" actor
2025-11-11T14:16:15.511178Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:113: Call create coordination node "local/row_dispatcher/compute"
2025-11-11T14:16:15.511181Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:411: Call create coordination node "local/row_dispatcher/compute"
2025-11-11T14:16:15.521749Z :SCHEME_BOARD_SUBSCRIBER NOTICE: subscriber.cpp:849: [main][1:7571471469808169563:2077][/Root] Set up state: owner# [1:7571471469808169523:2052], state# { Deleted: 1 Strong: 0 Version: <Invalid> DomainId: <Invalid> AbandonedSchemeShards: there are 0 elements }
2025-11-11T14:16:15.521790Z :SCHEME_BOARD_SUBSCRIBER NOTICE: subscriber.cpp:849: [main][1:7571471469808169565:2079][/Root] Set up state: owner# [1:7571471469808169524:2053], state# { Deleted: 1 Strong: 0 Version: <Invalid> DomainId: <Invalid> AbandonedSchemeShards: there are 0 elements }
2025-11-11T14:16:15.525475Z :SCHEME_BOARD_SUBSCRIBER NOTICE: subscriber.cpp:849: [main][1:7571471469808169564:2078][/compute] Set up state: owner# [1:7571471469808169523:2052], state# { Deleted: 1 Strong: 0 Version: <Invalid> DomainId: <Invalid> AbandonedSchemeShards: there are 0 elements }
2025-11-11T14:16:15.525486Z :GRPC_SERVER WARN: grpc_request_proxy.cpp:572: SchemeBoardDelete /Root Strong=0
2025-11-11T14:16:15.525491Z :GRPC_SERVER WARN: grpc_request_proxy.cpp:572: SchemeBoardDelete /Root Strong=0
2025-11-11T14:16:15.525493Z :GRPC_SERVER WARN: grpc_request_proxy.cpp:572: SchemeBoardDelete /compute Strong=0
2025-11-11T14:16:15.525604Z :SCHEME_BOARD_SUBSCRIBER NOTICE: subscriber.cpp:849: [main][1:7571471469808169566:2080][/compute] Set up state: owner# [1:7571471469808169524:2053], state# { Deleted: 1 Strong: 0 Version: <Invalid> DomainId: <Invalid> AbandonedSchemeShards: there are 0 elements }
2025-11-11T14:16:15.525623Z :GRPC_SERVER WARN: grpc_request_proxy.cpp:572: SchemeBoardDelete /compute Strong=0
2025-11-11T14:16:15.533008Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:155: Successfully created coordination node "local/row_dispatcher/compute"
2025-11-11T14:16:15.533028Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:122: Reply for create coordination node "local/row_dispatcher/compute": { <main>: Error: Check failed: path: '/local/row_dispatcher/compute', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 29], type: EPathTypeKesus, state: EPathStateNoChanges), source_location: ydb/core/tx/schemeshard/schemeshard__operation_create_kesus.cpp:339 }
2025-11-11T14:16:15.533038Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:345: TLeaderElection [1:7571471469808169585:2083] Coordination node successfully created
2025-11-11T14:16:15.533042Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:323: TLeaderElection [1:7571471469808169585:2083] Start session
2025-11-11T14:16:15.582119Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:499: Checkpoint storage and state storage were successfully inited
2025-11-11T14:16:15.625450Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-11T14:16:15.625465Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-11T14:16:15.625488Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:389: Send NodeInfo with size: 0 to DynamicNameserver
2025-11-11T14:16:15.629551Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:359: TLeaderElection [1:7571471469808169585:2083] Session successfully created
2025-11-11T14:16:15.645646Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:372: TLeaderElection [1:7571471469808169585:2083] Semaphore successfully created
2025-11-11T14:16:15.645657Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:304: TLeaderElection [1:7571471469808169585:2083] Try to acquire semaphore
2025-11-11T14:16:15.645745Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:420: TLeaderElection [1:7571471469808169585:2083] Describe semaphore
2025-11-11T14:16:15.653626Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:386: TLeaderElection [1:7571471469808169585:2083] Semaphore successfully acquired
2025-11-11T14:16:15.653647Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:469: TLeaderElection [1:7571471469808169585:2083] Semaphore successfully described: coordinator id [1:7571471469808169584:2082] generation 4
2025-11-11T14:16:15.653653Z :FQ_ROW_DISPATCHER INFO: leader_election.cpp:471: TLeaderElection [1:7571471469808169585:2083] Send TEvCoordinatorChanged to [1:7571471469808169544:2063], new coordinator id [1:7571471469808169584:2082], previous coordinator id [0:0:0]
2025-11-11T14:16:15.653671Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:559: RowDispatcher: Coordinator changed, old leader (empty maybe), new [1:7571471469808169584:2082] generation 4
2025-11-11T14:16:15.653682Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:314: Coordinator: TEvPing received, [1:7571471469808169544:2063]
2025-11-11T14:16:15.653686Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:317: Coordinator: Send TEvPong to [1:7571471469808169544:2063]
2025-11-11T14:16:15.653693Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:386: Coordinator: New leader [1:7571471469808169584:2082], SelfId [1:7571471469808169584:2082]
2025-11-11T14:16:15.653696Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:623: RowDispatcher: NActors::TEvents::TEvPong
2025-11-11T14:16:16.470353Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:542: Coordinator: Send TEvGetNodesRequest to NodesManager
2025-11-11T14:16:16.470380Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: eddcb26f-38d004a5-9471148-3a628dd92, Host: ghrun-vb3yoermsa, Tenant: /compute
2025-11-11T14:16:16.470391Z :YQL_NODES_MANAGER DEBUG: nodes_manager.cpp:300: TNodesManagerActor::TEvGetNodesRequest
2025-11-11T14:16:16.470461Z :FQ_ROW_DISPATCHER INFO: coordinator.cpp:573: Coordinator: Updated node info, node count: 1
2025-11-11T14:16:16.495680Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-11T14:16:16.495694Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-11T14:16:17.469623Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:617: RowDispatcher: Send ping to [1:7571471469808169584:2082]
2025-11-11T14:16:17.469645Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1161: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-11-11T14:16:17.469654Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:314: Coordinator: TEvPing received, [1:7571471469808169544:2063]
2025-11-11T14:16:17.469657Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:317: Coordinator: Send TEvPong to [1:7571471469808169544:2063]
2025-11-11T14:16:17.469662Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:623: RowDispatcher: NActors::TEvents::TEvPong
2025-11-11T14:16:17.470626Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: eddcb26f-38d004a5-9471148-3a628dd93, Host: ghrun-vb3yoermsa, Tenant: /compute
2025-11-11T14:16:17.476894Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-11T14:16:17.476907Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-11T14:16:18.471057Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: eddcb26f-38d004a5-9471148-3a628dd94, Host: ghrun-vb3yoermsa, Tenant: /compute
2025-11-11T14:16:18.474377Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-11T14:16:18.474399Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-11T14:16:18.519207Z :INTERCONNECT ERROR: interconnect_nameserver_dynamic.cpp:61:  ICN06 Unknown nodeId: 2
2025-11-11T14:16:18.961568Z :INTERCONNECT ERROR: interconnect_nameserver_dynamic.cpp:61:  ICN06 Unknown nodeId: 2
2025-11-11T14:16:19.470502Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:617: RowDispatcher: Send ping to [1:7571471469808169584:2082]
2025-11-11T14:16:19.470526Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1161: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-11-11T14:16:19.470533Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:314: Coordinator: TEvPing received, [1:7571471469808169544:2063]
2025-11-11T14:16:19.470536Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:317: Coordinator: Send TEvPong to [1:7571471469808169544:2063]
2025-11-11T14:16:19.470543Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:623: RowDispatcher: NActors::TEvents::TEvPong
2025-11-11T14:16:19.471509Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: eddcb26f-38d004a5-9471148-3a628dd95, Host: ghrun-vb3yoermsa, Tenant: /compute
2025-11-11T14:16:19.474617Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-11T14:16:19.474628Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-11T14:16:20.123808Z :INTERCONNECT ERROR: interconnect_nameserver_dynamic.cpp:61:  ICN06 Unknown nodeId: 2
2025-11-11T14:16:20.123831Z :INTERCONNECT ERROR: interconnect_nameserver_dynamic.cpp:61:  ICN06 Unknown nodeId: 3
2025-11-11T14:16:20.468925Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-11-11T14:16:20.471960Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: eddcb26f-38d004a5-9471148-3a628dd96, Host: ghrun-vb3yoermsa, Tenant: /compute
2025-11-11T14:16:20.484512Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-11T14:16:20.484527Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-11T14:16:20.486244Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:389: Send NodeInfo with size: 2 to DynamicNameserver
2025-11-11T14:16:20.487429Z :INTERCONNECT WARN: interconnect_handshake.cpp:543: Handshake [1:7571471491283006224:2057] [node 3] ICH09 Neither CompatibilityInfo nor VersionTag of the peer can be validated, accepting by default
2025-11-11T14:16:20.497597Z :FQ_QUOTA_SERVICE DEBUG: quota_manager.cpp:230: IC Peers[2]: [2, 3]
2025-11-11T14:16:20.714412Z :INTERCONNECT WARN: interconnect_handshake.cpp:543: Handshake [1:7571471491283006237:2059] [node 2] ICH09 Neither CompatibilityInfo nor VersionTag of the peer can be validated, accepting by default
2025-11-11T14:16:21.471431Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:617: RowDispatcher: Send ping to [1:7571471469808169584:2082]
2025-11-11T14:16:21.471452Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1161: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-11-11T14:16:21.471684Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:314: Coordinator: TEvPing received, [1:7571471469808169544:2063]
2025-11-11T14:16:21.471689Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:317: Coordinator: Send TEvPong to [1:7571471469808169544:2063]
2025-11-11T14:16:21.471696Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:623: RowDispatcher: NActors::TEvents::TEvPong
2025-11-11T14:16:21.472413Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: eddcb26f-38d004a5-9471148-3a628dd97, Host: ghrun-vb3yoermsa, Tenant: /compute
2025-11-11T14:16:21.475479Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-11T14:16:21.475489Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-11T14:16:21.780261Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:134: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Start compute actor [1:7571471495577973543:2141], task: 2
2025-11-11T14:16:21.780305Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:113: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Use CPU quota: 1. Rate limiter resource: { "local/RateLimiter_21e807b4-7e3f-4d8c-a5e6-0326e77d6bc9/rate_limiter", "mock_cloud/my_folder/ptqudslmqjs79hp24ued" }
2025-11-11T14:16:21.942496Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:314: Coordinator: TEvPing received, [3:7571471486365932951:2063]
2025-11-11T14:16:21.942735Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:317: Coordinator: Send TEvPong to [3:7571471486365932951:2063]
2025-11-11T14:16:21.942961Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:350: Coordinator: EvNodeConnected 3
2025-11-11T14:16:22.007055Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:197: [] Task: 2. Got TEvNewCheckpointCoordinator event: generation 1, actorId: [2:7571471493335860584:2148]
2025-11-11T14:16:22.007070Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:208: [] Task: 2. Assign checkpoint coordinator (generation = 1)
2025-11-11T14:16:22.008644Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1457: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Create sink for output 0 { Sink { Type: "PqSink" Settings { type_url: "type.googleapis.com/NYql.NPq.NProto.TDqPqTopicSink" value: "\n\032test_metadatafields_output\022\017localhost:11957\032\025\n\023cluster:default_yds\"\005local0\0018\002" } } }
2025-11-11T14:16:22.009465Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:395: [ptqudslmqjs79hp24ued-0] Task: 2. Handle connected node 2
2025-11-11T14:16:22.010017Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1174: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Got TEvRun from actor [2:7571471493335860584:2148]
2025-11-11T14:16:22.010040Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1491: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Poll inputs
2025-11-11T14:16:22.010043Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1506: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Poll sources
2025-11-11T14:16:22.010044Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-11-11T14:16:22.010372Z :KQP_COMPUTE TRACE: dq_compute_memory_quota.h:97: TxId: ptqudslmqjs79hp24ued, task: 2. Peak memory usage: 2031616
2025-11-11T14:16:22.010385Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. update task runner stats
2025-11-11T14:16:22.010404Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-11T14:16:22.010406Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-11T14:16:22.010411Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:571: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-11-11T14:16:22.010415Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1105: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Ask CPU quota: 229ms
2025-11-11T14:16:22.010432Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:188: SelfId: [0:0:0], TxId: ptqudslmqjs79hp24ued, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-11-11T14:16:22.010852Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1023: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-11-11T14:16:22.010861Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1027: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-11-11T14:16:22.010869Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:605: TxId: ptqudslmqjs79hp24ued, task: 2. no poll, channelId: 1, hasPeer: 0, finished: 0, retry: 0, lastSeqNo: 0, freeSpace: 1000000
2025-11-11T14:16:22.010873Z :FQ_ROW_DISPATCHER INFO: coordinator.cpp:451: Coordinator: TEvCoordinatorRequest from [2:7571471493335860590:2151], test_metadatafields_input, partIds: 0
2025-11-11T14:16:22.010896Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:506: Coordinator: Send TEvCoordinatorResult to [2:7571471493335860590:2151]
2025-11-11T14:16:22.010943Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:350: Coordinator: EvNodeConnected 2
2025-11-11T14:16:22.011493Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:843: RowDispatcher: Received TEvStartSession from [2:7571471493335860590:2151], read group ptcudslmqk7kv9j5k4up, topicPath test_metadatafields_input part id 0 query id ptqudslmqjs79hp24ued cookie 1
2025-11-11T14:16:22.011530Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:880: RowDispatcher: Create new session: read group ptcudslmqk7kv9j5k4up topic test_metadatafields_input part id 0
2025-11-11T14:16:22.011587Z :FQ_ROW_DISPATCHER DEBUG: topic_session.cpp:425: TopicSession [1:7571471499872940844:2142] Bootstrap test_metadatafields_input/0, Timeout 5.000000s sec
2025-11-11T14:16:22.011596Z :FQ_ROW_DISPATCHER INFO: topic_session.cpp:777: TopicSession [1:7571471499872940844:2142] New client: read actor id [2:7571471493335860590:2151], predicate: , watermark expr: , offset: (empty maybe)
2025-11-11T14:16:22.011637Z :FQ_ROW_DISPATCHER DEBUG: format_handler.cpp:440: TTopicFormatHandler [json_each_row]: Add client with id [2:7571471493335860590:2151]
2025-11-11T14:16:22.011957Z :FQ_ROW_DISPATCHER DEBUG: format_handler.cpp:559: TTopicFormatHandler [json_each_row]: UpdateParser to new schema with size 1
2025-11-11T14:16:22.012336Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1074: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Received channels info: Update { Id: 1 TransportVersion: DATA_TRANSPORT_UV_PICKLE_1_0 SrcTaskId: 1 DstTaskId: 2 SrcEndpoint { ActorId { RawX1: 7571471493335860587 RawX2: 4503608217307239 } } DstEndpoint { ActorId { RawX1: 7571471495577973543 RawX2: 4503603922339933 } } SrcStageId: 213650 DstStageId: 213670 }
2025-11-11T14:16:22.012341Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1081: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Update input channelId: 1, peer: [2:7571471493335860587:2151]
2025-11-11T14:16:22.012345Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1491: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Poll inputs
2025-11-11T14:16:22.012347Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1506: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Poll sources
2025-11-11T14:16:22.012349Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-11-11T14:16:22.012368Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1039: RowDispatcher: TEvTryConnect to node id 2
2025-11-11T14:16:22.012414Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:577: RowDispatcher: EvNodeConnected, node id 2
2025-11-11T14:16:22.012562Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1162: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. CPU quota delay: 2ms
2025-11-11T14:16:22.012618Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. update task runner stats
2025-11-11T14:16:22.012640Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-11T14:16:22.012642Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-11T14:16:22.012645Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:571: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-11-11T14:16:22.012653Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:188: SelfId: [1:7571471499872940843:2141], TxId: ptqudslmqjs79hp24ued, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-11-11T14:16:22.012656Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1023: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-11-11T14:16:22.012657Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1027: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-11-11T14:16:22.012662Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:605: TxId: ptqudslmqjs79hp24ued, task: 2. no poll, channelId: 1, hasPeer: 1, finished: 0, retry: 0, lastSeqNo: 0, freeSpace: 1000000
2025-11-11T14:16:22.012969Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:129: TxId: ptqudslmqjs79hp24ued, task: 2. Received input for channelId: 1, seqNo: 1, size: 0, chunks: 0, watermark: 0, checkpoint: 1, finished: 0, from: [2:7571471493335860588:2151], expected seqNo: 1
2025-11-11T14:16:22.012973Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:609: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. took input
2025-11-11T14:16:22.012986Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:485: [ptqudslmqjs79hp24ued-0] Task: 2. [Checkpoint 1.1] Got checkpoint barrier from channel 1
2025-11-11T14:16:22.012997Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:395: SelfId: [1:7571471495577973545:2141], TxId: ptqudslmqjs79hp24ued, task: 2. No watermark 
2025-11-11T14:16:22.012998Z :FQ_ROW_DISPATCHER INFO: json_parser.cpp:363: TJsonParser: Simdjson active implementation icelake (Intel/AMD AVX512), error skip mode: 0
2025-11-11T14:16:22.013000Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1491: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Poll inputs
2025-11-11T14:16:22.013002Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1502: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-11-11T14:16:22.013003Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. DoExecuteImpl: 1
2025-11-11T14:16:22.013009Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:965: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Input data push finished. Cookie: 0 Watermark: (empty maybe) Ack: 1 TakeInputChannelDataRequests: 1
2025-11-11T14:16:22.013013Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:738: TxId: ptqudslmqjs79hp24ued, task: 2. Sending channel data ack to channelId: 1, peer: [2:7571471493335860587:2151], from: [1:7571471495577973543:2141], freeSpace: 1000000, seqNo: 1, finished: 0
2025-11-11T14:16:22.013045Z :FQ_ROW_DISPATCHER DEBUG: format_handler.cpp:570: TTopicFormatHandler [json_each_row]: Parser was created on schema with 1 columns
2025-11-11T14:16:22.013051Z :FQ_ROW_DISPATCHER TRACE: purecalc_filter.cpp:439: GenerateSql: No sql was generated
2025-11-11T14:16:22.013055Z :FQ_ROW_DISPATCHER TRACE: filters_set.cpp:116: TTopicFilters: Create program with client id [2:7571471493335860590:2151]
2025-11-11T14:16:22.013063Z :FQ_ROW_DISPATCHER TRACE: filters_set.cpp:110: TTopicFilters: Start program with client id [2:7571471493335860590:2151]
2025-11-11T14:16:22.013068Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:930: TopicSession [1:7571471499872940844:2142] SendStatistics
2025-11-11T14:16:22.013086Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1221: RowDispatcher: TEvSessionStatistic from [1:7571471499872940844:2142]
2025-11-11T14:16:22.013088Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:510: SelfId: [1:7571471495577973545:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Pending 1 checkpoints to be sent
2025-11-11T14:16:22.013093Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1491: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Poll inputs
2025-11-11T14:16:22.013095Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1502: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-11-11T14:16:22.013096Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-11-11T14:16:22.013100Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. update task runner stats
2025-11-11T14:16:22.013116Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 1 watermark injected: (empty maybe)
2025-11-11T14:16:22.013118Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:447: [ptqudslmqjs79hp24ued-0] Task: 2. [Checkpoint 1.1] Performing task checkpoint
2025-11-11T14:16:22.013120Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:822: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Save state
2025-11-11T14:16:22.013122Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:474: [ptqudslmqjs79hp24ued-0] Task: 2. [Checkpoint 1.1] CA state saved
2025-11-11T14:16:22.013124Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:449: [ptqudslmqjs79hp24ued-0] Task: 2. [Checkpoint 1.1] Injecting checkpoint barrier to outputs
2025-11-11T14:16:22.013126Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-11T14:16:22.013129Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:571: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-11-11T14:16:22.013134Z :KQP_COMPUTE INFO: dq_async_compute_actor.cpp:1008: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Resume inputs
2025-11-11T14:16:22.013138Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:188: SelfId: [1:7571471499872940843:2141], TxId: ptqudslmqjs79hp24ued, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 1. Finished: 0
2025-11-11T14:16:22.013141Z :KQP_COMPUTE DEBUG: dq_pq_write_actor.cpp:233: SelfId: [1:7571471499872940843:2141], TxId: ptqudslmqjs79hp24ued, TaskId: 2, PQ sink. [Checkpoint 1.1] Send checkpoint state immediately
2025-11-11T14:16:22.013293Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:411: SelfId: [1:7571471499872940843:2141], TxId: ptqudslmqjs79hp24ued, TaskId: 2, PQ sink. Save checkpoint { Id: 1 Generation: 1 Type: CHECKPOINT_TYPE_SNAPSHOT } state: { SourceId: "dd6325aa-406a174d-4a846f43-5b4f84d5" }
2025-11-11T14:16:22.013296Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:524: [ptqudslmqjs79hp24ued-0] Task: 2. Sink[0] state saved
2025-11-11T14:16:22.013310Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:536: [ptqudslmqjs79hp24ued-0] Task: 2. [Checkpoint 1.1] Task checkpoint is done. Send to storage
2025-11-11T14:16:22.013314Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1023: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 6 bytes of checkpoint barrier
2025-11-11T14:16:22.013315Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1027: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-11-11T14:16:22.013322Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudslmqjs79hp24ued, task: 2. no poll, channelId: 1, has inflight messages: [1], last with freeSpace: 1000000, current freeSpace: 1000000
2025-11-11T14:16:22.013326Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:409: [ptqudslmqjs79hp24ued-0] [1:1] Got TEvSaveTaskState: task 2
2025-11-11T14:16:22.013343Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1491: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Poll inputs
2025-11-11T14:16:22.013345Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1506: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Poll sources
2025-11-11T14:16:22.013346Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-11-11T14:16:22.013348Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. update task runner stats
2025-11-11T14:16:22.013356Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-11T14:16:22.013358Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-11T14:16:22.013359Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:571: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-11-11T14:16:22.013363Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:188: SelfId: [1:7571471499872940843:2141], TxId: ptqudslmqjs79hp24ued, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-11-11T14:16:22.013365Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1023: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-11-11T14:16:22.013366Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1027: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-11-11T14:16:22.013369Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudslmqjs79hp24ued, task: 2. no poll, channelId: 1, has inflight messages: [1], last with freeSpace: 1000000, current freeSpace: 1000000
2025-11-11T14:16:22.013380Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. update task runner stats
2025-11-11T14:16:22.013386Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-11T14:16:22.013387Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-11T14:16:22.013388Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:571: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-11-11T14:16:22.013391Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:188: SelfId: [1:7571471499872940843:2141], TxId: ptqudslmqjs79hp24ued, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-11-11T14:16:22.013392Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1023: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-11-11T14:16:22.013394Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1027: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-11-11T14:16:22.013396Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudslmqjs79hp24ued, task: 2. no poll, channelId: 1, has inflight messages: [1], last with freeSpace: 1000000, current freeSpace: 1000000
2025-11-11T14:16:22.016285Z :YDB_SDK INFO: actor.cpp:37: 2025-11-11T14:16:22.016271Z :INFO: [local] OnFederationDiscovery fall back to single mode, database=local
2025-11-11T14:16:22.016420Z :YDB_SDK INFO: actor.cpp:37: [] [] Start federated write session to database '' (previous was <empty>) FederationState: { Status: SUCCESS SelfLocation: "" DbInfos: [ { path: "local" endpoint: "localhost:11957" status: AVAILABLE weight: 100 } ] ControlPlaneEndpoint: localhost:11957 }
2025-11-11T14:16:22.016478Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:22.016472Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmqjs79hp24ued, TaskId: 2, PQ sink. ]  SessionId []  MessageGroupId [dd6325aa-406a174d-4a846f43-5b4f84d5] Write session: try to update token
2025-11-11T14:16:22.016730Z :YDB_SDK INFO: actor.cpp:37: 2025-11-11T14:16:22.016727Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmqjs79hp24ued, TaskId: 2, PQ sink. ]  SessionId []  MessageGroupId [dd6325aa-406a174d-4a846f43-5b4f84d5] Start write session. Will connect to nodeId: 0
2025-11-11T14:16:22.017055Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:22.017041Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmqjs79hp24ued, TaskId: 2, PQ sink. ]  SessionId []  MessageGroupId [dd6325aa-406a174d-4a846f43-5b4f84d5] Write session: write to message_group: dd6325aa-406a174d-4a846f43-5b4f84d5
2025-11-11T14:16:22.017084Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:22.017081Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmqjs79hp24ued, TaskId: 2, PQ sink. ]  SessionId []  MessageGroupId [dd6325aa-406a174d-4a846f43-5b4f84d5] Write session: send init request: init_request { path: "test_metadatafields_output" producer_id: "dd6325aa-406a174d-4a846f43-5b4f84d5" message_group_id: "dd6325aa-406a174d-4a846f43-5b4f84d5" }
2025-11-11T14:16:22.017087Z :YDB_SDK TRACE: actor.cpp:37: 2025-11-11T14:16:22.017085Z :TRACE: [local] TRACE_EVENT InitRequest 
2025-11-11T14:16:22.017182Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:22.017179Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmqjs79hp24ued, TaskId: 2, PQ sink. ]  SessionId []  MessageGroupId [dd6325aa-406a174d-4a846f43-5b4f84d5] Write session: OnWriteDone gRpcStatusCode: 0
2025-11-11T14:16:22.023101Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:22.023094Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmqjs79hp24ued, TaskId: 2, PQ sink. ]  SessionId []  MessageGroupId [dd6325aa-406a174d-4a846f43-5b4f84d5] Write session: OnReadDone gRpcStatusCode: 0
2025-11-11T14:16:22.023134Z :YDB_SDK INFO: actor.cpp:37: 2025-11-11T14:16:22.023131Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmqjs79hp24ued, TaskId: 2, PQ sink. ]  SessionId []  MessageGroupId [dd6325aa-406a174d-4a846f43-5b4f84d5] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1762870582023 BytesWritten: 0 MessagesWritten: 0 BytesWrittenCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:16:22.023153Z :YDB_SDK INFO: actor.cpp:37: 2025-11-11T14:16:22.023151Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmqjs79hp24ued, TaskId: 2, PQ sink. ]  SessionId []  MessageGroupId [dd6325aa-406a174d-4a846f43-5b4f84d5] Write session established. Init response: session_id: "dd6325aa-406a174d-4a846f43-5b4f84d5|183e0cce-4dfba75-c0536d4b-57f1ddb7_0"
2025-11-11T14:16:22.023159Z :YDB_SDK TRACE: actor.cpp:37: 2025-11-11T14:16:22.023157Z :TRACE: [local] TRACE_EVENT InitResponse  partition_id=0 session_id=dd6325aa-406a174d-4a846f43-5b4f84d5|183e0cce-4dfba75-c0536d4b-57f1ddb7_0
2025-11-11T14:16:22.023162Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:22.023161Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmqjs79hp24ued, TaskId: 2, PQ sink. ]  SessionId [dd6325aa-406a174d-4a846f43-5b4f84d5|183e0cce-4dfba75-c0536d4b-57f1ddb7_0]  MessageGroupId [dd6325aa-406a174d-4a846f43-5b4f84d5] Write session: set DirectWriteToPartitionId 0
2025-11-11T14:16:22.023225Z :YDB_SDK INFO: actor.cpp:37: 2025-11-11T14:16:22.023223Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmqjs79hp24ued, TaskId: 2, PQ sink. ]  SessionId [dd6325aa-406a174d-4a846f43-5b4f84d5|183e0cce-4dfba75-c0536d4b-57f1ddb7_0]  PartitionId [0]  Generation [0] Get partition location async, partition 0, delay 0.000000s
2025-11-11T14:16:22.023250Z :YDB_SDK TRACE: actor.cpp:37: 2025-11-11T14:16:22.023236Z :TRACE: [local] TRACE_EVENT DescribePartitionRequest  path=local/test_metadatafields_output partition_id=0
2025-11-11T14:16:22.023288Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:22.023281Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmqjs79hp24ued, TaskId: 2, PQ sink. ]  SessionId [dd6325aa-406a174d-4a846f43-5b4f84d5|183e0cce-4dfba75-c0536d4b-57f1ddb7_0]  PartitionId [0]  Generation [0]  Getting partition location, partition 0
2025-11-11T14:16:22.024295Z :YDB_SDK INFO: actor.cpp:37: 2025-11-11T14:16:22.024289Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmqjs79hp24ued, TaskId: 2, PQ sink. ]  SessionId [dd6325aa-406a174d-4a846f43-5b4f84d5|183e0cce-4dfba75-c0536d4b-57f1ddb7_0]  PartitionId [0]  Generation [0] Got PartitionLocation response. Status SUCCESS, proto:
partition {
  active: true
  partition_location {
    node_id: 1
    generation: 1
  }
}

2025-11-11T14:16:22.024307Z :YDB_SDK TRACE: actor.cpp:37: 2025-11-11T14:16:22.024305Z :TRACE: [local] TRACE_EVENT DescribePartitionResponse  partition_id=0 active=1 pl_node_id=1 pl_generation=1
2025-11-11T14:16:22.024313Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:22.024311Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmqjs79hp24ued, TaskId: 2, PQ sink. ]  SessionId [dd6325aa-406a174d-4a846f43-5b4f84d5|183e0cce-4dfba75-c0536d4b-57f1ddb7_0]  PartitionId [0]  Generation [0] GetPreferredEndpoint: partitionId 0, partitionNodeId 1 exists in the endpoint pool.
2025-11-11T14:16:22.024318Z :YDB_SDK TRACE: actor.cpp:37: 2025-11-11T14:16:22.024317Z :TRACE: [local] TRACE_EVENT PreferredPartitionLocation  Endpoint= NodeId=1 Generation=1
2025-11-11T14:16:22.024323Z :YDB_SDK INFO: actor.cpp:37: 2025-11-11T14:16:22.024321Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmqjs79hp24ued, TaskId: 2, PQ sink. ]  SessionId [dd6325aa-406a174d-4a846f43-5b4f84d5|183e0cce-4dfba75-c0536d4b-57f1ddb7_0]  PartitionId [0]  Generation [1] Start write session. Will connect to nodeId: 1
2025-11-11T14:16:22.024664Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:22.024657Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmqjs79hp24ued, TaskId: 2, PQ sink. ]  SessionId [dd6325aa-406a174d-4a846f43-5b4f84d5|183e0cce-4dfba75-c0536d4b-57f1ddb7_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 1, Msg: CANCELLED, Details: , InternalError: 0
2025-11-11T14:16:22.024743Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:22.024741Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmqjs79hp24ued, TaskId: 2, PQ sink. ]  SessionId [dd6325aa-406a174d-4a846f43-5b4f84d5|183e0cce-4dfba75-c0536d4b-57f1ddb7_0]  PartitionId [0]  Generation [1] Write session: direct write to partition: 0, generation 1
2025-11-11T14:16:22.024770Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:22.024768Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmqjs79hp24ued, TaskId: 2, PQ sink. ]  SessionId [dd6325aa-406a174d-4a846f43-5b4f84d5|183e0cce-4dfba75-c0536d4b-57f1ddb7_0]  PartitionId [0]  Generation [1] Write session: send init request: init_request { path: "test_metadatafields_output" producer_id: "dd6325aa-406a174d-4a846f43-5b4f84d5" partition_with_generation { generation: 1 } }
2025-11-11T14:16:22.024779Z :YDB_SDK TRACE: actor.cpp:37: 2025-11-11T14:16:22.024777Z :TRACE: [local] TRACE_EVENT InitRequest  pwg_partition_id=0 pwg_generation=1
2025-11-11T14:16:22.024860Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:22.024858Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmqjs79hp24ued, TaskId: 2, PQ sink. ]  SessionId [dd6325aa-406a174d-4a846f43-5b4f84d5|183e0cce-4dfba75-c0536d4b-57f1ddb7_0]  PartitionId [0]  Generation [1] Write session: OnWriteDone gRpcStatusCode: 0
2025-11-11T14:16:22.030231Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:433: [ptqudslmqjs79hp24ued-0] [1:1] TEvSaveTaskState Apply: task: 2
2025-11-11T14:16:22.030242Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:448: [ptqudslmqjs79hp24ued-0] [1:1] Send TEvSaveTaskStateResult: task: 2
2025-11-11T14:16:22.030459Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:22.030455Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmqjs79hp24ued, TaskId: 2, PQ sink. ]  SessionId [dd6325aa-406a174d-4a846f43-5b4f84d5|183e0cce-4dfba75-c0536d4b-57f1ddb7_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-11-11T14:16:22.030478Z :YDB_SDK INFO: actor.cpp:37: 2025-11-11T14:16:22.030476Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmqjs79hp24ued, TaskId: 2, PQ sink. ]  SessionId [dd6325aa-406a174d-4a846f43-5b4f84d5|183e0cce-4dfba75-c0536d4b-57f1ddb7_0]  PartitionId [0]  Generation [1] Write session established. Init response: session_id: "dd6325aa-406a174d-4a846f43-5b4f84d5|36331218-54e20254-5672c3cc-50b9972a_0"
2025-11-11T14:16:22.030484Z :YDB_SDK TRACE: actor.cpp:37: 2025-11-11T14:16:22.030483Z :TRACE: [local] TRACE_EVENT InitResponse  partition_id=0 session_id=dd6325aa-406a174d-4a846f43-5b4f84d5|36331218-54e20254-5672c3cc-50b9972a_0
2025-11-11T14:16:22.030487Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:22.030486Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmqjs79hp24ued, TaskId: 2, PQ sink. ]  SessionId [dd6325aa-406a174d-4a846f43-5b4f84d5|36331218-54e20254-5672c3cc-50b9972a_0]  PartitionId [0]  Generation [1] Write session: set DirectWriteToPartitionId 0
2025-11-11T14:16:22.102754Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:746: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Commit state
2025-11-11T14:16:22.222224Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:314: Coordinator: TEvPing received, [2:7571471480450958475:2063]
2025-11-11T14:16:22.222240Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:317: Coordinator: Send TEvPong to [2:7571471480450958475:2063]
2025-11-11T14:16:22.472887Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: eddcb26f-38d004a5-9471148-3a628dd98, Host: ghrun-vb3yoermsa, Tenant: /compute
2025-11-11T14:16:22.477514Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-11T14:16:22.477525Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-11T14:16:22.895970Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:129: TxId: ptqudslmqjs79hp24ued, task: 2. Received input for channelId: 1, seqNo: 2, size: 0, chunks: 0, watermark: 0, checkpoint: 1, finished: 0, from: [2:7571471493335860588:2151], expected seqNo: 2
2025-11-11T14:16:22.895981Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:609: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. took input
2025-11-11T14:16:22.895992Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:485: [ptqudslmqjs79hp24ued-0] Task: 2. [Checkpoint 1.2] Got checkpoint barrier from channel 1
2025-11-11T14:16:22.896011Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:395: SelfId: [1:7571471495577973545:2141], TxId: ptqudslmqjs79hp24ued, task: 2. No watermark 
2025-11-11T14:16:22.896014Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1491: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Poll inputs
2025-11-11T14:16:22.896016Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1502: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-11-11T14:16:22.896018Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. DoExecuteImpl: 1
2025-11-11T14:16:22.896025Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:965: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Input data push finished. Cookie: 1 Watermark: (empty maybe) Ack: 1 TakeInputChannelDataRequests: 1
2025-11-11T14:16:22.896029Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:738: TxId: ptqudslmqjs79hp24ued, task: 2. Sending channel data ack to channelId: 1, peer: [2:7571471493335860587:2151], from: [1:7571471495577973543:2141], freeSpace: 1000000, seqNo: 2, finished: 0
2025-11-11T14:16:22.896115Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:510: SelfId: [1:7571471495577973545:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Pending 1 checkpoints to be sent
2025-11-11T14:16:22.896126Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1491: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Poll inputs
2025-11-11T14:16:22.896127Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1502: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-11-11T14:16:22.896128Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-11-11T14:16:22.896131Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. update task runner stats
2025-11-11T14:16:22.896164Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 1 watermark injected: (empty maybe)
2025-11-11T14:16:22.896166Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:447: [ptqudslmqjs79hp24ued-0] Task: 2. [Checkpoint 1.2] Performing task checkpoint
2025-11-11T14:16:22.896168Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:822: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Save state
2025-11-11T14:16:22.896169Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:474: [ptqudslmqjs79hp24ued-0] Task: 2. [Checkpoint 1.2] CA state saved
2025-11-11T14:16:22.896171Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:449: [ptqudslmqjs79hp24ued-0] Task: 2. [Checkpoint 1.2] Injecting checkpoint barrier to outputs
2025-11-11T14:16:22.896172Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-11T14:16:22.896177Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:571: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-11-11T14:16:22.896183Z :KQP_COMPUTE INFO: dq_async_compute_actor.cpp:1008: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Resume inputs
2025-11-11T14:16:22.896187Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:188: SelfId: [1:7571471499872940843:2141], TxId: ptqudslmqjs79hp24ued, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 1. Finished: 0
2025-11-11T14:16:22.896190Z :KQP_COMPUTE DEBUG: dq_pq_write_actor.cpp:233: SelfId: [1:7571471499872940843:2141], TxId: ptqudslmqjs79hp24ued, TaskId: 2, PQ sink. [Checkpoint 1.2] Send checkpoint state immediately
2025-11-11T14:16:22.896219Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:411: SelfId: [1:7571471499872940843:2141], TxId: ptqudslmqjs79hp24ued, TaskId: 2, PQ sink. Save checkpoint { Id: 2 Generation: 1 Type: CHECKPOINT_TYPE_SNAPSHOT } state: { SourceId: "dd6325aa-406a174d-4a846f43-5b4f84d5" }
2025-11-11T14:16:22.896222Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:524: [ptqudslmqjs79hp24ued-0] Task: 2. Sink[0] state saved
2025-11-11T14:16:22.896233Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:536: [ptqudslmqjs79hp24ued-0] Task: 2. [Checkpoint 1.2] Task checkpoint is done. Send to storage
2025-11-11T14:16:22.896240Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1023: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 6 bytes of checkpoint barrier
2025-11-11T14:16:22.896242Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1027: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-11-11T14:16:22.896248Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudslmqjs79hp24ued, task: 2. no poll, channelId: 1, has inflight messages: [2], last with freeSpace: 1000000, current freeSpace: 1000000
2025-11-11T14:16:22.896266Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1491: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Poll inputs
2025-11-11T14:16:22.896267Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1506: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Poll sources
2025-11-11T14:16:22.896268Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-11-11T14:16:22.896269Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. update task runner stats
2025-11-11T14:16:22.896275Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-11T14:16:22.896276Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-11T14:16:22.896278Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:571: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-11-11T14:16:22.896281Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:188: SelfId: [1:7571471499872940843:2141], TxId: ptqudslmqjs79hp24ued, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-11-11T14:16:22.896283Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1023: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-11-11T14:16:22.896285Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1027: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-11-11T14:16:22.896287Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudslmqjs79hp24ued, task: 2. no poll, channelId: 1, has inflight messages: [2], last with freeSpace: 1000000, current freeSpace: 1000000
2025-11-11T14:16:22.896297Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. update task runner stats
2025-11-11T14:16:22.896301Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-11T14:16:22.896302Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-11T14:16:22.896303Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:571: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-11-11T14:16:22.896305Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:188: SelfId: [1:7571471499872940843:2141], TxId: ptqudslmqjs79hp24ued, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-11-11T14:16:22.896307Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1023: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-11-11T14:16:22.896307Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1027: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-11-11T14:16:22.896309Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudslmqjs79hp24ued, task: 2. no poll, channelId: 1, has inflight messages: [2], last with freeSpace: 1000000, current freeSpace: 1000000
2025-11-11T14:16:22.896314Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:409: [ptqudslmqjs79hp24ued-0] [1:2] Got TEvSaveTaskState: task 2
2025-11-11T14:16:22.899132Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:433: [ptqudslmqjs79hp24ued-0] [1:2] TEvSaveTaskState Apply: task: 2
2025-11-11T14:16:22.899141Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:448: [ptqudslmqjs79hp24ued-0] [1:2] Send TEvSaveTaskStateResult: task: 2
2025-11-11T14:16:22.922057Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:746: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Commit state
2025-11-11T14:16:23.472295Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:617: RowDispatcher: Send ping to [1:7571471469808169584:2082]
2025-11-11T14:16:23.472320Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1161: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-11-11T14:16:23.472337Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:314: Coordinator: TEvPing received, [1:7571471469808169544:2063]
2025-11-11T14:16:23.472342Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:317: Coordinator: Send TEvPong to [1:7571471469808169544:2063]
2025-11-11T14:16:23.472359Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:623: RowDispatcher: NActors::TEvents::TEvPong
2025-11-11T14:16:23.473305Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: eddcb26f-38d004a5-9471148-3a628dd99, Host: ghrun-vb3yoermsa, Tenant: /compute
2025-11-11T14:16:23.476417Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-11T14:16:23.476427Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-11T14:16:23.864152Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:129: TxId: ptqudslmqjs79hp24ued, task: 2. Received input for channelId: 1, seqNo: 3, size: 0, chunks: 0, watermark: 0, checkpoint: 1, finished: 0, from: [2:7571471493335860588:2151], expected seqNo: 3
2025-11-11T14:16:23.864165Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:609: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. took input
2025-11-11T14:16:23.864188Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:485: [ptqudslmqjs79hp24ued-0] Task: 2. [Checkpoint 1.3] Got checkpoint barrier from channel 1
2025-11-11T14:16:23.864207Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:395: SelfId: [1:7571471495577973545:2141], TxId: ptqudslmqjs79hp24ued, task: 2. No watermark 
2025-11-11T14:16:23.864211Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1491: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Poll inputs
2025-11-11T14:16:23.864215Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1502: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-11-11T14:16:23.864216Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. DoExecuteImpl: 1
2025-11-11T14:16:23.864225Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:965: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Input data push finished. Cookie: 2 Watermark: (empty maybe) Ack: 1 TakeInputChannelDataRequests: 1
2025-11-11T14:16:23.864229Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:738: TxId: ptqudslmqjs79hp24ued, task: 2. Sending channel data ack to channelId: 1, peer: [2:7571471493335860587:2151], from: [1:7571471495577973543:2141], freeSpace: 1000000, seqNo: 3, finished: 0
2025-11-11T14:16:23.864326Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:510: SelfId: [1:7571471495577973545:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Pending 1 checkpoints to be sent
2025-11-11T14:16:23.864339Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1491: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Poll inputs
2025-11-11T14:16:23.864340Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1502: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-11-11T14:16:23.864342Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-11-11T14:16:23.864344Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. update task runner stats
2025-11-11T14:16:23.864369Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 1 watermark injected: (empty maybe)
2025-11-11T14:16:23.864372Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:447: [ptqudslmqjs79hp24ued-0] Task: 2. [Checkpoint 1.3] Performing task checkpoint
2025-11-11T14:16:23.864373Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:822: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Save state
2025-11-11T14:16:23.864375Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:474: [ptqudslmqjs79hp24ued-0] Task: 2. [Checkpoint 1.3] CA state saved
2025-11-11T14:16:23.864379Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:449: [ptqudslmqjs79hp24ued-0] Task: 2. [Checkpoint 1.3] Injecting checkpoint barrier to outputs
2025-11-11T14:16:23.864381Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-11T14:16:23.864384Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:571: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-11-11T14:16:23.864391Z :KQP_COMPUTE INFO: dq_async_compute_actor.cpp:1008: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Resume inputs
2025-11-11T14:16:23.864394Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:188: SelfId: [1:7571471499872940843:2141], TxId: ptqudslmqjs79hp24ued, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 1. Finished: 0
2025-11-11T14:16:23.864398Z :KQP_COMPUTE DEBUG: dq_pq_write_actor.cpp:233: SelfId: [1:7571471499872940843:2141], TxId: ptqudslmqjs79hp24ued, TaskId: 2, PQ sink. [Checkpoint 1.3] Send checkpoint state immediately
2025-11-11T14:16:23.864422Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:411: SelfId: [1:7571471499872940843:2141], TxId: ptqudslmqjs79hp24ued, TaskId: 2, PQ sink. Save checkpoint { Id: 3 Generation: 1 Type: CHECKPOINT_TYPE_SNAPSHOT } state: { SourceId: "dd6325aa-406a174d-4a846f43-5b4f84d5" }
2025-11-11T14:16:23.864433Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:524: [ptqudslmqjs79hp24ued-0] Task: 2. Sink[0] state saved
2025-11-11T14:16:23.864443Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:536: [ptqudslmqjs79hp24ued-0] Task: 2. [Checkpoint 1.3] Task checkpoint is done. Send to storage
2025-11-11T14:16:23.864450Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1023: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 6 bytes of checkpoint barrier
2025-11-11T14:16:23.864451Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1027: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-11-11T14:16:23.864458Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudslmqjs79hp24ued, task: 2. no poll, channelId: 1, has inflight messages: [3], last with freeSpace: 1000000, current freeSpace: 1000000
2025-11-11T14:16:23.864464Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:409: [ptqudslmqjs79hp24ued-0] [1:3] Got TEvSaveTaskState: task 2
2025-11-11T14:16:23.864475Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1491: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Poll inputs
2025-11-11T14:16:23.864476Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1506: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Poll sources
2025-11-11T14:16:23.864477Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-11-11T14:16:23.864479Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. update task runner stats
2025-11-11T14:16:23.864484Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-11T14:16:23.864486Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-11T14:16:23.864487Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:571: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-11-11T14:16:23.864491Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:188: SelfId: [1:7571471499872940843:2141], TxId: ptqudslmqjs79hp24ued, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-11-11T14:16:23.864492Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1023: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-11-11T14:16:23.864494Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1027: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-11-11T14:16:23.864496Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudslmqjs79hp24ued, task: 2. no poll, channelId: 1, has inflight messages: [3], last with freeSpace: 1000000, current freeSpace: 1000000
2025-11-11T14:16:23.864506Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. update task runner stats
2025-11-11T14:16:23.864514Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-11T14:16:23.864515Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-11T14:16:23.864516Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:571: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-11-11T14:16:23.864518Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:188: SelfId: [1:7571471499872940843:2141], TxId: ptqudslmqjs79hp24ued, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-11-11T14:16:23.864520Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1023: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-11-11T14:16:23.864521Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1027: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-11-11T14:16:23.864524Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudslmqjs79hp24ued, task: 2. no poll, channelId: 1, has inflight messages: [3], last with freeSpace: 1000000, current freeSpace: 1000000
2025-11-11T14:16:23.866888Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:433: [ptqudslmqjs79hp24ued-0] [1:3] TEvSaveTaskState Apply: task: 2
2025-11-11T14:16:23.866899Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:448: [ptqudslmqjs79hp24ued-0] [1:3] Send TEvSaveTaskStateResult: task: 2
2025-11-11T14:16:23.892732Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:746: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Commit state
2025-11-11T14:16:23.942411Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:314: Coordinator: TEvPing received, [3:7571471486365932951:2063]
2025-11-11T14:16:23.942427Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:317: Coordinator: Send TEvPong to [3:7571471486365932951:2063]
2025-11-11T14:16:24.011934Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:930: TopicSession [1:7571471499872940844:2142] SendStatistics
2025-11-11T14:16:24.011974Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1221: RowDispatcher: TEvSessionStatistic from [1:7571471499872940844:2142]
2025-11-11T14:16:24.012689Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:949: RowDispatcher: Received TEvHeartbeat from [2:7571471493335860590:2151], part id 0 query id ptqudslmqjs79hp24ued
2025-11-11T14:16:24.218564Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:314: Coordinator: TEvPing received, [2:7571471480450958475:2063]
2025-11-11T14:16:24.218582Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:317: Coordinator: Send TEvPong to [2:7571471480450958475:2063]
2025-11-11T14:16:24.473758Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: eddcb26f-38d004a5-9471148-3a628dd910, Host: ghrun-vb3yoermsa, Tenant: /compute
2025-11-11T14:16:24.477567Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-11T14:16:24.477580Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-11T14:16:24.869281Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:129: TxId: ptqudslmqjs79hp24ued, task: 2. Received input for channelId: 1, seqNo: 4, size: 0, chunks: 0, watermark: 0, checkpoint: 1, finished: 0, from: [2:7571471493335860588:2151], expected seqNo: 4
2025-11-11T14:16:24.869296Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:609: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. took input
2025-11-11T14:16:24.869310Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:485: [ptqudslmqjs79hp24ued-0] Task: 2. [Checkpoint 1.4] Got checkpoint barrier from channel 1
2025-11-11T14:16:24.869329Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:395: SelfId: [1:7571471495577973545:2141], TxId: ptqudslmqjs79hp24ued, task: 2. No watermark 
2025-11-11T14:16:24.869334Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1491: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Poll inputs
2025-11-11T14:16:24.869336Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1502: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-11-11T14:16:24.869341Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. DoExecuteImpl: 1
2025-11-11T14:16:24.869349Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:965: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Input data push finished. Cookie: 3 Watermark: (empty maybe) Ack: 1 TakeInputChannelDataRequests: 1
2025-11-11T14:16:24.869354Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:738: TxId: ptqudslmqjs79hp24ued, task: 2. Sending channel data ack to channelId: 1, peer: [2:7571471493335860587:2151], from: [1:7571471495577973543:2141], freeSpace: 1000000, seqNo: 4, finished: 0
2025-11-11T14:16:24.869501Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:510: SelfId: [1:7571471495577973545:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Pending 1 checkpoints to be sent
2025-11-11T14:16:24.869513Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1491: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Poll inputs
2025-11-11T14:16:24.869515Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1502: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-11-11T14:16:24.869517Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-11-11T14:16:24.869520Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. update task runner stats
2025-11-11T14:16:24.869547Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 1 watermark injected: (empty maybe)
2025-11-11T14:16:24.869551Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:447: [ptqudslmqjs79hp24ued-0] Task: 2. [Checkpoint 1.4] Performing task checkpoint
2025-11-11T14:16:24.869552Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:822: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Save state
2025-11-11T14:16:24.869555Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:474: [ptqudslmqjs79hp24ued-0] Task: 2. [Checkpoint 1.4] CA state saved
2025-11-11T14:16:24.869557Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:449: [ptqudslmqjs79hp24ued-0] Task: 2. [Checkpoint 1.4] Injecting checkpoint barrier to outputs
2025-11-11T14:16:24.869559Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-11T14:16:24.869563Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:571: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-11-11T14:16:24.869570Z :KQP_COMPUTE INFO: dq_async_compute_actor.cpp:1008: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Resume inputs
2025-11-11T14:16:24.869574Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:188: SelfId: [1:7571471499872940843:2141], TxId: ptqudslmqjs79hp24ued, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 1. Finished: 0
2025-11-11T14:16:24.869578Z :KQP_COMPUTE DEBUG: dq_pq_write_actor.cpp:233: SelfId: [1:7571471499872940843:2141], TxId: ptqudslmqjs79hp24ued, TaskId: 2, PQ sink. [Checkpoint 1.4] Send checkpoint state immediately
2025-11-11T14:16:24.869609Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:411: SelfId: [1:7571471499872940843:2141], TxId: ptqudslmqjs79hp24ued, TaskId: 2, PQ sink. Save checkpoint { Id: 4 Generation: 1 Type: CHECKPOINT_TYPE_SNAPSHOT } state: { SourceId: "dd6325aa-406a174d-4a846f43-5b4f84d5" }
2025-11-11T14:16:24.869614Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:524: [ptqudslmqjs79hp24ued-0] Task: 2. Sink[0] state saved
2025-11-11T14:16:24.869630Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:536: [ptqudslmqjs79hp24ued-0] Task: 2. [Checkpoint 1.4] Task checkpoint is done. Send to storage
2025-11-11T14:16:24.869638Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1023: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 6 bytes of checkpoint barrier
2025-11-11T14:16:24.869640Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1027: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-11-11T14:16:24.869649Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudslmqjs79hp24ued, task: 2. no poll, channelId: 1, has inflight messages: [4], last with freeSpace: 1000000, current freeSpace: 1000000
2025-11-11T14:16:24.869651Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:409: [ptqudslmqjs79hp24ued-0] [1:4] Got TEvSaveTaskState: task 2
2025-11-11T14:16:24.869676Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1491: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Poll inputs
2025-11-11T14:16:24.869677Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1506: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Poll sources
2025-11-11T14:16:24.869679Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-11-11T14:16:24.869681Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. update task runner stats
2025-11-11T14:16:24.869689Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-11T14:16:24.869690Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-11T14:16:24.869692Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:571: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-11-11T14:16:24.869697Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:188: SelfId: [1:7571471499872940843:2141], TxId: ptqudslmqjs79hp24ued, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-11-11T14:16:24.869710Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1023: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-11-11T14:16:24.869711Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1027: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-11-11T14:16:24.869715Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudslmqjs79hp24ued, task: 2. no poll, channelId: 1, has inflight messages: [4], last with freeSpace: 1000000, current freeSpace: 1000000
2025-11-11T14:16:24.869729Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. update task runner stats
2025-11-11T14:16:24.869735Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-11T14:16:24.869737Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-11T14:16:24.869738Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:571: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-11-11T14:16:24.869741Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:188: SelfId: [1:7571471499872940843:2141], TxId: ptqudslmqjs79hp24ued, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-11-11T14:16:24.869743Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1023: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-11-11T14:16:24.869744Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1027: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-11-11T14:16:24.869746Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudslmqjs79hp24ued, task: 2. no poll, channelId: 1, has inflight messages: [4], last with freeSpace: 1000000, current freeSpace: 1000000
2025-11-11T14:16:24.872544Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:433: [ptqudslmqjs79hp24ued-0] [1:4] TEvSaveTaskState Apply: task: 2
2025-11-11T14:16:24.872554Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:448: [ptqudslmqjs79hp24ued-0] [1:4] Send TEvSaveTaskStateResult: task: 2
2025-11-11T14:16:24.896500Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:746: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Commit state
2025-11-11T14:16:25.469097Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-11-11T14:16:25.473186Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:617: RowDispatcher: Send ping to [1:7571471469808169584:2082]
2025-11-11T14:16:25.473209Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1161: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-11-11T14:16:25.473241Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:314: Coordinator: TEvPing received, [1:7571471469808169544:2063]
2025-11-11T14:16:25.473244Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:317: Coordinator: Send TEvPong to [1:7571471469808169544:2063]
2025-11-11T14:16:25.473251Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:623: RowDispatcher: NActors::TEvents::TEvPong
2025-11-11T14:16:25.474213Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: eddcb26f-38d004a5-9471148-3a628dd911, Host: ghrun-vb3yoermsa, Tenant: /compute
2025-11-11T14:16:25.477080Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:389: Send NodeInfo with size: 2 to DynamicNameserver
2025-11-11T14:16:25.477105Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-11T14:16:25.477118Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-11T14:16:25.865690Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:129: TxId: ptqudslmqjs79hp24ued, task: 2. Received input for channelId: 1, seqNo: 5, size: 0, chunks: 0, watermark: 0, checkpoint: 1, finished: 0, from: [2:7571471493335860588:2151], expected seqNo: 5
2025-11-11T14:16:25.865705Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:609: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. took input
2025-11-11T14:16:25.865719Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:485: [ptqudslmqjs79hp24ued-0] Task: 2. [Checkpoint 1.5] Got checkpoint barrier from channel 1
2025-11-11T14:16:25.865739Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:395: SelfId: [1:7571471495577973545:2141], TxId: ptqudslmqjs79hp24ued, task: 2. No watermark 
2025-11-11T14:16:25.865743Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1491: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Poll inputs
2025-11-11T14:16:25.865748Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1502: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-11-11T14:16:25.865750Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. DoExecuteImpl: 1
2025-11-11T14:16:25.865757Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:965: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Input data push finished. Cookie: 4 Watermark: (empty maybe) Ack: 1 TakeInputChannelDataRequests: 1
2025-11-11T14:16:25.865763Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:738: TxId: ptqudslmqjs79hp24ued, task: 2. Sending channel data ack to channelId: 1, peer: [2:7571471493335860587:2151], from: [1:7571471495577973543:2141], freeSpace: 1000000, seqNo: 5, finished: 0
2025-11-11T14:16:25.865868Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:510: SelfId: [1:7571471495577973545:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Pending 1 checkpoints to be sent
2025-11-11T14:16:25.865878Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1491: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Poll inputs
2025-11-11T14:16:25.865880Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1502: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-11-11T14:16:25.865881Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-11-11T14:16:25.865884Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. update task runner stats
2025-11-11T14:16:25.865911Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 1 watermark injected: (empty maybe)
2025-11-11T14:16:25.865928Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:447: [ptqudslmqjs79hp24ued-0] Task: 2. [Checkpoint 1.5] Performing task checkpoint
2025-11-11T14:16:25.865929Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:822: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Save state
2025-11-11T14:16:25.865931Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:474: [ptqudslmqjs79hp24ued-0] Task: 2. [Checkpoint 1.5] CA state saved
2025-11-11T14:16:25.865933Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:449: [ptqudslmqjs79hp24ued-0] Task: 2. [Checkpoint 1.5] Injecting checkpoint barrier to outputs
2025-11-11T14:16:25.865935Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-11T14:16:25.865940Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:571: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-11-11T14:16:25.865947Z :KQP_COMPUTE INFO: dq_async_compute_actor.cpp:1008: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Resume inputs
2025-11-11T14:16:25.865951Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:188: SelfId: [1:7571471499872940843:2141], TxId: ptqudslmqjs79hp24ued, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 1. Finished: 0
2025-11-11T14:16:25.865954Z :KQP_COMPUTE DEBUG: dq_pq_write_actor.cpp:233: SelfId: [1:7571471499872940843:2141], TxId: ptqudslmqjs79hp24ued, TaskId: 2, PQ sink. [Checkpoint 1.5] Send checkpoint state immediately
2025-11-11T14:16:25.865985Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:411: SelfId: [1:7571471499872940843:2141], TxId: ptqudslmqjs79hp24ued, TaskId: 2, PQ sink. Save checkpoint { Id: 5 Generation: 1 Type: CHECKPOINT_TYPE_SNAPSHOT } state: { SourceId: "dd6325aa-406a174d-4a846f43-5b4f84d5" }
2025-11-11T14:16:25.865988Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:524: [ptqudslmqjs79hp24ued-0] Task: 2. Sink[0] state saved
2025-11-11T14:16:25.866011Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:536: [ptqudslmqjs79hp24ued-0] Task: 2. [Checkpoint 1.5] Task checkpoint is done. Send to storage
2025-11-11T14:16:25.866023Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1023: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 6 bytes of checkpoint barrier
2025-11-11T14:16:25.866025Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1027: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-11-11T14:16:25.866031Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:409: [ptqudslmqjs79hp24ued-0] [1:5] Got TEvSaveTaskState: task 2
2025-11-11T14:16:25.866033Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudslmqjs79hp24ued, task: 2. no poll, channelId: 1, has inflight messages: [5], last with freeSpace: 1000000, current freeSpace: 1000000
2025-11-11T14:16:25.866058Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1491: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Poll inputs
2025-11-11T14:16:25.866075Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1506: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Poll sources
2025-11-11T14:16:25.866081Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-11-11T14:16:25.866083Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. update task runner stats
2025-11-11T14:16:25.866094Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-11T14:16:25.866096Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-11T14:16:25.866098Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:571: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-11-11T14:16:25.866102Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:188: SelfId: [1:7571471499872940843:2141], TxId: ptqudslmqjs79hp24ued, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-11-11T14:16:25.866105Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1023: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-11-11T14:16:25.866106Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1027: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-11-11T14:16:25.866109Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudslmqjs79hp24ued, task: 2. no poll, channelId: 1, has inflight messages: [5], last with freeSpace: 1000000, current freeSpace: 1000000
2025-11-11T14:16:25.866126Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. update task runner stats
2025-11-11T14:16:25.866132Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-11T14:16:25.866134Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-11T14:16:25.866135Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:571: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-11-11T14:16:25.866138Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:188: SelfId: [1:7571471499872940843:2141], TxId: ptqudslmqjs79hp24ued, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-11-11T14:16:25.866140Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1023: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-11-11T14:16:25.866141Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1027: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-11-11T14:16:25.866144Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudslmqjs79hp24ued, task: 2. no poll, channelId: 1, has inflight messages: [5], last with freeSpace: 1000000, current freeSpace: 1000000
2025-11-11T14:16:25.868869Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:433: [ptqudslmqjs79hp24ued-0] [1:5] TEvSaveTaskState Apply: task: 2
2025-11-11T14:16:25.868880Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:448: [ptqudslmqjs79hp24ued-0] [1:5] Send TEvSaveTaskStateResult: task: 2
2025-11-11T14:16:25.891841Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:746: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Commit state
2025-11-11T14:16:25.943231Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:314: Coordinator: TEvPing received, [3:7571471486365932951:2063]
2025-11-11T14:16:25.943247Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:317: Coordinator: Send TEvPong to [3:7571471486365932951:2063]
2025-11-11T14:16:26.012817Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:930: TopicSession [1:7571471499872940844:2142] SendStatistics
2025-11-11T14:16:26.012861Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1221: RowDispatcher: TEvSessionStatistic from [1:7571471499872940844:2142]
2025-11-11T14:16:26.013719Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:949: RowDispatcher: Received TEvHeartbeat from [2:7571471493335860590:2151], part id 0 query id ptqudslmqjs79hp24ued
2025-11-11T14:16:26.224541Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:314: Coordinator: TEvPing received, [2:7571471480450958475:2063]
2025-11-11T14:16:26.224557Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:317: Coordinator: Send TEvPong to [2:7571471480450958475:2063]
2025-11-11T14:16:26.474644Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: eddcb26f-38d004a5-9471148-3a628dd912, Host: ghrun-vb3yoermsa, Tenant: /compute
2025-11-11T14:16:26.477828Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-11T14:16:26.477839Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-11T14:16:26.864631Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:129: TxId: ptqudslmqjs79hp24ued, task: 2. Received input for channelId: 1, seqNo: 6, size: 0, chunks: 0, watermark: 0, checkpoint: 1, finished: 0, from: [2:7571471493335860588:2151], expected seqNo: 6
2025-11-11T14:16:26.864643Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:609: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. took input
2025-11-11T14:16:26.864665Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:485: [ptqudslmqjs79hp24ued-0] Task: 2. [Checkpoint 1.6] Got checkpoint barrier from channel 1
2025-11-11T14:16:26.864684Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:395: SelfId: [1:7571471495577973545:2141], TxId: ptqudslmqjs79hp24ued, task: 2. No watermark 
2025-11-11T14:16:26.864689Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1491: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Poll inputs
2025-11-11T14:16:26.864693Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1502: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-11-11T14:16:26.864697Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. DoExecuteImpl: 1
2025-11-11T14:16:26.864706Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:965: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Input data push finished. Cookie: 5 Watermark: (empty maybe) Ack: 1 TakeInputChannelDataRequests: 1
2025-11-11T14:16:26.864711Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:738: TxId: ptqudslmqjs79hp24ued, task: 2. Sending channel data ack to channelId: 1, peer: [2:7571471493335860587:2151], from: [1:7571471495577973543:2141], freeSpace: 1000000, seqNo: 6, finished: 0
2025-11-11T14:16:26.864811Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:510: SelfId: [1:7571471495577973545:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Pending 1 checkpoints to be sent
2025-11-11T14:16:26.864826Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1491: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Poll inputs
2025-11-11T14:16:26.864828Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1502: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-11-11T14:16:26.864829Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-11-11T14:16:26.864832Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. update task runner stats
2025-11-11T14:16:26.864861Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 1 watermark injected: (empty maybe)
2025-11-11T14:16:26.864864Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:447: [ptqudslmqjs79hp24ued-0] Task: 2. [Checkpoint 1.6] Performing task checkpoint
2025-11-11T14:16:26.864866Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:822: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Save state
2025-11-11T14:16:26.864868Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:474: [ptqudslmqjs79hp24ued-0] Task: 2. [Checkpoint 1.6] CA state saved
2025-11-11T14:16:26.864871Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:449: [ptqudslmqjs79hp24ued-0] Task: 2. [Checkpoint 1.6] Injecting checkpoint barrier to outputs
2025-11-11T14:16:26.864873Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-11T14:16:26.864876Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:571: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-11-11T14:16:26.864884Z :KQP_COMPUTE INFO: dq_async_compute_actor.cpp:1008: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Resume inputs
2025-11-11T14:16:26.864888Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:188: SelfId: [1:7571471499872940843:2141], TxId: ptqudslmqjs79hp24ued, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 1. Finished: 0
2025-11-11T14:16:26.864892Z :KQP_COMPUTE DEBUG: dq_pq_write_actor.cpp:233: SelfId: [1:7571471499872940843:2141], TxId: ptqudslmqjs79hp24ued, TaskId: 2, PQ sink. [Checkpoint 1.6] Send checkpoint state immediately
2025-11-11T14:16:26.864925Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:411: SelfId: [1:7571471499872940843:2141], TxId: ptqudslmqjs79hp24ued, TaskId: 2, PQ sink. Save checkpoint { Id: 6 Generation: 1 Type: CHECKPOINT_TYPE_SNAPSHOT } state: { SourceId: "dd6325aa-406a174d-4a846f43-5b4f84d5" }
2025-11-11T14:16:26.864930Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:524: [ptqudslmqjs79hp24ued-0] Task: 2. Sink[0] state saved
2025-11-11T14:16:26.864942Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:536: [ptqudslmqjs79hp24ued-0] Task: 2. [Checkpoint 1.6] Task checkpoint is done. Send to storage
2025-11-11T14:16:26.864950Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1023: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 6 bytes of checkpoint barrier
2025-11-11T14:16:26.864952Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1027: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-11-11T14:16:26.864953Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:409: [ptqudslmqjs79hp24ued-0] [1:6] Got TEvSaveTaskState: task 2
2025-11-11T14:16:26.864959Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudslmqjs79hp24ued, task: 2. no poll, channelId: 1, has inflight messages: [6], last with freeSpace: 1000000, current freeSpace: 1000000
2025-11-11T14:16:26.864993Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1491: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Poll inputs
2025-11-11T14:16:26.864994Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1506: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Poll sources
2025-11-11T14:16:26.864996Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-11-11T14:16:26.864998Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. update task runner stats
2025-11-11T14:16:26.865007Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-11T14:16:26.865009Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-11T14:16:26.865010Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:571: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-11-11T14:16:26.865014Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:188: SelfId: [1:7571471499872940843:2141], TxId: ptqudslmqjs79hp24ued, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-11-11T14:16:26.865016Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1023: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-11-11T14:16:26.865018Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1027: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-11-11T14:16:26.865020Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudslmqjs79hp24ued, task: 2. no poll, channelId: 1, has inflight messages: [6], last with freeSpace: 1000000, current freeSpace: 1000000
2025-11-11T14:16:26.865034Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. update task runner stats
2025-11-11T14:16:26.865040Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-11T14:16:26.865043Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-11T14:16:26.865044Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:571: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-11-11T14:16:26.865047Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:188: SelfId: [1:7571471499872940843:2141], TxId: ptqudslmqjs79hp24ued, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-11-11T14:16:26.865049Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1023: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-11-11T14:16:26.865051Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1027: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-11-11T14:16:26.865053Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudslmqjs79hp24ued, task: 2. no poll, channelId: 1, has inflight messages: [6], last with freeSpace: 1000000, current freeSpace: 1000000
2025-11-11T14:16:26.867143Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:433: [ptqudslmqjs79hp24ued-0] [1:6] TEvSaveTaskState Apply: task: 2
2025-11-11T14:16:26.867154Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:448: [ptqudslmqjs79hp24ued-0] [1:6] Send TEvSaveTaskStateResult: task: 2
2025-11-11T14:16:26.891200Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:746: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Commit state
2025-11-11T14:16:27.013288Z :FQ_ROW_DISPATCHER INFO: topic_session.cpp:497: TopicSession [1:7571471499872940844:2142] Create topic session, Path test_metadatafields_input/0, StartingMessageTimestamp 2025-11-11T14:16:21.816000Z, BufferSize 16000000, GetConsumerMode Without
2025-11-11T14:16:27.013331Z :YDB_SDK INFO: actor.cpp:37: 2025-11-11T14:16:27.013326Z :INFO: [local] [local] [fa89730-e51c5d40-6ff84d0d-4754ec8] Starting read session
2025-11-11T14:16:27.013337Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:27.013334Z :DEBUG: [local] [local] [fa89730-e51c5d40-6ff84d0d-4754ec8] Starting single session
2025-11-11T14:16:27.013383Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:27.013381Z :DEBUG: [local] [local] [fa89730-e51c5d40-6ff84d0d-4754ec8] [] In Reconnect, ReadSizeBudget = 8000000, ReadSizeServerDelta = 0
2025-11-11T14:16:27.013391Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:27.013390Z :DEBUG: [local] [local] [fa89730-e51c5d40-6ff84d0d-4754ec8] [] New values: ReadSizeBudget = 8000000, ReadSizeServerDelta = 0
2025-11-11T14:16:27.013397Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:27.013395Z :DEBUG: [local] [local] [fa89730-e51c5d40-6ff84d0d-4754ec8] [] Reconnecting session to cluster  in 0.000000s
2025-11-11T14:16:27.013597Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:447: TopicSession [1:7571471499872940844:2142] SubscribeOnNextEvent
2025-11-11T14:16:27.014437Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:27.014429Z :DEBUG: [local] [local] [fa89730-e51c5d40-6ff84d0d-4754ec8] [] Successfully connected. Initializing session
2025-11-11T14:16:27.017269Z :YDB_SDK INFO: actor.cpp:37: 2025-11-11T14:16:27.017261Z :INFO: [local] [local] [fa89730-e51c5d40-6ff84d0d-4754ec8] [] Got InitResponse. ReadSessionId: _1_7_15379067829846780857_v1
2025-11-11T14:16:27.017293Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:27.017279Z :DEBUG: [local] [local] [fa89730-e51c5d40-6ff84d0d-4754ec8] [] In ContinueReadingDataImpl, ReadSizeBudget = 8000000, ReadSizeServerDelta = 0
2025-11-11T14:16:27.017372Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:27.017370Z :DEBUG: [local] [local] [fa89730-e51c5d40-6ff84d0d-4754ec8] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 8000000
2025-11-11T14:16:27.020059Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:540: TopicSession [1:7571471499872940844:2142] TEvPqEventsReady
2025-11-11T14:16:27.020077Z :FQ_ROW_DISPATCHER DEBUG: topic_session.cpp:655: TopicSession [1:7571471499872940844:2142] StartPartitionSessionEvent received
2025-11-11T14:16:27.020081Z :FQ_ROW_DISPATCHER DEBUG: topic_session.cpp:663: TopicSession [1:7571471499872940844:2142] Confirm StartPartitionSession with offset (NULL)
2025-11-11T14:16:27.020093Z :YDB_SDK INFO: actor.cpp:37: 2025-11-11T14:16:27.020088Z :INFO: [local] [local] [fa89730-e51c5d40-6ff84d0d-4754ec8] [] Confirm partition stream create. Partition stream id: 1. Cluster: "-". Topic: "test_metadatafields_input". Partition: 0. Read offset: (NULL)
2025-11-11T14:16:27.020158Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:447: TopicSession [1:7571471499872940844:2142] SubscribeOnNextEvent
2025-11-11T14:16:27.020796Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:27.020790Z :DEBUG: [local] [local] [fa89730-e51c5d40-6ff84d0d-4754ec8] [] Got ReadResponse, serverBytesSize = 151, now ReadSizeBudget = 0, ReadSizeServerDelta = 7999849
2025-11-11T14:16:27.020826Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:27.020824Z :DEBUG: [local] [local] [fa89730-e51c5d40-6ff84d0d-4754ec8] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 7999849
2025-11-11T14:16:27.020871Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:27.020868Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (0-2)
2025-11-11T14:16:27.020889Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:27.020887Z :DEBUG: [local] [local] [fa89730-e51c5d40-6ff84d0d-4754ec8] [] Returning serverBytesSize = 151 to budget
2025-11-11T14:16:27.020893Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:27.020890Z :DEBUG: [local] [local] [fa89730-e51c5d40-6ff84d0d-4754ec8] [] In ContinueReadingDataImpl, ReadSizeBudget = 151, ReadSizeServerDelta = 7999849
2025-11-11T14:16:27.020928Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:27.020925Z :DEBUG: [local] [local] [fa89730-e51c5d40-6ff84d0d-4754ec8] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 8000000
2025-11-11T14:16:27.020958Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:540: TopicSession [1:7571471499872940844:2142] TEvPqEventsReady
2025-11-11T14:16:27.020975Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:27.020973Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-11-11T14:16:27.020986Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:27.020985Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (1-1)
2025-11-11T14:16:27.020991Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:27.020990Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 1} (2-2)
2025-11-11T14:16:27.021001Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:27.020999Z :DEBUG: [local] [local] [fa89730-e51c5d40-6ff84d0d-4754ec8] [] The application data is transferred to the client. Number of messages 3, size 39 bytes
2025-11-11T14:16:27.021010Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:27.021008Z :DEBUG: [local] [local] [fa89730-e51c5d40-6ff84d0d-4754ec8] [] Returning serverBytesSize = 0 to budget
2025-11-11T14:16:27.021026Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:632: TopicSession [1:7571471499872940844:2142] Data received: Message { Data: "{"time": 100}" Information: { Offset: 0 ProducerId: "" SeqNo: 0 CreateTime: 2025-11-11T14:16:22.696000Z WriteTime: 2025-11-11T14:16:22.696000Z MessageGroupId: "" Meta: { } MessageMeta: { } } Partition session id: 1 Topic: "test_metadatafields_input" Partition: 0 }
2025-11-11T14:16:27.021030Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:632: TopicSession [1:7571471499872940844:2142] Data received: Message { Data: "{"time": 109}" Information: { Offset: 1 ProducerId: "" SeqNo: 0 CreateTime: 2025-11-11T14:16:22.696000Z WriteTime: 2025-11-11T14:16:22.702000Z MessageGroupId: "" Meta: { } MessageMeta: { } } Partition session id: 1 Topic: "test_metadatafields_input" Partition: 0 }
2025-11-11T14:16:27.021034Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:632: TopicSession [1:7571471499872940844:2142] Data received: Message { Data: "{"time": 118}" Information: { Offset: 2 ProducerId: "" SeqNo: 0 CreateTime: 2025-11-11T14:16:22.696000Z WriteTime: 2025-11-11T14:16:22.702000Z MessageGroupId: "" Meta: { } MessageMeta: { } } Partition session id: 1 Topic: "test_metadatafields_input" Partition: 0 }
2025-11-11T14:16:27.021037Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:685: TopicSession [1:7571471499872940844:2142] SendToParsing, messages: 3
2025-11-11T14:16:27.021041Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:417: TTopicFormatHandler [json_each_row]: Send 3 messages to parser
2025-11-11T14:16:27.021045Z :FQ_ROW_DISPATCHER TRACE: json_parser.cpp:396: TJsonParser: Add 3 messages to parse
2025-11-11T14:16:27.021053Z :FQ_ROW_DISPATCHER TRACE: json_parser.cpp:462: TJsonParser: Do parsing, first offset: 0, values:
{"time": 100}{"time": 109}{"time": 118}                                                                
2025-11-11T14:16:27.021056Z :FQ_ROW_DISPATCHER TRACE: json_parser.cpp:598: TJsonParser: Init parser, skipped 0, outputRowId 0 size 103
2025-11-11T14:16:27.021077Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:77: TTopicFormatHandler [json_each_row]: TParserHandler: Got parsed data, number rows: 3
2025-11-11T14:16:27.021084Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:614: TTopicFormatHandler [json_each_row]: Send 3 messages to programs, first offset: 0, last offset: 2
2025-11-11T14:16:27.021087Z :FQ_ROW_DISPATCHER TRACE: filters_set.cpp:34: TTopicFilters: ProcessData for 1 clients, number rows: 3
2025-11-11T14:16:27.021093Z :FQ_ROW_DISPATCHER TRACE: filters_set.cpp:223: TTopicFilters: Pass 3 rows to purecalc filter (client id: [2:7571471493335860590:2151])
2025-11-11T14:16:27.021096Z :FQ_ROW_DISPATCHER TRACE: purecalc_filter.cpp:408: TProgramRunHandler: ProcessData for 3 rows
2025-11-11T14:16:27.021099Z :FQ_ROW_DISPATCHER TRACE: purecalc_filter.cpp:411: TProgramRunHandler: Add 3 rows to client [2:7571471493335860590:2151] without processing
2025-11-11T14:16:27.036655Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:292: TTopicFormatHandler [json_each_row]: TClientHandler [2:7571471493335860590:2151]: OnBatchFinish, offset: 0, number rows: 1, row size: 12, watermark: (empty maybe)
2025-11-11T14:16:27.036672Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:187: TopicSession [1:7571471499872940844:2142] AddDataToClient to [2:7571471493335860590:2151], offset: 0, number rows: 1, row size: 12, watermark: (empty maybe)
2025-11-11T14:16:27.036674Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:914: TopicSession [1:7571471499872940844:2142] Send TEvNewDataArrived to [2:7571471493335860590:2151]
2025-11-11T14:16:27.036704Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1068: RowDispatcher: Forward TEvNewDataArrived from [1:7571471499872940844:2142] to [2:7571471493335860590:2151] query id ptqudslmqjs79hp24ued
2025-11-11T14:16:27.036886Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:292: TTopicFormatHandler [json_each_row]: TClientHandler [2:7571471493335860590:2151]: OnBatchFinish, offset: 1, number rows: 1, row size: 4, watermark: (empty maybe)
2025-11-11T14:16:27.036895Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:187: TopicSession [1:7571471499872940844:2142] AddDataToClient to [2:7571471493335860590:2151], offset: 1, number rows: 1, row size: 4, watermark: (empty maybe)
2025-11-11T14:16:27.036897Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:292: TTopicFormatHandler [json_each_row]: TClientHandler [2:7571471493335860590:2151]: OnBatchFinish, offset: 2, number rows: 1, row size: 4, watermark: (empty maybe)
2025-11-11T14:16:27.036900Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:187: TopicSession [1:7571471499872940844:2142] AddDataToClient to [2:7571471493335860590:2151], offset: 2, number rows: 1, row size: 4, watermark: (empty maybe)
2025-11-11T14:16:27.036905Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:622: TTopicFormatHandler [json_each_row]: Commit client [2:7571471493335860590:2151] offset 2
2025-11-11T14:16:27.036909Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:199: TopicSession [1:7571471499872940844:2142] UpdateClientOffset for [2:7571471493335860590:2151], new offset: 2
2025-11-11T14:16:27.036932Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:447: TopicSession [1:7571471499872940844:2142] SubscribeOnNextEvent
2025-11-11T14:16:27.037217Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:927: RowDispatcher: Received TEvGetNextBatch from [2:7571471493335860590:2151] part id 0 query id ptqudslmqjs79hp24ued
2025-11-11T14:16:27.037233Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:569: TopicSession [1:7571471499872940844:2142] TEvGetNextBatch from [2:7571471493335860590:2151]
2025-11-11T14:16:27.037243Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:324: TTopicFormatHandler [json_each_row]: TClientHandler [2:7571471493335860590:2151]: FinishPacking, batch size: 20, number rows: 3
2025-11-11T14:16:27.037253Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:174: TTopicFormatHandler [json_each_row]: TClientHandler [2:7571471493335860590:2151]: ExtractClientData, number batches: 1
2025-11-11T14:16:27.037261Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:742: TopicSession [1:7571471499872940844:2142] SendData to [2:7571471493335860590:2151], batch size 1
2025-11-11T14:16:27.037273Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:438: TopicSession [1:7571471499872940844:2142] Skip SubscribeOnNextEvent, has ReadSession: true, IsWaitingEvents: 1
2025-11-11T14:16:27.037282Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1087: RowDispatcher: Forward TEvMessageBatch from [1:7571471499872940844:2142] to [2:7571471493335860590:2151] query id ptqudslmqjs79hp24ued
2025-11-11T14:16:27.038051Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:129: TxId: ptqudslmqjs79hp24ued, task: 2. Received input for channelId: 1, seqNo: 7, size: 29, chunks: 3, watermark: 0, checkpoint: 0, finished: 0, from: [2:7571471493335860588:2151], expected seqNo: 7
2025-11-11T14:16:27.038060Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:609: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. took input
2025-11-11T14:16:27.038080Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:395: SelfId: [1:7571471495577973545:2141], TxId: ptqudslmqjs79hp24ued, task: 2. No watermark 
2025-11-11T14:16:27.038085Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:965: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Input data push finished. Cookie: 6 Watermark: (empty maybe) Ack: 1 TakeInputChannelDataRequests: 1
2025-11-11T14:16:27.038089Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:738: TxId: ptqudslmqjs79hp24ued, task: 2. Sending channel data ack to channelId: 1, peer: [2:7571471493335860587:2151], from: [1:7571471495577973543:2141], freeSpace: 999971, seqNo: 7, finished: 0
2025-11-11T14:16:27.038101Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1491: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Poll inputs
2025-11-11T14:16:27.038106Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1506: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Poll sources
2025-11-11T14:16:27.038109Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-11-11T14:16:27.038429Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. update task runner stats
2025-11-11T14:16:27.038460Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-11T14:16:27.038466Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-11T14:16:27.038470Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:571: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-11-11T14:16:27.038479Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:188: SelfId: [1:7571471499872940843:2141], TxId: ptqudslmqjs79hp24ued, TaskId: 2, PQ sink. SendData. Batch: 1. Checkpoint: 0. Finished: 0
2025-11-11T14:16:27.038483Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:214: SelfId: [1:7571471499872940843:2141], TxId: ptqudslmqjs79hp24ued, TaskId: 2, PQ sink. Received data for sending: {"b_key":100}
2025-11-11T14:16:27.038508Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:27.038504Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmqjs79hp24ued, TaskId: 2, PQ sink. ]  SessionId [dd6325aa-406a174d-4a846f43-5b4f84d5|36331218-54e20254-5672c3cc-50b9972a_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 1 to 1
2025-11-11T14:16:27.038526Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:27.038524Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmqjs79hp24ued, TaskId: 2, PQ sink. ]  SessionId [dd6325aa-406a174d-4a846f43-5b4f84d5|36331218-54e20254-5672c3cc-50b9972a_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-11-11T14:16:27.038536Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:27.038535Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmqjs79hp24ued, TaskId: 2, PQ sink. ]  SessionId [dd6325aa-406a174d-4a846f43-5b4f84d5|36331218-54e20254-5672c3cc-50b9972a_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 1
2025-11-11T14:16:27.038661Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1023: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Sink 0: sent 17 bytes of data and 0 bytes of checkpoint barrier
2025-11-11T14:16:27.038668Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1027: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 13, sent data from buffer: 17
2025-11-11T14:16:27.038674Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:629: TxId: ptqudslmqjs79hp24ued, task: 2. do poll, channelId: 1, last freeSpace: 999971, current freeSpace: 1000000, seqNo: 7
2025-11-11T14:16:27.038677Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:639: TxId: ptqudslmqjs79hp24ued, task: 2. Poll input channelId: 1, from: [2:7571471493335860587:2151], seqNo: 7, freeSpace: 1000000
2025-11-11T14:16:27.038681Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:738: TxId: ptqudslmqjs79hp24ued, task: 2. Sending channel data ack to channelId: 1, peer: [2:7571471493335860587:2151], from: [1:7571471495577973543:2141], freeSpace: 1000000, seqNo: 7, finished: 0
2025-11-11T14:16:27.040149Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:27.040142Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmqjs79hp24ued, TaskId: 2, PQ sink. ]  SessionId [dd6325aa-406a174d-4a846f43-5b4f84d5|36331218-54e20254-5672c3cc-50b9972a_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-11-11T14:16:27.040193Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:27.040191Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmqjs79hp24ued, TaskId: 2, PQ sink. ]  SessionId [dd6325aa-406a174d-4a846f43-5b4f84d5|36331218-54e20254-5672c3cc-50b9972a_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 1 written { } } 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:16:27.040198Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:27.040196Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmqjs79hp24ued, TaskId: 2, PQ sink. ]  SessionId [dd6325aa-406a174d-4a846f43-5b4f84d5|36331218-54e20254-5672c3cc-50b9972a_0]  PartitionId [0]  Generation [1] OnAck: seqNo=1, txId=?
2025-11-11T14:16:27.040202Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:27.040201Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmqjs79hp24ued, TaskId: 2, PQ sink. ]  SessionId [dd6325aa-406a174d-4a846f43-5b4f84d5|36331218-54e20254-5672c3cc-50b9972a_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 1
2025-11-11T14:16:27.041489Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:447: SelfId: [1:7571471499872940843:2141], TxId: ptqudslmqjs79hp24ued, TaskId: 2, PQ sink. Ack seq no 1
2025-11-11T14:16:27.104243Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:451: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Got TEvStateRequest from actor [2:7571471493335860585:2149] PingCookie: 2
2025-11-11T14:16:27.104267Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. update task runner stats
2025-11-11T14:16:27.474115Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:617: RowDispatcher: Send ping to [1:7571471469808169584:2082]
2025-11-11T14:16:27.474133Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1161: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-11-11T14:16:27.474154Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:314: Coordinator: TEvPing received, [1:7571471469808169544:2063]
2025-11-11T14:16:27.474160Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:317: Coordinator: Send TEvPong to [1:7571471469808169544:2063]
2025-11-11T14:16:27.474187Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:623: RowDispatcher: NActors::TEvents::TEvPong
2025-11-11T14:16:27.475093Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: eddcb26f-38d004a5-9471148-3a628dd913, Host: ghrun-vb3yoermsa, Tenant: /compute
2025-11-11T14:16:27.478637Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-11T14:16:27.478647Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-11T14:16:27.806160Z :KQP_COMPUTE ERROR: dq_compute_actor_impl.h:1215: SelfId: [1:7571471495577973543:2141], TxId: ptqudslmqjs79hp24ued, task: 2. Ctx: {}. Handle abort execution event from: [1:7571471469808169545:2064], status: UNAVAILABLE, reason: { <main>: Error: Aborted by LWM }
2025-11-11T14:16:27.806210Z :KQP_COMPUTE DEBUG: dq_compute_actor_channels.cpp:494: TxId: ptqudslmqjs79hp24ued, task: 2. pass away
2025-11-11T14:16:27.807296Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:988: RowDispatcher: Received TEvStopSession from [2:7571471493335860590:2151] topic test_metadatafields_input query id ptqudslmqjs79hp24ued
2025-11-11T14:16:27.807321Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:1003: RowDispatcher: DeleteConsumer, readActorId [2:7571471493335860590:2151] query id ptqudslmqjs79hp24ued, partitions size 1
2025-11-11T14:16:27.807344Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:1023: RowDispatcher: Session is not used, sent TEvPoisonPill to [1:7571471499872940844:2142]
2025-11-11T14:16:27.807371Z :FQ_ROW_DISPATCHER DEBUG: topic_session.cpp:809: TopicSession [1:7571471499872940844:2142] TEvStopSession from [2:7571471493335860590:2151] topicPath test_metadatafields_input clients count 1
2025-11-11T14:16:27.807390Z :FQ_ROW_DISPATCHER DEBUG: format_handler.cpp:477: TTopicFormatHandler [json_each_row]: Remove client with id [2:7571471493335860590:2151]
2025-11-11T14:16:27.807394Z :FQ_ROW_DISPATCHER TRACE: filters_set.cpp:94: TTopicFilters: Remove program with client id [2:7571471493335860590:2151]
2025-11-11T14:16:27.807409Z :FQ_ROW_DISPATCHER DEBUG: format_handler.cpp:559: TTopicFormatHandler [json_each_row]: UpdateParser to new schema with size 0
2025-11-11T14:16:27.807412Z :FQ_ROW_DISPATCHER INFO: format_handler.cpp:584: TTopicFormatHandler [json_each_row]: No columns to parse, reset parser
2025-11-11T14:16:27.807586Z :FQ_ROW_DISPATCHER DEBUG: topic_session.cpp:902: TopicSession [1:7571471499872940844:2142] Close read session
2025-11-11T14:16:27.807603Z :YDB_SDK INFO: actor.cpp:37: 2025-11-11T14:16:27.807598Z :INFO: [local] [local] [fa89730-e51c5d40-6ff84d0d-4754ec8] Closing read session. Close timeout: 0.000000s
2025-11-11T14:16:27.807617Z :YDB_SDK INFO: actor.cpp:37: 2025-11-11T14:16:27.807615Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:test_metadatafields_input:0:1:2:0
2025-11-11T14:16:27.807630Z :YDB_SDK INFO: actor.cpp:37: 2025-11-11T14:16:27.807628Z :INFO: [local] [local] [fa89730-e51c5d40-6ff84d0d-4754ec8] Counters: { Errors: 0 CurrentSessionLifetimeMs: 794 BytesRead: 39 MessagesRead: 3 BytesReadCompressed: 39 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:16:27.807647Z :YDB_SDK NOTICE: actor.cpp:37: 2025-11-11T14:16:27.807645Z :NOTICE: [local] [local] [fa89730-e51c5d40-6ff84d0d-4754ec8] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Close with zero timeout " }
2025-11-11T14:16:27.807660Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:27.807658Z :DEBUG: [local] [local] [fa89730-e51c5d40-6ff84d0d-4754ec8] [] Abort session to cluster
2025-11-11T14:16:27.807810Z :YDB_SDK INFO: actor.cpp:37: 2025-11-11T14:16:27.807807Z :INFO: [local] [local] [fa89730-e51c5d40-6ff84d0d-4754ec8] Closing read session. Close timeout: 0.000000s
2025-11-11T14:16:27.807818Z :YDB_SDK INFO: actor.cpp:37: 2025-11-11T14:16:27.807816Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:test_metadatafields_input:0:1:2:0
2025-11-11T14:16:27.807822Z :YDB_SDK INFO: actor.cpp:37: 2025-11-11T14:16:27.807820Z :INFO: [local] [local] [fa89730-e51c5d40-6ff84d0d-4754ec8] Counters: { Errors: 0 CurrentSessionLifetimeMs: 794 BytesRead: 39 MessagesRead: 3 BytesReadCompressed: 39 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-11T14:16:27.807829Z :YDB_SDK NOTICE: actor.cpp:37: 2025-11-11T14:16:27.807828Z :NOTICE: [local] [local] [fa89730-e51c5d40-6ff84d0d-4754ec8] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-11-11T14:16:27.807860Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:438: TopicSession [1:7571471499872940844:2142] Skip SubscribeOnNextEvent, has ReadSession: false, IsWaitingEvents: 1
2025-11-11T14:16:27.807864Z :YDB_SDK INFO: actor.cpp:37: 2025-11-11T14:16:27.807857Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmqjs79hp24ued, TaskId: 2, PQ sink. ]  SessionId [dd6325aa-406a174d-4a846f43-5b4f84d5|36331218-54e20254-5672c3cc-50b9972a_0]  PartitionId [0]  Generation [1] Write session: close. Timeout 0.000000s
2025-11-11T14:16:27.807869Z :YDB_SDK INFO: actor.cpp:37: 2025-11-11T14:16:27.807867Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmqjs79hp24ued, TaskId: 2, PQ sink. ]  SessionId [dd6325aa-406a174d-4a846f43-5b4f84d5|36331218-54e20254-5672c3cc-50b9972a_0]  PartitionId [0]  Generation [1] Write session will now close
2025-11-11T14:16:27.807881Z :FQ_ROW_DISPATCHER DEBUG: topic_session.cpp:430: TopicSession [1:7571471499872940844:2142] PassAway
2025-11-11T14:16:27.807887Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:27.807885Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmqjs79hp24ued, TaskId: 2, PQ sink. ]  SessionId [dd6325aa-406a174d-4a846f43-5b4f84d5|36331218-54e20254-5672c3cc-50b9972a_0]  PartitionId [0]  Generation [1] Write session: aborting
2025-11-11T14:16:27.807918Z :YDB_SDK INFO: actor.cpp:37: 2025-11-11T14:16:27.807916Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmqjs79hp24ued, TaskId: 2, PQ sink. ]  SessionId [dd6325aa-406a174d-4a846f43-5b4f84d5|36331218-54e20254-5672c3cc-50b9972a_0]  PartitionId [0]  Generation [1] Write session: gracefully shut down, all writes complete
2025-11-11T14:16:27.807922Z :YDB_SDK DEBUG: actor.cpp:37: 2025-11-11T14:16:27.807920Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudslmqjs79hp24ued, TaskId: 2, PQ sink. ]  SessionId [dd6325aa-406a174d-4a846f43-5b4f84d5|36331218-54e20254-5672c3cc-50b9972a_0]  PartitionId [0]  Generation [1] Write session: destroy
2025-11-11T14:16:27.944164Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:314: Coordinator: TEvPing received, [3:7571471486365932951:2063]
2025-11-11T14:16:27.944179Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:317: Coordinator: Send TEvPong to [3:7571471486365932951:2063]
2025-11-11T14:16:28.014747Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1046: RowDispatcher: No consumer with EventQueueId = 0
2025-11-11T14:16:28.220343Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:314: Coordinator: TEvPing received, [2:7571471480450958475:2063]
2025-11-11T14:16:28.220359Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:317: Coordinator: Send TEvPong to [2:7571471480450958475:2063]
2025-11-11T14:16:28.475552Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: eddcb26f-38d004a5-9471148-3a628dd914, Host: ghrun-vb3yoermsa, Tenant: /compute
2025-11-11T14:16:28.480054Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-11T14:16:28.480072Z :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:25213: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-vb3yoermsa.auto.internal:25213
2025-11-11T14:16:29.474972Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:617: RowDispatcher: Send ping to [1:7571471469808169584:2082]
2025-11-11T14:16:29.474998Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1161: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-11-11T14:16:29.475005Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:314: Coordinator: TEvPing received, [1:7571471469808169544:2063]
2025-11-11T14:16:29.475009Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:317: Coordinator: Send TEvPong to [1:7571471469808169544:2063]
2025-11-11T14:16:29.475014Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:623: RowDispatcher: NActors::TEvents::TEvPong
2025-11-11T14:16:29.475997Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: eddcb26f-38d004a5-9471148-3a628dd915, Host: ghrun-vb3yoermsa, Tenant: /compute
2025-11-11T14:16:29.481153Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-11T14:16:29.481173Z :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:25213: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-vb3yoermsa.auto.internal:25213
2025-11-11T14:16:29.945009Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:314: Coordinator: TEvPing received, [3:7571471486365932951:2063]
2025-11-11T14:16:29.945036Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:317: Coordinator: Send TEvPong to [3:7571471486365932951:2063]
2025-11-11T14:16:30.221245Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:314: Coordinator: TEvPing received, [2:7571471480450958475:2063]
2025-11-11T14:16:30.221260Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:317: Coordinator: Send TEvPong to [2:7571471480450958475:2063]
2025-11-11T14:16:30.469279Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-11-11T14:16:30.476431Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: eddcb26f-38d004a5-9471148-3a628dd916, Host: ghrun-vb3yoermsa, Tenant: /compute
2025-11-11T14:16:30.477265Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-11T14:16:30.477281Z :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:25213: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-vb3yoermsa.auto.internal:25213
2025-11-11T14:16:30.477333Z :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:25213: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-vb3yoermsa.auto.internal:25213
2025-11-11T14:16:31.475880Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:617: RowDispatcher: Send ping to [1:7571471469808169584:2082]
2025-11-11T14:16:31.475919Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1161: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-11-11T14:16:31.475925Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:314: Coordinator: TEvPing received, [1:7571471469808169544:2063]
2025-11-11T14:16:31.475927Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:317: Coordinator: Send TEvPong to [1:7571471469808169544:2063]
2025-11-11T14:16:31.475936Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:623: RowDispatcher: NActors::TEvents::TEvPong
2025-11-11T14:16:31.476886Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: eddcb26f-38d004a5-9471148-3a628dd917, Host: ghrun-vb3yoermsa, Tenant: /compute
2025-11-11T14:16:31.481391Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-11T14:16:31.481406Z :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:25213: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-vb3yoermsa.auto.internal:25213
2025-11-11T14:16:31.945998Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:314: Coordinator: TEvPing received, [3:7571471486365932951:2063]
2025-11-11T14:16:31.946016Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:317: Coordinator: Send TEvPong to [3:7571471486365932951:2063]
2025-11-11T14:16:32.222186Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:314: Coordinator: TEvPing received, [2:7571471480450958475:2063]
2025-11-11T14:16:32.222204Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:317: Coordinator: Send TEvPong to [2:7571471480450958475:2063]
2025-11-11T14:16:32.477337Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: eddcb26f-38d004a5-9471148-3a628dd918, Host: ghrun-vb3yoermsa, Tenant: /compute
2025-11-11T14:16:32.482222Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-11T14:16:32.482241Z :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:25213: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-vb3yoermsa.auto.internal:25213
2025-11-11T14:16:33.476761Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:617: RowDispatcher: Send ping to [1:7571471469808169584:2082]
2025-11-11T14:16:33.476786Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1161: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-11-11T14:16:33.476794Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:314: Coordinator: TEvPing received, [1:7571471469808169544:2063]
2025-11-11T14:16:33.476798Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:317: Coordinator: Send TEvPong to [1:7571471469808169544:2063]
2025-11-11T14:16:33.476804Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:623: RowDispatcher: NActors::TEvents::TEvPong
2025-11-11T14:16:33.477771Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: eddcb26f-38d004a5-9471148-3a628dd919, Host: ghrun-vb3yoermsa, Tenant: /compute
2025-11-11T14:16:33.482588Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-11T14:16:33.482608Z :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:25213: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-vb3yoermsa.auto.internal:25213
2025-11-11T14:16:33.946843Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:314: Coordinator: TEvPing received, [3:7571471486365932951:2063]
2025-11-11T14:16:33.946856Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:317: Coordinator: Send TEvPong to [3:7571471486365932951:2063]
2025-11-11T14:16:34.223044Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:314: Coordinator: TEvPing received, [2:7571471480450958475:2063]
2025-11-11T14:16:34.223060Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:317: Coordinator: Send TEvPong to [2:7571471480450958475:2063]
2025-11-11T14:16:34.483177Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: eddcb26f-38d004a5-9471148-3a628dd920, Host: ghrun-vb3yoermsa, Tenant: /compute
2025-11-11T14:16:34.489238Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-11T14:16:34.489257Z :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:25213: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-vb3yoermsa.auto.internal:25213
2025-11-11T14:16:35.377808Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:356: Coordinator: TEvNodeDisconnected, node id 2
2025-11-11T14:16:35.377831Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:587: RowDispatcher: TEvNodeDisconnected, node id 2
2025-11-11T14:16:35.377977Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:356: Coordinator: TEvNodeDisconnected, node id 3
2025-11-11T14:16:35.378329Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1039: RowDispatcher: TEvTryConnect to node id 2
2025-11-11T14:16:35.378358Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:587: RowDispatcher: TEvNodeDisconnected, node id 2
2025-11-11T14:16:35.432625Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1039: RowDispatcher: TEvTryConnect to node id 2
2025-11-11T14:16:35.432678Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:587: RowDispatcher: TEvNodeDisconnected, node id 2
2025-11-11T14:16:35.469516Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-11-11T14:16:35.474646Z :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:25213: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-vb3yoermsa.auto.internal:25213
2025-11-11T14:16:35.477659Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:617: RowDispatcher: Send ping to [1:7571471469808169584:2082]
2025-11-11T14:16:35.477674Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1161: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-11-11T14:16:35.477704Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:314: Coordinator: TEvPing received, [1:7571471469808169544:2063]
2025-11-11T14:16:35.477709Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:317: Coordinator: Send TEvPong to [1:7571471469808169544:2063]
2025-11-11T14:16:35.477731Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:623: RowDispatcher: NActors::TEvents::TEvPong
2025-11-11T14:16:35.483810Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: eddcb26f-38d004a5-9471148-3a628dd921, Host: ghrun-vb3yoermsa, Tenant: /compute
2025-11-11T14:16:35.493934Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-11T14:16:35.493969Z :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:25213: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-vb3yoermsa.auto.internal:25213
