2025-11-01T17:56:11.867147Z :GRPC_SERVER NOTICE: grpc_request_proxy_simple.cpp:161: Grpc simple request proxy started, nodeid# 3
2025-11-01T17:56:11.867405Z :GRPC_SERVER NOTICE: grpc_request_proxy_simple.cpp:161: Grpc simple request proxy started, nodeid# 3
2025-11-01T17:56:11.868495Z :FQ_LOG_UPDATER DEBUG: log.cpp:93: Updated YQL logs priority: 8
2025-11-01T17:56:11.868522Z :YQ_CONTROL_PLANE_STORAGE INFO: ydb_control_plane_storage.cpp:50: Starting ydb control plane storage service. Actor id: [3:7567817294263715006:2060]
2025-11-01T17:56:11.868612Z :FQ_LOG_UPDATER CRIT: log.cpp:55: Failed to deliver subscription request to config dispatcher.
2025-11-01T17:56:11.868646Z :FQ_CONTROL_PLANE_CONFIG DEBUG: control_plane_config.cpp:58: STARTING: [3:7567817294263715007:2061]
2025-11-01T17:56:11.869467Z :YQ_CONTROL_PLANE_PROXY DEBUG: control_plane_proxy.cpp:532: Starting yandex query control plane proxy. Actor id: [3:7567817294263715008:2062]
2025-11-01T17:56:11.873772Z :YQ_RATE_LIMITER INFO: quoter_service.cpp:124: Bootstraping with config: { Enabled: true ControlPlaneEnabled: true DataPlaneEnabled: true Database { Endpoint: "localhost:9219" Database: "local" TablePrefix: "RateLimiter_2b63e3b3-6058-422f-800b-b93bdd634d88" } Limiters { CoordinationNodePath: "rate_limiter" } }
2025-11-01T17:56:11.874698Z :MEMORY_PROFILER NOTICE: monitor.cpp:332: Bootstrapped
2025-11-01T17:56:11.885890Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:145: Bootstrap
2025-11-01T17:56:11.886193Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:165: Initialize
2025-11-01T17:56:11.911010Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:534: RowDispatcher: Successfully bootstrapped row dispatcher, id [3:7567817294263715013:2067], tenant /default
2025-11-01T17:56:11.911179Z :YQL_NODES_MANAGER INFO: nodes_manager.cpp:88: Bootstrap, InstanceId: ca20daa2-4c8b516b-7e71c7ae-ed2f8e87
2025-11-01T17:56:11.911197Z :YQL_NODES_MANAGER DEBUG: nodes_manager.cpp:310: TNodesManagerActor::ResolveSelfAddress
2025-11-01T17:56:11.911268Z :YQ_TEST_CONNECTION DEBUG: test_connection.cpp:142: Starting yandex query test connection. Actor id: [3:7567817294263715018:2072]
2025-11-01T17:56:11.912182Z :FQ_QUOTA_SERVICE INFO: quota_manager.cpp:196: STARTED
2025-11-01T17:56:11.912210Z :FQ_QUOTA_PROXY INFO: quota_proxy.cpp:90: STARTED
2025-11-01T17:56:11.912372Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 225bc33a-18de9753-c230e7ba-8148c6911, Host: ghrun-ku4naohwou, Tenant: /default
2025-11-01T17:56:11.912471Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create directory "local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88" actor
2025-11-01T17:56:11.912471Z :YQ_RATE_LIMITER DEBUG: schema.cpp:71: Run create coordination node "local/RateLimiter_2b63e3b3-6058-422f-800b-b93bdd634d88/rate_limiter" actor
2025-11-01T17:56:11.912493Z :YQ_RATE_LIMITER DEBUG: schema.cpp:113: Call create coordination node "local/RateLimiter_2b63e3b3-6058-422f-800b-b93bdd634d88/rate_limiter"
2025-11-01T17:56:11.912495Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create directory "local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88"
2025-11-01T17:56:11.912515Z :YQ_RATE_LIMITER DEBUG: schema.cpp:411: Call create coordination node "local/RateLimiter_2b63e3b3-6058-422f-800b-b93bdd634d88/rate_limiter"
2025-11-01T17:56:11.912518Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:383: Call create directory "local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88"
2025-11-01T17:56:11.912663Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/queries" actor
2025-11-01T17:56:11.912733Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/pending_small" actor
2025-11-01T17:56:11.912963Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/connections" actor
2025-11-01T17:56:11.913037Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/bindings" actor
2025-11-01T17:56:11.913269Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/idempotency_keys" actor
2025-11-01T17:56:11.913397Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/result_sets" actor
2025-11-01T17:56:11.913522Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/jobs" actor
2025-11-01T17:56:11.914012Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/nodes" actor
2025-11-01T17:56:11.914150Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/quotas" actor
2025-11-01T17:56:11.914159Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/tenants" actor
2025-11-01T17:56:11.914279Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/tenant_acks" actor
2025-11-01T17:56:11.914299Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/mappings" actor
2025-11-01T17:56:11.914371Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/compute_databases" actor
2025-11-01T17:56:11.914635Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:267: Coordinator: Successfully bootstrapped coordinator, id [3:7567817294263715113:2138], NodesManagerId [0:4705493345362661702:78]
2025-11-01T17:56:11.915239Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:231: TLeaderElection [3:7567817294263715114:2139] Successfully bootstrapped, local coordinator id [3:7567817294263715113:2138], tenant id default, local mode 0, coordination node path local/row_dispatcher/default
2025-11-01T17:56:11.922652Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:627: RowDispatcher: TEvCoordinatorChangesSubscribe from [3:7567817294263715113:2138]
2025-11-01T17:56:11.922765Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:71: Run create coordination node "local/row_dispatcher/default" actor
2025-11-01T17:56:11.922778Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-11-01T17:56:11.922781Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:113: Call create coordination node "local/row_dispatcher/default"
2025-11-01T17:56:11.922796Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:411: Call create coordination node "local/row_dispatcher/default"
2025-11-01T17:56:11.949557Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:155: Successfully created coordination node "local/row_dispatcher/default"
2025-11-01T17:56:11.949686Z :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: 13], type: EPathTypeKesus, state: EPathStateNoChanges) }
2025-11-01T17:56:11.949765Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:344: TLeaderElection [3:7567817294263715114:2139] Coordination node successfully created
2025-11-01T17:56:11.949811Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:322: TLeaderElection [3:7567817294263715114:2139] Start session
2025-11-01T17:56:11.968108Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:358: TLeaderElection [3:7567817294263715114:2139] Session successfully created
2025-11-01T17:56:11.972277Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:371: TLeaderElection [3:7567817294263715114:2139] Semaphore successfully created
2025-11-01T17:56:11.972329Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:303: TLeaderElection [3:7567817294263715114:2139] Try to acquire semaphore
2025-11-01T17:56:11.972641Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:419: TLeaderElection [3:7567817294263715114:2139] Describe semaphore
2025-11-01T17:56:11.978893Z :YQ_RATE_LIMITER DEBUG: schema.cpp:155: Successfully created coordination node "local/RateLimiter_2b63e3b3-6058-422f-800b-b93bdd634d88/rate_limiter"
2025-11-01T17:56:11.978946Z :YQ_RATE_LIMITER DEBUG: schema.cpp:122: Reply for create coordination node "local/RateLimiter_2b63e3b3-6058-422f-800b-b93bdd634d88/rate_limiter": { <main>: Error: Check failed: path: '/local/RateLimiter_2b63e3b3-6058-422f-800b-b93bdd634d88/rate_limiter', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 77], type: EPathTypeKesus, state: EPathStateNoChanges) }
2025-11-01T17:56:11.978957Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created directory "local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88"
2025-11-01T17:56:11.979020Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create directory "local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88": { <main>: Error: Check failed: path: '/local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 71], type: EPathTypeDir, state: EPathStateNoChanges) }
2025-11-01T17:56:11.981699Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:468: TLeaderElection [3:7567817294263715114:2139] Semaphore successfully described: coordinator id [1:7567817290597514392:2124] generation 4
2025-11-01T17:56:11.981761Z :FQ_ROW_DISPATCHER INFO: leader_election.cpp:470: TLeaderElection [3:7567817294263715114:2139] Send TEvCoordinatorChanged to [3:7567817294263715013:2067], new coordinator id [1:7567817290597514392:2124], previous coordinator id [0:0:0]
2025-11-01T17:56:11.981854Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:559: RowDispatcher: Coordinator changed, old leader (empty maybe), new [1:7567817290597514392:2124] generation 4
2025-11-01T17:56:11.981948Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:386: Coordinator: New leader [1:7567817290597514392:2124], SelfId [3:7567817294263715113:2138]
2025-11-01T17:56:11.982271Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:597: RowDispatcher: TEvUndelivered, from [1:7567817290597514392:2124], reason Disconnected
2025-11-01T17:56:11.998844Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/queries". Create session OK
2025-11-01T17:56:11.998920Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/queries"
2025-11-01T17:56:11.998957Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/queries"
2025-11-01T17:56:11.999283Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/connections". Create session OK
2025-11-01T17:56:11.999306Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/connections"
2025-11-01T17:56:11.999325Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/connections"
2025-11-01T17:56:12.003000Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/pending_small". Create session OK
2025-11-01T17:56:12.003030Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/pending_small"
2025-11-01T17:56:12.003039Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/pending_small"
2025-11-01T17:56:12.003299Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/bindings". Create session OK
2025-11-01T17:56:12.003322Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/bindings"
2025-11-01T17:56:12.003331Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/bindings"
2025-11-01T17:56:12.005447Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/result_sets". Create session OK
2025-11-01T17:56:12.005471Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/result_sets"
2025-11-01T17:56:12.005506Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/result_sets"
2025-11-01T17:56:12.005802Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/idempotency_keys". Create session OK
2025-11-01T17:56:12.005834Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/idempotency_keys"
2025-11-01T17:56:12.005848Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/idempotency_keys"
2025-11-01T17:56:12.007420Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/jobs". Create session OK
2025-11-01T17:56:12.007447Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/jobs"
2025-11-01T17:56:12.007458Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/jobs"
2025-11-01T17:56:12.008525Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/nodes". Create session OK
2025-11-01T17:56:12.008560Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/nodes"
2025-11-01T17:56:12.008583Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/nodes"
2025-11-01T17:56:12.009463Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/quotas". Create session OK
2025-11-01T17:56:12.009485Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/quotas"
2025-11-01T17:56:12.009490Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/quotas"
2025-11-01T17:56:12.013340Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/tenants". Create session OK
2025-11-01T17:56:12.013373Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/tenants"
2025-11-01T17:56:12.013386Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/tenants"
2025-11-01T17:56:12.014283Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/tenant_acks". Create session OK
2025-11-01T17:56:12.014327Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/tenant_acks"
2025-11-01T17:56:12.014336Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/tenant_acks"
2025-11-01T17:56:12.015936Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/mappings". Create session OK
2025-11-01T17:56:12.015966Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/mappings"
2025-11-01T17:56:12.015973Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/mappings"
2025-11-01T17:56:12.016814Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/compute_databases". Create session OK
2025-11-01T17:56:12.016860Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/compute_databases"
2025-11-01T17:56:12.016869Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/compute_databases"
2025-11-01T17:56:12.018199Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-01T17:56:12.018229Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-01T17:56:12.023137Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:389: Send NodeInfo with size: 2 to DynamicNameserver
2025-11-01T17:56:12.025514Z :FQ_CONTROL_PLANE_CONFIG DEBUG: control_plane_config.cpp:190: LOADED TenantInfo: State CHANGED at 2025-11-01T17:56:06.309051Z
2025-11-01T17:56:12.028821Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/queries"
2025-11-01T17:56:12.028871Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/queries": { <main>: Error: Check failed: path: '/local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/queries', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 78], type: EPathTypeTable, state: EPathStateNoChanges) }
2025-11-01T17:56:12.032194Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/connections"
2025-11-01T17:56:12.032358Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/connections": { <main>: Error: Check failed: path: '/local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/connections', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 80], type: EPathTypeTable, state: EPathStateNoChanges) }
2025-11-01T17:56:12.032733Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/bindings"
2025-11-01T17:56:12.032797Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/bindings": { <main>: Error: Check failed: path: '/local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/bindings', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 81], type: EPathTypeTable, state: EPathStateNoChanges) }
2025-11-01T17:56:12.034806Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/pending_small"
2025-11-01T17:56:12.034854Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/pending_small": { <main>: Error: Check failed: path: '/local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/pending_small', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 79], type: EPathTypeTable, state: EPathStateNoChanges) }
2025-11-01T17:56:12.037327Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/result_sets"
2025-11-01T17:56:12.037378Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/result_sets": { <main>: Error: Check failed: path: '/local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/result_sets', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 84], type: EPathTypeTable, state: EPathStateNoChanges) }
2025-11-01T17:56:12.037665Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/idempotency_keys"
2025-11-01T17:56:12.037739Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/idempotency_keys": { <main>: Error: Check failed: path: '/local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/idempotency_keys', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 83], type: EPathTypeTable, state: EPathStateNoChanges) }
2025-11-01T17:56:12.043184Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/jobs"
2025-11-01T17:56:12.043239Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/jobs": { <main>: Error: Check failed: path: '/local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/jobs', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 82], type: EPathTypeTable, state: EPathStateNoChanges) }
2025-11-01T17:56:12.043469Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/quotas"
2025-11-01T17:56:12.043508Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/quotas": { <main>: Error: Check failed: path: '/local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/quotas', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 85], type: EPathTypeTable, state: EPathStateNoChanges) }
2025-11-01T17:56:12.045353Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/nodes"
2025-11-01T17:56:12.045393Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/nodes": { <main>: Error: Check failed: path: '/local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/nodes', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 87], type: EPathTypeTable, state: EPathStateNoChanges) }
2025-11-01T17:56:12.045420Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/mappings"
2025-11-01T17:56:12.045476Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/mappings": { <main>: Error: Check failed: path: '/local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/mappings', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 73], type: EPathTypeTable, state: EPathStateNoChanges) }
2025-11-01T17:56:12.047321Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/tenant_acks"
2025-11-01T17:56:12.047359Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/tenant_acks": { <main>: Error: Check failed: path: '/local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/tenant_acks', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 86], type: EPathTypeTable, state: EPathStateNoChanges) }
2025-11-01T17:56:12.047438Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/compute_databases"
2025-11-01T17:56:12.047468Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/compute_databases": { <main>: Error: Check failed: path: '/local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/compute_databases', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 88], type: EPathTypeTable, state: EPathStateNoChanges) }
2025-11-01T17:56:12.049195Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/tenants"
2025-11-01T17:56:12.049366Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/tenants": { <main>: Error: Check failed: path: '/local/DbPoolStorage_2b63e3b3-6058-422f-800b-b93bdd634d88/tenants', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 72], type: EPathTypeTable, state: EPathStateNoChanges) }
2025-11-01T17:56:12.103210Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:158: Successfully bootstrapped TStorageProxy [3:7567817294263715012:2066] with connection to localhost:9219:local
2025-11-01T17:56:12.912460Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 225bc33a-18de9753-c230e7ba-8148c6912, Host: ghrun-ku4naohwou, Tenant: /default
2025-11-01T17:56:12.914478Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:542: Coordinator: Send TEvGetNodesRequest to NodesManager
2025-11-01T17:56:12.914579Z :YQL_NODES_MANAGER DEBUG: nodes_manager.cpp:300: TNodesManagerActor::TEvGetNodesRequest
2025-11-01T17:56:12.914648Z :FQ_ROW_DISPATCHER INFO: coordinator.cpp:573: Coordinator: Updated node info, node count: 3
2025-11-01T17:56:12.922738Z :FQ_QUOTA_SERVICE DEBUG: quota_manager.cpp:230: IC Peers[2]: [1, 2]
2025-11-01T17:56:12.939900Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-01T17:56:12.939927Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-01T17:56:13.911375Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:617: RowDispatcher: Send ping to [1:7567817290597514392:2124]
2025-11-01T17:56:13.911445Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1161: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-11-01T17:56:13.912679Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 225bc33a-18de9753-c230e7ba-8148c6913, Host: ghrun-ku4naohwou, Tenant: /default
2025-11-01T17:56:13.940216Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-01T17:56:13.940271Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-01T17:56:14.912805Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 225bc33a-18de9753-c230e7ba-8148c6914, Host: ghrun-ku4naohwou, Tenant: /default
2025-11-01T17:56:14.930482Z :FQ_CONTROL_PLANE_CONFIG TRACE: control_plane_config.cpp:192: LOADED TenantInfo: State NOT changed
2025-11-01T17:56:14.938723Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-01T17:56:14.938745Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-01T17:56:15.911428Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:617: RowDispatcher: Send ping to [1:7567817290597514392:2124]
2025-11-01T17:56:15.911493Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1161: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-11-01T17:56:15.913037Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 225bc33a-18de9753-c230e7ba-8148c6915, Host: ghrun-ku4naohwou, Tenant: /default
2025-11-01T17:56:15.920026Z :INTERCONNECT WARN: interconnect_handshake.cpp:501: Handshake [3:7567817311443584324:2056] [node 1] ICH09 Neither CompatibilityInfo nor VersionTag of the peer can be validated, accepting by default
2025-11-01T17:56:15.922894Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:623: RowDispatcher: NActors::TEvents::TEvPong
2025-11-01T17:56:15.942895Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-01T17:56:15.942941Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-01T17:56:16.913248Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 225bc33a-18de9753-c230e7ba-8148c6916, Host: ghrun-ku4naohwou, Tenant: /default
2025-11-01T17:56:16.922932Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-11-01T17:56:16.970461Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-01T17:56:16.970495Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-01T17:56:16.972105Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:389: Send NodeInfo with size: 3 to DynamicNameserver
2025-11-01T17:56:17.272121Z :INTERCONNECT WARN: interconnect_handshake.cpp:501: Handshake [3:7567817320033518925:2058] [node 4] ICH09 Neither CompatibilityInfo nor VersionTag of the peer can be validated, accepting by default
2025-11-01T17:56:17.911609Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:617: RowDispatcher: Send ping to [1:7567817290597514392:2124]
2025-11-01T17:56:17.911657Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1161: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-11-01T17:56:17.912271Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:623: RowDispatcher: NActors::TEvents::TEvPong
2025-11-01T17:56:17.913367Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 225bc33a-18de9753-c230e7ba-8148c6917, Host: ghrun-ku4naohwou, Tenant: /default
2025-11-01T17:56:17.922957Z :FQ_QUOTA_SERVICE DEBUG: quota_manager.cpp:230: IC Peers[3]: [1, 2, 4]
2025-11-01T17:56:17.932130Z :FQ_CONTROL_PLANE_CONFIG TRACE: control_plane_config.cpp:192: LOADED TenantInfo: State NOT changed
2025-11-01T17:56:17.938024Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-01T17:56:17.938046Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-01T17:56:18.419136Z :INTERCONNECT WARN: interconnect_handshake.cpp:501: Handshake [3:7567817324328486230:2060] [node 2] ICH09 Neither CompatibilityInfo nor VersionTag of the peer can be validated, accepting by default
2025-11-01T17:56:18.913566Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 225bc33a-18de9753-c230e7ba-8148c6918, Host: ghrun-ku4naohwou, Tenant: /default
2025-11-01T17:56:19.400809Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-01T17:56:19.400844Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-01T17:56:19.911715Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:617: RowDispatcher: Send ping to [1:7567817290597514392:2124]
2025-11-01T17:56:19.911782Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1161: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-11-01T17:56:19.912495Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:623: RowDispatcher: NActors::TEvents::TEvPong
2025-11-01T17:56:19.913780Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 225bc33a-18de9753-c230e7ba-8148c6919, Host: ghrun-ku4naohwou, Tenant: /default
2025-11-01T17:56:19.938718Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-01T17:56:19.938744Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-01T17:56:20.913993Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 225bc33a-18de9753-c230e7ba-8148c69110, Host: ghrun-ku4naohwou, Tenant: /default
2025-11-01T17:56:20.936629Z :FQ_CONTROL_PLANE_CONFIG TRACE: control_plane_config.cpp:192: LOADED TenantInfo: State NOT changed
2025-11-01T17:56:20.944532Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-01T17:56:20.944560Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-01T17:56:21.567148Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: 225bc33a-18de9753-c230e7ba-8148c691 2025-11-01 17:56:21.566 DEBUG ydbd(pid=1252503, tid=0x00007B971ADCE640) [DQ] local_worker_manager.cpp:316: {ptqudtef6hgbqqqtjl81} TLocalWorkerManager::TEvAllocateWorkersRequest 562954248388609
2025-11-01T17:56:21.567378Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: 225bc33a-18de9753-c230e7ba-8148c691 2025-11-01 17:56:21.567 DEBUG ydbd(pid=1252503, tid=0x00007B971ADCE640) [DQ] local_worker_manager.cpp:376: {ptqudtef6hgbqqqtjl81} Create compute actor: async
2025-11-01T17:56:21.692415Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:134: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. Start compute actor [3:7567817337213388125:2157], task: 2
2025-11-01T17:56:21.692622Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:113: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. Use CPU quota: 1. Rate limiter resource: { "local/RateLimiter_2b63e3b3-6058-422f-800b-b93bdd634d88/rate_limiter", "mock_cloud/my_folder/ptqudtef6hgbqqqtjl81" }
2025-11-01T17:56:21.911853Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:617: RowDispatcher: Send ping to [1:7567817290597514392:2124]
2025-11-01T17:56:21.911895Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1161: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-11-01T17:56:21.912662Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:623: RowDispatcher: NActors::TEvents::TEvPong
2025-11-01T17:56:21.914152Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 225bc33a-18de9753-c230e7ba-8148c69111, Host: ghrun-ku4naohwou, Tenant: /default
2025-11-01T17:56:21.923137Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-11-01T17:56:21.925721Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:197: [] Task: 2. Got TEvNewCheckpointCoordinator event: generation 1, actorId: [1:7567817337842154935:2377]
2025-11-01T17:56:21.925740Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:208: [] Task: 2. Assign checkpoint coordinator (generation = 1)
2025-11-01T17:56:21.926024Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:395: [ptqudtef6hgbqqqtjl81-0] Task: 2. Handle connected node 1
2025-11-01T17:56:21.944659Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-01T17:56:21.944683Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-01T17:56:21.973241Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:389: Send NodeInfo with size: 3 to DynamicNameserver
2025-11-01T17:56:22.058036Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1074: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. Received channels info: Update { Id: 1 TransportVersion: DATA_TRANSPORT_UV_PICKLE_1_0 SrcTaskId: 1 DstTaskId: 2 SrcEndpoint { ActorId { RawX1: 7567817337842154938 RawX2: 4503603922340172 } } DstEndpoint { ActorId { RawX1: 7567817337213388125 RawX2: 4503612512274541 } } SrcStageId: 200322 DstStageId: 200339 } Update { Id: 2 TransportVersion: DATA_TRANSPORT_UV_PICKLE_1_0 SrcTaskId: 2 SrcEndpoint { ActorId { RawX1: 7567817337213388125 RawX2: 4503612512274541 } } DstEndpoint { ActorId { RawX1: 7567817337842154934 RawX2: 4503603922340168 } } }
2025-11-01T17:56:22.058075Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1081: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. Update input channelId: 1, peer: [1:7567817337842154938:2380]
2025-11-01T17:56:22.058105Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1093: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. Update output channelId: 2, peer: [1:7567817337842154934:2376]
2025-11-01T17:56:22.783103Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1169: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. Got TEvRun from actor [1:7567817337842154935:2377]
2025-11-01T17:56:22.783199Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1486: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. Poll inputs
2025-11-01T17:56:22.783216Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1501: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. Poll sources
2025-11-01T17:56:22.783229Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-11-01T17:56:22.783427Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: 225bc33a-18de9753-c230e7ba-8148c691 2025-11-01 17:56:22.783 DEBUG ydbd(pid=1252503, tid=0x00007B971ADCE640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Run task: 2
2025-11-01T17:56:22.783602Z :KQP_COMPUTE TRACE: dq_compute_memory_quota.h:97: TxId: ptqudtef6hgbqqqtjl81, task: 2. Peak memory usage: 2031616
2025-11-01T17:56:22.783649Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. update task runner stats
2025-11-01T17:56:22.783747Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-01T17:56:22.783763Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-01T17:56:22.783791Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:532: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. About to drain channelId: 2, hasPeer: 1, peerState:(freeSpace:1000000;inFlightBytes:0;inFlightCount:0;)
2025-11-01T17:56:22.783810Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1105: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. Ask CPU quota: 60ms
2025-11-01T17:56:22.783921Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:605: TxId: ptqudtef6hgbqqqtjl81, task: 2. no poll, channelId: 1, hasPeer: 1, finished: 0, retry: 0, lastSeqNo: 0, freeSpace: 1000000
2025-11-01T17:56:22.784245Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:129: TxId: ptqudtef6hgbqqqtjl81, task: 2. Received input for channelId: 1, seqNo: 1, size: 0, chunks: 0, watermark: 0, checkpoint: 1, finished: 0, from: [1:7567817337842154939:2380], expected seqNo: 1
2025-11-01T17:56:22.784266Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:609: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. took input
2025-11-01T17:56:22.784367Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:485: [ptqudtef6hgbqqqtjl81-0] Task: 2. [Checkpoint 1.1] Got checkpoint barrier from channel 1
2025-11-01T17:56:22.784426Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:395: SelfId: [3:7567817337213388127:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. No watermark 
2025-11-01T17:56:22.784449Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1486: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. Poll inputs
2025-11-01T17:56:22.784459Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1497: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-11-01T17:56:22.784485Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. DoExecuteImpl: 1
2025-11-01T17:56:22.784520Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:965: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. Input data push finished. Cookie: 0 Watermark: (empty maybe) Ack: 1 TakeInputChannelDataRequests: 1
2025-11-01T17:56:22.784551Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:738: TxId: ptqudtef6hgbqqqtjl81, task: 2. Sending channel data ack to channelId: 1, peer: [1:7567817337842154938:2380], from: [3:7567817337213388125:2157], freeSpace: 1000000, seqNo: 1, finished: 0
2025-11-01T17:56:22.784596Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1486: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. Poll inputs
2025-11-01T17:56:22.784601Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1497: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-11-01T17:56:22.784608Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-11-01T17:56:22.794362Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1162: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. CPU quota delay: 10ms
2025-11-01T17:56:22.794618Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:510: SelfId: [3:7567817337213388127:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Pending 1 checkpoints to be sent
2025-11-01T17:56:22.794665Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. update task runner stats
2025-11-01T17:56:22.794787Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 1 watermark injected: (empty maybe)
2025-11-01T17:56:22.794817Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:447: [ptqudtef6hgbqqqtjl81-0] Task: 2. [Checkpoint 1.1] Performing task checkpoint
2025-11-01T17:56:22.794845Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:822: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. Save state
2025-11-01T17:56:22.794872Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:474: [ptqudtef6hgbqqqtjl81-0] Task: 2. [Checkpoint 1.1] CA state saved
2025-11-01T17:56:22.794883Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:449: [ptqudtef6hgbqqqtjl81-0] Task: 2. [Checkpoint 1.1] Injecting checkpoint barrier to outputs
2025-11-01T17:56:22.794916Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:536: [ptqudtef6hgbqqqtjl81-0] Task: 2. [Checkpoint 1.1] Task checkpoint is done. Send to storage
2025-11-01T17:56:22.794925Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-01T17:56:22.794945Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:532: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. About to drain channelId: 2, hasPeer: 1, peerState:(freeSpace:1000000;inFlightBytes:0;inFlightCount:0;)
2025-11-01T17:56:22.794968Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:366: [ptqudtef6hgbqqqtjl81-0] [1:1] Got TEvSaveTaskState: task 2
2025-11-01T17:56:22.795001Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:566: TxId: ptqudtef6hgbqqqtjl81, task: 2. SendChannelData, channelId: 2, peer: [1:7567817337842154934:2376], chunks: 0, bytes: 0, watermark: 0, checkpoint: 1, seqNo: 1, finished: 0
2025-11-01T17:56:22.795079Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudtef6hgbqqqtjl81, task: 2. no poll, channelId: 1, has inflight messages: [1], last with freeSpace: 1000000, current freeSpace: 1000000
2025-11-01T17:56:22.795108Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1486: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. Poll inputs
2025-11-01T17:56:22.795117Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1501: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. Poll sources
2025-11-01T17:56:22.795125Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-11-01T17:56:22.795341Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. update task runner stats
2025-11-01T17:56:22.795398Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-01T17:56:22.795406Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-01T17:56:22.795427Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:532: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. About to drain channelId: 2, hasPeer: 1, peerState:(freeSpace:1000000;inFlightBytes:96;inFlightCount:1;)
2025-11-01T17:56:22.795466Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudtef6hgbqqqtjl81, task: 2. no poll, channelId: 1, has inflight messages: [1], last with freeSpace: 1000000, current freeSpace: 1000000
2025-11-01T17:56:22.796005Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:179: TxId: ptqudtef6hgbqqqtjl81, task: 2. Received channel data ack for channelId: 2, seqNo: 1, lastSentSeqNo: 1, freeSpace: 67108864, early finish: 0
2025-11-01T17:56:22.796056Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:207: TxId: ptqudtef6hgbqqqtjl81, task: 2. PeerState, peerState:(freeSpace:67108864;inFlightBytes:0;inFlightCount:0;), sentSeqNo: 1, ackSeqNo: 1
2025-11-01T17:56:22.796078Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:220: TxId: ptqudtef6hgbqqqtjl81, task: 2. Resume compute actor
2025-11-01T17:56:22.796106Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1486: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. Poll inputs
2025-11-01T17:56:22.796113Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1501: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. Poll sources
2025-11-01T17:56:22.796121Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-11-01T17:56:22.796262Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: 225bc33a-18de9753-c230e7ba-8148c691 2025-11-01 17:56:22.796 DEBUG ydbd(pid=1252503, tid=0x00007B971ADCE640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Run task: 2
2025-11-01T17:56:22.796321Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. update task runner stats
2025-11-01T17:56:22.796400Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-01T17:56:22.796411Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-01T17:56:22.796428Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:532: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. About to drain channelId: 2, hasPeer: 1, peerState:(freeSpace:67108864;inFlightBytes:0;inFlightCount:0;)
2025-11-01T17:56:22.796477Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudtef6hgbqqqtjl81, task: 2. no poll, channelId: 1, has inflight messages: [1], last with freeSpace: 1000000, current freeSpace: 1000000
2025-11-01T17:56:22.914354Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 225bc33a-18de9753-c230e7ba-8148c69112, Host: ghrun-ku4naohwou, Tenant: /default
2025-11-01T17:56:22.931230Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:390: [ptqudtef6hgbqqqtjl81-0] [1:1] TEvSaveTaskState Apply: task: 2
2025-11-01T17:56:22.931275Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:405: [ptqudtef6hgbqqqtjl81-0] [1:1] Send TEvSaveTaskStateResult: task: 2
2025-11-01T17:56:22.939833Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-01T17:56:22.939859Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-01T17:56:23.911983Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:617: RowDispatcher: Send ping to [1:7567817290597514392:2124]
2025-11-01T17:56:23.912035Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1161: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-11-01T17:56:23.912716Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:623: RowDispatcher: NActors::TEvents::TEvPong
2025-11-01T17:56:23.914547Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 225bc33a-18de9753-c230e7ba-8148c69113, Host: ghrun-ku4naohwou, Tenant: /default
2025-11-01T17:56:23.930814Z :FQ_CONTROL_PLANE_CONFIG TRACE: control_plane_config.cpp:192: LOADED TenantInfo: State NOT changed
2025-11-01T17:56:23.945965Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-01T17:56:23.945990Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-01T17:56:24.357219Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:129: TxId: ptqudtef6hgbqqqtjl81, task: 2. Received input for channelId: 1, seqNo: 2, size: 0, chunks: 0, watermark: 0, checkpoint: 1, finished: 0, from: [1:7567817337842154939:2380], expected seqNo: 2
2025-11-01T17:56:24.357253Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:609: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. took input
2025-11-01T17:56:24.357296Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:485: [ptqudtef6hgbqqqtjl81-0] Task: 2. [Checkpoint 1.2] Got checkpoint barrier from channel 1
2025-11-01T17:56:24.357362Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:395: SelfId: [3:7567817337213388127:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. No watermark 
2025-11-01T17:56:24.357378Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1486: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. Poll inputs
2025-11-01T17:56:24.357386Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1497: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-11-01T17:56:24.357405Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. DoExecuteImpl: 1
2025-11-01T17:56:24.357429Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:965: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. Input data push finished. Cookie: 1 Watermark: (empty maybe) Ack: 1 TakeInputChannelDataRequests: 1
2025-11-01T17:56:24.357449Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:738: TxId: ptqudtef6hgbqqqtjl81, task: 2. Sending channel data ack to channelId: 1, peer: [1:7567817337842154938:2380], from: [3:7567817337213388125:2157], freeSpace: 1000000, seqNo: 2, finished: 0
2025-11-01T17:56:24.357607Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: 225bc33a-18de9753-c230e7ba-8148c691 2025-11-01 17:56:24.357 DEBUG ydbd(pid=1252503, tid=0x00007B971ADCE640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Run task: 2
2025-11-01T17:56:24.357701Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:510: SelfId: [3:7567817337213388127:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Pending 1 checkpoints to be sent
2025-11-01T17:56:24.357726Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1486: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. Poll inputs
2025-11-01T17:56:24.357731Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1497: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-11-01T17:56:24.357743Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-11-01T17:56:24.357755Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. update task runner stats
2025-11-01T17:56:24.357832Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 1 watermark injected: (empty maybe)
2025-11-01T17:56:24.357846Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:447: [ptqudtef6hgbqqqtjl81-0] Task: 2. [Checkpoint 1.2] Performing task checkpoint
2025-11-01T17:56:24.357853Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:822: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. Save state
2025-11-01T17:56:24.357864Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:474: [ptqudtef6hgbqqqtjl81-0] Task: 2. [Checkpoint 1.2] CA state saved
2025-11-01T17:56:24.357874Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:449: [ptqudtef6hgbqqqtjl81-0] Task: 2. [Checkpoint 1.2] Injecting checkpoint barrier to outputs
2025-11-01T17:56:24.357904Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:536: [ptqudtef6hgbqqqtjl81-0] Task: 2. [Checkpoint 1.2] Task checkpoint is done. Send to storage
2025-11-01T17:56:24.357912Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-01T17:56:24.357930Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:532: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. About to drain channelId: 2, hasPeer: 1, peerState:(freeSpace:67108864;inFlightBytes:0;inFlightCount:0;)
2025-11-01T17:56:24.357957Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:366: [ptqudtef6hgbqqqtjl81-0] [1:2] Got TEvSaveTaskState: task 2
2025-11-01T17:56:24.358100Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: 225bc33a-18de9753-c230e7ba-8148c691 2025-11-01 17:56:24.358 DEBUG ydbd(pid=1252503, tid=0x00007B971ADCE640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Run task: 2
2025-11-01T17:56:24.358169Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:566: TxId: ptqudtef6hgbqqqtjl81, task: 2. SendChannelData, channelId: 2, peer: [1:7567817337842154934:2376], chunks: 0, bytes: 0, watermark: 0, checkpoint: 1, seqNo: 2, finished: 0
2025-11-01T17:56:24.358252Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudtef6hgbqqqtjl81, task: 2. no poll, channelId: 1, has inflight messages: [2], last with freeSpace: 1000000, current freeSpace: 1000000
2025-11-01T17:56:24.358265Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. update task runner stats
2025-11-01T17:56:24.358317Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-01T17:56:24.358325Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-01T17:56:24.358338Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:532: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. About to drain channelId: 2, hasPeer: 1, peerState:(freeSpace:67108864;inFlightBytes:96;inFlightCount:1;)
2025-11-01T17:56:24.358361Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1486: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. Poll inputs
2025-11-01T17:56:24.358368Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1501: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. Poll sources
2025-11-01T17:56:24.358378Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-11-01T17:56:24.358470Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: 225bc33a-18de9753-c230e7ba-8148c691 2025-11-01 17:56:24.358 DEBUG ydbd(pid=1252503, tid=0x00007B971ADCE640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Run task: 2
2025-11-01T17:56:24.358517Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudtef6hgbqqqtjl81, task: 2. no poll, channelId: 1, has inflight messages: [2], last with freeSpace: 1000000, current freeSpace: 1000000
2025-11-01T17:56:24.358523Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. update task runner stats
2025-11-01T17:56:24.358554Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-01T17:56:24.358560Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-01T17:56:24.358578Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:532: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. About to drain channelId: 2, hasPeer: 1, peerState:(freeSpace:67108864;inFlightBytes:96;inFlightCount:1;)
2025-11-01T17:56:24.358602Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudtef6hgbqqqtjl81, task: 2. no poll, channelId: 1, has inflight messages: [2], last with freeSpace: 1000000, current freeSpace: 1000000
2025-11-01T17:56:24.358890Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:179: TxId: ptqudtef6hgbqqqtjl81, task: 2. Received channel data ack for channelId: 2, seqNo: 2, lastSentSeqNo: 2, freeSpace: 67108864, early finish: 0
2025-11-01T17:56:24.358914Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:207: TxId: ptqudtef6hgbqqqtjl81, task: 2. PeerState, peerState:(freeSpace:67108864;inFlightBytes:0;inFlightCount:0;), sentSeqNo: 2, ackSeqNo: 2
2025-11-01T17:56:24.358920Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:220: TxId: ptqudtef6hgbqqqtjl81, task: 2. Resume compute actor
2025-11-01T17:56:24.358951Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1486: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. Poll inputs
2025-11-01T17:56:24.358957Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1501: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. Poll sources
2025-11-01T17:56:24.358963Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-11-01T17:56:24.359090Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: 225bc33a-18de9753-c230e7ba-8148c691 2025-11-01 17:56:24.359 DEBUG ydbd(pid=1252503, tid=0x00007B971ADCE640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Run task: 2
2025-11-01T17:56:24.359164Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. update task runner stats
2025-11-01T17:56:24.359212Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-01T17:56:24.359219Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-01T17:56:24.359234Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:532: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. About to drain channelId: 2, hasPeer: 1, peerState:(freeSpace:67108864;inFlightBytes:0;inFlightCount:0;)
2025-11-01T17:56:24.359295Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudtef6hgbqqqtjl81, task: 2. no poll, channelId: 1, has inflight messages: [2], last with freeSpace: 1000000, current freeSpace: 1000000
2025-11-01T17:56:24.375317Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:390: [ptqudtef6hgbqqqtjl81-0] [1:2] TEvSaveTaskState Apply: task: 2
2025-11-01T17:56:24.375361Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:405: [ptqudtef6hgbqqqtjl81-0] [1:2] Send TEvSaveTaskStateResult: task: 2
2025-11-01T17:56:24.914779Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 225bc33a-18de9753-c230e7ba-8148c69114, Host: ghrun-ku4naohwou, Tenant: /default
2025-11-01T17:56:24.942729Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-01T17:56:24.942752Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-01T17:56:25.060186Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:129: TxId: ptqudtef6hgbqqqtjl81, task: 2. Received input for channelId: 1, seqNo: 3, size: 0, chunks: 0, watermark: 0, checkpoint: 1, finished: 0, from: [1:7567817337842154939:2380], expected seqNo: 3
2025-11-01T17:56:25.060214Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:609: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. took input
2025-11-01T17:56:25.060265Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:485: [ptqudtef6hgbqqqtjl81-0] Task: 2. [Checkpoint 1.3] Got checkpoint barrier from channel 1
2025-11-01T17:56:25.060312Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:395: SelfId: [3:7567817337213388127:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. No watermark 
2025-11-01T17:56:25.060333Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1486: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. Poll inputs
2025-11-01T17:56:25.060341Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1497: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-11-01T17:56:25.060349Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. DoExecuteImpl: 1
2025-11-01T17:56:25.060369Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:965: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. Input data push finished. Cookie: 2 Watermark: (empty maybe) Ack: 1 TakeInputChannelDataRequests: 1
2025-11-01T17:56:25.060387Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:738: TxId: ptqudtef6hgbqqqtjl81, task: 2. Sending channel data ack to channelId: 1, peer: [1:7567817337842154938:2380], from: [3:7567817337213388125:2157], freeSpace: 1000000, seqNo: 3, finished: 0
2025-11-01T17:56:25.060582Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: 225bc33a-18de9753-c230e7ba-8148c691 2025-11-01 17:56:25.060 DEBUG ydbd(pid=1252503, tid=0x00007B971ADCE640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Run task: 2
2025-11-01T17:56:25.060654Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:510: SelfId: [3:7567817337213388127:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Pending 1 checkpoints to be sent
2025-11-01T17:56:25.060681Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1486: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. Poll inputs
2025-11-01T17:56:25.060687Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1497: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-11-01T17:56:25.060692Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-11-01T17:56:25.060703Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. update task runner stats
2025-11-01T17:56:25.060774Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 1 watermark injected: (empty maybe)
2025-11-01T17:56:25.060786Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:447: [ptqudtef6hgbqqqtjl81-0] Task: 2. [Checkpoint 1.3] Performing task checkpoint
2025-11-01T17:56:25.060794Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:822: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. Save state
2025-11-01T17:56:25.060804Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:474: [ptqudtef6hgbqqqtjl81-0] Task: 2. [Checkpoint 1.3] CA state saved
2025-11-01T17:56:25.060812Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:449: [ptqudtef6hgbqqqtjl81-0] Task: 2. [Checkpoint 1.3] Injecting checkpoint barrier to outputs
2025-11-01T17:56:25.060858Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:536: [ptqudtef6hgbqqqtjl81-0] Task: 2. [Checkpoint 1.3] Task checkpoint is done. Send to storage
2025-11-01T17:56:25.060867Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-01T17:56:25.060884Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:532: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. About to drain channelId: 2, hasPeer: 1, peerState:(freeSpace:67108864;inFlightBytes:0;inFlightCount:0;)
2025-11-01T17:56:25.060900Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:366: [ptqudtef6hgbqqqtjl81-0] [1:3] Got TEvSaveTaskState: task 2
2025-11-01T17:56:25.060991Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: 225bc33a-18de9753-c230e7ba-8148c691 2025-11-01 17:56:25.060 DEBUG ydbd(pid=1252503, tid=0x00007B971ADCE640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Run task: 2
2025-11-01T17:56:25.061042Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:566: TxId: ptqudtef6hgbqqqtjl81, task: 2. SendChannelData, channelId: 2, peer: [1:7567817337842154934:2376], chunks: 0, bytes: 0, watermark: 0, checkpoint: 1, seqNo: 3, finished: 0
2025-11-01T17:56:25.061110Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudtef6hgbqqqtjl81, task: 2. no poll, channelId: 1, has inflight messages: [3], last with freeSpace: 1000000, current freeSpace: 1000000
2025-11-01T17:56:25.061143Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. update task runner stats
2025-11-01T17:56:25.061209Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-01T17:56:25.061222Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-01T17:56:25.061235Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:532: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. About to drain channelId: 2, hasPeer: 1, peerState:(freeSpace:67108864;inFlightBytes:96;inFlightCount:1;)
2025-11-01T17:56:25.061256Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1486: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. Poll inputs
2025-11-01T17:56:25.061264Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1501: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. Poll sources
2025-11-01T17:56:25.061269Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-11-01T17:56:25.061372Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: 225bc33a-18de9753-c230e7ba-8148c691 2025-11-01 17:56:25.061 DEBUG ydbd(pid=1252503, tid=0x00007B971ADCE640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Run task: 2
2025-11-01T17:56:25.061417Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudtef6hgbqqqtjl81, task: 2. no poll, channelId: 1, has inflight messages: [3], last with freeSpace: 1000000, current freeSpace: 1000000
2025-11-01T17:56:25.061430Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. update task runner stats
2025-11-01T17:56:25.061486Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-01T17:56:25.061503Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-01T17:56:25.061514Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:532: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. About to drain channelId: 2, hasPeer: 1, peerState:(freeSpace:67108864;inFlightBytes:96;inFlightCount:1;)
2025-11-01T17:56:25.061540Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudtef6hgbqqqtjl81, task: 2. no poll, channelId: 1, has inflight messages: [3], last with freeSpace: 1000000, current freeSpace: 1000000
2025-11-01T17:56:25.061676Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:179: TxId: ptqudtef6hgbqqqtjl81, task: 2. Received channel data ack for channelId: 2, seqNo: 3, lastSentSeqNo: 3, freeSpace: 67108864, early finish: 0
2025-11-01T17:56:25.061699Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:207: TxId: ptqudtef6hgbqqqtjl81, task: 2. PeerState, peerState:(freeSpace:67108864;inFlightBytes:0;inFlightCount:0;), sentSeqNo: 3, ackSeqNo: 3
2025-11-01T17:56:25.061706Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:220: TxId: ptqudtef6hgbqqqtjl81, task: 2. Resume compute actor
2025-11-01T17:56:25.061727Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1486: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. Poll inputs
2025-11-01T17:56:25.061760Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1501: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. Poll sources
2025-11-01T17:56:25.061772Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-11-01T17:56:25.061951Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: 225bc33a-18de9753-c230e7ba-8148c691 2025-11-01 17:56:25.061 DEBUG ydbd(pid=1252503, tid=0x00007B971ADCE640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Run task: 2
2025-11-01T17:56:25.062015Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. update task runner stats
2025-11-01T17:56:25.062067Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-01T17:56:25.062082Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-01T17:56:25.062123Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:532: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. About to drain channelId: 2, hasPeer: 1, peerState:(freeSpace:67108864;inFlightBytes:0;inFlightCount:0;)
2025-11-01T17:56:25.062169Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudtef6hgbqqqtjl81, task: 2. no poll, channelId: 1, has inflight messages: [3], last with freeSpace: 1000000, current freeSpace: 1000000
2025-11-01T17:56:25.076374Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:390: [ptqudtef6hgbqqqtjl81-0] [1:3] TEvSaveTaskState Apply: task: 2
2025-11-01T17:56:25.076400Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:405: [ptqudtef6hgbqqqtjl81-0] [1:3] Send TEvSaveTaskStateResult: task: 2
2025-11-01T17:56:25.390934Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:505: cloud.mock_cloud.yq.cpuPercent.count=0/10000 UPDATE from Peer 1
2025-11-01T17:56:25.624513Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:505: cloud.mock_cloud.yq.streamingQuery.count=1/100 UPDATE from Peer 1
2025-11-01T17:56:25.624555Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:505: cloud.mock_cloud.yq.analyticsQuery.count=0/100 UPDATE from Peer 1
2025-11-01T17:56:25.912192Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:617: RowDispatcher: Send ping to [1:7567817290597514392:2124]
2025-11-01T17:56:25.912260Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1161: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-11-01T17:56:25.914933Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 225bc33a-18de9753-c230e7ba-8148c69115, Host: ghrun-ku4naohwou, Tenant: /default
2025-11-01T17:56:25.918652Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:623: RowDispatcher: NActors::TEvents::TEvPong
2025-11-01T17:56:25.959696Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-01T17:56:25.959709Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-01T17:56:25.984187Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:129: TxId: ptqudtef6hgbqqqtjl81, task: 2. Received input for channelId: 1, seqNo: 4, size: 0, chunks: 0, watermark: 0, checkpoint: 1, finished: 0, from: [1:7567817337842154939:2380], expected seqNo: 4
2025-11-01T17:56:25.984215Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:609: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. took input
2025-11-01T17:56:25.984257Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:485: [ptqudtef6hgbqqqtjl81-0] Task: 2. [Checkpoint 1.4] Got checkpoint barrier from channel 1
2025-11-01T17:56:25.984314Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:395: SelfId: [3:7567817337213388127:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. No watermark 
2025-11-01T17:56:25.984330Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1486: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. Poll inputs
2025-11-01T17:56:25.984338Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1497: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-11-01T17:56:25.984357Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. DoExecuteImpl: 1
2025-11-01T17:56:25.984380Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:965: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. Input data push finished. Cookie: 3 Watermark: (empty maybe) Ack: 1 TakeInputChannelDataRequests: 1
2025-11-01T17:56:25.984398Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:738: TxId: ptqudtef6hgbqqqtjl81, task: 2. Sending channel data ack to channelId: 1, peer: [1:7567817337842154938:2380], from: [3:7567817337213388125:2157], freeSpace: 1000000, seqNo: 4, finished: 0
2025-11-01T17:56:25.984549Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: 225bc33a-18de9753-c230e7ba-8148c691 2025-11-01 17:56:25.984 DEBUG ydbd(pid=1252503, tid=0x00007B971ADCE640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Run task: 2
2025-11-01T17:56:25.984615Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:510: SelfId: [3:7567817337213388127:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Pending 1 checkpoints to be sent
2025-11-01T17:56:25.984639Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1486: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. Poll inputs
2025-11-01T17:56:25.984645Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1497: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-11-01T17:56:25.984656Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-11-01T17:56:25.984668Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. update task runner stats
2025-11-01T17:56:25.984737Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 1 watermark injected: (empty maybe)
2025-11-01T17:56:25.984749Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:447: [ptqudtef6hgbqqqtjl81-0] Task: 2. [Checkpoint 1.4] Performing task checkpoint
2025-11-01T17:56:25.984756Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:822: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. Save state
2025-11-01T17:56:25.984766Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:474: [ptqudtef6hgbqqqtjl81-0] Task: 2. [Checkpoint 1.4] CA state saved
2025-11-01T17:56:25.984775Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:449: [ptqudtef6hgbqqqtjl81-0] Task: 2. [Checkpoint 1.4] Injecting checkpoint barrier to outputs
2025-11-01T17:56:25.984805Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:536: [ptqudtef6hgbqqqtjl81-0] Task: 2. [Checkpoint 1.4] Task checkpoint is done. Send to storage
2025-11-01T17:56:25.984812Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-01T17:56:25.984833Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:532: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. About to drain channelId: 2, hasPeer: 1, peerState:(freeSpace:67108864;inFlightBytes:0;inFlightCount:0;)
2025-11-01T17:56:25.984843Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:366: [ptqudtef6hgbqqqtjl81-0] [1:4] Got TEvSaveTaskState: task 2
2025-11-01T17:56:25.984951Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: 225bc33a-18de9753-c230e7ba-8148c691 2025-11-01 17:56:25.984 DEBUG ydbd(pid=1252503, tid=0x00007B971ADCE640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Run task: 2
2025-11-01T17:56:25.985008Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:566: TxId: ptqudtef6hgbqqqtjl81, task: 2. SendChannelData, channelId: 2, peer: [1:7567817337842154934:2376], chunks: 0, bytes: 0, watermark: 0, checkpoint: 1, seqNo: 4, finished: 0
2025-11-01T17:56:25.985060Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudtef6hgbqqqtjl81, task: 2. no poll, channelId: 1, has inflight messages: [4], last with freeSpace: 1000000, current freeSpace: 1000000
2025-11-01T17:56:25.985093Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. update task runner stats
2025-11-01T17:56:25.985156Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-01T17:56:25.985181Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-01T17:56:25.985197Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:532: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. About to drain channelId: 2, hasPeer: 1, peerState:(freeSpace:67108864;inFlightBytes:96;inFlightCount:1;)
2025-11-01T17:56:25.985213Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1486: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. Poll inputs
2025-11-01T17:56:25.985219Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1501: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. Poll sources
2025-11-01T17:56:25.985225Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-11-01T17:56:25.985374Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: 225bc33a-18de9753-c230e7ba-8148c691 2025-11-01 17:56:25.985 DEBUG ydbd(pid=1252503, tid=0x00007B971ADCE640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Run task: 2
2025-11-01T17:56:25.985444Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudtef6hgbqqqtjl81, task: 2. no poll, channelId: 1, has inflight messages: [4], last with freeSpace: 1000000, current freeSpace: 1000000
2025-11-01T17:56:25.985458Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. update task runner stats
2025-11-01T17:56:25.985502Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-01T17:56:25.985510Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-01T17:56:25.985522Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:532: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. About to drain channelId: 2, hasPeer: 1, peerState:(freeSpace:67108864;inFlightBytes:96;inFlightCount:1;)
2025-11-01T17:56:25.985564Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudtef6hgbqqqtjl81, task: 2. no poll, channelId: 1, has inflight messages: [4], last with freeSpace: 1000000, current freeSpace: 1000000
2025-11-01T17:56:25.986150Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:179: TxId: ptqudtef6hgbqqqtjl81, task: 2. Received channel data ack for channelId: 2, seqNo: 4, lastSentSeqNo: 4, freeSpace: 67108864, early finish: 0
2025-11-01T17:56:25.986179Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:207: TxId: ptqudtef6hgbqqqtjl81, task: 2. PeerState, peerState:(freeSpace:67108864;inFlightBytes:0;inFlightCount:0;), sentSeqNo: 4, ackSeqNo: 4
2025-11-01T17:56:25.986186Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:220: TxId: ptqudtef6hgbqqqtjl81, task: 2. Resume compute actor
2025-11-01T17:56:25.986225Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1486: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. Poll inputs
2025-11-01T17:56:25.986232Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1501: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. Poll sources
2025-11-01T17:56:25.986238Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-11-01T17:56:25.986347Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: 225bc33a-18de9753-c230e7ba-8148c691 2025-11-01 17:56:25.986 DEBUG ydbd(pid=1252503, tid=0x00007B971ADCE640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Run task: 2
2025-11-01T17:56:25.986395Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. update task runner stats
2025-11-01T17:56:25.986459Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-01T17:56:25.986484Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-01T17:56:25.986511Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:532: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. About to drain channelId: 2, hasPeer: 1, peerState:(freeSpace:67108864;inFlightBytes:0;inFlightCount:0;)
2025-11-01T17:56:25.986553Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudtef6hgbqqqtjl81, task: 2. no poll, channelId: 1, has inflight messages: [4], last with freeSpace: 1000000, current freeSpace: 1000000
2025-11-01T17:56:26.002166Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:390: [ptqudtef6hgbqqqtjl81-0] [1:4] TEvSaveTaskState Apply: task: 2
2025-11-01T17:56:26.002194Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:405: [ptqudtef6hgbqqqtjl81-0] [1:4] Send TEvSaveTaskStateResult: task: 2
2025-11-01T17:56:26.805214Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:451: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. Got TEvStateRequest from actor [1:7567817337842154936:2378] PingCookie: 1
2025-11-01T17:56:26.805276Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. update task runner stats
2025-11-01T17:56:26.915123Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 225bc33a-18de9753-c230e7ba-8148c69116, Host: ghrun-ku4naohwou, Tenant: /default
2025-11-01T17:56:26.925816Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-11-01T17:56:26.932416Z :FQ_CONTROL_PLANE_CONFIG TRACE: control_plane_config.cpp:192: LOADED TenantInfo: State NOT changed
2025-11-01T17:56:26.946532Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-01T17:56:26.946554Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-01T17:56:26.984581Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:129: TxId: ptqudtef6hgbqqqtjl81, task: 2. Received input for channelId: 1, seqNo: 5, size: 0, chunks: 0, watermark: 0, checkpoint: 1, finished: 0, from: [1:7567817337842154939:2380], expected seqNo: 5
2025-11-01T17:56:26.984653Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:609: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. took input
2025-11-01T17:56:26.984698Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:485: [ptqudtef6hgbqqqtjl81-0] Task: 2. [Checkpoint 1.5] Got checkpoint barrier from channel 1
2025-11-01T17:56:26.984744Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:395: SelfId: [3:7567817337213388127:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. No watermark 
2025-11-01T17:56:26.984760Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1486: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. Poll inputs
2025-11-01T17:56:26.984883Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1497: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-11-01T17:56:26.984939Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. DoExecuteImpl: 1
2025-11-01T17:56:26.985032Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:965: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. Input data push finished. Cookie: 4 Watermark: (empty maybe) Ack: 1 TakeInputChannelDataRequests: 1
2025-11-01T17:56:26.985056Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:738: TxId: ptqudtef6hgbqqqtjl81, task: 2. Sending channel data ack to channelId: 1, peer: [1:7567817337842154938:2380], from: [3:7567817337213388125:2157], freeSpace: 1000000, seqNo: 5, finished: 0
2025-11-01T17:56:26.985251Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: 225bc33a-18de9753-c230e7ba-8148c691 2025-11-01 17:56:26.985 DEBUG ydbd(pid=1252503, tid=0x00007B971ADCE640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Run task: 2
2025-11-01T17:56:26.985316Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:510: SelfId: [3:7567817337213388127:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Pending 1 checkpoints to be sent
2025-11-01T17:56:26.985350Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1486: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. Poll inputs
2025-11-01T17:56:26.985367Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1497: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-11-01T17:56:26.985375Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-11-01T17:56:26.985391Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. update task runner stats
2025-11-01T17:56:26.985476Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 1 watermark injected: (empty maybe)
2025-11-01T17:56:26.985490Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:447: [ptqudtef6hgbqqqtjl81-0] Task: 2. [Checkpoint 1.5] Performing task checkpoint
2025-11-01T17:56:26.985496Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:822: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. Save state
2025-11-01T17:56:26.985506Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:474: [ptqudtef6hgbqqqtjl81-0] Task: 2. [Checkpoint 1.5] CA state saved
2025-11-01T17:56:26.985515Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:449: [ptqudtef6hgbqqqtjl81-0] Task: 2. [Checkpoint 1.5] Injecting checkpoint barrier to outputs
2025-11-01T17:56:26.985543Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:536: [ptqudtef6hgbqqqtjl81-0] Task: 2. [Checkpoint 1.5] Task checkpoint is done. Send to storage
2025-11-01T17:56:26.985564Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-01T17:56:26.985587Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:532: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. About to drain channelId: 2, hasPeer: 1, peerState:(freeSpace:67108864;inFlightBytes:0;inFlightCount:0;)
2025-11-01T17:56:26.985617Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:366: [ptqudtef6hgbqqqtjl81-0] [1:5] Got TEvSaveTaskState: task 2
2025-11-01T17:56:26.985795Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: 225bc33a-18de9753-c230e7ba-8148c691 2025-11-01 17:56:26.985 DEBUG ydbd(pid=1252503, tid=0x00007B971ADCE640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Run task: 2
2025-11-01T17:56:26.985861Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:566: TxId: ptqudtef6hgbqqqtjl81, task: 2. SendChannelData, channelId: 2, peer: [1:7567817337842154934:2376], chunks: 0, bytes: 0, watermark: 0, checkpoint: 1, seqNo: 5, finished: 0
2025-11-01T17:56:26.985926Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudtef6hgbqqqtjl81, task: 2. no poll, channelId: 1, has inflight messages: [5], last with freeSpace: 1000000, current freeSpace: 1000000
2025-11-01T17:56:26.985941Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. update task runner stats
2025-11-01T17:56:26.986023Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-01T17:56:26.986042Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-01T17:56:26.986086Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:532: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. About to drain channelId: 2, hasPeer: 1, peerState:(freeSpace:67108864;inFlightBytes:96;inFlightCount:1;)
2025-11-01T17:56:26.986126Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1486: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. Poll inputs
2025-11-01T17:56:26.986134Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1501: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. Poll sources
2025-11-01T17:56:26.986141Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-11-01T17:56:26.986255Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: 225bc33a-18de9753-c230e7ba-8148c691 2025-11-01 17:56:26.986 DEBUG ydbd(pid=1252503, tid=0x00007B971ADCE640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Run task: 2
2025-11-01T17:56:26.986334Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudtef6hgbqqqtjl81, task: 2. no poll, channelId: 1, has inflight messages: [5], last with freeSpace: 1000000, current freeSpace: 1000000
2025-11-01T17:56:26.986345Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. update task runner stats
2025-11-01T17:56:26.986408Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-01T17:56:26.986416Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-01T17:56:26.986428Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:532: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. About to drain channelId: 2, hasPeer: 1, peerState:(freeSpace:67108864;inFlightBytes:96;inFlightCount:1;)
2025-11-01T17:56:26.986437Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1105: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. Ask CPU quota: 10ms
2025-11-01T17:56:26.986490Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudtef6hgbqqqtjl81, task: 2. no poll, channelId: 1, has inflight messages: [5], last with freeSpace: 1000000, current freeSpace: 1000000
2025-11-01T17:56:26.986525Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:179: TxId: ptqudtef6hgbqqqtjl81, task: 2. Received channel data ack for channelId: 2, seqNo: 5, lastSentSeqNo: 5, freeSpace: 67108864, early finish: 0
2025-11-01T17:56:26.986543Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:207: TxId: ptqudtef6hgbqqqtjl81, task: 2. PeerState, peerState:(freeSpace:67108864;inFlightBytes:0;inFlightCount:0;), sentSeqNo: 5, ackSeqNo: 5
2025-11-01T17:56:26.986550Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:220: TxId: ptqudtef6hgbqqqtjl81, task: 2. Resume compute actor
2025-11-01T17:56:26.986563Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1486: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. Poll inputs
2025-11-01T17:56:26.986569Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1501: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. Poll sources
2025-11-01T17:56:26.986574Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-11-01T17:56:26.996047Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1162: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. CPU quota delay: 9ms
2025-11-01T17:56:26.996325Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. update task runner stats
2025-11-01T17:56:26.996414Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-01T17:56:26.996433Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-01T17:56:26.996478Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:532: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. About to drain channelId: 2, hasPeer: 1, peerState:(freeSpace:67108864;inFlightBytes:0;inFlightCount:0;)
2025-11-01T17:56:26.996542Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudtef6hgbqqqtjl81, task: 2. no poll, channelId: 1, has inflight messages: [5], last with freeSpace: 1000000, current freeSpace: 1000000
2025-11-01T17:56:27.002286Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:390: [ptqudtef6hgbqqqtjl81-0] [1:5] TEvSaveTaskState Apply: task: 2
2025-11-01T17:56:27.002333Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:405: [ptqudtef6hgbqqqtjl81-0] [1:5] Send TEvSaveTaskStateResult: task: 2
2025-11-01T17:56:27.518811Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:389: Send NodeInfo with size: 3 to DynamicNameserver
2025-11-01T17:56:27.790574Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: 225bc33a-18de9753-c230e7ba-8148c691 2025-11-01 17:56:27.790 DEBUG ydbd(pid=1252503, tid=0x00007B971ADCE640) [DQ] local_worker_manager.cpp:416: TEvFreeWorkersNotify 562954248388609
2025-11-01T17:56:27.790885Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: 225bc33a-18de9753-c230e7ba-8148c691 2025-11-01 17:56:27.790 DEBUG ydbd(pid=1252503, tid=0x00007B971ADCE640) [DQ] local_worker_manager.cpp:440: Free Group 562954248388609
2025-11-01T17:56:27.791521Z :KQP_COMPUTE ERROR: dq_compute_actor_impl.h:1210: SelfId: [3:7567817337213388125:2157], TxId: ptqudtef6hgbqqqtjl81, task: 2. Ctx: {}. Handle abort execution event from: [3:7567817294263715014:2068], status: UNAVAILABLE, reason: { <main>: Error: Aborted by LWM }
2025-11-01T17:56:27.791676Z :KQP_COMPUTE DEBUG: dq_compute_actor_channels.cpp:494: TxId: ptqudtef6hgbqqqtjl81, task: 2. pass away
2025-11-01T17:56:27.912237Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:617: RowDispatcher: Send ping to [1:7567817290597514392:2124]
2025-11-01T17:56:27.912273Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1161: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-11-01T17:56:27.912825Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:623: RowDispatcher: NActors::TEvents::TEvPong
2025-11-01T17:56:27.915312Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 225bc33a-18de9753-c230e7ba-8148c69117, Host: ghrun-ku4naohwou, Tenant: /default
2025-11-01T17:56:27.943093Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-01T17:56:27.943129Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-01T17:56:28.915534Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 225bc33a-18de9753-c230e7ba-8148c69118, Host: ghrun-ku4naohwou, Tenant: /default
2025-11-01T17:56:28.943237Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-01T17:56:28.943273Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-01T17:56:29.580209Z :INTERCONNECT_NETWORK NOTICE: interconnect_tcp_input_session.cpp:712: [3 <-> 4] connection closed by peer
2025-11-01T17:56:29.593578Z :INTERCONNECT_NETWORK NOTICE: interconnect_tcp_input_session.cpp:712: [3 <-> 1] connection closed by peer
2025-11-01T17:56:29.594253Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: 225bc33a-18de9753-c230e7ba-8148c691 2025-11-01 17:56:29.594 DEBUG ydbd(pid=1252503, tid=0x00007B971ADCE640) [DQ] local_worker_manager.cpp:257: Disconnected 1
2025-11-01T17:56:29.597134Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: 225bc33a-18de9753-c230e7ba-8148c691 2025-11-01 17:56:29.596 DEBUG ydbd(pid=1252503, tid=0x00007B971ADCE640) [DQ] local_worker_manager.cpp:228: Deallocate 1
2025-11-01T17:56:29.599245Z :INTERCONNECT_NETWORK NOTICE: interconnect_handshake.cpp:1262: [3 <-> 4] network-related error occured on handshake: outgoing handshake Peer# ghrun-ku4naohwou(127.0.1.1:19079) Couldn't connect to any resolved address
