2025-12-09T03:42:48.418972Z :GRPC_SERVER NOTICE: grpc_request_proxy.cpp:380: Grpc request proxy started, nodeid# 1, serve as static node
2025-12-09T03:42:48.419032Z :GRPC_SERVER CRIT: grpc_request_proxy.cpp:440: Failed to deliver subscription request to config dispatcher
2025-12-09T03:42:48.419036Z :GRPC_SERVER NOTICE: grpc_request_proxy.cpp:380: Grpc request proxy started, nodeid# 1, serve as static node
2025-12-09T03:42:48.419054Z :GRPC_SERVER CRIT: grpc_request_proxy.cpp:440: Failed to deliver subscription request to config dispatcher
2025-12-09T03:42:48.419347Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:214: Bootstrap
2025-12-09T03:42:48.419348Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:217: Create sdk ydb connection
2025-12-09T03:42:48.420243Z :FQ_QUOTA_PROXY INFO: quota_proxy.cpp:90: STARTED
2025-12-09T03:42:48.420285Z :FQ_LOG_UPDATER DEBUG: log.cpp:93: Updated YQL logs priority: 8
2025-12-09T03:42:48.420289Z :FQ_LOG_UPDATER CRIT: log.cpp:55: Failed to deliver subscription request to config dispatcher.
2025-12-09T03:42:48.420325Z :YQ_RATE_LIMITER INFO: quoter_service.cpp:124: Bootstraping with config: { Enabled: true DataPlaneEnabled: true Database { Endpoint: "localhost:23806" Database: "local" TablePrefix: "RateLimiter_240ef92d-5e09-495f-9c8b-cf6091e76cfc" } Limiters { CoordinationNodePath: "rate_limiter" } }
2025-12-09T03:42:48.420595Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:544: RowDispatcher: Successfully bootstrapped row dispatcher, id [1:7581698614495137367:2063], tenant /compute
2025-12-09T03:42:48.420613Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7581698614495137367:2063]
2025-12-09T03:42:48.420615Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:329: Coordinator: Add new row dispatcher to map (state 1)
2025-12-09T03:42:48.420715Z :YQL_NODES_MANAGER INFO: nodes_manager.cpp:88: Bootstrap, InstanceId: c399097-45257d71-947a7bb-d782002c
2025-12-09T03:42:48.420719Z :YQL_NODES_MANAGER DEBUG: nodes_manager.cpp:310: TNodesManagerActor::ResolveSelfAddress
2025-12-09T03:42:48.420735Z :YQ_TEST_CONNECTION DEBUG: test_connection.cpp:142: Starting yandex query test connection. Actor id: [1:7581698614495137372:2068]
2025-12-09T03:42:48.420801Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:239: Successfully bootstrapped TStorageProxy [1:7581698614495137366:2062] with connection to localhost:23806:local
2025-12-09T03:42:48.420829Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 55a2cdd3-99315dd9-b49ecced-900924191, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:42:48.420836Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:293: Coordinator: Successfully bootstrapped coordinator, id [1:7581698614495137407:2082], NodesManagerId [0:4705493345362661702:78], rebalancing timeout 5.000000s
2025-12-09T03:42:48.420838Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:637: RowDispatcher: TEvCoordinatorChangesSubscribe from [1:7581698614495137407:2082]
2025-12-09T03:42:48.420857Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:232: TLeaderElection [1:7581698614495137408:2083] Successfully bootstrapped, local coordinator id [1:7581698614495137407:2082], tenant id compute, local mode 0, coordination node path local/compute, endpoint localhost:23806
2025-12-09T03:42:48.421045Z :MEMORY_PROFILER NOTICE: monitor.cpp:332: Bootstrapped
2025-12-09T03:42:48.421673Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-12-09T03:42:48.423008Z :SCHEME_BOARD_SUBSCRIBER NOTICE: subscriber.cpp:849: [main][1:7581698614495137387:2078][/compute] Set up state: owner# [1:7581698614495137346:2052], state# { Deleted: 1 Strong: 0 Version: <Invalid> DomainId: <Invalid> AbandonedSchemeShards: there are 0 elements }
2025-12-09T03:42:48.423048Z :SCHEME_BOARD_SUBSCRIBER NOTICE: subscriber.cpp:849: [main][1:7581698614495137388:2079][/Root] Set up state: owner# [1:7581698614495137347:2053], state# { Deleted: 1 Strong: 0 Version: <Invalid> DomainId: <Invalid> AbandonedSchemeShards: there are 0 elements }
2025-12-09T03:42:48.423056Z :SCHEME_BOARD_SUBSCRIBER NOTICE: subscriber.cpp:849: [main][1:7581698614495137386:2077][/Root] Set up state: owner# [1:7581698614495137346:2052], state# { Deleted: 1 Strong: 0 Version: <Invalid> DomainId: <Invalid> AbandonedSchemeShards: there are 0 elements }
2025-12-09T03:42:48.423070Z :SCHEME_BOARD_SUBSCRIBER NOTICE: subscriber.cpp:849: [main][1:7581698614495137389:2080][/compute] Set up state: owner# [1:7581698614495137347:2053], state# { Deleted: 1 Strong: 0 Version: <Invalid> DomainId: <Invalid> AbandonedSchemeShards: there are 0 elements }
2025-12-09T03:42:48.423072Z :GRPC_SERVER WARN: grpc_request_proxy.cpp:583: SchemeBoardDelete /compute Strong=0
2025-12-09T03:42:48.423074Z :GRPC_SERVER WARN: grpc_request_proxy.cpp:583: SchemeBoardDelete /Root Strong=0
2025-12-09T03:42:48.423076Z :GRPC_SERVER WARN: grpc_request_proxy.cpp:583: SchemeBoardDelete /Root Strong=0
2025-12-09T03:42:48.423077Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:71: Run create coordination node "local/compute" actor
2025-12-09T03:42:48.423077Z :GRPC_SERVER WARN: grpc_request_proxy.cpp:583: SchemeBoardDelete /compute Strong=0
2025-12-09T03:42:48.423079Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:113: Call create coordination node "local/compute"
2025-12-09T03:42:48.423080Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:411: Call create coordination node "local/compute"
2025-12-09T03:42:48.423228Z :FQ_QUOTA_SERVICE INFO: quota_manager.cpp:196: STARTED
2025-12-09T03:42:48.440966Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:155: Successfully created coordination node "local/compute"
2025-12-09T03:42:48.440984Z :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-09T03:42:48.440999Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:345: TLeaderElection [1:7581698614495137408:2083] Coordination node successfully created
2025-12-09T03:42:48.441001Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:323: TLeaderElection [1:7581698614495137408:2083] Start session
2025-12-09T03:42:48.443145Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:359: TLeaderElection [1:7581698614495137408:2083] Session successfully created
2025-12-09T03:42:48.445068Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:372: TLeaderElection [1:7581698614495137408:2083] Semaphore successfully created
2025-12-09T03:42:48.445077Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:304: TLeaderElection [1:7581698614495137408:2083] Try to acquire semaphore
2025-12-09T03:42:48.445197Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:420: TLeaderElection [1:7581698614495137408:2083] Describe semaphore
2025-12-09T03:42:48.445964Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:386: TLeaderElection [1:7581698614495137408:2083] Semaphore successfully acquired
2025-12-09T03:42:48.446116Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:469: TLeaderElection [1:7581698614495137408:2083] Semaphore successfully described: coordinator id [1:7581698614495137407:2082] generation 4
2025-12-09T03:42:48.446126Z :FQ_ROW_DISPATCHER INFO: leader_election.cpp:471: TLeaderElection [1:7581698614495137408:2083] Send TEvCoordinatorChanged to [1:7581698614495137367:2063], new coordinator id [1:7581698614495137407:2082], previous coordinator id [0:0:0]
2025-12-09T03:42:48.446141Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:569: RowDispatcher: Coordinator changed, old leader (empty maybe), new [1:7581698614495137407:2082] generation 4
2025-12-09T03:42:48.446154Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7581698614495137367:2063]
2025-12-09T03:42:48.446161Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7581698614495137367:2063]
2025-12-09T03:42:48.446164Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7581698614495137367:2063]
2025-12-09T03:42:48.446172Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:440: Coordinator: New leader [1:7581698614495137407:2082], SelfId [1:7581698614495137407:2082]
2025-12-09T03:42:48.446181Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-09T03:42:48.486051Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:42:48.486065Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-09T03:42:48.502572Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:389: Send NodeInfo with size: 0 to DynamicNameserver
2025-12-09T03:42:49.125934Z :INTERCONNECT ERROR: interconnect_nameserver_dynamic.cpp:62:  ICN06 Unknown nodeId: 2
2025-12-09T03:42:49.417688Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 55a2cdd3-99315dd9-b49ecced-900924192, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:42:49.420403Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:42:49.420418Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-09T03:42:49.507802Z :INTERCONNECT ERROR: interconnect_nameserver_dynamic.cpp:62:  ICN06 Unknown nodeId: 3
2025-12-09T03:42:49.507834Z :INTERCONNECT ERROR: interconnect_nameserver_dynamic.cpp:62:  ICN06 Unknown nodeId: 2
2025-12-09T03:42:49.952050Z :INTERCONNECT ERROR: interconnect_nameserver_dynamic.cpp:62:  ICN06 Unknown nodeId: 3
2025-12-09T03:42:50.417155Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7581698614495137407:2082]
2025-12-09T03:42:50.417176Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-09T03:42:50.417182Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7581698614495137367:2063]
2025-12-09T03:42:50.417186Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7581698614495137367:2063]
2025-12-09T03:42:50.417188Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7581698614495137367:2063]
2025-12-09T03:42:50.417197Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-09T03:42:50.418142Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 55a2cdd3-99315dd9-b49ecced-900924193, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:42:50.421427Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:42:50.421438Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-09T03:42:50.477539Z :INTERCONNECT ERROR: interconnect_nameserver_dynamic.cpp:62:  ICN06 Unknown nodeId: 2
2025-12-09T03:42:51.114449Z :INTERCONNECT ERROR: interconnect_nameserver_dynamic.cpp:62:  ICN06 Unknown nodeId: 3
2025-12-09T03:42:51.418583Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 55a2cdd3-99315dd9-b49ecced-900924194, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:42:51.421965Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:42:51.421983Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-09T03:42:51.960280Z :INTERCONNECT ERROR: interconnect_nameserver_dynamic.cpp:62:  ICN06 Unknown nodeId: 2
2025-12-09T03:42:52.418019Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7581698614495137407:2082]
2025-12-09T03:42:52.418040Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-09T03:42:52.418045Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7581698614495137367:2063]
2025-12-09T03:42:52.418049Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7581698614495137367:2063]
2025-12-09T03:42:52.418054Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7581698614495137367:2063]
2025-12-09T03:42:52.418064Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-09T03:42:52.419028Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 55a2cdd3-99315dd9-b49ecced-900924195, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:42:52.422624Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:42:52.422635Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-09T03:42:52.596166Z :INTERCONNECT ERROR: interconnect_nameserver_dynamic.cpp:62:  ICN06 Unknown nodeId: 3
2025-12-09T03:42:53.258739Z :INTERCONNECT ERROR: interconnect_nameserver_dynamic.cpp:62:  ICN06 Unknown nodeId: 2
2025-12-09T03:42:53.417504Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-12-09T03:42:53.417644Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:665: Coordinator: Change global state to Started (by timeout)
2025-12-09T03:42:53.419468Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 55a2cdd3-99315dd9-b49ecced-900924196, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:42:53.426175Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:42:53.426186Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-09T03:42:53.430067Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:389: Send NodeInfo with size: 2 to DynamicNameserver
2025-12-09T03:42:53.544900Z :INTERCONNECT WARN: interconnect_handshake.cpp:501: Handshake [1:7581698635969974077:2063] [node 2] ICH09 Neither CompatibilityInfo nor VersionTag of the peer can be validated, accepting by default
2025-12-09T03:42:53.545232Z :INTERCONNECT WARN: interconnect_handshake.cpp:501: Handshake [1:7581698635969974075:2062] [node 3] ICH09 Neither CompatibilityInfo nor VersionTag of the peer can be validated, accepting by default
2025-12-09T03:42:53.560564Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: 55a2cdd3-99315dd9-b49ecced-90092419 2025-12-09 03:42:53.560 DEBUG ydbd(pid=1624813, tid=0x00007F05F9F6F640) [DQ] local_worker_manager.cpp:316: {ptqudqgd5lgim5dts52n} TLocalWorkerManager::TEvAllocateWorkersRequest 562962838323202
2025-12-09T03:42:53.560610Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: 55a2cdd3-99315dd9-b49ecced-90092419 2025-12-09 03:42:53.560 DEBUG ydbd(pid=1624813, tid=0x00007F05F9F6F640) [DQ] local_worker_manager.cpp:376: {ptqudqgd5lgim5dts52n} Create compute actor: async
2025-12-09T03:42:53.615240Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:144: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Start compute actor [1:7581698635969974086:2154], task: 2
2025-12-09T03:42:53.615298Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:114: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Use CPU quota: 1. Rate limiter resource: { "local/RateLimiter_240ef92d-5e09-495f-9c8b-cf6091e76cfc/rate_limiter", "mock_cloud/my_folder/ptqudqgd5lgim5dts52n" }
2025-12-09T03:42:53.774545Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:197: [] Task: 2. Got TEvNewCheckpointCoordinator event: generation 4, actorId: [2:7581698631372188970:2173]
2025-12-09T03:42:53.774557Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:208: [] Task: 2. Assign checkpoint coordinator (generation = 4)
2025-12-09T03:42:53.775237Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1447: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Create sink for output 0 { Sink { Type: "PqSink" Settings { type_url: "type.googleapis.com/NYql.NPq.NProto.TDqPqTopicSink" value: "\n\032test_filter_with_mr_output\022\017localhost:23806\032\025\n\023cluster:default_yds\"\005local0\0018\002" } } }
2025-12-09T03:42:53.775638Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:395: [ptqudqgd5lgim5dts52n-0] Task: 2. Handle connected node 2
2025-12-09T03:42:53.777212Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1064: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Received channels info: Update { Id: 1 TransportVersion: DATA_TRANSPORT_UV_PICKLE_1_0 SrcTaskId: 1 DstTaskId: 2 SrcEndpoint { ActorId { RawX1: 7581698631372188973 RawX2: 4503608217307264 } } DstEndpoint { ActorId { RawX1: 7581698635969974086 RawX2: 4503603922339946 } } WatermarksMode: WATERMARKS_MODE_DISABLED SrcStageId: 205162 DstStageId: 205182 }
2025-12-09T03:42:53.777227Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1071: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Update input channelId: 1, peer: [2:7581698631372188973:2176]
2025-12-09T03:42:53.853201Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1164: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Got TEvRun from actor [2:7581698631372188970:2173]
2025-12-09T03:42:53.853243Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Poll inputs
2025-12-09T03:42:53.853246Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Poll sources
2025-12-09T03:42:53.853249Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-12-09T03:42:53.853300Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: 55a2cdd3-99315dd9-b49ecced-90092419 2025-12-09 03:42:53.853 DEBUG ydbd(pid=1624813, tid=0x00007F05F9F6F640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Run task: 2
2025-12-09T03:42:53.853411Z :KQP_COMPUTE TRACE: dq_compute_memory_quota.h:97: TxId: ptqudqgd5lgim5dts52n, task: 2. Peak memory usage: 2031616
2025-12-09T03:42:53.853439Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:129: TxId: ptqudqgd5lgim5dts52n, task: 2. Received input for channelId: 1, seqNo: 1, size: 0, chunks: 0, watermark: 0, checkpoint: 1, finished: 0, from: [2:7581698631372188974:2176], expected seqNo: 1
2025-12-09T03:42:53.853442Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:611: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. took input
2025-12-09T03:42:53.853460Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:485: [ptqudqgd5lgim5dts52n-0] Task: 2. [Checkpoint 4.1] Got checkpoint barrier from channel 1
2025-12-09T03:42:53.853466Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. update task runner stats
2025-12-09T03:42:53.853491Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-09T03:42:53.853498Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-09T03:42:53.853504Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-09T03:42:53.853507Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1180: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. AsyncCheckRunStatus: TakeInputChannelDataRequests: 1
2025-12-09T03:42:53.853509Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1107: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Ask CPU quota: 161ms
2025-12-09T03:42:53.853510Z :FQ_ROW_DISPATCHER INFO: coordinator.cpp:507: Coordinator: TEvCoordinatorRequest from [2:7581698631372188976:2176], test_filter_with_mr_input, partIds: 0
2025-12-09T03:42:53.853527Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:356: SelfId: [1:7581698635969974088:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. No watermark 
2025-12-09T03:42:53.853531Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Poll inputs
2025-12-09T03:42:53.853532Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1494: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-12-09T03:42:53.853534Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. DoExecuteImpl: 1
2025-12-09T03:42:53.853540Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:562: Coordinator: Send TEvCoordinatorResult to [2:7581698631372188976:2176]
2025-12-09T03:42:53.853542Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [0:0:0], TxId: ptqudqgd5lgim5dts52n, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-12-09T03:42:53.853561Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:392: Coordinator: EvNodeConnected 2
2025-12-09T03:42:53.853658Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-12-09T03:42:53.853667Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-09T03:42:53.853669Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1180: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. AsyncCheckRunStatus: TakeInputChannelDataRequests: 1
2025-12-09T03:42:53.853674Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:965: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Input data push finished. Cookie: 0 Watermark: (empty maybe) Ack: 1 TakeInputChannelDataRequests: 1
2025-12-09T03:42:53.853679Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:738: TxId: ptqudqgd5lgim5dts52n, task: 2. Sending channel data ack to channelId: 1, peer: [2:7581698631372188973:2176], from: [1:7581698635969974086:2154], freeSpace: 1000000, seqNo: 1, finished: 0
2025-12-09T03:42:53.853695Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Poll inputs
2025-12-09T03:42:53.853696Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1494: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-12-09T03:42:53.853698Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-12-09T03:42:53.854334Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:853: RowDispatcher: Received TEvStartSession from [2:7581698631372188976:2176], read group ptcudqgd5ls29vsn6imi, topicPath test_filter_with_mr_input part id 0 query id ptqudqgd5lgim5dts52n cookie 1
2025-12-09T03:42:53.854370Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:892: RowDispatcher: Create new session: read group ptcudqgd5ls29vsn6imi topic test_filter_with_mr_input part id 0
2025-12-09T03:42:53.854453Z :FQ_ROW_DISPATCHER DEBUG: topic_session.cpp:443: TopicSession [1:7581698635969974091:2155] Bootstrap test_filter_with_mr_input/0, Timeout 5.000000s sec
2025-12-09T03:42:53.854470Z :FQ_ROW_DISPATCHER INFO: topic_session.cpp:799: TopicSession [1:7581698635969974091:2155] New client: read actor id [2:7581698631372188976:2176], predicate: (`event_class` = "event_class2"), watermark expr: , offset: (empty maybe)
2025-12-09T03:42:53.854532Z :FQ_ROW_DISPATCHER DEBUG: format_handler.cpp:440: TTopicFormatHandler [json_each_row]: Add client with id [2:7581698631372188976:2176]
2025-12-09T03:42:53.854612Z :FQ_ROW_DISPATCHER DEBUG: format_handler.cpp:559: TTopicFormatHandler [json_each_row]: UpdateParser to new schema with size 3
2025-12-09T03:42:53.854686Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1052: RowDispatcher: TEvTryConnect to node id 2
2025-12-09T03:42:53.854722Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:587: RowDispatcher: EvNodeConnected, node id 2
2025-12-09T03:42:53.859480Z :YDB_SDK INFO: actor.cpp:37: 2025-12-09T03:42:53.854798Z :INFO: [local] OnFederationDiscovery fall back to single mode, database=local
2025-12-09T03:42:53.859527Z :FQ_ROW_DISPATCHER INFO: json_parser.cpp:355: TJsonParser: Simdjson active implementation icelake (Intel/AMD AVX512), error skip mode: 0
2025-12-09T03:42:53.859629Z :FQ_ROW_DISPATCHER DEBUG: format_handler.cpp:570: TTopicFormatHandler [json_each_row]: Parser was created on schema with 3 columns
2025-12-09T03:42:53.859644Z :YDB_SDK INFO: actor.cpp:37: [] [] Start federated write session to database '' (previous was <empty>) FederationState: { Status: SUCCESS SelfLocation: "" DbInfos: [ { path: "local" endpoint: "localhost:23806" status: AVAILABLE weight: 100 } ] ControlPlaneEndpoint: localhost:23806 }
2025-12-09T03:42:53.859656Z :FQ_ROW_DISPATCHER DEBUG: purecalc_filter.cpp:461: GenerateSql: Generated sql:

            PRAGMA config.flags("LLVM", "OFF");
            SELECT COALESCE((`event_class` = "event_class2"), FALSE) AS _filter, _offset FROM Input;
        
2025-12-09T03:42:53.859693Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:53.859688Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd5lgim5dts52n, TaskId: 2, PQ sink. ]  SessionId []  MessageGroupId [cdc1fda9-9304ae87-7a886b32-908c68f4] Write session: try to update token
2025-12-09T03:42:53.859694Z :FQ_ROW_DISPATCHER TRACE: filters_set.cpp:116: TTopicFilters: Create program with client id [2:7581698631372188976:2176]
2025-12-09T03:42:53.859698Z :FQ_ROW_DISPATCHER TRACE: filters_set.cpp:123: TTopicFilters: Create purecalc program for query '
            PRAGMA config.flags("LLVM", "OFF");
            SELECT COALESCE((`event_class` = "event_class2"), FALSE) AS _filter, _offset FROM Input;
        ' (client id: [2:7581698631372188976:2176])
2025-12-09T03:42:53.859711Z :FQ_ROW_DISPATCHER TRACE: purecalc_filter.cpp:341: TProgramCompileHandler: Send compile request with id 1
2025-12-09T03:42:53.859730Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:952: TopicSession [1:7581698635969974091:2155] SendStatistics
2025-12-09T03:42:53.859776Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1234: RowDispatcher: TEvSessionStatistic from [1:7581698635969974091:2155]
2025-12-09T03:42:53.859792Z :FQ_ROW_DISPATCHER TRACE: compile_service.cpp:131: TPurecalcCompileService: Add to compile queue request with id 1 from [1:7581698635969974092:2155]
2025-12-09T03:42:53.860059Z :YDB_SDK INFO: actor.cpp:37: 2025-12-09T03:42:53.860055Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd5lgim5dts52n, TaskId: 2, PQ sink. ]  SessionId []  MessageGroupId [cdc1fda9-9304ae87-7a886b32-908c68f4] Start write session. Will connect to nodeId: 0
2025-12-09T03:42:53.860330Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1165: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. CPU quota delay: 6ms
2025-12-09T03:42:53.860346Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:53.860333Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd5lgim5dts52n, TaskId: 2, PQ sink. ]  SessionId []  MessageGroupId [cdc1fda9-9304ae87-7a886b32-908c68f4] Write session: write to message_group: cdc1fda9-9304ae87-7a886b32-908c68f4
2025-12-09T03:42:53.860369Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:53.860367Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd5lgim5dts52n, TaskId: 2, PQ sink. ]  SessionId []  MessageGroupId [cdc1fda9-9304ae87-7a886b32-908c68f4] Write session: send init request: init_request { path: "test_filter_with_mr_output" producer_id: "cdc1fda9-9304ae87-7a886b32-908c68f4" message_group_id: "cdc1fda9-9304ae87-7a886b32-908c68f4" }
2025-12-09T03:42:53.860374Z :YDB_SDK TRACE: actor.cpp:37: 2025-12-09T03:42:53.860371Z :TRACE: [local] TRACE_EVENT InitRequest 
2025-12-09T03:42:53.860438Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:462: SelfId: [1:7581698635969974088:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Pending 1 checkpoints to be sent
2025-12-09T03:42:53.860452Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. update task runner stats
2025-12-09T03:42:53.860463Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:53.860460Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd5lgim5dts52n, TaskId: 2, PQ sink. ]  SessionId []  MessageGroupId [cdc1fda9-9304ae87-7a886b32-908c68f4] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-09T03:42:53.860500Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 1 watermark injected: (empty maybe)
2025-12-09T03:42:53.860512Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:447: [ptqudqgd5lgim5dts52n-0] Task: 2. [Checkpoint 4.1] Performing task checkpoint
2025-12-09T03:42:53.860516Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:816: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Save state
2025-12-09T03:42:53.860518Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:474: [ptqudqgd5lgim5dts52n-0] Task: 2. [Checkpoint 4.1] CA state saved
2025-12-09T03:42:53.860521Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:449: [ptqudqgd5lgim5dts52n-0] Task: 2. [Checkpoint 4.1] Injecting checkpoint barrier to outputs
2025-12-09T03:42:53.860524Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-09T03:42:53.860529Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-09T03:42:53.860548Z :KQP_COMPUTE INFO: dq_async_compute_actor.cpp:1010: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Resume inputs
2025-12-09T03:42:53.860552Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [1:7581698635969974090:2154], TxId: ptqudqgd5lgim5dts52n, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 1. Finished: 0
2025-12-09T03:42:53.860557Z :KQP_COMPUTE DEBUG: dq_pq_write_actor.cpp:240: SelfId: [1:7581698635969974090:2154], TxId: ptqudqgd5lgim5dts52n, TaskId: 2, PQ sink. [Checkpoint 4.1] Send checkpoint state immediately
2025-12-09T03:42:53.860758Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:418: SelfId: [1:7581698635969974090:2154], TxId: ptqudqgd5lgim5dts52n, TaskId: 2, PQ sink. Save checkpoint { Id: 1 Generation: 4 Type: CHECKPOINT_TYPE_SNAPSHOT } state: { SourceId: "cdc1fda9-9304ae87-7a886b32-908c68f4" }
2025-12-09T03:42:53.860768Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:524: [ptqudqgd5lgim5dts52n-0] Task: 2. Sink[0] state saved
2025-12-09T03:42:53.860775Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:536: [ptqudqgd5lgim5dts52n-0] Task: 2. [Checkpoint 4.1] Task checkpoint is done. Send to storage
2025-12-09T03:42:53.860783Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 6 bytes of checkpoint barrier
2025-12-09T03:42:53.860787Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-09T03:42:53.860796Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudqgd5lgim5dts52n, task: 2. no poll, channelId: 1, has inflight messages: [1], last with freeSpace: 1000000, current freeSpace: 1000000
2025-12-09T03:42:53.860820Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Poll inputs
2025-12-09T03:42:53.860826Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Poll sources
2025-12-09T03:42:53.860828Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-12-09T03:42:53.860850Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. update task runner stats
2025-12-09T03:42:53.860862Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-09T03:42:53.860865Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-09T03:42:53.860868Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-09T03:42:53.860872Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [1:7581698635969974090:2154], TxId: ptqudqgd5lgim5dts52n, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-12-09T03:42:53.860874Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-12-09T03:42:53.860876Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-09T03:42:53.860879Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudqgd5lgim5dts52n, task: 2. no poll, channelId: 1, has inflight messages: [1], last with freeSpace: 1000000, current freeSpace: 1000000
2025-12-09T03:42:53.860888Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:460: [ptqudqgd5lgim5dts52n-0] [4:1] Got TEvSaveTaskState: task 2
2025-12-09T03:42:53.868035Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:53.868028Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd5lgim5dts52n, TaskId: 2, PQ sink. ]  SessionId []  MessageGroupId [cdc1fda9-9304ae87-7a886b32-908c68f4] Write session: OnReadDone gRpcStatusCode: 0
2025-12-09T03:42:53.868056Z :YDB_SDK INFO: actor.cpp:37: 2025-12-09T03:42:53.868054Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd5lgim5dts52n, TaskId: 2, PQ sink. ]  SessionId []  MessageGroupId [cdc1fda9-9304ae87-7a886b32-908c68f4] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1765251773868 BytesWritten: 0 MessagesWritten: 0 BytesWrittenCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:42:53.868072Z :YDB_SDK INFO: actor.cpp:37: 2025-12-09T03:42:53.868070Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd5lgim5dts52n, TaskId: 2, PQ sink. ]  SessionId []  MessageGroupId [cdc1fda9-9304ae87-7a886b32-908c68f4] Write session established. Init response: session_id: "cdc1fda9-9304ae87-7a886b32-908c68f4|309f4cb3-65222c26-5cff7d6b-2cf90e54_0"
2025-12-09T03:42:53.868080Z :YDB_SDK TRACE: actor.cpp:37: 2025-12-09T03:42:53.868078Z :TRACE: [local] TRACE_EVENT InitResponse  partition_id=0 session_id=cdc1fda9-9304ae87-7a886b32-908c68f4|309f4cb3-65222c26-5cff7d6b-2cf90e54_0
2025-12-09T03:42:53.868084Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:53.868082Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd5lgim5dts52n, TaskId: 2, PQ sink. ]  SessionId [cdc1fda9-9304ae87-7a886b32-908c68f4|309f4cb3-65222c26-5cff7d6b-2cf90e54_0]  MessageGroupId [cdc1fda9-9304ae87-7a886b32-908c68f4] Write session: set DirectWriteToPartitionId 0
2025-12-09T03:42:53.868152Z :YDB_SDK INFO: actor.cpp:37: 2025-12-09T03:42:53.868150Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd5lgim5dts52n, TaskId: 2, PQ sink. ]  SessionId [cdc1fda9-9304ae87-7a886b32-908c68f4|309f4cb3-65222c26-5cff7d6b-2cf90e54_0]  PartitionId [0]  Generation [0] Get partition location async, partition 0, delay 0.000000s
2025-12-09T03:42:53.868167Z :YDB_SDK TRACE: actor.cpp:37: 2025-12-09T03:42:53.868165Z :TRACE: [local] TRACE_EVENT DescribePartitionRequest  path=local/test_filter_with_mr_output partition_id=0
2025-12-09T03:42:53.868209Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:53.868201Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd5lgim5dts52n, TaskId: 2, PQ sink. ]  SessionId [cdc1fda9-9304ae87-7a886b32-908c68f4|309f4cb3-65222c26-5cff7d6b-2cf90e54_0]  PartitionId [0]  Generation [0]  Getting partition location, partition 0
2025-12-09T03:42:53.869175Z :YDB_SDK INFO: actor.cpp:37: 2025-12-09T03:42:53.869168Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd5lgim5dts52n, TaskId: 2, PQ sink. ]  SessionId [cdc1fda9-9304ae87-7a886b32-908c68f4|309f4cb3-65222c26-5cff7d6b-2cf90e54_0]  PartitionId [0]  Generation [0] Got PartitionLocation response. Status SUCCESS, proto:
partition {
  active: true
  partition_location {
    node_id: 1
    generation: 1
  }
}

2025-12-09T03:42:53.869191Z :YDB_SDK TRACE: actor.cpp:37: 2025-12-09T03:42:53.869189Z :TRACE: [local] TRACE_EVENT DescribePartitionResponse  partition_id=0 active=1 pl_node_id=1 pl_generation=1
2025-12-09T03:42:53.869201Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:53.869197Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd5lgim5dts52n, TaskId: 2, PQ sink. ]  SessionId [cdc1fda9-9304ae87-7a886b32-908c68f4|309f4cb3-65222c26-5cff7d6b-2cf90e54_0]  PartitionId [0]  Generation [0] GetPreferredEndpoint: partitionId 0, partitionNodeId 1 exists in the endpoint pool.
2025-12-09T03:42:53.869206Z :YDB_SDK TRACE: actor.cpp:37: 2025-12-09T03:42:53.869204Z :TRACE: [local] TRACE_EVENT PreferredPartitionLocation  Endpoint= NodeId=1 Generation=1
2025-12-09T03:42:53.869210Z :YDB_SDK INFO: actor.cpp:37: 2025-12-09T03:42:53.869208Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd5lgim5dts52n, TaskId: 2, PQ sink. ]  SessionId [cdc1fda9-9304ae87-7a886b32-908c68f4|309f4cb3-65222c26-5cff7d6b-2cf90e54_0]  PartitionId [0]  Generation [1] Start write session. Will connect to nodeId: 1
2025-12-09T03:42:53.869426Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:53.869420Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd5lgim5dts52n, TaskId: 2, PQ sink. ]  SessionId [cdc1fda9-9304ae87-7a886b32-908c68f4|309f4cb3-65222c26-5cff7d6b-2cf90e54_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 1, Msg: CANCELLED, Details: , InternalError: 0
2025-12-09T03:42:53.878706Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:484: [ptqudqgd5lgim5dts52n-0] [4:1] TEvSaveTaskState Apply: task: 2
2025-12-09T03:42:53.878719Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:499: [ptqudqgd5lgim5dts52n-0] [4:1] Send TEvSaveTaskStateResult: task: 2
2025-12-09T03:42:53.878720Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:53.878712Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd5lgim5dts52n, TaskId: 2, PQ sink. ]  SessionId [cdc1fda9-9304ae87-7a886b32-908c68f4|309f4cb3-65222c26-5cff7d6b-2cf90e54_0]  PartitionId [0]  Generation [1] Write session: direct write to partition: 0, generation 1
2025-12-09T03:42:53.878744Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:53.878742Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd5lgim5dts52n, TaskId: 2, PQ sink. ]  SessionId [cdc1fda9-9304ae87-7a886b32-908c68f4|309f4cb3-65222c26-5cff7d6b-2cf90e54_0]  PartitionId [0]  Generation [1] Write session: send init request: init_request { path: "test_filter_with_mr_output" producer_id: "cdc1fda9-9304ae87-7a886b32-908c68f4" partition_with_generation { generation: 1 } }
2025-12-09T03:42:53.878749Z :YDB_SDK TRACE: actor.cpp:37: 2025-12-09T03:42:53.878747Z :TRACE: [local] TRACE_EVENT InitRequest  pwg_partition_id=0 pwg_generation=1
2025-12-09T03:42:53.878853Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:53.878851Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd5lgim5dts52n, TaskId: 2, PQ sink. ]  SessionId [cdc1fda9-9304ae87-7a886b32-908c68f4|309f4cb3-65222c26-5cff7d6b-2cf90e54_0]  PartitionId [0]  Generation [1] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-09T03:42:53.885143Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:53.885135Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd5lgim5dts52n, TaskId: 2, PQ sink. ]  SessionId [cdc1fda9-9304ae87-7a886b32-908c68f4|309f4cb3-65222c26-5cff7d6b-2cf90e54_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-09T03:42:53.885177Z :YDB_SDK INFO: actor.cpp:37: 2025-12-09T03:42:53.885175Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd5lgim5dts52n, TaskId: 2, PQ sink. ]  SessionId [cdc1fda9-9304ae87-7a886b32-908c68f4|309f4cb3-65222c26-5cff7d6b-2cf90e54_0]  PartitionId [0]  Generation [1] Write session established. Init response: session_id: "cdc1fda9-9304ae87-7a886b32-908c68f4|5e84809c-654bb5ce-e73bf612-f8cc02c3_0"
2025-12-09T03:42:53.885185Z :YDB_SDK TRACE: actor.cpp:37: 2025-12-09T03:42:53.885180Z :TRACE: [local] TRACE_EVENT InitResponse  partition_id=0 session_id=cdc1fda9-9304ae87-7a886b32-908c68f4|5e84809c-654bb5ce-e73bf612-f8cc02c3_0
2025-12-09T03:42:53.885188Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:53.885187Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd5lgim5dts52n, TaskId: 2, PQ sink. ]  SessionId [cdc1fda9-9304ae87-7a886b32-908c68f4|5e84809c-654bb5ce-e73bf612-f8cc02c3_0]  PartitionId [0]  Generation [1] Write session: set DirectWriteToPartitionId 0
2025-12-09T03:42:53.930600Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:759: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Commit state
2025-12-09T03:42:54.303196Z :FQ_ROW_DISPATCHER TRACE: compile_service.cpp:52: TPurecalcCompileActor [1:7581698635969974092:2155] [id 1]: Started compile request
2025-12-09T03:42:54.372025Z :FQ_ROW_DISPATCHER TRACE: compile_service.cpp:70: TPurecalcCompileActor [1:7581698635969974092:2155] [id 1]: Compilation completed for request
2025-12-09T03:42:54.372076Z :FQ_ROW_DISPATCHER TRACE: filters_set.cpp:57: TTopicFilters: Got compile response for request with id 1
2025-12-09T03:42:54.372081Z :FQ_ROW_DISPATCHER TRACE: compile_service.cpp:151: TPurecalcCompileService: Compile finished for request with id 1 from [1:7581698635969974092:2155]
2025-12-09T03:42:54.372086Z :FQ_ROW_DISPATCHER TRACE: purecalc_filter.cpp:370: TProgramCompileHandler: Program compilation finished
2025-12-09T03:42:54.372100Z :FQ_ROW_DISPATCHER TRACE: filters_set.cpp:110: TTopicFilters: Start program with client id [2:7581698631372188976:2176]
2025-12-09T03:42:54.418913Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7581698614495137407:2082]
2025-12-09T03:42:54.418944Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-09T03:42:54.418969Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7581698614495137367:2063]
2025-12-09T03:42:54.418988Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7581698614495137367:2063]
2025-12-09T03:42:54.418994Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7581698614495137367:2063]
2025-12-09T03:42:54.419009Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-09T03:42:54.419946Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 55a2cdd3-99315dd9-b49ecced-900924197, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:42:54.424354Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:42:54.424368Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-09T03:42:54.426070Z :FQ_QUOTA_SERVICE DEBUG: quota_manager.cpp:230: IC Peers[2]: [2, 3]
2025-12-09T03:42:54.774883Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:129: TxId: ptqudqgd5lgim5dts52n, task: 2. Received input for channelId: 1, seqNo: 2, size: 0, chunks: 0, watermark: 0, checkpoint: 1, finished: 0, from: [2:7581698631372188974:2176], expected seqNo: 2
2025-12-09T03:42:54.774901Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:611: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. took input
2025-12-09T03:42:54.774919Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:485: [ptqudqgd5lgim5dts52n-0] Task: 2. [Checkpoint 4.2] Got checkpoint barrier from channel 1
2025-12-09T03:42:54.774943Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:356: SelfId: [1:7581698635969974088:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. No watermark 
2025-12-09T03:42:54.774948Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Poll inputs
2025-12-09T03:42:54.774950Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1494: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-12-09T03:42:54.774952Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. DoExecuteImpl: 1
2025-12-09T03:42:54.774963Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:965: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Input data push finished. Cookie: 1 Watermark: (empty maybe) Ack: 1 TakeInputChannelDataRequests: 1
2025-12-09T03:42:54.774968Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:738: TxId: ptqudqgd5lgim5dts52n, task: 2. Sending channel data ack to channelId: 1, peer: [2:7581698631372188973:2176], from: [1:7581698635969974086:2154], freeSpace: 1000000, seqNo: 2, finished: 0
2025-12-09T03:42:54.775045Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:462: SelfId: [1:7581698635969974088:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Pending 1 checkpoints to be sent
2025-12-09T03:42:54.775058Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Poll inputs
2025-12-09T03:42:54.775060Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1494: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-12-09T03:42:54.775062Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-12-09T03:42:54.775065Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. update task runner stats
2025-12-09T03:42:54.775103Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 1 watermark injected: (empty maybe)
2025-12-09T03:42:54.775107Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:447: [ptqudqgd5lgim5dts52n-0] Task: 2. [Checkpoint 4.2] Performing task checkpoint
2025-12-09T03:42:54.775108Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:816: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Save state
2025-12-09T03:42:54.775112Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:474: [ptqudqgd5lgim5dts52n-0] Task: 2. [Checkpoint 4.2] CA state saved
2025-12-09T03:42:54.775114Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:449: [ptqudqgd5lgim5dts52n-0] Task: 2. [Checkpoint 4.2] Injecting checkpoint barrier to outputs
2025-12-09T03:42:54.775115Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-09T03:42:54.775119Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-09T03:42:54.775125Z :KQP_COMPUTE INFO: dq_async_compute_actor.cpp:1010: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Resume inputs
2025-12-09T03:42:54.775128Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [1:7581698635969974090:2154], TxId: ptqudqgd5lgim5dts52n, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 1. Finished: 0
2025-12-09T03:42:54.775132Z :KQP_COMPUTE DEBUG: dq_pq_write_actor.cpp:240: SelfId: [1:7581698635969974090:2154], TxId: ptqudqgd5lgim5dts52n, TaskId: 2, PQ sink. [Checkpoint 4.2] Send checkpoint state immediately
2025-12-09T03:42:54.775163Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:418: SelfId: [1:7581698635969974090:2154], TxId: ptqudqgd5lgim5dts52n, TaskId: 2, PQ sink. Save checkpoint { Id: 2 Generation: 4 Type: CHECKPOINT_TYPE_SNAPSHOT } state: { SourceId: "cdc1fda9-9304ae87-7a886b32-908c68f4" }
2025-12-09T03:42:54.775167Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:524: [ptqudqgd5lgim5dts52n-0] Task: 2. Sink[0] state saved
2025-12-09T03:42:54.775180Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:536: [ptqudqgd5lgim5dts52n-0] Task: 2. [Checkpoint 4.2] Task checkpoint is done. Send to storage
2025-12-09T03:42:54.775188Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 6 bytes of checkpoint barrier
2025-12-09T03:42:54.775189Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-09T03:42:54.775197Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudqgd5lgim5dts52n, task: 2. no poll, channelId: 1, has inflight messages: [2], last with freeSpace: 1000000, current freeSpace: 1000000
2025-12-09T03:42:54.775207Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Poll inputs
2025-12-09T03:42:54.775208Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Poll sources
2025-12-09T03:42:54.775210Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-12-09T03:42:54.775211Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. update task runner stats
2025-12-09T03:42:54.775218Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-09T03:42:54.775220Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-09T03:42:54.775222Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-09T03:42:54.775225Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [1:7581698635969974090:2154], TxId: ptqudqgd5lgim5dts52n, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-12-09T03:42:54.775226Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-12-09T03:42:54.775227Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-09T03:42:54.775230Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudqgd5lgim5dts52n, task: 2. no poll, channelId: 1, has inflight messages: [2], last with freeSpace: 1000000, current freeSpace: 1000000
2025-12-09T03:42:54.775235Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. update task runner stats
2025-12-09T03:42:54.775239Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-09T03:42:54.775240Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-09T03:42:54.775241Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-09T03:42:54.775244Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [1:7581698635969974090:2154], TxId: ptqudqgd5lgim5dts52n, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-12-09T03:42:54.775246Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-12-09T03:42:54.775247Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-09T03:42:54.775250Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudqgd5lgim5dts52n, task: 2. no poll, channelId: 1, has inflight messages: [2], last with freeSpace: 1000000, current freeSpace: 1000000
2025-12-09T03:42:54.775259Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:460: [ptqudqgd5lgim5dts52n-0] [4:2] Got TEvSaveTaskState: task 2
2025-12-09T03:42:54.778797Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:484: [ptqudqgd5lgim5dts52n-0] [4:2] TEvSaveTaskState Apply: task: 2
2025-12-09T03:42:54.778810Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:499: [ptqudqgd5lgim5dts52n-0] [4:2] Send TEvSaveTaskStateResult: task: 2
2025-12-09T03:42:54.801711Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:759: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Commit state
2025-12-09T03:42:54.846625Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [2:7581698614192319536:2063]
2025-12-09T03:42:54.846644Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [2:7581698614192319536:2063]
2025-12-09T03:42:54.846648Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:329: Coordinator: Add new row dispatcher to map (state 0)
2025-12-09T03:42:54.846651Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:334: Coordinator: Schedule TEvRebalancing
2025-12-09T03:42:54.846658Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [2:7581698614192319536:2063]
2025-12-09T03:42:55.227610Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [3:7581698618792110379:2063]
2025-12-09T03:42:55.227634Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [3:7581698618792110379:2063]
2025-12-09T03:42:55.227636Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:329: Coordinator: Add new row dispatcher to map (state 0)
2025-12-09T03:42:55.227640Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [3:7581698618792110379:2063]
2025-12-09T03:42:55.227685Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:392: Coordinator: EvNodeConnected 3
2025-12-09T03:42:55.420373Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 55a2cdd3-99315dd9-b49ecced-900924198, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:42:55.424432Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:42:55.424444Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-09T03:42:55.717516Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:129: TxId: ptqudqgd5lgim5dts52n, task: 2. Received input for channelId: 1, seqNo: 3, size: 0, chunks: 0, watermark: 0, checkpoint: 1, finished: 0, from: [2:7581698631372188974:2176], expected seqNo: 3
2025-12-09T03:42:55.717534Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:611: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. took input
2025-12-09T03:42:55.717552Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:485: [ptqudqgd5lgim5dts52n-0] Task: 2. [Checkpoint 4.3] Got checkpoint barrier from channel 1
2025-12-09T03:42:55.717571Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:356: SelfId: [1:7581698635969974088:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. No watermark 
2025-12-09T03:42:55.717576Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Poll inputs
2025-12-09T03:42:55.717581Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1494: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-12-09T03:42:55.717583Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. DoExecuteImpl: 1
2025-12-09T03:42:55.717594Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:965: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Input data push finished. Cookie: 2 Watermark: (empty maybe) Ack: 1 TakeInputChannelDataRequests: 1
2025-12-09T03:42:55.717600Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:738: TxId: ptqudqgd5lgim5dts52n, task: 2. Sending channel data ack to channelId: 1, peer: [2:7581698631372188973:2176], from: [1:7581698635969974086:2154], freeSpace: 1000000, seqNo: 3, finished: 0
2025-12-09T03:42:55.717679Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:462: SelfId: [1:7581698635969974088:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Pending 1 checkpoints to be sent
2025-12-09T03:42:55.717695Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Poll inputs
2025-12-09T03:42:55.717696Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1494: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-12-09T03:42:55.717698Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-12-09T03:42:55.717700Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. update task runner stats
2025-12-09T03:42:55.717732Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 1 watermark injected: (empty maybe)
2025-12-09T03:42:55.717735Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:447: [ptqudqgd5lgim5dts52n-0] Task: 2. [Checkpoint 4.3] Performing task checkpoint
2025-12-09T03:42:55.717737Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:816: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Save state
2025-12-09T03:42:55.717739Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:474: [ptqudqgd5lgim5dts52n-0] Task: 2. [Checkpoint 4.3] CA state saved
2025-12-09T03:42:55.717741Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:449: [ptqudqgd5lgim5dts52n-0] Task: 2. [Checkpoint 4.3] Injecting checkpoint barrier to outputs
2025-12-09T03:42:55.717743Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-09T03:42:55.717747Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-09T03:42:55.717755Z :KQP_COMPUTE INFO: dq_async_compute_actor.cpp:1010: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Resume inputs
2025-12-09T03:42:55.717759Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [1:7581698635969974090:2154], TxId: ptqudqgd5lgim5dts52n, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 1. Finished: 0
2025-12-09T03:42:55.717763Z :KQP_COMPUTE DEBUG: dq_pq_write_actor.cpp:240: SelfId: [1:7581698635969974090:2154], TxId: ptqudqgd5lgim5dts52n, TaskId: 2, PQ sink. [Checkpoint 4.3] Send checkpoint state immediately
2025-12-09T03:42:55.717802Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:418: SelfId: [1:7581698635969974090:2154], TxId: ptqudqgd5lgim5dts52n, TaskId: 2, PQ sink. Save checkpoint { Id: 3 Generation: 4 Type: CHECKPOINT_TYPE_SNAPSHOT } state: { SourceId: "cdc1fda9-9304ae87-7a886b32-908c68f4" }
2025-12-09T03:42:55.717806Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:524: [ptqudqgd5lgim5dts52n-0] Task: 2. Sink[0] state saved
2025-12-09T03:42:55.717820Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:536: [ptqudqgd5lgim5dts52n-0] Task: 2. [Checkpoint 4.3] Task checkpoint is done. Send to storage
2025-12-09T03:42:55.717830Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 6 bytes of checkpoint barrier
2025-12-09T03:42:55.717833Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-09T03:42:55.717841Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudqgd5lgim5dts52n, task: 2. no poll, channelId: 1, has inflight messages: [3], last with freeSpace: 1000000, current freeSpace: 1000000
2025-12-09T03:42:55.717846Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:460: [ptqudqgd5lgim5dts52n-0] [4:3] Got TEvSaveTaskState: task 2
2025-12-09T03:42:55.717854Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Poll inputs
2025-12-09T03:42:55.717856Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Poll sources
2025-12-09T03:42:55.717872Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-12-09T03:42:55.717874Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. update task runner stats
2025-12-09T03:42:55.717885Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-09T03:42:55.717887Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-09T03:42:55.717890Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-09T03:42:55.717895Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [1:7581698635969974090:2154], TxId: ptqudqgd5lgim5dts52n, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-12-09T03:42:55.717897Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-12-09T03:42:55.717899Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-09T03:42:55.717903Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudqgd5lgim5dts52n, task: 2. no poll, channelId: 1, has inflight messages: [3], last with freeSpace: 1000000, current freeSpace: 1000000
2025-12-09T03:42:55.717911Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. update task runner stats
2025-12-09T03:42:55.717916Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-09T03:42:55.717918Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-09T03:42:55.717920Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-09T03:42:55.717923Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [1:7581698635969974090:2154], TxId: ptqudqgd5lgim5dts52n, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-12-09T03:42:55.717925Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-12-09T03:42:55.717926Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-09T03:42:55.717928Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudqgd5lgim5dts52n, task: 2. no poll, channelId: 1, has inflight messages: [3], last with freeSpace: 1000000, current freeSpace: 1000000
2025-12-09T03:42:55.728171Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:484: [ptqudqgd5lgim5dts52n-0] [4:3] TEvSaveTaskState Apply: task: 2
2025-12-09T03:42:55.728208Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:499: [ptqudqgd5lgim5dts52n-0] [4:3] Send TEvSaveTaskStateResult: task: 2
2025-12-09T03:42:55.752999Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:759: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Commit state
2025-12-09T03:42:55.854800Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:952: TopicSession [1:7581698635969974091:2155] SendStatistics
2025-12-09T03:42:55.854843Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1234: RowDispatcher: TEvSessionStatistic from [1:7581698635969974091:2155]
2025-12-09T03:42:55.855331Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:962: RowDispatcher: Received TEvHeartbeat from [2:7581698631372188976:2176], part id 0 query id ptqudqgd5lgim5dts52n
2025-12-09T03:42:56.419797Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7581698614495137407:2082]
2025-12-09T03:42:56.419818Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-09T03:42:56.419851Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7581698614495137367:2063]
2025-12-09T03:42:56.419856Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7581698614495137367:2063]
2025-12-09T03:42:56.419859Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7581698614495137367:2063]
2025-12-09T03:42:56.419876Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-09T03:42:56.420823Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 55a2cdd3-99315dd9-b49ecced-900924199, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:42:56.425448Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:42:56.425476Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-09T03:42:56.710927Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:129: TxId: ptqudqgd5lgim5dts52n, task: 2. Received input for channelId: 1, seqNo: 4, size: 0, chunks: 0, watermark: 0, checkpoint: 1, finished: 0, from: [2:7581698631372188974:2176], expected seqNo: 4
2025-12-09T03:42:56.710939Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:611: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. took input
2025-12-09T03:42:56.710951Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:485: [ptqudqgd5lgim5dts52n-0] Task: 2. [Checkpoint 4.4] Got checkpoint barrier from channel 1
2025-12-09T03:42:56.710965Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:356: SelfId: [1:7581698635969974088:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. No watermark 
2025-12-09T03:42:56.710969Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Poll inputs
2025-12-09T03:42:56.710971Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1494: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-12-09T03:42:56.710983Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. DoExecuteImpl: 1
2025-12-09T03:42:56.710991Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:965: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Input data push finished. Cookie: 3 Watermark: (empty maybe) Ack: 1 TakeInputChannelDataRequests: 1
2025-12-09T03:42:56.710995Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:738: TxId: ptqudqgd5lgim5dts52n, task: 2. Sending channel data ack to channelId: 1, peer: [2:7581698631372188973:2176], from: [1:7581698635969974086:2154], freeSpace: 1000000, seqNo: 4, finished: 0
2025-12-09T03:42:56.711048Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:462: SelfId: [1:7581698635969974088:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Pending 1 checkpoints to be sent
2025-12-09T03:42:56.711056Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Poll inputs
2025-12-09T03:42:56.711057Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1494: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-12-09T03:42:56.711058Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-12-09T03:42:56.711059Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. update task runner stats
2025-12-09T03:42:56.711086Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 1 watermark injected: (empty maybe)
2025-12-09T03:42:56.711089Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:447: [ptqudqgd5lgim5dts52n-0] Task: 2. [Checkpoint 4.4] Performing task checkpoint
2025-12-09T03:42:56.711091Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:816: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Save state
2025-12-09T03:42:56.711093Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:474: [ptqudqgd5lgim5dts52n-0] Task: 2. [Checkpoint 4.4] CA state saved
2025-12-09T03:42:56.711095Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:449: [ptqudqgd5lgim5dts52n-0] Task: 2. [Checkpoint 4.4] Injecting checkpoint barrier to outputs
2025-12-09T03:42:56.711097Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-09T03:42:56.711100Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-09T03:42:56.711106Z :KQP_COMPUTE INFO: dq_async_compute_actor.cpp:1010: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Resume inputs
2025-12-09T03:42:56.711108Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [1:7581698635969974090:2154], TxId: ptqudqgd5lgim5dts52n, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 1. Finished: 0
2025-12-09T03:42:56.711110Z :KQP_COMPUTE DEBUG: dq_pq_write_actor.cpp:240: SelfId: [1:7581698635969974090:2154], TxId: ptqudqgd5lgim5dts52n, TaskId: 2, PQ sink. [Checkpoint 4.4] Send checkpoint state immediately
2025-12-09T03:42:56.711146Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:418: SelfId: [1:7581698635969974090:2154], TxId: ptqudqgd5lgim5dts52n, TaskId: 2, PQ sink. Save checkpoint { Id: 4 Generation: 4 Type: CHECKPOINT_TYPE_SNAPSHOT } state: { SourceId: "cdc1fda9-9304ae87-7a886b32-908c68f4" }
2025-12-09T03:42:56.711150Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:524: [ptqudqgd5lgim5dts52n-0] Task: 2. Sink[0] state saved
2025-12-09T03:42:56.711161Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:536: [ptqudqgd5lgim5dts52n-0] Task: 2. [Checkpoint 4.4] Task checkpoint is done. Send to storage
2025-12-09T03:42:56.711168Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 6 bytes of checkpoint barrier
2025-12-09T03:42:56.711170Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-09T03:42:56.711175Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudqgd5lgim5dts52n, task: 2. no poll, channelId: 1, has inflight messages: [4], last with freeSpace: 1000000, current freeSpace: 1000000
2025-12-09T03:42:56.711187Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Poll inputs
2025-12-09T03:42:56.711189Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Poll sources
2025-12-09T03:42:56.711191Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-12-09T03:42:56.711193Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. update task runner stats
2025-12-09T03:42:56.711200Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:460: [ptqudqgd5lgim5dts52n-0] [4:4] Got TEvSaveTaskState: task 2
2025-12-09T03:42:56.711214Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-09T03:42:56.711216Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-09T03:42:56.711219Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-09T03:42:56.711223Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [1:7581698635969974090:2154], TxId: ptqudqgd5lgim5dts52n, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-12-09T03:42:56.711225Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-12-09T03:42:56.711227Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-09T03:42:56.711230Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudqgd5lgim5dts52n, task: 2. no poll, channelId: 1, has inflight messages: [4], last with freeSpace: 1000000, current freeSpace: 1000000
2025-12-09T03:42:56.711235Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. update task runner stats
2025-12-09T03:42:56.711240Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-09T03:42:56.711241Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-09T03:42:56.711243Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-09T03:42:56.711245Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [1:7581698635969974090:2154], TxId: ptqudqgd5lgim5dts52n, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-12-09T03:42:56.711247Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-12-09T03:42:56.711248Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-09T03:42:56.711250Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudqgd5lgim5dts52n, task: 2. no poll, channelId: 1, has inflight messages: [4], last with freeSpace: 1000000, current freeSpace: 1000000
2025-12-09T03:42:56.714088Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:484: [ptqudqgd5lgim5dts52n-0] [4:4] TEvSaveTaskState Apply: task: 2
2025-12-09T03:42:56.714107Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:499: [ptqudqgd5lgim5dts52n-0] [4:4] Send TEvSaveTaskStateResult: task: 2
2025-12-09T03:42:56.737032Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:759: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Commit state
2025-12-09T03:42:56.847493Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [2:7581698614192319536:2063]
2025-12-09T03:42:56.847508Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [2:7581698614192319536:2063]
2025-12-09T03:42:56.847511Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [2:7581698614192319536:2063]
2025-12-09T03:42:57.228468Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [3:7581698618792110379:2063]
2025-12-09T03:42:57.228481Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [3:7581698618792110379:2063]
2025-12-09T03:42:57.228483Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [3:7581698618792110379:2063]
2025-12-09T03:42:57.421282Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 55a2cdd3-99315dd9-b49ecced-9009241910, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:42:57.424930Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:42:57.424947Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-09T03:42:57.711133Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:129: TxId: ptqudqgd5lgim5dts52n, task: 2. Received input for channelId: 1, seqNo: 5, size: 0, chunks: 0, watermark: 0, checkpoint: 1, finished: 0, from: [2:7581698631372188974:2176], expected seqNo: 5
2025-12-09T03:42:57.711159Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:611: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. took input
2025-12-09T03:42:57.711171Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:485: [ptqudqgd5lgim5dts52n-0] Task: 2. [Checkpoint 4.5] Got checkpoint barrier from channel 1
2025-12-09T03:42:57.711188Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:356: SelfId: [1:7581698635969974088:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. No watermark 
2025-12-09T03:42:57.711192Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Poll inputs
2025-12-09T03:42:57.711195Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1494: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-12-09T03:42:57.711196Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. DoExecuteImpl: 1
2025-12-09T03:42:57.711204Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:965: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Input data push finished. Cookie: 4 Watermark: (empty maybe) Ack: 1 TakeInputChannelDataRequests: 1
2025-12-09T03:42:57.711209Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:738: TxId: ptqudqgd5lgim5dts52n, task: 2. Sending channel data ack to channelId: 1, peer: [2:7581698631372188973:2176], from: [1:7581698635969974086:2154], freeSpace: 1000000, seqNo: 5, finished: 0
2025-12-09T03:42:57.711279Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:462: SelfId: [1:7581698635969974088:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Pending 1 checkpoints to be sent
2025-12-09T03:42:57.711287Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Poll inputs
2025-12-09T03:42:57.711288Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1494: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-12-09T03:42:57.711288Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-12-09T03:42:57.711290Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. update task runner stats
2025-12-09T03:42:57.711315Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 1 watermark injected: (empty maybe)
2025-12-09T03:42:57.711317Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:447: [ptqudqgd5lgim5dts52n-0] Task: 2. [Checkpoint 4.5] Performing task checkpoint
2025-12-09T03:42:57.711318Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:816: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Save state
2025-12-09T03:42:57.711320Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:474: [ptqudqgd5lgim5dts52n-0] Task: 2. [Checkpoint 4.5] CA state saved
2025-12-09T03:42:57.711322Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:449: [ptqudqgd5lgim5dts52n-0] Task: 2. [Checkpoint 4.5] Injecting checkpoint barrier to outputs
2025-12-09T03:42:57.711324Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-09T03:42:57.711329Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-09T03:42:57.711336Z :KQP_COMPUTE INFO: dq_async_compute_actor.cpp:1010: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Resume inputs
2025-12-09T03:42:57.711339Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [1:7581698635969974090:2154], TxId: ptqudqgd5lgim5dts52n, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 1. Finished: 0
2025-12-09T03:42:57.711341Z :KQP_COMPUTE DEBUG: dq_pq_write_actor.cpp:240: SelfId: [1:7581698635969974090:2154], TxId: ptqudqgd5lgim5dts52n, TaskId: 2, PQ sink. [Checkpoint 4.5] Send checkpoint state immediately
2025-12-09T03:42:57.711369Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:418: SelfId: [1:7581698635969974090:2154], TxId: ptqudqgd5lgim5dts52n, TaskId: 2, PQ sink. Save checkpoint { Id: 5 Generation: 4 Type: CHECKPOINT_TYPE_SNAPSHOT } state: { SourceId: "cdc1fda9-9304ae87-7a886b32-908c68f4" }
2025-12-09T03:42:57.711378Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:524: [ptqudqgd5lgim5dts52n-0] Task: 2. Sink[0] state saved
2025-12-09T03:42:57.711388Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:536: [ptqudqgd5lgim5dts52n-0] Task: 2. [Checkpoint 4.5] Task checkpoint is done. Send to storage
2025-12-09T03:42:57.711395Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 6 bytes of checkpoint barrier
2025-12-09T03:42:57.711402Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-09T03:42:57.711408Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudqgd5lgim5dts52n, task: 2. no poll, channelId: 1, has inflight messages: [5], last with freeSpace: 1000000, current freeSpace: 1000000
2025-12-09T03:42:57.711411Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:460: [ptqudqgd5lgim5dts52n-0] [4:5] Got TEvSaveTaskState: task 2
2025-12-09T03:42:57.711439Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Poll inputs
2025-12-09T03:42:57.711440Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Poll sources
2025-12-09T03:42:57.711442Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-12-09T03:42:57.711443Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. update task runner stats
2025-12-09T03:42:57.711451Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-09T03:42:57.711452Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-09T03:42:57.711454Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-09T03:42:57.711459Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [1:7581698635969974090:2154], TxId: ptqudqgd5lgim5dts52n, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-12-09T03:42:57.711461Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-12-09T03:42:57.711462Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-09T03:42:57.711465Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudqgd5lgim5dts52n, task: 2. no poll, channelId: 1, has inflight messages: [5], last with freeSpace: 1000000, current freeSpace: 1000000
2025-12-09T03:42:57.711470Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. update task runner stats
2025-12-09T03:42:57.711475Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-09T03:42:57.711476Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-09T03:42:57.711478Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-09T03:42:57.711480Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [1:7581698635969974090:2154], TxId: ptqudqgd5lgim5dts52n, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-12-09T03:42:57.711482Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-12-09T03:42:57.711492Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-09T03:42:57.711495Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudqgd5lgim5dts52n, task: 2. no poll, channelId: 1, has inflight messages: [5], last with freeSpace: 1000000, current freeSpace: 1000000
2025-12-09T03:42:57.714554Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:484: [ptqudqgd5lgim5dts52n-0] [4:5] TEvSaveTaskState Apply: task: 2
2025-12-09T03:42:57.714572Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:499: [ptqudqgd5lgim5dts52n-0] [4:5] Send TEvSaveTaskStateResult: task: 2
2025-12-09T03:42:57.735457Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:759: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Commit state
2025-12-09T03:42:57.855408Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:952: TopicSession [1:7581698635969974091:2155] SendStatistics
2025-12-09T03:42:57.855443Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1234: RowDispatcher: TEvSessionStatistic from [1:7581698635969974091:2155]
2025-12-09T03:42:57.856100Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:962: RowDispatcher: Received TEvHeartbeat from [2:7581698631372188976:2176], part id 0 query id ptqudqgd5lgim5dts52n
2025-12-09T03:42:58.417634Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:599: Coordinator: Send TEvGetNodesRequest to NodesManager
2025-12-09T03:42:58.417639Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-12-09T03:42:58.417888Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:300: Received TNodesManagerActor::TEvGetNodesRequest
2025-12-09T03:42:58.417905Z :FQ_ROW_DISPATCHER INFO: coordinator.cpp:690: Coordinator: Updated node info, node count: 3
2025-12-09T03:42:58.420684Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7581698614495137407:2082]
2025-12-09T03:42:58.420702Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-09T03:42:58.420710Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7581698614495137367:2063]
2025-12-09T03:42:58.420722Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7581698614495137367:2063]
2025-12-09T03:42:58.420725Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7581698614495137367:2063]
2025-12-09T03:42:58.420733Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-09T03:42:58.421702Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 55a2cdd3-99315dd9-b49ecced-9009241911, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:42:58.424904Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:42:58.424918Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-09T03:42:58.426495Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:389: Send NodeInfo with size: 2 to DynamicNameserver
2025-12-09T03:42:58.713770Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:129: TxId: ptqudqgd5lgim5dts52n, task: 2. Received input for channelId: 1, seqNo: 6, size: 0, chunks: 0, watermark: 0, checkpoint: 1, finished: 0, from: [2:7581698631372188974:2176], expected seqNo: 6
2025-12-09T03:42:58.713786Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:611: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. took input
2025-12-09T03:42:58.713800Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:485: [ptqudqgd5lgim5dts52n-0] Task: 2. [Checkpoint 4.6] Got checkpoint barrier from channel 1
2025-12-09T03:42:58.713827Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:356: SelfId: [1:7581698635969974088:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. No watermark 
2025-12-09T03:42:58.713832Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Poll inputs
2025-12-09T03:42:58.713835Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1494: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-12-09T03:42:58.713837Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. DoExecuteImpl: 1
2025-12-09T03:42:58.713845Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:965: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Input data push finished. Cookie: 5 Watermark: (empty maybe) Ack: 1 TakeInputChannelDataRequests: 1
2025-12-09T03:42:58.713850Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:738: TxId: ptqudqgd5lgim5dts52n, task: 2. Sending channel data ack to channelId: 1, peer: [2:7581698631372188973:2176], from: [1:7581698635969974086:2154], freeSpace: 1000000, seqNo: 6, finished: 0
2025-12-09T03:42:58.713906Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:462: SelfId: [1:7581698635969974088:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Pending 1 checkpoints to be sent
2025-12-09T03:42:58.713917Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Poll inputs
2025-12-09T03:42:58.713918Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1494: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-12-09T03:42:58.713919Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-12-09T03:42:58.713921Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. update task runner stats
2025-12-09T03:42:58.713946Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 1 watermark injected: (empty maybe)
2025-12-09T03:42:58.713948Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:447: [ptqudqgd5lgim5dts52n-0] Task: 2. [Checkpoint 4.6] Performing task checkpoint
2025-12-09T03:42:58.713950Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:816: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Save state
2025-12-09T03:42:58.713952Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:474: [ptqudqgd5lgim5dts52n-0] Task: 2. [Checkpoint 4.6] CA state saved
2025-12-09T03:42:58.713954Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:449: [ptqudqgd5lgim5dts52n-0] Task: 2. [Checkpoint 4.6] Injecting checkpoint barrier to outputs
2025-12-09T03:42:58.713959Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-09T03:42:58.713963Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-09T03:42:58.713970Z :KQP_COMPUTE INFO: dq_async_compute_actor.cpp:1010: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Resume inputs
2025-12-09T03:42:58.713973Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [1:7581698635969974090:2154], TxId: ptqudqgd5lgim5dts52n, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 1. Finished: 0
2025-12-09T03:42:58.713976Z :KQP_COMPUTE DEBUG: dq_pq_write_actor.cpp:240: SelfId: [1:7581698635969974090:2154], TxId: ptqudqgd5lgim5dts52n, TaskId: 2, PQ sink. [Checkpoint 4.6] Send checkpoint state immediately
2025-12-09T03:42:58.714018Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:418: SelfId: [1:7581698635969974090:2154], TxId: ptqudqgd5lgim5dts52n, TaskId: 2, PQ sink. Save checkpoint { Id: 6 Generation: 4 Type: CHECKPOINT_TYPE_SNAPSHOT } state: { SourceId: "cdc1fda9-9304ae87-7a886b32-908c68f4" }
2025-12-09T03:42:58.714022Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:524: [ptqudqgd5lgim5dts52n-0] Task: 2. Sink[0] state saved
2025-12-09T03:42:58.714033Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:536: [ptqudqgd5lgim5dts52n-0] Task: 2. [Checkpoint 4.6] Task checkpoint is done. Send to storage
2025-12-09T03:42:58.714039Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 6 bytes of checkpoint barrier
2025-12-09T03:42:58.714041Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-09T03:42:58.714047Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudqgd5lgim5dts52n, task: 2. no poll, channelId: 1, has inflight messages: [6], last with freeSpace: 1000000, current freeSpace: 1000000
2025-12-09T03:42:58.714053Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:460: [ptqudqgd5lgim5dts52n-0] [4:6] Got TEvSaveTaskState: task 2
2025-12-09T03:42:58.714057Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Poll inputs
2025-12-09T03:42:58.714058Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Poll sources
2025-12-09T03:42:58.714060Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-12-09T03:42:58.714062Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. update task runner stats
2025-12-09T03:42:58.714069Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-09T03:42:58.714071Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-09T03:42:58.714074Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-09T03:42:58.714078Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [1:7581698635969974090:2154], TxId: ptqudqgd5lgim5dts52n, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-12-09T03:42:58.714079Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-12-09T03:42:58.714080Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-09T03:42:58.714083Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudqgd5lgim5dts52n, task: 2. no poll, channelId: 1, has inflight messages: [6], last with freeSpace: 1000000, current freeSpace: 1000000
2025-12-09T03:42:58.714088Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. update task runner stats
2025-12-09T03:42:58.714092Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-09T03:42:58.714093Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-09T03:42:58.714095Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-09T03:42:58.714098Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [1:7581698635969974090:2154], TxId: ptqudqgd5lgim5dts52n, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-12-09T03:42:58.714099Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-12-09T03:42:58.714100Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-09T03:42:58.714103Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudqgd5lgim5dts52n, task: 2. no poll, channelId: 1, has inflight messages: [6], last with freeSpace: 1000000, current freeSpace: 1000000
2025-12-09T03:42:58.716984Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:484: [ptqudqgd5lgim5dts52n-0] [4:6] TEvSaveTaskState Apply: task: 2
2025-12-09T03:42:58.716996Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:499: [ptqudqgd5lgim5dts52n-0] [4:6] Send TEvSaveTaskStateResult: task: 2
2025-12-09T03:42:58.740976Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:759: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Commit state
2025-12-09T03:42:58.837124Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:453: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Got TEvStateRequest from actor [2:7581698631372188971:2174] PingCookie: 2
2025-12-09T03:42:58.837147Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. update task runner stats
2025-12-09T03:42:58.848349Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [2:7581698614192319536:2063]
2025-12-09T03:42:58.848363Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [2:7581698614192319536:2063]
2025-12-09T03:42:58.848366Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [2:7581698614192319536:2063]
2025-12-09T03:42:59.229481Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [3:7581698618792110379:2063]
2025-12-09T03:42:59.229499Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [3:7581698618792110379:2063]
2025-12-09T03:42:59.229501Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [3:7581698618792110379:2063]
2025-12-09T03:42:59.372024Z :FQ_ROW_DISPATCHER INFO: topic_session.cpp:516: TopicSession [1:7581698635969974091:2155] Create topic session, Path test_filter_with_mr_input/0, StartingMessageTimestamp 2025-12-09T03:42:52.920000Z, BufferSize 16000000, GetConsumerMode Without
2025-12-09T03:42:59.372084Z :YDB_SDK INFO: actor.cpp:37: 2025-12-09T03:42:59.372078Z :INFO: [local] [local] [42709e9a-50ced28-3b618f70-ec70ce97] Starting read session
2025-12-09T03:42:59.372091Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:59.372088Z :DEBUG: [local] [local] [42709e9a-50ced28-3b618f70-ec70ce97] Starting single session
2025-12-09T03:42:59.372153Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:59.372150Z :DEBUG: [local] [local] [42709e9a-50ced28-3b618f70-ec70ce97] [] In Reconnect, ReadSizeBudget = 8000000, ReadSizeServerDelta = 0
2025-12-09T03:42:59.372158Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:59.372156Z :DEBUG: [local] [local] [42709e9a-50ced28-3b618f70-ec70ce97] [] New values: ReadSizeBudget = 8000000, ReadSizeServerDelta = 0
2025-12-09T03:42:59.372164Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:59.372162Z :DEBUG: [local] [local] [42709e9a-50ced28-3b618f70-ec70ce97] [] Reconnecting session to cluster  in 0.000000s
2025-12-09T03:42:59.372394Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:466: TopicSession [1:7581698635969974091:2155] SubscribeOnNextEvent
2025-12-09T03:42:59.372726Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:59.372721Z :DEBUG: [local] [local] [42709e9a-50ced28-3b618f70-ec70ce97] [] Successfully connected. Initializing session
2025-12-09T03:42:59.373814Z :YDB_SDK INFO: actor.cpp:37: 2025-12-09T03:42:59.373804Z :INFO: [local] [local] [42709e9a-50ced28-3b618f70-ec70ce97] [] Got InitResponse. ReadSessionId: _1_4_12989285679950995066_v1
2025-12-09T03:42:59.373835Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:59.373832Z :DEBUG: [local] [local] [42709e9a-50ced28-3b618f70-ec70ce97] [] In ContinueReadingDataImpl, ReadSizeBudget = 8000000, ReadSizeServerDelta = 0
2025-12-09T03:42:59.373914Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:59.373910Z :DEBUG: [local] [local] [42709e9a-50ced28-3b618f70-ec70ce97] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 8000000
2025-12-09T03:42:59.375467Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:559: TopicSession [1:7581698635969974091:2155] TEvPqEventsReady
2025-12-09T03:42:59.375492Z :FQ_ROW_DISPATCHER DEBUG: topic_session.cpp:677: TopicSession [1:7581698635969974091:2155] StartPartitionSessionEvent received
2025-12-09T03:42:59.375495Z :FQ_ROW_DISPATCHER DEBUG: topic_session.cpp:685: TopicSession [1:7581698635969974091:2155] Confirm StartPartitionSession with offset (NULL)
2025-12-09T03:42:59.375511Z :YDB_SDK INFO: actor.cpp:37: 2025-12-09T03:42:59.375506Z :INFO: [local] [local] [42709e9a-50ced28-3b618f70-ec70ce97] [] Confirm partition stream create. Partition stream id: 1. Cluster: "-". Topic: "test_filter_with_mr_input". Partition: 0. Read offset: (NULL)
2025-12-09T03:42:59.375618Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:466: TopicSession [1:7581698635969974091:2155] SubscribeOnNextEvent
2025-12-09T03:42:59.380377Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:59.380367Z :DEBUG: [local] [local] [42709e9a-50ced28-3b618f70-ec70ce97] [] Got ReadResponse, serverBytesSize = 379, now ReadSizeBudget = 0, ReadSizeServerDelta = 7999621
2025-12-09T03:42:59.380417Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:59.380413Z :DEBUG: [local] [local] [42709e9a-50ced28-3b618f70-ec70ce97] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 7999621
2025-12-09T03:42:59.380472Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:59.380468Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (0-3)
2025-12-09T03:42:59.380486Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:59.380483Z :DEBUG: [local] [local] [42709e9a-50ced28-3b618f70-ec70ce97] [] Returning serverBytesSize = 379 to budget
2025-12-09T03:42:59.380491Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:59.380488Z :DEBUG: [local] [local] [42709e9a-50ced28-3b618f70-ec70ce97] [] In ContinueReadingDataImpl, ReadSizeBudget = 379, ReadSizeServerDelta = 7999621
2025-12-09T03:42:59.380537Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:59.380534Z :DEBUG: [local] [local] [42709e9a-50ced28-3b618f70-ec70ce97] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 8000000
2025-12-09T03:42:59.380579Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:559: TopicSession [1:7581698635969974091:2155] TEvPqEventsReady
2025-12-09T03:42:59.380609Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:59.380604Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-12-09T03:42:59.380619Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:59.380617Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (1-1)
2025-12-09T03:42:59.380627Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:59.380625Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 1} (2-2)
2025-12-09T03:42:59.380635Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:59.380631Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 2} (3-3)
2025-12-09T03:42:59.380649Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:59.380646Z :DEBUG: [local] [local] [42709e9a-50ced28-3b618f70-ec70ce97] [] The application data is transferred to the client. Number of messages 4, size 244 bytes
2025-12-09T03:42:59.380660Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:59.380658Z :DEBUG: [local] [local] [42709e9a-50ced28-3b618f70-ec70ce97] [] Returning serverBytesSize = 0 to budget
2025-12-09T03:42:59.380696Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:654: TopicSession [1:7581698635969974091:2155] Data received: Message { Data: "{"time": 100, "event_class": "event_class1", "event_type": 1}" Information: { Offset: 0 ProducerId: "" SeqNo: 0 CreateTime: 2025-12-09T03:42:55.514000Z WriteTime: 2025-12-09T03:42:55.514000Z MessageGroupId: "" Meta: { } MessageMeta: { } } Partition session id: 1 Topic: "test_filter_with_mr_input" Partition: 0 }
2025-12-09T03:42:59.380700Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:654: TopicSession [1:7581698635969974091:2155] Data received: Message { Data: "{"time": 105, "event_class": "event_class2", "event_type": 2}" Information: { Offset: 1 ProducerId: "" SeqNo: 0 CreateTime: 2025-12-09T03:42:55.514000Z WriteTime: 2025-12-09T03:42:55.518000Z MessageGroupId: "" Meta: { } MessageMeta: { } } Partition session id: 1 Topic: "test_filter_with_mr_input" Partition: 0 }
2025-12-09T03:42:59.380704Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:654: TopicSession [1:7581698635969974091:2155] Data received: Message { Data: "{"time": 110, "event_class": "event_class2", "event_type": 3}" Information: { Offset: 2 ProducerId: "" SeqNo: 0 CreateTime: 2025-12-09T03:42:55.514000Z WriteTime: 2025-12-09T03:42:55.518000Z MessageGroupId: "" Meta: { } MessageMeta: { } } Partition session id: 1 Topic: "test_filter_with_mr_input" Partition: 0 }
2025-12-09T03:42:59.380708Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:654: TopicSession [1:7581698635969974091:2155] Data received: Message { Data: "{"time": 116, "event_class": "event_class2", "event_type": 4}" Information: { Offset: 3 ProducerId: "" SeqNo: 0 CreateTime: 2025-12-09T03:42:55.514000Z WriteTime: 2025-12-09T03:42:55.518000Z MessageGroupId: "" Meta: { } MessageMeta: { } } Partition session id: 1 Topic: "test_filter_with_mr_input" Partition: 0 }
2025-12-09T03:42:59.380711Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:707: TopicSession [1:7581698635969974091:2155] SendToParsing, messages: 4
2025-12-09T03:42:59.380717Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:417: TTopicFormatHandler [json_each_row]: Send 4 messages to parser
2025-12-09T03:42:59.380723Z :FQ_ROW_DISPATCHER TRACE: json_parser.cpp:388: TJsonParser: Add 4 messages to parse
2025-12-09T03:42:59.380732Z :FQ_ROW_DISPATCHER TRACE: json_parser.cpp:454: TJsonParser: Do parsing, first offset: 0, values:
{"time": 100, "event_class": "event_class1", "event_type": 1}{"time": 105, "event_class": "event_class2", "event_type": 2}{"time": 110, "event_class": "event_class2", "event_type": 3}{"time": 116, "event_class": "event_class2", "event_type": 4}                                                                
2025-12-09T03:42:59.380735Z :FQ_ROW_DISPATCHER TRACE: json_parser.cpp:590: TJsonParser: Init parser, skipped 0, outputRowId 0 size 308
2025-12-09T03:42:59.380762Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:77: TTopicFormatHandler [json_each_row]: TParserHandler: Got parsed data, number rows: 4
2025-12-09T03:42:59.380765Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:614: TTopicFormatHandler [json_each_row]: Send 4 messages to programs, first offset: 0, last offset: 3
2025-12-09T03:42:59.380769Z :FQ_ROW_DISPATCHER TRACE: filters_set.cpp:34: TTopicFilters: ProcessData for 1 clients, number rows: 4
2025-12-09T03:42:59.380776Z :FQ_ROW_DISPATCHER TRACE: filters_set.cpp:223: TTopicFilters: Pass 4 rows to purecalc filter (client id: [2:7581698631372188976:2176])
2025-12-09T03:42:59.380779Z :FQ_ROW_DISPATCHER TRACE: purecalc_filter.cpp:408: TProgramRunHandler: ProcessData for 4 rows
2025-12-09T03:42:59.380827Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:292: TTopicFormatHandler [json_each_row]: TClientHandler [2:7581698631372188976:2176]: OnBatchFinish, offset: 1, number rows: 1, row size: 40, watermark: (empty maybe)
2025-12-09T03:42:59.380838Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:198: TopicSession [1:7581698635969974091:2155] AddDataToClient to [2:7581698631372188976:2176], offset: 1, number rows: 1, row size: 40, watermark: (empty maybe)
2025-12-09T03:42:59.380840Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:936: TopicSession [1:7581698635969974091:2155] Send TEvNewDataArrived to [2:7581698631372188976:2176]
2025-12-09T03:42:59.380856Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:292: TTopicFormatHandler [json_each_row]: TClientHandler [2:7581698631372188976:2176]: OnBatchFinish, offset: 2, number rows: 1, row size: 32, watermark: (empty maybe)
2025-12-09T03:42:59.380860Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:198: TopicSession [1:7581698635969974091:2155] AddDataToClient to [2:7581698631372188976:2176], offset: 2, number rows: 1, row size: 32, watermark: (empty maybe)
2025-12-09T03:42:59.380864Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:292: TTopicFormatHandler [json_each_row]: TClientHandler [2:7581698631372188976:2176]: OnBatchFinish, offset: 3, number rows: 1, row size: 32, watermark: (empty maybe)
2025-12-09T03:42:59.380866Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:198: TopicSession [1:7581698635969974091:2155] AddDataToClient to [2:7581698631372188976:2176], offset: 3, number rows: 1, row size: 32, watermark: (empty maybe)
2025-12-09T03:42:59.380874Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:622: TTopicFormatHandler [json_each_row]: Commit client [2:7581698631372188976:2176] offset 3
2025-12-09T03:42:59.380877Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:210: TopicSession [1:7581698635969974091:2155] UpdateClientOffset for [2:7581698631372188976:2176], new offset: 3
2025-12-09T03:42:59.380884Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:466: TopicSession [1:7581698635969974091:2155] SubscribeOnNextEvent
2025-12-09T03:42:59.380899Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1081: RowDispatcher: Forward TEvNewDataArrived from [1:7581698635969974091:2155] to [2:7581698631372188976:2176] query id ptqudqgd5lgim5dts52n
2025-12-09T03:42:59.381821Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:940: RowDispatcher: Received TEvGetNextBatch from [2:7581698631372188976:2176] part id 0 query id ptqudqgd5lgim5dts52n
2025-12-09T03:42:59.381846Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:588: TopicSession [1:7581698635969974091:2155] TEvGetNextBatch from [2:7581698631372188976:2176]
2025-12-09T03:42:59.381854Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:324: TTopicFormatHandler [json_each_row]: TClientHandler [2:7581698631372188976:2176]: FinishPacking, batch size: 104, number rows: 3
2025-12-09T03:42:59.381862Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:174: TTopicFormatHandler [json_each_row]: TClientHandler [2:7581698631372188976:2176]: ExtractClientData, number batches: 1
2025-12-09T03:42:59.381870Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:764: TopicSession [1:7581698635969974091:2155] SendData to [2:7581698631372188976:2176], batch size 1
2025-12-09T03:42:59.381882Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:457: TopicSession [1:7581698635969974091:2155] Skip SubscribeOnNextEvent, has ReadSession: true, IsWaitingEvents: 1
2025-12-09T03:42:59.381889Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1100: RowDispatcher: Forward TEvMessageBatch from [1:7581698635969974091:2155] to [2:7581698631372188976:2176] query id ptqudqgd5lgim5dts52n
2025-12-09T03:42:59.382956Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:129: TxId: ptqudqgd5lgim5dts52n, task: 2. Received input for channelId: 1, seqNo: 7, size: 50, chunks: 3, watermark: 0, checkpoint: 0, finished: 0, from: [2:7581698631372188974:2176], expected seqNo: 7
2025-12-09T03:42:59.382964Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:611: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. took input
2025-12-09T03:42:59.382992Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:356: SelfId: [1:7581698635969974088:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. No watermark 
2025-12-09T03:42:59.382999Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:965: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Input data push finished. Cookie: 6 Watermark: (empty maybe) Ack: 1 TakeInputChannelDataRequests: 1
2025-12-09T03:42:59.383004Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:738: TxId: ptqudqgd5lgim5dts52n, task: 2. Sending channel data ack to channelId: 1, peer: [2:7581698631372188973:2176], from: [1:7581698635969974086:2154], freeSpace: 999950, seqNo: 7, finished: 0
2025-12-09T03:42:59.383015Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Poll inputs
2025-12-09T03:42:59.383019Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Poll sources
2025-12-09T03:42:59.383022Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-12-09T03:42:59.383371Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. update task runner stats
2025-12-09T03:42:59.383403Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-09T03:42:59.383406Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-09T03:42:59.383410Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-09T03:42:59.383422Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [1:7581698635969974090:2154], TxId: ptqudqgd5lgim5dts52n, TaskId: 2, PQ sink. SendData. Batch: 1. Checkpoint: 0. Finished: 0
2025-12-09T03:42:59.383426Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:221: SelfId: [1:7581698635969974090:2154], TxId: ptqudqgd5lgim5dts52n, TaskId: 2, PQ sink. Received data for sending: {"event_type":2}
2025-12-09T03:42:59.383455Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:59.383450Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd5lgim5dts52n, TaskId: 2, PQ sink. ]  SessionId [cdc1fda9-9304ae87-7a886b32-908c68f4|5e84809c-654bb5ce-e73bf612-f8cc02c3_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 1 to 1
2025-12-09T03:42:59.383475Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:59.383473Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd5lgim5dts52n, TaskId: 2, PQ sink. ]  SessionId [cdc1fda9-9304ae87-7a886b32-908c68f4|5e84809c-654bb5ce-e73bf612-f8cc02c3_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-09T03:42:59.383481Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:59.383480Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd5lgim5dts52n, TaskId: 2, PQ sink. ]  SessionId [cdc1fda9-9304ae87-7a886b32-908c68f4|5e84809c-654bb5ce-e73bf612-f8cc02c3_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 1
2025-12-09T03:42:59.383615Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Sink 0: sent 20 bytes of data and 0 bytes of checkpoint barrier
2025-12-09T03:42:59.383618Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 16, sent data from buffer: 20
2025-12-09T03:42:59.383624Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:629: TxId: ptqudqgd5lgim5dts52n, task: 2. do poll, channelId: 1, last freeSpace: 999950, current freeSpace: 1000000, seqNo: 7
2025-12-09T03:42:59.383630Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:639: TxId: ptqudqgd5lgim5dts52n, task: 2. Poll input channelId: 1, from: [2:7581698631372188973:2176], seqNo: 7, freeSpace: 1000000
2025-12-09T03:42:59.383635Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:738: TxId: ptqudqgd5lgim5dts52n, task: 2. Sending channel data ack to channelId: 1, peer: [2:7581698631372188973:2176], from: [1:7581698635969974086:2154], freeSpace: 1000000, seqNo: 7, finished: 0
2025-12-09T03:42:59.387186Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:59.387177Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd5lgim5dts52n, TaskId: 2, PQ sink. ]  SessionId [cdc1fda9-9304ae87-7a886b32-908c68f4|5e84809c-654bb5ce-e73bf612-f8cc02c3_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-09T03:42:59.387260Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:59.387257Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd5lgim5dts52n, TaskId: 2, PQ sink. ]  SessionId [cdc1fda9-9304ae87-7a886b32-908c68f4|5e84809c-654bb5ce-e73bf612-f8cc02c3_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 1 written { } } write_statistics { persisting_time { nanos: 3000000 } min_queue_wait_time { } max_queue_wait_time { } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-09T03:42:59.387266Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:59.387264Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd5lgim5dts52n, TaskId: 2, PQ sink. ]  SessionId [cdc1fda9-9304ae87-7a886b32-908c68f4|5e84809c-654bb5ce-e73bf612-f8cc02c3_0]  PartitionId [0]  Generation [1] OnAck: seqNo=1, txId=?
2025-12-09T03:42:59.387271Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:42:59.387269Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd5lgim5dts52n, TaskId: 2, PQ sink. ]  SessionId [cdc1fda9-9304ae87-7a886b32-908c68f4|5e84809c-654bb5ce-e73bf612-f8cc02c3_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 1
2025-12-09T03:42:59.387666Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:454: SelfId: [1:7581698635969974090:2154], TxId: ptqudqgd5lgim5dts52n, TaskId: 2, PQ sink. Ack seq no 1
2025-12-09T03:42:59.422253Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 55a2cdd3-99315dd9-b49ecced-9009241912, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:42:59.425855Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:42:59.425871Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-09T03:42:59.714481Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:129: TxId: ptqudqgd5lgim5dts52n, task: 2. Received input for channelId: 1, seqNo: 8, size: 0, chunks: 0, watermark: 0, checkpoint: 1, finished: 0, from: [2:7581698631372188974:2176], expected seqNo: 8
2025-12-09T03:42:59.714502Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:611: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. took input
2025-12-09T03:42:59.714519Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:485: [ptqudqgd5lgim5dts52n-0] Task: 2. [Checkpoint 4.7] Got checkpoint barrier from channel 1
2025-12-09T03:42:59.714556Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:356: SelfId: [1:7581698635969974088:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. No watermark 
2025-12-09T03:42:59.714562Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Poll inputs
2025-12-09T03:42:59.714565Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1494: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-12-09T03:42:59.714567Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. DoExecuteImpl: 1
2025-12-09T03:42:59.714578Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:965: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Input data push finished. Cookie: 7 Watermark: (empty maybe) Ack: 1 TakeInputChannelDataRequests: 1
2025-12-09T03:42:59.714591Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:738: TxId: ptqudqgd5lgim5dts52n, task: 2. Sending channel data ack to channelId: 1, peer: [2:7581698631372188973:2176], from: [1:7581698635969974086:2154], freeSpace: 1000000, seqNo: 8, finished: 0
2025-12-09T03:42:59.714702Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:462: SelfId: [1:7581698635969974088:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Pending 1 checkpoints to be sent
2025-12-09T03:42:59.714715Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Poll inputs
2025-12-09T03:42:59.714717Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1494: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-12-09T03:42:59.714720Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-12-09T03:42:59.714723Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. update task runner stats
2025-12-09T03:42:59.714755Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 1 watermark injected: (empty maybe)
2025-12-09T03:42:59.714765Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:447: [ptqudqgd5lgim5dts52n-0] Task: 2. [Checkpoint 4.7] Performing task checkpoint
2025-12-09T03:42:59.714768Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:816: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Save state
2025-12-09T03:42:59.714771Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:474: [ptqudqgd5lgim5dts52n-0] Task: 2. [Checkpoint 4.7] CA state saved
2025-12-09T03:42:59.714776Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:449: [ptqudqgd5lgim5dts52n-0] Task: 2. [Checkpoint 4.7] Injecting checkpoint barrier to outputs
2025-12-09T03:42:59.714778Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-09T03:42:59.714783Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-09T03:42:59.714791Z :KQP_COMPUTE INFO: dq_async_compute_actor.cpp:1010: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Resume inputs
2025-12-09T03:42:59.714809Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [1:7581698635969974090:2154], TxId: ptqudqgd5lgim5dts52n, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 1. Finished: 0
2025-12-09T03:42:59.714813Z :KQP_COMPUTE DEBUG: dq_pq_write_actor.cpp:240: SelfId: [1:7581698635969974090:2154], TxId: ptqudqgd5lgim5dts52n, TaskId: 2, PQ sink. [Checkpoint 4.7] Send checkpoint state immediately
2025-12-09T03:42:59.714848Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:418: SelfId: [1:7581698635969974090:2154], TxId: ptqudqgd5lgim5dts52n, TaskId: 2, PQ sink. Save checkpoint { Id: 7 Generation: 4 Type: CHECKPOINT_TYPE_SNAPSHOT } state: { SourceId: "cdc1fda9-9304ae87-7a886b32-908c68f4" ConfirmedSeqNo: 1 EgressBytes: 16 }
2025-12-09T03:42:59.714853Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:524: [ptqudqgd5lgim5dts52n-0] Task: 2. Sink[0] state saved
2025-12-09T03:42:59.714870Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:536: [ptqudqgd5lgim5dts52n-0] Task: 2. [Checkpoint 4.7] Task checkpoint is done. Send to storage
2025-12-09T03:42:59.714879Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 6 bytes of checkpoint barrier
2025-12-09T03:42:59.714881Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-09T03:42:59.714889Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudqgd5lgim5dts52n, task: 2. no poll, channelId: 1, has inflight messages: [8], last with freeSpace: 1000000, current freeSpace: 1000000
2025-12-09T03:42:59.714902Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Poll inputs
2025-12-09T03:42:59.714900Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:460: [ptqudqgd5lgim5dts52n-0] [4:7] Got TEvSaveTaskState: task 2
2025-12-09T03:42:59.714909Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Poll sources
2025-12-09T03:42:59.714911Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-12-09T03:42:59.714914Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. update task runner stats
2025-12-09T03:42:59.714936Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-09T03:42:59.714938Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-09T03:42:59.714940Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-09T03:42:59.714944Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [1:7581698635969974090:2154], TxId: ptqudqgd5lgim5dts52n, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-12-09T03:42:59.714946Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-12-09T03:42:59.714948Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-09T03:42:59.714951Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudqgd5lgim5dts52n, task: 2. no poll, channelId: 1, has inflight messages: [8], last with freeSpace: 1000000, current freeSpace: 1000000
2025-12-09T03:42:59.714958Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. update task runner stats
2025-12-09T03:42:59.714965Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-09T03:42:59.714967Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-09T03:42:59.714968Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-09T03:42:59.714971Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [1:7581698635969974090:2154], TxId: ptqudqgd5lgim5dts52n, TaskId: 2, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-12-09T03:42:59.714973Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-12-09T03:42:59.714974Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-09T03:42:59.714977Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudqgd5lgim5dts52n, task: 2. no poll, channelId: 1, has inflight messages: [8], last with freeSpace: 1000000, current freeSpace: 1000000
2025-12-09T03:42:59.717404Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:484: [ptqudqgd5lgim5dts52n-0] [4:7] TEvSaveTaskState Apply: task: 2
2025-12-09T03:42:59.717422Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:499: [ptqudqgd5lgim5dts52n-0] [4:7] Send TEvSaveTaskStateResult: task: 2
2025-12-09T03:42:59.742796Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:759: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Commit state
2025-12-09T03:42:59.846095Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:608: Coordinator: Rebalancing...
2025-12-09T03:42:59.846109Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:615: Coordinator: Current state (rebalancing):
2025-12-09T03:42:59.846116Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:617: Coordinator:   node 2 ([2:7581698614192319536:2063]) state Initializing connected 1 partitions count 0
2025-12-09T03:42:59.846122Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:617: Coordinator:   node 1 ([1:7581698614495137367:2063]) state Started connected 1 partitions count 1
2025-12-09T03:42:59.846127Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:617: Coordinator:   node 3 ([3:7581698618792110379:2063]) state Initializing connected 1 partitions count 0
2025-12-09T03:42:59.846132Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:648: Coordinator: Send TEvCoordinatorDistributionReset to [2:7581698631372188976:2176]
2025-12-09T03:42:59.846158Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:615: Coordinator: Current state (after rebalancing):
2025-12-09T03:42:59.846161Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:617: Coordinator:   node 2 ([2:7581698614192319536:2063]) state Started connected 1 partitions count 0
2025-12-09T03:42:59.846164Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:617: Coordinator:   node 1 ([1:7581698614495137367:2063]) state Started connected 1 partitions count 0
2025-12-09T03:42:59.846166Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:617: Coordinator:   node 3 ([3:7581698618792110379:2063]) state Started connected 1 partitions count 0
2025-12-09T03:42:59.856352Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:952: TopicSession [1:7581698635969974091:2155] SendStatistics
2025-12-09T03:42:59.856390Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1234: RowDispatcher: TEvSessionStatistic from [1:7581698635969974091:2155]
2025-12-09T03:43:00.373156Z :YDB_SDK INFO: actor.cpp:37: 2025-12-09T03:43:00.373142Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:test_filter_with_mr_input:0:1:3:0
2025-12-09T03:43:00.373177Z :YDB_SDK INFO: actor.cpp:37: 2025-12-09T03:43:00.373175Z :INFO: [local] [local] [42709e9a-50ced28-3b618f70-ec70ce97] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1001 BytesRead: 244 MessagesRead: 4 BytesReadCompressed: 244 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:43:00.421568Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7581698614495137407:2082]
2025-12-09T03:43:00.421599Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-09T03:43:00.421634Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7581698614495137367:2063]
2025-12-09T03:43:00.421651Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7581698614495137367:2063]
2025-12-09T03:43:00.421655Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7581698614495137367:2063]
2025-12-09T03:43:00.421672Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-09T03:43:00.422613Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 55a2cdd3-99315dd9-b49ecced-9009241913, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:43:00.426304Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:43:00.426321Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-09T03:43:00.632796Z :KQP_COMPUTE ERROR: dq_compute_actor_impl.h:1205: SelfId: [1:7581698635969974086:2154], TxId: ptqudqgd5lgim5dts52n, task: 2. Ctx: {}. Handle abort execution event from: [1:7581698614495137368:2064], status: UNAVAILABLE, reason: { <main>: Error: Aborted by LWM }
2025-12-09T03:43:00.632862Z :KQP_COMPUTE DEBUG: dq_compute_actor_channels.cpp:494: TxId: ptqudqgd5lgim5dts52n, task: 2. pass away
2025-12-09T03:43:00.632922Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:1001: RowDispatcher: Received TEvStopSession from [2:7581698631372188976:2176] topic test_filter_with_mr_input query id ptqudqgd5lgim5dts52n
2025-12-09T03:43:00.632995Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:1016: RowDispatcher: DeleteConsumer, readActorId [2:7581698631372188976:2176] query id ptqudqgd5lgim5dts52n, partitions size 1
2025-12-09T03:43:00.633023Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:1036: RowDispatcher: Session is not used, sent TEvPoisonPill to [1:7581698635969974091:2155]
2025-12-09T03:43:00.633043Z :FQ_ROW_DISPATCHER DEBUG: topic_session.cpp:831: TopicSession [1:7581698635969974091:2155] TEvStopSession from [2:7581698631372188976:2176] topicPath test_filter_with_mr_input clients count 1
2025-12-09T03:43:00.633065Z :FQ_ROW_DISPATCHER DEBUG: format_handler.cpp:477: TTopicFormatHandler [json_each_row]: Remove client with id [2:7581698631372188976:2176]
2025-12-09T03:43:00.633072Z :FQ_ROW_DISPATCHER TRACE: filters_set.cpp:94: TTopicFilters: Remove program with client id [2:7581698631372188976:2176]
2025-12-09T03:43:00.633382Z :FQ_ROW_DISPATCHER DEBUG: format_handler.cpp:559: TTopicFormatHandler [json_each_row]: UpdateParser to new schema with size 0
2025-12-09T03:43:00.633390Z :FQ_ROW_DISPATCHER INFO: format_handler.cpp:584: TTopicFormatHandler [json_each_row]: No columns to parse, reset parser
2025-12-09T03:43:00.633468Z :FQ_ROW_DISPATCHER DEBUG: topic_session.cpp:924: TopicSession [1:7581698635969974091:2155] Close read session
2025-12-09T03:43:00.633486Z :YDB_SDK INFO: actor.cpp:37: 2025-12-09T03:43:00.633482Z :INFO: [local] [local] [42709e9a-50ced28-3b618f70-ec70ce97] Closing read session. Close timeout: 0.000000s
2025-12-09T03:43:00.633499Z :YDB_SDK INFO: actor.cpp:37: 2025-12-09T03:43:00.633498Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:test_filter_with_mr_input:0:1:3:0
2025-12-09T03:43:00.633508Z :YDB_SDK INFO: actor.cpp:37: 2025-12-09T03:43:00.633506Z :INFO: [local] [local] [42709e9a-50ced28-3b618f70-ec70ce97] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1261 BytesRead: 244 MessagesRead: 4 BytesReadCompressed: 244 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:43:00.633524Z :YDB_SDK NOTICE: actor.cpp:37: 2025-12-09T03:43:00.633522Z :NOTICE: [local] [local] [42709e9a-50ced28-3b618f70-ec70ce97] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Close with zero timeout " }
2025-12-09T03:43:00.633546Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:43:00.633534Z :DEBUG: [local] [local] [42709e9a-50ced28-3b618f70-ec70ce97] [] Abort session to cluster
2025-12-09T03:43:00.633739Z :YDB_SDK INFO: actor.cpp:37: 2025-12-09T03:43:00.633736Z :INFO: [local] [local] [42709e9a-50ced28-3b618f70-ec70ce97] Closing read session. Close timeout: 0.000000s
2025-12-09T03:43:00.633749Z :YDB_SDK INFO: actor.cpp:37: 2025-12-09T03:43:00.633747Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:test_filter_with_mr_input:0:1:3:0
2025-12-09T03:43:00.633752Z :YDB_SDK INFO: actor.cpp:37: 2025-12-09T03:43:00.633751Z :INFO: [local] [local] [42709e9a-50ced28-3b618f70-ec70ce97] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1261 BytesRead: 244 MessagesRead: 4 BytesReadCompressed: 244 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:43:00.633759Z :YDB_SDK NOTICE: actor.cpp:37: 2025-12-09T03:43:00.633758Z :NOTICE: [local] [local] [42709e9a-50ced28-3b618f70-ec70ce97] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-09T03:43:00.633795Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:457: TopicSession [1:7581698635969974091:2155] Skip SubscribeOnNextEvent, has ReadSession: false, IsWaitingEvents: 1
2025-12-09T03:43:00.633817Z :FQ_ROW_DISPATCHER DEBUG: topic_session.cpp:449: TopicSession [1:7581698635969974091:2155] PassAway
2025-12-09T03:43:00.634724Z :YDB_SDK INFO: actor.cpp:37: 2025-12-09T03:43:00.634718Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd5lgim5dts52n, TaskId: 2, PQ sink. ]  SessionId [cdc1fda9-9304ae87-7a886b32-908c68f4|5e84809c-654bb5ce-e73bf612-f8cc02c3_0]  PartitionId [0]  Generation [1] Write session: close. Timeout 0.000000s
2025-12-09T03:43:00.634736Z :YDB_SDK INFO: actor.cpp:37: 2025-12-09T03:43:00.634733Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd5lgim5dts52n, TaskId: 2, PQ sink. ]  SessionId [cdc1fda9-9304ae87-7a886b32-908c68f4|5e84809c-654bb5ce-e73bf612-f8cc02c3_0]  PartitionId [0]  Generation [1] Write session will now close
2025-12-09T03:43:00.634756Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:43:00.634754Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd5lgim5dts52n, TaskId: 2, PQ sink. ]  SessionId [cdc1fda9-9304ae87-7a886b32-908c68f4|5e84809c-654bb5ce-e73bf612-f8cc02c3_0]  PartitionId [0]  Generation [1] Write session: aborting
2025-12-09T03:43:00.634789Z :YDB_SDK INFO: actor.cpp:37: 2025-12-09T03:43:00.634787Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd5lgim5dts52n, TaskId: 2, PQ sink. ]  SessionId [cdc1fda9-9304ae87-7a886b32-908c68f4|5e84809c-654bb5ce-e73bf612-f8cc02c3_0]  PartitionId [0]  Generation [1] Write session: gracefully shut down, all writes complete
2025-12-09T03:43:00.634797Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:43:00.634796Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudqgd5lgim5dts52n, TaskId: 2, PQ sink. ]  SessionId [cdc1fda9-9304ae87-7a886b32-908c68f4|5e84809c-654bb5ce-e73bf612-f8cc02c3_0]  PartitionId [0]  Generation [1] Write session: destroy
2025-12-09T03:43:00.849250Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [2:7581698614192319536:2063]
2025-12-09T03:43:00.849262Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [2:7581698614192319536:2063]
2025-12-09T03:43:00.849265Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [2:7581698614192319536:2063]
2025-12-09T03:43:01.230355Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [3:7581698618792110379:2063]
2025-12-09T03:43:01.230373Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [3:7581698618792110379:2063]
2025-12-09T03:43:01.230379Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [3:7581698618792110379:2063]
2025-12-09T03:43:01.423096Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 55a2cdd3-99315dd9-b49ecced-9009241914, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:43:01.428152Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:43:01.428182Z :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:19462: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-syjwtgwtdu.auto.internal:19462
2025-12-09T03:43:01.858277Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1059: RowDispatcher: No consumer with EventQueueId = 0
2025-12-09T03:43:02.422481Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7581698614495137407:2082]
2025-12-09T03:43:02.422502Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-09T03:43:02.422510Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7581698614495137367:2063]
2025-12-09T03:43:02.422513Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7581698614495137367:2063]
2025-12-09T03:43:02.422517Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7581698614495137367:2063]
2025-12-09T03:43:02.422526Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-09T03:43:02.423528Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 55a2cdd3-99315dd9-b49ecced-9009241915, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:43:02.428102Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:43:02.428124Z :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:19462: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-syjwtgwtdu.auto.internal:19462
2025-12-09T03:43:02.850218Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [2:7581698614192319536:2063]
2025-12-09T03:43:02.850238Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [2:7581698614192319536:2063]
2025-12-09T03:43:02.850241Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [2:7581698614192319536:2063]
2025-12-09T03:43:03.231238Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [3:7581698618792110379:2063]
2025-12-09T03:43:03.231250Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [3:7581698618792110379:2063]
2025-12-09T03:43:03.231254Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [3:7581698618792110379:2063]
2025-12-09T03:43:03.417835Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-12-09T03:43:03.423473Z :YQL_NODES_MANAGER ERROR: nodes_manager.cpp:395: ydb/core/fq/libs/actors/nodes_manager.cpp:353: TRANSPORT_UNAVAILABLE
<main>: Error: GRpc error: (14): connections to all backends failing; last error: UNKNOWN: ipv4:127.0.1.1:19462: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-syjwtgwtdu.auto.internal:19462
2025-12-09T03:43:03.423982Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 55a2cdd3-99315dd9-b49ecced-9009241916, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:43:03.428396Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:43:03.428416Z :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:19462: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-syjwtgwtdu.auto.internal:19462
2025-12-09T03:43:04.423410Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7581698614495137407:2082]
2025-12-09T03:43:04.423440Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-09T03:43:04.423450Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7581698614495137367:2063]
2025-12-09T03:43:04.423458Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7581698614495137367:2063]
2025-12-09T03:43:04.423462Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7581698614495137367:2063]
2025-12-09T03:43:04.423476Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-09T03:43:04.424539Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 55a2cdd3-99315dd9-b49ecced-9009241917, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:43:04.429669Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:43:04.429692Z :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:19462: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-syjwtgwtdu.auto.internal:19462
2025-12-09T03:43:04.851211Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [2:7581698614192319536:2063]
2025-12-09T03:43:04.851229Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [2:7581698614192319536:2063]
2025-12-09T03:43:04.851233Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [2:7581698614192319536:2063]
2025-12-09T03:43:05.232106Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [3:7581698618792110379:2063]
2025-12-09T03:43:05.232125Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [3:7581698618792110379:2063]
2025-12-09T03:43:05.232131Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [3:7581698618792110379:2063]
2025-12-09T03:43:05.424879Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 55a2cdd3-99315dd9-b49ecced-9009241918, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:43:05.430234Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:43:05.430259Z :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:19462: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-syjwtgwtdu.auto.internal:19462
2025-12-09T03:43:06.424526Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7581698614495137407:2082]
2025-12-09T03:43:06.424554Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-09T03:43:06.424565Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7581698614495137367:2063]
2025-12-09T03:43:06.424569Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7581698614495137367:2063]
2025-12-09T03:43:06.424577Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7581698614495137367:2063]
2025-12-09T03:43:06.424587Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-09T03:43:06.429633Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 55a2cdd3-99315dd9-b49ecced-9009241919, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:43:06.440139Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:43:06.440168Z :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:19462: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-syjwtgwtdu.auto.internal:19462
2025-12-09T03:43:06.852121Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [2:7581698614192319536:2063]
2025-12-09T03:43:06.852153Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [2:7581698614192319536:2063]
2025-12-09T03:43:06.852157Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [2:7581698614192319536:2063]
2025-12-09T03:43:07.233100Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [3:7581698618792110379:2063]
2025-12-09T03:43:07.233120Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [3:7581698618792110379:2063]
2025-12-09T03:43:07.233125Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [3:7581698618792110379:2063]
2025-12-09T03:43:07.429855Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 55a2cdd3-99315dd9-b49ecced-9009241920, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:43:07.434746Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:43:07.434769Z :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:19462: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-syjwtgwtdu.auto.internal:19462
2025-12-09T03:43:08.418037Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-12-09T03:43:08.423329Z :YQL_NODES_MANAGER ERROR: nodes_manager.cpp:395: ydb/core/fq/libs/actors/nodes_manager.cpp:353: TRANSPORT_UNAVAILABLE
<main>: Error: GRpc error: (14): connections to all backends failing; last error: UNKNOWN: ipv4:127.0.1.1:19462: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-syjwtgwtdu.auto.internal:19462
2025-12-09T03:43:08.425168Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7581698614495137407:2082]
2025-12-09T03:43:08.425188Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-09T03:43:08.425195Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7581698614495137367:2063]
2025-12-09T03:43:08.425198Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7581698614495137367:2063]
2025-12-09T03:43:08.425203Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7581698614495137367:2063]
2025-12-09T03:43:08.425211Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-09T03:43:08.430291Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 55a2cdd3-99315dd9-b49ecced-9009241921, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:43:08.435190Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:43:08.435217Z :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:19462: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-syjwtgwtdu.auto.internal:19462
2025-12-09T03:43:08.852862Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [2:7581698614192319536:2063]
2025-12-09T03:43:08.852888Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [2:7581698614192319536:2063]
2025-12-09T03:43:08.852891Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [2:7581698614192319536:2063]
2025-12-09T03:43:09.233912Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [3:7581698618792110379:2063]
2025-12-09T03:43:09.233927Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [3:7581698618792110379:2063]
2025-12-09T03:43:09.233931Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [3:7581698618792110379:2063]
2025-12-09T03:43:09.430752Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 55a2cdd3-99315dd9-b49ecced-9009241922, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:43:09.436097Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:43:09.436115Z :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:19462: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-syjwtgwtdu.auto.internal:19462
2025-12-09T03:43:10.426037Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7581698614495137407:2082]
2025-12-09T03:43:10.426058Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-09T03:43:10.426064Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7581698614495137367:2063]
2025-12-09T03:43:10.426068Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7581698614495137367:2063]
2025-12-09T03:43:10.426071Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7581698614495137367:2063]
2025-12-09T03:43:10.426080Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-09T03:43:10.431196Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 55a2cdd3-99315dd9-b49ecced-9009241923, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:43:10.436263Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:43:10.436282Z :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:19462: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-syjwtgwtdu.auto.internal:19462
2025-12-09T03:43:10.853774Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [2:7581698614192319536:2063]
2025-12-09T03:43:10.853789Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [2:7581698614192319536:2063]
2025-12-09T03:43:10.853793Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [2:7581698614192319536:2063]
2025-12-09T03:43:11.234809Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [3:7581698618792110379:2063]
2025-12-09T03:43:11.234824Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [3:7581698618792110379:2063]
2025-12-09T03:43:11.234828Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [3:7581698618792110379:2063]
2025-12-09T03:43:11.431641Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 55a2cdd3-99315dd9-b49ecced-9009241924, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:43:11.438927Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:43:11.438962Z :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:19462: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-syjwtgwtdu.auto.internal:19462
2025-12-09T03:43:12.426970Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7581698614495137407:2082]
2025-12-09T03:43:12.426989Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-09T03:43:12.427003Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7581698614495137367:2063]
2025-12-09T03:43:12.427007Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7581698614495137367:2063]
2025-12-09T03:43:12.427011Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7581698614495137367:2063]
2025-12-09T03:43:12.427022Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-09T03:43:12.432053Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 55a2cdd3-99315dd9-b49ecced-9009241925, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:43:12.438269Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:43:12.438288Z :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:19462: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-syjwtgwtdu.auto.internal:19462
2025-12-09T03:43:12.854857Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [2:7581698614192319536:2063]
2025-12-09T03:43:12.854882Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [2:7581698614192319536:2063]
2025-12-09T03:43:12.854885Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [2:7581698614192319536:2063]
2025-12-09T03:43:13.239770Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [3:7581698618792110379:2063]
2025-12-09T03:43:13.239787Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [3:7581698618792110379:2063]
2025-12-09T03:43:13.239791Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [3:7581698618792110379:2063]
2025-12-09T03:43:13.418700Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-12-09T03:43:13.430095Z :YQL_NODES_MANAGER ERROR: nodes_manager.cpp:395: ydb/core/fq/libs/actors/nodes_manager.cpp:353: TRANSPORT_UNAVAILABLE
<main>: Error: GRpc error: (14): connections to all backends failing; last error: UNKNOWN: ipv4:127.0.1.1:19462: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-syjwtgwtdu.auto.internal:19462
2025-12-09T03:43:13.433200Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 55a2cdd3-99315dd9-b49ecced-9009241926, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:43:13.442131Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:43:13.442150Z :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:19462: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-syjwtgwtdu.auto.internal:19462
2025-12-09T03:43:14.427837Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7581698614495137407:2082]
2025-12-09T03:43:14.427857Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-09T03:43:14.427859Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7581698614495137367:2063]
2025-12-09T03:43:14.427863Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7581698614495137367:2063]
2025-12-09T03:43:14.427866Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7581698614495137367:2063]
2025-12-09T03:43:14.427876Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-09T03:43:14.434024Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 55a2cdd3-99315dd9-b49ecced-9009241927, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:43:14.438632Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:43:14.438660Z :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:19462: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-syjwtgwtdu.auto.internal:19462
2025-12-09T03:43:14.857763Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [2:7581698614192319536:2063]
2025-12-09T03:43:14.857781Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [2:7581698614192319536:2063]
2025-12-09T03:43:14.857785Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [2:7581698614192319536:2063]
2025-12-09T03:43:15.242184Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [3:7581698618792110379:2063]
2025-12-09T03:43:15.242200Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [3:7581698618792110379:2063]
2025-12-09T03:43:15.242214Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [3:7581698618792110379:2063]
2025-12-09T03:43:15.434472Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 55a2cdd3-99315dd9-b49ecced-9009241928, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:43:15.440679Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:43:15.440710Z :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:19462: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-syjwtgwtdu.auto.internal:19462
2025-12-09T03:43:16.428763Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7581698614495137407:2082]
2025-12-09T03:43:16.428790Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-09T03:43:16.428798Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7581698614495137367:2063]
2025-12-09T03:43:16.428803Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7581698614495137367:2063]
2025-12-09T03:43:16.428812Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7581698614495137367:2063]
2025-12-09T03:43:16.428824Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-09T03:43:16.434924Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 55a2cdd3-99315dd9-b49ecced-9009241929, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:43:16.440165Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:43:16.440190Z :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:19462: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-syjwtgwtdu.auto.internal:19462
2025-12-09T03:43:16.856539Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [2:7581698614192319536:2063]
2025-12-09T03:43:16.856561Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [2:7581698614192319536:2063]
2025-12-09T03:43:16.856568Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [2:7581698614192319536:2063]
2025-12-09T03:43:17.240559Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [3:7581698618792110379:2063]
2025-12-09T03:43:17.240578Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [3:7581698618792110379:2063]
2025-12-09T03:43:17.240584Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [3:7581698618792110379:2063]
2025-12-09T03:43:17.436423Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 55a2cdd3-99315dd9-b49ecced-9009241930, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:43:17.451916Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:43:17.451969Z :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:19462: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-syjwtgwtdu.auto.internal:19462
2025-12-09T03:43:18.419428Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-12-09T03:43:18.424155Z :YQL_NODES_MANAGER ERROR: nodes_manager.cpp:395: ydb/core/fq/libs/actors/nodes_manager.cpp:353: TRANSPORT_UNAVAILABLE
<main>: Error: GRpc error: (14): connections to all backends failing; last error: UNKNOWN: ipv4:127.0.1.1:19462: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-syjwtgwtdu.auto.internal:19462
2025-12-09T03:43:18.429648Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7581698614495137407:2082]
2025-12-09T03:43:18.429666Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-09T03:43:18.429672Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7581698614495137367:2063]
2025-12-09T03:43:18.429676Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7581698614495137367:2063]
2025-12-09T03:43:18.429680Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7581698614495137367:2063]
2025-12-09T03:43:18.429690Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-09T03:43:18.436828Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 55a2cdd3-99315dd9-b49ecced-9009241931, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:43:18.445286Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:43:18.445305Z :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:19462: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-syjwtgwtdu.auto.internal:19462
2025-12-09T03:43:18.862173Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [2:7581698614192319536:2063]
2025-12-09T03:43:18.862187Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [2:7581698614192319536:2063]
2025-12-09T03:43:18.862190Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [2:7581698614192319536:2063]
2025-12-09T03:43:19.241462Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [3:7581698618792110379:2063]
2025-12-09T03:43:19.241474Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [3:7581698618792110379:2063]
2025-12-09T03:43:19.241477Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [3:7581698618792110379:2063]
2025-12-09T03:43:19.437280Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 55a2cdd3-99315dd9-b49ecced-9009241932, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:43:19.446158Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:43:19.446179Z :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:19462: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-syjwtgwtdu.auto.internal:19462
2025-12-09T03:43:20.430537Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7581698614495137407:2082]
2025-12-09T03:43:20.430560Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-09T03:43:20.430568Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7581698614495137367:2063]
2025-12-09T03:43:20.430573Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7581698614495137367:2063]
2025-12-09T03:43:20.430577Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7581698614495137367:2063]
2025-12-09T03:43:20.430588Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-09T03:43:20.437714Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 55a2cdd3-99315dd9-b49ecced-9009241933, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:43:20.442720Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:43:20.442740Z :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:19462: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-syjwtgwtdu.auto.internal:19462
2025-12-09T03:43:20.858260Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [2:7581698614192319536:2063]
2025-12-09T03:43:20.858283Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [2:7581698614192319536:2063]
2025-12-09T03:43:20.858288Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [2:7581698614192319536:2063]
2025-12-09T03:43:21.242356Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [3:7581698618792110379:2063]
2025-12-09T03:43:21.242374Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [3:7581698618792110379:2063]
2025-12-09T03:43:21.242379Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [3:7581698618792110379:2063]
2025-12-09T03:43:21.438191Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 55a2cdd3-99315dd9-b49ecced-9009241934, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:43:21.442943Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:43:21.442964Z :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:19462: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-syjwtgwtdu.auto.internal:19462
2025-12-09T03:43:22.431411Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7581698614495137407:2082]
2025-12-09T03:43:22.431447Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-09T03:43:22.431458Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7581698614495137367:2063]
2025-12-09T03:43:22.431463Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7581698614495137367:2063]
2025-12-09T03:43:22.431467Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7581698614495137367:2063]
2025-12-09T03:43:22.431479Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-09T03:43:22.438635Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 55a2cdd3-99315dd9-b49ecced-9009241935, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:43:22.444180Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:43:22.444206Z :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:19462: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-syjwtgwtdu.auto.internal:19462
2025-12-09T03:43:22.859237Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [2:7581698614192319536:2063]
2025-12-09T03:43:22.859252Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [2:7581698614192319536:2063]
2025-12-09T03:43:22.859260Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [2:7581698614192319536:2063]
2025-12-09T03:43:23.243289Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [3:7581698618792110379:2063]
2025-12-09T03:43:23.243303Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [3:7581698618792110379:2063]
2025-12-09T03:43:23.243306Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [3:7581698618792110379:2063]
2025-12-09T03:43:23.419608Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-12-09T03:43:23.424492Z :YQL_NODES_MANAGER ERROR: nodes_manager.cpp:395: ydb/core/fq/libs/actors/nodes_manager.cpp:353: TRANSPORT_UNAVAILABLE
<main>: Error: GRpc error: (14): connections to all backends failing; last error: UNKNOWN: ipv4:127.0.1.1:19462: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-syjwtgwtdu.auto.internal:19462
2025-12-09T03:43:23.439027Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 55a2cdd3-99315dd9-b49ecced-9009241936, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:43:23.443830Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:43:23.443845Z :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:19462: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-syjwtgwtdu.auto.internal:19462
2025-12-09T03:43:24.432336Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7581698614495137407:2082]
2025-12-09T03:43:24.432354Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-09T03:43:24.432361Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7581698614495137367:2063]
2025-12-09T03:43:24.432364Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7581698614495137367:2063]
2025-12-09T03:43:24.432377Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7581698614495137367:2063]
2025-12-09T03:43:24.432387Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-09T03:43:24.439514Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 55a2cdd3-99315dd9-b49ecced-9009241937, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:43:24.444352Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:43:24.444372Z :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:19462: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-syjwtgwtdu.auto.internal:19462
2025-12-09T03:43:24.860098Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [2:7581698614192319536:2063]
2025-12-09T03:43:24.860113Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [2:7581698614192319536:2063]
2025-12-09T03:43:24.860117Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [2:7581698614192319536:2063]
2025-12-09T03:43:25.244083Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [3:7581698618792110379:2063]
2025-12-09T03:43:25.244104Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [3:7581698618792110379:2063]
2025-12-09T03:43:25.244107Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [3:7581698618792110379:2063]
2025-12-09T03:43:25.439960Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 55a2cdd3-99315dd9-b49ecced-9009241938, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:43:25.444893Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:43:25.444915Z :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:19462: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-syjwtgwtdu.auto.internal:19462
2025-12-09T03:43:26.433232Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7581698614495137407:2082]
2025-12-09T03:43:26.433251Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-09T03:43:26.433257Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7581698614495137367:2063]
2025-12-09T03:43:26.433261Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7581698614495137367:2063]
2025-12-09T03:43:26.433263Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7581698614495137367:2063]
2025-12-09T03:43:26.433272Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-09T03:43:26.440408Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 55a2cdd3-99315dd9-b49ecced-9009241939, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:43:26.444588Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:43:26.444606Z :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:19462: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-syjwtgwtdu.auto.internal:19462
2025-12-09T03:43:26.860952Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [2:7581698614192319536:2063]
2025-12-09T03:43:26.860983Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [2:7581698614192319536:2063]
2025-12-09T03:43:26.860987Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [2:7581698614192319536:2063]
2025-12-09T03:43:27.244970Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [3:7581698618792110379:2063]
2025-12-09T03:43:27.244988Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [3:7581698618792110379:2063]
2025-12-09T03:43:27.244991Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [3:7581698618792110379:2063]
2025-12-09T03:43:27.440873Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 55a2cdd3-99315dd9-b49ecced-9009241940, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:43:27.445789Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:43:27.445818Z :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:19462: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-syjwtgwtdu.auto.internal:19462
2025-12-09T03:43:28.419799Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-12-09T03:43:28.424325Z :YQL_NODES_MANAGER ERROR: nodes_manager.cpp:395: ydb/core/fq/libs/actors/nodes_manager.cpp:353: TRANSPORT_UNAVAILABLE
<main>: Error: GRpc error: (14): connections to all backends failing; last error: UNKNOWN: ipv4:127.0.1.1:19462: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-syjwtgwtdu.auto.internal:19462
2025-12-09T03:43:28.434133Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7581698614495137407:2082]
2025-12-09T03:43:28.434148Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-09T03:43:28.434154Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7581698614495137367:2063]
2025-12-09T03:43:28.434157Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7581698614495137367:2063]
2025-12-09T03:43:28.434160Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7581698614495137367:2063]
2025-12-09T03:43:28.434169Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-09T03:43:28.441320Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 55a2cdd3-99315dd9-b49ecced-9009241941, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:43:28.446052Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:43:28.446082Z :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:19462: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-syjwtgwtdu.auto.internal:19462
2025-12-09T03:43:28.861928Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [2:7581698614192319536:2063]
2025-12-09T03:43:28.861956Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [2:7581698614192319536:2063]
2025-12-09T03:43:28.861959Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [2:7581698614192319536:2063]
2025-12-09T03:43:29.245885Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [3:7581698618792110379:2063]
2025-12-09T03:43:29.245900Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [3:7581698618792110379:2063]
2025-12-09T03:43:29.245903Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [3:7581698618792110379:2063]
2025-12-09T03:43:29.441762Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 55a2cdd3-99315dd9-b49ecced-9009241942, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:43:29.446729Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:43:29.446751Z :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:19462: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-syjwtgwtdu.auto.internal:19462
2025-12-09T03:43:30.435050Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7581698614495137407:2082]
2025-12-09T03:43:30.435065Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-09T03:43:30.435073Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7581698614495137367:2063]
2025-12-09T03:43:30.435083Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7581698614495137367:2063]
2025-12-09T03:43:30.435086Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7581698614495137367:2063]
2025-12-09T03:43:30.435097Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-09T03:43:30.442230Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 55a2cdd3-99315dd9-b49ecced-9009241943, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:43:30.447043Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:43:30.447081Z :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:19462: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-syjwtgwtdu.auto.internal:19462
2025-12-09T03:43:30.862748Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [2:7581698614192319536:2063]
2025-12-09T03:43:30.862777Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [2:7581698614192319536:2063]
2025-12-09T03:43:30.862781Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [2:7581698614192319536:2063]
2025-12-09T03:43:31.246794Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [3:7581698618792110379:2063]
2025-12-09T03:43:31.246812Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [3:7581698618792110379:2063]
2025-12-09T03:43:31.246816Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [3:7581698618792110379:2063]
2025-12-09T03:43:31.442683Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 55a2cdd3-99315dd9-b49ecced-9009241944, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:43:31.447029Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:43:31.447062Z :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:19462: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-syjwtgwtdu.auto.internal:19462
2025-12-09T03:43:32.435937Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7581698614495137407:2082]
2025-12-09T03:43:32.435964Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-09T03:43:32.435972Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7581698614495137367:2063]
2025-12-09T03:43:32.435976Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7581698614495137367:2063]
2025-12-09T03:43:32.435979Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7581698614495137367:2063]
2025-12-09T03:43:32.435990Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-09T03:43:32.443112Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 55a2cdd3-99315dd9-b49ecced-9009241945, Host: ghrun-syjwtgwtdu, Tenant: /compute
2025-12-09T03:43:32.448399Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:43:32.448417Z :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:19462: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-syjwtgwtdu.auto.internal:19462
2025-12-09T03:43:32.863689Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [2:7581698614192319536:2063]
2025-12-09T03:43:32.863705Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [2:7581698614192319536:2063]
2025-12-09T03:43:32.863708Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [2:7581698614192319536:2063]
2025-12-09T03:43:33.187996Z :INTERCONNECT_NETWORK NOTICE: interconnect_tcp_input_session.cpp:712: [1 <-> 3] connection closed by peer
2025-12-09T03:43:33.188259Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:398: Coordinator: TEvNodeDisconnected, node id 3
2025-12-09T03:43:33.188274Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:408: Coordinator: Schedule TEvRebalancing
2025-12-09T03:43:33.189075Z :INTERCONNECT_NETWORK NOTICE: interconnect_handshake.cpp:1262: [1 <-> 3] network-related error occured on handshake: outgoing handshake Peer# ghrun-syjwtgwtdu(127.0.1.1:26401) Socket error# Connection reset by peer state# ReceiveResponse processed# 0 remain# 52
2025-12-09T03:43:33.189412Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:597: RowDispatcher: TEvNodeDisconnected, node id 2
2025-12-09T03:43:33.189414Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:398: Coordinator: TEvNodeDisconnected, node id 2
2025-12-09T03:43:33.189576Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1052: RowDispatcher: TEvTryConnect to node id 2
2025-12-09T03:43:33.189800Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:597: RowDispatcher: TEvNodeDisconnected, node id 2
