2025-12-12T12:27:29.602054Z :GRPC_SERVER NOTICE: grpc_request_proxy_simple.cpp:161: Grpc simple request proxy started, nodeid# 1
2025-12-12T12:27:29.602105Z :GRPC_SERVER NOTICE: grpc_request_proxy_simple.cpp:161: Grpc simple request proxy started, nodeid# 1
2025-12-12T12:27:29.602612Z :YQ_TEST_CONNECTION DEBUG: test_connection.cpp:142: Starting yandex query test connection. Actor id: [1:7582947080946092824:2071]
2025-12-12T12:27:29.602851Z :YQ_CONTROL_PLANE_STORAGE INFO: ydb_control_plane_storage.cpp:50: Starting ydb control plane storage service. Actor id: [1:7582947080946092815:2062]
2025-12-12T12:27:29.603242Z :YQ_CONTROL_PLANE_PROXY DEBUG: control_plane_proxy.cpp:525: Starting yandex query control plane proxy. Actor id: [1:7582947080946092817:2064]
2025-12-12T12:27:29.603333Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_1fb303ed-ed93-4034-ace4-b066e21a3ab1/connections" actor
2025-12-12T12:27:29.603343Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:214: Bootstrap
2025-12-12T12:27:29.603345Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:217: Create sdk ydb connection
2025-12-12T12:27:29.603375Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:239: Successfully bootstrapped TStorageProxy [1:7582947080946092820:2067] with connection to localhost:25827:local
2025-12-12T12:27:29.603382Z :FQ_QUOTA_PROXY INFO: quota_proxy.cpp:90: STARTED
2025-12-12T12:27:29.603387Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_1fb303ed-ed93-4034-ace4-b066e21a3ab1/bindings" actor
2025-12-12T12:27:29.603395Z :FQ_LOG_UPDATER DEBUG: log.cpp:93: Updated YQL logs priority: 8
2025-12-12T12:27:29.603402Z :FQ_LOG_UPDATER CRIT: log.cpp:55: Failed to deliver subscription request to config dispatcher.
2025-12-12T12:27:29.603405Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_1fb303ed-ed93-4034-ace4-b066e21a3ab1/idempotency_keys" actor
2025-12-12T12:27:29.603413Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_1fb303ed-ed93-4034-ace4-b066e21a3ab1/result_sets" actor
2025-12-12T12:27:29.603423Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_1fb303ed-ed93-4034-ace4-b066e21a3ab1/quotas" actor
2025-12-12T12:27:29.603426Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_1fb303ed-ed93-4034-ace4-b066e21a3ab1/jobs" actor
2025-12-12T12:27:29.603435Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_1fb303ed-ed93-4034-ace4-b066e21a3ab1/nodes" actor
2025-12-12T12:27:29.603436Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_1fb303ed-ed93-4034-ace4-b066e21a3ab1/tenants" actor
2025-12-12T12:27:29.603443Z :FQ_CONTROL_PLANE_CONFIG DEBUG: control_plane_config.cpp:58: STARTING: [1:7582947080946092816:2063]
2025-12-12T12:27:29.603446Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_1fb303ed-ed93-4034-ace4-b066e21a3ab1/tenant_acks" actor
2025-12-12T12:27:29.603456Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_1fb303ed-ed93-4034-ace4-b066e21a3ab1/mappings" actor
2025-12-12T12:27:29.603463Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_1fb303ed-ed93-4034-ace4-b066e21a3ab1/compute_databases" actor
2025-12-12T12:27:29.603472Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:544: RowDispatcher: Successfully bootstrapped row dispatcher, id [1:7582947080946092821:2068], tenant /cp
2025-12-12T12:27:29.603492Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582947080946092821:2068]
2025-12-12T12:27:29.603494Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:329: Coordinator: Add new row dispatcher to map (state 1)
2025-12-12T12:27:29.603496Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create directory "local/DbPoolStorage_1fb303ed-ed93-4034-ace4-b066e21a3ab1" actor
2025-12-12T12:27:29.603499Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create directory "local/DbPoolStorage_1fb303ed-ed93-4034-ace4-b066e21a3ab1"
2025-12-12T12:27:29.603505Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:383: Call create directory "local/DbPoolStorage_1fb303ed-ed93-4034-ace4-b066e21a3ab1"
2025-12-12T12:27:29.603526Z :YQ_RATE_LIMITER DEBUG: schema.cpp:71: Run create coordination node "local/RateLimiter_1fb303ed-ed93-4034-ace4-b066e21a3ab1/rate_limiter" actor
2025-12-12T12:27:29.603528Z :YQ_RATE_LIMITER DEBUG: schema.cpp:113: Call create coordination node "local/RateLimiter_1fb303ed-ed93-4034-ace4-b066e21a3ab1/rate_limiter"
2025-12-12T12:27:29.603530Z :YQ_RATE_LIMITER DEBUG: schema.cpp:411: Call create coordination node "local/RateLimiter_1fb303ed-ed93-4034-ace4-b066e21a3ab1/rate_limiter"
2025-12-12T12:27:29.603558Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_1fb303ed-ed93-4034-ace4-b066e21a3ab1/queries" actor
2025-12-12T12:27:29.603573Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:293: Coordinator: Successfully bootstrapped coordinator, id [1:7582947080946092865:2107], NodesManagerId [0:4705493345362661702:78], rebalancing timeout 5.000000s
2025-12-12T12:27:29.603574Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_1fb303ed-ed93-4034-ace4-b066e21a3ab1/pending_small" actor
2025-12-12T12:27:29.603580Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:232: TLeaderElection [1:7582947080946092866:2108] Successfully bootstrapped, local coordinator id [1:7582947080946092865:2107], tenant id cp, local mode 0, coordination node path local/cp, endpoint localhost:25827
2025-12-12T12:27:29.603595Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:637: RowDispatcher: TEvCoordinatorChangesSubscribe from [1:7582947080946092865:2107]
2025-12-12T12:27:29.603730Z :MEMORY_PROFILER NOTICE: monitor.cpp:332: Bootstrapped
2025-12-12T12:27:29.617818Z :FQ_QUOTA_SERVICE INFO: quota_manager.cpp:196: STARTED
2025-12-12T12:27:29.617818Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:71: Run create coordination node "local/cp" actor
2025-12-12T12:27:29.617822Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:113: Call create coordination node "local/cp"
2025-12-12T12:27:29.617824Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:411: Call create coordination node "local/cp"
2025-12-12T12:27:29.632402Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_1fb303ed-ed93-4034-ace4-b066e21a3ab1/tenants". Create session OK
2025-12-12T12:27:29.632416Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_1fb303ed-ed93-4034-ace4-b066e21a3ab1/tenants"
2025-12-12T12:27:29.632419Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_1fb303ed-ed93-4034-ace4-b066e21a3ab1/tenants"
2025-12-12T12:27:29.632661Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_1fb303ed-ed93-4034-ace4-b066e21a3ab1/connections". Create session OK
2025-12-12T12:27:29.632672Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_1fb303ed-ed93-4034-ace4-b066e21a3ab1/connections"
2025-12-12T12:27:29.632673Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_1fb303ed-ed93-4034-ace4-b066e21a3ab1/connections"
2025-12-12T12:27:29.632702Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_1fb303ed-ed93-4034-ace4-b066e21a3ab1/idempotency_keys". Create session OK
2025-12-12T12:27:29.632705Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_1fb303ed-ed93-4034-ace4-b066e21a3ab1/idempotency_keys"
2025-12-12T12:27:29.632716Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_1fb303ed-ed93-4034-ace4-b066e21a3ab1/idempotency_keys"
2025-12-12T12:27:29.632823Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_1fb303ed-ed93-4034-ace4-b066e21a3ab1/queries". Create session OK
2025-12-12T12:27:29.632835Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_1fb303ed-ed93-4034-ace4-b066e21a3ab1/queries"
2025-12-12T12:27:29.632837Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_1fb303ed-ed93-4034-ace4-b066e21a3ab1/queries"
2025-12-12T12:27:29.632856Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_1fb303ed-ed93-4034-ace4-b066e21a3ab1/tenant_acks". Create session OK
2025-12-12T12:27:29.632858Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_1fb303ed-ed93-4034-ace4-b066e21a3ab1/tenant_acks"
2025-12-12T12:27:29.632860Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_1fb303ed-ed93-4034-ace4-b066e21a3ab1/tenant_acks"
2025-12-12T12:27:29.632934Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_1fb303ed-ed93-4034-ace4-b066e21a3ab1/result_sets". Create session OK
2025-12-12T12:27:29.632944Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_1fb303ed-ed93-4034-ace4-b066e21a3ab1/result_sets"
2025-12-12T12:27:29.632944Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_1fb303ed-ed93-4034-ace4-b066e21a3ab1/bindings". Create session OK
2025-12-12T12:27:29.632945Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_1fb303ed-ed93-4034-ace4-b066e21a3ab1/result_sets"
2025-12-12T12:27:29.632946Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_1fb303ed-ed93-4034-ace4-b066e21a3ab1/bindings"
2025-12-12T12:27:29.632947Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_1fb303ed-ed93-4034-ace4-b066e21a3ab1/bindings"
2025-12-12T12:27:29.633401Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_1fb303ed-ed93-4034-ace4-b066e21a3ab1/nodes". Create session OK
2025-12-12T12:27:29.633411Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_1fb303ed-ed93-4034-ace4-b066e21a3ab1/nodes"
2025-12-12T12:27:29.633413Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_1fb303ed-ed93-4034-ace4-b066e21a3ab1/nodes"
2025-12-12T12:27:29.633437Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_1fb303ed-ed93-4034-ace4-b066e21a3ab1/mappings". Create session OK
2025-12-12T12:27:29.633442Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_1fb303ed-ed93-4034-ace4-b066e21a3ab1/mappings"
2025-12-12T12:27:29.633444Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_1fb303ed-ed93-4034-ace4-b066e21a3ab1/mappings"
2025-12-12T12:27:29.633768Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_1fb303ed-ed93-4034-ace4-b066e21a3ab1/quotas". Create session OK
2025-12-12T12:27:29.633770Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_1fb303ed-ed93-4034-ace4-b066e21a3ab1/quotas"
2025-12-12T12:27:29.633771Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_1fb303ed-ed93-4034-ace4-b066e21a3ab1/quotas"
2025-12-12T12:27:29.633790Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_1fb303ed-ed93-4034-ace4-b066e21a3ab1/pending_small". Create session OK
2025-12-12T12:27:29.633792Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_1fb303ed-ed93-4034-ace4-b066e21a3ab1/pending_small"
2025-12-12T12:27:29.633794Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_1fb303ed-ed93-4034-ace4-b066e21a3ab1/pending_small"
2025-12-12T12:27:29.635953Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_1fb303ed-ed93-4034-ace4-b066e21a3ab1/compute_databases". Create session OK
2025-12-12T12:27:29.635963Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_1fb303ed-ed93-4034-ace4-b066e21a3ab1/compute_databases"
2025-12-12T12:27:29.635966Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_1fb303ed-ed93-4034-ace4-b066e21a3ab1/compute_databases"
2025-12-12T12:27:29.638132Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_1fb303ed-ed93-4034-ace4-b066e21a3ab1/jobs". Create session OK
2025-12-12T12:27:29.638145Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:155: Successfully created coordination node "local/cp"
2025-12-12T12:27:29.638153Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_1fb303ed-ed93-4034-ace4-b066e21a3ab1/jobs"
2025-12-12T12:27:29.638155Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_1fb303ed-ed93-4034-ace4-b066e21a3ab1/jobs"
2025-12-12T12:27:29.638157Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:122: Reply for create coordination node "local/cp": { <main>: Error: Check failed: path: '/local/cp', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 7], type: EPathTypeKesus, state: EPathStateNoChanges), source_location: ydb/core/tx/schemeshard/schemeshard__operation_create_kesus.cpp:339 }
2025-12-12T12:27:29.638164Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created directory "local/DbPoolStorage_1fb303ed-ed93-4034-ace4-b066e21a3ab1"
2025-12-12T12:27:29.638171Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:345: TLeaderElection [1:7582947080946092866:2108] Coordination node successfully created
2025-12-12T12:27:29.638175Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:323: TLeaderElection [1:7582947080946092866:2108] Start session
2025-12-12T12:27:29.638178Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create directory "local/DbPoolStorage_1fb303ed-ed93-4034-ace4-b066e21a3ab1": { <main>: Error: Check failed: path: '/local/DbPoolStorage_1fb303ed-ed93-4034-ace4-b066e21a3ab1', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 54], type: EPathTypeDir, state: EPathStateNoChanges), source_location: ydb/core/tx/schemeshard/schemeshard__operation_mkdir.cpp:155 }
2025-12-12T12:27:29.644313Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_1fb303ed-ed93-4034-ace4-b066e21a3ab1/tenants"
2025-12-12T12:27:29.644333Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_1fb303ed-ed93-4034-ace4-b066e21a3ab1/tenants": { <main>: Error: Check failed: path: '/local/DbPoolStorage_1fb303ed-ed93-4034-ace4-b066e21a3ab1/tenants', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 55], type: EPathTypeTable, state: EPathStateNoChanges), source_location: ydb/core/tx/schemeshard/schemeshard__operation_create_table.cpp:504 }
2025-12-12T12:27:29.649290Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_1fb303ed-ed93-4034-ace4-b066e21a3ab1/mappings"
2025-12-12T12:27:29.649312Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_1fb303ed-ed93-4034-ace4-b066e21a3ab1/mappings": { <main>: Error: Check failed: path: '/local/DbPoolStorage_1fb303ed-ed93-4034-ace4-b066e21a3ab1/mappings', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 56], type: EPathTypeTable, state: EPathStateNoChanges), source_location: ydb/core/tx/schemeshard/schemeshard__operation_create_table.cpp:504 }
2025-12-12T12:27:29.651365Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:359: TLeaderElection [1:7582947080946092866:2108] Session successfully created
2025-12-12T12:27:29.659520Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:372: TLeaderElection [1:7582947080946092866:2108] Semaphore successfully created
2025-12-12T12:27:29.659533Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:304: TLeaderElection [1:7582947080946092866:2108] Try to acquire semaphore
2025-12-12T12:27:29.659607Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:420: TLeaderElection [1:7582947080946092866:2108] Describe semaphore
2025-12-12T12:27:29.664249Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:386: TLeaderElection [1:7582947080946092866:2108] Semaphore successfully acquired
2025-12-12T12:27:29.664276Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:469: TLeaderElection [1:7582947080946092866:2108] Semaphore successfully described: coordinator id [1:7582947080946092865:2107] generation 3
2025-12-12T12:27:29.664280Z :FQ_ROW_DISPATCHER INFO: leader_election.cpp:471: TLeaderElection [1:7582947080946092866:2108] Send TEvCoordinatorChanged to [1:7582947080946092821:2068], new coordinator id [1:7582947080946092865:2107], previous coordinator id [0:0:0]
2025-12-12T12:27:29.664300Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:569: RowDispatcher: Coordinator changed, old leader (empty maybe), new [1:7582947080946092865:2107] generation 3
2025-12-12T12:27:29.664315Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582947080946092821:2068]
2025-12-12T12:27:29.664319Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582947080946092821:2068]
2025-12-12T12:27:29.664322Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582947080946092821:2068]
2025-12-12T12:27:29.664352Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:440: Coordinator: New leader [1:7582947080946092865:2107], SelfId [1:7582947080946092865:2107]
2025-12-12T12:27:29.664351Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:29.686969Z :FQ_CONTROL_PLANE_CONFIG DEBUG: control_plane_config.cpp:190: LOADED TenantInfo: State CHANGED at 2025-12-12T12:27:29.197816Z
2025-12-12T12:27:29.705098Z :YQ_RATE_LIMITER DEBUG: schema.cpp:155: Successfully created coordination node "local/RateLimiter_1fb303ed-ed93-4034-ace4-b066e21a3ab1/rate_limiter"
2025-12-12T12:27:29.705112Z :YQ_RATE_LIMITER DEBUG: schema.cpp:122: Reply for create coordination node "local/RateLimiter_1fb303ed-ed93-4034-ace4-b066e21a3ab1/rate_limiter": 
2025-12-12T12:27:29.705431Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_1fb303ed-ed93-4034-ace4-b066e21a3ab1/jobs"
2025-12-12T12:27:29.705439Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_1fb303ed-ed93-4034-ace4-b066e21a3ab1/jobs": 
2025-12-12T12:27:29.705811Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_1fb303ed-ed93-4034-ace4-b066e21a3ab1/idempotency_keys"
2025-12-12T12:27:29.705819Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_1fb303ed-ed93-4034-ace4-b066e21a3ab1/idempotency_keys": 
2025-12-12T12:27:29.708889Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_1fb303ed-ed93-4034-ace4-b066e21a3ab1/pending_small"
2025-12-12T12:27:29.708901Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_1fb303ed-ed93-4034-ace4-b066e21a3ab1/pending_small": 
2025-12-12T12:27:29.708923Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_1fb303ed-ed93-4034-ace4-b066e21a3ab1/connections"
2025-12-12T12:27:29.708927Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_1fb303ed-ed93-4034-ace4-b066e21a3ab1/connections": 
2025-12-12T12:27:29.709425Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_1fb303ed-ed93-4034-ace4-b066e21a3ab1/bindings"
2025-12-12T12:27:29.709437Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_1fb303ed-ed93-4034-ace4-b066e21a3ab1/bindings": 
2025-12-12T12:27:29.711304Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_1fb303ed-ed93-4034-ace4-b066e21a3ab1/quotas"
2025-12-12T12:27:29.711314Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_1fb303ed-ed93-4034-ace4-b066e21a3ab1/quotas": 
2025-12-12T12:27:29.711408Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_1fb303ed-ed93-4034-ace4-b066e21a3ab1/compute_databases"
2025-12-12T12:27:29.711437Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_1fb303ed-ed93-4034-ace4-b066e21a3ab1/compute_databases": 
2025-12-12T12:27:29.711553Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_1fb303ed-ed93-4034-ace4-b066e21a3ab1/result_sets"
2025-12-12T12:27:29.711573Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_1fb303ed-ed93-4034-ace4-b066e21a3ab1/result_sets": 
2025-12-12T12:27:29.711604Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_1fb303ed-ed93-4034-ace4-b066e21a3ab1/nodes"
2025-12-12T12:27:29.711611Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_1fb303ed-ed93-4034-ace4-b066e21a3ab1/nodes": 
2025-12-12T12:27:29.711620Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_1fb303ed-ed93-4034-ace4-b066e21a3ab1/tenant_acks"
2025-12-12T12:27:29.711622Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_1fb303ed-ed93-4034-ace4-b066e21a3ab1/tenant_acks": 
2025-12-12T12:27:29.715382Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_1fb303ed-ed93-4034-ace4-b066e21a3ab1/queries"
2025-12-12T12:27:29.715394Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_1fb303ed-ed93-4034-ace4-b066e21a3ab1/queries": 
2025-12-12T12:27:30.347881Z :TICKET_PARSER DEBUG: ticket_parser_impl.h:1875: Ticket **** (B6C6F477) (ipv6:[::1]:49826) has now valid token of root@builtin
2025-12-12T12:27:30.348103Z :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:27:30.348150Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:305: Resolve folder bootstrap. Folder id: my_folder Actor id: [1:7582947085241060218:2148]
2025-12-12T12:27:30.348176Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:367: Cloud id: mock_cloud Folder id: my_folder
2025-12-12T12:27:30.348201Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:91: Get quotas bootstrap. Cloud id: mock_cloud Actor id: [1:7582947085241060219:2149]
2025-12-12T12:27:30.348222Z :FQ_QUOTA_SERVICE DEBUG: quota_manager.cpp:255: cloud.mock_cloud NOT CASHED, Loading ...
2025-12-12T12:27:30.377578Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:441: cloud.mock_cloud {} FROM DB
2025-12-12T12:27:30.377630Z :FQ_QUOTA_SERVICE DEBUG: quota_manager.cpp:269: cloud.mock_cloud{yq.streamingQueryDurationMinutes.count=*/0, yq.queryResult.size=*/20971520, yq.analyticsQuery.count=*/100, yq.analyticsQueryDurationMinutes.count=*/1440, yq.memory.size=*/0, yq.result.size=*/0, yq.cpuPercent.count=*/10000, yq.streamingQuery.count=*/100} LOADED
2025-12-12T12:27:30.377634Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.analyticsQuery.count IS STALE, Refreshing ...
2025-12-12T12:27:30.377647Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.cpuPercent.count IS STALE, Refreshing ...
2025-12-12T12:27:30.377651Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.streamingQuery.count IS STALE, Refreshing ...
2025-12-12T12:27:30.377674Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.cpuPercent.count=0/10000 REFRESHED
2025-12-12T12:27:30.424227Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.cpuPercent.count=0/10000 NOTIFY CHANGE
2025-12-12T12:27:30.434548Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.analyticsQuery.count=0/100 REFRESHED
2025-12-12T12:27:30.434579Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.streamingQuery.count=0/100 REFRESHED
2025-12-12T12:27:30.434605Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:493: cloud.mock_cloud{yq.streamingQueryDurationMinutes.count=*/0, yq.queryResult.size=*/20971520, yq.analyticsQuery.count=0/100, yq.analyticsQueryDurationMinutes.count=*/1440, yq.memory.size=*/0, yq.result.size=*/0, yq.cpuPercent.count=0/10000, yq.streamingQuery.count=0/100} SEND QUOTAS
2025-12-12T12:27:30.434615Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:103: Cloud id: mock_cloud Quota count: 8
2025-12-12T12:27:30.434749Z :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:27:30.434833Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:169: Resolve subject type bootstrap. Token: **** (B6C6F477) Actor id: [1:7582947085241060225:2155]
2025-12-12T12:27:30.434857Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:230: Subject Type: federated_account Token: **** (B6C6F477)
2025-12-12T12:27:30.434966Z :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:27:30.435035Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:435: Create database bootstrap. CloudId: mock_cloud Scope: yandexcloud://my_folder Actor id: [1:7582947085241060226:2156]
2025-12-12T12:27:30.435156Z :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:27:30.435193Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:63: Request actor. Actor id: [1:7582947085241060227:2157]
2025-12-12T12:27:30.435340Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_connections.cpp:120: [yandexcloud://my_folder, root@builtin, ptcudq7uemfqqjepn05j] CreateConnectionRequest: **** (B6C6F477) content { name: "myyds" setting { data_streams { auth { none { } } endpoint: "localhost:25827" database: "local" } } acl { visibility: PRIVATE } } 
2025-12-12T12:27:30.441378Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.streamingQuery.count=0/100 NOTIFY CHANGE
2025-12-12T12:27:30.441455Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.analyticsQuery.count=0/100 NOTIFY CHANGE
2025-12-12T12:27:30.508156Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 9d95934e-c74316bc-fc75cdcf-190f9ed91, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 68 bytes
2025-12-12T12:27:30.508846Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "9d95934e-c74316bc-fc75cdcf-190f9ed91"
host: "ghrun-fhkyrtz6p4"
node_id: 1
}
2025-12-12T12:27:30.508905Z :YQ_CONTROL_PLANE_STORAGE TRACE: nodes_health_check.cpp:38: NodesHealthCheckRequest: {tenant: "/compute"
node {
  node_id: 1
  instance_id: "a4c27300-4c8a3604-64bcbba2-74f75614"
  hostname: "ghrun-fhkyrtz6p4"
  interconnect_port: 10229
  node_address: "127.0.1.1"
}
}
2025-12-12T12:27:30.560047Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:27:30.560127Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 9d95934e-c74316bc-fc75cdcf-190f9ed91, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:27:30.581041Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: NodesHealthCheckRequest - NodesHealthCheckResult: {nodes { node_id: 1 instance_id: "a4c27300-4c8a3604-64bcbba2-74f75614" hostname: "ghrun-fhkyrtz6p4" node_address: "127.0.1.1" } } SUCCESS
2025-12-12T12:27:30.776467Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: [yandexcloud://my_folder, root@builtin, ptcudq7uemfqqjepn05j] CreateConnectionRequest: {connection_id: "ptcudq7uemfqqjepn05j" } SUCCESS
2025-12-12T12:27:30.779679Z :TICKET_PARSER DEBUG: ticket_parser_impl.h:1875: Ticket **** (B6C6F477) (ipv6:[::1]:49826) has now valid token of root@builtin
2025-12-12T12:27:30.779843Z :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            pragma FeatureR010=\"prototype\";\n            pragma config.flags(\"TimeOrderRecoverDelay\", \"-1000000\");\n            pragma config.flags(\"TimeOrderRecoverAhead\", \"1000000\");\n\n            INSERT INTO myyds.`test_time_order_recoverer[v1-kikimr0]_v1_output`\n            SELECT ToBytes(Unwrap(Json::SerializeJson(Yson::From(TableRow()))))\n            FROM (SELECT * FROM myyds.`test_time_order_recoverer[v1-kikimr0]_v1_input`\n                WITH (\n                    format=json_each_row,\n                    SCHEMA\n                    (\n                        dt UINT64\n                    )))\n            MATCH_RECOGNIZE(\n                ORDER BY CAST(dt as Timestamp)\n                MEASURES\n                LAST(ALL_TRUE.dt) as dt\n                ONE ROW PER MATCH\n                PATTERN ( ALL_TRUE )\n                DEFINE\n                    ALL_TRUE as True)"
  syntax: YQL_V1
}
execute_mode: RUN
idempotency_key: "c07cb015-cba3-425c-85ac-cfc12b96368d"
2025-12-12T12:27:30.779891Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:305: Resolve folder bootstrap. Folder id: my_folder Actor id: [1:7582947085241060237:2166]
2025-12-12T12:27:30.779912Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:367: Cloud id: mock_cloud Folder id: my_folder
2025-12-12T12:27:30.779933Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:91: Get quotas bootstrap. Cloud id: mock_cloud Actor id: [1:7582947085241060238:2167]
2025-12-12T12:27:30.779958Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.analyticsQuery.count IS STALE, Refreshing ...
2025-12-12T12:27:30.779975Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.cpuPercent.count IS STALE, Refreshing ...
2025-12-12T12:27:30.779982Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.streamingQuery.count IS STALE, Refreshing ...
2025-12-12T12:27:30.779996Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.cpuPercent.count=0/10000 REFRESHED
2025-12-12T12:27:30.782310Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.analyticsQuery.count=0/100 REFRESHED
2025-12-12T12:27:30.782338Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.streamingQuery.count=0/100 REFRESHED
2025-12-12T12:27:30.782355Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:493: cloud.mock_cloud{yq.streamingQueryDurationMinutes.count=*/0, yq.queryResult.size=*/20971520, yq.analyticsQuery.count=0/100, yq.analyticsQueryDurationMinutes.count=*/1440, yq.memory.size=*/0, yq.result.size=*/0, yq.cpuPercent.count=0/10000, yq.streamingQuery.count=0/100} SEND QUOTAS
2025-12-12T12:27:30.782379Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:103: Cloud id: mock_cloud Quota count: 8
2025-12-12T12:27:30.782441Z :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            pragma FeatureR010=\"prototype\";\n            pragma config.flags(\"TimeOrderRecoverDelay\", \"-1000000\");\n            pragma config.flags(\"TimeOrderRecoverAhead\", \"1000000\");\n\n            INSERT INTO myyds.`test_time_order_recoverer[v1-kikimr0]_v1_output`\n            SELECT ToBytes(Unwrap(Json::SerializeJson(Yson::From(TableRow()))))\n            FROM (SELECT * FROM myyds.`test_time_order_recoverer[v1-kikimr0]_v1_input`\n                WITH (\n                    format=json_each_row,\n                    SCHEMA\n                    (\n                        dt UINT64\n                    )))\n            MATCH_RECOGNIZE(\n                ORDER BY CAST(dt as Timestamp)\n                MEASURES\n                LAST(ALL_TRUE.dt) as dt\n                ONE ROW PER MATCH\n                PATTERN ( ALL_TRUE )\n                DEFINE\n                    ALL_TRUE as True)"
  syntax: YQL_V1
}
execute_mode: RUN
idempotency_key: "c07cb015-cba3-425c-85ac-cfc12b96368d"
2025-12-12T12:27:30.782532Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:169: Resolve subject type bootstrap. Token: **** (B6C6F477) Actor id: [1:7582947085241060243:2172]
2025-12-12T12:27:30.782557Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:230: Subject Type: federated_account Token: **** (B6C6F477)
2025-12-12T12:27:30.782614Z :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            pragma FeatureR010=\"prototype\";\n            pragma config.flags(\"TimeOrderRecoverDelay\", \"-1000000\");\n            pragma config.flags(\"TimeOrderRecoverAhead\", \"1000000\");\n\n            INSERT INTO myyds.`test_time_order_recoverer[v1-kikimr0]_v1_output`\n            SELECT ToBytes(Unwrap(Json::SerializeJson(Yson::From(TableRow()))))\n            FROM (SELECT * FROM myyds.`test_time_order_recoverer[v1-kikimr0]_v1_input`\n                WITH (\n                    format=json_each_row,\n                    SCHEMA\n                    (\n                        dt UINT64\n                    )))\n            MATCH_RECOGNIZE(\n                ORDER BY CAST(dt as Timestamp)\n                MEASURES\n                LAST(ALL_TRUE.dt) as dt\n                ONE ROW PER MATCH\n                PATTERN ( ALL_TRUE )\n                DEFINE\n                    ALL_TRUE as True)"
  syntax: YQL_V1
}
execute_mode: RUN
idempotency_key: "c07cb015-cba3-425c-85ac-cfc12b96368d"
2025-12-12T12:27:30.782652Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:435: Create database bootstrap. CloudId: mock_cloud Scope: yandexcloud://my_folder Actor id: [1:7582947085241060244:2173]
2025-12-12T12:27:30.782689Z :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            pragma FeatureR010=\"prototype\";\n            pragma config.flags(\"TimeOrderRecoverDelay\", \"-1000000\");\n            pragma config.flags(\"TimeOrderRecoverAhead\", \"1000000\");\n\n            INSERT INTO myyds.`test_time_order_recoverer[v1-kikimr0]_v1_output`\n            SELECT ToBytes(Unwrap(Json::SerializeJson(Yson::From(TableRow()))))\n            FROM (SELECT * FROM myyds.`test_time_order_recoverer[v1-kikimr0]_v1_input`\n                WITH (\n                    format=json_each_row,\n                    SCHEMA\n                    (\n                        dt UINT64\n                    )))\n            MATCH_RECOGNIZE(\n                ORDER BY CAST(dt as Timestamp)\n                MEASURES\n                LAST(ALL_TRUE.dt) as dt\n                ONE ROW PER MATCH\n                PATTERN ( ALL_TRUE )\n                DEFINE\n                    ALL_TRUE as True)"
  syntax: YQL_V1
}
execute_mode: RUN
idempotency_key: "c07cb015-cba3-425c-85ac-cfc12b96368d"
2025-12-12T12:27:30.782707Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:63: Request actor. Actor id: [1:7582947085241060245:2174]
2025-12-12T12:27:30.782725Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:248: Create rate limiter resource for cloud with limit 100000ms
2025-12-12T12:27:30.782769Z :YQ_RATE_LIMITER DEBUG: schema.cpp:71: Run create rate limiter resource "mock_cloud" actor
2025-12-12T12:27:30.782778Z :YQ_RATE_LIMITER DEBUG: schema.cpp:113: Call create rate limiter resource "mock_cloud"
2025-12-12T12:27:30.786485Z :YQ_RATE_LIMITER DEBUG: schema.cpp:155: Successfully created rate limiter resource "mock_cloud"
2025-12-12T12:27:30.786499Z :YQ_RATE_LIMITER DEBUG: schema.cpp:122: Reply for create rate limiter resource "mock_cloud": 
2025-12-12T12:27:30.786542Z :YQ_CONTROL_PLANE_PROXY DEBUG: request_actor.h:272: Create response from rate limiter service. Success: 1
2025-12-12T12:27:30.786644Z :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            pragma FeatureR010=\"prototype\";\n            pragma config.flags(\"TimeOrderRecoverDelay\", \"-1000000\");\n            pragma config.flags(\"TimeOrderRecoverAhead\", \"1000000\");\n\n            INSERT INTO myyds.`test_time_order_recoverer[v1-kikimr0]_v1_output`\n            SELECT ToBytes(Unwrap(Json::SerializeJson(Yson::From(TableRow()))))\n            FROM (SELECT * FROM myyds.`test_time_order_recoverer[v1-kikimr0]_v1_input`\n                WITH (\n                    format=json_each_row,\n                    SCHEMA\n                    (\n                        dt UINT64\n                    )))\n            MATCH_RECOGNIZE(\n                ORDER BY CAST(dt as Timestamp)\n                MEASURES\n                LAST(ALL_TRUE.dt) as dt\n                ONE ROW PER MATCH\n                PATTERN ( ALL_TRUE )\n                DEFINE\n                    ALL_TRUE as True)"
  syntax: YQL_V1
}
execute_mode: RUN
idempotency_key: "c07cb015-cba3-425c-85ac-cfc12b96368d"
} [root@builtin, **** (B6C6F477)] 
2025-12-12T12:27:30.786713Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.cpuPercent.count=0/10000 NOTIFY CHANGE
2025-12-12T12:27:30.791668Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.streamingQuery.count=0/100 NOTIFY CHANGE
2025-12-12T12:27:30.791689Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.analyticsQuery.count=0/100 NOTIFY CHANGE
2025-12-12T12:27:31.027553Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: CreateQueryRequest - CreateQueryResult: {query_id: "ptqudq7uem53kjjhdml0" } SUCCESS
2025-12-12T12:27:31.030216Z :TICKET_PARSER DEBUG: ticket_parser_impl.h:1875: Ticket **** (B6C6F477) (ipv6:[::1]:49826) has now valid token of root@builtin
2025-12-12T12:27:31.030305Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudq7uem53kjjhdml0"
2025-12-12T12:27:31.030342Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:305: Resolve folder bootstrap. Folder id: my_folder Actor id: [1:7582947089536027546:2178]
2025-12-12T12:27:31.030368Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:367: Cloud id: mock_cloud Folder id: my_folder
2025-12-12T12:27:31.030385Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:91: Get quotas bootstrap. Cloud id: mock_cloud Actor id: [1:7582947089536027547:2179]
2025-12-12T12:27:31.030401Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.analyticsQuery.count IS STALE, Refreshing ...
2025-12-12T12:27:31.030407Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.cpuPercent.count IS STALE, Refreshing ...
2025-12-12T12:27:31.030410Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.streamingQuery.count IS STALE, Refreshing ...
2025-12-12T12:27:31.030434Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.cpuPercent.count=0/10000 REFRESHED
2025-12-12T12:27:31.039883Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.cpuPercent.count=0/10000 NOTIFY CHANGE
2025-12-12T12:27:31.059782Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.analyticsQuery.count=0/100 REFRESHED
2025-12-12T12:27:31.059811Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.streamingQuery.count=1/100 REFRESHED
2025-12-12T12:27:31.059834Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:493: cloud.mock_cloud{yq.streamingQueryDurationMinutes.count=*/0, yq.queryResult.size=*/20971520, yq.analyticsQuery.count=0/100, yq.analyticsQueryDurationMinutes.count=*/1440, yq.memory.size=*/0, yq.result.size=*/0, yq.cpuPercent.count=0/10000, yq.streamingQuery.count=1/100} SEND QUOTAS
2025-12-12T12:27:31.059848Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:103: Cloud id: mock_cloud Quota count: 8
2025-12-12T12:27:31.059887Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudq7uem53kjjhdml0"
2025-12-12T12:27:31.059983Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:169: Resolve subject type bootstrap. Token: **** (B6C6F477) Actor id: [1:7582947089536027552:2184]
2025-12-12T12:27:31.060014Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:230: Subject Type: federated_account Token: **** (B6C6F477)
2025-12-12T12:27:31.060068Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudq7uem53kjjhdml0"
2025-12-12T12:27:31.060113Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:63: Request actor. Actor id: [1:7582947089536027553:2185]
2025-12-12T12:27:31.060187Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_queries.cpp:641: DescribeQueryRequest: {query_id: "ptqudq7uem53kjjhdml0"
} [root@builtin, **** (B6C6F477)] 
2025-12-12T12:27:31.065107Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.streamingQuery.count=1/100 NOTIFY CHANGE
2025-12-12T12:27:31.065162Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.analyticsQuery.count=0/100 NOTIFY CHANGE
2025-12-12T12:27:31.098100Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: DescribeQueryRequest - DescribeQueryResult: {query { meta { common { id: "ptqudq7uem53kjjhdml0" created_by: "root@builtin" modified_by: "root@builtin" created_at { seconds: 1765542450 nanos: 786563000 } modified_at { seconds: 1765542450 nanos: 786563000 } revision: 1 } execute_mode: RUN status: STARTING last_job_query_revision: 1 last_job_id: "ptjudq7uem53keup7toj-ptqudq7uem53kjjhdml0" started_by: "root@builtin" submitted_at { seconds: 1765542450 nanos: 786563000 } } content { type: STREAMING name: "simple" acl { visibility: PRIVATE } limits { execution_timeout { } } text: "\n            PRAGMA dq.MaxTasksPerStage=\"2\";\n\n            pragma FeatureR010=\"prototype\";\n            pragma config.flags(\"TimeOrderRecoverDelay\", \"-1000000\");\n            pragma config.flags(\"TimeOrderRecoverAhead\", \"1000000\");\n\n            INSERT INTO myyds.`test_time_order_recoverer[v1-kikimr0]_v1_output`\n            SELECT ToBytes(Unwrap(Json::SerializeJson(Yson::From(TableRow()))))\n            FROM (SELECT * FROM myyds.`test_time_order_recoverer[v1-kikimr0]_v1_input`\n                WITH (\n                    format=json_each_row,\n                    SCHEMA\n                    (\n                        dt UINT64\n                    )))\n            MATCH_RECOGNIZE(\n                ORDER BY CAST(dt as Timestamp)\n                MEASURES\n                LAST(ALL_TRUE.dt) as dt\n                ONE ROW PER MATCH\n                PATTERN ( ALL_TRUE )\n                DEFINE\n                    ALL_TRUE as True)" syntax: YQL_V1 } } } SUCCESS
2025-12-12T12:27:31.499738Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 9d95934e-c74316bc-fc75cdcf-190f9ed92, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 68 bytes
2025-12-12T12:27:31.499826Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "9d95934e-c74316bc-fc75cdcf-190f9ed92"
host: "ghrun-fhkyrtz6p4"
node_id: 1
}
2025-12-12T12:27:31.502901Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:463: Task (Query): ptqudq7uem53kjjhdml0 RetryRate: 0 RetryCounter: 0 At: 2025-12-12T12:27:30.878776Z
2025-12-12T12:27:31.600549Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582947080946092865:2107]
2025-12-12T12:27:31.600573Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:31.600590Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582947080946092821:2068]
2025-12-12T12:27:31.600598Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582947080946092821:2068]
2025-12-12T12:27:31.600602Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582947080946092821:2068]
2025-12-12T12:27:31.600620Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:31.600903Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudq7uem53kjjhdml0"
2025-12-12T12:27:31.600956Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:305: Resolve folder bootstrap. Folder id: my_folder Actor id: [1:7582947089536027561:2192]
2025-12-12T12:27:31.600983Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:367: Cloud id: mock_cloud Folder id: my_folder
2025-12-12T12:27:31.601007Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:91: Get quotas bootstrap. Cloud id: mock_cloud Actor id: [1:7582947089536027562:2193]
2025-12-12T12:27:31.601036Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.analyticsQuery.count IS STALE, Refreshing ...
2025-12-12T12:27:31.601048Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.cpuPercent.count IS STALE, Refreshing ...
2025-12-12T12:27:31.601064Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.streamingQuery.count IS STALE, Refreshing ...
2025-12-12T12:27:31.601089Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.cpuPercent.count=0/10000 REFRESHED
2025-12-12T12:27:31.605271Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.analyticsQuery.count=0/100 REFRESHED
2025-12-12T12:27:31.605307Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.streamingQuery.count=1/100 REFRESHED
2025-12-12T12:27:31.605326Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:493: cloud.mock_cloud{yq.streamingQueryDurationMinutes.count=*/0, yq.queryResult.size=*/20971520, yq.analyticsQuery.count=0/100, yq.analyticsQueryDurationMinutes.count=*/1440, yq.memory.size=*/0, yq.result.size=*/0, yq.cpuPercent.count=0/10000, yq.streamingQuery.count=1/100} SEND QUOTAS
2025-12-12T12:27:31.605339Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:103: Cloud id: mock_cloud Quota count: 8
2025-12-12T12:27:31.605365Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudq7uem53kjjhdml0"
2025-12-12T12:27:31.605413Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:169: Resolve subject type bootstrap. Token: **** (B6C6F477) Actor id: [1:7582947089536027567:2198]
2025-12-12T12:27:31.605425Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {tasks { query_id { value: "ptqudq7uem53kjjhdml0" } job_id { value: "ptjudq7uem53keup7toj" } generation: 1 streaming: true text: "\n            PRAGMA dq.MaxTasksPerStage=\"2\";\n\n            pragma FeatureR010=\"prototype\";\n            pragma config.flags(\"TimeOrderRecoverDelay\", \"-1000000\");\n            pragma config.flags(\"TimeOrderRecoverAhead\", \"1000000\");\n\n            INSERT INTO myyds.`test_time_order_recoverer[v1-kikimr0]_v1_output`\n            SELECT ToBytes(Unwrap(Json::SerializeJson(Yson::From(TableRow()))))\n            FROM (SELECT * FROM myyds.`test_time_order_recoverer[v1-kikimr0]_v1_input`\n                WITH (\n                    format=json_each_row,\n                    SCHEMA\n                    (\n                        dt UINT64\n                    )))\n            MATCH_RECOGNIZE(\n                ORDER BY CAST(dt as Timestamp)\n                MEASURES\n                LAST(ALL_TRUE.dt) as dt\n                ONE ROW PER MATCH\n                PATTERN ( ALL_TRUE )\n                DEFINE\n                    ALL_TRUE as True)" connection { content { name: "myyds" setting { data_streams { auth { none { } } endpoint: "localhost:25827" database: "local" } } acl { visibility: PRIVATE } } meta { id: "ptcudq7uemfqqjepn05j" created_by: "root@builtin" modified_by: "root@builtin" created_at { seconds: 1765542450 nanos: 435226000 } modified_at { seconds: 1765542450 nanos: 435226000 } 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: 1765628851 nanos: 554613000 } 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: 1765542450 nanos: 786563000 } } } SUCCESS
2025-12-12T12:27:31.605435Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:230: Subject Type: federated_account Token: **** (B6C6F477)
2025-12-12T12:27:31.605454Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudq7uem53kjjhdml0"
2025-12-12T12:27:31.605469Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 9d95934e-c74316bc-fc75cdcf-190f9ed92, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:27:31.605511Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:63: Request actor. Actor id: [1:7582947089536027568:2199]
2025-12-12T12:27:31.605547Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_queries.cpp:641: DescribeQueryRequest: {query_id: "ptqudq7uem53kjjhdml0"
} [root@builtin, **** (B6C6F477)] 
2025-12-12T12:27:31.607029Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 9d95934e-c74316bc-fc75cdcf-190f9ed93, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 68 bytes
2025-12-12T12:27:31.607091Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "9d95934e-c74316bc-fc75cdcf-190f9ed93"
host: "ghrun-fhkyrtz6p4"
node_id: 1
}
2025-12-12T12:27:31.607125Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.cpuPercent.count=0/10000 NOTIFY CHANGE
2025-12-12T12:27:31.607144Z :YQL_PRIVATE_PROXY DEBUG: rate_limiter_resources.cpp:78: PrivateCreateRateLimiterResource - QueryId: ptqudq7uem53kjjhdml0, Owner: 9d95934e-c74316bc-fc75cdcf-190f9ed92, Request CP::CreateRateLimiterResource with size: 97 bytes
2025-12-12T12:27:31.607190Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudq7uem53kjjhdml0, Owner: 9d95934e-c74316bc-fc75cdcf-190f9ed92, Request CP::PingTask with size: 129 bytes
2025-12-12T12:27:31.607192Z :YQ_CONTROL_PLANE_STORAGE TRACE: request_actor.h:57: CreateRateLimiterResourceRequest: {owner_id: "9d95934e-c74316bc-fc75cdcf-190f9ed92"
query_id {
  value: "ptqudq7uem53kjjhdml0"
}
scope: "yandexcloud://my_folder"
tenant: "/compute"
} 
2025-12-12T12:27:31.607250Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "9d95934e-c74316bc-fc75cdcf-190f9ed92"
query_id {
  value: "ptqudq7uem53kjjhdml0"
}
scope: "yandexcloud://my_folder"
started_at {
  seconds: 1765542451
  nanos: 606000000
}
deadline {
  seconds: 1765628851
  nanos: 554613000
}
tenant: "/compute"
}
2025-12-12T12:27:31.608238Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: DescribeQueryRequest - DescribeQueryResult: {query { meta { common { id: "ptqudq7uem53kjjhdml0" created_by: "root@builtin" modified_by: "root@builtin" created_at { seconds: 1765542450 nanos: 786563000 } modified_at { seconds: 1765542450 nanos: 786563000 } revision: 1 } execute_mode: RUN status: STARTING last_job_query_revision: 1 last_job_id: "ptjudq7uem53keup7toj-ptqudq7uem53kjjhdml0" started_by: "root@builtin" submitted_at { seconds: 1765542450 nanos: 786563000 } } content { type: STREAMING name: "simple" acl { visibility: PRIVATE } limits { execution_timeout { } } text: "\n            PRAGMA dq.MaxTasksPerStage=\"2\";\n\n            pragma FeatureR010=\"prototype\";\n            pragma config.flags(\"TimeOrderRecoverDelay\", \"-1000000\");\n            pragma config.flags(\"TimeOrderRecoverAhead\", \"1000000\");\n\n            INSERT INTO myyds.`test_time_order_recoverer[v1-kikimr0]_v1_output`\n            SELECT ToBytes(Unwrap(Json::SerializeJson(Yson::From(TableRow()))))\n            FROM (SELECT * FROM myyds.`test_time_order_recoverer[v1-kikimr0]_v1_input`\n                WITH (\n                    format=json_each_row,\n                    SCHEMA\n                    (\n                        dt UINT64\n                    )))\n            MATCH_RECOGNIZE(\n                ORDER BY CAST(dt as Timestamp)\n                MEASURES\n                LAST(ALL_TRUE.dt) as dt\n                ONE ROW PER MATCH\n                PATTERN ( ALL_TRUE )\n                DEFINE\n                    ALL_TRUE as True)" syntax: YQL_V1 } } } SUCCESS
2025-12-12T12:27:31.609548Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:27:31.609582Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 9d95934e-c74316bc-fc75cdcf-190f9ed93, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:27:31.611370Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.analyticsQuery.count=0/100 NOTIFY CHANGE
2025-12-12T12:27:31.611813Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.streamingQuery.count=1/100 NOTIFY CHANGE
2025-12-12T12:27:31.648997Z :YQ_CONTROL_PLANE_STORAGE DEBUG: rate_limiter_resources.cpp:74: CreateRateLimiterResourceRequest. Got response from database: SUCCESS
2025-12-12T12:27:31.649125Z :YQ_RATE_LIMITER DEBUG: schema.cpp:71: Run create rate limiter resource "mock_cloud/my_folder/ptqudq7uem53kjjhdml0" actor
2025-12-12T12:27:31.649137Z :YQ_RATE_LIMITER DEBUG: schema.cpp:113: Call create rate limiter resource "mock_cloud/my_folder/ptqudq7uem53kjjhdml0"
2025-12-12T12:27:31.650254Z :YQ_RATE_LIMITER DEBUG: schema.cpp:261: Trying to recursively create rate limiter resource "mock_cloud/my_folder"
2025-12-12T12:27:31.650258Z :YQ_RATE_LIMITER DEBUG: schema.cpp:113: Call create rate limiter resource "mock_cloud/my_folder"
2025-12-12T12:27:31.652771Z :YQ_RATE_LIMITER DEBUG: schema.cpp:244: Successfully created rate limiter resource "mock_cloud/my_folder"
2025-12-12T12:27:31.652783Z :YQ_RATE_LIMITER DEBUG: schema.cpp:113: Call create rate limiter resource "mock_cloud/my_folder/ptqudq7uem53kjjhdml0"
2025-12-12T12:27:31.654593Z :YQ_RATE_LIMITER DEBUG: schema.cpp:155: Successfully created rate limiter resource "mock_cloud/my_folder/ptqudq7uem53kjjhdml0"
2025-12-12T12:27:31.654606Z :YQ_RATE_LIMITER DEBUG: schema.cpp:122: Reply for create rate limiter resource "mock_cloud/my_folder/ptqudq7uem53kjjhdml0": 
2025-12-12T12:27:31.654649Z :YQ_CONTROL_PLANE_STORAGE DEBUG: rate_limiter_resources.cpp:180: Got create response from rate limiter service
2025-12-12T12:27:31.654705Z :YQL_PRIVATE_PROXY DEBUG: rate_limiter_resources.cpp:102: PrivateCreateRateLimiterResource - QueryId: ptqudq7uem53kjjhdml0, Owner: 9d95934e-c74316bc-fc75cdcf-190f9ed92, Got CP::CreateRateLimiterResourceResponse
2025-12-12T12:27:31.819633Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {expired_at { seconds: 1765542471 nanos: 739000000 } } SUCCESS
2025-12-12T12:27:31.819695Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudq7uem53kjjhdml0, Owner: 9d95934e-c74316bc-fc75cdcf-190f9ed92, Got CP::PingTaskResponse
2025-12-12T12:27:31.820723Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudq7uem53kjjhdml0, Owner: 9d95934e-c74316bc-fc75cdcf-190f9ed92, Request CP::PingTask with size: 123 bytes
2025-12-12T12:27:31.820788Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "9d95934e-c74316bc-fc75cdcf-190f9ed92"
query_id {
  value: "ptqudq7uem53kjjhdml0"
}
status: RUNNING
resources {
  rate_limiter: PREPARE
  compilation: PREPARE
}
scope: "yandexcloud://my_folder"
deadline {
  seconds: 1765628851
  nanos: 554613000
}
tenant: "/compute"
}
2025-12-12T12:27:31.831460Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {expired_at { seconds: 1765542471 nanos: 826000000 } } SUCCESS
2025-12-12T12:27:31.831504Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudq7uem53kjjhdml0, Owner: 9d95934e-c74316bc-fc75cdcf-190f9ed92, Got CP::PingTaskResponse
2025-12-12T12:27:31.832414Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudq7uem53kjjhdml0, Owner: 9d95934e-c74316bc-fc75cdcf-190f9ed92, Request CP::PingTask with size: 192 bytes
2025-12-12T12:27:31.832491Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "9d95934e-c74316bc-fc75cdcf-190f9ed92"
query_id {
  value: "ptqudq7uem53kjjhdml0"
}
status: RUNNING
resources {
  rate_limiter: READY
  compilation: PREPARE
  rate_limiter_path: "local/RateLimiter_1fb303ed-ed93-4034-ace4-b066e21a3ab1/rate_limiter"
}
scope: "yandexcloud://my_folder"
deadline {
  seconds: 1765628851
  nanos: 554613000
}
tenant: "/compute"
}
2025-12-12T12:27:31.841490Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {expired_at { seconds: 1765542471 nanos: 837000000 } } SUCCESS
2025-12-12T12:27:31.841518Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudq7uem53kjjhdml0, Owner: 9d95934e-c74316bc-fc75cdcf-190f9ed92, Got CP::PingTaskResponse
2025-12-12T12:27:31.873434Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudq7uem53kjjhdml0, Owner: 9d95934e-c74316bc-fc75cdcf-190f9ed92, Request CP::PingTask with size: 4966 bytes
2025-12-12T12:27:31.873566Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "9d95934e-c74316bc-fc75cdcf-190f9ed92"
query_id {
  value: "ptqudq7uem53kjjhdml0"
}
ast: "(\n(let $1 (DataSource \'\"config\"))\n(let $2 (Configure! world $1 \'\"DqEngine\" \'\"force\"))\n(let $3 (Configure! $2 (DataSource \'\"dq\" \'\"$all\") \'\"Attr\" \'\"maxtasksperstage\" \'\"2\"))\n(let $4 (Configure! $3 $1 \'\"TimeOrderRecoverDelay\" \'\"-1000000\"))\n(let $5 (Configure! $4 $1 \'\"TimeOrderRecoverAhead\" \'\"1000000\"))\n(let $6 (DataSource \'\"pq\" \'\"myyds\"))\n(let $7 \'(\'(\'\"PartitionsCount\" \'1)))\n(let $8 (StructType \'(\'dt (OptionalType (DataType \'Uint64)))))\n(let $9 (PqTopic \'\"myyds\" \'\"local\" \'\"test_time_order_recoverer[v1-kikimr0]_v1_input\" $7 \'() $8))\n(let $10 \'(\'dt))\n(let $11 \'(\'\"Endpoint\" \'\"localhost:25827\"))\n(let $12 \'(\'\"SharedReading\" \'0))\n(let $13 \'(\'\"AddBearerToToken\" \'1))\n(let $14 \'($11 $12 \'(\'\"ReconnectPeriod\" \'\"\") \'(\'\"Format\" \'\"json_each_row\") \'(\'\"ReadGroup\" \'\"ptcudq7uemfqqjepn05j\") $13))\n(let $15 (SecureParam \'\"cluster:default_myyds\"))\n(let $16 (DqPqTopicSource $5 $9 $10 $14 $15 \'\"\" $8 \'\"\"))\n(let $17 (DqStage \'((DqSource $6 $16)) (lambda \'($21) (block \'(\n  (let $22 \'(\'(\'\"format\" \'\"json_each_row\") \'(\'\"formatSettings\" \'(\'(\'\"data.datetime.formatname\" \'\"POSIX\") \'(\'\"data.timestamp.formatname\" \'\"POSIX\"))) \'(\'\"settings\" \'($12))))\n  (let $23 (DqSourceWideWrap $21 $6 $8 $22))\n  (return (NarrowMap $23 (lambda \'($24) (AsStruct \'(\'dt $24)))))\n))) \'(\'(\'\"_logical_id\" \'200904))))\n(let $18 (DataSink \'\"pq\" \'\"myyds\"))\n(let $19 (PqTopic \'\"myyds\" \'\"local\" \'\"test_time_order_recoverer[v1-kikimr0]_v1_output\" $7 \'() (StructType \'(\'\"Data\" (DataType \'String)))))\n(let $20 (DqPqTopicSink $19 \'($11 $13) $15))\n(return (Commit! (DqQuery! $5 \'((DqStage \'((DqCnUnionAll (TDqOutput $17 \'0))) (lambda \'($25) (block \'(\n  (let $26 (TimeOrderRecover $25 (lambda \'($33) (SafeCast (Member $33 \'dt) (OptionalType (DataType \'Timestamp)))) (Interval \'\"-1000000\") (Interval \'\"1000000\") (Uint32 \'\"1000000\")))\n  (let $27 \'(\'\"ALL_TRUE\"))\n  (let $28 (MatchRecognizeMeasures $8 $27 $10 (lambda \'($36 $37) (block \'(\n    (let $38 (lambda \'($45) $45))\n    (let $39 (AggregationTraits $8 (lambda \'($42) (Member $42 \'dt)) (lambda \'($43 $44) (Coalesce (Member $43 \'dt) $44)) $38 $38 (lambda \'($46 $47) (Coalesce $46 $47)) $38 (Null)))\n    (return (Member (Head (Aggregate (OrderedFlatMap (OrderedFlatMap (Member $37 \'\"ALL_TRUE\") (lambda \'($40) (ListFromRange (Member $40 \'\"From\") (+ (Member $40 \'\"To\") (Uint64 \'1)) (Int64 \'1)))) (lambda \'($41) (Just (AsStruct \'(\'dt (Member (Unwrap (Lookup (ToIndexDict $36) $41)) \'dt)))))) \'() \'(\'(\'Last0 $39)) \'())) \'Last0))\n  )))))\n  (let $29 (Bool \'true))\n  (let $30 (MatchRecognizeDefines $8 $27 $27 (lambda \'($48 $49 $50) $29)))\n  (let $31 (MatchRecognizeParams $28 \'\"RowsPerMatch_OneRow\" \'(\'\"AfterMatchSkip_PastLastRow\" \'\"\") (MatchRecognizePattern \'(\'(\'\"ALL_TRUE\" \'1 \'1 \'1 \'1 \'0))) $30))\n  (let $32 (MatchRecognizeCore (OrderedFlatMap $26 (lambda \'($34) (OptionalIf (Not (Member $34 \'\"_yql_OutOfOrder\")) (AsStruct \'(\'dt (Member $34 \'dt)))))) (lambda \'($35) \'()) \'() $31 \'(\'(\'\"Streaming\" \'1))))\n  (return (FromFlow (FlatMap $32 (lambda \'($51) (block \'(\n    (let $52 (ResourceType \'\"Yson2.Node\"))\n    (let $53 \'($52 \'\"\" \'1))\n    (let $54 (ResourceType \'\"Yson2.Options\"))\n    (let $55 (OptionalType (DataType \'Bool)))\n    (let $56 (CallableType \'(\'\"4\") \'((OptionalType (DataType \'Json))) $53 \'((OptionalType $54)) \'($55 \'\"SkipMapEntity\") \'($55 \'\"EncodeUtf8\") \'($55 \'\"WriteNanAsString\")))\n    (let $57 (Udf \'\"Yson2.SerializeJson\" (Void) (VoidType) \'\"\" $56 (VoidType) \'\"\" \'()))\n    (let $58 (TupleType (TupleType $8) (StructType) (TupleType)))\n    (let $59 (CallableType \'() \'($52) \'($8)))\n    (let $60 \'(\'(\'\"strict\")))\n    (let $61 (Udf \'\"Yson2.From\" (Void) $58 \'\"\" $59 (VoidType) \'\"\" $60))\n    (let $62 (CallableType \'(\'\"2\") \'($54) \'($55 \'\"AutoConvert\") \'($55 \'\"Strict\")))\n    (let $63 (Udf \'\"Yson2.Options\" (Void) (VoidType) \'\"\" $62 (VoidType) \'\"\" $60))\n    (return (Just (AsStruct \'(\'\"column0\" (ToBytes (Unwrap (Apply $57 (Apply $61 $51) (Just (NamedApply $63 \'() (AsStruct \'(\'\"AutoConvert\" (Just (Bool \'false))) \'(\'\"Strict\" (Just $29))))))))))))\n  ))))))\n))) \'(\'(\'\"_logical_id\" \'201884) \'(\'\"_partition_mode\" \'\"aggregate\")) \'((DqSink \'0 $18 $20))))) $18))\n)\n"
plan: "{\"Detailed\":{\"Operations\":[{\"Id\":5,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[{\"Name\":\"DqSourceWideWrap\"},{\"Name\":\"NarrowMap\"}]}},{\"Id\":3,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[{\"Name\":\"TimeOrderRecover\"},{\"Name\":\"OrderedFlatMap\"},{\"Name\":\"MatchRecognizeCore\"},{\"Name\":\"FlatMap\"},{\"Name\":\"FromFlow\"}]},\"DependsOn\":[5]},{\"Id\":2,\"Name\":\"DqQuery!\",\"DependsOn\":[3]},{\"Id\":1,\"Name\":\"Commit!\",\"DependsOn\":[2]}],\"OperationRoot\":1,\"Providers\":[],\"OperationStats\":{\"Commit!\":1,\"DqQuery!\":1,\"DqStage\":2}},\"Basic\":{\"nodes\":[{\"id\":5,\"level\":1,\"name\":\"DqStage #5\",\"type\":\"op\"},{\"id\":3,\"level\":2,\"name\":\"DqStage #3\",\"type\":\"op\"},{\"id\":2,\"level\":3,\"name\":\"DqQuery!\",\"type\":\"op\"},{\"id\":1,\"level\":4,\"name\":\"Commit!\",\"type\":\"op\"}],\"links\":[{\"source\":5,\"target\":3},{\"source\":3,\"target\":2},{\"source\":2,\"target\":1}]}}"
scope: "yandexcloud://my_folder"
deadline {
  seconds: 1765628851
  nanos: 554613000
}
tenant: "/compute"
}
2025-12-12T12:27:31.882680Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {expired_at { seconds: 1765542471 nanos: 877000000 } } SUCCESS
2025-12-12T12:27:31.882707Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudq7uem53kjjhdml0, Owner: 9d95934e-c74316bc-fc75cdcf-190f9ed92, Got CP::PingTaskResponse
2025-12-12T12:27:31.883686Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudq7uem53kjjhdml0, Owner: 9d95934e-c74316bc-fc75cdcf-190f9ed92, Request CP::PingTask with size: 202 bytes
2025-12-12T12:27:31.883792Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "9d95934e-c74316bc-fc75cdcf-190f9ed92"
query_id {
  value: "ptqudq7uem53kjjhdml0"
}
transient_issues {
  message: "Parse Sql"
  severity: 2
  issues {
    position {
      row: 9
      column: 41
    }
    message: "Json UDF is deprecated. Please use JSON API instead"
    end_position {
      row: 9
      column: 41
    }
    issue_code: 4506
    severity: 2
  }
}
scope: "yandexcloud://my_folder"
deadline {
  seconds: 1765628851
  nanos: 554613000
}
tenant: "/compute"
}
2025-12-12T12:27:31.893982Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {expired_at { seconds: 1765542471 nanos: 888000000 } } SUCCESS
2025-12-12T12:27:31.894016Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudq7uem53kjjhdml0, Owner: 9d95934e-c74316bc-fc75cdcf-190f9ed92, Got CP::PingTaskResponse
2025-12-12T12:27:31.896545Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudq7uem53kjjhdml0, Owner: 9d95934e-c74316bc-fc75cdcf-190f9ed92, Request CP::PingTask with size: 4497 bytes
2025-12-12T12:27:31.896692Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "9d95934e-c74316bc-fc75cdcf-190f9ed92"
query_id {
  value: "ptqudq7uem53kjjhdml0"
}
dq_graph: "\022\210\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*\233\003Z\230\003\n\010PqSource\022\211\003\n4type.googleapis.com/NYql.NPq.NProto.TDqPqTopicSource\022\320\002\n.test_time_order_recoverer[v1-kikimr0]_v1_input\022\024ptqudq7uem53kjjhdml0\032\017localhost:25827\"\027\n\025cluster:default_myyds*\005local0\002@\001b\002dtj&[\"OptionalType\";[\"DataType\";\"Uint64\"]]\222\001\024ptcudq7uemfqqjepn05j\232\001\rjson_each_row\242\001>[\"StructType\";[[\"dt\";[\"OptionalType\";[\"DataType\";\"Uint64\"]]]]]\262\001\002\022\000\272\001\026\n\010cloud_id\022\nmock_cloud\272\001 \n\005scope\022\027yandexcloud://my_folder\030\0012D\n@\010\001\020\240\234\001\030\001 \002*\024\n\022\t\000\000\000\000\000\000\000\000\021\000\000\000\000\001\000\000\0002\024\n\022\t\000\000\000\000\000\000\000\000\021\000\000\000\000\002\000\000\000P\001X\367\276\014`\213\277\014R\000:\203\001\n*type.googleapis.com/Yql.DqsProto.TTaskMeta\022U\010\367\276\014\022A\022(88a034dc314301cb1522a933e690a4c49a7591e8\032\023dq_vanilla_job.lite \002\"\014\n\002pq\022\006\n\004\010\001\030\001H\367\276\014RClocal/RateLimiter_1fb303ed-ed93-4034-ace4-b066e21a3ab1/rate_limiterZ)mock_cloud/my_folder/ptqudq7uem53kjjhdml0`\200\200\200\200 \230\001\000\300\001\001\022\210\004\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*D\n@\010\001\020\240\234\001\030\001 \002*\024\n\022\t\000\000\000\000\000\000\000\000\021\000\000\000\000\001\000\000\0002\024\n\022\t\000\000\000\000\000\000\000\000\021\000\000\000\000\002\000\000\000P\001X\367\276\014`\213\277\014R\0002\252\001z\247\001\n\006PqSink\022\234\001\n2type.googleapis.com/NYql.NPq.NProto.TDqPqTopicSink\022f\n/test_time_order_recoverer[v1-kikimr0]_v1_output\022\017localhost:25827\032\027\n\025cluster:default_myyds\"\005local0\0018\002:u\n*type.googleapis.com/Yql.DqsProto.TTaskMeta\022G\010\213\277\014\022A\022(88a034dc314301cb1522a933e690a4c49a7591e8\032\023dq_vanilla_job.lite \002H\213\277\014RClocal/RateLimiter_1fb303ed-ed93-4034-ace4-b066e21a3ab1/rate_limiterZ)mock_cloud/my_folder/ptqudq7uem53kjjhdml0`\200\200\200\200 \230\001\000\300\001\0012qptqudq7uem53kjjhdml0#ptrudq7uelc354pr4d63#yandexcloud://my_folder#9d95934e-c74316bc-fc75cdcf-190f9ed92#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\265\003\010\367\276\014\022\256\003\037\004\006Arg\004dt\005\205\006\213\002\204\203\005@\205\000\204\205\002\207\203\010\006\030Inputs(Parameters\034Program\013?\004)\251\000?\002\002\000\010\000)\251\000?\006\002\000\026)\211\002?\016\215?\014 FromFlow\000)\211\006?\034\215\233\002?\n?\n?\014$NarrowMap\000)\211\006?\"\215\205\002?\n\006?&?\n$ExpandMap\000)\211\002?(\204?&\030ToFlow\000)\211\014?,\211\004?,\204\203\005@\207\203\001H\014UDF\002\203\004\203\005@\203\004\203\004?\002\030Apply2\000)\211\010?8\203\005@\200\203\005@\202\014Udf\000\003?D8ClickHouseClient.ParseFormat\213\006\213\002\204\203\005@?\006?&\003?F\252json_each_row{\"data.datetime.formatname\":\"POSIX\",\"data.timestamp.formatname\":\"POSIX\"}\002\017\n\003?:\000\003?<\000\003?>\000\003?@\000?\024\036\014\000\016)\251\000?&\002\000\004)\211\004?\n?&\203\004\030Member\000?f\003?h\000\002\006\000\020)\251\000?\n\002\000\002\005?\014?t\000\004\022\000\024\001/b\202\021\010\213\277\014\022\373\020\037$\nFlags\010Name\010Args\016Payload\000\006Udf\014Apply2\004dt\006Arg\014Unwrap\nIndex\024SourceType\014Lookup\014Member\014Invoke\016Collect\014ToFlow\006Map\005\205\006\213\002\204\205\002\207\203\010\036\205\000\204\205\002\203\005@\034column0\030Inputs(Parameters\034Program\013?\010)\251\000?\006\"\000`\000)\251\000?\n\"\000p)\211\002?\020\215?\016 FromFlow\000)\211\006?\036\215\205\002?\002\036?\"?\016F\000)\211(?$\215\205\002?\002\036?(\213\000\206\203\004\206\205\006\203\001H\203\010?\002<_yql_Classifier@_yql_MatchNumber\036\206?.\203\004\205\002\206\205\004\203\010\203\010\020From\010To ALL_TRUE\206?.?\002\213\002\213\002\213\014\203\005@\203\010\203\010\203\014\203\014\203\014\203\010\206?(\206\203\005@\203\014\203\014\203\002\203\005@\203\002\206\205\004\203\010\203\002*.HMatchRecognizeCore\000)\211\006?*\215\205\004\203\014?\002<_yql_OutOfOrder\036?z?((OrderedMap\000)\211\006?|?|?z?x4OrderedFilter\000)\211\020?|\215?\004?\004\207\203d\203\004\203\004\203f\203f\203\004@TimeOrderRecover\000)\211\002?\202?\006B\000?\026\000b)\251\000?\004\"\000Z)\211\004?\206\203\005@?\002:\000\003?\234\024ToIntegral)\211\004?\002?\004\203\0046\000?\232\003?\242\000\002\\\001^\003?\210\002\003?\212\000\003?\214\373#\364\003?\216\003$\364\003?\220\003\022z\370d)\251\000?z\"\000T)\211\002?x?x\014Not\000)\211\004?x?z\203\0046\000?\272\003?\276\000\002V\000X\000f)\251\000?z\"\000P\005?()\211\004?\002?z\203\0046\000?\314\003?\316\002\002R\000\004h)\251\000?(\"\000N\013\213\000\006\000?0)\251\000?8\"\000\036\006\004?:\003\203\004\000\003\203\004\002\003\003?<\002)\251\000?F\"\000:\006\002?H\003\203\004\000\001)\211\004?\002\207\205\002?\002\024Last0\203\0046\000)\211\002?\001\002\206?\376\020Head\000)\211\006?\r\002\206?\002?\002?\376F\000)\211\002?\025\002\215?\002>\000)\211\014?\035\002\215?>?>?\002?\002\203\014?\002$Condense1\000)\211\002?%\002\206?>B\000)\211\002?1\002\206?>>\000)\211\006?9\002?D?B\206?>8OrderedFlatMap\000)\211\004?D?F\203\0046\000?\366\003?I\002\000\002<)\251\000?B\"\0000)\211\006?A\002?>\203\010\203\0064ListFromRange\000)\211\004?>?B\203\0046\000?]\002\003?m\002\000\0026)\211\006?a\002\203\005@?@\203\010:\000\003?}\002\006Add)\211\004?@?B\203\0046\000?]\002\003?\215\002\002\0022\003?\201\002\002\0054\003?e\002\004\0048\000>\000@\000B)\251\000?>\"\000\034)\211\004?\002?6\203\0046\000)\211\n?6\207?6\203\005@\203\005@\203\004\203\004&\000)\211\004?\311\002\210\203\010?6?>2\000)\211\002?\345\002?8,ToIndexDict\000?\346\000 ?\275\002\000*\003?\315\002\000\003?\321\002\000\003?\325\002(\003?\331\002\"\036,\003?\301\002\004\002.)\251\000?\002\"\000\032\003?)\002\000)\211\004?\002?\002?\002 Coalesce\000)\211\004?\002?6\203\0046\000)\211\n?6\207?6\203\005@\203\005@\203\004\203\004&\000)\211\004?-\003?\345\002?>2\000?\361\002?\275\002\000\"\003?1\003\000\003?5\003\000\003?9\003(\003?=\003\"\036$\003?%\003\004\002&?\031\003\000(\020D\000F)\251\000?\002\"\000\030\005?\376?y\003\000\004H\000J\003?\005\002\000\002L\013?Z\013?X\013?V\003?J\020ALL_TRUE\003?L\002\003?N\002\003?P\001\003?R\001\003?T\000?\001\001)\251\000?\\\"\000\026)\251\000?^\"\000\024\006\002?b\003\203\005@\020ALL_TRUE\001\003?d\001\003?f\001\003?h\004\003?j\000\003?l\000\006\002?t\005\205\004\203\010\203\002*.\003?\345\003\000\003?\351\003\004\003\001l\345\017j)\251\000?\"\"\000\006\005?\016)\211\002?\014\203\tH\034ToBytes\000)\211\n?\r\004\207?\r\004\203\005@\203\005@\203\004\203\004&\000)\211\016?\025\004\311\n?\025\004\214(Yson2.Node\207\2144Yson2.Options\207\203\014?=\004?=\004\005\205\004\206\205\004\203\010\203\005@\002\006\203\005@\n\016\006\n?M\004\005\205\004\203\010\203\005@\002\006\003?Y\004\002\003?]\004\000\003\005\205\004\203\010\203\005@\002\006\003?q\004\000\003?u\004\000\003\005\205\004\203\010\203\005@\002\006\003?\211\004\000\003?\215\004\032SkipMapEntity\003\005\205\004\203\010\203\005@\002\006\003?\241\004\000\003?\245\004\024EncodeUtf8\003\005\205\004\203\010\203\005@\002\006\003?\271\004\000\003?\275\004 WriteNanAsString\003\037\003?Q\004\000\003\022\010\203\004\203\005@\203\004\203\004?-\004\207?1\004\032\000)\211\016?\335\004\203\005@\200\203\005@\202\203\005@\203\004\203\004\026\000\003?\371\004&Yson2.SerializeJson\202\003?\375\004\000\002\003?\001\005\000\003?\005\005\022\003?\t\005R\177\014\003?\341\004\000\003?\345\004\000\003?\351\004\022\003?\355\004R)\211\014?-\004\211\002?-\004\205\002\207\203\010\036\022\000\203\004\203\005@\203\004\203\004?\"\032\000)\211\016?E\005\203\005@\200\203\005@\202\203\005@\203\004\203\004\026\000\003?]\005\024Yson2.From\213\006\213\002?A\005?\n\213\000\003?a\005\000\002\003?e\005\000\003?i\005\022\003?m\005z\177\010\003?I\005\000\003?M\005\000\003?Q\005\022\003?U\005z?\t\004\036\n\027?\361\004)\211\016?1\004\311\004?1\004?=\004?=\004\005\205\004\206\205\004\203\010\203\005@\002\006\203\005@\n\016\006\004?\271\005\005\205\004\203\010\203\005@\002\006\003?\305\005\000\003?\311\005\026AutoConvert\003\005\205\004\203\010\203\005@\002\006\003?\335\005\000\003?\341\005\014Strict\003\003\003?\275\005\000\003\022\004\203\004\203\005@\203\004\203\004\207?)\002\207?d\032\000)\211\016?\001\006\203\005@\200\203\005@\202\203\005@\203\004\203\004\026\000\003?!\006\032Yson2.Options\202\003?%\006\000\002\003?)\006\000\003?-\006\022\003?1\006R\177\002\003?\005\006\000\003?\t\006\000\003?\r\006\022\003?\021\006R7?\025\006?\035\0037?\031\006?\321\003~\004^\016\003?\031\004\000\003?\035\004\000\003?!\004\022\003?%\0048\036\020\000\022\000\004l\000n\001/"
scope: "yandexcloud://my_folder"
deadline {
  seconds: 1765628851
  nanos: 554613000
}
tenant: "/compute"
}
2025-12-12T12:27:31.906257Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {expired_at { seconds: 1765542471 nanos: 901000000 } } SUCCESS
2025-12-12T12:27:31.906305Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudq7uem53kjjhdml0, Owner: 9d95934e-c74316bc-fc75cdcf-190f9ed92, Got CP::PingTaskResponse
2025-12-12T12:27:31.907317Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudq7uem53kjjhdml0, Owner: 9d95934e-c74316bc-fc75cdcf-190f9ed92, Request CP::PingTask with size: 316 bytes
2025-12-12T12:27:31.907426Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "9d95934e-c74316bc-fc75cdcf-190f9ed92"
query_id {
  value: "ptqudq7uem53kjjhdml0"
}
status: RUNNING
resources {
  rate_limiter: READY
  compilation: READY
  topic_consumers_state: PREPARE
  rate_limiter_path: "local/RateLimiter_1fb303ed-ed93-4034-ace4-b066e21a3ab1/rate_limiter"
  topic_consumers {
    database: "local"
    topic_path: "test_time_order_recoverer[v1-kikimr0]_v1_input"
    consumer_name: "ptqudq7uem53kjjhdml0"
    cluster_endpoint: "localhost:25827"
    token_name: "cluster:default_myyds"
    add_bearer_to_token: true
  }
}
scope: "yandexcloud://my_folder"
deadline {
  seconds: 1765628851
  nanos: 554613000
}
tenant: "/compute"
}
2025-12-12T12:27:31.916277Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {expired_at { seconds: 1765542471 nanos: 911000000 } } SUCCESS
2025-12-12T12:27:31.916315Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudq7uem53kjjhdml0, Owner: 9d95934e-c74316bc-fc75cdcf-190f9ed92, Got CP::PingTaskResponse
2025-12-12T12:27:31.927881Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudq7uem53kjjhdml0, Owner: 9d95934e-c74316bc-fc75cdcf-190f9ed92, Request CP::PingTask with size: 316 bytes
2025-12-12T12:27:31.927995Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "9d95934e-c74316bc-fc75cdcf-190f9ed92"
query_id {
  value: "ptqudq7uem53kjjhdml0"
}
status: RUNNING
resources {
  rate_limiter: READY
  compilation: READY
  topic_consumers_state: READY
  rate_limiter_path: "local/RateLimiter_1fb303ed-ed93-4034-ace4-b066e21a3ab1/rate_limiter"
  topic_consumers {
    database: "local"
    topic_path: "test_time_order_recoverer[v1-kikimr0]_v1_input"
    consumer_name: "ptqudq7uem53kjjhdml0"
    cluster_endpoint: "localhost:25827"
    token_name: "cluster:default_myyds"
    add_bearer_to_token: true
  }
}
scope: "yandexcloud://my_folder"
deadline {
  seconds: 1765628851
  nanos: 554613000
}
tenant: "/compute"
}
2025-12-12T12:27:31.939974Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {expired_at { seconds: 1765542471 nanos: 933000000 } } SUCCESS
2025-12-12T12:27:31.940007Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudq7uem53kjjhdml0, Owner: 9d95934e-c74316bc-fc75cdcf-190f9ed92, Got CP::PingTaskResponse
2025-12-12T12:27:32.113534Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudq7uem53kjjhdml0"
2025-12-12T12:27:32.113590Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:305: Resolve folder bootstrap. Folder id: my_folder Actor id: [1:7582947093830994900:2234]
2025-12-12T12:27:32.113614Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:367: Cloud id: mock_cloud Folder id: my_folder
2025-12-12T12:27:32.113634Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:91: Get quotas bootstrap. Cloud id: mock_cloud Actor id: [1:7582947093830994901:2235]
2025-12-12T12:27:32.113667Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.analyticsQuery.count IS STALE, Refreshing ...
2025-12-12T12:27:32.113682Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.cpuPercent.count IS STALE, Refreshing ...
2025-12-12T12:27:32.113687Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.streamingQuery.count IS STALE, Refreshing ...
2025-12-12T12:27:32.113719Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.cpuPercent.count=0/10000 REFRESHED
2025-12-12T12:27:32.118292Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.analyticsQuery.count=0/100 REFRESHED
2025-12-12T12:27:32.118340Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.streamingQuery.count=1/100 REFRESHED
2025-12-12T12:27:32.118366Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:493: cloud.mock_cloud{yq.streamingQueryDurationMinutes.count=*/0, yq.queryResult.size=*/20971520, yq.analyticsQuery.count=0/100, yq.analyticsQueryDurationMinutes.count=*/1440, yq.memory.size=*/0, yq.result.size=*/0, yq.cpuPercent.count=0/10000, yq.streamingQuery.count=1/100} SEND QUOTAS
2025-12-12T12:27:32.118396Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:103: Cloud id: mock_cloud Quota count: 8
2025-12-12T12:27:32.118431Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudq7uem53kjjhdml0"
2025-12-12T12:27:32.118523Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:169: Resolve subject type bootstrap. Token: **** (B6C6F477) Actor id: [1:7582947093830994906:2240]
2025-12-12T12:27:32.118571Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:230: Subject Type: federated_account Token: **** (B6C6F477)
2025-12-12T12:27:32.118607Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudq7uem53kjjhdml0"
2025-12-12T12:27:32.118643Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:63: Request actor. Actor id: [1:7582947093830994907:2241]
2025-12-12T12:27:32.118688Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_queries.cpp:641: DescribeQueryRequest: {query_id: "ptqudq7uem53kjjhdml0"
} [root@builtin, **** (B6C6F477)] 
2025-12-12T12:27:32.120960Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.cpuPercent.count=0/10000 NOTIFY CHANGE
2025-12-12T12:27:32.121147Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: DescribeQueryRequest - DescribeQueryResult: {query { meta { common { id: "ptqudq7uem53kjjhdml0" created_by: "root@builtin" modified_by: "root@builtin" created_at { seconds: 1765542450 nanos: 786563000 } modified_at { seconds: 1765542450 nanos: 786563000 } revision: 1 } started_at { seconds: 1765542451 nanos: 606000000 } execute_mode: RUN status: RUNNING last_job_query_revision: 1 last_job_id: "ptjudq7uem53keup7toj-ptqudq7uem53kjjhdml0" started_by: "root@builtin" submitted_at { seconds: 1765542450 nanos: 786563000 } } content { type: STREAMING name: "simple" acl { visibility: PRIVATE } limits { execution_timeout { } } text: "\n            PRAGMA dq.MaxTasksPerStage=\"2\";\n\n            pragma FeatureR010=\"prototype\";\n            pragma config.flags(\"TimeOrderRecoverDelay\", \"-1000000\");\n            pragma config.flags(\"TimeOrderRecoverAhead\", \"1000000\");\n\n            INSERT INTO myyds.`test_time_order_recoverer[v1-kikimr0]_v1_output`\n            SELECT ToBytes(Unwrap(Json::SerializeJson(Yson::From(TableRow()))))\n            FROM (SELECT * FROM myyds.`test_time_order_recoverer[v1-kikimr0]_v1_input`\n                WITH (\n                    format=json_each_row,\n                    SCHEMA\n                    (\n                        dt UINT64\n                    )))\n            MATCH_RECOGNIZE(\n                ORDER BY CAST(dt as Timestamp)\n                MEASURES\n                LAST(ALL_TRUE.dt) as dt\n                ONE ROW PER MATCH\n                PATTERN ( ALL_TRUE )\n                DEFINE\n                    ALL_TRUE as True)" syntax: YQL_V1 } plan { json: "{\"Detailed\":{\"Operations\":[{\"Id\":5,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[{\"Name\":\"DqSourceWideWrap\"},{\"Name\":\"NarrowMap\"}]}},{\"Id\":3,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[{\"Name\":\"TimeOrderRecover\"},{\"Name\":\"OrderedFlatMap\"},{\"Name\":\"MatchRecognizeCore\"},{\"Name\":\"FlatMap\"},{\"Name\":\"FromFlow\"}]},\"DependsOn\":[5]},{\"Id\":2,\"Name\":\"DqQuery!\",\"DependsOn\":[3]},{\"Id\":1,\"Name\":\"Commit!\",\"DependsOn\":[2]}],\"OperationRoot\":1,\"Providers\":[],\"OperationStats\":{\"Commit!\":1,\"DqQuery!\":1,\"DqStage\":2}},\"Basic\":{\"nodes\":[{\"id\":5,\"level\":1,\"name\":\"DqStage #5\",\"type\":\"op\"},{\"id\":3,\"level\":2,\"name\":\"DqStage #3\",\"type\":\"op\"},{\"id\":2,\"level\":3,\"name\":\"DqQuery!\",\"type\":\"op\"},{\"id\":1,\"level\":4,\"name\":\"Commit!\",\"type\":\"op\"}],\"links\":[{\"source\":5,\"target\":3},{\"source\":3,\"target\":2},{\"source\":2,\"target\":1}]}}" } transient_issue { message: "Parse Sql" severity: 2 issues { position { row: 9 column: 41 } message: "Json UDF is deprecated. Please use JSON API instead" end_position { row: 9 column: 41 } issue_code: 4506 severity: 2 } } ast { data: "(\n(let $1 (DataSource \'\"config\"))\n(let $2 (Configure! world $1 \'\"DqEngine\" \'\"force\"))\n(let $3 (Configure! $2 (DataSource \'\"dq\" \'\"$all\") \'\"Attr\" \'\"maxtasksperstage\" \'\"2\"))\n(let $4 (Configure! $3 $1 \'\"TimeOrderRecoverDelay\" \'\"-1000000\"))\n(let $5 (Configure! $4 $1 \'\"TimeOrderRecoverAhead\" \'\"1000000\"))\n(let $6 (DataSource \'\"pq\" \'\"myyds\"))\n(let $7 \'(\'(\'\"PartitionsCount\" \'1)))\n(let $8 (StructType \'(\'dt (OptionalType (DataType \'Uint64)))))\n(let $9 (PqTopic \'\"myyds\" \'\"local\" \'\"test_time_order_recoverer[v1-kikimr0]_v1_input\" $7 \'() $8))\n(let $10 \'(\'dt))\n(let $11 \'(\'\"Endpoint\" \'\"localhost:25827\"))\n(let $12 \'(\'\"SharedReading\" \'0))\n(let $13 \'(\'\"AddBearerToToken\" \'1))\n(let $14 \'($11 $12 \'(\'\"ReconnectPeriod\" \'\"\") \'(\'\"Format\" \'\"json_each_row\") \'(\'\"ReadGroup\" \'\"ptcudq7uemfqqjepn05j\") $13))\n(let $15 (SecureParam \'\"cluster:default_myyds\"))\n(let $16 (DqPqTopicSource $5 $9 $10 $14 $15 \'\"\" $8 \'\"\"))\n(let $17 (DqStage \'((DqSource $6 $16)) (lambda \'($21) (block \'(\n  (let $22 \'(\'(\'\"format\" \'\"json_each_row\") \'(\'\"formatSettings\" \'(\'(\'\"data.datetime.formatname\" \'\"POSIX\") \'(\'\"data.timestamp.formatname\" \'\"POSIX\"))) \'(\'\"settings\" \'($12))))\n  (let $23 (DqSourceWideWrap $21 $6 $8 $22))\n...} SUCCESS
2025-12-12T12:27:32.123809Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.analyticsQuery.count=0/100 NOTIFY CHANGE
2025-12-12T12:27:32.123894Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.streamingQuery.count=1/100 NOTIFY CHANGE
2025-12-12T12:27:32.189151Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudq7uem53kjjhdml0, Owner: 9d95934e-c74316bc-fc75cdcf-190f9ed92, Request CP::PingTask with size: 122 bytes
2025-12-12T12:27:32.189252Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "9d95934e-c74316bc-fc75cdcf-190f9ed92"
query_id {
  value: "ptqudq7uem53kjjhdml0"
}
state_load_mode: FROM_LAST_CHECKPOINT
disposition {
  from_last_checkpoint {
  }
}
scope: "yandexcloud://my_folder"
deadline {
  seconds: 1765628851
  nanos: 554613000
}
tenant: "/compute"
}
2025-12-12T12:27:32.202518Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {expired_at { seconds: 1765542472 nanos: 193000000 } } SUCCESS
2025-12-12T12:27:32.202558Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudq7uem53kjjhdml0, Owner: 9d95934e-c74316bc-fc75cdcf-190f9ed92, Got CP::PingTaskResponse
2025-12-12T12:27:32.500149Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 9d95934e-c74316bc-fc75cdcf-190f9ed94, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 68 bytes
2025-12-12T12:27:32.500247Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "9d95934e-c74316bc-fc75cdcf-190f9ed94"
host: "ghrun-fhkyrtz6p4"
node_id: 1
}
2025-12-12T12:27:32.503488Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:27:32.503526Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 9d95934e-c74316bc-fc75cdcf-190f9ed94, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:27:32.611185Z :FQ_CONTROL_PLANE_CONFIG TRACE: control_plane_config.cpp:192: LOADED TenantInfo: State NOT changed
2025-12-12T12:27:32.930575Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudq7uem53kjjhdml0, Owner: 9d95934e-c74316bc-fc75cdcf-190f9ed92, Request CP::PingTask with size: 591 bytes
2025-12-12T12:27:32.930690Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "9d95934e-c74316bc-fc75cdcf-190f9ed92"
query_id {
  value: "ptqudq7uem53kjjhdml0"
}
statistics: "{\"Graph=0\":{\"TaskRunner\":{\"Stage=204663\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":1,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":1,\"count\":1,\"avg\":1,\"max\":1,\"min\":1}},\"Stage=204683\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":1,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":1,\"count\":1,\"avg\":1,\"max\":1,\"min\":1}},\"Stage=Total\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":2,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":2,\"count\":2,\"avg\":1,\"max\":1,\"min\":1}}}}}"
scope: "yandexcloud://my_folder"
deadline {
  seconds: 1765628851
  nanos: 554613000
}
tenant: "/compute"
}
2025-12-12T12:27:32.940533Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {expired_at { seconds: 1765542472 nanos: 936000000 } } SUCCESS
2025-12-12T12:27:32.940563Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudq7uem53kjjhdml0, Owner: 9d95934e-c74316bc-fc75cdcf-190f9ed92, Got CP::PingTaskResponse
2025-12-12T12:27:33.601446Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582947080946092865:2107]
2025-12-12T12:27:33.601470Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:33.601478Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582947080946092821:2068]
2025-12-12T12:27:33.601497Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582947080946092821:2068]
2025-12-12T12:27:33.601501Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582947080946092821:2068]
2025-12-12T12:27:33.601511Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:34.600864Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:665: Coordinator: Change global state to Started (by timeout)
2025-12-12T12:27:34.924888Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 8f71b000-7466b0e9-41997d65-a6f433e61, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 68 bytes
2025-12-12T12:27:34.924937Z :YQ_CONTROL_PLANE_STORAGE TRACE: nodes_health_check.cpp:38: NodesHealthCheckRequest: {tenant: "/compute"
node {
  node_id: 1
  instance_id: "cbea4aea-4b282d6f-f20607bb-2fc73250"
  hostname: "ghrun-fhkyrtz6p4"
  interconnect_port: 10229
  node_address: "127.0.1.1"
}
}
2025-12-12T12:27:34.925009Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "8f71b000-7466b0e9-41997d65-a6f433e61"
host: "ghrun-fhkyrtz6p4"
node_id: 1
}
2025-12-12T12:27:34.927951Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:27:34.928015Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 8f71b000-7466b0e9-41997d65-a6f433e61, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:27:34.931859Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: NodesHealthCheckRequest - NodesHealthCheckResult: {nodes { node_id: 1 instance_id: "cbea4aea-4b282d6f-f20607bb-2fc73250" hostname: "ghrun-fhkyrtz6p4" node_address: "127.0.1.1" } } SUCCESS
2025-12-12T12:27:35.602351Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582947080946092865:2107]
2025-12-12T12:27:35.602374Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:35.602383Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582947080946092821:2068]
2025-12-12T12:27:35.602387Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582947080946092821:2068]
2025-12-12T12:27:35.602391Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582947080946092821:2068]
2025-12-12T12:27:35.602401Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:35.611252Z :FQ_CONTROL_PLANE_CONFIG TRACE: control_plane_config.cpp:192: LOADED TenantInfo: State NOT changed
2025-12-12T12:27:35.917664Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 8f71b000-7466b0e9-41997d65-a6f433e62, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 68 bytes
2025-12-12T12:27:35.917735Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "8f71b000-7466b0e9-41997d65-a6f433e62"
host: "ghrun-fhkyrtz6p4"
node_id: 1
}
2025-12-12T12:27:35.920390Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:27:35.920429Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 8f71b000-7466b0e9-41997d65-a6f433e62, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:27:35.968279Z :TICKET_PARSER DEBUG: ticket_parser_impl.h:1875: Ticket **** (B6C6F477) (ipv6:[::1]:49826) has now valid token of root@builtin
2025-12-12T12:27:35.968399Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:852: GetStatusRequest: query_id: "ptqudq7uem53kjjhdml0"
2025-12-12T12:27:35.968440Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:305: Resolve folder bootstrap. Folder id: my_folder Actor id: [1:7582947106715896819:2264]
2025-12-12T12:27:35.968474Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:367: Cloud id: mock_cloud Folder id: my_folder
2025-12-12T12:27:35.968508Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:91: Get quotas bootstrap. Cloud id: mock_cloud Actor id: [1:7582947106715896820:2265]
2025-12-12T12:27:35.968539Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.analyticsQuery.count IS STALE, Refreshing ...
2025-12-12T12:27:35.968550Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.cpuPercent.count IS STALE, Refreshing ...
2025-12-12T12:27:35.968561Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.streamingQuery.count IS STALE, Refreshing ...
2025-12-12T12:27:35.968574Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.cpuPercent.count=0/10000 REFRESHED
2025-12-12T12:27:35.974048Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.analyticsQuery.count=0/100 REFRESHED
2025-12-12T12:27:35.974067Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.streamingQuery.count=1/100 REFRESHED
2025-12-12T12:27:35.974085Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:493: cloud.mock_cloud{yq.streamingQueryDurationMinutes.count=*/0, yq.queryResult.size=*/20971520, yq.analyticsQuery.count=0/100, yq.analyticsQueryDurationMinutes.count=*/1440, yq.memory.size=*/0, yq.result.size=*/0, yq.cpuPercent.count=0/10000, yq.streamingQuery.count=1/100} SEND QUOTAS
2025-12-12T12:27:35.974093Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:103: Cloud id: mock_cloud Quota count: 8
2025-12-12T12:27:35.974118Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:852: GetStatusRequest: query_id: "ptqudq7uem53kjjhdml0"
2025-12-12T12:27:35.974190Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:169: Resolve subject type bootstrap. Token: **** (B6C6F477) Actor id: [1:7582947106715896825:2270]
2025-12-12T12:27:35.974238Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:230: Subject Type: federated_account Token: **** (B6C6F477)
2025-12-12T12:27:35.974259Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:852: GetStatusRequest: query_id: "ptqudq7uem53kjjhdml0"
2025-12-12T12:27:35.974285Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:63: Request actor. Actor id: [1:7582947106715896826:2271]
2025-12-12T12:27:35.974361Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_queries.cpp:725: GetQueryStatusRequest: {query_id: "ptqudq7uem53kjjhdml0"
} [root@builtin, **** (B6C6F477)] 
2025-12-12T12:27:35.975321Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.cpuPercent.count=0/10000 NOTIFY CHANGE
2025-12-12T12:27:35.980540Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.analyticsQuery.count=0/100 NOTIFY CHANGE
2025-12-12T12:27:35.980635Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.streamingQuery.count=1/100 NOTIFY CHANGE
2025-12-12T12:27:36.017925Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetQueryStatusRequest - GetQueryStatusResult: {status: RUNNING meta_revision: 10 } SUCCESS
2025-12-12T12:27:36.917955Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 8f71b000-7466b0e9-41997d65-a6f433e63, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 68 bytes
2025-12-12T12:27:36.918026Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "8f71b000-7466b0e9-41997d65-a6f433e63"
host: "ghrun-fhkyrtz6p4"
node_id: 1
}
2025-12-12T12:27:36.921213Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:27:36.921267Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 8f71b000-7466b0e9-41997d65-a6f433e63, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:27:37.603337Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582947080946092865:2107]
2025-12-12T12:27:37.603360Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:37.603368Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582947080946092821:2068]
2025-12-12T12:27:37.603371Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582947080946092821:2068]
2025-12-12T12:27:37.603374Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582947080946092821:2068]
2025-12-12T12:27:37.603383Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:37.918551Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 8f71b000-7466b0e9-41997d65-a6f433e64, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 68 bytes
2025-12-12T12:27:37.918614Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "8f71b000-7466b0e9-41997d65-a6f433e64"
host: "ghrun-fhkyrtz6p4"
node_id: 1
}
2025-12-12T12:27:37.921399Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:27:37.921427Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 8f71b000-7466b0e9-41997d65-a6f433e64, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:27:38.611607Z :FQ_CONTROL_PLANE_CONFIG TRACE: control_plane_config.cpp:192: LOADED TenantInfo: State NOT changed
2025-12-12T12:27:38.918922Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 8f71b000-7466b0e9-41997d65-a6f433e65, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 68 bytes
2025-12-12T12:27:38.918993Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "8f71b000-7466b0e9-41997d65-a6f433e65"
host: "ghrun-fhkyrtz6p4"
node_id: 1
}
2025-12-12T12:27:38.921751Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:27:38.921778Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 8f71b000-7466b0e9-41997d65-a6f433e65, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:27:39.601079Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:599: Coordinator: Send TEvGetNodesRequest to NodesManager
2025-12-12T12:27:39.601099Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:416: Coordinator: TEvUndelivered, ev: TSystem::Undelivered
2025-12-12T12:27:39.601101Z :FQ_ROW_DISPATCHER INFO: coordinator.cpp:419: Coordinator: TEvUndelivered, from nodes manager, reason: ActorUnknown
2025-12-12T12:27:39.604320Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582947080946092865:2107]
2025-12-12T12:27:39.604341Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:39.604348Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582947080946092821:2068]
2025-12-12T12:27:39.604351Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582947080946092821:2068]
2025-12-12T12:27:39.604353Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582947080946092821:2068]
2025-12-12T12:27:39.604368Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:39.917631Z :YQ_CONTROL_PLANE_STORAGE TRACE: nodes_health_check.cpp:38: NodesHealthCheckRequest: {tenant: "/compute"
node {
  node_id: 1
  instance_id: "cbea4aea-4b282d6f-f20607bb-2fc73250"
  hostname: "ghrun-fhkyrtz6p4"
  interconnect_port: 10229
  node_address: "127.0.1.1"
}
}
2025-12-12T12:27:39.919374Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 8f71b000-7466b0e9-41997d65-a6f433e66, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 68 bytes
2025-12-12T12:27:39.919454Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "8f71b000-7466b0e9-41997d65-a6f433e66"
host: "ghrun-fhkyrtz6p4"
node_id: 1
}
2025-12-12T12:27:39.922792Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:27:39.922822Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 8f71b000-7466b0e9-41997d65-a6f433e66, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:27:39.927088Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: NodesHealthCheckRequest - NodesHealthCheckResult: {nodes { node_id: 1 instance_id: "cbea4aea-4b282d6f-f20607bb-2fc73250" hostname: "ghrun-fhkyrtz6p4" node_address: "127.0.1.1" } } SUCCESS
2025-12-12T12:27:40.919863Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 8f71b000-7466b0e9-41997d65-a6f433e67, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 68 bytes
2025-12-12T12:27:40.919941Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "8f71b000-7466b0e9-41997d65-a6f433e67"
host: "ghrun-fhkyrtz6p4"
node_id: 1
}
2025-12-12T12:27:40.922711Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:27:40.922760Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 8f71b000-7466b0e9-41997d65-a6f433e67, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:27:41.605013Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582947080946092865:2107]
2025-12-12T12:27:41.605034Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:41.605041Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582947080946092821:2068]
2025-12-12T12:27:41.605045Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582947080946092821:2068]
2025-12-12T12:27:41.605048Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582947080946092821:2068]
2025-12-12T12:27:41.605060Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:41.611525Z :FQ_CONTROL_PLANE_CONFIG TRACE: control_plane_config.cpp:192: LOADED TenantInfo: State NOT changed
2025-12-12T12:27:41.920192Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 8f71b000-7466b0e9-41997d65-a6f433e68, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 68 bytes
2025-12-12T12:27:41.920248Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "8f71b000-7466b0e9-41997d65-a6f433e68"
host: "ghrun-fhkyrtz6p4"
node_id: 1
}
2025-12-12T12:27:41.925086Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:27:41.925117Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 8f71b000-7466b0e9-41997d65-a6f433e68, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:27:42.920763Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 8f71b000-7466b0e9-41997d65-a6f433e69, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 68 bytes
2025-12-12T12:27:42.920847Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "8f71b000-7466b0e9-41997d65-a6f433e69"
host: "ghrun-fhkyrtz6p4"
node_id: 1
}
2025-12-12T12:27:42.924497Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:27:42.924526Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 8f71b000-7466b0e9-41997d65-a6f433e69, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:27:43.605936Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582947080946092865:2107]
2025-12-12T12:27:43.605958Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:43.605965Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582947080946092821:2068]
2025-12-12T12:27:43.605969Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582947080946092821:2068]
2025-12-12T12:27:43.605972Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582947080946092821:2068]
2025-12-12T12:27:43.605985Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:43.921267Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 8f71b000-7466b0e9-41997d65-a6f433e610, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 69 bytes
2025-12-12T12:27:43.921338Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "8f71b000-7466b0e9-41997d65-a6f433e610"
host: "ghrun-fhkyrtz6p4"
node_id: 1
}
2025-12-12T12:27:43.925058Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:27:43.925106Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 8f71b000-7466b0e9-41997d65-a6f433e610, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:27:44.612497Z :FQ_CONTROL_PLANE_CONFIG TRACE: control_plane_config.cpp:192: LOADED TenantInfo: State NOT changed
2025-12-12T12:27:44.917772Z :YQ_CONTROL_PLANE_STORAGE TRACE: nodes_health_check.cpp:38: NodesHealthCheckRequest: {tenant: "/compute"
node {
  node_id: 1
  instance_id: "cbea4aea-4b282d6f-f20607bb-2fc73250"
  hostname: "ghrun-fhkyrtz6p4"
  interconnect_port: 10229
  node_address: "127.0.1.1"
}
}
2025-12-12T12:27:44.921531Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 8f71b000-7466b0e9-41997d65-a6f433e611, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 69 bytes
2025-12-12T12:27:44.921585Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "8f71b000-7466b0e9-41997d65-a6f433e611"
host: "ghrun-fhkyrtz6p4"
node_id: 1
}
2025-12-12T12:27:44.924343Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:27:44.924391Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 8f71b000-7466b0e9-41997d65-a6f433e611, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:27:44.924776Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: NodesHealthCheckRequest - NodesHealthCheckResult: {nodes { node_id: 1 instance_id: "cbea4aea-4b282d6f-f20607bb-2fc73250" hostname: "ghrun-fhkyrtz6p4" node_address: "127.0.1.1" } } SUCCESS
2025-12-12T12:27:45.607113Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582947080946092865:2107]
2025-12-12T12:27:45.607128Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:45.607136Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582947080946092821:2068]
2025-12-12T12:27:45.607140Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582947080946092821:2068]
2025-12-12T12:27:45.607142Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582947080946092821:2068]
2025-12-12T12:27:45.607152Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:45.922207Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 8f71b000-7466b0e9-41997d65-a6f433e612, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 69 bytes
2025-12-12T12:27:45.922271Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "8f71b000-7466b0e9-41997d65-a6f433e612"
host: "ghrun-fhkyrtz6p4"
node_id: 1
}
2025-12-12T12:27:45.925800Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:27:45.925841Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 8f71b000-7466b0e9-41997d65-a6f433e612, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:27:46.922511Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 8f71b000-7466b0e9-41997d65-a6f433e613, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 69 bytes
2025-12-12T12:27:46.922586Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "8f71b000-7466b0e9-41997d65-a6f433e613"
host: "ghrun-fhkyrtz6p4"
node_id: 1
}
2025-12-12T12:27:46.928579Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:27:46.928642Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 8f71b000-7466b0e9-41997d65-a6f433e613, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:27:47.608122Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582947080946092865:2107]
2025-12-12T12:27:47.608144Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:47.608151Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582947080946092821:2068]
2025-12-12T12:27:47.608155Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582947080946092821:2068]
2025-12-12T12:27:47.608160Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582947080946092821:2068]
2025-12-12T12:27:47.608170Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:47.616285Z :FQ_CONTROL_PLANE_CONFIG TRACE: control_plane_config.cpp:192: LOADED TenantInfo: State NOT changed
2025-12-12T12:27:47.923116Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 8f71b000-7466b0e9-41997d65-a6f433e614, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 69 bytes
2025-12-12T12:27:47.923186Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "8f71b000-7466b0e9-41997d65-a6f433e614"
host: "ghrun-fhkyrtz6p4"
node_id: 1
}
2025-12-12T12:27:47.926313Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:27:47.926358Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 8f71b000-7466b0e9-41997d65-a6f433e614, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:27:48.923610Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 8f71b000-7466b0e9-41997d65-a6f433e615, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 69 bytes
2025-12-12T12:27:48.923694Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "8f71b000-7466b0e9-41997d65-a6f433e615"
host: "ghrun-fhkyrtz6p4"
node_id: 1
}
2025-12-12T12:27:48.926712Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:27:48.926758Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 8f71b000-7466b0e9-41997d65-a6f433e615, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:27:49.601496Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:416: Coordinator: TEvUndelivered, ev: TSystem::Undelivered
2025-12-12T12:27:49.601507Z :FQ_ROW_DISPATCHER INFO: coordinator.cpp:419: Coordinator: TEvUndelivered, from nodes manager, reason: ActorUnknown
2025-12-12T12:27:49.608589Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582947080946092865:2107]
2025-12-12T12:27:49.608606Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:49.608613Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582947080946092821:2068]
2025-12-12T12:27:49.608616Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582947080946092821:2068]
2025-12-12T12:27:49.608619Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582947080946092821:2068]
2025-12-12T12:27:49.608629Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:49.918221Z :YQ_CONTROL_PLANE_STORAGE TRACE: nodes_health_check.cpp:38: NodesHealthCheckRequest: {tenant: "/compute"
node {
  node_id: 1
  instance_id: "cbea4aea-4b282d6f-f20607bb-2fc73250"
  hostname: "ghrun-fhkyrtz6p4"
  interconnect_port: 10229
  node_address: "127.0.1.1"
}
}
2025-12-12T12:27:49.923943Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 8f71b000-7466b0e9-41997d65-a6f433e616, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 69 bytes
2025-12-12T12:27:49.924007Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "8f71b000-7466b0e9-41997d65-a6f433e616"
host: "ghrun-fhkyrtz6p4"
node_id: 1
}
2025-12-12T12:27:49.926617Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:27:49.926725Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 8f71b000-7466b0e9-41997d65-a6f433e616, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:27:49.927043Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: NodesHealthCheckRequest - NodesHealthCheckResult: {nodes { node_id: 1 instance_id: "cbea4aea-4b282d6f-f20607bb-2fc73250" hostname: "ghrun-fhkyrtz6p4" node_address: "127.0.1.1" } } SUCCESS
2025-12-12T12:27:50.617066Z :FQ_CONTROL_PLANE_CONFIG TRACE: control_plane_config.cpp:192: LOADED TenantInfo: State NOT changed
2025-12-12T12:27:50.927729Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 8f71b000-7466b0e9-41997d65-a6f433e617, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 69 bytes
2025-12-12T12:27:50.927780Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "8f71b000-7466b0e9-41997d65-a6f433e617"
host: "ghrun-fhkyrtz6p4"
node_id: 1
}
2025-12-12T12:27:50.934233Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:27:50.934275Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 8f71b000-7466b0e9-41997d65-a6f433e617, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:27:51.609771Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582947080946092865:2107]
2025-12-12T12:27:51.609789Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:51.609806Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582947080946092821:2068]
2025-12-12T12:27:51.609810Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582947080946092821:2068]
2025-12-12T12:27:51.609812Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582947080946092821:2068]
2025-12-12T12:27:51.609818Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:51.927217Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 8f71b000-7466b0e9-41997d65-a6f433e618, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 69 bytes
2025-12-12T12:27:51.927274Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "8f71b000-7466b0e9-41997d65-a6f433e618"
host: "ghrun-fhkyrtz6p4"
node_id: 1
}
2025-12-12T12:27:51.931382Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:27:51.931441Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 8f71b000-7466b0e9-41997d65-a6f433e618, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:27:52.925693Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 8f71b000-7466b0e9-41997d65-a6f433e619, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 69 bytes
2025-12-12T12:27:52.925768Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "8f71b000-7466b0e9-41997d65-a6f433e619"
host: "ghrun-fhkyrtz6p4"
node_id: 1
}
2025-12-12T12:27:52.932204Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:27:52.932316Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 8f71b000-7466b0e9-41997d65-a6f433e619, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:27:53.610402Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582947080946092865:2107]
2025-12-12T12:27:53.610419Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:53.610424Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582947080946092821:2068]
2025-12-12T12:27:53.610429Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582947080946092821:2068]
2025-12-12T12:27:53.610432Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582947080946092821:2068]
2025-12-12T12:27:53.610440Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:53.619502Z :FQ_CONTROL_PLANE_CONFIG TRACE: control_plane_config.cpp:192: LOADED TenantInfo: State NOT changed
2025-12-12T12:27:53.931294Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 8f71b000-7466b0e9-41997d65-a6f433e620, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 69 bytes
2025-12-12T12:27:53.931362Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "8f71b000-7466b0e9-41997d65-a6f433e620"
host: "ghrun-fhkyrtz6p4"
node_id: 1
}
2025-12-12T12:27:53.947306Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:456: Task (Query): ptqudq7uem53kjjhdml0 Lease TIMEOUT, RetryCounterUpdatedAt 2025-12-12T12:27:30.878776Z LastSeenAt: 2025-12-12T12:27:32.936154Z
2025-12-12T12:27:53.947326Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:463: Task (Query): ptqudq7uem53kjjhdml0 RetryRate: 0.9995237551 RetryCounter: 1 At: 2025-12-12T12:27:53.947250Z
2025-12-12T12:27:53.971742Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {tasks { query_id { value: "ptqudq7uem53kjjhdml0" } job_id { value: "ptjudq7uem53keup7toj" } generation: 2 streaming: true dq_graph: "\022\210\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*\233\003Z\230\003\n\010PqSource\022\211\003\n4type.googleapis.com/NYql.NPq.NProto.TDqPqTopicSource\022\320\002\n.test_time_order_recoverer[v1-kikimr0]_v1_input\022\024ptqudq7uem53kjjhdml0\032\017localhost:25827\"\027\n\025cluster:default_myyds*\005local0\002@\001b\002dtj&[\"OptionalType\";[\"DataType\";\"Uint64\"]]\222\001\024ptcudq7uemfqqjepn05j\232\001\rjson_each_row\242\001>[\"StructType\";[[\"dt\";[\"OptionalType\";[\"DataType\";\"Uint64\"]]]]]\262\001\002\022\000\272\001\026\n\010cloud_id\022\nmock_cloud\272\001 \n\005scope\022\027yandexcloud://my_folder\030\0012D\n@\010\001\020\240\234\001\030\001 \002*\024\n\022\t\000\000\000\000\000\000\000\000\021\000\000\000\000\001\000\000\0002\024\n\022\t\000\000\000\000\000\000\000\000\021\000\000\000\000\002\000\000\000P\001X\367\276\014`\213\277\014R\000:\203\001\n*type.googleapis.com/Yql.DqsProto.TTaskMeta\022U\010\367\276\014\022A\022(88a034dc314301cb1522a933e690a4c49a7591e8\032\023dq_vanilla_job.lite \002\"\014\n\002pq\022\006\n\004\010\001\030\001H\367\276\014RClocal/RateLimiter_1fb303ed-ed93-4034-ace4-b066e21a3ab1/rate_limiterZ)mock_cloud/my_folder/ptqudq7uem53kjjhdml0`\200\200\200\200 \230\001\000\300\001\001\022\210\004\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*D\n@\010\001\020\240\234\001\030\001 \002*\024\n\022\t\000\000\000\000\000\000\000\000\021\000\000\000\000\001\000\000\0002\024\n\022\t\000\000\000\000\000\000\000\000\021\000\000\000\000\002\000\000\000P\001X\367\276\014`\213\277\014R\0002\252\001z\247\001\n\006PqSink\022\234\001\n2type.googleapis.com/NYql.NPq.NProto.TDqPqTopicSink\022f\n/test_time_order_recoverer[v1-kikimr0]_v1_output\022\017localhost:25827\032\027\n\025cluster:default_myyds\"\005local0\0018\002:u\n*type.googleapis.com/Yql.DqsProto.TTaskMeta\022G\010\213\277\014\022A\022(88a034dc314301cb1522a933e690a4c49a7591e8\032\023dq_vanilla_job.lite \002H\213\277\014RClocal/RateLimiter_1fb303ed-ed93-4034-ace4-b066e21a3ab1/rate_limiterZ)mock_cloud/my_folder/ptqudq7uem53kjjhdml0`\200\200\200\200 \230\001\000\300\001\0012qptqudq7uem53kjjhdml0#ptrudq7uelc354pr4d63#yandexcloud://my_folder#9d95934e-c74316bc-fc75cdcf-190f9ed92#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\265\003\010\367\276\014\022\256\003\037\004\006Arg\004dt\005\205\006\213\002\204\203\005@\205\000\204\205\002\207\203\010\006\030Inputs(Parameters\034Program\013?\004)\251\000?\002\002\000\010\000)\251\000?\006\002\000\026)\211\002?\016\215?\014 FromFlow\000)\211\006?\034\215\233\002?\n?\n?\014$NarrowMap\000)\211\006?\"\215\205\002?\n\006?&?\n$ExpandMap\000)\211\002?(\204?&\030ToFlow\000)\211\014?,\211\004?,\204\203\005@\207\203\001H\014UDF\002\203\004\203\005@\203\004\203\004?\002\030Apply2\000)\211\010?8\203\005@\200\203\005@\202\014Udf\000\003?D8ClickHouseClient.ParseFormat\213\006\213\002\204\203\005@?\006?&\003?F\252json_each_row{\"data.datetime.formatname\":\"POSIX\",\"data.timestamp.formatname\":\"POSIX\"}\002\017\n\003?:\000\003?<\000\003?>\000\003?@\000?\024\036\014\000\016)\251\000?&\002\000\004)\211\004?\n?&\203\004\030Member\000?f\003?h\000\002\006\000\020)\251\000?\n\002\000\002\005?\014?t\000\004\022\000\024\001/b\202\021\010\213\277\014\022\373\020\037$\nFlags\010Name\010Args\016Payload\000\006Udf\014Apply2\004dt\006Arg\014Unwrap\nIndex\024SourceType\014Lookup\014Member\014Invoke\016Co...} SUCCESS
2025-12-12T12:27:53.971857Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 8f71b000-7466b0e9-41997d65-a6f433e620, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:27:53.979717Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 8f71b000-7466b0e9-41997d65-a6f433e621, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 69 bytes
2025-12-12T12:27:53.979741Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudq7uem53kjjhdml0, Owner: 8f71b000-7466b0e9-41997d65-a6f433e620, Request CP::PingTask with size: 315 bytes
2025-12-12T12:27:53.979782Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "8f71b000-7466b0e9-41997d65-a6f433e621"
host: "ghrun-fhkyrtz6p4"
node_id: 1
}
2025-12-12T12:27:53.979906Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "8f71b000-7466b0e9-41997d65-a6f433e620"
query_id {
  value: "ptqudq7uem53kjjhdml0"
}
resources {
  rate_limiter: READY
  compilation: READY
  topic_consumers_state: READY
  rate_limiter_path: "local/RateLimiter_1fb303ed-ed93-4034-ace4-b066e21a3ab1/rate_limiter"
  topic_consumers {
    database: "local"
    topic_path: "test_time_order_recoverer[v1-kikimr0]_v1_input"
    consumer_name: "ptqudq7uem53kjjhdml0"
    cluster_endpoint: "localhost:25827"
    token_name: "cluster:default_myyds"
    add_bearer_to_token: true
  }
}
scope: "yandexcloud://my_folder"
deadline {
  seconds: 1765628873
  nanos: 960993000
}
tenant: "/compute"
}
2025-12-12T12:27:53.983119Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:27:53.983210Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 8f71b000-7466b0e9-41997d65-a6f433e621, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:27:54.011392Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {expired_at { seconds: 1765542493 nanos: 991000000 } } SUCCESS
2025-12-12T12:27:54.011457Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudq7uem53kjjhdml0, Owner: 8f71b000-7466b0e9-41997d65-a6f433e620, Got CP::PingTaskResponse
2025-12-12T12:27:54.394602Z :TICKET_PARSER DEBUG: ticket_parser_impl.h:1875: Ticket **** (B6C6F477) (ipv6:[::1]:49826) has now valid token of root@builtin
2025-12-12T12:27:54.394690Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:1061: ControlQueryRequest: query_id: "ptqudq7uem53kjjhdml0"
action: ABORT
2025-12-12T12:27:54.394737Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:305: Resolve folder bootstrap. Folder id: my_folder Actor id: [1:7582947188320275530:2350]
2025-12-12T12:27:54.394753Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:367: Cloud id: mock_cloud Folder id: my_folder
2025-12-12T12:27:54.394767Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:91: Get quotas bootstrap. Cloud id: mock_cloud Actor id: [1:7582947188320275531:2351]
2025-12-12T12:27:54.394781Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.analyticsQuery.count IS STALE, Refreshing ...
2025-12-12T12:27:54.394788Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.cpuPercent.count IS STALE, Refreshing ...
2025-12-12T12:27:54.394790Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.streamingQuery.count IS STALE, Refreshing ...
2025-12-12T12:27:54.394857Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.cpuPercent.count=0/10000 REFRESHED
2025-12-12T12:27:54.403741Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.analyticsQuery.count=0/100 REFRESHED
2025-12-12T12:27:54.403770Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.streamingQuery.count=1/100 REFRESHED
2025-12-12T12:27:54.403802Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:493: cloud.mock_cloud{yq.streamingQueryDurationMinutes.count=*/0, yq.queryResult.size=*/20971520, yq.analyticsQuery.count=0/100, yq.analyticsQueryDurationMinutes.count=*/1440, yq.memory.size=*/0, yq.result.size=*/0, yq.cpuPercent.count=0/10000, yq.streamingQuery.count=1/100} SEND QUOTAS
2025-12-12T12:27:54.403814Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:103: Cloud id: mock_cloud Quota count: 8
2025-12-12T12:27:54.403868Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:1061: ControlQueryRequest: query_id: "ptqudq7uem53kjjhdml0"
action: ABORT
2025-12-12T12:27:54.403950Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:169: Resolve subject type bootstrap. Token: **** (B6C6F477) Actor id: [1:7582947188320275536:2356]
2025-12-12T12:27:54.403978Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:230: Subject Type: federated_account Token: **** (B6C6F477)
2025-12-12T12:27:54.404003Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:1061: ControlQueryRequest: query_id: "ptqudq7uem53kjjhdml0"
action: ABORT
2025-12-12T12:27:54.404022Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:63: Request actor. Actor id: [1:7582947188320275537:2357]
2025-12-12T12:27:54.404091Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_queries.cpp:1342: ControlQueryRequest: {query_id: "ptqudq7uem53kjjhdml0"
action: ABORT
} [root@builtin, **** (B6C6F477)] 
2025-12-12T12:27:54.407353Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.cpuPercent.count=0/10000 NOTIFY CHANGE
2025-12-12T12:27:54.410757Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.analyticsQuery.count=0/100 NOTIFY CHANGE
2025-12-12T12:27:54.410773Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.streamingQuery.count=1/100 NOTIFY CHANGE
2025-12-12T12:27:54.613434Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: ControlQueryRequest - ControlQueryRequest: {} SUCCESS
2025-12-12T12:27:54.617056Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudq7uem53kjjhdml0"
2025-12-12T12:27:54.617111Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:305: Resolve folder bootstrap. Folder id: my_folder Actor id: [1:7582947188320275541:2360]
2025-12-12T12:27:54.617128Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:367: Cloud id: mock_cloud Folder id: my_folder
2025-12-12T12:27:54.617152Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:91: Get quotas bootstrap. Cloud id: mock_cloud Actor id: [1:7582947188320275542:2361]
2025-12-12T12:27:54.617181Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.analyticsQuery.count IS STALE, Refreshing ...
2025-12-12T12:27:54.617193Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.cpuPercent.count IS STALE, Refreshing ...
2025-12-12T12:27:54.617197Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.streamingQuery.count IS STALE, Refreshing ...
2025-12-12T12:27:54.617226Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.cpuPercent.count=0/10000 REFRESHED
2025-12-12T12:27:54.624362Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.analyticsQuery.count=0/100 REFRESHED
2025-12-12T12:27:54.624406Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.streamingQuery.count=1/100 REFRESHED
2025-12-12T12:27:54.624430Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:493: cloud.mock_cloud{yq.streamingQueryDurationMinutes.count=*/0, yq.queryResult.size=*/20971520, yq.analyticsQuery.count=0/100, yq.analyticsQueryDurationMinutes.count=*/1440, yq.memory.size=*/0, yq.result.size=*/0, yq.cpuPercent.count=0/10000, yq.streamingQuery.count=1/100} SEND QUOTAS
2025-12-12T12:27:54.624447Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:103: Cloud id: mock_cloud Quota count: 8
2025-12-12T12:27:54.624492Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudq7uem53kjjhdml0"
2025-12-12T12:27:54.624550Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:169: Resolve subject type bootstrap. Token: **** (B6C6F477) Actor id: [1:7582947188320275547:2366]
2025-12-12T12:27:54.624589Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:230: Subject Type: federated_account Token: **** (B6C6F477)
2025-12-12T12:27:54.624624Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudq7uem53kjjhdml0"
2025-12-12T12:27:54.624659Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:63: Request actor. Actor id: [1:7582947188320275548:2367]
2025-12-12T12:27:54.624699Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_queries.cpp:641: DescribeQueryRequest: {query_id: "ptqudq7uem53kjjhdml0"
} [root@builtin, **** (B6C6F477)] 
2025-12-12T12:27:54.624828Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.cpuPercent.count=0/10000 NOTIFY CHANGE
2025-12-12T12:27:54.627831Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: DescribeQueryRequest - DescribeQueryResult: {query { meta { common { id: "ptqudq7uem53kjjhdml0" created_by: "root@builtin" modified_by: "root@builtin" created_at { seconds: 1765542450 nanos: 786563000 } modified_at { seconds: 1765542474 nanos: 535188000 } revision: 2 } started_at { seconds: 1765542451 nanos: 606000000 } execute_mode: RUN status: ABORTING_BY_USER last_job_query_revision: 1 last_job_id: "ptjudq7uem53keup7toj-ptqudq7uem53kjjhdml0" started_by: "root@builtin" aborted_by: "root@builtin" has_saved_checkpoints: true submitted_at { seconds: 1765542450 nanos: 786563000 } } content { type: STREAMING name: "simple" acl { visibility: PRIVATE } limits { execution_timeout { } } text: "\n            PRAGMA dq.MaxTasksPerStage=\"2\";\n\n            pragma FeatureR010=\"prototype\";\n            pragma config.flags(\"TimeOrderRecoverDelay\", \"-1000000\");\n            pragma config.flags(\"TimeOrderRecoverAhead\", \"1000000\");\n\n            INSERT INTO myyds.`test_time_order_recoverer[v1-kikimr0]_v1_output`\n            SELECT ToBytes(Unwrap(Json::SerializeJson(Yson::From(TableRow()))))\n            FROM (SELECT * FROM myyds.`test_time_order_recoverer[v1-kikimr0]_v1_input`\n                WITH (\n                    format=json_each_row,\n                    SCHEMA\n                    (\n                        dt UINT64\n                    )))\n            MATCH_RECOGNIZE(\n                ORDER BY CAST(dt as Timestamp)\n                MEASURES\n                LAST(ALL_TRUE.dt) as dt\n                ONE ROW PER MATCH\n                PATTERN ( ALL_TRUE )\n                DEFINE\n                    ALL_TRUE as True)" syntax: YQL_V1 } plan { json: "{\"Detailed\":{\"Operations\":[{\"Id\":5,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[{\"Name\":\"DqSourceWideWrap\"},{\"Name\":\"NarrowMap\"}]}},{\"Id\":3,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[{\"Name\":\"TimeOrderRecover\"},{\"Name\":\"OrderedFlatMap\"},{\"Name\":\"MatchRecognizeCore\"},{\"Name\":\"FlatMap\"},{\"Name\":\"FromFlow\"}]},\"DependsOn\":[5]},{\"Id\":2,\"Name\":\"DqQuery!\",\"DependsOn\":[3]},{\"Id\":1,\"Name\":\"Commit!\",\"DependsOn\":[2]}],\"OperationRoot\":1,\"Providers\":[],\"OperationStats\":{\"Commit!\":1,\"DqQuery!\":1,\"DqStage\":2}},\"Basic\":{\"nodes\":[{\"id\":5,\"level\":1,\"name\":\"DqStage #5\",\"type\":\"op\"},{\"id\":3,\"level\":2,\"name\":\"DqStage #3\",\"type\":\"op\"},{\"id\":2,\"level\":3,\"name\":\"DqQuery!\",\"type\":\"op\"},{\"id\":1,\"level\":4,\"name\":\"Commit!\",\"type\":\"op\"}],\"links\":[{\"source\":5,\"target\":3},{\"source\":3,\"target\":2},{\"source\":2,\"target\":1}]}}" } transient_issue { message: "Parse Sql" severity: 2 issues { position { row: 9 column: 41 } message: "Json UDF is deprecated. Please use JSON API instead" end_position { row: 9 column: 41 } issue_code: 4506 severity: 2 } } statistics { json: "{\"Graph=0\":{\"Tasks\":{\"sum\":2,\"count\":2,\"avg\":1,\"max\":1,\"min\":1},\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":2,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"}}}" } ast { data: "(\n(let $1 (DataSource \'\"config\"))\n(let $2 (Configure! world $1 \'\"DqEngine\" \'\"force\"))\n(let $3 (Configure! $2 (DataSource \'\"dq\" \'\"$all\") \'\"Attr\" \'\"maxtasksperstage\" \'\"2\"))\n(let $4 (Configure! $3 $1 \'\"TimeOrderRecoverDelay\" \'\"-1000000\"))\n(let $5 (Configure! $4 $1 \'\"TimeOrderRecoverAhead\" \'\"1000000\"))\n(let $6 (DataSource \'\"pq\" \'\"myyds\"))\n(let $7 \'(\'(\'\"PartitionsCount\" \'1)))\n(let $8 (StructType \'(\'dt (OptionalType (DataType \'Uint64)))))\n(let $9 (PqTopic \'\"myyds\" \'\"local\" \'\"test_time_order_recoverer[v1-kikimr0]_v1_input\" $7 \'() $8))\n(let $10 \'(\'dt))\n(let $11 \'(\'\"Endpoint\" \'\"localhost:25827\"))\n(let $12 \'(\'\"SharedReading\" \'0))\n(let $13 \'(\'\"AddBearerToToken\" \'1))\n(let $14 \'($11 $12 \'(\'\"ReconnectPeriod\" \'\"\") \'(\'\"Format\" \'\"json_each_row\") \'(\'\"ReadGroup\" \'\"ptcudq7uemfqqjepn05j\") $13))\n(let $15 (SecureParam \'\"cluster:default_myyds\"))\n(let $16 (DqPqTopicSource $5 $9 $10 $14 $15 \'\"\" $8 \'\"\"))\n(let $17 (DqStage \'((DqSource $6 $16)) (lambda \'($...} SUCCESS
2025-12-12T12:27:54.632966Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.analyticsQuery.count=0/100 NOTIFY CHANGE
2025-12-12T12:27:54.633519Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.streamingQuery.count=1/100 NOTIFY CHANGE
2025-12-12T12:27:54.918350Z :YQ_CONTROL_PLANE_STORAGE TRACE: nodes_health_check.cpp:38: NodesHealthCheckRequest: {tenant: "/compute"
node {
  node_id: 1
  instance_id: "cbea4aea-4b282d6f-f20607bb-2fc73250"
  hostname: "ghrun-fhkyrtz6p4"
  active_workers: 2
  memory_allocated: 17179869184
  interconnect_port: 10229
  node_address: "127.0.1.1"
}
}
2025-12-12T12:27:54.926179Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 8f71b000-7466b0e9-41997d65-a6f433e622, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 69 bytes
2025-12-12T12:27:54.926242Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "8f71b000-7466b0e9-41997d65-a6f433e622"
host: "ghrun-fhkyrtz6p4"
node_id: 1
}
2025-12-12T12:27:54.928815Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:27:54.928856Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 8f71b000-7466b0e9-41997d65-a6f433e622, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:27:54.930826Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: NodesHealthCheckRequest - NodesHealthCheckResult: {nodes { node_id: 1 instance_id: "cbea4aea-4b282d6f-f20607bb-2fc73250" hostname: "ghrun-fhkyrtz6p4" active_workers: 2 memory_allocated: 17179869184 node_address: "127.0.1.1" } } SUCCESS
2025-12-12T12:27:55.045272Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudq7uem53kjjhdml0, Owner: 8f71b000-7466b0e9-41997d65-a6f433e620, Request CP::PingTask with size: 592 bytes
2025-12-12T12:27:55.045397Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "8f71b000-7466b0e9-41997d65-a6f433e620"
query_id {
  value: "ptqudq7uem53kjjhdml0"
}
statistics: "{\"Graph=0\":{\"TaskRunner\":{\"Stage=204663\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":1,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":1,\"count\":1,\"avg\":1,\"max\":1,\"min\":1}},\"Stage=204683\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":1,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":1,\"count\":1,\"avg\":1,\"max\":1,\"min\":1}},\"Stage=Total\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":2,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":2,\"count\":2,\"avg\":1,\"max\":1,\"min\":1}}}}}"
scope: "yandexcloud://my_folder"
deadline {
  seconds: 1765628873
  nanos: 960993000
}
tenant: "/compute"
}
2025-12-12T12:27:55.057031Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {action: ABORT expired_at { seconds: 1765542495 nanos: 51000000 } } SUCCESS
2025-12-12T12:27:55.057076Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudq7uem53kjjhdml0, Owner: 8f71b000-7466b0e9-41997d65-a6f433e620, Got CP::PingTaskResponse
2025-12-12T12:27:55.058223Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudq7uem53kjjhdml0, Owner: 8f71b000-7466b0e9-41997d65-a6f433e620, Request CP::PingTask with size: 117 bytes
2025-12-12T12:27:55.058299Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "8f71b000-7466b0e9-41997d65-a6f433e620"
query_id {
  value: "ptqudq7uem53kjjhdml0"
}
status: ABORTING_BY_USER
scope: "yandexcloud://my_folder"
deadline {
  seconds: 1765628873
  nanos: 960993000
}
tenant: "/compute"
}
2025-12-12T12:27:55.069762Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {action: ABORT expired_at { seconds: 1765542495 nanos: 62000000 } } SUCCESS
2025-12-12T12:27:55.069833Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudq7uem53kjjhdml0, Owner: 8f71b000-7466b0e9-41997d65-a6f433e620, Got CP::PingTaskResponse
2025-12-12T12:27:55.070972Z :YQL_PRIVATE_PROXY DEBUG: rate_limiter_resources.cpp:175: PrivateDeleteRateLimiterResource - QueryId: ptqudq7uem53kjjhdml0, Owner: 8f71b000-7466b0e9-41997d65-a6f433e620, Request CP::DeleteRateLimiterResource with size: 98 bytes
2025-12-12T12:27:55.071062Z :YQ_CONTROL_PLANE_STORAGE TRACE: request_actor.h:57: DeleteRateLimiterResourceRequest: {owner_id: "8f71b000-7466b0e9-41997d65-a6f433e620"
query_id {
  value: "ptqudq7uem53kjjhdml0"
}
scope: "yandexcloud://my_folder"
tenant: "/compute"
} 
2025-12-12T12:27:55.112138Z :YQ_CONTROL_PLANE_STORAGE DEBUG: rate_limiter_resources.cpp:74: DeleteRateLimiterResourceRequest. Got response from database: SUCCESS
2025-12-12T12:27:55.112294Z :YQ_RATE_LIMITER DEBUG: schema.cpp:71: Run delete rate limiter resource "mock_cloud/my_folder/ptqudq7uem53kjjhdml0" actor
2025-12-12T12:27:55.112318Z :YQ_RATE_LIMITER DEBUG: schema.cpp:113: Call delete rate limiter resource "mock_cloud/my_folder/ptqudq7uem53kjjhdml0"
2025-12-12T12:27:55.114527Z :YQ_RATE_LIMITER DEBUG: schema.cpp:179: Successfully deleted rate limiter resource "mock_cloud/my_folder/ptqudq7uem53kjjhdml0"
2025-12-12T12:27:55.114538Z :YQ_RATE_LIMITER DEBUG: schema.cpp:122: Reply for delete rate limiter resource "mock_cloud/my_folder/ptqudq7uem53kjjhdml0": 
2025-12-12T12:27:55.114563Z :YQ_CONTROL_PLANE_STORAGE DEBUG: rate_limiter_resources.cpp:219: Got delete response from rate limiter service
2025-12-12T12:27:55.114595Z :YQL_PRIVATE_PROXY DEBUG: rate_limiter_resources.cpp:199: PrivateDeleteRateLimiterResource - QueryId: ptqudq7uem53kjjhdml0, Owner: 8f71b000-7466b0e9-41997d65-a6f433e620, Got CP::DeleteRateLimiterResourceResponse
2025-12-12T12:27:55.115804Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudq7uem53kjjhdml0, Owner: 8f71b000-7466b0e9-41997d65-a6f433e620, Request CP::PingTask with size: 1178 bytes
2025-12-12T12:27:55.115930Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "8f71b000-7466b0e9-41997d65-a6f433e620"
query_id {
  value: "ptqudq7uem53kjjhdml0"
}
result_id {
  value: "ptrudq7ue01e8skng8d6"
}
status: ABORTED_BY_USER
issues {
  message: "ABORTED_BY_USER"
  severity: 1
}
statistics: "{\"Graph=0\":{\"Actor\":{\"ActorCreateTimeUs\":{\"sum\":\"0.13s\",\"count\":2,\"avg\":\"65ms\",\"max\":\"65ms\",\"min\":\"65ms\"}},\"AllocateWorkersUs\":{\"sum\":\"66ms\",\"count\":1,\"avg\":\"66ms\",\"max\":\"66ms\",\"min\":\"66ms\"},\"ExecutionTimeUs\":{\"sum\":\"1.01s\",\"count\":1,\"avg\":\"1.01s\",\"max\":\"1.01s\",\"min\":\"1.01s\"},\"TaskRunner\":{\"Stage=204663\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":1,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":1,\"count\":1,\"avg\":1,\"max\":1,\"min\":1}},\"Stage=204683\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":1,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":1,\"count\":1,\"avg\":1,\"max\":1,\"min\":1}},\"Stage=Total\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":2,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":2,\"count\":2,\"avg\":1,\"max\":1,\"min\":1}}},\"UniqueWorkers\":{\"sum\":1,\"count\":1,\"avg\":1,\"max\":1,\"min\":1}}}"
resources {
  rate_limiter: READY
  compilation: READY
  topic_consumers_state: READY
  rate_limiter_path: "local/RateLimiter_1fb303ed-ed93-4034-ace4-b066e21a3ab1/rate_limiter"
  topic_consumers {
    database: "local"
    topic_path: "test_time_order_recoverer[v1-kikimr0]_v1_input"
    consumer_name: "ptqudq7uem53kjjhdml0"
    cluster_endpoint: "localhost:25827"
    token_name: "cluster:default_myyds"
    add_bearer_to_token: true
  }
}
scope: "yandexcloud://my_folder"
finished_at {
  seconds: 1765542475
  nanos: 57000000
}
deadline {
  seconds: 1765628873
  nanos: 960993000
}
tenant: "/compute"
}
2025-12-12T12:27:55.131191Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudq7uem53kjjhdml0"
2025-12-12T12:27:55.131244Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:305: Resolve folder bootstrap. Folder id: my_folder Actor id: [1:7582947192615242868:2390]
2025-12-12T12:27:55.131306Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:367: Cloud id: mock_cloud Folder id: my_folder
2025-12-12T12:27:55.131335Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:91: Get quotas bootstrap. Cloud id: mock_cloud Actor id: [1:7582947192615242869:2391]
2025-12-12T12:27:55.131373Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.analyticsQuery.count IS STALE, Refreshing ...
2025-12-12T12:27:55.131390Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.cpuPercent.count IS STALE, Refreshing ...
2025-12-12T12:27:55.131400Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.streamingQuery.count IS STALE, Refreshing ...
2025-12-12T12:27:55.131428Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.cpuPercent.count=0/10000 REFRESHED
2025-12-12T12:27:55.139831Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.cpuPercent.count=0/10000 NOTIFY CHANGE
2025-12-12T12:27:55.139854Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.analyticsQuery.count=0/100 REFRESHED
2025-12-12T12:27:55.139882Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.streamingQuery.count=1/100 REFRESHED
2025-12-12T12:27:55.139904Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:493: cloud.mock_cloud{yq.streamingQueryDurationMinutes.count=*/0, yq.queryResult.size=*/20971520, yq.analyticsQuery.count=0/100, yq.analyticsQueryDurationMinutes.count=*/1440, yq.memory.size=*/0, yq.result.size=*/0, yq.cpuPercent.count=0/10000, yq.streamingQuery.count=1/100} SEND QUOTAS
2025-12-12T12:27:55.139936Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:103: Cloud id: mock_cloud Quota count: 8
2025-12-12T12:27:55.139974Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudq7uem53kjjhdml0"
2025-12-12T12:27:55.140033Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:169: Resolve subject type bootstrap. Token: **** (B6C6F477) Actor id: [1:7582947192615242874:2396]
2025-12-12T12:27:55.140072Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:230: Subject Type: federated_account Token: **** (B6C6F477)
2025-12-12T12:27:55.140092Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudq7uem53kjjhdml0"
2025-12-12T12:27:55.140103Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:63: Request actor. Actor id: [1:7582947192615242875:2397]
2025-12-12T12:27:55.140148Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_queries.cpp:641: DescribeQueryRequest: {query_id: "ptqudq7uem53kjjhdml0"
} [root@builtin, **** (B6C6F477)] 
2025-12-12T12:27:55.148613Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: DescribeQueryRequest - DescribeQueryResult: {query { meta { common { id: "ptqudq7uem53kjjhdml0" created_by: "root@builtin" modified_by: "root@builtin" created_at { seconds: 1765542450 nanos: 786563000 } modified_at { seconds: 1765542474 nanos: 535188000 } revision: 2 } started_at { seconds: 1765542451 nanos: 606000000 } execute_mode: RUN status: ABORTING_BY_USER last_job_query_revision: 1 last_job_id: "ptjudq7uem53keup7toj-ptqudq7uem53kjjhdml0" started_by: "root@builtin" aborted_by: "root@builtin" has_saved_checkpoints: true submitted_at { seconds: 1765542450 nanos: 786563000 } } content { type: STREAMING name: "simple" acl { visibility: PRIVATE } limits { execution_timeout { } } text: "\n            PRAGMA dq.MaxTasksPerStage=\"2\";\n\n            pragma FeatureR010=\"prototype\";\n            pragma config.flags(\"TimeOrderRecoverDelay\", \"-1000000\");\n            pragma config.flags(\"TimeOrderRecoverAhead\", \"1000000\");\n\n            INSERT INTO myyds.`test_time_order_recoverer[v1-kikimr0]_v1_output`\n            SELECT ToBytes(Unwrap(Json::SerializeJson(Yson::From(TableRow()))))\n            FROM (SELECT * FROM myyds.`test_time_order_recoverer[v1-kikimr0]_v1_input`\n                WITH (\n                    format=json_each_row,\n                    SCHEMA\n                    (\n                        dt UINT64\n                    )))\n            MATCH_RECOGNIZE(\n                ORDER BY CAST(dt as Timestamp)\n                MEASURES\n                LAST(ALL_TRUE.dt) as dt\n                ONE ROW PER MATCH\n                PATTERN ( ALL_TRUE )\n                DEFINE\n                    ALL_TRUE as True)" syntax: YQL_V1 } plan { json: "{\"Detailed\":{\"Operations\":[{\"Id\":5,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[{\"Name\":\"DqSourceWideWrap\"},{\"Name\":\"NarrowMap\"}]}},{\"Id\":3,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[{\"Name\":\"TimeOrderRecover\"},{\"Name\":\"OrderedFlatMap\"},{\"Name\":\"MatchRecognizeCore\"},{\"Name\":\"FlatMap\"},{\"Name\":\"FromFlow\"}]},\"DependsOn\":[5]},{\"Id\":2,\"Name\":\"DqQuery!\",\"DependsOn\":[3]},{\"Id\":1,\"Name\":\"Commit!\",\"DependsOn\":[2]}],\"OperationRoot\":1,\"Providers\":[],\"OperationStats\":{\"Commit!\":1,\"DqQuery!\":1,\"DqStage\":2}},\"Basic\":{\"nodes\":[{\"id\":5,\"level\":1,\"name\":\"DqStage #5\",\"type\":\"op\"},{\"id\":3,\"level\":2,\"name\":\"DqStage #3\",\"type\":\"op\"},{\"id\":2,\"level\":3,\"name\":\"DqQuery!\",\"type\":\"op\"},{\"id\":1,\"level\":4,\"name\":\"Commit!\",\"type\":\"op\"}],\"links\":[{\"source\":5,\"target\":3},{\"source\":3,\"target\":2},{\"source\":2,\"target\":1}]}}" } transient_issue { message: "Parse Sql" severity: 2 issues { position { row: 9 column: 41 } message: "Json UDF is deprecated. Please use JSON API instead" end_position { row: 9 column: 41 } issue_code: 4506 severity: 2 } } statistics { json: "{\"Graph=0\":{\"Tasks\":{\"sum\":2,\"count\":2,\"avg\":1,\"max\":1,\"min\":1},\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":2,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"}}}" } ast { data: "(\n(let $1 (DataSource \'\"config\"))\n(let $2 (Configure! world $1 \'\"DqEngine\" \'\"force\"))\n(let $3 (Configure! $2 (DataSource \'\"dq\" \'\"$all\") \'\"Attr\" \'\"maxtasksperstage\" \'\"2\"))\n(let $4 (Configure! $3 $1 \'\"TimeOrderRecoverDelay\" \'\"-1000000\"))\n(let $5 (Configure! $4 $1 \'\"TimeOrderRecoverAhead\" \'\"1000000\"))\n(let $6 (DataSource \'\"pq\" \'\"myyds\"))\n(let $7 \'(\'(\'\"PartitionsCount\" \'1)))\n(let $8 (StructType \'(\'dt (OptionalType (DataType \'Uint64)))))\n(let $9 (PqTopic \'\"myyds\" \'\"local\" \'\"test_time_order_recoverer[v1-kikimr0]_v1_input\" $7 \'() $8))\n(let $10 \'(\'dt))\n(let $11 \'(\'\"Endpoint\" \'\"localhost:25827\"))\n(let $12 \'(\'\"SharedReading\" \'0))\n(let $13 \'(\'\"AddBearerToToken\" \'1))\n(let $14 \'($11 $12 \'(\'\"ReconnectPeriod\" \'\"\") \'(\'\"Format\" \'\"json_each_row\") \'(\'\"ReadGroup\" \'\"ptcudq7uemfqqjepn05j\") $13))\n(let $15 (SecureParam \'\"cluster:default_myyds\"))\n(let $16 (DqPqTopicSource $5 $9 $10 $14 $15 \'\"\" $8 \'\"\"))\n(let $17 (DqStage \'((DqSource $6 $16)) (lambda \'($...} SUCCESS
2025-12-12T12:27:55.164209Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.streamingQuery.count=1/100 NOTIFY CHANGE
2025-12-12T12:27:55.166991Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.analyticsQuery.count=0/100 NOTIFY CHANGE
2025-12-12T12:27:55.211371Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {action: ABORT } SUCCESS
2025-12-12T12:27:55.211461Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudq7uem53kjjhdml0, Owner: 8f71b000-7466b0e9-41997d65-a6f433e620, Got CP::PingTaskResponse
2025-12-12T12:27:55.611325Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582947080946092865:2107]
2025-12-12T12:27:55.611348Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:55.611359Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582947080946092821:2068]
2025-12-12T12:27:55.611363Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582947080946092821:2068]
2025-12-12T12:27:55.611366Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582947080946092821:2068]
2025-12-12T12:27:55.611375Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:55.651748Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudq7uem53kjjhdml0"
2025-12-12T12:27:55.651815Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:305: Resolve folder bootstrap. Folder id: my_folder Actor id: [1:7582947192615242879:2400]
2025-12-12T12:27:55.651840Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:367: Cloud id: mock_cloud Folder id: my_folder
2025-12-12T12:27:55.651867Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:91: Get quotas bootstrap. Cloud id: mock_cloud Actor id: [1:7582947192615242880:2401]
2025-12-12T12:27:55.651901Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.analyticsQuery.count IS STALE, Refreshing ...
2025-12-12T12:27:55.651923Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.cpuPercent.count IS STALE, Refreshing ...
2025-12-12T12:27:55.651938Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.streamingQuery.count IS STALE, Refreshing ...
2025-12-12T12:27:55.651974Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.cpuPercent.count=0/10000 REFRESHED
2025-12-12T12:27:55.659256Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.analyticsQuery.count=0/100 REFRESHED
2025-12-12T12:27:55.659293Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.streamingQuery.count=0/100 REFRESHED
2025-12-12T12:27:55.659318Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:493: cloud.mock_cloud{yq.streamingQueryDurationMinutes.count=*/0, yq.queryResult.size=*/20971520, yq.analyticsQuery.count=0/100, yq.analyticsQueryDurationMinutes.count=*/1440, yq.memory.size=*/0, yq.result.size=*/0, yq.cpuPercent.count=0/10000, yq.streamingQuery.count=0/100} SEND QUOTAS
2025-12-12T12:27:55.659330Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:103: Cloud id: mock_cloud Quota count: 8
2025-12-12T12:27:55.659366Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudq7uem53kjjhdml0"
2025-12-12T12:27:55.659424Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:169: Resolve subject type bootstrap. Token: **** (B6C6F477) Actor id: [1:7582947192615242885:2406]
2025-12-12T12:27:55.659451Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:230: Subject Type: federated_account Token: **** (B6C6F477)
2025-12-12T12:27:55.659477Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudq7uem53kjjhdml0"
2025-12-12T12:27:55.659516Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:63: Request actor. Actor id: [1:7582947192615242886:2407]
2025-12-12T12:27:55.659598Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_queries.cpp:641: DescribeQueryRequest: {query_id: "ptqudq7uem53kjjhdml0"
} [root@builtin, **** (B6C6F477)] 
2025-12-12T12:27:55.662143Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: DescribeQueryRequest - DescribeQueryResult: {query { meta { common { id: "ptqudq7uem53kjjhdml0" created_by: "root@builtin" modified_by: "root@builtin" created_at { seconds: 1765542450 nanos: 786563000 } modified_at { seconds: 1765542474 nanos: 535188000 } revision: 2 } started_at { seconds: 1765542451 nanos: 606000000 } finished_at { seconds: 1765542475 nanos: 57000000 } execute_mode: RUN status: ABORTED_BY_USER last_job_query_revision: 1 last_job_id: "ptjudq7uem53keup7toj-ptqudq7uem53kjjhdml0" started_by: "root@builtin" aborted_by: "root@builtin" has_saved_checkpoints: true submitted_at { seconds: 1765542450 nanos: 786563000 } } content { type: STREAMING name: "simple" acl { visibility: PRIVATE } limits { execution_timeout { } } text: "\n            PRAGMA dq.MaxTasksPerStage=\"2\";\n\n            pragma FeatureR010=\"prototype\";\n            pragma config.flags(\"TimeOrderRecoverDelay\", \"-1000000\");\n            pragma config.flags(\"TimeOrderRecoverAhead\", \"1000000\");\n\n            INSERT INTO myyds.`test_time_order_recoverer[v1-kikimr0]_v1_output`\n            SELECT ToBytes(Unwrap(Json::SerializeJson(Yson::From(TableRow()))))\n            FROM (SELECT * FROM myyds.`test_time_order_recoverer[v1-kikimr0]_v1_input`\n                WITH (\n                    format=json_each_row,\n                    SCHEMA\n                    (\n                        dt UINT64\n                    )))\n            MATCH_RECOGNIZE(\n                ORDER BY CAST(dt as Timestamp)\n                MEASURES\n                LAST(ALL_TRUE.dt) as dt\n                ONE ROW PER MATCH\n                PATTERN ( ALL_TRUE )\n                DEFINE\n                    ALL_TRUE as True)" syntax: YQL_V1 } plan { json: "{\"Detailed\":{\"Operations\":[{\"Id\":5,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[{\"Name\":\"DqSourceWideWrap\"},{\"Name\":\"NarrowMap\"}]}},{\"Id\":3,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[{\"Name\":\"TimeOrderRecover\"},{\"Name\":\"OrderedFlatMap\"},{\"Name\":\"MatchRecognizeCore\"},{\"Name\":\"FlatMap\"},{\"Name\":\"FromFlow\"}]},\"DependsOn\":[5]},{\"Id\":2,\"Name\":\"DqQuery!\",\"DependsOn\":[3]},{\"Id\":1,\"Name\":\"Commit!\",\"DependsOn\":[2]}],\"OperationRoot\":1,\"Providers\":[],\"OperationStats\":{\"Commit!\":1,\"DqQuery!\":1,\"DqStage\":2}},\"Basic\":{\"nodes\":[{\"id\":5,\"level\":1,\"name\":\"DqStage #5\",\"type\":\"op\"},{\"id\":3,\"level\":2,\"name\":\"DqStage #3\",\"type\":\"op\"},{\"id\":2,\"level\":3,\"name\":\"DqQuery!\",\"type\":\"op\"},{\"id\":1,\"level\":4,\"name\":\"Commit!\",\"type\":\"op\"}],\"links\":[{\"source\":5,\"target\":3},{\"source\":3,\"target\":2},{\"source\":2,\"target\":1}]}}" } issue { message: "ABORTED_BY_USER" severity: 1 } transient_issue { message: "Parse Sql" severity: 2 issues { position { row: 9 column: 41 } message: "Json UDF is deprecated. Please use JSON API instead" end_position { row: 9 column: 41 } issue_code: 4506 severity: 2 } } statistics { json: "{\"Graph=0\":{\"Tasks\":{\"sum\":2,\"count\":2,\"avg\":1,\"max\":1,\"min\":1},\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":2,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"}}}" } ast { data: "(\n(let $1 (DataSource \'\"config\"))\n(let $2 (Configure! world $1 \'\"DqEngine\" \'\"force\"))\n(let $3 (Configure! $2 (DataSource \'\"dq\" \'\"$all\") \'\"Attr\" \'\"maxtasksperstage\" \'\"2\"))\n(let $4 (Configure! $3 $1 \'\"TimeOrderRecoverDelay\" \'\"-1000000\"))\n(let $5 (Configure! $4 $1 \'\"TimeOrderRecoverAhead\" \'\"1000000\"))\n(let $6 (DataSource \'\"pq\" \'\"myyds\"))\n(let $7 \'(\'(\'\"PartitionsCount\" \'1)))\n(let $8 (StructType \'(\'dt (OptionalType (DataType \'Uint64)))))\n(let $9 (PqTopic \'\"myyds\" \'\"local\" \'\"test_time_order_recoverer[v1-kikimr0]_v1_input\" $7 \'() $8))\n(let $10 \'(\'dt))\n(let $11 \'(\'\"Endpoint\" \'\"localhost:25827\"))\n(let $12 \'(\'\"SharedReading\" \'0))\n(let $13 \'(\'\"AddBearerToToken\" \'1))\n(let $14 \'($11 $12 \'(\'\"ReconnectPeriod\" \'\"\") \'(\'\"Format\" \'\"json_each_row\") \'(\'\"ReadGroup\" \'\"ptcudq7uemfqqjepn05j\") $13))\n(let $15 (SecureParam \'\"cluster:default_myyds\"))\n(let $16 (DqPqTo...} SUCCESS
2025-12-12T12:27:55.663928Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.cpuPercent.count=0/10000 NOTIFY CHANGE
2025-12-12T12:27:55.671202Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.streamingQuery.count=0/100 NOTIFY CHANGE
2025-12-12T12:27:55.671309Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.analyticsQuery.count=0/100 NOTIFY CHANGE
