2025-12-12T12:26:51.987976Z :GRPC_SERVER NOTICE: grpc_request_proxy.cpp:380: Grpc request proxy started, nodeid# 2, serve as static node
2025-12-12T12:26:51.988051Z :GRPC_SERVER CRIT: grpc_request_proxy.cpp:440: Failed to deliver subscription request to config dispatcher
2025-12-12T12:26:51.988056Z :GRPC_SERVER NOTICE: grpc_request_proxy.cpp:380: Grpc request proxy started, nodeid# 2, serve as static node
2025-12-12T12:26:51.988075Z :GRPC_SERVER CRIT: grpc_request_proxy.cpp:440: Failed to deliver subscription request to config dispatcher
2025-12-12T12:26:51.988308Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:214: Bootstrap
2025-12-12T12:26:51.988312Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:217: Create sdk ydb connection
2025-12-12T12:26:51.989423Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:239: Successfully bootstrapped TStorageProxy [2:7582946919182350597:2062] with connection to localhost:25827:local
2025-12-12T12:26:51.989440Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:544: RowDispatcher: Successfully bootstrapped row dispatcher, id [2:7582946919182350598:2063], tenant /compute
2025-12-12T12:26:51.989451Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [2:7582946919182350598:2063]
2025-12-12T12:26:51.989453Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:329: Coordinator: Add new row dispatcher to map (state 1)
2025-12-12T12:26:51.989558Z :YQL_NODES_MANAGER INFO: nodes_manager.cpp:88: Bootstrap, InstanceId: 5a3583cc-469446b2-f2966fb6-df4dc0c8
2025-12-12T12:26:51.989559Z :YQL_NODES_MANAGER DEBUG: nodes_manager.cpp:310: TNodesManagerActor::ResolveSelfAddress
2025-12-12T12:26:51.989579Z :FQ_QUOTA_PROXY INFO: quota_proxy.cpp:90: STARTED
2025-12-12T12:26:51.989603Z :FQ_LOG_UPDATER DEBUG: log.cpp:93: Updated YQL logs priority: 8
2025-12-12T12:26:51.989605Z :FQ_LOG_UPDATER CRIT: log.cpp:55: Failed to deliver subscription request to config dispatcher.
2025-12-12T12:26:51.989642Z :YQ_RATE_LIMITER INFO: quoter_service.cpp:124: Bootstraping with config: { Enabled: true DataPlaneEnabled: true Database { Endpoint: "localhost:25827" Database: "local" TablePrefix: "RateLimiter_df6e7bab-b514-4b78-b17e-e8ee264a681d" } Limiters { CoordinationNodePath: "rate_limiter" } }
2025-12-12T12:26:51.989760Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:293: Coordinator: Successfully bootstrapped coordinator, id [2:7582946919182350622:2082], NodesManagerId [0:4705493345362661702:78], rebalancing timeout 5.000000s
2025-12-12T12:26:51.989772Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:232: TLeaderElection [2:7582946919182350623:2083] Successfully bootstrapped, local coordinator id [2:7582946919182350622:2082], tenant id compute, local mode 0, coordination node path local/compute, endpoint localhost:25827
2025-12-12T12:26:51.990838Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:637: RowDispatcher: TEvCoordinatorChangesSubscribe from [2:7582946919182350622:2082]
2025-12-12T12:26:51.990935Z :YQ_TEST_CONNECTION DEBUG: test_connection.cpp:142: Starting yandex query test connection. Actor id: [2:7582946919182350603:2068]
2025-12-12T12:26:51.990986Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 98aed2a1-72ca4129-b8aeede3-59d0649b1, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:26:51.991298Z :MEMORY_PROFILER NOTICE: monitor.cpp:332: Bootstrapped
2025-12-12T12:26:51.993711Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:71: Run create coordination node "local/compute" actor
2025-12-12T12:26:51.993719Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:113: Call create coordination node "local/compute"
2025-12-12T12:26:51.993721Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:411: Call create coordination node "local/compute"
2025-12-12T12:26:51.993816Z :SCHEME_BOARD_SUBSCRIBER NOTICE: subscriber.cpp:849: [main][2:7582946919182350618:2078][/compute] Set up state: owner# [2:7582946919182350577:2052], state# { Deleted: 1 Strong: 0 Version: <Invalid> DomainId: <Invalid> AbandonedSchemeShards: there are 0 elements }
2025-12-12T12:26:51.993913Z :SCHEME_BOARD_SUBSCRIBER NOTICE: subscriber.cpp:849: [main][2:7582946919182350619:2079][/Root] Set up state: owner# [2:7582946919182350578:2053], state# { Deleted: 1 Strong: 0 Version: <Invalid> DomainId: <Invalid> AbandonedSchemeShards: there are 0 elements }
2025-12-12T12:26:51.993965Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-12-12T12:26:51.994196Z :GRPC_SERVER WARN: grpc_request_proxy.cpp:583: SchemeBoardDelete /compute Strong=0
2025-12-12T12:26:51.994217Z :SCHEME_BOARD_SUBSCRIBER NOTICE: subscriber.cpp:849: [main][2:7582946919182350617:2077][/Root] Set up state: owner# [2:7582946919182350577:2052], state# { Deleted: 1 Strong: 0 Version: <Invalid> DomainId: <Invalid> AbandonedSchemeShards: there are 0 elements }
2025-12-12T12:26:51.994220Z :GRPC_SERVER WARN: grpc_request_proxy.cpp:583: SchemeBoardDelete /Root Strong=0
2025-12-12T12:26:51.994221Z :GRPC_SERVER WARN: grpc_request_proxy.cpp:583: SchemeBoardDelete /Root Strong=0
2025-12-12T12:26:51.994279Z :SCHEME_BOARD_SUBSCRIBER NOTICE: subscriber.cpp:849: [main][2:7582946919182350620:2080][/compute] Set up state: owner# [2:7582946919182350578:2053], state# { Deleted: 1 Strong: 0 Version: <Invalid> DomainId: <Invalid> AbandonedSchemeShards: there are 0 elements }
2025-12-12T12:26:51.994291Z :GRPC_SERVER WARN: grpc_request_proxy.cpp:583: SchemeBoardDelete /compute Strong=0
2025-12-12T12:26:52.006490Z :FQ_QUOTA_SERVICE INFO: quota_manager.cpp:196: STARTED
2025-12-12T12:26:52.017163Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:155: Successfully created coordination node "local/compute"
2025-12-12T12:26:52.017179Z :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:52.017199Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:345: TLeaderElection [2:7582946919182350623:2083] Coordination node successfully created
2025-12-12T12:26:52.017202Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:323: TLeaderElection [2:7582946919182350623:2083] Start session
2025-12-12T12:26:52.025546Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:359: TLeaderElection [2:7582946919182350623:2083] Session successfully created
2025-12-12T12:26:52.042961Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:26:52.042973Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:26:52.044003Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:372: TLeaderElection [2:7582946919182350623:2083] Semaphore successfully created
2025-12-12T12:26:52.044007Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:304: TLeaderElection [2:7582946919182350623:2083] Try to acquire semaphore
2025-12-12T12:26:52.044140Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:420: TLeaderElection [2:7582946919182350623:2083] Describe semaphore
2025-12-12T12:26:52.050906Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:469: TLeaderElection [2:7582946919182350623:2083] Semaphore successfully described: coordinator id [1:7582946899284415308:2092] generation 3
2025-12-12T12:26:52.050921Z :FQ_ROW_DISPATCHER INFO: leader_election.cpp:471: TLeaderElection [2:7582946919182350623:2083] Send TEvCoordinatorChanged to [2:7582946919182350598:2063], new coordinator id [1:7582946899284415308:2092], previous coordinator id [0:0:0]
2025-12-12T12:26:52.050947Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:569: RowDispatcher: Coordinator changed, old leader (empty maybe), new [1:7582946899284415308:2092] generation 3
2025-12-12T12:26:52.050969Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:440: Coordinator: New leader [1:7582946899284415308:2092], SelfId [2:7582946919182350622:2082]
2025-12-12T12:26:52.051770Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:389: Send NodeInfo with size: 1 to DynamicNameserver
2025-12-12T12:26:52.072146Z :INTERCONNECT WARN: interconnect_handshake.cpp:501: Handshake [2:7582946923477318030:2052] [node 1] ICH09 Neither CompatibilityInfo nor VersionTag of the peer can be validated, accepting by default
2025-12-12T12:26:52.073068Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:26:52.988061Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 98aed2a1-72ca4129-b8aeede3-59d0649b2, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:26:53.007572Z :FQ_QUOTA_SERVICE DEBUG: quota_manager.cpp:230: IC Peers[1]: [1]
2025-12-12T12:26:53.011095Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:26:53.011111Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:26:53.043139Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:144: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Start compute actor [2:7582946927772285441:2253], task: 2
2025-12-12T12:26:53.043176Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:114: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Use CPU quota: 1. Rate limiter resource: { "local/RateLimiter_df6e7bab-b514-4b78-b17e-e8ee264a681d/rate_limiter", "mock_cloud/my_folder/ptqudq7ug3b8up2rk3ft" }
2025-12-12T12:26:53.111598Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:197: [] Task: 2. Got TEvNewCheckpointCoordinator event: generation 3, actorId: [1:7582946925054219408:2317]
2025-12-12T12:26:53.111610Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:208: [] Task: 2. Assign checkpoint coordinator (generation = 3)
2025-12-12T12:26:53.112425Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1360: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Create source for input 0 { Source { Type: "PqSource" Settings { type_url: "type.googleapis.com/NYql.NPq.NProto.TDqPqTopicSource" value: "\n\016recovery_input\022\024ptqudq7ug3b8up2rk3ft\032\017localhost:25827\"\027\n\025cluster:default_myyds*\005local0\002@\001b\004Dataj\025[\"DataType\";\"String\"]\222\001\024ptcudq7ug3orttdktg37\232\001\003raw\242\001/[\"StructType\";[[\"Data\";[\"DataType\";\"String\"]]]]\262\001\002\022\000\272\001\026\n\010cloud_id\022\nmock_cloud\272\001 \n\005scope\022\027yandexcloud://my_folder" } WatermarksMode: WATERMARKS_MODE_DISABLED } }
2025-12-12T12:26:53.112743Z :KQP_COMPUTE DEBUG: dq_pq_read_actor_base.cpp:153: SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, task: 2. 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:53.112760Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1447: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Create sink for output 0 { Sink { Type: "PqSink" Settings { type_url: "type.googleapis.com/NYql.NPq.NProto.TDqPqTopicSink" value: "\n\017recovery_output\022\017localhost:25827\032\027\n\025cluster:default_myyds\"\005local0\0018\002" } } }
2025-12-12T12:26:53.112898Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:265: [ptqudq7ug3b8up2rk3ft-0] Task: 2. [Checkpoint 1.2] TEvRestoreFromCheckpoint, StateLoadPlan = { StateType: STATE_TYPE_OWN }
2025-12-12T12:26:53.112930Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:508: [ptqudq7ug3b8up2rk3ft-0] [1:2] Got TEvGetTaskState: tasks {2}
2025-12-12T12:26:53.112936Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:519: [ptqudq7ug3b8up2rk3ft-0] [1:2] GetState, tasks: 2
2025-12-12T12:26:53.112973Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:395: [ptqudq7ug3b8up2rk3ft-0] Task: 2. Handle connected node 1
2025-12-12T12:26:53.113733Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1064: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Received channels info: 
2025-12-12T12:26:53.124082Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:654: [ptqudq7ug3b8up2rk3ft-0] [1:2] ListOfStates results:
2025-12-12T12:26:53.124127Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:675: [ptqudq7ug3b8up2rk3ft-0] [1:2] taskId 2 checkpoint id: 1:2, rows count: 1
2025-12-12T12:26:53.124130Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:675: [ptqudq7ug3b8up2rk3ft-0] [1:2] taskId 2 checkpoint id: 1:1, rows count: 1
2025-12-12T12:26:53.124140Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:901: [ptqudq7ug3b8up2rk3ft-0] [1:2] SkipStatesInFuture, skip 0 checkpoints
2025-12-12T12:26:53.125776Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:796: [ptqudq7ug3b8up2rk3ft-0] [1:2] SelectState: task_id 2, seq_no 2, blob_seq_num 0
2025-12-12T12:26:53.129024Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:410: [ptqudq7ug3b8up2rk3ft-0] [1:2] DeserializeState, task id 2, blob size 170
2025-12-12T12:26:53.129053Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:960: [ptqudq7ug3b8up2rk3ft-0] [1:2] ApplyIncrements
2025-12-12T12:26:53.129152Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:527: [ptqudq7ug3b8up2rk3ft-0] [{ Id: 2 Generation: 1 }] Send TEvGetTaskStateResult: tasks: {2}
2025-12-12T12:26:53.129198Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:336: [ptqudq7ug3b8up2rk3ft-0] Task: 2. [Checkpoint 1.2] TEvGetTaskStateResult: restoring state
2025-12-12T12:26:53.129211Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:793: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Load state
2025-12-12T12:26:53.129224Z :KQP_COMPUTE DEBUG: dq_pq_read_actor_base.cpp:153: SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, task: 2. 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:53.129248Z :KQP_COMPUTE DEBUG: dq_pq_read_actor_base.cpp:133: SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, task: 2. PQ source. SessionId: empty StartingMessageTs 2025-12-12T12:26:44.736000Z Restoring offset: {1@,8},
2025-12-12T12:26:53.129422Z :KQP_COMPUTE DEBUG: dq_pq_write_actor.cpp:268: SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. Load state: { SourceId: "c70334fe-e10b1ec-1f9ce4da-67724390" ConfirmedSeqNo: 8 EgressBytes: 9 }
2025-12-12T12:26:53.129445Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:362: [ptqudq7ug3b8up2rk3ft-0] Task: 2. [Checkpoint 1.2] Checkpoint state restored
2025-12-12T12:26:53.129851Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1164: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Got TEvRun from actor [1:7582946925054219408:2317]
2025-12-12T12:26:53.129875Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Poll inputs
2025-12-12T12:26:53.129877Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Poll sources
2025-12-12T12:26:53.129882Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:542: SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, task: 2. PQ source. SessionId: empty GetAsyncInputData freeSpace = 1
2025-12-12T12:26:53.129898Z :KQP_COMPUTE DEBUG: dq_pq_read_actor.cpp:648: SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, task: 2. PQ source. SessionId: empty PartitionsToRead: 1
2025-12-12T12:26:53.129924Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:26:53.129920Z :INFO: [local] [local] [865e475e-9f3c4a1f-4bba642a-9a9010f0] Starting read session
2025-12-12T12:26:53.129933Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:53.129931Z :DEBUG: [local] [local] [865e475e-9f3c4a1f-4bba642a-9a9010f0] Starting single session
2025-12-12T12:26:53.129963Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:53.129961Z :DEBUG: [local] [local] [865e475e-9f3c4a1f-4bba642a-9a9010f0] [] In Reconnect, ReadSizeBudget = 8388608, ReadSizeServerDelta = 0
2025-12-12T12:26:53.129970Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:53.129967Z :DEBUG: [local] [local] [865e475e-9f3c4a1f-4bba642a-9a9010f0] [] New values: ReadSizeBudget = 8388608, ReadSizeServerDelta = 0
2025-12-12T12:26:53.129975Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:53.129973Z :DEBUG: [local] [local] [865e475e-9f3c4a1f-4bba642a-9a9010f0] [] Reconnecting session to cluster  in 0.000000s
2025-12-12T12:26:53.130171Z :KQP_COMPUTE INFO: dq_pq_read_actor.cpp:315: SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, task: 2. PQ source. SessionId: 865e475e-9f3c4a1f-4bba642a-9a9010f0 CreateReadSession
2025-12-12T12:26:53.130182Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:81: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Poll async input 0. Buffer free space: 1, read from async input: 0 bytes, 0 rows, finished: 0
2025-12-12T12:26:53.130203Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-12-12T12:26:53.130274Z :KQP_COMPUTE TRACE: dq_compute_memory_quota.h:97: TxId: ptqudq7ug3b8up2rk3ft, task: 2. Peak memory usage: 2031616
2025-12-12T12:26:53.130280Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. update task runner stats
2025-12-12T12:26:53.130297Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-12T12:26:53.130299Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:26:53.130302Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-12T12:26:53.130305Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1107: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Ask CPU quota: 72ms
2025-12-12T12:26:53.130330Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-12-12T12:26:53.130392Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:53.130369Z :DEBUG: [local] [local] [865e475e-9f3c4a1f-4bba642a-9a9010f0] [] Successfully connected. Initializing session
2025-12-12T12:26:53.130501Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-12-12T12:26:53.130504Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-12T12:26:53.131486Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1165: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. CPU quota delay: 1ms
2025-12-12T12:26:53.131801Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:26:53.131794Z :INFO: [local] [local] [865e475e-9f3c4a1f-4bba642a-9a9010f0] [] Got InitResponse. ReadSessionId: ptqudq7ug3b8up2rk3ft_1_8_7015827103358650570_v1
2025-12-12T12:26:53.131807Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:53.131805Z :DEBUG: [local] [local] [865e475e-9f3c4a1f-4bba642a-9a9010f0] [] In ContinueReadingDataImpl, ReadSizeBudget = 8388608, ReadSizeServerDelta = 0
2025-12-12T12:26:53.131867Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:53.131865Z :DEBUG: [local] [local] [865e475e-9f3c4a1f-4bba642a-9a9010f0] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 8388608
2025-12-12T12:26:53.133334Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:363: SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, task: 2. PQ source. SessionId: 865e475e-9f3c4a1f-4bba642a-9a9010f0 Source data ready
2025-12-12T12:26:53.133348Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Poll inputs
2025-12-12T12:26:53.133351Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Poll sources
2025-12-12T12:26:53.133356Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:542: SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, task: 2. PQ source. SessionId: 865e475e-9f3c4a1f-4bba642a-9a9010f0 GetAsyncInputData freeSpace = 1000000
2025-12-12T12:26:53.133387Z :KQP_COMPUTE DEBUG: dq_pq_read_actor.cpp:820: SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, task: 2. PQ source. SessionId: 865e475e-9f3c4a1f-4bba642a-9a9010f0 Key: 1@ StartPartitionSessionEvent received
2025-12-12T12:26:53.133390Z :KQP_COMPUTE DEBUG: dq_pq_read_actor.cpp:827: SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, task: 2. PQ source. SessionId: 865e475e-9f3c4a1f-4bba642a-9a9010f0 Key: 1@ Confirm StartPartitionSession with offset 8
2025-12-12T12:26:53.133399Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:26:53.133396Z :INFO: [local] [local] [865e475e-9f3c4a1f-4bba642a-9a9010f0] [] Confirm partition stream create. Partition stream id: 1. Cluster: "-". Topic: "recovery_input". Partition: 1. Read offset: 8
2025-12-12T12:26:53.133494Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:81: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Poll async input 0. Buffer free space: 1000000, read from async input: 0 bytes, 0 rows, finished: 0
2025-12-12T12:26:53.133509Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:363: SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, task: 2. PQ source. SessionId: 865e475e-9f3c4a1f-4bba642a-9a9010f0 Source data ready
2025-12-12T12:26:53.133512Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-12-12T12:26:53.133582Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Poll inputs
2025-12-12T12:26:53.133584Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Poll sources
2025-12-12T12:26:53.133587Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:542: SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, task: 2. PQ source. SessionId: 865e475e-9f3c4a1f-4bba642a-9a9010f0 GetAsyncInputData freeSpace = 1000000
2025-12-12T12:26:53.133590Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:81: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Poll async input 0. Buffer free space: 1000000, read from async input: 0 bytes, 0 rows, finished: 0
2025-12-12T12:26:53.133596Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. update task runner stats
2025-12-12T12:26:53.133622Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-12T12:26:53.133624Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:26:53.133627Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-12T12:26:53.133629Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-12-12T12:26:53.133635Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [2:7582946927772285450:2253], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-12-12T12:26:53.133641Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-12-12T12:26:53.133642Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-12T12:26:53.133658Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. update task runner stats
2025-12-12T12:26:53.133664Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-12T12:26:53.133665Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:26:53.133667Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-12T12:26:53.133669Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [2:7582946927772285450:2253], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-12-12T12:26:53.133670Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-12-12T12:26:53.133671Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-12T12:26:53.134181Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:53.134174Z :DEBUG: [local] [local] [865e475e-9f3c4a1f-4bba642a-9a9010f0] [] Got ReadResponse, serverBytesSize = 185, now ReadSizeBudget = 0, ReadSizeServerDelta = 8388423
2025-12-12T12:26:53.134204Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:53.134202Z :DEBUG: [local] [local] [865e475e-9f3c4a1f-4bba642a-9a9010f0] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 8388423
2025-12-12T12:26:53.134272Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:53.134270Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (8-13)
2025-12-12T12:26:53.134277Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:53.134275Z :DEBUG: [local] [local] [865e475e-9f3c4a1f-4bba642a-9a9010f0] [] Returning serverBytesSize = 185 to budget
2025-12-12T12:26:53.134280Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:53.134278Z :DEBUG: [local] [local] [865e475e-9f3c4a1f-4bba642a-9a9010f0] [] In ContinueReadingDataImpl, ReadSizeBudget = 185, ReadSizeServerDelta = 8388423
2025-12-12T12:26:53.134313Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:53.134311Z :DEBUG: [local] [local] [865e475e-9f3c4a1f-4bba642a-9a9010f0] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 8388608
2025-12-12T12:26:53.134370Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:363: SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, task: 2. PQ source. SessionId: 865e475e-9f3c4a1f-4bba642a-9a9010f0 Source data ready
2025-12-12T12:26:53.134381Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Poll inputs
2025-12-12T12:26:53.134383Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Poll sources
2025-12-12T12:26:53.134387Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:542: SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, task: 2. PQ source. SessionId: 865e475e-9f3c4a1f-4bba642a-9a9010f0 GetAsyncInputData freeSpace = 1000000
2025-12-12T12:26:53.134404Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:53.134401Z :DEBUG: [local] Take Data. Partition 1. Read: {0, 0} (8-8)
2025-12-12T12:26:53.134410Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:53.134409Z :DEBUG: [local] Take Data. Partition 1. Read: {1, 0} (9-9)
2025-12-12T12:26:53.134414Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:53.134413Z :DEBUG: [local] Take Data. Partition 1. Read: {1, 1} (10-10)
2025-12-12T12:26:53.134418Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:53.134417Z :DEBUG: [local] Take Data. Partition 1. Read: {1, 2} (11-11)
2025-12-12T12:26:53.134423Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:53.134421Z :DEBUG: [local] Take Data. Partition 1. Read: {1, 3} (12-12)
2025-12-12T12:26:53.134426Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:53.134425Z :DEBUG: [local] Take Data. Partition 1. Read: {1, 4} (13-13)
2025-12-12T12:26:53.134435Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:53.134433Z :DEBUG: [local] [local] [865e475e-9f3c4a1f-4bba642a-9a9010f0] [] The application data is transferred to the client. Number of messages 6, size 12 bytes
2025-12-12T12:26:53.134444Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:53.134440Z :DEBUG: [local] [local] [865e475e-9f3c4a1f-4bba642a-9a9010f0] [] Returning serverBytesSize = 0 to budget
2025-12-12T12:26:53.134461Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:761: SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, task: 2. PQ source. SessionId: 865e475e-9f3c4a1f-4bba642a-9a9010f0 Key: 1@ Data received: Message { Data: "12" Information: { Offset: 8 ProducerId: "" SeqNo: 0 CreateTime: 2025-12-12T12:26:50.101000Z WriteTime: 2025-12-12T12:26:50.101000Z MessageGroupId: "" Meta: { } MessageMeta: { } } Partition session id: 1 Topic: "recovery_input" Partition: 1 }
2025-12-12T12:26:53.134470Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:761: SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, task: 2. PQ source. SessionId: 865e475e-9f3c4a1f-4bba642a-9a9010f0 Key: 1@ Data received: Message { Data: "13" Information: { Offset: 9 ProducerId: "" SeqNo: 0 CreateTime: 2025-12-12T12:26:50.101000Z WriteTime: 2025-12-12T12:26:50.106000Z MessageGroupId: "" Meta: { } MessageMeta: { } } Partition session id: 1 Topic: "recovery_input" Partition: 1 }
2025-12-12T12:26:53.134474Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:761: SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, task: 2. PQ source. SessionId: 865e475e-9f3c4a1f-4bba642a-9a9010f0 Key: 1@ Data received: Message { Data: "14" Information: { Offset: 10 ProducerId: "" SeqNo: 0 CreateTime: 2025-12-12T12:26:50.102000Z WriteTime: 2025-12-12T12:26:50.106000Z MessageGroupId: "" Meta: { } MessageMeta: { } } Partition session id: 1 Topic: "recovery_input" Partition: 1 }
2025-12-12T12:26:53.134478Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:761: SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, task: 2. PQ source. SessionId: 865e475e-9f3c4a1f-4bba642a-9a9010f0 Key: 1@ Data received: Message { Data: "15" Information: { Offset: 11 ProducerId: "" SeqNo: 0 CreateTime: 2025-12-12T12:26:50.102000Z WriteTime: 2025-12-12T12:26:50.106000Z MessageGroupId: "" Meta: { } MessageMeta: { } } Partition session id: 1 Topic: "recovery_input" Partition: 1 }
2025-12-12T12:26:53.134481Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:761: SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, task: 2. PQ source. SessionId: 865e475e-9f3c4a1f-4bba642a-9a9010f0 Key: 1@ Data received: Message { Data: "16" Information: { Offset: 12 ProducerId: "" SeqNo: 0 CreateTime: 2025-12-12T12:26:50.102000Z WriteTime: 2025-12-12T12:26:50.106000Z MessageGroupId: "" Meta: { } MessageMeta: { } } Partition session id: 1 Topic: "recovery_input" Partition: 1 }
2025-12-12T12:26:53.134484Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:761: SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, task: 2. PQ source. SessionId: 865e475e-9f3c4a1f-4bba642a-9a9010f0 Key: 1@ Data received: Message { Data: "20" Information: { Offset: 13 ProducerId: "" SeqNo: 0 CreateTime: 2025-12-12T12:26:50.102000Z WriteTime: 2025-12-12T12:26:50.106000Z MessageGroupId: "" Meta: { } MessageMeta: { } } Partition session id: 1 Topic: "recovery_input" Partition: 1 }
2025-12-12T12:26:53.134495Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:737: SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, task: 2. PQ source. SessionId: 865e475e-9f3c4a1f-4bba642a-9a9010f0 Return ready batch. DataCount = 6 Watermark = none Used space = 12
2025-12-12T12:26:53.134497Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:81: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Poll async input 0. Buffer free space: 1000000, read from async input: 12 bytes, 6 rows, finished: 0
2025-12-12T12:26:53.134525Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:363: SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, task: 2. PQ source. SessionId: 865e475e-9f3c4a1f-4bba642a-9a9010f0 Source data ready
2025-12-12T12:26:53.134527Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-12-12T12:26:53.134532Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Poll inputs
2025-12-12T12:26:53.134533Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Poll sources
2025-12-12T12:26:53.134535Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:542: SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, task: 2. PQ source. SessionId: 865e475e-9f3c4a1f-4bba642a-9a9010f0 GetAsyncInputData freeSpace = 999988
2025-12-12T12:26:53.134538Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:81: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Poll async input 0. Buffer free space: 999988, read from async input: 0 bytes, 0 rows, finished: 0
2025-12-12T12:26:53.134608Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-12-12T12:26:53.134610Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Poll inputs
2025-12-12T12:26:53.134611Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Poll sources
2025-12-12T12:26:53.134613Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:542: SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, task: 2. PQ source. SessionId: 865e475e-9f3c4a1f-4bba642a-9a9010f0 GetAsyncInputData freeSpace = 999988
2025-12-12T12:26:53.134615Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:81: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Poll async input 0. Buffer free space: 999988, read from async input: 0 bytes, 0 rows, finished: 0
2025-12-12T12:26:53.134618Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. update task runner stats
2025-12-12T12:26:53.134638Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-12T12:26:53.134640Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:26:53.134642Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-12T12:26:53.134645Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-12-12T12:26:53.134650Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [2:7582946927772285450:2253], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. SendData. Batch: 6. Checkpoint: 0. Finished: 0
2025-12-12T12:26:53.134652Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:221: SelfId: [2:7582946927772285450:2253], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. Received data for sending: 12
2025-12-12T12:26:53.134654Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:221: SelfId: [2:7582946927772285450:2253], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. Received data for sending: 13
2025-12-12T12:26:53.134656Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:221: SelfId: [2:7582946927772285450:2253], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. Received data for sending: 14
2025-12-12T12:26:53.134657Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:221: SelfId: [2:7582946927772285450:2253], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. Received data for sending: 15
2025-12-12T12:26:53.134658Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:221: SelfId: [2:7582946927772285450:2253], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. Received data for sending: 16
2025-12-12T12:26:53.134659Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:221: SelfId: [2:7582946927772285450:2253], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. Received data for sending: 20
2025-12-12T12:26:53.134679Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Sink 0: sent 36 bytes of data and 0 bytes of checkpoint barrier
2025-12-12T12:26:53.134680Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 12, sent data from buffer: 36
2025-12-12T12:26:53.134698Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Poll inputs
2025-12-12T12:26:53.134699Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Poll sources
2025-12-12T12:26:53.134702Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:542: SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, task: 2. PQ source. SessionId: 865e475e-9f3c4a1f-4bba642a-9a9010f0 GetAsyncInputData freeSpace = 1000000
2025-12-12T12:26:53.134704Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:81: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Poll async input 0. Buffer free space: 1000000, read from async input: 0 bytes, 0 rows, finished: 0
2025-12-12T12:26:53.134708Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. update task runner stats
2025-12-12T12:26:53.134715Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-12T12:26:53.134716Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:26:53.134718Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777204, allowedOvercommit: 500000, toSend: 17277204
2025-12-12T12:26:53.134720Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-12-12T12:26:53.134722Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [2:7582946927772285450:2253], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-12-12T12:26:53.134723Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-12-12T12:26:53.134735Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-12T12:26:53.134746Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. update task runner stats
2025-12-12T12:26:53.134751Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-12T12:26:53.134752Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:26:53.134753Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777204, allowedOvercommit: 500000, toSend: 17277204
2025-12-12T12:26:53.134756Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [2:7582946927772285450:2253], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-12-12T12:26:53.134757Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-12-12T12:26:53.134758Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-12T12:26:53.134767Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. update task runner stats
2025-12-12T12:26:53.134771Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-12T12:26:53.134772Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:26:53.134774Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777204, allowedOvercommit: 500000, toSend: 17277204
2025-12-12T12:26:53.134776Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [2:7582946927772285450:2253], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-12-12T12:26:53.134777Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-12-12T12:26:53.134778Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-12T12:26:53.136055Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:26:53.136048Z :INFO: [local] OnFederationDiscovery fall back to single mode, database=local
2025-12-12T12:26:53.136222Z :YDB_SDK INFO: actor.cpp:37: [] [] Start federated write session to database '' (previous was <empty>) FederationState: { Status: SUCCESS SelfLocation: "" DbInfos: [ { path: "local" endpoint: "localhost:25827" status: AVAILABLE weight: 100 } ] ControlPlaneEndpoint: localhost:25827 }
2025-12-12T12:26:53.136274Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:53.136271Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. ]  SessionId []  MessageGroupId [c70334fe-e10b1ec-1f9ce4da-67724390] Write session: try to update token
2025-12-12T12:26:53.136546Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:26:53.136542Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. ]  SessionId []  MessageGroupId [c70334fe-e10b1ec-1f9ce4da-67724390] Start write session. Will connect to nodeId: 0
2025-12-12T12:26:53.136722Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:53.136716Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. ]  SessionId []  MessageGroupId [c70334fe-e10b1ec-1f9ce4da-67724390] Write session: write to message_group: c70334fe-e10b1ec-1f9ce4da-67724390
2025-12-12T12:26:53.136743Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:53.136741Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. ]  SessionId []  MessageGroupId [c70334fe-e10b1ec-1f9ce4da-67724390] Write session: send init request: init_request { path: "recovery_output" producer_id: "c70334fe-e10b1ec-1f9ce4da-67724390" message_group_id: "c70334fe-e10b1ec-1f9ce4da-67724390" }
2025-12-12T12:26:53.136747Z :YDB_SDK TRACE: actor.cpp:37: 2025-12-12T12:26:53.136744Z :TRACE: [local] TRACE_EVENT InitRequest 
2025-12-12T12:26:53.136840Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:53.136838Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. ]  SessionId []  MessageGroupId [c70334fe-e10b1ec-1f9ce4da-67724390] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T12:26:53.144817Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:53.144808Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. ]  SessionId []  MessageGroupId [c70334fe-e10b1ec-1f9ce4da-67724390] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T12:26:53.144831Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:26:53.144828Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. ]  SessionId []  MessageGroupId [c70334fe-e10b1ec-1f9ce4da-67724390] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1765542413144 BytesWritten: 0 MessagesWritten: 0 BytesWrittenCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:26:53.144855Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:26:53.144853Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. ]  SessionId []  MessageGroupId [c70334fe-e10b1ec-1f9ce4da-67724390] Write session established. Init response: last_seq_no: 14 session_id: "c70334fe-e10b1ec-1f9ce4da-67724390|d9b70e62-cd586df7-cdebd24b-eaea041f_0" partition_id: 1
2025-12-12T12:26:53.144861Z :YDB_SDK TRACE: actor.cpp:37: 2025-12-12T12:26:53.144859Z :TRACE: [local] TRACE_EVENT InitResponse  partition_id=1 session_id=c70334fe-e10b1ec-1f9ce4da-67724390|d9b70e62-cd586df7-cdebd24b-eaea041f_0
2025-12-12T12:26:53.144865Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:53.144863Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. ]  SessionId [c70334fe-e10b1ec-1f9ce4da-67724390|d9b70e62-cd586df7-cdebd24b-eaea041f_0]  MessageGroupId [c70334fe-e10b1ec-1f9ce4da-67724390] Write session: set DirectWriteToPartitionId 1
2025-12-12T12:26:53.144941Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:26:53.144939Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. ]  SessionId [c70334fe-e10b1ec-1f9ce4da-67724390|d9b70e62-cd586df7-cdebd24b-eaea041f_0]  PartitionId [1]  Generation [0] Get partition location async, partition 1, delay 0.000000s
2025-12-12T12:26:53.144950Z :YDB_SDK TRACE: actor.cpp:37: 2025-12-12T12:26:53.144949Z :TRACE: [local] TRACE_EVENT DescribePartitionRequest  path=local/recovery_output partition_id=1
2025-12-12T12:26:53.144986Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:53.144978Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. ]  SessionId [c70334fe-e10b1ec-1f9ce4da-67724390|d9b70e62-cd586df7-cdebd24b-eaea041f_0]  PartitionId [1]  Generation [0]  Getting partition location, partition 1
2025-12-12T12:26:53.145985Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:26:53.145977Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. ]  SessionId [c70334fe-e10b1ec-1f9ce4da-67724390|d9b70e62-cd586df7-cdebd24b-eaea041f_0]  PartitionId [1]  Generation [0] Got PartitionLocation response. Status SUCCESS, proto:
partition {
  partition_id: 1
  active: true
  partition_location {
    node_id: 1
    generation: 1
  }
}

2025-12-12T12:26:53.145991Z :YDB_SDK TRACE: actor.cpp:37: 2025-12-12T12:26:53.145989Z :TRACE: [local] TRACE_EVENT DescribePartitionResponse  partition_id=1 active=1 pl_node_id=1 pl_generation=1
2025-12-12T12:26:53.145997Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:53.145995Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. ]  SessionId [c70334fe-e10b1ec-1f9ce4da-67724390|d9b70e62-cd586df7-cdebd24b-eaea041f_0]  PartitionId [1]  Generation [0] GetPreferredEndpoint: partitionId 1, partitionNodeId 1 exists in the endpoint pool.
2025-12-12T12:26:53.146003Z :YDB_SDK TRACE: actor.cpp:37: 2025-12-12T12:26:53.146001Z :TRACE: [local] TRACE_EVENT PreferredPartitionLocation  Endpoint= NodeId=1 Generation=1
2025-12-12T12:26:53.146007Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:26:53.146005Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. ]  SessionId [c70334fe-e10b1ec-1f9ce4da-67724390|d9b70e62-cd586df7-cdebd24b-eaea041f_0]  PartitionId [1]  Generation [1] Start write session. Will connect to nodeId: 1
2025-12-12T12:26:53.147242Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:53.147235Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. ]  SessionId [c70334fe-e10b1ec-1f9ce4da-67724390|d9b70e62-cd586df7-cdebd24b-eaea041f_0]  PartitionId [1]  Generation [1] Write session: OnReadDone gRpcStatusCode: 1, Msg: CANCELLED, Details: , InternalError: 0
2025-12-12T12:26:53.147331Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:53.147329Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. ]  SessionId [c70334fe-e10b1ec-1f9ce4da-67724390|d9b70e62-cd586df7-cdebd24b-eaea041f_0]  PartitionId [1]  Generation [1] Write session: direct write to partition: 1, generation 1
2025-12-12T12:26:53.147355Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:53.147353Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. ]  SessionId [c70334fe-e10b1ec-1f9ce4da-67724390|d9b70e62-cd586df7-cdebd24b-eaea041f_0]  PartitionId [1]  Generation [1] Write session: send init request: init_request { path: "recovery_output" producer_id: "c70334fe-e10b1ec-1f9ce4da-67724390" partition_with_generation { partition_id: 1 generation: 1 } }
2025-12-12T12:26:53.147359Z :YDB_SDK TRACE: actor.cpp:37: 2025-12-12T12:26:53.147357Z :TRACE: [local] TRACE_EVENT InitRequest  pwg_partition_id=1 pwg_generation=1
2025-12-12T12:26:53.147434Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:53.147432Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. ]  SessionId [c70334fe-e10b1ec-1f9ce4da-67724390|d9b70e62-cd586df7-cdebd24b-eaea041f_0]  PartitionId [1]  Generation [1] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T12:26:53.158399Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:53.158389Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. ]  SessionId [c70334fe-e10b1ec-1f9ce4da-67724390|d9b70e62-cd586df7-cdebd24b-eaea041f_0]  PartitionId [1]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T12:26:53.158445Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:26:53.158442Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. ]  SessionId [c70334fe-e10b1ec-1f9ce4da-67724390|d9b70e62-cd586df7-cdebd24b-eaea041f_0]  PartitionId [1]  Generation [1] Write session established. Init response: last_seq_no: 14 session_id: "c70334fe-e10b1ec-1f9ce4da-67724390|8e7a1caf-33f2452e-55d86734-16787576_0" partition_id: 1
2025-12-12T12:26:53.158450Z :YDB_SDK TRACE: actor.cpp:37: 2025-12-12T12:26:53.158448Z :TRACE: [local] TRACE_EVENT InitResponse  partition_id=1 session_id=c70334fe-e10b1ec-1f9ce4da-67724390|8e7a1caf-33f2452e-55d86734-16787576_0
2025-12-12T12:26:53.158454Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:53.158452Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. ]  SessionId [c70334fe-e10b1ec-1f9ce4da-67724390|8e7a1caf-33f2452e-55d86734-16787576_0]  PartitionId [1]  Generation [1] Write session: set DirectWriteToPartitionId 1
2025-12-12T12:26:53.158519Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:53.158501Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. ]  SessionId [c70334fe-e10b1ec-1f9ce4da-67724390|8e7a1caf-33f2452e-55d86734-16787576_0]  PartitionId [1]  Generation [1] Write 1 messages with Id from 9 to 9
2025-12-12T12:26:53.158538Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:53.158536Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. ]  SessionId [c70334fe-e10b1ec-1f9ce4da-67724390|8e7a1caf-33f2452e-55d86734-16787576_0]  PartitionId [1]  Generation [1] Write session: try to update token
2025-12-12T12:26:53.158544Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:53.158541Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. ]  SessionId [c70334fe-e10b1ec-1f9ce4da-67724390|8e7a1caf-33f2452e-55d86734-16787576_0]  PartitionId [1]  Generation [1] Send 1 message(s) (0 left), first sequence number is 9
2025-12-12T12:26:53.158644Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:53.158641Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. ]  SessionId [c70334fe-e10b1ec-1f9ce4da-67724390|8e7a1caf-33f2452e-55d86734-16787576_0]  PartitionId [1]  Generation [1] Write 1 messages with Id from 10 to 10
2025-12-12T12:26:53.158651Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:53.158649Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. ]  SessionId [c70334fe-e10b1ec-1f9ce4da-67724390|8e7a1caf-33f2452e-55d86734-16787576_0]  PartitionId [1]  Generation [1] Write session: try to update token
2025-12-12T12:26:53.158653Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:53.158652Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. ]  SessionId [c70334fe-e10b1ec-1f9ce4da-67724390|8e7a1caf-33f2452e-55d86734-16787576_0]  PartitionId [1]  Generation [1] Send 1 message(s) (0 left), first sequence number is 10
2025-12-12T12:26:53.158659Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:53.158658Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. ]  SessionId [c70334fe-e10b1ec-1f9ce4da-67724390|8e7a1caf-33f2452e-55d86734-16787576_0]  PartitionId [1]  Generation [1] Write 1 messages with Id from 11 to 11
2025-12-12T12:26:53.158663Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:53.158662Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. ]  SessionId [c70334fe-e10b1ec-1f9ce4da-67724390|8e7a1caf-33f2452e-55d86734-16787576_0]  PartitionId [1]  Generation [1] Write session: try to update token
2025-12-12T12:26:53.158665Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:53.158664Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. ]  SessionId [c70334fe-e10b1ec-1f9ce4da-67724390|8e7a1caf-33f2452e-55d86734-16787576_0]  PartitionId [1]  Generation [1] Send 1 message(s) (0 left), first sequence number is 11
2025-12-12T12:26:53.158670Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:53.158668Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. ]  SessionId [c70334fe-e10b1ec-1f9ce4da-67724390|8e7a1caf-33f2452e-55d86734-16787576_0]  PartitionId [1]  Generation [1] Write 1 messages with Id from 12 to 12
2025-12-12T12:26:53.158677Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:53.158676Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. ]  SessionId [c70334fe-e10b1ec-1f9ce4da-67724390|8e7a1caf-33f2452e-55d86734-16787576_0]  PartitionId [1]  Generation [1] Write session: try to update token
2025-12-12T12:26:53.158679Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:53.158678Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. ]  SessionId [c70334fe-e10b1ec-1f9ce4da-67724390|8e7a1caf-33f2452e-55d86734-16787576_0]  PartitionId [1]  Generation [1] Send 1 message(s) (0 left), first sequence number is 12
2025-12-12T12:26:53.158684Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:53.158683Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. ]  SessionId [c70334fe-e10b1ec-1f9ce4da-67724390|8e7a1caf-33f2452e-55d86734-16787576_0]  PartitionId [1]  Generation [1] Write 1 messages with Id from 13 to 13
2025-12-12T12:26:53.158688Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:53.158686Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. ]  SessionId [c70334fe-e10b1ec-1f9ce4da-67724390|8e7a1caf-33f2452e-55d86734-16787576_0]  PartitionId [1]  Generation [1] Write session: try to update token
2025-12-12T12:26:53.158690Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:53.158689Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. ]  SessionId [c70334fe-e10b1ec-1f9ce4da-67724390|8e7a1caf-33f2452e-55d86734-16787576_0]  PartitionId [1]  Generation [1] Send 1 message(s) (0 left), first sequence number is 13
2025-12-12T12:26:53.158696Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:53.158694Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. ]  SessionId [c70334fe-e10b1ec-1f9ce4da-67724390|8e7a1caf-33f2452e-55d86734-16787576_0]  PartitionId [1]  Generation [1] Write 1 messages with Id from 14 to 14
2025-12-12T12:26:53.158699Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:53.158698Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. ]  SessionId [c70334fe-e10b1ec-1f9ce4da-67724390|8e7a1caf-33f2452e-55d86734-16787576_0]  PartitionId [1]  Generation [1] Write session: try to update token
2025-12-12T12:26:53.158702Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:53.158701Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. ]  SessionId [c70334fe-e10b1ec-1f9ce4da-67724390|8e7a1caf-33f2452e-55d86734-16787576_0]  PartitionId [1]  Generation [1] Send 1 message(s) (0 left), first sequence number is 14
2025-12-12T12:26:53.159528Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:53.159522Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. ]  SessionId [c70334fe-e10b1ec-1f9ce4da-67724390|8e7a1caf-33f2452e-55d86734-16787576_0]  PartitionId [1]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T12:26:53.159571Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:53.159567Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. ]  SessionId [c70334fe-e10b1ec-1f9ce4da-67724390|8e7a1caf-33f2452e-55d86734-16787576_0]  PartitionId [1]  Generation [1] Write session got write response: acks { seq_no: 9 skipped { reason: REASON_ALREADY_WRITTEN } } partition_id: 1 write_statistics { persisting_time { } min_queue_wait_time { } max_queue_wait_time { } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T12:26:53.159574Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:53.159573Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. ]  SessionId [c70334fe-e10b1ec-1f9ce4da-67724390|8e7a1caf-33f2452e-55d86734-16787576_0]  PartitionId [1]  Generation [1] OnAck: seqNo=9, txId=?
2025-12-12T12:26:53.159578Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:53.159577Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. ]  SessionId [c70334fe-e10b1ec-1f9ce4da-67724390|8e7a1caf-33f2452e-55d86734-16787576_0]  PartitionId [1]  Generation [1] Write session: acknoledged message 9
2025-12-12T12:26:53.159636Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:454: SelfId: [2:7582946927772285450:2253], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. Ack seq no 9
2025-12-12T12:26:53.159790Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:53.159787Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. ]  SessionId [c70334fe-e10b1ec-1f9ce4da-67724390|8e7a1caf-33f2452e-55d86734-16787576_0]  PartitionId [1]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T12:26:53.159808Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:53.159806Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. ]  SessionId [c70334fe-e10b1ec-1f9ce4da-67724390|8e7a1caf-33f2452e-55d86734-16787576_0]  PartitionId [1]  Generation [1] Write session got write response: acks { seq_no: 10 skipped { reason: REASON_ALREADY_WRITTEN } } partition_id: 1 write_statistics { persisting_time { } min_queue_wait_time { } max_queue_wait_time { } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T12:26:53.159812Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:53.159810Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. ]  SessionId [c70334fe-e10b1ec-1f9ce4da-67724390|8e7a1caf-33f2452e-55d86734-16787576_0]  PartitionId [1]  Generation [1] OnAck: seqNo=10, txId=?
2025-12-12T12:26:53.159815Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:53.159814Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. ]  SessionId [c70334fe-e10b1ec-1f9ce4da-67724390|8e7a1caf-33f2452e-55d86734-16787576_0]  PartitionId [1]  Generation [1] Write session: acknoledged message 10
2025-12-12T12:26:53.159874Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:454: SelfId: [2:7582946927772285450:2253], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. Ack seq no 10
2025-12-12T12:26:53.159912Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:53.159910Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. ]  SessionId [c70334fe-e10b1ec-1f9ce4da-67724390|8e7a1caf-33f2452e-55d86734-16787576_0]  PartitionId [1]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T12:26:53.159925Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:53.159924Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. ]  SessionId [c70334fe-e10b1ec-1f9ce4da-67724390|8e7a1caf-33f2452e-55d86734-16787576_0]  PartitionId [1]  Generation [1] Write session got write response: acks { seq_no: 11 skipped { reason: REASON_ALREADY_WRITTEN } } partition_id: 1 write_statistics { persisting_time { } min_queue_wait_time { } max_queue_wait_time { } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T12:26:53.159928Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:53.159927Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. ]  SessionId [c70334fe-e10b1ec-1f9ce4da-67724390|8e7a1caf-33f2452e-55d86734-16787576_0]  PartitionId [1]  Generation [1] OnAck: seqNo=11, txId=?
2025-12-12T12:26:53.159931Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:53.159930Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. ]  SessionId [c70334fe-e10b1ec-1f9ce4da-67724390|8e7a1caf-33f2452e-55d86734-16787576_0]  PartitionId [1]  Generation [1] Write session: acknoledged message 11
2025-12-12T12:26:53.159961Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:454: SelfId: [2:7582946927772285450:2253], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. Ack seq no 11
2025-12-12T12:26:53.159965Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:53.159963Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. ]  SessionId [c70334fe-e10b1ec-1f9ce4da-67724390|8e7a1caf-33f2452e-55d86734-16787576_0]  PartitionId [1]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T12:26:53.159975Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:53.159974Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. ]  SessionId [c70334fe-e10b1ec-1f9ce4da-67724390|8e7a1caf-33f2452e-55d86734-16787576_0]  PartitionId [1]  Generation [1] Write session got write response: acks { seq_no: 12 skipped { reason: REASON_ALREADY_WRITTEN } } partition_id: 1 write_statistics { persisting_time { } min_queue_wait_time { } max_queue_wait_time { } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T12:26:53.159978Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:53.159977Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. ]  SessionId [c70334fe-e10b1ec-1f9ce4da-67724390|8e7a1caf-33f2452e-55d86734-16787576_0]  PartitionId [1]  Generation [1] OnAck: seqNo=12, txId=?
2025-12-12T12:26:53.159981Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:53.159980Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. ]  SessionId [c70334fe-e10b1ec-1f9ce4da-67724390|8e7a1caf-33f2452e-55d86734-16787576_0]  PartitionId [1]  Generation [1] Write session: acknoledged message 12
2025-12-12T12:26:53.160002Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:53.160001Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. ]  SessionId [c70334fe-e10b1ec-1f9ce4da-67724390|8e7a1caf-33f2452e-55d86734-16787576_0]  PartitionId [1]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T12:26:53.160013Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:53.160012Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. ]  SessionId [c70334fe-e10b1ec-1f9ce4da-67724390|8e7a1caf-33f2452e-55d86734-16787576_0]  PartitionId [1]  Generation [1] Write session got write response: acks { seq_no: 13 skipped { reason: REASON_ALREADY_WRITTEN } } partition_id: 1 write_statistics { persisting_time { } min_queue_wait_time { } max_queue_wait_time { } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T12:26:53.160016Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:53.160015Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. ]  SessionId [c70334fe-e10b1ec-1f9ce4da-67724390|8e7a1caf-33f2452e-55d86734-16787576_0]  PartitionId [1]  Generation [1] OnAck: seqNo=13, txId=?
2025-12-12T12:26:53.160017Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:454: SelfId: [2:7582946927772285450:2253], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. Ack seq no 12
2025-12-12T12:26:53.160019Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:53.160018Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. ]  SessionId [c70334fe-e10b1ec-1f9ce4da-67724390|8e7a1caf-33f2452e-55d86734-16787576_0]  PartitionId [1]  Generation [1] Write session: acknoledged message 13
2025-12-12T12:26:53.160054Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:454: SelfId: [2:7582946927772285450:2253], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. Ack seq no 13
2025-12-12T12:26:53.160129Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:53.160123Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. ]  SessionId [c70334fe-e10b1ec-1f9ce4da-67724390|8e7a1caf-33f2452e-55d86734-16787576_0]  PartitionId [1]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T12:26:53.160157Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:53.160155Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. ]  SessionId [c70334fe-e10b1ec-1f9ce4da-67724390|8e7a1caf-33f2452e-55d86734-16787576_0]  PartitionId [1]  Generation [1] Write session got write response: acks { seq_no: 14 skipped { reason: REASON_ALREADY_WRITTEN } } partition_id: 1 write_statistics { persisting_time { } min_queue_wait_time { } max_queue_wait_time { } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T12:26:53.160160Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:53.160159Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. ]  SessionId [c70334fe-e10b1ec-1f9ce4da-67724390|8e7a1caf-33f2452e-55d86734-16787576_0]  PartitionId [1]  Generation [1] OnAck: seqNo=14, txId=?
2025-12-12T12:26:53.160164Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:53.160162Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. ]  SessionId [c70334fe-e10b1ec-1f9ce4da-67724390|8e7a1caf-33f2452e-55d86734-16787576_0]  PartitionId [1]  Generation [1] Write session: acknoledged message 14
2025-12-12T12:26:53.160217Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:454: SelfId: [2:7582946927772285450:2253], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. Ack seq no 14
2025-12-12T12:26:53.986691Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582946899284415308:2092]
2025-12-12T12:26:53.986714Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:26:53.988517Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 98aed2a1-72ca4129-b8aeede3-59d0649b3, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:26:53.991909Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:26:53.999294Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:26:53.999309Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:26:54.091984Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:54.091976Z :DEBUG: [local] [local] [865e475e-9f3c4a1f-4bba642a-9a9010f0] [] Got ReadResponse, serverBytesSize = 90, now ReadSizeBudget = 0, ReadSizeServerDelta = 8388518
2025-12-12T12:26:54.092015Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:54.092012Z :DEBUG: [local] [local] [865e475e-9f3c4a1f-4bba642a-9a9010f0] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 8388518
2025-12-12T12:26:54.092033Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:54.092029Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (14-15)
2025-12-12T12:26:54.092038Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:54.092036Z :DEBUG: [local] [local] [865e475e-9f3c4a1f-4bba642a-9a9010f0] [] Returning serverBytesSize = 90 to budget
2025-12-12T12:26:54.092041Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:54.092039Z :DEBUG: [local] [local] [865e475e-9f3c4a1f-4bba642a-9a9010f0] [] In ContinueReadingDataImpl, ReadSizeBudget = 90, ReadSizeServerDelta = 8388518
2025-12-12T12:26:54.092083Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:54.092081Z :DEBUG: [local] [local] [865e475e-9f3c4a1f-4bba642a-9a9010f0] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 8388608
2025-12-12T12:26:54.092119Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:363: SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, task: 2. PQ source. SessionId: 865e475e-9f3c4a1f-4bba642a-9a9010f0 Source data ready
2025-12-12T12:26:54.092147Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Poll inputs
2025-12-12T12:26:54.092150Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Poll sources
2025-12-12T12:26:54.092156Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:542: SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, task: 2. PQ source. SessionId: 865e475e-9f3c4a1f-4bba642a-9a9010f0 GetAsyncInputData freeSpace = 1000000
2025-12-12T12:26:54.092172Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:54.092169Z :DEBUG: [local] Take Data. Partition 1. Read: {0, 0} (14-14)
2025-12-12T12:26:54.092178Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:54.092177Z :DEBUG: [local] Take Data. Partition 1. Read: {1, 0} (15-15)
2025-12-12T12:26:54.092186Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:54.092185Z :DEBUG: [local] [local] [865e475e-9f3c4a1f-4bba642a-9a9010f0] [] The application data is transferred to the client. Number of messages 2, size 4 bytes
2025-12-12T12:26:54.092194Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:54.092192Z :DEBUG: [local] [local] [865e475e-9f3c4a1f-4bba642a-9a9010f0] [] Returning serverBytesSize = 0 to budget
2025-12-12T12:26:54.092209Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:761: SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, task: 2. PQ source. SessionId: 865e475e-9f3c4a1f-4bba642a-9a9010f0 Key: 1@ Data received: Message { Data: "22" Information: { Offset: 14 ProducerId: "" SeqNo: 0 CreateTime: 2025-12-12T12:26:54.065000Z WriteTime: 2025-12-12T12:26:54.065000Z MessageGroupId: "" Meta: { } MessageMeta: { } } Partition session id: 1 Topic: "recovery_input" Partition: 1 }
2025-12-12T12:26:54.092227Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:761: SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, task: 2. PQ source. SessionId: 865e475e-9f3c4a1f-4bba642a-9a9010f0 Key: 1@ Data received: Message { Data: "25" Information: { Offset: 15 ProducerId: "" SeqNo: 0 CreateTime: 2025-12-12T12:26:54.065000Z WriteTime: 2025-12-12T12:26:54.089000Z MessageGroupId: "" Meta: { } MessageMeta: { } } Partition session id: 1 Topic: "recovery_input" Partition: 1 }
2025-12-12T12:26:54.092242Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:737: SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, task: 2. PQ source. SessionId: 865e475e-9f3c4a1f-4bba642a-9a9010f0 Return ready batch. DataCount = 2 Watermark = none Used space = 4
2025-12-12T12:26:54.092245Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:81: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Poll async input 0. Buffer free space: 1000000, read from async input: 4 bytes, 2 rows, finished: 0
2025-12-12T12:26:54.092264Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:363: SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, task: 2. PQ source. SessionId: 865e475e-9f3c4a1f-4bba642a-9a9010f0 Source data ready
2025-12-12T12:26:54.092268Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-12-12T12:26:54.092274Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Poll inputs
2025-12-12T12:26:54.092275Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Poll sources
2025-12-12T12:26:54.092280Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:542: SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, task: 2. PQ source. SessionId: 865e475e-9f3c4a1f-4bba642a-9a9010f0 GetAsyncInputData freeSpace = 999996
2025-12-12T12:26:54.092283Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:81: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Poll async input 0. Buffer free space: 999996, read from async input: 0 bytes, 0 rows, finished: 0
2025-12-12T12:26:54.092347Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-12-12T12:26:54.092355Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Poll inputs
2025-12-12T12:26:54.092356Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Poll sources
2025-12-12T12:26:54.092358Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:542: SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, task: 2. PQ source. SessionId: 865e475e-9f3c4a1f-4bba642a-9a9010f0 GetAsyncInputData freeSpace = 999996
2025-12-12T12:26:54.092360Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:81: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Poll async input 0. Buffer free space: 999996, read from async input: 0 bytes, 0 rows, finished: 0
2025-12-12T12:26:54.092364Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. update task runner stats
2025-12-12T12:26:54.092391Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-12T12:26:54.092394Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:26:54.092397Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-12T12:26:54.092401Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-12-12T12:26:54.092418Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [2:7582946927772285450:2253], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. SendData. Batch: 2. Checkpoint: 0. Finished: 0
2025-12-12T12:26:54.092422Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:221: SelfId: [2:7582946927772285450:2253], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. Received data for sending: 22
2025-12-12T12:26:54.092423Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:221: SelfId: [2:7582946927772285450:2253], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. Received data for sending: 25
2025-12-12T12:26:54.092438Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:54.092436Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. ]  SessionId [c70334fe-e10b1ec-1f9ce4da-67724390|8e7a1caf-33f2452e-55d86734-16787576_0]  PartitionId [1]  Generation [1] Write 1 messages with Id from 15 to 15
2025-12-12T12:26:54.092454Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:54.092452Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. ]  SessionId [c70334fe-e10b1ec-1f9ce4da-67724390|8e7a1caf-33f2452e-55d86734-16787576_0]  PartitionId [1]  Generation [1] Write session: try to update token
2025-12-12T12:26:54.092458Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:54.092457Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. ]  SessionId [c70334fe-e10b1ec-1f9ce4da-67724390|8e7a1caf-33f2452e-55d86734-16787576_0]  PartitionId [1]  Generation [1] Send 1 message(s) (0 left), first sequence number is 15
2025-12-12T12:26:54.092551Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Sink 0: sent 12 bytes of data and 0 bytes of checkpoint barrier
2025-12-12T12:26:54.092570Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 4, sent data from buffer: 12
2025-12-12T12:26:54.092602Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Poll inputs
2025-12-12T12:26:54.092604Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Poll sources
2025-12-12T12:26:54.092607Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:542: SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, task: 2. PQ source. SessionId: 865e475e-9f3c4a1f-4bba642a-9a9010f0 GetAsyncInputData freeSpace = 1000000
2025-12-12T12:26:54.092610Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:81: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Poll async input 0. Buffer free space: 1000000, read from async input: 0 bytes, 0 rows, finished: 0
2025-12-12T12:26:54.092614Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. update task runner stats
2025-12-12T12:26:54.092627Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-12T12:26:54.092628Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:26:54.092630Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777212, allowedOvercommit: 500000, toSend: 17277212
2025-12-12T12:26:54.092634Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-12-12T12:26:54.092637Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [2:7582946927772285450:2253], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-12-12T12:26:54.092640Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-12-12T12:26:54.092642Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-12T12:26:54.092654Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. update task runner stats
2025-12-12T12:26:54.092660Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-12T12:26:54.092661Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:26:54.092663Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777212, allowedOvercommit: 500000, toSend: 17277212
2025-12-12T12:26:54.092666Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [2:7582946927772285450:2253], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-12-12T12:26:54.092667Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-12-12T12:26:54.092668Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-12T12:26:54.092678Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. update task runner stats
2025-12-12T12:26:54.092683Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-12T12:26:54.092684Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:26:54.092685Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777212, allowedOvercommit: 500000, toSend: 17277212
2025-12-12T12:26:54.092688Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [2:7582946927772285450:2253], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-12-12T12:26:54.092689Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-12-12T12:26:54.092691Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-12T12:26:54.095062Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:54.095052Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. ]  SessionId [c70334fe-e10b1ec-1f9ce4da-67724390|8e7a1caf-33f2452e-55d86734-16787576_0]  PartitionId [1]  Generation [1] Write 1 messages with Id from 16 to 16
2025-12-12T12:26:54.095078Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:54.095076Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. ]  SessionId [c70334fe-e10b1ec-1f9ce4da-67724390|8e7a1caf-33f2452e-55d86734-16787576_0]  PartitionId [1]  Generation [1] Write session: try to update token
2025-12-12T12:26:54.095084Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:54.095081Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. ]  SessionId [c70334fe-e10b1ec-1f9ce4da-67724390|8e7a1caf-33f2452e-55d86734-16787576_0]  PartitionId [1]  Generation [1] Send 1 message(s) (0 left), first sequence number is 16
2025-12-12T12:26:54.098105Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:54.098096Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. ]  SessionId [c70334fe-e10b1ec-1f9ce4da-67724390|8e7a1caf-33f2452e-55d86734-16787576_0]  PartitionId [1]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T12:26:54.098144Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:54.098142Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. ]  SessionId [c70334fe-e10b1ec-1f9ce4da-67724390|8e7a1caf-33f2452e-55d86734-16787576_0]  PartitionId [1]  Generation [1] Write session got write response: acks { seq_no: 15 written { offset: 14 } } partition_id: 1 write_statistics { persisting_time { nanos: 1000000 } min_queue_wait_time { } max_queue_wait_time { } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T12:26:54.098148Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:54.098147Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. ]  SessionId [c70334fe-e10b1ec-1f9ce4da-67724390|8e7a1caf-33f2452e-55d86734-16787576_0]  PartitionId [1]  Generation [1] OnAck: seqNo=15, txId=?
2025-12-12T12:26:54.098152Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:54.098151Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. ]  SessionId [c70334fe-e10b1ec-1f9ce4da-67724390|8e7a1caf-33f2452e-55d86734-16787576_0]  PartitionId [1]  Generation [1] Write session: acknoledged message 15
2025-12-12T12:26:54.099053Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:54.099042Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. ]  SessionId [c70334fe-e10b1ec-1f9ce4da-67724390|8e7a1caf-33f2452e-55d86734-16787576_0]  PartitionId [1]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T12:26:54.099105Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:454: SelfId: [2:7582946927772285450:2253], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. Ack seq no 15
2025-12-12T12:26:54.099114Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:54.099111Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. ]  SessionId [c70334fe-e10b1ec-1f9ce4da-67724390|8e7a1caf-33f2452e-55d86734-16787576_0]  PartitionId [1]  Generation [1] Write session got write response: acks { seq_no: 16 written { offset: 15 } } partition_id: 1 write_statistics { persisting_time { nanos: 1000000 } min_queue_wait_time { } max_queue_wait_time { } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T12:26:54.099122Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:54.099120Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. ]  SessionId [c70334fe-e10b1ec-1f9ce4da-67724390|8e7a1caf-33f2452e-55d86734-16787576_0]  PartitionId [1]  Generation [1] OnAck: seqNo=16, txId=?
2025-12-12T12:26:54.099127Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:54.099125Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. ]  SessionId [c70334fe-e10b1ec-1f9ce4da-67724390|8e7a1caf-33f2452e-55d86734-16787576_0]  PartitionId [1]  Generation [1] Write session: acknoledged message 16
2025-12-12T12:26:54.103069Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:454: SelfId: [2:7582946927772285450:2253], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. Ack seq no 16
2025-12-12T12:26:54.130125Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:26:54.130111Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:recovery_input:1:1:15:8
2025-12-12T12:26:54.130156Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:26:54.130153Z :INFO: [local] [local] [865e475e-9f3c4a1f-4bba642a-9a9010f0] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1000 BytesRead: 16 MessagesRead: 8 BytesReadCompressed: 16 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:26:54.161550Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:239: [ptqudq7ug3b8up2rk3ft-0] Task: 2. [Checkpoint 3.1] TEvInjectCheckpoint
2025-12-12T12:26:54.161569Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Poll inputs
2025-12-12T12:26:54.161571Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1494: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-12-12T12:26:54.161573Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. DoExecuteImpl: 1
2025-12-12T12:26:54.161644Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:462: SelfId: [2:7582946927772285443:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Pending 1 checkpoints to be sent
2025-12-12T12:26:54.161649Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. update task runner stats
2025-12-12T12:26:54.161676Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 1 watermark injected: (empty maybe)
2025-12-12T12:26:54.161679Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:447: [ptqudq7ug3b8up2rk3ft-0] Task: 2. [Checkpoint 3.1] Performing task checkpoint
2025-12-12T12:26:54.161680Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:816: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Save state
2025-12-12T12:26:54.161689Z :KQP_COMPUTE DEBUG: dq_pq_read_actor_base.cpp:94: SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, task: 2. PQ source. SessionId: 865e475e-9f3c4a1f-4bba642a-9a9010f0 SaveState, offsets: {1,16},
2025-12-12T12:26:54.161717Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:474: [ptqudq7ug3b8up2rk3ft-0] Task: 2. [Checkpoint 3.1] CA state saved
2025-12-12T12:26:54.161721Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:449: [ptqudq7ug3b8up2rk3ft-0] Task: 2. [Checkpoint 3.1] Injecting checkpoint barrier to outputs
2025-12-12T12:26:54.161723Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:26:54.161727Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-12T12:26:54.161732Z :KQP_COMPUTE INFO: dq_async_compute_actor.cpp:1010: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Resume inputs
2025-12-12T12:26:54.161734Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [2:7582946927772285450:2253], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 1. Finished: 0
2025-12-12T12:26:54.161736Z :KQP_COMPUTE DEBUG: dq_pq_write_actor.cpp:240: SelfId: [2:7582946927772285450:2253], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. [Checkpoint 3.1] Send checkpoint state immediately
2025-12-12T12:26:54.161759Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:418: SelfId: [2:7582946927772285450:2253], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. Save checkpoint { Id: 1 Generation: 3 Type: CHECKPOINT_TYPE_SNAPSHOT } state: { SourceId: "c70334fe-e10b1ec-1f9ce4da-67724390" ConfirmedSeqNo: 16 EgressBytes: 25 }
2025-12-12T12:26:54.161763Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:524: [ptqudq7ug3b8up2rk3ft-0] Task: 2. Sink[0] state saved
2025-12-12T12:26:54.161773Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:536: [ptqudq7ug3b8up2rk3ft-0] Task: 2. [Checkpoint 3.1] Task checkpoint is done. Send to storage
2025-12-12T12:26:54.161779Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 6 bytes of checkpoint barrier
2025-12-12T12:26:54.161781Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-12T12:26:54.161784Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Poll inputs
2025-12-12T12:26:54.161785Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Poll sources
2025-12-12T12:26:54.161789Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:542: SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, task: 2. PQ source. SessionId: 865e475e-9f3c4a1f-4bba642a-9a9010f0 GetAsyncInputData freeSpace = 1000000
2025-12-12T12:26:54.161794Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:81: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Poll async input 0. Buffer free space: 1000000, read from async input: 0 bytes, 0 rows, finished: 0
2025-12-12T12:26:54.161794Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:460: [ptqudq7ug3b8up2rk3ft-0] [3:1] Got TEvSaveTaskState: task 2
2025-12-12T12:26:54.161802Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-12-12T12:26:54.161818Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. update task runner stats
2025-12-12T12:26:54.161825Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-12T12:26:54.161826Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:26:54.161828Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-12T12:26:54.161831Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [2:7582946927772285450:2253], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-12-12T12:26:54.161833Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-12-12T12:26:54.161834Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-12T12:26:54.165549Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:484: [ptqudq7ug3b8up2rk3ft-0] [3:1] TEvSaveTaskState Apply: task: 2
2025-12-12T12:26:54.165572Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:499: [ptqudq7ug3b8up2rk3ft-0] [3:1] Send TEvSaveTaskStateResult: task: 2
2025-12-12T12:26:54.193530Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:759: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Commit state
2025-12-12T12:26:54.193567Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:54.193563Z :DEBUG: [local] [local] [865e475e-9f3c4a1f-4bba642a-9a9010f0] [] Commit offsets [8, 16). Partition stream id: 1
2025-12-12T12:26:54.195126Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:54.195115Z :DEBUG: [local] [local] [865e475e-9f3c4a1f-4bba642a-9a9010f0] [] Committed response: { partitions_committed_offsets { partition_session_id: 1 committed_offset: 16 } }
2025-12-12T12:26:54.195252Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:363: SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, task: 2. PQ source. SessionId: 865e475e-9f3c4a1f-4bba642a-9a9010f0 Source data ready
2025-12-12T12:26:54.195289Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Poll inputs
2025-12-12T12:26:54.195294Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Poll sources
2025-12-12T12:26:54.195301Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:542: SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, task: 2. PQ source. SessionId: 865e475e-9f3c4a1f-4bba642a-9a9010f0 GetAsyncInputData freeSpace = 1000000
2025-12-12T12:26:54.195316Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:81: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Poll async input 0. Buffer free space: 1000000, read from async input: 0 bytes, 0 rows, finished: 0
2025-12-12T12:26:54.195337Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:363: SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, task: 2. PQ source. SessionId: 865e475e-9f3c4a1f-4bba642a-9a9010f0 Source data ready
2025-12-12T12:26:54.195353Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-12-12T12:26:54.195406Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Poll inputs
2025-12-12T12:26:54.195426Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Poll sources
2025-12-12T12:26:54.195429Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:542: SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, task: 2. PQ source. SessionId: 865e475e-9f3c4a1f-4bba642a-9a9010f0 GetAsyncInputData freeSpace = 1000000
2025-12-12T12:26:54.195432Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:81: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Poll async input 0. Buffer free space: 1000000, read from async input: 0 bytes, 0 rows, finished: 0
2025-12-12T12:26:54.195437Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. update task runner stats
2025-12-12T12:26:54.195463Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-12T12:26:54.195465Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:26:54.195469Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-12T12:26:54.195472Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-12-12T12:26:54.195478Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [2:7582946927772285450:2253], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-12-12T12:26:54.195483Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-12-12T12:26:54.195486Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-12T12:26:54.195501Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. update task runner stats
2025-12-12T12:26:54.195506Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-12T12:26:54.195507Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:26:54.195509Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-12T12:26:54.195512Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [2:7582946927772285450:2253], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-12-12T12:26:54.195513Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-12-12T12:26:54.195528Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-12T12:26:54.989009Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 98aed2a1-72ca4129-b8aeede3-59d0649b4, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:26:54.995084Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:26:54.995110Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:26:55.064510Z :KQP_COMPUTE ERROR: dq_compute_actor_impl.h:1205: SelfId: [2:7582946927772285441:2253], TxId: ptqudq7ug3b8up2rk3ft, task: 2. Ctx: {}. Handle abort execution event from: [2:7582946919182350599:2064], status: UNAVAILABLE, reason: { <main>: Error: Aborted by LWM }
2025-12-12T12:26:55.064555Z :KQP_COMPUTE DEBUG: dq_compute_actor_channels.cpp:494: TxId: ptqudq7ug3b8up2rk3ft, task: 2. pass away
2025-12-12T12:26:55.064573Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:26:55.064569Z :INFO: [local] [local] [865e475e-9f3c4a1f-4bba642a-9a9010f0] Closing read session. Close timeout: 0.000000s
2025-12-12T12:26:55.064584Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:26:55.064582Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:recovery_input:1:1:15:16
2025-12-12T12:26:55.064592Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:26:55.064590Z :INFO: [local] [local] [865e475e-9f3c4a1f-4bba642a-9a9010f0] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1934 BytesRead: 16 MessagesRead: 8 BytesReadCompressed: 16 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:26:55.064603Z :YDB_SDK NOTICE: actor.cpp:37: 2025-12-12T12:26:55.064601Z :NOTICE: [local] [local] [865e475e-9f3c4a1f-4bba642a-9a9010f0] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Close with zero timeout " }
2025-12-12T12:26:55.064610Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:55.064608Z :DEBUG: [local] [local] [865e475e-9f3c4a1f-4bba642a-9a9010f0] [] Abort session to cluster
2025-12-12T12:26:55.064734Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:26:55.064729Z :INFO: [local] [local] [865e475e-9f3c4a1f-4bba642a-9a9010f0] Closing read session. Close timeout: 0.000000s
2025-12-12T12:26:55.064741Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:26:55.064738Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:recovery_input:1:1:15:16
2025-12-12T12:26:55.064747Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:26:55.064745Z :INFO: [local] [local] [865e475e-9f3c4a1f-4bba642a-9a9010f0] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1934 BytesRead: 16 MessagesRead: 8 BytesReadCompressed: 16 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:26:55.064754Z :YDB_SDK NOTICE: actor.cpp:37: 2025-12-12T12:26:55.064753Z :NOTICE: [local] [local] [865e475e-9f3c4a1f-4bba642a-9a9010f0] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T12:26:55.065512Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:26:55.065507Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. ]  SessionId [c70334fe-e10b1ec-1f9ce4da-67724390|8e7a1caf-33f2452e-55d86734-16787576_0]  PartitionId [1]  Generation [1] Write session: close. Timeout 0.000000s
2025-12-12T12:26:55.065517Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:26:55.065515Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. ]  SessionId [c70334fe-e10b1ec-1f9ce4da-67724390|8e7a1caf-33f2452e-55d86734-16787576_0]  PartitionId [1]  Generation [1] Write session will now close
2025-12-12T12:26:55.065532Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:55.065530Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. ]  SessionId [c70334fe-e10b1ec-1f9ce4da-67724390|8e7a1caf-33f2452e-55d86734-16787576_0]  PartitionId [1]  Generation [1] Write session: aborting
2025-12-12T12:26:55.065632Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:26:55.065630Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. ]  SessionId [c70334fe-e10b1ec-1f9ce4da-67724390|8e7a1caf-33f2452e-55d86734-16787576_0]  PartitionId [1]  Generation [1] Write session: gracefully shut down, all writes complete
2025-12-12T12:26:55.065636Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:26:55.065635Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ug3b8up2rk3ft, TaskId: 2, PQ sink. ]  SessionId [c70334fe-e10b1ec-1f9ce4da-67724390|8e7a1caf-33f2452e-55d86734-16787576_0]  PartitionId [1]  Generation [1] Write session: destroy
2025-12-12T12:26:55.987405Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582946899284415308:2092]
2025-12-12T12:26:55.987425Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:26:55.987937Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:26:55.989498Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 98aed2a1-72ca4129-b8aeede3-59d0649b5, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:26:56.000029Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:26:56.000048Z :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:13484: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-fhkyrtz6p4.auto.internal:13484
2025-12-12T12:26:56.509833Z :INTERCONNECT_NETWORK NOTICE: interconnect_tcp_input_session.cpp:712: [2 <-> 1] connection closed by peer
2025-12-12T12:26:56.510683Z :INTERCONNECT_NETWORK NOTICE: interconnect_handshake.cpp:1262: [2 <-> 1] network-related error occured on handshake: outgoing handshake Peer# ghrun-fhkyrtz6p4(127.0.1.1:15973) Couldn't connect to any resolved address
2025-12-12T12:26:56.524191Z :INTERCONNECT_NETWORK NOTICE: interconnect_handshake.cpp:1262: [2 <-> 1] network-related error occured on handshake: outgoing handshake Peer# ghrun-fhkyrtz6p4(127.0.1.1:15973) Couldn't connect to any resolved address
