2025-12-12T12:26:36.424176Z :YQ_TEST_CONNECTION DEBUG: test_connection.cpp:142: Starting yandex query test connection. Actor id: [1:7582946854106404307:2071]
2025-12-12T12:26:36.424303Z :MEMORY_PROFILER NOTICE: monitor.cpp:332: Bootstrapped
2025-12-12T12:26:36.424704Z :GRPC_SERVER NOTICE: grpc_request_proxy_simple.cpp:161: Grpc simple request proxy started, nodeid# 1
2025-12-12T12:26:36.424742Z :GRPC_SERVER NOTICE: grpc_request_proxy_simple.cpp:161: Grpc simple request proxy started, nodeid# 1
2025-12-12T12:26:36.424910Z :YQ_CONTROL_PLANE_STORAGE INFO: ydb_control_plane_storage.cpp:50: Starting ydb control plane storage service. Actor id: [1:7582946854106404298:2062]
2025-12-12T12:26:36.425265Z :FQ_QUOTA_SERVICE INFO: quota_manager.cpp:196: STARTED
2025-12-12T12:26:36.425269Z :FQ_QUOTA_PROXY INFO: quota_proxy.cpp:90: STARTED
2025-12-12T12:26:36.425279Z :FQ_LOG_UPDATER DEBUG: log.cpp:93: Updated YQL logs priority: 8
2025-12-12T12:26:36.425284Z :FQ_LOG_UPDATER CRIT: log.cpp:55: Failed to deliver subscription request to config dispatcher.
2025-12-12T12:26:36.425298Z :FQ_CONTROL_PLANE_CONFIG DEBUG: control_plane_config.cpp:58: STARTING: [1:7582946854106404299:2063]
2025-12-12T12:26:36.425320Z :YQ_CONTROL_PLANE_PROXY DEBUG: control_plane_proxy.cpp:525: Starting yandex query control plane proxy. Actor id: [1:7582946854106404300:2064]
2025-12-12T12:26:36.425417Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:214: Bootstrap
2025-12-12T12:26:36.425418Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:217: Create sdk ydb connection
2025-12-12T12:26:36.425444Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:239: Successfully bootstrapped TStorageProxy [1:7582946854106404303:2067] with connection to localhost:25827:local
2025-12-12T12:26:36.425454Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:544: RowDispatcher: Successfully bootstrapped row dispatcher, id [1:7582946854106404304:2068], tenant /cp
2025-12-12T12:26:36.425463Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582946854106404304:2068]
2025-12-12T12:26:36.425464Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:329: Coordinator: Add new row dispatcher to map (state 1)
2025-12-12T12:26:36.425595Z :YQ_RATE_LIMITER DEBUG: schema.cpp:71: Run create coordination node "local/RateLimiter_df6e7bab-b514-4b78-b17e-e8ee264a681d/rate_limiter" actor
2025-12-12T12:26:36.425597Z :YQ_RATE_LIMITER DEBUG: schema.cpp:113: Call create coordination node "local/RateLimiter_df6e7bab-b514-4b78-b17e-e8ee264a681d/rate_limiter"
2025-12-12T12:26:36.425598Z :YQ_RATE_LIMITER DEBUG: schema.cpp:411: Call create coordination node "local/RateLimiter_df6e7bab-b514-4b78-b17e-e8ee264a681d/rate_limiter"
2025-12-12T12:26:36.425624Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:293: Coordinator: Successfully bootstrapped coordinator, id [1:7582946854106404374:2119], NodesManagerId [0:4705493345362661702:78], rebalancing timeout 5.000000s
2025-12-12T12:26:36.425709Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:637: RowDispatcher: TEvCoordinatorChangesSubscribe from [1:7582946854106404374:2119]
2025-12-12T12:26:36.425738Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:232: TLeaderElection [1:7582946854106404375:2120] Successfully bootstrapped, local coordinator id [1:7582946854106404374:2119], tenant id cp, local mode 0, coordination node path local/cp, endpoint localhost:25827
2025-12-12T12:26:36.434934Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:71: Run create coordination node "local/cp" actor
2025-12-12T12:26:36.434948Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:113: Call create coordination node "local/cp"
2025-12-12T12:26:36.434950Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:411: Call create coordination node "local/cp"
2025-12-12T12:26:36.435299Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_df6e7bab-b514-4b78-b17e-e8ee264a681d/idempotency_keys" actor
2025-12-12T12:26:36.435323Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_df6e7bab-b514-4b78-b17e-e8ee264a681d/result_sets" actor
2025-12-12T12:26:36.435330Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_df6e7bab-b514-4b78-b17e-e8ee264a681d/jobs" actor
2025-12-12T12:26:36.435335Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_df6e7bab-b514-4b78-b17e-e8ee264a681d/nodes" actor
2025-12-12T12:26:36.435341Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_df6e7bab-b514-4b78-b17e-e8ee264a681d/quotas" actor
2025-12-12T12:26:36.435348Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_df6e7bab-b514-4b78-b17e-e8ee264a681d/tenants" actor
2025-12-12T12:26:36.435355Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_df6e7bab-b514-4b78-b17e-e8ee264a681d/tenant_acks" actor
2025-12-12T12:26:36.435362Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_df6e7bab-b514-4b78-b17e-e8ee264a681d/mappings" actor
2025-12-12T12:26:36.435367Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_df6e7bab-b514-4b78-b17e-e8ee264a681d/compute_databases" actor
2025-12-12T12:26:36.435372Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create directory "local/DbPoolStorage_df6e7bab-b514-4b78-b17e-e8ee264a681d" actor
2025-12-12T12:26:36.435374Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create directory "local/DbPoolStorage_df6e7bab-b514-4b78-b17e-e8ee264a681d"
2025-12-12T12:26:36.435376Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:383: Call create directory "local/DbPoolStorage_df6e7bab-b514-4b78-b17e-e8ee264a681d"
2025-12-12T12:26:36.435390Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_df6e7bab-b514-4b78-b17e-e8ee264a681d/queries" actor
2025-12-12T12:26:36.435395Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_df6e7bab-b514-4b78-b17e-e8ee264a681d/pending_small" actor
2025-12-12T12:26:36.435402Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_df6e7bab-b514-4b78-b17e-e8ee264a681d/connections" actor
2025-12-12T12:26:36.435407Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_df6e7bab-b514-4b78-b17e-e8ee264a681d/bindings" actor
2025-12-12T12:26:36.462898Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_df6e7bab-b514-4b78-b17e-e8ee264a681d/idempotency_keys". Create session OK
2025-12-12T12:26:36.462912Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_df6e7bab-b514-4b78-b17e-e8ee264a681d/idempotency_keys"
2025-12-12T12:26:36.462916Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_df6e7bab-b514-4b78-b17e-e8ee264a681d/idempotency_keys"
2025-12-12T12:26:36.462963Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_df6e7bab-b514-4b78-b17e-e8ee264a681d/queries". Create session OK
2025-12-12T12:26:36.462966Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_df6e7bab-b514-4b78-b17e-e8ee264a681d/queries"
2025-12-12T12:26:36.462968Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_df6e7bab-b514-4b78-b17e-e8ee264a681d/queries"
2025-12-12T12:26:36.463075Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_df6e7bab-b514-4b78-b17e-e8ee264a681d/result_sets". Create session OK
2025-12-12T12:26:36.463091Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_df6e7bab-b514-4b78-b17e-e8ee264a681d/result_sets"
2025-12-12T12:26:36.463095Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_df6e7bab-b514-4b78-b17e-e8ee264a681d/result_sets"
2025-12-12T12:26:36.463214Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_df6e7bab-b514-4b78-b17e-e8ee264a681d/jobs". Create session OK
2025-12-12T12:26:36.463223Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_df6e7bab-b514-4b78-b17e-e8ee264a681d/jobs"
2025-12-12T12:26:36.463225Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_df6e7bab-b514-4b78-b17e-e8ee264a681d/jobs"
2025-12-12T12:26:36.463580Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_df6e7bab-b514-4b78-b17e-e8ee264a681d/mappings". Create session OK
2025-12-12T12:26:36.463582Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_df6e7bab-b514-4b78-b17e-e8ee264a681d/mappings"
2025-12-12T12:26:36.463584Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_df6e7bab-b514-4b78-b17e-e8ee264a681d/mappings"
2025-12-12T12:26:36.463651Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_df6e7bab-b514-4b78-b17e-e8ee264a681d/tenants". Create session OK
2025-12-12T12:26:36.463653Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_df6e7bab-b514-4b78-b17e-e8ee264a681d/tenants"
2025-12-12T12:26:36.463654Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_df6e7bab-b514-4b78-b17e-e8ee264a681d/tenants"
2025-12-12T12:26:36.463718Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_df6e7bab-b514-4b78-b17e-e8ee264a681d/nodes". Create session OK
2025-12-12T12:26:36.463720Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_df6e7bab-b514-4b78-b17e-e8ee264a681d/nodes"
2025-12-12T12:26:36.463722Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_df6e7bab-b514-4b78-b17e-e8ee264a681d/nodes"
2025-12-12T12:26:36.463757Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_df6e7bab-b514-4b78-b17e-e8ee264a681d/connections". Create session OK
2025-12-12T12:26:36.463760Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_df6e7bab-b514-4b78-b17e-e8ee264a681d/connections"
2025-12-12T12:26:36.463763Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_df6e7bab-b514-4b78-b17e-e8ee264a681d/connections"
2025-12-12T12:26:36.463789Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_df6e7bab-b514-4b78-b17e-e8ee264a681d/compute_databases". Create session OK
2025-12-12T12:26:36.463791Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_df6e7bab-b514-4b78-b17e-e8ee264a681d/compute_databases"
2025-12-12T12:26:36.463792Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_df6e7bab-b514-4b78-b17e-e8ee264a681d/compute_databases"
2025-12-12T12:26:36.463819Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created directory "local/DbPoolStorage_df6e7bab-b514-4b78-b17e-e8ee264a681d"
2025-12-12T12:26:36.463835Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_df6e7bab-b514-4b78-b17e-e8ee264a681d/tenant_acks". Create session OK
2025-12-12T12:26:36.463836Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_df6e7bab-b514-4b78-b17e-e8ee264a681d/tenant_acks"
2025-12-12T12:26:36.463837Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_df6e7bab-b514-4b78-b17e-e8ee264a681d/tenant_acks"
2025-12-12T12:26:36.463848Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create directory "local/DbPoolStorage_df6e7bab-b514-4b78-b17e-e8ee264a681d": { <main>: Error: Check failed: path: '/local/DbPoolStorage_df6e7bab-b514-4b78-b17e-e8ee264a681d', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 2], type: EPathTypeDir, state: EPathStateNoChanges), source_location: ydb/core/tx/schemeshard/schemeshard__operation_mkdir.cpp:155 }
2025-12-12T12:26:36.463857Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_df6e7bab-b514-4b78-b17e-e8ee264a681d/quotas". Create session OK
2025-12-12T12:26:36.463859Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_df6e7bab-b514-4b78-b17e-e8ee264a681d/quotas"
2025-12-12T12:26:36.463860Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_df6e7bab-b514-4b78-b17e-e8ee264a681d/quotas"
2025-12-12T12:26:36.463887Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_df6e7bab-b514-4b78-b17e-e8ee264a681d/pending_small". Create session OK
2025-12-12T12:26:36.463888Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_df6e7bab-b514-4b78-b17e-e8ee264a681d/pending_small"
2025-12-12T12:26:36.463890Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_df6e7bab-b514-4b78-b17e-e8ee264a681d/pending_small"
2025-12-12T12:26:36.463910Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_df6e7bab-b514-4b78-b17e-e8ee264a681d/bindings". Create session OK
2025-12-12T12:26:36.463911Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_df6e7bab-b514-4b78-b17e-e8ee264a681d/bindings"
2025-12-12T12:26:36.463923Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_df6e7bab-b514-4b78-b17e-e8ee264a681d/bindings"
2025-12-12T12:26:36.481282Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_df6e7bab-b514-4b78-b17e-e8ee264a681d/tenants"
2025-12-12T12:26:36.481320Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_df6e7bab-b514-4b78-b17e-e8ee264a681d/tenants": { <main>: Error: Check failed: path: '/local/DbPoolStorage_df6e7bab-b514-4b78-b17e-e8ee264a681d/tenants', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 3], type: EPathTypeTable, state: EPathStateNoChanges), source_location: ydb/core/tx/schemeshard/schemeshard__operation_create_table.cpp:504 }
2025-12-12T12:26:36.490564Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_df6e7bab-b514-4b78-b17e-e8ee264a681d/mappings"
2025-12-12T12:26:36.490583Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_df6e7bab-b514-4b78-b17e-e8ee264a681d/mappings": { <main>: Error: Check failed: path: '/local/DbPoolStorage_df6e7bab-b514-4b78-b17e-e8ee264a681d/mappings', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 4], type: EPathTypeTable, state: EPathStateNoChanges), source_location: ydb/core/tx/schemeshard/schemeshard__operation_create_table.cpp:504 }
2025-12-12T12:26:36.523618Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_df6e7bab-b514-4b78-b17e-e8ee264a681d/jobs"
2025-12-12T12:26:36.523628Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_df6e7bab-b514-4b78-b17e-e8ee264a681d/jobs": 
2025-12-12T12:26:36.523662Z :YQ_RATE_LIMITER DEBUG: schema.cpp:155: Successfully created coordination node "local/RateLimiter_df6e7bab-b514-4b78-b17e-e8ee264a681d/rate_limiter"
2025-12-12T12:26:36.523666Z :YQ_RATE_LIMITER DEBUG: schema.cpp:122: Reply for create coordination node "local/RateLimiter_df6e7bab-b514-4b78-b17e-e8ee264a681d/rate_limiter": 
2025-12-12T12:26:36.527441Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:155: Successfully created coordination node "local/cp"
2025-12-12T12:26:36.527452Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:122: Reply for create coordination node "local/cp": 
2025-12-12T12:26:36.527468Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:345: TLeaderElection [1:7582946854106404375:2120] Coordination node successfully created
2025-12-12T12:26:36.527471Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:323: TLeaderElection [1:7582946854106404375:2120] Start session
2025-12-12T12:26:36.538946Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_df6e7bab-b514-4b78-b17e-e8ee264a681d/bindings"
2025-12-12T12:26:36.538958Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_df6e7bab-b514-4b78-b17e-e8ee264a681d/bindings": 
2025-12-12T12:26:36.539246Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_df6e7bab-b514-4b78-b17e-e8ee264a681d/compute_databases"
2025-12-12T12:26:36.539249Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_df6e7bab-b514-4b78-b17e-e8ee264a681d/compute_databases": 
2025-12-12T12:26:36.539285Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_df6e7bab-b514-4b78-b17e-e8ee264a681d/queries"
2025-12-12T12:26:36.539290Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_df6e7bab-b514-4b78-b17e-e8ee264a681d/queries": 
2025-12-12T12:26:36.539352Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:359: TLeaderElection [1:7582946854106404375:2120] Session successfully created
2025-12-12T12:26:36.542265Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_df6e7bab-b514-4b78-b17e-e8ee264a681d/pending_small"
2025-12-12T12:26:36.542275Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_df6e7bab-b514-4b78-b17e-e8ee264a681d/pending_small": 
2025-12-12T12:26:36.542384Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_df6e7bab-b514-4b78-b17e-e8ee264a681d/result_sets"
2025-12-12T12:26:36.542388Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_df6e7bab-b514-4b78-b17e-e8ee264a681d/result_sets": 
2025-12-12T12:26:36.542431Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_df6e7bab-b514-4b78-b17e-e8ee264a681d/quotas"
2025-12-12T12:26:36.542433Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_df6e7bab-b514-4b78-b17e-e8ee264a681d/quotas": 
2025-12-12T12:26:36.542477Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_df6e7bab-b514-4b78-b17e-e8ee264a681d/connections"
2025-12-12T12:26:36.542478Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_df6e7bab-b514-4b78-b17e-e8ee264a681d/connections": 
2025-12-12T12:26:36.542512Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_df6e7bab-b514-4b78-b17e-e8ee264a681d/tenant_acks"
2025-12-12T12:26:36.542514Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_df6e7bab-b514-4b78-b17e-e8ee264a681d/tenant_acks": 
2025-12-12T12:26:36.542520Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_df6e7bab-b514-4b78-b17e-e8ee264a681d/nodes"
2025-12-12T12:26:36.542522Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_df6e7bab-b514-4b78-b17e-e8ee264a681d/nodes": 
2025-12-12T12:26:36.542569Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_df6e7bab-b514-4b78-b17e-e8ee264a681d/idempotency_keys"
2025-12-12T12:26:36.542571Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_df6e7bab-b514-4b78-b17e-e8ee264a681d/idempotency_keys": 
2025-12-12T12:26:36.547330Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:372: TLeaderElection [1:7582946854106404375:2120] Semaphore successfully created
2025-12-12T12:26:36.547341Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:304: TLeaderElection [1:7582946854106404375:2120] Try to acquire semaphore
2025-12-12T12:26:36.547419Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:420: TLeaderElection [1:7582946854106404375:2120] Describe semaphore
2025-12-12T12:26:36.549164Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:386: TLeaderElection [1:7582946854106404375:2120] Semaphore successfully acquired
2025-12-12T12:26:36.549180Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:469: TLeaderElection [1:7582946854106404375:2120] Semaphore successfully described: coordinator id [1:7582946854106404374:2119] generation 1
2025-12-12T12:26:36.549185Z :FQ_ROW_DISPATCHER INFO: leader_election.cpp:471: TLeaderElection [1:7582946854106404375:2120] Send TEvCoordinatorChanged to [1:7582946854106404304:2068], new coordinator id [1:7582946854106404374:2119], previous coordinator id [0:0:0]
2025-12-12T12:26:36.549200Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:569: RowDispatcher: Coordinator changed, old leader (empty maybe), new [1:7582946854106404374:2119] generation 1
2025-12-12T12:26:36.549214Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582946854106404304:2068]
2025-12-12T12:26:36.549217Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582946854106404304:2068]
2025-12-12T12:26:36.549220Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582946854106404304:2068]
2025-12-12T12:26:36.549231Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:440: Coordinator: New leader [1:7582946854106404374:2119], SelfId [1:7582946854106404374:2119]
2025-12-12T12:26:36.549241Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:26:36.550506Z :FQ_CONTROL_PLANE_CONFIG DEBUG: control_plane_config.cpp:190: LOADED TenantInfo: State CHANGED at 2025-12-12T12:26:35.973850Z
2025-12-12T12:26:37.592172Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: b3c34733-fb840005-ab5e9e00-5658733d1, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 68 bytes
2025-12-12T12:26:37.592823Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "b3c34733-fb840005-ab5e9e00-5658733d1"
host: "ghrun-fhkyrtz6p4"
node_id: 1
}
2025-12-12T12:26:37.608775Z :YQ_CONTROL_PLANE_STORAGE TRACE: nodes_health_check.cpp:38: NodesHealthCheckRequest: {tenant: "/compute"
node {
  node_id: 1
  instance_id: "a36f2a20-4571c9c6-1fee6da1-b35d6296"
  hostname: "ghrun-fhkyrtz6p4"
  interconnect_port: 15973
  node_address: "127.0.1.1"
}
}
2025-12-12T12:26:37.649488Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:26:37.649534Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: b3c34733-fb840005-ab5e9e00-5658733d1, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:26:37.700539Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: NodesHealthCheckRequest - NodesHealthCheckResult: {nodes { node_id: 1 instance_id: "a36f2a20-4571c9c6-1fee6da1-b35d6296" hostname: "ghrun-fhkyrtz6p4" node_address: "127.0.1.1" } } SUCCESS
2025-12-12T12:26:38.145970Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: a265f52-26d65083-401e9fd-55241e9a1, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 66 bytes
2025-12-12T12:26:38.145991Z :YQ_CONTROL_PLANE_STORAGE TRACE: nodes_health_check.cpp:38: NodesHealthCheckRequest: {tenant: "/compute"
node {
  node_id: 2
  instance_id: "f5d68a68-4a2b5323-f53e77ab-616b5055"
  hostname: "ghrun-fhkyrtz6p4"
  interconnect_port: 31922
  node_address: "127.0.1.1"
}
}
2025-12-12T12:26:38.146070Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "a265f52-26d65083-401e9fd-55241e9a1"
host: "ghrun-fhkyrtz6p4"
node_id: 2
}
2025-12-12T12:26:38.150561Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:26:38.150617Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: a265f52-26d65083-401e9fd-55241e9a1, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:26:38.165428Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: NodesHealthCheckRequest - NodesHealthCheckResult: {nodes { node_id: 2 instance_id: "f5d68a68-4a2b5323-f53e77ab-616b5055" hostname: "ghrun-fhkyrtz6p4" node_address: "127.0.1.1" } nodes { node_id: 1 instance_id: "a36f2a20-4571c9c6-1fee6da1-b35d6296" hostname: "ghrun-fhkyrtz6p4" interconnect_port: 15973 node_address: "127.0.1.1" } } SUCCESS
2025-12-12T12:26:38.425800Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582946854106404374:2119]
2025-12-12T12:26:38.425822Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:26:38.425831Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582946854106404304:2068]
2025-12-12T12:26:38.425835Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582946854106404304:2068]
2025-12-12T12:26:38.425837Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582946854106404304:2068]
2025-12-12T12:26:38.425856Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:26:38.583236Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: b3c34733-fb840005-ab5e9e00-5658733d2, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 68 bytes
2025-12-12T12:26:38.583287Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "b3c34733-fb840005-ab5e9e00-5658733d2"
host: "ghrun-fhkyrtz6p4"
node_id: 1
}
2025-12-12T12:26:38.589020Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:26:38.589067Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: b3c34733-fb840005-ab5e9e00-5658733d2, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:26:39.135879Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: a265f52-26d65083-401e9fd-55241e9a2, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 66 bytes
2025-12-12T12:26:39.135937Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "a265f52-26d65083-401e9fd-55241e9a2"
host: "ghrun-fhkyrtz6p4"
node_id: 2
}
2025-12-12T12:26:39.138691Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:26:39.138726Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: a265f52-26d65083-401e9fd-55241e9a2, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:26:39.434657Z :FQ_CONTROL_PLANE_CONFIG TRACE: control_plane_config.cpp:192: LOADED TenantInfo: State NOT changed
2025-12-12T12:26:39.579934Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: b3c34733-fb840005-ab5e9e00-5658733d3, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 68 bytes
2025-12-12T12:26:39.579996Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "b3c34733-fb840005-ab5e9e00-5658733d3"
host: "ghrun-fhkyrtz6p4"
node_id: 1
}
2025-12-12T12:26:39.584996Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:26:39.585058Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: b3c34733-fb840005-ab5e9e00-5658733d3, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:26:40.137226Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: a265f52-26d65083-401e9fd-55241e9a3, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 66 bytes
2025-12-12T12:26:40.137301Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "a265f52-26d65083-401e9fd-55241e9a3"
host: "ghrun-fhkyrtz6p4"
node_id: 2
}
2025-12-12T12:26:40.151474Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:26:40.151574Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: a265f52-26d65083-401e9fd-55241e9a3, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:26:40.426754Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582946854106404374:2119]
2025-12-12T12:26:40.426765Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:26:40.426773Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582946854106404304:2068]
2025-12-12T12:26:40.426777Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582946854106404304:2068]
2025-12-12T12:26:40.426780Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582946854106404304:2068]
2025-12-12T12:26:40.426786Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:26:40.583897Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: b3c34733-fb840005-ab5e9e00-5658733d4, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 68 bytes
2025-12-12T12:26:40.584036Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "b3c34733-fb840005-ab5e9e00-5658733d4"
host: "ghrun-fhkyrtz6p4"
node_id: 1
}
2025-12-12T12:26:40.616758Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:26:40.616819Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: b3c34733-fb840005-ab5e9e00-5658733d4, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:26:41.139667Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: a265f52-26d65083-401e9fd-55241e9a4, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 66 bytes
2025-12-12T12:26:41.139719Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "a265f52-26d65083-401e9fd-55241e9a4"
host: "ghrun-fhkyrtz6p4"
node_id: 2
}
2025-12-12T12:26:41.152621Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:26:41.152672Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: a265f52-26d65083-401e9fd-55241e9a4, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:26:41.426127Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:665: Coordinator: Change global state to Started (by timeout)
2025-12-12T12:26:41.587411Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: b3c34733-fb840005-ab5e9e00-5658733d5, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 68 bytes
2025-12-12T12:26:41.587463Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "b3c34733-fb840005-ab5e9e00-5658733d5"
host: "ghrun-fhkyrtz6p4"
node_id: 1
}
2025-12-12T12:26:41.594061Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:26:41.594117Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: b3c34733-fb840005-ab5e9e00-5658733d5, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:26:42.137943Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: a265f52-26d65083-401e9fd-55241e9a5, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 66 bytes
2025-12-12T12:26:42.138004Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "a265f52-26d65083-401e9fd-55241e9a5"
host: "ghrun-fhkyrtz6p4"
node_id: 2
}
2025-12-12T12:26:42.141348Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:26:42.141396Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: a265f52-26d65083-401e9fd-55241e9a5, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:26:42.427609Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582946854106404374:2119]
2025-12-12T12:26:42.427626Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:26:42.427643Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582946854106404304:2068]
2025-12-12T12:26:42.427652Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582946854106404304:2068]
2025-12-12T12:26:42.427656Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582946854106404304:2068]
2025-12-12T12:26:42.427669Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:26:42.439435Z :FQ_CONTROL_PLANE_CONFIG TRACE: control_plane_config.cpp:192: LOADED TenantInfo: State NOT changed
2025-12-12T12:26:42.591530Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: b3c34733-fb840005-ab5e9e00-5658733d6, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 68 bytes
2025-12-12T12:26:42.591595Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "b3c34733-fb840005-ab5e9e00-5658733d6"
host: "ghrun-fhkyrtz6p4"
node_id: 1
}
2025-12-12T12:26:42.600222Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:26:42.600283Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: b3c34733-fb840005-ab5e9e00-5658733d6, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:26:42.614253Z :YQ_CONTROL_PLANE_STORAGE TRACE: nodes_health_check.cpp:38: NodesHealthCheckRequest: {tenant: "/compute"
node {
  node_id: 1
  instance_id: "a36f2a20-4571c9c6-1fee6da1-b35d6296"
  hostname: "ghrun-fhkyrtz6p4"
  interconnect_port: 15973
  node_address: "127.0.1.1"
}
}
2025-12-12T12:26:42.639496Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: NodesHealthCheckRequest - NodesHealthCheckResult: {nodes { node_id: 1 instance_id: "a36f2a20-4571c9c6-1fee6da1-b35d6296" hostname: "ghrun-fhkyrtz6p4" node_address: "127.0.1.1" } nodes { node_id: 2 instance_id: "f5d68a68-4a2b5323-f53e77ab-616b5055" hostname: "ghrun-fhkyrtz6p4" interconnect_port: 31922 node_address: "127.0.1.1" } } SUCCESS
2025-12-12T12:26:42.817968Z :TICKET_PARSER DEBUG: ticket_parser_impl.h:1875: Ticket **** (B6C6F477) (ipv6:[::1]:46556) has now valid token of root@builtin
2025-12-12T12:26:42.818207Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:1330: CreateConnectionRequest: content { name: "myyds" setting { data_streams { auth { none { } } endpoint: "localhost:25827" database: "local" } } acl { visibility: PRIVATE } } 
2025-12-12T12:26:42.818247Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:305: Resolve folder bootstrap. Folder id: my_folder Actor id: [1:7582946879876208227:2194]
2025-12-12T12:26:42.818263Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:367: Cloud id: mock_cloud Folder id: my_folder
2025-12-12T12:26:42.818277Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:91: Get quotas bootstrap. Cloud id: mock_cloud Actor id: [1:7582946879876208228:2195]
2025-12-12T12:26:42.818289Z :FQ_QUOTA_SERVICE DEBUG: quota_manager.cpp:255: cloud.mock_cloud NOT CASHED, Loading ...
2025-12-12T12:26:42.852516Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:441: cloud.mock_cloud {} FROM DB
2025-12-12T12:26:42.852551Z :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:26:42.852555Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.analyticsQuery.count IS STALE, Refreshing ...
2025-12-12T12:26:42.852571Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.cpuPercent.count IS STALE, Refreshing ...
2025-12-12T12:26:42.852576Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.streamingQuery.count IS STALE, Refreshing ...
2025-12-12T12:26:42.852603Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.cpuPercent.count=0/10000 REFRESHED
2025-12-12T12:26:42.927547Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.cpuPercent.count=0/10000 NOTIFY CHANGE
2025-12-12T12:26:42.952714Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.analyticsQuery.count=0/100 REFRESHED
2025-12-12T12:26:42.952746Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.streamingQuery.count=0/100 REFRESHED
2025-12-12T12:26:42.952766Z :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:26:42.952790Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:103: Cloud id: mock_cloud Quota count: 8
2025-12-12T12:26:42.952972Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:1330: CreateConnectionRequest: content { name: "myyds" setting { data_streams { auth { none { } } endpoint: "localhost:25827" database: "local" } } acl { visibility: PRIVATE } } 
2025-12-12T12:26:42.953080Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:169: Resolve subject type bootstrap. Token: **** (B6C6F477) Actor id: [1:7582946879876208234:2201]
2025-12-12T12:26:42.953097Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:230: Subject Type: federated_account Token: **** (B6C6F477)
2025-12-12T12:26:42.953171Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:1330: CreateConnectionRequest: content { name: "myyds" setting { data_streams { auth { none { } } endpoint: "localhost:25827" database: "local" } } acl { visibility: PRIVATE } } 
2025-12-12T12:26:42.953186Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:435: Create database bootstrap. CloudId: mock_cloud Scope: yandexcloud://my_folder Actor id: [1:7582946879876208235:2202]
2025-12-12T12:26:42.953231Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:1330: CreateConnectionRequest: content { name: "myyds" setting { data_streams { auth { none { } } endpoint: "localhost:25827" database: "local" } } acl { visibility: PRIVATE } } 
2025-12-12T12:26:42.953248Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:63: Request actor. Actor id: [1:7582946879876208236:2203]
2025-12-12T12:26:42.953358Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_connections.cpp:120: [yandexcloud://my_folder, root@builtin, ptcudq7ug3orttdktg37] CreateConnectionRequest: **** (B6C6F477) content { name: "myyds" setting { data_streams { auth { none { } } endpoint: "localhost:25827" database: "local" } } acl { visibility: PRIVATE } } 
2025-12-12T12:26:42.963841Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.analyticsQuery.count=0/100 NOTIFY CHANGE
2025-12-12T12:26:42.963851Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.streamingQuery.count=0/100 NOTIFY CHANGE
2025-12-12T12:26:43.138764Z :YQ_CONTROL_PLANE_STORAGE TRACE: nodes_health_check.cpp:38: NodesHealthCheckRequest: {tenant: "/compute"
node {
  node_id: 2
  instance_id: "f5d68a68-4a2b5323-f53e77ab-616b5055"
  hostname: "ghrun-fhkyrtz6p4"
  interconnect_port: 31922
  node_address: "127.0.1.1"
}
}
2025-12-12T12:26:43.138808Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: a265f52-26d65083-401e9fd-55241e9a6, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 66 bytes
2025-12-12T12:26:43.138877Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "a265f52-26d65083-401e9fd-55241e9a6"
host: "ghrun-fhkyrtz6p4"
node_id: 2
}
2025-12-12T12:26:43.142657Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:26:43.142723Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: a265f52-26d65083-401e9fd-55241e9a6, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:26:43.157708Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: NodesHealthCheckRequest - NodesHealthCheckResult: {nodes { node_id: 2 instance_id: "f5d68a68-4a2b5323-f53e77ab-616b5055" hostname: "ghrun-fhkyrtz6p4" node_address: "127.0.1.1" } nodes { node_id: 1 instance_id: "a36f2a20-4571c9c6-1fee6da1-b35d6296" hostname: "ghrun-fhkyrtz6p4" interconnect_port: 15973 node_address: "127.0.1.1" } } SUCCESS
2025-12-12T12:26:43.379515Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: [yandexcloud://my_folder, root@builtin, ptcudq7ug3orttdktg37] CreateConnectionRequest: {connection_id: "ptcudq7ug3orttdktg37" } SUCCESS
2025-12-12T12:26:43.383364Z :TICKET_PARSER DEBUG: ticket_parser_impl.h:1875: Ticket **** (B6C6F477) (ipv6:[::1]:46556) has now valid token of root@builtin
2025-12-12T12:26:43.383493Z :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: "98db7490-4a12-44e9-ac49-4d50c02af726"
2025-12-12T12:26:43.383538Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:305: Resolve folder bootstrap. Folder id: my_folder Actor id: [1:7582946884171175542:2212]
2025-12-12T12:26:43.383552Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:367: Cloud id: mock_cloud Folder id: my_folder
2025-12-12T12:26:43.383575Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:91: Get quotas bootstrap. Cloud id: mock_cloud Actor id: [1:7582946884171175543:2213]
2025-12-12T12:26:43.383603Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.analyticsQuery.count IS STALE, Refreshing ...
2025-12-12T12:26:43.383615Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.cpuPercent.count IS STALE, Refreshing ...
2025-12-12T12:26:43.383620Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.streamingQuery.count IS STALE, Refreshing ...
2025-12-12T12:26:43.383656Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.cpuPercent.count=0/10000 REFRESHED
2025-12-12T12:26:43.391333Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.analyticsQuery.count=0/100 REFRESHED
2025-12-12T12:26:43.391352Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.streamingQuery.count=0/100 REFRESHED
2025-12-12T12:26:43.391373Z :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:26:43.391391Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:103: Cloud id: mock_cloud Quota count: 8
2025-12-12T12:26:43.391474Z :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: "98db7490-4a12-44e9-ac49-4d50c02af726"
2025-12-12T12:26:43.391541Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:169: Resolve subject type bootstrap. Token: **** (B6C6F477) Actor id: [1:7582946884171175548:2218]
2025-12-12T12:26:43.391556Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:230: Subject Type: federated_account Token: **** (B6C6F477)
2025-12-12T12:26:43.391579Z :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: "98db7490-4a12-44e9-ac49-4d50c02af726"
2025-12-12T12:26:43.391589Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:435: Create database bootstrap. CloudId: mock_cloud Scope: yandexcloud://my_folder Actor id: [1:7582946884171175549:2219]
2025-12-12T12:26:43.391607Z :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: "98db7490-4a12-44e9-ac49-4d50c02af726"
2025-12-12T12:26:43.391621Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:63: Request actor. Actor id: [1:7582946884171175550:2220]
2025-12-12T12:26:43.391634Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:248: Create rate limiter resource for cloud with limit 100000ms
2025-12-12T12:26:43.391658Z :YQ_RATE_LIMITER DEBUG: schema.cpp:71: Run create rate limiter resource "mock_cloud" actor
2025-12-12T12:26:43.391660Z :YQ_RATE_LIMITER DEBUG: schema.cpp:113: Call create rate limiter resource "mock_cloud"
2025-12-12T12:26:43.398504Z :YQ_RATE_LIMITER DEBUG: schema.cpp:155: Successfully created rate limiter resource "mock_cloud"
2025-12-12T12:26:43.398519Z :YQ_RATE_LIMITER DEBUG: schema.cpp:122: Reply for create rate limiter resource "mock_cloud": 
2025-12-12T12:26:43.398539Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.cpuPercent.count=0/10000 NOTIFY CHANGE
2025-12-12T12:26:43.398578Z :YQ_CONTROL_PLANE_PROXY DEBUG: request_actor.h:272: Create response from rate limiter service. Success: 1
2025-12-12T12:26:43.398678Z :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: "98db7490-4a12-44e9-ac49-4d50c02af726"
} [root@builtin, **** (B6C6F477)] 
2025-12-12T12:26:43.406705Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.streamingQuery.count=0/100 NOTIFY CHANGE
2025-12-12T12:26:43.406724Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.analyticsQuery.count=0/100 NOTIFY CHANGE
2025-12-12T12:26:43.588401Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: b3c34733-fb840005-ab5e9e00-5658733d7, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 68 bytes
2025-12-12T12:26:43.588454Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "b3c34733-fb840005-ab5e9e00-5658733d7"
host: "ghrun-fhkyrtz6p4"
node_id: 1
}
2025-12-12T12:26:43.592205Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:26:43.592251Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: b3c34733-fb840005-ab5e9e00-5658733d7, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:26:43.660007Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: CreateQueryRequest - CreateQueryResult: {query_id: "ptqudq7ug3b8up2rk3ft" } SUCCESS
2025-12-12T12:26:43.667679Z :TICKET_PARSER DEBUG: ticket_parser_impl.h:1875: Ticket **** (B6C6F477) (ipv6:[::1]:46556) has now valid token of root@builtin
2025-12-12T12:26:43.667766Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudq7ug3b8up2rk3ft"
2025-12-12T12:26:43.667806Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:305: Resolve folder bootstrap. Folder id: my_folder Actor id: [1:7582946884171175558:2227]
2025-12-12T12:26:43.667826Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:367: Cloud id: mock_cloud Folder id: my_folder
2025-12-12T12:26:43.667845Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:91: Get quotas bootstrap. Cloud id: mock_cloud Actor id: [1:7582946884171175559:2228]
2025-12-12T12:26:43.667859Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.analyticsQuery.count IS STALE, Refreshing ...
2025-12-12T12:26:43.667871Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.cpuPercent.count IS STALE, Refreshing ...
2025-12-12T12:26:43.667874Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.streamingQuery.count IS STALE, Refreshing ...
2025-12-12T12:26:43.667934Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.cpuPercent.count=0/10000 REFRESHED
2025-12-12T12:26:43.684049Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.cpuPercent.count=0/10000 NOTIFY CHANGE
2025-12-12T12:26:43.710452Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.analyticsQuery.count=0/100 REFRESHED
2025-12-12T12:26:43.710475Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.streamingQuery.count=1/100 REFRESHED
2025-12-12T12:26:43.710498Z :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:26:43.710519Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:103: Cloud id: mock_cloud Quota count: 8
2025-12-12T12:26:43.710545Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudq7ug3b8up2rk3ft"
2025-12-12T12:26:43.710624Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:169: Resolve subject type bootstrap. Token: **** (B6C6F477) Actor id: [1:7582946884171175564:2233]
2025-12-12T12:26:43.710641Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:230: Subject Type: federated_account Token: **** (B6C6F477)
2025-12-12T12:26:43.710657Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudq7ug3b8up2rk3ft"
2025-12-12T12:26:43.710669Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:63: Request actor. Actor id: [1:7582946884171175565:2234]
2025-12-12T12:26:43.710707Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_queries.cpp:641: DescribeQueryRequest: {query_id: "ptqudq7ug3b8up2rk3ft"
} [root@builtin, **** (B6C6F477)] 
2025-12-12T12:26:43.729638Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.analyticsQuery.count=0/100 NOTIFY CHANGE
2025-12-12T12:26:43.729690Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.streamingQuery.count=1/100 NOTIFY CHANGE
2025-12-12T12:26:43.757366Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: DescribeQueryRequest - DescribeQueryResult: {query { meta { common { id: "ptqudq7ug3b8up2rk3ft" created_by: "root@builtin" modified_by: "root@builtin" created_at { seconds: 1765542403 nanos: 398599000 } modified_at { seconds: 1765542403 nanos: 398599000 } revision: 1 } execute_mode: RUN status: STARTING last_job_query_revision: 1 last_job_id: "ptjudq7ug3b8u2caispn-ptqudq7ug3b8up2rk3ft" started_by: "root@builtin" submitted_at { seconds: 1765542403 nanos: 398599000 } } 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 } } } SUCCESS
2025-12-12T12:26:44.139176Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: a265f52-26d65083-401e9fd-55241e9a7, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 66 bytes
2025-12-12T12:26:44.139248Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "a265f52-26d65083-401e9fd-55241e9a7"
host: "ghrun-fhkyrtz6p4"
node_id: 2
}
2025-12-12T12:26:44.147217Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:463: Task (Query): ptqudq7ug3b8up2rk3ft RetryRate: 0 RetryCounter: 0 At: 2025-12-12T12:26:43.498954Z
2025-12-12T12:26:44.263530Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudq7ug3b8up2rk3ft"
2025-12-12T12:26:44.263575Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:305: Resolve folder bootstrap. Folder id: my_folder Actor id: [1:7582946888466142869:2241]
2025-12-12T12:26:44.263591Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:367: Cloud id: mock_cloud Folder id: my_folder
2025-12-12T12:26:44.263606Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:91: Get quotas bootstrap. Cloud id: mock_cloud Actor id: [1:7582946888466142870:2242]
2025-12-12T12:26:44.263621Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.analyticsQuery.count IS STALE, Refreshing ...
2025-12-12T12:26:44.263629Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.cpuPercent.count IS STALE, Refreshing ...
2025-12-12T12:26:44.263632Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.streamingQuery.count IS STALE, Refreshing ...
2025-12-12T12:26:44.263698Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.cpuPercent.count=0/10000 REFRESHED
2025-12-12T12:26:44.273761Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {tasks { query_id { value: "ptqudq7ug3b8up2rk3ft" } job_id { value: "ptjudq7ug3b8u2caispn" } 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:25827" database: "local" } } acl { visibility: PRIVATE } } meta { id: "ptcudq7ug3orttdktg37" created_by: "root@builtin" modified_by: "root@builtin" created_at { seconds: 1765542402 nanos: 953263000 } modified_at { seconds: 1765542402 nanos: 953263000 } 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: 1765628804 nanos: 199500000 } 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: 1765542403 nanos: 398599000 } } } SUCCESS
2025-12-12T12:26:44.273859Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: a265f52-26d65083-401e9fd-55241e9a7, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:26:44.279859Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.analyticsQuery.count=0/100 REFRESHED
2025-12-12T12:26:44.279889Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.streamingQuery.count=1/100 REFRESHED
2025-12-12T12:26:44.279907Z :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:26:44.279927Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:103: Cloud id: mock_cloud Quota count: 8
2025-12-12T12:26:44.279981Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudq7ug3b8up2rk3ft"
2025-12-12T12:26:44.280021Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:169: Resolve subject type bootstrap. Token: **** (B6C6F477) Actor id: [1:7582946888466142875:2247]
2025-12-12T12:26:44.280047Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:230: Subject Type: federated_account Token: **** (B6C6F477)
2025-12-12T12:26:44.280061Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudq7ug3b8up2rk3ft"
2025-12-12T12:26:44.280072Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:63: Request actor. Actor id: [1:7582946888466142876:2248]
2025-12-12T12:26:44.280096Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_queries.cpp:641: DescribeQueryRequest: {query_id: "ptqudq7ug3b8up2rk3ft"
} [root@builtin, **** (B6C6F477)] 
2025-12-12T12:26:44.280772Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: a265f52-26d65083-401e9fd-55241e9a8, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 66 bytes
2025-12-12T12:26:44.280813Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudq7ug3b8up2rk3ft, Owner: a265f52-26d65083-401e9fd-55241e9a7, Request CP::PingTask with size: 126 bytes
2025-12-12T12:26:44.280818Z :YQL_PRIVATE_PROXY DEBUG: rate_limiter_resources.cpp:78: PrivateCreateRateLimiterResource - QueryId: ptqudq7ug3b8up2rk3ft, Owner: a265f52-26d65083-401e9fd-55241e9a7, Request CP::CreateRateLimiterResource with size: 95 bytes
2025-12-12T12:26:44.280849Z :YQ_CONTROL_PLANE_STORAGE TRACE: request_actor.h:57: CreateRateLimiterResourceRequest: {owner_id: "a265f52-26d65083-401e9fd-55241e9a7"
query_id {
  value: "ptqudq7ug3b8up2rk3ft"
}
scope: "yandexcloud://my_folder"
tenant: "/compute"
} 
2025-12-12T12:26:44.281068Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "a265f52-26d65083-401e9fd-55241e9a8"
host: "ghrun-fhkyrtz6p4"
node_id: 2
}
2025-12-12T12:26:44.281134Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "a265f52-26d65083-401e9fd-55241e9a7"
query_id {
  value: "ptqudq7ug3b8up2rk3ft"
}
scope: "yandexcloud://my_folder"
started_at {
  seconds: 1765542404
  nanos: 279000000
}
deadline {
  seconds: 1765628804
  nanos: 199500000
}
tenant: "/compute"
}
2025-12-12T12:26:44.288484Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.cpuPercent.count=0/10000 NOTIFY CHANGE
2025-12-12T12:26:44.295604Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.streamingQuery.count=1/100 NOTIFY CHANGE
2025-12-12T12:26:44.295620Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.analyticsQuery.count=0/100 NOTIFY CHANGE
2025-12-12T12:26:44.295845Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: DescribeQueryRequest - DescribeQueryResult: {query { meta { common { id: "ptqudq7ug3b8up2rk3ft" created_by: "root@builtin" modified_by: "root@builtin" created_at { seconds: 1765542403 nanos: 398599000 } modified_at { seconds: 1765542403 nanos: 398599000 } revision: 1 } execute_mode: RUN status: STARTING last_job_query_revision: 1 last_job_id: "ptjudq7ug3b8u2caispn-ptqudq7ug3b8up2rk3ft" started_by: "root@builtin" submitted_at { seconds: 1765542403 nanos: 398599000 } } 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 } } } SUCCESS
2025-12-12T12:26:44.307567Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:26:44.307612Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: a265f52-26d65083-401e9fd-55241e9a8, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:26:44.339584Z :YQ_CONTROL_PLANE_STORAGE DEBUG: rate_limiter_resources.cpp:74: CreateRateLimiterResourceRequest. Got response from database: SUCCESS
2025-12-12T12:26:44.339726Z :YQ_RATE_LIMITER DEBUG: schema.cpp:71: Run create rate limiter resource "mock_cloud/my_folder/ptqudq7ug3b8up2rk3ft" actor
2025-12-12T12:26:44.339734Z :YQ_RATE_LIMITER DEBUG: schema.cpp:113: Call create rate limiter resource "mock_cloud/my_folder/ptqudq7ug3b8up2rk3ft"
2025-12-12T12:26:44.344002Z :YQ_RATE_LIMITER DEBUG: schema.cpp:261: Trying to recursively create rate limiter resource "mock_cloud/my_folder"
2025-12-12T12:26:44.344014Z :YQ_RATE_LIMITER DEBUG: schema.cpp:113: Call create rate limiter resource "mock_cloud/my_folder"
2025-12-12T12:26:44.346559Z :YQ_RATE_LIMITER DEBUG: schema.cpp:244: Successfully created rate limiter resource "mock_cloud/my_folder"
2025-12-12T12:26:44.346588Z :YQ_RATE_LIMITER DEBUG: schema.cpp:113: Call create rate limiter resource "mock_cloud/my_folder/ptqudq7ug3b8up2rk3ft"
2025-12-12T12:26:44.349671Z :YQ_RATE_LIMITER DEBUG: schema.cpp:155: Successfully created rate limiter resource "mock_cloud/my_folder/ptqudq7ug3b8up2rk3ft"
2025-12-12T12:26:44.349684Z :YQ_RATE_LIMITER DEBUG: schema.cpp:122: Reply for create rate limiter resource "mock_cloud/my_folder/ptqudq7ug3b8up2rk3ft": 
2025-12-12T12:26:44.349717Z :YQ_CONTROL_PLANE_STORAGE DEBUG: rate_limiter_resources.cpp:180: Got create response from rate limiter service
2025-12-12T12:26:44.349735Z :YQL_PRIVATE_PROXY DEBUG: rate_limiter_resources.cpp:102: PrivateCreateRateLimiterResource - QueryId: ptqudq7ug3b8up2rk3ft, Owner: a265f52-26d65083-401e9fd-55241e9a7, Got CP::CreateRateLimiterResourceResponse
2025-12-12T12:26:44.428992Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582946854106404374:2119]
2025-12-12T12:26:44.429016Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:26:44.429034Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582946854106404304:2068]
2025-12-12T12:26:44.429040Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582946854106404304:2068]
2025-12-12T12:26:44.429043Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582946854106404304:2068]
2025-12-12T12:26:44.429059Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:26:44.527377Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {expired_at { seconds: 1765542424 nanos: 443000000 } } SUCCESS
2025-12-12T12:26:44.527464Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudq7ug3b8up2rk3ft, Owner: a265f52-26d65083-401e9fd-55241e9a7, Got CP::PingTaskResponse
2025-12-12T12:26:44.532082Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudq7ug3b8up2rk3ft, Owner: a265f52-26d65083-401e9fd-55241e9a7, Request CP::PingTask with size: 120 bytes
2025-12-12T12:26:44.532176Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "a265f52-26d65083-401e9fd-55241e9a7"
query_id {
  value: "ptqudq7ug3b8up2rk3ft"
}
status: RUNNING
resources {
  rate_limiter: PREPARE
  compilation: PREPARE
}
scope: "yandexcloud://my_folder"
deadline {
  seconds: 1765628804
  nanos: 199500000
}
tenant: "/compute"
}
2025-12-12T12:26:44.558928Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {expired_at { seconds: 1765542424 nanos: 547000000 } } SUCCESS
2025-12-12T12:26:44.558976Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudq7ug3b8up2rk3ft, Owner: a265f52-26d65083-401e9fd-55241e9a7, Got CP::PingTaskResponse
2025-12-12T12:26:44.560659Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudq7ug3b8up2rk3ft, Owner: a265f52-26d65083-401e9fd-55241e9a7, Request CP::PingTask with size: 189 bytes
2025-12-12T12:26:44.560722Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "a265f52-26d65083-401e9fd-55241e9a7"
query_id {
  value: "ptqudq7ug3b8up2rk3ft"
}
status: RUNNING
resources {
  rate_limiter: READY
  compilation: PREPARE
  rate_limiter_path: "local/RateLimiter_df6e7bab-b514-4b78-b17e-e8ee264a681d/rate_limiter"
}
scope: "yandexcloud://my_folder"
deadline {
  seconds: 1765628804
  nanos: 199500000
}
tenant: "/compute"
}
2025-12-12T12:26:44.579434Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {expired_at { seconds: 1765542424 nanos: 569000000 } } SUCCESS
2025-12-12T12:26:44.579501Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudq7ug3b8up2rk3ft, Owner: a265f52-26d65083-401e9fd-55241e9a7, Got CP::PingTaskResponse
2025-12-12T12:26:44.583255Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudq7ug3b8up2rk3ft, Owner: a265f52-26d65083-401e9fd-55241e9a7, Request CP::PingTask with size: 1909 bytes
2025-12-12T12:26:44.583329Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "a265f52-26d65083-401e9fd-55241e9a7"
query_id {
  value: "ptqudq7ug3b8up2rk3ft"
}
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:25827\"))\n(let $8 \'(\'\"SharedReading\" \'\"0\"))\n(let $9 \'(\'\"AddBearerToToken\" \'\"1\"))\n(let $10 \'($7 $8 \'(\'\"ReconnectPeriod\" \'\"\") \'(\'\"Format\" \'\"raw\") \'(\'\"ReadGroup\" \'\"ptcudq7ug3orttdktg37\") $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: 1765628804
  nanos: 199500000
}
tenant: "/compute"
}
2025-12-12T12:26:44.588729Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: b3c34733-fb840005-ab5e9e00-5658733d8, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 68 bytes
2025-12-12T12:26:44.588762Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "b3c34733-fb840005-ab5e9e00-5658733d8"
host: "ghrun-fhkyrtz6p4"
node_id: 1
}
2025-12-12T12:26:44.592963Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:26:44.593003Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: b3c34733-fb840005-ab5e9e00-5658733d8, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:26:44.602896Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {expired_at { seconds: 1765542424 nanos: 591000000 } } SUCCESS
2025-12-12T12:26:44.602989Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudq7ug3b8up2rk3ft, Owner: a265f52-26d65083-401e9fd-55241e9a7, Got CP::PingTaskResponse
2025-12-12T12:26:44.608397Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudq7ug3b8up2rk3ft, Owner: a265f52-26d65083-401e9fd-55241e9a7, Request CP::PingTask with size: 2386 bytes
2025-12-12T12:26:44.608509Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "a265f52-26d65083-401e9fd-55241e9a7"
query_id {
  value: "ptqudq7ug3b8up2rk3ft"
}
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\024ptqudq7ug3b8up2rk3ft\032\017localhost:25827\"\027\n\025cluster:default_myyds*\005local0\002@\001b\004Dataj\025[\"DataType\";\"String\"]\222\001\024ptcudq7ug3orttdktg37\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:25827\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_df6e7bab-b514-4b78-b17e-e8ee264a681d/rate_limiterZ)mock_cloud/my_folder/ptqudq7ug3b8up2rk3ft`\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\024ptqudq7ug3b8up2rk3ft\032\017localhost:25827\"\027\n\025cluster:default_myyds*\005local0\002@\001b\004Dataj\025[\"DataType\";\"String\"]\222\001\024ptcudq7ug3orttdktg37\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:25827\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_df6e7bab-b514-4b78-b17e-e8ee264a681d/rate_limiterZ)mock_cloud/my_folder/ptqudq7ug3b8up2rk3ft`\200\200\200\200 \230\001\000\300\001\0012optqudq7ug3b8up2rk3ft#ptrudq7ug2gcm0ll3vs0#yandexcloud://my_folder#a265f52-26d65083-401e9fd-55241e9a7#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: 1765628804
  nanos: 199500000
}
tenant: "/compute"
}
2025-12-12T12:26:44.624239Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {expired_at { seconds: 1765542424 nanos: 616000000 } } SUCCESS
2025-12-12T12:26:44.624319Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudq7ug3b8up2rk3ft, Owner: a265f52-26d65083-401e9fd-55241e9a7, Got CP::PingTaskResponse
2025-12-12T12:26:44.625361Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudq7ug3b8up2rk3ft, Owner: a265f52-26d65083-401e9fd-55241e9a7, Request CP::PingTask with size: 281 bytes
2025-12-12T12:26:44.625472Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "a265f52-26d65083-401e9fd-55241e9a7"
query_id {
  value: "ptqudq7ug3b8up2rk3ft"
}
status: RUNNING
resources {
  rate_limiter: READY
  compilation: READY
  topic_consumers_state: PREPARE
  rate_limiter_path: "local/RateLimiter_df6e7bab-b514-4b78-b17e-e8ee264a681d/rate_limiter"
  topic_consumers {
    database: "local"
    topic_path: "recovery_input"
    consumer_name: "ptqudq7ug3b8up2rk3ft"
    cluster_endpoint: "localhost:25827"
    token_name: "cluster:default_myyds"
    add_bearer_to_token: true
  }
}
scope: "yandexcloud://my_folder"
deadline {
  seconds: 1765628804
  nanos: 199500000
}
tenant: "/compute"
}
2025-12-12T12:26:44.643545Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {expired_at { seconds: 1765542424 nanos: 635000000 } } SUCCESS
2025-12-12T12:26:44.643592Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudq7ug3b8up2rk3ft, Owner: a265f52-26d65083-401e9fd-55241e9a7, Got CP::PingTaskResponse
2025-12-12T12:26:44.649324Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudq7ug3b8up2rk3ft, Owner: a265f52-26d65083-401e9fd-55241e9a7, Request CP::PingTask with size: 281 bytes
2025-12-12T12:26:44.649460Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "a265f52-26d65083-401e9fd-55241e9a7"
query_id {
  value: "ptqudq7ug3b8up2rk3ft"
}
status: RUNNING
resources {
  rate_limiter: READY
  compilation: READY
  topic_consumers_state: READY
  rate_limiter_path: "local/RateLimiter_df6e7bab-b514-4b78-b17e-e8ee264a681d/rate_limiter"
  topic_consumers {
    database: "local"
    topic_path: "recovery_input"
    consumer_name: "ptqudq7ug3b8up2rk3ft"
    cluster_endpoint: "localhost:25827"
    token_name: "cluster:default_myyds"
    add_bearer_to_token: true
  }
}
scope: "yandexcloud://my_folder"
deadline {
  seconds: 1765628804
  nanos: 199500000
}
tenant: "/compute"
}
2025-12-12T12:26:44.661676Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {expired_at { seconds: 1765542424 nanos: 655000000 } } SUCCESS
2025-12-12T12:26:44.661754Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudq7ug3b8up2rk3ft, Owner: a265f52-26d65083-401e9fd-55241e9a7, Got CP::PingTaskResponse
2025-12-12T12:26:44.799374Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudq7ug3b8up2rk3ft"
2025-12-12T12:26:44.799412Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:305: Resolve folder bootstrap. Folder id: my_folder Actor id: [1:7582946888466142912:2283]
2025-12-12T12:26:44.799428Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:367: Cloud id: mock_cloud Folder id: my_folder
2025-12-12T12:26:44.799439Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:91: Get quotas bootstrap. Cloud id: mock_cloud Actor id: [1:7582946888466142913:2284]
2025-12-12T12:26:44.799455Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.analyticsQuery.count IS STALE, Refreshing ...
2025-12-12T12:26:44.799460Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.cpuPercent.count IS STALE, Refreshing ...
2025-12-12T12:26:44.799462Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.streamingQuery.count IS STALE, Refreshing ...
2025-12-12T12:26:44.799511Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.cpuPercent.count=0/10000 REFRESHED
2025-12-12T12:26:44.816006Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.analyticsQuery.count=0/100 REFRESHED
2025-12-12T12:26:44.816041Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.streamingQuery.count=1/100 REFRESHED
2025-12-12T12:26:44.816073Z :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:26:44.816091Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:103: Cloud id: mock_cloud Quota count: 8
2025-12-12T12:26:44.816168Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudq7ug3b8up2rk3ft"
2025-12-12T12:26:44.816235Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:169: Resolve subject type bootstrap. Token: **** (B6C6F477) Actor id: [1:7582946888466142918:2289]
2025-12-12T12:26:44.816262Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:230: Subject Type: federated_account Token: **** (B6C6F477)
2025-12-12T12:26:44.816277Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudq7ug3b8up2rk3ft"
2025-12-12T12:26:44.816298Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:63: Request actor. Actor id: [1:7582946888466142919:2290]
2025-12-12T12:26:44.816328Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_queries.cpp:641: DescribeQueryRequest: {query_id: "ptqudq7ug3b8up2rk3ft"
} [root@builtin, **** (B6C6F477)] 
2025-12-12T12:26:44.822765Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: DescribeQueryRequest - DescribeQueryResult: {query { meta { common { id: "ptqudq7ug3b8up2rk3ft" created_by: "root@builtin" modified_by: "root@builtin" created_at { seconds: 1765542403 nanos: 398599000 } modified_at { seconds: 1765542403 nanos: 398599000 } revision: 1 } started_at { seconds: 1765542404 nanos: 279000000 } execute_mode: RUN status: RUNNING last_job_query_revision: 1 last_job_id: "ptjudq7ug3b8u2caispn-ptqudq7ug3b8up2rk3ft" started_by: "root@builtin" submitted_at { seconds: 1765542403 nanos: 398599000 } } 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}]}}" } 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:25827\"))\n(let $8 \'(\'\"SharedReading\" \'\"0\"))\n(let $9 \'(\'\"AddBearerToToken\" \'\"1\"))\n(let $10 \'($7 $8 \'(\'\"ReconnectPeriod\" \'\"\") \'(\'\"Format\" \'\"raw\") \'(\'\"ReadGroup\" \'\"ptcudq7ug3orttdktg37\") $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:26:44.828881Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.cpuPercent.count=0/10000 NOTIFY CHANGE
2025-12-12T12:26:44.842861Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.streamingQuery.count=1/100 NOTIFY CHANGE
2025-12-12T12:26:44.842911Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.analyticsQuery.count=0/100 NOTIFY CHANGE
2025-12-12T12:26:45.058952Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudq7ug3b8up2rk3ft, Owner: a265f52-26d65083-401e9fd-55241e9a7, Request CP::PingTask with size: 119 bytes
2025-12-12T12:26:45.059052Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "a265f52-26d65083-401e9fd-55241e9a7"
query_id {
  value: "ptqudq7ug3b8up2rk3ft"
}
state_load_mode: FROM_LAST_CHECKPOINT
disposition {
  from_last_checkpoint {
  }
}
scope: "yandexcloud://my_folder"
deadline {
  seconds: 1765628804
  nanos: 199500000
}
tenant: "/compute"
}
2025-12-12T12:26:45.087275Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {expired_at { seconds: 1765542425 nanos: 75000000 } } SUCCESS
2025-12-12T12:26:45.087393Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudq7ug3b8up2rk3ft, Owner: a265f52-26d65083-401e9fd-55241e9a7, Got CP::PingTaskResponse
2025-12-12T12:26:45.139599Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: a265f52-26d65083-401e9fd-55241e9a9, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 66 bytes
2025-12-12T12:26:45.139668Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "a265f52-26d65083-401e9fd-55241e9a9"
host: "ghrun-fhkyrtz6p4"
node_id: 2
}
2025-12-12T12:26:45.149419Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:26:45.149508Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: a265f52-26d65083-401e9fd-55241e9a9, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:26:45.439718Z :FQ_CONTROL_PLANE_CONFIG TRACE: control_plane_config.cpp:192: LOADED TenantInfo: State NOT changed
2025-12-12T12:26:45.588838Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: b3c34733-fb840005-ab5e9e00-5658733d9, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 68 bytes
2025-12-12T12:26:45.588887Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "b3c34733-fb840005-ab5e9e00-5658733d9"
host: "ghrun-fhkyrtz6p4"
node_id: 1
}
2025-12-12T12:26:45.594192Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:26:45.594261Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: b3c34733-fb840005-ab5e9e00-5658733d9, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:26:45.683147Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudq7ug3b8up2rk3ft, Owner: a265f52-26d65083-401e9fd-55241e9a7, Request CP::PingTask with size: 439 bytes
2025-12-12T12:26:45.683246Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "a265f52-26d65083-401e9fd-55241e9a7"
query_id {
  value: "ptqudq7ug3b8up2rk3ft"
}
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: 1765628804
  nanos: 199500000
}
tenant: "/compute"
}
2025-12-12T12:26:45.786963Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {expired_at { seconds: 1765542425 nanos: 694000000 } } SUCCESS
2025-12-12T12:26:45.787016Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudq7ug3b8up2rk3ft, Owner: a265f52-26d65083-401e9fd-55241e9a7, Got CP::PingTaskResponse
2025-12-12T12:26:46.141053Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: a265f52-26d65083-401e9fd-55241e9a10, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 67 bytes
2025-12-12T12:26:46.141109Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "a265f52-26d65083-401e9fd-55241e9a10"
host: "ghrun-fhkyrtz6p4"
node_id: 2
}
2025-12-12T12:26:46.143760Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:26:46.143811Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: a265f52-26d65083-401e9fd-55241e9a10, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:26:46.425407Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:599: Coordinator: Send TEvGetNodesRequest to NodesManager
2025-12-12T12:26:46.425442Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:416: Coordinator: TEvUndelivered, ev: TSystem::Undelivered
2025-12-12T12:26:46.425445Z :FQ_ROW_DISPATCHER INFO: coordinator.cpp:419: Coordinator: TEvUndelivered, from nodes manager, reason: ActorUnknown
2025-12-12T12:26:46.430452Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582946854106404374:2119]
2025-12-12T12:26:46.430473Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:26:46.430479Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582946854106404304:2068]
2025-12-12T12:26:46.430483Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582946854106404304:2068]
2025-12-12T12:26:46.430486Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582946854106404304:2068]
2025-12-12T12:26:46.430496Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:26:46.687614Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudq7ug3b8up2rk3ft, Owner: a265f52-26d65083-401e9fd-55241e9a7, Request CP::PingTask with size: 439 bytes
2025-12-12T12:26:46.687686Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "a265f52-26d65083-401e9fd-55241e9a7"
query_id {
  value: "ptqudq7ug3b8up2rk3ft"
}
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: 1765628804
  nanos: 199500000
}
tenant: "/compute"
}
2025-12-12T12:26:46.706096Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {expired_at { seconds: 1765542426 nanos: 695000000 } } SUCCESS
2025-12-12T12:26:46.706184Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudq7ug3b8up2rk3ft, Owner: a265f52-26d65083-401e9fd-55241e9a7, Got CP::PingTaskResponse
2025-12-12T12:26:47.143404Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: a265f52-26d65083-401e9fd-55241e9a11, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 67 bytes
2025-12-12T12:26:47.143451Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "a265f52-26d65083-401e9fd-55241e9a11"
host: "ghrun-fhkyrtz6p4"
node_id: 2
}
2025-12-12T12:26:47.147634Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:26:47.147707Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: a265f52-26d65083-401e9fd-55241e9a11, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:26:47.684246Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudq7ug3b8up2rk3ft, Owner: a265f52-26d65083-401e9fd-55241e9a7, Request CP::PingTask with size: 439 bytes
2025-12-12T12:26:47.684312Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "a265f52-26d65083-401e9fd-55241e9a7"
query_id {
  value: "ptqudq7ug3b8up2rk3ft"
}
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: 1765628804
  nanos: 199500000
}
tenant: "/compute"
}
2025-12-12T12:26:47.701607Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {expired_at { seconds: 1765542427 nanos: 690000000 } } SUCCESS
2025-12-12T12:26:47.701639Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudq7ug3b8up2rk3ft, Owner: a265f52-26d65083-401e9fd-55241e9a7, Got CP::PingTaskResponse
2025-12-12T12:26:47.993267Z :YQ_CONTROL_PLANE_STORAGE TRACE: nodes_health_check.cpp:38: NodesHealthCheckRequest: {tenant: "/compute"
node {
  node_id: 1
  instance_id: "616217a3-42973493-2bb880be-eeae5a03"
  hostname: "ghrun-fhkyrtz6p4"
  interconnect_port: 15973
  node_address: "127.0.1.1"
}
}
2025-12-12T12:26:47.993283Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 20bca8ce-62d8e9de-ef95b538-169f99411, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 68 bytes
2025-12-12T12:26:47.993336Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "20bca8ce-62d8e9de-ef95b538-169f99411"
host: "ghrun-fhkyrtz6p4"
node_id: 1
}
2025-12-12T12:26:47.998752Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:26:47.998839Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 20bca8ce-62d8e9de-ef95b538-169f99411, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:26:48.014438Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: NodesHealthCheckRequest - NodesHealthCheckResult: {nodes { node_id: 1 instance_id: "616217a3-42973493-2bb880be-eeae5a03" hostname: "ghrun-fhkyrtz6p4" node_address: "127.0.1.1" } nodes { node_id: 2 instance_id: "f5d68a68-4a2b5323-f53e77ab-616b5055" hostname: "ghrun-fhkyrtz6p4" interconnect_port: 31922 node_address: "127.0.1.1" } } SUCCESS
2025-12-12T12:26:48.136146Z :YQ_CONTROL_PLANE_STORAGE TRACE: nodes_health_check.cpp:38: NodesHealthCheckRequest: {tenant: "/compute"
node {
  node_id: 2
  instance_id: "f5d68a68-4a2b5323-f53e77ab-616b5055"
  hostname: "ghrun-fhkyrtz6p4"
  active_workers: 1
  memory_allocated: 8589934592
  interconnect_port: 31922
  node_address: "127.0.1.1"
}
}
2025-12-12T12:26:48.143144Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: a265f52-26d65083-401e9fd-55241e9a12, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 67 bytes
2025-12-12T12:26:48.143198Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "a265f52-26d65083-401e9fd-55241e9a12"
host: "ghrun-fhkyrtz6p4"
node_id: 2
}
2025-12-12T12:26:48.151227Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:26:48.151297Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: a265f52-26d65083-401e9fd-55241e9a12, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:26:48.152296Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: NodesHealthCheckRequest - NodesHealthCheckResult: {nodes { node_id: 2 instance_id: "f5d68a68-4a2b5323-f53e77ab-616b5055" hostname: "ghrun-fhkyrtz6p4" active_workers: 1 memory_allocated: 8589934592 node_address: "127.0.1.1" } nodes { node_id: 1 instance_id: "616217a3-42973493-2bb880be-eeae5a03" hostname: "ghrun-fhkyrtz6p4" interconnect_port: 15973 node_address: "127.0.1.1" } } SUCCESS
2025-12-12T12:26:48.431340Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582946854106404374:2119]
2025-12-12T12:26:48.431371Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:26:48.431390Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582946854106404304:2068]
2025-12-12T12:26:48.431395Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582946854106404304:2068]
2025-12-12T12:26:48.431398Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582946854106404304:2068]
2025-12-12T12:26:48.431404Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:26:48.441068Z :FQ_CONTROL_PLANE_CONFIG TRACE: control_plane_config.cpp:192: LOADED TenantInfo: State NOT changed
2025-12-12T12:26:48.594796Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudq7ug3b8up2rk3ft, Owner: a265f52-26d65083-401e9fd-55241e9a7, Request CP::PingTask with size: 1103 bytes
2025-12-12T12:26:48.594908Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "a265f52-26d65083-401e9fd-55241e9a7"
query_id {
  value: "ptqudq7ug3b8up2rk3ft"
}
result_id {
  value: "ptrudq7ug2gcm0ll3vs0"
}
status: RUNNING
statistics: "{\"Graph=0\":{\"Actor\":{\"ActorCreateTimeUs\":{\"sum\":\"27ms\",\"count\":2,\"avg\":\"13ms\",\"max\":\"27ms\",\"min\":\"202us\"}},\"AllocateWorkersUs\":{\"sum\":\"28ms\",\"count\":1,\"avg\":\"28ms\",\"max\":\"28ms\",\"min\":\"28ms\"},\"ExecutionTimeUs\":{\"sum\":\"3.91s\",\"count\":1,\"avg\":\"3.91s\",\"max\":\"3.91s\",\"min\":\"3.91s\"},\"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\":2,\"count\":1,\"avg\":2,\"max\":2,\"min\":2}}}"
resign_query: true
transient_issues {
  message: "Undelivered Event 276037634 from [2:7582946885904530405:2194] (Self) to [1:7582946888736046524:3647] Reason: ActorUnknown Cookie: 0"
  severity: 1
}
status_code: UNAVAILABLE
resources {
  rate_limiter: READY
  compilation: READY
  topic_consumers_state: READY
  rate_limiter_path: "local/RateLimiter_df6e7bab-b514-4b78-b17e-e8ee264a681d/rate_limiter"
  topic_consumers {
    database: "local"
    topic_path: "recovery_input"
    consumer_name: "ptqudq7ug3b8up2rk3ft"
    cluster_endpoint: "localhost:25827"
    token_name: "cluster:default_myyds"
    add_bearer_to_token: true
  }
}
scope: "yandexcloud://my_folder"
deadline {
  seconds: 1765628804
  nanos: 199500000
}
tenant: "/compute"
}
2025-12-12T12:26:48.608359Z :YQ_CONTROL_PLANE_STORAGE DEBUG: task_ping.cpp:427: PingTaskRequest (resign):  UNAVAILABLE 1 2025-12-12T12:26:48.608323Z 0.000000s
2025-12-12T12:26:48.729979Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {expired_at { seconds: 1765542408 nanos: 608000000 } } SUCCESS
2025-12-12T12:26:48.730027Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudq7ug3b8up2rk3ft, Owner: a265f52-26d65083-401e9fd-55241e9a7, Got CP::PingTaskResponse
2025-12-12T12:26:48.976845Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 20bca8ce-62d8e9de-ef95b538-169f99412, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 68 bytes
2025-12-12T12:26:48.976895Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "20bca8ce-62d8e9de-ef95b538-169f99412"
host: "ghrun-fhkyrtz6p4"
node_id: 1
}
2025-12-12T12:26:48.980613Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:463: Task (Query): ptqudq7ug3b8up2rk3ft RetryRate: 0.9988172762 RetryCounter: 1 At: 2025-12-12T12:26:48.608323Z
2025-12-12T12:26:48.997828Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {tasks { query_id { value: "ptqudq7ug3b8up2rk3ft" } job_id { value: "ptjudq7ug3b8u2caispn" } 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\024ptqudq7ug3b8up2rk3ft\032\017localhost:25827\"\027\n\025cluster:default_myyds*\005local0\002@\001b\004Dataj\025[\"DataType\";\"String\"]\222\001\024ptcudq7ug3orttdktg37\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:25827\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_df6e7bab-b514-4b78-b17e-e8ee264a681d/rate_limiterZ)mock_cloud/my_folder/ptqudq7ug3b8up2rk3ft`\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\024ptqudq7ug3b8up2rk3ft\032\017localhost:25827\"\027\n\025cluster:default_myyds*\005local0\002@\001b\004Dataj\025[\"DataType\";\"String\"]\222\001\024ptcudq7ug3orttdktg37\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:25827\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_df6e7bab-b514-4b78-b17e-e8ee264a681d/rate_limiterZ)mock_cloud/my_folder/ptqudq7ug3b8up2rk3ft`\200\200\200\200 \230\001\000\300\001\0012optqudq7ug3b8up2rk3ft#ptrudq7ug2gcm0ll3vs0#yandexcloud://my_folder#a265f52-26d65083-401e9fd-55241e9a7#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:25827" datab...} SUCCESS
2025-12-12T12:26:48.997898Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 20bca8ce-62d8e9de-ef95b538-169f99412, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:26:49.003494Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 20bca8ce-62d8e9de-ef95b538-169f99413, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 68 bytes
2025-12-12T12:26:49.003520Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudq7ug3b8up2rk3ft, Owner: 20bca8ce-62d8e9de-ef95b538-169f99412, Request CP::PingTask with size: 282 bytes
2025-12-12T12:26:49.003553Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "20bca8ce-62d8e9de-ef95b538-169f99413"
host: "ghrun-fhkyrtz6p4"
node_id: 1
}
2025-12-12T12:26:49.003681Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "20bca8ce-62d8e9de-ef95b538-169f99412"
query_id {
  value: "ptqudq7ug3b8up2rk3ft"
}
resources {
  rate_limiter: READY
  compilation: READY
  topic_consumers_state: READY
  rate_limiter_path: "local/RateLimiter_df6e7bab-b514-4b78-b17e-e8ee264a681d/rate_limiter"
  topic_consumers {
    database: "local"
    topic_path: "recovery_input"
    consumer_name: "ptqudq7ug3b8up2rk3ft"
    cluster_endpoint: "localhost:25827"
    token_name: "cluster:default_myyds"
    add_bearer_to_token: true
  }
}
scope: "yandexcloud://my_folder"
deadline {
  seconds: 1765628808
  nanos: 988819000
}
tenant: "/compute"
}
2025-12-12T12:26:49.010059Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:26:49.010125Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 20bca8ce-62d8e9de-ef95b538-169f99413, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:26:49.029622Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {expired_at { seconds: 1765542429 nanos: 17000000 } } SUCCESS
2025-12-12T12:26:49.029678Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudq7ug3b8up2rk3ft, Owner: 20bca8ce-62d8e9de-ef95b538-169f99412, Got CP::PingTaskResponse
2025-12-12T12:26:49.146459Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: a265f52-26d65083-401e9fd-55241e9a13, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 67 bytes
2025-12-12T12:26:49.146522Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "a265f52-26d65083-401e9fd-55241e9a13"
host: "ghrun-fhkyrtz6p4"
node_id: 2
}
2025-12-12T12:26:49.149746Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:26:49.149798Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: a265f52-26d65083-401e9fd-55241e9a13, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:26:49.978752Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 20bca8ce-62d8e9de-ef95b538-169f99414, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 68 bytes
2025-12-12T12:26:49.978825Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "20bca8ce-62d8e9de-ef95b538-169f99414"
host: "ghrun-fhkyrtz6p4"
node_id: 1
}
2025-12-12T12:26:49.981474Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:26:49.981538Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 20bca8ce-62d8e9de-ef95b538-169f99414, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:26:50.060298Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudq7ug3b8up2rk3ft, Owner: 20bca8ce-62d8e9de-ef95b538-169f99412, Request CP::PingTask with size: 442 bytes
2025-12-12T12:26:50.060380Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "20bca8ce-62d8e9de-ef95b538-169f99412"
query_id {
  value: "ptqudq7ug3b8up2rk3ft"
}
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: 1765628808
  nanos: 988819000
}
tenant: "/compute"
}
2025-12-12T12:26:50.080779Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {expired_at { seconds: 1765542430 nanos: 71000000 } } SUCCESS
2025-12-12T12:26:50.080862Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudq7ug3b8up2rk3ft, Owner: 20bca8ce-62d8e9de-ef95b538-169f99412, Got CP::PingTaskResponse
2025-12-12T12:26:50.145769Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: a265f52-26d65083-401e9fd-55241e9a14, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 67 bytes
2025-12-12T12:26:50.145813Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "a265f52-26d65083-401e9fd-55241e9a14"
host: "ghrun-fhkyrtz6p4"
node_id: 2
}
2025-12-12T12:26:50.153612Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:26:50.153655Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: a265f52-26d65083-401e9fd-55241e9a14, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:26:50.432250Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582946854106404374:2119]
2025-12-12T12:26:50.432279Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:26:50.432336Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582946854106404304:2068]
2025-12-12T12:26:50.432354Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582946854106404304:2068]
2025-12-12T12:26:50.432358Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582946854106404304:2068]
2025-12-12T12:26:50.432367Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:26:50.979655Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 20bca8ce-62d8e9de-ef95b538-169f99415, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 68 bytes
2025-12-12T12:26:50.979718Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "20bca8ce-62d8e9de-ef95b538-169f99415"
host: "ghrun-fhkyrtz6p4"
node_id: 1
}
2025-12-12T12:26:50.988281Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:26:50.988381Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 20bca8ce-62d8e9de-ef95b538-169f99415, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:26:51.060771Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudq7ug3b8up2rk3ft, Owner: 20bca8ce-62d8e9de-ef95b538-169f99412, Request CP::PingTask with size: 442 bytes
2025-12-12T12:26:51.060848Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "20bca8ce-62d8e9de-ef95b538-169f99412"
query_id {
  value: "ptqudq7ug3b8up2rk3ft"
}
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: 1765628808
  nanos: 988819000
}
tenant: "/compute"
}
2025-12-12T12:26:51.089083Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {expired_at { seconds: 1765542431 nanos: 77000000 } } SUCCESS
2025-12-12T12:26:51.089211Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudq7ug3b8up2rk3ft, Owner: 20bca8ce-62d8e9de-ef95b538-169f99412, Got CP::PingTaskResponse
2025-12-12T12:26:51.443524Z :FQ_CONTROL_PLANE_CONFIG TRACE: control_plane_config.cpp:192: LOADED TenantInfo: State NOT changed
2025-12-12T12:26:51.984320Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 20bca8ce-62d8e9de-ef95b538-169f99416, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 68 bytes
2025-12-12T12:26:51.984365Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "20bca8ce-62d8e9de-ef95b538-169f99416"
host: "ghrun-fhkyrtz6p4"
node_id: 1
}
2025-12-12T12:26:51.993563Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:26:51.993634Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 20bca8ce-62d8e9de-ef95b538-169f99416, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:26:52.022721Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 98aed2a1-72ca4129-b8aeede3-59d0649b1, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 68 bytes
2025-12-12T12:26:52.022771Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "98aed2a1-72ca4129-b8aeede3-59d0649b1"
host: "ghrun-fhkyrtz6p4"
node_id: 2
}
2025-12-12T12:26:52.022847Z :YQ_CONTROL_PLANE_STORAGE TRACE: nodes_health_check.cpp:38: NodesHealthCheckRequest: {tenant: "/compute"
node {
  node_id: 2
  instance_id: "5a3583cc-469446b2-f2966fb6-df4dc0c8"
  hostname: "ghrun-fhkyrtz6p4"
  interconnect_port: 31922
  node_address: "127.0.1.1"
}
}
2025-12-12T12:26:52.035281Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:26:52.035350Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 98aed2a1-72ca4129-b8aeede3-59d0649b1, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:26:52.051094Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: NodesHealthCheckRequest - NodesHealthCheckResult: {nodes { node_id: 2 instance_id: "5a3583cc-469446b2-f2966fb6-df4dc0c8" hostname: "ghrun-fhkyrtz6p4" node_address: "127.0.1.1" } nodes { node_id: 1 instance_id: "616217a3-42973493-2bb880be-eeae5a03" hostname: "ghrun-fhkyrtz6p4" interconnect_port: 15973 node_address: "127.0.1.1" } } SUCCESS
2025-12-12T12:26:52.061312Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudq7ug3b8up2rk3ft, Owner: 20bca8ce-62d8e9de-ef95b538-169f99412, Request CP::PingTask with size: 442 bytes
2025-12-12T12:26:52.061383Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "20bca8ce-62d8e9de-ef95b538-169f99412"
query_id {
  value: "ptqudq7ug3b8up2rk3ft"
}
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: 1765628808
  nanos: 988819000
}
tenant: "/compute"
}
2025-12-12T12:26:52.081262Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {expired_at { seconds: 1765542432 nanos: 69000000 } } SUCCESS
2025-12-12T12:26:52.081348Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudq7ug3b8up2rk3ft, Owner: 20bca8ce-62d8e9de-ef95b538-169f99412, Got CP::PingTaskResponse
2025-12-12T12:26:52.222248Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudq7ug3b8up2rk3ft, Owner: 20bca8ce-62d8e9de-ef95b538-169f99412, Request CP::PingTask with size: 1102 bytes
2025-12-12T12:26:52.222405Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "20bca8ce-62d8e9de-ef95b538-169f99412"
query_id {
  value: "ptqudq7ug3b8up2rk3ft"
}
result_id {
  value: "ptrudq7ufu0bnknh2deu"
}
statistics: "{\"Graph=0\":{\"Actor\":{\"ActorCreateTimeUs\":{\"sum\":\"60ms\",\"count\":2,\"avg\":\"30ms\",\"max\":\"59ms\",\"min\":\"1ms\"}},\"AllocateWorkersUs\":{\"sum\":\"60ms\",\"count\":1,\"avg\":\"60ms\",\"max\":\"60ms\",\"min\":\"60ms\"},\"ExecutionTimeUs\":{\"sum\":\"3.15s\",\"count\":1,\"avg\":\"3.15s\",\"max\":\"3.15s\",\"min\":\"3.15s\"},\"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\":2,\"count\":1,\"avg\":2,\"max\":2,\"min\":2}}}"
resign_query: true
transient_issues {
  message: "Undelivered Event 276037632 from [1:7582946903579382806:2252] (Self) to [2:7582946907379366959:2210] Reason: ActorUnknown Cookie: 0"
  severity: 1
}
status_code: UNAVAILABLE
resources {
  rate_limiter: READY
  compilation: READY
  topic_consumers_state: READY
  rate_limiter_path: "local/RateLimiter_df6e7bab-b514-4b78-b17e-e8ee264a681d/rate_limiter"
  topic_consumers {
    database: "local"
    topic_path: "recovery_input"
    consumer_name: "ptqudq7ug3b8up2rk3ft"
    cluster_endpoint: "localhost:25827"
    token_name: "cluster:default_myyds"
    add_bearer_to_token: true
  }
}
scope: "yandexcloud://my_folder"
deadline {
  seconds: 1765628808
  nanos: 988819000
}
tenant: "/compute"
}
2025-12-12T12:26:52.227556Z :YQ_CONTROL_PLANE_STORAGE DEBUG: task_ping.cpp:427: PingTaskRequest (resign):  UNAVAILABLE 2 2025-12-12T12:26:52.227525Z 0.000000s
2025-12-12T12:26:52.237340Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {expired_at { seconds: 1765542412 nanos: 227000000 } } SUCCESS
2025-12-12T12:26:52.237361Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudq7ug3b8up2rk3ft, Owner: 20bca8ce-62d8e9de-ef95b538-169f99412, Got CP::PingTaskResponse
2025-12-12T12:26:52.433119Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582946854106404374:2119]
2025-12-12T12:26:52.433149Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:26:52.433790Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582946854106404304:2068]
2025-12-12T12:26:52.433795Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582946854106404304:2068]
2025-12-12T12:26:52.433798Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582946854106404304:2068]
2025-12-12T12:26:52.433805Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:26:52.979346Z :YQ_CONTROL_PLANE_STORAGE TRACE: nodes_health_check.cpp:38: NodesHealthCheckRequest: {tenant: "/compute"
node {
  node_id: 1
  instance_id: "616217a3-42973493-2bb880be-eeae5a03"
  hostname: "ghrun-fhkyrtz6p4"
  interconnect_port: 15973
  node_address: "127.0.1.1"
}
}
2025-12-12T12:26:52.984598Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 20bca8ce-62d8e9de-ef95b538-169f99417, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 68 bytes
2025-12-12T12:26:52.984658Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "20bca8ce-62d8e9de-ef95b538-169f99417"
host: "ghrun-fhkyrtz6p4"
node_id: 1
}
2025-12-12T12:26:52.990000Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 98aed2a1-72ca4129-b8aeede3-59d0649b2, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 68 bytes
2025-12-12T12:26:52.990052Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "98aed2a1-72ca4129-b8aeede3-59d0649b2"
host: "ghrun-fhkyrtz6p4"
node_id: 2
}
2025-12-12T12:26:52.991260Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:463: Task (Query): ptqudq7ug3b8up2rk3ft RetryRate: 1.997979498 RetryCounter: 2 At: 2025-12-12T12:26:52.227525Z
2025-12-12T12:26:52.995227Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:463: Task (Query): ptqudq7ug3b8up2rk3ft RetryRate: 1.997979498 RetryCounter: 2 At: 2025-12-12T12:26:52.227525Z
2025-12-12T12:26:53.000149Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: NodesHealthCheckRequest - NodesHealthCheckResult: {nodes { node_id: 1 instance_id: "616217a3-42973493-2bb880be-eeae5a03" hostname: "ghrun-fhkyrtz6p4" node_address: "127.0.1.1" } nodes { node_id: 2 instance_id: "5a3583cc-469446b2-f2966fb6-df4dc0c8" hostname: "ghrun-fhkyrtz6p4" interconnect_port: 31922 node_address: "127.0.1.1" } } SUCCESS
2025-12-12T12:26:53.008489Z :YQ_CONTROL_PLANE_STORAGE WARN: ydb_control_plane_storage.cpp:601: DB Error, Status: ABORTED, Issues: [ { <main>: Error: Transaction locks invalidated. Table: `local/DbPoolStorage_df6e7bab-b514-4b78-b17e-e8ee264a681d/queries`, code: 2001 } { <main>: Error: tx has deferred effects, but locks are broken } ], Query: --!syntax_v1
-- Query name: GetTask(write)
PRAGMA TablePathPrefix("local/DbPoolStorage_df6e7bab-b514-4b78-b17e-e8ee264a681d");
DECLARE $tenant as String;
DECLARE $scope as String;
DECLARE $query_id as String;
DECLARE $query as String;
DECLARE $internal as String;
DECLARE $host as String;
DECLARE $owner as String;
DECLARE $now as Timestamp;
DECLARE $ttl as Timestamp;
DECLARE $retry_counter as Uint64;
DECLARE $generation as Uint64;
DECLARE $retry_counter_update_time as Timestamp;
DECLARE $retry_rate as Double;


UPDATE `queries` SET `generation` = $generation, `query` = $query, `internal` = $internal
WHERE `scope` = $scope AND `query_id` = $query_id;
UPDATE `pending_small` SET `last_seen_at` = $now, `assigned_until` = $ttl,
`retry_counter` = $retry_counter, `retry_counter_updated_at` = $retry_counter_update_time, `retry_rate` = $retry_rate,
`hostname` = $host, `owner` = $owner
WHERE `tenant` = $tenant AND `scope` = $scope AND `query_id` = $query_id;
2025-12-12T12:26:53.008964Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:26:53.009059Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 98aed2a1-72ca4129-b8aeede3-59d0649b2, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:26:53.009094Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {tasks { query_id { value: "ptqudq7ug3b8up2rk3ft" } job_id { value: "ptjudq7ug3b8u2caispn" } generation: 3 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\024ptqudq7ug3b8up2rk3ft\032\017localhost:25827\"\027\n\025cluster:default_myyds*\005local0\002@\001b\004Dataj\025[\"DataType\";\"String\"]\222\001\024ptcudq7ug3orttdktg37\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:25827\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_df6e7bab-b514-4b78-b17e-e8ee264a681d/rate_limiterZ)mock_cloud/my_folder/ptqudq7ug3b8up2rk3ft`\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\024ptqudq7ug3b8up2rk3ft\032\017localhost:25827\"\027\n\025cluster:default_myyds*\005local0\002@\001b\004Dataj\025[\"DataType\";\"String\"]\222\001\024ptcudq7ug3orttdktg37\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:25827\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_df6e7bab-b514-4b78-b17e-e8ee264a681d/rate_limiterZ)mock_cloud/my_folder/ptqudq7ug3b8up2rk3ft`\200\200\200\200 \230\001\000\300\001\0012optqudq7ug3b8up2rk3ft#ptrudq7ug2gcm0ll3vs0#yandexcloud://my_folder#a265f52-26d65083-401e9fd-55241e9a7#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:25827" datab...} SUCCESS
2025-12-12T12:26:53.009200Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 20bca8ce-62d8e9de-ef95b538-169f99417, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:26:53.015339Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 20bca8ce-62d8e9de-ef95b538-169f99418, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 68 bytes
2025-12-12T12:26:53.015411Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "20bca8ce-62d8e9de-ef95b538-169f99418"
host: "ghrun-fhkyrtz6p4"
node_id: 1
}
2025-12-12T12:26:53.015492Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudq7ug3b8up2rk3ft, Owner: 20bca8ce-62d8e9de-ef95b538-169f99417, Request CP::PingTask with size: 282 bytes
2025-12-12T12:26:53.015573Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "20bca8ce-62d8e9de-ef95b538-169f99417"
query_id {
  value: "ptqudq7ug3b8up2rk3ft"
}
resources {
  rate_limiter: READY
  compilation: READY
  topic_consumers_state: READY
  rate_limiter_path: "local/RateLimiter_df6e7bab-b514-4b78-b17e-e8ee264a681d/rate_limiter"
  topic_consumers {
    database: "local"
    topic_path: "recovery_input"
    consumer_name: "ptqudq7ug3b8up2rk3ft"
    cluster_endpoint: "localhost:25827"
    token_name: "cluster:default_myyds"
    add_bearer_to_token: true
  }
}
scope: "yandexcloud://my_folder"
deadline {
  seconds: 1765628812
  nanos: 999450000
}
tenant: "/compute"
}
2025-12-12T12:26:53.023307Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:26:53.023392Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 20bca8ce-62d8e9de-ef95b538-169f99418, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:26:53.033201Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {expired_at { seconds: 1765542433 nanos: 23000000 } } SUCCESS
2025-12-12T12:26:53.033254Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudq7ug3b8up2rk3ft, Owner: 20bca8ce-62d8e9de-ef95b538-169f99417, Got CP::PingTaskResponse
2025-12-12T12:26:53.987247Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 20bca8ce-62d8e9de-ef95b538-169f99419, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 68 bytes
2025-12-12T12:26:53.987324Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "20bca8ce-62d8e9de-ef95b538-169f99419"
host: "ghrun-fhkyrtz6p4"
node_id: 1
}
2025-12-12T12:26:53.989049Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 98aed2a1-72ca4129-b8aeede3-59d0649b3, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 68 bytes
2025-12-12T12:26:53.989094Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "98aed2a1-72ca4129-b8aeede3-59d0649b3"
host: "ghrun-fhkyrtz6p4"
node_id: 2
}
2025-12-12T12:26:53.995575Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:26:53.995713Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:26:53.995752Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 20bca8ce-62d8e9de-ef95b538-169f99419, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:26:53.995768Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 98aed2a1-72ca4129-b8aeede3-59d0649b3, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:26:54.044854Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudq7ug3b8up2rk3ft, Owner: 20bca8ce-62d8e9de-ef95b538-169f99417, Request CP::PingTask with size: 442 bytes
2025-12-12T12:26:54.044929Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "20bca8ce-62d8e9de-ef95b538-169f99417"
query_id {
  value: "ptqudq7ug3b8up2rk3ft"
}
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: 1765628812
  nanos: 999450000
}
tenant: "/compute"
}
2025-12-12T12:26:54.063997Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {expired_at { seconds: 1765542434 nanos: 55000000 } } SUCCESS
2025-12-12T12:26:54.064097Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudq7ug3b8up2rk3ft, Owner: 20bca8ce-62d8e9de-ef95b538-169f99417, Got CP::PingTaskResponse
2025-12-12T12:26:54.222928Z :TICKET_PARSER DEBUG: ticket_parser_impl.h:1875: Ticket **** (B6C6F477) (ipv6:[::1]:46556) has now valid token of root@builtin
2025-12-12T12:26:54.223036Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:1061: ControlQueryRequest: query_id: "ptqudq7ug3b8up2rk3ft"
action: ABORT
2025-12-12T12:26:54.223076Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:305: Resolve folder bootstrap. Folder id: my_folder Actor id: [1:7582946931415815994:2404]
2025-12-12T12:26:54.223090Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:367: Cloud id: mock_cloud Folder id: my_folder
2025-12-12T12:26:54.223111Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:91: Get quotas bootstrap. Cloud id: mock_cloud Actor id: [1:7582946931415815995:2405]
2025-12-12T12:26:54.223142Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.analyticsQuery.count IS STALE, Refreshing ...
2025-12-12T12:26:54.223154Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.cpuPercent.count IS STALE, Refreshing ...
2025-12-12T12:26:54.223162Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.streamingQuery.count IS STALE, Refreshing ...
2025-12-12T12:26:54.223177Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.cpuPercent.count=0/10000 REFRESHED
2025-12-12T12:26:54.235342Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.cpuPercent.count=0/10000 NOTIFY CHANGE
2025-12-12T12:26:54.235357Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.analyticsQuery.count=0/100 REFRESHED
2025-12-12T12:26:54.235370Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.streamingQuery.count=1/100 REFRESHED
2025-12-12T12:26:54.235389Z :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:26:54.235408Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:103: Cloud id: mock_cloud Quota count: 8
2025-12-12T12:26:54.235481Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:1061: ControlQueryRequest: query_id: "ptqudq7ug3b8up2rk3ft"
action: ABORT
2025-12-12T12:26:54.235545Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:169: Resolve subject type bootstrap. Token: **** (B6C6F477) Actor id: [1:7582946931415816000:2410]
2025-12-12T12:26:54.235561Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:230: Subject Type: federated_account Token: **** (B6C6F477)
2025-12-12T12:26:54.235582Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:1061: ControlQueryRequest: query_id: "ptqudq7ug3b8up2rk3ft"
action: ABORT
2025-12-12T12:26:54.235593Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:63: Request actor. Actor id: [1:7582946931415816001:2411]
2025-12-12T12:26:54.235628Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_queries.cpp:1342: ControlQueryRequest: {query_id: "ptqudq7ug3b8up2rk3ft"
action: ABORT
} [root@builtin, **** (B6C6F477)] 
2025-12-12T12:26:54.247998Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.analyticsQuery.count=0/100 NOTIFY CHANGE
2025-12-12T12:26:54.248029Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.streamingQuery.count=1/100 NOTIFY CHANGE
2025-12-12T12:26:54.434034Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582946854106404374:2119]
2025-12-12T12:26:54.434064Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:26:54.434070Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582946854106404304:2068]
2025-12-12T12:26:54.434074Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582946854106404304:2068]
2025-12-12T12:26:54.434077Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582946854106404304:2068]
2025-12-12T12:26:54.434089Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:26:54.439508Z :FQ_CONTROL_PLANE_CONFIG TRACE: control_plane_config.cpp:192: LOADED TenantInfo: State NOT changed
2025-12-12T12:26:54.454445Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: ControlQueryRequest - ControlQueryRequest: {} SUCCESS
2025-12-12T12:26:54.456571Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudq7ug3b8up2rk3ft"
2025-12-12T12:26:54.456615Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:305: Resolve folder bootstrap. Folder id: my_folder Actor id: [1:7582946931415816006:2415]
2025-12-12T12:26:54.456640Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:367: Cloud id: mock_cloud Folder id: my_folder
2025-12-12T12:26:54.456654Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:91: Get quotas bootstrap. Cloud id: mock_cloud Actor id: [1:7582946931415816007:2416]
2025-12-12T12:26:54.456671Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.analyticsQuery.count IS STALE, Refreshing ...
2025-12-12T12:26:54.456677Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.cpuPercent.count IS STALE, Refreshing ...
2025-12-12T12:26:54.456680Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.streamingQuery.count IS STALE, Refreshing ...
2025-12-12T12:26:54.456708Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.cpuPercent.count=0/10000 REFRESHED
2025-12-12T12:26:54.463500Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.analyticsQuery.count=0/100 REFRESHED
2025-12-12T12:26:54.463523Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.streamingQuery.count=1/100 REFRESHED
2025-12-12T12:26:54.463543Z :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:26:54.463554Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:103: Cloud id: mock_cloud Quota count: 8
2025-12-12T12:26:54.463605Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudq7ug3b8up2rk3ft"
2025-12-12T12:26:54.463664Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:169: Resolve subject type bootstrap. Token: **** (B6C6F477) Actor id: [1:7582946931415816012:2421]
2025-12-12T12:26:54.463685Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:230: Subject Type: federated_account Token: **** (B6C6F477)
2025-12-12T12:26:54.463699Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudq7ug3b8up2rk3ft"
2025-12-12T12:26:54.463710Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:63: Request actor. Actor id: [1:7582946931415816013:2422]
2025-12-12T12:26:54.463737Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_queries.cpp:641: DescribeQueryRequest: {query_id: "ptqudq7ug3b8up2rk3ft"
} [root@builtin, **** (B6C6F477)] 
2025-12-12T12:26:54.465575Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.cpuPercent.count=0/10000 NOTIFY CHANGE
2025-12-12T12:26:54.467195Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: DescribeQueryRequest - DescribeQueryResult: {query { meta { common { id: "ptqudq7ug3b8up2rk3ft" created_by: "root@builtin" modified_by: "root@builtin" created_at { seconds: 1765542403 nanos: 398599000 } modified_at { seconds: 1765542414 nanos: 378422000 } revision: 2 } started_at { seconds: 1765542404 nanos: 279000000 } execute_mode: RUN status: ABORTING_BY_USER last_job_query_revision: 1 last_job_id: "ptjudq7ug3b8u2caispn-ptqudq7ug3b8up2rk3ft" started_by: "root@builtin" aborted_by: "root@builtin" has_saved_checkpoints: true submitted_at { seconds: 1765542403 nanos: 398599000 } } 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: "Undelivered Event 276037632 from [1:7582946903579382806:2252] (Self) to [2:7582946907379366959:2210] Reason: ActorUnknown Cookie: 0" severity: 1 } transient_issue { message: "Query failed with code UNAVAILABLE and will be restarted (RetryCount: 2) at 2025-12-12T12:26:52.227524Z" severity: 1 } transient_issue { message: "Undelivered Event 276037634 from [2:7582946885904530405:2194] (Self) to [1:7582946888736046524:3647] Reason: ActorUnknown Cookie: 0" severity: 1 } transient_issue { message: "Query failed with code UNAVAILABLE and will be restarted (RetryCount: 1) at 2025-12-12T12:26:48.608321Z" 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:25827\"))\n(let $8 \'(\'\"SharedReading\" \'\"0\"))\n(let $9 \'(\'\"AddBearerToToken\" \'\"1\"))\n(let $10 \'($7 $8 \'(\'\"ReconnectPeriod\" \'\"\") \'(\'\"Format\" \'\"raw\") \'(\'\"ReadGroup\" \'\"ptcudq7ug3orttdktg37\") $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:26:54.474534Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.analyticsQuery.count=0/100 NOTIFY CHANGE
2025-12-12T12:26:54.474560Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.streamingQuery.count=1/100 NOTIFY CHANGE
2025-12-12T12:26:54.970483Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudq7ug3b8up2rk3ft"
2025-12-12T12:26:54.970560Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:305: Resolve folder bootstrap. Folder id: my_folder Actor id: [1:7582946931415816017:2425]
2025-12-12T12:26:54.970595Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:367: Cloud id: mock_cloud Folder id: my_folder
2025-12-12T12:26:54.970660Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:91: Get quotas bootstrap. Cloud id: mock_cloud Actor id: [1:7582946931415816018:2426]
2025-12-12T12:26:54.970691Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.analyticsQuery.count IS STALE, Refreshing ...
2025-12-12T12:26:54.970702Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.cpuPercent.count IS STALE, Refreshing ...
2025-12-12T12:26:54.970713Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.streamingQuery.count IS STALE, Refreshing ...
2025-12-12T12:26:54.970734Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.cpuPercent.count=0/10000 REFRESHED
2025-12-12T12:26:54.976646Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.analyticsQuery.count=0/100 REFRESHED
2025-12-12T12:26:54.976681Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.streamingQuery.count=1/100 REFRESHED
2025-12-12T12:26:54.976704Z :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:26:54.976714Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:103: Cloud id: mock_cloud Quota count: 8
2025-12-12T12:26:54.976739Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudq7ug3b8up2rk3ft"
2025-12-12T12:26:54.976797Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:169: Resolve subject type bootstrap. Token: **** (B6C6F477) Actor id: [1:7582946931415816023:2431]
2025-12-12T12:26:54.976818Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:230: Subject Type: federated_account Token: **** (B6C6F477)
2025-12-12T12:26:54.976840Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudq7ug3b8up2rk3ft"
2025-12-12T12:26:54.976859Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:63: Request actor. Actor id: [1:7582946931415816024:2432]
2025-12-12T12:26:54.976887Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_queries.cpp:641: DescribeQueryRequest: {query_id: "ptqudq7ug3b8up2rk3ft"
} [root@builtin, **** (B6C6F477)] 
2025-12-12T12:26:54.977816Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.cpuPercent.count=0/10000 NOTIFY CHANGE
2025-12-12T12:26:54.979348Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: DescribeQueryRequest - DescribeQueryResult: {query { meta { common { id: "ptqudq7ug3b8up2rk3ft" created_by: "root@builtin" modified_by: "root@builtin" created_at { seconds: 1765542403 nanos: 398599000 } modified_at { seconds: 1765542414 nanos: 378422000 } revision: 2 } started_at { seconds: 1765542404 nanos: 279000000 } execute_mode: RUN status: ABORTING_BY_USER last_job_query_revision: 1 last_job_id: "ptjudq7ug3b8u2caispn-ptqudq7ug3b8up2rk3ft" started_by: "root@builtin" aborted_by: "root@builtin" has_saved_checkpoints: true submitted_at { seconds: 1765542403 nanos: 398599000 } } 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: "Undelivered Event 276037632 from [1:7582946903579382806:2252] (Self) to [2:7582946907379366959:2210] Reason: ActorUnknown Cookie: 0" severity: 1 } transient_issue { message: "Query failed with code UNAVAILABLE and will be restarted (RetryCount: 2) at 2025-12-12T12:26:52.227524Z" severity: 1 } transient_issue { message: "Undelivered Event 276037634 from [2:7582946885904530405:2194] (Self) to [1:7582946888736046524:3647] Reason: ActorUnknown Cookie: 0" severity: 1 } transient_issue { message: "Query failed with code UNAVAILABLE and will be restarted (RetryCount: 1) at 2025-12-12T12:26:48.608321Z" 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:25827\"))\n(let $8 \'(\'\"SharedReading\" \'\"0\"))\n(let $9 \'(\'\"AddBearerToToken\" \'\"1\"))\n(let $10 \'($7 $8 \'(\'\"ReconnectPeriod\" \'\"\") \'(\'\"Format\" \'\"raw\") \'(\'\"ReadGroup\" \'\"ptcudq7ug3orttdktg37\") $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:26:54.982939Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.analyticsQuery.count=0/100 NOTIFY CHANGE
2025-12-12T12:26:54.986414Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 20bca8ce-62d8e9de-ef95b538-169f994110, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 69 bytes
2025-12-12T12:26:54.986463Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "20bca8ce-62d8e9de-ef95b538-169f994110"
host: "ghrun-fhkyrtz6p4"
node_id: 1
}
2025-12-12T12:26:54.986874Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.streamingQuery.count=1/100 NOTIFY CHANGE
2025-12-12T12:26:54.988618Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:26:54.988668Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 20bca8ce-62d8e9de-ef95b538-169f994110, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:26:54.989473Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 98aed2a1-72ca4129-b8aeede3-59d0649b4, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 68 bytes
2025-12-12T12:26:54.989526Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "98aed2a1-72ca4129-b8aeede3-59d0649b4"
host: "ghrun-fhkyrtz6p4"
node_id: 2
}
2025-12-12T12:26:54.991789Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:26:54.991825Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 98aed2a1-72ca4129-b8aeede3-59d0649b4, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:26:55.047965Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudq7ug3b8up2rk3ft, Owner: 20bca8ce-62d8e9de-ef95b538-169f99417, Request CP::PingTask with size: 442 bytes
2025-12-12T12:26:55.048051Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "20bca8ce-62d8e9de-ef95b538-169f99417"
query_id {
  value: "ptqudq7ug3b8up2rk3ft"
}
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: 1765628812
  nanos: 999450000
}
tenant: "/compute"
}
2025-12-12T12:26:55.060513Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {action: ABORT expired_at { seconds: 1765542435 nanos: 54000000 } } SUCCESS
2025-12-12T12:26:55.060637Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudq7ug3b8up2rk3ft, Owner: 20bca8ce-62d8e9de-ef95b538-169f99417, Got CP::PingTaskResponse
2025-12-12T12:26:55.066095Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudq7ug3b8up2rk3ft, Owner: 20bca8ce-62d8e9de-ef95b538-169f99417, Request CP::PingTask with size: 116 bytes
2025-12-12T12:26:55.066189Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "20bca8ce-62d8e9de-ef95b538-169f99417"
query_id {
  value: "ptqudq7ug3b8up2rk3ft"
}
status: ABORTING_BY_USER
scope: "yandexcloud://my_folder"
deadline {
  seconds: 1765628812
  nanos: 999450000
}
tenant: "/compute"
}
2025-12-12T12:26:55.086857Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {action: ABORT expired_at { seconds: 1765542435 nanos: 76000000 } } SUCCESS
2025-12-12T12:26:55.086994Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudq7ug3b8up2rk3ft, Owner: 20bca8ce-62d8e9de-ef95b538-169f99417, Got CP::PingTaskResponse
2025-12-12T12:26:55.090371Z :YQL_PRIVATE_PROXY DEBUG: rate_limiter_resources.cpp:175: PrivateDeleteRateLimiterResource - QueryId: ptqudq7ug3b8up2rk3ft, Owner: 20bca8ce-62d8e9de-ef95b538-169f99417, Request CP::DeleteRateLimiterResource with size: 97 bytes
2025-12-12T12:26:55.090429Z :YQ_CONTROL_PLANE_STORAGE TRACE: request_actor.h:57: DeleteRateLimiterResourceRequest: {owner_id: "20bca8ce-62d8e9de-ef95b538-169f99417"
query_id {
  value: "ptqudq7ug3b8up2rk3ft"
}
scope: "yandexcloud://my_folder"
tenant: "/compute"
} 
2025-12-12T12:26:55.136604Z :YQ_CONTROL_PLANE_STORAGE DEBUG: rate_limiter_resources.cpp:74: DeleteRateLimiterResourceRequest. Got response from database: SUCCESS
2025-12-12T12:26:55.136707Z :YQ_RATE_LIMITER DEBUG: schema.cpp:71: Run delete rate limiter resource "mock_cloud/my_folder/ptqudq7ug3b8up2rk3ft" actor
2025-12-12T12:26:55.136709Z :YQ_RATE_LIMITER DEBUG: schema.cpp:113: Call delete rate limiter resource "mock_cloud/my_folder/ptqudq7ug3b8up2rk3ft"
2025-12-12T12:26:55.138931Z :YQ_RATE_LIMITER DEBUG: schema.cpp:179: Successfully deleted rate limiter resource "mock_cloud/my_folder/ptqudq7ug3b8up2rk3ft"
2025-12-12T12:26:55.138941Z :YQ_RATE_LIMITER DEBUG: schema.cpp:122: Reply for delete rate limiter resource "mock_cloud/my_folder/ptqudq7ug3b8up2rk3ft": 
2025-12-12T12:26:55.138966Z :YQ_CONTROL_PLANE_STORAGE DEBUG: rate_limiter_resources.cpp:219: Got delete response from rate limiter service
2025-12-12T12:26:55.138986Z :YQL_PRIVATE_PROXY DEBUG: rate_limiter_resources.cpp:199: PrivateDeleteRateLimiterResource - QueryId: ptqudq7ug3b8up2rk3ft, Owner: 20bca8ce-62d8e9de-ef95b538-169f99417, Got CP::DeleteRateLimiterResourceResponse
2025-12-12T12:26:55.144539Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudq7ug3b8up2rk3ft, Owner: 20bca8ce-62d8e9de-ef95b538-169f99417, Request CP::PingTask with size: 996 bytes
2025-12-12T12:26:55.144648Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "20bca8ce-62d8e9de-ef95b538-169f99417"
query_id {
  value: "ptqudq7ug3b8up2rk3ft"
}
result_id {
  value: "ptrudq7ufq5tcqcpdrr3"
}
status: ABORTED_BY_USER
issues {
  message: "ABORTED_BY_USER"
  severity: 1
}
statistics: "{\"Graph=0\":{\"Actor\":{\"ActorCreateTimeUs\":{\"sum\":\"31ms\",\"count\":2,\"avg\":\"15ms\",\"max\":\"30ms\",\"min\":\"221us\"}},\"AllocateWorkersUs\":{\"sum\":\"31ms\",\"count\":1,\"avg\":\"31ms\",\"max\":\"31ms\",\"min\":\"31ms\"},\"ExecutionTimeUs\":{\"sum\":\"2.02s\",\"count\":1,\"avg\":\"2.02s\",\"max\":\"2.02s\",\"min\":\"2.02s\"},\"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\":2,\"count\":1,\"avg\":2,\"max\":2,\"min\":2}}}"
resources {
  rate_limiter: READY
  compilation: READY
  topic_consumers_state: READY
  rate_limiter_path: "local/RateLimiter_df6e7bab-b514-4b78-b17e-e8ee264a681d/rate_limiter"
  topic_consumers {
    database: "local"
    topic_path: "recovery_input"
    consumer_name: "ptqudq7ug3b8up2rk3ft"
    cluster_endpoint: "localhost:25827"
    token_name: "cluster:default_myyds"
    add_bearer_to_token: true
  }
}
scope: "yandexcloud://my_folder"
finished_at {
  seconds: 1765542415
  nanos: 63000000
}
deadline {
  seconds: 1765628812
  nanos: 999450000
}
tenant: "/compute"
}
2025-12-12T12:26:55.150962Z :YQ_CONTROL_PLANE_STORAGE NOTICE: task_ping.cpp:224: Query ptqudq7ug3b8up2rk3ft is NOT billable, status: ABORTED_BY_USER, statusCode: UNAVAILABLE
2025-12-12T12:26:55.240188Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {action: ABORT } SUCCESS
2025-12-12T12:26:55.240217Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudq7ug3b8up2rk3ft, Owner: 20bca8ce-62d8e9de-ef95b538-169f99417, Got CP::PingTaskResponse
2025-12-12T12:26:55.482378Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudq7ug3b8up2rk3ft"
2025-12-12T12:26:55.482433Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:305: Resolve folder bootstrap. Folder id: my_folder Actor id: [1:7582946935710783344:2455]
2025-12-12T12:26:55.482449Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:367: Cloud id: mock_cloud Folder id: my_folder
2025-12-12T12:26:55.482462Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:91: Get quotas bootstrap. Cloud id: mock_cloud Actor id: [1:7582946935710783345:2456]
2025-12-12T12:26:55.482485Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.analyticsQuery.count IS STALE, Refreshing ...
2025-12-12T12:26:55.482497Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.cpuPercent.count IS STALE, Refreshing ...
2025-12-12T12:26:55.482500Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.streamingQuery.count IS STALE, Refreshing ...
2025-12-12T12:26:55.482581Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.cpuPercent.count=0/10000 REFRESHED
2025-12-12T12:26:55.489385Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.analyticsQuery.count=0/100 REFRESHED
2025-12-12T12:26:55.489417Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.streamingQuery.count=0/100 REFRESHED
2025-12-12T12:26:55.489439Z :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:26:55.489460Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:103: Cloud id: mock_cloud Quota count: 8
2025-12-12T12:26:55.489521Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudq7ug3b8up2rk3ft"
2025-12-12T12:26:55.489585Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:169: Resolve subject type bootstrap. Token: **** (B6C6F477) Actor id: [1:7582946935710783350:2461]
2025-12-12T12:26:55.489610Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:230: Subject Type: federated_account Token: **** (B6C6F477)
2025-12-12T12:26:55.489624Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudq7ug3b8up2rk3ft"
2025-12-12T12:26:55.489634Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:63: Request actor. Actor id: [1:7582946935710783351:2462]
2025-12-12T12:26:55.489666Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_queries.cpp:641: DescribeQueryRequest: {query_id: "ptqudq7ug3b8up2rk3ft"
} [root@builtin, **** (B6C6F477)] 
2025-12-12T12:26:55.496806Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: DescribeQueryRequest - DescribeQueryResult: {query { meta { common { id: "ptqudq7ug3b8up2rk3ft" created_by: "root@builtin" modified_by: "root@builtin" created_at { seconds: 1765542403 nanos: 398599000 } modified_at { seconds: 1765542414 nanos: 378422000 } revision: 2 } started_at { seconds: 1765542404 nanos: 279000000 } finished_at { seconds: 1765542415 nanos: 63000000 } execute_mode: RUN status: ABORTED_BY_USER last_job_query_revision: 1 last_job_id: "ptjudq7ug3b8u2caispn-ptqudq7ug3b8up2rk3ft" started_by: "root@builtin" aborted_by: "root@builtin" has_saved_checkpoints: true submitted_at { seconds: 1765542403 nanos: 398599000 } } 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: "Undelivered Event 276037632 from [1:7582946903579382806:2252] (Self) to [2:7582946907379366959:2210] Reason: ActorUnknown Cookie: 0" severity: 1 } transient_issue { message: "Query failed with code UNAVAILABLE and will be restarted (RetryCount: 2) at 2025-12-12T12:26:52.227524Z" severity: 1 } transient_issue { message: "Undelivered Event 276037634 from [2:7582946885904530405:2194] (Self) to [1:7582946888736046524:3647] Reason: ActorUnknown Cookie: 0" severity: 1 } transient_issue { message: "Query failed with code UNAVAILABLE and will be restarted (RetryCount: 1) at 2025-12-12T12:26:48.608321Z" 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:25827\"))\n(let $8 \'(\'\"SharedReading\" \'\"0\"))\n(let $9 \'(\'\"AddBearerToToken\" \'\"1\"))\n(let $10 \'($7 $8 \'(\'\"ReconnectPeriod\" \'\"\") \'(\'\"Format\" \'\"raw\") \'(\'\"ReadGroup\" \'\"ptcudq7ug3orttdktg37\") $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:26:55.499156Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.cpuPercent.count=0/10000 NOTIFY CHANGE
2025-12-12T12:26:55.504826Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.streamingQuery.count=0/100 NOTIFY CHANGE
2025-12-12T12:26:55.504864Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.analyticsQuery.count=0/100 NOTIFY CHANGE
