2025-12-12T12:27:46.387966Z :GRPC_SERVER NOTICE: grpc_request_proxy_simple.cpp:161: Grpc simple request proxy started, nodeid# 1
2025-12-12T12:27:46.388026Z :GRPC_SERVER NOTICE: grpc_request_proxy_simple.cpp:161: Grpc simple request proxy started, nodeid# 1
2025-12-12T12:27:46.388226Z :YQ_TEST_CONNECTION DEBUG: test_connection.cpp:142: Starting yandex query test connection. Actor id: [1:7582947155240276122:2071]
2025-12-12T12:27:46.388461Z :YQ_CONTROL_PLANE_STORAGE INFO: ydb_control_plane_storage.cpp:50: Starting ydb control plane storage service. Actor id: [1:7582947155240276113:2062]
2025-12-12T12:27:46.388860Z :YQ_CONTROL_PLANE_PROXY DEBUG: control_plane_proxy.cpp:525: Starting yandex query control plane proxy. Actor id: [1:7582947155240276115:2064]
2025-12-12T12:27:46.388943Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:214: Bootstrap
2025-12-12T12:27:46.388944Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:217: Create sdk ydb connection
2025-12-12T12:27:46.388972Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:239: Successfully bootstrapped TStorageProxy [1:7582947155240276118:2067] with connection to localhost:21682:local
2025-12-12T12:27:46.388984Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_59343c87-a0fa-4d02-bbd7-bed27d35921a/connections" actor
2025-12-12T12:27:46.389021Z :FQ_QUOTA_PROXY INFO: quota_proxy.cpp:90: STARTED
2025-12-12T12:27:46.389032Z :FQ_LOG_UPDATER DEBUG: log.cpp:93: Updated YQL logs priority: 8
2025-12-12T12:27:46.389044Z :FQ_LOG_UPDATER CRIT: log.cpp:55: Failed to deliver subscription request to config dispatcher.
2025-12-12T12:27:46.389052Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_59343c87-a0fa-4d02-bbd7-bed27d35921a/quotas" actor
2025-12-12T12:27:46.389059Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_59343c87-a0fa-4d02-bbd7-bed27d35921a/tenants" actor
2025-12-12T12:27:46.389069Z :FQ_CONTROL_PLANE_CONFIG DEBUG: control_plane_config.cpp:58: STARTING: [1:7582947155240276114:2063]
2025-12-12T12:27:46.389089Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_59343c87-a0fa-4d02-bbd7-bed27d35921a/mappings" actor
2025-12-12T12:27:46.389098Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_59343c87-a0fa-4d02-bbd7-bed27d35921a/compute_databases" actor
2025-12-12T12:27:46.389107Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:544: RowDispatcher: Successfully bootstrapped row dispatcher, id [1:7582947155240276119:2068], tenant /cp
2025-12-12T12:27:46.389118Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582947155240276119:2068]
2025-12-12T12:27:46.389120Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:329: Coordinator: Add new row dispatcher to map (state 1)
2025-12-12T12:27:46.389195Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create directory "local/DbPoolStorage_59343c87-a0fa-4d02-bbd7-bed27d35921a" actor
2025-12-12T12:27:46.389197Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create directory "local/DbPoolStorage_59343c87-a0fa-4d02-bbd7-bed27d35921a"
2025-12-12T12:27:46.389199Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:383: Call create directory "local/DbPoolStorage_59343c87-a0fa-4d02-bbd7-bed27d35921a"
2025-12-12T12:27:46.389222Z :YQ_RATE_LIMITER DEBUG: schema.cpp:71: Run create coordination node "local/RateLimiter_59343c87-a0fa-4d02-bbd7-bed27d35921a/rate_limiter" actor
2025-12-12T12:27:46.389223Z :YQ_RATE_LIMITER DEBUG: schema.cpp:113: Call create coordination node "local/RateLimiter_59343c87-a0fa-4d02-bbd7-bed27d35921a/rate_limiter"
2025-12-12T12:27:46.389225Z :YQ_RATE_LIMITER DEBUG: schema.cpp:411: Call create coordination node "local/RateLimiter_59343c87-a0fa-4d02-bbd7-bed27d35921a/rate_limiter"
2025-12-12T12:27:46.389272Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_59343c87-a0fa-4d02-bbd7-bed27d35921a/pending_small" actor
2025-12-12T12:27:46.389292Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_59343c87-a0fa-4d02-bbd7-bed27d35921a/bindings" actor
2025-12-12T12:27:46.389300Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_59343c87-a0fa-4d02-bbd7-bed27d35921a/idempotency_keys" actor
2025-12-12T12:27:46.389307Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_59343c87-a0fa-4d02-bbd7-bed27d35921a/result_sets" actor
2025-12-12T12:27:46.389318Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_59343c87-a0fa-4d02-bbd7-bed27d35921a/nodes" actor
2025-12-12T12:27:46.389324Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_59343c87-a0fa-4d02-bbd7-bed27d35921a/tenant_acks" actor
2025-12-12T12:27:46.389344Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_59343c87-a0fa-4d02-bbd7-bed27d35921a/queries" actor
2025-12-12T12:27:46.389357Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:293: Coordinator: Successfully bootstrapped coordinator, id [1:7582947155240276175:2107], NodesManagerId [0:4705493345362661702:78], rebalancing timeout 5.000000s
2025-12-12T12:27:46.389364Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:232: TLeaderElection [1:7582947155240276176:2108] Successfully bootstrapped, local coordinator id [1:7582947155240276175:2107], tenant id cp, local mode 0, coordination node path local/cp, endpoint localhost:21682
2025-12-12T12:27:46.389871Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:637: RowDispatcher: TEvCoordinatorChangesSubscribe from [1:7582947155240276175:2107]
2025-12-12T12:27:46.389956Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_59343c87-a0fa-4d02-bbd7-bed27d35921a/jobs" actor
2025-12-12T12:27:46.391240Z :MEMORY_PROFILER NOTICE: monitor.cpp:332: Bootstrapped
2025-12-12T12:27:46.399471Z :FQ_QUOTA_SERVICE INFO: quota_manager.cpp:196: STARTED
2025-12-12T12:27:46.399483Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:71: Run create coordination node "local/cp" actor
2025-12-12T12:27:46.399487Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:113: Call create coordination node "local/cp"
2025-12-12T12:27:46.399489Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:411: Call create coordination node "local/cp"
2025-12-12T12:27:46.423779Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_59343c87-a0fa-4d02-bbd7-bed27d35921a/mappings". Create session OK
2025-12-12T12:27:46.423796Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_59343c87-a0fa-4d02-bbd7-bed27d35921a/mappings"
2025-12-12T12:27:46.423799Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_59343c87-a0fa-4d02-bbd7-bed27d35921a/mappings"
2025-12-12T12:27:46.426507Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_59343c87-a0fa-4d02-bbd7-bed27d35921a/result_sets". Create session OK
2025-12-12T12:27:46.426524Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_59343c87-a0fa-4d02-bbd7-bed27d35921a/result_sets"
2025-12-12T12:27:46.426527Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_59343c87-a0fa-4d02-bbd7-bed27d35921a/result_sets"
2025-12-12T12:27:46.426826Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_59343c87-a0fa-4d02-bbd7-bed27d35921a/compute_databases". Create session OK
2025-12-12T12:27:46.426847Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_59343c87-a0fa-4d02-bbd7-bed27d35921a/compute_databases"
2025-12-12T12:27:46.426857Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_59343c87-a0fa-4d02-bbd7-bed27d35921a/compute_databases"
2025-12-12T12:27:46.426920Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_59343c87-a0fa-4d02-bbd7-bed27d35921a/idempotency_keys". Create session OK
2025-12-12T12:27:46.426939Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_59343c87-a0fa-4d02-bbd7-bed27d35921a/idempotency_keys"
2025-12-12T12:27:46.426942Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_59343c87-a0fa-4d02-bbd7-bed27d35921a/idempotency_keys"
2025-12-12T12:27:46.427064Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_59343c87-a0fa-4d02-bbd7-bed27d35921a/jobs". Create session OK
2025-12-12T12:27:46.427080Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_59343c87-a0fa-4d02-bbd7-bed27d35921a/jobs"
2025-12-12T12:27:46.427090Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_59343c87-a0fa-4d02-bbd7-bed27d35921a/jobs"
2025-12-12T12:27:46.427138Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_59343c87-a0fa-4d02-bbd7-bed27d35921a/connections". Create session OK
2025-12-12T12:27:46.427142Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_59343c87-a0fa-4d02-bbd7-bed27d35921a/connections"
2025-12-12T12:27:46.427144Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_59343c87-a0fa-4d02-bbd7-bed27d35921a/connections"
2025-12-12T12:27:46.427229Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_59343c87-a0fa-4d02-bbd7-bed27d35921a/nodes". Create session OK
2025-12-12T12:27:46.427237Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_59343c87-a0fa-4d02-bbd7-bed27d35921a/nodes"
2025-12-12T12:27:46.427239Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_59343c87-a0fa-4d02-bbd7-bed27d35921a/nodes"
2025-12-12T12:27:46.427250Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_59343c87-a0fa-4d02-bbd7-bed27d35921a/bindings". Create session OK
2025-12-12T12:27:46.427254Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_59343c87-a0fa-4d02-bbd7-bed27d35921a/bindings"
2025-12-12T12:27:46.427255Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_59343c87-a0fa-4d02-bbd7-bed27d35921a/bindings"
2025-12-12T12:27:46.427321Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_59343c87-a0fa-4d02-bbd7-bed27d35921a/tenants". Create session OK
2025-12-12T12:27:46.427332Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_59343c87-a0fa-4d02-bbd7-bed27d35921a/tenants"
2025-12-12T12:27:46.427334Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_59343c87-a0fa-4d02-bbd7-bed27d35921a/tenants"
2025-12-12T12:27:46.427871Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_59343c87-a0fa-4d02-bbd7-bed27d35921a/queries". Create session OK
2025-12-12T12:27:46.427881Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_59343c87-a0fa-4d02-bbd7-bed27d35921a/queries"
2025-12-12T12:27:46.427883Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_59343c87-a0fa-4d02-bbd7-bed27d35921a/queries"
2025-12-12T12:27:46.427885Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_59343c87-a0fa-4d02-bbd7-bed27d35921a/quotas". Create session OK
2025-12-12T12:27:46.427888Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_59343c87-a0fa-4d02-bbd7-bed27d35921a/quotas"
2025-12-12T12:27:46.427890Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_59343c87-a0fa-4d02-bbd7-bed27d35921a/quotas"
2025-12-12T12:27:46.427935Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_59343c87-a0fa-4d02-bbd7-bed27d35921a/pending_small". Create session OK
2025-12-12T12:27:46.427940Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_59343c87-a0fa-4d02-bbd7-bed27d35921a/pending_small"
2025-12-12T12:27:46.427942Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_59343c87-a0fa-4d02-bbd7-bed27d35921a/pending_small"
2025-12-12T12:27:46.428002Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_59343c87-a0fa-4d02-bbd7-bed27d35921a/tenant_acks". Create session OK
2025-12-12T12:27:46.428013Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_59343c87-a0fa-4d02-bbd7-bed27d35921a/tenant_acks"
2025-12-12T12:27:46.428016Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_59343c87-a0fa-4d02-bbd7-bed27d35921a/tenant_acks"
2025-12-12T12:27:46.428810Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created directory "local/DbPoolStorage_59343c87-a0fa-4d02-bbd7-bed27d35921a"
2025-12-12T12:27:46.428828Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create directory "local/DbPoolStorage_59343c87-a0fa-4d02-bbd7-bed27d35921a": { <main>: Error: Check failed: path: '/local/DbPoolStorage_59343c87-a0fa-4d02-bbd7-bed27d35921a', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 53], type: EPathTypeDir, state: EPathStateNoChanges), source_location: ydb/core/tx/schemeshard/schemeshard__operation_mkdir.cpp:155 }
2025-12-12T12:27:46.428986Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_59343c87-a0fa-4d02-bbd7-bed27d35921a/mappings"
2025-12-12T12:27:46.428997Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_59343c87-a0fa-4d02-bbd7-bed27d35921a/mappings": { <main>: Error: Check failed: path: '/local/DbPoolStorage_59343c87-a0fa-4d02-bbd7-bed27d35921a/mappings', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 55], type: EPathTypeTable, state: EPathStateNoChanges), source_location: ydb/core/tx/schemeshard/schemeshard__operation_create_table.cpp:504 }
2025-12-12T12:27:46.444693Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_59343c87-a0fa-4d02-bbd7-bed27d35921a/tenants"
2025-12-12T12:27:46.444722Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_59343c87-a0fa-4d02-bbd7-bed27d35921a/tenants": { <main>: Error: Check failed: path: '/local/DbPoolStorage_59343c87-a0fa-4d02-bbd7-bed27d35921a/tenants', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 54], type: EPathTypeTable, state: EPathStateNoChanges), source_location: ydb/core/tx/schemeshard/schemeshard__operation_create_table.cpp:504 }
2025-12-12T12:27:46.460381Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:155: Successfully created coordination node "local/cp"
2025-12-12T12:27:46.460397Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:122: Reply for create coordination node "local/cp": 
2025-12-12T12:27:46.460425Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:345: TLeaderElection [1:7582947155240276176:2108] Coordination node successfully created
2025-12-12T12:27:46.460429Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:323: TLeaderElection [1:7582947155240276176:2108] Start session
2025-12-12T12:27:46.472455Z :FQ_CONTROL_PLANE_CONFIG DEBUG: control_plane_config.cpp:190: LOADED TenantInfo: State CHANGED at 2025-12-12T12:27:45.985414Z
2025-12-12T12:27:46.475279Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:359: TLeaderElection [1:7582947155240276176:2108] Session successfully created
2025-12-12T12:27:46.480635Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:372: TLeaderElection [1:7582947155240276176:2108] Semaphore successfully created
2025-12-12T12:27:46.480646Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:304: TLeaderElection [1:7582947155240276176:2108] Try to acquire semaphore
2025-12-12T12:27:46.480799Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:420: TLeaderElection [1:7582947155240276176:2108] Describe semaphore
2025-12-12T12:27:46.483094Z :YQ_RATE_LIMITER DEBUG: schema.cpp:155: Successfully created coordination node "local/RateLimiter_59343c87-a0fa-4d02-bbd7-bed27d35921a/rate_limiter"
2025-12-12T12:27:46.483107Z :YQ_RATE_LIMITER DEBUG: schema.cpp:122: Reply for create coordination node "local/RateLimiter_59343c87-a0fa-4d02-bbd7-bed27d35921a/rate_limiter": 
2025-12-12T12:27:46.483128Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_59343c87-a0fa-4d02-bbd7-bed27d35921a/pending_small"
2025-12-12T12:27:46.483130Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_59343c87-a0fa-4d02-bbd7-bed27d35921a/pending_small": 
2025-12-12T12:27:46.484963Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:386: TLeaderElection [1:7582947155240276176:2108] Semaphore successfully acquired
2025-12-12T12:27:46.485352Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:469: TLeaderElection [1:7582947155240276176:2108] Semaphore successfully described: coordinator id [1:7582947155240276175:2107] generation 1
2025-12-12T12:27:46.485362Z :FQ_ROW_DISPATCHER INFO: leader_election.cpp:471: TLeaderElection [1:7582947155240276176:2108] Send TEvCoordinatorChanged to [1:7582947155240276119:2068], new coordinator id [1:7582947155240276175:2107], previous coordinator id [0:0:0]
2025-12-12T12:27:46.485378Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:569: RowDispatcher: Coordinator changed, old leader (empty maybe), new [1:7582947155240276175:2107] generation 1
2025-12-12T12:27:46.485391Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582947155240276119:2068]
2025-12-12T12:27:46.485395Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582947155240276119:2068]
2025-12-12T12:27:46.485398Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582947155240276119:2068]
2025-12-12T12:27:46.485410Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:440: Coordinator: New leader [1:7582947155240276175:2107], SelfId [1:7582947155240276175:2107]
2025-12-12T12:27:46.485414Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:46.488516Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_59343c87-a0fa-4d02-bbd7-bed27d35921a/tenant_acks"
2025-12-12T12:27:46.488527Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_59343c87-a0fa-4d02-bbd7-bed27d35921a/tenant_acks": 
2025-12-12T12:27:46.488534Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_59343c87-a0fa-4d02-bbd7-bed27d35921a/quotas"
2025-12-12T12:27:46.488539Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_59343c87-a0fa-4d02-bbd7-bed27d35921a/quotas": 
2025-12-12T12:27:46.491516Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_59343c87-a0fa-4d02-bbd7-bed27d35921a/jobs"
2025-12-12T12:27:46.491527Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_59343c87-a0fa-4d02-bbd7-bed27d35921a/jobs": 
2025-12-12T12:27:46.491570Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_59343c87-a0fa-4d02-bbd7-bed27d35921a/connections"
2025-12-12T12:27:46.491577Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_59343c87-a0fa-4d02-bbd7-bed27d35921a/nodes"
2025-12-12T12:27:46.491580Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_59343c87-a0fa-4d02-bbd7-bed27d35921a/connections": 
2025-12-12T12:27:46.491583Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_59343c87-a0fa-4d02-bbd7-bed27d35921a/nodes": 
2025-12-12T12:27:46.491707Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_59343c87-a0fa-4d02-bbd7-bed27d35921a/compute_databases"
2025-12-12T12:27:46.491711Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_59343c87-a0fa-4d02-bbd7-bed27d35921a/bindings"
2025-12-12T12:27:46.491713Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_59343c87-a0fa-4d02-bbd7-bed27d35921a/bindings": 
2025-12-12T12:27:46.491720Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_59343c87-a0fa-4d02-bbd7-bed27d35921a/compute_databases": 
2025-12-12T12:27:46.491776Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_59343c87-a0fa-4d02-bbd7-bed27d35921a/result_sets"
2025-12-12T12:27:46.491777Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_59343c87-a0fa-4d02-bbd7-bed27d35921a/result_sets": 
2025-12-12T12:27:46.491779Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_59343c87-a0fa-4d02-bbd7-bed27d35921a/idempotency_keys"
2025-12-12T12:27:46.491781Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_59343c87-a0fa-4d02-bbd7-bed27d35921a/idempotency_keys": 
2025-12-12T12:27:46.491780Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_59343c87-a0fa-4d02-bbd7-bed27d35921a/queries"
2025-12-12T12:27:46.491783Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_59343c87-a0fa-4d02-bbd7-bed27d35921a/queries": 
2025-12-12T12:27:47.371315Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 8cd48908-114eaca5-40f0faab-6c6f9e781, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 68 bytes
2025-12-12T12:27:47.372041Z :YQ_CONTROL_PLANE_STORAGE TRACE: nodes_health_check.cpp:38: NodesHealthCheckRequest: {tenant: "/compute"
node {
  node_id: 1
  instance_id: "d78f682c-486d5c39-64f74a4-900b51bb"
  hostname: "ghrun-fhkyrtz6p4"
  interconnect_port: 18549
  node_address: "127.0.1.1"
}
}
2025-12-12T12:27:47.372140Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "8cd48908-114eaca5-40f0faab-6c6f9e781"
host: "ghrun-fhkyrtz6p4"
node_id: 1
}
2025-12-12T12:27:47.447637Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:27:47.447688Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 8cd48908-114eaca5-40f0faab-6c6f9e781, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:27:47.475386Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: NodesHealthCheckRequest - NodesHealthCheckResult: {nodes { node_id: 1 instance_id: "d78f682c-486d5c39-64f74a4-900b51bb" hostname: "ghrun-fhkyrtz6p4" node_address: "127.0.1.1" } } SUCCESS
2025-12-12T12:27:47.900387Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 23f17547-a6ae60e4-cfc06ca9-d86b14f91, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 68 bytes
2025-12-12T12:27:47.900408Z :YQ_CONTROL_PLANE_STORAGE TRACE: nodes_health_check.cpp:38: NodesHealthCheckRequest: {tenant: "/compute"
node {
  node_id: 2
  instance_id: "9d9f24b1-434edf1f-bb4262b3-181f5524"
  hostname: "ghrun-fhkyrtz6p4"
  interconnect_port: 14648
  node_address: "127.0.1.1"
}
}
2025-12-12T12:27:47.900481Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "23f17547-a6ae60e4-cfc06ca9-d86b14f91"
host: "ghrun-fhkyrtz6p4"
node_id: 2
}
2025-12-12T12:27:47.903393Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:27:47.903434Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 23f17547-a6ae60e4-cfc06ca9-d86b14f91, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:27:47.908792Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: NodesHealthCheckRequest - NodesHealthCheckResult: {nodes { node_id: 2 instance_id: "9d9f24b1-434edf1f-bb4262b3-181f5524" hostname: "ghrun-fhkyrtz6p4" node_address: "127.0.1.1" } nodes { node_id: 1 instance_id: "d78f682c-486d5c39-64f74a4-900b51bb" hostname: "ghrun-fhkyrtz6p4" interconnect_port: 18549 node_address: "127.0.1.1" } } SUCCESS
2025-12-12T12:27:48.331296Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 8cd48908-114eaca5-40f0faab-6c6f9e782, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 68 bytes
2025-12-12T12:27:48.331345Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "8cd48908-114eaca5-40f0faab-6c6f9e782"
host: "ghrun-fhkyrtz6p4"
node_id: 1
}
2025-12-12T12:27:48.335208Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:27:48.335280Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 8cd48908-114eaca5-40f0faab-6c6f9e782, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:27:48.387967Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582947155240276175:2107]
2025-12-12T12:27:48.387991Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:48.388009Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582947155240276119:2068]
2025-12-12T12:27:48.388015Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582947155240276119:2068]
2025-12-12T12:27:48.388018Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582947155240276119:2068]
2025-12-12T12:27:48.388032Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:48.892966Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 23f17547-a6ae60e4-cfc06ca9-d86b14f92, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 68 bytes
2025-12-12T12:27:48.893049Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "23f17547-a6ae60e4-cfc06ca9-d86b14f92"
host: "ghrun-fhkyrtz6p4"
node_id: 2
}
2025-12-12T12:27:48.895576Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:27:48.895608Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 23f17547-a6ae60e4-cfc06ca9-d86b14f92, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:27:49.015548Z :TICKET_PARSER DEBUG: ticket_parser_impl.h:1875: Ticket **** (B6C6F477) (ipv6:[::1]:36944) has now valid token of root@builtin
2025-12-12T12:27:49.015736Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:1330: CreateConnectionRequest: content { name: "myyds" setting { data_streams { auth { none { } } endpoint: "localhost:21682" database: "local" } } acl { visibility: PRIVATE } } 
2025-12-12T12:27:49.015778Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:305: Resolve folder bootstrap. Folder id: my_folder Actor id: [1:7582947168125178128:2168]
2025-12-12T12:27:49.015797Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:367: Cloud id: mock_cloud Folder id: my_folder
2025-12-12T12:27:49.015812Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:91: Get quotas bootstrap. Cloud id: mock_cloud Actor id: [1:7582947168125178129:2169]
2025-12-12T12:27:49.015829Z :FQ_QUOTA_SERVICE DEBUG: quota_manager.cpp:255: cloud.mock_cloud NOT CASHED, Loading ...
2025-12-12T12:27:49.046280Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:441: cloud.mock_cloud {} FROM DB
2025-12-12T12:27:49.046309Z :FQ_QUOTA_SERVICE DEBUG: quota_manager.cpp:269: cloud.mock_cloud{yq.streamingQueryDurationMinutes.count=*/0, yq.queryResult.size=*/20971520, yq.analyticsQuery.count=*/100, yq.analyticsQueryDurationMinutes.count=*/1440, yq.memory.size=*/0, yq.result.size=*/0, yq.cpuPercent.count=*/10000, yq.streamingQuery.count=*/100} LOADED
2025-12-12T12:27:49.046314Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.analyticsQuery.count IS STALE, Refreshing ...
2025-12-12T12:27:49.046324Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.cpuPercent.count IS STALE, Refreshing ...
2025-12-12T12:27:49.046330Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.streamingQuery.count IS STALE, Refreshing ...
2025-12-12T12:27:49.046344Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.cpuPercent.count=0/10000 REFRESHED
2025-12-12T12:27:49.092368Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.cpuPercent.count=0/10000 NOTIFY CHANGE
2025-12-12T12:27:49.095813Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.analyticsQuery.count=0/100 REFRESHED
2025-12-12T12:27:49.095840Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.streamingQuery.count=0/100 REFRESHED
2025-12-12T12:27:49.095863Z :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:27:49.095876Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:103: Cloud id: mock_cloud Quota count: 8
2025-12-12T12:27:49.096000Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:1330: CreateConnectionRequest: content { name: "myyds" setting { data_streams { auth { none { } } endpoint: "localhost:21682" database: "local" } } acl { visibility: PRIVATE } } 
2025-12-12T12:27:49.096086Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:169: Resolve subject type bootstrap. Token: **** (B6C6F477) Actor id: [1:7582947168125178135:2175]
2025-12-12T12:27:49.096114Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:230: Subject Type: federated_account Token: **** (B6C6F477)
2025-12-12T12:27:49.096212Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:1330: CreateConnectionRequest: content { name: "myyds" setting { data_streams { auth { none { } } endpoint: "localhost:21682" database: "local" } } acl { visibility: PRIVATE } } 
2025-12-12T12:27:49.096255Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:435: Create database bootstrap. CloudId: mock_cloud Scope: yandexcloud://my_folder Actor id: [1:7582947168125178136:2176]
2025-12-12T12:27:49.096332Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:1330: CreateConnectionRequest: content { name: "myyds" setting { data_streams { auth { none { } } endpoint: "localhost:21682" database: "local" } } acl { visibility: PRIVATE } } 
2025-12-12T12:27:49.096366Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:63: Request actor. Actor id: [1:7582947168125178137:2177]
2025-12-12T12:27:49.096490Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_connections.cpp:120: [yandexcloud://my_folder, root@builtin, ptcudq7ue4mb10b2jjv4] CreateConnectionRequest: **** (B6C6F477) content { name: "myyds" setting { data_streams { auth { none { } } endpoint: "localhost:21682" database: "local" } } acl { visibility: PRIVATE } } 
2025-12-12T12:27:49.101725Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.analyticsQuery.count=0/100 NOTIFY CHANGE
2025-12-12T12:27:49.102513Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.streamingQuery.count=0/100 NOTIFY CHANGE
2025-12-12T12:27:49.331237Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 8cd48908-114eaca5-40f0faab-6c6f9e783, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 68 bytes
2025-12-12T12:27:49.331311Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "8cd48908-114eaca5-40f0faab-6c6f9e783"
host: "ghrun-fhkyrtz6p4"
node_id: 1
}
2025-12-12T12:27:49.335434Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:27:49.335472Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 8cd48908-114eaca5-40f0faab-6c6f9e783, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:27:49.399242Z :FQ_CONTROL_PLANE_CONFIG TRACE: control_plane_config.cpp:192: LOADED TenantInfo: State NOT changed
2025-12-12T12:27:49.434852Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: [yandexcloud://my_folder, root@builtin, ptcudq7ue4mb10b2jjv4] CreateConnectionRequest: {connection_id: "ptcudq7ue4mb10b2jjv4" } SUCCESS
2025-12-12T12:27:49.437692Z :TICKET_PARSER DEBUG: ticket_parser_impl.h:1875: Ticket **** (B6C6F477) (ipv6:[::1]:36944) has now valid token of root@builtin
2025-12-12T12:27:49.437822Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:648: CreateQueryRequest: content {
  type: STREAMING
  name: "simple"
  acl {
    visibility: PRIVATE
  }
  limits {
    execution_timeout {
    }
  }
  text: "\n            PRAGMA dq.MaxTasksPerStage=\"2\";\n\n            INSERT INTO myyds.`recovery_output`\n            SELECT STREAM\n                *\n            FROM myyds.`recovery_input`;"
  syntax: YQL_V1
}
execute_mode: RUN
idempotency_key: "323c4a81-6ad1-4103-8ed4-80b07dad8524"
2025-12-12T12:27:49.437858Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:305: Resolve folder bootstrap. Folder id: my_folder Actor id: [1:7582947168125178145:2184]
2025-12-12T12:27:49.437882Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:367: Cloud id: mock_cloud Folder id: my_folder
2025-12-12T12:27:49.437915Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:91: Get quotas bootstrap. Cloud id: mock_cloud Actor id: [1:7582947168125178146:2185]
2025-12-12T12:27:49.437945Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.analyticsQuery.count IS STALE, Refreshing ...
2025-12-12T12:27:49.437958Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.cpuPercent.count IS STALE, Refreshing ...
2025-12-12T12:27:49.437971Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.streamingQuery.count IS STALE, Refreshing ...
2025-12-12T12:27:49.437983Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.cpuPercent.count=0/10000 REFRESHED
2025-12-12T12:27:49.440369Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.analyticsQuery.count=0/100 REFRESHED
2025-12-12T12:27:49.440387Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.streamingQuery.count=0/100 REFRESHED
2025-12-12T12:27:49.440404Z :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:27:49.440412Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:103: Cloud id: mock_cloud Quota count: 8
2025-12-12T12:27:49.440461Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:648: CreateQueryRequest: content {
  type: STREAMING
  name: "simple"
  acl {
    visibility: PRIVATE
  }
  limits {
    execution_timeout {
    }
  }
  text: "\n            PRAGMA dq.MaxTasksPerStage=\"2\";\n\n            INSERT INTO myyds.`recovery_output`\n            SELECT STREAM\n                *\n            FROM myyds.`recovery_input`;"
  syntax: YQL_V1
}
execute_mode: RUN
idempotency_key: "323c4a81-6ad1-4103-8ed4-80b07dad8524"
2025-12-12T12:27:49.440526Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:169: Resolve subject type bootstrap. Token: **** (B6C6F477) Actor id: [1:7582947168125178151:2190]
2025-12-12T12:27:49.440553Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:230: Subject Type: federated_account Token: **** (B6C6F477)
2025-12-12T12:27:49.440598Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:648: CreateQueryRequest: content {
  type: STREAMING
  name: "simple"
  acl {
    visibility: PRIVATE
  }
  limits {
    execution_timeout {
    }
  }
  text: "\n            PRAGMA dq.MaxTasksPerStage=\"2\";\n\n            INSERT INTO myyds.`recovery_output`\n            SELECT STREAM\n                *\n            FROM myyds.`recovery_input`;"
  syntax: YQL_V1
}
execute_mode: RUN
idempotency_key: "323c4a81-6ad1-4103-8ed4-80b07dad8524"
2025-12-12T12:27:49.440633Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:435: Create database bootstrap. CloudId: mock_cloud Scope: yandexcloud://my_folder Actor id: [1:7582947168125178152:2191]
2025-12-12T12:27:49.440686Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:648: CreateQueryRequest: content {
  type: STREAMING
  name: "simple"
  acl {
    visibility: PRIVATE
  }
  limits {
    execution_timeout {
    }
  }
  text: "\n            PRAGMA dq.MaxTasksPerStage=\"2\";\n\n            INSERT INTO myyds.`recovery_output`\n            SELECT STREAM\n                *\n            FROM myyds.`recovery_input`;"
  syntax: YQL_V1
}
execute_mode: RUN
idempotency_key: "323c4a81-6ad1-4103-8ed4-80b07dad8524"
2025-12-12T12:27:49.440727Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:63: Request actor. Actor id: [1:7582947168125178153:2192]
2025-12-12T12:27:49.440747Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:248: Create rate limiter resource for cloud with limit 100000ms
2025-12-12T12:27:49.440774Z :YQ_RATE_LIMITER DEBUG: schema.cpp:71: Run create rate limiter resource "mock_cloud" actor
2025-12-12T12:27:49.440780Z :YQ_RATE_LIMITER DEBUG: schema.cpp:113: Call create rate limiter resource "mock_cloud"
2025-12-12T12:27:49.443727Z :YQ_RATE_LIMITER DEBUG: schema.cpp:155: Successfully created rate limiter resource "mock_cloud"
2025-12-12T12:27:49.443738Z :YQ_RATE_LIMITER DEBUG: schema.cpp:122: Reply for create rate limiter resource "mock_cloud": 
2025-12-12T12:27:49.443770Z :YQ_CONTROL_PLANE_PROXY DEBUG: request_actor.h:272: Create response from rate limiter service. Success: 1
2025-12-12T12:27:49.443846Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_queries.cpp:226: CreateQueryRequest: {content {
  type: STREAMING
  name: "simple"
  acl {
    visibility: PRIVATE
  }
  limits {
    execution_timeout {
    }
  }
  text: "\n            PRAGMA dq.MaxTasksPerStage=\"2\";\n\n            INSERT INTO myyds.`recovery_output`\n            SELECT STREAM\n                *\n            FROM myyds.`recovery_input`;"
  syntax: YQL_V1
}
execute_mode: RUN
idempotency_key: "323c4a81-6ad1-4103-8ed4-80b07dad8524"
} [root@builtin, **** (B6C6F477)] 
2025-12-12T12:27:49.444958Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.cpuPercent.count=0/10000 NOTIFY CHANGE
2025-12-12T12:27:49.447905Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.analyticsQuery.count=0/100 NOTIFY CHANGE
2025-12-12T12:27:49.451462Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.streamingQuery.count=0/100 NOTIFY CHANGE
2025-12-12T12:27:49.663333Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: CreateQueryRequest - CreateQueryResult: {query_id: "ptqudq7ue4bnna4fk100" } SUCCESS
2025-12-12T12:27:49.894422Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 23f17547-a6ae60e4-cfc06ca9-d86b14f93, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 68 bytes
2025-12-12T12:27:49.894485Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "23f17547-a6ae60e4-cfc06ca9-d86b14f93"
host: "ghrun-fhkyrtz6p4"
node_id: 2
}
2025-12-12T12:27:49.897530Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:463: Task (Query): ptqudq7ue4bnna4fk100 RetryRate: 0 RetryCounter: 0 At: 2025-12-12T12:27:49.525943Z
2025-12-12T12:27:50.008821Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {tasks { query_id { value: "ptqudq7ue4bnna4fk100" } job_id { value: "ptjudq7ue4bnmkisuis9" } generation: 1 streaming: true text: "\n            PRAGMA dq.MaxTasksPerStage=\"2\";\n\n            INSERT INTO myyds.`recovery_output`\n            SELECT STREAM\n                *\n            FROM myyds.`recovery_input`;" connection { content { name: "myyds" setting { data_streams { auth { none { } } endpoint: "localhost:21682" database: "local" } } acl { visibility: PRIVATE } } meta { id: "ptcudq7ue4mb10b2jjv4" created_by: "root@builtin" modified_by: "root@builtin" created_at { seconds: 1765542469 nanos: 96399000 } modified_at { seconds: 1765542469 nanos: 96399000 } revision: 1 } } user_token: "root@builtin" user_id: "root@builtin" query_type: STREAMING scope: "yandexcloud://my_folder" execute_mode: RUN state_load_mode: EMPTY status: STARTING sensor_labels { key: "cloud_id" value: "mock_cloud" } sensor_labels { key: "scope" value: "yandexcloud://my_folder" } query_name: "simple" deadline { seconds: 1765628869 nanos: 949193000 } disposition { fresh { } } result_limit: 20971520 execution_limit { } request_started_at { } resources { } query_syntax: YQL_V1 compute_connection { } result_ttl { seconds: 86400 } request_submitted_at { seconds: 1765542469 nanos: 443788000 } } } SUCCESS
2025-12-12T12:27:50.008862Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 23f17547-a6ae60e4-cfc06ca9-d86b14f93, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:27:50.010636Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 23f17547-a6ae60e4-cfc06ca9-d86b14f94, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 68 bytes
2025-12-12T12:27:50.010679Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "23f17547-a6ae60e4-cfc06ca9-d86b14f94"
host: "ghrun-fhkyrtz6p4"
node_id: 2
}
2025-12-12T12:27:50.010777Z :YQL_PRIVATE_PROXY DEBUG: rate_limiter_resources.cpp:78: PrivateCreateRateLimiterResource - QueryId: ptqudq7ue4bnna4fk100, Owner: 23f17547-a6ae60e4-cfc06ca9-d86b14f93, Request CP::CreateRateLimiterResource with size: 97 bytes
2025-12-12T12:27:50.010793Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudq7ue4bnna4fk100, Owner: 23f17547-a6ae60e4-cfc06ca9-d86b14f93, Request CP::PingTask with size: 128 bytes
2025-12-12T12:27:50.010797Z :YQ_CONTROL_PLANE_STORAGE TRACE: request_actor.h:57: CreateRateLimiterResourceRequest: {owner_id: "23f17547-a6ae60e4-cfc06ca9-d86b14f93"
query_id {
  value: "ptqudq7ue4bnna4fk100"
}
scope: "yandexcloud://my_folder"
tenant: "/compute"
} 
2025-12-12T12:27:50.010856Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "23f17547-a6ae60e4-cfc06ca9-d86b14f93"
query_id {
  value: "ptqudq7ue4bnna4fk100"
}
scope: "yandexcloud://my_folder"
started_at {
  seconds: 1765542470
  nanos: 9000000
}
deadline {
  seconds: 1765628869
  nanos: 949193000
}
tenant: "/compute"
}
2025-12-12T12:27:50.017930Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:27:50.017998Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 23f17547-a6ae60e4-cfc06ca9-d86b14f94, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:27:50.052827Z :YQ_CONTROL_PLANE_STORAGE DEBUG: rate_limiter_resources.cpp:74: CreateRateLimiterResourceRequest. Got response from database: SUCCESS
2025-12-12T12:27:50.052958Z :YQ_RATE_LIMITER DEBUG: schema.cpp:71: Run create rate limiter resource "mock_cloud/my_folder/ptqudq7ue4bnna4fk100" actor
2025-12-12T12:27:50.052979Z :YQ_RATE_LIMITER DEBUG: schema.cpp:113: Call create rate limiter resource "mock_cloud/my_folder/ptqudq7ue4bnna4fk100"
2025-12-12T12:27:50.054322Z :YQ_RATE_LIMITER DEBUG: schema.cpp:261: Trying to recursively create rate limiter resource "mock_cloud/my_folder"
2025-12-12T12:27:50.054348Z :YQ_RATE_LIMITER DEBUG: schema.cpp:113: Call create rate limiter resource "mock_cloud/my_folder"
2025-12-12T12:27:50.056901Z :YQ_RATE_LIMITER DEBUG: schema.cpp:244: Successfully created rate limiter resource "mock_cloud/my_folder"
2025-12-12T12:27:50.056925Z :YQ_RATE_LIMITER DEBUG: schema.cpp:113: Call create rate limiter resource "mock_cloud/my_folder/ptqudq7ue4bnna4fk100"
2025-12-12T12:27:50.058689Z :YQ_RATE_LIMITER DEBUG: schema.cpp:155: Successfully created rate limiter resource "mock_cloud/my_folder/ptqudq7ue4bnna4fk100"
2025-12-12T12:27:50.058712Z :YQ_RATE_LIMITER DEBUG: schema.cpp:122: Reply for create rate limiter resource "mock_cloud/my_folder/ptqudq7ue4bnna4fk100": 
2025-12-12T12:27:50.058752Z :YQ_CONTROL_PLANE_STORAGE DEBUG: rate_limiter_resources.cpp:180: Got create response from rate limiter service
2025-12-12T12:27:50.058786Z :YQL_PRIVATE_PROXY DEBUG: rate_limiter_resources.cpp:102: PrivateCreateRateLimiterResource - QueryId: ptqudq7ue4bnna4fk100, Owner: 23f17547-a6ae60e4-cfc06ca9-d86b14f93, Got CP::CreateRateLimiterResourceResponse
2025-12-12T12:27:50.263492Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {expired_at { seconds: 1765542490 nanos: 176000000 } } SUCCESS
2025-12-12T12:27:50.263530Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudq7ue4bnna4fk100, Owner: 23f17547-a6ae60e4-cfc06ca9-d86b14f93, Got CP::PingTaskResponse
2025-12-12T12:27:50.267801Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudq7ue4bnna4fk100, Owner: 23f17547-a6ae60e4-cfc06ca9-d86b14f93, Request CP::PingTask with size: 123 bytes
2025-12-12T12:27:50.267882Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "23f17547-a6ae60e4-cfc06ca9-d86b14f93"
query_id {
  value: "ptqudq7ue4bnna4fk100"
}
status: RUNNING
resources {
  rate_limiter: PREPARE
  compilation: PREPARE
}
scope: "yandexcloud://my_folder"
deadline {
  seconds: 1765628869
  nanos: 949193000
}
tenant: "/compute"
}
2025-12-12T12:27:50.282186Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {expired_at { seconds: 1765542490 nanos: 274000000 } } SUCCESS
2025-12-12T12:27:50.282265Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudq7ue4bnna4fk100, Owner: 23f17547-a6ae60e4-cfc06ca9-d86b14f93, Got CP::PingTaskResponse
2025-12-12T12:27:50.283173Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudq7ue4bnna4fk100, Owner: 23f17547-a6ae60e4-cfc06ca9-d86b14f93, Request CP::PingTask with size: 192 bytes
2025-12-12T12:27:50.283237Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "23f17547-a6ae60e4-cfc06ca9-d86b14f93"
query_id {
  value: "ptqudq7ue4bnna4fk100"
}
status: RUNNING
resources {
  rate_limiter: READY
  compilation: PREPARE
  rate_limiter_path: "local/RateLimiter_59343c87-a0fa-4d02-bbd7-bed27d35921a/rate_limiter"
}
scope: "yandexcloud://my_folder"
deadline {
  seconds: 1765628869
  nanos: 949193000
}
tenant: "/compute"
}
2025-12-12T12:27:50.301246Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {expired_at { seconds: 1765542490 nanos: 292000000 } } SUCCESS
2025-12-12T12:27:50.301324Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudq7ue4bnna4fk100, Owner: 23f17547-a6ae60e4-cfc06ca9-d86b14f93, Got CP::PingTaskResponse
2025-12-12T12:27:50.302593Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudq7ue4bnna4fk100, Owner: 23f17547-a6ae60e4-cfc06ca9-d86b14f93, Request CP::PingTask with size: 1912 bytes
2025-12-12T12:27:50.302664Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "23f17547-a6ae60e4-cfc06ca9-d86b14f93"
query_id {
  value: "ptqudq7ue4bnna4fk100"
}
ast: "(\n(let $1 (Configure! world (DataSource \'\"config\") \'\"DqEngine\" \'\"force\"))\n(let $2 (Configure! $1 (DataSource \'\"dq\" \'\"$all\") \'\"Attr\" \'\"maxtasksperstage\" \'\"2\"))\n(let $3 (DataSource \'\"pq\" \'\"myyds\"))\n(let $4 \'(\'(\'\"PartitionsCount\" \'\"2\")))\n(let $5 (StructType \'(\'\"Data\" (DataType \'String))))\n(let $6 (PqTopic \'\"myyds\" \'\"local\" \'\"recovery_input\" $4 \'() $5))\n(let $7 \'(\'\"Endpoint\" \'\"localhost:21682\"))\n(let $8 \'(\'\"SharedReading\" \'\"0\"))\n(let $9 \'(\'\"AddBearerToToken\" \'\"1\"))\n(let $10 \'($7 $8 \'(\'\"ReconnectPeriod\" \'\"\") \'(\'\"Format\" \'\"raw\") \'(\'\"ReadGroup\" \'\"ptcudq7ue4mb10b2jjv4\") $9))\n(let $11 (SecureParam \'\"cluster:default_myyds\"))\n(let $12 (DqPqTopicSource $2 $6 \'(\'\"Data\") $10 $11 \'\"\" $5 \'\"\"))\n(let $13 (DataSink \'\"pq\" \'\"myyds\"))\n(let $14 (PqTopic \'\"myyds\" \'\"local\" \'\"recovery_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"
plan: "{\"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}]}}"
scope: "yandexcloud://my_folder"
deadline {
  seconds: 1765628869
  nanos: 949193000
}
tenant: "/compute"
}
2025-12-12T12:27:50.313577Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {expired_at { seconds: 1765542490 nanos: 308000000 } } SUCCESS
2025-12-12T12:27:50.313618Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudq7ue4bnna4fk100, Owner: 23f17547-a6ae60e4-cfc06ca9-d86b14f93, Got CP::PingTaskResponse
2025-12-12T12:27:50.314632Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudq7ue4bnna4fk100, Owner: 23f17547-a6ae60e4-cfc06ca9-d86b14f93, Request CP::PingTask with size: 2391 bytes
2025-12-12T12:27:50.314731Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "23f17547-a6ae60e4-cfc06ca9-d86b14f93"
query_id {
  value: "ptqudq7ue4bnna4fk100"
}
dq_graph: "\022\206\006\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*\323\002Z\320\002\n\010PqSource\022\301\002\n4type.googleapis.com/NYql.NPq.NProto.TDqPqTopicSource\022\210\002\n\016recovery_input\022\024ptqudq7ue4bnna4fk100\032\017localhost:21682\"\027\n\025cluster:default_myyds*\005local0\002@\001b\004Dataj\025[\"DataType\";\"String\"]\222\001\024ptcudq7ue4mb10b2jjv4\232\001\003raw\242\001/[\"StructType\";[[\"Data\";[\"DataType\";\"String\"]]]]\262\001\002\022\000\272\001\026\n\010cloud_id\022\nmock_cloud\272\001 \n\005scope\022\027yandexcloud://my_folder\030\0012\211\001z\206\001\n\006PqSink\022|\n2type.googleapis.com/NYql.NPq.NProto.TDqPqTopicSink\022F\n\017recovery_output\022\017localhost:21682\032\027\n\025cluster:default_myyds\"\005local0\0018\002:\203\001\n*type.googleapis.com/Yql.DqsProto.TTaskMeta\022U\010\341\234\014\022A\022(88a034dc314301cb1522a933e690a4c49a7591e8\032\023dq_vanilla_job.lite \002\"\014\n\002pq\022\006\n\004\010\002\030\002H\341\234\014RClocal/RateLimiter_59343c87-a0fa-4d02-bbd7-bed27d35921a/rate_limiterZ)mock_cloud/my_folder/ptqudq7ue4bnna4fk100`\200\200\200\200 \230\001\000\300\001\001\022\210\006\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*\323\002Z\320\002\n\010PqSource\022\301\002\n4type.googleapis.com/NYql.NPq.NProto.TDqPqTopicSource\022\210\002\n\016recovery_input\022\024ptqudq7ue4bnna4fk100\032\017localhost:21682\"\027\n\025cluster:default_myyds*\005local0\002@\001b\004Dataj\025[\"DataType\";\"String\"]\222\001\024ptcudq7ue4mb10b2jjv4\232\001\003raw\242\001/[\"StructType\";[[\"Data\";[\"DataType\";\"String\"]]]]\262\001\002\022\000\272\001\026\n\010cloud_id\022\nmock_cloud\272\001 \n\005scope\022\027yandexcloud://my_folder\030\0012\211\001z\206\001\n\006PqSink\022|\n2type.googleapis.com/NYql.NPq.NProto.TDqPqTopicSink\022F\n\017recovery_output\022\017localhost:21682\032\027\n\025cluster:default_myyds\"\005local0\0018\002:\205\001\n*type.googleapis.com/Yql.DqsProto.TTaskMeta\022W\010\341\234\014\022A\022(88a034dc314301cb1522a933e690a4c49a7591e8\032\023dq_vanilla_job.lite \002\"\016\n\002pq\022\010\n\006\010\002\020\001\030\002H\341\234\014RClocal/RateLimiter_59343c87-a0fa-4d02-bbd7-bed27d35921a/rate_limiterZ)mock_cloud/my_folder/ptqudq7ue4bnna4fk100`\200\200\200\200 \230\001\000\300\001\0012qptqudq7ue4bnna4fk100#ptrudq7ue3qfaq9r3qtf#yandexcloud://my_folder#23f17547-a6ae60e4-cfc06ca9-d86b14f93#mock_cloud:\027\n\016FallbackPolicy\022\005never:\024\n\017_LiteralTimeout\022\0010:\022\n\r_TableTimeout\022\0010:\027\n\022_RowsLimitPerWrite\022\0010:\027\n\022EnableComputeActor\022\0011:\016\n\014WorkerFilter:\031\n\020ComputeActorType\022\005async:\031\n\016WatermarksMode\022\007disable:\037\n\027WatermarksGranularityMs\022\0041000:$\n\034WatermarksLateArrivalDelayMs\022\0045000:\027\n\022EnableChannelStats\022\0011:\020\n\013ExportStats\022\0011B\'\n\025cluster:default_myyds\022\016{\"no_auth\":\"\"}b\202\002\010\341\234\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/"
scope: "yandexcloud://my_folder"
deadline {
  seconds: 1765628869
  nanos: 949193000
}
tenant: "/compute"
}
2025-12-12T12:27:50.327632Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {expired_at { seconds: 1765542490 nanos: 319000000 } } SUCCESS
2025-12-12T12:27:50.327709Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudq7ue4bnna4fk100, Owner: 23f17547-a6ae60e4-cfc06ca9-d86b14f93, Got CP::PingTaskResponse
2025-12-12T12:27:50.329033Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudq7ue4bnna4fk100, Owner: 23f17547-a6ae60e4-cfc06ca9-d86b14f93, Request CP::PingTask with size: 284 bytes
2025-12-12T12:27:50.329120Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "23f17547-a6ae60e4-cfc06ca9-d86b14f93"
query_id {
  value: "ptqudq7ue4bnna4fk100"
}
status: RUNNING
resources {
  rate_limiter: READY
  compilation: READY
  topic_consumers_state: PREPARE
  rate_limiter_path: "local/RateLimiter_59343c87-a0fa-4d02-bbd7-bed27d35921a/rate_limiter"
  topic_consumers {
    database: "local"
    topic_path: "recovery_input"
    consumer_name: "ptqudq7ue4bnna4fk100"
    cluster_endpoint: "localhost:21682"
    token_name: "cluster:default_myyds"
    add_bearer_to_token: true
  }
}
scope: "yandexcloud://my_folder"
deadline {
  seconds: 1765628869
  nanos: 949193000
}
tenant: "/compute"
}
2025-12-12T12:27:50.330091Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 8cd48908-114eaca5-40f0faab-6c6f9e784, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 68 bytes
2025-12-12T12:27:50.330142Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "8cd48908-114eaca5-40f0faab-6c6f9e784"
host: "ghrun-fhkyrtz6p4"
node_id: 1
}
2025-12-12T12:27:50.336706Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:27:50.336757Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 8cd48908-114eaca5-40f0faab-6c6f9e784, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:27:50.361041Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {expired_at { seconds: 1765542490 nanos: 346000000 } } SUCCESS
2025-12-12T12:27:50.361091Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudq7ue4bnna4fk100, Owner: 23f17547-a6ae60e4-cfc06ca9-d86b14f93, Got CP::PingTaskResponse
2025-12-12T12:27:50.376006Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudq7ue4bnna4fk100, Owner: 23f17547-a6ae60e4-cfc06ca9-d86b14f93, Request CP::PingTask with size: 284 bytes
2025-12-12T12:27:50.376096Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "23f17547-a6ae60e4-cfc06ca9-d86b14f93"
query_id {
  value: "ptqudq7ue4bnna4fk100"
}
status: RUNNING
resources {
  rate_limiter: READY
  compilation: READY
  topic_consumers_state: READY
  rate_limiter_path: "local/RateLimiter_59343c87-a0fa-4d02-bbd7-bed27d35921a/rate_limiter"
  topic_consumers {
    database: "local"
    topic_path: "recovery_input"
    consumer_name: "ptqudq7ue4bnna4fk100"
    cluster_endpoint: "localhost:21682"
    token_name: "cluster:default_myyds"
    add_bearer_to_token: true
  }
}
scope: "yandexcloud://my_folder"
deadline {
  seconds: 1765628869
  nanos: 949193000
}
tenant: "/compute"
}
2025-12-12T12:27:50.388446Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582947155240276175:2107]
2025-12-12T12:27:50.388467Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:50.388479Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582947155240276119:2068]
2025-12-12T12:27:50.388485Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582947155240276119:2068]
2025-12-12T12:27:50.388488Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582947155240276119:2068]
2025-12-12T12:27:50.388501Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:50.388644Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {expired_at { seconds: 1765542490 nanos: 382000000 } } SUCCESS
2025-12-12T12:27:50.388674Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudq7ue4bnna4fk100, Owner: 23f17547-a6ae60e4-cfc06ca9-d86b14f93, Got CP::PingTaskResponse
2025-12-12T12:27:50.883307Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudq7ue4bnna4fk100, Owner: 23f17547-a6ae60e4-cfc06ca9-d86b14f93, Request CP::PingTask with size: 867 bytes
2025-12-12T12:27:50.883465Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "23f17547-a6ae60e4-cfc06ca9-d86b14f93"
query_id {
  value: "ptqudq7ue4bnna4fk100"
}
result_id {
  value: "ptrudq7ue3qfaq9r3qtf"
}
status: RUNNING
statistics: "{\"Graph=0\":{\"Actor\":{\"ActorCreateTimeUs\":{\"sum\":\"393us\",\"count\":1,\"avg\":\"393us\",\"max\":\"393us\",\"min\":\"393us\"},\"ClusterName=\":{\"CreateFailTimeUs\":{\"sum\":\"0.50s\",\"count\":1,\"avg\":\"0.50s\",\"max\":\"0.50s\",\"min\":\"0.50s\"}}},\"AllocateWorkersUs\":{\"sum\":\"0.50s\",\"count\":1,\"avg\":\"0.50s\",\"max\":\"0.50s\",\"min\":\"0.50s\"},\"Retry\":{\"sum\":5,\"count\":5,\"avg\":1,\"max\":1,\"min\":1},\"TaskRunner\":{\"Stage=Total\":{\"sum\":0,\"count\":0,\"avg\":0,\"max\":0,\"min\":0}}}}"
resign_query: true
transient_issues {
  message: "Disconnected from worker: `Id:d78f682c-486d5c39-64f74a4-900b51bb,ghrun-fhkyrtz6p4,NodeId:1,\', reason: Undelivered"
  issue_code: 6001
  severity: 1
}
status_code: UNAVAILABLE
resources {
  rate_limiter: READY
  compilation: READY
  topic_consumers_state: READY
  rate_limiter_path: "local/RateLimiter_59343c87-a0fa-4d02-bbd7-bed27d35921a/rate_limiter"
  topic_consumers {
    database: "local"
    topic_path: "recovery_input"
    consumer_name: "ptqudq7ue4bnna4fk100"
    cluster_endpoint: "localhost:21682"
    token_name: "cluster:default_myyds"
    add_bearer_to_token: true
  }
}
scope: "yandexcloud://my_folder"
deadline {
  seconds: 1765628869
  nanos: 949193000
}
tenant: "/compute"
}
2025-12-12T12:27:50.892101Z :YQ_CONTROL_PLANE_STORAGE DEBUG: task_ping.cpp:427: PingTaskRequest (resign):  UNAVAILABLE 1 2025-12-12T12:27:50.892063Z 0.000000s
2025-12-12T12:27:50.899243Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 23f17547-a6ae60e4-cfc06ca9-d86b14f95, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 68 bytes
2025-12-12T12:27:50.899311Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "23f17547-a6ae60e4-cfc06ca9-d86b14f95"
host: "ghrun-fhkyrtz6p4"
node_id: 2
}
2025-12-12T12:27:50.908943Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:27:50.909010Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 23f17547-a6ae60e4-cfc06ca9-d86b14f95, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:27:50.995454Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {expired_at { seconds: 1765542470 nanos: 892000000 } } SUCCESS
2025-12-12T12:27:50.995489Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudq7ue4bnna4fk100, Owner: 23f17547-a6ae60e4-cfc06ca9-d86b14f93, Got CP::PingTaskResponse
2025-12-12T12:27:51.331563Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 8cd48908-114eaca5-40f0faab-6c6f9e785, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 68 bytes
2025-12-12T12:27:51.331622Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "8cd48908-114eaca5-40f0faab-6c6f9e785"
host: "ghrun-fhkyrtz6p4"
node_id: 1
}
2025-12-12T12:27:51.342564Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:463: Task (Query): ptqudq7ue4bnna4fk100 RetryRate: 0.9996837687 RetryCounter: 1 At: 2025-12-12T12:27:50.892063Z
2025-12-12T12:27:51.381914Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {tasks { query_id { value: "ptqudq7ue4bnna4fk100" } job_id { value: "ptjudq7ue4bnmkisuis9" } generation: 2 streaming: true dq_graph: "\022\206\006\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*\323\002Z\320\002\n\010PqSource\022\301\002\n4type.googleapis.com/NYql.NPq.NProto.TDqPqTopicSource\022\210\002\n\016recovery_input\022\024ptqudq7ue4bnna4fk100\032\017localhost:21682\"\027\n\025cluster:default_myyds*\005local0\002@\001b\004Dataj\025[\"DataType\";\"String\"]\222\001\024ptcudq7ue4mb10b2jjv4\232\001\003raw\242\001/[\"StructType\";[[\"Data\";[\"DataType\";\"String\"]]]]\262\001\002\022\000\272\001\026\n\010cloud_id\022\nmock_cloud\272\001 \n\005scope\022\027yandexcloud://my_folder\030\0012\211\001z\206\001\n\006PqSink\022|\n2type.googleapis.com/NYql.NPq.NProto.TDqPqTopicSink\022F\n\017recovery_output\022\017localhost:21682\032\027\n\025cluster:default_myyds\"\005local0\0018\002:\203\001\n*type.googleapis.com/Yql.DqsProto.TTaskMeta\022U\010\341\234\014\022A\022(88a034dc314301cb1522a933e690a4c49a7591e8\032\023dq_vanilla_job.lite \002\"\014\n\002pq\022\006\n\004\010\002\030\002H\341\234\014RClocal/RateLimiter_59343c87-a0fa-4d02-bbd7-bed27d35921a/rate_limiterZ)mock_cloud/my_folder/ptqudq7ue4bnna4fk100`\200\200\200\200 \230\001\000\300\001\001\022\210\006\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*\323\002Z\320\002\n\010PqSource\022\301\002\n4type.googleapis.com/NYql.NPq.NProto.TDqPqTopicSource\022\210\002\n\016recovery_input\022\024ptqudq7ue4bnna4fk100\032\017localhost:21682\"\027\n\025cluster:default_myyds*\005local0\002@\001b\004Dataj\025[\"DataType\";\"String\"]\222\001\024ptcudq7ue4mb10b2jjv4\232\001\003raw\242\001/[\"StructType\";[[\"Data\";[\"DataType\";\"String\"]]]]\262\001\002\022\000\272\001\026\n\010cloud_id\022\nmock_cloud\272\001 \n\005scope\022\027yandexcloud://my_folder\030\0012\211\001z\206\001\n\006PqSink\022|\n2type.googleapis.com/NYql.NPq.NProto.TDqPqTopicSink\022F\n\017recovery_output\022\017localhost:21682\032\027\n\025cluster:default_myyds\"\005local0\0018\002:\205\001\n*type.googleapis.com/Yql.DqsProto.TTaskMeta\022W\010\341\234\014\022A\022(88a034dc314301cb1522a933e690a4c49a7591e8\032\023dq_vanilla_job.lite \002\"\016\n\002pq\022\010\n\006\010\002\020\001\030\002H\341\234\014RClocal/RateLimiter_59343c87-a0fa-4d02-bbd7-bed27d35921a/rate_limiterZ)mock_cloud/my_folder/ptqudq7ue4bnna4fk100`\200\200\200\200 \230\001\000\300\001\0012qptqudq7ue4bnna4fk100#ptrudq7ue3qfaq9r3qtf#yandexcloud://my_folder#23f17547-a6ae60e4-cfc06ca9-d86b14f93#mock_cloud:\027\n\016FallbackPolicy\022\005never:\024\n\017_LiteralTimeout\022\0010:\022\n\r_TableTimeout\022\0010:\027\n\022_RowsLimitPerWrite\022\0010:\027\n\022EnableComputeActor\022\0011:\016\n\014WorkerFilter:\031\n\020ComputeActorType\022\005async:\031\n\016WatermarksMode\022\007disable:\037\n\027WatermarksGranularityMs\022\0041000:$\n\034WatermarksLateArrivalDelayMs\022\0045000:\027\n\022EnableChannelStats\022\0011:\020\n\013ExportStats\022\0011B\'\n\025cluster:default_myyds\022\016{\"no_auth\":\"\"}b\202\002\010\341\234\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/" text: "\n            PRAGMA dq.MaxTasksPerStage=\"2\";\n\n            INSERT INTO myyds.`recovery_output`\n            SELECT STREAM\n                *\n            FROM myyds.`recovery_input`;" connection { content { name: "myyds" setting { data_streams { auth { none { } } endpoint: "localhost:21682" dat...} SUCCESS
2025-12-12T12:27:51.382029Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 8cd48908-114eaca5-40f0faab-6c6f9e785, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:27:51.387164Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:665: Coordinator: Change global state to Started (by timeout)
2025-12-12T12:27:51.389403Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 8cd48908-114eaca5-40f0faab-6c6f9e786, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 68 bytes
2025-12-12T12:27:51.389422Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudq7ue4bnna4fk100, Owner: 8cd48908-114eaca5-40f0faab-6c6f9e785, Request CP::PingTask with size: 282 bytes
2025-12-12T12:27:51.389463Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "8cd48908-114eaca5-40f0faab-6c6f9e786"
host: "ghrun-fhkyrtz6p4"
node_id: 1
}
2025-12-12T12:27:51.389564Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "8cd48908-114eaca5-40f0faab-6c6f9e785"
query_id {
  value: "ptqudq7ue4bnna4fk100"
}
resources {
  rate_limiter: READY
  compilation: READY
  topic_consumers_state: READY
  rate_limiter_path: "local/RateLimiter_59343c87-a0fa-4d02-bbd7-bed27d35921a/rate_limiter"
  topic_consumers {
    database: "local"
    topic_path: "recovery_input"
    consumer_name: "ptqudq7ue4bnna4fk100"
    cluster_endpoint: "localhost:21682"
    token_name: "cluster:default_myyds"
    add_bearer_to_token: true
  }
}
scope: "yandexcloud://my_folder"
deadline {
  seconds: 1765628871
  nanos: 358269000
}
tenant: "/compute"
}
2025-12-12T12:27:51.395469Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:27:51.395531Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 8cd48908-114eaca5-40f0faab-6c6f9e786, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:27:51.411480Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {expired_at { seconds: 1765542491 nanos: 399000000 } } SUCCESS
2025-12-12T12:27:51.411589Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudq7ue4bnna4fk100, Owner: 8cd48908-114eaca5-40f0faab-6c6f9e785, Got CP::PingTaskResponse
2025-12-12T12:27:51.725844Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudq7ue4bnna4fk100, Owner: 8cd48908-114eaca5-40f0faab-6c6f9e785, Request CP::PingTask with size: 122 bytes
2025-12-12T12:27:51.725952Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "8cd48908-114eaca5-40f0faab-6c6f9e785"
query_id {
  value: "ptqudq7ue4bnna4fk100"
}
state_load_mode: FROM_LAST_CHECKPOINT
disposition {
  from_last_checkpoint {
  }
}
scope: "yandexcloud://my_folder"
deadline {
  seconds: 1765628871
  nanos: 358269000
}
tenant: "/compute"
}
2025-12-12T12:27:51.741889Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {expired_at { seconds: 1765542491 nanos: 732000000 } } SUCCESS
2025-12-12T12:27:51.742028Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudq7ue4bnna4fk100, Owner: 8cd48908-114eaca5-40f0faab-6c6f9e785, Got CP::PingTaskResponse
2025-12-12T12:27:51.903493Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 23f17547-a6ae60e4-cfc06ca9-d86b14f96, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 68 bytes
2025-12-12T12:27:51.903541Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "23f17547-a6ae60e4-cfc06ca9-d86b14f96"
host: "ghrun-fhkyrtz6p4"
node_id: 2
}
2025-12-12T12:27:51.911238Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:27:51.911306Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 23f17547-a6ae60e4-cfc06ca9-d86b14f96, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:27:52.329089Z :YQ_CONTROL_PLANE_STORAGE TRACE: nodes_health_check.cpp:38: NodesHealthCheckRequest: {tenant: "/compute"
node {
  node_id: 1
  instance_id: "d78f682c-486d5c39-64f74a4-900b51bb"
  hostname: "ghrun-fhkyrtz6p4"
  active_workers: 2
  memory_allocated: 17179869184
  interconnect_port: 18549
  node_address: "127.0.1.1"
}
}
2025-12-12T12:27:52.331132Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 8cd48908-114eaca5-40f0faab-6c6f9e787, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 68 bytes
2025-12-12T12:27:52.331177Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "8cd48908-114eaca5-40f0faab-6c6f9e787"
host: "ghrun-fhkyrtz6p4"
node_id: 1
}
2025-12-12T12:27:52.335393Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:27:52.335430Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 8cd48908-114eaca5-40f0faab-6c6f9e787, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:27:52.338656Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: NodesHealthCheckRequest - NodesHealthCheckResult: {nodes { node_id: 1 instance_id: "d78f682c-486d5c39-64f74a4-900b51bb" hostname: "ghrun-fhkyrtz6p4" active_workers: 2 memory_allocated: 17179869184 node_address: "127.0.1.1" } nodes { node_id: 2 instance_id: "9d9f24b1-434edf1f-bb4262b3-181f5524" hostname: "ghrun-fhkyrtz6p4" interconnect_port: 14648 node_address: "127.0.1.1" } } SUCCESS
2025-12-12T12:27:52.389353Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582947155240276175:2107]
2025-12-12T12:27:52.389375Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:52.389382Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582947155240276119:2068]
2025-12-12T12:27:52.389386Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582947155240276119:2068]
2025-12-12T12:27:52.389389Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582947155240276119:2068]
2025-12-12T12:27:52.389400Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:52.400082Z :FQ_CONTROL_PLANE_CONFIG TRACE: control_plane_config.cpp:192: LOADED TenantInfo: State NOT changed
2025-12-12T12:27:52.420255Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudq7ue4bnna4fk100, Owner: 8cd48908-114eaca5-40f0faab-6c6f9e785, Request CP::PingTask with size: 442 bytes
2025-12-12T12:27:52.420352Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "8cd48908-114eaca5-40f0faab-6c6f9e785"
query_id {
  value: "ptqudq7ue4bnna4fk100"
}
statistics: "{\"Graph=0\":{\"TaskRunner\":{\"Stage=200289\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":2,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":2,\"count\":1,\"avg\":2,\"max\":2,\"min\":2}},\"Stage=Total\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":2,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":2,\"count\":1,\"avg\":2,\"max\":2,\"min\":2}}}}}"
scope: "yandexcloud://my_folder"
deadline {
  seconds: 1765628871
  nanos: 358269000
}
tenant: "/compute"
}
2025-12-12T12:27:52.431039Z :TICKET_PARSER DEBUG: ticket_parser_impl.h:1875: Ticket **** (B6C6F477) (ipv6:[::1]:36944) has now valid token of root@builtin
2025-12-12T12:27:52.431130Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:1061: ControlQueryRequest: query_id: "ptqudq7ue4bnna4fk100"
action: ABORT
2025-12-12T12:27:52.431173Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:305: Resolve folder bootstrap. Folder id: my_folder Actor id: [1:7582947181010080114:2264]
2025-12-12T12:27:52.431191Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:367: Cloud id: mock_cloud Folder id: my_folder
2025-12-12T12:27:52.431209Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:91: Get quotas bootstrap. Cloud id: mock_cloud Actor id: [1:7582947181010080115:2265]
2025-12-12T12:27:52.431226Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.analyticsQuery.count IS STALE, Refreshing ...
2025-12-12T12:27:52.431236Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.cpuPercent.count IS STALE, Refreshing ...
2025-12-12T12:27:52.431239Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.streamingQuery.count IS STALE, Refreshing ...
2025-12-12T12:27:52.431304Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.cpuPercent.count=0/10000 REFRESHED
2025-12-12T12:27:52.435307Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {expired_at { seconds: 1765542492 nanos: 426000000 } } SUCCESS
2025-12-12T12:27:52.435343Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudq7ue4bnna4fk100, Owner: 8cd48908-114eaca5-40f0faab-6c6f9e785, Got CP::PingTaskResponse
2025-12-12T12:27:52.442000Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.cpuPercent.count=0/10000 NOTIFY CHANGE
2025-12-12T12:27:52.464881Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.analyticsQuery.count=0/100 REFRESHED
2025-12-12T12:27:52.464906Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.streamingQuery.count=1/100 REFRESHED
2025-12-12T12:27:52.464923Z :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=1/100} SEND QUOTAS
2025-12-12T12:27:52.464946Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:103: Cloud id: mock_cloud Quota count: 8
2025-12-12T12:27:52.464980Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:1061: ControlQueryRequest: query_id: "ptqudq7ue4bnna4fk100"
action: ABORT
2025-12-12T12:27:52.465049Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:169: Resolve subject type bootstrap. Token: **** (B6C6F477) Actor id: [1:7582947181010080120:2270]
2025-12-12T12:27:52.465073Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:230: Subject Type: federated_account Token: **** (B6C6F477)
2025-12-12T12:27:52.465105Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:1061: ControlQueryRequest: query_id: "ptqudq7ue4bnna4fk100"
action: ABORT
2025-12-12T12:27:52.465155Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:63: Request actor. Actor id: [1:7582947181010080121:2271]
2025-12-12T12:27:52.465208Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_queries.cpp:1342: ControlQueryRequest: {query_id: "ptqudq7ue4bnna4fk100"
action: ABORT
} [root@builtin, **** (B6C6F477)] 
2025-12-12T12:27:52.470818Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.streamingQuery.count=1/100 NOTIFY CHANGE
2025-12-12T12:27:52.470837Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.analyticsQuery.count=0/100 NOTIFY CHANGE
2025-12-12T12:27:52.664585Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: ControlQueryRequest - ControlQueryRequest: {} SUCCESS
2025-12-12T12:27:52.667317Z :TICKET_PARSER DEBUG: ticket_parser_impl.h:1875: Ticket **** (B6C6F477) (ipv6:[::1]:36944) has now valid token of root@builtin
2025-12-12T12:27:52.667421Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudq7ue4bnna4fk100"
2025-12-12T12:27:52.667466Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:305: Resolve folder bootstrap. Folder id: my_folder Actor id: [1:7582947181010080125:2274]
2025-12-12T12:27:52.667489Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:367: Cloud id: mock_cloud Folder id: my_folder
2025-12-12T12:27:52.667506Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:91: Get quotas bootstrap. Cloud id: mock_cloud Actor id: [1:7582947181010080126:2275]
2025-12-12T12:27:52.667529Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.analyticsQuery.count IS STALE, Refreshing ...
2025-12-12T12:27:52.667538Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.cpuPercent.count IS STALE, Refreshing ...
2025-12-12T12:27:52.667544Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.streamingQuery.count IS STALE, Refreshing ...
2025-12-12T12:27:52.667557Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.cpuPercent.count=0/10000 REFRESHED
2025-12-12T12:27:52.671466Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.analyticsQuery.count=0/100 REFRESHED
2025-12-12T12:27:52.671493Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.streamingQuery.count=1/100 REFRESHED
2025-12-12T12:27:52.671515Z :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=1/100} SEND QUOTAS
2025-12-12T12:27:52.671531Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:103: Cloud id: mock_cloud Quota count: 8
2025-12-12T12:27:52.671565Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudq7ue4bnna4fk100"
2025-12-12T12:27:52.671626Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:169: Resolve subject type bootstrap. Token: **** (B6C6F477) Actor id: [1:7582947181010080131:2280]
2025-12-12T12:27:52.671649Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:230: Subject Type: federated_account Token: **** (B6C6F477)
2025-12-12T12:27:52.671669Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudq7ue4bnna4fk100"
2025-12-12T12:27:52.671685Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:63: Request actor. Actor id: [1:7582947181010080132:2281]
2025-12-12T12:27:52.671724Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_queries.cpp:641: DescribeQueryRequest: {query_id: "ptqudq7ue4bnna4fk100"
} [root@builtin, **** (B6C6F477)] 
2025-12-12T12:27:52.674947Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.cpuPercent.count=0/10000 NOTIFY CHANGE
2025-12-12T12:27:52.688246Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.streamingQuery.count=1/100 NOTIFY CHANGE
2025-12-12T12:27:52.688412Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.analyticsQuery.count=0/100 NOTIFY CHANGE
2025-12-12T12:27:52.713110Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: DescribeQueryRequest - DescribeQueryResult: {query { meta { common { id: "ptqudq7ue4bnna4fk100" created_by: "root@builtin" modified_by: "root@builtin" created_at { seconds: 1765542469 nanos: 443788000 } modified_at { seconds: 1765542472 nanos: 574356000 } revision: 2 } started_at { seconds: 1765542470 nanos: 9000000 } execute_mode: RUN status: ABORTING_BY_USER last_job_query_revision: 1 last_job_id: "ptjudq7ue4bnmkisuis9-ptqudq7ue4bnna4fk100" started_by: "root@builtin" aborted_by: "root@builtin" has_saved_checkpoints: true submitted_at { seconds: 1765542469 nanos: 443788000 } } content { type: STREAMING name: "simple" acl { visibility: PRIVATE } limits { execution_timeout { } } text: "\n            PRAGMA dq.MaxTasksPerStage=\"2\";\n\n            INSERT INTO myyds.`recovery_output`\n            SELECT STREAM\n                *\n            FROM myyds.`recovery_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}]}}" } transient_issue { message: "Disconnected from worker: `Id:d78f682c-486d5c39-64f74a4-900b51bb,ghrun-fhkyrtz6p4,NodeId:1,\', reason: Undelivered" issue_code: 6001 severity: 1 } transient_issue { message: "Query failed with code UNAVAILABLE and will be restarted (RetryCount: 1) at 2025-12-12T12:27:50.892062Z" severity: 1 } statistics { json: "{\"Graph=0\":{\"Tasks\":{\"sum\":2,\"count\":1,\"avg\":2,\"max\":2,\"min\":2},\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":2,\"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\" \'\"2\"))\n(let $3 (DataSource \'\"pq\" \'\"myyds\"))\n(let $4 \'(\'(\'\"PartitionsCount\" \'\"2\")))\n(let $5 (StructType \'(\'\"Data\" (DataType \'String))))\n(let $6 (PqTopic \'\"myyds\" \'\"local\" \'\"recovery_input\" $4 \'() $5))\n(let $7 \'(\'\"Endpoint\" \'\"localhost:21682\"))\n(let $8 \'(\'\"SharedReading\" \'\"0\"))\n(let $9 \'(\'\"AddBearerToToken\" \'\"1\"))\n(let $10 \'($7 $8 \'(\'\"ReconnectPeriod\" \'\"\") \'(\'\"Format\" \'\"raw\") \'(\'\"ReadGroup\" \'\"ptcudq7ue4mb10b2jjv4\") $9))\n(let $11 (SecureParam \'\"cluster:default_myyds\"))\n(let $12 (DqPqTopicSource $2 $6 \'(\'\"Data\") $10 $11 \'\"\" $5 \'\"\"))\n(let $13 (DataSink \'\"pq\" \'\"myyds\"))\n(let $14 (PqTopic \'\"myyds\" \'\"local\" \'\"recovery_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:27:52.894127Z :YQ_CONTROL_PLANE_STORAGE TRACE: nodes_health_check.cpp:38: NodesHealthCheckRequest: {tenant: "/compute"
node {
  node_id: 2
  instance_id: "9d9f24b1-434edf1f-bb4262b3-181f5524"
  hostname: "ghrun-fhkyrtz6p4"
  interconnect_port: 14648
  node_address: "127.0.1.1"
}
}
2025-12-12T12:27:52.899855Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 23f17547-a6ae60e4-cfc06ca9-d86b14f97, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 68 bytes
2025-12-12T12:27:52.899902Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "23f17547-a6ae60e4-cfc06ca9-d86b14f97"
host: "ghrun-fhkyrtz6p4"
node_id: 2
}
2025-12-12T12:27:52.906997Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:27:52.907075Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 23f17547-a6ae60e4-cfc06ca9-d86b14f97, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:27:52.913359Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: NodesHealthCheckRequest - NodesHealthCheckResult: {nodes { node_id: 2 instance_id: "9d9f24b1-434edf1f-bb4262b3-181f5524" hostname: "ghrun-fhkyrtz6p4" node_address: "127.0.1.1" } nodes { node_id: 1 instance_id: "d78f682c-486d5c39-64f74a4-900b51bb" hostname: "ghrun-fhkyrtz6p4" active_workers: 2 memory_allocated: 17179869184 interconnect_port: 18549 node_address: "127.0.1.1" } } SUCCESS
2025-12-12T12:27:53.216172Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudq7ue4bnna4fk100"
2025-12-12T12:27:53.216210Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:305: Resolve folder bootstrap. Folder id: my_folder Actor id: [1:7582947185305047438:2290]
2025-12-12T12:27:53.216232Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:367: Cloud id: mock_cloud Folder id: my_folder
2025-12-12T12:27:53.216243Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:91: Get quotas bootstrap. Cloud id: mock_cloud Actor id: [1:7582947185305047439:2291]
2025-12-12T12:27:53.216256Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.analyticsQuery.count IS STALE, Refreshing ...
2025-12-12T12:27:53.216262Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.cpuPercent.count IS STALE, Refreshing ...
2025-12-12T12:27:53.216264Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.streamingQuery.count IS STALE, Refreshing ...
2025-12-12T12:27:53.216318Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.cpuPercent.count=0/10000 REFRESHED
2025-12-12T12:27:53.227972Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.analyticsQuery.count=0/100 REFRESHED
2025-12-12T12:27:53.228000Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.streamingQuery.count=1/100 REFRESHED
2025-12-12T12:27:53.228019Z :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=1/100} SEND QUOTAS
2025-12-12T12:27:53.228048Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.cpuPercent.count=0/10000 NOTIFY CHANGE
2025-12-12T12:27:53.228053Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:103: Cloud id: mock_cloud Quota count: 8
2025-12-12T12:27:53.228076Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudq7ue4bnna4fk100"
2025-12-12T12:27:53.228127Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:169: Resolve subject type bootstrap. Token: **** (B6C6F477) Actor id: [1:7582947185305047444:2296]
2025-12-12T12:27:53.228153Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:230: Subject Type: federated_account Token: **** (B6C6F477)
2025-12-12T12:27:53.228168Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudq7ue4bnna4fk100"
2025-12-12T12:27:53.228189Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:63: Request actor. Actor id: [1:7582947185305047445:2297]
2025-12-12T12:27:53.228222Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_queries.cpp:641: DescribeQueryRequest: {query_id: "ptqudq7ue4bnna4fk100"
} [root@builtin, **** (B6C6F477)] 
2025-12-12T12:27:53.230160Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: DescribeQueryRequest - DescribeQueryResult: {query { meta { common { id: "ptqudq7ue4bnna4fk100" created_by: "root@builtin" modified_by: "root@builtin" created_at { seconds: 1765542469 nanos: 443788000 } modified_at { seconds: 1765542472 nanos: 574356000 } revision: 2 } started_at { seconds: 1765542470 nanos: 9000000 } execute_mode: RUN status: ABORTING_BY_USER last_job_query_revision: 1 last_job_id: "ptjudq7ue4bnmkisuis9-ptqudq7ue4bnna4fk100" started_by: "root@builtin" aborted_by: "root@builtin" has_saved_checkpoints: true submitted_at { seconds: 1765542469 nanos: 443788000 } } content { type: STREAMING name: "simple" acl { visibility: PRIVATE } limits { execution_timeout { } } text: "\n            PRAGMA dq.MaxTasksPerStage=\"2\";\n\n            INSERT INTO myyds.`recovery_output`\n            SELECT STREAM\n                *\n            FROM myyds.`recovery_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}]}}" } transient_issue { message: "Disconnected from worker: `Id:d78f682c-486d5c39-64f74a4-900b51bb,ghrun-fhkyrtz6p4,NodeId:1,\', reason: Undelivered" issue_code: 6001 severity: 1 } transient_issue { message: "Query failed with code UNAVAILABLE and will be restarted (RetryCount: 1) at 2025-12-12T12:27:50.892062Z" severity: 1 } statistics { json: "{\"Graph=0\":{\"Tasks\":{\"sum\":2,\"count\":1,\"avg\":2,\"max\":2,\"min\":2},\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":2,\"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\" \'\"2\"))\n(let $3 (DataSource \'\"pq\" \'\"myyds\"))\n(let $4 \'(\'(\'\"PartitionsCount\" \'\"2\")))\n(let $5 (StructType \'(\'\"Data\" (DataType \'String))))\n(let $6 (PqTopic \'\"myyds\" \'\"local\" \'\"recovery_input\" $4 \'() $5))\n(let $7 \'(\'\"Endpoint\" \'\"localhost:21682\"))\n(let $8 \'(\'\"SharedReading\" \'\"0\"))\n(let $9 \'(\'\"AddBearerToToken\" \'\"1\"))\n(let $10 \'($7 $8 \'(\'\"ReconnectPeriod\" \'\"\") \'(\'\"Format\" \'\"raw\") \'(\'\"ReadGroup\" \'\"ptcudq7ue4mb10b2jjv4\") $9))\n(let $11 (SecureParam \'\"cluster:default_myyds\"))\n(let $12 (DqPqTopicSource $2 $6 \'(\'\"Data\") $10 $11 \'\"\" $5 \'\"\"))\n(let $13 (DataSink \'\"pq\" \'\"myyds\"))\n(let $14 (PqTopic \'\"myyds\" \'\"local\" \'\"recovery_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:27:53.233347Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.streamingQuery.count=1/100 NOTIFY CHANGE
2025-12-12T12:27:53.233392Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.analyticsQuery.count=0/100 NOTIFY CHANGE
2025-12-12T12:27:53.331694Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 8cd48908-114eaca5-40f0faab-6c6f9e788, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 68 bytes
2025-12-12T12:27:53.331774Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "8cd48908-114eaca5-40f0faab-6c6f9e788"
host: "ghrun-fhkyrtz6p4"
node_id: 1
}
2025-12-12T12:27:53.335058Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:27:53.335106Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 8cd48908-114eaca5-40f0faab-6c6f9e788, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:27:53.423419Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudq7ue4bnna4fk100, Owner: 8cd48908-114eaca5-40f0faab-6c6f9e785, Request CP::PingTask with size: 442 bytes
2025-12-12T12:27:53.423519Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "8cd48908-114eaca5-40f0faab-6c6f9e785"
query_id {
  value: "ptqudq7ue4bnna4fk100"
}
statistics: "{\"Graph=0\":{\"TaskRunner\":{\"Stage=200289\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":2,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":2,\"count\":1,\"avg\":2,\"max\":2,\"min\":2}},\"Stage=Total\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":2,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":2,\"count\":1,\"avg\":2,\"max\":2,\"min\":2}}}}}"
scope: "yandexcloud://my_folder"
deadline {
  seconds: 1765628871
  nanos: 358269000
}
tenant: "/compute"
}
2025-12-12T12:27:53.433938Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {action: ABORT expired_at { seconds: 1765542493 nanos: 428000000 } } SUCCESS
2025-12-12T12:27:53.433977Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudq7ue4bnna4fk100, Owner: 8cd48908-114eaca5-40f0faab-6c6f9e785, Got CP::PingTaskResponse
2025-12-12T12:27:53.435903Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudq7ue4bnna4fk100, Owner: 8cd48908-114eaca5-40f0faab-6c6f9e785, Request CP::PingTask with size: 116 bytes
2025-12-12T12:27:53.435977Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "8cd48908-114eaca5-40f0faab-6c6f9e785"
query_id {
  value: "ptqudq7ue4bnna4fk100"
}
status: ABORTING_BY_USER
scope: "yandexcloud://my_folder"
deadline {
  seconds: 1765628871
  nanos: 358269000
}
tenant: "/compute"
}
2025-12-12T12:27:53.446788Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {action: ABORT expired_at { seconds: 1765542493 nanos: 441000000 } } SUCCESS
2025-12-12T12:27:53.446818Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudq7ue4bnna4fk100, Owner: 8cd48908-114eaca5-40f0faab-6c6f9e785, Got CP::PingTaskResponse
2025-12-12T12:27:53.447769Z :YQL_PRIVATE_PROXY DEBUG: rate_limiter_resources.cpp:175: PrivateDeleteRateLimiterResource - QueryId: ptqudq7ue4bnna4fk100, Owner: 8cd48908-114eaca5-40f0faab-6c6f9e785, Request CP::DeleteRateLimiterResource with size: 97 bytes
2025-12-12T12:27:53.447817Z :YQ_CONTROL_PLANE_STORAGE TRACE: request_actor.h:57: DeleteRateLimiterResourceRequest: {owner_id: "8cd48908-114eaca5-40f0faab-6c6f9e785"
query_id {
  value: "ptqudq7ue4bnna4fk100"
}
scope: "yandexcloud://my_folder"
tenant: "/compute"
} 
2025-12-12T12:27:53.488329Z :YQ_CONTROL_PLANE_STORAGE DEBUG: rate_limiter_resources.cpp:74: DeleteRateLimiterResourceRequest. Got response from database: SUCCESS
2025-12-12T12:27:53.488447Z :YQ_RATE_LIMITER DEBUG: schema.cpp:71: Run delete rate limiter resource "mock_cloud/my_folder/ptqudq7ue4bnna4fk100" actor
2025-12-12T12:27:53.488450Z :YQ_RATE_LIMITER DEBUG: schema.cpp:113: Call delete rate limiter resource "mock_cloud/my_folder/ptqudq7ue4bnna4fk100"
2025-12-12T12:27:53.491583Z :YQ_RATE_LIMITER DEBUG: schema.cpp:179: Successfully deleted rate limiter resource "mock_cloud/my_folder/ptqudq7ue4bnna4fk100"
2025-12-12T12:27:53.491594Z :YQ_RATE_LIMITER DEBUG: schema.cpp:122: Reply for delete rate limiter resource "mock_cloud/my_folder/ptqudq7ue4bnna4fk100": 
2025-12-12T12:27:53.491624Z :YQ_CONTROL_PLANE_STORAGE DEBUG: rate_limiter_resources.cpp:219: Got delete response from rate limiter service
2025-12-12T12:27:53.491649Z :YQL_PRIVATE_PROXY DEBUG: rate_limiter_resources.cpp:199: PrivateDeleteRateLimiterResource - QueryId: ptqudq7ue4bnna4fk100, Owner: 8cd48908-114eaca5-40f0faab-6c6f9e785, Got CP::DeleteRateLimiterResourceResponse
2025-12-12T12:27:53.492775Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudq7ue4bnna4fk100, Owner: 8cd48908-114eaca5-40f0faab-6c6f9e785, Request CP::PingTask with size: 996 bytes
2025-12-12T12:27:53.492879Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "8cd48908-114eaca5-40f0faab-6c6f9e785"
query_id {
  value: "ptqudq7ue4bnna4fk100"
}
result_id {
  value: "ptrudq7ue2gdp8i4fvtp"
}
status: ABORTED_BY_USER
issues {
  message: "ABORTED_BY_USER"
  severity: 1
}
statistics: "{\"Graph=0\":{\"Actor\":{\"ActorCreateTimeUs\":{\"sum\":\"55ms\",\"count\":2,\"avg\":\"27ms\",\"max\":\"27ms\",\"min\":\"27ms\"}},\"AllocateWorkersUs\":{\"sum\":\"29ms\",\"count\":1,\"avg\":\"29ms\",\"max\":\"29ms\",\"min\":\"29ms\"},\"ExecutionTimeUs\":{\"sum\":\"2.01s\",\"count\":1,\"avg\":\"2.01s\",\"max\":\"2.01s\",\"min\":\"2.01s\"},\"TaskRunner\":{\"Stage=200289\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":2,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":2,\"count\":1,\"avg\":2,\"max\":2,\"min\":2}},\"Stage=Total\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":2,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":2,\"count\":1,\"avg\":2,\"max\":2,\"min\":2}}},\"UniqueWorkers\":{\"sum\":1,\"count\":1,\"avg\":1,\"max\":1,\"min\":1}}}"
resources {
  rate_limiter: READY
  compilation: READY
  topic_consumers_state: READY
  rate_limiter_path: "local/RateLimiter_59343c87-a0fa-4d02-bbd7-bed27d35921a/rate_limiter"
  topic_consumers {
    database: "local"
    topic_path: "recovery_input"
    consumer_name: "ptqudq7ue4bnna4fk100"
    cluster_endpoint: "localhost:21682"
    token_name: "cluster:default_myyds"
    add_bearer_to_token: true
  }
}
scope: "yandexcloud://my_folder"
finished_at {
  seconds: 1765542473
  nanos: 435000000
}
deadline {
  seconds: 1765628871
  nanos: 358269000
}
tenant: "/compute"
}
2025-12-12T12:27:53.498435Z :YQ_CONTROL_PLANE_STORAGE NOTICE: task_ping.cpp:224: Query ptqudq7ue4bnna4fk100 is NOT billable, status: ABORTED_BY_USER, statusCode: UNAVAILABLE
2025-12-12T12:27:53.579272Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {action: ABORT } SUCCESS
2025-12-12T12:27:53.579356Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudq7ue4bnna4fk100, Owner: 8cd48908-114eaca5-40f0faab-6c6f9e785, Got CP::PingTaskResponse
2025-12-12T12:27:53.735481Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudq7ue4bnna4fk100"
2025-12-12T12:27:53.735521Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:305: Resolve folder bootstrap. Folder id: my_folder Actor id: [1:7582947185305047466:2317]
2025-12-12T12:27:53.735535Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:367: Cloud id: mock_cloud Folder id: my_folder
2025-12-12T12:27:53.735549Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:91: Get quotas bootstrap. Cloud id: mock_cloud Actor id: [1:7582947185305047467:2318]
2025-12-12T12:27:53.735570Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.analyticsQuery.count IS STALE, Refreshing ...
2025-12-12T12:27:53.735575Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.cpuPercent.count IS STALE, Refreshing ...
2025-12-12T12:27:53.735578Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.streamingQuery.count IS STALE, Refreshing ...
2025-12-12T12:27:53.735608Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.cpuPercent.count=0/10000 REFRESHED
2025-12-12T12:27:53.743189Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.analyticsQuery.count=0/100 REFRESHED
2025-12-12T12:27:53.743212Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.streamingQuery.count=0/100 REFRESHED
2025-12-12T12:27:53.743230Z :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:27:53.743247Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:103: Cloud id: mock_cloud Quota count: 8
2025-12-12T12:27:53.743296Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudq7ue4bnna4fk100"
2025-12-12T12:27:53.743336Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:169: Resolve subject type bootstrap. Token: **** (B6C6F477) Actor id: [1:7582947185305047472:2323]
2025-12-12T12:27:53.743359Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:230: Subject Type: federated_account Token: **** (B6C6F477)
2025-12-12T12:27:53.743374Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudq7ue4bnna4fk100"
2025-12-12T12:27:53.743384Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:63: Request actor. Actor id: [1:7582947185305047473:2324]
2025-12-12T12:27:53.743408Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_queries.cpp:641: DescribeQueryRequest: {query_id: "ptqudq7ue4bnna4fk100"
} [root@builtin, **** (B6C6F477)] 
2025-12-12T12:27:53.747208Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.cpuPercent.count=0/10000 NOTIFY CHANGE
2025-12-12T12:27:53.747512Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: DescribeQueryRequest - DescribeQueryResult: {query { meta { common { id: "ptqudq7ue4bnna4fk100" created_by: "root@builtin" modified_by: "root@builtin" created_at { seconds: 1765542469 nanos: 443788000 } modified_at { seconds: 1765542472 nanos: 574356000 } revision: 2 } started_at { seconds: 1765542470 nanos: 9000000 } finished_at { seconds: 1765542473 nanos: 435000000 } execute_mode: RUN status: ABORTED_BY_USER last_job_query_revision: 1 last_job_id: "ptjudq7ue4bnmkisuis9-ptqudq7ue4bnna4fk100" started_by: "root@builtin" aborted_by: "root@builtin" has_saved_checkpoints: true submitted_at { seconds: 1765542469 nanos: 443788000 } } content { type: STREAMING name: "simple" acl { visibility: PRIVATE } limits { execution_timeout { } } text: "\n            PRAGMA dq.MaxTasksPerStage=\"2\";\n\n            INSERT INTO myyds.`recovery_output`\n            SELECT STREAM\n                *\n            FROM myyds.`recovery_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_USER" severity: 1 } transient_issue { message: "Disconnected from worker: `Id:d78f682c-486d5c39-64f74a4-900b51bb,ghrun-fhkyrtz6p4,NodeId:1,\', reason: Undelivered" issue_code: 6001 severity: 1 } transient_issue { message: "Query failed with code UNAVAILABLE and will be restarted (RetryCount: 1) at 2025-12-12T12:27:50.892062Z" severity: 1 } statistics { json: "{\"Graph=0\":{\"Tasks\":{\"sum\":2,\"count\":1,\"avg\":2,\"max\":2,\"min\":2},\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":2,\"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\" \'\"2\"))\n(let $3 (DataSource \'\"pq\" \'\"myyds\"))\n(let $4 \'(\'(\'\"PartitionsCount\" \'\"2\")))\n(let $5 (StructType \'(\'\"Data\" (DataType \'String))))\n(let $6 (PqTopic \'\"myyds\" \'\"local\" \'\"recovery_input\" $4 \'() $5))\n(let $7 \'(\'\"Endpoint\" \'\"localhost:21682\"))\n(let $8 \'(\'\"SharedReading\" \'\"0\"))\n(let $9 \'(\'\"AddBearerToToken\" \'\"1\"))\n(let $10 \'($7 $8 \'(\'\"ReconnectPeriod\" \'\"\") \'(\'\"Format\" \'\"raw\") \'(\'\"ReadGroup\" \'\"ptcudq7ue4mb10b2jjv4\") $9))\n(let $11 (SecureParam \'\"cluster:default_myyds\"))\n(let $12 (DqPqTopicSource $2 $6 \'(\'\"Data\") $10 $11 \'\"\" $5 \'\"\"))\n(let $13 (DataSink \'\"pq\" \'\"myyds\"))\n(let $14 (PqTopic \'\"myyds\" \'\"local\" \'\"recovery_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:27:53.752949Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.analyticsQuery.count=0/100 NOTIFY CHANGE
2025-12-12T12:27:53.759176Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.streamingQuery.count=0/100 NOTIFY CHANGE
2025-12-12T12:27:53.900376Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 23f17547-a6ae60e4-cfc06ca9-d86b14f98, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 68 bytes
2025-12-12T12:27:53.900430Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "23f17547-a6ae60e4-cfc06ca9-d86b14f98"
host: "ghrun-fhkyrtz6p4"
node_id: 2
}
2025-12-12T12:27:53.903348Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:27:53.903387Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 23f17547-a6ae60e4-cfc06ca9-d86b14f98, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:27:54.333781Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 8cd48908-114eaca5-40f0faab-6c6f9e789, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 68 bytes
2025-12-12T12:27:54.333836Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "8cd48908-114eaca5-40f0faab-6c6f9e789"
host: "ghrun-fhkyrtz6p4"
node_id: 1
}
2025-12-12T12:27:54.336658Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:27:54.336722Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 8cd48908-114eaca5-40f0faab-6c6f9e789, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:27:54.391194Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582947155240276175:2107]
2025-12-12T12:27:54.391217Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:54.391225Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582947155240276119:2068]
2025-12-12T12:27:54.391229Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582947155240276119:2068]
2025-12-12T12:27:54.391232Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582947155240276119:2068]
2025-12-12T12:27:54.391244Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
