2025-11-01T13:36:53.242003Z :GRPC_SERVER NOTICE: grpc_request_proxy_simple.cpp:161: Grpc simple request proxy started, nodeid# 3
2025-11-01T13:36:53.242094Z :GRPC_SERVER NOTICE: grpc_request_proxy_simple.cpp:161: Grpc simple request proxy started, nodeid# 3
2025-11-01T13:36:53.243192Z :FQ_LOG_UPDATER DEBUG: log.cpp:93: Updated YQL logs priority: 8
2025-11-01T13:36:53.243199Z :YQ_CONTROL_PLANE_STORAGE INFO: ydb_control_plane_storage.cpp:50: Starting ydb control plane storage service. Actor id: [3:7567750471853028964:2060]
2025-11-01T13:36:53.243263Z :FQ_LOG_UPDATER CRIT: log.cpp:55: Failed to deliver subscription request to config dispatcher.
2025-11-01T13:36:53.243291Z :FQ_CONTROL_PLANE_CONFIG DEBUG: control_plane_config.cpp:58: STARTING: [3:7567750471853028965:2061]
2025-11-01T13:36:53.244374Z :YQ_CONTROL_PLANE_PROXY DEBUG: control_plane_proxy.cpp:532: Starting yandex query control plane proxy. Actor id: [3:7567750471853028966:2062]
2025-11-01T13:36:53.244737Z :MEMORY_PROFILER NOTICE: monitor.cpp:332: Bootstrapped
2025-11-01T13:36:53.246111Z :YQ_RATE_LIMITER INFO: quoter_service.cpp:124: Bootstraping with config: { Enabled: true ControlPlaneEnabled: true DataPlaneEnabled: true Database { Endpoint: "localhost:61956" Database: "local" TablePrefix: "RateLimiter_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5" } Limiters { CoordinationNodePath: "rate_limiter" } }
2025-11-01T13:36:53.252305Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:145: Bootstrap
2025-11-01T13:36:53.252522Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:165: Initialize
2025-11-01T13:36:53.282560Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:534: RowDispatcher: Successfully bootstrapped row dispatcher, id [3:7567750471853028971:2067], tenant /default
2025-11-01T13:36:53.283304Z :YQL_NODES_MANAGER INFO: nodes_manager.cpp:88: Bootstrap, InstanceId: f6d8e5c8-466d9c8d-bd2cbab3-2ba87b13
2025-11-01T13:36:53.283317Z :YQL_NODES_MANAGER DEBUG: nodes_manager.cpp:310: TNodesManagerActor::ResolveSelfAddress
2025-11-01T13:36:53.283533Z :YQ_TEST_CONNECTION DEBUG: test_connection.cpp:142: Starting yandex query test connection. Actor id: [3:7567750471853028976:2072]
2025-11-01T13:36:53.292852Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: ef5c71cf-e0ddc7a5-5710ed89-b937216d1, Host: ghrun-ebytu4uhfq, Tenant: /default
2025-11-01T13:36:53.293338Z :FQ_QUOTA_SERVICE INFO: quota_manager.cpp:196: STARTED
2025-11-01T13:36:53.293364Z :FQ_QUOTA_PROXY INFO: quota_proxy.cpp:90: STARTED
2025-11-01T13:36:53.293561Z :YQ_RATE_LIMITER DEBUG: schema.cpp:71: Run create coordination node "local/RateLimiter_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/rate_limiter" actor
2025-11-01T13:36:53.293573Z :YQ_RATE_LIMITER DEBUG: schema.cpp:113: Call create coordination node "local/RateLimiter_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/rate_limiter"
2025-11-01T13:36:53.293585Z :YQ_RATE_LIMITER DEBUG: schema.cpp:411: Call create coordination node "local/RateLimiter_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/rate_limiter"
2025-11-01T13:36:53.295385Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create directory "local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5" actor
2025-11-01T13:36:53.295412Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create directory "local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5"
2025-11-01T13:36:53.295439Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:383: Call create directory "local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5"
2025-11-01T13:36:53.295684Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/queries" actor
2025-11-01T13:36:53.295940Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/pending_small" actor
2025-11-01T13:36:53.296048Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/connections" actor
2025-11-01T13:36:53.296196Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/bindings" actor
2025-11-01T13:36:53.296387Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/idempotency_keys" actor
2025-11-01T13:36:53.297439Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/result_sets" actor
2025-11-01T13:36:53.297656Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/jobs" actor
2025-11-01T13:36:53.297783Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/nodes" actor
2025-11-01T13:36:53.297903Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/quotas" actor
2025-11-01T13:36:53.297980Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/tenants" actor
2025-11-01T13:36:53.298111Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/tenant_acks" actor
2025-11-01T13:36:53.298336Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/mappings" actor
2025-11-01T13:36:53.298490Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/compute_databases" actor
2025-11-01T13:36:53.299322Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:267: Coordinator: Successfully bootstrapped coordinator, id [3:7567750471853029071:2138], NodesManagerId [0:4705493345362661702:78]
2025-11-01T13:36:53.299395Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:231: TLeaderElection [3:7567750471853029072:2139] Successfully bootstrapped, local coordinator id [3:7567750471853029071:2138], tenant id default, local mode 0, coordination node path local/row_dispatcher/default
2025-11-01T13:36:53.308226Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-11-01T13:36:53.308383Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:627: RowDispatcher: TEvCoordinatorChangesSubscribe from [3:7567750471853029071:2138]
2025-11-01T13:36:53.308623Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:71: Run create coordination node "local/row_dispatcher/default" actor
2025-11-01T13:36:53.308662Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:113: Call create coordination node "local/row_dispatcher/default"
2025-11-01T13:36:53.308669Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:411: Call create coordination node "local/row_dispatcher/default"
2025-11-01T13:36:53.339969Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:155: Successfully created coordination node "local/row_dispatcher/default"
2025-11-01T13:36:53.340045Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:122: Reply for create coordination node "local/row_dispatcher/default": { <main>: Error: Check failed: path: '/local/row_dispatcher/default', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 10], type: EPathTypeKesus, state: EPathStateNoChanges) }
2025-11-01T13:36:53.340140Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:344: TLeaderElection [3:7567750471853029072:2139] Coordination node successfully created
2025-11-01T13:36:53.340277Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:322: TLeaderElection [3:7567750471853029072:2139] Start session
2025-11-01T13:36:53.361348Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:358: TLeaderElection [3:7567750471853029072:2139] Session successfully created
2025-11-01T13:36:53.363199Z :YQ_RATE_LIMITER DEBUG: schema.cpp:155: Successfully created coordination node "local/RateLimiter_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/rate_limiter"
2025-11-01T13:36:53.363216Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created directory "local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5"
2025-11-01T13:36:53.363279Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create directory "local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5": { <main>: Error: Check failed: path: '/local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 166], type: EPathTypeDir, state: EPathStateNoChanges) }
2025-11-01T13:36:53.363351Z :YQ_RATE_LIMITER DEBUG: schema.cpp:122: Reply for create coordination node "local/RateLimiter_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/rate_limiter": { <main>: Error: Check failed: path: '/local/RateLimiter_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/rate_limiter', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 172], type: EPathTypeKesus, state: EPathStateNoChanges) }
2025-11-01T13:36:53.365549Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:371: TLeaderElection [3:7567750471853029072:2139] Semaphore successfully created
2025-11-01T13:36:53.365631Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:303: TLeaderElection [3:7567750471853029072:2139] Try to acquire semaphore
2025-11-01T13:36:53.366020Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:419: TLeaderElection [3:7567750471853029072:2139] Describe semaphore
2025-11-01T13:36:53.370766Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:468: TLeaderElection [3:7567750471853029072:2139] Semaphore successfully described: coordinator id [1:7567750464762687077:2125] generation 8
2025-11-01T13:36:53.370834Z :FQ_ROW_DISPATCHER INFO: leader_election.cpp:470: TLeaderElection [3:7567750471853029072:2139] Send TEvCoordinatorChanged to [3:7567750471853028971:2067], new coordinator id [1:7567750464762687077:2125], previous coordinator id [0:0:0]
2025-11-01T13:36:53.370987Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:559: RowDispatcher: Coordinator changed, old leader (empty maybe), new [1:7567750464762687077:2125] generation 8
2025-11-01T13:36:53.371101Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:386: Coordinator: New leader [1:7567750464762687077:2125], SelfId [3:7567750471853029071:2138]
2025-11-01T13:36:53.371270Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:597: RowDispatcher: TEvUndelivered, from [1:7567750464762687077:2125], reason Disconnected
2025-11-01T13:36:53.379661Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/queries". Create session OK
2025-11-01T13:36:53.379735Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/queries"
2025-11-01T13:36:53.379749Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/queries"
2025-11-01T13:36:53.379843Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/pending_small". Create session OK
2025-11-01T13:36:53.379867Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/pending_small"
2025-11-01T13:36:53.379875Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/pending_small"
2025-11-01T13:36:53.383518Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/bindings". Create session OK
2025-11-01T13:36:53.383518Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/connections". Create session OK
2025-11-01T13:36:53.383552Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/connections"
2025-11-01T13:36:53.383566Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/bindings"
2025-11-01T13:36:53.383567Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/connections"
2025-11-01T13:36:53.383573Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/bindings"
2025-11-01T13:36:53.385917Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/idempotency_keys". Create session OK
2025-11-01T13:36:53.385990Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/idempotency_keys"
2025-11-01T13:36:53.385999Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/idempotency_keys"
2025-11-01T13:36:53.388245Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/result_sets". Create session OK
2025-11-01T13:36:53.388273Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/result_sets"
2025-11-01T13:36:53.388283Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/result_sets"
2025-11-01T13:36:53.390328Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/jobs". Create session OK
2025-11-01T13:36:53.390357Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/jobs"
2025-11-01T13:36:53.390357Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/nodes". Create session OK
2025-11-01T13:36:53.390382Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/nodes"
2025-11-01T13:36:53.390395Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/jobs"
2025-11-01T13:36:53.390395Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/nodes"
2025-11-01T13:36:53.395112Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/quotas". Create session OK
2025-11-01T13:36:53.395115Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/tenants". Create session OK
2025-11-01T13:36:53.395140Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/tenants"
2025-11-01T13:36:53.395141Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/quotas"
2025-11-01T13:36:53.395147Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/tenants"
2025-11-01T13:36:53.395147Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/quotas"
2025-11-01T13:36:53.397244Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/tenant_acks". Create session OK
2025-11-01T13:36:53.397271Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/tenant_acks"
2025-11-01T13:36:53.397280Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/tenant_acks"
2025-11-01T13:36:53.397688Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/mappings". Create session OK
2025-11-01T13:36:53.397712Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/mappings"
2025-11-01T13:36:53.397718Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/mappings"
2025-11-01T13:36:53.400434Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/compute_databases". Create session OK
2025-11-01T13:36:53.400480Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-01T13:36:53.400490Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/compute_databases"
2025-11-01T13:36:53.400509Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/compute_databases"
2025-11-01T13:36:53.400508Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-01T13:36:53.412465Z :FQ_CONTROL_PLANE_CONFIG DEBUG: control_plane_config.cpp:190: LOADED TenantInfo: State CHANGED at 2025-11-01T13:36:47.325956Z
2025-11-01T13:36:53.412810Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/queries"
2025-11-01T13:36:53.412896Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/queries": { <main>: Error: Check failed: path: '/local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/queries', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 173], type: EPathTypeTable, state: EPathStateNoChanges) }
2025-11-01T13:36:53.417374Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/pending_small"
2025-11-01T13:36:53.417455Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/pending_small": { <main>: Error: Check failed: path: '/local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/pending_small', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 174], type: EPathTypeTable, state: EPathStateNoChanges) }
2025-11-01T13:36:53.417627Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/bindings"
2025-11-01T13:36:53.417693Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/bindings": { <main>: Error: Check failed: path: '/local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/bindings', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 179], type: EPathTypeTable, state: EPathStateNoChanges) }
2025-11-01T13:36:53.421086Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:389: Send NodeInfo with size: 2 to DynamicNameserver
2025-11-01T13:36:53.426827Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/result_sets"
2025-11-01T13:36:53.426926Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/result_sets": { <main>: Error: Check failed: path: '/local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/result_sets', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 181], type: EPathTypeTable, state: EPathStateNoChanges) }
2025-11-01T13:36:53.431206Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/connections"
2025-11-01T13:36:53.431284Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/connections": { <main>: Error: Check failed: path: '/local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/connections', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 176], type: EPathTypeTable, state: EPathStateNoChanges) }
2025-11-01T13:36:53.444091Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/tenants"
2025-11-01T13:36:53.444177Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/tenants": { <main>: Error: Check failed: path: '/local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/tenants', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 167], type: EPathTypeTable, state: EPathStateNoChanges) }
2025-11-01T13:36:53.452836Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/quotas"
2025-11-01T13:36:53.452859Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/jobs"
2025-11-01T13:36:53.452913Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/jobs": { <main>: Error: Check failed: path: '/local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/jobs', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 178], type: EPathTypeTable, state: EPathStateNoChanges) }
2025-11-01T13:36:53.452927Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/quotas": { <main>: Error: Check failed: path: '/local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/quotas', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 177], type: EPathTypeTable, state: EPathStateNoChanges) }
2025-11-01T13:36:53.455433Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/mappings"
2025-11-01T13:36:53.455435Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/idempotency_keys"
2025-11-01T13:36:53.455483Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/idempotency_keys": { <main>: Error: Check failed: path: '/local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/idempotency_keys', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 175], type: EPathTypeTable, state: EPathStateNoChanges) }
2025-11-01T13:36:53.455488Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/mappings": { <main>: Error: Check failed: path: '/local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/mappings', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 168], type: EPathTypeTable, state: EPathStateNoChanges) }
2025-11-01T13:36:53.457774Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/nodes"
2025-11-01T13:36:53.457778Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/tenant_acks"
2025-11-01T13:36:53.457829Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/tenant_acks": { <main>: Error: Check failed: path: '/local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/tenant_acks', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 183], type: EPathTypeTable, state: EPathStateNoChanges) }
2025-11-01T13:36:53.457853Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/nodes": { <main>: Error: Check failed: path: '/local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/nodes', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 180], type: EPathTypeTable, state: EPathStateNoChanges) }
2025-11-01T13:36:53.460205Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/compute_databases"
2025-11-01T13:36:53.460361Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/compute_databases": { <main>: Error: Check failed: path: '/local/DbPoolStorage_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/compute_databases', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 182], type: EPathTypeTable, state: EPathStateNoChanges) }
2025-11-01T13:36:53.522816Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:158: Successfully bootstrapped TStorageProxy [3:7567750471853028970:2066] with connection to localhost:61956:local
2025-11-01T13:36:54.293064Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: ef5c71cf-e0ddc7a5-5710ed89-b937216d2, Host: ghrun-ebytu4uhfq, Tenant: /default
2025-11-01T13:36:54.299920Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:542: Coordinator: Send TEvGetNodesRequest to NodesManager
2025-11-01T13:36:54.299987Z :YQL_NODES_MANAGER DEBUG: nodes_manager.cpp:300: TNodesManagerActor::TEvGetNodesRequest
2025-11-01T13:36:54.300031Z :FQ_ROW_DISPATCHER INFO: coordinator.cpp:573: Coordinator: Updated node info, node count: 3
2025-11-01T13:36:54.308345Z :FQ_QUOTA_SERVICE DEBUG: quota_manager.cpp:230: IC Peers[2]: [1, 2]
2025-11-01T13:36:54.429233Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-01T13:36:54.429270Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-01T13:36:55.283120Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:617: RowDispatcher: Send ping to [1:7567750464762687077:2125]
2025-11-01T13:36:55.283210Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1161: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-11-01T13:36:55.293120Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: ef5c71cf-e0ddc7a5-5710ed89-b937216d3, Host: ghrun-ebytu4uhfq, Tenant: /default
2025-11-01T13:36:55.328954Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-01T13:36:55.328984Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-01T13:36:56.293259Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: ef5c71cf-e0ddc7a5-5710ed89-b937216d4, Host: ghrun-ebytu4uhfq, Tenant: /default
2025-11-01T13:36:56.327602Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-01T13:36:56.327626Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-01T13:36:56.332202Z :FQ_CONTROL_PLANE_CONFIG TRACE: control_plane_config.cpp:192: LOADED TenantInfo: State NOT changed
2025-11-01T13:36:56.695005Z :INTERCONNECT ERROR: interconnect_nameserver_dynamic.cpp:61:  ICN06 Unknown nodeId: 4
2025-11-01T13:36:57.283446Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:617: RowDispatcher: Send ping to [1:7567750464762687077:2125]
2025-11-01T13:36:57.283517Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1161: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-11-01T13:36:57.293151Z :INTERCONNECT WARN: interconnect_handshake.cpp:501: Handshake [3:7567750489032898279:2056] [node 1] ICH09 Neither CompatibilityInfo nor VersionTag of the peer can be validated, accepting by default
2025-11-01T13:36:57.293461Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: ef5c71cf-e0ddc7a5-5710ed89-b937216d5, Host: ghrun-ebytu4uhfq, Tenant: /default
2025-11-01T13:36:57.295772Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:623: RowDispatcher: NActors::TEvents::TEvPong
2025-11-01T13:36:57.326282Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-01T13:36:57.326323Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-01T13:36:58.293663Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: ef5c71cf-e0ddc7a5-5710ed89-b937216d6, Host: ghrun-ebytu4uhfq, Tenant: /default
2025-11-01T13:36:58.308660Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-11-01T13:36:58.375811Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-01T13:36:58.375845Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-01T13:36:58.397887Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:389: Send NodeInfo with size: 3 to DynamicNameserver
2025-11-01T13:36:58.556129Z :INTERCONNECT WARN: interconnect_handshake.cpp:501: Handshake [3:7567750493327865583:2058] [node 2] ICH09 Neither CompatibilityInfo nor VersionTag of the peer can be validated, accepting by default
2025-11-01T13:36:59.283579Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:617: RowDispatcher: Send ping to [1:7567750464762687077:2125]
2025-11-01T13:36:59.283637Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1161: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-11-01T13:36:59.284370Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:623: RowDispatcher: NActors::TEvents::TEvPong
2025-11-01T13:36:59.293809Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: ef5c71cf-e0ddc7a5-5710ed89-b937216d7, Host: ghrun-ebytu4uhfq, Tenant: /default
2025-11-01T13:36:59.308734Z :FQ_QUOTA_SERVICE DEBUG: quota_manager.cpp:230: IC Peers[3]: [1, 2, 4]
2025-11-01T13:36:59.320838Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-01T13:36:59.320875Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-01T13:36:59.325457Z :FQ_CONTROL_PLANE_CONFIG TRACE: control_plane_config.cpp:192: LOADED TenantInfo: State NOT changed
2025-11-01T13:36:59.502296Z :INTERCONNECT WARN: interconnect_handshake.cpp:501: Handshake [3:7567750497622832890:2060] [node 4] ICH09 Neither CompatibilityInfo nor VersionTag of the peer can be validated, accepting by default
2025-11-01T13:37:00.294033Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: ef5c71cf-e0ddc7a5-5710ed89-b937216d8, Host: ghrun-ebytu4uhfq, Tenant: /default
2025-11-01T13:37:00.326353Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-01T13:37:00.326380Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-01T13:37:01.283766Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:617: RowDispatcher: Send ping to [1:7567750464762687077:2125]
2025-11-01T13:37:01.283823Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1161: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-11-01T13:37:01.284881Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:623: RowDispatcher: NActors::TEvents::TEvPong
2025-11-01T13:37:01.294213Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: ef5c71cf-e0ddc7a5-5710ed89-b937216d9, Host: ghrun-ebytu4uhfq, Tenant: /default
2025-11-01T13:37:02.223402Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-01T13:37:02.223437Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-01T13:37:02.294427Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: ef5c71cf-e0ddc7a5-5710ed89-b937216d10, Host: ghrun-ebytu4uhfq, Tenant: /default
2025-11-01T13:37:02.334080Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-01T13:37:02.334111Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-01T13:37:02.339802Z :FQ_CONTROL_PLANE_CONFIG TRACE: control_plane_config.cpp:192: LOADED TenantInfo: State NOT changed
2025-11-01T13:37:03.286568Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:617: RowDispatcher: Send ping to [1:7567750464762687077:2125]
2025-11-01T13:37:03.286616Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1161: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-11-01T13:37:03.287546Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:623: RowDispatcher: NActors::TEvents::TEvPong
2025-11-01T13:37:03.294648Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: ef5c71cf-e0ddc7a5-5710ed89-b937216d11, Host: ghrun-ebytu4uhfq, Tenant: /default
2025-11-01T13:37:03.308992Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-11-01T13:37:03.328121Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-01T13:37:03.328149Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-01T13:37:03.373193Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:389: Send NodeInfo with size: 3 to DynamicNameserver
2025-11-01T13:37:04.294795Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: ef5c71cf-e0ddc7a5-5710ed89-b937216d12, Host: ghrun-ebytu4uhfq, Tenant: /default
2025-11-01T13:37:04.333460Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-01T13:37:04.333498Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-01T13:37:05.219897Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ef5c71cf-e0ddc7a5-5710ed89-b937216d 2025-11-01 13:37:05.219 DEBUG ydbd(pid=1314950, tid=0x00007B2F59487640) [DQ] local_worker_manager.cpp:316: {ptqudtetm6reckhg120m} TLocalWorkerManager::TEvAllocateWorkersRequest 562954248388609
2025-11-01T13:37:05.220108Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ef5c71cf-e0ddc7a5-5710ed89-b937216d 2025-11-01 13:37:05.219 DEBUG ydbd(pid=1314950, tid=0x00007B2F59487640) [DQ] local_worker_manager.cpp:376: {ptqudtetm6reckhg120m} Create compute actor: async
2025-11-01T13:37:05.286765Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:617: RowDispatcher: Send ping to [1:7567750464762687077:2125]
2025-11-01T13:37:05.286857Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1161: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-11-01T13:37:05.287639Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:623: RowDispatcher: NActors::TEvents::TEvPong
2025-11-01T13:37:05.294986Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: ef5c71cf-e0ddc7a5-5710ed89-b937216d13, Host: ghrun-ebytu4uhfq, Tenant: /default
2025-11-01T13:37:05.329902Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-01T13:37:05.329928Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-01T13:37:05.331757Z :FQ_CONTROL_PLANE_CONFIG TRACE: control_plane_config.cpp:192: LOADED TenantInfo: State NOT changed
2025-11-01T13:37:05.353926Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:134: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. Start compute actor [3:7567750523392636675:2158], task: 2
2025-11-01T13:37:05.354144Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:113: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. Use CPU quota: 1. Rate limiter resource: { "local/RateLimiter_ee1b7082-2b19-4dc4-afac-fbd6e65e4fe5/rate_limiter", "mock_cloud/my_folder/ptqudtetm6reckhg120m" }
2025-11-01T13:37:05.675968Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:197: [] Task: 2. Got TEvNewCheckpointCoordinator event: generation 1, actorId: [1:7567750524892229532:2402]
2025-11-01T13:37:05.675994Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:208: [] Task: 2. Assign checkpoint coordinator (generation = 1)
2025-11-01T13:37:05.676865Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:395: [ptqudtetm6reckhg120m-0] Task: 2. Handle connected node 1
2025-11-01T13:37:05.849385Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1074: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. Received channels info: Update { Id: 1 TransportVersion: DATA_TRANSPORT_UV_PICKLE_1_0 SrcTaskId: 1 DstTaskId: 2 SrcEndpoint { ActorId { RawX1: 7567750524892229538 RawX2: 4503603922340200 } } DstEndpoint { ActorId { RawX1: 7567750523392636675 RawX2: 4503612512274542 } } SrcStageId: 200322 DstStageId: 200339 } Update { Id: 2 TransportVersion: DATA_TRANSPORT_UV_PICKLE_1_0 SrcTaskId: 2 SrcEndpoint { ActorId { RawX1: 7567750523392636675 RawX2: 4503612512274542 } } DstEndpoint { ActorId { RawX1: 7567750524892229531 RawX2: 4503603922340193 } } }
2025-11-01T13:37:05.849428Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1081: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. Update input channelId: 1, peer: [1:7567750524892229538:2408]
2025-11-01T13:37:05.849460Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1093: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. Update output channelId: 2, peer: [1:7567750524892229531:2401]
2025-11-01T13:37:06.295169Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: ef5c71cf-e0ddc7a5-5710ed89-b937216d14, Host: ghrun-ebytu4uhfq, Tenant: /default
2025-11-01T13:37:06.323081Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-01T13:37:06.323113Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-01T13:37:06.720202Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1169: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. Got TEvRun from actor [1:7567750524892229532:2402]
2025-11-01T13:37:06.720323Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1486: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. Poll inputs
2025-11-01T13:37:06.720336Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1501: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. Poll sources
2025-11-01T13:37:06.720348Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-11-01T13:37:06.720563Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ef5c71cf-e0ddc7a5-5710ed89-b937216d 2025-11-01 13:37:06.720 DEBUG ydbd(pid=1314950, tid=0x00007B2F59487640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Run task: 2
2025-11-01T13:37:06.720741Z :KQP_COMPUTE TRACE: dq_compute_memory_quota.h:97: TxId: ptqudtetm6reckhg120m, task: 2. Peak memory usage: 2031616
2025-11-01T13:37:06.720801Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. update task runner stats
2025-11-01T13:37:06.720897Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-01T13:37:06.720926Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-01T13:37:06.720958Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:532: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. About to drain channelId: 2, hasPeer: 1, peerState:(freeSpace:1000000;inFlightBytes:0;inFlightCount:0;)
2025-11-01T13:37:06.720979Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1105: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. Ask CPU quota: 49ms
2025-11-01T13:37:06.721081Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:605: TxId: ptqudtetm6reckhg120m, task: 2. no poll, channelId: 1, hasPeer: 1, finished: 0, retry: 0, lastSeqNo: 0, freeSpace: 1000000
2025-11-01T13:37:06.723195Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:129: TxId: ptqudtetm6reckhg120m, task: 2. Received input for channelId: 1, seqNo: 1, size: 0, chunks: 0, watermark: 0, checkpoint: 1, finished: 0, from: [1:7567750524892229539:2408], expected seqNo: 1
2025-11-01T13:37:06.723232Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:609: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. took input
2025-11-01T13:37:06.723338Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:485: [ptqudtetm6reckhg120m-0] Task: 2. [Checkpoint 1.1] Got checkpoint barrier from channel 1
2025-11-01T13:37:06.723433Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:395: SelfId: [3:7567750523392636677:2158], TxId: ptqudtetm6reckhg120m, task: 2. No watermark 
2025-11-01T13:37:06.723456Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1486: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. Poll inputs
2025-11-01T13:37:06.723468Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1497: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-11-01T13:37:06.723478Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. DoExecuteImpl: 1
2025-11-01T13:37:06.723505Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:965: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. Input data push finished. Cookie: 0 Watermark: (empty maybe) Ack: 1 TakeInputChannelDataRequests: 1
2025-11-01T13:37:06.723540Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:738: TxId: ptqudtetm6reckhg120m, task: 2. Sending channel data ack to channelId: 1, peer: [1:7567750524892229538:2408], from: [3:7567750523392636675:2158], freeSpace: 1000000, seqNo: 1, finished: 0
2025-11-01T13:37:06.723581Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1486: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. Poll inputs
2025-11-01T13:37:06.723585Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1497: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-11-01T13:37:06.723591Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-11-01T13:37:06.731835Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1162: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. CPU quota delay: 10ms
2025-11-01T13:37:06.732114Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:510: SelfId: [3:7567750523392636677:2158], TxId: ptqudtetm6reckhg120m, task: 2. Pending 1 checkpoints to be sent
2025-11-01T13:37:06.732163Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. update task runner stats
2025-11-01T13:37:06.732345Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 1 watermark injected: (empty maybe)
2025-11-01T13:37:06.732377Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:447: [ptqudtetm6reckhg120m-0] Task: 2. [Checkpoint 1.1] Performing task checkpoint
2025-11-01T13:37:06.732389Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:822: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. Save state
2025-11-01T13:37:06.732405Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:474: [ptqudtetm6reckhg120m-0] Task: 2. [Checkpoint 1.1] CA state saved
2025-11-01T13:37:06.732423Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:449: [ptqudtetm6reckhg120m-0] Task: 2. [Checkpoint 1.1] Injecting checkpoint barrier to outputs
2025-11-01T13:37:06.732460Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:536: [ptqudtetm6reckhg120m-0] Task: 2. [Checkpoint 1.1] Task checkpoint is done. Send to storage
2025-11-01T13:37:06.732471Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-01T13:37:06.732495Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:532: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. About to drain channelId: 2, hasPeer: 1, peerState:(freeSpace:1000000;inFlightBytes:0;inFlightCount:0;)
2025-11-01T13:37:06.732569Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:566: TxId: ptqudtetm6reckhg120m, task: 2. SendChannelData, channelId: 2, peer: [1:7567750524892229531:2401], chunks: 0, bytes: 0, watermark: 0, checkpoint: 1, seqNo: 1, finished: 0
2025-11-01T13:37:06.732656Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudtetm6reckhg120m, task: 2. no poll, channelId: 1, has inflight messages: [1], last with freeSpace: 1000000, current freeSpace: 1000000
2025-11-01T13:37:06.732678Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1486: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. Poll inputs
2025-11-01T13:37:06.732710Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1501: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. Poll sources
2025-11-01T13:37:06.732725Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-11-01T13:37:06.732934Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. update task runner stats
2025-11-01T13:37:06.732989Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-01T13:37:06.732997Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-01T13:37:06.733035Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:532: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. About to drain channelId: 2, hasPeer: 1, peerState:(freeSpace:1000000;inFlightBytes:96;inFlightCount:1;)
2025-11-01T13:37:06.733082Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudtetm6reckhg120m, task: 2. no poll, channelId: 1, has inflight messages: [1], last with freeSpace: 1000000, current freeSpace: 1000000
2025-11-01T13:37:06.733143Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:366: [ptqudtetm6reckhg120m-0] [1:1] Got TEvSaveTaskState: task 2
2025-11-01T13:37:06.733630Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:179: TxId: ptqudtetm6reckhg120m, task: 2. Received channel data ack for channelId: 2, seqNo: 1, lastSentSeqNo: 1, freeSpace: 67108864, early finish: 0
2025-11-01T13:37:06.733690Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:207: TxId: ptqudtetm6reckhg120m, task: 2. PeerState, peerState:(freeSpace:67108864;inFlightBytes:0;inFlightCount:0;), sentSeqNo: 1, ackSeqNo: 1
2025-11-01T13:37:06.733707Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:220: TxId: ptqudtetm6reckhg120m, task: 2. Resume compute actor
2025-11-01T13:37:06.733731Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1486: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. Poll inputs
2025-11-01T13:37:06.733738Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1501: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. Poll sources
2025-11-01T13:37:06.733758Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-11-01T13:37:06.733934Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. update task runner stats
2025-11-01T13:37:06.733990Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-01T13:37:06.733997Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-01T13:37:06.734010Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:532: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. About to drain channelId: 2, hasPeer: 1, peerState:(freeSpace:67108864;inFlightBytes:0;inFlightCount:0;)
2025-11-01T13:37:06.734048Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudtetm6reckhg120m, task: 2. no poll, channelId: 1, has inflight messages: [1], last with freeSpace: 1000000, current freeSpace: 1000000
2025-11-01T13:37:06.933072Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:390: [ptqudtetm6reckhg120m-0] [1:1] TEvSaveTaskState Apply: task: 2
2025-11-01T13:37:06.933126Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:405: [ptqudtetm6reckhg120m-0] [1:1] Send TEvSaveTaskStateResult: task: 2
2025-11-01T13:37:07.287032Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:617: RowDispatcher: Send ping to [1:7567750464762687077:2125]
2025-11-01T13:37:07.287106Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1161: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-11-01T13:37:07.292106Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:623: RowDispatcher: NActors::TEvents::TEvPong
2025-11-01T13:37:07.295416Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: ef5c71cf-e0ddc7a5-5710ed89-b937216d15, Host: ghrun-ebytu4uhfq, Tenant: /default
2025-11-01T13:37:07.371751Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-01T13:37:07.371779Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-01T13:37:08.207838Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:505: cloud.mock_cloud.yq.cpuPercent.count=0/10000 UPDATE from Peer 1
2025-11-01T13:37:08.295569Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: ef5c71cf-e0ddc7a5-5710ed89-b937216d16, Host: ghrun-ebytu4uhfq, Tenant: /default
2025-11-01T13:37:08.305769Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:129: TxId: ptqudtetm6reckhg120m, task: 2. Received input for channelId: 1, seqNo: 2, size: 0, chunks: 0, watermark: 0, checkpoint: 1, finished: 0, from: [1:7567750524892229539:2408], expected seqNo: 2
2025-11-01T13:37:08.305827Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:609: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. took input
2025-11-01T13:37:08.305887Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:485: [ptqudtetm6reckhg120m-0] Task: 2. [Checkpoint 1.2] Got checkpoint barrier from channel 1
2025-11-01T13:37:08.305963Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:395: SelfId: [3:7567750523392636677:2158], TxId: ptqudtetm6reckhg120m, task: 2. No watermark 
2025-11-01T13:37:08.305996Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1486: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. Poll inputs
2025-11-01T13:37:08.306004Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1497: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-11-01T13:37:08.306014Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. DoExecuteImpl: 1
2025-11-01T13:37:08.306043Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:965: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. Input data push finished. Cookie: 1 Watermark: (empty maybe) Ack: 1 TakeInputChannelDataRequests: 1
2025-11-01T13:37:08.306066Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:738: TxId: ptqudtetm6reckhg120m, task: 2. Sending channel data ack to channelId: 1, peer: [1:7567750524892229538:2408], from: [3:7567750523392636675:2158], freeSpace: 1000000, seqNo: 2, finished: 0
2025-11-01T13:37:08.306302Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ef5c71cf-e0ddc7a5-5710ed89-b937216d 2025-11-01 13:37:08.306 DEBUG ydbd(pid=1314950, tid=0x00007B2F59487640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Run task: 2
2025-11-01T13:37:08.306418Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:510: SelfId: [3:7567750523392636677:2158], TxId: ptqudtetm6reckhg120m, task: 2. Pending 1 checkpoints to be sent
2025-11-01T13:37:08.306502Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1486: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. Poll inputs
2025-11-01T13:37:08.306517Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1497: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-11-01T13:37:08.306525Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-11-01T13:37:08.306546Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. update task runner stats
2025-11-01T13:37:08.306650Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 1 watermark injected: (empty maybe)
2025-11-01T13:37:08.306670Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:447: [ptqudtetm6reckhg120m-0] Task: 2. [Checkpoint 1.2] Performing task checkpoint
2025-11-01T13:37:08.306684Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:822: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. Save state
2025-11-01T13:37:08.306701Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:474: [ptqudtetm6reckhg120m-0] Task: 2. [Checkpoint 1.2] CA state saved
2025-11-01T13:37:08.306714Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:449: [ptqudtetm6reckhg120m-0] Task: 2. [Checkpoint 1.2] Injecting checkpoint barrier to outputs
2025-11-01T13:37:08.306780Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:536: [ptqudtetm6reckhg120m-0] Task: 2. [Checkpoint 1.2] Task checkpoint is done. Send to storage
2025-11-01T13:37:08.306798Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-01T13:37:08.306832Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:532: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. About to drain channelId: 2, hasPeer: 1, peerState:(freeSpace:67108864;inFlightBytes:0;inFlightCount:0;)
2025-11-01T13:37:08.306846Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:366: [ptqudtetm6reckhg120m-0] [1:2] Got TEvSaveTaskState: task 2
2025-11-01T13:37:08.307033Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ef5c71cf-e0ddc7a5-5710ed89-b937216d 2025-11-01 13:37:08.306 DEBUG ydbd(pid=1314950, tid=0x00007B2F59487640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Run task: 2
2025-11-01T13:37:08.307113Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:566: TxId: ptqudtetm6reckhg120m, task: 2. SendChannelData, channelId: 2, peer: [1:7567750524892229531:2401], chunks: 0, bytes: 0, watermark: 0, checkpoint: 1, seqNo: 2, finished: 0
2025-11-01T13:37:08.307181Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudtetm6reckhg120m, task: 2. no poll, channelId: 1, has inflight messages: [2], last with freeSpace: 1000000, current freeSpace: 1000000
2025-11-01T13:37:08.307233Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. update task runner stats
2025-11-01T13:37:08.307297Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-01T13:37:08.307311Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-01T13:37:08.307329Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:532: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. About to drain channelId: 2, hasPeer: 1, peerState:(freeSpace:67108864;inFlightBytes:96;inFlightCount:1;)
2025-11-01T13:37:08.307346Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1486: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. Poll inputs
2025-11-01T13:37:08.307354Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1501: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. Poll sources
2025-11-01T13:37:08.307362Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-11-01T13:37:08.307557Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ef5c71cf-e0ddc7a5-5710ed89-b937216d 2025-11-01 13:37:08.307 DEBUG ydbd(pid=1314950, tid=0x00007B2F59487640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Run task: 2
2025-11-01T13:37:08.307637Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudtetm6reckhg120m, task: 2. no poll, channelId: 1, has inflight messages: [2], last with freeSpace: 1000000, current freeSpace: 1000000
2025-11-01T13:37:08.307655Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. update task runner stats
2025-11-01T13:37:08.307783Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-01T13:37:08.307797Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-01T13:37:08.307817Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:532: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. About to drain channelId: 2, hasPeer: 1, peerState:(freeSpace:67108864;inFlightBytes:96;inFlightCount:1;)
2025-11-01T13:37:08.307859Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:179: TxId: ptqudtetm6reckhg120m, task: 2. Received channel data ack for channelId: 2, seqNo: 2, lastSentSeqNo: 2, freeSpace: 67108864, early finish: 0
2025-11-01T13:37:08.307896Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:207: TxId: ptqudtetm6reckhg120m, task: 2. PeerState, peerState:(freeSpace:67108864;inFlightBytes:0;inFlightCount:0;), sentSeqNo: 2, ackSeqNo: 2
2025-11-01T13:37:08.307905Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:220: TxId: ptqudtetm6reckhg120m, task: 2. Resume compute actor
2025-11-01T13:37:08.307934Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1486: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. Poll inputs
2025-11-01T13:37:08.307940Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1501: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. Poll sources
2025-11-01T13:37:08.307952Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-11-01T13:37:08.307993Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudtetm6reckhg120m, task: 2. no poll, channelId: 1, has inflight messages: [2], last with freeSpace: 1000000, current freeSpace: 1000000
2025-11-01T13:37:08.308124Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ef5c71cf-e0ddc7a5-5710ed89-b937216d 2025-11-01 13:37:08.308 DEBUG ydbd(pid=1314950, tid=0x00007B2F59487640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Run task: 2
2025-11-01T13:37:08.308169Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. update task runner stats
2025-11-01T13:37:08.308224Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-01T13:37:08.308246Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-01T13:37:08.308265Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:532: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. About to drain channelId: 2, hasPeer: 1, peerState:(freeSpace:67108864;inFlightBytes:0;inFlightCount:0;)
2025-11-01T13:37:08.308314Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudtetm6reckhg120m, task: 2. no poll, channelId: 1, has inflight messages: [2], last with freeSpace: 1000000, current freeSpace: 1000000
2025-11-01T13:37:08.309101Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-11-01T13:37:08.326989Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-01T13:37:08.327014Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-01T13:37:08.332731Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:390: [ptqudtetm6reckhg120m-0] [1:2] TEvSaveTaskState Apply: task: 2
2025-11-01T13:37:08.332774Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:405: [ptqudtetm6reckhg120m-0] [1:2] Send TEvSaveTaskStateResult: task: 2
2025-11-01T13:37:08.336846Z :FQ_CONTROL_PLANE_CONFIG TRACE: control_plane_config.cpp:192: LOADED TenantInfo: State NOT changed
2025-11-01T13:37:08.362090Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:389: Send NodeInfo with size: 3 to DynamicNameserver
2025-11-01T13:37:08.492444Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:505: cloud.mock_cloud.yq.streamingQuery.count=1/100 UPDATE from Peer 1
2025-11-01T13:37:08.492780Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:505: cloud.mock_cloud.yq.analyticsQuery.count=0/100 UPDATE from Peer 1
2025-11-01T13:37:08.744938Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:129: TxId: ptqudtetm6reckhg120m, task: 2. Received input for channelId: 1, seqNo: 3, size: 0, chunks: 0, watermark: 0, checkpoint: 1, finished: 0, from: [1:7567750524892229539:2408], expected seqNo: 3
2025-11-01T13:37:08.744969Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:609: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. took input
2025-11-01T13:37:08.745018Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:485: [ptqudtetm6reckhg120m-0] Task: 2. [Checkpoint 1.3] Got checkpoint barrier from channel 1
2025-11-01T13:37:08.745099Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:395: SelfId: [3:7567750523392636677:2158], TxId: ptqudtetm6reckhg120m, task: 2. No watermark 
2025-11-01T13:37:08.745119Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1486: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. Poll inputs
2025-11-01T13:37:08.745127Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1497: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-11-01T13:37:08.745137Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. DoExecuteImpl: 1
2025-11-01T13:37:08.745164Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:965: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. Input data push finished. Cookie: 2 Watermark: (empty maybe) Ack: 1 TakeInputChannelDataRequests: 1
2025-11-01T13:37:08.745187Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:738: TxId: ptqudtetm6reckhg120m, task: 2. Sending channel data ack to channelId: 1, peer: [1:7567750524892229538:2408], from: [3:7567750523392636675:2158], freeSpace: 1000000, seqNo: 3, finished: 0
2025-11-01T13:37:08.745388Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ef5c71cf-e0ddc7a5-5710ed89-b937216d 2025-11-01 13:37:08.745 DEBUG ydbd(pid=1314950, tid=0x00007B2F59487640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Run task: 2
2025-11-01T13:37:08.745494Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:510: SelfId: [3:7567750523392636677:2158], TxId: ptqudtetm6reckhg120m, task: 2. Pending 1 checkpoints to be sent
2025-11-01T13:37:08.745544Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1486: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. Poll inputs
2025-11-01T13:37:08.745556Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1497: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-11-01T13:37:08.745564Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-11-01T13:37:08.745580Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. update task runner stats
2025-11-01T13:37:08.745663Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 1 watermark injected: (empty maybe)
2025-11-01T13:37:08.745690Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:447: [ptqudtetm6reckhg120m-0] Task: 2. [Checkpoint 1.3] Performing task checkpoint
2025-11-01T13:37:08.745699Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:822: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. Save state
2025-11-01T13:37:08.745718Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:474: [ptqudtetm6reckhg120m-0] Task: 2. [Checkpoint 1.3] CA state saved
2025-11-01T13:37:08.745729Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:449: [ptqudtetm6reckhg120m-0] Task: 2. [Checkpoint 1.3] Injecting checkpoint barrier to outputs
2025-11-01T13:37:08.745762Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:536: [ptqudtetm6reckhg120m-0] Task: 2. [Checkpoint 1.3] Task checkpoint is done. Send to storage
2025-11-01T13:37:08.745772Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-01T13:37:08.745793Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:532: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. About to drain channelId: 2, hasPeer: 1, peerState:(freeSpace:67108864;inFlightBytes:0;inFlightCount:0;)
2025-11-01T13:37:08.745821Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:366: [ptqudtetm6reckhg120m-0] [1:3] Got TEvSaveTaskState: task 2
2025-11-01T13:37:08.746329Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ef5c71cf-e0ddc7a5-5710ed89-b937216d 2025-11-01 13:37:08.746 DEBUG ydbd(pid=1314950, tid=0x00007B2F59487640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Run task: 2
2025-11-01T13:37:08.746407Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:566: TxId: ptqudtetm6reckhg120m, task: 2. SendChannelData, channelId: 2, peer: [1:7567750524892229531:2401], chunks: 0, bytes: 0, watermark: 0, checkpoint: 1, seqNo: 3, finished: 0
2025-11-01T13:37:08.746473Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudtetm6reckhg120m, task: 2. no poll, channelId: 1, has inflight messages: [3], last with freeSpace: 1000000, current freeSpace: 1000000
2025-11-01T13:37:08.746488Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. update task runner stats
2025-11-01T13:37:08.746562Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-01T13:37:08.746574Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-01T13:37:08.746592Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:532: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. About to drain channelId: 2, hasPeer: 1, peerState:(freeSpace:67108864;inFlightBytes:96;inFlightCount:1;)
2025-11-01T13:37:08.746609Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1486: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. Poll inputs
2025-11-01T13:37:08.746617Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1501: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. Poll sources
2025-11-01T13:37:08.746634Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-11-01T13:37:08.746755Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ef5c71cf-e0ddc7a5-5710ed89-b937216d 2025-11-01 13:37:08.746 DEBUG ydbd(pid=1314950, tid=0x00007B2F59487640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Run task: 2
2025-11-01T13:37:08.746813Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudtetm6reckhg120m, task: 2. no poll, channelId: 1, has inflight messages: [3], last with freeSpace: 1000000, current freeSpace: 1000000
2025-11-01T13:37:08.746822Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. update task runner stats
2025-11-01T13:37:08.746867Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-01T13:37:08.746874Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-01T13:37:08.746897Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:532: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. About to drain channelId: 2, hasPeer: 1, peerState:(freeSpace:67108864;inFlightBytes:96;inFlightCount:1;)
2025-11-01T13:37:08.746928Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudtetm6reckhg120m, task: 2. no poll, channelId: 1, has inflight messages: [3], last with freeSpace: 1000000, current freeSpace: 1000000
2025-11-01T13:37:08.747013Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:179: TxId: ptqudtetm6reckhg120m, task: 2. Received channel data ack for channelId: 2, seqNo: 3, lastSentSeqNo: 3, freeSpace: 67108864, early finish: 0
2025-11-01T13:37:08.747039Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:207: TxId: ptqudtetm6reckhg120m, task: 2. PeerState, peerState:(freeSpace:67108864;inFlightBytes:0;inFlightCount:0;), sentSeqNo: 3, ackSeqNo: 3
2025-11-01T13:37:08.747048Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:220: TxId: ptqudtetm6reckhg120m, task: 2. Resume compute actor
2025-11-01T13:37:08.747070Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1486: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. Poll inputs
2025-11-01T13:37:08.747076Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1501: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. Poll sources
2025-11-01T13:37:08.747083Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-11-01T13:37:08.747193Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ef5c71cf-e0ddc7a5-5710ed89-b937216d 2025-11-01 13:37:08.747 DEBUG ydbd(pid=1314950, tid=0x00007B2F59487640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Run task: 2
2025-11-01T13:37:08.747242Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. update task runner stats
2025-11-01T13:37:08.747313Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-01T13:37:08.747323Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-01T13:37:08.747341Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:532: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. About to drain channelId: 2, hasPeer: 1, peerState:(freeSpace:67108864;inFlightBytes:0;inFlightCount:0;)
2025-11-01T13:37:08.747381Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudtetm6reckhg120m, task: 2. no poll, channelId: 1, has inflight messages: [3], last with freeSpace: 1000000, current freeSpace: 1000000
2025-11-01T13:37:08.779527Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:390: [ptqudtetm6reckhg120m-0] [1:3] TEvSaveTaskState Apply: task: 2
2025-11-01T13:37:08.779560Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:405: [ptqudtetm6reckhg120m-0] [1:3] Send TEvSaveTaskStateResult: task: 2
2025-11-01T13:37:09.287015Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:617: RowDispatcher: Send ping to [1:7567750464762687077:2125]
2025-11-01T13:37:09.287243Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1161: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-11-01T13:37:09.287802Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:623: RowDispatcher: NActors::TEvents::TEvPong
2025-11-01T13:37:09.295788Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: ef5c71cf-e0ddc7a5-5710ed89-b937216d17, Host: ghrun-ebytu4uhfq, Tenant: /default
2025-11-01T13:37:09.324056Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-01T13:37:09.324083Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-01T13:37:09.765835Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:129: TxId: ptqudtetm6reckhg120m, task: 2. Received input for channelId: 1, seqNo: 4, size: 0, chunks: 0, watermark: 0, checkpoint: 1, finished: 0, from: [1:7567750524892229539:2408], expected seqNo: 4
2025-11-01T13:37:09.765869Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:609: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. took input
2025-11-01T13:37:09.765917Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:485: [ptqudtetm6reckhg120m-0] Task: 2. [Checkpoint 1.4] Got checkpoint barrier from channel 1
2025-11-01T13:37:09.765974Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:395: SelfId: [3:7567750523392636677:2158], TxId: ptqudtetm6reckhg120m, task: 2. No watermark 
2025-11-01T13:37:09.765993Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1486: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. Poll inputs
2025-11-01T13:37:09.766014Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1497: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-11-01T13:37:09.766024Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. DoExecuteImpl: 1
2025-11-01T13:37:09.766052Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:965: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. Input data push finished. Cookie: 3 Watermark: (empty maybe) Ack: 1 TakeInputChannelDataRequests: 1
2025-11-01T13:37:09.766075Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:738: TxId: ptqudtetm6reckhg120m, task: 2. Sending channel data ack to channelId: 1, peer: [1:7567750524892229538:2408], from: [3:7567750523392636675:2158], freeSpace: 1000000, seqNo: 4, finished: 0
2025-11-01T13:37:09.766297Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ef5c71cf-e0ddc7a5-5710ed89-b937216d 2025-11-01 13:37:09.766 DEBUG ydbd(pid=1314950, tid=0x00007B2F59487640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Run task: 2
2025-11-01T13:37:09.766383Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:510: SelfId: [3:7567750523392636677:2158], TxId: ptqudtetm6reckhg120m, task: 2. Pending 1 checkpoints to be sent
2025-11-01T13:37:09.766411Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1486: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. Poll inputs
2025-11-01T13:37:09.766423Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1497: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-11-01T13:37:09.766430Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-11-01T13:37:09.766443Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. update task runner stats
2025-11-01T13:37:09.766563Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 1 watermark injected: (empty maybe)
2025-11-01T13:37:09.766583Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:447: [ptqudtetm6reckhg120m-0] Task: 2. [Checkpoint 1.4] Performing task checkpoint
2025-11-01T13:37:09.766593Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:822: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. Save state
2025-11-01T13:37:09.766606Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:474: [ptqudtetm6reckhg120m-0] Task: 2. [Checkpoint 1.4] CA state saved
2025-11-01T13:37:09.766617Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:449: [ptqudtetm6reckhg120m-0] Task: 2. [Checkpoint 1.4] Injecting checkpoint barrier to outputs
2025-11-01T13:37:09.766646Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:536: [ptqudtetm6reckhg120m-0] Task: 2. [Checkpoint 1.4] Task checkpoint is done. Send to storage
2025-11-01T13:37:09.766656Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-01T13:37:09.766695Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:532: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. About to drain channelId: 2, hasPeer: 1, peerState:(freeSpace:67108864;inFlightBytes:0;inFlightCount:0;)
2025-11-01T13:37:09.766702Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:366: [ptqudtetm6reckhg120m-0] [1:4] Got TEvSaveTaskState: task 2
2025-11-01T13:37:09.766839Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ef5c71cf-e0ddc7a5-5710ed89-b937216d 2025-11-01 13:37:09.766 DEBUG ydbd(pid=1314950, tid=0x00007B2F59487640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Run task: 2
2025-11-01T13:37:09.766920Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:566: TxId: ptqudtetm6reckhg120m, task: 2. SendChannelData, channelId: 2, peer: [1:7567750524892229531:2401], chunks: 0, bytes: 0, watermark: 0, checkpoint: 1, seqNo: 4, finished: 0
2025-11-01T13:37:09.766989Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudtetm6reckhg120m, task: 2. no poll, channelId: 1, has inflight messages: [4], last with freeSpace: 1000000, current freeSpace: 1000000
2025-11-01T13:37:09.767010Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. update task runner stats
2025-11-01T13:37:09.767092Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-01T13:37:09.767118Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-01T13:37:09.767136Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:532: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. About to drain channelId: 2, hasPeer: 1, peerState:(freeSpace:67108864;inFlightBytes:96;inFlightCount:1;)
2025-11-01T13:37:09.767160Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1486: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. Poll inputs
2025-11-01T13:37:09.767170Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1501: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. Poll sources
2025-11-01T13:37:09.767178Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-11-01T13:37:09.767303Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ef5c71cf-e0ddc7a5-5710ed89-b937216d 2025-11-01 13:37:09.767 DEBUG ydbd(pid=1314950, tid=0x00007B2F59487640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Run task: 2
2025-11-01T13:37:09.767361Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudtetm6reckhg120m, task: 2. no poll, channelId: 1, has inflight messages: [4], last with freeSpace: 1000000, current freeSpace: 1000000
2025-11-01T13:37:09.767373Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. update task runner stats
2025-11-01T13:37:09.767414Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-01T13:37:09.767431Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-01T13:37:09.767444Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:532: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. About to drain channelId: 2, hasPeer: 1, peerState:(freeSpace:67108864;inFlightBytes:96;inFlightCount:1;)
2025-11-01T13:37:09.767477Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudtetm6reckhg120m, task: 2. no poll, channelId: 1, has inflight messages: [4], last with freeSpace: 1000000, current freeSpace: 1000000
2025-11-01T13:37:09.767837Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:179: TxId: ptqudtetm6reckhg120m, task: 2. Received channel data ack for channelId: 2, seqNo: 4, lastSentSeqNo: 4, freeSpace: 67108864, early finish: 0
2025-11-01T13:37:09.767867Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:207: TxId: ptqudtetm6reckhg120m, task: 2. PeerState, peerState:(freeSpace:67108864;inFlightBytes:0;inFlightCount:0;), sentSeqNo: 4, ackSeqNo: 4
2025-11-01T13:37:09.767877Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:220: TxId: ptqudtetm6reckhg120m, task: 2. Resume compute actor
2025-11-01T13:37:09.767896Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1486: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. Poll inputs
2025-11-01T13:37:09.767902Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1501: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. Poll sources
2025-11-01T13:37:09.767914Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-11-01T13:37:09.768085Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ef5c71cf-e0ddc7a5-5710ed89-b937216d 2025-11-01 13:37:09.768 DEBUG ydbd(pid=1314950, tid=0x00007B2F59487640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Run task: 2
2025-11-01T13:37:09.768138Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. update task runner stats
2025-11-01T13:37:09.768190Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-01T13:37:09.768206Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-01T13:37:09.768223Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:532: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. About to drain channelId: 2, hasPeer: 1, peerState:(freeSpace:67108864;inFlightBytes:0;inFlightCount:0;)
2025-11-01T13:37:09.768323Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudtetm6reckhg120m, task: 2. no poll, channelId: 1, has inflight messages: [4], last with freeSpace: 1000000, current freeSpace: 1000000
2025-11-01T13:37:09.787460Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:390: [ptqudtetm6reckhg120m-0] [1:4] TEvSaveTaskState Apply: task: 2
2025-11-01T13:37:09.787504Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:405: [ptqudtetm6reckhg120m-0] [1:4] Send TEvSaveTaskStateResult: task: 2
2025-11-01T13:37:10.296056Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: ef5c71cf-e0ddc7a5-5710ed89-b937216d18, Host: ghrun-ebytu4uhfq, Tenant: /default
2025-11-01T13:37:10.355966Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-01T13:37:10.356000Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-01T13:37:10.492335Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:451: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. Got TEvStateRequest from actor [1:7567750524892229536:2406] PingCookie: 1
2025-11-01T13:37:10.492385Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. update task runner stats
2025-11-01T13:37:10.768953Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:129: TxId: ptqudtetm6reckhg120m, task: 2. Received input for channelId: 1, seqNo: 5, size: 0, chunks: 0, watermark: 0, checkpoint: 1, finished: 0, from: [1:7567750524892229539:2408], expected seqNo: 5
2025-11-01T13:37:10.768986Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:609: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. took input
2025-11-01T13:37:10.769036Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:485: [ptqudtetm6reckhg120m-0] Task: 2. [Checkpoint 1.5] Got checkpoint barrier from channel 1
2025-11-01T13:37:10.769091Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:395: SelfId: [3:7567750523392636677:2158], TxId: ptqudtetm6reckhg120m, task: 2. No watermark 
2025-11-01T13:37:10.769110Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1486: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. Poll inputs
2025-11-01T13:37:10.769120Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1497: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-11-01T13:37:10.769136Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. DoExecuteImpl: 1
2025-11-01T13:37:10.769164Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:965: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. Input data push finished. Cookie: 4 Watermark: (empty maybe) Ack: 1 TakeInputChannelDataRequests: 1
2025-11-01T13:37:10.769193Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:738: TxId: ptqudtetm6reckhg120m, task: 2. Sending channel data ack to channelId: 1, peer: [1:7567750524892229538:2408], from: [3:7567750523392636675:2158], freeSpace: 1000000, seqNo: 5, finished: 0
2025-11-01T13:37:10.769379Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ef5c71cf-e0ddc7a5-5710ed89-b937216d 2025-11-01 13:37:10.769 DEBUG ydbd(pid=1314950, tid=0x00007B2F59487640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Run task: 2
2025-11-01T13:37:10.769463Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:510: SelfId: [3:7567750523392636677:2158], TxId: ptqudtetm6reckhg120m, task: 2. Pending 1 checkpoints to be sent
2025-11-01T13:37:10.769488Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1486: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. Poll inputs
2025-11-01T13:37:10.769495Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1497: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-11-01T13:37:10.769509Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-11-01T13:37:10.769524Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. update task runner stats
2025-11-01T13:37:10.769603Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 1 watermark injected: (empty maybe)
2025-11-01T13:37:10.769617Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:447: [ptqudtetm6reckhg120m-0] Task: 2. [Checkpoint 1.5] Performing task checkpoint
2025-11-01T13:37:10.769626Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:822: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. Save state
2025-11-01T13:37:10.769639Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:474: [ptqudtetm6reckhg120m-0] Task: 2. [Checkpoint 1.5] CA state saved
2025-11-01T13:37:10.769649Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:449: [ptqudtetm6reckhg120m-0] Task: 2. [Checkpoint 1.5] Injecting checkpoint barrier to outputs
2025-11-01T13:37:10.769682Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:536: [ptqudtetm6reckhg120m-0] Task: 2. [Checkpoint 1.5] Task checkpoint is done. Send to storage
2025-11-01T13:37:10.769693Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-01T13:37:10.769722Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:532: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. About to drain channelId: 2, hasPeer: 1, peerState:(freeSpace:67108864;inFlightBytes:0;inFlightCount:0;)
2025-11-01T13:37:10.769737Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1105: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. Ask CPU quota: 10ms
2025-11-01T13:37:10.769798Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:566: TxId: ptqudtetm6reckhg120m, task: 2. SendChannelData, channelId: 2, peer: [1:7567750524892229531:2401], chunks: 0, bytes: 0, watermark: 0, checkpoint: 1, seqNo: 5, finished: 0
2025-11-01T13:37:10.769841Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudtetm6reckhg120m, task: 2. no poll, channelId: 1, has inflight messages: [5], last with freeSpace: 1000000, current freeSpace: 1000000
2025-11-01T13:37:10.769853Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1486: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. Poll inputs
2025-11-01T13:37:10.769861Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1501: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. Poll sources
2025-11-01T13:37:10.769868Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-11-01T13:37:10.769894Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:366: [ptqudtetm6reckhg120m-0] [1:5] Got TEvSaveTaskState: task 2
2025-11-01T13:37:10.777333Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:179: TxId: ptqudtetm6reckhg120m, task: 2. Received channel data ack for channelId: 2, seqNo: 5, lastSentSeqNo: 5, freeSpace: 67108864, early finish: 0
2025-11-01T13:37:10.777383Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:207: TxId: ptqudtetm6reckhg120m, task: 2. PeerState, peerState:(freeSpace:67108864;inFlightBytes:0;inFlightCount:0;), sentSeqNo: 5, ackSeqNo: 5
2025-11-01T13:37:10.777393Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:220: TxId: ptqudtetm6reckhg120m, task: 2. Resume compute actor
2025-11-01T13:37:10.777427Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1486: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. Poll inputs
2025-11-01T13:37:10.777437Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1501: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. Poll sources
2025-11-01T13:37:10.777448Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-11-01T13:37:10.786899Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1162: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. CPU quota delay: 17ms
2025-11-01T13:37:10.787210Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. update task runner stats
2025-11-01T13:37:10.787321Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-01T13:37:10.787334Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-01T13:37:10.787360Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:532: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. About to drain channelId: 2, hasPeer: 1, peerState:(freeSpace:67108864;inFlightBytes:0;inFlightCount:0;)
2025-11-01T13:37:10.787456Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudtetm6reckhg120m, task: 2. no poll, channelId: 1, has inflight messages: [5], last with freeSpace: 1000000, current freeSpace: 1000000
2025-11-01T13:37:10.797510Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:390: [ptqudtetm6reckhg120m-0] [1:5] TEvSaveTaskState Apply: task: 2
2025-11-01T13:37:10.797567Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:405: [ptqudtetm6reckhg120m-0] [1:5] Send TEvSaveTaskStateResult: task: 2
2025-11-01T13:37:11.287195Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:617: RowDispatcher: Send ping to [1:7567750464762687077:2125]
2025-11-01T13:37:11.287371Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1161: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-11-01T13:37:11.292590Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:623: RowDispatcher: NActors::TEvents::TEvPong
2025-11-01T13:37:11.296142Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: ef5c71cf-e0ddc7a5-5710ed89-b937216d19, Host: ghrun-ebytu4uhfq, Tenant: /default
2025-11-01T13:37:11.326602Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-01T13:37:11.326621Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-01T13:37:11.336767Z :FQ_CONTROL_PLANE_CONFIG TRACE: control_plane_config.cpp:192: LOADED TenantInfo: State NOT changed
2025-11-01T13:37:11.530508Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ef5c71cf-e0ddc7a5-5710ed89-b937216d 2025-11-01 13:37:11.530 DEBUG ydbd(pid=1314950, tid=0x00007B2F59487640) [DQ] local_worker_manager.cpp:416: TEvFreeWorkersNotify 562954248388609
2025-11-01T13:37:11.530727Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ef5c71cf-e0ddc7a5-5710ed89-b937216d 2025-11-01 13:37:11.530 DEBUG ydbd(pid=1314950, tid=0x00007B2F59487640) [DQ] local_worker_manager.cpp:440: Free Group 562954248388609
2025-11-01T13:37:11.531238Z :KQP_COMPUTE ERROR: dq_compute_actor_impl.h:1210: SelfId: [3:7567750523392636675:2158], TxId: ptqudtetm6reckhg120m, task: 2. Ctx: {}. Handle abort execution event from: [3:7567750471853028972:2068], status: UNAVAILABLE, reason: { <main>: Error: Aborted by LWM }
2025-11-01T13:37:11.531410Z :KQP_COMPUTE DEBUG: dq_compute_actor_channels.cpp:494: TxId: ptqudtetm6reckhg120m, task: 2. pass away
2025-11-01T13:37:12.296336Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: ef5c71cf-e0ddc7a5-5710ed89-b937216d20, Host: ghrun-ebytu4uhfq, Tenant: /default
2025-11-01T13:37:12.329628Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-01T13:37:12.329652Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-01T13:37:13.287297Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:617: RowDispatcher: Send ping to [1:7567750464762687077:2125]
2025-11-01T13:37:13.287515Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1161: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-11-01T13:37:13.288459Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:623: RowDispatcher: NActors::TEvents::TEvPong
2025-11-01T13:37:13.297589Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: ef5c71cf-e0ddc7a5-5710ed89-b937216d21, Host: ghrun-ebytu4uhfq, Tenant: /default
2025-11-01T13:37:13.309292Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-11-01T13:37:13.332539Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-01T13:37:13.332567Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-01T13:37:13.428007Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:389: Send NodeInfo with size: 3 to DynamicNameserver
2025-11-01T13:37:14.297745Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: ef5c71cf-e0ddc7a5-5710ed89-b937216d22, Host: ghrun-ebytu4uhfq, Tenant: /default
2025-11-01T13:37:14.335184Z :FQ_CONTROL_PLANE_CONFIG TRACE: control_plane_config.cpp:192: LOADED TenantInfo: State NOT changed
2025-11-01T13:37:14.338723Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-01T13:37:14.338751Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-01T13:37:15.197072Z :INTERCONNECT_NETWORK NOTICE: interconnect_tcp_input_session.cpp:712: [3 <-> 1] connection closed by peer
2025-11-01T13:37:15.198218Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ef5c71cf-e0ddc7a5-5710ed89-b937216d 2025-11-01 13:37:15.197 DEBUG ydbd(pid=1314950, tid=0x00007B2F59487640) [DQ] local_worker_manager.cpp:257: Disconnected 1
2025-11-01T13:37:15.198593Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ef5c71cf-e0ddc7a5-5710ed89-b937216d 2025-11-01 13:37:15.198 DEBUG ydbd(pid=1314950, tid=0x00007B2F59487640) [DQ] local_worker_manager.cpp:228: Deallocate 1
2025-11-01T13:37:15.228947Z :INTERCONNECT_NETWORK NOTICE: interconnect_tcp_input_session.cpp:712: [3 <-> 2] connection closed by peer
2025-11-01T13:37:15.233130Z :INTERCONNECT_NETWORK NOTICE: interconnect_tcp_input_session.cpp:712: [3 <-> 4] connection closed by peer
2025-11-01T13:37:15.287497Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:617: RowDispatcher: Send ping to [1:7567750464762687077:2125]
2025-11-01T13:37:15.287685Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1161: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-11-01T13:37:15.298149Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: ef5c71cf-e0ddc7a5-5710ed89-b937216d23, Host: ghrun-ebytu4uhfq, Tenant: /default
2025-11-01T13:37:15.329424Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-01T13:37:15.329447Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
