2025-10-15T15:05:30.531251Z :GRPC_SERVER NOTICE: grpc_request_proxy_simple.cpp:161: Grpc simple request proxy started, nodeid# 1
2025-10-15T15:05:30.531596Z :GRPC_SERVER NOTICE: grpc_request_proxy_simple.cpp:161: Grpc simple request proxy started, nodeid# 1
2025-10-15T15:05:30.532423Z :YQ_CONTROL_PLANE_STORAGE INFO: ydb_control_plane_storage.cpp:50: Starting ydb control plane storage service. Actor id: [1:7561464858818388897:2062]
2025-10-15T15:05:30.534695Z :YQL_NODES_MANAGER INFO: nodes_manager.cpp:88: Bootstrap, InstanceId: 5a3fc6b8-422b523b-2e762682-2fd3a581
2025-10-15T15:05:30.534703Z :YQL_NODES_MANAGER DEBUG: nodes_manager.cpp:310: TNodesManagerActor::ResolveSelfAddress
2025-10-15T15:05:30.534743Z :YQ_TEST_CONNECTION DEBUG: test_connection.cpp:142: Starting yandex query test connection. Actor id: [1:7561464858818388909:2074]
2025-10-15T15:05:30.534931Z :FQ_LOG_UPDATER DEBUG: log.cpp:93: Updated YQL logs priority: 8
2025-10-15T15:05:30.534965Z :FQ_LOG_UPDATER CRIT: log.cpp:55: Failed to deliver subscription request to config dispatcher.
2025-10-15T15:05:30.540342Z :FQ_QUOTA_SERVICE INFO: quota_manager.cpp:196: STARTED
2025-10-15T15:05:30.540425Z :FQ_QUOTA_PROXY INFO: quota_proxy.cpp:90: STARTED
2025-10-15T15:05:30.540538Z :YQ_CONTROL_PLANE_PROXY DEBUG: control_plane_proxy.cpp:525: Starting yandex query control plane proxy. Actor id: [1:7561464858818388899:2064]
2025-10-15T15:05:30.559262Z :YQ_RATE_LIMITER INFO: quoter_service.cpp:124: Bootstraping with config: { Enabled: true ControlPlaneEnabled: true DataPlaneEnabled: true Database { Endpoint: "localhost:23936" Database: "local" TablePrefix: "RateLimiter_37150301-54a0-47a0-b127-5da7e553f10e" } Limiters { CoordinationNodePath: "rate_limiter" } }
2025-10-15T15:05:30.593162Z :MEMORY_PROFILER NOTICE: monitor.cpp:332: Bootstrapped
2025-10-15T15:05:30.621503Z :FQ_CONTROL_PLANE_CONFIG DEBUG: control_plane_config.cpp:58: STARTING: [1:7561464858818388898:2063]
2025-10-15T15:05:30.621938Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:158: Bootstrap
2025-10-15T15:05:30.622115Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:178: Initialize
2025-10-15T15:05:30.693521Z :YQ_RATE_LIMITER DEBUG: schema.cpp:71: Run create coordination node "local/RateLimiter_37150301-54a0-47a0-b127-5da7e553f10e/rate_limiter" actor
2025-10-15T15:05:30.693551Z :YQ_RATE_LIMITER DEBUG: schema.cpp:113: Call create coordination node "local/RateLimiter_37150301-54a0-47a0-b127-5da7e553f10e/rate_limiter"
2025-10-15T15:05:30.693558Z :YQ_RATE_LIMITER DEBUG: schema.cpp:411: Call create coordination node "local/RateLimiter_37150301-54a0-47a0-b127-5da7e553f10e/rate_limiter"
2025-10-15T15:05:30.693717Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:537: RowDispatcher: Successfully bootstrapped row dispatcher, id [1:7561464858818388904:2069], tenant /default
2025-10-15T15:05:30.694233Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-10-15T15:05:30.695051Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: df355bdf-bddd72de-e9883691-13e142581, Host: ghrun-lvxbqnxafi, Tenant: /default
2025-10-15T15:05:30.711457Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:267: Coordinator: Successfully bootstrapped coordinator, id [1:7561464858818388987:2130], NodesManagerId [0:4705493345362661702:78]
2025-10-15T15:05:30.713343Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:630: RowDispatcher: TEvCoordinatorChangesSubscribe from [1:7561464858818388987:2130]
2025-10-15T15:05:30.713927Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create directory "local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e" actor
2025-10-15T15:05:30.714005Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create directory "local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e"
2025-10-15T15:05:30.714023Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:383: Call create directory "local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e"
2025-10-15T15:05:30.714266Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/queries" actor
2025-10-15T15:05:30.714576Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/connections" actor
2025-10-15T15:05:30.714696Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/bindings" actor
2025-10-15T15:05:30.716128Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/pending_small" actor
2025-10-15T15:05:30.716899Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/idempotency_keys" actor
2025-10-15T15:05:30.718208Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/result_sets" actor
2025-10-15T15:05:30.721796Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/jobs" actor
2025-10-15T15:05:30.721959Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:232: TLeaderElection [1:7561464858818388988:2131] Successfully bootstrapped, local coordinator id [1:7561464858818388987:2130], tenant id default, local mode 0, coordination node path local/row_dispatcher/default
2025-10-15T15:05:30.745502Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:71: Run create coordination node "local/row_dispatcher/default" actor
2025-10-15T15:05:30.745522Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:113: Call create coordination node "local/row_dispatcher/default"
2025-10-15T15:05:30.745539Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:411: Call create coordination node "local/row_dispatcher/default"
2025-10-15T15:05:30.760937Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/nodes" actor
2025-10-15T15:05:30.761052Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/quotas" actor
2025-10-15T15:05:30.761150Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/tenants" actor
2025-10-15T15:05:30.761246Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/tenant_acks" actor
2025-10-15T15:05:30.761294Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/mappings" actor
2025-10-15T15:05:30.761347Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/compute_databases" actor
2025-10-15T15:05:30.809576Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:155: Successfully created coordination node "local/row_dispatcher/default"
2025-10-15T15:05:30.809680Z :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: 15], type: EPathTypeKesus, state: EPathStateNoChanges) }
2025-10-15T15:05:30.809747Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:345: TLeaderElection [1:7561464858818388988:2131] Coordination node successfully created
2025-10-15T15:05:30.809770Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:323: TLeaderElection [1:7561464858818388988:2131] Start session
2025-10-15T15:05:30.985166Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:359: TLeaderElection [1:7561464858818388988:2131] Session successfully created
2025-10-15T15:05:31.033901Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:372: TLeaderElection [1:7561464858818388988:2131] Semaphore successfully created
2025-10-15T15:05:31.033921Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:304: TLeaderElection [1:7561464858818388988:2131] Try to acquire semaphore
2025-10-15T15:05:31.034187Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:420: TLeaderElection [1:7561464858818388988:2131] Describe semaphore
2025-10-15T15:05:31.045172Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/bindings". Create session OK
2025-10-15T15:05:31.045202Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/bindings"
2025-10-15T15:05:31.045231Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/bindings"
2025-10-15T15:05:31.058921Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/queries". Create session OK
2025-10-15T15:05:31.058975Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/queries"
2025-10-15T15:05:31.058983Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/queries"
2025-10-15T15:05:31.063753Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created directory "local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e"
2025-10-15T15:05:31.063787Z :YQ_RATE_LIMITER DEBUG: schema.cpp:155: Successfully created coordination node "local/RateLimiter_37150301-54a0-47a0-b127-5da7e553f10e/rate_limiter"
2025-10-15T15:05:31.063810Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create directory "local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e": { <main>: Error: Check failed: path: '/local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 31], type: EPathTypeDir, state: EPathStateNoChanges) }
2025-10-15T15:05:31.063829Z :YQ_RATE_LIMITER DEBUG: schema.cpp:122: Reply for create coordination node "local/RateLimiter_37150301-54a0-47a0-b127-5da7e553f10e/rate_limiter": { <main>: Error: Check failed: path: '/local/RateLimiter_37150301-54a0-47a0-b127-5da7e553f10e/rate_limiter', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 38], type: EPathTypeKesus, state: EPathStateNoChanges) }
2025-10-15T15:05:31.063844Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/pending_small". Create session OK
2025-10-15T15:05:31.063858Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/pending_small"
2025-10-15T15:05:31.063876Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/connections". Create session OK
2025-10-15T15:05:31.063890Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/pending_small"
2025-10-15T15:05:31.063897Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/connections"
2025-10-15T15:05:31.063905Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/connections"
2025-10-15T15:05:31.068079Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/idempotency_keys". Create session OK
2025-10-15T15:05:31.068094Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/idempotency_keys"
2025-10-15T15:05:31.068114Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/idempotency_keys"
2025-10-15T15:05:31.069516Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:386: TLeaderElection [1:7561464858818388988:2131] Semaphore successfully acquired
2025-10-15T15:05:31.069555Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:469: TLeaderElection [1:7561464858818388988:2131] Semaphore successfully described: coordinator id [1:7561464858818388987:2130] generation 4
2025-10-15T15:05:31.069590Z :FQ_ROW_DISPATCHER INFO: leader_election.cpp:471: TLeaderElection [1:7561464858818388988:2131] Send TEvCoordinatorChanged to [1:7561464858818388904:2069], new coordinator id [1:7561464858818388987:2130], previous coordinator id [0:0:0]
2025-10-15T15:05:31.079413Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/jobs". Create session OK
2025-10-15T15:05:31.079444Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/jobs"
2025-10-15T15:05:31.079451Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/jobs"
2025-10-15T15:05:31.080664Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/nodes". Create session OK
2025-10-15T15:05:31.080696Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/nodes"
2025-10-15T15:05:31.080717Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/nodes"
2025-10-15T15:05:31.081832Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/result_sets". Create session OK
2025-10-15T15:05:31.081845Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/result_sets"
2025-10-15T15:05:31.087191Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/result_sets"
2025-10-15T15:05:31.107181Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/quotas". Create session OK
2025-10-15T15:05:31.107208Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/quotas"
2025-10-15T15:05:31.107213Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/quotas"
2025-10-15T15:05:31.110827Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/tenants". Create session OK
2025-10-15T15:05:31.110865Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/tenants"
2025-10-15T15:05:31.110905Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/tenants"
2025-10-15T15:05:31.111083Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/compute_databases". Create session OK
2025-10-15T15:05:31.111098Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/compute_databases"
2025-10-15T15:05:31.111108Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/compute_databases"
2025-10-15T15:05:31.115154Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/tenant_acks". Create session OK
2025-10-15T15:05:31.115179Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/tenant_acks"
2025-10-15T15:05:31.115186Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/tenant_acks"
2025-10-15T15:05:31.122268Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:562: RowDispatcher: Coordinator changed, old leader (empty maybe), new [1:7561464858818388987:2130] generation 4
2025-10-15T15:05:31.130618Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/mappings". Create session OK
2025-10-15T15:05:31.130651Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/mappings"
2025-10-15T15:05:31.130660Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/mappings"
2025-10-15T15:05:31.131599Z :FQ_CONTROL_PLANE_CONFIG DEBUG: control_plane_config.cpp:190: LOADED TenantInfo: State CHANGED at 2025-10-15T15:04:53.937780Z
2025-10-15T15:05:31.131722Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:314: Coordinator: TEvPing received, [1:7561464858818388904:2069]
2025-10-15T15:05:31.131740Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:317: Coordinator: Send TEvPong to [1:7561464858818388904:2069]
2025-10-15T15:05:31.131799Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:386: Coordinator: New leader [1:7561464858818388987:2130], SelfId [1:7561464858818388987:2130]
2025-10-15T15:05:31.140433Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:626: RowDispatcher: NActors::TEvents::TEvPong
2025-10-15T15:05:31.153283Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: df355bdf-bddd72de-e9883691-13e142581, Host: ghrun-lvxbqnxafi, Tenant: /default, Request CP::GetTask with size: 68 bytes
2025-10-15T15:05:31.163539Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/bindings"
2025-10-15T15:05:31.163595Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/bindings": { <main>: Error: Check failed: path: '/local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/bindings', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 42], type: EPathTypeTable, state: EPathStateNoChanges) }
2025-10-15T15:05:31.175050Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/connections"
2025-10-15T15:05:31.176100Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/connections": { <main>: Error: Check failed: path: '/local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/connections', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 41], type: EPathTypeTable, state: EPathStateNoChanges) }
2025-10-15T15:05:31.178271Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/queries"
2025-10-15T15:05:31.178324Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/queries": { <main>: Error: Check failed: path: '/local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/queries', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 47], type: EPathTypeTable, state: EPathStateNoChanges) }
2025-10-15T15:05:31.179746Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/idempotency_keys"
2025-10-15T15:05:31.179781Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/idempotency_keys": { <main>: Error: Check failed: path: '/local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/idempotency_keys', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 43], type: EPathTypeTable, state: EPathStateNoChanges) }
2025-10-15T15:05:31.182092Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/pending_small"
2025-10-15T15:05:31.182145Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/pending_small": { <main>: Error: Check failed: path: '/local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/pending_small', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 46], type: EPathTypeTable, state: EPathStateNoChanges) }
2025-10-15T15:05:31.184022Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/nodes"
2025-10-15T15:05:31.184068Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/nodes": { <main>: Error: Check failed: path: '/local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/nodes', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 40], type: EPathTypeTable, state: EPathStateNoChanges) }
2025-10-15T15:05:31.186160Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/jobs"
2025-10-15T15:05:31.186205Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/jobs": { <main>: Error: Check failed: path: '/local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/jobs', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 39], type: EPathTypeTable, state: EPathStateNoChanges) }
2025-10-15T15:05:31.187807Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/result_sets"
2025-10-15T15:05:31.187849Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/result_sets": { <main>: Error: Check failed: path: '/local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/result_sets', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 45], type: EPathTypeTable, state: EPathStateNoChanges) }
2025-10-15T15:05:31.191204Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/quotas"
2025-10-15T15:05:31.191244Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/quotas": { <main>: Error: Check failed: path: '/local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/quotas', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 44], type: EPathTypeTable, state: EPathStateNoChanges) }
2025-10-15T15:05:31.192873Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/tenants"
2025-10-15T15:05:31.192902Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/tenants": { <main>: Error: Check failed: path: '/local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/tenants', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 32], type: EPathTypeTable, state: EPathStateNoChanges) }
2025-10-15T15:05:31.195214Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/tenant_acks"
2025-10-15T15:05:31.195259Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/tenant_acks": { <main>: Error: Check failed: path: '/local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/tenant_acks', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 49], type: EPathTypeTable, state: EPathStateNoChanges) }
2025-10-15T15:05:31.196951Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/compute_databases"
2025-10-15T15:05:31.197002Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/compute_databases": { <main>: Error: Check failed: path: '/local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/compute_databases', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 48], type: EPathTypeTable, state: EPathStateNoChanges) }
2025-10-15T15:05:31.200822Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/mappings"
2025-10-15T15:05:31.200860Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/mappings": { <main>: Error: Check failed: path: '/local/DbPoolStorage_37150301-54a0-47a0-b127-5da7e553f10e/mappings', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 33], type: EPathTypeTable, state: EPathStateNoChanges) }
2025-10-15T15:05:31.236547Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/default"
owner_id: "df355bdf-bddd72de-e9883691-13e142581"
host: "ghrun-lvxbqnxafi"
node_id: 1
}
2025-10-15T15:05:31.237139Z :YQ_CONTROL_PLANE_STORAGE TRACE: nodes_health_check.cpp:38: NodesHealthCheckRequest: {tenant: "/default"
node {
  node_id: 1
  instance_id: "5a3fc6b8-422b523b-2e762682-2fd3a581"
  hostname: "ghrun-lvxbqnxafi"
  interconnect_port: 29743
  node_address: "127.0.1.1"
}
}
2025-10-15T15:05:31.263230Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:456: Task (Query): ptqudupgm6dporp466o1 Lease TIMEOUT, RetryCounterUpdatedAt 2025-10-15T15:05:12.592434Z LastSeenAt: 2025-10-15T15:05:19.702074Z
2025-10-15T15:05:31.263264Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:463: Task (Query): ptqudupgm6dporp466o1 RetryRate: 0 RetryCounter: 2 At: 2025-10-15T15:05:31.263047Z
2025-10-15T15:05:31.316849Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: NodesHealthCheckRequest - NodesHealthCheckResult: {nodes { node_id: 1 instance_id: "5a3fc6b8-422b523b-2e762682-2fd3a581" hostname: "ghrun-lvxbqnxafi" node_address: "127.0.1.1" } } SUCCESS
2025-10-15T15:05:31.320528Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:389: Send NodeInfo with size: 0 to DynamicNameserver
2025-10-15T15:05:31.341205Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:171: Successfully bootstrapped TStorageProxy [1:7561464858818388903:2068] with connection to localhost:23936:local
2025-10-15T15:05:31.356928Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {tasks { query_id { value: "ptqudupgm6dporp466o1" } job_id { value: "ptjudupgm6dpo6q6tlaa" } generation: 3 streaming: true dq_graph: "\022\301\005\010\001\022\024\n\022\t\000\000\000\000\000\000\000\000\021\000\000\000\000\000\000\000\000\032\004\010\240\215\006*\326\002Z\323\002\n\010PqSource\022\304\002\n4type.googleapis.com/NYql.NPq.NProto.TDqPqTopicSource\022\213\002\n\016low_rate_input\022\024ptqudupgm6dporp466o1\032\017localhost:23936\"\032\n\030cluster:default_low_rate*\005local0\002@\001b\004Dataj\025[\"DataType\";\"String\"]\222\001\024ptcudupgm9klidrpbo5h\232\001\003raw\242\001/[\"StructType\";[[\"Data\";[\"DataType\";\"String\"]]]]\262\001\002\022\000\272\001\026\n\010cloud_id\022\nmock_cloud\272\001 \n\005scope\022\027yandexcloud://my_folder\030\0012B\n>\010\001\020\240\234\001\030\001 \002*\024\n\022\t\000\000\000\000\000\000\000\000\021\000\000\000\000\001\000\000\0002\024\n\022\t\000\000\000\000\000\000\000\000\021\000\000\000\000\002\000\000\000X\202\235\014`\223\235\014R\000:\203\001\n*type.googleapis.com/Yql.DqsProto.TTaskMeta\022U\010\202\235\014\022A\022(407626920c115831f1a477a2b30b7078a40af8e5\032\023dq_vanilla_job.lite \002\"\014\n\002pq\022\006\n\004\010\001\030\001H\202\235\014RClocal/RateLimiter_37150301-54a0-47a0-b127-5da7e553f10e/rate_limiterZ)mock_cloud/my_folder/ptqudupgm6dporp466o1`\200\200\200\200 \230\001\000\300\001\001\022\223\003\010\002\022\024\n\022\t\000\000\000\000\000\000\000\000\021\000\000\000\000\000\000\000\000\032\004\010\240\215\006*B\n>\010\001\020\240\234\001\030\001 \002*\024\n\022\t\000\000\000\000\000\000\000\000\021\000\000\000\000\001\000\000\0002\024\n\022\t\000\000\000\000\000\000\000\000\021\000\000\000\000\002\000\000\000X\202\235\014`\223\235\014R\00028\n4\010\002\020\240\234\001\030\002*\024\n\022\t\000\000\000\000\000\000\000\000\021\000\000\000\000\002\000\000\0002\024\n\022\t\001\000\000\000\000\000\000\000\021\000\000\000\000\001\000\000\000R\000:u\n*type.googleapis.com/Yql.DqsProto.TTaskMeta\022G\010\223\235\014\022A\022(407626920c115831f1a477a2b30b7078a40af8e5\032\023dq_vanilla_job.lite \002H\223\235\014RClocal/RateLimiter_37150301-54a0-47a0-b127-5da7e553f10e/rate_limiterZ)mock_cloud/my_folder/ptqudupgm6dporp466o1`\200\200\200\200 \230\001\000\300\001\001\030\001\"\r\037\000\205\002\203\005@\020Data/*\004Data2rptqudupgm6dporp466o1#ptrudupgm3bc7ppsq70v#yandexcloud://my_folder#b8497079-e8975825-15f208e5-15d8eca615#mock_cloud:\027\n\016FallbackPolicy\022\005never:\024\n\017_LiteralTimeout\022\0010:\022\n\r_TableTimeout\022\0010:\037\n\025_AllResultsBytesLimit\022\006100000:\032\n\022_RowsLimitPerWrite\022\0041000:\027\n\022EnableComputeActor\022\0011:\016\n\014WorkerFilter:\031\n\020ComputeActorType\022\005async:\031\n\016WatermarksMode\022\007disable:\037\n\027WatermarksGranularityMs\022\0041000:$\n\034WatermarksLateArrivalDelayMs\022\0045000:\027\n\022EnableChannelStats\022\0011:\020\n\013ExportStats\022\0011B*\n\030cluster:default_low_rate\022\016{\"no_auth\":\"\"}b\202\002\010\202\235\014\022\373\001\037\004\006Arg\010Data\005\205\006\213\002\204\203\005@\205\000\204\205\002\203\005@\006\030Inputs(Parameters\034Program\013?\004)\251\000?\002\002\000\n\000)\251\000?\006\002\000\026)\211\002?\014\215?\n FromFlow\000)\211\006?\032\215\233\002?\010?\010?\n$NarrowMap\000)\211\006? \215\205\002?\010\006?$?\010$ExpandMap\000)\211\006?&\215?\000?\000?$\014Map\000)\211\002?*?\002\030ToFlow\000?\022\000\014)\251\000?\000\002\000\010\005?$?4\000\004\016)\251\000?$\002\000\004)\211\004?\010?$\203\004\030Member\000?<\003?>\000\002\006\000\020)\251\000?\010\002\000\002\005?\n?J\000\004\022\000\024\001/bR\010\223\235\014\022L\037\002\006Arg\005\205\006\213\002\204\205\002\203\005@\020Data\205\000?\004\030Inputs(Parameters\034Program\013?\006)\251\000?\004\002\000\002\000)\251\000?\010\002\000\004?\016\001/" text: "SELECT * FROM low_rate.`low_rate_input`;" connection { content { name: "low_rate" setting { data_streams { auth { none { } } endpoint: "localhost:23936" database: "local" } } acl { visibility: PRIVATE } } meta { id: "ptcudupgm9klidrpbo5h" created_by: "root@bu...} SUCCESS
2025-10-15T15:05:31.357122Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: df355bdf-bddd72de-e9883691-13e142581, Host: ghrun-lvxbqnxafi, Tenant: /default, Got CP::GetTask Response
2025-10-15T15:05:31.363361Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-10-15T15:05:31.363388Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 1
2025-10-15T15:05:31.363843Z :FQ_PENDING_FETCHER DEBUG: pending_fetcher.cpp:361: NewTask: Scope: yandexcloud://my_folder Id: ptqudupgm6dporp466o1 UserId: root@builtin AuthToken: **** (B6C6F477)
2025-10-15T15:05:31.364641Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: df355bdf-bddd72de-e9883691-13e142582, Host: ghrun-lvxbqnxafi, Tenant: /default
2025-10-15T15:05:31.365031Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:375: QueryId: ptqudupgm6dporp466o1 Start run actor. Compute state: RUNNING
2025-10-15T15:05:31.365049Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:469: QueryId: ptqudupgm6dporp466o1 FillConnections
2025-10-15T15:05:31.365210Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:2332: QueryId: ptqudupgm6dporp466o1 Run actors params: { QueryId: ptqudupgm6dporp466o1 CloudId: mock_cloud UserId: root@builtin Owner: df355bdf-bddd72de-e9883691-13e142581 PreviousQueryRevision: 3 Connections: 1 Bindings: 0 AccountIdSignatures: 0 QueryType: STREAMING ExecuteMode: RUN ResultId: ptrudupglhgbajj0c99n StateLoadMode: FROM_LAST_CHECKPOINT StreamingDisposition: { from_last_checkpoint { } } Status: RUNNING DqGraphs: 1 DqGraphIndex: 0 Resource.TopicConsumers: 1 }
2025-10-15T15:05:31.365685Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:911: QueryId: ptqudupgm6dporp466o1 Overall dq tasks: 2
2025-10-15T15:05:31.366053Z :FQ_PINGER TRACE: pinger.cpp:171: QueryId: ptqudupgm6dporp466o1, Owner: df355bdf-bddd72de-e9883691-13e142581 Start Pinger
2025-10-15T15:05:31.367377Z :FQ_PINGER TRACE: pinger.cpp:250: QueryId: ptqudupgm6dporp466o1, Owner: df355bdf-bddd72de-e9883691-13e142581 Forward ping request: { resources { rate_limiter: READY compilation: READY topic_consumers_state: READY rate_limiter_path: "local/RateLimiter_37150301-54a0-47a0-b127-5da7e553f10e/rate_limiter" topic_consumers { database: "local" topic_path: "low_rate_input" consumer_name: "ptqudupgm6dporp466o1" cluster_endpoint: "localhost:23936" token_name: "cluster:default_low_rate" add_bearer_to_token: true } } }
2025-10-15T15:05:31.368050Z :FQ_PINGER TRACE: pinger.cpp:393: QueryId: ptqudupgm6dporp466o1, Owner: df355bdf-bddd72de-e9883691-13e142581 Forward request Private::PingTask
2025-10-15T15:05:31.414453Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: df355bdf-bddd72de-e9883691-13e142582, Host: ghrun-lvxbqnxafi, Tenant: /default, Request CP::GetTask with size: 68 bytes
2025-10-15T15:05:31.414494Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudupgm6dporp466o1, Owner: df355bdf-bddd72de-e9883691-13e142581, Request CP::PingTask with size: 285 bytes
2025-10-15T15:05:31.414641Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/default"
owner_id: "df355bdf-bddd72de-e9883691-13e142582"
host: "ghrun-lvxbqnxafi"
node_id: 1
}
2025-10-15T15:05:31.415055Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "df355bdf-bddd72de-e9883691-13e142581"
query_id {
  value: "ptqudupgm6dporp466o1"
}
resources {
  rate_limiter: READY
  compilation: READY
  topic_consumers_state: READY
  rate_limiter_path: "local/RateLimiter_37150301-54a0-47a0-b127-5da7e553f10e/rate_limiter"
  topic_consumers {
    database: "local"
    topic_path: "low_rate_input"
    consumer_name: "ptqudupgm6dporp466o1"
    cluster_endpoint: "localhost:23936"
    token_name: "cluster:default_low_rate"
    add_bearer_to_token: true
  }
}
scope: "yandexcloud://my_folder"
deadline {
  seconds: 1760627131
  nanos: 320903000
}
tenant: "/default"
}
2025-10-15T15:05:31.437396Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-10-15T15:05:31.437586Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: df355bdf-bddd72de-e9883691-13e142582, Host: ghrun-lvxbqnxafi, Tenant: /default, Got CP::GetTask Response
2025-10-15T15:05:31.446582Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-10-15T15:05:31.446629Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-10-15T15:05:31.504377Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {expired_at { seconds: 1760540732 nanos: 455000000 } } SUCCESS
2025-10-15T15:05:31.504575Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudupgm6dporp466o1, Owner: df355bdf-bddd72de-e9883691-13e142581, Got CP::PingTaskResponse
2025-10-15T15:05:31.509379Z :FQ_PINGER TRACE: pinger.cpp:338: QueryId: ptqudupgm6dporp466o1, Owner: df355bdf-bddd72de-e9883691-13e142581 Ping response success: { expired_at { seconds: 1760540732 nanos: 455000000 } }
2025-10-15T15:05:31.602857Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudupgm6dporp466o1 2025-10-15 15:05:31.602 DEBUG ydbd(pid=497468, tid=0x00007B9E6A15C640) [DQ] task_controller_impl.h:83: _AllResultsBytesLimit = 100000
2025-10-15T15:05:31.602979Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudupgm6dporp466o1 2025-10-15 15:05:31.602 DEBUG ydbd(pid=497468, tid=0x00007B9E6A15C640) [DQ] task_controller_impl.h:86: _RowsLimitPerWrite = 1000
2025-10-15T15:05:31.603440Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:1659: QueryId: ptqudupgm6dporp466o1 Executer: [1:7561464863113356329:2175], Controller: [1:7561464863113356346:2192], ResultIdActor: [1:7561464863113356344:2190]
2025-10-15T15:05:31.603557Z :FQ_RUN_ACTOR TRACE: run_actor.cpp:861: QueryId: ptqudupgm6dporp466o1 Forward ping response. Success: 1. Cookie: 0
2025-10-15T15:05:31.603734Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudupgm6dporp466o1 2025-10-15 15:05:31.603 DEBUG ydbd(pid=497468, tid=0x00007B9E6A15C640) [DQ] executer_actor.cpp:140: {ptqudupgm6dporp466o1} TDqExecuter::OnGraph
2025-10-15T15:05:31.603896Z :YQL_PROXY INFO: log.cpp:64: SessionId: ptqudupgm6dporp466o1 2025-10-15 15:05:31.603 INFO  ydbd(pid=497468, tid=0x00007B9E6A15C640) [DQ] executer_actor.cpp:157: {ptqudupgm6dporp466o1} Trying to allocate 2 workers [EnableComputeActor=1]
2025-10-15T15:05:31.607389Z :FQ_RESULT_WRITER INFO: result_writer.cpp:62: TraceId: ptqudupgm6dporp466o1#ptrudupgm3bc7ppsq70v#yandexcloud://my_folder#b8497079-e8975825-15f208e5-15d8eca615#mock_cloud Bootstrap
2025-10-15T15:05:31.610457Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudupgm6dporp466o1 2025-10-15 15:05:31.610 DEBUG ydbd(pid=497468, tid=0x00007B9E6A15C640) [DQ] executer_actor.cpp:247: {ptqudupgm6dporp466o1} Dq timeouts are set to: 0.000000s (global), 600.000000s (workers allocation fail), 30.000000s (workers allocation warn) 
2025-10-15T15:05:31.616352Z :YQL_NODES_MANAGER DEBUG: nodes_manager.cpp:125: TEvAllocateWorkersResponse Nodes {
  ResourceId: 4294967297
  Worker {
    NodeId: 1
    Guid: "5a3fc6b8-422b523b-2e762682-2fd3a581,ghrun-lvxbqnxafi"
  }
  Worker {
    NodeId: 1
    Guid: "5a3fc6b8-422b523b-2e762682-2fd3a581,ghrun-lvxbqnxafi"
  }
}
2025-10-15T15:05:31.620236Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: df355bdf-bddd72de-e9883691-13e14258 2025-10-15 15:05:31.620 DEBUG ydbd(pid=497468, tid=0x00007B9E67B48640) [DQ] resource_allocator.cpp:141: {ptqudupgm6dporp466o1/[1:7561464863113356347:2193]} TEvAllocateWorkersResponse 1
2025-10-15T15:05:31.620336Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:134: SelfId: [1:7561464863113356348:2194], TxId: ptqudupgm6dporp466o1, task: 2. Ctx: {}. Start compute actor [1:7561464863113356348:2194], task: 2
2025-10-15T15:05:31.620506Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:113: SelfId: [1:7561464863113356348:2194], TxId: ptqudupgm6dporp466o1, task: 2. Ctx: {}. Use CPU quota: 1. Rate limiter resource: { "local/RateLimiter_37150301-54a0-47a0-b127-5da7e553f10e/rate_limiter", "mock_cloud/my_folder/ptqudupgm6dporp466o1" }
2025-10-15T15:05:31.621140Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudupgm6dporp466o1 2025-10-15 15:05:31.621 DEBUG ydbd(pid=497468, tid=0x00007B9E6A15C640) [DQ] executer_actor.cpp:358: {ptqudupgm6dporp466o1} TDqExecuter::TEvAllocateWorkersResponse
2025-10-15T15:05:31.622086Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudupgm6dporp466o1 2025-10-15 15:05:31.621 DEBUG ydbd(pid=497468, tid=0x00007B9E6A15C640) [DQ] executer_actor.cpp:384: {ptqudupgm6dporp466o1} Allocated resource 4294967297
2025-10-15T15:05:31.622114Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: df355bdf-bddd72de-e9883691-13e14258 2025-10-15 15:05:31.621 DEBUG ydbd(pid=497468, tid=0x00007B9E67B48640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Build task: 2
2025-10-15T15:05:31.625183Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:134: SelfId: [1:7561464863113356351:2195], TxId: ptqudupgm6dporp466o1, task: 1. Ctx: {}. Start compute actor [1:7561464863113356351:2195], task: 1
2025-10-15T15:05:31.629181Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:113: SelfId: [1:7561464863113356351:2195], TxId: ptqudupgm6dporp466o1, task: 1. Ctx: {}. Use CPU quota: 1. Rate limiter resource: { "local/RateLimiter_37150301-54a0-47a0-b127-5da7e553f10e/rate_limiter", "mock_cloud/my_folder/ptqudupgm6dporp466o1" }
2025-10-15T15:05:31.633451Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudupgm6dporp466o1 2025-10-15 15:05:31.633 DEBUG ydbd(pid=497468, tid=0x00007B9E6A15C640) [DQ] executer_actor.cpp:401: {ptqudupgm6dporp466o1} WorkerInfo: Id:5a3fc6b8-422b523b-2e762682-2fd3a581,ghrun-lvxbqnxafi,NodeId:1,StageId:200322
2025-10-15T15:05:31.633892Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudupgm6dporp466o1 2025-10-15 15:05:31.633 DEBUG ydbd(pid=497468, tid=0x00007B9E6A15C640) [DQ] executer_actor.cpp:402: {ptqudupgm6dporp466o1} TaskInfo: 0/1
2025-10-15T15:05:31.634144Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudupgm6dporp466o1 2025-10-15 15:05:31.633 DEBUG ydbd(pid=497468, tid=0x00007B9E6A15C640) [DQ] executer_actor.cpp:404: {ptqudupgm6dporp466o1}  ObjectId: 407626920c115831f1a477a2b30b7078a40af8e5, dq_vanilla_job.lite, 
2025-10-15T15:05:31.638993Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: df355bdf-bddd72de-e9883691-13e14258 2025-10-15 15:05:31.638 DEBUG ydbd(pid=497468, tid=0x00007B9E67B48640) [DQ] tasks_runner_local.cpp:267: {TODO/2} task: 2, program size: 6, llvm: ``.
2025-10-15T15:05:31.639023Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudupgm6dporp466o1 2025-10-15 15:05:31.638 DEBUG ydbd(pid=497468, tid=0x00007B9E6A15C640) [DQ] executer_actor.cpp:401: {ptqudupgm6dporp466o1} WorkerInfo: Id:5a3fc6b8-422b523b-2e762682-2fd3a581,ghrun-lvxbqnxafi,NodeId:1,StageId:200339
2025-10-15T15:05:31.639124Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudupgm6dporp466o1 2025-10-15 15:05:31.639 DEBUG ydbd(pid=497468, tid=0x00007B9E6A15C640) [DQ] executer_actor.cpp:402: {ptqudupgm6dporp466o1} TaskInfo: 1/2
2025-10-15T15:05:31.640432Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudupgm6dporp466o1 2025-10-15 15:05:31.640 DEBUG ydbd(pid=497468, tid=0x00007B9E6A15C640) [DQ] executer_actor.cpp:404: {ptqudupgm6dporp466o1}  ObjectId: 407626920c115831f1a477a2b30b7078a40af8e5, dq_vanilla_job.lite, 
2025-10-15T15:05:31.643810Z :YQL_PROXY INFO: log.cpp:64: SessionId: ptqudupgm6dporp466o1 2025-10-15 15:05:31.643 INFO  ydbd(pid=497468, tid=0x00007B9E6A15C640) [DQ] executer_actor.cpp:415: {ptqudupgm6dporp466o1} 2 workers allocated
2025-10-15T15:05:31.653555Z :YQL_PROXY TRACE: log.cpp:64: SessionId:  2025-10-15 15:05:31.653 TRACE ydbd(pid=497468, tid=0x00007B9E6A15C640) [DQ] task_controller_impl.h:271:  [1:7561464863113356346:2192] ExportStats Summary
2025-10-15T15:05:31.653925Z :YQL_PROXY DEBUG: log.cpp:64: SessionId:  2025-10-15 15:05:31.653 DEBUG ydbd(pid=497468, tid=0x00007B9E6A15C640) [DQ] task_controller_impl.h:526: Ready State: [1:7561464863113356346:2192]
2025-10-15T15:05:31.654053Z :YQL_PROXY DEBUG: log.cpp:64: SessionId:  2025-10-15 15:05:31.653 DEBUG ydbd(pid=497468, tid=0x00007B9E6A15C640) [DQ] task_controller_impl.h:537: Forward: [1:7561464863113356346:2192] to [1:7561464863113356345:2191]
2025-10-15T15:05:31.654370Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:51: [ptqudupgm6dporp466o1-0.3] TEvReadyState, streaming disposition { from_last_checkpoint { } }, state load mode FROM_LAST_CHECKPOINT
2025-10-15T15:05:31.654441Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:85: [ptqudupgm6dporp466o1-0.3] AllActors count: 2, ActorsToTrigger count: 1, ActorsToNotify count: 1, ActorsToWaitFor count: 2
2025-10-15T15:05:31.654454Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:95: [ptqudupgm6dporp466o1-0.3] Send TEvRegisterCoordinatorRequest
2025-10-15T15:05:31.654523Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:199: [ptqudupgm6dporp466o1-0.3] Got TEvRegisterCoordinatorRequest
2025-10-15T15:05:31.693423Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: df355bdf-bddd72de-e9883691-13e142583, Host: ghrun-lvxbqnxafi, Tenant: /default
2025-10-15T15:05:31.697613Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: df355bdf-bddd72de-e9883691-13e14258 2025-10-15 15:05:31.697 DEBUG ydbd(pid=497468, tid=0x00007B9E67B48640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Build task: 2 takes 75272 us
2025-10-15T15:05:31.697810Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: df355bdf-bddd72de-e9883691-13e14258 2025-10-15 15:05:31.697 DEBUG ydbd(pid=497468, tid=0x00007B9E67B48640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Prepare task: 2
2025-10-15T15:05:31.698023Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: df355bdf-bddd72de-e9883691-13e14258 2025-10-15 15:05:31.697 DEBUG ydbd(pid=497468, tid=0x00007B9E67B48640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Prepare task: 2, takes 99 us
2025-10-15T15:05:31.698479Z :YQL_PROXY TRACE: log.cpp:64: SessionId:  2025-10-15 15:05:31.698 TRACE ydbd(pid=497468, tid=0x00007B9E67B48640) [DQ] task_controller_impl.h:160: [1:7561464863113356346:2192] EvState TaskId: 2 State: 2 PingCookie: 0 StatusCode: UNSPECIFIED
2025-10-15T15:05:31.698651Z :YQL_PROXY TRACE: log.cpp:64: SessionId:  2025-10-15 15:05:31.698 TRACE ydbd(pid=497468, tid=0x00007B9E67B48640) [DQ] task_controller_impl.h:201:  [1:7561464863113356346:2192] Executing TaskId: 2
2025-10-15T15:05:31.704390Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: df355bdf-bddd72de-e9883691-13e142583, Host: ghrun-lvxbqnxafi, Tenant: /default, Request CP::GetTask with size: 68 bytes
2025-10-15T15:05:31.704594Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/default"
owner_id: "df355bdf-bddd72de-e9883691-13e142583"
host: "ghrun-lvxbqnxafi"
node_id: 1
}
2025-10-15T15:05:31.711296Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:542: Coordinator: Send TEvGetNodesRequest to NodesManager
2025-10-15T15:05:31.711355Z :YQL_NODES_MANAGER DEBUG: nodes_manager.cpp:300: TNodesManagerActor::TEvGetNodesRequest
2025-10-15T15:05:31.711408Z :FQ_ROW_DISPATCHER INFO: coordinator.cpp:573: Coordinator: Updated node info, node count: 1
2025-10-15T15:05:31.721363Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:213: [ptqudupgm6dporp466o1-0.3] Graph registered
2025-10-15T15:05:31.721402Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:215: [ptqudupgm6dporp466o1-0.3] Send TEvRegisterCoordinatorResponse
2025-10-15T15:05:31.721491Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:112: [ptqudupgm6dporp466o1-0.3] Got TEvRegisterCoordinatorResponse; issues: 
2025-10-15T15:05:31.721516Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:121: [ptqudupgm6dporp466o1-0.3] Successfully registered in storage
2025-10-15T15:05:31.721539Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:122: [ptqudupgm6dporp466o1-0.3] Send TEvNewCheckpointCoordinator to 2 actor(s)
2025-10-15T15:05:31.721593Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:130: [ptqudupgm6dporp466o1-0.3] Send TEvGetCheckpointsMetadataRequest; state load mode: FROM_LAST_CHECKPOINT; load graph: 0
2025-10-15T15:05:31.721843Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:197: [] Task: 2. Got TEvNewCheckpointCoordinator event: generation 3, actorId: [1:7561464863113356345:2191]
2025-10-15T15:05:31.721860Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:208: [] Task: 2. Assign checkpoint coordinator (generation = 3)
2025-10-15T15:05:31.721864Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:357: [ptqudupgm6dporp466o1-0] Got TEvGetCheckpointsMetadataRequest
2025-10-15T15:05:31.727854Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-10-15T15:05:31.728057Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: df355bdf-bddd72de-e9883691-13e142583, Host: ghrun-lvxbqnxafi, Tenant: /default, Got CP::GetTask Response
2025-10-15T15:05:31.731033Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-10-15T15:05:31.731055Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-10-15T15:05:31.869550Z :FQ_PINGER TRACE: pinger.cpp:400: QueryId: ptqudupgm6dporp466o1, Owner: df355bdf-bddd72de-e9883691-13e142581 Request Private::PingTask
2025-10-15T15:05:31.887010Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudupgm6dporp466o1, Owner: df355bdf-bddd72de-e9883691-13e142581, Request CP::PingTask with size: 114 bytes
2025-10-15T15:05:31.887294Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "df355bdf-bddd72de-e9883691-13e142581"
query_id {
  value: "ptqudupgm6dporp466o1"
}
scope: "yandexcloud://my_folder"
deadline {
  seconds: 1760627131
  nanos: 320903000
}
tenant: "/default"
}
2025-10-15T15:05:31.948221Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {expired_at { seconds: 1760540732 nanos: 909000000 } } SUCCESS
2025-10-15T15:05:31.948409Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudupgm6dporp466o1, Owner: df355bdf-bddd72de-e9883691-13e142581, Got CP::PingTaskResponse
2025-10-15T15:05:31.949654Z :FQ_PINGER TRACE: pinger.cpp:338: QueryId: ptqudupgm6dporp466o1, Owner: df355bdf-bddd72de-e9883691-13e142581 Ping response success: { expired_at { seconds: 1760540732 nanos: 909000000 } }
2025-10-15T15:05:32.186638Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:370: [ptqudupgm6dporp466o1-0] Send TEvGetCheckpointsMetadataResponse
2025-10-15T15:05:32.186701Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:167: [ptqudupgm6dporp466o1-0.3] Got TEvGetCheckpointsMetadataResponse
2025-10-15T15:05:32.186717Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:200: [ptqudupgm6dporp466o1-0.3] Will restore from checkpoint 2:4
2025-10-15T15:05:32.187699Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:265: [ptqudupgm6dporp466o1-0] Task: 2. [Checkpoint 2.4] TEvRestoreFromCheckpoint, StateLoadPlan = { StateType: STATE_TYPE_OWN }
2025-10-15T15:05:32.187784Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:427: [ptqudupgm6dporp466o1-0] [2:4] Got TEvGetTaskState: tasks {2}
2025-10-15T15:05:32.187823Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:532: [ptqudupgm6dporp466o1-0] [2:4] GetState, tasks: 2
2025-10-15T15:05:32.214882Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:197: [] Task: 1. Got TEvNewCheckpointCoordinator event: generation 3, actorId: [1:7561464863113356345:2191]
2025-10-15T15:05:32.214902Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:208: [] Task: 1. Assign checkpoint coordinator (generation = 3)
2025-10-15T15:05:32.219331Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1365: SelfId: [1:7561464863113356351:2195], TxId: ptqudupgm6dporp466o1, task: 1. Ctx: {}. Create source for input 0 { Source { Type: "PqSource" Settings { type_url: "type.googleapis.com/NYql.NPq.NProto.TDqPqTopicSource" value: "\n\016low_rate_input\022\024ptqudupgm6dporp466o1\032\017localhost:23936\"\032\n\030cluster:default_low_rate*\005local0\002@\001b\004Dataj\025[\"DataType\";\"String\"]\222\001\024ptcudupgm9klidrpbo5h\232\001\003raw\242\001/[\"StructType\";[[\"Data\";[\"DataType\";\"String\"]]]]\262\001\002\022\000\272\001\026\n\010cloud_id\022\nmock_cloud\272\001 \n\005scope\022\027yandexcloud://my_folder" } WatermarksMode: WATERMARKS_MODE_DISABLED } }
2025-10-15T15:05:32.221465Z :KQP_COMPUTE DEBUG: dq_pq_read_actor.cpp:619: SelfId: [0:0:0], TxId: ptqudupgm6dporp466o1, task: 1. PQ source. SessionId: empty Watermarks enabled: 0 granularity: 0 microseconds
2025-10-15T15:05:32.221569Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:265: [ptqudupgm6dporp466o1-0] Task: 1. [Checkpoint 2.4] TEvRestoreFromCheckpoint, StateLoadPlan = { StateType: STATE_TYPE_OWN }
2025-10-15T15:05:32.221641Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:427: [ptqudupgm6dporp466o1-0] [2:4] Got TEvGetTaskState: tasks {1}
2025-10-15T15:05:32.221665Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:532: [ptqudupgm6dporp466o1-0] [2:4] GetState, tasks: 1
2025-10-15T15:05:32.221775Z :YQL_PROXY TRACE: log.cpp:64: SessionId:  2025-10-15 15:05:32.221 TRACE ydbd(pid=497468, tid=0x00007B9E6A15C640) [DQ] task_controller_impl.h:160: [1:7561464863113356346:2192] EvState TaskId: 1 State: 2 PingCookie: 0 StatusCode: UNSPECIFIED
2025-10-15T15:05:32.221890Z :YQL_PROXY TRACE: log.cpp:64: SessionId:  2025-10-15 15:05:32.221 TRACE ydbd(pid=497468, tid=0x00007B9E6A15C640) [DQ] task_controller_impl.h:201:  [1:7561464863113356346:2192] Executing TaskId: 1
2025-10-15T15:05:32.222071Z :YQL_PROXY DEBUG: log.cpp:64: SessionId:  2025-10-15 15:05:32.221 DEBUG ydbd(pid=497468, tid=0x00007B9E6A15C640) [DQ] task_controller_impl.h:561: Update channels
2025-10-15T15:05:32.227743Z :YQL_PROXY TRACE: log.cpp:64: SessionId:  2025-10-15 15:05:32.222 TRACE ydbd(pid=497468, tid=0x00007B9E6A15C640) [DQ] task_controller_impl.h:577: 1 Update { Id: 1 TransportVersion: DATA_TRANSPORT_UV_PICKLE_1_0 SrcTaskId: 1 DstTaskId: 2 SrcEndpoint { ActorId { RawX1: 7561464863113356351 RawX2: 4503603922339987 } } DstEndpoint { ActorId { RawX1: 7561464863113356348 RawX2: 4503603922339986 } } SrcStageId: 200322 DstStageId: 200339 }
2025-10-15T15:05:32.228037Z :YQL_PROXY TRACE: log.cpp:64: SessionId:  2025-10-15 15:05:32.227 TRACE ydbd(pid=497468, tid=0x00007B9E6A15C640) [DQ] task_controller_impl.h:577: 2 Update { Id: 1 TransportVersion: DATA_TRANSPORT_UV_PICKLE_1_0 SrcTaskId: 1 DstTaskId: 2 SrcEndpoint { ActorId { RawX1: 7561464863113356351 RawX2: 4503603922339987 } } DstEndpoint { ActorId { RawX1: 7561464863113356348 RawX2: 4503603922339986 } } SrcStageId: 200322 DstStageId: 200339 } Update { Id: 2 TransportVersion: DATA_TRANSPORT_UV_PICKLE_1_0 SrcTaskId: 2 SrcEndpoint { ActorId { RawX1: 7561464863113356348 RawX2: 4503603922339986 } } DstEndpoint { ActorId { RawX1: 7561464863113356344 RawX2: 4503603922339982 } } }
2025-10-15T15:05:32.228249Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1074: SelfId: [1:7561464863113356351:2195], TxId: ptqudupgm6dporp466o1, task: 1. Ctx: {}. Received channels info: Update { Id: 1 TransportVersion: DATA_TRANSPORT_UV_PICKLE_1_0 SrcTaskId: 1 DstTaskId: 2 SrcEndpoint { ActorId { RawX1: 7561464863113356351 RawX2: 4503603922339987 } } DstEndpoint { ActorId { RawX1: 7561464863113356348 RawX2: 4503603922339986 } } SrcStageId: 200322 DstStageId: 200339 }
2025-10-15T15:05:32.228271Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1093: SelfId: [1:7561464863113356351:2195], TxId: ptqudupgm6dporp466o1, task: 1. Ctx: {}. Update output channelId: 1, peer: [1:7561464863113356348:2194]
2025-10-15T15:05:32.228321Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1074: SelfId: [1:7561464863113356348:2194], TxId: ptqudupgm6dporp466o1, task: 2. Ctx: {}. Received channels info: Update { Id: 1 TransportVersion: DATA_TRANSPORT_UV_PICKLE_1_0 SrcTaskId: 1 DstTaskId: 2 SrcEndpoint { ActorId { RawX1: 7561464863113356351 RawX2: 4503603922339987 } } DstEndpoint { ActorId { RawX1: 7561464863113356348 RawX2: 4503603922339986 } } SrcStageId: 200322 DstStageId: 200339 } Update { Id: 2 TransportVersion: DATA_TRANSPORT_UV_PICKLE_1_0 SrcTaskId: 2 SrcEndpoint { ActorId { RawX1: 7561464863113356348 RawX2: 4503603922339986 } } DstEndpoint { ActorId { RawX1: 7561464863113356344 RawX2: 4503603922339982 } } }
2025-10-15T15:05:32.228338Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1081: SelfId: [1:7561464863113356348:2194], TxId: ptqudupgm6dporp466o1, task: 2. Ctx: {}. Update input channelId: 1, peer: [1:7561464863113356351:2195]
2025-10-15T15:05:32.228349Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1093: SelfId: [1:7561464863113356348:2194], TxId: ptqudupgm6dporp466o1, task: 2. Ctx: {}. Update output channelId: 2, peer: [1:7561464863113356344:2190]
2025-10-15T15:05:32.449349Z :FQ_PINGER TRACE: pinger.cpp:400: QueryId: ptqudupgm6dporp466o1, Owner: df355bdf-bddd72de-e9883691-13e142581 Request Private::PingTask
2025-10-15T15:05:32.467360Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudupgm6dporp466o1, Owner: df355bdf-bddd72de-e9883691-13e142581, Request CP::PingTask with size: 114 bytes
2025-10-15T15:05:32.467539Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "df355bdf-bddd72de-e9883691-13e142581"
query_id {
  value: "ptqudupgm6dporp466o1"
}
scope: "yandexcloud://my_folder"
deadline {
  seconds: 1760627131
  nanos: 320903000
}
tenant: "/default"
}
2025-10-15T15:05:32.523759Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {expired_at { seconds: 1760540733 nanos: 492000000 } } SUCCESS
2025-10-15T15:05:32.524014Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudupgm6dporp466o1, Owner: df355bdf-bddd72de-e9883691-13e142581, Got CP::PingTaskResponse
2025-10-15T15:05:32.526047Z :FQ_PINGER TRACE: pinger.cpp:338: QueryId: ptqudupgm6dporp466o1, Owner: df355bdf-bddd72de-e9883691-13e142581 Ping response success: { expired_at { seconds: 1760540733 nanos: 492000000 } }
2025-10-15T15:05:32.654437Z :YQL_PROXY TRACE: log.cpp:64: SessionId:  2025-10-15 15:05:32.654 TRACE ydbd(pid=497468, tid=0x00007B9E6B466640) [DQ] task_controller_impl.h:271:  [1:7561464863113356346:2192] ExportStats Summary
2025-10-15T15:05:32.655740Z :FQ_PINGER TRACE: pinger.cpp:250: QueryId: ptqudupgm6dporp466o1, Owner: df355bdf-bddd72de-e9883691-13e142581 Forward ping request: { statistics: "{\"Graph=0\":{\"TaskRunner\":{\"Stage=200322\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":1,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":1,\"count\":1,\"avg\":1,\"max\":1,\"min\":1}},\"Stage=200339\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":1,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":1,\"count\":1,\"avg\":1,\"max\":1,\"min\":1}},\"Stage=Total\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":2,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":2,\"count\":2,\"avg\":1,\"max\":1,\"min\":1}}}}}" }
2025-10-15T15:05:32.655771Z :FQ_PINGER TRACE: pinger.cpp:393: QueryId: ptqudupgm6dporp466o1, Owner: df355bdf-bddd72de-e9883691-13e142581 Forward request Private::PingTask
2025-10-15T15:05:32.671939Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudupgm6dporp466o1, Owner: df355bdf-bddd72de-e9883691-13e142581, Request CP::PingTask with size: 591 bytes
2025-10-15T15:05:32.672152Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "df355bdf-bddd72de-e9883691-13e142581"
query_id {
  value: "ptqudupgm6dporp466o1"
}
statistics: "{\"Graph=0\":{\"TaskRunner\":{\"Stage=200322\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":1,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":1,\"count\":1,\"avg\":1,\"max\":1,\"min\":1}},\"Stage=200339\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":1,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":1,\"count\":1,\"avg\":1,\"max\":1,\"min\":1}},\"Stage=Total\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":2,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":2,\"count\":2,\"avg\":1,\"max\":1,\"min\":1}}}}}"
scope: "yandexcloud://my_folder"
deadline {
  seconds: 1760627131
  nanos: 320903000
}
tenant: "/default"
}
2025-10-15T15:05:32.694649Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: df355bdf-bddd72de-e9883691-13e142584, Host: ghrun-lvxbqnxafi, Tenant: /default
2025-10-15T15:05:32.694721Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:620: RowDispatcher: Send ping to [1:7561464858818388987:2130]
2025-10-15T15:05:32.694741Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1164: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-10-15T15:05:32.694777Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:314: Coordinator: TEvPing received, [1:7561464858818388904:2069]
2025-10-15T15:05:32.694789Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:317: Coordinator: Send TEvPong to [1:7561464858818388904:2069]
2025-10-15T15:05:32.694803Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:626: RowDispatcher: NActors::TEvents::TEvPong
2025-10-15T15:05:32.709573Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: df355bdf-bddd72de-e9883691-13e142584, Host: ghrun-lvxbqnxafi, Tenant: /default, Request CP::GetTask with size: 68 bytes
2025-10-15T15:05:32.709707Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/default"
owner_id: "df355bdf-bddd72de-e9883691-13e142584"
host: "ghrun-lvxbqnxafi"
node_id: 1
}
2025-10-15T15:05:32.737740Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-10-15T15:05:32.737895Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: df355bdf-bddd72de-e9883691-13e142584, Host: ghrun-lvxbqnxafi, Tenant: /default, Got CP::GetTask Response
2025-10-15T15:05:32.739100Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-10-15T15:05:32.739117Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-10-15T15:05:32.759544Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {expired_at { seconds: 1760540733 nanos: 716000000 } } SUCCESS
2025-10-15T15:05:32.759747Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudupgm6dporp466o1, Owner: df355bdf-bddd72de-e9883691-13e142581, Got CP::PingTaskResponse
2025-10-15T15:05:32.762201Z :FQ_PINGER TRACE: pinger.cpp:338: QueryId: ptqudupgm6dporp466o1, Owner: df355bdf-bddd72de-e9883691-13e142581 Ping response success: { expired_at { seconds: 1760540733 nanos: 716000000 } }
2025-10-15T15:05:32.762264Z :FQ_RUN_ACTOR TRACE: run_actor.cpp:861: QueryId: ptqudupgm6dporp466o1 Forward ping response. Success: 1. Cookie: 6
2025-10-15T15:05:32.967409Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:667: [ptqudupgm6dporp466o1-0] [2:4] ListOfStates results:
2025-10-15T15:05:32.967505Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:688: [ptqudupgm6dporp466o1-0] [2:4] taskId 2 checkpoint id: 2:4, rows count: 1
2025-10-15T15:05:32.967529Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:688: [ptqudupgm6dporp466o1-0] [2:4] taskId 2 checkpoint id: 2:3, rows count: 1
2025-10-15T15:05:32.967547Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:688: [ptqudupgm6dporp466o1-0] [2:4] taskId 2 checkpoint id: 2:2, rows count: 1
2025-10-15T15:05:32.967557Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:688: [ptqudupgm6dporp466o1-0] [2:4] taskId 2 checkpoint id: 2:1, rows count: 1
2025-10-15T15:05:32.967598Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:920: [ptqudupgm6dporp466o1-0] [2:4] SkipStatesInFuture, skip 0 checkpoints
2025-10-15T15:05:32.970186Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:667: [ptqudupgm6dporp466o1-0] [2:4] ListOfStates results:
2025-10-15T15:05:32.970283Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:688: [ptqudupgm6dporp466o1-0] [2:4] taskId 1 checkpoint id: 2:4, rows count: 1
2025-10-15T15:05:32.970305Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:688: [ptqudupgm6dporp466o1-0] [2:4] taskId 1 checkpoint id: 2:3, rows count: 1
2025-10-15T15:05:32.970318Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:688: [ptqudupgm6dporp466o1-0] [2:4] taskId 1 checkpoint id: 2:2, rows count: 1
2025-10-15T15:05:32.970331Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:688: [ptqudupgm6dporp466o1-0] [2:4] taskId 1 checkpoint id: 2:1, rows count: 1
2025-10-15T15:05:32.970351Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:920: [ptqudupgm6dporp466o1-0] [2:4] SkipStatesInFuture, skip 0 checkpoints
2025-10-15T15:05:32.970513Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:812: [ptqudupgm6dporp466o1-0] [2:4] SelectState: task_id 1, seq_no 4, blob_seq_num 0
2025-10-15T15:05:32.981830Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:812: [ptqudupgm6dporp466o1-0] [2:4] SelectState: task_id 2, seq_no 4, blob_seq_num 0
2025-10-15T15:05:33.030326Z :FQ_PINGER TRACE: pinger.cpp:400: QueryId: ptqudupgm6dporp466o1, Owner: df355bdf-bddd72de-e9883691-13e142581 Request Private::PingTask
2025-10-15T15:05:33.040439Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudupgm6dporp466o1, Owner: df355bdf-bddd72de-e9883691-13e142581, Request CP::PingTask with size: 114 bytes
2025-10-15T15:05:33.040701Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "df355bdf-bddd72de-e9883691-13e142581"
query_id {
  value: "ptqudupgm6dporp466o1"
}
scope: "yandexcloud://my_folder"
deadline {
  seconds: 1760627131
  nanos: 320903000
}
tenant: "/default"
}
2025-10-15T15:05:33.088662Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {expired_at { seconds: 1760540734 nanos: 63000000 } } SUCCESS
2025-10-15T15:05:33.088774Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudupgm6dporp466o1, Owner: df355bdf-bddd72de-e9883691-13e142581, Got CP::PingTaskResponse
2025-10-15T15:05:33.093480Z :FQ_PINGER TRACE: pinger.cpp:338: QueryId: ptqudupgm6dporp466o1, Owner: df355bdf-bddd72de-e9883691-13e142581 Ping response success: { expired_at { seconds: 1760540734 nanos: 63000000 } }
2025-10-15T15:05:33.526621Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:423: [ptqudupgm6dporp466o1-0] [2:4] DeserializeState, task id 1, blob size 102
2025-10-15T15:05:33.526675Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:979: [ptqudupgm6dporp466o1-0] [2:4] ApplyIncrements
2025-10-15T15:05:33.534475Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:446: [ptqudupgm6dporp466o1-0] [{ Id: 4 Generation: 2 }] Send TEvGetTaskStateResult: tasks: {1}
2025-10-15T15:05:33.535097Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:423: [ptqudupgm6dporp466o1-0] [2:4] DeserializeState, task id 2, blob size 29
2025-10-15T15:05:33.535148Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:979: [ptqudupgm6dporp466o1-0] [2:4] ApplyIncrements
2025-10-15T15:05:33.535209Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:446: [ptqudupgm6dporp466o1-0] [{ Id: 4 Generation: 2 }] Send TEvGetTaskStateResult: tasks: {2}
2025-10-15T15:05:33.535570Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:336: [ptqudupgm6dporp466o1-0] Task: 1. [Checkpoint 2.4] TEvGetTaskStateResult: restoring state
2025-10-15T15:05:33.535595Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:792: SelfId: [1:7561464863113356351:2195], TxId: ptqudupgm6dporp466o1, task: 1. Ctx: {}. Load state
2025-10-15T15:05:33.535719Z :KQP_COMPUTE DEBUG: dq_pq_read_actor_base.cpp:127: SelfId: [0:0:0], TxId: ptqudupgm6dporp466o1, task: 1. PQ source. SessionId: empty StartingMessageTs 2025-10-15T15:05:15.418000Z Restoring offset: 
2025-10-15T15:05:33.535749Z :KQP_COMPUTE DEBUG: dq_pq_read_actor.cpp:619: SelfId: [0:0:0], TxId: ptqudupgm6dporp466o1, task: 1. PQ source. SessionId: empty Watermarks enabled: 0 granularity: 0 microseconds
2025-10-15T15:05:33.535809Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:362: [ptqudupgm6dporp466o1-0] Task: 1. [Checkpoint 2.4] Checkpoint state restored
2025-10-15T15:05:33.535869Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:336: [ptqudupgm6dporp466o1-0] Task: 2. [Checkpoint 2.4] TEvGetTaskStateResult: restoring state
2025-10-15T15:05:33.535879Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:792: SelfId: [1:7561464863113356348:2194], TxId: ptqudupgm6dporp466o1, task: 2. Ctx: {}. Load state
2025-10-15T15:05:33.535891Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:362: [ptqudupgm6dporp466o1-0] Task: 2. [Checkpoint 2.4] Checkpoint state restored
2025-10-15T15:05:33.535925Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:275: [ptqudupgm6dporp466o1-0.3] [2:4] Got TEvRestoreFromCheckpointResult; taskId: 1, checkpoint: 2:4, status: OK, issues: 
2025-10-15T15:05:33.535940Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:298: [ptqudupgm6dporp466o1-0.3] [2:4] Task state restored, need 1 more acks
2025-10-15T15:05:33.535955Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:275: [ptqudupgm6dporp466o1-0.3] [2:4] Got TEvRestoreFromCheckpointResult; taskId: 2, checkpoint: 2:4, status: OK, issues: 
2025-10-15T15:05:33.535961Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:298: [ptqudupgm6dporp466o1-0.3] [2:4] Task state restored, need 0 more acks
2025-10-15T15:05:33.535978Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:423: [ptqudupgm6dporp466o1-0.3] Send TEvRun to all actors
2025-10-15T15:05:33.536009Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1169: SelfId: [1:7561464863113356351:2195], TxId: ptqudupgm6dporp466o1, task: 1. Ctx: {}. Got TEvRun from actor [1:7561464863113356345:2191]
2025-10-15T15:05:33.536034Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1486: SelfId: [1:7561464863113356351:2195], TxId: ptqudupgm6dporp466o1, task: 1. Ctx: {}. Poll inputs
2025-10-15T15:05:33.536050Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1501: SelfId: [1:7561464863113356351:2195], TxId: ptqudupgm6dporp466o1, task: 1. Ctx: {}. Poll sources
2025-10-15T15:05:33.536077Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:530: SelfId: [0:0:0], TxId: ptqudupgm6dporp466o1, task: 1. PQ source. SessionId: empty GetAsyncInputData freeSpace = 1
2025-10-15T15:05:33.536193Z :KQP_COMPUTE DEBUG: dq_pq_read_actor.cpp:639: SelfId: [0:0:0], TxId: ptqudupgm6dporp466o1, task: 1. PQ source. SessionId: empty PartitionsToRead: 0
2025-10-15T15:05:33.536476Z :YDB_SDK INFO: actor.cpp:37: 2025-10-15T15:05:33.536452Z :INFO: [local] [local] [9e332c99-3d83934c-7cf99b60-60640827] Starting read session
2025-10-15T15:05:33.536538Z :YDB_SDK DEBUG: actor.cpp:37: 2025-10-15T15:05:33.536520Z :DEBUG: [local] [local] [9e332c99-3d83934c-7cf99b60-60640827] Starting single session
2025-10-15T15:05:33.536711Z :YDB_SDK DEBUG: actor.cpp:37: 2025-10-15T15:05:33.536692Z :DEBUG: [local] [local] [9e332c99-3d83934c-7cf99b60-60640827] [] In Reconnect, ReadSizeBudget = 8388608, ReadSizeServerDelta = 0
2025-10-15T15:05:33.536758Z :YDB_SDK DEBUG: actor.cpp:37: 2025-10-15T15:05:33.536734Z :DEBUG: [local] [local] [9e332c99-3d83934c-7cf99b60-60640827] [] New values: ReadSizeBudget = 8388608, ReadSizeServerDelta = 0
2025-10-15T15:05:33.536800Z :YDB_SDK DEBUG: actor.cpp:37: 2025-10-15T15:05:33.536783Z :DEBUG: [local] [local] [9e332c99-3d83934c-7cf99b60-60640827] [] Reconnecting session to cluster  in 0.000000s
2025-10-15T15:05:33.537165Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1169: SelfId: [1:7561464863113356348:2194], TxId: ptqudupgm6dporp466o1, task: 2. Ctx: {}. Got TEvRun from actor [1:7561464863113356345:2191]
2025-10-15T15:05:33.537207Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1486: SelfId: [1:7561464863113356348:2194], TxId: ptqudupgm6dporp466o1, task: 2. Ctx: {}. Poll inputs
2025-10-15T15:05:33.537214Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1501: SelfId: [1:7561464863113356348:2194], TxId: ptqudupgm6dporp466o1, task: 2. Ctx: {}. Poll sources
2025-10-15T15:05:33.537226Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [1:7561464863113356348:2194], TxId: ptqudupgm6dporp466o1, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-10-15T15:05:33.537426Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: df355bdf-bddd72de-e9883691-13e14258 2025-10-15 15:05:33.537 DEBUG ydbd(pid=497468, tid=0x00007B9E67B48640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Run task: 2
2025-10-15T15:05:33.537670Z :KQP_COMPUTE TRACE: dq_compute_memory_quota.h:97: TxId: ptqudupgm6dporp466o1, task: 2. Peak memory usage: 2031616
2025-10-15T15:05:33.537716Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [1:7561464863113356348:2194], TxId: ptqudupgm6dporp466o1, task: 2. Ctx: {}. update task runner stats
2025-10-15T15:05:33.537859Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [1:7561464863113356348:2194], TxId: ptqudupgm6dporp466o1, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-10-15T15:05:33.537874Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [1:7561464863113356348:2194], TxId: ptqudupgm6dporp466o1, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-10-15T15:05:33.537907Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:532: SelfId: [1:7561464863113356348:2194], TxId: ptqudupgm6dporp466o1, task: 2. Ctx: {}. About to drain channelId: 2, hasPeer: 1, peerState:(freeSpace:1000000;inFlightBytes:0;inFlightCount:0;)
2025-10-15T15:05:33.537926Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1105: SelfId: [1:7561464863113356348:2194], TxId: ptqudupgm6dporp466o1, task: 2. Ctx: {}. Ask CPU quota: 79ms
2025-10-15T15:05:33.538078Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:605: TxId: ptqudupgm6dporp466o1, task: 2. no poll, channelId: 1, hasPeer: 1, finished: 0, retry: 0, lastSeqNo: 0, freeSpace: 1000000
2025-10-15T15:05:33.539540Z :KQP_COMPUTE INFO: dq_pq_read_actor.cpp:298: SelfId: [0:0:0], TxId: ptqudupgm6dporp466o1, task: 1. PQ source. SessionId: 9e332c99-3d83934c-7cf99b60-60640827 CreateReadSession
2025-10-15T15:05:33.539610Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:77: SelfId: [1:7561464863113356351:2195], TxId: ptqudupgm6dporp466o1, task: 1. Ctx: {}. Poll async input 0. Buffer free space: 1, read from async input: 0 bytes, 0 rows, finished: 0
2025-10-15T15:05:33.539721Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [1:7561464863113356351:2195], TxId: ptqudupgm6dporp466o1, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-10-15T15:05:33.539957Z :KQP_COMPUTE TRACE: dq_compute_memory_quota.h:97: TxId: ptqudupgm6dporp466o1, task: 1. Peak memory usage: 2031616
2025-10-15T15:05:33.539986Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [1:7561464863113356351:2195], TxId: ptqudupgm6dporp466o1, task: 1. Ctx: {}. update task runner stats
2025-10-15T15:05:33.540097Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [1:7561464863113356351:2195], TxId: ptqudupgm6dporp466o1, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-10-15T15:05:33.540110Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [1:7561464863113356351:2195], TxId: ptqudupgm6dporp466o1, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-10-15T15:05:33.540130Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:532: SelfId: [1:7561464863113356351:2195], TxId: ptqudupgm6dporp466o1, task: 1. Ctx: {}. About to drain channelId: 1, hasPeer: 1, peerState:(freeSpace:1000000;inFlightBytes:0;inFlightCount:0;)
2025-10-15T15:05:33.540145Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1105: SelfId: [1:7561464863113356351:2195], TxId: ptqudupgm6dporp466o1, task: 1. Ctx: {}. Ask CPU quota: 607ms
2025-10-15T15:05:33.546308Z :YDB_SDK DEBUG: actor.cpp:37: 2025-10-15T15:05:33.546258Z :DEBUG: [local] [local] [9e332c99-3d83934c-7cf99b60-60640827] [] Successfully connected. Initializing session
2025-10-15T15:05:33.561075Z :YDB_SDK INFO: actor.cpp:37: 2025-10-15T15:05:33.561034Z :INFO: [local] [local] [9e332c99-3d83934c-7cf99b60-60640827] [] Got InitResponse. ReadSessionId: ptqudupgm6dporp466o1_1_2_3809124004158506516_v1
2025-10-15T15:05:33.561172Z :YDB_SDK DEBUG: actor.cpp:37: 2025-10-15T15:05:33.561144Z :DEBUG: [local] [local] [9e332c99-3d83934c-7cf99b60-60640827] [] In ContinueReadingDataImpl, ReadSizeBudget = 8388608, ReadSizeServerDelta = 0
2025-10-15T15:05:33.561423Z :YDB_SDK DEBUG: actor.cpp:37: 2025-10-15T15:05:33.561394Z :DEBUG: [local] [local] [9e332c99-3d83934c-7cf99b60-60640827] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 8388608
2025-10-15T15:05:33.562732Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1162: SelfId: [1:7561464863113356348:2194], TxId: ptqudupgm6dporp466o1, task: 2. Ctx: {}. CPU quota delay: 24ms
2025-10-15T15:05:33.573722Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:344: SelfId: [0:0:0], TxId: ptqudupgm6dporp466o1, task: 1. PQ source. SessionId: 9e332c99-3d83934c-7cf99b60-60640827 Source data ready
2025-10-15T15:05:33.573787Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1486: SelfId: [1:7561464863113356351:2195], TxId: ptqudupgm6dporp466o1, task: 1. Ctx: {}. Poll inputs
2025-10-15T15:05:33.573797Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1501: SelfId: [1:7561464863113356351:2195], TxId: ptqudupgm6dporp466o1, task: 1. Ctx: {}. Poll sources
2025-10-15T15:05:33.573826Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:530: SelfId: [0:0:0], TxId: ptqudupgm6dporp466o1, task: 1. PQ source. SessionId: 9e332c99-3d83934c-7cf99b60-60640827 GetAsyncInputData freeSpace = 1000000
2025-10-15T15:05:33.573885Z :KQP_COMPUTE DEBUG: dq_pq_read_actor.cpp:811: SelfId: [0:0:0], TxId: ptqudupgm6dporp466o1, task: 1. PQ source. SessionId: 9e332c99-3d83934c-7cf99b60-60640827 Key: 0@ StartPartitionSessionEvent received
2025-10-15T15:05:33.573907Z :KQP_COMPUTE DEBUG: dq_pq_read_actor.cpp:818: SelfId: [0:0:0], TxId: ptqudupgm6dporp466o1, task: 1. PQ source. SessionId: 9e332c99-3d83934c-7cf99b60-60640827 Key: 0@ Confirm StartPartitionSession with offset (NULL)
2025-10-15T15:05:33.573960Z :YDB_SDK INFO: actor.cpp:37: 2025-10-15T15:05:33.573935Z :INFO: [local] [local] [9e332c99-3d83934c-7cf99b60-60640827] [] Confirm partition stream create. Partition stream id: 1. Cluster: "-". Topic: "low_rate_input". Partition: 0. Read offset: (NULL)
2025-10-15T15:05:33.574169Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:77: SelfId: [1:7561464863113356351:2195], TxId: ptqudupgm6dporp466o1, task: 1. Ctx: {}. Poll async input 0. Buffer free space: 1000000, read from async input: 0 bytes, 0 rows, finished: 0
2025-10-15T15:05:33.574218Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:344: SelfId: [0:0:0], TxId: ptqudupgm6dporp466o1, task: 1. PQ source. SessionId: 9e332c99-3d83934c-7cf99b60-60640827 Source data ready
2025-10-15T15:05:33.574233Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [1:7561464863113356351:2195], TxId: ptqudupgm6dporp466o1, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-10-15T15:05:33.574254Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1486: SelfId: [1:7561464863113356351:2195], TxId: ptqudupgm6dporp466o1, task: 1. Ctx: {}. Poll inputs
2025-10-15T15:05:33.574259Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1501: SelfId: [1:7561464863113356351:2195], TxId: ptqudupgm6dporp466o1, task: 1. Ctx: {}. Poll sources
2025-10-15T15:05:33.574300Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:530: SelfId: [0:0:0], TxId: ptqudupgm6dporp466o1, task: 1. PQ source. SessionId: 9e332c99-3d83934c-7cf99b60-60640827 GetAsyncInputData freeSpace = 1000000
2025-10-15T15:05:33.574323Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:77: SelfId: [1:7561464863113356351:2195], TxId: ptqudupgm6dporp466o1, task: 1. Ctx: {}. Poll async input 0. Buffer free space: 1000000, read from async input: 0 bytes, 0 rows, finished: 0
2025-10-15T15:05:33.574341Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [1:7561464863113356351:2195], TxId: ptqudupgm6dporp466o1, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-10-15T15:05:33.581814Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1162: SelfId: [1:7561464863113356351:2195], TxId: ptqudupgm6dporp466o1, task: 1. Ctx: {}. CPU quota delay: 41ms
2025-10-15T15:05:33.582071Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [1:7561464863113356351:2195], TxId: ptqudupgm6dporp466o1, task: 1. Ctx: {}. update task runner stats
2025-10-15T15:05:33.582244Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [1:7561464863113356351:2195], TxId: ptqudupgm6dporp466o1, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-10-15T15:05:33.582257Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [1:7561464863113356351:2195], TxId: ptqudupgm6dporp466o1, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-10-15T15:05:33.582282Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:532: SelfId: [1:7561464863113356351:2195], TxId: ptqudupgm6dporp466o1, task: 1. Ctx: {}. About to drain channelId: 1, hasPeer: 1, peerState:(freeSpace:1000000;inFlightBytes:0;inFlightCount:0;)
2025-10-15T15:05:33.593183Z :FQ_PINGER TRACE: pinger.cpp:400: QueryId: ptqudupgm6dporp466o1, Owner: df355bdf-bddd72de-e9883691-13e142581 Request Private::PingTask
2025-10-15T15:05:33.606719Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudupgm6dporp466o1, Owner: df355bdf-bddd72de-e9883691-13e142581, Request CP::PingTask with size: 114 bytes
2025-10-15T15:05:33.606902Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "df355bdf-bddd72de-e9883691-13e142581"
query_id {
  value: "ptqudupgm6dporp466o1"
}
scope: "yandexcloud://my_folder"
deadline {
  seconds: 1760627131
  nanos: 320903000
}
tenant: "/default"
}
2025-10-15T15:05:33.656524Z :YQL_PROXY TRACE: log.cpp:64: SessionId:  2025-10-15 15:05:33.656 TRACE ydbd(pid=497468, tid=0x00007B9E6B466640) [DQ] task_controller_impl.h:271:  [1:7561464863113356346:2192] ExportStats Summary
2025-10-15T15:05:33.657491Z :FQ_PINGER TRACE: pinger.cpp:250: QueryId: ptqudupgm6dporp466o1, Owner: df355bdf-bddd72de-e9883691-13e142581 Forward ping request: { statistics: "{\"Graph=0\":{\"TaskRunner\":{\"Stage=200322\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":1,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":1,\"count\":1,\"avg\":1,\"max\":1,\"min\":1}},\"Stage=200339\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":1,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":1,\"count\":1,\"avg\":1,\"max\":1,\"min\":1}},\"Stage=Total\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":2,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":2,\"count\":2,\"avg\":1,\"max\":1,\"min\":1}}}}}" }
2025-10-15T15:05:33.657514Z :FQ_PINGER TRACE: pinger.cpp:393: QueryId: ptqudupgm6dporp466o1, Owner: df355bdf-bddd72de-e9883691-13e142581 Forward request Private::PingTask
2025-10-15T15:05:33.669570Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {expired_at { seconds: 1760540734 nanos: 637000000 } } SUCCESS
2025-10-15T15:05:33.669748Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudupgm6dporp466o1, Owner: df355bdf-bddd72de-e9883691-13e142581, Got CP::PingTaskResponse
2025-10-15T15:05:33.670346Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudupgm6dporp466o1, Owner: df355bdf-bddd72de-e9883691-13e142581, Request CP::PingTask with size: 591 bytes
2025-10-15T15:05:33.670510Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "df355bdf-bddd72de-e9883691-13e142581"
query_id {
  value: "ptqudupgm6dporp466o1"
}
statistics: "{\"Graph=0\":{\"TaskRunner\":{\"Stage=200322\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":1,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":1,\"count\":1,\"avg\":1,\"max\":1,\"min\":1}},\"Stage=200339\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":1,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":1,\"count\":1,\"avg\":1,\"max\":1,\"min\":1}},\"Stage=Total\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":2,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":2,\"count\":2,\"avg\":1,\"max\":1,\"min\":1}}}}}"
scope: "yandexcloud://my_folder"
deadline {
  seconds: 1760627131
  nanos: 320903000
}
tenant: "/default"
}
2025-10-15T15:05:33.673630Z :FQ_PINGER TRACE: pinger.cpp:338: QueryId: ptqudupgm6dporp466o1, Owner: df355bdf-bddd72de-e9883691-13e142581 Ping response success: { expired_at { seconds: 1760540734 nanos: 637000000 } }
2025-10-15T15:05:33.697272Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: df355bdf-bddd72de-e9883691-13e142585, Host: ghrun-lvxbqnxafi, Tenant: /default
2025-10-15T15:05:33.718007Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: df355bdf-bddd72de-e9883691-13e142585, Host: ghrun-lvxbqnxafi, Tenant: /default, Request CP::GetTask with size: 68 bytes
2025-10-15T15:05:33.718183Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/default"
owner_id: "df355bdf-bddd72de-e9883691-13e142585"
host: "ghrun-lvxbqnxafi"
node_id: 1
}
2025-10-15T15:05:33.734146Z :FQ_CONTROL_PLANE_CONFIG TRACE: control_plane_config.cpp:192: LOADED TenantInfo: State NOT changed
2025-10-15T15:05:33.756548Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-10-15T15:05:33.756766Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: df355bdf-bddd72de-e9883691-13e142585, Host: ghrun-lvxbqnxafi, Tenant: /default, Got CP::GetTask Response
2025-10-15T15:05:33.757684Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-10-15T15:05:33.757704Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-10-15T15:05:33.769634Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {expired_at { seconds: 1760540734 nanos: 699000000 } } SUCCESS
2025-10-15T15:05:33.769879Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudupgm6dporp466o1, Owner: df355bdf-bddd72de-e9883691-13e142581, Got CP::PingTaskResponse
2025-10-15T15:05:33.770776Z :FQ_PINGER TRACE: pinger.cpp:338: QueryId: ptqudupgm6dporp466o1, Owner: df355bdf-bddd72de-e9883691-13e142581 Ping response success: { expired_at { seconds: 1760540734 nanos: 699000000 } }
2025-10-15T15:05:33.770830Z :FQ_RUN_ACTOR TRACE: run_actor.cpp:861: QueryId: ptqudupgm6dporp466o1 Forward ping response. Success: 1. Cookie: 6
2025-10-15T15:05:34.173552Z :FQ_PINGER TRACE: pinger.cpp:400: QueryId: ptqudupgm6dporp466o1, Owner: df355bdf-bddd72de-e9883691-13e142581 Request Private::PingTask
2025-10-15T15:05:34.191615Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudupgm6dporp466o1, Owner: df355bdf-bddd72de-e9883691-13e142581, Request CP::PingTask with size: 114 bytes
2025-10-15T15:05:34.191866Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "df355bdf-bddd72de-e9883691-13e142581"
query_id {
  value: "ptqudupgm6dporp466o1"
}
scope: "yandexcloud://my_folder"
deadline {
  seconds: 1760627131
  nanos: 320903000
}
tenant: "/default"
}
2025-10-15T15:05:34.253176Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {expired_at { seconds: 1760540735 nanos: 216000000 } } SUCCESS
2025-10-15T15:05:34.253339Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudupgm6dporp466o1, Owner: df355bdf-bddd72de-e9883691-13e142581, Got CP::PingTaskResponse
2025-10-15T15:05:34.254185Z :FQ_PINGER TRACE: pinger.cpp:338: QueryId: ptqudupgm6dporp466o1, Owner: df355bdf-bddd72de-e9883691-13e142581 Ping response success: { expired_at { seconds: 1760540735 nanos: 216000000 } }
2025-10-15T15:05:34.536262Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:351: [ptqudupgm6dporp466o1-0.3] Got TEvScheduleCheckpointing
2025-10-15T15:05:34.536301Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:327: [ptqudupgm6dporp466o1-0.3] [3:1] Registering new checkpoint in storage
2025-10-15T15:05:34.536756Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:223: [ptqudupgm6dporp466o1-0.3] [3:1] Got TEvCreateCheckpointRequest
2025-10-15T15:05:34.537363Z :YDB_SDK INFO: actor.cpp:37: 2025-10-15T15:05:34.537317Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:low_rate_input:0:1:0:0
2025-10-15T15:05:34.537488Z :YDB_SDK INFO: actor.cpp:37: 2025-10-15T15:05:34.537450Z :INFO: [local] [local] [9e332c99-3d83934c-7cf99b60-60640827] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1000 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-10-15T15:05:34.636706Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:265: [ptqudupgm6dporp466o1-0.3] [3:1] Checkpoint created
2025-10-15T15:05:34.636756Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:267: [ptqudupgm6dporp466o1-0.3] [3:1] Send TEvCreateCheckpointResponse
2025-10-15T15:05:34.636850Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:367: [ptqudupgm6dporp466o1-0.3] [3:1] Got TEvCreateCheckpointResponse
2025-10-15T15:05:34.636877Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:413: [ptqudupgm6dporp466o1-0.3] [3:1] Checkpoint successfully created, going to inject barriers to 1 actor(s)
2025-10-15T15:05:34.636947Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:239: [ptqudupgm6dporp466o1-0] Task: 1. [Checkpoint 3.1] TEvInjectCheckpoint
2025-10-15T15:05:34.636996Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1486: SelfId: [1:7561464863113356351:2195], TxId: ptqudupgm6dporp466o1, task: 1. Ctx: {}. Poll inputs
2025-10-15T15:05:34.637011Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1497: SelfId: [1:7561464863113356351:2195], TxId: ptqudupgm6dporp466o1, task: 1. Ctx: {}. Skip polling sources because of pending checkpoint
2025-10-15T15:05:34.637019Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [1:7561464863113356351:2195], TxId: ptqudupgm6dporp466o1, task: 1. Ctx: {}. DoExecuteImpl: 1
2025-10-15T15:05:34.637251Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:510: SelfId: [1:7561464863113356353:2195], TxId: ptqudupgm6dporp466o1, task: 1. Pending 1 checkpoints to be sent
2025-10-15T15:05:34.637278Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [1:7561464863113356351:2195], TxId: ptqudupgm6dporp466o1, task: 1. Ctx: {}. update task runner stats
2025-10-15T15:05:34.637374Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [1:7561464863113356351:2195], TxId: ptqudupgm6dporp466o1, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 1 watermark injected: (empty maybe)
2025-10-15T15:05:34.637400Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:447: [ptqudupgm6dporp466o1-0] Task: 1. [Checkpoint 3.1] Performing task checkpoint
2025-10-15T15:05:34.637409Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:822: SelfId: [1:7561464863113356351:2195], TxId: ptqudupgm6dporp466o1, task: 1. Ctx: {}. Save state
2025-10-15T15:05:34.637447Z :KQP_COMPUTE DEBUG: dq_pq_read_actor_base.cpp:89: SelfId: [0:0:0], TxId: ptqudupgm6dporp466o1, task: 1. PQ source. SessionId: 9e332c99-3d83934c-7cf99b60-60640827 SaveState, offsets: 
2025-10-15T15:05:34.637481Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:474: [ptqudupgm6dporp466o1-0] Task: 1. [Checkpoint 3.1] CA state saved
2025-10-15T15:05:34.637508Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:449: [ptqudupgm6dporp466o1-0] Task: 1. [Checkpoint 3.1] Injecting checkpoint barrier to outputs
2025-10-15T15:05:34.637537Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:536: [ptqudupgm6dporp466o1-0] Task: 1. [Checkpoint 3.1] Task checkpoint is done. Send to storage
2025-10-15T15:05:34.637550Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [1:7561464863113356351:2195], TxId: ptqudupgm6dporp466o1, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-10-15T15:05:34.637570Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:532: SelfId: [1:7561464863113356351:2195], TxId: ptqudupgm6dporp466o1, task: 1. Ctx: {}. About to drain channelId: 1, hasPeer: 1, peerState:(freeSpace:1000000;inFlightBytes:0;inFlightCount:0;)
2025-10-15T15:05:34.637577Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:379: [ptqudupgm6dporp466o1-0] [3:1] Got TEvSaveTaskState: task 1
2025-10-15T15:05:34.637642Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:566: TxId: ptqudupgm6dporp466o1, task: 1. SendChannelData, channelId: 1, peer: [1:7561464863113356348:2194], chunks: 0, bytes: 0, watermark: 0, checkpoint: 1, seqNo: 1, finished: 0
2025-10-15T15:05:34.637698Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1486: SelfId: [1:7561464863113356351:2195], TxId: ptqudupgm6dporp466o1, task: 1. Ctx: {}. Poll inputs
2025-10-15T15:05:34.637708Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1501: SelfId: [1:7561464863113356351:2195], TxId: ptqudupgm6dporp466o1, task: 1. Ctx: {}. Poll sources
2025-10-15T15:05:34.637725Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:530: SelfId: [0:0:0], TxId: ptqudupgm6dporp466o1, task: 1. PQ source. SessionId: 9e332c99-3d83934c-7cf99b60-60640827 GetAsyncInputData freeSpace = 1000000
2025-10-15T15:05:34.637745Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:77: SelfId: [1:7561464863113356351:2195], TxId: ptqudupgm6dporp466o1, task: 1. Ctx: {}. Poll async input 0. Buffer free space: 1000000, read from async input: 0 bytes, 0 rows, finished: 0
2025-10-15T15:05:34.637751Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:129: TxId: ptqudupgm6dporp466o1, task: 2. Received input for channelId: 1, seqNo: 1, size: 0, chunks: 0, watermark: 0, checkpoint: 1, finished: 0, from: [1:7561464863113356352:2195], expected seqNo: 1
2025-10-15T15:05:34.637766Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:609: SelfId: [1:7561464863113356348:2194], TxId: ptqudupgm6dporp466o1, task: 2. Ctx: {}. took input
2025-10-15T15:05:34.637772Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [1:7561464863113356351:2195], TxId: ptqudupgm6dporp466o1, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-10-15T15:05:34.637880Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:485: [ptqudupgm6dporp466o1-0] Task: 2. [Checkpoint 3.1] Got checkpoint barrier from channel 1
2025-10-15T15:05:34.637895Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [1:7561464863113356351:2195], TxId: ptqudupgm6dporp466o1, task: 1. Ctx: {}. update task runner stats
2025-10-15T15:05:34.637935Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:395: SelfId: [1:7561464863113356350:2194], TxId: ptqudupgm6dporp466o1, task: 2. No watermark 
2025-10-15T15:05:34.637951Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1486: SelfId: [1:7561464863113356348:2194], TxId: ptqudupgm6dporp466o1, task: 2. Ctx: {}. Poll inputs
2025-10-15T15:05:34.637958Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1497: SelfId: [1:7561464863113356348:2194], TxId: ptqudupgm6dporp466o1, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-10-15T15:05:34.637970Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [1:7561464863113356348:2194], TxId: ptqudupgm6dporp466o1, task: 2. Ctx: {}. DoExecuteImpl: 1
2025-10-15T15:05:34.638007Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:965: SelfId: [1:7561464863113356348:2194], TxId: ptqudupgm6dporp466o1, task: 2. Ctx: {}. Input data push finished. Cookie: 0 Watermark: (empty maybe) Ack: 1 TakeInputChannelDataRequests: 1
2025-10-15T15:05:34.638008Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [1:7561464863113356351:2195], TxId: ptqudupgm6dporp466o1, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-10-15T15:05:34.638019Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [1:7561464863113356351:2195], TxId: ptqudupgm6dporp466o1, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-10-15T15:05:34.638032Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:532: SelfId: [1:7561464863113356351:2195], TxId: ptqudupgm6dporp466o1, task: 1. Ctx: {}. About to drain channelId: 1, hasPeer: 1, peerState:(freeSpace:1000000;inFlightBytes:96;inFlightCount:1;)
2025-10-15T15:05:34.638033Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:738: TxId: ptqudupgm6dporp466o1, task: 2. Sending channel data ack to channelId: 1, peer: [1:7561464863113356351:2195], from: [1:7561464863113356348:2194], freeSpace: 1000000, seqNo: 1, finished: 0
2025-10-15T15:05:34.638075Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:179: TxId: ptqudupgm6dporp466o1, task: 1. Received channel data ack for channelId: 1, seqNo: 1, lastSentSeqNo: 1, freeSpace: 1000000, early finish: 0
2025-10-15T15:05:34.638105Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:207: TxId: ptqudupgm6dporp466o1, task: 1. PeerState, peerState:(freeSpace:1000000;inFlightBytes:0;inFlightCount:0;), sentSeqNo: 1, ackSeqNo: 1
2025-10-15T15:05:34.638117Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:220: TxId: ptqudupgm6dporp466o1, task: 1. Resume compute actor
2025-10-15T15:05:34.638129Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1486: SelfId: [1:7561464863113356351:2195], TxId: ptqudupgm6dporp466o1, task: 1. Ctx: {}. Poll inputs
2025-10-15T15:05:34.638142Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1501: SelfId: [1:7561464863113356351:2195], TxId: ptqudupgm6dporp466o1, task: 1. Ctx: {}. Poll sources
2025-10-15T15:05:34.638153Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: df355bdf-bddd72de-e9883691-13e14258 2025-10-15 15:05:34.638 DEBUG ydbd(pid=497468, tid=0x00007B9E67B48640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Run task: 2
2025-10-15T15:05:34.638157Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:530: SelfId: [0:0:0], TxId: ptqudupgm6dporp466o1, task: 1. PQ source. SessionId: 9e332c99-3d83934c-7cf99b60-60640827 GetAsyncInputData freeSpace = 1000000
2025-10-15T15:05:34.638176Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:77: SelfId: [1:7561464863113356351:2195], TxId: ptqudupgm6dporp466o1, task: 1. Ctx: {}. Poll async input 0. Buffer free space: 1000000, read from async input: 0 bytes, 0 rows, finished: 0
2025-10-15T15:05:34.638196Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [1:7561464863113356351:2195], TxId: ptqudupgm6dporp466o1, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-10-15T15:05:34.638199Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:510: SelfId: [1:7561464863113356350:2194], TxId: ptqudupgm6dporp466o1, task: 2. Pending 1 checkpoints to be sent
2025-10-15T15:05:34.638244Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1486: SelfId: [1:7561464863113356348:2194], TxId: ptqudupgm6dporp466o1, task: 2. Ctx: {}. Poll inputs
2025-10-15T15:05:34.638251Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1497: SelfId: [1:7561464863113356348:2194], TxId: ptqudupgm6dporp466o1, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-10-15T15:05:34.638257Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [1:7561464863113356348:2194], TxId: ptqudupgm6dporp466o1, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-10-15T15:05:34.638274Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [1:7561464863113356348:2194], TxId: ptqudupgm6dporp466o1, task: 2. Ctx: {}. update task runner stats
2025-10-15T15:05:34.638300Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [1:7561464863113356351:2195], TxId: ptqudupgm6dporp466o1, task: 1. Ctx: {}. update task runner stats
2025-10-15T15:05:34.638361Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [1:7561464863113356351:2195], TxId: ptqudupgm6dporp466o1, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-10-15T15:05:34.638369Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [1:7561464863113356351:2195], TxId: ptqudupgm6dporp466o1, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-10-15T15:05:34.638388Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:532: SelfId: [1:7561464863113356351:2195], TxId: ptqudupgm6dporp466o1, task: 1. Ctx: {}. About to drain channelId: 1, hasPeer: 1, peerState:(freeSpace:1000000;inFlightBytes:0;inFlightCount:0;)
2025-10-15T15:05:34.638390Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [1:7561464863113356348:2194], TxId: ptqudupgm6dporp466o1, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 1 watermark injected: (empty maybe)
2025-10-15T15:05:34.638403Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:447: [ptqudupgm6dporp466o1-0] Task: 2. [Checkpoint 3.1] Performing task checkpoint
2025-10-15T15:05:34.638410Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:822: SelfId: [1:7561464863113356348:2194], TxId: ptqudupgm6dporp466o1, task: 2. Ctx: {}. Save state
2025-10-15T15:05:34.638419Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:474: [ptqudupgm6dporp466o1-0] Task: 2. [Checkpoint 3.1] CA state saved
2025-10-15T15:05:34.638427Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:449: [ptqudupgm6dporp466o1-0] Task: 2. [Checkpoint 3.1] Injecting checkpoint barrier to outputs
2025-10-15T15:05:34.638451Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:536: [ptqudupgm6dporp466o1-0] Task: 2. [Checkpoint 3.1] Task checkpoint is done. Send to storage
2025-10-15T15:05:34.638458Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [1:7561464863113356348:2194], TxId: ptqudupgm6dporp466o1, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-10-15T15:05:34.638473Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:532: SelfId: [1:7561464863113356348:2194], TxId: ptqudupgm6dporp466o1, task: 2. Ctx: {}. About to drain channelId: 2, hasPeer: 1, peerState:(freeSpace:1000000;inFlightBytes:0;inFlightCount:0;)
2025-10-15T15:05:34.638565Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: df355bdf-bddd72de-e9883691-13e14258 2025-10-15 15:05:34.638 DEBUG ydbd(pid=497468, tid=0x00007B9E67B48640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Run task: 2
2025-10-15T15:05:34.638619Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:566: TxId: ptqudupgm6dporp466o1, task: 2. SendChannelData, channelId: 2, peer: [1:7561464863113356344:2190], chunks: 0, bytes: 0, watermark: 0, checkpoint: 1, seqNo: 1, finished: 0
2025-10-15T15:05:34.638672Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudupgm6dporp466o1, task: 2. no poll, channelId: 1, has inflight messages: [1], last with freeSpace: 1000000, current freeSpace: 1000000
2025-10-15T15:05:34.638682Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [1:7561464863113356348:2194], TxId: ptqudupgm6dporp466o1, task: 2. Ctx: {}. update task runner stats
2025-10-15T15:05:34.638725Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [1:7561464863113356348:2194], TxId: ptqudupgm6dporp466o1, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-10-15T15:05:34.638731Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [1:7561464863113356348:2194], TxId: ptqudupgm6dporp466o1, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-10-15T15:05:34.638743Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:532: SelfId: [1:7561464863113356348:2194], TxId: ptqudupgm6dporp466o1, task: 2. Ctx: {}. About to drain channelId: 2, hasPeer: 1, peerState:(freeSpace:1000000;inFlightBytes:96;inFlightCount:1;)
2025-10-15T15:05:34.638758Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1486: SelfId: [1:7561464863113356348:2194], TxId: ptqudupgm6dporp466o1, task: 2. Ctx: {}. Poll inputs
2025-10-15T15:05:34.638763Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1501: SelfId: [1:7561464863113356348:2194], TxId: ptqudupgm6dporp466o1, task: 2. Ctx: {}. Poll sources
2025-10-15T15:05:34.638768Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [1:7561464863113356348:2194], TxId: ptqudupgm6dporp466o1, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-10-15T15:05:34.638867Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: df355bdf-bddd72de-e9883691-13e14258 2025-10-15 15:05:34.638 DEBUG ydbd(pid=497468, tid=0x00007B9E67B48640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Run task: 2
2025-10-15T15:05:34.638918Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudupgm6dporp466o1, task: 2. no poll, channelId: 1, has inflight messages: [1], last with freeSpace: 1000000, current freeSpace: 1000000
2025-10-15T15:05:34.638925Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [1:7561464863113356348:2194], TxId: ptqudupgm6dporp466o1, task: 2. Ctx: {}. update task runner stats
2025-10-15T15:05:34.638967Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [1:7561464863113356348:2194], TxId: ptqudupgm6dporp466o1, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-10-15T15:05:34.638978Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [1:7561464863113356348:2194], TxId: ptqudupgm6dporp466o1, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-10-15T15:05:34.638989Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:532: SelfId: [1:7561464863113356348:2194], TxId: ptqudupgm6dporp466o1, task: 2. Ctx: {}. About to drain channelId: 2, hasPeer: 1, peerState:(freeSpace:1000000;inFlightBytes:96;inFlightCount:1;)
2025-10-15T15:05:34.639020Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudupgm6dporp466o1, task: 2. no poll, channelId: 1, has inflight messages: [1], last with freeSpace: 1000000, current freeSpace: 1000000
2025-10-15T15:05:34.639048Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:379: [ptqudupgm6dporp466o1-0] [3:1] Got TEvSaveTaskState: task 2
2025-10-15T15:05:34.639167Z :FQ_RESULT_WRITER TRACE: result_writer.cpp:231: TraceId: ptqudupgm6dporp466o1#ptrudupgm3bc7ppsq70v#yandexcloud://my_folder#b8497079-e8975825-15f208e5-15d8eca615#mock_cloud ChannelData Shift, Records: 0 HasError: 0 Size: 0 Rows: 0 FreeSpace: 67108864 Duration: 3.036855s AvgSpeed: 0
2025-10-15T15:05:34.639209Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:179: TxId: ptqudupgm6dporp466o1, task: 2. Received channel data ack for channelId: 2, seqNo: 1, lastSentSeqNo: 1, freeSpace: 67108864, early finish: 0
2025-10-15T15:05:34.639241Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:207: TxId: ptqudupgm6dporp466o1, task: 2. PeerState, peerState:(freeSpace:67108864;inFlightBytes:0;inFlightCount:0;), sentSeqNo: 1, ackSeqNo: 1
2025-10-15T15:05:34.639249Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:220: TxId: ptqudupgm6dporp466o1, task: 2. Resume compute actor
2025-10-15T15:05:34.639263Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1486: SelfId: [1:7561464863113356348:2194], TxId: ptqudupgm6dporp466o1, task: 2. Ctx: {}. Poll inputs
2025-10-15T15:05:34.639267Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1501: SelfId: [1:7561464863113356348:2194], TxId: ptqudupgm6dporp466o1, task: 2. Ctx: {}. Poll sources
2025-10-15T15:05:34.639276Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [1:7561464863113356348:2194], TxId: ptqudupgm6dporp466o1, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-10-15T15:05:34.639342Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: df355bdf-bddd72de-e9883691-13e14258 2025-10-15 15:05:34.639 DEBUG ydbd(pid=497468, tid=0x00007B9E67B48640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Run task: 2
2025-10-15T15:05:34.639400Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [1:7561464863113356348:2194], TxId: ptqudupgm6dporp466o1, task: 2. Ctx: {}. update task runner stats
2025-10-15T15:05:34.639450Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [1:7561464863113356348:2194], TxId: ptqudupgm6dporp466o1, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-10-15T15:05:34.639469Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [1:7561464863113356348:2194], TxId: ptqudupgm6dporp466o1, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-10-15T15:05:34.639484Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:532: SelfId: [1:7561464863113356348:2194], TxId: ptqudupgm6dporp466o1, task: 2. Ctx: {}. About to drain channelId: 2, hasPeer: 1, peerState:(freeSpace:67108864;inFlightBytes:0;inFlightCount:0;)
2025-10-15T15:05:34.639522Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudupgm6dporp466o1, task: 2. no poll, channelId: 1, has inflight messages: [1], last with freeSpace: 1000000, current freeSpace: 1000000
2025-10-15T15:05:34.657320Z :YQL_PROXY TRACE: log.cpp:64: SessionId:  2025-10-15 15:05:34.657 TRACE ydbd(pid=497468, tid=0x00007B9E6B466640) [DQ] task_controller_impl.h:271:  [1:7561464863113356346:2192] ExportStats Summary
2025-10-15T15:05:34.658351Z :FQ_PINGER TRACE: pinger.cpp:250: QueryId: ptqudupgm6dporp466o1, Owner: df355bdf-bddd72de-e9883691-13e142581 Forward ping request: { statistics: "{\"Graph=0\":{\"TaskRunner\":{\"Stage=200322\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":1,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":1,\"count\":1,\"avg\":1,\"max\":1,\"min\":1}},\"Stage=200339\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":1,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":1,\"count\":1,\"avg\":1,\"max\":1,\"min\":1}},\"Stage=Total\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":2,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":2,\"count\":2,\"avg\":1,\"max\":1,\"min\":1}}}}}" }
2025-10-15T15:05:34.658374Z :FQ_PINGER TRACE: pinger.cpp:393: QueryId: ptqudupgm6dporp466o1, Owner: df355bdf-bddd72de-e9883691-13e142581 Forward request Private::PingTask
2025-10-15T15:05:34.670546Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudupgm6dporp466o1, Owner: df355bdf-bddd72de-e9883691-13e142581, Request CP::PingTask with size: 591 bytes
2025-10-15T15:05:34.670776Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "df355bdf-bddd72de-e9883691-13e142581"
query_id {
  value: "ptqudupgm6dporp466o1"
}
statistics: "{\"Graph=0\":{\"TaskRunner\":{\"Stage=200322\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":1,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":1,\"count\":1,\"avg\":1,\"max\":1,\"min\":1}},\"Stage=200339\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":1,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":1,\"count\":1,\"avg\":1,\"max\":1,\"min\":1}},\"Stage=Total\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":2,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":2,\"count\":2,\"avg\":1,\"max\":1,\"min\":1}}}}}"
scope: "yandexcloud://my_folder"
deadline {
  seconds: 1760627131
  nanos: 320903000
}
tenant: "/default"
}
2025-10-15T15:05:34.676831Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:403: [ptqudupgm6dporp466o1-0] [3:1] TEvSaveTaskState Apply: task: 2
2025-10-15T15:05:34.676856Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:418: [ptqudupgm6dporp466o1-0] [3:1] Send TEvSaveTaskStateResult: task: 2
2025-10-15T15:05:34.676933Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:444: [ptqudupgm6dporp466o1-0.3] [3:1] Got TEvSaveTaskStateResult; task 2, status: OK, size: 29
2025-10-15T15:05:34.676948Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:454: [ptqudupgm6dporp466o1-0.3] [3:1] Task state saved, need 1 more acks
2025-10-15T15:05:34.677044Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:403: [ptqudupgm6dporp466o1-0] [3:1] TEvSaveTaskState Apply: task: 1
2025-10-15T15:05:34.677061Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:418: [ptqudupgm6dporp466o1-0] [3:1] Send TEvSaveTaskStateResult: task: 1
2025-10-15T15:05:34.677170Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:444: [ptqudupgm6dporp466o1-0.3] [3:1] Got TEvSaveTaskStateResult; task 1, status: OK, size: 102
2025-10-15T15:05:34.677181Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:454: [ptqudupgm6dporp466o1-0.3] [3:1] Task state saved, need 0 more acks
2025-10-15T15:05:34.677193Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:467: [ptqudupgm6dporp466o1-0.3] [3:1] Got all acks, changing checkpoint status to 'PendingCommit'
2025-10-15T15:05:34.677238Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:275: [ptqudupgm6dporp466o1-0.3] [3:1] Got TEvSetCheckpointPendingCommitStatusRequest
2025-10-15T15:05:34.697330Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:620: RowDispatcher: Send ping to [1:7561464858818388987:2130]
2025-10-15T15:05:34.697374Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1164: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-10-15T15:05:34.697413Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: df355bdf-bddd72de-e9883691-13e142586, Host: ghrun-lvxbqnxafi, Tenant: /default
2025-10-15T15:05:34.697449Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:314: Coordinator: TEvPing received, [1:7561464858818388904:2069]
2025-10-15T15:05:34.697474Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:317: Coordinator: Send TEvPong to [1:7561464858818388904:2069]
2025-10-15T15:05:34.697487Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:626: RowDispatcher: NActors::TEvents::TEvPong
2025-10-15T15:05:34.709591Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: df355bdf-bddd72de-e9883691-13e142586, Host: ghrun-lvxbqnxafi, Tenant: /default, Request CP::GetTask with size: 68 bytes
2025-10-15T15:05:34.709710Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/default"
owner_id: "df355bdf-bddd72de-e9883691-13e142586"
host: "ghrun-lvxbqnxafi"
node_id: 1
}
2025-10-15T15:05:34.746782Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-10-15T15:05:34.746872Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: df355bdf-bddd72de-e9883691-13e142586, Host: ghrun-lvxbqnxafi, Tenant: /default, Got CP::GetTask Response
2025-10-15T15:05:34.748774Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-10-15T15:05:34.748793Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-10-15T15:05:34.754398Z :FQ_PINGER TRACE: pinger.cpp:400: QueryId: ptqudupgm6dporp466o1, Owner: df355bdf-bddd72de-e9883691-13e142581 Request Private::PingTask
2025-10-15T15:05:34.767707Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {expired_at { seconds: 1760540735 nanos: 709000000 } } SUCCESS
2025-10-15T15:05:34.767808Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudupgm6dporp466o1, Owner: df355bdf-bddd72de-e9883691-13e142581, Got CP::PingTaskResponse
2025-10-15T15:05:34.768307Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudupgm6dporp466o1, Owner: df355bdf-bddd72de-e9883691-13e142581, Request CP::PingTask with size: 114 bytes
2025-10-15T15:05:34.768460Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "df355bdf-bddd72de-e9883691-13e142581"
query_id {
  value: "ptqudupgm6dporp466o1"
}
scope: "yandexcloud://my_folder"
deadline {
  seconds: 1760627131
  nanos: 320903000
}
tenant: "/default"
}
2025-10-15T15:05:34.768856Z :FQ_PINGER TRACE: pinger.cpp:338: QueryId: ptqudupgm6dporp466o1, Owner: df355bdf-bddd72de-e9883691-13e142581 Ping response success: { expired_at { seconds: 1760540735 nanos: 709000000 } }
2025-10-15T15:05:34.768904Z :FQ_RUN_ACTOR TRACE: run_actor.cpp:861: QueryId: ptqudupgm6dporp466o1 Forward ping response. Success: 1. Cookie: 6
2025-10-15T15:05:34.771342Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:290: [ptqudupgm6dporp466o1-0.3] [3:1] Status updated to 'PendingCommit'
2025-10-15T15:05:34.771369Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:292: [ptqudupgm6dporp466o1-0.3] [3:1] Send TEvSetCheckpointPendingCommitStatusResponse
2025-10-15T15:05:34.771621Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:479: [ptqudupgm6dporp466o1-0.3] [3:1] Got TEvSetCheckpointPendingCommitStatusResponse
2025-10-15T15:05:34.771669Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:494: [ptqudupgm6dporp466o1-0.3] [3:1] Checkpoint status changed to 'PendingCommit', committing states to 1 actor(s)
2025-10-15T15:05:34.771737Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:746: SelfId: [1:7561464863113356351:2195], TxId: ptqudupgm6dporp466o1, task: 1. Ctx: {}. Commit state
2025-10-15T15:05:34.771778Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:510: [ptqudupgm6dporp466o1-0.3] [3:1] Got TEvStateCommitted; task: 1
2025-10-15T15:05:34.771803Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:519: [ptqudupgm6dporp466o1-0.3] [3:1] State committed [1:7561464863113356351:2195], need 0 more acks
2025-10-15T15:05:34.771817Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:521: [ptqudupgm6dporp466o1-0.3] [3:1] Got all acks, changing checkpoint status to 'Completed'
2025-10-15T15:05:34.771846Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:300: [ptqudupgm6dporp466o1-0.3] [3:1] Got TEvCompleteCheckpointRequest
2025-10-15T15:05:34.828339Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {expired_at { seconds: 1760540735 nanos: 792000000 } } SUCCESS
2025-10-15T15:05:34.828427Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudupgm6dporp466o1, Owner: df355bdf-bddd72de-e9883691-13e142581, Got CP::PingTaskResponse
2025-10-15T15:05:34.829233Z :FQ_PINGER TRACE: pinger.cpp:338: QueryId: ptqudupgm6dporp466o1, Owner: df355bdf-bddd72de-e9883691-13e142581 Ping response success: { expired_at { seconds: 1760540735 nanos: 792000000 } }
2025-10-15T15:05:34.842999Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:318: [ptqudupgm6dporp466o1-0.3] [3:1] Status updated to 'Completed'
2025-10-15T15:05:34.843028Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:325: [ptqudupgm6dporp466o1-0.3] [3:1] Send TEvCompleteCheckpointResponse
2025-10-15T15:05:34.843094Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:542: [ptqudupgm6dporp466o1-0.3] [3:1] Got TEvCompleteCheckpointResponse
2025-10-15T15:05:34.843114Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:557: [ptqudupgm6dporp466o1-0.3] [3:1] Checkpoint completed
2025-10-15T15:05:35.329401Z :FQ_PINGER TRACE: pinger.cpp:400: QueryId: ptqudupgm6dporp466o1, Owner: df355bdf-bddd72de-e9883691-13e142581 Request Private::PingTask
2025-10-15T15:05:35.346698Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudupgm6dporp466o1, Owner: df355bdf-bddd72de-e9883691-13e142581, Request CP::PingTask with size: 114 bytes
2025-10-15T15:05:35.346863Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "df355bdf-bddd72de-e9883691-13e142581"
query_id {
  value: "ptqudupgm6dporp466o1"
}
scope: "yandexcloud://my_folder"
deadline {
  seconds: 1760627131
  nanos: 320903000
}
tenant: "/default"
}
2025-10-15T15:05:35.391629Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {expired_at { seconds: 1760540736 nanos: 364000000 } } SUCCESS
2025-10-15T15:05:35.391691Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudupgm6dporp466o1, Owner: df355bdf-bddd72de-e9883691-13e142581, Got CP::PingTaskResponse
2025-10-15T15:05:35.398784Z :FQ_PINGER TRACE: pinger.cpp:338: QueryId: ptqudupgm6dporp466o1, Owner: df355bdf-bddd72de-e9883691-13e142581 Ping response success: { expired_at { seconds: 1760540736 nanos: 364000000 } }
2025-10-15T15:05:35.537444Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:351: [ptqudupgm6dporp466o1-0.3] Got TEvScheduleCheckpointing
2025-10-15T15:05:35.537467Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:327: [ptqudupgm6dporp466o1-0.3] [3:2] Registering new checkpoint in storage
2025-10-15T15:05:35.537507Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:223: [ptqudupgm6dporp466o1-0.3] [3:2] Got TEvCreateCheckpointRequest
2025-10-15T15:05:35.614890Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:265: [ptqudupgm6dporp466o1-0.3] [3:2] Checkpoint created
2025-10-15T15:05:35.614924Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:267: [ptqudupgm6dporp466o1-0.3] [3:2] Send TEvCreateCheckpointResponse
2025-10-15T15:05:35.614996Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:367: [ptqudupgm6dporp466o1-0.3] [3:2] Got TEvCreateCheckpointResponse
2025-10-15T15:05:35.615021Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:413: [ptqudupgm6dporp466o1-0.3] [3:2] Checkpoint successfully created, going to inject barriers to 1 actor(s)
2025-10-15T15:05:35.615073Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:239: [ptqudupgm6dporp466o1-0] Task: 1. [Checkpoint 3.2] TEvInjectCheckpoint
2025-10-15T15:05:35.615107Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1486: SelfId: [1:7561464863113356351:2195], TxId: ptqudupgm6dporp466o1, task: 1. Ctx: {}. Poll inputs
2025-10-15T15:05:35.615115Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1497: SelfId: [1:7561464863113356351:2195], TxId: ptqudupgm6dporp466o1, task: 1. Ctx: {}. Skip polling sources because of pending checkpoint
2025-10-15T15:05:35.615125Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [1:7561464863113356351:2195], TxId: ptqudupgm6dporp466o1, task: 1. Ctx: {}. DoExecuteImpl: 1
2025-10-15T15:05:35.615298Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:510: SelfId: [1:7561464863113356353:2195], TxId: ptqudupgm6dporp466o1, task: 1. Pending 1 checkpoints to be sent
2025-10-15T15:05:35.615348Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [1:7561464863113356351:2195], TxId: ptqudupgm6dporp466o1, task: 1. Ctx: {}. update task runner stats
2025-10-15T15:05:35.615470Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [1:7561464863113356351:2195], TxId: ptqudupgm6dporp466o1, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 1 watermark injected: (empty maybe)
2025-10-15T15:05:35.615489Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:447: [ptqudupgm6dporp466o1-0] Task: 1. [Checkpoint 3.2] Performing task checkpoint
2025-10-15T15:05:35.615500Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:822: SelfId: [1:7561464863113356351:2195], TxId: ptqudupgm6dporp466o1, task: 1. Ctx: {}. Save state
2025-10-15T15:05:35.615528Z :KQP_COMPUTE DEBUG: dq_pq_read_actor_base.cpp:89: SelfId: [0:0:0], TxId: ptqudupgm6dporp466o1, task: 1. PQ source. SessionId: 9e332c99-3d83934c-7cf99b60-60640827 SaveState, offsets: 
2025-10-15T15:05:35.615578Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:474: [ptqudupgm6dporp466o1-0] Task: 1. [Checkpoint 3.2] CA state saved
2025-10-15T15:05:35.615590Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:449: [ptqudupgm6dporp466o1-0] Task: 1. [Checkpoint 3.2] Injecting checkpoint barrier to outputs
2025-10-15T15:05:35.615614Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:536: [ptqudupgm6dporp466o1-0] Task: 1. [Checkpoint 3.2] Task checkpoint is done. Send to storage
2025-10-15T15:05:35.615622Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [1:7561464863113356351:2195], TxId: ptqudupgm6dporp466o1, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-10-15T15:05:35.615639Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:532: SelfId: [1:7561464863113356351:2195], TxId: ptqudupgm6dporp466o1, task: 1. Ctx: {}. About to drain channelId: 1, hasPeer: 1, peerState:(freeSpace:1000000;inFlightBytes:0;inFlightCount:0;)
2025-10-15T15:05:35.615667Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:379: [ptqudupgm6dporp466o1-0] [3:2] Got TEvSaveTaskState: task 1
2025-10-15T15:05:35.615716Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:566: TxId: ptqudupgm6dporp466o1, task: 1. SendChannelData, channelId: 1, peer: [1:7561464863113356348:2194], chunks: 0, bytes: 0, watermark: 0, checkpoint: 1, seqNo: 2, finished: 0
2025-10-15T15:05:35.615752Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1486: SelfId: [1:7561464863113356351:2195], TxId: ptqudupgm6dporp466o1, task: 1. Ctx: {}. Poll inputs
2025-10-15T15:05:35.615759Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1501: SelfId: [1:7561464863113356351:2195], TxId: ptqudupgm6dporp466o1, task: 1. Ctx: {}. Poll sources
2025-10-15T15:05:35.615788Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:530: SelfId: [0:0:0], TxId: ptqudupgm6dporp466o1, task: 1. PQ source. SessionId: 9e332c99-3d83934c-7cf99b60-60640827 GetAsyncInputData freeSpace = 1000000
2025-10-15T15:05:35.615810Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:77: SelfId: [1:7561464863113356351:2195], TxId: ptqudupgm6dporp466o1, task: 1. Ctx: {}. Poll async input 0. Buffer free space: 1000000, read from async input: 0 bytes, 0 rows, finished: 0
2025-10-15T15:05:35.615815Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:129: TxId: ptqudupgm6dporp466o1, task: 2. Received input for channelId: 1, seqNo: 2, size: 0, chunks: 0, watermark: 0, checkpoint: 1, finished: 0, from: [1:7561464863113356352:2195], expected seqNo: 2
2025-10-15T15:05:35.615833Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:609: SelfId: [1:7561464863113356348:2194], TxId: ptqudupgm6dporp466o1, task: 2. Ctx: {}. took input
2025-10-15T15:05:35.615839Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [1:7561464863113356351:2195], TxId: ptqudupgm6dporp466o1, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-10-15T15:05:35.615883Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:485: [ptqudupgm6dporp466o1-0] Task: 2. [Checkpoint 3.2] Got checkpoint barrier from channel 1
2025-10-15T15:05:35.615924Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:395: SelfId: [1:7561464863113356350:2194], TxId: ptqudupgm6dporp466o1, task: 2. No watermark 
2025-10-15T15:05:35.615949Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [1:7561464863113356351:2195], TxId: ptqudupgm6dporp466o1, task: 1. Ctx: {}. update task runner stats
2025-10-15T15:05:35.616004Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1486: SelfId: [1:7561464863113356348:2194], TxId: ptqudupgm6dporp466o1, task: 2. Ctx: {}. Poll inputs
2025-10-15T15:05:35.616008Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [1:7561464863113356351:2195], TxId: ptqudupgm6dporp466o1, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-10-15T15:05:35.616015Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1497: SelfId: [1:7561464863113356348:2194], TxId: ptqudupgm6dporp466o1, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-10-15T15:05:35.616016Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [1:7561464863113356351:2195], TxId: ptqudupgm6dporp466o1, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-10-15T15:05:35.616023Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [1:7561464863113356348:2194], TxId: ptqudupgm6dporp466o1, task: 2. Ctx: {}. DoExecuteImpl: 1
2025-10-15T15:05:35.616029Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:532: SelfId: [1:7561464863113356351:2195], TxId: ptqudupgm6dporp466o1, task: 1. Ctx: {}. About to drain channelId: 1, hasPeer: 1, peerState:(freeSpace:1000000;inFlightBytes:96;inFlightCount:1;)
2025-10-15T15:05:35.616056Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:965: SelfId: [1:7561464863113356348:2194], TxId: ptqudupgm6dporp466o1, task: 2. Ctx: {}. Input data push finished. Cookie: 1 Watermark: (empty maybe) Ack: 1 TakeInputChannelDataRequests: 1
2025-10-15T15:05:35.616074Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:738: TxId: ptqudupgm6dporp466o1, task: 2. Sending channel data ack to channelId: 1, peer: [1:7561464863113356351:2195], from: [1:7561464863113356348:2194], freeSpace: 1000000, seqNo: 2, finished: 0
2025-10-15T15:05:35.616191Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: df355bdf-bddd72de-e9883691-13e14258 2025-10-15 15:05:35.616 DEBUG ydbd(pid=497468, tid=0x00007B9E67B48640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Run task: 2
2025-10-15T15:05:35.616248Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:510: SelfId: [1:7561464863113356350:2194], TxId: ptqudupgm6dporp466o1, task: 2. Pending 1 checkpoints to be sent
2025-10-15T15:05:35.616270Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1486: SelfId: [1:7561464863113356348:2194], TxId: ptqudupgm6dporp466o1, task: 2. Ctx: {}. Poll inputs
2025-10-15T15:05:35.616300Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1497: SelfId: [1:7561464863113356348:2194], TxId: ptqudupgm6dporp466o1, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-10-15T15:05:35.616307Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [1:7561464863113356348:2194], TxId: ptqudupgm6dporp466o1, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-10-15T15:05:35.616327Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [1:7561464863113356348:2194], TxId: ptqudupgm6dporp466o1, task: 2. Ctx: {}. update task runner stats
2025-10-15T15:05:35.616413Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [1:7561464863113356348:2194], TxId: ptqudupgm6dporp466o1, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 1 watermark injected: (empty maybe)
2025-10-15T15:05:35.616426Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:447: [ptqudupgm6dporp466o1-0] Task: 2. [Checkpoint 3.2] Performing task checkpoint
2025-10-15T15:05:35.616432Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:822: SelfId: [1:7561464863113356348:2194], TxId: ptqudupgm6dporp466o1, task: 2. Ctx: {}. Save state
2025-10-15T15:05:35.616440Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:474: [ptqudupgm6dporp466o1-0] Task: 2. [Checkpoint 3.2] CA state saved
2025-10-15T15:05:35.616448Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:449: [ptqudupgm6dporp466o1-0] Task: 2. [Checkpoint 3.2] Injecting checkpoint barrier to outputs
2025-10-15T15:05:35.616469Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:536: [ptqudupgm6dporp466o1-0] Task: 2. [Checkpoint 3.2] Task checkpoint is done. Send to storage
2025-10-15T15:05:35.616768Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [1:7561464863113356348:2194], TxId: ptqudupgm6dporp466o1, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-10-15T15:05:35.616790Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:532: SelfId: [1:7561464863113356348:2194], TxId: ptqudupgm6dporp466o1, task: 2. Ctx: {}. About to drain channelId: 2, hasPeer: 1, peerState:(freeSpace:67108864;inFlightBytes:0;inFlightCount:0;)
2025-10-15T15:05:35.616906Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: df355bdf-bddd72de-e9883691-13e14258 2025-10-15 15:05:35.616 DEBUG ydbd(pid=497468, tid=0x00007B9E67B48640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Run task: 2
2025-10-15T15:05:35.616979Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:566: TxId: ptqudupgm6dporp466o1, task: 2. SendChannelData, channelId: 2, peer: [1:7561464863113356344:2190], chunks: 0, bytes: 0, watermark: 0, checkpoint: 1, seqNo: 2, finished: 0
2025-10-15T15:05:35.617018Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudupgm6dporp466o1, task: 2. no poll, channelId: 1, has inflight messages: [2], last with freeSpace: 1000000, current freeSpace: 1000000
2025-10-15T15:05:35.617029Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [1:7561464863113356348:2194], TxId: ptqudupgm6dporp466o1, task: 2. Ctx: {}. update task runner stats
2025-10-15T15:05:35.617125Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [1:7561464863113356348:2194], TxId: ptqudupgm6dporp466o1, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-10-15T15:05:35.617135Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [1:7561464863113356348:2194], TxId: ptqudupgm6dporp466o1, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-10-15T15:05:35.617147Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:532: SelfId: [1:7561464863113356348:2194], TxId: ptqudupgm6dporp466o1, task: 2. Ctx: {}. About to drain channelId: 2, hasPeer: 1, peerState:(freeSpace:67108864;inFlightBytes:96;inFlightCount:1;)
2025-10-15T15:05:35.617168Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1486: SelfId: [1:7561464863113356348:2194], TxId: ptqudupgm6dporp466o1, task: 2. Ctx: {}. Poll inputs
2025-10-15T15:05:35.617176Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1501: SelfId: [1:7561464863113356348:2194], TxId: ptqudupgm6dporp466o1, task: 2. Ctx: {}. Poll sources
2025-10-15T15:05:35.617181Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [1:7561464863113356348:2194], TxId: ptqudupgm6dporp466o1, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-10-15T15:05:35.617290Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: df355bdf-bddd72de-e9883691-13e14258 2025-10-15 15:05:35.617 DEBUG ydbd(pid=497468, tid=0x00007B9E67B48640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Run task: 2
2025-10-15T15:05:35.617362Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudupgm6dporp466o1, task: 2. no poll, channelId: 1, has inflight messages: [2], last with freeSpace: 1000000, current freeSpace: 1000000
2025-10-15T15:05:35.617373Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [1:7561464863113356348:2194], TxId: ptqudupgm6dporp466o1, task: 2. Ctx: {}. update task runner stats
2025-10-15T15:05:35.617414Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [1:7561464863113356348:2194], TxId: ptqudupgm6dporp466o1, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-10-15T15:05:35.617420Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [1:7561464863113356348:2194], TxId: ptqudupgm6dporp466o1, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-10-15T15:05:35.617430Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:532: SelfId: [1:7561464863113356348:2194], TxId: ptqudupgm6dporp466o1, task: 2. Ctx: {}. About to drain channelId: 2, hasPeer: 1, peerState:(freeSpace:67108864;inFlightBytes:96;inFlightCount:1;)
2025-10-15T15:05:35.617487Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudupgm6dporp466o1, task: 2. no poll, channelId: 1, has inflight messages: [2], last with freeSpace: 1000000, current freeSpace: 1000000
2025-10-15T15:05:35.617516Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:179: TxId: ptqudupgm6dporp466o1, task: 1. Received channel data ack for channelId: 1, seqNo: 2, lastSentSeqNo: 2, freeSpace: 1000000, early finish: 0
2025-10-15T15:05:35.617536Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:207: TxId: ptqudupgm6dporp466o1, task: 1. PeerState, peerState:(freeSpace:1000000;inFlightBytes:0;inFlightCount:0;), sentSeqNo: 2, ackSeqNo: 2
2025-10-15T15:05:35.617543Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:220: TxId: ptqudupgm6dporp466o1, task: 1. Resume compute actor
2025-10-15T15:05:35.617556Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1486: SelfId: [1:7561464863113356351:2195], TxId: ptqudupgm6dporp466o1, task: 1. Ctx: {}. Poll inputs
2025-10-15T15:05:35.617561Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1501: SelfId: [1:7561464863113356351:2195], TxId: ptqudupgm6dporp466o1, task: 1. Ctx: {}. Poll sources
2025-10-15T15:05:35.617580Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:530: SelfId: [0:0:0], TxId: ptqudupgm6dporp466o1, task: 1. PQ source. SessionId: 9e332c99-3d83934c-7cf99b60-60640827 GetAsyncInputData freeSpace = 1000000
2025-10-15T15:05:35.617598Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:77: SelfId: [1:7561464863113356351:2195], TxId: ptqudupgm6dporp466o1, task: 1. Ctx: {}. Poll async input 0. Buffer free space: 1000000, read from async input: 0 bytes, 0 rows, finished: 0
2025-10-15T15:05:35.617635Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [1:7561464863113356351:2195], TxId: ptqudupgm6dporp466o1, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-10-15T15:05:35.617754Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: df355bdf-bddd72de-e9883691-13e14258 2025-10-15 15:05:35.617 DEBUG ydbd(pid=497468, tid=0x00007B9E67B48640) [DQ] tasks_runner_local.cpp:267: {TODO/1} Run task: 1
2025-10-15T15:05:35.617805Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [1:7561464863113356351:2195], TxId: ptqudupgm6dporp466o1, task: 1. Ctx: {}. update task runner stats
2025-10-15T15:05:35.617863Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [1:7561464863113356351:2195], TxId: ptqudupgm6dporp466o1, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-10-15T15:05:35.617869Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [1:7561464863113356351:2195], TxId: ptqudupgm6dporp466o1, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-10-15T15:05:35.617883Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:532: SelfId: [1:7561464863113356351:2195], TxId: ptqudupgm6dporp466o1, task: 1. Ctx: {}. About to drain channelId: 1, hasPeer: 1, peerState:(freeSpace:1000000;inFlightBytes:0;inFlightCount:0;)
2025-10-15T15:05:35.617926Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:379: [ptqudupgm6dporp466o1-0] [3:2] Got TEvSaveTaskState: task 2
2025-10-15T15:05:35.618016Z :FQ_RESULT_WRITER TRACE: result_writer.cpp:231: TraceId: ptqudupgm6dporp466o1#ptrudupgm3bc7ppsq70v#yandexcloud://my_folder#b8497079-e8975825-15f208e5-15d8eca615#mock_cloud ChannelData Shift, Records: 0 HasError: 0 Size: 0 Rows: 0 FreeSpace: 67108864 Duration: 4.015705s AvgSpeed: 0
2025-10-15T15:05:35.618050Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:179: TxId: ptqudupgm6dporp466o1, task: 2. Received channel data ack for channelId: 2, seqNo: 2, lastSentSeqNo: 2, freeSpace: 67108864, early finish: 0
2025-10-15T15:05:35.618069Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:207: TxId: ptqudupgm6dporp466o1, task: 2. PeerState, peerState:(freeSpace:67108864;inFlightBytes:0;inFlightCount:0;), sentSeqNo: 2, ackSeqNo: 2
2025-10-15T15:05:35.618075Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:220: TxId: ptqudupgm6dporp466o1, task: 2. Resume compute actor
2025-10-15T15:05:35.618087Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1486: SelfId: [1:7561464863113356348:2194], TxId: ptqudupgm6dporp466o1, task: 2. Ctx: {}. Poll inputs
2025-10-15T15:05:35.618092Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1501: SelfId: [1:7561464863113356348:2194], TxId: ptqudupgm6dporp466o1, task: 2. Ctx: {}. Poll sources
2025-10-15T15:05:35.618098Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [1:7561464863113356348:2194], TxId: ptqudupgm6dporp466o1, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-10-15T15:05:35.618198Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: df355bdf-bddd72de-e9883691-13e14258 2025-10-15 15:05:35.618 DEBUG ydbd(pid=497468, tid=0x00007B9E67B48640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Run task: 2
2025-10-15T15:05:35.618243Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [1:7561464863113356348:2194], TxId: ptqudupgm6dporp466o1, task: 2. Ctx: {}. update task runner stats
2025-10-15T15:05:35.618314Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [1:7561464863113356348:2194], TxId: ptqudupgm6dporp466o1, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-10-15T15:05:35.618322Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [1:7561464863113356348:2194], TxId: ptqudupgm6dporp466o1, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-10-15T15:05:35.618335Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:532: SelfId: [1:7561464863113356348:2194], TxId: ptqudupgm6dporp466o1, task: 2. Ctx: {}. About to drain channelId: 2, hasPeer: 1, peerState:(freeSpace:67108864;inFlightBytes:0;inFlightCount:0;)
2025-10-15T15:05:35.618373Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudupgm6dporp466o1, task: 2. no poll, channelId: 1, has inflight messages: [2], last with freeSpace: 1000000, current freeSpace: 1000000
2025-10-15T15:05:35.635306Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:403: [ptqudupgm6dporp466o1-0] [3:2] TEvSaveTaskState Apply: task: 1
2025-10-15T15:05:35.635325Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:418: [ptqudupgm6dporp466o1-0] [3:2] Send TEvSaveTaskStateResult: task: 1
2025-10-15T15:05:35.635466Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:444: [ptqudupgm6dporp466o1-0.3] [3:2] Got TEvSaveTaskStateResult; task 1, status: OK, size: 102
2025-10-15T15:05:35.635480Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:454: [ptqudupgm6dporp466o1-0.3] [3:2] Task state saved, need 1 more acks
2025-10-15T15:05:35.635647Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:403: [ptqudupgm6dporp466o1-0] [3:2] TEvSaveTaskState Apply: task: 2
2025-10-15T15:05:35.635669Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:418: [ptqudupgm6dporp466o1-0] [3:2] Send TEvSaveTaskStateResult: task: 2
2025-10-15T15:05:35.635817Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:444: [ptqudupgm6dporp466o1-0.3] [3:2] Got TEvSaveTaskStateResult; task 2, status: OK, size: 29
2025-10-15T15:05:35.635829Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:454: [ptqudupgm6dporp466o1-0.3] [3:2] Task state saved, need 0 more acks
2025-10-15T15:05:35.635837Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:467: [ptqudupgm6dporp466o1-0.3] [3:2] Got all acks, changing checkpoint status to 'PendingCommit'
2025-10-15T15:05:35.635871Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:275: [ptqudupgm6dporp466o1-0.3] [3:2] Got TEvSetCheckpointPendingCommitStatusRequest
2025-10-15T15:05:35.658596Z :YQL_PROXY TRACE: log.cpp:64: SessionId:  2025-10-15 15:05:35.658 TRACE ydbd(pid=497468, tid=0x00007B9E6A15C640) [DQ] task_controller_impl.h:271:  [1:7561464863113356346:2192] ExportStats Summary
2025-10-15T15:05:35.659491Z :FQ_PINGER TRACE: pinger.cpp:250: QueryId: ptqudupgm6dporp466o1, Owner: df355bdf-bddd72de-e9883691-13e142581 Forward ping request: { statistics: "{\"Graph=0\":{\"TaskRunner\":{\"Stage=200322\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":1,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":1,\"count\":1,\"avg\":1,\"max\":1,\"min\":1}},\"Stage=200339\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":1,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":1,\"count\":1,\"avg\":1,\"max\":1,\"min\":1}},\"Stage=Total\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":2,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":2,\"count\":2,\"avg\":1,\"max\":1,\"min\":1}}}}}" }
2025-10-15T15:05:35.659510Z :FQ_PINGER TRACE: pinger.cpp:393: QueryId: ptqudupgm6dporp466o1, Owner: df355bdf-bddd72de-e9883691-13e142581 Forward request Private::PingTask
2025-10-15T15:05:35.669887Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudupgm6dporp466o1, Owner: df355bdf-bddd72de-e9883691-13e142581, Request CP::PingTask with size: 591 bytes
2025-10-15T15:05:35.670050Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "df355bdf-bddd72de-e9883691-13e142581"
query_id {
  value: "ptqudupgm6dporp466o1"
}
statistics: "{\"Graph=0\":{\"TaskRunner\":{\"Stage=200322\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":1,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":1,\"count\":1,\"avg\":1,\"max\":1,\"min\":1}},\"Stage=200339\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":1,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":1,\"count\":1,\"avg\":1,\"max\":1,\"min\":1}},\"Stage=Total\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":2,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":2,\"count\":2,\"avg\":1,\"max\":1,\"min\":1}}}}}"
scope: "yandexcloud://my_folder"
deadline {
  seconds: 1760627131
  nanos: 320903000
}
tenant: "/default"
}
2025-10-15T15:05:35.691288Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:290: [ptqudupgm6dporp466o1-0.3] [3:2] Status updated to 'PendingCommit'
2025-10-15T15:05:35.691310Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:292: [ptqudupgm6dporp466o1-0.3] [3:2] Send TEvSetCheckpointPendingCommitStatusResponse
2025-10-15T15:05:35.691549Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:479: [ptqudupgm6dporp466o1-0.3] [3:2] Got TEvSetCheckpointPendingCommitStatusResponse
2025-10-15T15:05:35.691568Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:494: [ptqudupgm6dporp466o1-0.3] [3:2] Checkpoint status changed to 'PendingCommit', committing states to 1 actor(s)
2025-10-15T15:05:35.691625Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:746: SelfId: [1:7561464863113356351:2195], TxId: ptqudupgm6dporp466o1, task: 1. Ctx: {}. Commit state
2025-10-15T15:05:35.691666Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:510: [ptqudupgm6dporp466o1-0.3] [3:2] Got TEvStateCommitted; task: 1
2025-10-15T15:05:35.691679Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:519: [ptqudupgm6dporp466o1-0.3] [3:2] State committed [1:7561464863113356351:2195], need 0 more acks
2025-10-15T15:05:35.691686Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:521: [ptqudupgm6dporp466o1-0.3] [3:2] Got all acks, changing checkpoint status to 'Completed'
2025-10-15T15:05:35.691708Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:300: [ptqudupgm6dporp466o1-0.3] [3:2] Got TEvCompleteCheckpointRequest
2025-10-15T15:05:35.693709Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-10-15T15:05:35.698406Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: df355bdf-bddd72de-e9883691-13e142587, Host: ghrun-lvxbqnxafi, Tenant: /default
2025-10-15T15:05:35.707414Z :YQ_CONTROL_PLANE_STORAGE TRACE: nodes_health_check.cpp:38: NodesHealthCheckRequest: {tenant: "/default"
node {
  node_id: 1
  instance_id: "5a3fc6b8-422b523b-2e762682-2fd3a581"
  hostname: "ghrun-lvxbqnxafi"
  active_workers: 2
  memory_allocated: 17179869184
  interconnect_port: 29743
  node_address: "127.0.1.1"
}
}
2025-10-15T15:05:35.707670Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: df355bdf-bddd72de-e9883691-13e142587, Host: ghrun-lvxbqnxafi, Tenant: /default, Request CP::GetTask with size: 68 bytes
2025-10-15T15:05:35.707847Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/default"
owner_id: "df355bdf-bddd72de-e9883691-13e142587"
host: "ghrun-lvxbqnxafi"
node_id: 1
}
2025-10-15T15:05:35.734353Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-10-15T15:05:35.734563Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: df355bdf-bddd72de-e9883691-13e142587, Host: ghrun-lvxbqnxafi, Tenant: /default, Got CP::GetTask Response
2025-10-15T15:05:35.737208Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-10-15T15:05:35.737228Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {expired_at { seconds: 1760540736 nanos: 695000000 } } SUCCESS
2025-10-15T15:05:35.737244Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-10-15T15:05:35.737278Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudupgm6dporp466o1, Owner: df355bdf-bddd72de-e9883691-13e142581, Got CP::PingTaskResponse
2025-10-15T15:05:35.742168Z :FQ_PINGER TRACE: pinger.cpp:338: QueryId: ptqudupgm6dporp466o1, Owner: df355bdf-bddd72de-e9883691-13e142581 Ping response success: { expired_at { seconds: 1760540736 nanos: 695000000 } }
2025-10-15T15:05:35.742257Z :FQ_RUN_ACTOR TRACE: run_actor.cpp:861: QueryId: ptqudupgm6dporp466o1 Forward ping response. Success: 1. Cookie: 6
