2025-12-12T12:30:37.938698Z :GRPC_SERVER NOTICE: grpc_request_proxy_simple.cpp:161: Grpc simple request proxy started, nodeid# 1
2025-12-12T12:30:37.938731Z :GRPC_SERVER NOTICE: grpc_request_proxy_simple.cpp:161: Grpc simple request proxy started, nodeid# 1
2025-12-12T12:30:37.938899Z :YQL_NODES_MANAGER INFO: nodes_manager.cpp:88: Bootstrap, InstanceId: 36a8860c-446019a9-70a193-d16d0bda
2025-12-12T12:30:37.938903Z :YQL_NODES_MANAGER DEBUG: nodes_manager.cpp:310: TNodesManagerActor::ResolveSelfAddress
2025-12-12T12:30:37.938915Z :YQ_TEST_CONNECTION DEBUG: test_connection.cpp:142: Starting yandex query test connection. Actor id: [1:7582947886208536960:2074]
2025-12-12T12:30:37.938963Z :FQ_LOG_UPDATER DEBUG: log.cpp:93: Updated YQL logs priority: 8
2025-12-12T12:30:37.938969Z :FQ_LOG_UPDATER CRIT: log.cpp:55: Failed to deliver subscription request to config dispatcher.
2025-12-12T12:30:37.938985Z :YQ_CONTROL_PLANE_STORAGE INFO: ydb_control_plane_storage.cpp:50: Starting ydb control plane storage service. Actor id: [1:7582947886208536948:2062]
2025-12-12T12:30:37.939345Z :YQ_CONTROL_PLANE_PROXY DEBUG: control_plane_proxy.cpp:525: Starting yandex query control plane proxy. Actor id: [1:7582947886208536950:2064]
2025-12-12T12:30:37.939417Z :YQ_RATE_LIMITER INFO: quoter_service.cpp:124: Bootstraping with config: { Enabled: true ControlPlaneEnabled: true DataPlaneEnabled: true Database { Endpoint: "localhost:64299" Database: "local" TablePrefix: "RateLimiter_fc63a0f1-6a53-42d2-b1d5-64d825d97259" } Limiters { CoordinationNodePath: "rate_limiter" } }
2025-12-12T12:30:37.939512Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create directory "local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259" actor
2025-12-12T12:30:37.939514Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create directory "local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259"
2025-12-12T12:30:37.939519Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:383: Call create directory "local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259"
2025-12-12T12:30:37.939576Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/bindings" actor
2025-12-12T12:30:37.939596Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/result_sets" actor
2025-12-12T12:30:37.939608Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/jobs" actor
2025-12-12T12:30:37.939612Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/connections" actor
2025-12-12T12:30:37.939627Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 83f32c25-411e3665-9904be74-55016d691, Host: ghrun-fhkyrtz6p4, Tenant: /default
2025-12-12T12:30:37.939635Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/tenants" actor
2025-12-12T12:30:37.939642Z :FQ_QUOTA_PROXY INFO: quota_proxy.cpp:90: STARTED
2025-12-12T12:30:37.939645Z :FQ_CONTROL_PLANE_CONFIG DEBUG: control_plane_config.cpp:58: STARTING: [1:7582947886208536949:2063]
2025-12-12T12:30:37.939709Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/compute_databases" actor
2025-12-12T12:30:37.939717Z :YQ_RATE_LIMITER DEBUG: schema.cpp:71: Run create coordination node "local/RateLimiter_fc63a0f1-6a53-42d2-b1d5-64d825d97259/rate_limiter" actor
2025-12-12T12:30:37.939718Z :YQ_RATE_LIMITER DEBUG: schema.cpp:113: Call create coordination node "local/RateLimiter_fc63a0f1-6a53-42d2-b1d5-64d825d97259/rate_limiter"
2025-12-12T12:30:37.939718Z :YQ_RATE_LIMITER DEBUG: schema.cpp:411: Call create coordination node "local/RateLimiter_fc63a0f1-6a53-42d2-b1d5-64d825d97259/rate_limiter"
2025-12-12T12:30:37.939731Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:214: Bootstrap
2025-12-12T12:30:37.939733Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:217: Create sdk ydb connection
2025-12-12T12:30:37.939771Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:239: Successfully bootstrapped TStorageProxy [1:7582947886208536954:2068] with connection to localhost:64299:local
2025-12-12T12:30:37.939775Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/queries" actor
2025-12-12T12:30:37.939783Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:544: RowDispatcher: Successfully bootstrapped row dispatcher, id [1:7582947886208536955:2069], tenant /default
2025-12-12T12:30:37.939790Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582947886208536955:2069]
2025-12-12T12:30:37.939791Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:329: Coordinator: Add new row dispatcher to map (state 1)
2025-12-12T12:30:37.939838Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:232: TLeaderElection [1:7582947886208537017:2114] Successfully bootstrapped, local coordinator id [1:7582947886208537016:2113], tenant id default, local mode 0, coordination node path local/default, endpoint localhost:64299
2025-12-12T12:30:37.940220Z :FQ_QUOTA_SERVICE INFO: quota_manager.cpp:196: STARTED
2025-12-12T12:30:37.940230Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/tenant_acks" actor
2025-12-12T12:30:37.940260Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/pending_small" actor
2025-12-12T12:30:37.941183Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:293: Coordinator: Successfully bootstrapped coordinator, id [1:7582947886208537016:2113], NodesManagerId [0:4705493345362661702:78], rebalancing timeout 5.000000s
2025-12-12T12:30:37.941196Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/idempotency_keys" actor
2025-12-12T12:30:37.941236Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/nodes" actor
2025-12-12T12:30:37.941245Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-12-12T12:30:37.941466Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/quotas" actor
2025-12-12T12:30:37.941481Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:637: RowDispatcher: TEvCoordinatorChangesSubscribe from [1:7582947886208537016:2113]
2025-12-12T12:30:37.941485Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/mappings" actor
2025-12-12T12:30:37.941552Z :MEMORY_PROFILER NOTICE: monitor.cpp:332: Bootstrapped
2025-12-12T12:30:37.942280Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:71: Run create coordination node "local/default" actor
2025-12-12T12:30:37.942288Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:113: Call create coordination node "local/default"
2025-12-12T12:30:37.942289Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:411: Call create coordination node "local/default"
2025-12-12T12:30:37.942474Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:30:37.942485Z :FQ_PENDING_FETCHER ERROR: pending_fetcher.cpp:259: Error with GetTask: <main>: Error: GRpc error: (14): connections to all backends failing; last error: UNKNOWN: ipv4:127.0.0.1:27430: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint localhost:27430
2025-12-12T12:30:37.942554Z :YQL_NODES_MANAGER ERROR: nodes_manager.cpp:395: ydb/core/fq/libs/actors/nodes_manager.cpp:353: TRANSPORT_UNAVAILABLE
<main>: Error: GRpc error: (14): connections to all backends failing; last error: UNKNOWN: ipv4:127.0.0.1:27430: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint localhost:27430
2025-12-12T12:30:37.948622Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:155: Successfully created coordination node "local/default"
2025-12-12T12:30:37.948637Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:122: Reply for create coordination node "local/default": { <main>: Error: Check failed: path: '/local/default', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 7], type: EPathTypeKesus, state: EPathStateNoChanges), source_location: ydb/core/tx/schemeshard/schemeshard__operation_create_kesus.cpp:339 }
2025-12-12T12:30:37.948650Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:345: TLeaderElection [1:7582947886208537017:2114] Coordination node successfully created
2025-12-12T12:30:37.948652Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:323: TLeaderElection [1:7582947886208537017:2114] Start session
2025-12-12T12:30:37.950812Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/pending_small". Create session OK
2025-12-12T12:30:37.950826Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/pending_small"
2025-12-12T12:30:37.950828Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/pending_small"
2025-12-12T12:30:37.950877Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/nodes". Create session OK
2025-12-12T12:30:37.950881Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/nodes"
2025-12-12T12:30:37.950883Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/nodes"
2025-12-12T12:30:37.951057Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/tenant_acks". Create session OK
2025-12-12T12:30:37.951067Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/tenant_acks"
2025-12-12T12:30:37.951070Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/tenant_acks"
2025-12-12T12:30:37.951133Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/jobs". Create session OK
2025-12-12T12:30:37.951144Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/jobs"
2025-12-12T12:30:37.951145Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/jobs"
2025-12-12T12:30:37.951202Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/compute_databases". Create session OK
2025-12-12T12:30:37.951211Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/compute_databases"
2025-12-12T12:30:37.951213Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/compute_databases"
2025-12-12T12:30:37.951225Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/bindings". Create session OK
2025-12-12T12:30:37.951226Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/bindings"
2025-12-12T12:30:37.951228Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/bindings"
2025-12-12T12:30:37.951299Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created directory "local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259"
2025-12-12T12:30:37.951319Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create directory "local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259": { <main>: Error: Check failed: path: '/local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 2], type: EPathTypeDir, state: EPathStateNoChanges), source_location: ydb/core/tx/schemeshard/schemeshard__operation_mkdir.cpp:155 }
2025-12-12T12:30:37.951327Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/result_sets". Create session OK
2025-12-12T12:30:37.951329Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/result_sets"
2025-12-12T12:30:37.951330Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/result_sets"
2025-12-12T12:30:37.951331Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/connections". Create session OK
2025-12-12T12:30:37.951335Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/connections"
2025-12-12T12:30:37.951336Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/connections"
2025-12-12T12:30:37.951412Z :YQ_RATE_LIMITER DEBUG: schema.cpp:155: Successfully created coordination node "local/RateLimiter_fc63a0f1-6a53-42d2-b1d5-64d825d97259/rate_limiter"
2025-12-12T12:30:37.951419Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:359: TLeaderElection [1:7582947886208537017:2114] Session successfully created
2025-12-12T12:30:37.951419Z :YQ_RATE_LIMITER DEBUG: schema.cpp:122: Reply for create coordination node "local/RateLimiter_fc63a0f1-6a53-42d2-b1d5-64d825d97259/rate_limiter": { <main>: Error: Check failed: path: '/local/RateLimiter_fc63a0f1-6a53-42d2-b1d5-64d825d97259/rate_limiter', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 9], type: EPathTypeKesus, state: EPathStateNoChanges), source_location: ydb/core/tx/schemeshard/schemeshard__operation_create_kesus.cpp:339 }
2025-12-12T12:30:37.951425Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/quotas". Create session OK
2025-12-12T12:30:37.951428Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/quotas"
2025-12-12T12:30:37.951429Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/quotas"
2025-12-12T12:30:37.951445Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/mappings". Create session OK
2025-12-12T12:30:37.951447Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/mappings"
2025-12-12T12:30:37.951447Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/mappings"
2025-12-12T12:30:37.951506Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/queries". Create session OK
2025-12-12T12:30:37.951514Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/tenants". Create session OK
2025-12-12T12:30:37.951515Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/queries"
2025-12-12T12:30:37.951516Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/queries"
2025-12-12T12:30:37.951516Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/tenants"
2025-12-12T12:30:37.951518Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/tenants"
2025-12-12T12:30:37.951577Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/idempotency_keys". Create session OK
2025-12-12T12:30:37.951578Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/idempotency_keys"
2025-12-12T12:30:37.951579Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/idempotency_keys"
2025-12-12T12:30:37.953560Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:372: TLeaderElection [1:7582947886208537017:2114] Semaphore successfully created
2025-12-12T12:30:37.953570Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:304: TLeaderElection [1:7582947886208537017:2114] Try to acquire semaphore
2025-12-12T12:30:37.953663Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:420: TLeaderElection [1:7582947886208537017:2114] Describe semaphore
2025-12-12T12:30:37.954201Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/pending_small"
2025-12-12T12:30:37.954218Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/pending_small": { <main>: Error: Check failed: path: '/local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/pending_small', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 20], type: EPathTypeTable, state: EPathStateNoChanges), source_location: ydb/core/tx/schemeshard/schemeshard__operation_create_table.cpp:504 }
2025-12-12T12:30:37.954318Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/nodes"
2025-12-12T12:30:37.954325Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/nodes": { <main>: Error: Check failed: path: '/local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/nodes', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 15], type: EPathTypeTable, state: EPathStateNoChanges), source_location: ydb/core/tx/schemeshard/schemeshard__operation_create_table.cpp:504 }
2025-12-12T12:30:37.954614Z :FQ_CONTROL_PLANE_CONFIG DEBUG: control_plane_config.cpp:190: LOADED TenantInfo: State CHANGED at 2025-12-12T12:27:09.909185Z
2025-12-12T12:30:37.954642Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/tenant_acks"
2025-12-12T12:30:37.954649Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/tenant_acks": { <main>: Error: Check failed: path: '/local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/tenant_acks', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 14], type: EPathTypeTable, state: EPathStateNoChanges), source_location: ydb/core/tx/schemeshard/schemeshard__operation_create_table.cpp:504 }
2025-12-12T12:30:37.955182Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:386: TLeaderElection [1:7582947886208537017:2114] Semaphore successfully acquired
2025-12-12T12:30:37.955315Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:469: TLeaderElection [1:7582947886208537017:2114] Semaphore successfully described: coordinator id [1:7582947886208537016:2113] generation 4
2025-12-12T12:30:37.955325Z :FQ_ROW_DISPATCHER INFO: leader_election.cpp:471: TLeaderElection [1:7582947886208537017:2114] Send TEvCoordinatorChanged to [1:7582947886208536955:2069], new coordinator id [1:7582947886208537016:2113], previous coordinator id [0:0:0]
2025-12-12T12:30:37.955352Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:569: RowDispatcher: Coordinator changed, old leader (empty maybe), new [1:7582947886208537016:2113] generation 4
2025-12-12T12:30:37.955370Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582947886208536955:2069]
2025-12-12T12:30:37.955376Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582947886208536955:2069]
2025-12-12T12:30:37.955379Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582947886208536955:2069]
2025-12-12T12:30:37.955390Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:440: Coordinator: New leader [1:7582947886208537016:2113], SelfId [1:7582947886208537016:2113]
2025-12-12T12:30:37.955393Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:30:37.955762Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/jobs"
2025-12-12T12:30:37.955771Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/jobs": { <main>: Error: Check failed: path: '/local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/jobs', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 19], type: EPathTypeTable, state: EPathStateNoChanges), source_location: ydb/core/tx/schemeshard/schemeshard__operation_create_table.cpp:504 }
2025-12-12T12:30:37.955780Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/quotas"
2025-12-12T12:30:37.955789Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/quotas": { <main>: Error: Check failed: path: '/local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/quotas', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 17], type: EPathTypeTable, state: EPathStateNoChanges), source_location: ydb/core/tx/schemeshard/schemeshard__operation_create_table.cpp:504 }
2025-12-12T12:30:37.955803Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/bindings"
2025-12-12T12:30:37.955815Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/bindings": { <main>: Error: Check failed: path: '/local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/bindings', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 12], type: EPathTypeTable, state: EPathStateNoChanges), source_location: ydb/core/tx/schemeshard/schemeshard__operation_create_table.cpp:504 }
2025-12-12T12:30:37.956124Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/connections"
2025-12-12T12:30:37.956130Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/connections": { <main>: Error: Check failed: path: '/local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/connections', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 18], type: EPathTypeTable, state: EPathStateNoChanges), source_location: ydb/core/tx/schemeshard/schemeshard__operation_create_table.cpp:504 }
2025-12-12T12:30:37.956155Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/result_sets"
2025-12-12T12:30:37.956161Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/result_sets": { <main>: Error: Check failed: path: '/local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/result_sets', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 11], type: EPathTypeTable, state: EPathStateNoChanges), source_location: ydb/core/tx/schemeshard/schemeshard__operation_create_table.cpp:504 }
2025-12-12T12:30:37.956179Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/mappings"
2025-12-12T12:30:37.956186Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/mappings": { <main>: Error: Check failed: path: '/local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/mappings', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 4], type: EPathTypeTable, state: EPathStateNoChanges), source_location: ydb/core/tx/schemeshard/schemeshard__operation_create_table.cpp:504 }
2025-12-12T12:30:37.956212Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/tenants"
2025-12-12T12:30:37.956217Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/tenants": { <main>: Error: Check failed: path: '/local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/tenants', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 3], type: EPathTypeTable, state: EPathStateNoChanges), source_location: ydb/core/tx/schemeshard/schemeshard__operation_create_table.cpp:504 }
2025-12-12T12:30:37.956242Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/compute_databases"
2025-12-12T12:30:37.956246Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/compute_databases": { <main>: Error: Check failed: path: '/local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/compute_databases', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 13], type: EPathTypeTable, state: EPathStateNoChanges), source_location: ydb/core/tx/schemeshard/schemeshard__operation_create_table.cpp:504 }
2025-12-12T12:30:37.956263Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/queries"
2025-12-12T12:30:37.956266Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/queries": { <main>: Error: Check failed: path: '/local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/queries', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 10], type: EPathTypeTable, state: EPathStateNoChanges), source_location: ydb/core/tx/schemeshard/schemeshard__operation_create_table.cpp:504 }
2025-12-12T12:30:37.956295Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/idempotency_keys"
2025-12-12T12:30:37.956299Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/idempotency_keys": { <main>: Error: Check failed: path: '/local/DbPoolStorage_fc63a0f1-6a53-42d2-b1d5-64d825d97259/idempotency_keys', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 16], type: EPathTypeTable, state: EPathStateNoChanges), source_location: ydb/core/tx/schemeshard/schemeshard__operation_create_table.cpp:504 }
2025-12-12T12:30:38.937344Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 83f32c25-411e3665-9904be74-55016d692, Host: ghrun-fhkyrtz6p4, Tenant: /default
2025-12-12T12:30:38.945003Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 83f32c25-411e3665-9904be74-55016d692, Host: ghrun-fhkyrtz6p4, Tenant: /default, Request CP::GetTask with size: 68 bytes
2025-12-12T12:30:38.945616Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/default"
owner_id: "83f32c25-411e3665-9904be74-55016d692"
host: "ghrun-fhkyrtz6p4"
node_id: 1
}
2025-12-12T12:30:38.948217Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:30:38.948240Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 83f32c25-411e3665-9904be74-55016d692, Host: ghrun-fhkyrtz6p4, Tenant: /default, Got CP::GetTask Response
2025-12-12T12:30:38.948532Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:30:38.948541Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:30:38.962152Z :TICKET_PARSER DEBUG: ticket_parser_impl.h:1875: Ticket **** (B6C6F477) (ipv6:[::1]:40826) has now valid token of root@builtin
2025-12-12T12:30:38.962226Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudq7uf4v1m09vu4bp"
2025-12-12T12:30:38.962255Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:305: Resolve folder bootstrap. Folder id: my_folder Actor id: [1:7582947890503504586:2380]
2025-12-12T12:30:38.962274Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:367: Cloud id: mock_cloud Folder id: my_folder
2025-12-12T12:30:38.962290Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:91: Get quotas bootstrap. Cloud id: mock_cloud Actor id: [1:7582947890503504587:2381]
2025-12-12T12:30:38.962307Z :FQ_QUOTA_SERVICE DEBUG: quota_manager.cpp:255: cloud.mock_cloud NOT CASHED, Loading ...
2025-12-12T12:30:38.964410Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:441: cloud.mock_cloud {yq.analyticsQuery.count=0/100, yq.cpuPercent.count=0/10000, yq.streamingQuery.count=1/100} FROM DB
2025-12-12T12:30:38.964442Z :FQ_QUOTA_SERVICE DEBUG: quota_manager.cpp:269: cloud.mock_cloud{yq.streamingQueryDurationMinutes.count=*/0, yq.queryResult.size=*/20971520, yq.analyticsQuery.count=0/100, yq.analyticsQueryDurationMinutes.count=*/1440, yq.memory.size=*/0, yq.result.size=*/0, yq.cpuPercent.count=0/10000, yq.streamingQuery.count=1/100} LOADED
2025-12-12T12:30:38.964445Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.analyticsQuery.count IS STALE, Refreshing ...
2025-12-12T12:30:38.964455Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.cpuPercent.count IS STALE, Refreshing ...
2025-12-12T12:30:38.964463Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.streamingQuery.count IS STALE, Refreshing ...
2025-12-12T12:30:38.964476Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.cpuPercent.count=0/10000 REFRESHED
2025-12-12T12:30:38.967076Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.analyticsQuery.count=0/100 REFRESHED
2025-12-12T12:30:38.967092Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.streamingQuery.count=0/100 REFRESHED
2025-12-12T12:30:38.967105Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:493: cloud.mock_cloud{yq.streamingQueryDurationMinutes.count=*/0, yq.queryResult.size=*/20971520, yq.analyticsQuery.count=0/100, yq.analyticsQueryDurationMinutes.count=*/1440, yq.memory.size=*/0, yq.result.size=*/0, yq.cpuPercent.count=0/10000, yq.streamingQuery.count=0/100} SEND QUOTAS
2025-12-12T12:30:38.967110Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:103: Cloud id: mock_cloud Quota count: 8
2025-12-12T12:30:38.967136Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudq7uf4v1m09vu4bp"
2025-12-12T12:30:38.967181Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:169: Resolve subject type bootstrap. Token: **** (B6C6F477) Actor id: [1:7582947890503504593:2387]
2025-12-12T12:30:38.967203Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:230: Subject Type: federated_account Token: **** (B6C6F477)
2025-12-12T12:30:38.967218Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudq7uf4v1m09vu4bp"
2025-12-12T12:30:38.967234Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:63: Request actor. Actor id: [1:7582947890503504594:2388]
2025-12-12T12:30:38.967272Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_queries.cpp:641: DescribeQueryRequest: {query_id: "ptqudq7uf4v1m09vu4bp"
} [root@builtin, **** (B6C6F477)] 
2025-12-12T12:30:38.969939Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.cpuPercent.count=0/10000 NOTIFY CHANGE
2025-12-12T12:30:38.970000Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: DescribeQueryRequest - DescribeQueryResult: {query { meta { common { id: "ptqudq7uf4v1m09vu4bp" created_by: "root@builtin" modified_by: "root@builtin" created_at { seconds: 1765542435 nanos: 256545000 } modified_at { seconds: 1765542435 nanos: 256545000 } revision: 1 } started_at { seconds: 1765542435 nanos: 822000000 } finished_at { seconds: 1765542630 nanos: 337000000 } execute_mode: RUN status: ABORTED_BY_SYSTEM last_job_query_revision: 1 last_job_id: "ptjudq7uf4v1lrak34fv-ptqudq7uf4v1m09vu4bp" started_by: "root@builtin" has_saved_checkpoints: true submitted_at { seconds: 1765542435 nanos: 256545000 } } content { type: STREAMING name: "simple" acl { visibility: PRIVATE } limits { execution_timeout { } } text: "\n            PRAGMA dq.MaxTasksPerStage=\"5\";\n\n            INSERT INTO yds_0.`read_rules_leaking_output`\n            SELECT * FROM yds_0.`read_rules_leaking_input`;" syntax: YQL_V1 } plan { json: "{\"Detailed\":{\"Operations\":[{\"Id\":3,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[{\"Name\":\"DqSourceWideWrap\"},{\"Name\":\"NarrowMap\"}]}},{\"Id\":2,\"Name\":\"DqQuery!\",\"DependsOn\":[3]},{\"Id\":1,\"Name\":\"Commit!\",\"DependsOn\":[2]}],\"OperationRoot\":1,\"Providers\":[],\"OperationStats\":{\"Commit!\":1,\"DqQuery!\":1,\"DqStage\":1}},\"Basic\":{\"nodes\":[{\"id\":3,\"level\":1,\"name\":\"DqStage #3\",\"type\":\"op\"},{\"id\":2,\"level\":2,\"name\":\"DqQuery!\",\"type\":\"op\"},{\"id\":1,\"level\":3,\"name\":\"Commit!\",\"type\":\"op\"}],\"links\":[{\"source\":3,\"target\":2},{\"source\":2,\"target\":1}]}}" } issue { message: "ABORTED_BY_SYSTEM" severity: 1 } transient_issue { message: "Query was aborted by system due to high failure rate" severity: 1 } statistics { json: "{\"Graph=0\":{\"Tasks\":{\"sum\":1,\"count\":1,\"avg\":1,\"max\":1,\"min\":1},\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":1,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"}}}" } ast { data: "(\n(let $1 (Configure! world (DataSource \'\"config\") \'\"DqEngine\" \'\"force\"))\n(let $2 (Configure! $1 (DataSource \'\"dq\" \'\"$all\") \'\"Attr\" \'\"maxtasksperstage\" \'\"5\"))\n(let $3 (DataSource \'\"pq\" \'\"yds_0\"))\n(let $4 \'(\'(\'\"PartitionsCount\" \'\"1\")))\n(let $5 (StructType \'(\'\"Data\" (DataType \'String))))\n(let $6 (PqTopic \'\"yds_0\" \'\"local\" \'\"read_rules_leaking_input\" $4 \'() $5))\n(let $7 \'(\'\"Endpoint\" \'\"localhost:64299\"))\n(let $8 \'(\'\"SharedReading\" \'\"0\"))\n(let $9 \'(\'\"AddBearerToToken\" \'\"1\"))\n(let $10 \'($7 $8 \'(\'\"ReconnectPeriod\" \'\"\") \'(\'\"Format\" \'\"raw\") \'(\'\"ReadGroup\" \'\"ptcudq7uf59fj0r5nfpe\") $9))\n(let $11 (SecureParam \'\"cluster:default_yds_0\"))\n(let $12 (DqPqTopicSource $2 $6 \'(\'\"Data\") $10 $11 \'\"\" $5 \'\"\"))\n(let $13 (DataSink \'\"pq\" \'\"yds_0\"))\n(let $14 (PqTopic \'\"yds_0\" \'\"local\" \'\"read_rules_leaking_output\" $4 \'() $5))\n(let $15 (DqPqTopicSink $14 \'($7 $9) $11))\n(return (Commit! (DqQuery! $2 \'((DqStage \'((DqSource $3 $12)) (lambda \'($16) (block \'(\n  (let $17 \'(\'(\'\"format\" \'\"raw\") \'(\'\"formatSettings\" \'(\'(\'\"data.datetime.formatname\" \'\"POSIX\") \'(\'\"data.timestamp.formatname\" \'\"POSIX\"))) \'(\'\"settings\" \'($8))))\n  (let $18 (DqSourceWideWrap $16 $3 $5 $17))\n  (return (NarrowMap $18 (lambda \'($19) (AsStruct \'(\'\"Data\" $19)))))\n))) \'(\'(\'\"_logical_id\" \'200208)) \'((DqSink \'\"0\" $13 $15))))) $13))\n)\n" } } } SUCCESS
2025-12-12T12:30:38.972060Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.analyticsQuery.count=0/100 NOTIFY CHANGE
2025-12-12T12:30:38.972094Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.streamingQuery.count=0/100 NOTIFY CHANGE
