2025-12-12T12:27:18.367522Z :GRPC_SERVER NOTICE: grpc_request_proxy.cpp:380: Grpc request proxy started, nodeid# 1, serve as static node
2025-12-12T12:27:18.367577Z :GRPC_SERVER CRIT: grpc_request_proxy.cpp:440: Failed to deliver subscription request to config dispatcher
2025-12-12T12:27:18.367594Z :GRPC_SERVER NOTICE: grpc_request_proxy.cpp:380: Grpc request proxy started, nodeid# 1, serve as static node
2025-12-12T12:27:18.367611Z :GRPC_SERVER CRIT: grpc_request_proxy.cpp:440: Failed to deliver subscription request to config dispatcher
2025-12-12T12:27:18.367779Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:214: Bootstrap
2025-12-12T12:27:18.367781Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:217: Create sdk ydb connection
2025-12-12T12:27:18.367835Z :FQ_QUOTA_PROXY INFO: quota_proxy.cpp:90: STARTED
2025-12-12T12:27:18.367875Z :FQ_LOG_UPDATER DEBUG: log.cpp:93: Updated YQL logs priority: 8
2025-12-12T12:27:18.367881Z :FQ_LOG_UPDATER CRIT: log.cpp:55: Failed to deliver subscription request to config dispatcher.
2025-12-12T12:27:18.367914Z :YQ_RATE_LIMITER INFO: quoter_service.cpp:124: Bootstraping with config: { Enabled: true DataPlaneEnabled: true Database { Endpoint: "localhost:4719" Database: "local" TablePrefix: "RateLimiter_7ac237b7-55a0-4089-82cd-46ba182cd1f3" } Limiters { CoordinationNodePath: "rate_limiter" } }
2025-12-12T12:27:18.368181Z :MEMORY_PROFILER NOTICE: monitor.cpp:332: Bootstrapped
2025-12-12T12:27:18.368242Z :FQ_QUOTA_SERVICE INFO: quota_manager.cpp:196: STARTED
2025-12-12T12:27:18.368273Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:544: RowDispatcher: Successfully bootstrapped row dispatcher, id [1:7582947031622470815:2063], tenant /compute
2025-12-12T12:27:18.368284Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582947031622470815:2063]
2025-12-12T12:27:18.368286Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:329: Coordinator: Add new row dispatcher to map (state 1)
2025-12-12T12:27:18.368402Z :YQL_NODES_MANAGER INFO: nodes_manager.cpp:88: Bootstrap, InstanceId: 58b9cfed-43bb6206-eb34ceb8-6df436b8
2025-12-12T12:27:18.368404Z :YQL_NODES_MANAGER DEBUG: nodes_manager.cpp:310: TNodesManagerActor::ResolveSelfAddress
2025-12-12T12:27:18.368414Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:293: Coordinator: Successfully bootstrapped coordinator, id [1:7582947031622470849:2092], NodesManagerId [0:4705493345362661702:78], rebalancing timeout 5.000000s
2025-12-12T12:27:18.368424Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:232: TLeaderElection [1:7582947031622470850:2093] Successfully bootstrapped, local coordinator id [1:7582947031622470849:2092], tenant id compute, local mode 0, coordination node path local/compute, endpoint localhost:4719
2025-12-12T12:27:18.369234Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:239: Successfully bootstrapped TStorageProxy [1:7582947031622470814:2062] with connection to localhost:4719:local
2025-12-12T12:27:18.369255Z :YQ_TEST_CONNECTION DEBUG: test_connection.cpp:142: Starting yandex query test connection. Actor id: [1:7582947031622470820:2068]
2025-12-12T12:27:18.369309Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: f992d040-c9567214-5bb9b6cb-b47493841, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:18.369318Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:637: RowDispatcher: TEvCoordinatorChangesSubscribe from [1:7582947031622470849:2092]
2025-12-12T12:27:18.370853Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:71: Run create coordination node "local/compute" actor
2025-12-12T12:27:18.370862Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:113: Call create coordination node "local/compute"
2025-12-12T12:27:18.370865Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:411: Call create coordination node "local/compute"
2025-12-12T12:27:18.376115Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-12-12T12:27:18.376228Z :SCHEME_BOARD_SUBSCRIBER NOTICE: subscriber.cpp:849: [main][1:7582947031622470834:2077][/Root] Set up state: owner# [1:7582947031622470794:2052], state# { Deleted: 1 Strong: 0 Version: <Invalid> DomainId: <Invalid> AbandonedSchemeShards: there are 0 elements }
2025-12-12T12:27:18.376253Z :SCHEME_BOARD_SUBSCRIBER NOTICE: subscriber.cpp:849: [main][1:7582947031622470836:2079][/Root] Set up state: owner# [1:7582947031622470795:2053], state# { Deleted: 1 Strong: 0 Version: <Invalid> DomainId: <Invalid> AbandonedSchemeShards: there are 0 elements }
2025-12-12T12:27:18.376381Z :SCHEME_BOARD_SUBSCRIBER NOTICE: subscriber.cpp:849: [main][1:7582947031622470835:2078][/compute] Set up state: owner# [1:7582947031622470794:2052], state# { Deleted: 1 Strong: 0 Version: <Invalid> DomainId: <Invalid> AbandonedSchemeShards: there are 0 elements }
2025-12-12T12:27:18.376390Z :GRPC_SERVER WARN: grpc_request_proxy.cpp:583: SchemeBoardDelete /Root Strong=0
2025-12-12T12:27:18.376391Z :GRPC_SERVER WARN: grpc_request_proxy.cpp:583: SchemeBoardDelete /compute Strong=0
2025-12-12T12:27:18.376393Z :GRPC_SERVER WARN: grpc_request_proxy.cpp:583: SchemeBoardDelete /Root Strong=0
2025-12-12T12:27:18.377365Z :SCHEME_BOARD_SUBSCRIBER NOTICE: subscriber.cpp:849: [main][1:7582947031622470837:2080][/compute] Set up state: owner# [1:7582947031622470795:2053], state# { Deleted: 1 Strong: 0 Version: <Invalid> DomainId: <Invalid> AbandonedSchemeShards: there are 0 elements }
2025-12-12T12:27:18.377386Z :GRPC_SERVER WARN: grpc_request_proxy.cpp:583: SchemeBoardDelete /compute Strong=0
2025-12-12T12:27:18.393730Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:155: Successfully created coordination node "local/compute"
2025-12-12T12:27:18.393752Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:122: Reply for create coordination node "local/compute": { <main>: Error: Check failed: path: '/local/compute', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 19], type: EPathTypeKesus, state: EPathStateNoChanges), source_location: ydb/core/tx/schemeshard/schemeshard__operation_create_kesus.cpp:339 }
2025-12-12T12:27:18.393772Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:345: TLeaderElection [1:7582947031622470850:2093] Coordination node successfully created
2025-12-12T12:27:18.393776Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:323: TLeaderElection [1:7582947031622470850:2093] Start session
2025-12-12T12:27:18.398320Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:359: TLeaderElection [1:7582947031622470850:2093] Session successfully created
2025-12-12T12:27:18.408792Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:372: TLeaderElection [1:7582947031622470850:2093] Semaphore successfully created
2025-12-12T12:27:18.408802Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:304: TLeaderElection [1:7582947031622470850:2093] Try to acquire semaphore
2025-12-12T12:27:18.408938Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:420: TLeaderElection [1:7582947031622470850:2093] Describe semaphore
2025-12-12T12:27:18.412160Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:386: TLeaderElection [1:7582947031622470850:2093] Semaphore successfully acquired
2025-12-12T12:27:18.412181Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:469: TLeaderElection [1:7582947031622470850:2093] Semaphore successfully described: coordinator id [1:7582947031622470849:2092] generation 4
2025-12-12T12:27:18.412186Z :FQ_ROW_DISPATCHER INFO: leader_election.cpp:471: TLeaderElection [1:7582947031622470850:2093] Send TEvCoordinatorChanged to [1:7582947031622470815:2063], new coordinator id [1:7582947031622470849:2092], previous coordinator id [0:0:0]
2025-12-12T12:27:18.412218Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:569: RowDispatcher: Coordinator changed, old leader (empty maybe), new [1:7582947031622470849:2092] generation 4
2025-12-12T12:27:18.412233Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582947031622470815:2063]
2025-12-12T12:27:18.412240Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582947031622470815:2063]
2025-12-12T12:27:18.412243Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582947031622470815:2063]
2025-12-12T12:27:18.412254Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:440: Coordinator: New leader [1:7582947031622470849:2092], SelfId [1:7582947031622470849:2092]
2025-12-12T12:27:18.412256Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:18.431110Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:18.431126Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:18.453218Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:389: Send NodeInfo with size: 0 to DynamicNameserver
2025-12-12T12:27:19.178362Z :INTERCONNECT ERROR: interconnect_nameserver_dynamic.cpp:62:  ICN06 Unknown nodeId: 2
2025-12-12T12:27:19.369808Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: f992d040-c9567214-5bb9b6cb-b47493842, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:19.374532Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:19.374552Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:19.622757Z :INTERCONNECT ERROR: interconnect_nameserver_dynamic.cpp:62:  ICN06 Unknown nodeId: 2
2025-12-12T12:27:19.622795Z :INTERCONNECT ERROR: interconnect_nameserver_dynamic.cpp:62:  ICN06 Unknown nodeId: 3
2025-12-12T12:27:20.066182Z :INTERCONNECT ERROR: interconnect_nameserver_dynamic.cpp:62:  ICN06 Unknown nodeId: 3
2025-12-12T12:27:20.367941Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582947031622470849:2092]
2025-12-12T12:27:20.367963Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:20.367972Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582947031622470815:2063]
2025-12-12T12:27:20.367975Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582947031622470815:2063]
2025-12-12T12:27:20.367978Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582947031622470815:2063]
2025-12-12T12:27:20.367983Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:20.370268Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: f992d040-c9567214-5bb9b6cb-b47493843, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:20.375212Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:20.375231Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:20.719468Z :INTERCONNECT ERROR: interconnect_nameserver_dynamic.cpp:62:  ICN06 Unknown nodeId: 2
2025-12-12T12:27:21.229404Z :INTERCONNECT ERROR: interconnect_nameserver_dynamic.cpp:62:  ICN06 Unknown nodeId: 3
2025-12-12T12:27:21.370787Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: f992d040-c9567214-5bb9b6cb-b47493844, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:21.377833Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:21.377851Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:21.920619Z :INTERCONNECT ERROR: interconnect_nameserver_dynamic.cpp:62:  ICN06 Unknown nodeId: 2
2025-12-12T12:27:22.368118Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582947031622470849:2092]
2025-12-12T12:27:22.368127Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:22.368153Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582947031622470815:2063]
2025-12-12T12:27:22.368156Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582947031622470815:2063]
2025-12-12T12:27:22.368159Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582947031622470815:2063]
2025-12-12T12:27:22.368181Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:22.374336Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: f992d040-c9567214-5bb9b6cb-b47493845, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:22.383632Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:22.383645Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:22.712184Z :INTERCONNECT ERROR: interconnect_nameserver_dynamic.cpp:62:  ICN06 Unknown nodeId: 3
2025-12-12T12:27:23.122811Z :INTERCONNECT ERROR: interconnect_nameserver_dynamic.cpp:62:  ICN06 Unknown nodeId: 2
2025-12-12T12:27:23.367125Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:665: Coordinator: Change global state to Started (by timeout)
2025-12-12T12:27:23.374719Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: f992d040-c9567214-5bb9b6cb-b47493846, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:23.375716Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-12-12T12:27:23.379339Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:23.379349Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:23.387437Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:389: Send NodeInfo with size: 2 to DynamicNameserver
2025-12-12T12:27:23.496109Z :INTERCONNECT WARN: interconnect_handshake.cpp:501: Handshake [1:7582947053097307513:2062] [node 2] ICH09 Neither CompatibilityInfo nor VersionTag of the peer can be validated, accepting by default
2025-12-12T12:27:23.496404Z :INTERCONNECT WARN: interconnect_handshake.cpp:501: Handshake [1:7582947053097307515:2063] [node 3] ICH09 Neither CompatibilityInfo nor VersionTag of the peer can be validated, accepting by default
2025-12-12T12:27:24.123730Z :FQ_ROW_DISPATCHER INFO: coordinator.cpp:507: Coordinator: TEvCoordinatorRequest from [2:7582947042671855358:2150], test_read_raw_format_with_row_dispatcher_input, partIds: 0
2025-12-12T12:27:24.123773Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:562: Coordinator: Send TEvCoordinatorResult to [2:7582947042671855358:2150]
2025-12-12T12:27:24.123793Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:392: Coordinator: EvNodeConnected 2
2025-12-12T12:27:24.125520Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:853: RowDispatcher: Received TEvStartSession from [2:7582947042671855358:2150], read group ptcudq7uf16n0fokcj2e, topicPath test_read_raw_format_with_row_dispatcher_input part id 0 query id ptqudq7uf0ohfducsop6 cookie 1
2025-12-12T12:27:24.125563Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:892: RowDispatcher: Create new session: read group ptcudq7uf16n0fokcj2e topic test_read_raw_format_with_row_dispatcher_input part id 0
2025-12-12T12:27:24.125666Z :FQ_ROW_DISPATCHER DEBUG: topic_session.cpp:443: TopicSession [1:7582947057392274821:2144] Bootstrap test_read_raw_format_with_row_dispatcher_input/0, Timeout 5.000000s sec
2025-12-12T12:27:24.125683Z :FQ_ROW_DISPATCHER INFO: topic_session.cpp:799: TopicSession [1:7582947057392274821:2144] New client: read actor id [2:7582947042671855358:2150], predicate: , watermark expr: , offset: (empty maybe)
2025-12-12T12:27:24.125754Z :FQ_ROW_DISPATCHER DEBUG: format_handler.cpp:440: TTopicFormatHandler [raw]: Add client with id [2:7582947042671855358:2150]
2025-12-12T12:27:24.126310Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1052: RowDispatcher: TEvTryConnect to node id 2
2025-12-12T12:27:24.126409Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:587: RowDispatcher: EvNodeConnected, node id 2
2025-12-12T12:27:24.167633Z :FQ_ROW_DISPATCHER DEBUG: format_handler.cpp:559: TTopicFormatHandler [raw]: UpdateParser to new schema with size 1
2025-12-12T12:27:24.167714Z :FQ_ROW_DISPATCHER DEBUG: format_handler.cpp:570: TTopicFormatHandler [raw]: Parser was created on schema with 1 columns
2025-12-12T12:27:24.167727Z :FQ_ROW_DISPATCHER TRACE: purecalc_filter.cpp:439: GenerateSql: No sql was generated
2025-12-12T12:27:24.167731Z :FQ_ROW_DISPATCHER TRACE: filters_set.cpp:116: TTopicFilters: Create program with client id [2:7582947042671855358:2150]
2025-12-12T12:27:24.167736Z :FQ_ROW_DISPATCHER TRACE: filters_set.cpp:110: TTopicFilters: Start program with client id [2:7582947042671855358:2150]
2025-12-12T12:27:24.167744Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:952: TopicSession [1:7582947057392274821:2144] SendStatistics
2025-12-12T12:27:24.167803Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1234: RowDispatcher: TEvSessionStatistic from [1:7582947057392274821:2144]
2025-12-12T12:27:24.369017Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582947031622470849:2092]
2025-12-12T12:27:24.369059Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:24.369060Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582947031622470815:2063]
2025-12-12T12:27:24.369069Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582947031622470815:2063]
2025-12-12T12:27:24.369072Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582947031622470815:2063]
2025-12-12T12:27:24.369089Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:24.375202Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: f992d040-c9567214-5bb9b6cb-b47493847, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:24.375234Z :FQ_QUOTA_SERVICE DEBUG: quota_manager.cpp:230: IC Peers[2]: [2, 3]
2025-12-12T12:27:24.387210Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:24.387235Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:24.911129Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [2:7582947034081920562:2063]
2025-12-12T12:27:24.911142Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [2:7582947034081920562:2063]
2025-12-12T12:27:24.911153Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:329: Coordinator: Add new row dispatcher to map (state 0)
2025-12-12T12:27:24.911156Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:334: Coordinator: Schedule TEvRebalancing
2025-12-12T12:27:24.911160Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [2:7582947034081920562:2063]
2025-12-12T12:27:25.374891Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [3:7582947035351577334:2063]
2025-12-12T12:27:25.374916Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [3:7582947035351577334:2063]
2025-12-12T12:27:25.374920Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:329: Coordinator: Add new row dispatcher to map (state 0)
2025-12-12T12:27:25.374924Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [3:7582947035351577334:2063]
2025-12-12T12:27:25.374933Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:392: Coordinator: EvNodeConnected 3
2025-12-12T12:27:25.375540Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: f992d040-c9567214-5bb9b6cb-b47493848, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:25.383146Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:25.383158Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:26.126188Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:952: TopicSession [1:7582947057392274821:2144] SendStatistics
2025-12-12T12:27:26.126228Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:962: RowDispatcher: Received TEvHeartbeat from [2:7582947042671855358:2150], part id 0 query id ptqudq7uf0ohfducsop6
2025-12-12T12:27:26.126254Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1234: RowDispatcher: TEvSessionStatistic from [1:7582947057392274821:2144]
2025-12-12T12:27:26.369937Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582947031622470849:2092]
2025-12-12T12:27:26.369957Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:26.369976Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582947031622470815:2063]
2025-12-12T12:27:26.369983Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582947031622470815:2063]
2025-12-12T12:27:26.369986Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582947031622470815:2063]
2025-12-12T12:27:26.370016Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:26.377801Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: f992d040-c9567214-5bb9b6cb-b47493849, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:26.382876Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:26.382889Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:26.911523Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [2:7582947034081920562:2063]
2025-12-12T12:27:26.911542Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [2:7582947034081920562:2063]
2025-12-12T12:27:26.911545Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [2:7582947034081920562:2063]
2025-12-12T12:27:27.375842Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [3:7582947035351577334:2063]
2025-12-12T12:27:27.375856Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [3:7582947035351577334:2063]
2025-12-12T12:27:27.375860Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [3:7582947035351577334:2063]
2025-12-12T12:27:27.378548Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: f992d040-c9567214-5bb9b6cb-b474938410, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:27.387403Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:27.387419Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:28.127109Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:952: TopicSession [1:7582947057392274821:2144] SendStatistics
2025-12-12T12:27:28.127153Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:962: RowDispatcher: Received TEvHeartbeat from [2:7582947042671855358:2150], part id 0 query id ptqudq7uf0ohfducsop6
2025-12-12T12:27:28.127174Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1234: RowDispatcher: TEvSessionStatistic from [1:7582947057392274821:2144]
2025-12-12T12:27:28.366728Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:599: Coordinator: Send TEvGetNodesRequest to NodesManager
2025-12-12T12:27:28.366761Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:300: Received TNodesManagerActor::TEvGetNodesRequest
2025-12-12T12:27:28.366776Z :FQ_ROW_DISPATCHER INFO: coordinator.cpp:690: Coordinator: Updated node info, node count: 3
2025-12-12T12:27:28.370779Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582947031622470849:2092]
2025-12-12T12:27:28.370805Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:28.370839Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582947031622470815:2063]
2025-12-12T12:27:28.370843Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582947031622470815:2063]
2025-12-12T12:27:28.370847Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582947031622470815:2063]
2025-12-12T12:27:28.370856Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:28.375899Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-12-12T12:27:28.378950Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: f992d040-c9567214-5bb9b6cb-b474938411, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:28.385679Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:28.385693Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:28.389287Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:389: Send NodeInfo with size: 2 to DynamicNameserver
2025-12-12T12:27:28.912437Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [2:7582947034081920562:2063]
2025-12-12T12:27:28.912451Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [2:7582947034081920562:2063]
2025-12-12T12:27:28.912455Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [2:7582947034081920562:2063]
2025-12-12T12:27:29.166475Z :FQ_ROW_DISPATCHER INFO: topic_session.cpp:516: TopicSession [1:7582947057392274821:2144] Create topic session, Path test_read_raw_format_with_row_dispatcher_input/0, StartingMessageTimestamp 2025-12-12T12:27:20.297000Z, BufferSize 16000000, GetConsumerMode Without
2025-12-12T12:27:29.166525Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:27:29.166521Z :INFO: [local] [local] [cdb6fda9-55c7d0fe-4f12ba8b-acadd831] Starting read session
2025-12-12T12:27:29.166531Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:29.166529Z :DEBUG: [local] [local] [cdb6fda9-55c7d0fe-4f12ba8b-acadd831] Starting single session
2025-12-12T12:27:29.166579Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:29.166565Z :DEBUG: [local] [local] [cdb6fda9-55c7d0fe-4f12ba8b-acadd831] [] In Reconnect, ReadSizeBudget = 8000000, ReadSizeServerDelta = 0
2025-12-12T12:27:29.166589Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:29.166586Z :DEBUG: [local] [local] [cdb6fda9-55c7d0fe-4f12ba8b-acadd831] [] New values: ReadSizeBudget = 8000000, ReadSizeServerDelta = 0
2025-12-12T12:27:29.166594Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:29.166592Z :DEBUG: [local] [local] [cdb6fda9-55c7d0fe-4f12ba8b-acadd831] [] Reconnecting session to cluster  in 0.000000s
2025-12-12T12:27:29.167335Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:466: TopicSession [1:7582947057392274821:2144] SubscribeOnNextEvent
2025-12-12T12:27:29.172068Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:29.172052Z :DEBUG: [local] [local] [cdb6fda9-55c7d0fe-4f12ba8b-acadd831] [] Successfully connected. Initializing session
2025-12-12T12:27:29.173634Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:27:29.173626Z :INFO: [local] [local] [cdb6fda9-55c7d0fe-4f12ba8b-acadd831] [] Got InitResponse. ReadSessionId: _1_4_11176010523123124311_v1
2025-12-12T12:27:29.173650Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:29.173648Z :DEBUG: [local] [local] [cdb6fda9-55c7d0fe-4f12ba8b-acadd831] [] In ContinueReadingDataImpl, ReadSizeBudget = 8000000, ReadSizeServerDelta = 0
2025-12-12T12:27:29.173716Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:29.173712Z :DEBUG: [local] [local] [cdb6fda9-55c7d0fe-4f12ba8b-acadd831] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 8000000
2025-12-12T12:27:29.175366Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:559: TopicSession [1:7582947057392274821:2144] TEvPqEventsReady
2025-12-12T12:27:29.175387Z :FQ_ROW_DISPATCHER DEBUG: topic_session.cpp:677: TopicSession [1:7582947057392274821:2144] StartPartitionSessionEvent received
2025-12-12T12:27:29.175389Z :FQ_ROW_DISPATCHER DEBUG: topic_session.cpp:685: TopicSession [1:7582947057392274821:2144] Confirm StartPartitionSession with offset (NULL)
2025-12-12T12:27:29.175405Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:27:29.175400Z :INFO: [local] [local] [cdb6fda9-55c7d0fe-4f12ba8b-acadd831] [] Confirm partition stream create. Partition stream id: 1. Cluster: "-". Topic: "test_read_raw_format_with_row_dispatcher_input". Partition: 0. Read offset: (NULL)
2025-12-12T12:27:29.175494Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:466: TopicSession [1:7582947057392274821:2144] SubscribeOnNextEvent
2025-12-12T12:27:29.176381Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:29.176367Z :DEBUG: [local] [local] [cdb6fda9-55c7d0fe-4f12ba8b-acadd831] [] Got ReadResponse, serverBytesSize = 114, now ReadSizeBudget = 0, ReadSizeServerDelta = 7999886
2025-12-12T12:27:29.176417Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:29.176414Z :DEBUG: [local] [local] [cdb6fda9-55c7d0fe-4f12ba8b-acadd831] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 7999886
2025-12-12T12:27:29.176477Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:29.176473Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (0-1)
2025-12-12T12:27:29.176488Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:29.176486Z :DEBUG: [local] [local] [cdb6fda9-55c7d0fe-4f12ba8b-acadd831] [] Returning serverBytesSize = 114 to budget
2025-12-12T12:27:29.176492Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:29.176490Z :DEBUG: [local] [local] [cdb6fda9-55c7d0fe-4f12ba8b-acadd831] [] In ContinueReadingDataImpl, ReadSizeBudget = 114, ReadSizeServerDelta = 7999886
2025-12-12T12:27:29.176536Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:29.176534Z :DEBUG: [local] [local] [cdb6fda9-55c7d0fe-4f12ba8b-acadd831] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 8000000
2025-12-12T12:27:29.176571Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:559: TopicSession [1:7582947057392274821:2144] TEvPqEventsReady
2025-12-12T12:27:29.176609Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:29.176605Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-12-12T12:27:29.176620Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:29.176619Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (1-1)
2025-12-12T12:27:29.176631Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:29.176629Z :DEBUG: [local] [local] [cdb6fda9-55c7d0fe-4f12ba8b-acadd831] [] The application data is transferred to the client. Number of messages 2, size 30 bytes
2025-12-12T12:27:29.176644Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:29.176643Z :DEBUG: [local] [local] [cdb6fda9-55c7d0fe-4f12ba8b-acadd831] [] Returning serverBytesSize = 0 to budget
2025-12-12T12:27:29.176671Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:654: TopicSession [1:7582947057392274821:2144] Data received: Message { Data: "{"time" = 101;}" Information: { Offset: 0 ProducerId: "" SeqNo: 0 CreateTime: 2025-12-12T12:27:21.011000Z WriteTime: 2025-12-12T12:27:21.011000Z MessageGroupId: "" Meta: { } MessageMeta: { } } Partition session id: 1 Topic: "test_read_raw_format_with_row_dispatcher_input" Partition: 0 }
2025-12-12T12:27:29.176680Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:654: TopicSession [1:7582947057392274821:2144] Data received: Message { Data: "{"time" = 102;}" Information: { Offset: 1 ProducerId: "" SeqNo: 0 CreateTime: 2025-12-12T12:27:21.011000Z WriteTime: 2025-12-12T12:27:21.015000Z MessageGroupId: "" Meta: { } MessageMeta: { } } Partition session id: 1 Topic: "test_read_raw_format_with_row_dispatcher_input" Partition: 0 }
2025-12-12T12:27:29.176681Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:707: TopicSession [1:7582947057392274821:2144] SendToParsing, messages: 2
2025-12-12T12:27:29.176685Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:417: TTopicFormatHandler [raw]: Send 2 messages to parser
2025-12-12T12:27:29.176688Z :FQ_ROW_DISPATCHER TRACE: raw_parser.cpp:56: TRawParser: Add 2 messages to parse
2025-12-12T12:27:29.176766Z :FQ_ROW_DISPATCHER TRACE: raw_parser.cpp:93: TRawParser: Do parsing, first offset: 0, value: {"time" = 101;}
2025-12-12T12:27:29.176787Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:77: TTopicFormatHandler [raw]: TParserHandler: Got parsed data, number rows: 1
2025-12-12T12:27:29.176795Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:614: TTopicFormatHandler [raw]: Send 1 messages to programs, first offset: 0, last offset: 0
2025-12-12T12:27:29.176798Z :FQ_ROW_DISPATCHER TRACE: filters_set.cpp:34: TTopicFilters: ProcessData for 1 clients, number rows: 1
2025-12-12T12:27:29.176805Z :FQ_ROW_DISPATCHER TRACE: filters_set.cpp:223: TTopicFilters: Pass 1 rows to purecalc filter (client id: [2:7582947042671855358:2150])
2025-12-12T12:27:29.176806Z :FQ_ROW_DISPATCHER TRACE: purecalc_filter.cpp:408: TProgramRunHandler: ProcessData for 1 rows
2025-12-12T12:27:29.176819Z :FQ_ROW_DISPATCHER TRACE: purecalc_filter.cpp:411: TProgramRunHandler: Add 1 rows to client [2:7582947042671855358:2150] without processing
2025-12-12T12:27:29.176829Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:292: TTopicFormatHandler [raw]: TClientHandler [2:7582947042671855358:2150]: OnBatchFinish, offset: 0, number rows: 1, row size: 27, watermark: (empty maybe)
2025-12-12T12:27:29.176832Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:198: TopicSession [1:7582947057392274821:2144] AddDataToClient to [2:7582947042671855358:2150], offset: 0, number rows: 1, row size: 27, watermark: (empty maybe)
2025-12-12T12:27:29.176834Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:936: TopicSession [1:7582947057392274821:2144] Send TEvNewDataArrived to [2:7582947042671855358:2150]
2025-12-12T12:27:29.176850Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:622: TTopicFormatHandler [raw]: Commit client [2:7582947042671855358:2150] offset 0
2025-12-12T12:27:29.176852Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:210: TopicSession [1:7582947057392274821:2144] UpdateClientOffset for [2:7582947042671855358:2150], new offset: 0
2025-12-12T12:27:29.176856Z :FQ_ROW_DISPATCHER TRACE: raw_parser.cpp:93: TRawParser: Do parsing, first offset: 1, value: {"time" = 102;}
2025-12-12T12:27:29.176858Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:77: TTopicFormatHandler [raw]: TParserHandler: Got parsed data, number rows: 1
2025-12-12T12:27:29.176860Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:614: TTopicFormatHandler [raw]: Send 1 messages to programs, first offset: 1, last offset: 1
2025-12-12T12:27:29.176862Z :FQ_ROW_DISPATCHER TRACE: filters_set.cpp:34: TTopicFilters: ProcessData for 1 clients, number rows: 1
2025-12-12T12:27:29.176864Z :FQ_ROW_DISPATCHER TRACE: filters_set.cpp:223: TTopicFilters: Pass 1 rows to purecalc filter (client id: [2:7582947042671855358:2150])
2025-12-12T12:27:29.176865Z :FQ_ROW_DISPATCHER TRACE: purecalc_filter.cpp:408: TProgramRunHandler: ProcessData for 1 rows
2025-12-12T12:27:29.176866Z :FQ_ROW_DISPATCHER TRACE: purecalc_filter.cpp:411: TProgramRunHandler: Add 1 rows to client [2:7582947042671855358:2150] without processing
2025-12-12T12:27:29.176868Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:292: TTopicFormatHandler [raw]: TClientHandler [2:7582947042671855358:2150]: OnBatchFinish, offset: 1, number rows: 1, row size: 19, watermark: (empty maybe)
2025-12-12T12:27:29.176869Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:198: TopicSession [1:7582947057392274821:2144] AddDataToClient to [2:7582947042671855358:2150], offset: 1, number rows: 1, row size: 19, watermark: (empty maybe)
2025-12-12T12:27:29.176872Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:622: TTopicFormatHandler [raw]: Commit client [2:7582947042671855358:2150] offset 1
2025-12-12T12:27:29.176874Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:210: TopicSession [1:7582947057392274821:2144] UpdateClientOffset for [2:7582947042671855358:2150], new offset: 1
2025-12-12T12:27:29.176880Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:466: TopicSession [1:7582947057392274821:2144] SubscribeOnNextEvent
2025-12-12T12:27:29.176889Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1081: RowDispatcher: Forward TEvNewDataArrived from [1:7582947057392274821:2144] to [2:7582947042671855358:2150] query id ptqudq7uf0ohfducsop6
2025-12-12T12:27:29.179415Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:940: RowDispatcher: Received TEvGetNextBatch from [2:7582947042671855358:2150] part id 0 query id ptqudq7uf0ohfducsop6
2025-12-12T12:27:29.179444Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:588: TopicSession [1:7582947057392274821:2144] TEvGetNextBatch from [2:7582947042671855358:2150]
2025-12-12T12:27:29.179451Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:324: TTopicFormatHandler [raw]: TClientHandler [2:7582947042671855358:2150]: FinishPacking, batch size: 46, number rows: 2
2025-12-12T12:27:29.179460Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:174: TTopicFormatHandler [raw]: TClientHandler [2:7582947042671855358:2150]: ExtractClientData, number batches: 1
2025-12-12T12:27:29.179467Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:764: TopicSession [1:7582947057392274821:2144] SendData to [2:7582947042671855358:2150], batch size 1
2025-12-12T12:27:29.179475Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:457: TopicSession [1:7582947057392274821:2144] Skip SubscribeOnNextEvent, has ReadSession: true, IsWaitingEvents: 1
2025-12-12T12:27:29.179488Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1100: RowDispatcher: Forward TEvMessageBatch from [1:7582947057392274821:2144] to [2:7582947042671855358:2150] query id ptqudq7uf0ohfducsop6
2025-12-12T12:27:29.376752Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [3:7582947035351577334:2063]
2025-12-12T12:27:29.376769Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [3:7582947035351577334:2063]
2025-12-12T12:27:29.376773Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [3:7582947035351577334:2063]
2025-12-12T12:27:29.379431Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: f992d040-c9567214-5bb9b6cb-b474938412, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:29.385926Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:29.385941Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:29.910844Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:608: Coordinator: Rebalancing...
2025-12-12T12:27:29.910858Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:615: Coordinator: Current state (rebalancing):
2025-12-12T12:27:29.910863Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:617: Coordinator:   node 1 ([1:7582947031622470815:2063]) state Started connected 1 partitions count 1
2025-12-12T12:27:29.910868Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:617: Coordinator:   node 2 ([2:7582947034081920562:2063]) state Initializing connected 1 partitions count 0
2025-12-12T12:27:29.910871Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:617: Coordinator:   node 3 ([3:7582947035351577334:2063]) state Initializing connected 1 partitions count 0
2025-12-12T12:27:29.910874Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:648: Coordinator: Send TEvCoordinatorDistributionReset to [2:7582947042671855358:2150]
2025-12-12T12:27:29.910890Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:615: Coordinator: Current state (after rebalancing):
2025-12-12T12:27:29.910892Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:617: Coordinator:   node 1 ([1:7582947031622470815:2063]) state Started connected 1 partitions count 0
2025-12-12T12:27:29.910893Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:617: Coordinator:   node 2 ([2:7582947034081920562:2063]) state Started connected 1 partitions count 0
2025-12-12T12:27:29.910896Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:617: Coordinator:   node 3 ([3:7582947035351577334:2063]) state Started connected 1 partitions count 0
2025-12-12T12:27:30.106118Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:1001: RowDispatcher: Received TEvStopSession from [2:7582947042671855358:2150] topic test_read_raw_format_with_row_dispatcher_input query id ptqudq7uf0ohfducsop6
2025-12-12T12:27:30.106169Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:1016: RowDispatcher: DeleteConsumer, readActorId [2:7582947042671855358:2150] query id ptqudq7uf0ohfducsop6, partitions size 1
2025-12-12T12:27:30.106200Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:1036: RowDispatcher: Session is not used, sent TEvPoisonPill to [1:7582947057392274821:2144]
2025-12-12T12:27:30.106226Z :FQ_ROW_DISPATCHER DEBUG: topic_session.cpp:831: TopicSession [1:7582947057392274821:2144] TEvStopSession from [2:7582947042671855358:2150] topicPath test_read_raw_format_with_row_dispatcher_input clients count 1
2025-12-12T12:27:30.106237Z :FQ_ROW_DISPATCHER DEBUG: format_handler.cpp:477: TTopicFormatHandler [raw]: Remove client with id [2:7582947042671855358:2150]
2025-12-12T12:27:30.106241Z :FQ_ROW_DISPATCHER TRACE: filters_set.cpp:94: TTopicFilters: Remove program with client id [2:7582947042671855358:2150]
2025-12-12T12:27:30.106259Z :FQ_ROW_DISPATCHER DEBUG: format_handler.cpp:559: TTopicFormatHandler [raw]: UpdateParser to new schema with size 0
2025-12-12T12:27:30.106262Z :FQ_ROW_DISPATCHER INFO: format_handler.cpp:584: TTopicFormatHandler [raw]: No columns to parse, reset parser
2025-12-12T12:27:30.106309Z :FQ_ROW_DISPATCHER DEBUG: topic_session.cpp:924: TopicSession [1:7582947057392274821:2144] Close read session
2025-12-12T12:27:30.106324Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:27:30.106318Z :INFO: [local] [local] [cdb6fda9-55c7d0fe-4f12ba8b-acadd831] Closing read session. Close timeout: 0.000000s
2025-12-12T12:27:30.106342Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:27:30.106340Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:test_read_raw_format_with_row_dispatcher_input:0:1:1:0
2025-12-12T12:27:30.106351Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:27:30.106349Z :INFO: [local] [local] [cdb6fda9-55c7d0fe-4f12ba8b-acadd831] Counters: { Errors: 0 CurrentSessionLifetimeMs: 939 BytesRead: 30 MessagesRead: 2 BytesReadCompressed: 30 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:27:30.106369Z :YDB_SDK NOTICE: actor.cpp:37: 2025-12-12T12:27:30.106366Z :NOTICE: [local] [local] [cdb6fda9-55c7d0fe-4f12ba8b-acadd831] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Close with zero timeout " }
2025-12-12T12:27:30.106390Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:30.106388Z :DEBUG: [local] [local] [cdb6fda9-55c7d0fe-4f12ba8b-acadd831] [] Abort session to cluster
2025-12-12T12:27:30.106596Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:27:30.106592Z :INFO: [local] [local] [cdb6fda9-55c7d0fe-4f12ba8b-acadd831] Closing read session. Close timeout: 0.000000s
2025-12-12T12:27:30.106603Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:27:30.106601Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:test_read_raw_format_with_row_dispatcher_input:0:1:1:0
2025-12-12T12:27:30.106617Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:27:30.106605Z :INFO: [local] [local] [cdb6fda9-55c7d0fe-4f12ba8b-acadd831] Counters: { Errors: 0 CurrentSessionLifetimeMs: 940 BytesRead: 30 MessagesRead: 2 BytesReadCompressed: 30 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:27:30.106625Z :YDB_SDK NOTICE: actor.cpp:37: 2025-12-12T12:27:30.106624Z :NOTICE: [local] [local] [cdb6fda9-55c7d0fe-4f12ba8b-acadd831] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T12:27:30.106657Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:457: TopicSession [1:7582947057392274821:2144] Skip SubscribeOnNextEvent, has ReadSession: false, IsWaitingEvents: 1
2025-12-12T12:27:30.106679Z :FQ_ROW_DISPATCHER DEBUG: topic_session.cpp:449: TopicSession [1:7582947057392274821:2144] PassAway
2025-12-12T12:27:30.128990Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1059: RowDispatcher: No consumer with EventQueueId = 0
2025-12-12T12:27:30.371695Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582947031622470849:2092]
2025-12-12T12:27:30.371712Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:30.371729Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582947031622470815:2063]
2025-12-12T12:27:30.371735Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582947031622470815:2063]
2025-12-12T12:27:30.371738Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582947031622470815:2063]
2025-12-12T12:27:30.371750Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:30.382722Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: f992d040-c9567214-5bb9b6cb-b474938413, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:30.386768Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:30.386782Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:30.913363Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [2:7582947034081920562:2063]
2025-12-12T12:27:30.913379Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [2:7582947034081920562:2063]
2025-12-12T12:27:30.913383Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [2:7582947034081920562:2063]
2025-12-12T12:27:31.017519Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: f992d040-c9567214-5bb9b6cb-b4749384 2025-12-12 12:27:31.017 DEBUG ydbd(pid=1203530, tid=0x00007F0105977640) [DQ] local_worker_manager.cpp:316: {ptqudq7uembs22j8723s} TLocalWorkerManager::TEvAllocateWorkersRequest 281483566645250
2025-12-12T12:27:31.017555Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: f992d040-c9567214-5bb9b6cb-b4749384 2025-12-12 12:27:31.017 DEBUG ydbd(pid=1203530, tid=0x00007F0105977640) [DQ] local_worker_manager.cpp:376: {ptqudq7uembs22j8723s} Create compute actor: async
2025-12-12T12:27:31.017719Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:144: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Start compute actor [1:7582947087457045899:2147], task: 1
2025-12-12T12:27:31.017771Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:114: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Use CPU quota: 1. Rate limiter resource: { "local/RateLimiter_7ac237b7-55a0-4089-82cd-46ba182cd1f3/rate_limiter", "mock_cloud/my_folder/ptqudq7uembs22j8723s" }
2025-12-12T12:27:31.065122Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:197: [] Task: 1. Got TEvNewCheckpointCoordinator event: generation 1, actorId: [2:7582947089916495676:2165]
2025-12-12T12:27:31.065135Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:208: [] Task: 1. Assign checkpoint coordinator (generation = 1)
2025-12-12T12:27:31.065822Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1360: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Create source for input 0 { Source { Type: "PqSource" Settings { type_url: "type.googleapis.com/NYql.NPq.NProto.TDqPqTopicSource" value: "\n.test_read_raw_format_with_row_dispatcher_input\022\024ptqudq7uembs22j8723s\032\016localhost:4719\"\025\n\023cluster:default_yds*\005local0\002@\001b\004dataj\025[\"DataType\";\"String\"]r\026(`data` <> \"romashka\")x\001\222\001\024ptcudq7uf16n0fokcj2e\232\001\003raw\242\001/[\"StructType\";[[\"data\";[\"DataType\";\"String\"]]]]\262\001\002\022\000\272\001\026\n\010cloud_id\022\nmock_cloud\272\001 \n\005scope\022\027yandexcloud://my_folder" } WatermarksMode: WATERMARKS_MODE_DISABLED } }
2025-12-12T12:27:31.066163Z :KQP_COMPUTE INFO: dq_pq_rd_read_actor.cpp:557: SelfId: [0:0:0], TxId: ptqudq7uembs22j8723s, task: 1. PQ source. Start read actor, local row dispatcher [0:5788050504107380562:5260383], metadatafields: , partitions: 0, skip json errors: 0
2025-12-12T12:27:31.066214Z :KQP_COMPUTE DEBUG: dq_pq_read_actor_base.cpp:153: SelfId: [0:0:0], TxId: ptqudq7uembs22j8723s, task: 1. PQ source. SessionId: empty Watermarks enabled: 0 granularity: 0.000000s late arrival delay: 0.000000s idle: 0 idle timeout: 0.000000s
2025-12-12T12:27:31.066241Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1447: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Create sink for output 0 { Sink { Type: "PqSink" Settings { type_url: "type.googleapis.com/NYql.NPq.NProto.TDqPqTopicSink" value: "\n/test_read_raw_format_with_row_dispatcher_output\022\016localhost:4719\032\025\n\023cluster:default_yds\"\005local0\0018\002" } } }
2025-12-12T12:27:31.066341Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:395: [ptqudq7uembs22j8723s-0] Task: 1. Handle connected node 2
2025-12-12T12:27:31.067378Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1064: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Received channels info: 
2025-12-12T12:27:31.071177Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:239: [ptqudq7uembs22j8723s-0] Task: 1. [Checkpoint 1.1] TEvInjectCheckpoint
2025-12-12T12:27:31.071191Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1164: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Got TEvRun from actor [2:7582947089916495676:2165]
2025-12-12T12:27:31.071203Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Poll inputs
2025-12-12T12:27:31.071206Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1494: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Skip polling sources because of pending checkpoint
2025-12-12T12:27:31.071209Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. DoExecuteImpl: 1
2025-12-12T12:27:31.071249Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: f992d040-c9567214-5bb9b6cb-b4749384 2025-12-12 12:27:31.071 DEBUG ydbd(pid=1203530, tid=0x00007F0105977640) [DQ] tasks_runner_local.cpp:267: {TODO/1} Run task: 1
2025-12-12T12:27:31.071296Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:462: SelfId: [1:7582947087457045901:2147], TxId: ptqudq7uembs22j8723s, task: 1. Pending 1 checkpoints to be sent
2025-12-12T12:27:31.071306Z :KQP_COMPUTE TRACE: dq_compute_memory_quota.h:97: TxId: ptqudq7uembs22j8723s, task: 1. Peak memory usage: 131072
2025-12-12T12:27:31.071314Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. update task runner stats
2025-12-12T12:27:31.071350Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 1 watermark injected: (empty maybe)
2025-12-12T12:27:31.071353Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:447: [ptqudq7uembs22j8723s-0] Task: 1. [Checkpoint 1.1] Performing task checkpoint
2025-12-12T12:27:31.071355Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:816: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Save state
2025-12-12T12:27:31.071362Z :KQP_COMPUTE DEBUG: dq_pq_read_actor_base.cpp:94: SelfId: [0:0:0], TxId: ptqudq7uembs22j8723s, task: 1. PQ source. SessionId: empty SaveState, offsets: 
2025-12-12T12:27:31.071369Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:474: [ptqudq7uembs22j8723s-0] Task: 1. [Checkpoint 1.1] CA state saved
2025-12-12T12:27:31.071371Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:449: [ptqudq7uembs22j8723s-0] Task: 1. [Checkpoint 1.1] Injecting checkpoint barrier to outputs
2025-12-12T12:27:31.071375Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:27:31.071379Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-12T12:27:31.071383Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1107: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Ask CPU quota: 49ms
2025-12-12T12:27:31.071410Z :KQP_COMPUTE INFO: dq_async_compute_actor.cpp:1010: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Resume inputs
2025-12-12T12:27:31.071413Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [0:0:0], TxId: ptqudq7uembs22j8723s, TaskId: 1, PQ sink. SendData. Batch: 0. Checkpoint: 1. Finished: 0
2025-12-12T12:27:31.071517Z :KQP_COMPUTE DEBUG: dq_pq_write_actor.cpp:240: SelfId: [0:0:0], TxId: ptqudq7uembs22j8723s, TaskId: 1, PQ sink. [Checkpoint 1.1] Send checkpoint state immediately
2025-12-12T12:27:31.071682Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:418: SelfId: [0:0:0], TxId: ptqudq7uembs22j8723s, TaskId: 1, PQ sink. Save checkpoint { Id: 1 Generation: 1 Type: CHECKPOINT_TYPE_SNAPSHOT } state: { SourceId: "6f8fb322-8654a169-31a0708b-41019f17" }
2025-12-12T12:27:31.071687Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:524: [ptqudq7uembs22j8723s-0] Task: 1. Sink[0] state saved
2025-12-12T12:27:31.071699Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:536: [ptqudq7uembs22j8723s-0] Task: 1. [Checkpoint 1.1] Task checkpoint is done. Send to storage
2025-12-12T12:27:31.071709Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Sink 0: sent 0 bytes of data and 6 bytes of checkpoint barrier
2025-12-12T12:27:31.071711Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-12T12:27:31.071713Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:460: [ptqudq7uembs22j8723s-0] [1:1] Got TEvSaveTaskState: task 1
2025-12-12T12:27:31.071722Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Poll inputs
2025-12-12T12:27:31.071723Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Poll sources
2025-12-12T12:27:31.071727Z :KQP_COMPUTE TRACE: dq_pq_rd_read_actor.cpp:767: SelfId: [0:0:0], TxId: ptqudq7uembs22j8723s, task: 1. PQ source. GetAsyncInputData freeSpace = 1000000
2025-12-12T12:27:31.071733Z :KQP_COMPUTE DEBUG: dq_pq_rd_read_actor.cpp:1515: SelfId: [1:7582947087457045903:2147], TxId: ptqudq7uembs22j8723s, task: 1, Cluster: . PQ source. Switch to single-cluster mode
2025-12-12T12:27:31.071736Z :KQP_COMPUTE INFO: dq_pq_rd_read_actor.cpp:608: SelfId: [1:7582947087457045903:2147], TxId: ptqudq7uembs22j8723s, task: 1, Cluster: . PQ source. Send TEvCoordinatorChangesSubscribe to local RD ([0:5788050504107380562:5260383])
2025-12-12T12:27:31.071746Z :KQP_COMPUTE INFO: dq_pq_rd_read_actor.cpp:635: SelfId: [1:7582947087457045903:2147], TxId: ptqudq7uembs22j8723s, task: 1, Cluster: . PQ source. Send TEvCoordinatorChangesSubscribe to local row dispatcher, self id [1:7582947087457045903:2147]
2025-12-12T12:27:31.071751Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:81: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Poll async input 0. Buffer free space: 1000000, read from async input: 0 bytes, 0 rows, finished: 0
2025-12-12T12:27:31.071766Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-12-12T12:27:31.071781Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:637: RowDispatcher: TEvCoordinatorChangesSubscribe from [1:7582947087457045903:2147]
2025-12-12T12:27:31.071813Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:637: RowDispatcher: TEvCoordinatorChangesSubscribe from [1:7582947087457045903:2147]
2025-12-12T12:27:31.071830Z :KQP_COMPUTE DEBUG: dq_pq_rd_read_actor.cpp:1009: SelfId: [1:7582947087457045903:2147], TxId: ptqudq7uembs22j8723s, task: 1, Cluster: . PQ source. TEvCoordinatorChanged, new coordinator [1:7582947031622470849:2092]
2025-12-12T12:27:31.071837Z :KQP_COMPUTE INFO: dq_pq_rd_read_actor.cpp:655: SelfId: [1:7582947087457045903:2147], TxId: ptqudq7uembs22j8723s, task: 1, Cluster: . PQ source. Send TEvCoordinatorRequest to coordinator [1:7582947031622470849:2092], partIds: 0 cookie 1
2025-12-12T12:27:31.071861Z :KQP_COMPUTE DEBUG: dq_pq_rd_read_actor.cpp:1009: SelfId: [1:7582947087457045903:2147], TxId: ptqudq7uembs22j8723s, task: 1, Cluster: . PQ source. TEvCoordinatorChanged, new coordinator [1:7582947031622470849:2092]
2025-12-12T12:27:31.071875Z :FQ_ROW_DISPATCHER INFO: coordinator.cpp:507: Coordinator: TEvCoordinatorRequest from [1:7582947087457045903:2147], test_read_raw_format_with_row_dispatcher_input, partIds: 0
2025-12-12T12:27:31.071916Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:562: Coordinator: Send TEvCoordinatorResult to [1:7582947087457045903:2147]
2025-12-12T12:27:31.071944Z :KQP_COMPUTE INFO: dq_pq_rd_read_actor.cpp:1053: SelfId: [1:7582947087457045903:2147], TxId: ptqudq7uembs22j8723s, task: 1, Cluster: . PQ source. Received TEvCoordinatorResult from [1:7582947031622470849:2092], cookie 1
2025-12-12T12:27:31.071954Z :KQP_COMPUTE INFO: dq_pq_rd_read_actor.cpp:1352: SelfId: [1:7582947087457045903:2147], TxId: ptqudq7uembs22j8723s, task: 1, Cluster: . PQ source. UpdateSessions, Sessions size 0
2025-12-12T12:27:31.071956Z :KQP_COMPUTE INFO: dq_pq_rd_read_actor.cpp:1355: SelfId: [1:7582947087457045903:2147], TxId: ptqudq7uembs22j8723s, task: 1, Cluster: . PQ source. Distribution is changed, remove sessions
2025-12-12T12:27:31.071964Z :KQP_COMPUTE INFO: dq_pq_rd_read_actor.cpp:1374: SelfId: [1:7582947087457045903:2147], TxId: ptqudq7uembs22j8723s, task: 1, Cluster: . PQ source. Create session to [1:7582947031622470815:2063], generation 1
2025-12-12T12:27:31.071973Z :KQP_COMPUTE INFO: dq_pq_rd_read_actor.cpp:719: SelfId: [1:7582947087457045903:2147], TxId: ptqudq7uembs22j8723s, task: 1, Cluster: . PQ source. Send TEvStartSession to [1:7582947031622470815:2063], connection id 1 partitions offsets (0 / <empty>),
2025-12-12T12:27:31.071997Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:853: RowDispatcher: Received TEvStartSession from [1:7582947087457045903:2147], read group ptcudq7uf16n0fokcj2e, topicPath test_read_raw_format_with_row_dispatcher_input part id 0 query id ptqudq7uembs22j8723s cookie 1
2025-12-12T12:27:31.072035Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:892: RowDispatcher: Create new session: read group ptcudq7uf16n0fokcj2e topic test_read_raw_format_with_row_dispatcher_input part id 0
2025-12-12T12:27:31.072096Z :KQP_COMPUTE INFO: dq_pq_rd_read_actor.cpp:864: SelfId: [1:7582947087457045903:2147], TxId: ptqudq7uembs22j8723s, task: 1, Cluster: . PQ source. Received TEvStartSessionAck from [1:7582947031622470815:2063], seqNo 0, ConfirmedSeqNo 0, generation 1
2025-12-12T12:27:31.072115Z :FQ_ROW_DISPATCHER DEBUG: topic_session.cpp:443: TopicSession [1:7582947087457045905:2148] Bootstrap test_read_raw_format_with_row_dispatcher_input/0, Timeout 5.000000s sec
2025-12-12T12:27:31.072121Z :FQ_ROW_DISPATCHER INFO: topic_session.cpp:799: TopicSession [1:7582947087457045905:2148] New client: read actor id [1:7582947087457045903:2147], predicate: (`data` <> "romashka"), watermark expr: , offset: (empty maybe)
2025-12-12T12:27:31.072164Z :FQ_ROW_DISPATCHER DEBUG: format_handler.cpp:440: TTopicFormatHandler [raw]: Add client with id [1:7582947087457045903:2147]
2025-12-12T12:27:31.072326Z :FQ_ROW_DISPATCHER DEBUG: format_handler.cpp:559: TTopicFormatHandler [raw]: UpdateParser to new schema with size 1
2025-12-12T12:27:31.072361Z :FQ_ROW_DISPATCHER DEBUG: format_handler.cpp:570: TTopicFormatHandler [raw]: Parser was created on schema with 1 columns
2025-12-12T12:27:31.072374Z :FQ_ROW_DISPATCHER DEBUG: purecalc_filter.cpp:461: GenerateSql: Generated sql:

            PRAGMA config.flags("LLVM", "OFF");
            SELECT COALESCE((`data` <> "romashka"), FALSE) AS _filter, _offset FROM Input;
        
2025-12-12T12:27:31.072388Z :FQ_ROW_DISPATCHER TRACE: filters_set.cpp:116: TTopicFilters: Create program with client id [1:7582947087457045903:2147]
2025-12-12T12:27:31.072397Z :FQ_ROW_DISPATCHER TRACE: filters_set.cpp:123: TTopicFilters: Create purecalc program for query '
            PRAGMA config.flags("LLVM", "OFF");
            SELECT COALESCE((`data` <> "romashka"), FALSE) AS _filter, _offset FROM Input;
        ' (client id: [1:7582947087457045903:2147])
2025-12-12T12:27:31.072405Z :FQ_ROW_DISPATCHER TRACE: purecalc_filter.cpp:341: TProgramCompileHandler: Send compile request with id 1
2025-12-12T12:27:31.072417Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:952: TopicSession [1:7582947087457045905:2148] SendStatistics
2025-12-12T12:27:31.072435Z :FQ_ROW_DISPATCHER TRACE: compile_service.cpp:131: TPurecalcCompileService: Add to compile queue request with id 1 from [1:7582947087457045906:2148]
2025-12-12T12:27:31.072437Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1234: RowDispatcher: TEvSessionStatistic from [1:7582947087457045905:2148]
2025-12-12T12:27:31.072700Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1165: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. CPU quota delay: 1ms
2025-12-12T12:27:31.072735Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:27:31.072716Z :INFO: [local] OnFederationDiscovery fall back to single mode, database=local
2025-12-12T12:27:31.072744Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. update task runner stats
2025-12-12T12:27:31.072772Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-12T12:27:31.072780Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:27:31.072783Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-12T12:27:31.072791Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [1:7582947087457045904:2147], TxId: ptqudq7uembs22j8723s, TaskId: 1, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-12-12T12:27:31.072797Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-12-12T12:27:31.072799Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-12T12:27:31.072891Z :YDB_SDK INFO: actor.cpp:37: [] [] Start federated write session to database '' (previous was <empty>) FederationState: { Status: SUCCESS SelfLocation: "" DbInfos: [ { path: "local" endpoint: "localhost:4719" status: AVAILABLE weight: 100 } ] ControlPlaneEndpoint: localhost:4719 }
2025-12-12T12:27:31.072972Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:31.072957Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uembs22j8723s, TaskId: 1, PQ sink. ]  SessionId []  MessageGroupId [6f8fb322-8654a169-31a0708b-41019f17] Write session: try to update token
2025-12-12T12:27:31.073282Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:27:31.073277Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uembs22j8723s, TaskId: 1, PQ sink. ]  SessionId []  MessageGroupId [6f8fb322-8654a169-31a0708b-41019f17] Start write session. Will connect to nodeId: 0
2025-12-12T12:27:31.073503Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:31.073497Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uembs22j8723s, TaskId: 1, PQ sink. ]  SessionId []  MessageGroupId [6f8fb322-8654a169-31a0708b-41019f17] Write session: write to message_group: 6f8fb322-8654a169-31a0708b-41019f17
2025-12-12T12:27:31.073534Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:31.073532Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uembs22j8723s, TaskId: 1, PQ sink. ]  SessionId []  MessageGroupId [6f8fb322-8654a169-31a0708b-41019f17] Write session: send init request: init_request { path: "test_read_raw_format_with_row_dispatcher_output" producer_id: "6f8fb322-8654a169-31a0708b-41019f17" message_group_id: "6f8fb322-8654a169-31a0708b-41019f17" }
2025-12-12T12:27:31.073543Z :YDB_SDK TRACE: actor.cpp:37: 2025-12-12T12:27:31.073541Z :TRACE: [local] TRACE_EVENT InitRequest 
2025-12-12T12:27:31.073649Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:31.073646Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uembs22j8723s, TaskId: 1, PQ sink. ]  SessionId []  MessageGroupId [6f8fb322-8654a169-31a0708b-41019f17] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T12:27:31.076357Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:484: [ptqudq7uembs22j8723s-0] [1:1] TEvSaveTaskState Apply: task: 1
2025-12-12T12:27:31.076370Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:499: [ptqudq7uembs22j8723s-0] [1:1] Send TEvSaveTaskStateResult: task: 1
2025-12-12T12:27:31.078941Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:31.078922Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uembs22j8723s, TaskId: 1, PQ sink. ]  SessionId []  MessageGroupId [6f8fb322-8654a169-31a0708b-41019f17] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T12:27:31.078967Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:27:31.078962Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uembs22j8723s, TaskId: 1, PQ sink. ]  SessionId []  MessageGroupId [6f8fb322-8654a169-31a0708b-41019f17] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1765542451078 BytesWritten: 0 MessagesWritten: 0 BytesWrittenCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:27:31.078987Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:27:31.078985Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uembs22j8723s, TaskId: 1, PQ sink. ]  SessionId []  MessageGroupId [6f8fb322-8654a169-31a0708b-41019f17] Write session established. Init response: session_id: "6f8fb322-8654a169-31a0708b-41019f17|17386e2-f0c43c11-fa76df04-c297a41e_0"
2025-12-12T12:27:31.078994Z :YDB_SDK TRACE: actor.cpp:37: 2025-12-12T12:27:31.078992Z :TRACE: [local] TRACE_EVENT InitResponse  partition_id=0 session_id=6f8fb322-8654a169-31a0708b-41019f17|17386e2-f0c43c11-fa76df04-c297a41e_0
2025-12-12T12:27:31.078997Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:31.078996Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uembs22j8723s, TaskId: 1, PQ sink. ]  SessionId [6f8fb322-8654a169-31a0708b-41019f17|17386e2-f0c43c11-fa76df04-c297a41e_0]  MessageGroupId [6f8fb322-8654a169-31a0708b-41019f17] Write session: set DirectWriteToPartitionId 0
2025-12-12T12:27:31.079077Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:27:31.079072Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uembs22j8723s, TaskId: 1, PQ sink. ]  SessionId [6f8fb322-8654a169-31a0708b-41019f17|17386e2-f0c43c11-fa76df04-c297a41e_0]  PartitionId [0]  Generation [0] Get partition location async, partition 0, delay 0.000000s
2025-12-12T12:27:31.079097Z :YDB_SDK TRACE: actor.cpp:37: 2025-12-12T12:27:31.079094Z :TRACE: [local] TRACE_EVENT DescribePartitionRequest  path=local/test_read_raw_format_with_row_dispatcher_output partition_id=0
2025-12-12T12:27:31.079671Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:31.079662Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uembs22j8723s, TaskId: 1, PQ sink. ]  SessionId [6f8fb322-8654a169-31a0708b-41019f17|17386e2-f0c43c11-fa76df04-c297a41e_0]  PartitionId [0]  Generation [0]  Getting partition location, partition 0
2025-12-12T12:27:31.080943Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:27:31.080935Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uembs22j8723s, TaskId: 1, PQ sink. ]  SessionId [6f8fb322-8654a169-31a0708b-41019f17|17386e2-f0c43c11-fa76df04-c297a41e_0]  PartitionId [0]  Generation [0] Got PartitionLocation response. Status SUCCESS, proto:
partition {
  active: true
  partition_location {
    node_id: 1
    generation: 1
  }
}

2025-12-12T12:27:31.080956Z :YDB_SDK TRACE: actor.cpp:37: 2025-12-12T12:27:31.080954Z :TRACE: [local] TRACE_EVENT DescribePartitionResponse  partition_id=0 active=1 pl_node_id=1 pl_generation=1
2025-12-12T12:27:31.080964Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:31.080961Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uembs22j8723s, TaskId: 1, PQ sink. ]  SessionId [6f8fb322-8654a169-31a0708b-41019f17|17386e2-f0c43c11-fa76df04-c297a41e_0]  PartitionId [0]  Generation [0] GetPreferredEndpoint: partitionId 0, partitionNodeId 1 exists in the endpoint pool.
2025-12-12T12:27:31.080970Z :YDB_SDK TRACE: actor.cpp:37: 2025-12-12T12:27:31.080968Z :TRACE: [local] TRACE_EVENT PreferredPartitionLocation  Endpoint= NodeId=1 Generation=1
2025-12-12T12:27:31.080976Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:27:31.080974Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uembs22j8723s, TaskId: 1, PQ sink. ]  SessionId [6f8fb322-8654a169-31a0708b-41019f17|17386e2-f0c43c11-fa76df04-c297a41e_0]  PartitionId [0]  Generation [1] Start write session. Will connect to nodeId: 1
2025-12-12T12:27:31.081257Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:31.081251Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uembs22j8723s, TaskId: 1, PQ sink. ]  SessionId [6f8fb322-8654a169-31a0708b-41019f17|17386e2-f0c43c11-fa76df04-c297a41e_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 1, Msg: CANCELLED, Details: , InternalError: 0
2025-12-12T12:27:31.081357Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:31.081354Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uembs22j8723s, TaskId: 1, PQ sink. ]  SessionId [6f8fb322-8654a169-31a0708b-41019f17|17386e2-f0c43c11-fa76df04-c297a41e_0]  PartitionId [0]  Generation [1] Write session: direct write to partition: 0, generation 1
2025-12-12T12:27:31.081396Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:31.081394Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uembs22j8723s, TaskId: 1, PQ sink. ]  SessionId [6f8fb322-8654a169-31a0708b-41019f17|17386e2-f0c43c11-fa76df04-c297a41e_0]  PartitionId [0]  Generation [1] Write session: send init request: init_request { path: "test_read_raw_format_with_row_dispatcher_output" producer_id: "6f8fb322-8654a169-31a0708b-41019f17" partition_with_generation { generation: 1 } }
2025-12-12T12:27:31.081406Z :YDB_SDK TRACE: actor.cpp:37: 2025-12-12T12:27:31.081404Z :TRACE: [local] TRACE_EVENT InitRequest  pwg_partition_id=0 pwg_generation=1
2025-12-12T12:27:31.081501Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:31.081499Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uembs22j8723s, TaskId: 1, PQ sink. ]  SessionId [6f8fb322-8654a169-31a0708b-41019f17|17386e2-f0c43c11-fa76df04-c297a41e_0]  PartitionId [0]  Generation [1] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T12:27:31.088044Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:31.088034Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uembs22j8723s, TaskId: 1, PQ sink. ]  SessionId [6f8fb322-8654a169-31a0708b-41019f17|17386e2-f0c43c11-fa76df04-c297a41e_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T12:27:31.088089Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:27:31.088086Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uembs22j8723s, TaskId: 1, PQ sink. ]  SessionId [6f8fb322-8654a169-31a0708b-41019f17|17386e2-f0c43c11-fa76df04-c297a41e_0]  PartitionId [0]  Generation [1] Write session established. Init response: session_id: "6f8fb322-8654a169-31a0708b-41019f17|831a94f0-462e3c89-4433deda-3743e242_0"
2025-12-12T12:27:31.088095Z :YDB_SDK TRACE: actor.cpp:37: 2025-12-12T12:27:31.088093Z :TRACE: [local] TRACE_EVENT InitResponse  partition_id=0 session_id=6f8fb322-8654a169-31a0708b-41019f17|831a94f0-462e3c89-4433deda-3743e242_0
2025-12-12T12:27:31.088099Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:31.088097Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uembs22j8723s, TaskId: 1, PQ sink. ]  SessionId [6f8fb322-8654a169-31a0708b-41019f17|831a94f0-462e3c89-4433deda-3743e242_0]  PartitionId [0]  Generation [1] Write session: set DirectWriteToPartitionId 0
2025-12-12T12:27:31.099306Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:759: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Commit state
2025-12-12T12:27:31.377555Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [3:7582947035351577334:2063]
2025-12-12T12:27:31.377572Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [3:7582947035351577334:2063]
2025-12-12T12:27:31.377575Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [3:7582947035351577334:2063]
2025-12-12T12:27:31.383384Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: f992d040-c9567214-5bb9b6cb-b474938414, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:31.389275Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:31.389289Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:31.459197Z :FQ_ROW_DISPATCHER TRACE: compile_service.cpp:52: TPurecalcCompileActor [1:7582947087457045906:2148] [id 1]: Started compile request
2025-12-12T12:27:31.508528Z :FQ_ROW_DISPATCHER TRACE: compile_service.cpp:70: TPurecalcCompileActor [1:7582947087457045906:2148] [id 1]: Compilation completed for request
2025-12-12T12:27:31.508579Z :FQ_ROW_DISPATCHER TRACE: filters_set.cpp:57: TTopicFilters: Got compile response for request with id 1
2025-12-12T12:27:31.508588Z :FQ_ROW_DISPATCHER TRACE: purecalc_filter.cpp:370: TProgramCompileHandler: Program compilation finished
2025-12-12T12:27:31.508595Z :FQ_ROW_DISPATCHER TRACE: compile_service.cpp:151: TPurecalcCompileService: Compile finished for request with id 1 from [1:7582947087457045906:2148]
2025-12-12T12:27:31.508599Z :FQ_ROW_DISPATCHER TRACE: filters_set.cpp:110: TTopicFilters: Start program with client id [1:7582947087457045903:2147]
2025-12-12T12:27:32.068464Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:239: [ptqudq7uembs22j8723s-0] Task: 1. [Checkpoint 1.2] TEvInjectCheckpoint
2025-12-12T12:27:32.068485Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Poll inputs
2025-12-12T12:27:32.068489Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1494: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Skip polling sources because of pending checkpoint
2025-12-12T12:27:32.068492Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. DoExecuteImpl: 1
2025-12-12T12:27:32.068531Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:462: SelfId: [1:7582947087457045901:2147], TxId: ptqudq7uembs22j8723s, task: 1. Pending 1 checkpoints to be sent
2025-12-12T12:27:32.068552Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. update task runner stats
2025-12-12T12:27:32.068590Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 1 watermark injected: (empty maybe)
2025-12-12T12:27:32.068598Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:447: [ptqudq7uembs22j8723s-0] Task: 1. [Checkpoint 1.2] Performing task checkpoint
2025-12-12T12:27:32.068601Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:816: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Save state
2025-12-12T12:27:32.068608Z :KQP_COMPUTE DEBUG: dq_pq_read_actor_base.cpp:94: SelfId: [1:7582947087457045903:2147], TxId: ptqudq7uembs22j8723s, task: 1, Cluster: . PQ source. SessionId: empty SaveState, offsets: 
2025-12-12T12:27:32.068616Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:474: [ptqudq7uembs22j8723s-0] Task: 1. [Checkpoint 1.2] CA state saved
2025-12-12T12:27:32.068622Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:449: [ptqudq7uembs22j8723s-0] Task: 1. [Checkpoint 1.2] Injecting checkpoint barrier to outputs
2025-12-12T12:27:32.068626Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:27:32.068632Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-12T12:27:32.068640Z :KQP_COMPUTE INFO: dq_async_compute_actor.cpp:1010: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Resume inputs
2025-12-12T12:27:32.068644Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [1:7582947087457045904:2147], TxId: ptqudq7uembs22j8723s, TaskId: 1, PQ sink. SendData. Batch: 0. Checkpoint: 1. Finished: 0
2025-12-12T12:27:32.068655Z :KQP_COMPUTE DEBUG: dq_pq_write_actor.cpp:240: SelfId: [1:7582947087457045904:2147], TxId: ptqudq7uembs22j8723s, TaskId: 1, PQ sink. [Checkpoint 1.2] Send checkpoint state immediately
2025-12-12T12:27:32.068676Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:418: SelfId: [1:7582947087457045904:2147], TxId: ptqudq7uembs22j8723s, TaskId: 1, PQ sink. Save checkpoint { Id: 2 Generation: 1 Type: CHECKPOINT_TYPE_SNAPSHOT } state: { SourceId: "6f8fb322-8654a169-31a0708b-41019f17" }
2025-12-12T12:27:32.068680Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:524: [ptqudq7uembs22j8723s-0] Task: 1. Sink[0] state saved
2025-12-12T12:27:32.068691Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:536: [ptqudq7uembs22j8723s-0] Task: 1. [Checkpoint 1.2] Task checkpoint is done. Send to storage
2025-12-12T12:27:32.068700Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Sink 0: sent 0 bytes of data and 6 bytes of checkpoint barrier
2025-12-12T12:27:32.068703Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-12T12:27:32.068706Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Poll inputs
2025-12-12T12:27:32.068708Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Poll sources
2025-12-12T12:27:32.068711Z :KQP_COMPUTE TRACE: dq_pq_rd_read_actor.cpp:767: SelfId: [1:7582947087457045903:2147], TxId: ptqudq7uembs22j8723s, task: 1, Cluster: . PQ source. GetAsyncInputData freeSpace = 1000000
2025-12-12T12:27:32.068714Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:460: [ptqudq7uembs22j8723s-0] [1:2] Got TEvSaveTaskState: task 1
2025-12-12T12:27:32.068716Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:81: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Poll async input 0. Buffer free space: 1000000, read from async input: 0 bytes, 0 rows, finished: 0
2025-12-12T12:27:32.068725Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-12-12T12:27:32.068733Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. update task runner stats
2025-12-12T12:27:32.068741Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-12T12:27:32.068742Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:27:32.068744Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-12T12:27:32.068748Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [1:7582947087457045904:2147], TxId: ptqudq7uembs22j8723s, TaskId: 1, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-12-12T12:27:32.068750Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-12-12T12:27:32.068752Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-12T12:27:32.071728Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:484: [ptqudq7uembs22j8723s-0] [1:2] TEvSaveTaskState Apply: task: 1
2025-12-12T12:27:32.071738Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:499: [ptqudq7uembs22j8723s-0] [1:2] Send TEvSaveTaskStateResult: task: 1
2025-12-12T12:27:32.094473Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:759: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Commit state
2025-12-12T12:27:32.372590Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582947031622470849:2092]
2025-12-12T12:27:32.372601Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:32.372608Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582947031622470815:2063]
2025-12-12T12:27:32.372613Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582947031622470815:2063]
2025-12-12T12:27:32.372617Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582947031622470815:2063]
2025-12-12T12:27:32.372623Z :KQP_COMPUTE TRACE: dq_pq_rd_read_actor.cpp:890: SelfId: [1:7582947087457045903:2147], TxId: ptqudq7uembs22j8723s, task: 1, Cluster: . PQ source. Received TEvStatistics from [1:7582947031622470815:2063], seqNo 0, ConfirmedSeqNo 0 generation 1
2025-12-12T12:27:32.372625Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:32.383851Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: f992d040-c9567214-5bb9b6cb-b474938415, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:32.389108Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:32.389126Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:32.914187Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [2:7582947034081920562:2063]
2025-12-12T12:27:32.914210Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [2:7582947034081920562:2063]
2025-12-12T12:27:32.914213Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [2:7582947034081920562:2063]
2025-12-12T12:27:33.069022Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:239: [ptqudq7uembs22j8723s-0] Task: 1. [Checkpoint 1.3] TEvInjectCheckpoint
2025-12-12T12:27:33.069040Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Poll inputs
2025-12-12T12:27:33.069043Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1494: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Skip polling sources because of pending checkpoint
2025-12-12T12:27:33.069046Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. DoExecuteImpl: 1
2025-12-12T12:27:33.069096Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:462: SelfId: [1:7582947087457045901:2147], TxId: ptqudq7uembs22j8723s, task: 1. Pending 1 checkpoints to be sent
2025-12-12T12:27:33.069109Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. update task runner stats
2025-12-12T12:27:33.069149Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 1 watermark injected: (empty maybe)
2025-12-12T12:27:33.069152Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:447: [ptqudq7uembs22j8723s-0] Task: 1. [Checkpoint 1.3] Performing task checkpoint
2025-12-12T12:27:33.069154Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:816: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Save state
2025-12-12T12:27:33.069163Z :KQP_COMPUTE DEBUG: dq_pq_read_actor_base.cpp:94: SelfId: [1:7582947087457045903:2147], TxId: ptqudq7uembs22j8723s, task: 1, Cluster: . PQ source. SessionId: empty SaveState, offsets: 
2025-12-12T12:27:33.069171Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:474: [ptqudq7uembs22j8723s-0] Task: 1. [Checkpoint 1.3] CA state saved
2025-12-12T12:27:33.069173Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:449: [ptqudq7uembs22j8723s-0] Task: 1. [Checkpoint 1.3] Injecting checkpoint barrier to outputs
2025-12-12T12:27:33.069176Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:27:33.069193Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-12T12:27:33.069202Z :KQP_COMPUTE INFO: dq_async_compute_actor.cpp:1010: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Resume inputs
2025-12-12T12:27:33.069204Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [1:7582947087457045904:2147], TxId: ptqudq7uembs22j8723s, TaskId: 1, PQ sink. SendData. Batch: 0. Checkpoint: 1. Finished: 0
2025-12-12T12:27:33.069207Z :KQP_COMPUTE DEBUG: dq_pq_write_actor.cpp:240: SelfId: [1:7582947087457045904:2147], TxId: ptqudq7uembs22j8723s, TaskId: 1, PQ sink. [Checkpoint 1.3] Send checkpoint state immediately
2025-12-12T12:27:33.069237Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:418: SelfId: [1:7582947087457045904:2147], TxId: ptqudq7uembs22j8723s, TaskId: 1, PQ sink. Save checkpoint { Id: 3 Generation: 1 Type: CHECKPOINT_TYPE_SNAPSHOT } state: { SourceId: "6f8fb322-8654a169-31a0708b-41019f17" }
2025-12-12T12:27:33.069241Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:524: [ptqudq7uembs22j8723s-0] Task: 1. Sink[0] state saved
2025-12-12T12:27:33.069256Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:536: [ptqudq7uembs22j8723s-0] Task: 1. [Checkpoint 1.3] Task checkpoint is done. Send to storage
2025-12-12T12:27:33.069280Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Sink 0: sent 0 bytes of data and 6 bytes of checkpoint barrier
2025-12-12T12:27:33.069282Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-12T12:27:33.069286Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Poll inputs
2025-12-12T12:27:33.069288Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Poll sources
2025-12-12T12:27:33.069289Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:460: [ptqudq7uembs22j8723s-0] [1:3] Got TEvSaveTaskState: task 1
2025-12-12T12:27:33.069292Z :KQP_COMPUTE TRACE: dq_pq_rd_read_actor.cpp:767: SelfId: [1:7582947087457045903:2147], TxId: ptqudq7uembs22j8723s, task: 1, Cluster: . PQ source. GetAsyncInputData freeSpace = 1000000
2025-12-12T12:27:33.069297Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:81: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Poll async input 0. Buffer free space: 1000000, read from async input: 0 bytes, 0 rows, finished: 0
2025-12-12T12:27:33.069306Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-12-12T12:27:33.069314Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. update task runner stats
2025-12-12T12:27:33.069323Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-12T12:27:33.069324Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:27:33.069326Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-12T12:27:33.069329Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [1:7582947087457045904:2147], TxId: ptqudq7uembs22j8723s, TaskId: 1, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-12-12T12:27:33.069331Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-12-12T12:27:33.069332Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-12T12:27:33.072236Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:484: [ptqudq7uembs22j8723s-0] [1:3] TEvSaveTaskState Apply: task: 1
2025-12-12T12:27:33.072251Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:499: [ptqudq7uembs22j8723s-0] [1:3] Send TEvSaveTaskStateResult: task: 1
2025-12-12T12:27:33.072974Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:952: TopicSession [1:7582947087457045905:2148] SendStatistics
2025-12-12T12:27:33.073016Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1234: RowDispatcher: TEvSessionStatistic from [1:7582947087457045905:2148]
2025-12-12T12:27:33.092348Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:759: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Commit state
2025-12-12T12:27:33.376094Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-12-12T12:27:33.378415Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [3:7582947035351577334:2063]
2025-12-12T12:27:33.378428Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [3:7582947035351577334:2063]
2025-12-12T12:27:33.378431Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [3:7582947035351577334:2063]
2025-12-12T12:27:33.384317Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: f992d040-c9567214-5bb9b6cb-b474938416, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:33.386583Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:389: Send NodeInfo with size: 2 to DynamicNameserver
2025-12-12T12:27:33.387813Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:33.387820Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:34.071337Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:239: [ptqudq7uembs22j8723s-0] Task: 1. [Checkpoint 1.4] TEvInjectCheckpoint
2025-12-12T12:27:34.071356Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Poll inputs
2025-12-12T12:27:34.071358Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1494: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Skip polling sources because of pending checkpoint
2025-12-12T12:27:34.071366Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. DoExecuteImpl: 1
2025-12-12T12:27:34.071411Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:462: SelfId: [1:7582947087457045901:2147], TxId: ptqudq7uembs22j8723s, task: 1. Pending 1 checkpoints to be sent
2025-12-12T12:27:34.071419Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. update task runner stats
2025-12-12T12:27:34.071464Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 1 watermark injected: (empty maybe)
2025-12-12T12:27:34.071470Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:447: [ptqudq7uembs22j8723s-0] Task: 1. [Checkpoint 1.4] Performing task checkpoint
2025-12-12T12:27:34.071474Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:816: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Save state
2025-12-12T12:27:34.071479Z :KQP_COMPUTE DEBUG: dq_pq_read_actor_base.cpp:94: SelfId: [1:7582947087457045903:2147], TxId: ptqudq7uembs22j8723s, task: 1, Cluster: . PQ source. SessionId: empty SaveState, offsets: 
2025-12-12T12:27:34.071486Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:474: [ptqudq7uembs22j8723s-0] Task: 1. [Checkpoint 1.4] CA state saved
2025-12-12T12:27:34.071487Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:449: [ptqudq7uembs22j8723s-0] Task: 1. [Checkpoint 1.4] Injecting checkpoint barrier to outputs
2025-12-12T12:27:34.071489Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:27:34.071493Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-12T12:27:34.071499Z :KQP_COMPUTE INFO: dq_async_compute_actor.cpp:1010: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Resume inputs
2025-12-12T12:27:34.071501Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [1:7582947087457045904:2147], TxId: ptqudq7uembs22j8723s, TaskId: 1, PQ sink. SendData. Batch: 0. Checkpoint: 1. Finished: 0
2025-12-12T12:27:34.071504Z :KQP_COMPUTE DEBUG: dq_pq_write_actor.cpp:240: SelfId: [1:7582947087457045904:2147], TxId: ptqudq7uembs22j8723s, TaskId: 1, PQ sink. [Checkpoint 1.4] Send checkpoint state immediately
2025-12-12T12:27:34.071526Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:418: SelfId: [1:7582947087457045904:2147], TxId: ptqudq7uembs22j8723s, TaskId: 1, PQ sink. Save checkpoint { Id: 4 Generation: 1 Type: CHECKPOINT_TYPE_SNAPSHOT } state: { SourceId: "6f8fb322-8654a169-31a0708b-41019f17" }
2025-12-12T12:27:34.071529Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:524: [ptqudq7uembs22j8723s-0] Task: 1. Sink[0] state saved
2025-12-12T12:27:34.071540Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:536: [ptqudq7uembs22j8723s-0] Task: 1. [Checkpoint 1.4] Task checkpoint is done. Send to storage
2025-12-12T12:27:34.071549Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Sink 0: sent 0 bytes of data and 6 bytes of checkpoint barrier
2025-12-12T12:27:34.071554Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-12T12:27:34.071556Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Poll inputs
2025-12-12T12:27:34.071557Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Poll sources
2025-12-12T12:27:34.071558Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:460: [ptqudq7uembs22j8723s-0] [1:4] Got TEvSaveTaskState: task 1
2025-12-12T12:27:34.071560Z :KQP_COMPUTE TRACE: dq_pq_rd_read_actor.cpp:767: SelfId: [1:7582947087457045903:2147], TxId: ptqudq7uembs22j8723s, task: 1, Cluster: . PQ source. GetAsyncInputData freeSpace = 1000000
2025-12-12T12:27:34.071564Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:81: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Poll async input 0. Buffer free space: 1000000, read from async input: 0 bytes, 0 rows, finished: 0
2025-12-12T12:27:34.071571Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-12-12T12:27:34.071579Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. update task runner stats
2025-12-12T12:27:34.071586Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-12T12:27:34.071587Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:27:34.071589Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-12T12:27:34.071592Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [1:7582947087457045904:2147], TxId: ptqudq7uembs22j8723s, TaskId: 1, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-12-12T12:27:34.071594Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-12-12T12:27:34.071595Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-12T12:27:34.074734Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:484: [ptqudq7uembs22j8723s-0] [1:4] TEvSaveTaskState Apply: task: 1
2025-12-12T12:27:34.074751Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:499: [ptqudq7uembs22j8723s-0] [1:4] Send TEvSaveTaskStateResult: task: 1
2025-12-12T12:27:34.100103Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:759: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Commit state
2025-12-12T12:27:34.373621Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582947031622470849:2092]
2025-12-12T12:27:34.373641Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:34.373652Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582947031622470815:2063]
2025-12-12T12:27:34.373658Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582947031622470815:2063]
2025-12-12T12:27:34.373661Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582947031622470815:2063]
2025-12-12T12:27:34.373668Z :KQP_COMPUTE TRACE: dq_pq_rd_read_actor.cpp:890: SelfId: [1:7582947087457045903:2147], TxId: ptqudq7uembs22j8723s, task: 1, Cluster: . PQ source. Received TEvStatistics from [1:7582947031622470815:2063], seqNo 0, ConfirmedSeqNo 0 generation 1
2025-12-12T12:27:34.373669Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:34.384731Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: f992d040-c9567214-5bb9b6cb-b474938417, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:34.388568Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:34.388584Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:34.915166Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [2:7582947034081920562:2063]
2025-12-12T12:27:34.915179Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [2:7582947034081920562:2063]
2025-12-12T12:27:34.915184Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [2:7582947034081920562:2063]
2025-12-12T12:27:35.071151Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:239: [ptqudq7uembs22j8723s-0] Task: 1. [Checkpoint 1.5] TEvInjectCheckpoint
2025-12-12T12:27:35.071176Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Poll inputs
2025-12-12T12:27:35.071179Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1494: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Skip polling sources because of pending checkpoint
2025-12-12T12:27:35.071181Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. DoExecuteImpl: 1
2025-12-12T12:27:35.071222Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:462: SelfId: [1:7582947087457045901:2147], TxId: ptqudq7uembs22j8723s, task: 1. Pending 1 checkpoints to be sent
2025-12-12T12:27:35.071233Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. update task runner stats
2025-12-12T12:27:35.071279Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 1 watermark injected: (empty maybe)
2025-12-12T12:27:35.071286Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:447: [ptqudq7uembs22j8723s-0] Task: 1. [Checkpoint 1.5] Performing task checkpoint
2025-12-12T12:27:35.071289Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:816: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Save state
2025-12-12T12:27:35.071296Z :KQP_COMPUTE DEBUG: dq_pq_read_actor_base.cpp:94: SelfId: [1:7582947087457045903:2147], TxId: ptqudq7uembs22j8723s, task: 1, Cluster: . PQ source. SessionId: empty SaveState, offsets: 
2025-12-12T12:27:35.071304Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:474: [ptqudq7uembs22j8723s-0] Task: 1. [Checkpoint 1.5] CA state saved
2025-12-12T12:27:35.071306Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:449: [ptqudq7uembs22j8723s-0] Task: 1. [Checkpoint 1.5] Injecting checkpoint barrier to outputs
2025-12-12T12:27:35.071309Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:27:35.071314Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-12T12:27:35.071322Z :KQP_COMPUTE INFO: dq_async_compute_actor.cpp:1010: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Resume inputs
2025-12-12T12:27:35.071325Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [1:7582947087457045904:2147], TxId: ptqudq7uembs22j8723s, TaskId: 1, PQ sink. SendData. Batch: 0. Checkpoint: 1. Finished: 0
2025-12-12T12:27:35.071328Z :KQP_COMPUTE DEBUG: dq_pq_write_actor.cpp:240: SelfId: [1:7582947087457045904:2147], TxId: ptqudq7uembs22j8723s, TaskId: 1, PQ sink. [Checkpoint 1.5] Send checkpoint state immediately
2025-12-12T12:27:35.071355Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:418: SelfId: [1:7582947087457045904:2147], TxId: ptqudq7uembs22j8723s, TaskId: 1, PQ sink. Save checkpoint { Id: 5 Generation: 1 Type: CHECKPOINT_TYPE_SNAPSHOT } state: { SourceId: "6f8fb322-8654a169-31a0708b-41019f17" }
2025-12-12T12:27:35.071359Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:524: [ptqudq7uembs22j8723s-0] Task: 1. Sink[0] state saved
2025-12-12T12:27:35.071369Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:536: [ptqudq7uembs22j8723s-0] Task: 1. [Checkpoint 1.5] Task checkpoint is done. Send to storage
2025-12-12T12:27:35.071378Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Sink 0: sent 0 bytes of data and 6 bytes of checkpoint barrier
2025-12-12T12:27:35.071380Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-12T12:27:35.071383Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Poll inputs
2025-12-12T12:27:35.071385Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Poll sources
2025-12-12T12:27:35.071388Z :KQP_COMPUTE TRACE: dq_pq_rd_read_actor.cpp:767: SelfId: [1:7582947087457045903:2147], TxId: ptqudq7uembs22j8723s, task: 1, Cluster: . PQ source. GetAsyncInputData freeSpace = 1000000
2025-12-12T12:27:35.071390Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:460: [ptqudq7uembs22j8723s-0] [1:5] Got TEvSaveTaskState: task 1
2025-12-12T12:27:35.071394Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:81: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Poll async input 0. Buffer free space: 1000000, read from async input: 0 bytes, 0 rows, finished: 0
2025-12-12T12:27:35.071403Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-12-12T12:27:35.071409Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. update task runner stats
2025-12-12T12:27:35.071416Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-12T12:27:35.071417Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:27:35.071418Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-12T12:27:35.071421Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [1:7582947087457045904:2147], TxId: ptqudq7uembs22j8723s, TaskId: 1, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-12-12T12:27:35.071422Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-12-12T12:27:35.071423Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-12T12:27:35.072916Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1067: RowDispatcher: Send TEvHeartbeat to [1:7582947087457045903:2147] query id ptqudq7uembs22j8723s
2025-12-12T12:27:35.072939Z :KQP_COMPUTE TRACE: dq_pq_rd_read_actor.cpp:1003: SelfId: [1:7582947087457045903:2147], TxId: ptqudq7uembs22j8723s, task: 1, Cluster: . PQ source. Received TEvHeartbeat from [1:7582947031622470815:2063], generation 1
2025-12-12T12:27:35.073891Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:952: TopicSession [1:7582947087457045905:2148] SendStatistics
2025-12-12T12:27:35.073921Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1234: RowDispatcher: TEvSessionStatistic from [1:7582947087457045905:2148]
2025-12-12T12:27:35.074207Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:484: [ptqudq7uembs22j8723s-0] [1:5] TEvSaveTaskState Apply: task: 1
2025-12-12T12:27:35.074223Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:499: [ptqudq7uembs22j8723s-0] [1:5] Send TEvSaveTaskStateResult: task: 1
2025-12-12T12:27:35.096205Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:759: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Commit state
2025-12-12T12:27:35.379368Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [3:7582947035351577334:2063]
2025-12-12T12:27:35.379383Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [3:7582947035351577334:2063]
2025-12-12T12:27:35.379386Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [3:7582947035351577334:2063]
2025-12-12T12:27:35.385133Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: f992d040-c9567214-5bb9b6cb-b474938418, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:35.391021Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:35.391035Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:36.077515Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:239: [ptqudq7uembs22j8723s-0] Task: 1. [Checkpoint 1.6] TEvInjectCheckpoint
2025-12-12T12:27:36.077539Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Poll inputs
2025-12-12T12:27:36.077543Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1494: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Skip polling sources because of pending checkpoint
2025-12-12T12:27:36.077547Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. DoExecuteImpl: 1
2025-12-12T12:27:36.077592Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:462: SelfId: [1:7582947087457045901:2147], TxId: ptqudq7uembs22j8723s, task: 1. Pending 1 checkpoints to be sent
2025-12-12T12:27:36.077602Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. update task runner stats
2025-12-12T12:27:36.077653Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 1 watermark injected: (empty maybe)
2025-12-12T12:27:36.077661Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:447: [ptqudq7uembs22j8723s-0] Task: 1. [Checkpoint 1.6] Performing task checkpoint
2025-12-12T12:27:36.077663Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:816: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Save state
2025-12-12T12:27:36.077671Z :KQP_COMPUTE DEBUG: dq_pq_read_actor_base.cpp:94: SelfId: [1:7582947087457045903:2147], TxId: ptqudq7uembs22j8723s, task: 1, Cluster: . PQ source. SessionId: empty SaveState, offsets: 
2025-12-12T12:27:36.077680Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:474: [ptqudq7uembs22j8723s-0] Task: 1. [Checkpoint 1.6] CA state saved
2025-12-12T12:27:36.077682Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:449: [ptqudq7uembs22j8723s-0] Task: 1. [Checkpoint 1.6] Injecting checkpoint barrier to outputs
2025-12-12T12:27:36.077688Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:27:36.077692Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-12T12:27:36.077704Z :KQP_COMPUTE INFO: dq_async_compute_actor.cpp:1010: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Resume inputs
2025-12-12T12:27:36.077707Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [1:7582947087457045904:2147], TxId: ptqudq7uembs22j8723s, TaskId: 1, PQ sink. SendData. Batch: 0. Checkpoint: 1. Finished: 0
2025-12-12T12:27:36.077710Z :KQP_COMPUTE DEBUG: dq_pq_write_actor.cpp:240: SelfId: [1:7582947087457045904:2147], TxId: ptqudq7uembs22j8723s, TaskId: 1, PQ sink. [Checkpoint 1.6] Send checkpoint state immediately
2025-12-12T12:27:36.077757Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:418: SelfId: [1:7582947087457045904:2147], TxId: ptqudq7uembs22j8723s, TaskId: 1, PQ sink. Save checkpoint { Id: 6 Generation: 1 Type: CHECKPOINT_TYPE_SNAPSHOT } state: { SourceId: "6f8fb322-8654a169-31a0708b-41019f17" }
2025-12-12T12:27:36.077765Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:524: [ptqudq7uembs22j8723s-0] Task: 1. Sink[0] state saved
2025-12-12T12:27:36.077779Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:536: [ptqudq7uembs22j8723s-0] Task: 1. [Checkpoint 1.6] Task checkpoint is done. Send to storage
2025-12-12T12:27:36.077787Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Sink 0: sent 0 bytes of data and 6 bytes of checkpoint barrier
2025-12-12T12:27:36.077789Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-12T12:27:36.077793Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Poll inputs
2025-12-12T12:27:36.077795Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Poll sources
2025-12-12T12:27:36.077799Z :KQP_COMPUTE TRACE: dq_pq_rd_read_actor.cpp:767: SelfId: [1:7582947087457045903:2147], TxId: ptqudq7uembs22j8723s, task: 1, Cluster: . PQ source. GetAsyncInputData freeSpace = 1000000
2025-12-12T12:27:36.077800Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:460: [ptqudq7uembs22j8723s-0] [1:6] Got TEvSaveTaskState: task 1
2025-12-12T12:27:36.077803Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:81: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Poll async input 0. Buffer free space: 1000000, read from async input: 0 bytes, 0 rows, finished: 0
2025-12-12T12:27:36.077813Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-12-12T12:27:36.077820Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. update task runner stats
2025-12-12T12:27:36.077829Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-12T12:27:36.077836Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:27:36.077837Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-12T12:27:36.077840Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [1:7582947087457045904:2147], TxId: ptqudq7uembs22j8723s, TaskId: 1, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-12-12T12:27:36.077842Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-12-12T12:27:36.077843Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-12T12:27:36.080783Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:484: [ptqudq7uembs22j8723s-0] [1:6] TEvSaveTaskState Apply: task: 1
2025-12-12T12:27:36.080797Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:499: [ptqudq7uembs22j8723s-0] [1:6] Send TEvSaveTaskStateResult: task: 1
2025-12-12T12:27:36.111259Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:759: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Commit state
2025-12-12T12:27:36.135793Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:453: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Got TEvStateRequest from actor [2:7582947089916495677:2166] PingCookie: 1
2025-12-12T12:27:36.135818Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. update task runner stats
2025-12-12T12:27:36.374365Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582947031622470849:2092]
2025-12-12T12:27:36.374381Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:36.374403Z :KQP_COMPUTE TRACE: dq_pq_rd_read_actor.cpp:890: SelfId: [1:7582947087457045903:2147], TxId: ptqudq7uembs22j8723s, task: 1, Cluster: . PQ source. Received TEvStatistics from [1:7582947031622470815:2063], seqNo 0, ConfirmedSeqNo 0 generation 1
2025-12-12T12:27:36.374403Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582947031622470815:2063]
2025-12-12T12:27:36.374409Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582947031622470815:2063]
2025-12-12T12:27:36.374412Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582947031622470815:2063]
2025-12-12T12:27:36.374425Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:36.385640Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: f992d040-c9567214-5bb9b6cb-b474938419, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:36.393223Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:36.393238Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:36.508528Z :FQ_ROW_DISPATCHER INFO: topic_session.cpp:516: TopicSession [1:7582947087457045905:2148] Create topic session, Path test_read_raw_format_with_row_dispatcher_input/0, StartingMessageTimestamp 2025-12-12T12:27:31.066000Z, BufferSize 16000000, GetConsumerMode Without
2025-12-12T12:27:36.508569Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:27:36.508565Z :INFO: [local] [local] [e8475fda-827e9aaa-e84185bb-7dc814d] Starting read session
2025-12-12T12:27:36.508576Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:36.508573Z :DEBUG: [local] [local] [e8475fda-827e9aaa-e84185bb-7dc814d] Starting single session
2025-12-12T12:27:36.508639Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:36.508637Z :DEBUG: [local] [local] [e8475fda-827e9aaa-e84185bb-7dc814d] [] In Reconnect, ReadSizeBudget = 8000000, ReadSizeServerDelta = 0
2025-12-12T12:27:36.508646Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:36.508645Z :DEBUG: [local] [local] [e8475fda-827e9aaa-e84185bb-7dc814d] [] New values: ReadSizeBudget = 8000000, ReadSizeServerDelta = 0
2025-12-12T12:27:36.508652Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:36.508650Z :DEBUG: [local] [local] [e8475fda-827e9aaa-e84185bb-7dc814d] [] Reconnecting session to cluster  in 0.000000s
2025-12-12T12:27:36.508828Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:466: TopicSession [1:7582947087457045905:2148] SubscribeOnNextEvent
2025-12-12T12:27:36.508865Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:36.508862Z :DEBUG: [local] [local] [e8475fda-827e9aaa-e84185bb-7dc814d] [] Successfully connected. Initializing session
2025-12-12T12:27:36.510155Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:27:36.510149Z :INFO: [local] [local] [e8475fda-827e9aaa-e84185bb-7dc814d] [] Got InitResponse. ReadSessionId: _1_6_17652368773500330696_v1
2025-12-12T12:27:36.510172Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:36.510169Z :DEBUG: [local] [local] [e8475fda-827e9aaa-e84185bb-7dc814d] [] In ContinueReadingDataImpl, ReadSizeBudget = 8000000, ReadSizeServerDelta = 0
2025-12-12T12:27:36.510257Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:36.510254Z :DEBUG: [local] [local] [e8475fda-827e9aaa-e84185bb-7dc814d] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 8000000
2025-12-12T12:27:36.511574Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:559: TopicSession [1:7582947087457045905:2148] TEvPqEventsReady
2025-12-12T12:27:36.511604Z :FQ_ROW_DISPATCHER DEBUG: topic_session.cpp:677: TopicSession [1:7582947087457045905:2148] StartPartitionSessionEvent received
2025-12-12T12:27:36.511609Z :FQ_ROW_DISPATCHER DEBUG: topic_session.cpp:685: TopicSession [1:7582947087457045905:2148] Confirm StartPartitionSession with offset (NULL)
2025-12-12T12:27:36.511626Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:27:36.511619Z :INFO: [local] [local] [e8475fda-827e9aaa-e84185bb-7dc814d] [] Confirm partition stream create. Partition stream id: 1. Cluster: "-". Topic: "test_read_raw_format_with_row_dispatcher_input". Partition: 0. Read offset: (NULL)
2025-12-12T12:27:36.511676Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:466: TopicSession [1:7582947087457045905:2148] SubscribeOnNextEvent
2025-12-12T12:27:36.512289Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:36.512284Z :DEBUG: [local] [local] [e8475fda-827e9aaa-e84185bb-7dc814d] [] Got ReadResponse, serverBytesSize = 102, now ReadSizeBudget = 0, ReadSizeServerDelta = 7999898
2025-12-12T12:27:36.512313Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:36.512311Z :DEBUG: [local] [local] [e8475fda-827e9aaa-e84185bb-7dc814d] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 7999898
2025-12-12T12:27:36.512368Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:36.512364Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (2-3)
2025-12-12T12:27:36.512374Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:36.512372Z :DEBUG: [local] [local] [e8475fda-827e9aaa-e84185bb-7dc814d] [] Returning serverBytesSize = 102 to budget
2025-12-12T12:27:36.512378Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:36.512376Z :DEBUG: [local] [local] [e8475fda-827e9aaa-e84185bb-7dc814d] [] In ContinueReadingDataImpl, ReadSizeBudget = 102, ReadSizeServerDelta = 7999898
2025-12-12T12:27:36.512404Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:36.512402Z :DEBUG: [local] [local] [e8475fda-827e9aaa-e84185bb-7dc814d] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 8000000
2025-12-12T12:27:36.512548Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:559: TopicSession [1:7582947087457045905:2148] TEvPqEventsReady
2025-12-12T12:27:36.512562Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:36.512559Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (2-2)
2025-12-12T12:27:36.512568Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:36.512566Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 1} (3-3)
2025-12-12T12:27:36.512577Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:36.512574Z :DEBUG: [local] [local] [e8475fda-827e9aaa-e84185bb-7dc814d] [] The application data is transferred to the client. Number of messages 2, size 30 bytes
2025-12-12T12:27:36.512583Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:36.512579Z :DEBUG: [local] [local] [e8475fda-827e9aaa-e84185bb-7dc814d] [] Returning serverBytesSize = 0 to budget
2025-12-12T12:27:36.512596Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:654: TopicSession [1:7582947087457045905:2148] Data received: Message { Data: "{"time" = 103;}" Information: { Offset: 2 ProducerId: "" SeqNo: 0 CreateTime: 2025-12-12T12:27:31.642000Z WriteTime: 2025-12-12T12:27:31.641000Z MessageGroupId: "" Meta: { } MessageMeta: { } } Partition session id: 1 Topic: "test_read_raw_format_with_row_dispatcher_input" Partition: 0 }
2025-12-12T12:27:36.512600Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:654: TopicSession [1:7582947087457045905:2148] Data received: Message { Data: "{"time" = 104;}" Information: { Offset: 3 ProducerId: "" SeqNo: 0 CreateTime: 2025-12-12T12:27:31.642000Z WriteTime: 2025-12-12T12:27:31.641000Z MessageGroupId: "" Meta: { } MessageMeta: { } } Partition session id: 1 Topic: "test_read_raw_format_with_row_dispatcher_input" Partition: 0 }
2025-12-12T12:27:36.512602Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:707: TopicSession [1:7582947087457045905:2148] SendToParsing, messages: 2
2025-12-12T12:27:36.512606Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:417: TTopicFormatHandler [raw]: Send 2 messages to parser
2025-12-12T12:27:36.512609Z :FQ_ROW_DISPATCHER TRACE: raw_parser.cpp:56: TRawParser: Add 2 messages to parse
2025-12-12T12:27:36.512625Z :FQ_ROW_DISPATCHER TRACE: raw_parser.cpp:93: TRawParser: Do parsing, first offset: 2, value: {"time" = 103;}
2025-12-12T12:27:36.512644Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:77: TTopicFormatHandler [raw]: TParserHandler: Got parsed data, number rows: 1
2025-12-12T12:27:36.512648Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:614: TTopicFormatHandler [raw]: Send 1 messages to programs, first offset: 2, last offset: 2
2025-12-12T12:27:36.512652Z :FQ_ROW_DISPATCHER TRACE: filters_set.cpp:34: TTopicFilters: ProcessData for 1 clients, number rows: 1
2025-12-12T12:27:36.512658Z :FQ_ROW_DISPATCHER TRACE: filters_set.cpp:223: TTopicFilters: Pass 1 rows to purecalc filter (client id: [1:7582947087457045903:2147])
2025-12-12T12:27:36.512660Z :FQ_ROW_DISPATCHER TRACE: purecalc_filter.cpp:408: TProgramRunHandler: ProcessData for 1 rows
2025-12-12T12:27:36.512715Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:292: TTopicFormatHandler [raw]: TClientHandler [1:7582947087457045903:2147]: OnBatchFinish, offset: 2, number rows: 1, row size: 27, watermark: (empty maybe)
2025-12-12T12:27:36.512717Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:198: TopicSession [1:7582947087457045905:2148] AddDataToClient to [1:7582947087457045903:2147], offset: 2, number rows: 1, row size: 27, watermark: (empty maybe)
2025-12-12T12:27:36.512721Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:936: TopicSession [1:7582947087457045905:2148] Send TEvNewDataArrived to [1:7582947087457045903:2147]
2025-12-12T12:27:36.512739Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:622: TTopicFormatHandler [raw]: Commit client [1:7582947087457045903:2147] offset 2
2025-12-12T12:27:36.512742Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:210: TopicSession [1:7582947087457045905:2148] UpdateClientOffset for [1:7582947087457045903:2147], new offset: 2
2025-12-12T12:27:36.512756Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1081: RowDispatcher: Forward TEvNewDataArrived from [1:7582947087457045905:2148] to [1:7582947087457045903:2147] query id ptqudq7uembs22j8723s
2025-12-12T12:27:36.512757Z :FQ_ROW_DISPATCHER TRACE: raw_parser.cpp:93: TRawParser: Do parsing, first offset: 3, value: {"time" = 104;}
2025-12-12T12:27:36.512759Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:77: TTopicFormatHandler [raw]: TParserHandler: Got parsed data, number rows: 1
2025-12-12T12:27:36.512760Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:614: TTopicFormatHandler [raw]: Send 1 messages to programs, first offset: 3, last offset: 3
2025-12-12T12:27:36.512762Z :FQ_ROW_DISPATCHER TRACE: filters_set.cpp:34: TTopicFilters: ProcessData for 1 clients, number rows: 1
2025-12-12T12:27:36.512764Z :FQ_ROW_DISPATCHER TRACE: filters_set.cpp:223: TTopicFilters: Pass 1 rows to purecalc filter (client id: [1:7582947087457045903:2147])
2025-12-12T12:27:36.512766Z :FQ_ROW_DISPATCHER TRACE: purecalc_filter.cpp:408: TProgramRunHandler: ProcessData for 1 rows
2025-12-12T12:27:36.512772Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:292: TTopicFormatHandler [raw]: TClientHandler [1:7582947087457045903:2147]: OnBatchFinish, offset: 3, number rows: 1, row size: 19, watermark: (empty maybe)
2025-12-12T12:27:36.512775Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:198: TopicSession [1:7582947087457045905:2148] AddDataToClient to [1:7582947087457045903:2147], offset: 3, number rows: 1, row size: 19, watermark: (empty maybe)
2025-12-12T12:27:36.512778Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:622: TTopicFormatHandler [raw]: Commit client [1:7582947087457045903:2147] offset 3
2025-12-12T12:27:36.512780Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:210: TopicSession [1:7582947087457045905:2148] UpdateClientOffset for [1:7582947087457045903:2147], new offset: 3
2025-12-12T12:27:36.512784Z :KQP_COMPUTE TRACE: dq_pq_rd_read_actor.cpp:945: SelfId: [1:7582947087457045903:2147], TxId: ptqudq7uembs22j8723s, task: 1, Cluster: . PQ source. Received TEvNewDataArrived from [1:7582947031622470815:2063], partition 0, seqNo 0, ConfirmedSeqNo 0 generation 1
2025-12-12T12:27:36.512791Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:466: TopicSession [1:7582947087457045905:2148] SubscribeOnNextEvent
2025-12-12T12:27:36.512802Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:940: RowDispatcher: Received TEvGetNextBatch from [1:7582947087457045903:2147] part id 0 query id ptqudq7uembs22j8723s
2025-12-12T12:27:36.512813Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:588: TopicSession [1:7582947087457045905:2148] TEvGetNextBatch from [1:7582947087457045903:2147]
2025-12-12T12:27:36.512817Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:324: TTopicFormatHandler [raw]: TClientHandler [1:7582947087457045903:2147]: FinishPacking, batch size: 46, number rows: 2
2025-12-12T12:27:36.512828Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:174: TTopicFormatHandler [raw]: TClientHandler [1:7582947087457045903:2147]: ExtractClientData, number batches: 1
2025-12-12T12:27:36.512833Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:764: TopicSession [1:7582947087457045905:2148] SendData to [1:7582947087457045903:2147], batch size 1
2025-12-12T12:27:36.512841Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:457: TopicSession [1:7582947087457045905:2148] Skip SubscribeOnNextEvent, has ReadSession: true, IsWaitingEvents: 1
2025-12-12T12:27:36.512847Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1100: RowDispatcher: Forward TEvMessageBatch from [1:7582947087457045905:2148] to [1:7582947087457045903:2147] query id ptqudq7uembs22j8723s
2025-12-12T12:27:36.512870Z :KQP_COMPUTE TRACE: dq_pq_rd_read_actor.cpp:1123: SelfId: [1:7582947087457045903:2147], TxId: ptqudq7uembs22j8723s, task: 1, Cluster: . PQ source. Received TEvMessageBatch from [1:7582947031622470815:2063], seqNo 0, ConfirmedSeqNo 0 generation 1
2025-12-12T12:27:36.512879Z :KQP_COMPUTE TRACE: dq_pq_rd_read_actor.cpp:1171: SelfId: [1:7582947087457045903:2147], TxId: ptqudq7uembs22j8723s, task: 1, Cluster: . PQ source. TEvMessageBatch NextOffset 4
2025-12-12T12:27:36.512897Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Poll inputs
2025-12-12T12:27:36.512900Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Poll sources
2025-12-12T12:27:36.512902Z :KQP_COMPUTE TRACE: dq_pq_rd_read_actor.cpp:767: SelfId: [1:7582947087457045903:2147], TxId: ptqudq7uembs22j8723s, task: 1, Cluster: . PQ source. GetAsyncInputData freeSpace = 1000000
2025-12-12T12:27:36.512945Z :KQP_COMPUTE TRACE: dq_pq_rd_read_actor.cpp:807: SelfId: [1:7582947087457045903:2147], TxId: ptqudq7uembs22j8723s, task: 1, Cluster: . PQ source. NextOffset 4
2025-12-12T12:27:36.512949Z :KQP_COMPUTE TRACE: dq_pq_rd_read_actor.cpp:811: SelfId: [1:7582947087457045903:2147], TxId: ptqudq7uembs22j8723s, task: 1, Cluster: . PQ source. Return 2 rows, watermark (empty maybe), buffer size 0, free space 999954, result size 46
2025-12-12T12:27:36.512952Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:81: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Poll async input 0. Buffer free space: 1000000, read from async input: 46 bytes, 2 rows, finished: 0
2025-12-12T12:27:36.512981Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-12-12T12:27:36.512986Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Poll inputs
2025-12-12T12:27:36.512987Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Poll sources
2025-12-12T12:27:36.512990Z :KQP_COMPUTE TRACE: dq_pq_rd_read_actor.cpp:767: SelfId: [1:7582947087457045903:2147], TxId: ptqudq7uembs22j8723s, task: 1, Cluster: . PQ source. GetAsyncInputData freeSpace = 999954
2025-12-12T12:27:36.512992Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:81: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Poll async input 0. Buffer free space: 999954, read from async input: 0 bytes, 0 rows, finished: 0
2025-12-12T12:27:36.513035Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-12-12T12:27:36.513037Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. update task runner stats
2025-12-12T12:27:36.513079Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-12T12:27:36.513081Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:27:36.513084Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-12T12:27:36.513088Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1107: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Ask CPU quota: 442ms
2025-12-12T12:27:36.513117Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [1:7582947087457045904:2147], TxId: ptqudq7uembs22j8723s, TaskId: 1, PQ sink. SendData. Batch: 2. Checkpoint: 0. Finished: 0
2025-12-12T12:27:36.513119Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:221: SelfId: [1:7582947087457045904:2147], TxId: ptqudq7uembs22j8723s, TaskId: 1, PQ sink. Received data for sending: {"time" = 103;}
2025-12-12T12:27:36.513122Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:221: SelfId: [1:7582947087457045904:2147], TxId: ptqudq7uembs22j8723s, TaskId: 1, PQ sink. Received data for sending: {"time" = 104;}
2025-12-12T12:27:36.513141Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:36.513138Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uembs22j8723s, TaskId: 1, PQ sink. ]  SessionId [6f8fb322-8654a169-31a0708b-41019f17|831a94f0-462e3c89-4433deda-3743e242_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 1 to 1
2025-12-12T12:27:36.513154Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:36.513152Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uembs22j8723s, TaskId: 1, PQ sink. ]  SessionId [6f8fb322-8654a169-31a0708b-41019f17|831a94f0-462e3c89-4433deda-3743e242_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T12:27:36.513159Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:36.513157Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uembs22j8723s, TaskId: 1, PQ sink. ]  SessionId [6f8fb322-8654a169-31a0708b-41019f17|831a94f0-462e3c89-4433deda-3743e242_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 1
2025-12-12T12:27:36.513259Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Sink 0: sent 38 bytes of data and 0 bytes of checkpoint barrier
2025-12-12T12:27:36.513261Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Drain sink 0. Free space decreased: 30, sent data from buffer: 38
2025-12-12T12:27:36.513267Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Poll inputs
2025-12-12T12:27:36.513268Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Poll sources
2025-12-12T12:27:36.513270Z :KQP_COMPUTE TRACE: dq_pq_rd_read_actor.cpp:767: SelfId: [1:7582947087457045903:2147], TxId: ptqudq7uembs22j8723s, task: 1, Cluster: . PQ source. GetAsyncInputData freeSpace = 1000000
2025-12-12T12:27:36.513274Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:81: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Poll async input 0. Buffer free space: 1000000, read from async input: 0 bytes, 0 rows, finished: 0
2025-12-12T12:27:36.513278Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-12-12T12:27:36.513298Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:36.513284Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uembs22j8723s, TaskId: 1, PQ sink. ]  SessionId [6f8fb322-8654a169-31a0708b-41019f17|831a94f0-462e3c89-4433deda-3743e242_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 2 to 2
2025-12-12T12:27:36.513313Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:36.513311Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uembs22j8723s, TaskId: 1, PQ sink. ]  SessionId [6f8fb322-8654a169-31a0708b-41019f17|831a94f0-462e3c89-4433deda-3743e242_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T12:27:36.513318Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:36.513315Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uembs22j8723s, TaskId: 1, PQ sink. ]  SessionId [6f8fb322-8654a169-31a0708b-41019f17|831a94f0-462e3c89-4433deda-3743e242_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 2
2025-12-12T12:27:36.514318Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1165: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. CPU quota delay: 1ms
2025-12-12T12:27:36.514360Z :KQP_COMPUTE TRACE: dq_compute_memory_quota.h:97: TxId: ptqudq7uembs22j8723s, task: 1. Peak memory usage: 196608
2025-12-12T12:27:36.514365Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. update task runner stats
2025-12-12T12:27:36.514388Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-12T12:27:36.514390Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:27:36.514394Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. About to drain sink 0. FreeSpace: 16777186, allowedOvercommit: 500000, toSend: 17277186
2025-12-12T12:27:36.514400Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [1:7582947087457045904:2147], TxId: ptqudq7uembs22j8723s, TaskId: 1, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-12-12T12:27:36.514403Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-12-12T12:27:36.514405Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-12T12:27:36.515996Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:36.515990Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uembs22j8723s, TaskId: 1, PQ sink. ]  SessionId [6f8fb322-8654a169-31a0708b-41019f17|831a94f0-462e3c89-4433deda-3743e242_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T12:27:36.516052Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:36.516049Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uembs22j8723s, TaskId: 1, PQ sink. ]  SessionId [6f8fb322-8654a169-31a0708b-41019f17|831a94f0-462e3c89-4433deda-3743e242_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 1 written { offset: 2 } } write_statistics { persisting_time { } min_queue_wait_time { } max_queue_wait_time { } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T12:27:36.516061Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:36.516059Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uembs22j8723s, TaskId: 1, PQ sink. ]  SessionId [6f8fb322-8654a169-31a0708b-41019f17|831a94f0-462e3c89-4433deda-3743e242_0]  PartitionId [0]  Generation [1] OnAck: seqNo=1, txId=?
2025-12-12T12:27:36.516066Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:36.516063Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uembs22j8723s, TaskId: 1, PQ sink. ]  SessionId [6f8fb322-8654a169-31a0708b-41019f17|831a94f0-462e3c89-4433deda-3743e242_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 1
2025-12-12T12:27:36.516180Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:454: SelfId: [1:7582947087457045904:2147], TxId: ptqudq7uembs22j8723s, TaskId: 1, PQ sink. Ack seq no 1
2025-12-12T12:27:36.516632Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:36.516628Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uembs22j8723s, TaskId: 1, PQ sink. ]  SessionId [6f8fb322-8654a169-31a0708b-41019f17|831a94f0-462e3c89-4433deda-3743e242_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T12:27:36.516657Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:36.516655Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uembs22j8723s, TaskId: 1, PQ sink. ]  SessionId [6f8fb322-8654a169-31a0708b-41019f17|831a94f0-462e3c89-4433deda-3743e242_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 2 written { offset: 3 } } write_statistics { persisting_time { nanos: 1000000 } min_queue_wait_time { } max_queue_wait_time { } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T12:27:36.516660Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:36.516659Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uembs22j8723s, TaskId: 1, PQ sink. ]  SessionId [6f8fb322-8654a169-31a0708b-41019f17|831a94f0-462e3c89-4433deda-3743e242_0]  PartitionId [0]  Generation [1] OnAck: seqNo=2, txId=?
2025-12-12T12:27:36.516663Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:36.516662Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uembs22j8723s, TaskId: 1, PQ sink. ]  SessionId [6f8fb322-8654a169-31a0708b-41019f17|831a94f0-462e3c89-4433deda-3743e242_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 2
2025-12-12T12:27:36.516726Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:454: SelfId: [1:7582947087457045904:2147], TxId: ptqudq7uembs22j8723s, TaskId: 1, PQ sink. Ack seq no 2
2025-12-12T12:27:36.916063Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [2:7582947034081920562:2063]
2025-12-12T12:27:36.916079Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [2:7582947034081920562:2063]
2025-12-12T12:27:36.916082Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [2:7582947034081920562:2063]
2025-12-12T12:27:37.035575Z :KQP_COMPUTE ERROR: dq_compute_actor_impl.h:1205: SelfId: [1:7582947087457045899:2147], TxId: ptqudq7uembs22j8723s, task: 1. Ctx: {}. Handle abort execution event from: [1:7582947031622470816:2064], status: UNAVAILABLE, reason: { <main>: Error: Aborted by LWM }
2025-12-12T12:27:37.035644Z :KQP_COMPUTE DEBUG: dq_compute_actor_channels.cpp:494: TxId: ptqudq7uembs22j8723s, task: 1. pass away
2025-12-12T12:27:37.035663Z :KQP_COMPUTE INFO: dq_pq_rd_read_actor.cpp:744: SelfId: [1:7582947087457045903:2147], TxId: ptqudq7uembs22j8723s, task: 1, Cluster: . PQ source. PassAway
2025-12-12T12:27:37.035685Z :KQP_COMPUTE INFO: dq_pq_rd_read_actor.cpp:1242: SelfId: [1:7582947087457045903:2147], TxId: ptqudq7uembs22j8723s, task: 1, Cluster: . PQ source. SelfId: [1:7582947087457045903:2147], TxId: ptqudq7uembs22j8723s, task: 1, Cluster: . PQ source. State: used buffer size 0 ready buffer event size 0 state 5 InFlyAsyncInputData 0
Counters: CoordinatorChanged 2 CoordinatorResult 1 MessageBatch 1 StartSessionAck 1 NewDataArrived 1 SessionError 0 Statistics 3 NodeDisconnected 0 NodeConnected 0 Undelivered 0 Retry 0 PrivateHeartbeat 0 SessionClosed 0 Pong 0 Heartbeat 1 PrintState 0 ProcessState 0 GetAsyncInputData 9 NotifyCA 1
 [1:7582947031622470815:2063] status 2 is waiting ack 0 connection id 1 id 1, LocalRecipient
 partitions 0 offsets 0=4 has pending data
2025-12-12T12:27:37.035693Z :KQP_COMPUTE INFO: dq_pq_rd_read_actor.cpp:736: SelfId: [1:7582947087457045903:2147], TxId: ptqudq7uembs22j8723s, task: 1, Cluster: . PQ source. Send StopSession to [1:7582947031622470815:2063] generation 1
2025-12-12T12:27:37.035730Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:1001: RowDispatcher: Received TEvStopSession from [1:7582947087457045903:2147] topic test_read_raw_format_with_row_dispatcher_input query id ptqudq7uembs22j8723s
2025-12-12T12:27:37.035741Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:1016: RowDispatcher: DeleteConsumer, readActorId [1:7582947087457045903:2147] query id ptqudq7uembs22j8723s, partitions size 1
2025-12-12T12:27:37.035769Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:1036: RowDispatcher: Session is not used, sent TEvPoisonPill to [1:7582947087457045905:2148]
2025-12-12T12:27:37.035789Z :FQ_ROW_DISPATCHER DEBUG: topic_session.cpp:831: TopicSession [1:7582947087457045905:2148] TEvStopSession from [1:7582947087457045903:2147] topicPath test_read_raw_format_with_row_dispatcher_input clients count 1
2025-12-12T12:27:37.035809Z :FQ_ROW_DISPATCHER DEBUG: format_handler.cpp:477: TTopicFormatHandler [raw]: Remove client with id [1:7582947087457045903:2147]
2025-12-12T12:27:37.035817Z :FQ_ROW_DISPATCHER TRACE: filters_set.cpp:94: TTopicFilters: Remove program with client id [1:7582947087457045903:2147]
2025-12-12T12:27:37.035980Z :FQ_ROW_DISPATCHER DEBUG: format_handler.cpp:559: TTopicFormatHandler [raw]: UpdateParser to new schema with size 0
2025-12-12T12:27:37.035987Z :FQ_ROW_DISPATCHER INFO: format_handler.cpp:584: TTopicFormatHandler [raw]: No columns to parse, reset parser
2025-12-12T12:27:37.036007Z :FQ_ROW_DISPATCHER DEBUG: topic_session.cpp:924: TopicSession [1:7582947087457045905:2148] Close read session
2025-12-12T12:27:37.036023Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:27:37.036018Z :INFO: [local] [local] [e8475fda-827e9aaa-e84185bb-7dc814d] Closing read session. Close timeout: 0.000000s
2025-12-12T12:27:37.036035Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:27:37.036033Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:test_read_raw_format_with_row_dispatcher_input:0:1:3:0
2025-12-12T12:27:37.036046Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:27:37.036045Z :INFO: [local] [local] [e8475fda-827e9aaa-e84185bb-7dc814d] Counters: { Errors: 0 CurrentSessionLifetimeMs: 527 BytesRead: 30 MessagesRead: 2 BytesReadCompressed: 30 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:27:37.036062Z :YDB_SDK NOTICE: actor.cpp:37: 2025-12-12T12:27:37.036060Z :NOTICE: [local] [local] [e8475fda-827e9aaa-e84185bb-7dc814d] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Close with zero timeout " }
2025-12-12T12:27:37.036070Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:37.036068Z :DEBUG: [local] [local] [e8475fda-827e9aaa-e84185bb-7dc814d] [] Abort session to cluster
2025-12-12T12:27:37.036222Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:27:37.036220Z :INFO: [local] [local] [e8475fda-827e9aaa-e84185bb-7dc814d] Closing read session. Close timeout: 0.000000s
2025-12-12T12:27:37.036231Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:27:37.036230Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:test_read_raw_format_with_row_dispatcher_input:0:1:3:0
2025-12-12T12:27:37.036234Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:27:37.036233Z :INFO: [local] [local] [e8475fda-827e9aaa-e84185bb-7dc814d] Counters: { Errors: 0 CurrentSessionLifetimeMs: 527 BytesRead: 30 MessagesRead: 2 BytesReadCompressed: 30 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:27:37.036241Z :YDB_SDK NOTICE: actor.cpp:37: 2025-12-12T12:27:37.036240Z :NOTICE: [local] [local] [e8475fda-827e9aaa-e84185bb-7dc814d] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T12:27:37.036274Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:457: TopicSession [1:7582947087457045905:2148] Skip SubscribeOnNextEvent, has ReadSession: false, IsWaitingEvents: 1
2025-12-12T12:27:37.036285Z :FQ_ROW_DISPATCHER DEBUG: topic_session.cpp:449: TopicSession [1:7582947087457045905:2148] PassAway
2025-12-12T12:27:37.036706Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:27:37.036700Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uembs22j8723s, TaskId: 1, PQ sink. ]  SessionId [6f8fb322-8654a169-31a0708b-41019f17|831a94f0-462e3c89-4433deda-3743e242_0]  PartitionId [0]  Generation [1] Write session: close. Timeout 0.000000s
2025-12-12T12:27:37.036712Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:27:37.036710Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uembs22j8723s, TaskId: 1, PQ sink. ]  SessionId [6f8fb322-8654a169-31a0708b-41019f17|831a94f0-462e3c89-4433deda-3743e242_0]  PartitionId [0]  Generation [1] Write session will now close
2025-12-12T12:27:37.036732Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:37.036731Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uembs22j8723s, TaskId: 1, PQ sink. ]  SessionId [6f8fb322-8654a169-31a0708b-41019f17|831a94f0-462e3c89-4433deda-3743e242_0]  PartitionId [0]  Generation [1] Write session: aborting
2025-12-12T12:27:37.036845Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:27:37.036843Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uembs22j8723s, TaskId: 1, PQ sink. ]  SessionId [6f8fb322-8654a169-31a0708b-41019f17|831a94f0-462e3c89-4433deda-3743e242_0]  PartitionId [0]  Generation [1] Write session: gracefully shut down, all writes complete
2025-12-12T12:27:37.036849Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:37.036848Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7uembs22j8723s, TaskId: 1, PQ sink. ]  SessionId [6f8fb322-8654a169-31a0708b-41019f17|831a94f0-462e3c89-4433deda-3743e242_0]  PartitionId [0]  Generation [1] Write session: destroy
2025-12-12T12:27:37.073712Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1059: RowDispatcher: No consumer with EventQueueId = 1
2025-12-12T12:27:37.380255Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [3:7582947035351577334:2063]
2025-12-12T12:27:37.380271Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [3:7582947035351577334:2063]
2025-12-12T12:27:37.380276Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [3:7582947035351577334:2063]
2025-12-12T12:27:37.386074Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: f992d040-c9567214-5bb9b6cb-b474938420, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:37.454669Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:37.454692Z :FQ_PENDING_FETCHER ERROR: pending_fetcher.cpp:259: Error with GetTask: <main>: Error: GRpc error: (1): Cancelled on the server side
<main>: Error: Grpc error response on endpoint ghrun-fhkyrtz6p4.auto.internal:2707
2025-12-12T12:27:38.375270Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582947031622470849:2092]
2025-12-12T12:27:38.375291Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:38.375304Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582947031622470815:2063]
2025-12-12T12:27:38.375309Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582947031622470815:2063]
2025-12-12T12:27:38.375312Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582947031622470815:2063]
2025-12-12T12:27:38.375325Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:38.376286Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-12-12T12:27:38.381363Z :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:2707: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-fhkyrtz6p4.auto.internal:2707
2025-12-12T12:27:38.386516Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: f992d040-c9567214-5bb9b6cb-b474938421, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:38.391761Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:38.391781Z :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:2707: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-fhkyrtz6p4.auto.internal:2707
2025-12-12T12:27:38.918720Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [2:7582947034081920562:2063]
2025-12-12T12:27:38.918736Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [2:7582947034081920562:2063]
2025-12-12T12:27:38.918739Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [2:7582947034081920562:2063]
2025-12-12T12:27:39.382572Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [3:7582947035351577334:2063]
2025-12-12T12:27:39.382587Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [3:7582947035351577334:2063]
2025-12-12T12:27:39.382591Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [3:7582947035351577334:2063]
2025-12-12T12:27:39.386967Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: f992d040-c9567214-5bb9b6cb-b474938422, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:39.393728Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:39.393752Z :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:2707: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-fhkyrtz6p4.auto.internal:2707
2025-12-12T12:27:40.376152Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582947031622470849:2092]
2025-12-12T12:27:40.376169Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:40.376193Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582947031622470815:2063]
2025-12-12T12:27:40.376201Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582947031622470815:2063]
2025-12-12T12:27:40.376205Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582947031622470815:2063]
2025-12-12T12:27:40.376236Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:40.387386Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: f992d040-c9567214-5bb9b6cb-b474938423, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:40.392861Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:40.392883Z :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:2707: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-fhkyrtz6p4.auto.internal:2707
2025-12-12T12:27:40.917791Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [2:7582947034081920562:2063]
2025-12-12T12:27:40.917808Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [2:7582947034081920562:2063]
2025-12-12T12:27:40.917811Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [2:7582947034081920562:2063]
2025-12-12T12:27:41.382095Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [3:7582947035351577334:2063]
2025-12-12T12:27:41.382111Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [3:7582947035351577334:2063]
2025-12-12T12:27:41.382115Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [3:7582947035351577334:2063]
2025-12-12T12:27:41.387862Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: f992d040-c9567214-5bb9b6cb-b474938424, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:41.394149Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:41.394173Z :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:2707: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-fhkyrtz6p4.auto.internal:2707
2025-12-12T12:27:42.377057Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582947031622470849:2092]
2025-12-12T12:27:42.377073Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:42.377084Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582947031622470815:2063]
2025-12-12T12:27:42.377089Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582947031622470815:2063]
2025-12-12T12:27:42.377096Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582947031622470815:2063]
2025-12-12T12:27:42.377109Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:42.388345Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: f992d040-c9567214-5bb9b6cb-b474938425, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:42.393533Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:42.393561Z :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:2707: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-fhkyrtz6p4.auto.internal:2707
2025-12-12T12:27:42.918726Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [2:7582947034081920562:2063]
2025-12-12T12:27:42.918740Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [2:7582947034081920562:2063]
2025-12-12T12:27:42.918744Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [2:7582947034081920562:2063]
2025-12-12T12:27:43.376491Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-12-12T12:27:43.381640Z :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:2707: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-fhkyrtz6p4.auto.internal:2707
2025-12-12T12:27:43.383308Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [3:7582947035351577334:2063]
2025-12-12T12:27:43.383321Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [3:7582947035351577334:2063]
2025-12-12T12:27:43.383325Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [3:7582947035351577334:2063]
2025-12-12T12:27:43.388774Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: f992d040-c9567214-5bb9b6cb-b474938426, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:43.393379Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:43.393401Z :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:2707: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-fhkyrtz6p4.auto.internal:2707
2025-12-12T12:27:44.377947Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582947031622470849:2092]
2025-12-12T12:27:44.377967Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:44.377981Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582947031622470815:2063]
2025-12-12T12:27:44.377987Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582947031622470815:2063]
2025-12-12T12:27:44.377991Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582947031622470815:2063]
2025-12-12T12:27:44.378007Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:44.389209Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: f992d040-c9567214-5bb9b6cb-b474938427, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:44.394815Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:44.394847Z :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:2707: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-fhkyrtz6p4.auto.internal:2707
2025-12-12T12:27:44.919665Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [2:7582947034081920562:2063]
2025-12-12T12:27:44.919682Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [2:7582947034081920562:2063]
2025-12-12T12:27:44.919686Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [2:7582947034081920562:2063]
2025-12-12T12:27:45.383966Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [3:7582947035351577334:2063]
2025-12-12T12:27:45.383982Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [3:7582947035351577334:2063]
2025-12-12T12:27:45.383985Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [3:7582947035351577334:2063]
2025-12-12T12:27:45.389631Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: f992d040-c9567214-5bb9b6cb-b474938428, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:45.395386Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:45.395407Z :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:2707: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-fhkyrtz6p4.auto.internal:2707
2025-12-12T12:27:46.378844Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582947031622470849:2092]
2025-12-12T12:27:46.378867Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:46.378890Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582947031622470815:2063]
2025-12-12T12:27:46.378897Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582947031622470815:2063]
2025-12-12T12:27:46.378900Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582947031622470815:2063]
2025-12-12T12:27:46.378914Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:46.390121Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: f992d040-c9567214-5bb9b6cb-b474938429, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:46.395541Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:46.395562Z :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:2707: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-fhkyrtz6p4.auto.internal:2707
2025-12-12T12:27:46.920639Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [2:7582947034081920562:2063]
2025-12-12T12:27:46.920653Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [2:7582947034081920562:2063]
2025-12-12T12:27:46.920657Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [2:7582947034081920562:2063]
2025-12-12T12:27:47.384734Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [3:7582947035351577334:2063]
2025-12-12T12:27:47.384748Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [3:7582947035351577334:2063]
2025-12-12T12:27:47.384752Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [3:7582947035351577334:2063]
2025-12-12T12:27:47.390591Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: f992d040-c9567214-5bb9b6cb-b474938430, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:47.399394Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:47.399417Z :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:2707: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-fhkyrtz6p4.auto.internal:2707
2025-12-12T12:27:48.376678Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-12-12T12:27:48.379706Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582947031622470849:2092]
2025-12-12T12:27:48.379726Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:48.379733Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582947031622470815:2063]
2025-12-12T12:27:48.379737Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582947031622470815:2063]
2025-12-12T12:27:48.379741Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582947031622470815:2063]
2025-12-12T12:27:48.379750Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:48.383689Z :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:2707: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-fhkyrtz6p4.auto.internal:2707
2025-12-12T12:27:48.390976Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: f992d040-c9567214-5bb9b6cb-b474938431, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:48.396673Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:48.396696Z :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:2707: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-fhkyrtz6p4.auto.internal:2707
2025-12-12T12:27:48.921408Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [2:7582947034081920562:2063]
2025-12-12T12:27:48.921427Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [2:7582947034081920562:2063]
2025-12-12T12:27:48.921430Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [2:7582947034081920562:2063]
2025-12-12T12:27:49.385817Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [3:7582947035351577334:2063]
2025-12-12T12:27:49.385832Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [3:7582947035351577334:2063]
2025-12-12T12:27:49.385835Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [3:7582947035351577334:2063]
2025-12-12T12:27:49.391412Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: f992d040-c9567214-5bb9b6cb-b474938432, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:49.399412Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:49.399436Z :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:2707: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-fhkyrtz6p4.auto.internal:2707
2025-12-12T12:27:50.380684Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582947031622470849:2092]
2025-12-12T12:27:50.380718Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:50.380730Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582947031622470815:2063]
2025-12-12T12:27:50.380735Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582947031622470815:2063]
2025-12-12T12:27:50.380738Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582947031622470815:2063]
2025-12-12T12:27:50.380752Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:50.391942Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: f992d040-c9567214-5bb9b6cb-b474938433, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:50.399652Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:50.399675Z :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:2707: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-fhkyrtz6p4.auto.internal:2707
2025-12-12T12:27:50.931202Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [2:7582947034081920562:2063]
2025-12-12T12:27:50.931224Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [2:7582947034081920562:2063]
2025-12-12T12:27:50.931229Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [2:7582947034081920562:2063]
2025-12-12T12:27:51.389282Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [3:7582947035351577334:2063]
2025-12-12T12:27:51.389305Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [3:7582947035351577334:2063]
2025-12-12T12:27:51.389309Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [3:7582947035351577334:2063]
2025-12-12T12:27:51.395041Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: f992d040-c9567214-5bb9b6cb-b474938434, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:51.408210Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:51.408237Z :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:2707: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-fhkyrtz6p4.auto.internal:2707
2025-12-12T12:27:52.383614Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582947031622470849:2092]
2025-12-12T12:27:52.383635Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:52.383661Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582947031622470815:2063]
2025-12-12T12:27:52.383665Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582947031622470815:2063]
2025-12-12T12:27:52.383669Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582947031622470815:2063]
2025-12-12T12:27:52.383675Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:52.396968Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: f992d040-c9567214-5bb9b6cb-b474938435, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:52.407347Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:52.407397Z :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:2707: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-fhkyrtz6p4.auto.internal:2707
2025-12-12T12:27:52.924277Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [2:7582947034081920562:2063]
2025-12-12T12:27:52.924294Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [2:7582947034081920562:2063]
2025-12-12T12:27:52.924297Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [2:7582947034081920562:2063]
2025-12-12T12:27:53.376885Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-12-12T12:27:53.383348Z :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:2707: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-fhkyrtz6p4.auto.internal:2707
2025-12-12T12:27:53.387407Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [3:7582947035351577334:2063]
2025-12-12T12:27:53.387422Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [3:7582947035351577334:2063]
2025-12-12T12:27:53.387425Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [3:7582947035351577334:2063]
2025-12-12T12:27:53.400805Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: f992d040-c9567214-5bb9b6cb-b474938436, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:53.405403Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:53.405431Z :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:2707: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-fhkyrtz6p4.auto.internal:2707
2025-12-12T12:27:54.384999Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582947031622470849:2092]
2025-12-12T12:27:54.385018Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:54.385031Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582947031622470815:2063]
2025-12-12T12:27:54.385034Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582947031622470815:2063]
2025-12-12T12:27:54.385038Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582947031622470815:2063]
2025-12-12T12:27:54.385042Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:54.400860Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: f992d040-c9567214-5bb9b6cb-b474938437, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:54.407012Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:54.407032Z :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:2707: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-fhkyrtz6p4.auto.internal:2707
2025-12-12T12:27:54.925140Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [2:7582947034081920562:2063]
2025-12-12T12:27:54.925156Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [2:7582947034081920562:2063]
2025-12-12T12:27:54.925168Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [2:7582947034081920562:2063]
2025-12-12T12:27:55.388291Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [3:7582947035351577334:2063]
2025-12-12T12:27:55.388305Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [3:7582947035351577334:2063]
2025-12-12T12:27:55.388309Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [3:7582947035351577334:2063]
2025-12-12T12:27:55.401305Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: f992d040-c9567214-5bb9b6cb-b474938438, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:55.415545Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:55.415572Z :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:2707: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-fhkyrtz6p4.auto.internal:2707
2025-12-12T12:27:56.385347Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582947031622470849:2092]
2025-12-12T12:27:56.385360Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:56.385371Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582947031622470815:2063]
2025-12-12T12:27:56.385375Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582947031622470815:2063]
2025-12-12T12:27:56.385379Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582947031622470815:2063]
2025-12-12T12:27:56.385384Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:56.401820Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: f992d040-c9567214-5bb9b6cb-b474938439, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:56.406070Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:56.406093Z :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:2707: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-fhkyrtz6p4.auto.internal:2707
2025-12-12T12:27:56.928334Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [2:7582947034081920562:2063]
2025-12-12T12:27:56.928353Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [2:7582947034081920562:2063]
2025-12-12T12:27:56.928356Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [2:7582947034081920562:2063]
2025-12-12T12:27:57.393205Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [3:7582947035351577334:2063]
2025-12-12T12:27:57.393224Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [3:7582947035351577334:2063]
2025-12-12T12:27:57.393229Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [3:7582947035351577334:2063]
2025-12-12T12:27:57.403397Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: f992d040-c9567214-5bb9b6cb-b474938440, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:57.414602Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:57.414625Z :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:2707: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-fhkyrtz6p4.auto.internal:2707
2025-12-12T12:27:58.377108Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-12-12T12:27:58.386267Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582947031622470849:2092]
2025-12-12T12:27:58.386288Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:58.386307Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582947031622470815:2063]
2025-12-12T12:27:58.386313Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582947031622470815:2063]
2025-12-12T12:27:58.386316Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582947031622470815:2063]
2025-12-12T12:27:58.386323Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:58.387669Z :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:2707: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-fhkyrtz6p4.auto.internal:2707
2025-12-12T12:27:58.404848Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: f992d040-c9567214-5bb9b6cb-b474938441, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:58.415163Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:58.415190Z :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:2707: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-fhkyrtz6p4.auto.internal:2707
2025-12-12T12:27:58.946063Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [2:7582947034081920562:2063]
2025-12-12T12:27:58.946083Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [2:7582947034081920562:2063]
2025-12-12T12:27:58.946088Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [2:7582947034081920562:2063]
2025-12-12T12:27:59.394167Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [3:7582947035351577334:2063]
2025-12-12T12:27:59.394186Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [3:7582947035351577334:2063]
2025-12-12T12:27:59.394191Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [3:7582947035351577334:2063]
2025-12-12T12:27:59.405159Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: f992d040-c9567214-5bb9b6cb-b474938442, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:59.410423Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:59.410446Z :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:2707: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-fhkyrtz6p4.auto.internal:2707
2025-12-12T12:28:00.387193Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582947031622470849:2092]
2025-12-12T12:28:00.387222Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:28:00.387240Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582947031622470815:2063]
2025-12-12T12:28:00.387250Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582947031622470815:2063]
2025-12-12T12:28:00.387253Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582947031622470815:2063]
2025-12-12T12:28:00.387267Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:28:00.405634Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: f992d040-c9567214-5bb9b6cb-b474938443, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:28:00.410795Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:28:00.410813Z :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:2707: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-fhkyrtz6p4.auto.internal:2707
2025-12-12T12:28:00.927788Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [2:7582947034081920562:2063]
2025-12-12T12:28:00.927808Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [2:7582947034081920562:2063]
2025-12-12T12:28:00.927813Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [2:7582947034081920562:2063]
2025-12-12T12:28:01.395296Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [3:7582947035351577334:2063]
2025-12-12T12:28:01.395312Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [3:7582947035351577334:2063]
2025-12-12T12:28:01.395315Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [3:7582947035351577334:2063]
2025-12-12T12:28:01.406177Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: f992d040-c9567214-5bb9b6cb-b474938444, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:28:01.411648Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:28:01.411672Z :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:2707: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-fhkyrtz6p4.auto.internal:2707
2025-12-12T12:28:02.388092Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582947031622470849:2092]
2025-12-12T12:28:02.388113Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:28:02.388125Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582947031622470815:2063]
2025-12-12T12:28:02.388132Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582947031622470815:2063]
2025-12-12T12:28:02.388138Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582947031622470815:2063]
2025-12-12T12:28:02.388153Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:28:02.406502Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: f992d040-c9567214-5bb9b6cb-b474938445, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:28:02.412692Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:28:02.412708Z :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:2707: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-fhkyrtz6p4.auto.internal:2707
2025-12-12T12:28:02.931161Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [2:7582947034081920562:2063]
2025-12-12T12:28:02.931183Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [2:7582947034081920562:2063]
2025-12-12T12:28:02.931187Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [2:7582947034081920562:2063]
2025-12-12T12:28:03.377465Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-12-12T12:28:03.383901Z :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:2707: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-fhkyrtz6p4.auto.internal:2707
2025-12-12T12:28:03.396054Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [3:7582947035351577334:2063]
2025-12-12T12:28:03.396070Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [3:7582947035351577334:2063]
2025-12-12T12:28:03.396074Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [3:7582947035351577334:2063]
2025-12-12T12:28:03.406963Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: f992d040-c9567214-5bb9b6cb-b474938446, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:28:03.414280Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:28:03.414300Z :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:2707: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-fhkyrtz6p4.auto.internal:2707
2025-12-12T12:28:04.388928Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582947031622470849:2092]
2025-12-12T12:28:04.388944Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:28:04.388954Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582947031622470815:2063]
2025-12-12T12:28:04.388957Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582947031622470815:2063]
2025-12-12T12:28:04.388960Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582947031622470815:2063]
2025-12-12T12:28:04.388973Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:28:04.407392Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: f992d040-c9567214-5bb9b6cb-b474938447, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:28:04.412896Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:28:04.412921Z :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:2707: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-fhkyrtz6p4.auto.internal:2707
2025-12-12T12:28:04.929651Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [2:7582947034081920562:2063]
2025-12-12T12:28:04.929670Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [2:7582947034081920562:2063]
2025-12-12T12:28:04.929673Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [2:7582947034081920562:2063]
2025-12-12T12:28:05.396938Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [3:7582947035351577334:2063]
2025-12-12T12:28:05.396954Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [3:7582947035351577334:2063]
2025-12-12T12:28:05.396962Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [3:7582947035351577334:2063]
2025-12-12T12:28:05.407898Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: f992d040-c9567214-5bb9b6cb-b474938448, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:28:05.418651Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:28:05.418676Z :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:2707: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-fhkyrtz6p4.auto.internal:2707
2025-12-12T12:28:06.389870Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582947031622470849:2092]
2025-12-12T12:28:06.389894Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:28:06.389904Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582947031622470815:2063]
2025-12-12T12:28:06.389908Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582947031622470815:2063]
2025-12-12T12:28:06.389913Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582947031622470815:2063]
2025-12-12T12:28:06.389943Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:28:06.408318Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: f992d040-c9567214-5bb9b6cb-b474938449, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:28:06.414672Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:28:06.414697Z :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:2707: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-fhkyrtz6p4.auto.internal:2707
2025-12-12T12:28:06.931683Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [2:7582947034081920562:2063]
2025-12-12T12:28:06.931703Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [2:7582947034081920562:2063]
2025-12-12T12:28:06.931707Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [2:7582947034081920562:2063]
2025-12-12T12:28:07.397995Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [3:7582947035351577334:2063]
2025-12-12T12:28:07.398015Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [3:7582947035351577334:2063]
2025-12-12T12:28:07.398019Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [3:7582947035351577334:2063]
2025-12-12T12:28:07.408836Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: f992d040-c9567214-5bb9b6cb-b474938450, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:28:07.418042Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:28:07.418071Z :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:2707: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-fhkyrtz6p4.auto.internal:2707
2025-12-12T12:28:08.378800Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-12-12T12:28:08.385008Z :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:2707: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-fhkyrtz6p4.auto.internal:2707
2025-12-12T12:28:08.391086Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582947031622470849:2092]
2025-12-12T12:28:08.391109Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:28:08.391119Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582947031622470815:2063]
2025-12-12T12:28:08.391126Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582947031622470815:2063]
2025-12-12T12:28:08.391141Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582947031622470815:2063]
2025-12-12T12:28:08.391156Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:28:08.410605Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: f992d040-c9567214-5bb9b6cb-b474938451, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:28:08.420061Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:28:08.420097Z :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:2707: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-fhkyrtz6p4.auto.internal:2707
2025-12-12T12:28:08.931421Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [2:7582947034081920562:2063]
2025-12-12T12:28:08.931437Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [2:7582947034081920562:2063]
2025-12-12T12:28:08.931442Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [2:7582947034081920562:2063]
2025-12-12T12:28:09.158266Z :INTERCONNECT_NETWORK NOTICE: interconnect_tcp_input_session.cpp:712: [1 <-> 2] connection closed by peer
2025-12-12T12:28:09.158887Z :INTERCONNECT_NETWORK NOTICE: interconnect_handshake.cpp:1262: [1 <-> 2] network-related error occured on handshake: outgoing handshake Peer# ghrun-fhkyrtz6p4(127.0.1.1:15938) Couldn't connect to any resolved address
2025-12-12T12:28:09.159118Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:597: RowDispatcher: TEvNodeDisconnected, node id 2
2025-12-12T12:28:09.159136Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:398: Coordinator: TEvNodeDisconnected, node id 2
2025-12-12T12:28:09.159140Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:408: Coordinator: Schedule TEvRebalancing
2025-12-12T12:28:09.159332Z :INTERCONNECT_NETWORK NOTICE: interconnect_tcp_input_session.cpp:712: [1 <-> 3] connection closed by peer
2025-12-12T12:28:09.159608Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:398: Coordinator: TEvNodeDisconnected, node id 3
2025-12-12T12:28:09.159735Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1052: RowDispatcher: TEvTryConnect to node id 2
2025-12-12T12:28:09.161721Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:597: RowDispatcher: TEvNodeDisconnected, node id 2
2025-12-12T12:28:09.236619Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1052: RowDispatcher: TEvTryConnect to node id 2
2025-12-12T12:28:09.236682Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:597: RowDispatcher: TEvNodeDisconnected, node id 2
