2025-12-12T12:26:57.217055Z :GRPC_SERVER NOTICE: grpc_request_proxy.cpp:380: Grpc request proxy started, nodeid# 1, serve as static node
2025-12-12T12:26:57.217111Z :GRPC_SERVER CRIT: grpc_request_proxy.cpp:440: Failed to deliver subscription request to config dispatcher
2025-12-12T12:26:57.217115Z :GRPC_SERVER NOTICE: grpc_request_proxy.cpp:380: Grpc request proxy started, nodeid# 1, serve as static node
2025-12-12T12:26:57.217130Z :GRPC_SERVER CRIT: grpc_request_proxy.cpp:440: Failed to deliver subscription request to config dispatcher
2025-12-12T12:26:57.217290Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:214: Bootstrap
2025-12-12T12:26:57.217292Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:217: Create sdk ydb connection
2025-12-12T12:26:57.218407Z :FQ_QUOTA_PROXY INFO: quota_proxy.cpp:90: STARTED
2025-12-12T12:26:57.218455Z :FQ_LOG_UPDATER DEBUG: log.cpp:93: Updated YQL logs priority: 8
2025-12-12T12:26:57.218459Z :FQ_LOG_UPDATER CRIT: log.cpp:55: Failed to deliver subscription request to config dispatcher.
2025-12-12T12:26:57.218483Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:239: Successfully bootstrapped TStorageProxy [1:7582946944559253465:2062] with connection to localhost:14020:local
2025-12-12T12:26:57.218499Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:544: RowDispatcher: Successfully bootstrapped row dispatcher, id [1:7582946944559253466:2063], tenant /compute
2025-12-12T12:26:57.218501Z :YQ_RATE_LIMITER INFO: quoter_service.cpp:124: Bootstraping with config: { Enabled: true DataPlaneEnabled: true Database { Endpoint: "localhost:14020" Database: "local" TablePrefix: "RateLimiter_a57e0649-393d-4a7f-b0b4-636f1bb05e6d" } Limiters { CoordinationNodePath: "rate_limiter" } }
2025-12-12T12:26:57.218509Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582946944559253466:2063]
2025-12-12T12:26:57.218512Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:329: Coordinator: Add new row dispatcher to map (state 1)
2025-12-12T12:26:57.218675Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:293: Coordinator: Successfully bootstrapped coordinator, id [1:7582946944559253506:2082], NodesManagerId [0:4705493345362661702:78], rebalancing timeout 5.000000s
2025-12-12T12:26:57.218686Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:637: RowDispatcher: TEvCoordinatorChangesSubscribe from [1:7582946944559253506:2082]
2025-12-12T12:26:57.218688Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:232: TLeaderElection [1:7582946944559253507:2083] Successfully bootstrapped, local coordinator id [1:7582946944559253506:2082], tenant id compute, local mode 0, coordination node path local/compute, endpoint localhost:14020
2025-12-12T12:26:57.218713Z :FQ_QUOTA_SERVICE INFO: quota_manager.cpp:196: STARTED
2025-12-12T12:26:57.218732Z :YQL_NODES_MANAGER INFO: nodes_manager.cpp:88: Bootstrap, InstanceId: 9df0ec9-4c33a7ed-c80338a8-7dac703b
2025-12-12T12:26:57.218734Z :YQL_NODES_MANAGER DEBUG: nodes_manager.cpp:310: TNodesManagerActor::ResolveSelfAddress
2025-12-12T12:26:57.218751Z :YQ_TEST_CONNECTION DEBUG: test_connection.cpp:142: Starting yandex query test connection. Actor id: [1:7582946944559253471:2068]
2025-12-12T12:26:57.218794Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 78b82b8d-1230c1ab-b5d0b60f-66f25fd01, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:26:57.218828Z :MEMORY_PROFILER NOTICE: monitor.cpp:332: Bootstrapped
2025-12-12T12:26:57.220285Z :SCHEME_BOARD_SUBSCRIBER NOTICE: subscriber.cpp:849: [main][1:7582946944559253496:2078][/compute] Set up state: owner# [1:7582946944559253445:2052], state# { Deleted: 1 Strong: 0 Version: <Invalid> DomainId: <Invalid> AbandonedSchemeShards: there are 0 elements }
2025-12-12T12:26:57.220311Z :SCHEME_BOARD_SUBSCRIBER NOTICE: subscriber.cpp:849: [main][1:7582946944559253497:2079][/Root] Set up state: owner# [1:7582946944559253446:2053], state# { Deleted: 1 Strong: 0 Version: <Invalid> DomainId: <Invalid> AbandonedSchemeShards: there are 0 elements }
2025-12-12T12:26:57.220321Z :SCHEME_BOARD_SUBSCRIBER NOTICE: subscriber.cpp:849: [main][1:7582946944559253498:2080][/compute] Set up state: owner# [1:7582946944559253446:2053], state# { Deleted: 1 Strong: 0 Version: <Invalid> DomainId: <Invalid> AbandonedSchemeShards: there are 0 elements }
2025-12-12T12:26:57.220325Z :GRPC_SERVER WARN: grpc_request_proxy.cpp:583: SchemeBoardDelete /compute Strong=0
2025-12-12T12:26:57.220327Z :GRPC_SERVER WARN: grpc_request_proxy.cpp:583: SchemeBoardDelete /Root Strong=0
2025-12-12T12:26:57.220329Z :GRPC_SERVER WARN: grpc_request_proxy.cpp:583: SchemeBoardDelete /compute Strong=0
2025-12-12T12:26:57.220352Z :SCHEME_BOARD_SUBSCRIBER NOTICE: subscriber.cpp:849: [main][1:7582946944559253495:2077][/Root] Set up state: owner# [1:7582946944559253445:2052], state# { Deleted: 1 Strong: 0 Version: <Invalid> DomainId: <Invalid> AbandonedSchemeShards: there are 0 elements }
2025-12-12T12:26:57.220354Z :GRPC_SERVER WARN: grpc_request_proxy.cpp:583: SchemeBoardDelete /Root Strong=0
2025-12-12T12:26:57.220832Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-12-12T12:26:57.229789Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:71: Run create coordination node "local/compute" actor
2025-12-12T12:26:57.229804Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:113: Call create coordination node "local/compute"
2025-12-12T12:26:57.229807Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:411: Call create coordination node "local/compute"
2025-12-12T12:26:57.302315Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:155: Successfully created coordination node "local/compute"
2025-12-12T12:26:57.302325Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:122: Reply for create coordination node "local/compute": 
2025-12-12T12:26:57.302345Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:345: TLeaderElection [1:7582946944559253507:2083] Coordination node successfully created
2025-12-12T12:26:57.302348Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:323: TLeaderElection [1:7582946944559253507:2083] Start session
2025-12-12T12:26:57.307261Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:359: TLeaderElection [1:7582946944559253507:2083] Session successfully created
2025-12-12T12:26:57.311671Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:372: TLeaderElection [1:7582946944559253507:2083] Semaphore successfully created
2025-12-12T12:26:57.311691Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:304: TLeaderElection [1:7582946944559253507:2083] Try to acquire semaphore
2025-12-12T12:26:57.311822Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:420: TLeaderElection [1:7582946944559253507:2083] Describe semaphore
2025-12-12T12:26:57.315133Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:26:57.315152Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:26:57.316115Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:386: TLeaderElection [1:7582946944559253507:2083] Semaphore successfully acquired
2025-12-12T12:26:57.316428Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:469: TLeaderElection [1:7582946944559253507:2083] Semaphore successfully described: coordinator id [1:7582946944559253506:2082] generation 1
2025-12-12T12:26:57.316450Z :FQ_ROW_DISPATCHER INFO: leader_election.cpp:471: TLeaderElection [1:7582946944559253507:2083] Send TEvCoordinatorChanged to [1:7582946944559253466:2063], new coordinator id [1:7582946944559253506:2082], previous coordinator id [0:0:0]
2025-12-12T12:26:57.316472Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:569: RowDispatcher: Coordinator changed, old leader (empty maybe), new [1:7582946944559253506:2082] generation 1
2025-12-12T12:26:57.316490Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582946944559253466:2063]
2025-12-12T12:26:57.316494Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582946944559253466:2063]
2025-12-12T12:26:57.316496Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582946944559253466:2063]
2025-12-12T12:26:57.316508Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:440: Coordinator: New leader [1:7582946944559253506:2082], SelfId [1:7582946944559253506:2082]
2025-12-12T12:26:57.316520Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:26:57.365479Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:389: Send NodeInfo with size: 0 to DynamicNameserver
2025-12-12T12:26:57.993755Z :INTERCONNECT ERROR: interconnect_nameserver_dynamic.cpp:62:  ICN06 Unknown nodeId: 2
2025-12-12T12:26:58.213871Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 78b82b8d-1230c1ab-b5d0b60f-66f25fd02, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:26:58.219451Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:26:58.219467Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:26:58.433537Z :INTERCONNECT ERROR: interconnect_nameserver_dynamic.cpp:62:  ICN06 Unknown nodeId: 2
2025-12-12T12:26:59.003265Z :INTERCONNECT ERROR: interconnect_nameserver_dynamic.cpp:62:  ICN06 Unknown nodeId: 3
2025-12-12T12:26:59.214183Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582946944559253506:2082]
2025-12-12T12:26:59.214200Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:26:59.215174Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 78b82b8d-1230c1ab-b5d0b60f-66f25fd03, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:26:59.215218Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582946944559253466:2063]
2025-12-12T12:26:59.215222Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582946944559253466:2063]
2025-12-12T12:26:59.215225Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582946944559253466:2063]
2025-12-12T12:26:59.215231Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:26:59.221320Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:26:59.221336Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:26:59.457877Z :INTERCONNECT ERROR: interconnect_nameserver_dynamic.cpp:62:  ICN06 Unknown nodeId: 3
2025-12-12T12:26:59.457902Z :INTERCONNECT ERROR: interconnect_nameserver_dynamic.cpp:62:  ICN06 Unknown nodeId: 2
2025-12-12T12:27:00.215405Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 78b82b8d-1230c1ab-b5d0b60f-66f25fd04, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:00.223260Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:00.223277Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:00.624181Z :INTERCONNECT ERROR: interconnect_nameserver_dynamic.cpp:62:  ICN06 Unknown nodeId: 3
2025-12-12T12:27:00.919404Z :INTERCONNECT ERROR: interconnect_nameserver_dynamic.cpp:62:  ICN06 Unknown nodeId: 2
2025-12-12T12:27:01.215449Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582946944559253506:2082]
2025-12-12T12:27:01.215477Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:01.215485Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582946944559253466:2063]
2025-12-12T12:27:01.215491Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582946944559253466:2063]
2025-12-12T12:27:01.215496Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582946944559253466:2063]
2025-12-12T12:27:01.215508Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:01.218574Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 78b82b8d-1230c1ab-b5d0b60f-66f25fd05, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:01.239251Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:01.239267Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:01.832777Z :INTERCONNECT ERROR: interconnect_nameserver_dynamic.cpp:62:  ICN06 Unknown nodeId: 3
2025-12-12T12:27:02.213482Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:665: Coordinator: Change global state to Started (by timeout)
2025-12-12T12:27:02.216507Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 78b82b8d-1230c1ab-b5d0b60f-66f25fd06, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:02.221379Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-12-12T12:27:02.222838Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:02.222844Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:02.258565Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:389: Send NodeInfo with size: 2 to DynamicNameserver
2025-12-12T12:27:02.354140Z :INTERCONNECT WARN: interconnect_handshake.cpp:501: Handshake [1:7582946966034090167:2061] [node 2] ICH09 Neither CompatibilityInfo nor VersionTag of the peer can be validated, accepting by default
2025-12-12T12:27:02.847758Z :INTERCONNECT WARN: interconnect_handshake.cpp:501: Handshake [1:7582946966034090173:2063] [node 3] ICH09 Neither CompatibilityInfo nor VersionTag of the peer can be validated, accepting by default
2025-12-12T12:27:02.848987Z :FQ_ROW_DISPATCHER INFO: coordinator.cpp:507: Coordinator: TEvCoordinatorRequest from [3:7582946957272664743:2150], test_scheme_error_input, partIds: 0
2025-12-12T12:27:02.849022Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:562: Coordinator: Send TEvCoordinatorResult to [3:7582946957272664743:2150]
2025-12-12T12:27:02.849039Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:392: Coordinator: EvNodeConnected 3
2025-12-12T12:27:02.851196Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:853: RowDispatcher: Received TEvStartSession from [3:7582946957272664743:2150], read group ptcudq7ufkllb25uoffr, topicPath test_scheme_error_input part id 0 query id ptqudq7ufk6rtvrqftt3 cookie 1
2025-12-12T12:27:02.851238Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:892: RowDispatcher: Create new session: read group ptcudq7ufkllb25uoffr topic test_scheme_error_input part id 0
2025-12-12T12:27:02.851304Z :FQ_ROW_DISPATCHER DEBUG: topic_session.cpp:443: TopicSession [1:7582946966034090178:2148] Bootstrap test_scheme_error_input/0, Timeout 5.000000s sec
2025-12-12T12:27:02.851315Z :FQ_ROW_DISPATCHER INFO: topic_session.cpp:799: TopicSession [1:7582946966034090178:2148] New client: read actor id [3:7582946957272664743:2150], predicate: , watermark expr: , offset: (empty maybe)
2025-12-12T12:27:02.851355Z :FQ_ROW_DISPATCHER DEBUG: format_handler.cpp:440: TTopicFormatHandler [json_each_row]: Add client with id [3:7582946957272664743:2150]
2025-12-12T12:27:02.851410Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1052: RowDispatcher: TEvTryConnect to node id 3
2025-12-12T12:27:02.851459Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:587: RowDispatcher: EvNodeConnected, node id 3
2025-12-12T12:27:02.878520Z :FQ_ROW_DISPATCHER DEBUG: format_handler.cpp:559: TTopicFormatHandler [json_each_row]: UpdateParser to new schema with size 1
2025-12-12T12:27:02.892351Z :FQ_ROW_DISPATCHER INFO: json_parser.cpp:355: TJsonParser: Simdjson active implementation icelake (Intel/AMD AVX512), error skip mode: 0
2025-12-12T12:27:02.892431Z :FQ_ROW_DISPATCHER DEBUG: format_handler.cpp:570: TTopicFormatHandler [json_each_row]: Parser was created on schema with 1 columns
2025-12-12T12:27:02.892443Z :FQ_ROW_DISPATCHER TRACE: purecalc_filter.cpp:439: GenerateSql: No sql was generated
2025-12-12T12:27:02.892447Z :FQ_ROW_DISPATCHER TRACE: filters_set.cpp:116: TTopicFilters: Create program with client id [3:7582946957272664743:2150]
2025-12-12T12:27:02.892456Z :FQ_ROW_DISPATCHER TRACE: filters_set.cpp:110: TTopicFilters: Start program with client id [3:7582946957272664743:2150]
2025-12-12T12:27:02.892463Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:952: TopicSession [1:7582946966034090178:2148] SendStatistics
2025-12-12T12:27:02.892509Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1234: RowDispatcher: TEvSessionStatistic from [1:7582946966034090178:2148]
2025-12-12T12:27:03.215983Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582946944559253506:2082]
2025-12-12T12:27:03.216000Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:03.216024Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582946944559253466:2063]
2025-12-12T12:27:03.216039Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582946944559253466:2063]
2025-12-12T12:27:03.216042Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582946944559253466:2063]
2025-12-12T12:27:03.216053Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:03.216998Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 78b82b8d-1230c1ab-b5d0b60f-66f25fd07, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:03.222872Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:03.222883Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:03.248283Z :FQ_QUOTA_SERVICE DEBUG: quota_manager.cpp:230: IC Peers[2]: [2, 3]
2025-12-12T12:27:03.710000Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [2:7582946941773163192:2063]
2025-12-12T12:27:03.710024Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [2:7582946941773163192:2063]
2025-12-12T12:27:03.710027Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:329: Coordinator: Add new row dispatcher to map (state 0)
2025-12-12T12:27:03.710031Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:334: Coordinator: Schedule TEvRebalancing
2025-12-12T12:27:03.710036Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [2:7582946941773163192:2063]
2025-12-12T12:27:03.710046Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:392: Coordinator: EvNodeConnected 2
2025-12-12T12:27:04.217505Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 78b82b8d-1230c1ab-b5d0b60f-66f25fd08, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:04.231799Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:04.231814Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:04.655332Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [3:7582946948682729947:2063]
2025-12-12T12:27:04.655353Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [3:7582946948682729947:2063]
2025-12-12T12:27:04.655357Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:329: Coordinator: Add new row dispatcher to map (state 0)
2025-12-12T12:27:04.655363Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [3:7582946948682729947:2063]
2025-12-12T12:27:04.851316Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:952: TopicSession [1:7582946966034090178:2148] SendStatistics
2025-12-12T12:27:04.851360Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1234: RowDispatcher: TEvSessionStatistic from [1:7582946966034090178:2148]
2025-12-12T12:27:04.852498Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1067: RowDispatcher: Send TEvHeartbeat to [3:7582946957272664743:2150] query id ptqudq7ufk6rtvrqftt3
2025-12-12T12:27:04.857826Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:962: RowDispatcher: Received TEvHeartbeat from [3:7582946957272664743:2150], part id 0 query id ptqudq7ufk6rtvrqftt3
2025-12-12T12:27:05.216844Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582946944559253506:2082]
2025-12-12T12:27:05.216868Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:05.216896Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582946944559253466:2063]
2025-12-12T12:27:05.216899Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582946944559253466:2063]
2025-12-12T12:27:05.216906Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582946944559253466:2063]
2025-12-12T12:27:05.216916Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:05.217873Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 78b82b8d-1230c1ab-b5d0b60f-66f25fd09, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:05.235118Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:05.235134Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:05.711044Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [2:7582946941773163192:2063]
2025-12-12T12:27:05.711063Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [2:7582946941773163192:2063]
2025-12-12T12:27:05.711067Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [2:7582946941773163192:2063]
2025-12-12T12:27:06.218351Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 78b82b8d-1230c1ab-b5d0b60f-66f25fd010, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:06.222164Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:06.222182Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:06.654716Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [3:7582946948682729947:2063]
2025-12-12T12:27:06.654746Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [3:7582946948682729947:2063]
2025-12-12T12:27:06.654749Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [3:7582946948682729947:2063]
2025-12-12T12:27:06.853872Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:952: TopicSession [1:7582946966034090178:2148] SendStatistics
2025-12-12T12:27:06.853906Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1234: RowDispatcher: TEvSessionStatistic from [1:7582946966034090178:2148]
2025-12-12T12:27:06.855157Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:962: RowDispatcher: Received TEvHeartbeat from [3:7582946957272664743:2150], part id 0 query id ptqudq7ufk6rtvrqftt3
2025-12-12T12:27:07.213697Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:599: Coordinator: Send TEvGetNodesRequest to NodesManager
2025-12-12T12:27:07.213731Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:300: Received TNodesManagerActor::TEvGetNodesRequest
2025-12-12T12:27:07.213748Z :FQ_ROW_DISPATCHER INFO: coordinator.cpp:690: Coordinator: Updated node info, node count: 3
2025-12-12T12:27:07.218095Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582946944559253506:2082]
2025-12-12T12:27:07.218117Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:07.218139Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582946944559253466:2063]
2025-12-12T12:27:07.218145Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582946944559253466:2063]
2025-12-12T12:27:07.218148Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582946944559253466:2063]
2025-12-12T12:27:07.218166Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:07.218802Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 78b82b8d-1230c1ab-b5d0b60f-66f25fd011, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:07.220968Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-12-12T12:27:07.226227Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:07.226241Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:07.235206Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:389: Send NodeInfo with size: 2 to DynamicNameserver
2025-12-12T12:27:07.711875Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [2:7582946941773163192:2063]
2025-12-12T12:27:07.711892Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [2:7582946941773163192:2063]
2025-12-12T12:27:07.711896Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [2:7582946941773163192:2063]
2025-12-12T12:27:07.892602Z :FQ_ROW_DISPATCHER INFO: topic_session.cpp:516: TopicSession [1:7582946966034090178:2148] Create topic session, Path test_scheme_error_input/0, StartingMessageTimestamp 2025-12-12T12:27:00.317000Z, BufferSize 16000000, GetConsumerMode Without
2025-12-12T12:27:07.892652Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:27:07.892644Z :INFO: [local] [local] [2bc8a5d7-1c8c4b01-5bb19e6c-a8805471] Starting read session
2025-12-12T12:27:07.892670Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:07.892656Z :DEBUG: [local] [local] [2bc8a5d7-1c8c4b01-5bb19e6c-a8805471] Starting single session
2025-12-12T12:27:07.892716Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:07.892714Z :DEBUG: [local] [local] [2bc8a5d7-1c8c4b01-5bb19e6c-a8805471] [] In Reconnect, ReadSizeBudget = 8000000, ReadSizeServerDelta = 0
2025-12-12T12:27:07.892725Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:07.892723Z :DEBUG: [local] [local] [2bc8a5d7-1c8c4b01-5bb19e6c-a8805471] [] New values: ReadSizeBudget = 8000000, ReadSizeServerDelta = 0
2025-12-12T12:27:07.892730Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:07.892727Z :DEBUG: [local] [local] [2bc8a5d7-1c8c4b01-5bb19e6c-a8805471] [] Reconnecting session to cluster  in 0.000000s
2025-12-12T12:27:07.893347Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:466: TopicSession [1:7582946966034090178:2148] SubscribeOnNextEvent
2025-12-12T12:27:07.898438Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:07.898419Z :DEBUG: [local] [local] [2bc8a5d7-1c8c4b01-5bb19e6c-a8805471] [] Successfully connected. Initializing session
2025-12-12T12:27:07.900078Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:27:07.900068Z :INFO: [local] [local] [2bc8a5d7-1c8c4b01-5bb19e6c-a8805471] [] Got InitResponse. ReadSessionId: _1_1_14566660252344408761_v1
2025-12-12T12:27:07.900104Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:07.900102Z :DEBUG: [local] [local] [2bc8a5d7-1c8c4b01-5bb19e6c-a8805471] [] In ContinueReadingDataImpl, ReadSizeBudget = 8000000, ReadSizeServerDelta = 0
2025-12-12T12:27:07.900154Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:07.900152Z :DEBUG: [local] [local] [2bc8a5d7-1c8c4b01-5bb19e6c-a8805471] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 8000000
2025-12-12T12:27:07.902030Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:559: TopicSession [1:7582946966034090178:2148] TEvPqEventsReady
2025-12-12T12:27:07.902051Z :FQ_ROW_DISPATCHER DEBUG: topic_session.cpp:677: TopicSession [1:7582946966034090178:2148] StartPartitionSessionEvent received
2025-12-12T12:27:07.902054Z :FQ_ROW_DISPATCHER DEBUG: topic_session.cpp:685: TopicSession [1:7582946966034090178:2148] Confirm StartPartitionSession with offset (NULL)
2025-12-12T12:27:07.902068Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:27:07.902064Z :INFO: [local] [local] [2bc8a5d7-1c8c4b01-5bb19e6c-a8805471] [] Confirm partition stream create. Partition stream id: 1. Cluster: "-". Topic: "test_scheme_error_input". Partition: 0. Read offset: (NULL)
2025-12-12T12:27:07.902118Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:466: TopicSession [1:7582946966034090178:2148] SubscribeOnNextEvent
2025-12-12T12:27:07.903143Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:07.903134Z :DEBUG: [local] [local] [2bc8a5d7-1c8c4b01-5bb19e6c-a8805471] [] Got ReadResponse, serverBytesSize = 119, now ReadSizeBudget = 0, ReadSizeServerDelta = 7999881
2025-12-12T12:27:07.903170Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:07.903168Z :DEBUG: [local] [local] [2bc8a5d7-1c8c4b01-5bb19e6c-a8805471] [] In ContinueReadingDataImpl, ReadSizeBudget = 0, ReadSizeServerDelta = 7999881
2025-12-12T12:27:07.903211Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:07.903209Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 1 (0-1)
2025-12-12T12:27:07.903219Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:07.903215Z :DEBUG: [local] [local] [2bc8a5d7-1c8c4b01-5bb19e6c-a8805471] [] Returning serverBytesSize = 119 to budget
2025-12-12T12:27:07.903223Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:07.903222Z :DEBUG: [local] [local] [2bc8a5d7-1c8c4b01-5bb19e6c-a8805471] [] In ContinueReadingDataImpl, ReadSizeBudget = 119, ReadSizeServerDelta = 7999881
2025-12-12T12:27:07.903259Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:07.903257Z :DEBUG: [local] [local] [2bc8a5d7-1c8c4b01-5bb19e6c-a8805471] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 8000000
2025-12-12T12:27:07.903293Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:559: TopicSession [1:7582946966034090178:2148] TEvPqEventsReady
2025-12-12T12:27:07.903311Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:07.903309Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-12-12T12:27:07.903318Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:07.903316Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 1} (1-1)
2025-12-12T12:27:07.903327Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:07.903325Z :DEBUG: [local] [local] [2bc8a5d7-1c8c4b01-5bb19e6c-a8805471] [] The application data is transferred to the client. Number of messages 2, size 52 bytes
2025-12-12T12:27:07.903333Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:07.903331Z :DEBUG: [local] [local] [2bc8a5d7-1c8c4b01-5bb19e6c-a8805471] [] Returning serverBytesSize = 0 to budget
2025-12-12T12:27:07.903347Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:654: TopicSession [1:7582946966034090178:2148] Data received: Message { Data: "{"this": "is", not json}" Information: { Offset: 0 ProducerId: "" SeqNo: 0 CreateTime: 2025-12-12T12:27:04.187000Z WriteTime: 2025-12-12T12:27:04.188000Z MessageGroupId: "" Meta: { } MessageMeta: { } } Partition session id: 1 Topic: "test_scheme_error_input" Partition: 0 }
2025-12-12T12:27:07.903351Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:654: TopicSession [1:7582946966034090178:2148] Data received: Message { Data: "{"noch einmal / nicht json"}" Information: { Offset: 1 ProducerId: "" SeqNo: 0 CreateTime: 2025-12-12T12:27:04.187000Z WriteTime: 2025-12-12T12:27:04.188000Z MessageGroupId: "" Meta: { } MessageMeta: { } } Partition session id: 1 Topic: "test_scheme_error_input" Partition: 0 }
2025-12-12T12:27:07.903353Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:707: TopicSession [1:7582946966034090178:2148] SendToParsing, messages: 2
2025-12-12T12:27:07.903357Z :FQ_ROW_DISPATCHER TRACE: format_handler.cpp:417: TTopicFormatHandler [json_each_row]: Send 2 messages to parser
2025-12-12T12:27:07.903362Z :FQ_ROW_DISPATCHER TRACE: json_parser.cpp:388: TJsonParser: Add 2 messages to parse
2025-12-12T12:27:07.903371Z :FQ_ROW_DISPATCHER TRACE: json_parser.cpp:454: TJsonParser: Do parsing, first offset: 0, values:
{"this": "is", not json}{"noch einmal / nicht json"}                                                                
2025-12-12T12:27:07.903374Z :FQ_ROW_DISPATCHER TRACE: json_parser.cpp:590: TJsonParser: Init parser, skipped 0, outputRowId 0 size 116
2025-12-12T12:27:07.903483Z :FQ_ROW_DISPATCHER ERROR: format_handler.cpp:72: TTopicFormatHandler [json_each_row]: TParserHandler: Got parsing error: { <main>: Error: Failed to parse json message for offset 0, json item was corrupted: TAPE_ERROR: The JSON document has an improper structure: missing or superfluous commas, braces, missing keys, etc.  This is a fatal and unrecoverable error. Current data batch: {"this": "is", not json}{"noch einmal / nicht json"}                                                                , buffered offsets: 0 1 }
2025-12-12T12:27:07.903488Z :FQ_ROW_DISPATCHER ERROR: format_handler.cpp:629: TTopicFormatHandler [json_each_row]: Got fatal error: { <main>: Error: Failed to parse json message for offset 0, json item was corrupted: TAPE_ERROR: The JSON document has an improper structure: missing or superfluous commas, braces, missing keys, etc.  This is a fatal and unrecoverable error. Current data batch: {"this": "is", not json}{"noch einmal / nicht json"}                                                                , buffered offsets: 0 1 }
2025-12-12T12:27:07.903492Z :FQ_ROW_DISPATCHER WARN: format_handler.cpp:179: TTopicFormatHandler [json_each_row]: TClientHandler [3:7582946957272664743:2150]: OnClientError, { <main>: Error: Failed to parse json message for offset 0, json item was corrupted: TAPE_ERROR: The JSON document has an improper structure: missing or superfluous commas, braces, missing keys, etc.  This is a fatal and unrecoverable error. Current data batch: {"this": "is", not json}{"noch einmal / nicht json"}                                                                , buffered offsets: 0 1 }
2025-12-12T12:27:07.903500Z :FQ_ROW_DISPATCHER WARN: topic_session.cpp:909: TopicSession [1:7582946966034090178:2148] SendSessionError to [3:7582946957272664743:2150], status: { <main>: Error: Failed to parse json message for offset 0, json item was corrupted: TAPE_ERROR: The JSON document has an improper structure: missing or superfluous commas, braces, missing keys, etc.  This is a fatal and unrecoverable error. Current data batch: {"this": "is", not json}{"noch einmal / nicht json"}                                                                , buffered offsets: 0 1 }
2025-12-12T12:27:07.903520Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:466: TopicSession [1:7582946966034090178:2148] SubscribeOnNextEvent
2025-12-12T12:27:07.903535Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1120: RowDispatcher: Forward TEvSessionError from [1:7582946966034090178:2148] to [3:7582946957272664743:2150] query id ptqudq7ufk6rtvrqftt3
2025-12-12T12:27:07.903560Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:1016: RowDispatcher: DeleteConsumer, readActorId [3:7582946957272664743:2150] query id ptqudq7ufk6rtvrqftt3, partitions size 1
2025-12-12T12:27:07.903588Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:1036: RowDispatcher: Session is not used, sent TEvPoisonPill to [1:7582946966034090178:2148]
2025-12-12T12:27:07.903620Z :FQ_ROW_DISPATCHER DEBUG: topic_session.cpp:831: TopicSession [1:7582946966034090178:2148] TEvStopSession from [3:7582946957272664743:2150] topicPath test_scheme_error_input clients count 1
2025-12-12T12:27:07.903626Z :FQ_ROW_DISPATCHER DEBUG: format_handler.cpp:477: TTopicFormatHandler [json_each_row]: Remove client with id [3:7582946957272664743:2150]
2025-12-12T12:27:07.903629Z :FQ_ROW_DISPATCHER TRACE: filters_set.cpp:94: TTopicFilters: Remove program with client id [3:7582946957272664743:2150]
2025-12-12T12:27:07.903646Z :FQ_ROW_DISPATCHER DEBUG: format_handler.cpp:559: TTopicFormatHandler [json_each_row]: UpdateParser to new schema with size 0
2025-12-12T12:27:07.903649Z :FQ_ROW_DISPATCHER INFO: format_handler.cpp:584: TTopicFormatHandler [json_each_row]: No columns to parse, reset parser
2025-12-12T12:27:07.903788Z :FQ_ROW_DISPATCHER DEBUG: topic_session.cpp:924: TopicSession [1:7582946966034090178:2148] Close read session
2025-12-12T12:27:07.903808Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:27:07.903804Z :INFO: [local] [local] [2bc8a5d7-1c8c4b01-5bb19e6c-a8805471] Closing read session. Close timeout: 0.000000s
2025-12-12T12:27:07.903817Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:27:07.903815Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:test_scheme_error_input:0:1:1:0
2025-12-12T12:27:07.903823Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:27:07.903822Z :INFO: [local] [local] [2bc8a5d7-1c8c4b01-5bb19e6c-a8805471] Counters: { Errors: 0 CurrentSessionLifetimeMs: 11 BytesRead: 52 MessagesRead: 2 BytesReadCompressed: 52 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:27:07.903838Z :YDB_SDK NOTICE: actor.cpp:37: 2025-12-12T12:27:07.903836Z :NOTICE: [local] [local] [2bc8a5d7-1c8c4b01-5bb19e6c-a8805471] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Close with zero timeout " }
2025-12-12T12:27:07.903844Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:07.903843Z :DEBUG: [local] [local] [2bc8a5d7-1c8c4b01-5bb19e6c-a8805471] [] Abort session to cluster
2025-12-12T12:27:07.903966Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:27:07.903963Z :INFO: [local] [local] [2bc8a5d7-1c8c4b01-5bb19e6c-a8805471] Closing read session. Close timeout: 0.000000s
2025-12-12T12:27:07.903976Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:27:07.903974Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:test_scheme_error_input:0:1:1:0
2025-12-12T12:27:07.903981Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:27:07.903979Z :INFO: [local] [local] [2bc8a5d7-1c8c4b01-5bb19e6c-a8805471] Counters: { Errors: 0 CurrentSessionLifetimeMs: 11 BytesRead: 52 MessagesRead: 2 BytesReadCompressed: 52 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:27:07.903987Z :YDB_SDK NOTICE: actor.cpp:37: 2025-12-12T12:27:07.903986Z :NOTICE: [local] [local] [2bc8a5d7-1c8c4b01-5bb19e6c-a8805471] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T12:27:07.904019Z :FQ_ROW_DISPATCHER TRACE: topic_session.cpp:457: TopicSession [1:7582946966034090178:2148] Skip SubscribeOnNextEvent, has ReadSession: false, IsWaitingEvents: 1
2025-12-12T12:27:07.904037Z :FQ_ROW_DISPATCHER DEBUG: topic_session.cpp:449: TopicSession [1:7582946966034090178:2148] PassAway
2025-12-12T12:27:07.905862Z :FQ_ROW_DISPATCHER WARN: row_dispatcher.cpp:996: RowDispatcher: Ignore TEvStopSession from [3:7582946957272664743:2150]
2025-12-12T12:27:08.219262Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 78b82b8d-1230c1ab-b5d0b60f-66f25fd012, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:08.235157Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:08.235172Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 1
2025-12-12T12:27:08.235186Z :FQ_PENDING_FETCHER DEBUG: pending_fetcher.cpp:361: NewTask: Scope: yandexcloud://my_folder Id: ptqudq7ufk6rtvrqftt3 UserId: root@builtin AuthToken: **** (B6C6F477)
2025-12-12T12:27:08.235369Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 78b82b8d-1230c1ab-b5d0b60f-66f25fd013, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:08.235373Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:375: QueryId: ptqudq7ufk6rtvrqftt3 Start run actor. Compute state: FAILING
2025-12-12T12:27:08.235378Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:469: QueryId: ptqudq7ufk6rtvrqftt3 FillConnections
2025-12-12T12:27:08.235408Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:2333: QueryId: ptqudq7ufk6rtvrqftt3 Run actors params: { QueryId: ptqudq7ufk6rtvrqftt3 CloudId: mock_cloud UserId: root@builtin Owner: 78b82b8d-1230c1ab-b5d0b60f-66f25fd012 PreviousQueryRevision: 2 Connections: 1 Bindings: 0 AccountIdSignatures: 0 QueryType: STREAMING ExecuteMode: RUN ResultId: ptrudq7ufblagbkvfkk0 StateLoadMode: FROM_LAST_CHECKPOINT StreamingDisposition: { from_last_checkpoint { } } Status: FAILING DqGraphs: 1 DqGraphIndex: 0 Resource.TopicConsumers: 1 }
2025-12-12T12:27:08.235458Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:1827: QueryId: ptqudq7ufk6rtvrqftt3 Is about to finish query with status FAILED
2025-12-12T12:27:08.235489Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:1507: QueryId: ptqudq7ufk6rtvrqftt3 Start rate limiter resource deleter
2025-12-12T12:27:08.235500Z :FQ_PINGER TRACE: pinger.cpp:171: QueryId: ptqudq7ufk6rtvrqftt3, Owner: 78b82b8d-1230c1ab-b5d0b60f-66f25fd012 Start Pinger
2025-12-12T12:27:08.235504Z :STREAMS DEBUG: read_rule_deleter.cpp:214: ptqudq7ufk6rtvrqftt3: Create read rule deleter actor for `test_scheme_error_input` [0]
2025-12-12T12:27:08.235519Z :STREAMS DEBUG: read_rule_deleter.cpp:106: ptqudq7ufk6rtvrqftt3: Make request for read rule deletion for topic `test_scheme_error_input` [0]
2025-12-12T12:27:08.238762Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:08.238777Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:08.281634Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:1498: QueryId: ptqudq7ufk6rtvrqftt3 Rate limiter resource deletion finished. Success: 1. Issues: 
2025-12-12T12:27:08.281651Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:1919: QueryId: ptqudq7ufk6rtvrqftt3 SendPingAndPassAway, FinalQueryStatus FAILED
2025-12-12T12:27:08.281678Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:536: QueryId: ptqudq7ufk6rtvrqftt3 PassAway
2025-12-12T12:27:08.281924Z :FQ_PINGER TRACE: pinger.cpp:250: QueryId: ptqudq7ufk6rtvrqftt3, Owner: 78b82b8d-1230c1ab-b5d0b60f-66f25fd012 Forward ping request: { result_id { } status: FAILED resources { rate_limiter: READY compilation: READY topic_consumers_state: READY rate_limiter_path: "local/RateLimiter_a57e0649-393d-4a7f-b0b4-636f1bb05e6d/rate_limiter" topic_consumers { database: "local" topic_path: "test_scheme_error_input" consumer_name: "ptqudq7ufk6rtvrqftt3" cluster_endpoint: "localhost:14020" token_name: "cluster:default_yds" add_bearer_to_token: true } } finished_at { seconds: 1765542428 nanos: 235000000 } }
2025-12-12T12:27:08.281939Z :FQ_PINGER TRACE: pinger.cpp:393: QueryId: ptqudq7ufk6rtvrqftt3, Owner: 78b82b8d-1230c1ab-b5d0b60f-66f25fd012 Forward request Private::PingTask
2025-12-12T12:27:08.386457Z :FQ_PINGER TRACE: pinger.cpp:338: QueryId: ptqudq7ufk6rtvrqftt3, Owner: 78b82b8d-1230c1ab-b5d0b60f-66f25fd012 Ping response success: {  }
2025-12-12T12:27:08.386479Z :FQ_PINGER DEBUG: pinger.cpp:379: QueryId: ptqudq7ufk6rtvrqftt3, Owner: 78b82b8d-1230c1ab-b5d0b60f-66f25fd012 Query finished
2025-12-12T12:27:08.386482Z :FQ_PINGER TRACE: pinger.cpp:187: QueryId: ptqudq7ufk6rtvrqftt3, Owner: 78b82b8d-1230c1ab-b5d0b60f-66f25fd012 Stop Pinger
2025-12-12T12:27:08.655075Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [3:7582946948682729947:2063]
2025-12-12T12:27:08.655090Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [3:7582946948682729947:2063]
2025-12-12T12:27:08.655097Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [3:7582946948682729947:2063]
2025-12-12T12:27:08.709719Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:608: Coordinator: Rebalancing...
2025-12-12T12:27:08.709736Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:615: Coordinator: Current state (rebalancing):
2025-12-12T12:27:08.709743Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:617: Coordinator:   node 2 ([2:7582946941773163192:2063]) state Initializing connected 1 partitions count 0
2025-12-12T12:27:08.709746Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:617: Coordinator:   node 1 ([1:7582946944559253466:2063]) state Started connected 1 partitions count 1
2025-12-12T12:27:08.709761Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:617: Coordinator:   node 3 ([3:7582946948682729947:2063]) state Initializing connected 1 partitions count 0
2025-12-12T12:27:08.709765Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:648: Coordinator: Send TEvCoordinatorDistributionReset to [3:7582946957272664743:2150]
2025-12-12T12:27:08.709777Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:615: Coordinator: Current state (after rebalancing):
2025-12-12T12:27:08.709780Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:617: Coordinator:   node 2 ([2:7582946941773163192:2063]) state Started connected 1 partitions count 0
2025-12-12T12:27:08.709782Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:617: Coordinator:   node 1 ([1:7582946944559253466:2063]) state Started connected 1 partitions count 0
2025-12-12T12:27:08.709787Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:617: Coordinator:   node 3 ([3:7582946948682729947:2063]) state Started connected 1 partitions count 0
2025-12-12T12:27:08.710177Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:416: Coordinator: TEvUndelivered, ev: TSystem::Undelivered
2025-12-12T12:27:08.797912Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:144: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Start compute actor [1:7582946991803893974:2162], task: 1
2025-12-12T12:27:08.797977Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:114: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Use CPU quota: 1. Rate limiter resource: { "local/RateLimiter_a57e0649-393d-4a7f-b0b4-636f1bb05e6d/rate_limiter", "mock_cloud/my_folder/ptqudq7ufbdb48s1rj9n" }
2025-12-12T12:27:08.799166Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: 78b82b8d-1230c1ab-b5d0b60f-66f25fd0 2025-12-12 12:27:08.799 DEBUG ydbd(pid=1188997, tid=0x00007F4A4C904640) [DQ] tasks_runner_local.cpp:267: {TODO/1} Build task: 1
2025-12-12T12:27:08.799266Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: 78b82b8d-1230c1ab-b5d0b60f-66f25fd0 2025-12-12 12:27:08.799 DEBUG ydbd(pid=1188997, tid=0x00007F4A4C904640) [DQ] tasks_runner_local.cpp:267: {TODO/1} task: 1, program size: 32, llvm: ``.
2025-12-12T12:27:08.836427Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: 78b82b8d-1230c1ab-b5d0b60f-66f25fd0 2025-12-12 12:27:08.836 DEBUG ydbd(pid=1188997, tid=0x00007F4A4C904640) [DQ] tasks_runner_local.cpp:267: {TODO/1} Build task: 1 takes 37202 us
2025-12-12T12:27:08.836463Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: 78b82b8d-1230c1ab-b5d0b60f-66f25fd0 2025-12-12 12:27:08.836 DEBUG ydbd(pid=1188997, tid=0x00007F4A4C904640) [DQ] tasks_runner_local.cpp:267: {TODO/1} Prepare task: 1
2025-12-12T12:27:08.836496Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: 78b82b8d-1230c1ab-b5d0b60f-66f25fd0 2025-12-12 12:27:08.836 DEBUG ydbd(pid=1188997, tid=0x00007F4A4C904640) [DQ] tasks_runner_local.cpp:267: {TODO/1} Prepare task: 1, takes 22 us
2025-12-12T12:27:08.836599Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:197: [] Task: 1. Got TEvNewCheckpointCoordinator event: generation 1, actorId: [3:7582946991632403181:2168]
2025-12-12T12:27:08.836606Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:208: [] Task: 1. Assign checkpoint coordinator (generation = 1)
2025-12-12T12:27:08.837552Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1360: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Create source for input 0 { Source { Type: "PqSource" Settings { type_url: "type.googleapis.com/NYql.NPq.NProto.TDqPqTopicSource" value: "\n\027test_scheme_error_input\022\024ptqudq7ufbdb48s1rj9n\032\017localhost:14020\"\025\n\023cluster:default_yds*\005local0\002@\001b\004timej\024[\"DataType\";\"Int32\"]x\001\222\001\024ptcudq7ufkllb25uoffr\232\001\rjson_each_row\242\001.[\"StructType\";[[\"time\";[\"DataType\";\"Int32\"]]]]\262\001\002\022\000\272\001\026\n\010cloud_id\022\nmock_cloud\272\001 \n\005scope\022\027yandexcloud://my_folder" } WatermarksMode: WATERMARKS_MODE_DISABLED } }
2025-12-12T12:27:08.837919Z :KQP_COMPUTE INFO: dq_pq_rd_read_actor.cpp:557: SelfId: [0:0:0], TxId: ptqudq7ufbdb48s1rj9n, task: 1. PQ source. Start read actor, local row dispatcher [0:5788050504107380562:5260383], metadatafields: , partitions: 0, skip json errors: 0
2025-12-12T12:27:08.837972Z :KQP_COMPUTE DEBUG: dq_pq_read_actor_base.cpp:153: SelfId: [0:0:0], TxId: ptqudq7ufbdb48s1rj9n, 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:08.837997Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1447: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Create sink for output 0 { Sink { Type: "PqSink" Settings { type_url: "type.googleapis.com/NYql.NPq.NProto.TDqPqTopicSink" value: "\n\030test_scheme_error_output\022\017localhost:14020\032\025\n\023cluster:default_yds\"\005local0\0018\002" } } }
2025-12-12T12:27:08.838201Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:395: [ptqudq7ufbdb48s1rj9n-0] Task: 1. Handle connected node 3
2025-12-12T12:27:08.839990Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1064: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Received channels info: 
2025-12-12T12:27:08.854086Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1059: RowDispatcher: No consumer with EventQueueId = 0
2025-12-12T12:27:08.854126Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:239: [ptqudq7ufbdb48s1rj9n-0] Task: 1. [Checkpoint 1.1] TEvInjectCheckpoint
2025-12-12T12:27:08.854132Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1164: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Got TEvRun from actor [3:7582946991632403181:2168]
2025-12-12T12:27:08.854145Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Poll inputs
2025-12-12T12:27:08.854147Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1494: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Skip polling sources because of pending checkpoint
2025-12-12T12:27:08.854150Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. DoExecuteImpl: 1
2025-12-12T12:27:08.854239Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:462: SelfId: [1:7582946991803893976:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Pending 1 checkpoints to be sent
2025-12-12T12:27:08.854246Z :KQP_COMPUTE TRACE: dq_compute_memory_quota.h:97: TxId: ptqudq7ufbdb48s1rj9n, task: 1. Peak memory usage: 131072
2025-12-12T12:27:08.854254Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. update task runner stats
2025-12-12T12:27:08.854279Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 1 watermark injected: (empty maybe)
2025-12-12T12:27:08.854283Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:447: [ptqudq7ufbdb48s1rj9n-0] Task: 1. [Checkpoint 1.1] Performing task checkpoint
2025-12-12T12:27:08.854285Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:816: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Save state
2025-12-12T12:27:08.854301Z :KQP_COMPUTE DEBUG: dq_pq_read_actor_base.cpp:94: SelfId: [0:0:0], TxId: ptqudq7ufbdb48s1rj9n, task: 1. PQ source. SessionId: empty SaveState, offsets: 
2025-12-12T12:27:08.854309Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:474: [ptqudq7ufbdb48s1rj9n-0] Task: 1. [Checkpoint 1.1] CA state saved
2025-12-12T12:27:08.854311Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:449: [ptqudq7ufbdb48s1rj9n-0] Task: 1. [Checkpoint 1.1] Injecting checkpoint barrier to outputs
2025-12-12T12:27:08.854314Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:27:08.854318Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-12T12:27:08.854321Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1107: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Ask CPU quota: 40ms
2025-12-12T12:27:08.854340Z :KQP_COMPUTE INFO: dq_async_compute_actor.cpp:1010: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Resume inputs
2025-12-12T12:27:08.854343Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [0:0:0], TxId: ptqudq7ufbdb48s1rj9n, TaskId: 1, PQ sink. SendData. Batch: 0. Checkpoint: 1. Finished: 0
2025-12-12T12:27:08.854446Z :KQP_COMPUTE DEBUG: dq_pq_write_actor.cpp:240: SelfId: [0:0:0], TxId: ptqudq7ufbdb48s1rj9n, TaskId: 1, PQ sink. [Checkpoint 1.1] Send checkpoint state immediately
2025-12-12T12:27:08.854625Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:418: SelfId: [0:0:0], TxId: ptqudq7ufbdb48s1rj9n, TaskId: 1, PQ sink. Save checkpoint { Id: 1 Generation: 1 Type: CHECKPOINT_TYPE_SNAPSHOT } state: { SourceId: "af2e0234-304b601d-51c6665c-694fb5e2" }
2025-12-12T12:27:08.854630Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:524: [ptqudq7ufbdb48s1rj9n-0] Task: 1. Sink[0] state saved
2025-12-12T12:27:08.854646Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:536: [ptqudq7ufbdb48s1rj9n-0] Task: 1. [Checkpoint 1.1] Task checkpoint is done. Send to storage
2025-12-12T12:27:08.854649Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:460: [ptqudq7ufbdb48s1rj9n-0] [1:1] Got TEvSaveTaskState: task 1
2025-12-12T12:27:08.854653Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Sink 0: sent 0 bytes of data and 6 bytes of checkpoint barrier
2025-12-12T12:27:08.854655Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-12T12:27:08.854664Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Poll inputs
2025-12-12T12:27:08.854666Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Poll sources
2025-12-12T12:27:08.854669Z :KQP_COMPUTE TRACE: dq_pq_rd_read_actor.cpp:767: SelfId: [0:0:0], TxId: ptqudq7ufbdb48s1rj9n, task: 1. PQ source. GetAsyncInputData freeSpace = 1000000
2025-12-12T12:27:08.854675Z :KQP_COMPUTE DEBUG: dq_pq_rd_read_actor.cpp:1515: SelfId: [1:7582946991803893978:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1, Cluster: . PQ source. Switch to single-cluster mode
2025-12-12T12:27:08.854679Z :KQP_COMPUTE INFO: dq_pq_rd_read_actor.cpp:608: SelfId: [1:7582946991803893978:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1, Cluster: . PQ source. Send TEvCoordinatorChangesSubscribe to local RD ([0:5788050504107380562:5260383])
2025-12-12T12:27:08.854690Z :KQP_COMPUTE INFO: dq_pq_rd_read_actor.cpp:635: SelfId: [1:7582946991803893978:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1, Cluster: . PQ source. Send TEvCoordinatorChangesSubscribe to local row dispatcher, self id [1:7582946991803893978:2162]
2025-12-12T12:27:08.854705Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:81: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, 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:08.854708Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:637: RowDispatcher: TEvCoordinatorChangesSubscribe from [1:7582946991803893978:2162]
2025-12-12T12:27:08.854718Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:637: RowDispatcher: TEvCoordinatorChangesSubscribe from [1:7582946991803893978:2162]
2025-12-12T12:27:08.854723Z :KQP_COMPUTE DEBUG: dq_pq_rd_read_actor.cpp:1009: SelfId: [1:7582946991803893978:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1, Cluster: . PQ source. TEvCoordinatorChanged, new coordinator [1:7582946944559253506:2082]
2025-12-12T12:27:08.854729Z :KQP_COMPUTE INFO: dq_pq_rd_read_actor.cpp:655: SelfId: [1:7582946991803893978:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1, Cluster: . PQ source. Send TEvCoordinatorRequest to coordinator [1:7582946944559253506:2082], partIds: 0 cookie 1
2025-12-12T12:27:08.854755Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-12-12T12:27:08.854758Z :KQP_COMPUTE DEBUG: dq_pq_rd_read_actor.cpp:1009: SelfId: [1:7582946991803893978:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1, Cluster: . PQ source. TEvCoordinatorChanged, new coordinator [1:7582946944559253506:2082]
2025-12-12T12:27:08.854781Z :FQ_ROW_DISPATCHER INFO: coordinator.cpp:507: Coordinator: TEvCoordinatorRequest from [1:7582946991803893978:2162], test_scheme_error_input, partIds: 0
2025-12-12T12:27:08.854819Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:562: Coordinator: Send TEvCoordinatorResult to [1:7582946991803893978:2162]
2025-12-12T12:27:08.854856Z :KQP_COMPUTE INFO: dq_pq_rd_read_actor.cpp:1053: SelfId: [1:7582946991803893978:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1, Cluster: . PQ source. Received TEvCoordinatorResult from [1:7582946944559253506:2082], cookie 1
2025-12-12T12:27:08.854863Z :KQP_COMPUTE INFO: dq_pq_rd_read_actor.cpp:1352: SelfId: [1:7582946991803893978:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1, Cluster: . PQ source. UpdateSessions, Sessions size 0
2025-12-12T12:27:08.854865Z :KQP_COMPUTE INFO: dq_pq_rd_read_actor.cpp:1355: SelfId: [1:7582946991803893978:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1, Cluster: . PQ source. Distribution is changed, remove sessions
2025-12-12T12:27:08.854882Z :KQP_COMPUTE INFO: dq_pq_rd_read_actor.cpp:1374: SelfId: [1:7582946991803893978:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1, Cluster: . PQ source. Create session to [2:7582946941773163192:2063], generation 1
2025-12-12T12:27:08.854893Z :KQP_COMPUTE INFO: dq_pq_rd_read_actor.cpp:719: SelfId: [1:7582946991803893978:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1, Cluster: . PQ source. Send TEvStartSession to [2:7582946941773163192:2063], connection id 1 partitions offsets (0 / <empty>),
2025-12-12T12:27:08.855479Z :KQP_COMPUTE TRACE: dq_pq_rd_read_actor.cpp:963: SelfId: [1:7582946991803893978:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1, Cluster: . PQ source. Received TEvRetry, EventQueueId 1
2025-12-12T12:27:08.855541Z :KQP_COMPUTE DEBUG: dq_pq_rd_read_actor.cpp:1078: SelfId: [1:7582946991803893978:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1, Cluster: . PQ source. EvNodeConnected 2
2025-12-12T12:27:08.858931Z :KQP_COMPUTE INFO: dq_pq_rd_read_actor.cpp:864: SelfId: [1:7582946991803893978:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1, Cluster: . PQ source. Received TEvStartSessionAck from [2:7582946941773163192:2063], seqNo 1, ConfirmedSeqNo 1, generation 1
2025-12-12T12:27:08.859451Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1165: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. CPU quota delay: 5ms
2025-12-12T12:27:08.859454Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:27:08.859435Z :INFO: [local] OnFederationDiscovery fall back to single mode, database=local
2025-12-12T12:27:08.859538Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. update task runner stats
2025-12-12T12:27:08.859595Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-12T12:27:08.859603Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:27:08.859608Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-12T12:27:08.859610Z :YDB_SDK INFO: actor.cpp:37: [] [] Start federated write session to database '' (previous was <empty>) FederationState: { Status: SUCCESS SelfLocation: "" DbInfos: [ { path: "local" endpoint: "localhost:14020" status: AVAILABLE weight: 100 } ] ControlPlaneEndpoint: localhost:14020 }
2025-12-12T12:27:08.859619Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [1:7582946991803893979:2162], TxId: ptqudq7ufbdb48s1rj9n, TaskId: 1, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-12-12T12:27:08.859635Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-12-12T12:27:08.859641Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-12T12:27:08.859677Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:08.859669Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ufbdb48s1rj9n, TaskId: 1, PQ sink. ]  SessionId []  MessageGroupId [af2e0234-304b601d-51c6665c-694fb5e2] Write session: try to update token
2025-12-12T12:27:08.859975Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:27:08.859971Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ufbdb48s1rj9n, TaskId: 1, PQ sink. ]  SessionId []  MessageGroupId [af2e0234-304b601d-51c6665c-694fb5e2] Start write session. Will connect to nodeId: 0
2025-12-12T12:27:08.860199Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:08.860194Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ufbdb48s1rj9n, TaskId: 1, PQ sink. ]  SessionId []  MessageGroupId [af2e0234-304b601d-51c6665c-694fb5e2] Write session: write to message_group: af2e0234-304b601d-51c6665c-694fb5e2
2025-12-12T12:27:08.860241Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:08.860240Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ufbdb48s1rj9n, TaskId: 1, PQ sink. ]  SessionId []  MessageGroupId [af2e0234-304b601d-51c6665c-694fb5e2] Write session: send init request: init_request { path: "test_scheme_error_output" producer_id: "af2e0234-304b601d-51c6665c-694fb5e2" message_group_id: "af2e0234-304b601d-51c6665c-694fb5e2" }
2025-12-12T12:27:08.860246Z :YDB_SDK TRACE: actor.cpp:37: 2025-12-12T12:27:08.860243Z :TRACE: [local] TRACE_EVENT InitRequest 
2025-12-12T12:27:08.860328Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:08.860326Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ufbdb48s1rj9n, TaskId: 1, PQ sink. ]  SessionId []  MessageGroupId [af2e0234-304b601d-51c6665c-694fb5e2] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T12:27:08.864279Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:484: [ptqudq7ufbdb48s1rj9n-0] [1:1] TEvSaveTaskState Apply: task: 1
2025-12-12T12:27:08.864298Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:499: [ptqudq7ufbdb48s1rj9n-0] [1:1] Send TEvSaveTaskStateResult: task: 1
2025-12-12T12:27:08.867504Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:08.867496Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ufbdb48s1rj9n, TaskId: 1, PQ sink. ]  SessionId []  MessageGroupId [af2e0234-304b601d-51c6665c-694fb5e2] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T12:27:08.867541Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:27:08.867529Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ufbdb48s1rj9n, TaskId: 1, PQ sink. ]  SessionId []  MessageGroupId [af2e0234-304b601d-51c6665c-694fb5e2] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1765542428867 BytesWritten: 0 MessagesWritten: 0 BytesWrittenCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:27:08.867559Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:27:08.867557Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ufbdb48s1rj9n, TaskId: 1, PQ sink. ]  SessionId []  MessageGroupId [af2e0234-304b601d-51c6665c-694fb5e2] Write session established. Init response: session_id: "af2e0234-304b601d-51c6665c-694fb5e2|7db27ca4-864a3ba1-db8239cf-66aae3e0_0"
2025-12-12T12:27:08.867565Z :YDB_SDK TRACE: actor.cpp:37: 2025-12-12T12:27:08.867563Z :TRACE: [local] TRACE_EVENT InitResponse  partition_id=0 session_id=af2e0234-304b601d-51c6665c-694fb5e2|7db27ca4-864a3ba1-db8239cf-66aae3e0_0
2025-12-12T12:27:08.867570Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:08.867568Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ufbdb48s1rj9n, TaskId: 1, PQ sink. ]  SessionId [af2e0234-304b601d-51c6665c-694fb5e2|7db27ca4-864a3ba1-db8239cf-66aae3e0_0]  MessageGroupId [af2e0234-304b601d-51c6665c-694fb5e2] Write session: set DirectWriteToPartitionId 0
2025-12-12T12:27:08.867621Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:27:08.867618Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ufbdb48s1rj9n, TaskId: 1, PQ sink. ]  SessionId [af2e0234-304b601d-51c6665c-694fb5e2|7db27ca4-864a3ba1-db8239cf-66aae3e0_0]  PartitionId [0]  Generation [0] Get partition location async, partition 0, delay 0.000000s
2025-12-12T12:27:08.867644Z :YDB_SDK TRACE: actor.cpp:37: 2025-12-12T12:27:08.867642Z :TRACE: [local] TRACE_EVENT DescribePartitionRequest  path=local/test_scheme_error_output partition_id=0
2025-12-12T12:27:08.867779Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:08.867775Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ufbdb48s1rj9n, TaskId: 1, PQ sink. ]  SessionId [af2e0234-304b601d-51c6665c-694fb5e2|7db27ca4-864a3ba1-db8239cf-66aae3e0_0]  PartitionId [0]  Generation [0]  Getting partition location, partition 0
2025-12-12T12:27:08.869857Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:27:08.869847Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ufbdb48s1rj9n, TaskId: 1, PQ sink. ]  SessionId [af2e0234-304b601d-51c6665c-694fb5e2|7db27ca4-864a3ba1-db8239cf-66aae3e0_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:08.869875Z :YDB_SDK TRACE: actor.cpp:37: 2025-12-12T12:27:08.869873Z :TRACE: [local] TRACE_EVENT DescribePartitionResponse  partition_id=0 active=1 pl_node_id=1 pl_generation=1
2025-12-12T12:27:08.869882Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:08.869880Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ufbdb48s1rj9n, TaskId: 1, PQ sink. ]  SessionId [af2e0234-304b601d-51c6665c-694fb5e2|7db27ca4-864a3ba1-db8239cf-66aae3e0_0]  PartitionId [0]  Generation [0] GetPreferredEndpoint: partitionId 0, partitionNodeId 1 exists in the endpoint pool.
2025-12-12T12:27:08.869889Z :YDB_SDK TRACE: actor.cpp:37: 2025-12-12T12:27:08.869887Z :TRACE: [local] TRACE_EVENT PreferredPartitionLocation  Endpoint= NodeId=1 Generation=1
2025-12-12T12:27:08.869893Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:27:08.869891Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ufbdb48s1rj9n, TaskId: 1, PQ sink. ]  SessionId [af2e0234-304b601d-51c6665c-694fb5e2|7db27ca4-864a3ba1-db8239cf-66aae3e0_0]  PartitionId [0]  Generation [1] Start write session. Will connect to nodeId: 1
2025-12-12T12:27:08.871171Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:08.871164Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ufbdb48s1rj9n, TaskId: 1, PQ sink. ]  SessionId [af2e0234-304b601d-51c6665c-694fb5e2|7db27ca4-864a3ba1-db8239cf-66aae3e0_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 1, Msg: CANCELLED, Details: , InternalError: 0
2025-12-12T12:27:08.871279Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:08.871276Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ufbdb48s1rj9n, TaskId: 1, PQ sink. ]  SessionId [af2e0234-304b601d-51c6665c-694fb5e2|7db27ca4-864a3ba1-db8239cf-66aae3e0_0]  PartitionId [0]  Generation [1] Write session: direct write to partition: 0, generation 1
2025-12-12T12:27:08.871303Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:08.871301Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ufbdb48s1rj9n, TaskId: 1, PQ sink. ]  SessionId [af2e0234-304b601d-51c6665c-694fb5e2|7db27ca4-864a3ba1-db8239cf-66aae3e0_0]  PartitionId [0]  Generation [1] Write session: send init request: init_request { path: "test_scheme_error_output" producer_id: "af2e0234-304b601d-51c6665c-694fb5e2" partition_with_generation { generation: 1 } }
2025-12-12T12:27:08.871307Z :YDB_SDK TRACE: actor.cpp:37: 2025-12-12T12:27:08.871306Z :TRACE: [local] TRACE_EVENT InitRequest  pwg_partition_id=0 pwg_generation=1
2025-12-12T12:27:08.871416Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:08.871413Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ufbdb48s1rj9n, TaskId: 1, PQ sink. ]  SessionId [af2e0234-304b601d-51c6665c-694fb5e2|7db27ca4-864a3ba1-db8239cf-66aae3e0_0]  PartitionId [0]  Generation [1] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T12:27:08.879362Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:08.879351Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ufbdb48s1rj9n, TaskId: 1, PQ sink. ]  SessionId [af2e0234-304b601d-51c6665c-694fb5e2|7db27ca4-864a3ba1-db8239cf-66aae3e0_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T12:27:08.879398Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:27:08.879395Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ufbdb48s1rj9n, TaskId: 1, PQ sink. ]  SessionId [af2e0234-304b601d-51c6665c-694fb5e2|7db27ca4-864a3ba1-db8239cf-66aae3e0_0]  PartitionId [0]  Generation [1] Write session established. Init response: session_id: "af2e0234-304b601d-51c6665c-694fb5e2|f3688066-990d94fa-119c9bc4-b0a81743_0"
2025-12-12T12:27:08.879403Z :YDB_SDK TRACE: actor.cpp:37: 2025-12-12T12:27:08.879400Z :TRACE: [local] TRACE_EVENT InitResponse  partition_id=0 session_id=af2e0234-304b601d-51c6665c-694fb5e2|f3688066-990d94fa-119c9bc4-b0a81743_0
2025-12-12T12:27:08.879406Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:08.879405Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ufbdb48s1rj9n, TaskId: 1, PQ sink. ]  SessionId [af2e0234-304b601d-51c6665c-694fb5e2|f3688066-990d94fa-119c9bc4-b0a81743_0]  PartitionId [0]  Generation [1] Write session: set DirectWriteToPartitionId 0
2025-12-12T12:27:08.898777Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:759: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Commit state
2025-12-12T12:27:09.218639Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582946944559253506:2082]
2025-12-12T12:27:09.218665Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:09.218674Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582946944559253466:2063]
2025-12-12T12:27:09.218678Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582946944559253466:2063]
2025-12-12T12:27:09.218682Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582946944559253466:2063]
2025-12-12T12:27:09.218694Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:09.219628Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 78b82b8d-1230c1ab-b5d0b60f-66f25fd014, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:09.223896Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:09.223926Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:09.712773Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [2:7582946941773163192:2063]
2025-12-12T12:27:09.712793Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [2:7582946941773163192:2063]
2025-12-12T12:27:09.712797Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [2:7582946941773163192:2063]
2025-12-12T12:27:09.712798Z :KQP_COMPUTE TRACE: dq_pq_rd_read_actor.cpp:890: SelfId: [1:7582946991803893978:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1, Cluster: . PQ source. Received TEvStatistics from [2:7582946941773163192:2063], seqNo 2, ConfirmedSeqNo 1 generation 1
2025-12-12T12:27:09.859228Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:239: [ptqudq7ufbdb48s1rj9n-0] Task: 1. [Checkpoint 1.2] TEvInjectCheckpoint
2025-12-12T12:27:09.859253Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Poll inputs
2025-12-12T12:27:09.859257Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1494: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Skip polling sources because of pending checkpoint
2025-12-12T12:27:09.859259Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. DoExecuteImpl: 1
2025-12-12T12:27:09.859334Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:462: SelfId: [1:7582946991803893976:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Pending 1 checkpoints to be sent
2025-12-12T12:27:09.859346Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. update task runner stats
2025-12-12T12:27:09.859383Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 1 watermark injected: (empty maybe)
2025-12-12T12:27:09.859389Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:447: [ptqudq7ufbdb48s1rj9n-0] Task: 1. [Checkpoint 1.2] Performing task checkpoint
2025-12-12T12:27:09.859392Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:816: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Save state
2025-12-12T12:27:09.859402Z :KQP_COMPUTE DEBUG: dq_pq_read_actor_base.cpp:94: SelfId: [1:7582946991803893978:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1, Cluster: . PQ source. SessionId: empty SaveState, offsets: 
2025-12-12T12:27:09.859410Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:474: [ptqudq7ufbdb48s1rj9n-0] Task: 1. [Checkpoint 1.2] CA state saved
2025-12-12T12:27:09.859417Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:449: [ptqudq7ufbdb48s1rj9n-0] Task: 1. [Checkpoint 1.2] Injecting checkpoint barrier to outputs
2025-12-12T12:27:09.859420Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:27:09.859425Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-12T12:27:09.859432Z :KQP_COMPUTE INFO: dq_async_compute_actor.cpp:1010: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Resume inputs
2025-12-12T12:27:09.859435Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [1:7582946991803893979:2162], TxId: ptqudq7ufbdb48s1rj9n, TaskId: 1, PQ sink. SendData. Batch: 0. Checkpoint: 1. Finished: 0
2025-12-12T12:27:09.859438Z :KQP_COMPUTE DEBUG: dq_pq_write_actor.cpp:240: SelfId: [1:7582946991803893979:2162], TxId: ptqudq7ufbdb48s1rj9n, TaskId: 1, PQ sink. [Checkpoint 1.2] Send checkpoint state immediately
2025-12-12T12:27:09.859463Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:418: SelfId: [1:7582946991803893979:2162], TxId: ptqudq7ufbdb48s1rj9n, TaskId: 1, PQ sink. Save checkpoint { Id: 2 Generation: 1 Type: CHECKPOINT_TYPE_SNAPSHOT } state: { SourceId: "af2e0234-304b601d-51c6665c-694fb5e2" }
2025-12-12T12:27:09.859471Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:524: [ptqudq7ufbdb48s1rj9n-0] Task: 1. Sink[0] state saved
2025-12-12T12:27:09.859482Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:536: [ptqudq7ufbdb48s1rj9n-0] Task: 1. [Checkpoint 1.2] Task checkpoint is done. Send to storage
2025-12-12T12:27:09.859493Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Sink 0: sent 0 bytes of data and 6 bytes of checkpoint barrier
2025-12-12T12:27:09.859496Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-12T12:27:09.859499Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Poll inputs
2025-12-12T12:27:09.859503Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Poll sources
2025-12-12T12:27:09.859504Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:460: [ptqudq7ufbdb48s1rj9n-0] [1:2] Got TEvSaveTaskState: task 1
2025-12-12T12:27:09.859505Z :KQP_COMPUTE TRACE: dq_pq_rd_read_actor.cpp:767: SelfId: [1:7582946991803893978:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1, Cluster: . PQ source. GetAsyncInputData freeSpace = 1000000
2025-12-12T12:27:09.859510Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:81: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, 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:09.859518Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-12-12T12:27:09.859535Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. update task runner stats
2025-12-12T12:27:09.859544Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-12T12:27:09.859545Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:27:09.859546Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-12T12:27:09.859550Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [1:7582946991803893979:2162], TxId: ptqudq7ufbdb48s1rj9n, TaskId: 1, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-12-12T12:27:09.859552Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-12-12T12:27:09.859554Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-12T12:27:09.863157Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:484: [ptqudq7ufbdb48s1rj9n-0] [1:2] TEvSaveTaskState Apply: task: 1
2025-12-12T12:27:09.863171Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:499: [ptqudq7ufbdb48s1rj9n-0] [1:2] Send TEvSaveTaskStateResult: task: 1
2025-12-12T12:27:09.889155Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:759: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Commit state
2025-12-12T12:27:10.220152Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 78b82b8d-1230c1ab-b5d0b60f-66f25fd015, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:10.226001Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:10.226016Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:10.659210Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [3:7582946948682729947:2063]
2025-12-12T12:27:10.659226Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [3:7582946948682729947:2063]
2025-12-12T12:27:10.659229Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [3:7582946948682729947:2063]
2025-12-12T12:27:10.852098Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:239: [ptqudq7ufbdb48s1rj9n-0] Task: 1. [Checkpoint 1.3] TEvInjectCheckpoint
2025-12-12T12:27:10.852116Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Poll inputs
2025-12-12T12:27:10.852118Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1494: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Skip polling sources because of pending checkpoint
2025-12-12T12:27:10.852119Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. DoExecuteImpl: 1
2025-12-12T12:27:10.852190Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:462: SelfId: [1:7582946991803893976:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Pending 1 checkpoints to be sent
2025-12-12T12:27:10.852197Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. update task runner stats
2025-12-12T12:27:10.852233Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 1 watermark injected: (empty maybe)
2025-12-12T12:27:10.852238Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:447: [ptqudq7ufbdb48s1rj9n-0] Task: 1. [Checkpoint 1.3] Performing task checkpoint
2025-12-12T12:27:10.852240Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:816: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Save state
2025-12-12T12:27:10.852249Z :KQP_COMPUTE DEBUG: dq_pq_read_actor_base.cpp:94: SelfId: [1:7582946991803893978:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1, Cluster: . PQ source. SessionId: empty SaveState, offsets: 
2025-12-12T12:27:10.852257Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:474: [ptqudq7ufbdb48s1rj9n-0] Task: 1. [Checkpoint 1.3] CA state saved
2025-12-12T12:27:10.852260Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:449: [ptqudq7ufbdb48s1rj9n-0] Task: 1. [Checkpoint 1.3] Injecting checkpoint barrier to outputs
2025-12-12T12:27:10.852262Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:27:10.852267Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-12T12:27:10.852272Z :KQP_COMPUTE INFO: dq_async_compute_actor.cpp:1010: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Resume inputs
2025-12-12T12:27:10.852274Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [1:7582946991803893979:2162], TxId: ptqudq7ufbdb48s1rj9n, TaskId: 1, PQ sink. SendData. Batch: 0. Checkpoint: 1. Finished: 0
2025-12-12T12:27:10.852276Z :KQP_COMPUTE DEBUG: dq_pq_write_actor.cpp:240: SelfId: [1:7582946991803893979:2162], TxId: ptqudq7ufbdb48s1rj9n, TaskId: 1, PQ sink. [Checkpoint 1.3] Send checkpoint state immediately
2025-12-12T12:27:10.852298Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:418: SelfId: [1:7582946991803893979:2162], TxId: ptqudq7ufbdb48s1rj9n, TaskId: 1, PQ sink. Save checkpoint { Id: 3 Generation: 1 Type: CHECKPOINT_TYPE_SNAPSHOT } state: { SourceId: "af2e0234-304b601d-51c6665c-694fb5e2" }
2025-12-12T12:27:10.852301Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:524: [ptqudq7ufbdb48s1rj9n-0] Task: 1. Sink[0] state saved
2025-12-12T12:27:10.852315Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:536: [ptqudq7ufbdb48s1rj9n-0] Task: 1. [Checkpoint 1.3] Task checkpoint is done. Send to storage
2025-12-12T12:27:10.852321Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Sink 0: sent 0 bytes of data and 6 bytes of checkpoint barrier
2025-12-12T12:27:10.852323Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-12T12:27:10.852326Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Poll inputs
2025-12-12T12:27:10.852328Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Poll sources
2025-12-12T12:27:10.852330Z :KQP_COMPUTE TRACE: dq_pq_rd_read_actor.cpp:767: SelfId: [1:7582946991803893978:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1, Cluster: . PQ source. GetAsyncInputData freeSpace = 1000000
2025-12-12T12:27:10.852334Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:81: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, 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:10.852337Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:460: [ptqudq7ufbdb48s1rj9n-0] [1:3] Got TEvSaveTaskState: task 1
2025-12-12T12:27:10.852344Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-12-12T12:27:10.852362Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. update task runner stats
2025-12-12T12:27:10.852373Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-12T12:27:10.852375Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:27:10.852376Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-12T12:27:10.852379Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [1:7582946991803893979:2162], TxId: ptqudq7ufbdb48s1rj9n, TaskId: 1, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-12-12T12:27:10.852381Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-12-12T12:27:10.852382Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-12T12:27:10.856009Z :KQP_COMPUTE TRACE: dq_pq_rd_read_actor.cpp:981: SelfId: [1:7582946991803893978:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1, Cluster: . PQ source. TEvRetryQueuePrivate::TEvEvHeartbeat
2025-12-12T12:27:10.856024Z :KQP_COMPUTE TRACE: dq_pq_rd_read_actor.cpp:997: SelfId: [1:7582946991803893978:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1, Cluster: . PQ source. Send TEvEvHeartbeat
2025-12-12T12:27:10.858528Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:484: [ptqudq7ufbdb48s1rj9n-0] [1:3] TEvSaveTaskState Apply: task: 1
2025-12-12T12:27:10.858541Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:499: [ptqudq7ufbdb48s1rj9n-0] [1:3] Send TEvSaveTaskStateResult: task: 1
2025-12-12T12:27:10.884697Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:759: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Commit state
2025-12-12T12:27:11.219543Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582946944559253506:2082]
2025-12-12T12:27:11.219567Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:11.219576Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582946944559253466:2063]
2025-12-12T12:27:11.219580Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582946944559253466:2063]
2025-12-12T12:27:11.219583Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582946944559253466:2063]
2025-12-12T12:27:11.219595Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:11.220744Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 78b82b8d-1230c1ab-b5d0b60f-66f25fd016, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:11.227150Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:11.227162Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:11.713674Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [2:7582946941773163192:2063]
2025-12-12T12:27:11.713690Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [2:7582946941773163192:2063]
2025-12-12T12:27:11.713693Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [2:7582946941773163192:2063]
2025-12-12T12:27:11.713696Z :KQP_COMPUTE TRACE: dq_pq_rd_read_actor.cpp:890: SelfId: [1:7582946991803893978:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1, Cluster: . PQ source. Received TEvStatistics from [2:7582946941773163192:2063], seqNo 3, ConfirmedSeqNo 2 generation 1
2025-12-12T12:27:11.855236Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:239: [ptqudq7ufbdb48s1rj9n-0] Task: 1. [Checkpoint 1.4] TEvInjectCheckpoint
2025-12-12T12:27:11.855263Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Poll inputs
2025-12-12T12:27:11.855265Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1494: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Skip polling sources because of pending checkpoint
2025-12-12T12:27:11.855268Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. DoExecuteImpl: 1
2025-12-12T12:27:11.855344Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:462: SelfId: [1:7582946991803893976:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Pending 1 checkpoints to be sent
2025-12-12T12:27:11.855357Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. update task runner stats
2025-12-12T12:27:11.855395Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 1 watermark injected: (empty maybe)
2025-12-12T12:27:11.855403Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:447: [ptqudq7ufbdb48s1rj9n-0] Task: 1. [Checkpoint 1.4] Performing task checkpoint
2025-12-12T12:27:11.855406Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:816: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Save state
2025-12-12T12:27:11.855413Z :KQP_COMPUTE DEBUG: dq_pq_read_actor_base.cpp:94: SelfId: [1:7582946991803893978:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1, Cluster: . PQ source. SessionId: empty SaveState, offsets: 
2025-12-12T12:27:11.855422Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:474: [ptqudq7ufbdb48s1rj9n-0] Task: 1. [Checkpoint 1.4] CA state saved
2025-12-12T12:27:11.855429Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:449: [ptqudq7ufbdb48s1rj9n-0] Task: 1. [Checkpoint 1.4] Injecting checkpoint barrier to outputs
2025-12-12T12:27:11.855432Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:27:11.855437Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-12T12:27:11.855444Z :KQP_COMPUTE INFO: dq_async_compute_actor.cpp:1010: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Resume inputs
2025-12-12T12:27:11.855448Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [1:7582946991803893979:2162], TxId: ptqudq7ufbdb48s1rj9n, TaskId: 1, PQ sink. SendData. Batch: 0. Checkpoint: 1. Finished: 0
2025-12-12T12:27:11.855452Z :KQP_COMPUTE DEBUG: dq_pq_write_actor.cpp:240: SelfId: [1:7582946991803893979:2162], TxId: ptqudq7ufbdb48s1rj9n, TaskId: 1, PQ sink. [Checkpoint 1.4] Send checkpoint state immediately
2025-12-12T12:27:11.855480Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:418: SelfId: [1:7582946991803893979:2162], TxId: ptqudq7ufbdb48s1rj9n, TaskId: 1, PQ sink. Save checkpoint { Id: 4 Generation: 1 Type: CHECKPOINT_TYPE_SNAPSHOT } state: { SourceId: "af2e0234-304b601d-51c6665c-694fb5e2" }
2025-12-12T12:27:11.855489Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:524: [ptqudq7ufbdb48s1rj9n-0] Task: 1. Sink[0] state saved
2025-12-12T12:27:11.855502Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:536: [ptqudq7ufbdb48s1rj9n-0] Task: 1. [Checkpoint 1.4] Task checkpoint is done. Send to storage
2025-12-12T12:27:11.855509Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Sink 0: sent 0 bytes of data and 6 bytes of checkpoint barrier
2025-12-12T12:27:11.855513Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-12T12:27:11.855516Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Poll inputs
2025-12-12T12:27:11.855519Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Poll sources
2025-12-12T12:27:11.855522Z :KQP_COMPUTE TRACE: dq_pq_rd_read_actor.cpp:767: SelfId: [1:7582946991803893978:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1, Cluster: . PQ source. GetAsyncInputData freeSpace = 1000000
2025-12-12T12:27:11.855527Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:81: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, 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:11.855536Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-12-12T12:27:11.855555Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. update task runner stats
2025-12-12T12:27:11.855564Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-12T12:27:11.855570Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:27:11.855572Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-12T12:27:11.855576Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [1:7582946991803893979:2162], TxId: ptqudq7ufbdb48s1rj9n, TaskId: 1, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-12-12T12:27:11.855578Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-12-12T12:27:11.855580Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-12T12:27:11.855589Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:460: [ptqudq7ufbdb48s1rj9n-0] [1:4] Got TEvSaveTaskState: task 1
2025-12-12T12:27:11.863182Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:484: [ptqudq7ufbdb48s1rj9n-0] [1:4] TEvSaveTaskState Apply: task: 1
2025-12-12T12:27:11.863198Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:499: [ptqudq7ufbdb48s1rj9n-0] [1:4] Send TEvSaveTaskStateResult: task: 1
2025-12-12T12:27:11.890362Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:759: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Commit state
2025-12-12T12:27:12.221008Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 78b82b8d-1230c1ab-b5d0b60f-66f25fd017, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:12.222021Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-12-12T12:27:12.224574Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:12.224584Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:12.230124Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:389: Send NodeInfo with size: 2 to DynamicNameserver
2025-12-12T12:27:12.656882Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [3:7582946948682729947:2063]
2025-12-12T12:27:12.656919Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [3:7582946948682729947:2063]
2025-12-12T12:27:12.656923Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [3:7582946948682729947:2063]
2025-12-12T12:27:12.853937Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:239: [ptqudq7ufbdb48s1rj9n-0] Task: 1. [Checkpoint 1.5] TEvInjectCheckpoint
2025-12-12T12:27:12.853971Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Poll inputs
2025-12-12T12:27:12.853976Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1494: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Skip polling sources because of pending checkpoint
2025-12-12T12:27:12.853979Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. DoExecuteImpl: 1
2025-12-12T12:27:12.854072Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:462: SelfId: [1:7582946991803893976:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Pending 1 checkpoints to be sent
2025-12-12T12:27:12.854081Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. update task runner stats
2025-12-12T12:27:12.854120Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 1 watermark injected: (empty maybe)
2025-12-12T12:27:12.854123Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:447: [ptqudq7ufbdb48s1rj9n-0] Task: 1. [Checkpoint 1.5] Performing task checkpoint
2025-12-12T12:27:12.854126Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:816: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Save state
2025-12-12T12:27:12.854134Z :KQP_COMPUTE DEBUG: dq_pq_read_actor_base.cpp:94: SelfId: [1:7582946991803893978:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1, Cluster: . PQ source. SessionId: empty SaveState, offsets: 
2025-12-12T12:27:12.854145Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:474: [ptqudq7ufbdb48s1rj9n-0] Task: 1. [Checkpoint 1.5] CA state saved
2025-12-12T12:27:12.854147Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:449: [ptqudq7ufbdb48s1rj9n-0] Task: 1. [Checkpoint 1.5] Injecting checkpoint barrier to outputs
2025-12-12T12:27:12.854151Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:27:12.854155Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-12T12:27:12.854164Z :KQP_COMPUTE INFO: dq_async_compute_actor.cpp:1010: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Resume inputs
2025-12-12T12:27:12.854167Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [1:7582946991803893979:2162], TxId: ptqudq7ufbdb48s1rj9n, TaskId: 1, PQ sink. SendData. Batch: 0. Checkpoint: 1. Finished: 0
2025-12-12T12:27:12.854179Z :KQP_COMPUTE DEBUG: dq_pq_write_actor.cpp:240: SelfId: [1:7582946991803893979:2162], TxId: ptqudq7ufbdb48s1rj9n, TaskId: 1, PQ sink. [Checkpoint 1.5] Send checkpoint state immediately
2025-12-12T12:27:12.854209Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:418: SelfId: [1:7582946991803893979:2162], TxId: ptqudq7ufbdb48s1rj9n, TaskId: 1, PQ sink. Save checkpoint { Id: 5 Generation: 1 Type: CHECKPOINT_TYPE_SNAPSHOT } state: { SourceId: "af2e0234-304b601d-51c6665c-694fb5e2" }
2025-12-12T12:27:12.854213Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:524: [ptqudq7ufbdb48s1rj9n-0] Task: 1. Sink[0] state saved
2025-12-12T12:27:12.854227Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:536: [ptqudq7ufbdb48s1rj9n-0] Task: 1. [Checkpoint 1.5] Task checkpoint is done. Send to storage
2025-12-12T12:27:12.854243Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Sink 0: sent 0 bytes of data and 6 bytes of checkpoint barrier
2025-12-12T12:27:12.854247Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-12T12:27:12.854251Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Poll inputs
2025-12-12T12:27:12.854252Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Poll sources
2025-12-12T12:27:12.854256Z :KQP_COMPUTE TRACE: dq_pq_rd_read_actor.cpp:767: SelfId: [1:7582946991803893978:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1, Cluster: . PQ source. GetAsyncInputData freeSpace = 1000000
2025-12-12T12:27:12.854261Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:81: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, 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:12.854270Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-12-12T12:27:12.854288Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. update task runner stats
2025-12-12T12:27:12.854295Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-12T12:27:12.854297Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:27:12.854299Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-12T12:27:12.854302Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [1:7582946991803893979:2162], TxId: ptqudq7ufbdb48s1rj9n, TaskId: 1, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-12-12T12:27:12.854305Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-12-12T12:27:12.854306Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-12T12:27:12.854314Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:460: [ptqudq7ufbdb48s1rj9n-0] [1:5] Got TEvSaveTaskState: task 1
2025-12-12T12:27:12.857119Z :KQP_COMPUTE TRACE: dq_pq_rd_read_actor.cpp:981: SelfId: [1:7582946991803893978:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1, Cluster: . PQ source. TEvRetryQueuePrivate::TEvEvHeartbeat
2025-12-12T12:27:12.857133Z :KQP_COMPUTE TRACE: dq_pq_rd_read_actor.cpp:997: SelfId: [1:7582946991803893978:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1, Cluster: . PQ source. Send TEvEvHeartbeat
2025-12-12T12:27:12.857212Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:484: [ptqudq7ufbdb48s1rj9n-0] [1:5] TEvSaveTaskState Apply: task: 1
2025-12-12T12:27:12.857231Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:499: [ptqudq7ufbdb48s1rj9n-0] [1:5] Send TEvSaveTaskStateResult: task: 1
2025-12-12T12:27:12.882392Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:759: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Commit state
2025-12-12T12:27:13.220902Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582946944559253506:2082]
2025-12-12T12:27:13.220920Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:13.220928Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582946944559253466:2063]
2025-12-12T12:27:13.220934Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582946944559253466:2063]
2025-12-12T12:27:13.220937Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582946944559253466:2063]
2025-12-12T12:27:13.220945Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:13.222392Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 78b82b8d-1230c1ab-b5d0b60f-66f25fd018, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:13.227090Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:13.227107Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:13.714535Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [2:7582946941773163192:2063]
2025-12-12T12:27:13.714553Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [2:7582946941773163192:2063]
2025-12-12T12:27:13.714555Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [2:7582946941773163192:2063]
2025-12-12T12:27:13.714569Z :KQP_COMPUTE TRACE: dq_pq_rd_read_actor.cpp:890: SelfId: [1:7582946991803893978:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1, Cluster: . PQ source. Received TEvStatistics from [2:7582946941773163192:2063], seqNo 4, ConfirmedSeqNo 3 generation 1
2025-12-12T12:27:13.858657Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:239: [ptqudq7ufbdb48s1rj9n-0] Task: 1. [Checkpoint 1.6] TEvInjectCheckpoint
2025-12-12T12:27:13.858687Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Poll inputs
2025-12-12T12:27:13.858690Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1494: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Skip polling sources because of pending checkpoint
2025-12-12T12:27:13.858695Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. DoExecuteImpl: 1
2025-12-12T12:27:13.858771Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:462: SelfId: [1:7582946991803893976:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Pending 1 checkpoints to be sent
2025-12-12T12:27:13.858786Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. update task runner stats
2025-12-12T12:27:13.858827Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 1 watermark injected: (empty maybe)
2025-12-12T12:27:13.858834Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:447: [ptqudq7ufbdb48s1rj9n-0] Task: 1. [Checkpoint 1.6] Performing task checkpoint
2025-12-12T12:27:13.858836Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:816: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Save state
2025-12-12T12:27:13.858846Z :KQP_COMPUTE DEBUG: dq_pq_read_actor_base.cpp:94: SelfId: [1:7582946991803893978:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1, Cluster: . PQ source. SessionId: empty SaveState, offsets: 
2025-12-12T12:27:13.858853Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:474: [ptqudq7ufbdb48s1rj9n-0] Task: 1. [Checkpoint 1.6] CA state saved
2025-12-12T12:27:13.858855Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:449: [ptqudq7ufbdb48s1rj9n-0] Task: 1. [Checkpoint 1.6] Injecting checkpoint barrier to outputs
2025-12-12T12:27:13.858858Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:27:13.858863Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-12T12:27:13.858872Z :KQP_COMPUTE INFO: dq_async_compute_actor.cpp:1010: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Resume inputs
2025-12-12T12:27:13.858875Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [1:7582946991803893979:2162], TxId: ptqudq7ufbdb48s1rj9n, TaskId: 1, PQ sink. SendData. Batch: 0. Checkpoint: 1. Finished: 0
2025-12-12T12:27:13.858880Z :KQP_COMPUTE DEBUG: dq_pq_write_actor.cpp:240: SelfId: [1:7582946991803893979:2162], TxId: ptqudq7ufbdb48s1rj9n, TaskId: 1, PQ sink. [Checkpoint 1.6] Send checkpoint state immediately
2025-12-12T12:27:13.858909Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:418: SelfId: [1:7582946991803893979:2162], TxId: ptqudq7ufbdb48s1rj9n, TaskId: 1, PQ sink. Save checkpoint { Id: 6 Generation: 1 Type: CHECKPOINT_TYPE_SNAPSHOT } state: { SourceId: "af2e0234-304b601d-51c6665c-694fb5e2" }
2025-12-12T12:27:13.858913Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:524: [ptqudq7ufbdb48s1rj9n-0] Task: 1. Sink[0] state saved
2025-12-12T12:27:13.858926Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:536: [ptqudq7ufbdb48s1rj9n-0] Task: 1. [Checkpoint 1.6] Task checkpoint is done. Send to storage
2025-12-12T12:27:13.858934Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Sink 0: sent 0 bytes of data and 6 bytes of checkpoint barrier
2025-12-12T12:27:13.858937Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-12T12:27:13.858941Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Poll inputs
2025-12-12T12:27:13.858943Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Poll sources
2025-12-12T12:27:13.858947Z :KQP_COMPUTE TRACE: dq_pq_rd_read_actor.cpp:767: SelfId: [1:7582946991803893978:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1, Cluster: . PQ source. GetAsyncInputData freeSpace = 1000000
2025-12-12T12:27:13.858953Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:81: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, 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:13.858962Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-12-12T12:27:13.858974Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:460: [ptqudq7ufbdb48s1rj9n-0] [1:6] Got TEvSaveTaskState: task 1
2025-12-12T12:27:13.858983Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. update task runner stats
2025-12-12T12:27:13.858992Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-12T12:27:13.858994Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:27:13.858996Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-12T12:27:13.859014Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [1:7582946991803893979:2162], TxId: ptqudq7ufbdb48s1rj9n, TaskId: 1, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-12-12T12:27:13.859016Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-12-12T12:27:13.859018Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-12T12:27:13.863751Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:484: [ptqudq7ufbdb48s1rj9n-0] [1:6] TEvSaveTaskState Apply: task: 1
2025-12-12T12:27:13.863770Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:499: [ptqudq7ufbdb48s1rj9n-0] [1:6] Send TEvSaveTaskStateResult: task: 1
2025-12-12T12:27:13.899330Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:759: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Commit state
2025-12-12T12:27:13.917364Z :KQP_COMPUTE TRACE: dq_pq_rd_read_actor.cpp:945: SelfId: [1:7582946991803893978:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1, Cluster: . PQ source. Received TEvNewDataArrived from [2:7582946941773163192:2063], partition 0, seqNo 5, ConfirmedSeqNo 3 generation 1
2025-12-12T12:27:13.917862Z :KQP_COMPUTE TRACE: dq_pq_rd_read_actor.cpp:1123: SelfId: [1:7582946991803893978:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1, Cluster: . PQ source. Received TEvMessageBatch from [2:7582946941773163192:2063], seqNo 6, ConfirmedSeqNo 4 generation 1
2025-12-12T12:27:13.917884Z :KQP_COMPUTE TRACE: dq_pq_rd_read_actor.cpp:1171: SelfId: [1:7582946991803893978:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1, Cluster: . PQ source. TEvMessageBatch NextOffset 3
2025-12-12T12:27:13.917908Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Poll inputs
2025-12-12T12:27:13.917911Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Poll sources
2025-12-12T12:27:13.917915Z :KQP_COMPUTE TRACE: dq_pq_rd_read_actor.cpp:767: SelfId: [1:7582946991803893978:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1, Cluster: . PQ source. GetAsyncInputData freeSpace = 1000000
2025-12-12T12:27:13.917955Z :KQP_COMPUTE TRACE: dq_pq_rd_read_actor.cpp:807: SelfId: [1:7582946991803893978:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1, Cluster: . PQ source. NextOffset 3
2025-12-12T12:27:13.917965Z :KQP_COMPUTE TRACE: dq_pq_rd_read_actor.cpp:811: SelfId: [1:7582946991803893978:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1, Cluster: . PQ source. Return 1 rows, watermark (empty maybe), buffer size 0, free space 999988, result size 12
2025-12-12T12:27:13.917969Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:81: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Poll async input 0. Buffer free space: 1000000, read from async input: 12 bytes, 1 rows, finished: 0
2025-12-12T12:27:13.917991Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-12-12T12:27:13.917998Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Poll inputs
2025-12-12T12:27:13.918000Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Poll sources
2025-12-12T12:27:13.918002Z :KQP_COMPUTE TRACE: dq_pq_rd_read_actor.cpp:767: SelfId: [1:7582946991803893978:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1, Cluster: . PQ source. GetAsyncInputData freeSpace = 999988
2025-12-12T12:27:13.918005Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:81: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Poll async input 0. Buffer free space: 999988, read from async input: 0 bytes, 0 rows, finished: 0
2025-12-12T12:27:13.918077Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-12-12T12:27:13.918080Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. update task runner stats
2025-12-12T12:27:13.918127Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-12T12:27:13.918130Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:27:13.918134Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. About to drain sink 0. FreeSpace: 16777216, allowedOvercommit: 500000, toSend: 17277216
2025-12-12T12:27:13.918139Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1107: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Ask CPU quota: 55ms
2025-12-12T12:27:13.918166Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [1:7582946991803893979:2162], TxId: ptqudq7ufbdb48s1rj9n, TaskId: 1, PQ sink. SendData. Batch: 1. Checkpoint: 0. Finished: 0
2025-12-12T12:27:13.918170Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:221: SelfId: [1:7582946991803893979:2162], TxId: ptqudq7ufbdb48s1rj9n, TaskId: 1, PQ sink. Received data for sending: 101
2025-12-12T12:27:13.918197Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:13.918192Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ufbdb48s1rj9n, TaskId: 1, PQ sink. ]  SessionId [af2e0234-304b601d-51c6665c-694fb5e2|f3688066-990d94fa-119c9bc4-b0a81743_0]  PartitionId [0]  Generation [1] Write 1 messages with Id from 1 to 1
2025-12-12T12:27:13.918213Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:13.918211Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ufbdb48s1rj9n, TaskId: 1, PQ sink. ]  SessionId [af2e0234-304b601d-51c6665c-694fb5e2|f3688066-990d94fa-119c9bc4-b0a81743_0]  PartitionId [0]  Generation [1] Write session: try to update token
2025-12-12T12:27:13.918220Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:13.918217Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ufbdb48s1rj9n, TaskId: 1, PQ sink. ]  SessionId [af2e0234-304b601d-51c6665c-694fb5e2|f3688066-990d94fa-119c9bc4-b0a81743_0]  PartitionId [0]  Generation [1] Send 1 message(s) (0 left), first sequence number is 1
2025-12-12T12:27:13.918348Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Sink 0: sent 7 bytes of data and 0 bytes of checkpoint barrier
2025-12-12T12:27:13.918350Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Drain sink 0. Free space decreased: 3, sent data from buffer: 7
2025-12-12T12:27:13.918360Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Poll inputs
2025-12-12T12:27:13.918362Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Poll sources
2025-12-12T12:27:13.918366Z :KQP_COMPUTE TRACE: dq_pq_rd_read_actor.cpp:767: SelfId: [1:7582946991803893978:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1, Cluster: . PQ source. GetAsyncInputData freeSpace = 1000000
2025-12-12T12:27:13.918368Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:81: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, 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:13.918374Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-12-12T12:27:13.919269Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1165: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. CPU quota delay: 1ms
2025-12-12T12:27:13.919319Z :KQP_COMPUTE TRACE: dq_compute_memory_quota.h:97: TxId: ptqudq7ufbdb48s1rj9n, task: 1. Peak memory usage: 196608
2025-12-12T12:27:13.919331Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. update task runner stats
2025-12-12T12:27:13.919358Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-12T12:27:13.919360Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:27:13.919380Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:573: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. About to drain sink 0. FreeSpace: 16777213, allowedOvercommit: 500000, toSend: 17277213
2025-12-12T12:27:13.919387Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:195: SelfId: [1:7582946991803893979:2162], TxId: ptqudq7ufbdb48s1rj9n, TaskId: 1, PQ sink. SendData. Batch: 0. Checkpoint: 0. Finished: 0
2025-12-12T12:27:13.919393Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1025: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Sink 0: sent 0 bytes of data and 0 bytes of checkpoint barrier
2025-12-12T12:27:13.919394Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1029: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Drain sink 0. Free space decreased: 0, sent data from buffer: 0
2025-12-12T12:27:13.921042Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:453: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Got TEvStateRequest from actor [3:7582946991632403182:2169] PingCookie: 1
2025-12-12T12:27:13.921060Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. update task runner stats
2025-12-12T12:27:13.921278Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:13.921266Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ufbdb48s1rj9n, TaskId: 1, PQ sink. ]  SessionId [af2e0234-304b601d-51c6665c-694fb5e2|f3688066-990d94fa-119c9bc4-b0a81743_0]  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T12:27:13.921345Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:13.921342Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ufbdb48s1rj9n, TaskId: 1, PQ sink. ]  SessionId [af2e0234-304b601d-51c6665c-694fb5e2|f3688066-990d94fa-119c9bc4-b0a81743_0]  PartitionId [0]  Generation [1] Write session got write response: acks { seq_no: 1 written { } } write_statistics { persisting_time { nanos: 2000000 } min_queue_wait_time { } max_queue_wait_time { } partition_quota_wait_time { } topic_quota_wait_time { } }
2025-12-12T12:27:13.921351Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:13.921349Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ufbdb48s1rj9n, TaskId: 1, PQ sink. ]  SessionId [af2e0234-304b601d-51c6665c-694fb5e2|f3688066-990d94fa-119c9bc4-b0a81743_0]  PartitionId [0]  Generation [1] OnAck: seqNo=1, txId=?
2025-12-12T12:27:13.921355Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:13.921354Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ufbdb48s1rj9n, TaskId: 1, PQ sink. ]  SessionId [af2e0234-304b601d-51c6665c-694fb5e2|f3688066-990d94fa-119c9bc4-b0a81743_0]  PartitionId [0]  Generation [1] Write session: acknoledged message 1
2025-12-12T12:27:13.921427Z :KQP_COMPUTE TRACE: dq_pq_write_actor.cpp:454: SelfId: [1:7582946991803893979:2162], TxId: ptqudq7ufbdb48s1rj9n, TaskId: 1, PQ sink. Ack seq no 1
2025-12-12T12:27:14.222944Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 78b82b8d-1230c1ab-b5d0b60f-66f25fd019, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:14.226696Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:14.226713Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:14.657782Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [3:7582946948682729947:2063]
2025-12-12T12:27:14.657808Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [3:7582946948682729947:2063]
2025-12-12T12:27:14.657812Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [3:7582946948682729947:2063]
2025-12-12T12:27:14.817175Z :KQP_COMPUTE ERROR: dq_compute_actor_impl.h:1205: SelfId: [1:7582946991803893974:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1. Ctx: {}. Handle abort execution event from: [1:7582946944559253467:2064], status: UNAVAILABLE, reason: { <main>: Error: Aborted by LWM }
2025-12-12T12:27:14.817243Z :KQP_COMPUTE DEBUG: dq_compute_actor_channels.cpp:494: TxId: ptqudq7ufbdb48s1rj9n, task: 1. pass away
2025-12-12T12:27:14.817255Z :KQP_COMPUTE INFO: dq_pq_rd_read_actor.cpp:744: SelfId: [1:7582946991803893978:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1, Cluster: . PQ source. PassAway
2025-12-12T12:27:14.817282Z :KQP_COMPUTE INFO: dq_pq_rd_read_actor.cpp:1242: SelfId: [1:7582946991803893978:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1, Cluster: . PQ source. SelfId: [1:7582946991803893978:2162], TxId: ptqudq7ufbdb48s1rj9n, 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 1 Undelivered 0 Retry 1 PrivateHeartbeat 2 SessionClosed 0 Pong 0 Heartbeat 0 PrintState 0 ProcessState 0 GetAsyncInputData 9 NotifyCA 1
 [2:7582946941773163192:2063] status 2 is waiting ack 0 connection id 1 id 1, NextSeqNo 5, MyConfSeqNo 6, SeqNos 0, events size 0, connected 1, heartbeat shed 1, last received 2025-12-12T12:27:13.917872Z, last sent 2025-12-12T12:27:13.917389Z
 partitions 0 offsets 0=3 has pending data
2025-12-12T12:27:14.817292Z :KQP_COMPUTE INFO: dq_pq_rd_read_actor.cpp:736: SelfId: [1:7582946991803893978:2162], TxId: ptqudq7ufbdb48s1rj9n, task: 1, Cluster: . PQ source. Send StopSession to [2:7582946941773163192:2063] generation 1
2025-12-12T12:27:14.818054Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:27:14.818048Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ufbdb48s1rj9n, TaskId: 1, PQ sink. ]  SessionId [af2e0234-304b601d-51c6665c-694fb5e2|f3688066-990d94fa-119c9bc4-b0a81743_0]  PartitionId [0]  Generation [1] Write session: close. Timeout 0.000000s
2025-12-12T12:27:14.818068Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:27:14.818066Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ufbdb48s1rj9n, TaskId: 1, PQ sink. ]  SessionId [af2e0234-304b601d-51c6665c-694fb5e2|f3688066-990d94fa-119c9bc4-b0a81743_0]  PartitionId [0]  Generation [1] Write session will now close
2025-12-12T12:27:14.818083Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:14.818081Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ufbdb48s1rj9n, TaskId: 1, PQ sink. ]  SessionId [af2e0234-304b601d-51c6665c-694fb5e2|f3688066-990d94fa-119c9bc4-b0a81743_0]  PartitionId [0]  Generation [1] Write session: aborting
2025-12-12T12:27:14.818226Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:27:14.818224Z :INFO: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ufbdb48s1rj9n, TaskId: 1, PQ sink. ]  SessionId [af2e0234-304b601d-51c6665c-694fb5e2|f3688066-990d94fa-119c9bc4-b0a81743_0]  PartitionId [0]  Generation [1] Write session: gracefully shut down, all writes complete
2025-12-12T12:27:14.818235Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:27:14.818234Z :DEBUG: [local]  TraceId [SelfId: [0:0:0], TxId: ptqudq7ufbdb48s1rj9n, TaskId: 1, PQ sink. ]  SessionId [af2e0234-304b601d-51c6665c-694fb5e2|f3688066-990d94fa-119c9bc4-b0a81743_0]  PartitionId [0]  Generation [1] Write session: destroy
2025-12-12T12:27:15.221801Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582946944559253506:2082]
2025-12-12T12:27:15.221825Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:15.221834Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582946944559253466:2063]
2025-12-12T12:27:15.221838Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582946944559253466:2063]
2025-12-12T12:27:15.221841Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582946944559253466:2063]
2025-12-12T12:27:15.221853Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:15.223387Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 78b82b8d-1230c1ab-b5d0b60f-66f25fd020, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:15.227408Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:15.227422Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:27:15.716063Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [2:7582946941773163192:2063]
2025-12-12T12:27:15.716080Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [2:7582946941773163192:2063]
2025-12-12T12:27:15.716084Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [2:7582946941773163192:2063]
2025-12-12T12:27:16.223865Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 78b82b8d-1230c1ab-b5d0b60f-66f25fd021, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:16.235163Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:16.235183Z :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:31768: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-fhkyrtz6p4.auto.internal:31768
2025-12-12T12:27:16.663185Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [3:7582946948682729947:2063]
2025-12-12T12:27:16.663205Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [3:7582946948682729947:2063]
2025-12-12T12:27:16.663210Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [3:7582946948682729947:2063]
2025-12-12T12:27:17.222296Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-12-12T12:27:17.222321Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582946944559253506:2082]
2025-12-12T12:27:17.222336Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:17.222358Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582946944559253466:2063]
2025-12-12T12:27:17.222363Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582946944559253466:2063]
2025-12-12T12:27:17.222366Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582946944559253466:2063]
2025-12-12T12:27:17.222379Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:17.224368Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 78b82b8d-1230c1ab-b5d0b60f-66f25fd022, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:17.233987Z :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:31768: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-fhkyrtz6p4.auto.internal:31768
2025-12-12T12:27:17.234017Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:17.234024Z :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:31768: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-fhkyrtz6p4.auto.internal:31768
2025-12-12T12:27:17.718453Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [2:7582946941773163192:2063]
2025-12-12T12:27:17.718474Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [2:7582946941773163192:2063]
2025-12-12T12:27:17.718477Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [2:7582946941773163192:2063]
2025-12-12T12:27:18.227217Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 78b82b8d-1230c1ab-b5d0b60f-66f25fd023, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:18.239628Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:18.239656Z :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:31768: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-fhkyrtz6p4.auto.internal:31768
2025-12-12T12:27:18.661616Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [3:7582946948682729947:2063]
2025-12-12T12:27:18.661635Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [3:7582946948682729947:2063]
2025-12-12T12:27:18.661638Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [3:7582946948682729947:2063]
2025-12-12T12:27:19.223150Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582946944559253506:2082]
2025-12-12T12:27:19.223173Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:19.223189Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582946944559253466:2063]
2025-12-12T12:27:19.223193Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582946944559253466:2063]
2025-12-12T12:27:19.223196Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582946944559253466:2063]
2025-12-12T12:27:19.223205Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:19.228238Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 78b82b8d-1230c1ab-b5d0b60f-66f25fd024, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:19.233393Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:19.233415Z :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:31768: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-fhkyrtz6p4.auto.internal:31768
2025-12-12T12:27:19.721254Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [2:7582946941773163192:2063]
2025-12-12T12:27:19.721288Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [2:7582946941773163192:2063]
2025-12-12T12:27:19.721291Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [2:7582946941773163192:2063]
2025-12-12T12:27:20.228694Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 78b82b8d-1230c1ab-b5d0b60f-66f25fd025, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:20.234501Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:20.234541Z :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:31768: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-fhkyrtz6p4.auto.internal:31768
2025-12-12T12:27:20.662524Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [3:7582946948682729947:2063]
2025-12-12T12:27:20.662543Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [3:7582946948682729947:2063]
2025-12-12T12:27:20.662547Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [3:7582946948682729947:2063]
2025-12-12T12:27:21.224147Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582946944559253506:2082]
2025-12-12T12:27:21.224173Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:21.224181Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582946944559253466:2063]
2025-12-12T12:27:21.224185Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582946944559253466:2063]
2025-12-12T12:27:21.224203Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582946944559253466:2063]
2025-12-12T12:27:21.224213Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:21.229149Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 78b82b8d-1230c1ab-b5d0b60f-66f25fd026, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:21.237117Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:21.237136Z :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:31768: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-fhkyrtz6p4.auto.internal:31768
2025-12-12T12:27:21.720155Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [2:7582946941773163192:2063]
2025-12-12T12:27:21.720174Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [2:7582946941773163192:2063]
2025-12-12T12:27:21.720177Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [2:7582946941773163192:2063]
2025-12-12T12:27:22.222423Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-12-12T12:27:22.228367Z :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:31768: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-fhkyrtz6p4.auto.internal:31768
2025-12-12T12:27:22.229595Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 78b82b8d-1230c1ab-b5d0b60f-66f25fd027, Host: ghrun-fhkyrtz6p4, Tenant: /compute
2025-12-12T12:27:22.234525Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:27:22.234556Z :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:31768: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-fhkyrtz6p4.auto.internal:31768
2025-12-12T12:27:22.326673Z :INTERCONNECT_NETWORK NOTICE: interconnect_tcp_input_session.cpp:712: [1 <-> 3] connection closed by peer
2025-12-12T12:27:22.326955Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: 78b82b8d-1230c1ab-b5d0b60f-66f25fd0 2025-12-12 12:27:22.326 DEBUG ydbd(pid=1188997, tid=0x00007F4A4C904640) [DQ] local_worker_manager.cpp:257: Disconnected 3
2025-12-12T12:27:22.326978Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: 78b82b8d-1230c1ab-b5d0b60f-66f25fd0 2025-12-12 12:27:22.326 DEBUG ydbd(pid=1188997, tid=0x00007F4A4C904640) [DQ] local_worker_manager.cpp:228: Deallocate 3
2025-12-12T12:27:22.326990Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:597: RowDispatcher: TEvNodeDisconnected, node id 3
2025-12-12T12:27:22.326998Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:398: Coordinator: TEvNodeDisconnected, node id 3
2025-12-12T12:27:22.327015Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:408: Coordinator: Schedule TEvRebalancing
2025-12-12T12:27:22.327814Z :INTERCONNECT_NETWORK NOTICE: interconnect_handshake.cpp:1262: [1 <-> 3] network-related error occured on handshake: outgoing handshake Peer# ghrun-fhkyrtz6p4(127.0.1.1:27129) Couldn't connect to any resolved address
2025-12-12T12:27:22.327961Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1052: RowDispatcher: TEvTryConnect to node id 3
2025-12-12T12:27:22.328082Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:597: RowDispatcher: TEvNodeDisconnected, node id 3
2025-12-12T12:27:22.331743Z :INTERCONNECT_NETWORK NOTICE: interconnect_tcp_input_session.cpp:712: [1 <-> 2] connection closed by peer
2025-12-12T12:27:22.332277Z :INTERCONNECT_NETWORK NOTICE: interconnect_handshake.cpp:1262: [1 <-> 2] network-related error occured on handshake: outgoing handshake Peer# ghrun-fhkyrtz6p4(127.0.1.1:10937) Couldn't connect to any resolved address
2025-12-12T12:27:22.332430Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:398: Coordinator: TEvNodeDisconnected, node id 2
