2025-10-26T16:22:18.548437Z :GRPC_SERVER NOTICE: Grpc simple request proxy started, nodeid# 2
2025-10-26T16:22:18.548534Z :GRPC_SERVER NOTICE: Grpc simple request proxy started, nodeid# 2
2025-10-26T16:22:18.548641Z :YQ_CONTROL_PLANE_PROXY DEBUG: Starting yandex query control plane proxy. Actor id: [2:7565566588377063839:11]
2025-10-26T16:22:18.549050Z :FQ_LOG_UPDATER DEBUG: Updated YQL logs priority: 8
2025-10-26T16:22:18.549065Z :FQ_LOG_UPDATER CRIT: Failed to deliver subscription request to config dispatcher.
2025-10-26T16:22:18.549072Z :YQ_CONTROL_PLANE_STORAGE INFO: Starting ydb control plane storage service. Actor id: [2:7565566588377063837:4092]
2025-10-26T16:22:18.549331Z :FQ_QUOTA_PROXY INFO: STARTED
2025-10-26T16:22:18.549360Z :FQ_CONTROL_PLANE_CONFIG DEBUG: STARTING: [2:7565566588377063838:10]
2025-10-26T16:22:18.549443Z :YQ_RATE_LIMITER DEBUG: Run create coordination node "local/RateLimiter_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/rate_limiter" actor
2025-10-26T16:22:18.549446Z :YQ_RATE_LIMITER DEBUG: Call create coordination node "local/RateLimiter_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/rate_limiter"
2025-10-26T16:22:18.549448Z :YQ_RATE_LIMITER DEBUG: Call create coordination node "local/RateLimiter_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/rate_limiter"
2025-10-26T16:22:18.549501Z :YQ_RATE_LIMITER INFO: Bootstraping with config: { Enabled: true ControlPlaneEnabled: true DataPlaneEnabled: true Database { Endpoint: "localhost:24793" Database: "local" TablePrefix: "RateLimiter_b07d7bc2-0090-453a-b348-ea3efaa6bbf0" } Limiters { CoordinationNodePath: "rate_limiter" } }
2025-10-26T16:22:18.549586Z :YQ_CONTROL_PLANE_STORAGE DEBUG: Run create table "local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/idempotency_keys" actor
2025-10-26T16:22:18.549608Z :YQ_CONTROL_PLANE_STORAGE DEBUG: Run create table "local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/result_sets" actor
2025-10-26T16:22:18.549619Z :YQ_CONTROL_PLANE_STORAGE DEBUG: Run create table "local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/jobs" actor
2025-10-26T16:22:18.549652Z :YQ_CONTROL_PLANE_STORAGE DEBUG: Run create table "local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/quotas" actor
2025-10-26T16:22:18.549662Z :YQ_CONTROL_PLANE_STORAGE DEBUG: Run create table "local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/nodes" actor
2025-10-26T16:22:18.549664Z :YQ_CONTROL_PLANE_STORAGE DEBUG: Run create table "local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/tenants" actor
2025-10-26T16:22:18.549687Z :YQ_CONTROL_PLANE_STORAGE DEBUG: Run create table "local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/tenant_acks" actor
2025-10-26T16:22:18.549698Z :YQ_CONTROL_PLANE_STORAGE DEBUG: Run create table "local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/mappings" actor
2025-10-26T16:22:18.549711Z :YQL_NODES_MANAGER INFO: Bootstrap, InstanceId: aa0d4238-4b619a4d-2cfd599a-3469a662
2025-10-26T16:22:18.549713Z :YQL_NODES_MANAGER DEBUG: TNodesManagerActor::ResolveSelfAddress
2025-10-26T16:22:18.549717Z :YQ_TEST_CONNECTION DEBUG: Starting yandex query test connection. Actor id: [2:7565566588377063848:4093]
2025-10-26T16:22:18.549728Z :YQ_CONTROL_PLANE_STORAGE DEBUG: Run create table "local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/compute_databases" actor
2025-10-26T16:22:18.550075Z :MEMORY_PROFILER NOTICE: Bootstrapped
2025-10-26T16:22:18.550349Z :FQ_PENDING_FETCHER TRACE: Request Private::GetTask, Owner: 717f0dae-ec1c1334-99acf168-5d9efd071, Host: ghrun-zwq4uro7ay, Tenant: /default
2025-10-26T16:22:18.550359Z :YQ_CONTROL_PLANE_STORAGE DEBUG: Run create directory "local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0" actor
2025-10-26T16:22:18.550361Z :YQ_CONTROL_PLANE_STORAGE DEBUG: Call create directory "local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0"
2025-10-26T16:22:18.550364Z :YQ_CONTROL_PLANE_STORAGE DEBUG: Call create directory "local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0"
2025-10-26T16:22:18.551522Z :FQ_QUOTA_SERVICE INFO: STARTED
2025-10-26T16:22:18.551546Z :YQ_CONTROL_PLANE_STORAGE DEBUG: Run create table "local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/connections" actor
2025-10-26T16:22:18.551568Z :YQ_CONTROL_PLANE_STORAGE DEBUG: Run create table "local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/bindings" actor
2025-10-26T16:22:18.551650Z :YQ_CONTROL_PLANE_STORAGE DEBUG: Run create table "local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/queries" actor
2025-10-26T16:22:18.551665Z :YQ_CONTROL_PLANE_STORAGE DEBUG: Run create table "local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/pending_small" actor
2025-10-26T16:22:18.551684Z :YQL_NODES_MANAGER TRACE: TNodesManagerActor::NodesHealthCheck
2025-10-26T16:22:18.557794Z :FQ_PENDING_FETCHER TRACE: Got GetTask response from PrivateApi
2025-10-26T16:22:18.557885Z :FQ_PENDING_FETCHER ERROR: Error with GetTask: <main>: Error: Control Plane is not ready yet. Please retry later., code: 1007
<main>: Error: ControlPlane::GetTaskError
2025-10-26T16:22:18.570748Z :YQ_CONTROL_PLANE_STORAGE DEBUG: Create table "local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/queries". Create session OK
2025-10-26T16:22:18.570761Z :YQ_CONTROL_PLANE_STORAGE DEBUG: Call create table "local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/queries"
2025-10-26T16:22:18.570763Z :YQ_CONTROL_PLANE_STORAGE DEBUG: Call create table "local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/queries"
2025-10-26T16:22:18.570768Z :YQ_CONTROL_PLANE_STORAGE DEBUG: Create table "local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/nodes". Create session OK
2025-10-26T16:22:18.570774Z :YQ_CONTROL_PLANE_STORAGE DEBUG: Call create table "local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/nodes"
2025-10-26T16:22:18.570776Z :YQ_CONTROL_PLANE_STORAGE DEBUG: Call create table "local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/nodes"
2025-10-26T16:22:18.570946Z :YQ_CONTROL_PLANE_STORAGE DEBUG: Create table "local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/pending_small". Create session OK
2025-10-26T16:22:18.570956Z :YQ_CONTROL_PLANE_STORAGE DEBUG: Call create table "local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/pending_small"
2025-10-26T16:22:18.570968Z :YQ_CONTROL_PLANE_STORAGE DEBUG: Call create table "local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/pending_small"
2025-10-26T16:22:18.570991Z :YQ_CONTROL_PLANE_STORAGE DEBUG: Create table "local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/idempotency_keys". Create session OK
2025-10-26T16:22:18.570999Z :YQ_CONTROL_PLANE_STORAGE DEBUG: Call create table "local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/idempotency_keys"
2025-10-26T16:22:18.571000Z :YQ_CONTROL_PLANE_STORAGE DEBUG: Call create table "local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/idempotency_keys"
2025-10-26T16:22:18.571071Z :YQ_CONTROL_PLANE_STORAGE DEBUG: Create table "local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/quotas". Create session OK
2025-10-26T16:22:18.571077Z :YQ_CONTROL_PLANE_STORAGE DEBUG: Create table "local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/mappings". Create session OK
2025-10-26T16:22:18.571079Z :YQ_CONTROL_PLANE_STORAGE DEBUG: Call create table "local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/mappings"
2025-10-26T16:22:18.571080Z :YQ_CONTROL_PLANE_STORAGE DEBUG: Call create table "local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/mappings"
2025-10-26T16:22:18.571080Z :YQ_CONTROL_PLANE_STORAGE DEBUG: Call create table "local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/quotas"
2025-10-26T16:22:18.571082Z :YQ_CONTROL_PLANE_STORAGE DEBUG: Call create table "local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/quotas"
2025-10-26T16:22:18.571243Z :YQ_CONTROL_PLANE_STORAGE DEBUG: Create table "local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/tenants". Create session OK
2025-10-26T16:22:18.571252Z :YQ_CONTROL_PLANE_STORAGE DEBUG: Call create table "local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/tenants"
2025-10-26T16:22:18.571253Z :YQ_CONTROL_PLANE_STORAGE DEBUG: Call create table "local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/tenants"
2025-10-26T16:22:18.571352Z :YQ_CONTROL_PLANE_STORAGE DEBUG: Create table "local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/compute_databases". Create session OK
2025-10-26T16:22:18.571357Z :YQ_CONTROL_PLANE_STORAGE DEBUG: Call create table "local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/compute_databases"
2025-10-26T16:22:18.571359Z :YQ_CONTROL_PLANE_STORAGE DEBUG: Call create table "local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/compute_databases"
2025-10-26T16:22:18.571375Z :YQ_CONTROL_PLANE_STORAGE DEBUG: Create table "local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/jobs". Create session OK
2025-10-26T16:22:18.571378Z :YQ_CONTROL_PLANE_STORAGE DEBUG: Call create table "local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/jobs"
2025-10-26T16:22:18.571379Z :YQ_CONTROL_PLANE_STORAGE DEBUG: Call create table "local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/jobs"
2025-10-26T16:22:18.573356Z :YQ_CONTROL_PLANE_STORAGE DEBUG: Create table "local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/result_sets". Create session OK
2025-10-26T16:22:18.573368Z :YQ_CONTROL_PLANE_STORAGE DEBUG: Call create table "local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/result_sets"
2025-10-26T16:22:18.573370Z :YQ_CONTROL_PLANE_STORAGE DEBUG: Call create table "local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/result_sets"
2025-10-26T16:22:18.573382Z :YQ_RATE_LIMITER DEBUG: Successfully created coordination node "local/RateLimiter_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/rate_limiter"
2025-10-26T16:22:18.573395Z :YQ_RATE_LIMITER DEBUG: Reply for create coordination node "local/RateLimiter_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/rate_limiter": { <main>: Error: Check failed: path: '/local/RateLimiter_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/rate_limiter', error: path exist, request accepts it (id: [OwnerId: 72075186232723360, LocalPathId: 8], type: EPathTypeKesus, state: EPathStateNoChanges) }
2025-10-26T16:22:18.573409Z :YQ_CONTROL_PLANE_STORAGE DEBUG: Create table "local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/bindings". Create session OK
2025-10-26T16:22:18.573411Z :YQ_CONTROL_PLANE_STORAGE DEBUG: Call create table "local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/bindings"
2025-10-26T16:22:18.573412Z :YQ_CONTROL_PLANE_STORAGE DEBUG: Call create table "local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/bindings"
2025-10-26T16:22:18.573517Z :YQ_CONTROL_PLANE_STORAGE DEBUG: Create table "local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/tenant_acks". Create session OK
2025-10-26T16:22:18.573525Z :YQ_CONTROL_PLANE_STORAGE DEBUG: Call create table "local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/tenant_acks"
2025-10-26T16:22:18.573526Z :YQ_CONTROL_PLANE_STORAGE DEBUG: Call create table "local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/tenant_acks"
2025-10-26T16:22:18.578082Z :YQ_CONTROL_PLANE_STORAGE DEBUG: Successfully created directory "local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0"
2025-10-26T16:22:18.578105Z :YQ_CONTROL_PLANE_STORAGE DEBUG: Reply for create directory "local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0": { <main>: Error: Check failed: path: '/local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0', error: path exist, request accepts it (id: [OwnerId: 72075186232723360, LocalPathId: 2], type: EPathTypeDir, state: EPathStateNoChanges) }
2025-10-26T16:22:18.578158Z :YQ_CONTROL_PLANE_STORAGE DEBUG: Create table "local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/connections". Create session OK
2025-10-26T16:22:18.578169Z :YQ_CONTROL_PLANE_STORAGE DEBUG: Call create table "local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/connections"
2025-10-26T16:22:18.578170Z :YQ_CONTROL_PLANE_STORAGE DEBUG: Call create table "local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/connections"
2025-10-26T16:22:18.585978Z :YQ_CONTROL_PLANE_STORAGE DEBUG: Successfully created table "local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/queries"
2025-10-26T16:22:18.586004Z :YQ_CONTROL_PLANE_STORAGE DEBUG: Reply for create table "local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/queries": { <main>: Error: Check failed: path: '/local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/queries', error: path exist, request accepts it (id: [OwnerId: 72075186232723360, LocalPathId: 18], type: EPathTypeTable, state: EPathStateNoChanges) }
2025-10-26T16:22:18.587971Z :YQ_CONTROL_PLANE_STORAGE DEBUG: Successfully created table "local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/tenant_acks"
2025-10-26T16:22:18.587994Z :YQ_CONTROL_PLANE_STORAGE DEBUG: Reply for create table "local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/tenant_acks": { <main>: Error: Check failed: path: '/local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/tenant_acks', error: path exist, request accepts it (id: [OwnerId: 72075186232723360, LocalPathId: 14], type: EPathTypeTable, state: EPathStateNoChanges) }
2025-10-26T16:22:18.588355Z :YQ_CONTROL_PLANE_STORAGE DEBUG: Successfully created table "local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/bindings"
2025-10-26T16:22:18.588373Z :YQ_CONTROL_PLANE_STORAGE DEBUG: Reply for create table "local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/bindings": { <main>: Error: Check failed: path: '/local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/bindings', error: path exist, request accepts it (id: [OwnerId: 72075186232723360, LocalPathId: 17], type: EPathTypeTable, state: EPathStateNoChanges) }
2025-10-26T16:22:18.588391Z :YQ_CONTROL_PLANE_STORAGE DEBUG: Successfully created table "local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/nodes"
2025-10-26T16:22:18.588404Z :YQ_CONTROL_PLANE_STORAGE DEBUG: Reply for create table "local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/nodes": { <main>: Error: Check failed: path: '/local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/nodes', error: path exist, request accepts it (id: [OwnerId: 72075186232723360, LocalPathId: 12], type: EPathTypeTable, state: EPathStateNoChanges) }
2025-10-26T16:22:18.591731Z :YQ_CONTROL_PLANE_STORAGE DEBUG: Successfully created table "local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/tenants"
2025-10-26T16:22:18.591758Z :YQ_CONTROL_PLANE_STORAGE DEBUG: Reply for create table "local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/tenants": { <main>: Error: Check failed: path: '/local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/tenants', error: path exist, request accepts it (id: [OwnerId: 72075186232723360, LocalPathId: 3], type: EPathTypeTable, state: EPathStateNoChanges) }
2025-10-26T16:22:18.591757Z :YQ_CONTROL_PLANE_STORAGE DEBUG: Successfully created table "local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/jobs"
2025-10-26T16:22:18.591767Z :YQ_CONTROL_PLANE_STORAGE DEBUG: Reply for create table "local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/jobs": { <main>: Error: Check failed: path: '/local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/jobs', error: path exist, request accepts it (id: [OwnerId: 72075186232723360, LocalPathId: 11], type: EPathTypeTable, state: EPathStateNoChanges) }
2025-10-26T16:22:18.591902Z :YQ_CONTROL_PLANE_STORAGE DEBUG: Successfully created table "local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/result_sets"
2025-10-26T16:22:18.591907Z :YQ_CONTROL_PLANE_STORAGE DEBUG: Reply for create table "local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/result_sets": { <main>: Error: Check failed: path: '/local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/result_sets', error: path exist, request accepts it (id: [OwnerId: 72075186232723360, LocalPathId: 10], type: EPathTypeTable, state: EPathStateNoChanges) }
2025-10-26T16:22:18.591910Z :YQ_CONTROL_PLANE_STORAGE DEBUG: Successfully created table "local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/pending_small"
2025-10-26T16:22:18.591916Z :YQ_CONTROL_PLANE_STORAGE DEBUG: Reply for create table "local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/pending_small": { <main>: Error: Check failed: path: '/local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/pending_small', error: path exist, request accepts it (id: [OwnerId: 72075186232723360, LocalPathId: 19], type: EPathTypeTable, state: EPathStateNoChanges) }
2025-10-26T16:22:18.591978Z :YQ_CONTROL_PLANE_STORAGE DEBUG: Successfully created table "local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/idempotency_keys"
2025-10-26T16:22:18.591983Z :YQ_CONTROL_PLANE_STORAGE DEBUG: Reply for create table "local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/idempotency_keys": { <main>: Error: Check failed: path: '/local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/idempotency_keys', error: path exist, request accepts it (id: [OwnerId: 72075186232723360, LocalPathId: 13], type: EPathTypeTable, state: EPathStateNoChanges) }
2025-10-26T16:22:18.591986Z :YQ_CONTROL_PLANE_STORAGE DEBUG: Successfully created table "local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/connections"
2025-10-26T16:22:18.591990Z :YQ_CONTROL_PLANE_STORAGE DEBUG: Reply for create table "local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/connections": { <main>: Error: Check failed: path: '/local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/connections', error: path exist, request accepts it (id: [OwnerId: 72075186232723360, LocalPathId: 16], type: EPathTypeTable, state: EPathStateNoChanges) }
2025-10-26T16:22:18.592051Z :YQ_CONTROL_PLANE_STORAGE DEBUG: Successfully created table "local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/mappings"
2025-10-26T16:22:18.592055Z :YQ_CONTROL_PLANE_STORAGE DEBUG: Reply for create table "local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/mappings": { <main>: Error: Check failed: path: '/local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/mappings', error: path exist, request accepts it (id: [OwnerId: 72075186232723360, LocalPathId: 4], type: EPathTypeTable, state: EPathStateNoChanges) }
2025-10-26T16:22:18.592059Z :YQ_CONTROL_PLANE_STORAGE DEBUG: Successfully created table "local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/compute_databases"
2025-10-26T16:22:18.592065Z :YQ_CONTROL_PLANE_STORAGE DEBUG: Reply for create table "local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/compute_databases": { <main>: Error: Check failed: path: '/local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/compute_databases', error: path exist, request accepts it (id: [OwnerId: 72075186232723360, LocalPathId: 15], type: EPathTypeTable, state: EPathStateNoChanges) }
2025-10-26T16:22:18.592112Z :YQ_CONTROL_PLANE_STORAGE DEBUG: Successfully created table "local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/quotas"
2025-10-26T16:22:18.592116Z :YQ_CONTROL_PLANE_STORAGE DEBUG: Reply for create table "local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/quotas": { <main>: Error: Check failed: path: '/local/DbPoolStorage_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/quotas', error: path exist, request accepts it (id: [OwnerId: 72075186232723360, LocalPathId: 9], type: EPathTypeTable, state: EPathStateNoChanges) }
2025-10-26T16:22:18.592948Z :FQ_CONTROL_PLANE_CONFIG DEBUG: LOADED TenantInfo: State CHANGED at 2025-10-26T16:22:17.752431Z
2025-10-26T16:22:18.635272Z :YQL_NODES_MANAGER TRACE: Send NodeInfo with size: 2 to DynamicNameserver
2025-10-26T16:22:19.547786Z :FQ_PENDING_FETCHER TRACE: Request Private::GetTask, Owner: 717f0dae-ec1c1334-99acf168-5d9efd072, Host: ghrun-zwq4uro7ay, Tenant: /default
2025-10-26T16:22:19.551606Z :FQ_QUOTA_SERVICE DEBUG: IC Peers[2]: [1, 3]
2025-10-26T16:22:19.557962Z :FQ_PENDING_FETCHER TRACE: Got GetTask response from PrivateApi
2025-10-26T16:22:19.557976Z :FQ_PENDING_FETCHER TRACE: Tasks count: 0
2025-10-26T16:22:19.977695Z :STREAMS_STORAGE_SERVICE INFO: Successfully bootstrapped TStorageProxy [2:7565566588377063843:6] with connection to localhost:24793:local
2025-10-26T16:22:20.547956Z :FQ_PENDING_FETCHER TRACE: Request Private::GetTask, Owner: 717f0dae-ec1c1334-99acf168-5d9efd073, Host: ghrun-zwq4uro7ay, Tenant: /default
2025-10-26T16:22:20.551410Z :FQ_PENDING_FETCHER TRACE: Got GetTask response from PrivateApi
2025-10-26T16:22:20.551427Z :FQ_PENDING_FETCHER TRACE: Tasks count: 0
2025-10-26T16:22:21.548142Z :FQ_PENDING_FETCHER TRACE: Request Private::GetTask, Owner: 717f0dae-ec1c1334-99acf168-5d9efd074, Host: ghrun-zwq4uro7ay, Tenant: /default
2025-10-26T16:22:21.550838Z :FQ_PENDING_FETCHER TRACE: Got GetTask response from PrivateApi
2025-10-26T16:22:21.550848Z :FQ_PENDING_FETCHER TRACE: Tasks count: 0
2025-10-26T16:22:21.553611Z :FQ_CONTROL_PLANE_CONFIG TRACE: LOADED TenantInfo: State NOT changed
2025-10-26T16:22:22.548309Z :FQ_PENDING_FETCHER TRACE: Request Private::GetTask, Owner: 717f0dae-ec1c1334-99acf168-5d9efd075, Host: ghrun-zwq4uro7ay, Tenant: /default
2025-10-26T16:22:22.551222Z :FQ_PENDING_FETCHER TRACE: Got GetTask response from PrivateApi
2025-10-26T16:22:22.551233Z :FQ_PENDING_FETCHER TRACE: Tasks count: 0
2025-10-26T16:22:23.548498Z :FQ_PENDING_FETCHER TRACE: Request Private::GetTask, Owner: 717f0dae-ec1c1334-99acf168-5d9efd076, Host: ghrun-zwq4uro7ay, Tenant: /default
2025-10-26T16:22:23.551460Z :FQ_PENDING_FETCHER TRACE: Got GetTask response from PrivateApi
2025-10-26T16:22:23.551471Z :FQ_PENDING_FETCHER TRACE: Tasks count: 0
2025-10-26T16:22:23.551794Z :YQL_NODES_MANAGER TRACE: TNodesManagerActor::NodesHealthCheck
2025-10-26T16:22:23.557361Z :YQL_NODES_MANAGER TRACE: Send NodeInfo with size: 3 to DynamicNameserver
2025-10-26T16:22:24.548730Z :FQ_PENDING_FETCHER TRACE: Request Private::GetTask, Owner: 717f0dae-ec1c1334-99acf168-5d9efd077, Host: ghrun-zwq4uro7ay, Tenant: /default
2025-10-26T16:22:24.551547Z :FQ_PENDING_FETCHER TRACE: Got GetTask response from PrivateApi
2025-10-26T16:22:24.551557Z :FQ_PENDING_FETCHER TRACE: Tasks count: 0
2025-10-26T16:22:24.551810Z :FQ_QUOTA_SERVICE DEBUG: IC Peers[3]: [1, 3, 4]
2025-10-26T16:22:24.554375Z :FQ_CONTROL_PLANE_CONFIG TRACE: LOADED TenantInfo: State NOT changed
2025-10-26T16:22:25.548861Z :FQ_PENDING_FETCHER TRACE: Request Private::GetTask, Owner: 717f0dae-ec1c1334-99acf168-5d9efd078, Host: ghrun-zwq4uro7ay, Tenant: /default
2025-10-26T16:22:25.551771Z :FQ_PENDING_FETCHER TRACE: Got GetTask response from PrivateApi
2025-10-26T16:22:25.551784Z :FQ_PENDING_FETCHER TRACE: Tasks count: 0
2025-10-26T16:22:26.549092Z :FQ_PENDING_FETCHER TRACE: Request Private::GetTask, Owner: 717f0dae-ec1c1334-99acf168-5d9efd079, Host: ghrun-zwq4uro7ay, Tenant: /default
2025-10-26T16:22:26.552274Z :FQ_PENDING_FETCHER TRACE: Got GetTask response from PrivateApi
2025-10-26T16:22:26.552286Z :FQ_PENDING_FETCHER TRACE: Tasks count: 0
2025-10-26T16:22:27.549278Z :FQ_PENDING_FETCHER TRACE: Request Private::GetTask, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0710, Host: ghrun-zwq4uro7ay, Tenant: /default
2025-10-26T16:22:27.551705Z :FQ_PENDING_FETCHER TRACE: Got GetTask response from PrivateApi
2025-10-26T16:22:27.551716Z :FQ_PENDING_FETCHER TRACE: Tasks count: 0
2025-10-26T16:22:27.554297Z :FQ_CONTROL_PLANE_CONFIG TRACE: LOADED TenantInfo: State NOT changed
2025-10-26T16:22:27.841488Z :INTERCONNECT WARN: Handshake [2:7565566627031769609:4106] [node 1] ICH09 Neither CompatibilityInfo nor VersionTag of the peer can be validated, accepting by default
2025-10-26T16:22:27.842948Z :FQ_QUOTA_SERVICE TRACE: cloud.mock_cloud.yq.cpuPercent.count=0/200 UPDATE from Peer 1
2025-10-26T16:22:27.844118Z :FQ_QUOTA_SERVICE TRACE: cloud.mock_cloud.yq.streamingQuery.count=0/100 UPDATE from Peer 1
2025-10-26T16:22:27.844134Z :FQ_QUOTA_SERVICE TRACE: cloud.mock_cloud.yq.analyticsQuery.count=0/100 UPDATE from Peer 1
2025-10-26T16:22:28.155600Z :FQ_QUOTA_SERVICE TRACE: cloud.mock_cloud.yq.cpuPercent.count=0/200 UPDATE from Peer 1
2025-10-26T16:22:28.158793Z :FQ_QUOTA_SERVICE TRACE: cloud.mock_cloud.yq.analyticsQuery.count=0/100 UPDATE from Peer 1
2025-10-26T16:22:28.158807Z :FQ_QUOTA_SERVICE TRACE: cloud.mock_cloud.yq.streamingQuery.count=0/100 UPDATE from Peer 1
2025-10-26T16:22:28.340110Z :FQ_QUOTA_SERVICE TRACE: cloud.mock_cloud.yq.cpuPercent.count=0/200 UPDATE from Peer 1
2025-10-26T16:22:28.360840Z :FQ_QUOTA_SERVICE TRACE: cloud.mock_cloud.yq.analyticsQuery.count=1/100 UPDATE from Peer 1
2025-10-26T16:22:28.360863Z :FQ_QUOTA_SERVICE TRACE: cloud.mock_cloud.yq.streamingQuery.count=1/100 UPDATE from Peer 1
2025-10-26T16:22:28.549471Z :FQ_PENDING_FETCHER TRACE: Request Private::GetTask, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0711, Host: ghrun-zwq4uro7ay, Tenant: /default
2025-10-26T16:22:28.552016Z :YQL_NODES_MANAGER TRACE: TNodesManagerActor::NodesHealthCheck
2025-10-26T16:22:28.557977Z :YQL_NODES_MANAGER TRACE: Send NodeInfo with size: 3 to DynamicNameserver
2025-10-26T16:22:28.609603Z :FQ_PENDING_FETCHER TRACE: Got GetTask response from PrivateApi
2025-10-26T16:22:28.609619Z :FQ_PENDING_FETCHER TRACE: Tasks count: 1
2025-10-26T16:22:28.609632Z :FQ_PENDING_FETCHER DEBUG: NewTask: Scope: yandexcloud://my_folder Id: ptqudttn7qgq6bfhs4q5 UserId: root@builtin AuthToken: **** (B6C6F477)
2025-10-26T16:22:28.609838Z :FQ_RUN_ACTOR DEBUG: QueryId: ptqudttn7qgq6bfhs4q5 Start run actor. Compute state: STARTING
2025-10-26T16:22:28.609840Z :FQ_PENDING_FETCHER TRACE: Request Private::GetTask, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0712, Host: ghrun-zwq4uro7ay, Tenant: /default
2025-10-26T16:22:28.609849Z :FQ_RUN_ACTOR DEBUG: QueryId: ptqudttn7qgq6bfhs4q5 FillConnections
2025-10-26T16:22:28.609969Z :FQ_RUN_ACTOR DEBUG: QueryId: ptqudttn7qgq6bfhs4q5 Run actors params: { QueryId: ptqudttn7qgq6bfhs4q5 CloudId: mock_cloud UserId: root@builtin Owner: 717f0dae-ec1c1334-99acf168-5d9efd0711 PreviousQueryRevision: 1 Connections: 1 Bindings: 0 AccountIdSignatures: 0 QueryType: STREAMING ExecuteMode: RUN ResultId: ptrudttn7q2ub5a0kgdp StateLoadMode: EMPTY StreamingDisposition: { fresh { } } Status: STARTING DqGraphs: 0 DqGraphIndex: 0 Resource.TopicConsumers: 0 }
2025-10-26T16:22:28.609993Z :FQ_PINGER TRACE: QueryId: ptqudttn7qgq6bfhs4q5, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0711 Start Pinger
2025-10-26T16:22:28.609997Z :FQ_RUN_ACTOR DEBUG: QueryId: ptqudttn7qgq6bfhs4q5 Start rate limiter resource creator
2025-10-26T16:22:28.610049Z :FQ_PINGER TRACE: QueryId: ptqudttn7qgq6bfhs4q5, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0711 Forward ping request: { started_at { seconds: 1761495748 nanos: 609000000 } }
2025-10-26T16:22:28.610053Z :FQ_PINGER TRACE: QueryId: ptqudttn7qgq6bfhs4q5, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0711 Forward request Private::PingTask
2025-10-26T16:22:28.610148Z :FQ_PINGER TRACE: QueryId: ptqudttn7qgq6bfhs4q5, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0711 Forward ping request: { status: RUNNING resources { rate_limiter: PREPARE compilation: PREPARE } }
2025-10-26T16:22:28.612801Z :FQ_PENDING_FETCHER TRACE: Got GetTask response from PrivateApi
2025-10-26T16:22:28.612830Z :FQ_PENDING_FETCHER TRACE: Tasks count: 0
2025-10-26T16:22:28.647172Z :FQ_RUN_ACTOR DEBUG: QueryId: ptqudttn7qgq6bfhs4q5 Rate limiter resource creation finished. Success: 1
2025-10-26T16:22:28.647208Z :FQ_RUN_ACTOR DEBUG: QueryId: ptqudttn7qgq6bfhs4q5 Compiling query ...
2025-10-26T16:22:28.647235Z :FQ_PINGER TRACE: QueryId: ptqudttn7qgq6bfhs4q5, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0711 Forward ping request: { status: RUNNING resources { rate_limiter: READY compilation: PREPARE rate_limiter_path: "local/RateLimiter_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/rate_limiter" } }
2025-10-26T16:22:28.665724Z :YQL_PROXY TRACE: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.665 TRACE ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] yql_facade.cpp:644: Execution of [ParseSql] took 18.3ms
2025-10-26T16:22:28.666171Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.666 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [PQ] yql_pq_settings.cpp:52: Settings: clusterName = myyds, clusterDbId = , cluster.GetEndpoint(): localhost:24793, HasEndpoint = TRUE
2025-10-26T16:22:28.666315Z :YQL_PROXY TRACE: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.666 TRACE ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] yql_facade.cpp:662: Execution of [Compile] took 574us
2025-10-26T16:22:28.666421Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.666 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [DQ] yql_dq_provider.cpp:109: OpenSession ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud
2025-10-26T16:22:28.666430Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.666 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [DQ] yql_dq_provider.cpp:112: OpenSession ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud complete in 0
2025-10-26T16:22:28.666569Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.666 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [core eval] yql_eval_expr.cpp:403: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} EvaluateExpression - start
2025-10-26T16:22:28.666654Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.666 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [core eval] yql_eval_expr.cpp:1165: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} EvaluateExpression - finish
2025-10-26T16:22:28.666811Z :YQL_PROXY INFO: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.666 INFO  ydbd(pid=1984802, tid=0x00007EFC4E602640) [PQ] yql_pq_helpers.cpp:59: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} Found cluster: myyds
2025-10-26T16:22:28.666821Z :YQL_PROXY INFO: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.666 INFO  ydbd(pid=1984802, tid=0x00007EFC4E602640) [PQ] yql_pq_helpers.cpp:77: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} Ids to resolve: 0
2025-10-26T16:22:28.666908Z :YQL_PROXY INFO: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.666 INFO  ydbd(pid=1984802, tid=0x00007EFC4E602640) [PQ] yql_pq_load_meta.cpp:35: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} Load topic meta for: `myyds`.`select_dc_locality_input`
2025-10-26T16:22:28.668400Z :YQL_PROXY INFO: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.668 INFO  ydbd(pid=1984802, tid=0x00007EFC4E602640) [PQ] yql_pq_datasource.cpp:88: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} RewriteIO
2025-10-26T16:22:28.668432Z :YQL_PROXY INFO: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.668 INFO  ydbd(pid=1984802, tid=0x00007EFC4E602640) [PQ] yql_pq_datasource.cpp:88: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} RewriteIO
2025-10-26T16:22:28.668525Z :YQL_PROXY INFO: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.668 INFO  ydbd(pid=1984802, tid=0x00007EFC4E602640) [RESULT] yql_result_provider.cpp:1414: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} RewriteIO
2025-10-26T16:22:28.669144Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.669 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] type_ann_expr.cpp:44: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} Execution of [TypeAnnotationTransformer::DoTransform] took 584us
2025-10-26T16:22:28.669238Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.669 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] yql_expr_constraint.cpp:3079: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} Execution of [ConstraintTransformer::DoTransform] took 73us
2025-10-26T16:22:28.669291Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.669 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] type_ann_expr.cpp:44: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} Execution of [TypeAnnotationTransformer::DoTransform] took 0us
2025-10-26T16:22:28.669313Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.669 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] yql_expr_constraint.cpp:3079: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} Execution of [ConstraintTransformer::DoTransform] took 16us
2025-10-26T16:22:28.669331Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.669 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] yql_expr_csee.cpp:598: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} Execution of [UpdateCompletness] took 10us
2025-10-26T16:22:28.669393Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.669 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] yql_expr_csee.cpp:611: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} Execution of [EliminateCommonSubExpressions] took 57us
2025-10-26T16:22:28.669475Z :YQL_PROXY TRACE: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.669 TRACE ydbd(pid=1984802, tid=0x00007EFC4E602640) [core] yql_out_transformers.cpp:62: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} OptimizedExpr:
(
(let $1 (Configure! world (DataSource '"config") '"DqEngine" '"force"))
(let $2 (DataSink 'result))
(let $3 '"_yql_sys_create_time")
(let $4 '"_yql_sys_tsp_write_time")
(let $5 '"_yql_sys_partition_id")
(let $6 '"_yql_sys_message_group_id")
(let $7 '('('"system" $3) '('"system" $4) '('"system" $5) '('"system" '"_yql_sys_offset") '('"system" $6) '('"system" '"_yql_sys_seq_no")))
(let $8 (DataType 'String))
(let $9 '('"Data" $8))
(let $10 (PqTopic '"myyds" '"local" '"select_dc_locality_input" '('('"PartitionsCount" '"1")) $7 (StructType $9)))
(let $11 (DataType 'Timestamp))
(let $12 (DataType 'Uint64))
(let $13 (ResWrite! $1 $2 (Key) (RemovePrefixMembers (SqlProject (Right! (PqReadTopic! $1 (DataSource '"pq" '"myyds") $10 (Void) '"raw" '"" (Void) '('('"data.datetime.formatname" '"POSIX") '('"data.timestamp.formatname" '"POSIX")))) '((SqlProjectStarItem (ListType (StructType $9 '($3 $11) '($6 $8) '('"_yql_sys_offset" $12) '($5 $12) '('"_yql_sys_seq_no" $12) '($4 $11))) '"" (lambda '($14) $14) '()))) '('_yql_)) '('('type) '('autoref))))
(return (Commit! (Commit! $13 $2) (DataSink '"pq" '"myyds")))
)

2025-10-26T16:22:28.669642Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.669 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [core] yql_co_simple1.cpp:6127: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} Expand SqlProject
2025-10-26T16:22:28.669751Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.669 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] type_ann_expr.cpp:44: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} Execution of [TypeAnnotationTransformer::DoTransform] took 36us
2025-10-26T16:22:28.669775Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.669 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] yql_expr_constraint.cpp:3079: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} Execution of [ConstraintTransformer::DoTransform] took 13us
2025-10-26T16:22:28.669799Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.669 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] type_ann_expr.cpp:44: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} Execution of [TypeAnnotationTransformer::DoTransform] took 0us
2025-10-26T16:22:28.669822Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.669 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] yql_expr_constraint.cpp:3079: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} Execution of [ConstraintTransformer::DoTransform] took 17us
2025-10-26T16:22:28.669834Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.669 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] yql_expr_csee.cpp:598: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} Execution of [UpdateCompletness] took 6us
2025-10-26T16:22:28.669864Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.669 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] yql_expr_csee.cpp:611: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} Execution of [EliminateCommonSubExpressions] took 27us
2025-10-26T16:22:28.669927Z :YQL_PROXY TRACE: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.669 TRACE ydbd(pid=1984802, tid=0x00007EFC4E602640) [core] yql_out_transformers.cpp:62: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} OptimizedExpr:
(
(let $1 (Configure! world (DataSource '"config") '"DqEngine" '"force"))
(let $2 (DataSink 'result))
(let $3 '('('"system" '"_yql_sys_create_time") '('"system" '"_yql_sys_tsp_write_time") '('"system" '"_yql_sys_partition_id") '('"system" '"_yql_sys_offset") '('"system" '"_yql_sys_message_group_id") '('"system" '"_yql_sys_seq_no")))
(let $4 (PqTopic '"myyds" '"local" '"select_dc_locality_input" '('('"PartitionsCount" '"1")) $3 (StructType '('"Data" (DataType 'String)))))
(let $5 (ResWrite! $1 $2 (Key) (RemovePrefixMembers (FlatMap (Right! (PqReadTopic! $1 (DataSource '"pq" '"myyds") $4 (Void) '"raw" '"" (Void) '('('"data.datetime.formatname" '"POSIX") '('"data.timestamp.formatname" '"POSIX")))) (lambda '($6) (AsList (FlattenMembers '('"" $6))))) '('_yql_)) '('('type) '('autoref))))
(return (Commit! (Commit! $5 $2) (DataSink '"pq" '"myyds")))
)

2025-10-26T16:22:28.669957Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.669 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [core] yql_opt_utils.cpp:785: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} Enumerate struct object for FlattenMembers
2025-10-26T16:22:28.670064Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.670 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] type_ann_expr.cpp:44: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} Execution of [TypeAnnotationTransformer::DoTransform] took 39us
2025-10-26T16:22:28.670076Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.670 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] yql_expr_constraint.cpp:3079: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} Execution of [ConstraintTransformer::DoTransform] took 5us
2025-10-26T16:22:28.670095Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.670 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] type_ann_expr.cpp:44: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} Execution of [TypeAnnotationTransformer::DoTransform] took 0us
2025-10-26T16:22:28.670120Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.670 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] yql_expr_constraint.cpp:3079: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} Execution of [ConstraintTransformer::DoTransform] took 19us
2025-10-26T16:22:28.670136Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.670 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] yql_expr_csee.cpp:598: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} Execution of [UpdateCompletness] took 10us
2025-10-26T16:22:28.670186Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.670 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] yql_expr_csee.cpp:611: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} Execution of [EliminateCommonSubExpressions] took 43us
2025-10-26T16:22:28.670241Z :YQL_PROXY TRACE: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.670 TRACE ydbd(pid=1984802, tid=0x00007EFC4E602640) [core] yql_out_transformers.cpp:62: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} OptimizedExpr:
(
(let $1 (Configure! world (DataSource '"config") '"DqEngine" '"force"))
(let $2 (DataSink 'result))
(let $3 '"_yql_sys_create_time")
(let $4 '"_yql_sys_tsp_write_time")
(let $5 '"_yql_sys_partition_id")
(let $6 '"_yql_sys_message_group_id")
(let $7 '('('"system" $3) '('"system" $4) '('"system" $5) '('"system" '"_yql_sys_offset") '('"system" $6) '('"system" '"_yql_sys_seq_no")))
(let $8 (PqTopic '"myyds" '"local" '"select_dc_locality_input" '('('"PartitionsCount" '"1")) $7 (StructType '('"Data" (DataType 'String)))))
(let $9 (ResWrite! $1 $2 (Key) (RemovePrefixMembers (FlatMap (Right! (PqReadTopic! $1 (DataSource '"pq" '"myyds") $8 (Void) '"raw" '"" (Void) '('('"data.datetime.formatname" '"POSIX") '('"data.timestamp.formatname" '"POSIX")))) (lambda '($10) (AsList (AsStruct '('"Data" (Member $10 '"Data")) '($3 (Member $10 $3)) '($6 (Member $10 $6)) '('"_yql_sys_offset" (Member $10 '"_yql_sys_offset")) '($5 (Member $10 $5)) '('"_yql_sys_seq_no" (Member $10 '"_yql_sys_seq_no")) '($4 (Member $10 $4)))))) '('_yql_)) '('('type) '('autoref))))
(return (Commit! (Commit! $9 $2) (DataSink '"pq" '"myyds")))
)

2025-10-26T16:22:28.670275Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.670 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [core] yql_co_simple1.cpp:1124: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} CheckClonedStructure
2025-10-26T16:22:28.670350Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.670 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] type_ann_expr.cpp:44: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} Execution of [TypeAnnotationTransformer::DoTransform] took 25us
2025-10-26T16:22:28.670368Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.670 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] yql_expr_constraint.cpp:3079: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} Execution of [ConstraintTransformer::DoTransform] took 9us
2025-10-26T16:22:28.670391Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.670 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] type_ann_expr.cpp:44: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} Execution of [TypeAnnotationTransformer::DoTransform] took 0us
2025-10-26T16:22:28.670415Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.670 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] yql_expr_constraint.cpp:3079: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} Execution of [ConstraintTransformer::DoTransform] took 15us
2025-10-26T16:22:28.670429Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.670 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] yql_expr_csee.cpp:598: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} Execution of [UpdateCompletness] took 7us
2025-10-26T16:22:28.670469Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.670 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] yql_expr_csee.cpp:611: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} Execution of [EliminateCommonSubExpressions] took 33us
2025-10-26T16:22:28.670519Z :YQL_PROXY TRACE: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.670 TRACE ydbd(pid=1984802, tid=0x00007EFC4E602640) [core] yql_out_transformers.cpp:62: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} OptimizedExpr:
(
(let $1 (Configure! world (DataSource '"config") '"DqEngine" '"force"))
(let $2 (DataSink 'result))
(let $3 '('('"system" '"_yql_sys_create_time") '('"system" '"_yql_sys_tsp_write_time") '('"system" '"_yql_sys_partition_id") '('"system" '"_yql_sys_offset") '('"system" '"_yql_sys_message_group_id") '('"system" '"_yql_sys_seq_no")))
(let $4 (PqTopic '"myyds" '"local" '"select_dc_locality_input" '('('"PartitionsCount" '"1")) $3 (StructType '('"Data" (DataType 'String)))))
(let $5 (ResWrite! $1 $2 (Key) (RemovePrefixMembers (FlatMap (Right! (PqReadTopic! $1 (DataSource '"pq" '"myyds") $4 (Void) '"raw" '"" (Void) '('('"data.datetime.formatname" '"POSIX") '('"data.timestamp.formatname" '"POSIX")))) (lambda '($6) (AsList $6))) '('_yql_)) '('('type) '('autoref))))
(return (Commit! (Commit! $5 $2) (DataSink '"pq" '"myyds")))
)

2025-10-26T16:22:28.670553Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.670 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [core] yql_co_simple1.cpp:2016: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} FlatMap with single arg AsList
2025-10-26T16:22:28.670607Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.670 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] type_ann_expr.cpp:44: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} Execution of [TypeAnnotationTransformer::DoTransform] took 18us
2025-10-26T16:22:28.670619Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.670 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] yql_expr_constraint.cpp:3079: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} Execution of [ConstraintTransformer::DoTransform] took 5us
2025-10-26T16:22:28.670633Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.670 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] type_ann_expr.cpp:44: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} Execution of [TypeAnnotationTransformer::DoTransform] took 0us
2025-10-26T16:22:28.670643Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.670 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] yql_expr_constraint.cpp:3079: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} Execution of [ConstraintTransformer::DoTransform] took 7us
2025-10-26T16:22:28.670654Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.670 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] yql_expr_csee.cpp:598: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} Execution of [UpdateCompletness] took 6us
2025-10-26T16:22:28.670693Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.670 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] yql_expr_csee.cpp:611: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} Execution of [EliminateCommonSubExpressions] took 32us
2025-10-26T16:22:28.670747Z :YQL_PROXY TRACE: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.670 TRACE ydbd(pid=1984802, tid=0x00007EFC4E602640) [core] yql_out_transformers.cpp:62: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} OptimizedExpr:
(
(let $1 (Configure! world (DataSource '"config") '"DqEngine" '"force"))
(let $2 (DataSink 'result))
(let $3 '('('"system" '"_yql_sys_create_time") '('"system" '"_yql_sys_tsp_write_time") '('"system" '"_yql_sys_partition_id") '('"system" '"_yql_sys_offset") '('"system" '"_yql_sys_message_group_id") '('"system" '"_yql_sys_seq_no")))
(let $4 (PqTopic '"myyds" '"local" '"select_dc_locality_input" '('('"PartitionsCount" '"1")) $3 (StructType '('"Data" (DataType 'String)))))
(let $5 (ResWrite! $1 $2 (Key) (RemovePrefixMembers (FlatMap (Right! (PqReadTopic! $1 (DataSource '"pq" '"myyds") $4 (Void) '"raw" '"" (Void) '('('"data.datetime.formatname" '"POSIX") '('"data.timestamp.formatname" '"POSIX")))) (lambda '($6) (Just $6))) '('_yql_)) '('('type) '('autoref))))
(return (Commit! (Commit! $5 $2) (DataSink '"pq" '"myyds")))
)

2025-10-26T16:22:28.670768Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.670 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [core] yql_co_simple1.cpp:2028: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} FlatMap with Just
2025-10-26T16:22:28.670803Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.670 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] type_ann_expr.cpp:44: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} Execution of [TypeAnnotationTransformer::DoTransform] took 8us
2025-10-26T16:22:28.670815Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.670 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] yql_expr_constraint.cpp:3079: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} Execution of [ConstraintTransformer::DoTransform] took 5us
2025-10-26T16:22:28.670821Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.670 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] yql_expr_csee.cpp:598: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} Execution of [UpdateCompletness] took 5us
2025-10-26T16:22:28.670841Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.670 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] yql_expr_csee.cpp:611: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} Execution of [EliminateCommonSubExpressions] took 18us
2025-10-26T16:22:28.670873Z :YQL_PROXY TRACE: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.670 TRACE ydbd(pid=1984802, tid=0x00007EFC4E602640) [core] yql_out_transformers.cpp:62: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} OptimizedExpr:
(
(let $1 (Configure! world (DataSource '"config") '"DqEngine" '"force"))
(let $2 (DataSink 'result))
(let $3 '('('"system" '"_yql_sys_create_time") '('"system" '"_yql_sys_tsp_write_time") '('"system" '"_yql_sys_partition_id") '('"system" '"_yql_sys_offset") '('"system" '"_yql_sys_message_group_id") '('"system" '"_yql_sys_seq_no")))
(let $4 (PqTopic '"myyds" '"local" '"select_dc_locality_input" '('('"PartitionsCount" '"1")) $3 (StructType '('"Data" (DataType 'String)))))
(let $5 (ResWrite! $1 $2 (Key) (RemovePrefixMembers (Right! (PqReadTopic! $1 (DataSource '"pq" '"myyds") $4 (Void) '"raw" '"" (Void) '('('"data.datetime.formatname" '"POSIX") '('"data.timestamp.formatname" '"POSIX")))) '('_yql_)) '('('type) '('autoref))))
(return (Commit! (Commit! $5 $2) (DataSink '"pq" '"myyds")))
)

2025-10-26T16:22:28.670888Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.670 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [core] yql_opt_utils.cpp:843: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} Expand RemovePrefixMembers
2025-10-26T16:22:28.670938Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.670 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] type_ann_expr.cpp:44: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} Execution of [TypeAnnotationTransformer::DoTransform] took 11us
2025-10-26T16:22:28.670950Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.670 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] yql_expr_constraint.cpp:3079: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} Execution of [ConstraintTransformer::DoTransform] took 7us
2025-10-26T16:22:28.670956Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.670 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] yql_expr_csee.cpp:598: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} Execution of [UpdateCompletness] took 4us
2025-10-26T16:22:28.670979Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.670 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] yql_expr_csee.cpp:611: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} Execution of [EliminateCommonSubExpressions] took 20us
2025-10-26T16:22:28.671011Z :YQL_PROXY TRACE: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.671 TRACE ydbd(pid=1984802, tid=0x00007EFC4E602640) [core] yql_out_transformers.cpp:62: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} OptimizedExpr:
(
(let $1 (Configure! world (DataSource '"config") '"DqEngine" '"force"))
(let $2 (DataSink 'result))
(let $3 '('('"system" '"_yql_sys_create_time") '('"system" '"_yql_sys_tsp_write_time") '('"system" '"_yql_sys_partition_id") '('"system" '"_yql_sys_offset") '('"system" '"_yql_sys_message_group_id") '('"system" '"_yql_sys_seq_no")))
(let $4 (PqTopic '"myyds" '"local" '"select_dc_locality_input" '('('"PartitionsCount" '"1")) $3 (StructType '('"Data" (DataType 'String)))))
(let $5 (ResWrite! $1 $2 (Key) (ExtractMembers (Right! (PqReadTopic! $1 (DataSource '"pq" '"myyds") $4 (Void) '"raw" '"" (Void) '('('"data.datetime.formatname" '"POSIX") '('"data.timestamp.formatname" '"POSIX")))) '('"Data")) '('('type) '('autoref))))
(return (Commit! (Commit! $5 $2) (DataSink '"pq" '"myyds")))
)

2025-10-26T16:22:28.671191Z :YQL_PROXY INFO: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.671 INFO  ydbd(pid=1984802, tid=0x00007EFC4E602640) [DQ] yql_dq_recapture.cpp:102: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} DqsRecapture
2025-10-26T16:22:28.671270Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.671 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] type_ann_expr.cpp:44: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} Execution of [TypeAnnotationTransformer::DoTransform] took 35us
2025-10-26T16:22:28.671295Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.671 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] yql_expr_constraint.cpp:3079: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} Execution of [ConstraintTransformer::DoTransform] took 19us
2025-10-26T16:22:28.671307Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.671 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] yql_expr_csee.cpp:598: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} Execution of [UpdateCompletness] took 7us
2025-10-26T16:22:28.671351Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.671 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] yql_expr_csee.cpp:611: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} Execution of [EliminateCommonSubExpressions] took 37us
2025-10-26T16:22:28.671407Z :YQL_PROXY TRACE: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.671 TRACE ydbd(pid=1984802, tid=0x00007EFC4E602640) [core] yql_out_transformers.cpp:62: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} OptimizedExpr:
(
(let $1 (Configure! world (DataSource '"config") '"DqEngine" '"force"))
(let $2 (DataSink 'result))
(let $3 '"_yql_sys_create_time")
(let $4 '"_yql_sys_tsp_write_time")
(let $5 '"_yql_sys_partition_id")
(let $6 '"_yql_sys_message_group_id")
(let $7 '('('"system" $3) '('"system" $4) '('"system" $5) '('"system" '"_yql_sys_offset") '('"system" $6) '('"system" '"_yql_sys_seq_no")))
(let $8 (DataType 'String))
(let $9 '('"Data" $8))
(let $10 (PqTopic '"myyds" '"local" '"select_dc_locality_input" '('('"PartitionsCount" '"1")) $7 (StructType $9)))
(let $11 '('"Data" $3 $6 '"_yql_sys_offset" $5 '"_yql_sys_seq_no" $4))
(let $12 (DqPqTopicSource $10 $11 '('('"Endpoint" '"localhost:24793") '('"AddBearerToToken" '"1")) (SecureParam '"cluster:default_myyds")))
(let $13 (DataType 'Timestamp))
(let $14 (DataType 'Uint64))
(let $15 (StructType $9 '($3 $13) '($6 $8) '('"_yql_sys_offset" $14) '($5 $14) '('"_yql_sys_seq_no" $14) '($4 $13)))
(let $16 '($3 $4 $5 '"_yql_sys_offset" $6 '"_yql_sys_seq_no"))
(let $17 '('('"format" '"raw") '('"metadataColumns" $16) '('"formatSettings" '('('"data.datetime.formatname" '"POSIX") '('"data.timestamp.formatname" '"POSIX")))))
(let $18 (DqSourceWrap $12 (DataSource '"pq" '"myyds") $15 $17))
(let $19 (ResWrite! $1 $2 (Key) (ExtractMembers $18 '('"Data")) '('('type) '('autoref))))
(return (Commit! (Commit! $19 $2) (DataSink '"pq" '"myyds")))
)

2025-10-26T16:22:28.671893Z :YQL_PROXY INFO: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.671 INFO  ydbd(pid=1984802, tid=0x00007EFC4E602640) [PQ] yql_optimize.cpp:135: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} LogicalOptimizer-ExtractMembersOverDqWrap
2025-10-26T16:22:28.671976Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.671 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] type_ann_expr.cpp:44: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} Execution of [TypeAnnotationTransformer::DoTransform] took 35us
2025-10-26T16:22:28.672004Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.672 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] yql_expr_constraint.cpp:3079: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} Execution of [ConstraintTransformer::DoTransform] took 19us
2025-10-26T16:22:28.672018Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.672 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] yql_expr_csee.cpp:598: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} Execution of [UpdateCompletness] took 6us
2025-10-26T16:22:28.672055Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.672 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] yql_expr_csee.cpp:611: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} Execution of [EliminateCommonSubExpressions] took 30us
2025-10-26T16:22:28.672109Z :YQL_PROXY TRACE: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.672 TRACE ydbd(pid=1984802, tid=0x00007EFC4E602640) [core] yql_out_transformers.cpp:62: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} OptimizedExpr:
(
(let $1 (Configure! world (DataSource '"config") '"DqEngine" '"force"))
(let $2 (DataSink 'result))
(let $3 (StructType '('"Data" (DataType 'String))))
(let $4 (PqTopic '"myyds" '"local" '"select_dc_locality_input" '('('"PartitionsCount" '"1")) '() $3))
(let $5 (DqPqTopicSource $4 '('"Data") '('('"Endpoint" '"localhost:24793") '('"AddBearerToToken" '"1")) (SecureParam '"cluster:default_myyds")))
(let $6 (DqSourceWrap $5 (DataSource '"pq" '"myyds") $3 '('('"format" '"raw") '('"formatSettings" '('('"data.datetime.formatname" '"POSIX") '('"data.timestamp.formatname" '"POSIX"))))))
(let $7 (ResWrite! $1 $2 (Key) $6 '('('type) '('autoref))))
(return (Commit! (Commit! $7 $2) (DataSink '"pq" '"myyds")))
)

2025-10-26T16:22:28.672315Z :YQL_PROXY INFO: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.672 INFO  ydbd(pid=1984802, tid=0x00007EFC4E602640) [DQ] yql_optimize.cpp:135: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} DqsPhy-BuildStageWithSourceWrap
2025-10-26T16:22:28.672415Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.672 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] type_ann_expr.cpp:44: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} Execution of [TypeAnnotationTransformer::DoTransform] took 59us
2025-10-26T16:22:28.672447Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.672 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] yql_expr_constraint.cpp:3079: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} Execution of [ConstraintTransformer::DoTransform] took 23us
2025-10-26T16:22:28.672477Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.672 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] type_ann_expr.cpp:44: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} Execution of [TypeAnnotationTransformer::DoTransform] took 1us
2025-10-26T16:22:28.672494Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.672 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] yql_expr_constraint.cpp:3079: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} Execution of [ConstraintTransformer::DoTransform] took 11us
2025-10-26T16:22:28.672511Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.672 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] type_ann_expr.cpp:44: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} Execution of [TypeAnnotationTransformer::DoTransform] took 0us
2025-10-26T16:22:28.672534Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.672 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] yql_expr_constraint.cpp:3079: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} Execution of [ConstraintTransformer::DoTransform] took 15us
2025-10-26T16:22:28.672547Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.672 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] yql_expr_csee.cpp:598: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} Execution of [UpdateCompletness] took 7us
2025-10-26T16:22:28.672591Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.672 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] yql_expr_csee.cpp:611: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} Execution of [EliminateCommonSubExpressions] took 38us
2025-10-26T16:22:28.672652Z :YQL_PROXY TRACE: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.672 TRACE ydbd(pid=1984802, tid=0x00007EFC4E602640) [core] yql_out_transformers.cpp:62: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} OptimizedExpr:
(
(let $1 (Configure! world (DataSource '"config") '"DqEngine" '"force"))
(let $2 (DataSink 'result))
(let $3 (DataSource '"pq" '"myyds"))
(let $4 (StructType '('"Data" (DataType 'String))))
(let $5 (PqTopic '"myyds" '"local" '"select_dc_locality_input" '('('"PartitionsCount" '"1")) '() $4))
(let $6 (DqPqTopicSource $5 '('"Data") '('('"Endpoint" '"localhost:24793") '('"AddBearerToToken" '"1")) (SecureParam '"cluster:default_myyds")))
(let $7 (DqStage '((DqSource $3 $6)) (lambda '($9) (block '(
  (let $10 (DqSourceWideWrap $9 $3 $4 '('('"format" '"raw") '('"formatSettings" '('('"data.datetime.formatname" '"POSIX") '('"data.timestamp.formatname" '"POSIX"))))))
  (return (NarrowMap $10 (lambda '($11) (AsStruct '('"Data" $11)))))
))) '('('"_logical_id" '199397))))
(let $8 (ResWrite! $1 $2 (Key) (DqCnUnionAll (TDqOutput $7 '"0")) '('('type) '('autoref))))
(return (Commit! (Commit! $8 $2) (DataSink '"pq" '"myyds")))
)

2025-10-26T16:22:28.673138Z :YQL_PROXY TRACE: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.673 TRACE ydbd(pid=1984802, tid=0x00007EFC4E602640) [core dq] dq_opt_phy_finalizing.cpp:488: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} DqReplicateStageMultiOutput: start traverse node #199408, Commit!
2025-10-26T16:22:28.673149Z :YQL_PROXY TRACE: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.673 TRACE ydbd(pid=1984802, tid=0x00007EFC4E602640) [core dq] dq_opt_phy_finalizing.cpp:517: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} DqReplicateStageMultiOutput: test connection DqCnUnionAll (#199405)
2025-10-26T16:22:28.673232Z :YQL_PROXY INFO: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.673 INFO  ydbd(pid=1984802, tid=0x00007EFC4E602640) [RESULT] yql_result_provider.cpp:769: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} ResPull
2025-10-26T16:22:28.673303Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.673 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] type_ann_expr.cpp:44: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} Execution of [TypeAnnotationTransformer::DoTransform] took 29us
2025-10-26T16:22:28.673320Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.673 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] yql_expr_constraint.cpp:3079: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} Execution of [ConstraintTransformer::DoTransform] took 11us
2025-10-26T16:22:28.673340Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.673 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] type_ann_expr.cpp:44: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} Execution of [TypeAnnotationTransformer::DoTransform] took 0us
2025-10-26T16:22:28.673356Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.673 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] yql_expr_constraint.cpp:3079: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} Execution of [ConstraintTransformer::DoTransform] took 11us
2025-10-26T16:22:28.673367Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.673 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] yql_expr_csee.cpp:598: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} Execution of [UpdateCompletness] took 8us
2025-10-26T16:22:28.673404Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.673 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] yql_expr_csee.cpp:611: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} Execution of [EliminateCommonSubExpressions] took 31us
2025-10-26T16:22:28.673458Z :YQL_PROXY TRACE: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.673 TRACE ydbd(pid=1984802, tid=0x00007EFC4E602640) [core] yql_out_transformers.cpp:62: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} OptimizedExpr:
(
(let $1 (Configure! world (DataSource '"config") '"DqEngine" '"force"))
(let $2 (DataSink 'result))
(let $3 (DataSource '"pq" '"myyds"))
(let $4 (StructType '('"Data" (DataType 'String))))
(let $5 (PqTopic '"myyds" '"local" '"select_dc_locality_input" '('('"PartitionsCount" '"1")) '() $4))
(let $6 (DqPqTopicSource $5 '('"Data") '('('"Endpoint" '"localhost:24793") '('"AddBearerToToken" '"1")) (SecureParam '"cluster:default_myyds")))
(let $7 (DqStage '((DqSource $3 $6)) (lambda '($10) (block '(
  (let $11 (DqSourceWideWrap $10 $3 $4 '('('"format" '"raw") '('"formatSettings" '('('"data.datetime.formatname" '"POSIX") '('"data.timestamp.formatname" '"POSIX"))))))
  (return (NarrowMap $11 (lambda '($12) (AsStruct '('"Data" $12)))))
))) '('('"_logical_id" '199397))))
(let $8 (DqStage '((DqCnUnionAll (TDqOutput $7 '"0"))) (lambda '($13) $13) '('('"_logical_id" '199424))))
(let $9 (ResPull! $1 $2 (Key) (DqCnResult (TDqOutput $8 '"0") '()) '('('type) '('autoref)) '"dq"))
(return (Commit! (Commit! $9 $2) (DataSink '"pq" '"myyds")))
)

2025-10-26T16:22:28.673703Z :YQL_PROXY TRACE: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.673 TRACE ydbd(pid=1984802, tid=0x00007EFC4E602640) [core dq] dq_opt_phy_finalizing.cpp:488: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} DqReplicateStageMultiOutput: start traverse node #199437, Commit!
2025-10-26T16:22:28.673714Z :YQL_PROXY TRACE: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.673 TRACE ydbd(pid=1984802, tid=0x00007EFC4E602640) [core dq] dq_opt_phy_finalizing.cpp:517: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} DqReplicateStageMultiOutput: test connection DqCnResult (#199433)
2025-10-26T16:22:28.673718Z :YQL_PROXY TRACE: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.673 TRACE ydbd(pid=1984802, tid=0x00007EFC4E602640) [core dq] dq_opt_phy_finalizing.cpp:517: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} DqReplicateStageMultiOutput: test connection DqCnUnionAll (#199405)
2025-10-26T16:22:28.673906Z :YQL_PROXY INFO: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.673 INFO  ydbd(pid=1984802, tid=0x00007EFC4E602640) [core exec] yql_execution.cpp:59: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} Begin, root #199437
2025-10-26T16:22:28.673914Z :YQL_PROXY INFO: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.673 INFO  ydbd(pid=1984802, tid=0x00007EFC4E602640) [core exec] yql_execution.cpp:72: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} Collect unused nodes for root #199437, status: Ok
2025-10-26T16:22:28.673918Z :YQL_PROXY TRACE: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.673 TRACE ydbd(pid=1984802, tid=0x00007EFC4E602640) [core exec] yql_execution.cpp:387: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} {0}, callable #199437 <Commit!>
2025-10-26T16:22:28.673922Z :YQL_PROXY TRACE: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.673 TRACE ydbd(pid=1984802, tid=0x00007EFC4E602640) [core exec] yql_execution.cpp:387: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} {1}, callable #199436 <Commit!>
2025-10-26T16:22:28.673926Z :YQL_PROXY TRACE: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.673 TRACE ydbd(pid=1984802, tid=0x00007EFC4E602640) [core exec] yql_execution.cpp:387: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} {2}, callable #199435 <ResPull!>
2025-10-26T16:22:28.673932Z :YQL_PROXY TRACE: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.673 TRACE ydbd(pid=1984802, tid=0x00007EFC4E602640) [core exec] yql_execution.cpp:387: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} {3}, callable #199031 <Configure!>
2025-10-26T16:22:28.673937Z :YQL_PROXY TRACE: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.673 TRACE ydbd(pid=1984802, tid=0x00007EFC4E602640) [core exec] yql_execution.cpp:387: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} {3}, callable #199031 <Configure!>
2025-10-26T16:22:28.673944Z :YQL_PROXY INFO: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.673 INFO  ydbd(pid=1984802, tid=0x00007EFC4E602640) [core exec] yql_execution.cpp:577: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} Node #199031<Configure!> finished execution
2025-10-26T16:22:28.673948Z :YQL_PROXY INFO: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.673 INFO  ydbd(pid=1984802, tid=0x00007EFC4E602640) [core exec] yql_execution.cpp:594: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} Node #199031<Configure!> created 0 trackable nodes: 
2025-10-26T16:22:28.673952Z :YQL_PROXY TRACE: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.673 TRACE ydbd(pid=1984802, tid=0x00007EFC4E602640) [core exec] yql_execution.cpp:387: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} {3}, callable #199433 <DqCnResult>
2025-10-26T16:22:28.673963Z :YQL_PROXY INFO: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.673 INFO  ydbd(pid=1984802, tid=0x00007EFC4E602640) [core exec] yql_execution.cpp:577: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} Node #199433<DqCnResult> finished execution
2025-10-26T16:22:28.673970Z :YQL_PROXY INFO: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.673 INFO  ydbd(pid=1984802, tid=0x00007EFC4E602640) [core exec] yql_execution.cpp:594: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} Node #199433<DqCnResult> created 0 trackable nodes: 
2025-10-26T16:22:28.673973Z :YQL_PROXY TRACE: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.673 TRACE ydbd(pid=1984802, tid=0x00007EFC4E602640) [core exec] yql_execution.cpp:387: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} {2}, callable #199435 <ResPull!>
2025-10-26T16:22:28.674007Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.674 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [DQ] yql_dq_exectransformer.cpp:1247: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud/#199435/#199450} Executing Pull (UniqueId=199450)
2025-10-26T16:22:28.674092Z :YQL_PROXY TRACE: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.674 TRACE ydbd(pid=1984802, tid=0x00007EFC4E602640) [DQ] yql_dq_exectransformer.cpp:1248: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud/#199435/#199450} HandlePull (
(let $1 (DataSource '"pq" '"myyds"))
(let $2 (StructType '('"Data" (DataType 'String))))
(let $3 (PqTopic '"myyds" '"local" '"select_dc_locality_input" '('('"PartitionsCount" '"1")) '() $2))
(let $4 (DqPqTopicSource $3 '('"Data") '('('"Endpoint" '"localhost:24793") '('"AddBearerToToken" '"1")) (SecureParam '"cluster:default_myyds")))
(let $5 (DqStage '((DqSource $1 $4)) (lambda '($11) (block '(
  (let $12 (DqSourceWideWrap $11 $1 $2 '('('"format" '"raw") '('"formatSettings" '('('"data.datetime.formatname" '"POSIX") '('"data.timestamp.formatname" '"POSIX"))))))
  (return (NarrowMap $12 (lambda '($13) (AsStruct '('"Data" $13)))))
))) '('('"_logical_id" '199397))))
(let $6 (DqStage '((DqCnUnionAll (TDqOutput $5 '"0"))) (lambda '($14) $14) '('('"_logical_id" '199424))))
(let $7 (DqCnResult (TDqOutput $6 '"0") '()))
(let $8 '('('type) '('autoref)))
(let $9 (Configure! world (DataSource '"config") '"DqEngine" '"force"))
(let $10 (ResPull! $9 (DataSink 'result) (Key) $7 $8 '"dq"))
(return (Pull $7 '"100000" '"1000" '"0" $8 '"0" '"" '"0" $10))
)

2025-10-26T16:22:28.674201Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.674 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] type_ann_expr.cpp:44: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud/#199435/#199450} Execution of [TypeAnnotationTransformer::DoTransform] took 3us
2025-10-26T16:22:28.674209Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.674 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] yql_expr_constraint.cpp:3079: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud/#199435/#199450} Execution of [ConstraintTransformer::DoTransform] took 2us
2025-10-26T16:22:28.674218Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.674 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] yql_expr_csee.cpp:598: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud/#199435/#199450} Execution of [UpdateCompletness] took 6us
2025-10-26T16:22:28.674256Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.674 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] yql_expr_csee.cpp:611: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud/#199435/#199450} Execution of [EliminateCommonSubExpressionsForSubGraph] took 31us
2025-10-26T16:22:28.674305Z :YQL_PROXY TRACE: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.674 TRACE ydbd(pid=1984802, tid=0x00007EFC4E602640) [core peephole] yql_out_transformers.cpp:62: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud/#199435/#199450} PeepHoleOpt:
(
(let $1 (DataSource '"pq" '"myyds"))
(let $2 (StructType '('"Data" (DataType 'String))))
(let $3 (PqTopic '"myyds" '"local" '"select_dc_locality_input" '('('"PartitionsCount" '"1")) '() $2))
(let $4 (DqPqTopicSource $3 '('"Data") '('('"Endpoint" '"localhost:24793") '('"AddBearerToToken" '"1")) (SecureParam '"cluster:default_myyds")))
(let $5 (DqStage '((DqSource $1 $4)) (lambda '($7) (block '(
  (let $8 (DqSourceWideWrap $7 $1 $2 '('('"format" '"raw") '('"formatSettings" '('('"data.datetime.formatname" '"POSIX") '('"data.timestamp.formatname" '"POSIX"))))))
  (return (NarrowMap $8 (lambda '($9) (AsStruct '('"Data" $9)))))
))) '('('"_logical_id" '199397))))
(let $6 (DqStage '((DqCnUnionAll (TDqOutput $5 '"0"))) (lambda '($10) $10) '('('"_logical_id" '199424))))
(return (DqCnResult (TDqOutput $6 '"0") '()))
)

2025-10-26T16:22:28.678542Z :YQL_PROXY TRACE: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.678 TRACE ydbd(pid=1984802, tid=0x00007EFC4E602640) [core dq] dq_opt_phy_finalizing.cpp:488: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud/#199435/#199450} DqReplicateStageMultiOutput: start traverse node #199451, DqCnResult
2025-10-26T16:22:28.678558Z :YQL_PROXY TRACE: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.678 TRACE ydbd(pid=1984802, tid=0x00007EFC4E602640) [core dq] dq_opt_phy_finalizing.cpp:517: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud/#199435/#199450} DqReplicateStageMultiOutput: test connection DqCnUnionAll (#199405)
2025-10-26T16:22:28.678642Z :YQL_PROXY TRACE: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.678 TRACE ydbd(pid=1984802, tid=0x00007EFC4E602640) [core dq] dq_opt_build.cpp:235: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud/#199435/#199450} [DQ/Build/TransformConsumers] (
(let $1 (DataSource '"pq" '"myyds"))
(let $2 (StructType '('"Data" (DataType 'String))))
(let $3 (PqTopic '"myyds" '"local" '"select_dc_locality_input" '('('"PartitionsCount" '"1")) '() $2))
(let $4 (DqPqTopicSource $3 '('"Data") '('('"Endpoint" '"localhost:24793") '('"AddBearerToToken" '"1")) (SecureParam '"cluster:default_myyds")))
(let $5 (DqStage '((DqSource $1 $4)) (lambda '($7) (block '(
  (let $8 (DqSourceWideWrap $7 $1 $2 '('('"format" '"raw") '('"formatSettings" '('('"data.datetime.formatname" '"POSIX") '('"data.timestamp.formatname" '"POSIX"))))))
  (return (NarrowMap $8 (lambda '($9) (AsStruct '('"Data" $9)))))
))) '('('"_logical_id" '199397))))
(let $6 (DqStage '((DqCnUnionAll (TDqOutput $5 '"0"))) (lambda '($10) $10) '('('"_logical_id" '199424))))
(return (DqCnResult (TDqOutput $6 '"0") '()))
)

2025-10-26T16:22:28.678712Z :YQL_PROXY TRACE: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.678 TRACE ydbd(pid=1984802, tid=0x00007EFC4E602640) [core dq] dq_opt_build.cpp:325: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud/#199435/#199450} [DQ/Build/TransformPhysical] (
(let $1 (DataSource '"pq" '"myyds"))
(let $2 (StructType '('"Data" (DataType 'String))))
(let $3 (PqTopic '"myyds" '"local" '"select_dc_locality_input" '('('"PartitionsCount" '"1")) '() $2))
(let $4 (DqPqTopicSource $3 '('"Data") '('('"Endpoint" '"localhost:24793") '('"AddBearerToToken" '"1")) (SecureParam '"cluster:default_myyds")))
(let $5 (DqStage '((DqSource $1 $4)) (lambda '($7) (block '(
  (let $8 (DqSourceWideWrap $7 $1 $2 '('('"format" '"raw") '('"formatSettings" '('('"data.datetime.formatname" '"POSIX") '('"data.timestamp.formatname" '"POSIX"))))))
  (return (NarrowMap $8 (lambda '($9) (AsStruct '('"Data" $9)))))
))) '('('"_logical_id" '199397))))
(let $6 (DqStage '((DqCnUnionAll (TDqOutput $5 '"0"))) (lambda '($10) $10) '('('"_logical_id" '199424))))
(return (DqCnResult (TDqOutput $6 '"0") '()))
)

2025-10-26T16:22:28.678764Z :YQL_PROXY TRACE: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.678 TRACE ydbd(pid=1984802, tid=0x00007EFC4E602640) [core dq] dq_opt_build.cpp:363: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud/#199435/#199450}  [DQ/Build/TransformPhysical] replace stage #199429 -> #199465
2025-10-26T16:22:28.678792Z :YQL_PROXY TRACE: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.678 TRACE ydbd(pid=1984802, tid=0x00007EFC4E602640) [core dq] dq_opt_build.cpp:363: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud/#199435/#199450}  [DQ/Build/TransformPhysical] replace stage #199402 -> #199480
2025-10-26T16:22:28.678927Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.678 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] type_ann_expr.cpp:44: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud/#199435/#199450} Execution of [TypeAnnotationTransformer::DoTransform] took 85us
2025-10-26T16:22:28.678961Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.678 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] yql_expr_constraint.cpp:3079: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud/#199435/#199450} Execution of [ConstraintTransformer::DoTransform] took 24us
2025-10-26T16:22:28.678969Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.678 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] type_ann_expr.cpp:44: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud/#199435/#199450} Execution of [TypeAnnotationTransformer::DoTransform] took 1us
2025-10-26T16:22:28.679000Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.678 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] yql_expr_constraint.cpp:3079: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud/#199435/#199450} Execution of [ConstraintTransformer::DoTransform] took 27us
2025-10-26T16:22:28.679008Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.679 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] type_ann_expr.cpp:44: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud/#199435/#199450} Execution of [TypeAnnotationTransformer::DoTransform] took 0us
2025-10-26T16:22:28.679019Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.679 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] yql_expr_constraint.cpp:3079: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud/#199435/#199450} Execution of [ConstraintTransformer::DoTransform] took 9us
2025-10-26T16:22:28.679036Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.679 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] yql_expr_csee.cpp:598: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud/#199435/#199450} Execution of [UpdateCompletness] took 12us
2025-10-26T16:22:28.679092Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.679 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] yql_expr_csee.cpp:611: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud/#199435/#199450} Execution of [EliminateCommonSubExpressionsForSubGraph] took 47us
2025-10-26T16:22:28.679160Z :YQL_PROXY TRACE: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.679 TRACE ydbd(pid=1984802, tid=0x00007EFC4E602640) [core peephole] yql_out_transformers.cpp:62: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud/#199435/#199450} PeepHoleOpt:
(
(let $1 (DataSource '"pq" '"myyds"))
(let $2 (StructType '('"Data" (DataType 'String))))
(let $3 (PqTopic '"myyds" '"local" '"select_dc_locality_input" '('('"PartitionsCount" '"1")) '() $2))
(let $4 (DqPqTopicSource $3 '('"Data") '('('"Endpoint" '"localhost:24793") '('"AddBearerToToken" '"1")) (SecureParam '"cluster:default_myyds")))
(let $5 (DqPhyStage '((DqSource $1 $4)) (lambda '($7) (block '(
  (let $8 (DqSourceWideWrap $7 $1 $2 '('('"format" '"raw") '('"formatSettings" '('('"data.datetime.formatname" '"POSIX") '('"data.timestamp.formatname" '"POSIX"))))))
  (return (FromFlow (NarrowMap $8 (lambda '($9) (AsStruct '('"Data" $9))))))
))) '('('"_logical_id" '199397) '('"_id" '"f66842cf-d2963b2e-86e6f3a8-250cec81"))))
(let $6 (DqPhyStage '((DqCnUnionAll (TDqOutput $5 '"0"))) (lambda '($10) (FromFlow (ToFlow $10))) '('('"_logical_id" '199424) '('"_id" '"586107bb-14db53db-8ae69656-ef86eecc"))))
(return (DqCnResult (TDqOutput $6 '"0") '()))
)

2025-10-26T16:22:28.679272Z :YQL_PROXY TRACE: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.679 TRACE ydbd(pid=1984802, tid=0x00007EFC4E602640) [core dq] dq_opt_build.cpp:235: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud/#199435/#199450} [DQ/Build/TransformConsumers] (
(let $1 (DataSource '"pq" '"myyds"))
(let $2 (StructType '('"Data" (DataType 'String))))
(let $3 (PqTopic '"myyds" '"local" '"select_dc_locality_input" '('('"PartitionsCount" '"1")) '() $2))
(let $4 (DqPqTopicSource $3 '('"Data") '('('"Endpoint" '"localhost:24793") '('"AddBearerToToken" '"1")) (SecureParam '"cluster:default_myyds")))
(let $5 (DqPhyStage '((DqSource $1 $4)) (lambda '($7) (block '(
  (let $8 (DqSourceWideWrap $7 $1 $2 '('('"format" '"raw") '('"formatSettings" '('('"data.datetime.formatname" '"POSIX") '('"data.timestamp.formatname" '"POSIX"))))))
  (return (FromFlow (NarrowMap $8 (lambda '($9) (AsStruct '('"Data" $9))))))
))) '('('"_logical_id" '199397) '('"_id" '"f66842cf-d2963b2e-86e6f3a8-250cec81"))))
(let $6 (DqPhyStage '((DqCnUnionAll (TDqOutput $5 '"0"))) (lambda '($10) (FromFlow (ToFlow $10))) '('('"_logical_id" '199424) '('"_id" '"586107bb-14db53db-8ae69656-ef86eecc"))))
(return (DqCnResult (TDqOutput $6 '"0") '()))
)

2025-10-26T16:22:28.679335Z :YQL_PROXY TRACE: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.679 TRACE ydbd(pid=1984802, tid=0x00007EFC4E602640) [core dq] dq_opt_build.cpp:325: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud/#199435/#199450} [DQ/Build/TransformPhysical] (
(let $1 (DataSource '"pq" '"myyds"))
(let $2 (StructType '('"Data" (DataType 'String))))
(let $3 (PqTopic '"myyds" '"local" '"select_dc_locality_input" '('('"PartitionsCount" '"1")) '() $2))
(let $4 (DqPqTopicSource $3 '('"Data") '('('"Endpoint" '"localhost:24793") '('"AddBearerToToken" '"1")) (SecureParam '"cluster:default_myyds")))
(let $5 (DqPhyStage '((DqSource $1 $4)) (lambda '($7) (block '(
  (let $8 (DqSourceWideWrap $7 $1 $2 '('('"format" '"raw") '('"formatSettings" '('('"data.datetime.formatname" '"POSIX") '('"data.timestamp.formatname" '"POSIX"))))))
  (return (FromFlow (NarrowMap $8 (lambda '($9) (AsStruct '('"Data" $9))))))
))) '('('"_logical_id" '199397) '('"_id" '"f66842cf-d2963b2e-86e6f3a8-250cec81"))))
(let $6 (DqPhyStage '((DqCnUnionAll (TDqOutput $5 '"0"))) (lambda '($10) (FromFlow (ToFlow $10))) '('('"_logical_id" '199424) '('"_id" '"586107bb-14db53db-8ae69656-ef86eecc"))))
(return (DqCnResult (TDqOutput $6 '"0") '()))
)

2025-10-26T16:22:28.679564Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.679 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [core] yql_co_flow2.cpp:1012: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud/#199435/#199450} Drop FromFlow with ToFlow
2025-10-26T16:22:28.679612Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.679 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] type_ann_expr.cpp:44: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud/#199435/#199450} Execution of [TypeAnnotationTransformer::DoTransform] took 27us
2025-10-26T16:22:28.679627Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.679 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] yql_expr_constraint.cpp:3079: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud/#199435/#199450} Execution of [ConstraintTransformer::DoTransform] took 7us
2025-10-26T16:22:28.679635Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.679 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] type_ann_expr.cpp:44: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud/#199435/#199450} Execution of [TypeAnnotationTransformer::DoTransform] took 0us
2025-10-26T16:22:28.679649Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.679 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] yql_expr_constraint.cpp:3079: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud/#199435/#199450} Execution of [ConstraintTransformer::DoTransform] took 9us
2025-10-26T16:22:28.679666Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.679 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] yql_expr_csee.cpp:598: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud/#199435/#199450} Execution of [UpdateCompletness] took 10us
2025-10-26T16:22:28.679709Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.679 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] yql_expr_csee.cpp:611: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud/#199435/#199450} Execution of [EliminateCommonSubExpressionsForSubGraph] took 35us
2025-10-26T16:22:28.679774Z :YQL_PROXY TRACE: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.679 TRACE ydbd(pid=1984802, tid=0x00007EFC4E602640) [core peephole] yql_out_transformers.cpp:62: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud/#199435/#199450} PeepHoleOpt:
(
(let $1 (DataSource '"pq" '"myyds"))
(let $2 (StructType '('"Data" (DataType 'String))))
(let $3 (PqTopic '"myyds" '"local" '"select_dc_locality_input" '('('"PartitionsCount" '"1")) '() $2))
(let $4 (DqPqTopicSource $3 '('"Data") '('('"Endpoint" '"localhost:24793") '('"AddBearerToToken" '"1")) (SecureParam '"cluster:default_myyds")))
(let $5 (DqPhyStage '((DqSource $1 $4)) (lambda '($7) (block '(
  (let $8 (DqSourceWideWrap $7 $1 $2 '('('"format" '"raw") '('"formatSettings" '('('"data.datetime.formatname" '"POSIX") '('"data.timestamp.formatname" '"POSIX"))))))
  (return (FromFlow (NarrowMap $8 (lambda '($9) (AsStruct '('"Data" $9))))))
))) '('('"_logical_id" '199397) '('"_id" '"f66842cf-d2963b2e-86e6f3a8-250cec81"))))
(let $6 (DqPhyStage '((DqCnUnionAll (TDqOutput $5 '"0"))) (lambda '($10) $10) '('('"_logical_id" '199424) '('"_id" '"586107bb-14db53db-8ae69656-ef86eecc"))))
(return (DqCnResult (TDqOutput $6 '"0") '()))
)

2025-10-26T16:22:28.679961Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.679 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] type_ann_expr.cpp:44: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud/#199435/#199450} Execution of [TypeAnnotationTransformer::DoTransform] took 1us
2025-10-26T16:22:28.679970Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.679 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] yql_expr_constraint.cpp:3079: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud/#199435/#199450} Execution of [ConstraintTransformer::DoTransform] took 2us
2025-10-26T16:22:28.679979Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.679 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] yql_expr_csee.cpp:598: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud/#199435/#199450} Execution of [UpdateCompletness] took 7us
2025-10-26T16:22:28.680001Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.680 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] yql_expr_csee.cpp:611: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud/#199435/#199450} Execution of [EliminateCommonSubExpressionsForSubGraph] took 20us
2025-10-26T16:22:28.680050Z :YQL_PROXY TRACE: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.680 TRACE ydbd(pid=1984802, tid=0x00007EFC4E602640) [core peephole] yql_out_transformers.cpp:62: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud/#199435/#199450} PeepHoleOpt:
(
(let $1 (DataSource '"pq" '"myyds"))
(let $2 (StructType '('"Data" (DataType 'String))))
(let $3 (PqTopic '"myyds" '"local" '"select_dc_locality_input" '('('"PartitionsCount" '"1")) '() $2))
(let $4 (DqPqTopicSource $3 '('"Data") '('('"Endpoint" '"localhost:24793") '('"AddBearerToToken" '"1")) (SecureParam '"cluster:default_myyds")))
(let $5 (DqPhyStage '((DqSource $1 $4)) (lambda '($7) (block '(
  (let $8 (DqSourceWideWrap $7 $1 $2 '('('"format" '"raw") '('"formatSettings" '('('"data.datetime.formatname" '"POSIX") '('"data.timestamp.formatname" '"POSIX"))))))
  (return (FromFlow (NarrowMap $8 (lambda '($9) (AsStruct '('"Data" $9))))))
))) '('('"_logical_id" '199397) '('"_id" '"f66842cf-d2963b2e-86e6f3a8-250cec81"))))
(let $6 (DqPhyStage '((DqCnUnionAll (TDqOutput $5 '"0"))) (lambda '($10) $10) '('('"_logical_id" '199424) '('"_id" '"586107bb-14db53db-8ae69656-ef86eecc"))))
(return (DqCnResult (TDqOutput $6 '"0") '()))
)

2025-10-26T16:22:28.680118Z :YQL_PROXY INFO: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.680 INFO  ydbd(pid=1984802, tid=0x00007EFC4E602640) [core dq] yql_dq_exectransformer.cpp:376: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud/#199435/#199450} Setting block status for stage #199397 to None
2025-10-26T16:22:28.680171Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.680 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] type_ann_expr.cpp:44: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud/#199435/#199450} Execution of [TypeAnnotationTransformer::DoTransform] took 21us
2025-10-26T16:22:28.680197Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.680 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] yql_expr_constraint.cpp:3079: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud/#199435/#199450} Execution of [ConstraintTransformer::DoTransform] took 19us
2025-10-26T16:22:28.680214Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.680 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] yql_expr_csee.cpp:598: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud/#199435/#199450} Execution of [UpdateCompletness] took 10us
2025-10-26T16:22:28.680257Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.680 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] yql_expr_csee.cpp:611: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud/#199435/#199450} Execution of [EliminateCommonSubExpressionsForSubGraph] took 37us
2025-10-26T16:22:28.680321Z :YQL_PROXY TRACE: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.680 TRACE ydbd(pid=1984802, tid=0x00007EFC4E602640) [core peephole] yql_out_transformers.cpp:62: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud/#199435/#199450} PeepHoleOpt:
(
(let $1 (DataSource '"pq" '"myyds"))
(let $2 (StructType '('"Data" (DataType 'String))))
(let $3 (PqTopic '"myyds" '"local" '"select_dc_locality_input" '('('"PartitionsCount" '"1")) '() $2))
(let $4 (DqPqTopicSource $3 '('"Data") '('('"Endpoint" '"localhost:24793") '('"AddBearerToToken" '"1")) (SecureParam '"cluster:default_myyds")))
(let $5 '('('"_logical_id" '199397) '('"_id" '"f66842cf-d2963b2e-86e6f3a8-250cec81") '('"_block_status" '"None")))
(let $6 (DqPhyStage '((DqSource $1 $4)) (lambda '($8) (block '(
  (let $9 (DqSourceWideWrap $8 $1 $2 '('('"format" '"raw") '('"formatSettings" '('('"data.datetime.formatname" '"POSIX") '('"data.timestamp.formatname" '"POSIX"))))))
  (return (FromFlow (NarrowMap $9 (lambda '($10) (AsStruct '('"Data" $10))))))
))) $5))
(let $7 (DqPhyStage '((DqCnUnionAll (TDqOutput $6 '"0"))) (lambda '($11) $11) '('('"_logical_id" '199424) '('"_id" '"586107bb-14db53db-8ae69656-ef86eecc"))))
(return (DqCnResult (TDqOutput $7 '"0") '()))
)

2025-10-26T16:22:28.680387Z :YQL_PROXY INFO: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.680 INFO  ydbd(pid=1984802, tid=0x00007EFC4E602640) [core dq] yql_dq_exectransformer.cpp:376: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud/#199435/#199450} Setting block status for stage #199424 to None
2025-10-26T16:22:28.680424Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.680 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] type_ann_expr.cpp:44: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud/#199435/#199450} Execution of [TypeAnnotationTransformer::DoTransform] took 16us
2025-10-26T16:22:28.680444Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.680 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] yql_expr_constraint.cpp:3079: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud/#199435/#199450} Execution of [ConstraintTransformer::DoTransform] took 12us
2025-10-26T16:22:28.680460Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.680 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] yql_expr_csee.cpp:598: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud/#199435/#199450} Execution of [UpdateCompletness] took 9us
2025-10-26T16:22:28.680492Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.680 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [perf] yql_expr_csee.cpp:611: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud/#199435/#199450} Execution of [EliminateCommonSubExpressionsForSubGraph] took 29us
2025-10-26T16:22:28.680546Z :YQL_PROXY TRACE: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.680 TRACE ydbd(pid=1984802, tid=0x00007EFC4E602640) [core peephole] yql_out_transformers.cpp:62: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud/#199435/#199450} PeepHoleOpt:
(
(let $1 (DataSource '"pq" '"myyds"))
(let $2 (StructType '('"Data" (DataType 'String))))
(let $3 (PqTopic '"myyds" '"local" '"select_dc_locality_input" '('('"PartitionsCount" '"1")) '() $2))
(let $4 (DqPqTopicSource $3 '('"Data") '('('"Endpoint" '"localhost:24793") '('"AddBearerToToken" '"1")) (SecureParam '"cluster:default_myyds")))
(let $5 '('"_block_status" '"None"))
(let $6 '('('"_logical_id" '199397) '('"_id" '"f66842cf-d2963b2e-86e6f3a8-250cec81") $5))
(let $7 (DqPhyStage '((DqSource $1 $4)) (lambda '($10) (block '(
  (let $11 (DqSourceWideWrap $10 $1 $2 '('('"format" '"raw") '('"formatSettings" '('('"data.datetime.formatname" '"POSIX") '('"data.timestamp.formatname" '"POSIX"))))))
  (return (FromFlow (NarrowMap $11 (lambda '($12) (AsStruct '('"Data" $12))))))
))) $6))
(let $8 '('('"_logical_id" '199424) '('"_id" '"586107bb-14db53db-8ae69656-ef86eecc") $5))
(let $9 (DqPhyStage '((DqCnUnionAll (TDqOutput $7 '"0"))) (lambda '($13) $13) $8))
(return (DqCnResult (TDqOutput $9 '"0") '()))
)

2025-10-26T16:22:28.680687Z :YQL_PROXY TRACE: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.680 TRACE ydbd(pid=1984802, tid=0x00007EFC4E602640) [DQ] yql_dq_exectransformer.cpp:2069: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud/#199435/#199450} After PeepHole
(
(let $1 (DataSource '"pq" '"myyds"))
(let $2 (StructType '('"Data" (DataType 'String))))
(let $3 (PqTopic '"myyds" '"local" '"select_dc_locality_input" '('('"PartitionsCount" '"1")) '() $2))
(let $4 (DqPqTopicSource $3 '('"Data") '('('"Endpoint" '"localhost:24793") '('"AddBearerToToken" '"1")) (SecureParam '"cluster:default_myyds")))
(let $5 '('"_block_status" '"None"))
(let $6 '('('"_logical_id" '199397) '('"_id" '"f66842cf-d2963b2e-86e6f3a8-250cec81") $5))
(let $7 (DqPhyStage '((DqSource $1 $4)) (lambda '($10) (block '(
  (let $11 (DqSourceWideWrap $10 $1 $2 '('('"format" '"raw") '('"formatSettings" '('('"data.datetime.formatname" '"POSIX") '('"data.timestamp.formatname" '"POSIX"))))))
  (return (FromFlow (NarrowMap $11 (lambda '($12) (AsStruct '('"Data" $12))))))
))) $6))
(let $8 '('('"_logical_id" '199424) '('"_id" '"586107bb-14db53db-8ae69656-ef86eecc") $5))
(let $9 (DqPhyStage '((DqCnUnionAll (TDqOutput $7 '"0"))) (lambda '($13) $13) $8))
(return (DqCnResult (TDqOutput $9 '"0") '()))
)

2025-10-26T16:22:28.680812Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.680 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [DQ] execution_planner.cpp:152: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud/#199435/#199450} Execution Plan (
(let $1 (DataSource '"pq" '"myyds"))
(let $2 (StructType '('"Data" (DataType 'String))))
(let $3 (PqTopic '"myyds" '"local" '"select_dc_locality_input" '('('"PartitionsCount" '"1")) '() $2))
(let $4 (DqPqTopicSource $3 '('"Data") '('('"Endpoint" '"localhost:24793") '('"AddBearerToToken" '"1")) (SecureParam '"cluster:default_myyds")))
(let $5 '('"_block_status" '"None"))
(let $6 '('('"_logical_id" '199397) '('"_id" '"f66842cf-d2963b2e-86e6f3a8-250cec81") $5))
(let $7 (DqPhyStage '((DqSource $1 $4)) (lambda '($10) (block '(
  (let $11 (DqSourceWideWrap $10 $1 $2 '('('"format" '"raw") '('"formatSettings" '('('"data.datetime.formatname" '"POSIX") '('"data.timestamp.formatname" '"POSIX"))))))
  (return (FromFlow (NarrowMap $11 (lambda '($12) (AsStruct '('"Data" $12))))))
))) $6))
(let $8 '('('"_logical_id" '199424) '('"_id" '"586107bb-14db53db-8ae69656-ef86eecc") $5))
(let $9 (DqPhyStage '((DqCnUnionAll (TDqOutput $7 '"0"))) (lambda '($13) $13) $8))
(return (DqCnResult (TDqOutput $9 '"0") '()))
)

2025-10-26T16:22:28.680919Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.680 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [PQ] yql_pq_dq_integration.cpp:50: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud/#199435/#199450} Create DQ reading partition { PartitioningParams { TopicPartitionsCount: 1 DqPartitionsCount: 1 } }
2025-10-26T16:22:28.681060Z :YQL_PROXY TRACE: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.681 TRACE ydbd(pid=1984802, tid=0x00007EFC4E602640) [DQ] execution_planner.cpp:164: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud/#199435/#199450} Read stage (
(let $1 (DataSource '"pq" '"myyds"))
(let $2 (StructType '('"Data" (DataType 'String))))
(let $3 (PqTopic '"myyds" '"local" '"select_dc_locality_input" '('('"PartitionsCount" '"1")) '() $2))
(let $4 (DqPqTopicSource $3 '('"Data") '('('"Endpoint" '"localhost:24793") '('"AddBearerToToken" '"1")) (SecureParam '"cluster:default_myyds")))
(let $5 '('('"_logical_id" '199397) '('"_id" '"f66842cf-d2963b2e-86e6f3a8-250cec81") '('"_block_status" '"None")))
(return (DqPhyStage '((DqSource $1 $4)) (lambda '($6) (block '(
  (let $7 (DqSourceWideWrap $6 $1 $2 '('('"format" '"raw") '('"formatSettings" '('('"data.datetime.formatname" '"POSIX") '('"data.timestamp.formatname" '"POSIX"))))))
  (return (FromFlow (NarrowMap $7 (lambda '($8) (AsStruct '('"Data" $8))))))
))) $5))
)

2025-10-26T16:22:28.681101Z :YQL_PROXY TRACE: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.681 TRACE ydbd(pid=1984802, tid=0x00007EFC4E602640) [DQ] execution_planner.cpp:166: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud/#199435/#199450} Common stage (
(let $1 (DataSource '"pq" '"myyds"))
(let $2 (StructType '('"Data" (DataType 'String))))
(let $3 (PqTopic '"myyds" '"local" '"select_dc_locality_input" '('('"PartitionsCount" '"1")) '() $2))
(let $4 (DqPqTopicSource $3 '('"Data") '('('"Endpoint" '"localhost:24793") '('"AddBearerToToken" '"1")) (SecureParam '"cluster:default_myyds")))
(let $5 '('"_block_status" '"None"))
(let $6 '('('"_logical_id" '199397) '('"_id" '"f66842cf-d2963b2e-86e6f3a8-250cec81") $5))
(let $7 (DqPhyStage '((DqSource $1 $4)) (lambda '($9) (block '(
  (let $10 (DqSourceWideWrap $9 $1 $2 '('('"format" '"raw") '('"formatSettings" '('('"data.datetime.formatname" '"POSIX") '('"data.timestamp.formatname" '"POSIX"))))))
  (return (FromFlow (NarrowMap $10 (lambda '($11) (AsStruct '('"Data" $11))))))
))) $6))
(let $8 '('('"_logical_id" '199424) '('"_id" '"586107bb-14db53db-8ae69656-ef86eecc") $5))
(return (DqPhyStage '((DqCnUnionAll (TDqOutput $7 '"0"))) (lambda '($12) $12) $8))
)

2025-10-26T16:22:28.682912Z :FQ_RUN_ACTOR DEBUG: QueryId: ptqudttn7qgq6bfhs4q5 Graph (execution) with tasks: 2
2025-10-26T16:22:28.682928Z :YQL_PROXY INFO: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.682 INFO  ydbd(pid=1984802, tid=0x00007EFC4E602640) [core exec] yql_execution.cpp:466: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} Register async execution for node #199435
2025-10-26T16:22:28.682945Z :YQL_PROXY INFO: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.682 INFO  ydbd(pid=1984802, tid=0x00007EFC4E602640) [core exec] yql_execution.cpp:87: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} Finish, output #199437, status: Async
2025-10-26T16:22:28.683006Z :YQL_PROXY INFO: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.682 INFO  ydbd(pid=1984802, tid=0x00007EFC4CDFF640) [core exec] yql_execution.cpp:133: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} Completed async execution for node #199435
2025-10-26T16:22:28.683023Z :YQL_PROXY INFO: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.683 INFO  ydbd(pid=1984802, tid=0x00007EFC4CDFF640) [DQ] yql_dq_exectransformer.cpp:1463: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} Execution Pull complete, duration: 0.008921s
2025-10-26T16:22:28.683072Z :YQL_PROXY INFO: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.683 INFO  ydbd(pid=1984802, tid=0x00007EFC4CDFF640) [core exec] yql_execution.cpp:153: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} State is ExecutionComplete after apply async changes for node #199435
2025-10-26T16:22:28.683083Z :YQL_PROXY INFO: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.683 INFO  ydbd(pid=1984802, tid=0x00007EFC4CDFF640) [core exec] yql_execution.cpp:59: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} Begin, root #199437
2025-10-26T16:22:28.683087Z :YQL_PROXY INFO: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.683 INFO  ydbd(pid=1984802, tid=0x00007EFC4CDFF640) [core exec] yql_execution.cpp:72: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} Collect unused nodes for root #199437, status: Ok
2025-10-26T16:22:28.683092Z :YQL_PROXY TRACE: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.683 TRACE ydbd(pid=1984802, tid=0x00007EFC4CDFF640) [core exec] yql_execution.cpp:387: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} {0}, callable #199437 <Commit!>
2025-10-26T16:22:28.683109Z :YQL_PROXY TRACE: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.683 TRACE ydbd(pid=1984802, tid=0x00007EFC4CDFF640) [core exec] yql_execution.cpp:387: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} {1}, callable #199436 <Commit!>
2025-10-26T16:22:28.683121Z :YQL_PROXY INFO: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.683 INFO  ydbd(pid=1984802, tid=0x00007EFC4CDFF640) [core exec] yql_execution.cpp:577: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} Node #199436<Commit!> finished execution
2025-10-26T16:22:28.683134Z :YQL_PROXY INFO: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.683 INFO  ydbd(pid=1984802, tid=0x00007EFC4CDFF640) [core exec] yql_execution.cpp:594: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} Node #199436<Commit!> created 0 trackable nodes: 
2025-10-26T16:22:28.683142Z :YQL_PROXY TRACE: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.683 TRACE ydbd(pid=1984802, tid=0x00007EFC4CDFF640) [core exec] yql_execution.cpp:387: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} {0}, callable #199437 <Commit!>
2025-10-26T16:22:28.683149Z :YQL_PROXY INFO: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.683 INFO  ydbd(pid=1984802, tid=0x00007EFC4CDFF640) [core exec] yql_execution.cpp:577: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} Node #199437<Commit!> finished execution
2025-10-26T16:22:28.683152Z :YQL_PROXY INFO: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.683 INFO  ydbd(pid=1984802, tid=0x00007EFC4CDFF640) [core exec] yql_execution.cpp:594: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} Node #199437<Commit!> created 0 trackable nodes: 
2025-10-26T16:22:28.683156Z :YQL_PROXY INFO: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.683 INFO  ydbd(pid=1984802, tid=0x00007EFC4CDFF640) [core exec] yql_execution.cpp:87: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} Finish, output #199437, status: Ok
2025-10-26T16:22:28.683159Z :YQL_PROXY INFO: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.683 INFO  ydbd(pid=1984802, tid=0x00007EFC4CDFF640) [core exec] yql_execution.cpp:93: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} Creating finalizing transformer, output #199437
2025-10-26T16:22:28.683504Z :FQ_RUN_ACTOR DEBUG: QueryId: ptqudttn7qgq6bfhs4q5 Overall dq tasks: 2
2025-10-26T16:22:28.683539Z :FQ_RUN_ACTOR DEBUG: QueryId: ptqudttn7qgq6bfhs4q5 Graph 0
2025-10-26T16:22:28.683541Z :FQ_PINGER TRACE: QueryId: ptqudttn7qgq6bfhs4q5, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0711 Forward ping request: { ast: "(\n(let $1 (Configure! world (DataSource \'\"config\") \'\"DqEngine\" \'\"force\"))\n(let $2 (DataSink \'result))\n(let $3 (DataSource \'\"pq\" \'\"myyds\"))\n(let $4 (StructType \'(\'\"Data\" (DataType \'String))))\n(let $5 (PqTopic \'\"myyds\" \'\"local\" \'\"select_dc_locality_input\" \'(\'(\'\"PartitionsCount\" \'\"1\")) \'() $4))\n(let $6 (DqPqTopicSource $5 \'(\'\"Data\") \'(\'(\'\"Endpoint\" \'\"localhost:24793\") \'(\'\"AddBearerToToken\" \'\"1\")) (SecureParam \'\"cluster:default_myyds\")))\n(let $7 (DqStage \'((DqSource $3 $6)) (lambda \'($10) (block \'(\n  (let $11 (DqSourceWideWrap $10 $3 $4 \'(\'(\'\"format\" \'\"raw\") \'(\'\"formatSettings\" \'(\'(\'\"data.datetime.formatname\" \'\"POSIX\") \'(\'\"data.timestamp.formatname\" \'\"POSIX\"))))))\n  (return (NarrowMap $11 (lambda \'($12) (AsStruct \'(\'\"Data\" $12)))))\n))) \'(\'(\'\"_logical_id\" \'199397))))\n(let $8 (DqStage \'((DqCnUnionAll (TDqOutput $7 \'\"0\"))) (lambda \'($13) $13) \'(\'(\'\"_logical_id\" \'199424))))\n(let $9 (ResPull! $1 $2 (Key) (DqCnResult (TDqOutput $8 \'\"0\") \'()) \'(\'(\'type) \'(\'autoref)) \'\"dq\"))\n(return (Commit! (Commit! $9 $2) (DataSink \'\"pq\" \'\"myyds\")))\n)\n" plan: "{\"Detailed\":{\"Operations\":[{\"Id\":8,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[{\"Name\":\"DqSourceWideWrap\"},{\"Name\":\"NarrowMap\"}]}},{\"Id\":6,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[]},\"DependsOn\":[8]},{\"Id\":3,\"Name\":\"ResPull!\",\"DependsOn\":[6]},{\"Id\":1,\"Name\":\"Commit!\",\"DependsOn\":[3]}],\"OperationRoot\":1,\"Providers\":[],\"OperationStats\":{\"Commit!\":1,\"DqStage\":2,\"ResPull!\":1}},\"Basic\":{\"nodes\":[{\"id\":8,\"level\":1,\"name\":\"DqStage #8\",\"type\":\"op\"},{\"id\":6,\"level\":2,\"name\":\"DqStage #6\",\"type\":\"op\"},{\"id\":3,\"level\":3,\"name\":\"ResPull!\",\"type\":\"op\"},{\"id\":1,\"level\":4,\"name\":\"Commit!\",\"type\":\"op\"}],\"links\":[{\"source\":8,\"target\":6},{\"source\":6,\"target\":3},{\"source\":3,\"target\":1}]}}" }
2025-10-26T16:22:28.683577Z :FQ_RUN_ACTOR DEBUG: QueryId: ptqudttn7qgq6bfhs4q5 Create consumer "ptqudttn7qgq6bfhs4q5" for topic "select_dc_locality_input"
2025-10-26T16:22:28.683664Z :FQ_PINGER TRACE: QueryId: ptqudttn7qgq6bfhs4q5, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0711 Forward ping request: { result_set_count: 1 result_set_meta { column { name: "Data" type { type_id: STRING } } } dq_graph: "\022\227\004\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*\257\001Z\254\001\n\010PqSource\022\235\001\n4type.googleapis.com/NYql.NPq.NProto.TDqPqTopicSource\022e\n\030select_dc_locality_input\022\024ptqudttn7qgq6bfhs4q5\032\017localhost:24793\"\027\n\025cluster:default_myyds*\005local0\002@\001\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\335\226\014`\356\226\014R\000:\203\001\n*type.googleapis.com/Yql.DqsProto.TTaskMeta\022U\010\335\226\014\022A\022(fdf4d714894959461510bca89fc9c78fb17340e9\032\023dq_vanilla_job.lite \002\"\014\n\002pq\022\006\n\004\010\001\030\001H\335\226\014RClocal/RateLimiter_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/rate_limiterZ)mock_cloud/my_folder/ptqudttn7qgq6bfhs4q5`\200\200\200\200 \230\001\000\022\220\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\335\226\014`\356\226\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\356\226\014\022A\022(fdf4d714894959461510bca89fc9c78fb17340e9\032\023dq_vanilla_job.lite \002H\356\226\014RClocal/RateLimiter_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/rate_limiterZ)mock_cloud/my_folder/ptqudttn7qgq6bfhs4q5`\200\200\200\200 \230\001\000\030\001\"\r\037\000\205\002\203\005@\020Data/*\004Data2rptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#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:\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\025cluster:default_myyds\022\016{\"no_auth\":\"\"}b\202\002\010\335\226\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\356\226\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/" }
2025-10-26T16:22:28.762782Z :FQ_PINGER TRACE: QueryId: ptqudttn7qgq6bfhs4q5, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0711 Ping response success: { expired_at { seconds: 1761495758 nanos: 708000000 } }
2025-10-26T16:22:28.762809Z :FQ_PINGER TRACE: QueryId: ptqudttn7qgq6bfhs4q5, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0711 Forward request Private::PingTask
2025-10-26T16:22:28.762837Z :FQ_RUN_ACTOR TRACE: QueryId: ptqudttn7qgq6bfhs4q5 Forward ping response. Success: 1. Cookie: 2
2025-10-26T16:22:28.773840Z :FQ_PINGER TRACE: QueryId: ptqudttn7qgq6bfhs4q5, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0711 Ping response success: { expired_at { seconds: 1761495758 nanos: 768000000 } }
2025-10-26T16:22:28.773863Z :FQ_PINGER TRACE: QueryId: ptqudttn7qgq6bfhs4q5, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0711 Forward request Private::PingTask
2025-10-26T16:22:28.773887Z :FQ_RUN_ACTOR TRACE: QueryId: ptqudttn7qgq6bfhs4q5 Forward ping response. Success: 1. Cookie: 0
2025-10-26T16:22:28.782321Z :FQ_PINGER TRACE: QueryId: ptqudttn7qgq6bfhs4q5, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0711 Ping response success: { expired_at { seconds: 1761495758 nanos: 777000000 } }
2025-10-26T16:22:28.782342Z :FQ_PINGER TRACE: QueryId: ptqudttn7qgq6bfhs4q5, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0711 Forward request Private::PingTask
2025-10-26T16:22:28.782356Z :FQ_RUN_ACTOR TRACE: QueryId: ptqudttn7qgq6bfhs4q5 Forward ping response. Success: 1. Cookie: 0
2025-10-26T16:22:28.792236Z :FQ_PINGER TRACE: QueryId: ptqudttn7qgq6bfhs4q5, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0711 Ping response success: { expired_at { seconds: 1761495758 nanos: 787000000 } }
2025-10-26T16:22:28.792258Z :FQ_PINGER TRACE: QueryId: ptqudttn7qgq6bfhs4q5, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0711 Forward request Private::PingTask
2025-10-26T16:22:28.792281Z :FQ_RUN_ACTOR TRACE: QueryId: ptqudttn7qgq6bfhs4q5 Forward ping response. Success: 1. Cookie: 0
2025-10-26T16:22:28.801248Z :FQ_PINGER TRACE: QueryId: ptqudttn7qgq6bfhs4q5, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0711 Ping response success: { expired_at { seconds: 1761495758 nanos: 796000000 } }
2025-10-26T16:22:28.801286Z :FQ_RUN_ACTOR TRACE: QueryId: ptqudttn7qgq6bfhs4q5 Forward ping response. Success: 1. Cookie: 1
2025-10-26T16:22:28.801355Z :STREAMS DEBUG: ptqudttn7qgq6bfhs4q5: Create read rule creation actor for `select_dc_locality_input` [0]
2025-10-26T16:22:28.801385Z :STREAMS DEBUG: ptqudttn7qgq6bfhs4q5: Make request for read rule creation for topic `select_dc_locality_input` [0]
2025-10-26T16:22:28.801395Z :FQ_PINGER TRACE: QueryId: ptqudttn7qgq6bfhs4q5, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0711 Forward ping request: { owner_id: "717f0dae-ec1c1334-99acf168-5d9efd0711" query_id { value: "ptqudttn7qgq6bfhs4q5" } status: RUNNING result_set_count: 1 result_set_meta { column { name: "Data" type { type_id: STRING } } } resources { rate_limiter: READY compilation: READY topic_consumers_state: PREPARE rate_limiter_path: "local/RateLimiter_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/rate_limiter" topic_consumers { database: "local" topic_path: "select_dc_locality_input" consumer_name: "ptqudttn7qgq6bfhs4q5" cluster_endpoint: "localhost:24793" token_name: "cluster:default_myyds" add_bearer_to_token: true } } scope: "yandexcloud://my_folder" }
2025-10-26T16:22:28.801400Z :FQ_PINGER TRACE: QueryId: ptqudttn7qgq6bfhs4q5, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0711 Forward request Private::PingTask
2025-10-26T16:22:28.810199Z :FQ_PINGER TRACE: QueryId: ptqudttn7qgq6bfhs4q5, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0711 Ping response success: { expired_at { seconds: 1761495758 nanos: 805000000 } }
2025-10-26T16:22:28.810243Z :FQ_RUN_ACTOR TRACE: QueryId: ptqudttn7qgq6bfhs4q5 Forward ping response. Success: 1. Cookie: 0
2025-10-26T16:22:28.814495Z :FQ_RUN_ACTOR DEBUG: QueryId: ptqudttn7qgq6bfhs4q5 Read rules creation finished. Issues: 0
2025-10-26T16:22:28.814527Z :FQ_RUN_ACTOR DEBUG: QueryId: ptqudttn7qgq6bfhs4q5 Overall dq tasks: 2
2025-10-26T16:22:28.814612Z :FQ_PINGER TRACE: QueryId: ptqudttn7qgq6bfhs4q5, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0711 Forward ping request: { owner_id: "717f0dae-ec1c1334-99acf168-5d9efd0711" query_id { value: "ptqudttn7qgq6bfhs4q5" } status: RUNNING result_set_count: 1 result_set_meta { column { name: "Data" type { type_id: STRING } } } resources { rate_limiter: READY compilation: READY topic_consumers_state: READY rate_limiter_path: "local/RateLimiter_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/rate_limiter" topic_consumers { database: "local" topic_path: "select_dc_locality_input" consumer_name: "ptqudttn7qgq6bfhs4q5" cluster_endpoint: "localhost:24793" token_name: "cluster:default_myyds" add_bearer_to_token: true } } scope: "yandexcloud://my_folder" }
2025-10-26T16:22:28.814621Z :FQ_PINGER TRACE: QueryId: ptqudttn7qgq6bfhs4q5, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0711 Forward request Private::PingTask
2025-10-26T16:22:28.814762Z :FQ_RESULT_WRITER INFO: TraceId: ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud Bootstrap
2025-10-26T16:22:28.814774Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.814 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [DQ] task_controller_impl.h:78: _AllResultsBytesLimit = 100000
2025-10-26T16:22:28.814778Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.814 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [DQ] task_controller_impl.h:81: _RowsLimitPerWrite = 1000
2025-10-26T16:22:28.814910Z :FQ_RUN_ACTOR DEBUG: QueryId: ptqudttn7qgq6bfhs4q5 Executer: [2:7565566631326736921:59], Controller: [2:7565566631326736923:38], ResultIdActor: [2:7565566631326736922:19]
2025-10-26T16:22:28.814929Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.814 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [DQ] executer_actor.cpp:140: {ptqudttn7qgq6bfhs4q5} TDqExecuter::OnGraph
2025-10-26T16:22:28.814939Z :YQL_PROXY INFO: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.814 INFO  ydbd(pid=1984802, tid=0x00007EFC4E602640) [DQ] executer_actor.cpp:157: {ptqudttn7qgq6bfhs4q5} Trying to allocate 2 workers [EnableComputeActor=1]
2025-10-26T16:22:28.815084Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.815 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [DQ] executer_actor.cpp:245: {ptqudttn7qgq6bfhs4q5} Dq timeouts are set to: 0.000000s (global), 600.000000s (workers allocation fail), 30.000000s (workers allocation warn) 
2025-10-26T16:22:28.815800Z :YQL_NODES_MANAGER DEBUG: TEvAllocateWorkersResponse Nodes {
  ResourceId: 4294967298
  Worker {
    NodeId: 2
    Guid: "aa0d4238-4b619a4d-2cfd599a-3469a662,ghrun-zwq4uro7ay"
  }
  Worker {
    NodeId: 4
    Guid: "3046c52d-46ac25d3-538fd59d-dfceb0bc,ghrun-zwq4uro7ay"
  }
}
2025-10-26T16:22:28.816226Z :KQP_COMPUTE DEBUG: SelfId: [2:7565566631326736927:60], TxId: ptqudttn7qgq6bfhs4q5, task: 1. Ctx: {}. Start compute actor [2:7565566631326736927:60], task: 1
2025-10-26T16:22:28.816271Z :KQP_COMPUTE DEBUG: SelfId: [2:7565566631326736927:60], TxId: ptqudttn7qgq6bfhs4q5, task: 1. Ctx: {}. Use CPU quota: 1. Rate limiter resource: { "local/RateLimiter_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/rate_limiter", "mock_cloud/my_folder/ptqudttn7qgq6bfhs4q5" }
2025-10-26T16:22:28.818382Z :INTERCONNECT WARN: Handshake [2:7565566631326736932:1362] [node 4] ICH09 Neither CompatibilityInfo nor VersionTag of the peer can be validated, accepting by default
2025-10-26T16:22:28.825559Z :FQ_PINGER TRACE: QueryId: ptqudttn7qgq6bfhs4q5, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0711 Ping response success: { expired_at { seconds: 1761495758 nanos: 819000000 } }
2025-10-26T16:22:28.825601Z :FQ_RUN_ACTOR TRACE: QueryId: ptqudttn7qgq6bfhs4q5 Forward ping response. Success: 1. Cookie: 0
2025-10-26T16:22:28.827404Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.827 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [DQ] executer_actor.cpp:355: {ptqudttn7qgq6bfhs4q5} TDqExecuter::TEvAllocateWorkersResponse
2025-10-26T16:22:28.827418Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.827 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [DQ] executer_actor.cpp:381: {ptqudttn7qgq6bfhs4q5} Allocated resource 4294967298
2025-10-26T16:22:28.827475Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.827 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [DQ] executer_actor.cpp:398: {ptqudttn7qgq6bfhs4q5} WorkerInfo: Id:aa0d4238-4b619a4d-2cfd599a-3469a662,ghrun-zwq4uro7ay,NodeId:2,StageId:199517
2025-10-26T16:22:28.827483Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.827 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [DQ] executer_actor.cpp:399: {ptqudttn7qgq6bfhs4q5} TaskInfo: 0/1
2025-10-26T16:22:28.827488Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.827 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [DQ] executer_actor.cpp:401: {ptqudttn7qgq6bfhs4q5}  ObjectId: fdf4d714894959461510bca89fc9c78fb17340e9, dq_vanilla_job.lite, 
2025-10-26T16:22:28.827505Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.827 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [DQ] executer_actor.cpp:398: {ptqudttn7qgq6bfhs4q5} WorkerInfo: Id:3046c52d-46ac25d3-538fd59d-dfceb0bc,ghrun-zwq4uro7ay,NodeId:4,StageId:199534
2025-10-26T16:22:28.827509Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.827 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [DQ] executer_actor.cpp:399: {ptqudttn7qgq6bfhs4q5} TaskInfo: 1/2
2025-10-26T16:22:28.827512Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.827 DEBUG ydbd(pid=1984802, tid=0x00007EFC4E602640) [DQ] executer_actor.cpp:401: {ptqudttn7qgq6bfhs4q5}  ObjectId: fdf4d714894959461510bca89fc9c78fb17340e9, dq_vanilla_job.lite, 
2025-10-26T16:22:28.827520Z :YQL_PROXY INFO: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:28.827 INFO  ydbd(pid=1984802, tid=0x00007EFC4E602640) [DQ] executer_actor.cpp:412: {ptqudttn7qgq6bfhs4q5} 2 workers allocated
2025-10-26T16:22:28.827738Z :YQL_PROXY TRACE: SessionId: 717f0dae-ec1c1334-99acf168-5d9efd07 2025-10-26 16:22:28.827 TRACE ydbd(pid=1984802, tid=0x00007EFC4BDED640) [DQ] task_controller_impl.h:270: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud}  [2:7565566631326736923:38] ExportStats Summary
2025-10-26T16:22:28.827778Z :YQL_PROXY DEBUG: SessionId: 717f0dae-ec1c1334-99acf168-5d9efd07 2025-10-26 16:22:28.827 DEBUG ydbd(pid=1984802, tid=0x00007EFC4BDED640) [DQ] task_controller_impl.h:500: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} Ready State: [2:7565566631326736923:38]
2025-10-26T16:22:28.827797Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: [ptqudttn7qgq6bfhs4q5-0.1] TEvReadyState, streaming disposition { fresh { } }, state load mode EMPTY
2025-10-26T16:22:28.827830Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: [ptqudttn7qgq6bfhs4q5-0.1] Send TEvRegisterCoordinatorRequest
2025-10-26T16:22:28.827862Z :STREAMS_STORAGE_SERVICE DEBUG: [ptqudttn7qgq6bfhs4q5-0.1] Got TEvRegisterCoordinatorRequest
2025-10-26T16:22:28.861358Z :STREAMS_STORAGE_SERVICE INFO: [ptqudttn7qgq6bfhs4q5-0.1] Graph registered
2025-10-26T16:22:28.861374Z :STREAMS_STORAGE_SERVICE DEBUG: [ptqudttn7qgq6bfhs4q5-0.1] Send TEvRegisterCoordinatorResponse
2025-10-26T16:22:28.861419Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: [ptqudttn7qgq6bfhs4q5-0.1] Got TEvRegisterCoordinatorResponse; issues: 
2025-10-26T16:22:28.861423Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: [ptqudttn7qgq6bfhs4q5-0.1] Successfully registered in storage
2025-10-26T16:22:28.861426Z :STREAMS_CHECKPOINT_COORDINATOR INFO: [ptqudttn7qgq6bfhs4q5-0.1] Send TEvNewCheckpointCoordinator to 2 actor(s)
2025-10-26T16:22:28.861436Z :STREAMS_CHECKPOINT_COORDINATOR INFO: [ptqudttn7qgq6bfhs4q5-0.1] [1:1] Registering new checkpoint in storage
2025-10-26T16:22:28.861550Z :STREAMS_STORAGE_SERVICE DEBUG: [ptqudttn7qgq6bfhs4q5-0.1] [1:1] Got TEvCreateCheckpointRequest
2025-10-26T16:22:28.861575Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: [ptqudttn7qgq6bfhs4q5-0.1] Handle connected node 4
2025-10-26T16:22:28.893007Z :FQ_QUOTA_SERVICE TRACE: cloud.mock_cloud.yq.cpuPercent.count=0/200 UPDATE from Peer 1
2025-10-26T16:22:28.897222Z :FQ_QUOTA_SERVICE TRACE: cloud.mock_cloud.yq.streamingQuery.count=1/100 UPDATE from Peer 1
2025-10-26T16:22:28.897378Z :FQ_QUOTA_SERVICE TRACE: cloud.mock_cloud.yq.analyticsQuery.count=1/100 UPDATE from Peer 1
2025-10-26T16:22:28.911347Z :KQP_COMPUTE DEBUG: [] Task: 1. Got TEvNewCheckpointCoordinator event: generation 1, actorId: [2:7565566631326736923:38]
2025-10-26T16:22:28.911357Z :KQP_COMPUTE TRACE: [] Task: 1. Assign checkpoint coordinator (generation = 1)
2025-10-26T16:22:28.911947Z :KQP_COMPUTE DEBUG: SelfId: [2:7565566631326736927:60], TxId: ptqudttn7qgq6bfhs4q5, task: 1. Ctx: {}. Create source for input 0 { Source { Type: "PqSource" Settings { type_url: "type.googleapis.com/NYql.NPq.NProto.TDqPqTopicSource" value: "\n\030select_dc_locality_input\022\024ptqudttn7qgq6bfhs4q5\032\017localhost:24793\"\027\n\025cluster:default_myyds*\005local0\002@\001" } WatermarksMode: WATERMARKS_MODE_DISABLED } }
2025-10-26T16:22:28.912007Z :KQP_COMPUTE DEBUG: SelfId: [0:0:0], TxId: ptqudttn7qgq6bfhs4q5, task: 1. PQ source. SessionId: empty Watermarks enabled: 0 granularity: 0 microseconds
2025-10-26T16:22:28.912650Z :KQP_COMPUTE DEBUG: SelfId: [2:7565566631326736927:60], TxId: ptqudttn7qgq6bfhs4q5, task: 1. Ctx: {}. Received channels info: Update { Id: 1 TransportVersion: DATA_TRANSPORT_UV_PICKLE_1_0 SrcTaskId: 1 DstTaskId: 2 SrcEndpoint { ActorId { RawX1: 7565566631326736927 RawX2: 4503608217305148 } } DstEndpoint { ActorId { RawX1: 7565566633608213054 RawX2: 4503616807239713 } } SrcStageId: 199517 DstStageId: 199534 }
2025-10-26T16:22:28.912661Z :KQP_COMPUTE DEBUG: SelfId: [2:7565566631326736927:60], TxId: ptqudttn7qgq6bfhs4q5, task: 1. Ctx: {}. Update output channelId: 1, peer: [4:7565566633608213054:33]
2025-10-26T16:22:29.000537Z :STREAMS_STORAGE_SERVICE INFO: [ptqudttn7qgq6bfhs4q5-0.1] [1:1] Checkpoint created
2025-10-26T16:22:29.000548Z :STREAMS_STORAGE_SERVICE DEBUG: [ptqudttn7qgq6bfhs4q5-0.1] [1:1] Send TEvCreateCheckpointResponse
2025-10-26T16:22:29.000571Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: [ptqudttn7qgq6bfhs4q5-0.1] [1:1] Got TEvCreateCheckpointResponse
2025-10-26T16:22:29.000576Z :STREAMS_CHECKPOINT_COORDINATOR INFO: [ptqudttn7qgq6bfhs4q5-0.1] [1:1] Checkpoint successfully created, going to inject barriers to 1 actor(s)
2025-10-26T16:22:29.000592Z :STREAMS_CHECKPOINT_COORDINATOR INFO: [ptqudttn7qgq6bfhs4q5-0.1] [1:1] Send TEvRun to all actors
2025-10-26T16:22:29.000619Z :KQP_COMPUTE DEBUG: [ptqudttn7qgq6bfhs4q5-0] Task: 1. [Checkpoint 1.1] TEvInjectCheckpoint
2025-10-26T16:22:29.000629Z :KQP_COMPUTE DEBUG: SelfId: [2:7565566631326736927:60], TxId: ptqudttn7qgq6bfhs4q5, task: 1. Ctx: {}. Got TEvRun from actor [2:7565566631326736923:38]
2025-10-26T16:22:29.000639Z :KQP_COMPUTE TRACE: SelfId: [2:7565566631326736927:60], TxId: ptqudttn7qgq6bfhs4q5, task: 1. Ctx: {}. Skip polling sources because of pending checkpoint
2025-10-26T16:22:29.000646Z :KQP_COMPUTE TRACE: SelfId: [2:7565566631326736927:60], TxId: ptqudttn7qgq6bfhs4q5, task: 1. Ctx: {}. DoExecuteImpl: 1
2025-10-26T16:22:29.000728Z :KQP_COMPUTE TRACE: TxId: ptqudttn7qgq6bfhs4q5, task: 1. Peak memory usage: 131072
2025-10-26T16:22:29.000749Z :KQP_COMPUTE TRACE: SelfId: [2:7565566631326736927:60], TxId: ptqudttn7qgq6bfhs4q5, task: 1. Ctx: {}. update task runner stats
2025-10-26T16:22:29.000772Z :KQP_COMPUTE TRACE: SelfId: [2:7565566631326736927:60], TxId: ptqudttn7qgq6bfhs4q5, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 1 watermark injected: 0
2025-10-26T16:22:29.000775Z :KQP_COMPUTE DEBUG: [ptqudttn7qgq6bfhs4q5-0] Task: 1. [Checkpoint 1.1] Performing task checkpoint
2025-10-26T16:22:29.000778Z :KQP_COMPUTE DEBUG: SelfId: [2:7565566631326736927:60], TxId: ptqudttn7qgq6bfhs4q5, task: 1. Ctx: {}. Save state
2025-10-26T16:22:29.000791Z :KQP_COMPUTE TRACE: [ptqudttn7qgq6bfhs4q5-0] Task: 1. [Checkpoint 1.1] CA state saved
2025-10-26T16:22:29.000793Z :KQP_COMPUTE TRACE: [ptqudttn7qgq6bfhs4q5-0] Task: 1. [Checkpoint 1.1] Injecting checkpoint barrier to outputs
2025-10-26T16:22:29.000804Z :KQP_COMPUTE DEBUG: [ptqudttn7qgq6bfhs4q5-0] Task: 1. [Checkpoint 1.1] Task checkpoint is done. Send to storage
2025-10-26T16:22:29.000806Z :KQP_COMPUTE TRACE: SelfId: [2:7565566631326736927:60], TxId: ptqudttn7qgq6bfhs4q5, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-10-26T16:22:29.000812Z :KQP_COMPUTE TRACE: SelfId: [2:7565566631326736927:60], TxId: ptqudttn7qgq6bfhs4q5, task: 1. Ctx: {}. About to drain channelId: 1, hasPeer: 1, peerState:(freeSpace:1000000;inFlightBytes:0;inFlightCount:0;)
2025-10-26T16:22:29.000814Z :STREAMS_STORAGE_SERVICE DEBUG: [ptqudttn7qgq6bfhs4q5-0] [1:1] Got TEvSaveTaskState: task 1
2025-10-26T16:22:29.000829Z :KQP_COMPUTE TRACE: TxId: ptqudttn7qgq6bfhs4q5, task: 1. SendChannelData, channelId: 1, peer: [4:7565566633608213054:33], rows: 0, bytes: 0, watermark: 0, checkpoint: 1, seqNo: 1, finished: 0
2025-10-26T16:22:29.000844Z :KQP_COMPUTE TRACE: SelfId: [2:7565566631326736927:60], TxId: ptqudttn7qgq6bfhs4q5, task: 1. Ctx: {}. Poll sources
2025-10-26T16:22:29.000848Z :KQP_COMPUTE TRACE: SelfId: [0:0:0], TxId: ptqudttn7qgq6bfhs4q5, task: 1. PQ source. SessionId: empty GetAsyncInputData freeSpace = 1000000
2025-10-26T16:22:29.000870Z :KQP_COMPUTE DEBUG: SelfId: [0:0:0], TxId: ptqudttn7qgq6bfhs4q5, task: 1. PQ source. SessionId: empty PartitionsToRead: 0
2025-10-26T16:22:29.000898Z :YDB_SDK INFO: 2025-10-26T16:22:29.000894Z :INFO: [local] [local] [cc264365-8e5e2c7-37d1e99b-ce952c65] Starting read session
2025-10-26T16:22:29.000919Z :YDB_SDK DEBUG: 2025-10-26T16:22:29.000916Z :DEBUG: [local] [local] [cc264365-8e5e2c7-37d1e99b-ce952c65] Starting single session
2025-10-26T16:22:29.001168Z :FQ_RESULT_WRITER TRACE: TraceId: ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud ChannelData Shift, Records: 0 HasError: 0 Size: 0 Rows: 0 FreeSpace: 67108864 Duration: 0.186415s AvgSpeed: 0
2025-10-26T16:22:29.001443Z :YDB_SDK DEBUG: 2025-10-26T16:22:29.001438Z :DEBUG: [local] [local] [cc264365-8e5e2c7-37d1e99b-ce952c65] [] In Reconnect, ReadSizeBudget = 8388608, ReadSizeServerDelta = 0
2025-10-26T16:22:29.001454Z :YDB_SDK DEBUG: 2025-10-26T16:22:29.001451Z :DEBUG: [local] [local] [cc264365-8e5e2c7-37d1e99b-ce952c65] [] New values: ReadSizeBudget = 8388608, ReadSizeServerDelta = 0
2025-10-26T16:22:29.001458Z :YDB_SDK DEBUG: 2025-10-26T16:22:29.001457Z :DEBUG: [local] [local] [cc264365-8e5e2c7-37d1e99b-ce952c65] [] Reconnecting session to cluster  in 0.000000s
2025-10-26T16:22:29.001634Z :KQP_COMPUTE INFO: SelfId: [0:0:0], TxId: ptqudttn7qgq6bfhs4q5, task: 1. PQ source. SessionId: cc264365-8e5e2c7-37d1e99b-ce952c65 CreateReadSession
2025-10-26T16:22:29.001649Z :KQP_COMPUTE TRACE: Poll async input 0. Buffer free space: 1000000, read from async input: 0 bytes, 0 rows, finished: 0
2025-10-26T16:22:29.001664Z :KQP_COMPUTE TRACE: SelfId: [2:7565566631326736927:60], TxId: ptqudttn7qgq6bfhs4q5, task: 1. Ctx: {}. Poll inputs
2025-10-26T16:22:29.001676Z :YDB_SDK DEBUG: 2025-10-26T16:22:29.001661Z :DEBUG: [local] [local] [cc264365-8e5e2c7-37d1e99b-ce952c65] [] Successfully connected. Initializing session
2025-10-26T16:22:29.001683Z :KQP_COMPUTE TRACE: TxId: ptqudttn7qgq6bfhs4q5, task: 1. Received channel data ack for channelId: 1, seqNo: 1, lastSentSeqNo: 1, freeSpace: 1000000, early finish: 0
2025-10-26T16:22:29.001687Z :KQP_COMPUTE TRACE: TxId: ptqudttn7qgq6bfhs4q5, task: 1. PeerState, peerState:(freeSpace:1000000;inFlightBytes:0;inFlightCount:0;), sentSeqNo: 1, ackSeqNo: 1
2025-10-26T16:22:29.001689Z :KQP_COMPUTE TRACE: TxId: ptqudttn7qgq6bfhs4q5, task: 1. Resume compute actor
2025-10-26T16:22:29.001697Z :KQP_COMPUTE TRACE: SelfId: [2:7565566631326736927:60], TxId: ptqudttn7qgq6bfhs4q5, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-10-26T16:22:29.001702Z :KQP_COMPUTE TRACE: SelfId: [2:7565566631326736927:60], TxId: ptqudttn7qgq6bfhs4q5, task: 1. Ctx: {}. Poll sources
2025-10-26T16:22:29.001705Z :KQP_COMPUTE TRACE: SelfId: [0:0:0], TxId: ptqudttn7qgq6bfhs4q5, task: 1. PQ source. SessionId: cc264365-8e5e2c7-37d1e99b-ce952c65 GetAsyncInputData freeSpace = 1000000
2025-10-26T16:22:29.001708Z :KQP_COMPUTE TRACE: Poll async input 0. Buffer free space: 1000000, read from async input: 0 bytes, 0 rows, finished: 0
2025-10-26T16:22:29.001711Z :KQP_COMPUTE TRACE: SelfId: [2:7565566631326736927:60], TxId: ptqudttn7qgq6bfhs4q5, task: 1. Ctx: {}. Poll inputs
2025-10-26T16:22:29.001749Z :KQP_COMPUTE TRACE: TxId: ptqudttn7qgq6bfhs4q5, task: 1. Peak memory usage: 131072
2025-10-26T16:22:29.001760Z :KQP_COMPUTE TRACE: SelfId: [2:7565566631326736927:60], TxId: ptqudttn7qgq6bfhs4q5, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-10-26T16:22:29.001762Z :KQP_COMPUTE TRACE: SelfId: [2:7565566631326736927:60], TxId: ptqudttn7qgq6bfhs4q5, task: 1. Ctx: {}. update task runner stats
2025-10-26T16:22:29.001777Z :KQP_COMPUTE TRACE: SelfId: [2:7565566631326736927:60], TxId: ptqudttn7qgq6bfhs4q5, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: 0
2025-10-26T16:22:29.001779Z :KQP_COMPUTE TRACE: SelfId: [2:7565566631326736927:60], TxId: ptqudttn7qgq6bfhs4q5, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-10-26T16:22:29.001782Z :KQP_COMPUTE TRACE: SelfId: [2:7565566631326736927:60], TxId: ptqudttn7qgq6bfhs4q5, task: 1. Ctx: {}. About to drain channelId: 1, hasPeer: 1, peerState:(freeSpace:1000000;inFlightBytes:0;inFlightCount:0;)
2025-10-26T16:22:29.001795Z :KQP_COMPUTE TRACE: TxId: ptqudttn7qgq6bfhs4q5, task: 1. Peak memory usage: 131072
2025-10-26T16:22:29.001799Z :KQP_COMPUTE TRACE: SelfId: [2:7565566631326736927:60], TxId: ptqudttn7qgq6bfhs4q5, task: 1. Ctx: {}. update task runner stats
2025-10-26T16:22:29.001804Z :KQP_COMPUTE TRACE: SelfId: [2:7565566631326736927:60], TxId: ptqudttn7qgq6bfhs4q5, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: 0
2025-10-26T16:22:29.001805Z :KQP_COMPUTE TRACE: SelfId: [2:7565566631326736927:60], TxId: ptqudttn7qgq6bfhs4q5, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-10-26T16:22:29.001807Z :KQP_COMPUTE TRACE: SelfId: [2:7565566631326736927:60], TxId: ptqudttn7qgq6bfhs4q5, task: 1. Ctx: {}. About to drain channelId: 1, hasPeer: 1, peerState:(freeSpace:1000000;inFlightBytes:0;inFlightCount:0;)
2025-10-26T16:22:29.003260Z :YDB_SDK INFO: 2025-10-26T16:22:29.003250Z :INFO: [local] [local] [cc264365-8e5e2c7-37d1e99b-ce952c65] [] Server session id: ptqudttn7qgq6bfhs4q5_1_1_12623295012964356632_v1
2025-10-26T16:22:29.003280Z :YDB_SDK DEBUG: 2025-10-26T16:22:29.003276Z :DEBUG: [local] [local] [cc264365-8e5e2c7-37d1e99b-ce952c65] [] In ContinueReadingDataImpl, ReadSizeBudget = 8388608, ReadSizeServerDelta = 0
2025-10-26T16:22:29.003388Z :YDB_SDK DEBUG: 2025-10-26T16:22:29.003385Z :DEBUG: [local] [local] [cc264365-8e5e2c7-37d1e99b-ce952c65] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 8388608
2025-10-26T16:22:29.004715Z :KQP_COMPUTE TRACE: SelfId: [0:0:0], TxId: ptqudttn7qgq6bfhs4q5, task: 1. PQ source. SessionId: cc264365-8e5e2c7-37d1e99b-ce952c65 Source data ready
2025-10-26T16:22:29.004743Z :KQP_COMPUTE TRACE: SelfId: [2:7565566631326736927:60], TxId: ptqudttn7qgq6bfhs4q5, task: 1. Ctx: {}. Poll sources
2025-10-26T16:22:29.004747Z :KQP_COMPUTE TRACE: SelfId: [0:0:0], TxId: ptqudttn7qgq6bfhs4q5, task: 1. PQ source. SessionId: cc264365-8e5e2c7-37d1e99b-ce952c65 GetAsyncInputData freeSpace = 1000000
2025-10-26T16:22:29.004762Z :KQP_COMPUTE DEBUG: SelfId: [0:0:0], TxId: ptqudttn7qgq6bfhs4q5, task: 1. PQ source. SessionId: cc264365-8e5e2c7-37d1e99b-ce952c65 Key: [, 0] StartPartitionSessionEvent received
2025-10-26T16:22:29.004766Z :KQP_COMPUTE DEBUG: SelfId: [0:0:0], TxId: ptqudttn7qgq6bfhs4q5, task: 1. PQ source. SessionId: cc264365-8e5e2c7-37d1e99b-ce952c65 Key: [, 0] Confirm StartPartitionSession with offset (empty maybe)
2025-10-26T16:22:29.004788Z :YDB_SDK INFO: 2025-10-26T16:22:29.004784Z :INFO: [local] [local] [cc264365-8e5e2c7-37d1e99b-ce952c65] [] Confirm partition stream create. Partition stream id: 1. Cluster: "-". Topic: "select_dc_locality_input". Partition: 0. Read offset: (empty maybe)
2025-10-26T16:22:29.004891Z :KQP_COMPUTE TRACE: Poll async input 0. Buffer free space: 1000000, read from async input: 0 bytes, 0 rows, finished: 0
2025-10-26T16:22:29.004911Z :KQP_COMPUTE TRACE: SelfId: [2:7565566631326736927:60], TxId: ptqudttn7qgq6bfhs4q5, task: 1. Ctx: {}. Poll inputs
2025-10-26T16:22:29.004916Z :KQP_COMPUTE TRACE: SelfId: [0:0:0], TxId: ptqudttn7qgq6bfhs4q5, task: 1. PQ source. SessionId: cc264365-8e5e2c7-37d1e99b-ce952c65 Source data ready
2025-10-26T16:22:29.004919Z :KQP_COMPUTE TRACE: SelfId: [2:7565566631326736927:60], TxId: ptqudttn7qgq6bfhs4q5, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-10-26T16:22:29.004975Z :KQP_COMPUTE TRACE: TxId: ptqudttn7qgq6bfhs4q5, task: 1. Peak memory usage: 131072
2025-10-26T16:22:29.004996Z :KQP_COMPUTE TRACE: SelfId: [2:7565566631326736927:60], TxId: ptqudttn7qgq6bfhs4q5, task: 1. Ctx: {}. Poll sources
2025-10-26T16:22:29.005002Z :KQP_COMPUTE TRACE: SelfId: [0:0:0], TxId: ptqudttn7qgq6bfhs4q5, task: 1. PQ source. SessionId: cc264365-8e5e2c7-37d1e99b-ce952c65 GetAsyncInputData freeSpace = 1000000
2025-10-26T16:22:29.005007Z :KQP_COMPUTE TRACE: Poll async input 0. Buffer free space: 1000000, read from async input: 0 bytes, 0 rows, finished: 0
2025-10-26T16:22:29.005012Z :KQP_COMPUTE TRACE: SelfId: [2:7565566631326736927:60], TxId: ptqudttn7qgq6bfhs4q5, task: 1. Ctx: {}. Poll inputs
2025-10-26T16:22:29.005015Z :KQP_COMPUTE TRACE: SelfId: [2:7565566631326736927:60], TxId: ptqudttn7qgq6bfhs4q5, task: 1. Ctx: {}. update task runner stats
2025-10-26T16:22:29.005043Z :KQP_COMPUTE TRACE: SelfId: [2:7565566631326736927:60], TxId: ptqudttn7qgq6bfhs4q5, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: 0
2025-10-26T16:22:29.005046Z :KQP_COMPUTE TRACE: SelfId: [2:7565566631326736927:60], TxId: ptqudttn7qgq6bfhs4q5, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-10-26T16:22:29.005052Z :KQP_COMPUTE TRACE: SelfId: [2:7565566631326736927:60], TxId: ptqudttn7qgq6bfhs4q5, task: 1. Ctx: {}. About to drain channelId: 1, hasPeer: 1, peerState:(freeSpace:1000000;inFlightBytes:0;inFlightCount:0;)
2025-10-26T16:22:29.005055Z :KQP_COMPUTE TRACE: SelfId: [2:7565566631326736927:60], TxId: ptqudttn7qgq6bfhs4q5, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-10-26T16:22:29.005078Z :KQP_COMPUTE TRACE: TxId: ptqudttn7qgq6bfhs4q5, task: 1. Peak memory usage: 131072
2025-10-26T16:22:29.005088Z :KQP_COMPUTE TRACE: SelfId: [2:7565566631326736927:60], TxId: ptqudttn7qgq6bfhs4q5, task: 1. Ctx: {}. update task runner stats
2025-10-26T16:22:29.005094Z :KQP_COMPUTE TRACE: SelfId: [2:7565566631326736927:60], TxId: ptqudttn7qgq6bfhs4q5, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: 0
2025-10-26T16:22:29.005095Z :KQP_COMPUTE TRACE: SelfId: [2:7565566631326736927:60], TxId: ptqudttn7qgq6bfhs4q5, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-10-26T16:22:29.005097Z :KQP_COMPUTE TRACE: SelfId: [2:7565566631326736927:60], TxId: ptqudttn7qgq6bfhs4q5, task: 1. Ctx: {}. About to drain channelId: 1, hasPeer: 1, peerState:(freeSpace:1000000;inFlightBytes:0;inFlightCount:0;)
2025-10-26T16:22:29.018729Z :STREAMS_STORAGE_SERVICE DEBUG: [ptqudttn7qgq6bfhs4q5-0] [1:1] TEvSaveTaskState Apply: task: 1
2025-10-26T16:22:29.018746Z :STREAMS_STORAGE_SERVICE DEBUG: [ptqudttn7qgq6bfhs4q5-0] [1:1] Send TEvSaveTaskStateResult: task: 1
2025-10-26T16:22:29.018808Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: [ptqudttn7qgq6bfhs4q5-0.1] [1:1] Got TEvSaveTaskStateResult; task 1, status: OK, size: 112
2025-10-26T16:22:29.018820Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: [ptqudttn7qgq6bfhs4q5-0.1] [1:1] Task state saved, need 1 more acks
2025-10-26T16:22:29.019011Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: [ptqudttn7qgq6bfhs4q5-0.1] [1:1] Got TEvSaveTaskStateResult; task 2, status: OK, size: 29
2025-10-26T16:22:29.019021Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: [ptqudttn7qgq6bfhs4q5-0.1] [1:1] Task state saved, need 0 more acks
2025-10-26T16:22:29.019023Z :STREAMS_CHECKPOINT_COORDINATOR INFO: [ptqudttn7qgq6bfhs4q5-0.1] [1:1] Got all acks, changing checkpoint status to 'PendingCommit'
2025-10-26T16:22:29.019049Z :FQ_RUN_ACTOR DEBUG: QueryId: ptqudttn7qgq6bfhs4q5 Coordinator saved zero checkpoint
2025-10-26T16:22:29.019048Z :STREAMS_STORAGE_SERVICE DEBUG: [ptqudttn7qgq6bfhs4q5-0.1] [1:1] Got TEvSetCheckpointPendingCommitStatusRequest
2025-10-26T16:22:29.019092Z :FQ_PINGER TRACE: QueryId: ptqudttn7qgq6bfhs4q5, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0711 Forward ping request: { state_load_mode: FROM_LAST_CHECKPOINT disposition { from_last_checkpoint { } } }
2025-10-26T16:22:29.019094Z :FQ_PINGER TRACE: QueryId: ptqudttn7qgq6bfhs4q5, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0711 Forward request Private::PingTask
2025-10-26T16:22:29.028738Z :FQ_PINGER TRACE: QueryId: ptqudttn7qgq6bfhs4q5, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0711 Ping response success: { expired_at { seconds: 1761495759 nanos: 23000000 } }
2025-10-26T16:22:29.028770Z :FQ_RUN_ACTOR TRACE: QueryId: ptqudttn7qgq6bfhs4q5 Forward ping response. Success: 1. Cookie: 4
2025-10-26T16:22:29.063705Z :STREAMS_STORAGE_SERVICE INFO: [ptqudttn7qgq6bfhs4q5-0.1] [1:1] Status updated to 'PendingCommit'
2025-10-26T16:22:29.063715Z :STREAMS_STORAGE_SERVICE DEBUG: [ptqudttn7qgq6bfhs4q5-0.1] [1:1] Send TEvSetCheckpointPendingCommitStatusResponse
2025-10-26T16:22:29.063746Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: [ptqudttn7qgq6bfhs4q5-0.1] [1:1] Got TEvSetCheckpointPendingCommitStatusResponse
2025-10-26T16:22:29.063751Z :STREAMS_CHECKPOINT_COORDINATOR INFO: [ptqudttn7qgq6bfhs4q5-0.1] [1:1] Checkpoint status changed to 'PendingCommit', committing states
2025-10-26T16:22:29.063789Z :KQP_COMPUTE DEBUG: SelfId: [2:7565566631326736927:60], TxId: ptqudttn7qgq6bfhs4q5, task: 1. Ctx: {}. Commit state
2025-10-26T16:22:29.063820Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: [ptqudttn7qgq6bfhs4q5-0.1] [1:1] Got TEvStateCommitted; task: 1
2025-10-26T16:22:29.063836Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: [ptqudttn7qgq6bfhs4q5-0.1] [1:1] State committed [2:7565566631326736927:60], need 0 more acks
2025-10-26T16:22:29.063844Z :STREAMS_CHECKPOINT_COORDINATOR INFO: [ptqudttn7qgq6bfhs4q5-0.1] [1:1] Got all acks, changing checkpoint status to 'Completed'
2025-10-26T16:22:29.063864Z :STREAMS_STORAGE_SERVICE DEBUG: [ptqudttn7qgq6bfhs4q5-0.1] [1:1] Got TEvCompleteCheckpointRequest
2025-10-26T16:22:29.113090Z :STREAMS_STORAGE_SERVICE INFO: [ptqudttn7qgq6bfhs4q5-0.1] [1:1] Status updated to 'Completed'
2025-10-26T16:22:29.113109Z :STREAMS_STORAGE_SERVICE DEBUG: [ptqudttn7qgq6bfhs4q5-0.1] [1:1] Send TEvCompleteCheckpointResponse
2025-10-26T16:22:29.113140Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: [ptqudttn7qgq6bfhs4q5-0.1] [1:1] Got TEvCompleteCheckpointResponse
2025-10-26T16:22:29.113148Z :STREAMS_CHECKPOINT_COORDINATOR INFO: [ptqudttn7qgq6bfhs4q5-0.1] [1:1] Checkpoint completed
2025-10-26T16:22:29.549660Z :FQ_PENDING_FETCHER TRACE: Request Private::GetTask, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0713, Host: ghrun-zwq4uro7ay, Tenant: /default
2025-10-26T16:22:29.552726Z :FQ_PENDING_FETCHER TRACE: Got GetTask response from PrivateApi
2025-10-26T16:22:29.552736Z :FQ_PENDING_FETCHER TRACE: Tasks count: 0
2025-10-26T16:22:29.556190Z :FQ_QUOTA_SERVICE TRACE: cloud.mock_cloud.yq.cpuPercent.count=0/200 UPDATE from Peer 1
2025-10-26T16:22:29.560074Z :FQ_QUOTA_SERVICE TRACE: cloud.mock_cloud.yq.streamingQuery.count=1/100 UPDATE from Peer 1
2025-10-26T16:22:29.560088Z :FQ_QUOTA_SERVICE TRACE: cloud.mock_cloud.yq.analyticsQuery.count=1/100 UPDATE from Peer 1
2025-10-26T16:22:29.705219Z :FQ_QUOTA_SERVICE TRACE: cloud.mock_cloud.yq.cpuPercent.count=0/200 UPDATE from Peer 1
2025-10-26T16:22:29.708726Z :FQ_QUOTA_SERVICE TRACE: cloud.mock_cloud.yq.streamingQuery.count=1/100 UPDATE from Peer 1
2025-10-26T16:22:29.708741Z :FQ_QUOTA_SERVICE TRACE: cloud.mock_cloud.yq.analyticsQuery.count=1/100 UPDATE from Peer 1
2025-10-26T16:22:29.828181Z :FQ_PINGER TRACE: QueryId: ptqudttn7qgq6bfhs4q5, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0711 Forward ping request: { statistics: "{\"Graph=0\":{\"TaskRunner\":{\"Stage=199517\":{\"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=199534\":{\"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-26T16:22:29.828206Z :FQ_PINGER TRACE: QueryId: ptqudttn7qgq6bfhs4q5, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0711 Forward request Private::PingTask
2025-10-26T16:22:29.839399Z :FQ_PINGER TRACE: QueryId: ptqudttn7qgq6bfhs4q5, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0711 Ping response success: { action: ABORT expired_at { seconds: 1761495759 nanos: 833000000 } }
2025-10-26T16:22:29.839413Z :FQ_PINGER DEBUG: QueryId: ptqudttn7qgq6bfhs4q5, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0711 Query action: ABORT
2025-10-26T16:22:29.839449Z :FQ_RUN_ACTOR DEBUG: QueryId: ptqudttn7qgq6bfhs4q5 New query action received: ABORT
2025-10-26T16:22:29.839455Z :FQ_RUN_ACTOR DEBUG: QueryId: ptqudttn7qgq6bfhs4q5 Is about to finish query with status ABORTED_BY_USER
2025-10-26T16:22:29.839459Z :FQ_RUN_ACTOR DEBUG: QueryId: ptqudttn7qgq6bfhs4q5 Write finalizing status: ABORTING_BY_USER
2025-10-26T16:22:29.839474Z :FQ_RUN_ACTOR DEBUG: QueryId: ptqudttn7qgq6bfhs4q5 Cancel running query
2025-10-26T16:22:29.839497Z :FQ_RUN_ACTOR TRACE: QueryId: ptqudttn7qgq6bfhs4q5 Forward ping response. Success: 1. Cookie: 0
2025-10-26T16:22:29.839498Z :FQ_PINGER TRACE: QueryId: ptqudttn7qgq6bfhs4q5, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0711 Forward ping request: { status: ABORTING_BY_USER }
2025-10-26T16:22:29.839501Z :FQ_PINGER TRACE: QueryId: ptqudttn7qgq6bfhs4q5, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0711 Forward request Private::PingTask
2025-10-26T16:22:29.839559Z :YQL_PROXY DEBUG: SessionId: 717f0dae-ec1c1334-99acf168-5d9efd07 2025-10-26 16:22:29.839 DEBUG ydbd(pid=1984802, tid=0x00007EFC4BDED640) [DQ] task_controller_impl.h:125: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} AbortExecution from [2:7565566631326736915:28]:ABORTED { <main>: Error: ABORTED_BY_USER }
2025-10-26T16:22:29.839573Z :YQL_PROXY DEBUG: SessionId: 717f0dae-ec1c1334-99acf168-5d9efd07 2025-10-26 16:22:29.839 DEBUG ydbd(pid=1984802, tid=0x00007EFC4BDED640) [DQ] task_controller_impl.h:573: {ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud} OnError { <main>: Error: ABORTED_BY_USER } ABORTED
2025-10-26T16:22:29.839639Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:29.839 DEBUG ydbd(pid=1984802, tid=0x00007EFC4CDFF640) [DQ] executer_actor.cpp:301: {ptqudttn7qgq6bfhs4q5} OnFailure, status=4, issues size=1, sender=[2:7565566631326736923:38]
2025-10-26T16:22:29.839671Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:29.839 DEBUG ydbd(pid=1984802, tid=0x00007EFC4CDFF640) [DQ] executer_actor.cpp:312: {ptqudttn7qgq6bfhs4q5} Issues: <main>: Error: ABORTED_BY_USER

2025-10-26T16:22:29.839679Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:29.839 DEBUG ydbd(pid=1984802, tid=0x00007EFC4CDFF640) [DQ] executer_actor.cpp:282: {ptqudttn7qgq6bfhs4q5} Finish with status=4 issues=<main>: Error: ABORTED_BY_USER

2025-10-26T16:22:29.839744Z :FQ_RESULT_WRITER DEBUG: TraceId: ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud Send response to executer
2025-10-26T16:22:29.839759Z :YQL_PROXY DEBUG: SessionId: ptqudttn7qgq6bfhs4q5 2025-10-26 16:22:29.839 DEBUG ydbd(pid=1984802, tid=0x00007EFC4CDFF640) [DQ] executer_actor.cpp:338: {ptqudttn7qgq6bfhs4q5} OnQueryResponse status=4 issuses_size=1
2025-10-26T16:22:29.839776Z :FQ_RUN_ACTOR DEBUG: QueryId: ptqudttn7qgq6bfhs4q5 Query response CANCELLED. Result set index: 0. Issues count: 1. Rows count: 0
2025-10-26T16:22:29.839786Z :FQ_RESULT_WRITER INFO: TraceId: ptqudttn7qgq6bfhs4q5#ptrudttn7q2ub5a0kgdp#yandexcloud://my_folder#717f0dae-ec1c1334-99acf168-5d9efd0711#mock_cloud FinishWrite, Records: 0 HasError: 0 Size: 0 Rows: 0 FreeSpace: 67108864 Duration: 1.025041s AvgSpeed: 0 ResultChunks.size(): 0
2025-10-26T16:22:29.839867Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: [ptqudttn7qgq6bfhs4q5-0.1] Got TEvPoison
2025-10-26T16:22:29.839902Z :YQL_PROXY DEBUG: SessionId: 717f0dae-ec1c1334-99acf168-5d9efd07 2025-10-26 16:22:29.839 DEBUG ydbd(pid=1984802, tid=0x00007EFC4BDED640) [DQ] local_worker_manager.cpp:416: TEvFreeWorkersNotify 281479271677954
2025-10-26T16:22:29.839907Z :YQL_PROXY DEBUG: SessionId: 717f0dae-ec1c1334-99acf168-5d9efd07 2025-10-26 16:22:29.839 DEBUG ydbd(pid=1984802, tid=0x00007EFC4BDED640) [DQ] local_worker_manager.cpp:440: Free Group 281479271677954
2025-10-26T16:22:29.839945Z :KQP_COMPUTE ERROR: SelfId: [2:7565566631326736927:60], TxId: ptqudttn7qgq6bfhs4q5, task: 1. Ctx: {}. Handle abort execution event from: [2:7565566588377063844:7], status: UNAVAILABLE, reason: { <main>: Error: Aborted by LWM }
2025-10-26T16:22:29.839975Z :KQP_COMPUTE DEBUG: TxId: ptqudttn7qgq6bfhs4q5, task: 1. pass away
2025-10-26T16:22:29.840019Z :YDB_SDK INFO: 2025-10-26T16:22:29.840015Z :INFO: [local] [local] [cc264365-8e5e2c7-37d1e99b-ce952c65] Closing read session. Close timeout: 0.000000s
2025-10-26T16:22:29.840030Z :YDB_SDK INFO: 2025-10-26T16:22:29.840028Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:select_dc_locality_input:0:1:0:0
2025-10-26T16:22:29.840037Z :YDB_SDK INFO: 2025-10-26T16:22:29.840036Z :INFO: [local] [local] [cc264365-8e5e2c7-37d1e99b-ce952c65] Counters: { Errors: 0 CurrentSessionLifetimeMs: 839 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-10-26T16:22:29.840051Z :YDB_SDK NOTICE: 2025-10-26T16:22:29.840049Z :NOTICE: [local] [local] [cc264365-8e5e2c7-37d1e99b-ce952c65] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Close with zero timeout " }
2025-10-26T16:22:29.840061Z :YDB_SDK DEBUG: 2025-10-26T16:22:29.840059Z :DEBUG: [local] [local] [cc264365-8e5e2c7-37d1e99b-ce952c65] [] Abort session to cluster
2025-10-26T16:22:29.840199Z :YDB_SDK INFO: 2025-10-26T16:22:29.840196Z :INFO: [local] [local] [cc264365-8e5e2c7-37d1e99b-ce952c65] Closing read session. Close timeout: 0.000000s
2025-10-26T16:22:29.840215Z :YDB_SDK INFO: 2025-10-26T16:22:29.840214Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:select_dc_locality_input:0:1:0:0
2025-10-26T16:22:29.840221Z :YDB_SDK INFO: 2025-10-26T16:22:29.840218Z :INFO: [local] [local] [cc264365-8e5e2c7-37d1e99b-ce952c65] Counters: { Errors: 0 CurrentSessionLifetimeMs: 839 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-10-26T16:22:29.840229Z :YDB_SDK NOTICE: 2025-10-26T16:22:29.840227Z :NOTICE: [local] [local] [cc264365-8e5e2c7-37d1e99b-ce952c65] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-10-26T16:22:29.849139Z :FQ_PINGER TRACE: QueryId: ptqudttn7qgq6bfhs4q5, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0711 Ping response success: { action: ABORT expired_at { seconds: 1761495759 nanos: 843000000 } }
2025-10-26T16:22:29.849149Z :FQ_PINGER DEBUG: QueryId: ptqudttn7qgq6bfhs4q5, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0711 Query action: ABORT
2025-10-26T16:22:29.849182Z :FQ_RUN_ACTOR TRACE: QueryId: ptqudttn7qgq6bfhs4q5 Forward ping response. Success: 1. Cookie: 3
2025-10-26T16:22:29.849220Z :FQ_RUN_ACTOR DEBUG: QueryId: ptqudttn7qgq6bfhs4q5 Start rate limiter resource deleter
2025-10-26T16:22:29.849233Z :STREAMS DEBUG: ptqudttn7qgq6bfhs4q5: Create read rule deleter actor for `select_dc_locality_input` [0]
2025-10-26T16:22:29.849271Z :STREAMS DEBUG: ptqudttn7qgq6bfhs4q5: Make request for read rule deletion for topic `select_dc_locality_input` [0]
2025-10-26T16:22:29.887093Z :FQ_RUN_ACTOR DEBUG: QueryId: ptqudttn7qgq6bfhs4q5 Rate limiter resource deletion finished. Success: 1. Issues: 
2025-10-26T16:22:29.887278Z :FQ_PINGER TRACE: QueryId: ptqudttn7qgq6bfhs4q5, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0711 Forward ping request: { owner_id: "717f0dae-ec1c1334-99acf168-5d9efd0711" query_id { value: "ptqudttn7qgq6bfhs4q5" } result_id { value: "ptrudttn7q2ub5a0kgdp" } status: ABORTED_BY_USER issues { message: "ABORTED_BY_USER" severity: 1 } result_set_count: 1 statistics: "{\"Graph=0\":{\"Actor\":{\"ActorCreateTimeUs\":{\"sum\":\"11ms\",\"count\":2,\"avg\":\"5ms\",\"max\":\"11ms\",\"min\":\"372us\"}},\"AllocateWorkersUs\":{\"sum\":\"12ms\",\"count\":1,\"avg\":\"12ms\",\"max\":\"12ms\",\"min\":\"12ms\"},\"ExecutionTimeUs\":{\"sum\":\"1.01s\",\"count\":1,\"avg\":\"1.01s\",\"max\":\"1.01s\",\"min\":\"1.01s\"},\"TaskRunner\":{\"Stage=199517\":{\"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=199534\":{\"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}}},\"UniqueWorkers\":{\"sum\":2,\"count\":1,\"avg\":2,\"max\":2,\"min\":2}}}" result_set_meta { column { name: "Data" type { type_id: STRING } } } resources { rate_limiter: READY compilation: READY topic_consumers_state: READY rate_limiter_path: "local/RateLimiter_b07d7bc2-0090-453a-b348-ea3efaa6bbf0/rate_limiter" topic_consumers { database: "local" topic_path: "select_dc_locality_input" consumer_name: "ptqudttn7qgq6bfhs4q5" cluster_endpoint: "localhost:24793" token_name: "cluster:default_myyds" add_bearer_to_token: true } } scope: "yandexcloud://my_folder" finished_at { seconds: 1761495749 nanos: 839000000 } }
2025-10-26T16:22:29.887290Z :FQ_PINGER TRACE: QueryId: ptqudttn7qgq6bfhs4q5, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0711 Forward request Private::PingTask
2025-10-26T16:22:29.955953Z :FQ_PINGER TRACE: QueryId: ptqudttn7qgq6bfhs4q5, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0711 Ping response success: { action: ABORT }
2025-10-26T16:22:29.956001Z :FQ_PINGER DEBUG: QueryId: ptqudttn7qgq6bfhs4q5, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0711 Query finished
2025-10-26T16:22:29.956008Z :FQ_PINGER TRACE: QueryId: ptqudttn7qgq6bfhs4q5, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0711 Stop Pinger
2025-10-26T16:22:30.216027Z :FQ_QUOTA_SERVICE TRACE: cloud.mock_cloud.yq.cpuPercent.count=0/200 UPDATE from Peer 1
2025-10-26T16:22:30.217042Z :FQ_QUOTA_SERVICE TRACE: cloud.mock_cloud.yq.analyticsQuery.count=0/100 UPDATE from Peer 1
2025-10-26T16:22:30.217055Z :FQ_QUOTA_SERVICE TRACE: cloud.mock_cloud.yq.streamingQuery.count=0/100 UPDATE from Peer 1
2025-10-26T16:22:30.549857Z :FQ_PENDING_FETCHER TRACE: Request Private::GetTask, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0714, Host: ghrun-zwq4uro7ay, Tenant: /default
2025-10-26T16:22:30.552693Z :FQ_PENDING_FETCHER TRACE: Got GetTask response from PrivateApi
2025-10-26T16:22:30.552707Z :FQ_PENDING_FETCHER TRACE: Tasks count: 0
2025-10-26T16:22:30.554448Z :FQ_CONTROL_PLANE_CONFIG TRACE: LOADED TenantInfo: State NOT changed
2025-10-26T16:22:31.550052Z :FQ_PENDING_FETCHER TRACE: Request Private::GetTask, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0715, Host: ghrun-zwq4uro7ay, Tenant: /default
2025-10-26T16:22:31.553540Z :FQ_PENDING_FETCHER TRACE: Got GetTask response from PrivateApi
2025-10-26T16:22:31.553550Z :FQ_PENDING_FETCHER TRACE: Tasks count: 0
2025-10-26T16:22:32.550261Z :FQ_PENDING_FETCHER TRACE: Request Private::GetTask, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0716, Host: ghrun-zwq4uro7ay, Tenant: /default
2025-10-26T16:22:32.553527Z :FQ_PENDING_FETCHER TRACE: Got GetTask response from PrivateApi
2025-10-26T16:22:32.553540Z :FQ_PENDING_FETCHER TRACE: Tasks count: 0
2025-10-26T16:22:33.550430Z :FQ_PENDING_FETCHER TRACE: Request Private::GetTask, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0717, Host: ghrun-zwq4uro7ay, Tenant: /default
2025-10-26T16:22:33.552238Z :YQL_NODES_MANAGER TRACE: TNodesManagerActor::NodesHealthCheck
2025-10-26T16:22:33.553367Z :FQ_PENDING_FETCHER TRACE: Got GetTask response from PrivateApi
2025-10-26T16:22:33.553378Z :FQ_PENDING_FETCHER TRACE: Tasks count: 0
2025-10-26T16:22:33.555478Z :FQ_CONTROL_PLANE_CONFIG TRACE: LOADED TenantInfo: State NOT changed
2025-10-26T16:22:33.559586Z :YQL_NODES_MANAGER TRACE: Send NodeInfo with size: 3 to DynamicNameserver
2025-10-26T16:22:34.550588Z :FQ_PENDING_FETCHER TRACE: Request Private::GetTask, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0718, Host: ghrun-zwq4uro7ay, Tenant: /default
2025-10-26T16:22:34.554710Z :FQ_PENDING_FETCHER TRACE: Got GetTask response from PrivateApi
2025-10-26T16:22:34.554725Z :FQ_PENDING_FETCHER TRACE: Tasks count: 0
2025-10-26T16:22:35.550790Z :FQ_PENDING_FETCHER TRACE: Request Private::GetTask, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0719, Host: ghrun-zwq4uro7ay, Tenant: /default
2025-10-26T16:22:35.553556Z :FQ_PENDING_FETCHER TRACE: Got GetTask response from PrivateApi
2025-10-26T16:22:35.553567Z :FQ_PENDING_FETCHER TRACE: Tasks count: 0
2025-10-26T16:22:36.550997Z :FQ_PENDING_FETCHER TRACE: Request Private::GetTask, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0720, Host: ghrun-zwq4uro7ay, Tenant: /default
2025-10-26T16:22:36.553723Z :FQ_PENDING_FETCHER TRACE: Got GetTask response from PrivateApi
2025-10-26T16:22:36.553730Z :FQ_PENDING_FETCHER TRACE: Tasks count: 0
2025-10-26T16:22:36.554922Z :FQ_CONTROL_PLANE_CONFIG TRACE: LOADED TenantInfo: State NOT changed
2025-10-26T16:22:37.551207Z :FQ_PENDING_FETCHER TRACE: Request Private::GetTask, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0721, Host: ghrun-zwq4uro7ay, Tenant: /default
2025-10-26T16:22:37.554274Z :FQ_PENDING_FETCHER TRACE: Got GetTask response from PrivateApi
2025-10-26T16:22:37.554285Z :FQ_PENDING_FETCHER TRACE: Tasks count: 0
2025-10-26T16:22:38.551395Z :FQ_PENDING_FETCHER TRACE: Request Private::GetTask, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0722, Host: ghrun-zwq4uro7ay, Tenant: /default
2025-10-26T16:22:38.552403Z :YQL_NODES_MANAGER TRACE: TNodesManagerActor::NodesHealthCheck
2025-10-26T16:22:38.554034Z :FQ_PENDING_FETCHER TRACE: Got GetTask response from PrivateApi
2025-10-26T16:22:38.554046Z :FQ_PENDING_FETCHER TRACE: Tasks count: 0
2025-10-26T16:22:38.559108Z :YQL_NODES_MANAGER TRACE: Send NodeInfo with size: 3 to DynamicNameserver
2025-10-26T16:22:39.551557Z :FQ_PENDING_FETCHER TRACE: Request Private::GetTask, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0723, Host: ghrun-zwq4uro7ay, Tenant: /default
2025-10-26T16:22:39.554261Z :FQ_PENDING_FETCHER TRACE: Got GetTask response from PrivateApi
2025-10-26T16:22:39.554281Z :FQ_PENDING_FETCHER TRACE: Tasks count: 0
2025-10-26T16:22:39.555547Z :FQ_CONTROL_PLANE_CONFIG TRACE: LOADED TenantInfo: State NOT changed
2025-10-26T16:22:40.551774Z :FQ_PENDING_FETCHER TRACE: Request Private::GetTask, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0724, Host: ghrun-zwq4uro7ay, Tenant: /default
2025-10-26T16:22:40.555099Z :FQ_PENDING_FETCHER TRACE: Got GetTask response from PrivateApi
2025-10-26T16:22:40.555114Z :FQ_PENDING_FETCHER TRACE: Tasks count: 0
2025-10-26T16:22:41.551968Z :FQ_PENDING_FETCHER TRACE: Request Private::GetTask, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0725, Host: ghrun-zwq4uro7ay, Tenant: /default
2025-10-26T16:22:41.555026Z :FQ_PENDING_FETCHER TRACE: Got GetTask response from PrivateApi
2025-10-26T16:22:41.555037Z :FQ_PENDING_FETCHER TRACE: Tasks count: 0
2025-10-26T16:22:42.552157Z :FQ_PENDING_FETCHER TRACE: Request Private::GetTask, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0726, Host: ghrun-zwq4uro7ay, Tenant: /default
2025-10-26T16:22:42.554869Z :FQ_PENDING_FETCHER TRACE: Got GetTask response from PrivateApi
2025-10-26T16:22:42.554882Z :FQ_PENDING_FETCHER TRACE: Tasks count: 0
2025-10-26T16:22:42.555572Z :FQ_CONTROL_PLANE_CONFIG TRACE: LOADED TenantInfo: State NOT changed
2025-10-26T16:22:43.552365Z :FQ_PENDING_FETCHER TRACE: Request Private::GetTask, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0727, Host: ghrun-zwq4uro7ay, Tenant: /default
2025-10-26T16:22:43.552617Z :YQL_NODES_MANAGER TRACE: TNodesManagerActor::NodesHealthCheck
2025-10-26T16:22:43.555293Z :FQ_PENDING_FETCHER TRACE: Got GetTask response from PrivateApi
2025-10-26T16:22:43.555304Z :FQ_PENDING_FETCHER TRACE: Tasks count: 0
2025-10-26T16:22:43.560050Z :YQL_NODES_MANAGER TRACE: Send NodeInfo with size: 3 to DynamicNameserver
2025-10-26T16:22:44.552637Z :FQ_PENDING_FETCHER TRACE: Request Private::GetTask, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0728, Host: ghrun-zwq4uro7ay, Tenant: /default
2025-10-26T16:22:44.555957Z :FQ_PENDING_FETCHER TRACE: Got GetTask response from PrivateApi
2025-10-26T16:22:44.555972Z :FQ_PENDING_FETCHER TRACE: Tasks count: 0
2025-10-26T16:22:45.552790Z :FQ_PENDING_FETCHER TRACE: Request Private::GetTask, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0729, Host: ghrun-zwq4uro7ay, Tenant: /default
2025-10-26T16:22:45.556071Z :FQ_PENDING_FETCHER TRACE: Got GetTask response from PrivateApi
2025-10-26T16:22:45.556092Z :FQ_PENDING_FETCHER TRACE: Tasks count: 0
2025-10-26T16:22:45.556734Z :FQ_CONTROL_PLANE_CONFIG TRACE: LOADED TenantInfo: State NOT changed
2025-10-26T16:22:46.552925Z :FQ_PENDING_FETCHER TRACE: Request Private::GetTask, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0730, Host: ghrun-zwq4uro7ay, Tenant: /default
2025-10-26T16:22:46.556140Z :FQ_PENDING_FETCHER TRACE: Got GetTask response from PrivateApi
2025-10-26T16:22:46.556154Z :FQ_PENDING_FETCHER TRACE: Tasks count: 0
2025-10-26T16:22:47.553146Z :FQ_PENDING_FETCHER TRACE: Request Private::GetTask, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0731, Host: ghrun-zwq4uro7ay, Tenant: /default
2025-10-26T16:22:47.556696Z :FQ_PENDING_FETCHER TRACE: Got GetTask response from PrivateApi
2025-10-26T16:22:47.556712Z :FQ_PENDING_FETCHER TRACE: Tasks count: 0
2025-10-26T16:22:48.552830Z :YQL_NODES_MANAGER TRACE: TNodesManagerActor::NodesHealthCheck
2025-10-26T16:22:48.553404Z :FQ_PENDING_FETCHER TRACE: Request Private::GetTask, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0732, Host: ghrun-zwq4uro7ay, Tenant: /default
2025-10-26T16:22:48.556501Z :FQ_CONTROL_PLANE_CONFIG TRACE: LOADED TenantInfo: State NOT changed
2025-10-26T16:22:48.556688Z :FQ_PENDING_FETCHER TRACE: Got GetTask response from PrivateApi
2025-10-26T16:22:48.556699Z :FQ_PENDING_FETCHER TRACE: Tasks count: 0
2025-10-26T16:22:48.563725Z :YQL_NODES_MANAGER TRACE: Send NodeInfo with size: 3 to DynamicNameserver
2025-10-26T16:22:49.553542Z :FQ_PENDING_FETCHER TRACE: Request Private::GetTask, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0733, Host: ghrun-zwq4uro7ay, Tenant: /default
2025-10-26T16:22:49.556625Z :FQ_PENDING_FETCHER TRACE: Got GetTask response from PrivateApi
2025-10-26T16:22:49.556637Z :FQ_PENDING_FETCHER TRACE: Tasks count: 0
2025-10-26T16:22:50.553689Z :FQ_PENDING_FETCHER TRACE: Request Private::GetTask, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0734, Host: ghrun-zwq4uro7ay, Tenant: /default
2025-10-26T16:22:50.556473Z :FQ_PENDING_FETCHER TRACE: Got GetTask response from PrivateApi
2025-10-26T16:22:50.556484Z :FQ_PENDING_FETCHER TRACE: Tasks count: 0
2025-10-26T16:22:51.553883Z :FQ_PENDING_FETCHER TRACE: Request Private::GetTask, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0735, Host: ghrun-zwq4uro7ay, Tenant: /default
2025-10-26T16:22:51.556681Z :FQ_CONTROL_PLANE_CONFIG TRACE: LOADED TenantInfo: State NOT changed
2025-10-26T16:22:51.556781Z :FQ_PENDING_FETCHER TRACE: Got GetTask response from PrivateApi
2025-10-26T16:22:51.556801Z :FQ_PENDING_FETCHER TRACE: Tasks count: 0
2025-10-26T16:22:52.554094Z :FQ_PENDING_FETCHER TRACE: Request Private::GetTask, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0736, Host: ghrun-zwq4uro7ay, Tenant: /default
2025-10-26T16:22:52.557241Z :FQ_PENDING_FETCHER TRACE: Got GetTask response from PrivateApi
2025-10-26T16:22:52.557254Z :FQ_PENDING_FETCHER TRACE: Tasks count: 0
2025-10-26T16:22:53.552978Z :YQL_NODES_MANAGER TRACE: TNodesManagerActor::NodesHealthCheck
2025-10-26T16:22:53.554259Z :FQ_PENDING_FETCHER TRACE: Request Private::GetTask, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0737, Host: ghrun-zwq4uro7ay, Tenant: /default
2025-10-26T16:22:53.556984Z :FQ_PENDING_FETCHER TRACE: Got GetTask response from PrivateApi
2025-10-26T16:22:53.557000Z :FQ_PENDING_FETCHER TRACE: Tasks count: 0
2025-10-26T16:22:53.559967Z :YQL_NODES_MANAGER TRACE: Send NodeInfo with size: 3 to DynamicNameserver
2025-10-26T16:22:54.554467Z :FQ_PENDING_FETCHER TRACE: Request Private::GetTask, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0738, Host: ghrun-zwq4uro7ay, Tenant: /default
2025-10-26T16:22:54.557852Z :FQ_CONTROL_PLANE_CONFIG TRACE: LOADED TenantInfo: State NOT changed
2025-10-26T16:22:54.558239Z :FQ_PENDING_FETCHER TRACE: Got GetTask response from PrivateApi
2025-10-26T16:22:54.558254Z :FQ_PENDING_FETCHER TRACE: Tasks count: 0
2025-10-26T16:22:55.554659Z :FQ_PENDING_FETCHER TRACE: Request Private::GetTask, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0739, Host: ghrun-zwq4uro7ay, Tenant: /default
2025-10-26T16:22:55.557817Z :FQ_PENDING_FETCHER TRACE: Got GetTask response from PrivateApi
2025-10-26T16:22:55.557828Z :FQ_PENDING_FETCHER TRACE: Tasks count: 0
2025-10-26T16:22:56.554853Z :FQ_PENDING_FETCHER TRACE: Request Private::GetTask, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0740, Host: ghrun-zwq4uro7ay, Tenant: /default
2025-10-26T16:22:56.565877Z :FQ_PENDING_FETCHER TRACE: Got GetTask response from PrivateApi
2025-10-26T16:22:56.565889Z :FQ_PENDING_FETCHER TRACE: Tasks count: 0
2025-10-26T16:22:57.555011Z :FQ_PENDING_FETCHER TRACE: Request Private::GetTask, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0741, Host: ghrun-zwq4uro7ay, Tenant: /default
2025-10-26T16:22:57.557249Z :FQ_CONTROL_PLANE_CONFIG TRACE: LOADED TenantInfo: State NOT changed
2025-10-26T16:22:57.557880Z :FQ_PENDING_FETCHER TRACE: Got GetTask response from PrivateApi
2025-10-26T16:22:57.557893Z :FQ_PENDING_FETCHER TRACE: Tasks count: 0
2025-10-26T16:22:58.553181Z :YQL_NODES_MANAGER TRACE: TNodesManagerActor::NodesHealthCheck
2025-10-26T16:22:58.555229Z :FQ_PENDING_FETCHER TRACE: Request Private::GetTask, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0742, Host: ghrun-zwq4uro7ay, Tenant: /default
2025-10-26T16:22:58.557933Z :FQ_PENDING_FETCHER TRACE: Got GetTask response from PrivateApi
2025-10-26T16:22:58.557945Z :FQ_PENDING_FETCHER TRACE: Tasks count: 0
2025-10-26T16:22:58.560113Z :YQL_NODES_MANAGER TRACE: Send NodeInfo with size: 3 to DynamicNameserver
2025-10-26T16:22:59.555438Z :FQ_PENDING_FETCHER TRACE: Request Private::GetTask, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0743, Host: ghrun-zwq4uro7ay, Tenant: /default
2025-10-26T16:22:59.558102Z :FQ_PENDING_FETCHER TRACE: Got GetTask response from PrivateApi
2025-10-26T16:22:59.558113Z :FQ_PENDING_FETCHER TRACE: Tasks count: 0
2025-10-26T16:23:00.241707Z :INTERCONNECT_NETWORK NOTICE: [2 <-> 1] connection closed by peer
2025-10-26T16:23:00.555643Z :FQ_PENDING_FETCHER TRACE: Request Private::GetTask, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0744, Host: ghrun-zwq4uro7ay, Tenant: /default
2025-10-26T16:23:00.556761Z :FQ_PENDING_FETCHER TRACE: Got GetTask response from PrivateApi
2025-10-26T16:23:00.556803Z :FQ_PENDING_FETCHER ERROR: Error with GetTask: <main>: Error: GRpc error: (14): failed to connect to all addresses; last error: UNKNOWN: ipv4:127.0.1.1:1363: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-zwq4uro7ay.auto.internal:1363
2025-10-26T16:23:00.558177Z :FQ_CONTROL_PLANE_CONFIG TRACE: LOADED TenantInfo: State NOT changed
2025-10-26T16:23:01.555796Z :FQ_PENDING_FETCHER TRACE: Request Private::GetTask, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0745, Host: ghrun-zwq4uro7ay, Tenant: /default
2025-10-26T16:23:01.557305Z :FQ_PENDING_FETCHER TRACE: Got GetTask response from PrivateApi
2025-10-26T16:23:01.557333Z :FQ_PENDING_FETCHER ERROR: Error with GetTask: <main>: Error: GRpc error: (14): failed to connect to all addresses; last error: UNKNOWN: ipv4:127.0.1.1:1363: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-zwq4uro7ay.auto.internal:1363
2025-10-26T16:23:02.556048Z :FQ_PENDING_FETCHER TRACE: Request Private::GetTask, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0746, Host: ghrun-zwq4uro7ay, Tenant: /default
2025-10-26T16:23:02.557658Z :FQ_PENDING_FETCHER TRACE: Got GetTask response from PrivateApi
2025-10-26T16:23:02.557685Z :FQ_PENDING_FETCHER ERROR: Error with GetTask: <main>: Error: GRpc error: (14): failed to connect to all addresses; last error: UNKNOWN: ipv4:127.0.1.1:1363: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-zwq4uro7ay.auto.internal:1363
2025-10-26T16:23:03.553367Z :YQL_NODES_MANAGER TRACE: TNodesManagerActor::NodesHealthCheck
2025-10-26T16:23:03.554917Z :YQL_NODES_MANAGER ERROR: ydb/core/fq/libs/actors/nodes_manager.cpp:263: TRANSPORT_UNAVAILABLE
<main>: Error: GRpc error: (14): failed to connect to all addresses; last error: UNKNOWN: ipv4:127.0.1.1:1363: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-zwq4uro7ay.auto.internal:1363
2025-10-26T16:23:03.556141Z :FQ_PENDING_FETCHER TRACE: Request Private::GetTask, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0747, Host: ghrun-zwq4uro7ay, Tenant: /default
2025-10-26T16:23:03.558127Z :FQ_CONTROL_PLANE_CONFIG TRACE: LOADED TenantInfo: State NOT changed
2025-10-26T16:23:03.558289Z :FQ_PENDING_FETCHER TRACE: Got GetTask response from PrivateApi
2025-10-26T16:23:03.558321Z :FQ_PENDING_FETCHER ERROR: Error with GetTask: <main>: Error: GRpc error: (14): failed to connect to all addresses; last error: UNKNOWN: ipv4:127.0.1.1:1363: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-zwq4uro7ay.auto.internal:1363
2025-10-26T16:23:04.556396Z :FQ_PENDING_FETCHER TRACE: Request Private::GetTask, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0748, Host: ghrun-zwq4uro7ay, Tenant: /default
2025-10-26T16:23:04.557646Z :FQ_PENDING_FETCHER TRACE: Got GetTask response from PrivateApi
2025-10-26T16:23:04.557668Z :FQ_PENDING_FETCHER ERROR: Error with GetTask: <main>: Error: GRpc error: (14): failed to connect to all addresses; last error: UNKNOWN: ipv4:127.0.1.1:1363: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-zwq4uro7ay.auto.internal:1363
2025-10-26T16:23:05.556590Z :FQ_PENDING_FETCHER TRACE: Request Private::GetTask, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0749, Host: ghrun-zwq4uro7ay, Tenant: /default
2025-10-26T16:23:05.558042Z :FQ_PENDING_FETCHER TRACE: Got GetTask response from PrivateApi
2025-10-26T16:23:05.558074Z :FQ_PENDING_FETCHER ERROR: Error with GetTask: <main>: Error: GRpc error: (14): failed to connect to all addresses; last error: UNKNOWN: ipv4:127.0.1.1:1363: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-zwq4uro7ay.auto.internal:1363
2025-10-26T16:23:06.556759Z :FQ_PENDING_FETCHER TRACE: Request Private::GetTask, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0750, Host: ghrun-zwq4uro7ay, Tenant: /default
2025-10-26T16:23:06.557955Z :FQ_PENDING_FETCHER TRACE: Got GetTask response from PrivateApi
2025-10-26T16:23:06.557974Z :FQ_PENDING_FETCHER ERROR: Error with GetTask: <main>: Error: GRpc error: (14): failed to connect to all addresses; last error: UNKNOWN: ipv4:127.0.1.1:1363: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-zwq4uro7ay.auto.internal:1363
2025-10-26T16:23:06.558564Z :FQ_CONTROL_PLANE_CONFIG TRACE: LOADED TenantInfo: State NOT changed
2025-10-26T16:23:07.557125Z :FQ_PENDING_FETCHER TRACE: Request Private::GetTask, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0751, Host: ghrun-zwq4uro7ay, Tenant: /default
2025-10-26T16:23:07.558418Z :FQ_PENDING_FETCHER TRACE: Got GetTask response from PrivateApi
2025-10-26T16:23:07.558447Z :FQ_PENDING_FETCHER ERROR: Error with GetTask: <main>: Error: GRpc error: (14): failed to connect to all addresses; last error: UNKNOWN: ipv4:127.0.1.1:1363: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-zwq4uro7ay.auto.internal:1363
2025-10-26T16:23:08.553542Z :YQL_NODES_MANAGER TRACE: TNodesManagerActor::NodesHealthCheck
2025-10-26T16:23:08.555399Z :YQL_NODES_MANAGER ERROR: ydb/core/fq/libs/actors/nodes_manager.cpp:263: TRANSPORT_UNAVAILABLE
<main>: Error: GRpc error: (14): failed to connect to all addresses; last error: UNKNOWN: ipv4:127.0.1.1:1363: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-zwq4uro7ay.auto.internal:1363
2025-10-26T16:23:08.557420Z :FQ_PENDING_FETCHER TRACE: Request Private::GetTask, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0752, Host: ghrun-zwq4uro7ay, Tenant: /default
2025-10-26T16:23:08.558698Z :FQ_PENDING_FETCHER TRACE: Got GetTask response from PrivateApi
2025-10-26T16:23:08.558719Z :FQ_PENDING_FETCHER ERROR: Error with GetTask: <main>: Error: GRpc error: (14): failed to connect to all addresses; last error: UNKNOWN: ipv4:127.0.1.1:1363: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-zwq4uro7ay.auto.internal:1363
2025-10-26T16:23:09.557599Z :FQ_PENDING_FETCHER TRACE: Request Private::GetTask, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0753, Host: ghrun-zwq4uro7ay, Tenant: /default
2025-10-26T16:23:09.558649Z :FQ_CONTROL_PLANE_CONFIG TRACE: LOADED TenantInfo: State NOT changed
2025-10-26T16:23:09.558825Z :FQ_PENDING_FETCHER TRACE: Got GetTask response from PrivateApi
2025-10-26T16:23:09.558848Z :FQ_PENDING_FETCHER ERROR: Error with GetTask: <main>: Error: GRpc error: (14): failed to connect to all addresses; last error: UNKNOWN: ipv4:127.0.1.1:1363: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-zwq4uro7ay.auto.internal:1363
2025-10-26T16:23:10.557800Z :FQ_PENDING_FETCHER TRACE: Request Private::GetTask, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0754, Host: ghrun-zwq4uro7ay, Tenant: /default
2025-10-26T16:23:10.559120Z :FQ_PENDING_FETCHER TRACE: Got GetTask response from PrivateApi
2025-10-26T16:23:10.559146Z :FQ_PENDING_FETCHER ERROR: Error with GetTask: <main>: Error: GRpc error: (14): failed to connect to all addresses; last error: UNKNOWN: ipv4:127.0.1.1:1363: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-zwq4uro7ay.auto.internal:1363
2025-10-26T16:23:11.557969Z :FQ_PENDING_FETCHER TRACE: Request Private::GetTask, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0755, Host: ghrun-zwq4uro7ay, Tenant: /default
2025-10-26T16:23:11.559283Z :FQ_PENDING_FETCHER TRACE: Got GetTask response from PrivateApi
2025-10-26T16:23:11.559322Z :FQ_PENDING_FETCHER ERROR: Error with GetTask: <main>: Error: GRpc error: (14): failed to connect to all addresses; last error: UNKNOWN: ipv4:127.0.1.1:1363: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-zwq4uro7ay.auto.internal:1363
2025-10-26T16:23:12.558172Z :FQ_PENDING_FETCHER TRACE: Request Private::GetTask, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0756, Host: ghrun-zwq4uro7ay, Tenant: /default
2025-10-26T16:23:12.558558Z :FQ_CONTROL_PLANE_CONFIG TRACE: LOADED TenantInfo: State NOT changed
2025-10-26T16:23:12.559237Z :FQ_PENDING_FETCHER TRACE: Got GetTask response from PrivateApi
2025-10-26T16:23:12.559267Z :FQ_PENDING_FETCHER ERROR: Error with GetTask: <main>: Error: GRpc error: (14): failed to connect to all addresses; last error: UNKNOWN: ipv4:127.0.1.1:1363: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-zwq4uro7ay.auto.internal:1363
2025-10-26T16:23:13.553798Z :YQL_NODES_MANAGER TRACE: TNodesManagerActor::NodesHealthCheck
2025-10-26T16:23:13.555512Z :YQL_NODES_MANAGER ERROR: ydb/core/fq/libs/actors/nodes_manager.cpp:263: TRANSPORT_UNAVAILABLE
<main>: Error: GRpc error: (14): failed to connect to all addresses; last error: UNKNOWN: ipv4:127.0.1.1:1363: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-zwq4uro7ay.auto.internal:1363
2025-10-26T16:23:13.558371Z :FQ_PENDING_FETCHER TRACE: Request Private::GetTask, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0757, Host: ghrun-zwq4uro7ay, Tenant: /default
2025-10-26T16:23:13.559413Z :FQ_PENDING_FETCHER TRACE: Got GetTask response from PrivateApi
2025-10-26T16:23:13.559432Z :FQ_PENDING_FETCHER ERROR: Error with GetTask: <main>: Error: GRpc error: (14): failed to connect to all addresses; last error: UNKNOWN: ipv4:127.0.1.1:1363: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-zwq4uro7ay.auto.internal:1363
2025-10-26T16:23:14.558535Z :FQ_PENDING_FETCHER TRACE: Request Private::GetTask, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0758, Host: ghrun-zwq4uro7ay, Tenant: /default
2025-10-26T16:23:14.559940Z :FQ_PENDING_FETCHER TRACE: Got GetTask response from PrivateApi
2025-10-26T16:23:14.559962Z :FQ_PENDING_FETCHER ERROR: Error with GetTask: <main>: Error: GRpc error: (14): failed to connect to all addresses; last error: UNKNOWN: ipv4:127.0.1.1:1363: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-zwq4uro7ay.auto.internal:1363
2025-10-26T16:23:15.558718Z :FQ_PENDING_FETCHER TRACE: Request Private::GetTask, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0759, Host: ghrun-zwq4uro7ay, Tenant: /default
2025-10-26T16:23:15.559163Z :FQ_CONTROL_PLANE_CONFIG TRACE: LOADED TenantInfo: State NOT changed
2025-10-26T16:23:15.560029Z :FQ_PENDING_FETCHER TRACE: Got GetTask response from PrivateApi
2025-10-26T16:23:15.560054Z :FQ_PENDING_FETCHER ERROR: Error with GetTask: <main>: Error: GRpc error: (14): failed to connect to all addresses; last error: UNKNOWN: ipv4:127.0.1.1:1363: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-zwq4uro7ay.auto.internal:1363
2025-10-26T16:23:16.558976Z :FQ_PENDING_FETCHER TRACE: Request Private::GetTask, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0760, Host: ghrun-zwq4uro7ay, Tenant: /default
2025-10-26T16:23:16.560256Z :FQ_PENDING_FETCHER TRACE: Got GetTask response from PrivateApi
2025-10-26T16:23:16.560283Z :FQ_PENDING_FETCHER ERROR: Error with GetTask: <main>: Error: GRpc error: (14): failed to connect to all addresses; last error: UNKNOWN: ipv4:127.0.1.1:1363: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-zwq4uro7ay.auto.internal:1363
2025-10-26T16:23:17.559137Z :FQ_PENDING_FETCHER TRACE: Request Private::GetTask, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0761, Host: ghrun-zwq4uro7ay, Tenant: /default
2025-10-26T16:23:17.560450Z :FQ_PENDING_FETCHER TRACE: Got GetTask response from PrivateApi
2025-10-26T16:23:17.560475Z :FQ_PENDING_FETCHER ERROR: Error with GetTask: <main>: Error: GRpc error: (14): failed to connect to all addresses; last error: UNKNOWN: ipv4:127.0.1.1:1363: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-zwq4uro7ay.auto.internal:1363
2025-10-26T16:23:18.553950Z :YQL_NODES_MANAGER TRACE: TNodesManagerActor::NodesHealthCheck
2025-10-26T16:23:18.555391Z :YQL_NODES_MANAGER ERROR: ydb/core/fq/libs/actors/nodes_manager.cpp:263: TRANSPORT_UNAVAILABLE
<main>: Error: GRpc error: (14): failed to connect to all addresses; last error: UNKNOWN: ipv4:127.0.1.1:1363: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-zwq4uro7ay.auto.internal:1363
2025-10-26T16:23:18.559032Z :FQ_CONTROL_PLANE_CONFIG TRACE: LOADED TenantInfo: State NOT changed
2025-10-26T16:23:18.559284Z :FQ_PENDING_FETCHER TRACE: Request Private::GetTask, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0762, Host: ghrun-zwq4uro7ay, Tenant: /default
2025-10-26T16:23:18.560250Z :FQ_PENDING_FETCHER TRACE: Got GetTask response from PrivateApi
2025-10-26T16:23:18.560276Z :FQ_PENDING_FETCHER ERROR: Error with GetTask: <main>: Error: GRpc error: (14): failed to connect to all addresses; last error: UNKNOWN: ipv4:127.0.1.1:1363: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-zwq4uro7ay.auto.internal:1363
2025-10-26T16:23:19.559463Z :FQ_PENDING_FETCHER TRACE: Request Private::GetTask, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0763, Host: ghrun-zwq4uro7ay, Tenant: /default
2025-10-26T16:23:19.560755Z :FQ_PENDING_FETCHER TRACE: Got GetTask response from PrivateApi
2025-10-26T16:23:19.560784Z :FQ_PENDING_FETCHER ERROR: Error with GetTask: <main>: Error: GRpc error: (14): failed to connect to all addresses; last error: UNKNOWN: ipv4:127.0.1.1:1363: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-zwq4uro7ay.auto.internal:1363
2025-10-26T16:23:20.559726Z :FQ_PENDING_FETCHER TRACE: Request Private::GetTask, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0764, Host: ghrun-zwq4uro7ay, Tenant: /default
2025-10-26T16:23:20.561102Z :FQ_PENDING_FETCHER TRACE: Got GetTask response from PrivateApi
2025-10-26T16:23:20.561141Z :FQ_PENDING_FETCHER ERROR: Error with GetTask: <main>: Error: GRpc error: (14): failed to connect to all addresses; last error: UNKNOWN: ipv4:127.0.1.1:1363: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-zwq4uro7ay.auto.internal:1363
2025-10-26T16:23:21.559500Z :FQ_CONTROL_PLANE_CONFIG TRACE: LOADED TenantInfo: State NOT changed
2025-10-26T16:23:21.559879Z :FQ_PENDING_FETCHER TRACE: Request Private::GetTask, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0765, Host: ghrun-zwq4uro7ay, Tenant: /default
2025-10-26T16:23:21.561121Z :FQ_PENDING_FETCHER TRACE: Got GetTask response from PrivateApi
2025-10-26T16:23:21.561139Z :FQ_PENDING_FETCHER ERROR: Error with GetTask: <main>: Error: GRpc error: (14): failed to connect to all addresses; last error: UNKNOWN: ipv4:127.0.1.1:1363: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-zwq4uro7ay.auto.internal:1363
2025-10-26T16:23:22.560135Z :FQ_PENDING_FETCHER TRACE: Request Private::GetTask, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0766, Host: ghrun-zwq4uro7ay, Tenant: /default
2025-10-26T16:23:22.562052Z :FQ_PENDING_FETCHER TRACE: Got GetTask response from PrivateApi
2025-10-26T16:23:22.562075Z :FQ_PENDING_FETCHER ERROR: Error with GetTask: <main>: Error: GRpc error: (14): failed to connect to all addresses; last error: UNKNOWN: ipv4:127.0.1.1:1363: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-zwq4uro7ay.auto.internal:1363
2025-10-26T16:23:23.554110Z :YQL_NODES_MANAGER TRACE: TNodesManagerActor::NodesHealthCheck
2025-10-26T16:23:23.555610Z :YQL_NODES_MANAGER ERROR: ydb/core/fq/libs/actors/nodes_manager.cpp:263: TRANSPORT_UNAVAILABLE
<main>: Error: GRpc error: (14): failed to connect to all addresses; last error: UNKNOWN: ipv4:127.0.1.1:1363: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-zwq4uro7ay.auto.internal:1363
2025-10-26T16:23:23.560282Z :FQ_PENDING_FETCHER TRACE: Request Private::GetTask, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0767, Host: ghrun-zwq4uro7ay, Tenant: /default
2025-10-26T16:23:23.561299Z :FQ_PENDING_FETCHER TRACE: Got GetTask response from PrivateApi
2025-10-26T16:23:23.561319Z :FQ_PENDING_FETCHER ERROR: Error with GetTask: <main>: Error: GRpc error: (14): failed to connect to all addresses; last error: UNKNOWN: ipv4:127.0.1.1:1363: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-zwq4uro7ay.auto.internal:1363
2025-10-26T16:23:24.560277Z :FQ_CONTROL_PLANE_CONFIG TRACE: LOADED TenantInfo: State NOT changed
2025-10-26T16:23:24.560470Z :FQ_PENDING_FETCHER TRACE: Request Private::GetTask, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0768, Host: ghrun-zwq4uro7ay, Tenant: /default
2025-10-26T16:23:24.561591Z :FQ_PENDING_FETCHER TRACE: Got GetTask response from PrivateApi
2025-10-26T16:23:24.561612Z :FQ_PENDING_FETCHER ERROR: Error with GetTask: <main>: Error: GRpc error: (14): failed to connect to all addresses; last error: UNKNOWN: ipv4:127.0.1.1:1363: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-zwq4uro7ay.auto.internal:1363
2025-10-26T16:23:25.560678Z :FQ_PENDING_FETCHER TRACE: Request Private::GetTask, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0769, Host: ghrun-zwq4uro7ay, Tenant: /default
2025-10-26T16:23:25.562024Z :FQ_PENDING_FETCHER TRACE: Got GetTask response from PrivateApi
2025-10-26T16:23:25.562046Z :FQ_PENDING_FETCHER ERROR: Error with GetTask: <main>: Error: GRpc error: (14): failed to connect to all addresses; last error: UNKNOWN: ipv4:127.0.1.1:1363: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-zwq4uro7ay.auto.internal:1363
2025-10-26T16:23:26.560850Z :FQ_PENDING_FETCHER TRACE: Request Private::GetTask, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0770, Host: ghrun-zwq4uro7ay, Tenant: /default
2025-10-26T16:23:26.562344Z :FQ_PENDING_FETCHER TRACE: Got GetTask response from PrivateApi
2025-10-26T16:23:26.562369Z :FQ_PENDING_FETCHER ERROR: Error with GetTask: <main>: Error: GRpc error: (14): failed to connect to all addresses; last error: UNKNOWN: ipv4:127.0.1.1:1363: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-zwq4uro7ay.auto.internal:1363
2025-10-26T16:23:27.561033Z :FQ_CONTROL_PLANE_CONFIG TRACE: LOADED TenantInfo: State NOT changed
2025-10-26T16:23:27.561195Z :FQ_PENDING_FETCHER TRACE: Request Private::GetTask, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0771, Host: ghrun-zwq4uro7ay, Tenant: /default
2025-10-26T16:23:27.562490Z :FQ_PENDING_FETCHER TRACE: Got GetTask response from PrivateApi
2025-10-26T16:23:27.562512Z :FQ_PENDING_FETCHER ERROR: Error with GetTask: <main>: Error: GRpc error: (14): failed to connect to all addresses; last error: UNKNOWN: ipv4:127.0.1.1:1363: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-zwq4uro7ay.auto.internal:1363
2025-10-26T16:23:28.554335Z :YQL_NODES_MANAGER TRACE: TNodesManagerActor::NodesHealthCheck
2025-10-26T16:23:28.556229Z :YQL_NODES_MANAGER ERROR: ydb/core/fq/libs/actors/nodes_manager.cpp:263: TRANSPORT_UNAVAILABLE
<main>: Error: GRpc error: (14): failed to connect to all addresses; last error: UNKNOWN: ipv4:127.0.1.1:1363: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-zwq4uro7ay.auto.internal:1363
2025-10-26T16:23:28.561508Z :FQ_PENDING_FETCHER TRACE: Request Private::GetTask, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0772, Host: ghrun-zwq4uro7ay, Tenant: /default
2025-10-26T16:23:28.562752Z :FQ_PENDING_FETCHER TRACE: Got GetTask response from PrivateApi
2025-10-26T16:23:28.562772Z :FQ_PENDING_FETCHER ERROR: Error with GetTask: <main>: Error: GRpc error: (14): failed to connect to all addresses; last error: UNKNOWN: ipv4:127.0.1.1:1363: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-zwq4uro7ay.auto.internal:1363
2025-10-26T16:23:29.561717Z :FQ_PENDING_FETCHER TRACE: Request Private::GetTask, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0773, Host: ghrun-zwq4uro7ay, Tenant: /default
2025-10-26T16:23:29.563147Z :FQ_PENDING_FETCHER TRACE: Got GetTask response from PrivateApi
2025-10-26T16:23:29.563169Z :FQ_PENDING_FETCHER ERROR: Error with GetTask: <main>: Error: GRpc error: (14): failed to connect to all addresses; last error: UNKNOWN: ipv4:127.0.1.1:1363: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-zwq4uro7ay.auto.internal:1363
2025-10-26T16:23:30.560408Z :FQ_CONTROL_PLANE_CONFIG TRACE: LOADED TenantInfo: State NOT changed
2025-10-26T16:23:30.561918Z :FQ_PENDING_FETCHER TRACE: Request Private::GetTask, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0774, Host: ghrun-zwq4uro7ay, Tenant: /default
2025-10-26T16:23:30.563096Z :FQ_PENDING_FETCHER TRACE: Got GetTask response from PrivateApi
2025-10-26T16:23:30.563118Z :FQ_PENDING_FETCHER ERROR: Error with GetTask: <main>: Error: GRpc error: (14): failed to connect to all addresses; last error: UNKNOWN: ipv4:127.0.1.1:1363: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-zwq4uro7ay.auto.internal:1363
2025-10-26T16:23:31.562086Z :FQ_PENDING_FETCHER TRACE: Request Private::GetTask, Owner: 717f0dae-ec1c1334-99acf168-5d9efd0775, Host: ghrun-zwq4uro7ay, Tenant: /default
2025-10-26T16:23:31.563432Z :FQ_PENDING_FETCHER TRACE: Got GetTask response from PrivateApi
2025-10-26T16:23:31.563457Z :FQ_PENDING_FETCHER ERROR: Error with GetTask: <main>: Error: GRpc error: (14): failed to connect to all addresses; last error: UNKNOWN: ipv4:127.0.1.1:1363: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-zwq4uro7ay.auto.internal:1363
