2025-12-12T12:26:45.054834Z :GRPC_SERVER NOTICE: grpc_request_proxy.cpp:380: Grpc request proxy started, nodeid# 2, serve as static node
2025-12-12T12:26:45.054893Z :GRPC_SERVER CRIT: grpc_request_proxy.cpp:440: Failed to deliver subscription request to config dispatcher
2025-12-12T12:26:45.054897Z :GRPC_SERVER NOTICE: grpc_request_proxy.cpp:380: Grpc request proxy started, nodeid# 2, serve as static node
2025-12-12T12:26:45.054914Z :GRPC_SERVER CRIT: grpc_request_proxy.cpp:440: Failed to deliver subscription request to config dispatcher
2025-12-12T12:26:45.055078Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:214: Bootstrap
2025-12-12T12:26:45.055079Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:217: Create sdk ydb connection
2025-12-12T12:26:45.055625Z :FQ_QUOTA_PROXY INFO: quota_proxy.cpp:90: STARTED
2025-12-12T12:26:45.055670Z :FQ_LOG_UPDATER DEBUG: log.cpp:93: Updated YQL logs priority: 8
2025-12-12T12:26:45.055673Z :FQ_LOG_UPDATER CRIT: log.cpp:55: Failed to deliver subscription request to config dispatcher.
2025-12-12T12:26:45.055712Z :YQ_RATE_LIMITER INFO: quoter_service.cpp:124: Bootstraping with config: { Enabled: true DataPlaneEnabled: true Database { Endpoint: "localhost:10706" Database: "local" TablePrefix: "RateLimiter_aa8e5e39-078a-4312-ac39-3dfb6cffb35f" } Limiters { CoordinationNodePath: "rate_limiter" } }
2025-12-12T12:26:45.055930Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:544: RowDispatcher: Successfully bootstrapped row dispatcher, id [2:7582946890864811842:2063], tenant /compute
2025-12-12T12:26:45.055948Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [2:7582946890864811842:2063]
2025-12-12T12:26:45.055949Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:329: Coordinator: Add new row dispatcher to map (state 1)
2025-12-12T12:26:45.056043Z :YQL_NODES_MANAGER INFO: nodes_manager.cpp:88: Bootstrap, InstanceId: 5c1cd0bb-40bbb2eb-7da4d088-e9de76d7
2025-12-12T12:26:45.056045Z :YQL_NODES_MANAGER DEBUG: nodes_manager.cpp:310: TNodesManagerActor::ResolveSelfAddress
2025-12-12T12:26:45.056063Z :YQ_TEST_CONNECTION DEBUG: test_connection.cpp:142: Starting yandex query test connection. Actor id: [2:7582946890864811847:2068]
2025-12-12T12:26:45.056095Z :FQ_QUOTA_SERVICE INFO: quota_manager.cpp:196: STARTED
2025-12-12T12:26:45.056123Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:293: Coordinator: Successfully bootstrapped coordinator, id [2:7582946890864811882:2082], NodesManagerId [0:4705493345362661702:78], rebalancing timeout 5.000000s
2025-12-12T12:26:45.056149Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:637: RowDispatcher: TEvCoordinatorChangesSubscribe from [2:7582946890864811882:2082]
2025-12-12T12:26:45.056157Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:232: TLeaderElection [2:7582946890864811883:2083] Successfully bootstrapped, local coordinator id [2:7582946890864811882:2082], tenant id compute, local mode 0, coordination node path local/compute, endpoint localhost:10706
2025-12-12T12:26:45.056164Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: ee00f4e3-30733b25-466103a7-271834a41, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:26:45.056493Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:239: Successfully bootstrapped TStorageProxy [2:7582946890864811841:2062] with connection to localhost:10706:local
2025-12-12T12:26:45.056601Z :MEMORY_PROFILER NOTICE: monitor.cpp:332: Bootstrapped
2025-12-12T12:26:45.057021Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-12-12T12:26:45.058286Z :SCHEME_BOARD_SUBSCRIBER NOTICE: subscriber.cpp:849: [main][2:7582946890864811861:2077][/Root] Set up state: owner# [2:7582946890864811821:2052], state# { Deleted: 1 Strong: 0 Version: <Invalid> DomainId: <Invalid> AbandonedSchemeShards: there are 0 elements }
2025-12-12T12:26:45.058314Z :SCHEME_BOARD_SUBSCRIBER NOTICE: subscriber.cpp:849: [main][2:7582946890864811863:2079][/Root] Set up state: owner# [2:7582946890864811822:2053], state# { Deleted: 1 Strong: 0 Version: <Invalid> DomainId: <Invalid> AbandonedSchemeShards: there are 0 elements }
2025-12-12T12:26:45.058326Z :SCHEME_BOARD_SUBSCRIBER NOTICE: subscriber.cpp:849: [main][2:7582946890864811864:2080][/compute] Set up state: owner# [2:7582946890864811822:2053], state# { Deleted: 1 Strong: 0 Version: <Invalid> DomainId: <Invalid> AbandonedSchemeShards: there are 0 elements }
2025-12-12T12:26:45.058331Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:71: Run create coordination node "local/compute" actor
2025-12-12T12:26:45.058333Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:113: Call create coordination node "local/compute"
2025-12-12T12:26:45.058335Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:411: Call create coordination node "local/compute"
2025-12-12T12:26:45.058355Z :GRPC_SERVER WARN: grpc_request_proxy.cpp:583: SchemeBoardDelete /Root Strong=0
2025-12-12T12:26:45.058357Z :GRPC_SERVER WARN: grpc_request_proxy.cpp:583: SchemeBoardDelete /compute Strong=0
2025-12-12T12:26:45.058379Z :GRPC_SERVER WARN: grpc_request_proxy.cpp:583: SchemeBoardDelete /Root Strong=0
2025-12-12T12:26:45.058386Z :SCHEME_BOARD_SUBSCRIBER NOTICE: subscriber.cpp:849: [main][2:7582946890864811862:2078][/compute] Set up state: owner# [2:7582946890864811821:2052], state# { Deleted: 1 Strong: 0 Version: <Invalid> DomainId: <Invalid> AbandonedSchemeShards: there are 0 elements }
2025-12-12T12:26:45.058389Z :GRPC_SERVER WARN: grpc_request_proxy.cpp:583: SchemeBoardDelete /compute Strong=0
2025-12-12T12:26:45.104295Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:26:45.104312Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:26:45.106949Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:155: Successfully created coordination node "local/compute"
2025-12-12T12:26:45.106961Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:122: Reply for create coordination node "local/compute": { <main>: Error: Check failed: path: '/local/compute', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 19], type: EPathTypeKesus, state: EPathStateNoChanges), source_location: ydb/core/tx/schemeshard/schemeshard__operation_create_kesus.cpp:339 }
2025-12-12T12:26:45.106975Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:345: TLeaderElection [2:7582946890864811883:2083] Coordination node successfully created
2025-12-12T12:26:45.106987Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:323: TLeaderElection [2:7582946890864811883:2083] Start session
2025-12-12T12:26:45.113243Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:359: TLeaderElection [2:7582946890864811883:2083] Session successfully created
2025-12-12T12:26:45.116596Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:389: Send NodeInfo with size: 1 to DynamicNameserver
2025-12-12T12:26:45.117815Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:372: TLeaderElection [2:7582946890864811883:2083] Semaphore successfully created
2025-12-12T12:26:45.117823Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:304: TLeaderElection [2:7582946890864811883:2083] Try to acquire semaphore
2025-12-12T12:26:45.117876Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:420: TLeaderElection [2:7582946890864811883:2083] Describe semaphore
2025-12-12T12:26:45.126188Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:469: TLeaderElection [2:7582946890864811883:2083] Semaphore successfully described: coordinator id [1:7582946887818600390:2082] generation 1
2025-12-12T12:26:45.126206Z :FQ_ROW_DISPATCHER INFO: leader_election.cpp:471: TLeaderElection [2:7582946890864811883:2083] Send TEvCoordinatorChanged to [2:7582946890864811842:2063], new coordinator id [1:7582946887818600390:2082], previous coordinator id [0:0:0]
2025-12-12T12:26:45.126238Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:569: RowDispatcher: Coordinator changed, old leader (empty maybe), new [1:7582946887818600390:2082] generation 1
2025-12-12T12:26:45.126263Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:440: Coordinator: New leader [1:7582946887818600390:2082], SelfId [2:7582946890864811882:2082]
2025-12-12T12:26:45.329113Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:607: RowDispatcher: TEvUndelivered, from [1:7582946887818600390:2082], reason Disconnected
2025-12-12T12:26:45.828282Z :INTERCONNECT ERROR: interconnect_nameserver_dynamic.cpp:62:  ICN06 Unknown nodeId: 3
2025-12-12T12:26:46.055050Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: ee00f4e3-30733b25-466103a7-271834a42, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:26:46.060382Z :FQ_QUOTA_SERVICE DEBUG: quota_manager.cpp:230: IC Peers[1]: [1]
2025-12-12T12:26:46.075334Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:26:46.075356Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:26:46.281817Z :INTERCONNECT ERROR: interconnect_nameserver_dynamic.cpp:62:  ICN06 Unknown nodeId: 3
2025-12-12T12:26:47.055776Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582946887818600390:2082]
2025-12-12T12:26:47.055803Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:26:47.056427Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: ee00f4e3-30733b25-466103a7-271834a43, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:26:47.067120Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:26:47.067134Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:26:47.445047Z :INTERCONNECT ERROR: interconnect_nameserver_dynamic.cpp:62:  ICN06 Unknown nodeId: 3
2025-12-12T12:26:48.056408Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: ee00f4e3-30733b25-466103a7-271834a44, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:26:48.087245Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:26:48.087261Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 1
2025-12-12T12:26:48.087276Z :FQ_PENDING_FETCHER DEBUG: pending_fetcher.cpp:361: NewTask: Scope: yandexcloud://my_folder Id: ptqudq7ug0qh33tsumcl UserId: root@builtin AuthToken: **** (B6C6F477)
2025-12-12T12:26:48.087451Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: ee00f4e3-30733b25-466103a7-271834a45, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:26:48.087476Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:375: QueryId: ptqudq7ug0qh33tsumcl Start run actor. Compute state: RUNNING
2025-12-12T12:26:48.087478Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:469: QueryId: ptqudq7ug0qh33tsumcl FillConnections
2025-12-12T12:26:48.087518Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:2333: QueryId: ptqudq7ug0qh33tsumcl Run actors params: { QueryId: ptqudq7ug0qh33tsumcl CloudId: mock_cloud UserId: root@builtin Owner: ee00f4e3-30733b25-466103a7-271834a44 PreviousQueryRevision: 2 Connections: 1 Bindings: 0 AccountIdSignatures: 0 QueryType: STREAMING ExecuteMode: RUN ResultId: ptrudq7ufus672cg09bv StateLoadMode: EMPTY StreamingDisposition: { fresh { } } Status: RUNNING DqGraphs: 1 DqGraphIndex: 0 Resource.TopicConsumers: 1 }
2025-12-12T12:26:48.087582Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:911: QueryId: ptqudq7ug0qh33tsumcl Overall dq tasks: 2
2025-12-12T12:26:48.087751Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:1598: QueryId: ptqudq7ug0qh33tsumcl ResultWriter was NOT CREATED since ResultType is empty
2025-12-12T12:26:48.087822Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudq7ug0qh33tsumcl 2025-12-12 12:26:48.087 DEBUG ydbd(pid=1181914, tid=0x00007FF9FC8EB640) [DQ] task_controller_impl.h:86: _RowsLimitPerWrite = 0
2025-12-12T12:26:48.087869Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:1652: QueryId: ptqudq7ug0qh33tsumcl Executer: [2:7582946903749713941:2148], Controller: [2:7582946903749713943:2150], ResultIdActor: [2:7582946903749713941:2148]
2025-12-12T12:26:48.087885Z :FQ_PINGER TRACE: pinger.cpp:171: QueryId: ptqudq7ug0qh33tsumcl, Owner: ee00f4e3-30733b25-466103a7-271834a44 Start Pinger
2025-12-12T12:26:48.088021Z :FQ_PINGER TRACE: pinger.cpp:250: QueryId: ptqudq7ug0qh33tsumcl, Owner: ee00f4e3-30733b25-466103a7-271834a44 Forward ping request: { resources { rate_limiter: READY compilation: READY topic_consumers_state: READY rate_limiter_path: "local/RateLimiter_aa8e5e39-078a-4312-ac39-3dfb6cffb35f/rate_limiter" topic_consumers { database: "local" topic_path: "test_metadatafields_input" consumer_name: "ptqudq7ug0qh33tsumcl" cluster_endpoint: "localhost:10706" token_name: "cluster:default_yds" add_bearer_to_token: true } } }
2025-12-12T12:26:48.088025Z :FQ_PINGER TRACE: pinger.cpp:393: QueryId: ptqudq7ug0qh33tsumcl, Owner: ee00f4e3-30733b25-466103a7-271834a44 Forward request Private::PingTask
2025-12-12T12:26:48.088192Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudq7ug0qh33tsumcl 2025-12-12 12:26:48.088 DEBUG ydbd(pid=1181914, tid=0x00007FF9FB0E8640) [DQ] executer_actor.cpp:140: {ptqudq7ug0qh33tsumcl} TDqExecuter::OnGraph
2025-12-12T12:26:48.088207Z :YQL_PROXY INFO: log.cpp:64: SessionId: ptqudq7ug0qh33tsumcl 2025-12-12 12:26:48.088 INFO  ydbd(pid=1181914, tid=0x00007FF9FB0E8640) [DQ] executer_actor.cpp:157: {ptqudq7ug0qh33tsumcl} Trying to allocate 2 workers [EnableComputeActor=1]
2025-12-12T12:26:48.089226Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudq7ug0qh33tsumcl 2025-12-12 12:26:48.089 DEBUG ydbd(pid=1181914, tid=0x00007FF9FB0E8640) [DQ] executer_actor.cpp:247: {ptqudq7ug0qh33tsumcl} Dq timeouts are set to: 0.000000s (global), 600.000000s (workers allocation fail), 30.000000s (workers allocation warn) 
2025-12-12T12:26:48.090170Z :YQL_NODES_MANAGER DEBUG: nodes_manager.cpp:125: TEvAllocateWorkersResponse Nodes {
  ResourceId: 4294967298
  Worker {
    NodeId: 2
    Guid: "5c1cd0bb-40bbb2eb-7da4d088-e9de76d7,ghrun-fhkyrtz6p4"
  }
  Worker {
    NodeId: 1
    Guid: "d829f000-4dbdfde3-3bf560b6-de987134,ghrun-fhkyrtz6p4"
  }
}
2025-12-12T12:26:48.095096Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:26:48.095112Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:26:48.111161Z :FQ_PINGER TRACE: pinger.cpp:338: QueryId: ptqudq7ug0qh33tsumcl, Owner: ee00f4e3-30733b25-466103a7-271834a44 Ping response success: { expired_at { seconds: 1765542428 nanos: 99000000 } }
2025-12-12T12:26:48.111202Z :FQ_RUN_ACTOR TRACE: run_actor.cpp:861: QueryId: ptqudq7ug0qh33tsumcl Forward ping response. Success: 1. Cookie: 0
2025-12-12T12:26:48.134801Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:144: SelfId: [2:7582946903749713948:2152], TxId: ptqudq7ug0qh33tsumcl, task: 1. Ctx: {}. Start compute actor [2:7582946903749713948:2152], task: 1
2025-12-12T12:26:48.134848Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:114: SelfId: [2:7582946903749713948:2152], TxId: ptqudq7ug0qh33tsumcl, task: 1. Ctx: {}. Use CPU quota: 1. Rate limiter resource: { "local/RateLimiter_aa8e5e39-078a-4312-ac39-3dfb6cffb35f/rate_limiter", "mock_cloud/my_folder/ptqudq7ug0qh33tsumcl" }
2025-12-12T12:26:48.214242Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1360: SelfId: [2:7582946903749713948:2152], TxId: ptqudq7ug0qh33tsumcl, task: 1. Ctx: {}. Create source for input 0 { Source { Type: "PqSource" Settings { type_url: "type.googleapis.com/NYql.NPq.NProto.TDqPqTopicSource" value: "\n\031test_metadatafields_input\022\024ptqudq7ug0qh33tsumcl\032\017localhost:10706\"\025\n\023cluster:default_yds*\005local0\002@\001R\017_yql_sys_seq_noR\025_yql_sys_partition_idR\024_yql_sys_create_timeR\031_yql_sys_message_group_idR\027_yql_sys_tsp_write_timeR\017_yql_sys_offsetb\004timej\024[\"DataType\";\"Int32\"]x\001\222\001\024ptcudq7ug1asmkbben1h\232\001\rjson_each_row\242\001\315\002[\"StructType\";[[\"_yql_sys_create_time\";[\"DataType\";\"Timestamp\"]];[\"_yql_sys_message_group_id\";[\"DataType\";\"String\"]];[\"_yql_sys_offset\";[\"DataType\";\"Uint64\"]];[\"_yql_sys_partition_id\";[\"DataType\";\"Uint64\"]];[\"_yql_sys_seq_no\";[\"DataType\";\"Uint64\"]];[\"_yql_sys_tsp_write_time\";[\"DataType\";\"Timestamp\"]];[\"time\";[\"DataType\";\"Int32\"]]]]\262\001\002\022\000\272\001\026\n\010cloud_id\022\nmock_cloud\272\001 \n\005scope\022\027yandexcloud://my_folder" } WatermarksMode: WATERMARKS_MODE_DISABLED } }
2025-12-12T12:26:48.214566Z :KQP_COMPUTE INFO: dq_pq_rd_read_actor.cpp:557: SelfId: [0:0:0], TxId: ptqudq7ug0qh33tsumcl, task: 1. PQ source. Start read actor, local row dispatcher [0:5788050504107380562:5260383], metadatafields: _yql_sys_seq_no,_yql_sys_partition_id,_yql_sys_create_time,_yql_sys_message_group_id,_yql_sys_tsp_write_time,_yql_sys_offset, partitions: 0, skip json errors: 0
2025-12-12T12:26:48.214632Z :KQP_COMPUTE DEBUG: dq_pq_read_actor_base.cpp:153: SelfId: [0:0:0], TxId: ptqudq7ug0qh33tsumcl, task: 1. PQ source. SessionId: empty Watermarks enabled: 0 granularity: 0.000000s late arrival delay: 0.000000s idle: 0 idle timeout: 0.000000s
2025-12-12T12:26:48.214691Z :YQL_PROXY TRACE: log.cpp:64: SessionId:  2025-12-12 12:26:48.214 TRACE ydbd(pid=1181914, tid=0x00007FF9FD8ED640) [DQ] task_controller_impl.h:160: [2:7582946903749713943:2150] EvState TaskId: 1 State: 2 PingCookie: 0 StatusCode: UNSPECIFIED
2025-12-12T12:26:48.214706Z :YQL_PROXY TRACE: log.cpp:64: SessionId:  2025-12-12 12:26:48.214 TRACE ydbd(pid=1181914, tid=0x00007FF9FD8ED640) [DQ] task_controller_impl.h:201:  [2:7582946903749713943:2150] Executing TaskId: 1
2025-12-12T12:26:48.814351Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudq7ug0qh33tsumcl 2025-12-12 12:26:48.814 DEBUG ydbd(pid=1181914, tid=0x00007FF9FD8ED640) [DQ] executer_actor.cpp:358: {ptqudq7ug0qh33tsumcl} TDqExecuter::TEvAllocateWorkersResponse
2025-12-12T12:26:48.814379Z :YQL_PROXY ERROR: log.cpp:64: SessionId: ptqudq7ug0qh33tsumcl 2025-12-12 12:26:48.814 ERROR ydbd(pid=1181914, tid=0x00007FF9FD8ED640) [DQ] executer_actor.cpp:370: {ptqudq7ug0qh33tsumcl} Error on allocate workers Disconnected from worker: `Id:d829f000-4dbdfde3-3bf560b6-de987134,ghrun-fhkyrtz6p4,NodeId:1,', reason: Undelivered:UNAVAILABLE
2025-12-12T12:26:48.814465Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudq7ug0qh33tsumcl 2025-12-12 12:26:48.814 DEBUG ydbd(pid=1181914, tid=0x00007FF9FD8ED640) [DQ] executer_actor.cpp:284: {ptqudq7ug0qh33tsumcl} Finish with status=5 issues=<main>: Error: Disconnected from worker: `Id:d829f000-4dbdfde3-3bf560b6-de987134,ghrun-fhkyrtz6p4,NodeId:1,', reason: Undelivered, code: 6001

2025-12-12T12:26:48.814510Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudq7ug0qh33tsumcl 2025-12-12 12:26:48.814 DEBUG ydbd(pid=1181914, tid=0x00007FF9FD8ED640) [DQ] executer_actor.cpp:341: {ptqudq7ug0qh33tsumcl} OnQueryResponse status=5 issuses_size=1
2025-12-12T12:26:48.814565Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:1233: QueryId: ptqudq7ug0qh33tsumcl Query response UNAVAILABLE. Result set index: 0. Issues count: 1. Rows count: 0
2025-12-12T12:26:48.814686Z :FQ_RUN_ACTOR WARN: run_actor.cpp:1914: QueryId: ptqudq7ug0qh33tsumcl ResignQuery, status UNAVAILABLE
2025-12-12T12:26:48.814692Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:1919: QueryId: ptqudq7ug0qh33tsumcl SendPingAndPassAway, FinalQueryStatus COMPUTE_STATUS_UNSPECIFIED
2025-12-12T12:26:48.814725Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:536: QueryId: ptqudq7ug0qh33tsumcl PassAway
2025-12-12T12:26:48.814816Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:657: [ptqudq7ug0qh33tsumcl-0.2] PassAway
2025-12-12T12:26:48.814925Z :FQ_PINGER TRACE: pinger.cpp:250: QueryId: ptqudq7ug0qh33tsumcl, Owner: ee00f4e3-30733b25-466103a7-271834a44 Forward ping request: { result_id { value: "ptrudq7ufus672cg09bv" } statistics: "{\"Graph=0\":{\"Actor\":{\"ActorCreateTimeUs\":{\"sum\":\"52ms\",\"count\":1,\"avg\":\"52ms\",\"max\":\"52ms\",\"min\":\"52ms\"},\"ClusterName=\":{\"CreateFailTimeUs\":{\"sum\":\"0.72s\",\"count\":1,\"avg\":\"0.72s\",\"max\":\"0.72s\",\"min\":\"0.72s\"}}},\"AllocateWorkersUs\":{\"sum\":\"0.72s\",\"count\":1,\"avg\":\"0.72s\",\"max\":\"0.72s\",\"min\":\"0.72s\"},\"Retry\":{\"sum\":5,\"count\":5,\"avg\":1,\"max\":1,\"min\":1},\"TaskRunner\":{\"Stage=Total\":{\"sum\":0,\"count\":0,\"avg\":0,\"max\":0,\"min\":0}}}}" resign_query: true transient_issues { message: "Disconnected from worker: `Id:d829f000-4dbdfde3-3bf560b6-de987134,ghrun-fhkyrtz6p4,NodeId:1,\', reason: Undelivered" issue_code: 6001 severity: 1 } status_code: UNAVAILABLE resources { rate_limiter: READY compilation: READY topic_consumers_state: READY rate_limiter_path: "local/RateLimiter_aa8e5e39-078a-4312-ac39-3dfb6cffb35f/rate_limiter" topic_consumers { database: "local" topic_path: "test_metadatafields_input" consumer_name: "ptqudq7ug0qh33tsumcl" cluster_endpoint: "localhost:10706" token_name: "cluster:default_yds" add_bearer_to_token: true } } }
2025-12-12T12:26:48.814927Z :FQ_PINGER TRACE: pinger.cpp:393: QueryId: ptqudq7ug0qh33tsumcl, Owner: ee00f4e3-30733b25-466103a7-271834a44 Forward request Private::PingTask
2025-12-12T12:26:48.815063Z :KQP_COMPUTE ERROR: dq_compute_actor_impl.h:1205: SelfId: [2:7582946903749713948:2152], TxId: ptqudq7ug0qh33tsumcl, task: 1. Ctx: {}. Handle abort execution event from: [2:7582946890864811843:2064], status: UNAVAILABLE, reason: { <main>: Error: Aborted by LWM }
2025-12-12T12:26:48.815691Z :KQP_COMPUTE DEBUG: dq_compute_actor_channels.cpp:494: TxId: ptqudq7ug0qh33tsumcl, task: 1. pass away
2025-12-12T12:26:48.815702Z :KQP_COMPUTE INFO: dq_pq_rd_read_actor.cpp:744: SelfId: [0:0:0], TxId: ptqudq7ug0qh33tsumcl, task: 1. PQ source. PassAway
2025-12-12T12:26:48.815717Z :KQP_COMPUTE INFO: dq_pq_rd_read_actor.cpp:1242: SelfId: [0:0:0], TxId: ptqudq7ug0qh33tsumcl, task: 1. PQ source. SelfId: [0:0:0], TxId: ptqudq7ug0qh33tsumcl, task: 1. PQ source. State: used buffer size 0 ready buffer event size 0 state 0 InFlyAsyncInputData 0
Counters: CoordinatorChanged 0 CoordinatorResult 0 MessageBatch 0 StartSessionAck 0 NewDataArrived 0 SessionError 0 Statistics 0 NodeDisconnected 0 NodeConnected 0 Undelivered 0 Retry 0 PrivateHeartbeat 0 SessionClosed 0 Pong 0 Heartbeat 0 PrintState 0 ProcessState 0 GetAsyncInputData 0 NotifyCA 0
2025-12-12T12:26:48.895107Z :FQ_PINGER ERROR: pinger.cpp:365: QueryId: ptqudq7ug0qh33tsumcl, Owner: ee00f4e3-30733b25-466103a7-271834a44 Ping response error: Query ownership time is over: expired_at=2025-12-12T12:26:48.875000Z < now=2025-12-12T12:26:48.895063Z. Retried 0 times during 0.081172s
2025-12-12T12:26:48.895133Z :FQ_PINGER DEBUG: pinger.cpp:379: QueryId: ptqudq7ug0qh33tsumcl, Owner: ee00f4e3-30733b25-466103a7-271834a44 Query finished
2025-12-12T12:26:48.895135Z :FQ_PINGER TRACE: pinger.cpp:187: QueryId: ptqudq7ug0qh33tsumcl, Owner: ee00f4e3-30733b25-466103a7-271834a44 Stop Pinger
2025-12-12T12:26:48.933906Z :INTERCONNECT ERROR: interconnect_nameserver_dynamic.cpp:62:  ICN06 Unknown nodeId: 3
2025-12-12T12:26:49.056844Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582946887818600390:2082]
2025-12-12T12:26:49.056869Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:26:49.056884Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: ee00f4e3-30733b25-466103a7-271834a46, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:26:49.095416Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:26:49.095430Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 1
2025-12-12T12:26:49.095444Z :FQ_PENDING_FETCHER DEBUG: pending_fetcher.cpp:361: NewTask: Scope: yandexcloud://my_folder Id: ptqudq7ug0qh33tsumcl UserId: root@builtin AuthToken: **** (B6C6F477)
2025-12-12T12:26:49.095607Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: ee00f4e3-30733b25-466103a7-271834a47, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:26:49.095642Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:375: QueryId: ptqudq7ug0qh33tsumcl Start run actor. Compute state: RUNNING
2025-12-12T12:26:49.095644Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:469: QueryId: ptqudq7ug0qh33tsumcl FillConnections
2025-12-12T12:26:49.095669Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:2333: QueryId: ptqudq7ug0qh33tsumcl Run actors params: { QueryId: ptqudq7ug0qh33tsumcl CloudId: mock_cloud UserId: root@builtin Owner: ee00f4e3-30733b25-466103a7-271834a46 PreviousQueryRevision: 3 Connections: 1 Bindings: 0 AccountIdSignatures: 0 QueryType: STREAMING ExecuteMode: RUN ResultId: ptrudq7ufttdlujj7plp StateLoadMode: EMPTY StreamingDisposition: { fresh { } } Status: RUNNING DqGraphs: 1 DqGraphIndex: 0 Resource.TopicConsumers: 1 }
2025-12-12T12:26:49.095720Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:911: QueryId: ptqudq7ug0qh33tsumcl Overall dq tasks: 2
2025-12-12T12:26:49.095801Z :FQ_PINGER TRACE: pinger.cpp:171: QueryId: ptqudq7ug0qh33tsumcl, Owner: ee00f4e3-30733b25-466103a7-271834a46 Start Pinger
2025-12-12T12:26:49.095847Z :FQ_PINGER TRACE: pinger.cpp:250: QueryId: ptqudq7ug0qh33tsumcl, Owner: ee00f4e3-30733b25-466103a7-271834a46 Forward ping request: { resources { rate_limiter: READY compilation: READY topic_consumers_state: READY rate_limiter_path: "local/RateLimiter_aa8e5e39-078a-4312-ac39-3dfb6cffb35f/rate_limiter" topic_consumers { database: "local" topic_path: "test_metadatafields_input" consumer_name: "ptqudq7ug0qh33tsumcl" cluster_endpoint: "localhost:10706" token_name: "cluster:default_yds" add_bearer_to_token: true } } }
2025-12-12T12:26:49.095852Z :FQ_PINGER TRACE: pinger.cpp:393: QueryId: ptqudq7ug0qh33tsumcl, Owner: ee00f4e3-30733b25-466103a7-271834a46 Forward request Private::PingTask
2025-12-12T12:26:49.095853Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:1598: QueryId: ptqudq7ug0qh33tsumcl ResultWriter was NOT CREATED since ResultType is empty
2025-12-12T12:26:49.095919Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudq7ug0qh33tsumcl 2025-12-12 12:26:49.095 DEBUG ydbd(pid=1181914, tid=0x00007FF9FD8ED640) [DQ] task_controller_impl.h:86: _RowsLimitPerWrite = 0
2025-12-12T12:26:49.095970Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:1652: QueryId: ptqudq7ug0qh33tsumcl Executer: [2:7582946908044681257:2157], Controller: [2:7582946908044681259:2159], ResultIdActor: [2:7582946908044681257:2157]
2025-12-12T12:26:49.095991Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudq7ug0qh33tsumcl 2025-12-12 12:26:49.095 DEBUG ydbd(pid=1181914, tid=0x00007FF9FD8ED640) [DQ] executer_actor.cpp:140: {ptqudq7ug0qh33tsumcl} TDqExecuter::OnGraph
2025-12-12T12:26:49.096000Z :YQL_PROXY INFO: log.cpp:64: SessionId: ptqudq7ug0qh33tsumcl 2025-12-12 12:26:49.095 INFO  ydbd(pid=1181914, tid=0x00007FF9FD8ED640) [DQ] executer_actor.cpp:157: {ptqudq7ug0qh33tsumcl} Trying to allocate 2 workers [EnableComputeActor=1]
2025-12-12T12:26:49.096143Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudq7ug0qh33tsumcl 2025-12-12 12:26:49.096 DEBUG ydbd(pid=1181914, tid=0x00007FF9FD8ED640) [DQ] executer_actor.cpp:247: {ptqudq7ug0qh33tsumcl} Dq timeouts are set to: 0.000000s (global), 600.000000s (workers allocation fail), 30.000000s (workers allocation warn) 
2025-12-12T12:26:49.096202Z :YQL_NODES_MANAGER DEBUG: nodes_manager.cpp:125: TEvAllocateWorkersResponse Nodes {
  ResourceId: 8589934594
  Worker {
    NodeId: 2
    Guid: "5c1cd0bb-40bbb2eb-7da4d088-e9de76d7,ghrun-fhkyrtz6p4"
  }
  Worker {
    NodeId: 1
    Guid: "d829f000-4dbdfde3-3bf560b6-de987134,ghrun-fhkyrtz6p4"
  }
}
2025-12-12T12:26:49.096417Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:144: SelfId: [2:7582946908044681261:2161], TxId: ptqudq7ug0qh33tsumcl, task: 1. Ctx: {}. Start compute actor [2:7582946908044681261:2161], task: 1
2025-12-12T12:26:49.096432Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:114: SelfId: [2:7582946908044681261:2161], TxId: ptqudq7ug0qh33tsumcl, task: 1. Ctx: {}. Use CPU quota: 1. Rate limiter resource: { "local/RateLimiter_aa8e5e39-078a-4312-ac39-3dfb6cffb35f/rate_limiter", "mock_cloud/my_folder/ptqudq7ug0qh33tsumcl" }
2025-12-12T12:26:49.106910Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:26:49.106922Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:26:49.123879Z :FQ_PINGER TRACE: pinger.cpp:338: QueryId: ptqudq7ug0qh33tsumcl, Owner: ee00f4e3-30733b25-466103a7-271834a46 Ping response success: { expired_at { seconds: 1765542429 nanos: 111000000 } }
2025-12-12T12:26:49.123911Z :FQ_RUN_ACTOR TRACE: run_actor.cpp:861: QueryId: ptqudq7ug0qh33tsumcl Forward ping response. Success: 1. Cookie: 0
2025-12-12T12:26:49.195240Z :YQL_PROXY WARN: log.cpp:64: SessionId: ee00f4e3-30733b25-466103a7-271834a4 2025-12-12 12:26:49.195 WARN  ydbd(pid=1181914, tid=0x00007FF9FC8EB640) [DQ] resource_allocator.cpp:281: {ptqudq7ug0qh33tsumcl/[2:7582946908044681260:2160]} Retry Allocate Request
2025-12-12T12:26:49.195288Z :YQL_PROXY WARN: log.cpp:64: SessionId: ee00f4e3-30733b25-466103a7-271834a4 2025-12-12 12:26:49.195 WARN  ydbd(pid=1181914, tid=0x00007FF9FC8EB640) [DQ] resource_allocator.cpp:259: {ptqudq7ug0qh33tsumcl/[2:7582946908044681260:2160]} Send TEvAllocateWorkersRequest to Id:d829f000-4dbdfde3-3bf560b6-de987134,ghrun-fhkyrtz6p4,NodeId:1,
2025-12-12T12:26:49.200978Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1360: SelfId: [2:7582946908044681261:2161], TxId: ptqudq7ug0qh33tsumcl, task: 1. Ctx: {}. Create source for input 0 { Source { Type: "PqSource" Settings { type_url: "type.googleapis.com/NYql.NPq.NProto.TDqPqTopicSource" value: "\n\031test_metadatafields_input\022\024ptqudq7ug0qh33tsumcl\032\017localhost:10706\"\025\n\023cluster:default_yds*\005local0\002@\001R\017_yql_sys_seq_noR\025_yql_sys_partition_idR\024_yql_sys_create_timeR\031_yql_sys_message_group_idR\027_yql_sys_tsp_write_timeR\017_yql_sys_offsetb\004timej\024[\"DataType\";\"Int32\"]x\001\222\001\024ptcudq7ug1asmkbben1h\232\001\rjson_each_row\242\001\315\002[\"StructType\";[[\"_yql_sys_create_time\";[\"DataType\";\"Timestamp\"]];[\"_yql_sys_message_group_id\";[\"DataType\";\"String\"]];[\"_yql_sys_offset\";[\"DataType\";\"Uint64\"]];[\"_yql_sys_partition_id\";[\"DataType\";\"Uint64\"]];[\"_yql_sys_seq_no\";[\"DataType\";\"Uint64\"]];[\"_yql_sys_tsp_write_time\";[\"DataType\";\"Timestamp\"]];[\"time\";[\"DataType\";\"Int32\"]]]]\262\001\002\022\000\272\001\026\n\010cloud_id\022\nmock_cloud\272\001 \n\005scope\022\027yandexcloud://my_folder" } WatermarksMode: WATERMARKS_MODE_DISABLED } }
2025-12-12T12:26:49.201054Z :KQP_COMPUTE INFO: dq_pq_rd_read_actor.cpp:557: SelfId: [0:0:0], TxId: ptqudq7ug0qh33tsumcl, task: 1. PQ source. Start read actor, local row dispatcher [0:5788050504107380562:5260383], metadatafields: _yql_sys_seq_no,_yql_sys_partition_id,_yql_sys_create_time,_yql_sys_message_group_id,_yql_sys_tsp_write_time,_yql_sys_offset, partitions: 0, skip json errors: 0
2025-12-12T12:26:49.201110Z :KQP_COMPUTE DEBUG: dq_pq_read_actor_base.cpp:153: SelfId: [0:0:0], TxId: ptqudq7ug0qh33tsumcl, task: 1. PQ source. SessionId: empty Watermarks enabled: 0 granularity: 0.000000s late arrival delay: 0.000000s idle: 0 idle timeout: 0.000000s
2025-12-12T12:26:49.201142Z :YQL_PROXY TRACE: log.cpp:64: SessionId:  2025-12-12 12:26:49.201 TRACE ydbd(pid=1181914, tid=0x00007FF9FD8ED640) [DQ] task_controller_impl.h:160: [2:7582946908044681259:2159] EvState TaskId: 1 State: 2 PingCookie: 0 StatusCode: UNSPECIFIED
2025-12-12T12:26:49.201151Z :YQL_PROXY TRACE: log.cpp:64: SessionId:  2025-12-12 12:26:49.201 TRACE ydbd(pid=1181914, tid=0x00007FF9FD8ED640) [DQ] task_controller_impl.h:201:  [2:7582946908044681259:2159] Executing TaskId: 1
2025-12-12T12:26:49.799479Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudq7ug0qh33tsumcl 2025-12-12 12:26:49.799 DEBUG ydbd(pid=1181914, tid=0x00007FF9FD8ED640) [DQ] executer_actor.cpp:358: {ptqudq7ug0qh33tsumcl} TDqExecuter::TEvAllocateWorkersResponse
2025-12-12T12:26:49.799515Z :YQL_PROXY ERROR: log.cpp:64: SessionId: ptqudq7ug0qh33tsumcl 2025-12-12 12:26:49.799 ERROR ydbd(pid=1181914, tid=0x00007FF9FD8ED640) [DQ] executer_actor.cpp:370: {ptqudq7ug0qh33tsumcl} Error on allocate workers Disconnected from worker: `Id:d829f000-4dbdfde3-3bf560b6-de987134,ghrun-fhkyrtz6p4,NodeId:1,', reason: Undelivered:UNAVAILABLE
2025-12-12T12:26:49.799538Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudq7ug0qh33tsumcl 2025-12-12 12:26:49.799 DEBUG ydbd(pid=1181914, tid=0x00007FF9FD8ED640) [DQ] executer_actor.cpp:284: {ptqudq7ug0qh33tsumcl} Finish with status=5 issues=<main>: Error: Disconnected from worker: `Id:d829f000-4dbdfde3-3bf560b6-de987134,ghrun-fhkyrtz6p4,NodeId:1,', reason: Undelivered, code: 6001

2025-12-12T12:26:49.799581Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudq7ug0qh33tsumcl 2025-12-12 12:26:49.799 DEBUG ydbd(pid=1181914, tid=0x00007FF9FD8ED640) [DQ] executer_actor.cpp:341: {ptqudq7ug0qh33tsumcl} OnQueryResponse status=5 issuses_size=1
2025-12-12T12:26:49.799624Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:1233: QueryId: ptqudq7ug0qh33tsumcl Query response UNAVAILABLE. Result set index: 0. Issues count: 1. Rows count: 0
2025-12-12T12:26:49.799717Z :FQ_RUN_ACTOR WARN: run_actor.cpp:1914: QueryId: ptqudq7ug0qh33tsumcl ResignQuery, status UNAVAILABLE
2025-12-12T12:26:49.799723Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:1919: QueryId: ptqudq7ug0qh33tsumcl SendPingAndPassAway, FinalQueryStatus COMPUTE_STATUS_UNSPECIFIED
2025-12-12T12:26:49.799743Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:536: QueryId: ptqudq7ug0qh33tsumcl PassAway
2025-12-12T12:26:49.799831Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:657: [ptqudq7ug0qh33tsumcl-0.3] PassAway
2025-12-12T12:26:49.799934Z :KQP_COMPUTE ERROR: dq_compute_actor_impl.h:1205: SelfId: [2:7582946908044681261:2161], TxId: ptqudq7ug0qh33tsumcl, task: 1. Ctx: {}. Handle abort execution event from: [2:7582946890864811843:2064], status: UNAVAILABLE, reason: { <main>: Error: Aborted by LWM }
2025-12-12T12:26:49.799941Z :FQ_PINGER TRACE: pinger.cpp:250: QueryId: ptqudq7ug0qh33tsumcl, Owner: ee00f4e3-30733b25-466103a7-271834a46 Forward ping request: { result_id { value: "ptrudq7ufttdlujj7plp" } statistics: "{\"Graph=0\":{\"Actor\":{\"ActorCreateTimeUs\":{\"sum\":\"3ms\",\"count\":1,\"avg\":\"3ms\",\"max\":\"3ms\",\"min\":\"3ms\"},\"ClusterName=\":{\"CreateFailTimeUs\":{\"sum\":\"0.70s\",\"count\":1,\"avg\":\"0.70s\",\"max\":\"0.70s\",\"min\":\"0.70s\"}}},\"AllocateWorkersUs\":{\"sum\":\"0.70s\",\"count\":1,\"avg\":\"0.70s\",\"max\":\"0.70s\",\"min\":\"0.70s\"},\"Retry\":{\"sum\":5,\"count\":5,\"avg\":1,\"max\":1,\"min\":1},\"TaskRunner\":{\"Stage=Total\":{\"sum\":0,\"count\":0,\"avg\":0,\"max\":0,\"min\":0}}}}" resign_query: true transient_issues { message: "Disconnected from worker: `Id:d829f000-4dbdfde3-3bf560b6-de987134,ghrun-fhkyrtz6p4,NodeId:1,\', reason: Undelivered" issue_code: 6001 severity: 1 } status_code: UNAVAILABLE resources { rate_limiter: READY compilation: READY topic_consumers_state: READY rate_limiter_path: "local/RateLimiter_aa8e5e39-078a-4312-ac39-3dfb6cffb35f/rate_limiter" topic_consumers { database: "local" topic_path: "test_metadatafields_input" consumer_name: "ptqudq7ug0qh33tsumcl" cluster_endpoint: "localhost:10706" token_name: "cluster:default_yds" add_bearer_to_token: true } } }
2025-12-12T12:26:49.799944Z :FQ_PINGER TRACE: pinger.cpp:393: QueryId: ptqudq7ug0qh33tsumcl, Owner: ee00f4e3-30733b25-466103a7-271834a46 Forward request Private::PingTask
2025-12-12T12:26:49.799960Z :KQP_COMPUTE DEBUG: dq_compute_actor_channels.cpp:494: TxId: ptqudq7ug0qh33tsumcl, task: 1. pass away
2025-12-12T12:26:49.799970Z :KQP_COMPUTE INFO: dq_pq_rd_read_actor.cpp:744: SelfId: [0:0:0], TxId: ptqudq7ug0qh33tsumcl, task: 1. PQ source. PassAway
2025-12-12T12:26:49.799983Z :KQP_COMPUTE INFO: dq_pq_rd_read_actor.cpp:1242: SelfId: [0:0:0], TxId: ptqudq7ug0qh33tsumcl, task: 1. PQ source. SelfId: [0:0:0], TxId: ptqudq7ug0qh33tsumcl, task: 1. PQ source. State: used buffer size 0 ready buffer event size 0 state 0 InFlyAsyncInputData 0
Counters: CoordinatorChanged 0 CoordinatorResult 0 MessageBatch 0 StartSessionAck 0 NewDataArrived 0 SessionError 0 Statistics 0 NodeDisconnected 0 NodeConnected 0 Undelivered 0 Retry 0 PrivateHeartbeat 0 SessionClosed 0 Pong 0 Heartbeat 0 PrintState 0 ProcessState 0 GetAsyncInputData 0 NotifyCA 0
2025-12-12T12:26:49.830634Z :FQ_PINGER ERROR: pinger.cpp:365: QueryId: ptqudq7ug0qh33tsumcl, Owner: ee00f4e3-30733b25-466103a7-271834a46 Ping response error: Query ownership time is over: expired_at=2025-12-12T12:26:49.812000Z < now=2025-12-12T12:26:49.829884Z. Retried 0 times during 0.030656s
2025-12-12T12:26:49.830671Z :FQ_PINGER DEBUG: pinger.cpp:379: QueryId: ptqudq7ug0qh33tsumcl, Owner: ee00f4e3-30733b25-466103a7-271834a46 Query finished
2025-12-12T12:26:49.830674Z :FQ_PINGER TRACE: pinger.cpp:187: QueryId: ptqudq7ug0qh33tsumcl, Owner: ee00f4e3-30733b25-466103a7-271834a46 Stop Pinger
2025-12-12T12:26:50.053184Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:665: Coordinator: Change global state to Started (by timeout)
2025-12-12T12:26:50.053184Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-12-12T12:26:50.057250Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: ee00f4e3-30733b25-466103a7-271834a48, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:26:50.077000Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:389: Send NodeInfo with size: 2 to DynamicNameserver
2025-12-12T12:26:50.085108Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:26:50.085132Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 1
2025-12-12T12:26:50.085148Z :FQ_PENDING_FETCHER DEBUG: pending_fetcher.cpp:361: NewTask: Scope: yandexcloud://my_folder Id: ptqudq7ug0qh33tsumcl UserId: root@builtin AuthToken: **** (B6C6F477)
2025-12-12T12:26:50.085309Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: ee00f4e3-30733b25-466103a7-271834a49, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:26:50.085329Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:375: QueryId: ptqudq7ug0qh33tsumcl Start run actor. Compute state: RUNNING
2025-12-12T12:26:50.085344Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:469: QueryId: ptqudq7ug0qh33tsumcl FillConnections
2025-12-12T12:26:50.085395Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:2333: QueryId: ptqudq7ug0qh33tsumcl Run actors params: { QueryId: ptqudq7ug0qh33tsumcl CloudId: mock_cloud UserId: root@builtin Owner: ee00f4e3-30733b25-466103a7-271834a48 PreviousQueryRevision: 4 Connections: 1 Bindings: 0 AccountIdSignatures: 0 QueryType: STREAMING ExecuteMode: RUN ResultId: ptrudq7ufsv75gaig4et StateLoadMode: EMPTY StreamingDisposition: { fresh { } } Status: RUNNING DqGraphs: 1 DqGraphIndex: 0 Resource.TopicConsumers: 1 }
2025-12-12T12:26:50.085430Z :FQ_PINGER TRACE: pinger.cpp:171: QueryId: ptqudq7ug0qh33tsumcl, Owner: ee00f4e3-30733b25-466103a7-271834a48 Start Pinger
2025-12-12T12:26:50.085504Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:911: QueryId: ptqudq7ug0qh33tsumcl Overall dq tasks: 2
2025-12-12T12:26:50.085611Z :FQ_PINGER TRACE: pinger.cpp:250: QueryId: ptqudq7ug0qh33tsumcl, Owner: ee00f4e3-30733b25-466103a7-271834a48 Forward ping request: { resources { rate_limiter: READY compilation: READY topic_consumers_state: READY rate_limiter_path: "local/RateLimiter_aa8e5e39-078a-4312-ac39-3dfb6cffb35f/rate_limiter" topic_consumers { database: "local" topic_path: "test_metadatafields_input" consumer_name: "ptqudq7ug0qh33tsumcl" cluster_endpoint: "localhost:10706" token_name: "cluster:default_yds" add_bearer_to_token: true } } }
2025-12-12T12:26:50.085625Z :FQ_PINGER TRACE: pinger.cpp:393: QueryId: ptqudq7ug0qh33tsumcl, Owner: ee00f4e3-30733b25-466103a7-271834a48 Forward request Private::PingTask
2025-12-12T12:26:50.085673Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:1598: QueryId: ptqudq7ug0qh33tsumcl ResultWriter was NOT CREATED since ResultType is empty
2025-12-12T12:26:50.085745Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudq7ug0qh33tsumcl 2025-12-12 12:26:50.085 DEBUG ydbd(pid=1181914, tid=0x00007FF9FC8EB640) [DQ] task_controller_impl.h:86: _RowsLimitPerWrite = 0
2025-12-12T12:26:50.085824Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:1652: QueryId: ptqudq7ug0qh33tsumcl Executer: [2:7582946912339648570:2168], Controller: [2:7582946912339648572:2170], ResultIdActor: [2:7582946912339648570:2168]
2025-12-12T12:26:50.085856Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudq7ug0qh33tsumcl 2025-12-12 12:26:50.085 DEBUG ydbd(pid=1181914, tid=0x00007FF9FD8ED640) [DQ] executer_actor.cpp:140: {ptqudq7ug0qh33tsumcl} TDqExecuter::OnGraph
2025-12-12T12:26:50.085871Z :YQL_PROXY INFO: log.cpp:64: SessionId: ptqudq7ug0qh33tsumcl 2025-12-12 12:26:50.085 INFO  ydbd(pid=1181914, tid=0x00007FF9FD8ED640) [DQ] executer_actor.cpp:157: {ptqudq7ug0qh33tsumcl} Trying to allocate 2 workers [EnableComputeActor=1]
2025-12-12T12:26:50.086076Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudq7ug0qh33tsumcl 2025-12-12 12:26:50.086 DEBUG ydbd(pid=1181914, tid=0x00007FF9FD8ED640) [DQ] executer_actor.cpp:247: {ptqudq7ug0qh33tsumcl} Dq timeouts are set to: 0.000000s (global), 600.000000s (workers allocation fail), 30.000000s (workers allocation warn) 
2025-12-12T12:26:50.086136Z :YQL_NODES_MANAGER DEBUG: nodes_manager.cpp:125: TEvAllocateWorkersResponse Nodes {
  ResourceId: 12884901890
  Worker {
    NodeId: 2
    Guid: "5c1cd0bb-40bbb2eb-7da4d088-e9de76d7,ghrun-fhkyrtz6p4"
  }
  Worker {
    NodeId: 1
    Guid: "d829f000-4dbdfde3-3bf560b6-de987134,ghrun-fhkyrtz6p4"
  }
}
2025-12-12T12:26:50.086191Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ee00f4e3-30733b25-466103a7-271834a4 2025-12-12 12:26:50.086 DEBUG ydbd(pid=1181914, tid=0x00007FF9FC8EB640) [DQ] resource_allocator.cpp:141: {ptqudq7ug0qh33tsumcl/[2:7582946912339648573:2171]} TEvAllocateWorkersResponse 2
2025-12-12T12:26:50.086200Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ee00f4e3-30733b25-466103a7-271834a4 2025-12-12 12:26:50.086 DEBUG ydbd(pid=1181914, tid=0x00007FF9FC8EB640) [DQ] resource_allocator.cpp:106: {ptqudq7ug0qh33tsumcl/[2:7582946912339648573:2171]} RequestActorIdsFromNodes 2
2025-12-12T12:26:50.086206Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ee00f4e3-30733b25-466103a7-271834a4 2025-12-12 12:26:50.086 DEBUG ydbd(pid=1181914, tid=0x00007FF9FC8EB640) [DQ] resource_allocator.cpp:115: {ptqudq7ug0qh33tsumcl/[2:7582946912339648573:2171]} RequestActorIdsFromNodes 2 12884901890
2025-12-12T12:26:50.086212Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ee00f4e3-30733b25-466103a7-271834a4 2025-12-12 12:26:50.086 DEBUG ydbd(pid=1181914, tid=0x00007FF9FC8EB640) [DQ] resource_allocator.cpp:119: {ptqudq7ug0qh33tsumcl/[2:7582946912339648573:2171]} RequestedNode: 2
2025-12-12T12:26:50.086235Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ee00f4e3-30733b25-466103a7-271834a4 2025-12-12 12:26:50.086 DEBUG ydbd(pid=1181914, tid=0x00007FF9FC8EB640) [DQ] resource_allocator.cpp:119: {ptqudq7ug0qh33tsumcl/[2:7582946912339648573:2171]} RequestedNode: 1
2025-12-12T12:26:50.086259Z :YQL_PROXY WARN: log.cpp:64: SessionId: ee00f4e3-30733b25-466103a7-271834a4 2025-12-12 12:26:50.086 WARN  ydbd(pid=1181914, tid=0x00007FF9FC8EB640) [DQ] resource_allocator.cpp:259: {ptqudq7ug0qh33tsumcl/[2:7582946912339648573:2171]} Send TEvAllocateWorkersRequest to Id:5c1cd0bb-40bbb2eb-7da4d088-e9de76d7,ghrun-fhkyrtz6p4,NodeId:2,
2025-12-12T12:26:50.086278Z :YQL_PROXY WARN: log.cpp:64: SessionId: ee00f4e3-30733b25-466103a7-271834a4 2025-12-12 12:26:50.086 WARN  ydbd(pid=1181914, tid=0x00007FF9FC8EB640) [DQ] resource_allocator.cpp:259: {ptqudq7ug0qh33tsumcl/[2:7582946912339648573:2171]} Send TEvAllocateWorkersRequest to Id:d829f000-4dbdfde3-3bf560b6-de987134,ghrun-fhkyrtz6p4,NodeId:1,
2025-12-12T12:26:50.086298Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ee00f4e3-30733b25-466103a7-271834a4 2025-12-12 12:26:50.086 DEBUG ydbd(pid=1181914, tid=0x00007FF9FC8EB640) [DQ] local_worker_manager.cpp:316: {ptqudq7ug0qh33tsumcl} TLocalWorkerManager::TEvAllocateWorkersRequest 281487861612546
2025-12-12T12:26:50.086316Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ee00f4e3-30733b25-466103a7-271834a4 2025-12-12 12:26:50.086 DEBUG ydbd(pid=1181914, tid=0x00007FF9FC8EB640) [DQ] local_worker_manager.cpp:376: {ptqudq7ug0qh33tsumcl} Create compute actor: async
2025-12-12T12:26:50.086651Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ee00f4e3-30733b25-466103a7-271834a4 2025-12-12 12:26:50.086 DEBUG ydbd(pid=1181914, tid=0x00007FF9FC8EB640) [DQ] resource_allocator.cpp:141: {ptqudq7ug0qh33tsumcl/[2:7582946912339648573:2171]} TEvAllocateWorkersResponse 2
2025-12-12T12:26:50.086662Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:144: SelfId: [2:7582946912339648574:2172], TxId: ptqudq7ug0qh33tsumcl, task: 1. Ctx: {}. Start compute actor [2:7582946912339648574:2172], task: 1
2025-12-12T12:26:50.086685Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:114: SelfId: [2:7582946912339648574:2172], TxId: ptqudq7ug0qh33tsumcl, task: 1. Ctx: {}. Use CPU quota: 1. Rate limiter resource: { "local/RateLimiter_aa8e5e39-078a-4312-ac39-3dfb6cffb35f/rate_limiter", "mock_cloud/my_folder/ptqudq7ug0qh33tsumcl" }
2025-12-12T12:26:50.086746Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ee00f4e3-30733b25-466103a7-271834a4 2025-12-12 12:26:50.086 DEBUG ydbd(pid=1181914, tid=0x00007FF9FC8EB640) [DQ] tasks_runner_local.cpp:267: {TODO/1} Build task: 1
2025-12-12T12:26:50.086816Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ee00f4e3-30733b25-466103a7-271834a4 2025-12-12 12:26:50.086 DEBUG ydbd(pid=1181914, tid=0x00007FF9FC8EB640) [DQ] tasks_runner_local.cpp:267: {TODO/1} task: 1, program size: 68, llvm: ``.
2025-12-12T12:26:50.090402Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:26:50.090415Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:26:50.096839Z :INTERCONNECT WARN: interconnect_handshake.cpp:501: Handshake [2:7582946912339648579:2062] [node 3] ICH09 Neither CompatibilityInfo nor VersionTag of the peer can be validated, accepting by default
2025-12-12T12:26:50.144883Z :FQ_PINGER TRACE: pinger.cpp:338: QueryId: ptqudq7ug0qh33tsumcl, Owner: ee00f4e3-30733b25-466103a7-271834a48 Ping response success: { expired_at { seconds: 1765542430 nanos: 131000000 } }
2025-12-12T12:26:50.144924Z :FQ_RUN_ACTOR TRACE: run_actor.cpp:861: QueryId: ptqudq7ug0qh33tsumcl Forward ping response. Success: 1. Cookie: 0
2025-12-12T12:26:50.164725Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ee00f4e3-30733b25-466103a7-271834a4 2025-12-12 12:26:50.164 DEBUG ydbd(pid=1181914, tid=0x00007FF9FC8EB640) [DQ] tasks_runner_local.cpp:267: {TODO/1} Build task: 1 takes 77938 us
2025-12-12T12:26:50.164752Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ee00f4e3-30733b25-466103a7-271834a4 2025-12-12 12:26:50.164 DEBUG ydbd(pid=1181914, tid=0x00007FF9FC8EB640) [DQ] tasks_runner_local.cpp:267: {TODO/1} Prepare task: 1
2025-12-12T12:26:50.164778Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ee00f4e3-30733b25-466103a7-271834a4 2025-12-12 12:26:50.164 DEBUG ydbd(pid=1181914, tid=0x00007FF9FC8EB640) [DQ] tasks_runner_local.cpp:267: {TODO/1} Prepare task: 1, takes 19 us
2025-12-12T12:26:50.164873Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1360: SelfId: [2:7582946912339648574:2172], TxId: ptqudq7ug0qh33tsumcl, task: 1. Ctx: {}. Create source for input 0 { Source { Type: "PqSource" Settings { type_url: "type.googleapis.com/NYql.NPq.NProto.TDqPqTopicSource" value: "\n\031test_metadatafields_input\022\024ptqudq7ug0qh33tsumcl\032\017localhost:10706\"\025\n\023cluster:default_yds*\005local0\002@\001R\017_yql_sys_seq_noR\025_yql_sys_partition_idR\024_yql_sys_create_timeR\031_yql_sys_message_group_idR\027_yql_sys_tsp_write_timeR\017_yql_sys_offsetb\004timej\024[\"DataType\";\"Int32\"]x\001\222\001\024ptcudq7ug1asmkbben1h\232\001\rjson_each_row\242\001\315\002[\"StructType\";[[\"_yql_sys_create_time\";[\"DataType\";\"Timestamp\"]];[\"_yql_sys_message_group_id\";[\"DataType\";\"String\"]];[\"_yql_sys_offset\";[\"DataType\";\"Uint64\"]];[\"_yql_sys_partition_id\";[\"DataType\";\"Uint64\"]];[\"_yql_sys_seq_no\";[\"DataType\";\"Uint64\"]];[\"_yql_sys_tsp_write_time\";[\"DataType\";\"Timestamp\"]];[\"time\";[\"DataType\";\"Int32\"]]]]\262\001\002\022\000\272\001\026\n\010cloud_id\022\nmock_cloud\272\001 \n\005scope\022\027yandexcloud://my_folder" } WatermarksMode: WATERMARKS_MODE_DISABLED } }
2025-12-12T12:26:50.164954Z :KQP_COMPUTE INFO: dq_pq_rd_read_actor.cpp:557: SelfId: [0:0:0], TxId: ptqudq7ug0qh33tsumcl, task: 1. PQ source. Start read actor, local row dispatcher [0:5788050504107380562:5260383], metadatafields: _yql_sys_seq_no,_yql_sys_partition_id,_yql_sys_create_time,_yql_sys_message_group_id,_yql_sys_tsp_write_time,_yql_sys_offset, partitions: 0, skip json errors: 0
2025-12-12T12:26:50.165020Z :KQP_COMPUTE DEBUG: dq_pq_read_actor_base.cpp:153: SelfId: [0:0:0], TxId: ptqudq7ug0qh33tsumcl, task: 1. PQ source. SessionId: empty Watermarks enabled: 0 granularity: 0.000000s late arrival delay: 0.000000s idle: 0 idle timeout: 0.000000s
2025-12-12T12:26:50.165059Z :YQL_PROXY TRACE: log.cpp:64: SessionId:  2025-12-12 12:26:50.165 TRACE ydbd(pid=1181914, tid=0x00007FF9FC8EB640) [DQ] task_controller_impl.h:160: [2:7582946912339648572:2170] EvState TaskId: 1 State: 2 PingCookie: 0 StatusCode: UNSPECIFIED
2025-12-12T12:26:50.165067Z :YQL_PROXY TRACE: log.cpp:64: SessionId:  2025-12-12 12:26:50.165 TRACE ydbd(pid=1181914, tid=0x00007FF9FC8EB640) [DQ] task_controller_impl.h:201:  [2:7582946912339648572:2170] Executing TaskId: 1
2025-12-12T12:26:50.591848Z :YQL_PROXY ERROR: log.cpp:64: SessionId: ee00f4e3-30733b25-466103a7-271834a4 2025-12-12 12:26:50.591 ERROR ydbd(pid=1181914, tid=0x00007FF9FC8EB640) [DQ] resource_allocator.cpp:303: {ptqudq7ug0qh33tsumcl/[2:7582946912339648573:2171]} Disconnected from worker: `Id:d829f000-4dbdfde3-3bf560b6-de987134,ghrun-fhkyrtz6p4,NodeId:1,', reason: Undelivered
2025-12-12T12:26:50.591905Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudq7ug0qh33tsumcl 2025-12-12 12:26:50.591 DEBUG ydbd(pid=1181914, tid=0x00007FF9FC8EB640) [DQ] executer_actor.cpp:358: {ptqudq7ug0qh33tsumcl} TDqExecuter::TEvAllocateWorkersResponse
2025-12-12T12:26:50.591917Z :YQL_PROXY ERROR: log.cpp:64: SessionId: ptqudq7ug0qh33tsumcl 2025-12-12 12:26:50.591 ERROR ydbd(pid=1181914, tid=0x00007FF9FC8EB640) [DQ] executer_actor.cpp:370: {ptqudq7ug0qh33tsumcl} Error on allocate workers Disconnected from worker: `Id:d829f000-4dbdfde3-3bf560b6-de987134,ghrun-fhkyrtz6p4,NodeId:1,', reason: Undelivered:UNAVAILABLE
2025-12-12T12:26:50.591935Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudq7ug0qh33tsumcl 2025-12-12 12:26:50.591 DEBUG ydbd(pid=1181914, tid=0x00007FF9FC8EB640) [DQ] executer_actor.cpp:284: {ptqudq7ug0qh33tsumcl} Finish with status=5 issues=<main>: Error: Disconnected from worker: `Id:d829f000-4dbdfde3-3bf560b6-de987134,ghrun-fhkyrtz6p4,NodeId:1,', reason: Undelivered, code: 6001

2025-12-12T12:26:50.591970Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudq7ug0qh33tsumcl 2025-12-12 12:26:50.591 DEBUG ydbd(pid=1181914, tid=0x00007FF9FC8EB640) [DQ] executer_actor.cpp:341: {ptqudq7ug0qh33tsumcl} OnQueryResponse status=5 issuses_size=1
2025-12-12T12:26:50.592016Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:1233: QueryId: ptqudq7ug0qh33tsumcl Query response UNAVAILABLE. Result set index: 0. Issues count: 1. Rows count: 0
2025-12-12T12:26:50.592076Z :FQ_RUN_ACTOR WARN: run_actor.cpp:1914: QueryId: ptqudq7ug0qh33tsumcl ResignQuery, status UNAVAILABLE
2025-12-12T12:26:50.592080Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:1919: QueryId: ptqudq7ug0qh33tsumcl SendPingAndPassAway, FinalQueryStatus COMPUTE_STATUS_UNSPECIFIED
2025-12-12T12:26:50.592094Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:536: QueryId: ptqudq7ug0qh33tsumcl PassAway
2025-12-12T12:26:50.592214Z :YQL_PROXY TRACE: log.cpp:64: SessionId: ee00f4e3-30733b25-466103a7-271834a4 2025-12-12 12:26:50.592 TRACE ydbd(pid=1181914, tid=0x00007FF9FC8EB640) [DQ] task_controller_impl.h:271:  [2:7582946912339648572:2170] ExportStats Summary
2025-12-12T12:26:50.592239Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ee00f4e3-30733b25-466103a7-271834a4 2025-12-12 12:26:50.592 DEBUG ydbd(pid=1181914, tid=0x00007FF9FC8EB640) [DQ] resource_allocator.cpp:228: {ptqudq7ug0qh33tsumcl/[2:7582946912339648573:2171]} TEvFreeWorkersNotify 281487861612546
2025-12-12T12:26:50.592247Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ee00f4e3-30733b25-466103a7-271834a4 2025-12-12 12:26:50.592 DEBUG ydbd(pid=1181914, tid=0x00007FF9FC8EB640) [DQ] resource_allocator.cpp:235: {ptqudq7ug0qh33tsumcl/[2:7582946912339648573:2171]} TEvFreeWorkersNotify 12884901890 (failed)
2025-12-12T12:26:50.592371Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:657: [ptqudq7ug0qh33tsumcl-0.4] PassAway
2025-12-12T12:26:50.592460Z :FQ_PINGER TRACE: pinger.cpp:250: QueryId: ptqudq7ug0qh33tsumcl, Owner: ee00f4e3-30733b25-466103a7-271834a48 Forward ping request: { result_id { value: "ptrudq7ufsv75gaig4et" } statistics: "{\"Graph=0\":{\"Actor\":{\"ActorCreateTimeUs\":{\"sum\":\"447us\",\"count\":1,\"avg\":\"447us\",\"max\":\"447us\",\"min\":\"447us\"},\"ClusterName=\":{\"CreateFailTimeUs\":{\"sum\":\"0.50s\",\"count\":1,\"avg\":\"0.50s\",\"max\":\"0.50s\",\"min\":\"0.50s\"}}},\"AllocateWorkersUs\":{\"sum\":\"0.50s\",\"count\":1,\"avg\":\"0.50s\",\"max\":\"0.50s\",\"min\":\"0.50s\"},\"Retry\":{\"sum\":5,\"count\":5,\"avg\":1,\"max\":1,\"min\":1},\"TaskRunner\":{\"Stage=Total\":{\"sum\":0,\"count\":0,\"avg\":0,\"max\":0,\"min\":0}}}}" resign_query: true transient_issues { message: "Disconnected from worker: `Id:d829f000-4dbdfde3-3bf560b6-de987134,ghrun-fhkyrtz6p4,NodeId:1,\', reason: Undelivered" issue_code: 6001 severity: 1 } status_code: UNAVAILABLE resources { rate_limiter: READY compilation: READY topic_consumers_state: READY rate_limiter_path: "local/RateLimiter_aa8e5e39-078a-4312-ac39-3dfb6cffb35f/rate_limiter" topic_consumers { database: "local" topic_path: "test_metadatafields_input" consumer_name: "ptqudq7ug0qh33tsumcl" cluster_endpoint: "localhost:10706" token_name: "cluster:default_yds" add_bearer_to_token: true } } }
2025-12-12T12:26:50.592462Z :FQ_PINGER TRACE: pinger.cpp:393: QueryId: ptqudq7ug0qh33tsumcl, Owner: ee00f4e3-30733b25-466103a7-271834a48 Forward request Private::PingTask
2025-12-12T12:26:50.592486Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ee00f4e3-30733b25-466103a7-271834a4 2025-12-12 12:26:50.592 DEBUG ydbd(pid=1181914, tid=0x00007FF9FC8EB640) [DQ] local_worker_manager.cpp:416: TEvFreeWorkersNotify 281487861612546
2025-12-12T12:26:50.592491Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ee00f4e3-30733b25-466103a7-271834a4 2025-12-12 12:26:50.592 DEBUG ydbd(pid=1181914, tid=0x00007FF9FC8EB640) [DQ] local_worker_manager.cpp:440: Free Group 281487861612546
2025-12-12T12:26:50.592697Z :KQP_COMPUTE ERROR: dq_compute_actor_impl.h:1205: SelfId: [2:7582946912339648574:2172], TxId: ptqudq7ug0qh33tsumcl, task: 1. Ctx: {}. Handle abort execution event from: [2:7582946890864811843:2064], status: UNAVAILABLE, reason: { <main>: Error: Aborted by LWM }
2025-12-12T12:26:50.592716Z :KQP_COMPUTE DEBUG: dq_compute_actor_channels.cpp:494: TxId: ptqudq7ug0qh33tsumcl, task: 1. pass away
2025-12-12T12:26:50.592722Z :KQP_COMPUTE INFO: dq_pq_rd_read_actor.cpp:744: SelfId: [0:0:0], TxId: ptqudq7ug0qh33tsumcl, task: 1. PQ source. PassAway
2025-12-12T12:26:50.592734Z :KQP_COMPUTE INFO: dq_pq_rd_read_actor.cpp:1242: SelfId: [0:0:0], TxId: ptqudq7ug0qh33tsumcl, task: 1. PQ source. SelfId: [0:0:0], TxId: ptqudq7ug0qh33tsumcl, task: 1. PQ source. State: used buffer size 0 ready buffer event size 0 state 0 InFlyAsyncInputData 0
Counters: CoordinatorChanged 0 CoordinatorResult 0 MessageBatch 0 StartSessionAck 0 NewDataArrived 0 SessionError 0 Statistics 0 NodeDisconnected 0 NodeConnected 0 Undelivered 0 Retry 0 PrivateHeartbeat 0 SessionClosed 0 Pong 0 Heartbeat 0 PrintState 0 ProcessState 0 GetAsyncInputData 0 NotifyCA 0
2025-12-12T12:26:50.613292Z :FQ_PINGER ERROR: pinger.cpp:365: QueryId: ptqudq7ug0qh33tsumcl, Owner: ee00f4e3-30733b25-466103a7-271834a48 Ping response error: Query ownership time is over: expired_at=2025-12-12T12:26:50.601000Z < now=2025-12-12T12:26:50.610202Z. Retried 0 times during 0.018433s
2025-12-12T12:26:50.613330Z :FQ_PINGER DEBUG: pinger.cpp:379: QueryId: ptqudq7ug0qh33tsumcl, Owner: ee00f4e3-30733b25-466103a7-271834a48 Query finished
2025-12-12T12:26:50.613333Z :FQ_PINGER TRACE: pinger.cpp:187: QueryId: ptqudq7ug0qh33tsumcl, Owner: ee00f4e3-30733b25-466103a7-271834a48 Stop Pinger
2025-12-12T12:26:50.724667Z :INTERCONNECT WARN: interconnect_handshake.cpp:501: Handshake [2:7582946912339648593:2064] [node 1] ICH09 Neither CompatibilityInfo nor VersionTag of the peer can be validated, accepting by default
2025-12-12T12:26:50.725526Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:144: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Start compute actor [2:7582946912339648598:2177], task: 2
2025-12-12T12:26:50.725547Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:114: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Use CPU quota: 1. Rate limiter resource: { "local/RateLimiter_aa8e5e39-078a-4312-ac39-3dfb6cffb35f/rate_limiter", "mock_cloud/my_folder/ptqudq7ug0qh33tsumcl" }
2025-12-12T12:26:50.910131Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1447: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, 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:10706\032\025\n\023cluster:default_yds\"\005local0\0018\002" } } }
2025-12-12T12:26:50.912107Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1064: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Received channels info: Update { Id: 1 TransportVersion: DATA_TRANSPORT_UV_PICKLE_1_0 SrcTaskId: 1 DstTaskId: 2 SrcEndpoint { ActorId { RawX1: 7582946913588404373 RawX2: 4503603922339954 } } DstEndpoint { ActorId { RawX1: 7582946912339648598 RawX2: 4503608217307265 } } WatermarksMode: WATERMARKS_MODE_DISABLED SrcStageId: 204497 DstStageId: 204517 }
2025-12-12T12:26:50.912119Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1071: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Update input channelId: 1, peer: [1:7582946913588404373:2162]
2025-12-12T12:26:50.919779Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:197: [] Task: 2. Got TEvNewCheckpointCoordinator event: generation 5, actorId: [1:7582946913588404364:2159]
2025-12-12T12:26:50.919791Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:208: [] Task: 2. Assign checkpoint coordinator (generation = 5)
2025-12-12T12:26:50.920522Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:395: [ptqudq7ug0qh33tsumcl-0] Task: 2. Handle connected node 1
2025-12-12T12:26:51.057743Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: ee00f4e3-30733b25-466103a7-271834a410, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:26:51.057748Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582946887818600390:2082]
2025-12-12T12:26:51.057765Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:26:51.063081Z :FQ_QUOTA_SERVICE DEBUG: quota_manager.cpp:230: IC Peers[2]: [1, 3]
2025-12-12T12:26:51.063327Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:26:51.071360Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:26:51.071384Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:26:51.119249Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1164: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Got TEvRun from actor [1:7582946913588404364:2159]
2025-12-12T12:26:51.119292Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:129: TxId: ptqudq7ug0qh33tsumcl, task: 2. Received input for channelId: 1, seqNo: 1, size: 0, chunks: 0, watermark: 0, checkpoint: 1, finished: 0, from: [1:7582946913588404374:2162], expected seqNo: 1
2025-12-12T12:26:51.119295Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:611: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. took input
2025-12-12T12:26:51.119321Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:485: [ptqudq7ug0qh33tsumcl-0] Task: 2. [Checkpoint 5.1] Got checkpoint barrier from channel 1
2025-12-12T12:26:51.119332Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Poll inputs
2025-12-12T12:26:51.119334Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1494: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-12-12T12:26:51.119337Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. DoExecuteImpl: 1
2025-12-12T12:26:51.119352Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:356: SelfId: [2:7582946912339648600:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. No watermark 
2025-12-12T12:26:51.119489Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:462: SelfId: [2:7582946912339648600:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Pending 1 checkpoints to be sent
2025-12-12T12:26:51.119494Z :KQP_COMPUTE TRACE: dq_compute_memory_quota.h:97: TxId: ptqudq7ug0qh33tsumcl, task: 2. Peak memory usage: 196608
2025-12-12T12:26:51.119503Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:965: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Input data push finished. Cookie: 0 Watermark: (empty maybe) Ack: 1 TakeInputChannelDataRequests: 1
2025-12-12T12:26:51.119508Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:738: TxId: ptqudq7ug0qh33tsumcl, task: 2. Sending channel data ack to channelId: 1, peer: [1:7582946913588404373:2162], from: [2:7582946912339648598:2177], freeSpace: 1000000, seqNo: 1, finished: 0
2025-12-12T12:26:51.119520Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. update task runner stats
2025-12-12T12:26:51.119542Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 1 watermark injected: (empty maybe)
2025-12-12T12:26:51.119545Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:447: [ptqudq7ug0qh33tsumcl-0] Task: 2. [Checkpoint 5.1] Performing task checkpoint
2025-12-12T12:26:51.119547Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:816: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Save state
2025-12-12T12:26:51.119549Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:474: [ptqudq7ug0qh33tsumcl-0] Task: 2. [Checkpoint 5.1] CA state saved
2025-12-12T12:26:51.119551Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:449: [ptqudq7ug0qh33tsumcl-0] Task: 2. [Checkpoint 5.1] Injecting checkpoint barrier to outputs
2025-12-12T12:26:51.119554Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:26:51.119558Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-12T12:26:51.119563Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1107: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Ask CPU quota: 185ms
2025-12-12T12:26:51.119585Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Poll inputs
2025-12-12T12:26:51.119587Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Poll sources
2025-12-12T12:26:51.119588Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-12-12T12:26:51.119595Z :KQP_COMPUTE INFO: dq_async_compute_actor.cpp:1010: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Resume inputs
2025-12-12T12:26:51.119598Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [0:0:0], TxId: ptqudq7ug0qh33tsumcl, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 1. Finished: 0
2025-12-12T12:26:51.119675Z :KQP_COMPUTE DEBUG: dq_pq_write_actor.cpp:240: SelfId: [0:0:0], TxId: ptqudq7ug0qh33tsumcl, TaskId: 2, PQ sink. [Checkpoint 5.1] Send checkpoint state immediately
2025-12-12T12:26:51.119847Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:418: SelfId: [0:0:0], TxId: ptqudq7ug0qh33tsumcl, TaskId: 2, PQ sink. Save checkpoint { Id: 1 Generation: 5 Type: CHECKPOINT_TYPE_SNAPSHOT } state: { SourceId: "d4bed037-c2c9c284-b6a94c47-e88c4d91" }
2025-12-12T12:26:51.119852Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:524: [ptqudq7ug0qh33tsumcl-0] Task: 2. Sink[0] state saved
2025-12-12T12:26:51.119865Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:536: [ptqudq7ug0qh33tsumcl-0] Task: 2. [Checkpoint 5.1] Task checkpoint is done. Send to storage
2025-12-12T12:26:51.119872Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 6 bytes of checkpoint barrier
2025-12-12T12:26:51.119875Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-12T12:26:51.119884Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudq7ug0qh33tsumcl, task: 2. no poll, channelId: 1, has inflight messages: [1], last with freeSpace: 1000000, current freeSpace: 1000000
2025-12-12T12:26:51.119894Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Poll inputs
2025-12-12T12:26:51.119895Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Poll sources
2025-12-12T12:26:51.119897Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-12-12T12:26:51.120088Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:460: [ptqudq7ug0qh33tsumcl-0] [5:1] Got TEvSaveTaskState: task 2
2025-12-12T12:26:51.127120Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:26:51.127100Z :INFO: [local] OnFederationDiscovery fall back to single mode, database=local
2025-12-12T12:26:51.127338Z :YDB_SDK INFO: actor.cpp:37: [] [] Start federated write session to database '' (previous was <empty>) FederationState: { Status: SUCCESS SelfLocation: "" DbInfos: [ { path: "local" endpoint: "localhost:10706" status: AVAILABLE weight: 100 } ] ControlPlaneEndpoint: localhost:10706 }
2025-12-12T12:26:51.127457Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:51.127450Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug0qh33tsumcl, TaskId: 2, PQ sink. ]  SessionId []  MessageGroupId [d4bed037-c2c9c284-b6a94c47-e88c4d91] Write session: try to update token
2025-12-12T12:26:51.127750Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:26:51.127747Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug0qh33tsumcl, TaskId: 2, PQ sink. ]  SessionId []  MessageGroupId [d4bed037-c2c9c284-b6a94c47-e88c4d91] Start write session. Will connect to nodeId: 0
2025-12-12T12:26:51.128095Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:51.128085Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug0qh33tsumcl, TaskId: 2, PQ sink. ]  SessionId []  MessageGroupId [d4bed037-c2c9c284-b6a94c47-e88c4d91] Write session: write to message_group: d4bed037-c2c9c284-b6a94c47-e88c4d91
2025-12-12T12:26:51.128128Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:51.128126Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug0qh33tsumcl, TaskId: 2, PQ sink. ]  SessionId []  MessageGroupId [d4bed037-c2c9c284-b6a94c47-e88c4d91] Write session: send init request: init_request { path: "test_metadatafields_output" producer_id: "d4bed037-c2c9c284-b6a94c47-e88c4d91" message_group_id: "d4bed037-c2c9c284-b6a94c47-e88c4d91" }
2025-12-12T12:26:51.128132Z :YDB_SDK TRACE: actor.cpp:37: 2025-12-12T12:26:51.128130Z :TRACE: [local] TRACE_EVENT InitRequest 
2025-12-12T12:26:51.128218Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:51.128215Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug0qh33tsumcl, TaskId: 2, PQ sink. ]  SessionId []  MessageGroupId [d4bed037-c2c9c284-b6a94c47-e88c4d91] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T12:26:51.135123Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1165: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. CPU quota delay: 15ms
2025-12-12T12:26:51.135254Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. update task runner stats
2025-12-12T12:26:51.135304Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-12T12:26:51.135321Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:26:51.135327Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-12T12:26:51.135340Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [2:7582946912339648605:2177], TxId: ptqudq7ug0qh33tsumcl, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-12-12T12:26:51.135351Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-12-12T12:26:51.135353Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-12T12:26:51.135363Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudq7ug0qh33tsumcl, task: 2. no poll, channelId: 1, has inflight messages: [1], last with freeSpace: 1000000, current freeSpace: 1000000
2025-12-12T12:26:51.145848Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:484: [ptqudq7ug0qh33tsumcl-0] [5:1] TEvSaveTaskState Apply: task: 2
2025-12-12T12:26:51.145872Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:499: [ptqudq7ug0qh33tsumcl-0] [5:1] Send TEvSaveTaskStateResult: task: 2
2025-12-12T12:26:51.227989Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:759: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Commit state
2025-12-12T12:26:51.770596Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:51.770585Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug0qh33tsumcl, TaskId: 2, PQ sink. ]  SessionId []  MessageGroupId [d4bed037-c2c9c284-b6a94c47-e88c4d91] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T12:26:51.770620Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:26:51.770618Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug0qh33tsumcl, TaskId: 2, PQ sink. ]  SessionId []  MessageGroupId [d4bed037-c2c9c284-b6a94c47-e88c4d91] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1765542411770 BytesWritten: 0 MessagesWritten: 0 BytesWrittenCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:26:51.770647Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:26:51.770644Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug0qh33tsumcl, TaskId: 2, PQ sink. ]  SessionId []  MessageGroupId [d4bed037-c2c9c284-b6a94c47-e88c4d91] Write session established. Init response: session_id: "d4bed037-c2c9c284-b6a94c47-e88c4d91|5a3dda01-47d5fe26-6b38256c-d11a07d0_0"
2025-12-12T12:26:51.770653Z :YDB_SDK TRACE: actor.cpp:37: 2025-12-12T12:26:51.770651Z :TRACE: [local] TRACE_EVENT InitResponse  partition_id=0 session_id=d4bed037-c2c9c284-b6a94c47-e88c4d91|5a3dda01-47d5fe26-6b38256c-d11a07d0_0
2025-12-12T12:26:51.770657Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:51.770656Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug0qh33tsumcl, TaskId: 2, PQ sink. ]  SessionId [d4bed037-c2c9c284-b6a94c47-e88c4d91|5a3dda01-47d5fe26-6b38256c-d11a07d0_0]  MessageGroupId [d4bed037-c2c9c284-b6a94c47-e88c4d91] Write session: set DirectWriteToPartitionId 0
2025-12-12T12:26:51.770721Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:26:51.770718Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug0qh33tsumcl, TaskId: 2, PQ sink. ]  SessionId [d4bed037-c2c9c284-b6a94c47-e88c4d91|5a3dda01-47d5fe26-6b38256c-d11a07d0_0]  PartitionId [0]  Generation [0] Get partition location async, partition 0, delay 0.000000s
2025-12-12T12:26:51.770738Z :YDB_SDK TRACE: actor.cpp:37: 2025-12-12T12:26:51.770737Z :TRACE: [local] TRACE_EVENT DescribePartitionRequest  path=local/test_metadatafields_output partition_id=0
2025-12-12T12:26:51.770778Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:51.770774Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug0qh33tsumcl, TaskId: 2, PQ sink. ]  SessionId [d4bed037-c2c9c284-b6a94c47-e88c4d91|5a3dda01-47d5fe26-6b38256c-d11a07d0_0]  PartitionId [0]  Generation [0]  Getting partition location, partition 0
2025-12-12T12:26:51.776816Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:26:51.776806Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug0qh33tsumcl, TaskId: 2, PQ sink. ]  SessionId [d4bed037-c2c9c284-b6a94c47-e88c4d91|5a3dda01-47d5fe26-6b38256c-d11a07d0_0]  PartitionId [0]  Generation [0] Got PartitionLocation response. Status SUCCESS, proto:
partition {
  active: true
  partition_location {
    node_id: 1
    generation: 1
  }
}

2025-12-12T12:26:51.776837Z :YDB_SDK TRACE: actor.cpp:37: 2025-12-12T12:26:51.776834Z :TRACE: [local] TRACE_EVENT DescribePartitionResponse  partition_id=0 active=1 pl_node_id=1 pl_generation=1
2025-12-12T12:26:51.776846Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:51.776844Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug0qh33tsumcl, TaskId: 2, PQ sink. ]  SessionId [d4bed037-c2c9c284-b6a94c47-e88c4d91|5a3dda01-47d5fe26-6b38256c-d11a07d0_0]  PartitionId [0]  Generation [0] GetPreferredEndpoint: partitionId 0, partitionNodeId 1 exists in the endpoint pool.
2025-12-12T12:26:51.776855Z :YDB_SDK TRACE: actor.cpp:37: 2025-12-12T12:26:51.776854Z :TRACE: [local] TRACE_EVENT PreferredPartitionLocation  Endpoint= NodeId=1 Generation=1
2025-12-12T12:26:51.776860Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:26:51.776858Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug0qh33tsumcl, TaskId: 2, PQ sink. ]  SessionId [d4bed037-c2c9c284-b6a94c47-e88c4d91|5a3dda01-47d5fe26-6b38256c-d11a07d0_0]  PartitionId [0]  Generation [1] Start write session. Will connect to nodeId: 1
2025-12-12T12:26:51.777504Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:51.777498Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug0qh33tsumcl, TaskId: 2, PQ sink. ]  SessionId [d4bed037-c2c9c284-b6a94c47-e88c4d91|5a3dda01-47d5fe26-6b38256c-d11a07d0_0]  PartitionId [0]  Generation [1] Write session: direct write to partition: 0, generation 1
2025-12-12T12:26:51.777550Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:51.777548Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug0qh33tsumcl, TaskId: 2, PQ sink. ]  SessionId [d4bed037-c2c9c284-b6a94c47-e88c4d91|5a3dda01-47d5fe26-6b38256c-d11a07d0_0]  PartitionId [0]  Generation [1] Write session: send init request: init_request { path: "test_metadatafields_output" producer_id: "d4bed037-c2c9c284-b6a94c47-e88c4d91" partition_with_generation { generation: 1 } }
2025-12-12T12:26:51.777557Z :YDB_SDK TRACE: actor.cpp:37: 2025-12-12T12:26:51.777553Z :TRACE: [local] TRACE_EVENT InitRequest  pwg_partition_id=0 pwg_generation=1
2025-12-12T12:26:51.777635Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:51.777633Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug0qh33tsumcl, TaskId: 2, PQ sink. ]  SessionId [d4bed037-c2c9c284-b6a94c47-e88c4d91|5a3dda01-47d5fe26-6b38256c-d11a07d0_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 1, Msg: CANCELLED, Details: , InternalError: 0
2025-12-12T12:26:51.777722Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:51.777720Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug0qh33tsumcl, TaskId: 2, PQ sink. ]  SessionId [d4bed037-c2c9c284-b6a94c47-e88c4d91|5a3dda01-47d5fe26-6b38256c-d11a07d0_0]  PartitionId [0]  Generation [1] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T12:26:51.792842Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:51.792817Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug0qh33tsumcl, TaskId: 2, PQ sink. ]  SessionId [d4bed037-c2c9c284-b6a94c47-e88c4d91|5a3dda01-47d5fe26-6b38256c-d11a07d0_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T12:26:51.792889Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:26:51.792884Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug0qh33tsumcl, TaskId: 2, PQ sink. ]  SessionId [d4bed037-c2c9c284-b6a94c47-e88c4d91|5a3dda01-47d5fe26-6b38256c-d11a07d0_0]  PartitionId [0]  Generation [1] Write session established. Init response: session_id: "d4bed037-c2c9c284-b6a94c47-e88c4d91|ffd2bc97-aafc0c1c-34fd4523-8ebff99a_0"
2025-12-12T12:26:51.792898Z :YDB_SDK TRACE: actor.cpp:37: 2025-12-12T12:26:51.792894Z :TRACE: [local] TRACE_EVENT InitResponse  partition_id=0 session_id=d4bed037-c2c9c284-b6a94c47-e88c4d91|ffd2bc97-aafc0c1c-34fd4523-8ebff99a_0
2025-12-12T12:26:51.792902Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:51.792900Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug0qh33tsumcl, TaskId: 2, PQ sink. ]  SessionId [d4bed037-c2c9c284-b6a94c47-e88c4d91|ffd2bc97-aafc0c1c-34fd4523-8ebff99a_0]  PartitionId [0]  Generation [1] Write session: set DirectWriteToPartitionId 0
2025-12-12T12:26:52.058875Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: ee00f4e3-30733b25-466103a7-271834a411, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:26:52.068081Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:129: TxId: ptqudq7ug0qh33tsumcl, task: 2. Received input for channelId: 1, seqNo: 2, size: 0, chunks: 0, watermark: 0, checkpoint: 1, finished: 0, from: [1:7582946913588404374:2162], expected seqNo: 2
2025-12-12T12:26:52.068096Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:611: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. took input
2025-12-12T12:26:52.068109Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:485: [ptqudq7ug0qh33tsumcl-0] Task: 2. [Checkpoint 5.2] Got checkpoint barrier from channel 1
2025-12-12T12:26:52.068127Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:356: SelfId: [2:7582946912339648600:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. No watermark 
2025-12-12T12:26:52.068132Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Poll inputs
2025-12-12T12:26:52.068134Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1494: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-12-12T12:26:52.068136Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. DoExecuteImpl: 1
2025-12-12T12:26:52.068145Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:965: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Input data push finished. Cookie: 1 Watermark: (empty maybe) Ack: 1 TakeInputChannelDataRequests: 1
2025-12-12T12:26:52.068151Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:738: TxId: ptqudq7ug0qh33tsumcl, task: 2. Sending channel data ack to channelId: 1, peer: [1:7582946913588404373:2162], from: [2:7582946912339648598:2177], freeSpace: 1000000, seqNo: 2, finished: 0
2025-12-12T12:26:52.068250Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:462: SelfId: [2:7582946912339648600:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Pending 1 checkpoints to be sent
2025-12-12T12:26:52.068257Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Poll inputs
2025-12-12T12:26:52.068258Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1494: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-12-12T12:26:52.068259Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-12-12T12:26:52.068262Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. update task runner stats
2025-12-12T12:26:52.068296Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 1 watermark injected: (empty maybe)
2025-12-12T12:26:52.068300Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:447: [ptqudq7ug0qh33tsumcl-0] Task: 2. [Checkpoint 5.2] Performing task checkpoint
2025-12-12T12:26:52.068302Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:816: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Save state
2025-12-12T12:26:52.068305Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:474: [ptqudq7ug0qh33tsumcl-0] Task: 2. [Checkpoint 5.2] CA state saved
2025-12-12T12:26:52.068308Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:449: [ptqudq7ug0qh33tsumcl-0] Task: 2. [Checkpoint 5.2] Injecting checkpoint barrier to outputs
2025-12-12T12:26:52.068310Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:26:52.068314Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-12T12:26:52.068322Z :KQP_COMPUTE INFO: dq_async_compute_actor.cpp:1010: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Resume inputs
2025-12-12T12:26:52.068325Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [2:7582946912339648605:2177], TxId: ptqudq7ug0qh33tsumcl, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 1. Finished: 0
2025-12-12T12:26:52.068328Z :KQP_COMPUTE DEBUG: dq_pq_write_actor.cpp:240: SelfId: [2:7582946912339648605:2177], TxId: ptqudq7ug0qh33tsumcl, TaskId: 2, PQ sink. [Checkpoint 5.2] Send checkpoint state immediately
2025-12-12T12:26:52.068369Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:418: SelfId: [2:7582946912339648605:2177], TxId: ptqudq7ug0qh33tsumcl, TaskId: 2, PQ sink. Save checkpoint { Id: 2 Generation: 5 Type: CHECKPOINT_TYPE_SNAPSHOT } state: { SourceId: "d4bed037-c2c9c284-b6a94c47-e88c4d91" }
2025-12-12T12:26:52.068373Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:524: [ptqudq7ug0qh33tsumcl-0] Task: 2. Sink[0] state saved
2025-12-12T12:26:52.068383Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:536: [ptqudq7ug0qh33tsumcl-0] Task: 2. [Checkpoint 5.2] Task checkpoint is done. Send to storage
2025-12-12T12:26:52.068391Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 6 bytes of checkpoint barrier
2025-12-12T12:26:52.068392Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-12T12:26:52.068399Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudq7ug0qh33tsumcl, task: 2. no poll, channelId: 1, has inflight messages: [2], last with freeSpace: 1000000, current freeSpace: 1000000
2025-12-12T12:26:52.068422Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Poll inputs
2025-12-12T12:26:52.068423Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Poll sources
2025-12-12T12:26:52.068426Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-12-12T12:26:52.068428Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. update task runner stats
2025-12-12T12:26:52.068436Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-12T12:26:52.068438Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:26:52.068440Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-12T12:26:52.068444Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [2:7582946912339648605:2177], TxId: ptqudq7ug0qh33tsumcl, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-12-12T12:26:52.068446Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-12-12T12:26:52.068448Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-12T12:26:52.068451Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudq7ug0qh33tsumcl, task: 2. no poll, channelId: 1, has inflight messages: [2], last with freeSpace: 1000000, current freeSpace: 1000000
2025-12-12T12:26:52.068463Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. update task runner stats
2025-12-12T12:26:52.068469Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-12T12:26:52.068470Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:26:52.068472Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-12T12:26:52.068475Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [2:7582946912339648605:2177], TxId: ptqudq7ug0qh33tsumcl, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-12-12T12:26:52.068477Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-12-12T12:26:52.068479Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-12T12:26:52.068481Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudq7ug0qh33tsumcl, task: 2. no poll, channelId: 1, has inflight messages: [2], last with freeSpace: 1000000, current freeSpace: 1000000
2025-12-12T12:26:52.068490Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:460: [ptqudq7ug0qh33tsumcl-0] [5:2] Got TEvSaveTaskState: task 2
2025-12-12T12:26:52.071648Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:26:52.071658Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:26:52.074651Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:484: [ptqudq7ug0qh33tsumcl-0] [5:2] TEvSaveTaskState Apply: task: 2
2025-12-12T12:26:52.074666Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:499: [ptqudq7ug0qh33tsumcl-0] [5:2] Send TEvSaveTaskStateResult: task: 2
2025-12-12T12:26:52.106020Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:759: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Commit state
2025-12-12T12:26:52.999299Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:129: TxId: ptqudq7ug0qh33tsumcl, task: 2. Received input for channelId: 1, seqNo: 3, size: 0, chunks: 0, watermark: 0, checkpoint: 1, finished: 0, from: [1:7582946913588404374:2162], expected seqNo: 3
2025-12-12T12:26:52.999315Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:611: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. took input
2025-12-12T12:26:52.999329Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:485: [ptqudq7ug0qh33tsumcl-0] Task: 2. [Checkpoint 5.3] Got checkpoint barrier from channel 1
2025-12-12T12:26:52.999349Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:356: SelfId: [2:7582946912339648600:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. No watermark 
2025-12-12T12:26:52.999354Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Poll inputs
2025-12-12T12:26:52.999358Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1494: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-12-12T12:26:52.999360Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. DoExecuteImpl: 1
2025-12-12T12:26:52.999369Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:965: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Input data push finished. Cookie: 2 Watermark: (empty maybe) Ack: 1 TakeInputChannelDataRequests: 1
2025-12-12T12:26:52.999374Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:738: TxId: ptqudq7ug0qh33tsumcl, task: 2. Sending channel data ack to channelId: 1, peer: [1:7582946913588404373:2162], from: [2:7582946912339648598:2177], freeSpace: 1000000, seqNo: 3, finished: 0
2025-12-12T12:26:52.999467Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:462: SelfId: [2:7582946912339648600:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Pending 1 checkpoints to be sent
2025-12-12T12:26:52.999473Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Poll inputs
2025-12-12T12:26:52.999474Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1494: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-12-12T12:26:52.999476Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-12-12T12:26:52.999479Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. update task runner stats
2025-12-12T12:26:52.999507Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 1 watermark injected: (empty maybe)
2025-12-12T12:26:52.999510Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:447: [ptqudq7ug0qh33tsumcl-0] Task: 2. [Checkpoint 5.3] Performing task checkpoint
2025-12-12T12:26:52.999513Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:816: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Save state
2025-12-12T12:26:52.999515Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:474: [ptqudq7ug0qh33tsumcl-0] Task: 2. [Checkpoint 5.3] CA state saved
2025-12-12T12:26:52.999517Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:449: [ptqudq7ug0qh33tsumcl-0] Task: 2. [Checkpoint 5.3] Injecting checkpoint barrier to outputs
2025-12-12T12:26:52.999520Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:26:52.999526Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-12T12:26:52.999534Z :KQP_COMPUTE INFO: dq_async_compute_actor.cpp:1010: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Resume inputs
2025-12-12T12:26:52.999537Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [2:7582946912339648605:2177], TxId: ptqudq7ug0qh33tsumcl, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 1. Finished: 0
2025-12-12T12:26:52.999540Z :KQP_COMPUTE DEBUG: dq_pq_write_actor.cpp:240: SelfId: [2:7582946912339648605:2177], TxId: ptqudq7ug0qh33tsumcl, TaskId: 2, PQ sink. [Checkpoint 5.3] Send checkpoint state immediately
2025-12-12T12:26:52.999570Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:418: SelfId: [2:7582946912339648605:2177], TxId: ptqudq7ug0qh33tsumcl, TaskId: 2, PQ sink. Save checkpoint { Id: 3 Generation: 5 Type: CHECKPOINT_TYPE_SNAPSHOT } state: { SourceId: "d4bed037-c2c9c284-b6a94c47-e88c4d91" }
2025-12-12T12:26:52.999573Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:524: [ptqudq7ug0qh33tsumcl-0] Task: 2. Sink[0] state saved
2025-12-12T12:26:52.999586Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:536: [ptqudq7ug0qh33tsumcl-0] Task: 2. [Checkpoint 5.3] Task checkpoint is done. Send to storage
2025-12-12T12:26:52.999595Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 6 bytes of checkpoint barrier
2025-12-12T12:26:52.999597Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-12T12:26:52.999605Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudq7ug0qh33tsumcl, task: 2. no poll, channelId: 1, has inflight messages: [3], last with freeSpace: 1000000, current freeSpace: 1000000
2025-12-12T12:26:52.999629Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Poll inputs
2025-12-12T12:26:52.999632Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Poll sources
2025-12-12T12:26:52.999634Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-12-12T12:26:52.999636Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. update task runner stats
2025-12-12T12:26:52.999645Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-12T12:26:52.999647Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:26:52.999649Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-12T12:26:52.999654Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [2:7582946912339648605:2177], TxId: ptqudq7ug0qh33tsumcl, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-12-12T12:26:52.999656Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-12-12T12:26:52.999658Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-12T12:26:52.999661Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudq7ug0qh33tsumcl, task: 2. no poll, channelId: 1, has inflight messages: [3], last with freeSpace: 1000000, current freeSpace: 1000000
2025-12-12T12:26:52.999673Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. update task runner stats
2025-12-12T12:26:52.999679Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-12T12:26:52.999680Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:26:52.999681Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-12T12:26:52.999684Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [2:7582946912339648605:2177], TxId: ptqudq7ug0qh33tsumcl, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-12-12T12:26:52.999686Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-12-12T12:26:52.999687Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-12T12:26:52.999689Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudq7ug0qh33tsumcl, task: 2. no poll, channelId: 1, has inflight messages: [3], last with freeSpace: 1000000, current freeSpace: 1000000
2025-12-12T12:26:52.999698Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:460: [ptqudq7ug0qh33tsumcl-0] [5:3] Got TEvSaveTaskState: task 2
2025-12-12T12:26:53.005703Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:484: [ptqudq7ug0qh33tsumcl-0] [5:3] TEvSaveTaskState Apply: task: 2
2025-12-12T12:26:53.005726Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:499: [ptqudq7ug0qh33tsumcl-0] [5:3] Send TEvSaveTaskStateResult: task: 2
2025-12-12T12:26:53.034395Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:759: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Commit state
2025-12-12T12:26:53.058703Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582946887818600390:2082]
2025-12-12T12:26:53.058735Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:26:53.058755Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: ee00f4e3-30733b25-466103a7-271834a412, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:26:53.061723Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:26:53.080680Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:26:53.080692Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:26:53.963806Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:129: TxId: ptqudq7ug0qh33tsumcl, task: 2. Received input for channelId: 1, seqNo: 4, size: 0, chunks: 0, watermark: 0, checkpoint: 1, finished: 0, from: [1:7582946913588404374:2162], expected seqNo: 4
2025-12-12T12:26:53.963819Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:611: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. took input
2025-12-12T12:26:53.963835Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:485: [ptqudq7ug0qh33tsumcl-0] Task: 2. [Checkpoint 5.4] Got checkpoint barrier from channel 1
2025-12-12T12:26:53.963851Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:356: SelfId: [2:7582946912339648600:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. No watermark 
2025-12-12T12:26:53.963855Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Poll inputs
2025-12-12T12:26:53.963857Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1494: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-12-12T12:26:53.963862Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. DoExecuteImpl: 1
2025-12-12T12:26:53.963869Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:965: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Input data push finished. Cookie: 3 Watermark: (empty maybe) Ack: 1 TakeInputChannelDataRequests: 1
2025-12-12T12:26:53.963873Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:738: TxId: ptqudq7ug0qh33tsumcl, task: 2. Sending channel data ack to channelId: 1, peer: [1:7582946913588404373:2162], from: [2:7582946912339648598:2177], freeSpace: 1000000, seqNo: 4, finished: 0
2025-12-12T12:26:53.963953Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:462: SelfId: [2:7582946912339648600:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Pending 1 checkpoints to be sent
2025-12-12T12:26:53.963958Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Poll inputs
2025-12-12T12:26:53.963959Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1494: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-12-12T12:26:53.963960Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-12-12T12:26:53.963963Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. update task runner stats
2025-12-12T12:26:53.963998Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 1 watermark injected: (empty maybe)
2025-12-12T12:26:53.964000Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:447: [ptqudq7ug0qh33tsumcl-0] Task: 2. [Checkpoint 5.4] Performing task checkpoint
2025-12-12T12:26:53.964002Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:816: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Save state
2025-12-12T12:26:53.964004Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:474: [ptqudq7ug0qh33tsumcl-0] Task: 2. [Checkpoint 5.4] CA state saved
2025-12-12T12:26:53.964006Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:449: [ptqudq7ug0qh33tsumcl-0] Task: 2. [Checkpoint 5.4] Injecting checkpoint barrier to outputs
2025-12-12T12:26:53.964008Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:26:53.964012Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-12T12:26:53.964019Z :KQP_COMPUTE INFO: dq_async_compute_actor.cpp:1010: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Resume inputs
2025-12-12T12:26:53.964022Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [2:7582946912339648605:2177], TxId: ptqudq7ug0qh33tsumcl, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 1. Finished: 0
2025-12-12T12:26:53.964026Z :KQP_COMPUTE DEBUG: dq_pq_write_actor.cpp:240: SelfId: [2:7582946912339648605:2177], TxId: ptqudq7ug0qh33tsumcl, TaskId: 2, PQ sink. [Checkpoint 5.4] Send checkpoint state immediately
2025-12-12T12:26:53.964050Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:418: SelfId: [2:7582946912339648605:2177], TxId: ptqudq7ug0qh33tsumcl, TaskId: 2, PQ sink. Save checkpoint { Id: 4 Generation: 5 Type: CHECKPOINT_TYPE_SNAPSHOT } state: { SourceId: "d4bed037-c2c9c284-b6a94c47-e88c4d91" }
2025-12-12T12:26:53.964055Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:524: [ptqudq7ug0qh33tsumcl-0] Task: 2. Sink[0] state saved
2025-12-12T12:26:53.964065Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:536: [ptqudq7ug0qh33tsumcl-0] Task: 2. [Checkpoint 5.4] Task checkpoint is done. Send to storage
2025-12-12T12:26:53.964072Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 6 bytes of checkpoint barrier
2025-12-12T12:26:53.964074Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-12T12:26:53.964081Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudq7ug0qh33tsumcl, task: 2. no poll, channelId: 1, has inflight messages: [4], last with freeSpace: 1000000, current freeSpace: 1000000
2025-12-12T12:26:53.964106Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Poll inputs
2025-12-12T12:26:53.964107Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Poll sources
2025-12-12T12:26:53.964109Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-12-12T12:26:53.964111Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. update task runner stats
2025-12-12T12:26:53.964120Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-12T12:26:53.964121Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:26:53.964123Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-12T12:26:53.964127Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [2:7582946912339648605:2177], TxId: ptqudq7ug0qh33tsumcl, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-12-12T12:26:53.964129Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-12-12T12:26:53.964131Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-12T12:26:53.964133Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudq7ug0qh33tsumcl, task: 2. no poll, channelId: 1, has inflight messages: [4], last with freeSpace: 1000000, current freeSpace: 1000000
2025-12-12T12:26:53.964157Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. update task runner stats
2025-12-12T12:26:53.964163Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-12T12:26:53.964165Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:26:53.964167Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-12T12:26:53.964170Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [2:7582946912339648605:2177], TxId: ptqudq7ug0qh33tsumcl, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-12-12T12:26:53.964171Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-12-12T12:26:53.964173Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-12T12:26:53.964175Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudq7ug0qh33tsumcl, task: 2. no poll, channelId: 1, has inflight messages: [4], last with freeSpace: 1000000, current freeSpace: 1000000
2025-12-12T12:26:53.964182Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:460: [ptqudq7ug0qh33tsumcl-0] [5:4] Got TEvSaveTaskState: task 2
2025-12-12T12:26:53.971086Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:484: [ptqudq7ug0qh33tsumcl-0] [5:4] TEvSaveTaskState Apply: task: 2
2025-12-12T12:26:53.971100Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:499: [ptqudq7ug0qh33tsumcl-0] [5:4] Send TEvSaveTaskStateResult: task: 2
2025-12-12T12:26:54.006391Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:759: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Commit state
2025-12-12T12:26:54.059066Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: ee00f4e3-30733b25-466103a7-271834a413, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:26:54.063461Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:26:54.063476Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:26:54.948629Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:129: TxId: ptqudq7ug0qh33tsumcl, task: 2. Received input for channelId: 1, seqNo: 5, size: 0, chunks: 0, watermark: 0, checkpoint: 1, finished: 0, from: [1:7582946913588404374:2162], expected seqNo: 5
2025-12-12T12:26:54.948646Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:611: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. took input
2025-12-12T12:26:54.948659Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:485: [ptqudq7ug0qh33tsumcl-0] Task: 2. [Checkpoint 5.5] Got checkpoint barrier from channel 1
2025-12-12T12:26:54.948675Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:356: SelfId: [2:7582946912339648600:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. No watermark 
2025-12-12T12:26:54.948679Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Poll inputs
2025-12-12T12:26:54.948681Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1494: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-12-12T12:26:54.948683Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. DoExecuteImpl: 1
2025-12-12T12:26:54.948692Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:965: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Input data push finished. Cookie: 4 Watermark: (empty maybe) Ack: 1 TakeInputChannelDataRequests: 1
2025-12-12T12:26:54.948696Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:738: TxId: ptqudq7ug0qh33tsumcl, task: 2. Sending channel data ack to channelId: 1, peer: [1:7582946913588404373:2162], from: [2:7582946912339648598:2177], freeSpace: 1000000, seqNo: 5, finished: 0
2025-12-12T12:26:54.948779Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:462: SelfId: [2:7582946912339648600:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Pending 1 checkpoints to be sent
2025-12-12T12:26:54.948790Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Poll inputs
2025-12-12T12:26:54.948792Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1494: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-12-12T12:26:54.948793Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-12-12T12:26:54.948795Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. update task runner stats
2025-12-12T12:26:54.948821Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 1 watermark injected: (empty maybe)
2025-12-12T12:26:54.948823Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:447: [ptqudq7ug0qh33tsumcl-0] Task: 2. [Checkpoint 5.5] Performing task checkpoint
2025-12-12T12:26:54.948825Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:816: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Save state
2025-12-12T12:26:54.948828Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:474: [ptqudq7ug0qh33tsumcl-0] Task: 2. [Checkpoint 5.5] CA state saved
2025-12-12T12:26:54.948830Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:449: [ptqudq7ug0qh33tsumcl-0] Task: 2. [Checkpoint 5.5] Injecting checkpoint barrier to outputs
2025-12-12T12:26:54.948832Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:26:54.948835Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-12T12:26:54.948842Z :KQP_COMPUTE INFO: dq_async_compute_actor.cpp:1010: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Resume inputs
2025-12-12T12:26:54.948845Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [2:7582946912339648605:2177], TxId: ptqudq7ug0qh33tsumcl, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 1. Finished: 0
2025-12-12T12:26:54.948848Z :KQP_COMPUTE DEBUG: dq_pq_write_actor.cpp:240: SelfId: [2:7582946912339648605:2177], TxId: ptqudq7ug0qh33tsumcl, TaskId: 2, PQ sink. [Checkpoint 5.5] Send checkpoint state immediately
2025-12-12T12:26:54.948875Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:418: SelfId: [2:7582946912339648605:2177], TxId: ptqudq7ug0qh33tsumcl, TaskId: 2, PQ sink. Save checkpoint { Id: 5 Generation: 5 Type: CHECKPOINT_TYPE_SNAPSHOT } state: { SourceId: "d4bed037-c2c9c284-b6a94c47-e88c4d91" }
2025-12-12T12:26:54.948878Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:524: [ptqudq7ug0qh33tsumcl-0] Task: 2. Sink[0] state saved
2025-12-12T12:26:54.948891Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:536: [ptqudq7ug0qh33tsumcl-0] Task: 2. [Checkpoint 5.5] Task checkpoint is done. Send to storage
2025-12-12T12:26:54.948898Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 6 bytes of checkpoint barrier
2025-12-12T12:26:54.948901Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-12T12:26:54.948908Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudq7ug0qh33tsumcl, task: 2. no poll, channelId: 1, has inflight messages: [5], last with freeSpace: 1000000, current freeSpace: 1000000
2025-12-12T12:26:54.948909Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:460: [ptqudq7ug0qh33tsumcl-0] [5:5] Got TEvSaveTaskState: task 2
2025-12-12T12:26:54.948926Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Poll inputs
2025-12-12T12:26:54.948928Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Poll sources
2025-12-12T12:26:54.948929Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-12-12T12:26:54.948930Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. update task runner stats
2025-12-12T12:26:54.948947Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-12T12:26:54.948948Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:26:54.948950Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-12T12:26:54.948953Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [2:7582946912339648605:2177], TxId: ptqudq7ug0qh33tsumcl, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-12-12T12:26:54.948955Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-12-12T12:26:54.948956Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-12T12:26:54.948958Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudq7ug0qh33tsumcl, task: 2. no poll, channelId: 1, has inflight messages: [5], last with freeSpace: 1000000, current freeSpace: 1000000
2025-12-12T12:26:54.948971Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. update task runner stats
2025-12-12T12:26:54.948976Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-12T12:26:54.948978Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:26:54.948979Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-12T12:26:54.948982Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [2:7582946912339648605:2177], TxId: ptqudq7ug0qh33tsumcl, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-12-12T12:26:54.948985Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-12-12T12:26:54.948986Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-12T12:26:54.948988Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudq7ug0qh33tsumcl, task: 2. no poll, channelId: 1, has inflight messages: [5], last with freeSpace: 1000000, current freeSpace: 1000000
2025-12-12T12:26:54.956827Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:484: [ptqudq7ug0qh33tsumcl-0] [5:5] TEvSaveTaskState Apply: task: 2
2025-12-12T12:26:54.956840Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:499: [ptqudq7ug0qh33tsumcl-0] [5:5] Send TEvSaveTaskStateResult: task: 2
2025-12-12T12:26:54.986831Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:759: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Commit state
2025-12-12T12:26:55.053356Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:599: Coordinator: Send TEvGetNodesRequest to NodesManager
2025-12-12T12:26:55.053392Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-12-12T12:26:55.053648Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:300: Received TNodesManagerActor::TEvGetNodesRequest
2025-12-12T12:26:55.053667Z :FQ_ROW_DISPATCHER INFO: coordinator.cpp:690: Coordinator: Updated node info, node count: 3
2025-12-12T12:26:55.059489Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582946887818600390:2082]
2025-12-12T12:26:55.059512Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:26:55.059527Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: ee00f4e3-30733b25-466103a7-271834a414, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:26:55.059974Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:26:55.065736Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:26:55.065755Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:26:55.066899Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:389: Send NodeInfo with size: 2 to DynamicNameserver
2025-12-12T12:26:55.956321Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:129: TxId: ptqudq7ug0qh33tsumcl, task: 2. Received input for channelId: 1, seqNo: 6, size: 0, chunks: 0, watermark: 0, checkpoint: 1, finished: 0, from: [1:7582946913588404374:2162], expected seqNo: 6
2025-12-12T12:26:55.956339Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:611: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. took input
2025-12-12T12:26:55.956354Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:485: [ptqudq7ug0qh33tsumcl-0] Task: 2. [Checkpoint 5.6] Got checkpoint barrier from channel 1
2025-12-12T12:26:55.956373Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:356: SelfId: [2:7582946912339648600:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. No watermark 
2025-12-12T12:26:55.956378Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Poll inputs
2025-12-12T12:26:55.956379Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1494: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-12-12T12:26:55.956381Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. DoExecuteImpl: 1
2025-12-12T12:26:55.956400Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:965: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Input data push finished. Cookie: 5 Watermark: (empty maybe) Ack: 1 TakeInputChannelDataRequests: 1
2025-12-12T12:26:55.956404Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:738: TxId: ptqudq7ug0qh33tsumcl, task: 2. Sending channel data ack to channelId: 1, peer: [1:7582946913588404373:2162], from: [2:7582946912339648598:2177], freeSpace: 1000000, seqNo: 6, finished: 0
2025-12-12T12:26:55.956506Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:462: SelfId: [2:7582946912339648600:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Pending 1 checkpoints to be sent
2025-12-12T12:26:55.956512Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Poll inputs
2025-12-12T12:26:55.956517Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1494: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-12-12T12:26:55.956518Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-12-12T12:26:55.956521Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. update task runner stats
2025-12-12T12:26:55.956544Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 1 watermark injected: (empty maybe)
2025-12-12T12:26:55.956547Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:447: [ptqudq7ug0qh33tsumcl-0] Task: 2. [Checkpoint 5.6] Performing task checkpoint
2025-12-12T12:26:55.956548Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:816: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Save state
2025-12-12T12:26:55.956551Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:474: [ptqudq7ug0qh33tsumcl-0] Task: 2. [Checkpoint 5.6] CA state saved
2025-12-12T12:26:55.956553Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:449: [ptqudq7ug0qh33tsumcl-0] Task: 2. [Checkpoint 5.6] Injecting checkpoint barrier to outputs
2025-12-12T12:26:55.956555Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:26:55.956558Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-12T12:26:55.956566Z :KQP_COMPUTE INFO: dq_async_compute_actor.cpp:1010: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Resume inputs
2025-12-12T12:26:55.956569Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [2:7582946912339648605:2177], TxId: ptqudq7ug0qh33tsumcl, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 1. Finished: 0
2025-12-12T12:26:55.956571Z :KQP_COMPUTE DEBUG: dq_pq_write_actor.cpp:240: SelfId: [2:7582946912339648605:2177], TxId: ptqudq7ug0qh33tsumcl, TaskId: 2, PQ sink. [Checkpoint 5.6] Send checkpoint state immediately
2025-12-12T12:26:55.956597Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:418: SelfId: [2:7582946912339648605:2177], TxId: ptqudq7ug0qh33tsumcl, TaskId: 2, PQ sink. Save checkpoint { Id: 6 Generation: 5 Type: CHECKPOINT_TYPE_SNAPSHOT } state: { SourceId: "d4bed037-c2c9c284-b6a94c47-e88c4d91" }
2025-12-12T12:26:55.956601Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:524: [ptqudq7ug0qh33tsumcl-0] Task: 2. Sink[0] state saved
2025-12-12T12:26:55.956613Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:536: [ptqudq7ug0qh33tsumcl-0] Task: 2. [Checkpoint 5.6] Task checkpoint is done. Send to storage
2025-12-12T12:26:55.956621Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 6 bytes of checkpoint barrier
2025-12-12T12:26:55.956624Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-12T12:26:55.956640Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudq7ug0qh33tsumcl, task: 2. no poll, channelId: 1, has inflight messages: [6], last with freeSpace: 1000000, current freeSpace: 1000000
2025-12-12T12:26:55.956663Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Poll inputs
2025-12-12T12:26:55.956663Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:460: [ptqudq7ug0qh33tsumcl-0] [5:6] Got TEvSaveTaskState: task 2
2025-12-12T12:26:55.956664Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Poll sources
2025-12-12T12:26:55.956665Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-12-12T12:26:55.956667Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. update task runner stats
2025-12-12T12:26:55.956674Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-12T12:26:55.956676Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:26:55.956678Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-12T12:26:55.956681Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [2:7582946912339648605:2177], TxId: ptqudq7ug0qh33tsumcl, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-12-12T12:26:55.956683Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-12-12T12:26:55.956685Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-12T12:26:55.956687Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudq7ug0qh33tsumcl, task: 2. no poll, channelId: 1, has inflight messages: [6], last with freeSpace: 1000000, current freeSpace: 1000000
2025-12-12T12:26:55.956698Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. update task runner stats
2025-12-12T12:26:55.956702Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-12T12:26:55.956704Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:26:55.956706Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-12T12:26:55.956708Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [2:7582946912339648605:2177], TxId: ptqudq7ug0qh33tsumcl, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-12-12T12:26:55.956710Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-12-12T12:26:55.956711Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-12T12:26:55.956715Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudq7ug0qh33tsumcl, task: 2. no poll, channelId: 1, has inflight messages: [6], last with freeSpace: 1000000, current freeSpace: 1000000
2025-12-12T12:26:55.959604Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:484: [ptqudq7ug0qh33tsumcl-0] [5:6] TEvSaveTaskState Apply: task: 2
2025-12-12T12:26:55.959608Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:499: [ptqudq7ug0qh33tsumcl-0] [5:6] Send TEvSaveTaskStateResult: task: 2
2025-12-12T12:26:56.002975Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:453: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Got TEvStateRequest from actor [1:7582946913588404365:2160] PingCookie: 2
2025-12-12T12:26:56.003014Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. update task runner stats
2025-12-12T12:26:56.003541Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:759: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Commit state
2025-12-12T12:26:56.061622Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: ee00f4e3-30733b25-466103a7-271834a415, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:26:56.072600Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:26:56.072619Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:26:56.139674Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:129: TxId: ptqudq7ug0qh33tsumcl, task: 2. Received input for channelId: 1, seqNo: 7, size: 29, chunks: 3, watermark: 0, checkpoint: 0, finished: 0, from: [1:7582946913588404374:2162], expected seqNo: 7
2025-12-12T12:26:56.139687Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:611: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. took input
2025-12-12T12:26:56.139715Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:356: SelfId: [2:7582946912339648600:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. No watermark 
2025-12-12T12:26:56.139720Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:965: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Input data push finished. Cookie: 6 Watermark: (empty maybe) Ack: 1 TakeInputChannelDataRequests: 1
2025-12-12T12:26:56.139724Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:738: TxId: ptqudq7ug0qh33tsumcl, task: 2. Sending channel data ack to channelId: 1, peer: [1:7582946913588404373:2162], from: [2:7582946912339648598:2177], freeSpace: 999971, seqNo: 7, finished: 0
2025-12-12T12:26:56.139736Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Poll inputs
2025-12-12T12:26:56.139739Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Poll sources
2025-12-12T12:26:56.139742Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-12-12T12:26:56.140064Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. update task runner stats
2025-12-12T12:26:56.140095Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-12T12:26:56.140097Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:26:56.140101Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-12T12:26:56.140110Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [2:7582946912339648605:2177], TxId: ptqudq7ug0qh33tsumcl, TaskId: 2, PQ sink. SendData. Batch: 1. Checkpoint: 0. Finished: 0
2025-12-12T12:26:56.140113Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:221: SelfId: [2:7582946912339648605:2177], TxId: ptqudq7ug0qh33tsumcl, TaskId: 2, PQ sink. Received data for sending: {"b_key":100}
2025-12-12T12:26:56.140135Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:56.140131Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug0qh33tsumcl, TaskId: 2, PQ sink. ]  SessionId [d4bed037-c2c9c284-b6a94c47-e88c4d91|ffd2bc97-aafc0c1c-34fd4523-8ebff99a_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 1 to 1
2025-12-12T12:26:56.140152Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:56.140150Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug0qh33tsumcl, TaskId: 2, PQ sink. ]  SessionId [d4bed037-c2c9c284-b6a94c47-e88c4d91|ffd2bc97-aafc0c1c-34fd4523-8ebff99a_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T12:26:56.140173Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:56.140171Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug0qh33tsumcl, TaskId: 2, PQ sink. ]  SessionId [d4bed037-c2c9c284-b6a94c47-e88c4d91|ffd2bc97-aafc0c1c-34fd4523-8ebff99a_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 1
2025-12-12T12:26:56.140294Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Sink 0: sent 17 bytes of data and 0 bytes of checkpoint barrier
2025-12-12T12:26:56.140296Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 13, sent data from buffer: 17
2025-12-12T12:26:56.140302Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:629: TxId: ptqudq7ug0qh33tsumcl, task: 2. do poll, channelId: 1, last freeSpace: 999971, current freeSpace: 1000000, seqNo: 7
2025-12-12T12:26:56.140306Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:639: TxId: ptqudq7ug0qh33tsumcl, task: 2. Poll input channelId: 1, from: [1:7582946913588404373:2162], seqNo: 7, freeSpace: 1000000
2025-12-12T12:26:56.140310Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:738: TxId: ptqudq7ug0qh33tsumcl, task: 2. Sending channel data ack to channelId: 1, peer: [1:7582946913588404373:2162], from: [2:7582946912339648598:2177], freeSpace: 1000000, seqNo: 7, finished: 0
2025-12-12T12:26:56.155391Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:56.155381Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug0qh33tsumcl, TaskId: 2, PQ sink. ]  SessionId [d4bed037-c2c9c284-b6a94c47-e88c4d91|ffd2bc97-aafc0c1c-34fd4523-8ebff99a_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T12:26:56.155464Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:56.155460Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug0qh33tsumcl, TaskId: 2, PQ sink. ]  SessionId [d4bed037-c2c9c284-b6a94c47-e88c4d91|ffd2bc97-aafc0c1c-34fd4523-8ebff99a_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 1 written { } } write_statistics { persisting_time { nanos: 3000000 } min_queue_wait_time { nanos: 8000000 } max_queue_wait_time { nanos: 8000000 } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T12:26:56.155470Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:56.155468Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug0qh33tsumcl, TaskId: 2, PQ sink. ]  SessionId [d4bed037-c2c9c284-b6a94c47-e88c4d91|ffd2bc97-aafc0c1c-34fd4523-8ebff99a_0]  PartitionId [0]  Generation [1] OnAck: seqNo=1, txId=?
2025-12-12T12:26:56.155474Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:56.155472Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug0qh33tsumcl, TaskId: 2, PQ sink. ]  SessionId [d4bed037-c2c9c284-b6a94c47-e88c4d91|ffd2bc97-aafc0c1c-34fd4523-8ebff99a_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 1
2025-12-12T12:26:56.159568Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:454: SelfId: [2:7582946912339648605:2177], TxId: ptqudq7ug0qh33tsumcl, TaskId: 2, PQ sink. Ack seq no 1
2025-12-12T12:26:56.792690Z :KQP_COMPUTE ERROR: dq_compute_actor_impl.h:1205: SelfId: [2:7582946912339648598:2177], TxId: ptqudq7ug0qh33tsumcl, task: 2. Ctx: {}. Handle abort execution event from: [2:7582946890864811843:2064], status: UNAVAILABLE, reason: { <main>: Error: Aborted by LWM }
2025-12-12T12:26:56.792738Z :KQP_COMPUTE DEBUG: dq_compute_actor_channels.cpp:494: TxId: ptqudq7ug0qh33tsumcl, task: 2. pass away
2025-12-12T12:26:56.794555Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:26:56.794548Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug0qh33tsumcl, TaskId: 2, PQ sink. ]  SessionId [d4bed037-c2c9c284-b6a94c47-e88c4d91|ffd2bc97-aafc0c1c-34fd4523-8ebff99a_0]  PartitionId [0]  Generation [1] Write session: close. Timeout 0.000000s
2025-12-12T12:26:56.794560Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:26:56.794558Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug0qh33tsumcl, TaskId: 2, PQ sink. ]  SessionId [d4bed037-c2c9c284-b6a94c47-e88c4d91|ffd2bc97-aafc0c1c-34fd4523-8ebff99a_0]  PartitionId [0]  Generation [1] Write session will now close
2025-12-12T12:26:56.794577Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:56.794576Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug0qh33tsumcl, TaskId: 2, PQ sink. ]  SessionId [d4bed037-c2c9c284-b6a94c47-e88c4d91|ffd2bc97-aafc0c1c-34fd4523-8ebff99a_0]  PartitionId [0]  Generation [1] Write session: aborting
2025-12-12T12:26:56.794608Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:26:56.794607Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug0qh33tsumcl, TaskId: 2, PQ sink. ]  SessionId [d4bed037-c2c9c284-b6a94c47-e88c4d91|ffd2bc97-aafc0c1c-34fd4523-8ebff99a_0]  PartitionId [0]  Generation [1] Write session: gracefully shut down, all writes complete
2025-12-12T12:26:56.794612Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:56.794611Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug0qh33tsumcl, TaskId: 2, PQ sink. ]  SessionId [d4bed037-c2c9c284-b6a94c47-e88c4d91|ffd2bc97-aafc0c1c-34fd4523-8ebff99a_0]  PartitionId [0]  Generation [1] Write session: destroy
2025-12-12T12:26:57.060451Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582946887818600390:2082]
2025-12-12T12:26:57.060483Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:26:57.062480Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: ee00f4e3-30733b25-466103a7-271834a416, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:26:57.064555Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:26:57.071162Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:26:57.071184Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:26:58.062942Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: ee00f4e3-30733b25-466103a7-271834a417, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:26:58.068229Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:26:58.068251Z :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:12637: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-fhkyrtz6p4.auto.internal:12637
2025-12-12T12:26:59.065352Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582946887818600390:2082]
2025-12-12T12:26:59.065368Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: ee00f4e3-30733b25-466103a7-271834a418, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:26:59.065380Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:26:59.072285Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:26:59.072303Z :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:12637: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-fhkyrtz6p4.auto.internal:12637
2025-12-12T12:26:59.078316Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:00.053575Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-12-12T12:27:00.065847Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: ee00f4e3-30733b25-466103a7-271834a419, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:00.068590Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:00.068617Z :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:12637: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-fhkyrtz6p4.auto.internal:12637
2025-12-12T12:27:00.068675Z :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:12637: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-fhkyrtz6p4.auto.internal:12637
