2025-12-12T12:26:58.895949Z :GRPC_SERVER NOTICE: grpc_request_proxy_simple.cpp:161: Grpc simple request proxy started, nodeid# 1
2025-12-12T12:26:58.895993Z :GRPC_SERVER NOTICE: grpc_request_proxy_simple.cpp:161: Grpc simple request proxy started, nodeid# 1
2025-12-12T12:26:58.896250Z :YQ_CONTROL_PLANE_STORAGE INFO: ydb_control_plane_storage.cpp:50: Starting ydb control plane storage service. Actor id: [1:7582946948108156544:2062]
2025-12-12T12:26:58.896991Z :YQ_TEST_CONNECTION DEBUG: test_connection.cpp:142: Starting yandex query test connection. Actor id: [1:7582946948108156553:2071]
2025-12-12T12:26:58.897165Z :FQ_QUOTA_SERVICE INFO: quota_manager.cpp:196: STARTED
2025-12-12T12:26:58.897168Z :FQ_QUOTA_PROXY INFO: quota_proxy.cpp:90: STARTED
2025-12-12T12:26:58.897177Z :FQ_LOG_UPDATER DEBUG: log.cpp:93: Updated YQL logs priority: 8
2025-12-12T12:26:58.897180Z :FQ_LOG_UPDATER CRIT: log.cpp:55: Failed to deliver subscription request to config dispatcher.
2025-12-12T12:26:58.897191Z :FQ_CONTROL_PLANE_CONFIG DEBUG: control_plane_config.cpp:58: STARTING: [1:7582946948108156545:2063]
2025-12-12T12:26:58.897204Z :YQ_CONTROL_PLANE_PROXY DEBUG: control_plane_proxy.cpp:525: Starting yandex query control plane proxy. Actor id: [1:7582946948108156546:2064]
2025-12-12T12:26:58.897272Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:214: Bootstrap
2025-12-12T12:26:58.897273Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:217: Create sdk ydb connection
2025-12-12T12:26:58.897306Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:239: Successfully bootstrapped TStorageProxy [1:7582946948108156549:2067] with connection to localhost:25827:local
2025-12-12T12:26:58.897320Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:544: RowDispatcher: Successfully bootstrapped row dispatcher, id [1:7582946948108156550:2068], tenant /cp
2025-12-12T12:26:58.897328Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582946948108156550:2068]
2025-12-12T12:26:58.897330Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:329: Coordinator: Add new row dispatcher to map (state 1)
2025-12-12T12:26:58.897421Z :YQ_RATE_LIMITER DEBUG: schema.cpp:71: Run create coordination node "local/RateLimiter_5958a75f-5918-4b93-a01c-15191f6a0817/rate_limiter" actor
2025-12-12T12:26:58.897422Z :YQ_RATE_LIMITER DEBUG: schema.cpp:113: Call create coordination node "local/RateLimiter_5958a75f-5918-4b93-a01c-15191f6a0817/rate_limiter"
2025-12-12T12:26:58.897423Z :YQ_RATE_LIMITER DEBUG: schema.cpp:411: Call create coordination node "local/RateLimiter_5958a75f-5918-4b93-a01c-15191f6a0817/rate_limiter"
2025-12-12T12:26:58.897451Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:293: Coordinator: Successfully bootstrapped coordinator, id [1:7582946948108156592:2093], NodesManagerId [0:4705493345362661702:78], rebalancing timeout 5.000000s
2025-12-12T12:26:58.897459Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:232: TLeaderElection [1:7582946948108156593:2094] Successfully bootstrapped, local coordinator id [1:7582946948108156592:2093], tenant id cp, local mode 0, coordination node path local/cp, endpoint localhost:25827
2025-12-12T12:26:58.898123Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:637: RowDispatcher: TEvCoordinatorChangesSubscribe from [1:7582946948108156592:2093]
2025-12-12T12:26:58.898702Z :MEMORY_PROFILER NOTICE: monitor.cpp:332: Bootstrapped
2025-12-12T12:26:58.911879Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_5958a75f-5918-4b93-a01c-15191f6a0817/idempotency_keys" actor
2025-12-12T12:26:58.911912Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_5958a75f-5918-4b93-a01c-15191f6a0817/result_sets" actor
2025-12-12T12:26:58.911918Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_5958a75f-5918-4b93-a01c-15191f6a0817/jobs" actor
2025-12-12T12:26:58.911924Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_5958a75f-5918-4b93-a01c-15191f6a0817/nodes" actor
2025-12-12T12:26:58.911929Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_5958a75f-5918-4b93-a01c-15191f6a0817/quotas" actor
2025-12-12T12:26:58.911934Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_5958a75f-5918-4b93-a01c-15191f6a0817/tenants" actor
2025-12-12T12:26:58.911940Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_5958a75f-5918-4b93-a01c-15191f6a0817/tenant_acks" actor
2025-12-12T12:26:58.911946Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_5958a75f-5918-4b93-a01c-15191f6a0817/mappings" actor
2025-12-12T12:26:58.911960Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_5958a75f-5918-4b93-a01c-15191f6a0817/compute_databases" actor
2025-12-12T12:26:58.911966Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create directory "local/DbPoolStorage_5958a75f-5918-4b93-a01c-15191f6a0817" actor
2025-12-12T12:26:58.911967Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create directory "local/DbPoolStorage_5958a75f-5918-4b93-a01c-15191f6a0817"
2025-12-12T12:26:58.911969Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:383: Call create directory "local/DbPoolStorage_5958a75f-5918-4b93-a01c-15191f6a0817"
2025-12-12T12:26:58.911979Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_5958a75f-5918-4b93-a01c-15191f6a0817/queries" actor
2025-12-12T12:26:58.911986Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_5958a75f-5918-4b93-a01c-15191f6a0817/pending_small" actor
2025-12-12T12:26:58.911993Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_5958a75f-5918-4b93-a01c-15191f6a0817/connections" actor
2025-12-12T12:26:58.911998Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_5958a75f-5918-4b93-a01c-15191f6a0817/bindings" actor
2025-12-12T12:26:58.912950Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:71: Run create coordination node "local/cp" actor
2025-12-12T12:26:58.912961Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:113: Call create coordination node "local/cp"
2025-12-12T12:26:58.912964Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:411: Call create coordination node "local/cp"
2025-12-12T12:26:58.991181Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:155: Successfully created coordination node "local/cp"
2025-12-12T12:26:58.991198Z :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:26:58.991212Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:345: TLeaderElection [1:7582946948108156593:2094] Coordination node successfully created
2025-12-12T12:26:58.991215Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:323: TLeaderElection [1:7582946948108156593:2094] Start session
2025-12-12T12:26:59.006783Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:359: TLeaderElection [1:7582946948108156593:2094] Session successfully created
2025-12-12T12:26:59.007375Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_5958a75f-5918-4b93-a01c-15191f6a0817/pending_small". Create session OK
2025-12-12T12:26:59.007399Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_5958a75f-5918-4b93-a01c-15191f6a0817/pending_small"
2025-12-12T12:26:59.007402Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_5958a75f-5918-4b93-a01c-15191f6a0817/pending_small"
2025-12-12T12:26:59.007418Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_5958a75f-5918-4b93-a01c-15191f6a0817/connections". Create session OK
2025-12-12T12:26:59.007436Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_5958a75f-5918-4b93-a01c-15191f6a0817/connections"
2025-12-12T12:26:59.007443Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_5958a75f-5918-4b93-a01c-15191f6a0817/connections"
2025-12-12T12:26:59.007579Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_5958a75f-5918-4b93-a01c-15191f6a0817/queries". Create session OK
2025-12-12T12:26:59.007587Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_5958a75f-5918-4b93-a01c-15191f6a0817/queries"
2025-12-12T12:26:59.007588Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_5958a75f-5918-4b93-a01c-15191f6a0817/queries"
2025-12-12T12:26:59.007650Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_5958a75f-5918-4b93-a01c-15191f6a0817/bindings". Create session OK
2025-12-12T12:26:59.007662Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_5958a75f-5918-4b93-a01c-15191f6a0817/bindings"
2025-12-12T12:26:59.007663Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_5958a75f-5918-4b93-a01c-15191f6a0817/bindings"
2025-12-12T12:26:59.007722Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_5958a75f-5918-4b93-a01c-15191f6a0817/quotas". Create session OK
2025-12-12T12:26:59.007732Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_5958a75f-5918-4b93-a01c-15191f6a0817/mappings". Create session OK
2025-12-12T12:26:59.007734Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_5958a75f-5918-4b93-a01c-15191f6a0817/quotas"
2025-12-12T12:26:59.007735Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_5958a75f-5918-4b93-a01c-15191f6a0817/mappings"
2025-12-12T12:26:59.007736Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_5958a75f-5918-4b93-a01c-15191f6a0817/mappings"
2025-12-12T12:26:59.007736Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_5958a75f-5918-4b93-a01c-15191f6a0817/quotas"
2025-12-12T12:26:59.007806Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_5958a75f-5918-4b93-a01c-15191f6a0817/nodes". Create session OK
2025-12-12T12:26:59.007808Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_5958a75f-5918-4b93-a01c-15191f6a0817/nodes"
2025-12-12T12:26:59.007810Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_5958a75f-5918-4b93-a01c-15191f6a0817/nodes"
2025-12-12T12:26:59.007828Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_5958a75f-5918-4b93-a01c-15191f6a0817/tenants". Create session OK
2025-12-12T12:26:59.007832Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_5958a75f-5918-4b93-a01c-15191f6a0817/tenants"
2025-12-12T12:26:59.007834Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_5958a75f-5918-4b93-a01c-15191f6a0817/tenants"
2025-12-12T12:26:59.007886Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_5958a75f-5918-4b93-a01c-15191f6a0817/idempotency_keys". Create session OK
2025-12-12T12:26:59.007896Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_5958a75f-5918-4b93-a01c-15191f6a0817/idempotency_keys"
2025-12-12T12:26:59.007898Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_5958a75f-5918-4b93-a01c-15191f6a0817/idempotency_keys"
2025-12-12T12:26:59.007909Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_5958a75f-5918-4b93-a01c-15191f6a0817/compute_databases". Create session OK
2025-12-12T12:26:59.007911Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_5958a75f-5918-4b93-a01c-15191f6a0817/compute_databases"
2025-12-12T12:26:59.007912Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_5958a75f-5918-4b93-a01c-15191f6a0817/compute_databases"
2025-12-12T12:26:59.007927Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_5958a75f-5918-4b93-a01c-15191f6a0817/result_sets". Create session OK
2025-12-12T12:26:59.007929Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_5958a75f-5918-4b93-a01c-15191f6a0817/result_sets"
2025-12-12T12:26:59.007930Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_5958a75f-5918-4b93-a01c-15191f6a0817/result_sets"
2025-12-12T12:26:59.007965Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_5958a75f-5918-4b93-a01c-15191f6a0817/jobs". Create session OK
2025-12-12T12:26:59.007967Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_5958a75f-5918-4b93-a01c-15191f6a0817/jobs"
2025-12-12T12:26:59.007969Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_5958a75f-5918-4b93-a01c-15191f6a0817/jobs"
2025-12-12T12:26:59.007987Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created directory "local/DbPoolStorage_5958a75f-5918-4b93-a01c-15191f6a0817"
2025-12-12T12:26:59.007995Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create directory "local/DbPoolStorage_5958a75f-5918-4b93-a01c-15191f6a0817": { <main>: Error: Check failed: path: '/local/DbPoolStorage_5958a75f-5918-4b93-a01c-15191f6a0817', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 31], type: EPathTypeDir, state: EPathStateNoChanges), source_location: ydb/core/tx/schemeshard/schemeshard__operation_mkdir.cpp:155 }
2025-12-12T12:26:59.008002Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_5958a75f-5918-4b93-a01c-15191f6a0817/tenant_acks". Create session OK
2025-12-12T12:26:59.008003Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_5958a75f-5918-4b93-a01c-15191f6a0817/tenant_acks"
2025-12-12T12:26:59.008005Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_5958a75f-5918-4b93-a01c-15191f6a0817/tenant_acks"
2025-12-12T12:26:59.015073Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:372: TLeaderElection [1:7582946948108156593:2094] Semaphore successfully created
2025-12-12T12:26:59.015090Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:304: TLeaderElection [1:7582946948108156593:2094] Try to acquire semaphore
2025-12-12T12:26:59.015204Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:420: TLeaderElection [1:7582946948108156593:2094] Describe semaphore
2025-12-12T12:26:59.018184Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:386: TLeaderElection [1:7582946948108156593:2094] Semaphore successfully acquired
2025-12-12T12:26:59.018772Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:469: TLeaderElection [1:7582946948108156593:2094] Semaphore successfully described: coordinator id [1:7582946948108156592:2093] generation 2
2025-12-12T12:26:59.018783Z :FQ_ROW_DISPATCHER INFO: leader_election.cpp:471: TLeaderElection [1:7582946948108156593:2094] Send TEvCoordinatorChanged to [1:7582946948108156550:2068], new coordinator id [1:7582946948108156592:2093], previous coordinator id [0:0:0]
2025-12-12T12:26:59.018817Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:569: RowDispatcher: Coordinator changed, old leader (empty maybe), new [1:7582946948108156592:2093] generation 2
2025-12-12T12:26:59.018832Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582946948108156550:2068]
2025-12-12T12:26:59.018836Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582946948108156550:2068]
2025-12-12T12:26:59.018839Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582946948108156550:2068]
2025-12-12T12:26:59.018852Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:440: Coordinator: New leader [1:7582946948108156592:2093], SelfId [1:7582946948108156592:2093]
2025-12-12T12:26:59.018856Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:26:59.023092Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_5958a75f-5918-4b93-a01c-15191f6a0817/mappings"
2025-12-12T12:26:59.023111Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_5958a75f-5918-4b93-a01c-15191f6a0817/mappings": { <main>: Error: Check failed: path: '/local/DbPoolStorage_5958a75f-5918-4b93-a01c-15191f6a0817/mappings', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 33], type: EPathTypeTable, state: EPathStateNoChanges), source_location: ydb/core/tx/schemeshard/schemeshard__operation_create_table.cpp:504 }
2025-12-12T12:26:59.027149Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_5958a75f-5918-4b93-a01c-15191f6a0817/tenants"
2025-12-12T12:26:59.027159Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_5958a75f-5918-4b93-a01c-15191f6a0817/tenants": { <main>: Error: Check failed: path: '/local/DbPoolStorage_5958a75f-5918-4b93-a01c-15191f6a0817/tenants', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 32], type: EPathTypeTable, state: EPathStateNoChanges), source_location: ydb/core/tx/schemeshard/schemeshard__operation_create_table.cpp:504 }
2025-12-12T12:26:59.051472Z :YQ_RATE_LIMITER DEBUG: schema.cpp:155: Successfully created coordination node "local/RateLimiter_5958a75f-5918-4b93-a01c-15191f6a0817/rate_limiter"
2025-12-12T12:26:59.051489Z :YQ_RATE_LIMITER DEBUG: schema.cpp:122: Reply for create coordination node "local/RateLimiter_5958a75f-5918-4b93-a01c-15191f6a0817/rate_limiter": 
2025-12-12T12:26:59.065763Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_5958a75f-5918-4b93-a01c-15191f6a0817/bindings"
2025-12-12T12:26:59.065779Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_5958a75f-5918-4b93-a01c-15191f6a0817/bindings": 
2025-12-12T12:26:59.079276Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_5958a75f-5918-4b93-a01c-15191f6a0817/jobs"
2025-12-12T12:26:59.079290Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_5958a75f-5918-4b93-a01c-15191f6a0817/jobs": 
2025-12-12T12:26:59.079422Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_5958a75f-5918-4b93-a01c-15191f6a0817/connections"
2025-12-12T12:26:59.079428Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_5958a75f-5918-4b93-a01c-15191f6a0817/connections": 
2025-12-12T12:26:59.079879Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_5958a75f-5918-4b93-a01c-15191f6a0817/nodes"
2025-12-12T12:26:59.079889Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_5958a75f-5918-4b93-a01c-15191f6a0817/nodes": 
2025-12-12T12:26:59.079914Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_5958a75f-5918-4b93-a01c-15191f6a0817/tenant_acks"
2025-12-12T12:26:59.079918Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_5958a75f-5918-4b93-a01c-15191f6a0817/tenant_acks": 
2025-12-12T12:26:59.080002Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_5958a75f-5918-4b93-a01c-15191f6a0817/quotas"
2025-12-12T12:26:59.080005Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_5958a75f-5918-4b93-a01c-15191f6a0817/quotas": 
2025-12-12T12:26:59.080041Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_5958a75f-5918-4b93-a01c-15191f6a0817/compute_databases"
2025-12-12T12:26:59.080044Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_5958a75f-5918-4b93-a01c-15191f6a0817/compute_databases": 
2025-12-12T12:26:59.080058Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_5958a75f-5918-4b93-a01c-15191f6a0817/idempotency_keys"
2025-12-12T12:26:59.080060Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_5958a75f-5918-4b93-a01c-15191f6a0817/idempotency_keys": 
2025-12-12T12:26:59.080109Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_5958a75f-5918-4b93-a01c-15191f6a0817/result_sets"
2025-12-12T12:26:59.080111Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_5958a75f-5918-4b93-a01c-15191f6a0817/result_sets": 
2025-12-12T12:26:59.080115Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_5958a75f-5918-4b93-a01c-15191f6a0817/queries"
2025-12-12T12:26:59.080117Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_5958a75f-5918-4b93-a01c-15191f6a0817/queries": 
2025-12-12T12:26:59.087978Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_5958a75f-5918-4b93-a01c-15191f6a0817/pending_small"
2025-12-12T12:26:59.087993Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_5958a75f-5918-4b93-a01c-15191f6a0817/pending_small": 
2025-12-12T12:26:59.088018Z :FQ_CONTROL_PLANE_CONFIG DEBUG: control_plane_config.cpp:190: LOADED TenantInfo: State CHANGED at 2025-12-12T12:26:57.908409Z
2025-12-12T12:26:59.919640Z :TICKET_PARSER DEBUG: ticket_parser_impl.h:1875: Ticket **** (B6C6F477) (ipv6:[::1]:52944) has now valid token of root@builtin
2025-12-12T12:26:59.919814Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:1330: CreateConnectionRequest: content { name: "myyds" setting { data_streams { auth { none { } } endpoint: "localhost:25827" database: "local" } } acl { visibility: PRIVATE } } 
2025-12-12T12:26:59.919845Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:305: Resolve folder bootstrap. Folder id: my_folder Actor id: [1:7582946952403123947:2148]
2025-12-12T12:26:59.919859Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:367: Cloud id: mock_cloud Folder id: my_folder
2025-12-12T12:26:59.919870Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:91: Get quotas bootstrap. Cloud id: mock_cloud Actor id: [1:7582946952403123948:2149]
2025-12-12T12:26:59.919880Z :FQ_QUOTA_SERVICE DEBUG: quota_manager.cpp:255: cloud.mock_cloud NOT CASHED, Loading ...
2025-12-12T12:26:59.955404Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:441: cloud.mock_cloud {} FROM DB
2025-12-12T12:26:59.955437Z :FQ_QUOTA_SERVICE DEBUG: quota_manager.cpp:269: cloud.mock_cloud{yq.streamingQueryDurationMinutes.count=*/0, yq.queryResult.size=*/20971520, yq.analyticsQuery.count=*/100, yq.analyticsQueryDurationMinutes.count=*/1440, yq.memory.size=*/0, yq.result.size=*/0, yq.cpuPercent.count=*/10000, yq.streamingQuery.count=*/100} LOADED
2025-12-12T12:26:59.955441Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.analyticsQuery.count IS STALE, Refreshing ...
2025-12-12T12:26:59.955449Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.cpuPercent.count IS STALE, Refreshing ...
2025-12-12T12:26:59.955452Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.streamingQuery.count IS STALE, Refreshing ...
2025-12-12T12:26:59.955469Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.cpuPercent.count=0/10000 REFRESHED
2025-12-12T12:27:00.009809Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.cpuPercent.count=0/10000 NOTIFY CHANGE
2025-12-12T12:27:00.022314Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.analyticsQuery.count=0/100 REFRESHED
2025-12-12T12:27:00.022347Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.streamingQuery.count=0/100 REFRESHED
2025-12-12T12:27:00.022377Z :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:00.022387Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:103: Cloud id: mock_cloud Quota count: 8
2025-12-12T12:27:00.022509Z :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:00.022587Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:169: Resolve subject type bootstrap. Token: **** (B6C6F477) Actor id: [1:7582946956698091250:2155]
2025-12-12T12:27:00.022602Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:230: Subject Type: federated_account Token: **** (B6C6F477)
2025-12-12T12:27:00.022653Z :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:00.022679Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:435: Create database bootstrap. CloudId: mock_cloud Scope: yandexcloud://my_folder Actor id: [1:7582946956698091251:2156]
2025-12-12T12:27:00.022720Z :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:00.022749Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:63: Request actor. Actor id: [1:7582946956698091252:2157]
2025-12-12T12:27:00.022862Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_connections.cpp:120: [yandexcloud://my_folder, root@builtin, ptcudq7ufjfufnmne5eb] CreateConnectionRequest: **** (B6C6F477) content { name: "myyds" setting { data_streams { auth { none { } } endpoint: "localhost:25827" database: "local" } } acl { visibility: PRIVATE } } 
2025-12-12T12:27:00.035596Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: d75b22cc-ded50da4-a0ea8476-6e0a8e2f1, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 68 bytes
2025-12-12T12:27:00.036346Z :YQ_CONTROL_PLANE_STORAGE TRACE: nodes_health_check.cpp:38: NodesHealthCheckRequest: {tenant: "/compute"
node {
  node_id: 1
  instance_id: "8d7bba5c-4b336f5f-acf7ed80-992bbd3c"
  hostname: "ghrun-fhkyrtz6p4"
  interconnect_port: 11355
  node_address: "127.0.1.1"
}
}
2025-12-12T12:27:00.036432Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "d75b22cc-ded50da4-a0ea8476-6e0a8e2f1"
host: "ghrun-fhkyrtz6p4"
node_id: 1
}
2025-12-12T12:27:00.051363Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.streamingQuery.count=0/100 NOTIFY CHANGE
2025-12-12T12:27:00.051506Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.analyticsQuery.count=0/100 NOTIFY CHANGE
2025-12-12T12:27:00.099728Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:27:00.099798Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: d75b22cc-ded50da4-a0ea8476-6e0a8e2f1, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:27:00.127035Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: NodesHealthCheckRequest - NodesHealthCheckResult: {nodes { node_id: 1 instance_id: "8d7bba5c-4b336f5f-acf7ed80-992bbd3c" hostname: "ghrun-fhkyrtz6p4" node_address: "127.0.1.1" } } SUCCESS
2025-12-12T12:27:00.387460Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: [yandexcloud://my_folder, root@builtin, ptcudq7ufjfufnmne5eb] CreateConnectionRequest: {connection_id: "ptcudq7ufjfufnmne5eb" } SUCCESS
2025-12-12T12:27:00.395640Z :TICKET_PARSER DEBUG: ticket_parser_impl.h:1875: Ticket **** (B6C6F477) (ipv6:[::1]:52944) has now valid token of root@builtin
2025-12-12T12:27:00.395747Z :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            pragma config.flags(\"MatchRecognizeStream\", \"auto\");\n\n            INSERT INTO myyds.`test_match_recognize[v1-kikimr0]_v1_output`\n            SELECT ToBytes(Unwrap(Json::SerializeJson(Yson::From(TableRow()))))\n            FROM (SELECT * FROM myyds.`test_match_recognize[v1-kikimr0]_v1_input`\n                WITH (\n                    format=json_each_row,\n                    SCHEMA\n                    (\n                        dt UINT64,\n                        str STRING\n                    )))\n            MATCH_RECOGNIZE(\n                ORDER BY CAST(dt as Timestamp)\n                MEASURES\n                   LAST(A.dt) as dt_begin,\n                   LAST(C.dt) as dt_end,\n                   LAST(A.str) as a_str,\n                   LAST(B.str) as b_str,\n                   LAST(C.str) as c_str\n                ONE ROW PER MATCH\n                PATTERN ( A B C )\n                DEFINE\n                    A as A.str=\'A\',\n                    B as B.str=\'B\',\n                    C as C.str=\'C\')"
  syntax: YQL_V1
}
execute_mode: RUN
idempotency_key: "5e765ed7-ed81-4dca-8356-8d58da7a36d0"
2025-12-12T12:27:00.395777Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:305: Resolve folder bootstrap. Folder id: my_folder Actor id: [1:7582946956698091262:2166]
2025-12-12T12:27:00.395792Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:367: Cloud id: mock_cloud Folder id: my_folder
2025-12-12T12:27:00.395804Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:91: Get quotas bootstrap. Cloud id: mock_cloud Actor id: [1:7582946956698091263:2167]
2025-12-12T12:27:00.395818Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.analyticsQuery.count IS STALE, Refreshing ...
2025-12-12T12:27:00.395822Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.cpuPercent.count IS STALE, Refreshing ...
2025-12-12T12:27:00.395825Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.streamingQuery.count IS STALE, Refreshing ...
2025-12-12T12:27:00.395886Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.cpuPercent.count=0/10000 REFRESHED
2025-12-12T12:27:00.403483Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.analyticsQuery.count=0/100 REFRESHED
2025-12-12T12:27:00.403498Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.streamingQuery.count=0/100 REFRESHED
2025-12-12T12:27:00.403517Z :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:00.403530Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:103: Cloud id: mock_cloud Quota count: 8
2025-12-12T12:27:00.403589Z :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            pragma config.flags(\"MatchRecognizeStream\", \"auto\");\n\n            INSERT INTO myyds.`test_match_recognize[v1-kikimr0]_v1_output`\n            SELECT ToBytes(Unwrap(Json::SerializeJson(Yson::From(TableRow()))))\n            FROM (SELECT * FROM myyds.`test_match_recognize[v1-kikimr0]_v1_input`\n                WITH (\n                    format=json_each_row,\n                    SCHEMA\n                    (\n                        dt UINT64,\n                        str STRING\n                    )))\n            MATCH_RECOGNIZE(\n                ORDER BY CAST(dt as Timestamp)\n                MEASURES\n                   LAST(A.dt) as dt_begin,\n                   LAST(C.dt) as dt_end,\n                   LAST(A.str) as a_str,\n                   LAST(B.str) as b_str,\n                   LAST(C.str) as c_str\n                ONE ROW PER MATCH\n                PATTERN ( A B C )\n                DEFINE\n                    A as A.str=\'A\',\n                    B as B.str=\'B\',\n                    C as C.str=\'C\')"
  syntax: YQL_V1
}
execute_mode: RUN
idempotency_key: "5e765ed7-ed81-4dca-8356-8d58da7a36d0"
2025-12-12T12:27:00.403667Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:169: Resolve subject type bootstrap. Token: **** (B6C6F477) Actor id: [1:7582946956698091268:2172]
2025-12-12T12:27:00.403679Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:230: Subject Type: federated_account Token: **** (B6C6F477)
2025-12-12T12:27:00.403709Z :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            pragma config.flags(\"MatchRecognizeStream\", \"auto\");\n\n            INSERT INTO myyds.`test_match_recognize[v1-kikimr0]_v1_output`\n            SELECT ToBytes(Unwrap(Json::SerializeJson(Yson::From(TableRow()))))\n            FROM (SELECT * FROM myyds.`test_match_recognize[v1-kikimr0]_v1_input`\n                WITH (\n                    format=json_each_row,\n                    SCHEMA\n                    (\n                        dt UINT64,\n                        str STRING\n                    )))\n            MATCH_RECOGNIZE(\n                ORDER BY CAST(dt as Timestamp)\n                MEASURES\n                   LAST(A.dt) as dt_begin,\n                   LAST(C.dt) as dt_end,\n                   LAST(A.str) as a_str,\n                   LAST(B.str) as b_str,\n                   LAST(C.str) as c_str\n                ONE ROW PER MATCH\n                PATTERN ( A B C )\n                DEFINE\n                    A as A.str=\'A\',\n                    B as B.str=\'B\',\n                    C as C.str=\'C\')"
  syntax: YQL_V1
}
execute_mode: RUN
idempotency_key: "5e765ed7-ed81-4dca-8356-8d58da7a36d0"
2025-12-12T12:27:00.403722Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:435: Create database bootstrap. CloudId: mock_cloud Scope: yandexcloud://my_folder Actor id: [1:7582946956698091269:2173]
2025-12-12T12:27:00.403744Z :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            pragma config.flags(\"MatchRecognizeStream\", \"auto\");\n\n            INSERT INTO myyds.`test_match_recognize[v1-kikimr0]_v1_output`\n            SELECT ToBytes(Unwrap(Json::SerializeJson(Yson::From(TableRow()))))\n            FROM (SELECT * FROM myyds.`test_match_recognize[v1-kikimr0]_v1_input`\n                WITH (\n                    format=json_each_row,\n                    SCHEMA\n                    (\n                        dt UINT64,\n                        str STRING\n                    )))\n            MATCH_RECOGNIZE(\n                ORDER BY CAST(dt as Timestamp)\n                MEASURES\n                   LAST(A.dt) as dt_begin,\n                   LAST(C.dt) as dt_end,\n                   LAST(A.str) as a_str,\n                   LAST(B.str) as b_str,\n                   LAST(C.str) as c_str\n                ONE ROW PER MATCH\n                PATTERN ( A B C )\n                DEFINE\n                    A as A.str=\'A\',\n                    B as B.str=\'B\',\n                    C as C.str=\'C\')"
  syntax: YQL_V1
}
execute_mode: RUN
idempotency_key: "5e765ed7-ed81-4dca-8356-8d58da7a36d0"
2025-12-12T12:27:00.403755Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:63: Request actor. Actor id: [1:7582946956698091270:2174]
2025-12-12T12:27:00.403764Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:248: Create rate limiter resource for cloud with limit 100000ms
2025-12-12T12:27:00.403787Z :YQ_RATE_LIMITER DEBUG: schema.cpp:71: Run create rate limiter resource "mock_cloud" actor
2025-12-12T12:27:00.403789Z :YQ_RATE_LIMITER DEBUG: schema.cpp:113: Call create rate limiter resource "mock_cloud"
2025-12-12T12:27:00.415627Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.cpuPercent.count=0/10000 NOTIFY CHANGE
2025-12-12T12:27:00.415645Z :YQ_RATE_LIMITER DEBUG: schema.cpp:155: Successfully created rate limiter resource "mock_cloud"
2025-12-12T12:27:00.415648Z :YQ_RATE_LIMITER DEBUG: schema.cpp:122: Reply for create rate limiter resource "mock_cloud": 
2025-12-12T12:27:00.415676Z :YQ_CONTROL_PLANE_PROXY DEBUG: request_actor.h:272: Create response from rate limiter service. Success: 1
2025-12-12T12:27:00.415754Z :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            pragma config.flags(\"MatchRecognizeStream\", \"auto\");\n\n            INSERT INTO myyds.`test_match_recognize[v1-kikimr0]_v1_output`\n            SELECT ToBytes(Unwrap(Json::SerializeJson(Yson::From(TableRow()))))\n            FROM (SELECT * FROM myyds.`test_match_recognize[v1-kikimr0]_v1_input`\n                WITH (\n                    format=json_each_row,\n                    SCHEMA\n                    (\n                        dt UINT64,\n                        str STRING\n                    )))\n            MATCH_RECOGNIZE(\n                ORDER BY CAST(dt as Timestamp)\n                MEASURES\n                   LAST(A.dt) as dt_begin,\n                   LAST(C.dt) as dt_end,\n                   LAST(A.str) as a_str,\n                   LAST(B.str) as b_str,\n                   LAST(C.str) as c_str\n                ONE ROW PER MATCH\n                PATTERN ( A B C )\n                DEFINE\n                    A as A.str=\'A\',\n                    B as B.str=\'B\',\n                    C as C.str=\'C\')"
  syntax: YQL_V1
}
execute_mode: RUN
idempotency_key: "5e765ed7-ed81-4dca-8356-8d58da7a36d0"
} [root@builtin, **** (B6C6F477)] 
2025-12-12T12:27:00.431294Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.analyticsQuery.count=0/100 NOTIFY CHANGE
2025-12-12T12:27:00.431309Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.streamingQuery.count=0/100 NOTIFY CHANGE
2025-12-12T12:27:00.731506Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: CreateQueryRequest - CreateQueryResult: {query_id: "ptqudq7ufj3un8ovpbv9" } SUCCESS
2025-12-12T12:27:00.736126Z :TICKET_PARSER DEBUG: ticket_parser_impl.h:1875: Ticket **** (B6C6F477) (ipv6:[::1]:52944) has now valid token of root@builtin
2025-12-12T12:27:00.736199Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudq7ufj3un8ovpbv9"
2025-12-12T12:27:00.736228Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:305: Resolve folder bootstrap. Folder id: my_folder Actor id: [1:7582946956698091275:2178]
2025-12-12T12:27:00.736251Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:367: Cloud id: mock_cloud Folder id: my_folder
2025-12-12T12:27:00.736280Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:91: Get quotas bootstrap. Cloud id: mock_cloud Actor id: [1:7582946956698091276:2179]
2025-12-12T12:27:00.736293Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.analyticsQuery.count IS STALE, Refreshing ...
2025-12-12T12:27:00.736315Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.cpuPercent.count IS STALE, Refreshing ...
2025-12-12T12:27:00.736319Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.streamingQuery.count IS STALE, Refreshing ...
2025-12-12T12:27:00.736330Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.cpuPercent.count=0/10000 REFRESHED
2025-12-12T12:27:00.744512Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.cpuPercent.count=0/10000 NOTIFY CHANGE
2025-12-12T12:27:00.767433Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.analyticsQuery.count=0/100 REFRESHED
2025-12-12T12:27:00.767464Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.streamingQuery.count=1/100 REFRESHED
2025-12-12T12:27:00.767488Z :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:00.767508Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:103: Cloud id: mock_cloud Quota count: 8
2025-12-12T12:27:00.767561Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudq7ufj3un8ovpbv9"
2025-12-12T12:27:00.767643Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:169: Resolve subject type bootstrap. Token: **** (B6C6F477) Actor id: [1:7582946956698091281:2184]
2025-12-12T12:27:00.767662Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:230: Subject Type: federated_account Token: **** (B6C6F477)
2025-12-12T12:27:00.767676Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudq7ufj3un8ovpbv9"
2025-12-12T12:27:00.767688Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:63: Request actor. Actor id: [1:7582946956698091282:2185]
2025-12-12T12:27:00.767731Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_queries.cpp:641: DescribeQueryRequest: {query_id: "ptqudq7ufj3un8ovpbv9"
} [root@builtin, **** (B6C6F477)] 
2025-12-12T12:27:00.796461Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.streamingQuery.count=1/100 NOTIFY CHANGE
2025-12-12T12:27:00.796711Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.analyticsQuery.count=0/100 NOTIFY CHANGE
2025-12-12T12:27:00.821439Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: DescribeQueryRequest - DescribeQueryResult: {query { meta { common { id: "ptqudq7ufj3un8ovpbv9" created_by: "root@builtin" modified_by: "root@builtin" created_at { seconds: 1765542420 nanos: 415688000 } modified_at { seconds: 1765542420 nanos: 415688000 } revision: 1 } execute_mode: RUN status: STARTING last_job_query_revision: 1 last_job_id: "ptjudq7ufj3uml71nrkh-ptqudq7ufj3un8ovpbv9" started_by: "root@builtin" submitted_at { seconds: 1765542420 nanos: 415688000 } } 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            pragma config.flags(\"MatchRecognizeStream\", \"auto\");\n\n            INSERT INTO myyds.`test_match_recognize[v1-kikimr0]_v1_output`\n            SELECT ToBytes(Unwrap(Json::SerializeJson(Yson::From(TableRow()))))\n            FROM (SELECT * FROM myyds.`test_match_recognize[v1-kikimr0]_v1_input`\n                WITH (\n                    format=json_each_row,\n                    SCHEMA\n                    (\n                        dt UINT64,\n                        str STRING\n                    )))\n            MATCH_RECOGNIZE(\n                ORDER BY CAST(dt as Timestamp)\n                MEASURES\n                   LAST(A.dt) as dt_begin,\n                   LAST(C.dt) as dt_end,\n                   LAST(A.str) as a_str,\n                   LAST(B.str) as b_str,\n                   LAST(C.str) as c_str\n                ONE ROW PER MATCH\n                PATTERN ( A B C )\n                DEFINE\n                    A as A.str=\'A\',\n                    B as B.str=\'B\',\n                    C as C.str=\'C\')" syntax: YQL_V1 } } } SUCCESS
2025-12-12T12:27:00.880373Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582946948108156592:2093]
2025-12-12T12:27:00.880401Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:00.880410Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582946948108156550:2068]
2025-12-12T12:27:00.880415Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582946948108156550:2068]
2025-12-12T12:27:00.880419Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582946948108156550:2068]
2025-12-12T12:27:00.880441Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:01.023518Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: d75b22cc-ded50da4-a0ea8476-6e0a8e2f2, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 68 bytes
2025-12-12T12:27:01.023581Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "d75b22cc-ded50da4-a0ea8476-6e0a8e2f2"
host: "ghrun-fhkyrtz6p4"
node_id: 1
}
2025-12-12T12:27:01.027866Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:463: Task (Query): ptqudq7ufj3un8ovpbv9 RetryRate: 0 RetryCounter: 0 At: 2025-12-12T12:27:00.539439Z
2025-12-12T12:27:01.177044Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {tasks { query_id { value: "ptqudq7ufj3un8ovpbv9" } job_id { value: "ptjudq7ufj3uml71nrkh" } 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            pragma config.flags(\"MatchRecognizeStream\", \"auto\");\n\n            INSERT INTO myyds.`test_match_recognize[v1-kikimr0]_v1_output`\n            SELECT ToBytes(Unwrap(Json::SerializeJson(Yson::From(TableRow()))))\n            FROM (SELECT * FROM myyds.`test_match_recognize[v1-kikimr0]_v1_input`\n                WITH (\n                    format=json_each_row,\n                    SCHEMA\n                    (\n                        dt UINT64,\n                        str STRING\n                    )))\n            MATCH_RECOGNIZE(\n                ORDER BY CAST(dt as Timestamp)\n                MEASURES\n                   LAST(A.dt) as dt_begin,\n                   LAST(C.dt) as dt_end,\n                   LAST(A.str) as a_str,\n                   LAST(B.str) as b_str,\n                   LAST(C.str) as c_str\n                ONE ROW PER MATCH\n                PATTERN ( A B C )\n                DEFINE\n                    A as A.str=\'A\',\n                    B as B.str=\'B\',\n                    C as C.str=\'C\')" connection { content { name: "myyds" setting { data_streams { auth { none { } } endpoint: "localhost:25827" database: "local" } } acl { visibility: PRIVATE } } meta { id: "ptcudq7ufjfufnmne5eb" created_by: "root@builtin" modified_by: "root@builtin" created_at { seconds: 1765542420 nanos: 22778000 } modified_at { seconds: 1765542420 nanos: 22778000 } 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: 1765628821 nanos: 82764000 } 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: 1765542420 nanos: 415688000 } } } SUCCESS
2025-12-12T12:27:01.177156Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: d75b22cc-ded50da4-a0ea8476-6e0a8e2f2, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:27:01.180344Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: d75b22cc-ded50da4-a0ea8476-6e0a8e2f3, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 68 bytes
2025-12-12T12:27:01.180381Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "d75b22cc-ded50da4-a0ea8476-6e0a8e2f3"
host: "ghrun-fhkyrtz6p4"
node_id: 1
}
2025-12-12T12:27:01.180429Z :YQL_PRIVATE_PROXY DEBUG: rate_limiter_resources.cpp:78: PrivateCreateRateLimiterResource - QueryId: ptqudq7ufj3un8ovpbv9, Owner: d75b22cc-ded50da4-a0ea8476-6e0a8e2f2, Request CP::CreateRateLimiterResource with size: 97 bytes
2025-12-12T12:27:01.180438Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudq7ufj3un8ovpbv9, Owner: d75b22cc-ded50da4-a0ea8476-6e0a8e2f2, Request CP::PingTask with size: 127 bytes
2025-12-12T12:27:01.180454Z :YQ_CONTROL_PLANE_STORAGE TRACE: request_actor.h:57: CreateRateLimiterResourceRequest: {owner_id: "d75b22cc-ded50da4-a0ea8476-6e0a8e2f2"
query_id {
  value: "ptqudq7ufj3un8ovpbv9"
}
scope: "yandexcloud://my_folder"
tenant: "/compute"
} 
2025-12-12T12:27:01.180539Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "d75b22cc-ded50da4-a0ea8476-6e0a8e2f2"
query_id {
  value: "ptqudq7ufj3un8ovpbv9"
}
scope: "yandexcloud://my_folder"
started_at {
  seconds: 1765542421
  nanos: 178000000
}
deadline {
  seconds: 1765628821
  nanos: 82764000
}
tenant: "/compute"
}
2025-12-12T12:27:01.187498Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:27:01.187564Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: d75b22cc-ded50da4-a0ea8476-6e0a8e2f3, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:27:01.228556Z :YQ_CONTROL_PLANE_STORAGE DEBUG: rate_limiter_resources.cpp:74: CreateRateLimiterResourceRequest. Got response from database: SUCCESS
2025-12-12T12:27:01.228666Z :YQ_RATE_LIMITER DEBUG: schema.cpp:71: Run create rate limiter resource "mock_cloud/my_folder/ptqudq7ufj3un8ovpbv9" actor
2025-12-12T12:27:01.228667Z :YQ_RATE_LIMITER DEBUG: schema.cpp:113: Call create rate limiter resource "mock_cloud/my_folder/ptqudq7ufj3un8ovpbv9"
2025-12-12T12:27:01.230183Z :YQ_RATE_LIMITER DEBUG: schema.cpp:261: Trying to recursively create rate limiter resource "mock_cloud/my_folder"
2025-12-12T12:27:01.230192Z :YQ_RATE_LIMITER DEBUG: schema.cpp:113: Call create rate limiter resource "mock_cloud/my_folder"
2025-12-12T12:27:01.243205Z :YQ_RATE_LIMITER DEBUG: schema.cpp:244: Successfully created rate limiter resource "mock_cloud/my_folder"
2025-12-12T12:27:01.243222Z :YQ_RATE_LIMITER DEBUG: schema.cpp:113: Call create rate limiter resource "mock_cloud/my_folder/ptqudq7ufj3un8ovpbv9"
2025-12-12T12:27:01.259303Z :YQ_RATE_LIMITER DEBUG: schema.cpp:155: Successfully created rate limiter resource "mock_cloud/my_folder/ptqudq7ufj3un8ovpbv9"
2025-12-12T12:27:01.259318Z :YQ_RATE_LIMITER DEBUG: schema.cpp:122: Reply for create rate limiter resource "mock_cloud/my_folder/ptqudq7ufj3un8ovpbv9": 
2025-12-12T12:27:01.259378Z :YQ_CONTROL_PLANE_STORAGE DEBUG: rate_limiter_resources.cpp:180: Got create response from rate limiter service
2025-12-12T12:27:01.259412Z :YQL_PRIVATE_PROXY DEBUG: rate_limiter_resources.cpp:102: PrivateCreateRateLimiterResource - QueryId: ptqudq7ufj3un8ovpbv9, Owner: d75b22cc-ded50da4-a0ea8476-6e0a8e2f2, Got CP::CreateRateLimiterResourceResponse
2025-12-12T12:27:01.327622Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudq7ufj3un8ovpbv9"
2025-12-12T12:27:01.327676Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:305: Resolve folder bootstrap. Folder id: my_folder Actor id: [1:7582946960993058597:2203]
2025-12-12T12:27:01.327702Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:367: Cloud id: mock_cloud Folder id: my_folder
2025-12-12T12:27:01.327730Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:91: Get quotas bootstrap. Cloud id: mock_cloud Actor id: [1:7582946960993058598:2204]
2025-12-12T12:27:01.327762Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.analyticsQuery.count IS STALE, Refreshing ...
2025-12-12T12:27:01.327774Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.cpuPercent.count IS STALE, Refreshing ...
2025-12-12T12:27:01.327777Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.streamingQuery.count IS STALE, Refreshing ...
2025-12-12T12:27:01.327823Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.cpuPercent.count=0/10000 REFRESHED
2025-12-12T12:27:01.343543Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.analyticsQuery.count=0/100 REFRESHED
2025-12-12T12:27:01.343577Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.streamingQuery.count=1/100 REFRESHED
2025-12-12T12:27:01.343604Z :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:01.343614Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:103: Cloud id: mock_cloud Quota count: 8
2025-12-12T12:27:01.343646Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudq7ufj3un8ovpbv9"
2025-12-12T12:27:01.343743Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:169: Resolve subject type bootstrap. Token: **** (B6C6F477) Actor id: [1:7582946960993058603:2209]
2025-12-12T12:27:01.343767Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:230: Subject Type: federated_account Token: **** (B6C6F477)
2025-12-12T12:27:01.343800Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudq7ufj3un8ovpbv9"
2025-12-12T12:27:01.343812Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:63: Request actor. Actor id: [1:7582946960993058604:2210]
2025-12-12T12:27:01.343844Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_queries.cpp:641: DescribeQueryRequest: {query_id: "ptqudq7ufj3un8ovpbv9"
} [root@builtin, **** (B6C6F477)] 
2025-12-12T12:27:01.355419Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: DescribeQueryRequest - DescribeQueryResult: {query { meta { common { id: "ptqudq7ufj3un8ovpbv9" created_by: "root@builtin" modified_by: "root@builtin" created_at { seconds: 1765542420 nanos: 415688000 } modified_at { seconds: 1765542420 nanos: 415688000 } revision: 1 } execute_mode: RUN status: STARTING last_job_query_revision: 1 last_job_id: "ptjudq7ufj3uml71nrkh-ptqudq7ufj3un8ovpbv9" started_by: "root@builtin" submitted_at { seconds: 1765542420 nanos: 415688000 } } 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            pragma config.flags(\"MatchRecognizeStream\", \"auto\");\n\n            INSERT INTO myyds.`test_match_recognize[v1-kikimr0]_v1_output`\n            SELECT ToBytes(Unwrap(Json::SerializeJson(Yson::From(TableRow()))))\n            FROM (SELECT * FROM myyds.`test_match_recognize[v1-kikimr0]_v1_input`\n                WITH (\n                    format=json_each_row,\n                    SCHEMA\n                    (\n                        dt UINT64,\n                        str STRING\n                    )))\n            MATCH_RECOGNIZE(\n                ORDER BY CAST(dt as Timestamp)\n                MEASURES\n                   LAST(A.dt) as dt_begin,\n                   LAST(C.dt) as dt_end,\n                   LAST(A.str) as a_str,\n                   LAST(B.str) as b_str,\n                   LAST(C.str) as c_str\n                ONE ROW PER MATCH\n                PATTERN ( A B C )\n                DEFINE\n                    A as A.str=\'A\',\n                    B as B.str=\'B\',\n                    C as C.str=\'C\')" syntax: YQL_V1 } } } SUCCESS
2025-12-12T12:27:01.358249Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.cpuPercent.count=0/10000 NOTIFY CHANGE
2025-12-12T12:27:01.371458Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.analyticsQuery.count=0/100 NOTIFY CHANGE
2025-12-12T12:27:01.371476Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.streamingQuery.count=1/100 NOTIFY CHANGE
2025-12-12T12:27:01.455619Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {expired_at { seconds: 1765542441 nanos: 362000000 } } SUCCESS
2025-12-12T12:27:01.455667Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudq7ufj3un8ovpbv9, Owner: d75b22cc-ded50da4-a0ea8476-6e0a8e2f2, Got CP::PingTaskResponse
2025-12-12T12:27:01.463140Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudq7ufj3un8ovpbv9, Owner: d75b22cc-ded50da4-a0ea8476-6e0a8e2f2, Request CP::PingTask with size: 122 bytes
2025-12-12T12:27:01.463232Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "d75b22cc-ded50da4-a0ea8476-6e0a8e2f2"
query_id {
  value: "ptqudq7ufj3un8ovpbv9"
}
status: RUNNING
resources {
  rate_limiter: PREPARE
  compilation: PREPARE
}
scope: "yandexcloud://my_folder"
deadline {
  seconds: 1765628821
  nanos: 82764000
}
tenant: "/compute"
}
2025-12-12T12:27:01.483174Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {expired_at { seconds: 1765542441 nanos: 474000000 } } SUCCESS
2025-12-12T12:27:01.483216Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudq7ufj3un8ovpbv9, Owner: d75b22cc-ded50da4-a0ea8476-6e0a8e2f2, Got CP::PingTaskResponse
2025-12-12T12:27:01.490197Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudq7ufj3un8ovpbv9, Owner: d75b22cc-ded50da4-a0ea8476-6e0a8e2f2, Request CP::PingTask with size: 191 bytes
2025-12-12T12:27:01.490284Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "d75b22cc-ded50da4-a0ea8476-6e0a8e2f2"
query_id {
  value: "ptqudq7ufj3un8ovpbv9"
}
status: RUNNING
resources {
  rate_limiter: READY
  compilation: PREPARE
  rate_limiter_path: "local/RateLimiter_5958a75f-5918-4b93-a01c-15191f6a0817/rate_limiter"
}
scope: "yandexcloud://my_folder"
deadline {
  seconds: 1765628821
  nanos: 82764000
}
tenant: "/compute"
}
2025-12-12T12:27:01.506561Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {expired_at { seconds: 1765542441 nanos: 496000000 } } SUCCESS
2025-12-12T12:27:01.506667Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudq7ufj3un8ovpbv9, Owner: d75b22cc-ded50da4-a0ea8476-6e0a8e2f2, Got CP::PingTaskResponse
2025-12-12T12:27:01.710606Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudq7ufj3un8ovpbv9, Owner: d75b22cc-ded50da4-a0ea8476-6e0a8e2f2, Request CP::PingTask with size: 6781 bytes
2025-12-12T12:27:01.710711Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "d75b22cc-ded50da4-a0ea8476-6e0a8e2f2"
query_id {
  value: "ptqudq7ufj3un8ovpbv9"
}
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 (Configure! $5 $1 \'\"MatchRecognizeStream\" \'\"auto\"))\n(let $7 (DataSource \'\"pq\" \'\"myyds\"))\n(let $8 \'(\'(\'\"PartitionsCount\" \'1)))\n(let $9 (OptionalType (DataType \'Uint64)))\n(let $10 \'(\'dt $9))\n(let $11 (DataType \'String))\n(let $12 (OptionalType $11))\n(let $13 \'(\'str $12))\n(let $14 (StructType $10 $13))\n(let $15 (PqTopic \'\"myyds\" \'\"local\" \'\"test_match_recognize[v1-kikimr0]_v1_input\" $8 \'() $14))\n(let $16 \'(\'\"Endpoint\" \'\"localhost:25827\"))\n(let $17 \'(\'\"SharedReading\" \'0))\n(let $18 \'(\'\"AddBearerToToken\" \'1))\n(let $19 \'($16 $17 \'(\'\"ReconnectPeriod\" \'\"\") \'(\'\"Format\" \'\"json_each_row\") \'(\'\"ReadGroup\" \'\"ptcudq7ufjfufnmne5eb\") $18))\n(let $20 (SecureParam \'\"cluster:default_myyds\"))\n(let $21 (DqPqTopicSource $6 $15 \'(\'dt \'str) $19 $20 \'\"\" $14 \'\"\"))\n(let $22 (DqStage \'((DqSource $7 $21)) (lambda \'($26) (block \'(\n  (let $27 \'(\'(\'\"format\" \'\"json_each_row\") \'(\'\"formatSettings\" \'(\'(\'\"data.datetime.formatname\" \'\"POSIX\") \'(\'\"data.timestamp.formatname\" \'\"POSIX\"))) \'(\'\"settings\" \'($17))))\n  (let $28 (DqSourceWideWrap $26 $7 $14 $27))\n  (return (NarrowMap $28 (lambda \'($29 $30) (AsStruct \'(\'dt $29) \'(\'str $30)))))\n))) \'(\'(\'\"_logical_id\" \'201711))))\n(let $23 (DataSink \'\"pq\" \'\"myyds\"))\n(let $24 (PqTopic \'\"myyds\" \'\"local\" \'\"test_match_recognize[v1-kikimr0]_v1_output\" $8 \'() (StructType \'(\'\"Data\" $11))))\n(let $25 (DqPqTopicSink $24 \'($16 $18) $20))\n(return (Commit! (DqQuery! $6 \'((DqStage \'((DqCnUnionAll (TDqOutput $22 \'0))) (lambda \'($31) (block \'(\n  (let $32 (TimeOrderRecover $31 (lambda \'($47) (SafeCast (Member $47 \'dt) (OptionalType (DataType \'Timestamp)))) (Interval \'\"-1000000\") (Interval \'\"1000000\") (Uint32 \'\"1000000\")))\n  (let $33 \'(\'\"A\" \'\"B\" \'\"C\"))\n  (let $34 \'(\'\"dt_begin\" \'\"dt_end\" \'\"a_str\" \'\"b_str\" \'\"c_str\"))\n  (let $35 (lambda \'($52) (ListFromRange (Member $52 \'\"From\") (+ (Member $52 \'\"To\") (Uint64 \'1)) (Int64 \'1))))\n  (let $36 (lambda \'($57) $57))\n  (let $37 (AggregationTraits (StructType $10) (lambda \'($54) (Member $54 \'dt)) (lambda \'($55 $56) (Coalesce (Member $55 \'dt) $56)) $36 $36 (lambda \'($58 $59) (Coalesce $58 $59)) $36 (Null)))\n  (let $38 (lambda \'($69) $69))\n  (let $39 (AggregationTraits (StructType $13) (lambda \'($66) (Member $66 \'str)) (lambda \'($67 $68) (Coalesce (Member $67 \'str) $68)) $38 $38 (lambda \'($70 $71) (Coalesce $70 $71)) $38 (Null)))\n  (let $40 (MatchRecognizeMeasures $14 $33 $34 (lambda \'($50 $51) (Member (Head (Aggregate (OrderedFlatMap (OrderedFlatMap (Member $51 \'\"A\") $35) (lambda \'($53) (Just (AsStruct \'(\'dt (Member (Unwrap (Lookup (ToIndexDict $50) $53)) \'dt)))))) \'() \'(\'(\'Last0 $37)) \'())) \'Last0)) (lambda \'($60 $61) (Member (Head (Aggregate (OrderedFlatMap (OrderedFlatMap (Member $61 \'\"C\") $35) (lambda \'($62) (Just (AsStruct \'(\'dt (Member (Unwrap (Lookup (ToIndexDict $60) $62)) \'dt)))))) \'() \'(\'(\'Last1 $37)) \'())) \'Last1)) (lambda \'($63 $64) (Member (Head (Aggregate (OrderedFlatMap (OrderedFlatMap (Member $64 \'\"A\") $35) (lambda \'($65) (Just (AsStruct \'(\'str (Member (Unwrap (Lookup (ToIndexDict $63) $65)) \'str)))))) \'() \'(\'(\'Last2 $39)) \'())) \'Last2)) (lambda \'($72 $73) (Member (Head (Aggregate (OrderedFlatMap (OrderedFlatMap (Member $73 \'\"B\") $35) (lambda \'($74) (Just (AsStruct \'(\'str (Member (Unwrap (Lookup (ToIndexDict $72) $74)) \'str)))))) \'() \'(\'(\'Last3 $39)) \'())) \'Last3)) (lambda \'($75 $76) (Member (Head (Aggregate (OrderedFlatMap (OrderedFlatMap (Member $76 \'\"C\") $35) (lambda \'($77) (Just (AsStruct \'(\'str (Member (Unwrap (Lookup (ToIndexDict $75) $77)) \'str)))))) \'() \'(\'(\'Last4 $39)) \'())) \'Last4))))\n  (let $41 \'(\'\"A\" \'1 \'1 \'1 \'1 \'0))\n  (let $42 \'(\'\"B\" \'1 \'1 \'1 \'1 \'0))\n  (let $43 \'(\'\"C\" \'1 \'1 \'1 \'1 \'0))\n  (let $44 (MatchRecognizeDefines $14 $33 $33 (lambda \'($78 $79 $80) (== (Member (Lookup (ToIndexDict $78) $80) \'str) (String \'\"A\"))) (lambda \'($81 $82 $83) (== (Member (Lookup (ToIndexDict $81) $83) \'str) (String \'\"B\"))) (lambda \'($84 $85 $86) (== (Member (Lookup (ToIndexDict $84) $86) \'str) (String \'\"C\")))))\n  (let $45 (MatchRecognizeParams $40 \'\"RowsPerMatch_OneRow\" \'(\'\"AfterMatchSkip_PastLastRow\" \'\"\") (MatchRecognizePattern \'($41 $42 $43)) $44))\n  (let $46 (MatchRecognizeCore (OrderedFlatMap $32 (lambda \'($48) (OptionalIf (Not (Member $48 \'\"_yql_OutOfOrder\")) (AsStruct \'(\'dt (Member $48 \'dt)) \'(\'str (Member $48 \'str)))))) (lambda \'($49) \'()) \'() $45 \'(\'(\'\"Streaming\" \'1))))\n  (return (FromFlow (FlatMap $46 (lambda \'($87) (block \'(\n    (let $88 (ResourceType \'\"Yson2.Node\"))\n    (let $89 \'($88 \'\"\" \'1))\n    (let $90 (ResourceType \'\"Yson2.Options\"))\n    (let $91 (OptionalType (DataType \'Bool)))\n    (let $92 (CallableType \'(\'\"4\") \'((OptionalType (DataType \'Json))) $89 \'((OptionalType $90)) \'($91 \'\"SkipMapEntity\") \'($91 \'\"EncodeUtf8\") \'($91 \'\"WriteNanAsString\")))\n    (let $93 (Udf \'\"Yson2.SerializeJson\" (Void) (VoidType) \'\"\" $92 (VoidType) \'\"\" \'()))\n    (let $94 (StructType \'(\'\"a_str\" $12) \'(\'\"b_str\" $12) \'(\'\"c_str\" $12) \'(\'\"dt_begin\" $9) \'(\'\"dt_end\" $9)))\n    (let $95 (TupleType (TupleType $94) (StructType) (TupleType)))\n    (let $96 (CallableType \'() \'($88) \'($94)))\n    (let $97 \'(\'(\'\"strict\")))\n    (let $98 (Udf \'\"Yson2.From\" (Void) $95 \'\"\" $96 (VoidType) \'\"\" $97))\n    (let $99 (CallableType \'(\'\"2\") \'($90) \'($91 \'\"AutoConvert\") \'($91 \'\"Strict\")))\n    (let $100 (Udf \'\"Yson2.Options\" (Void) (VoidType) \'\"\" $99 (VoidType) \'\"\" $97))\n    (return (Just (AsStruct \'(\'\"column0\" (ToBytes (Unwrap (Apply $93 (Apply $98 $87) (Just (NamedApply $100 \'() (AsStruct \'(\'\"AutoConvert\" (Just (Bool \'false))) \'(\'\"Strict\" (Just (Bool \'true)))))))))))))\n  ))))))\n))) \'(\'(\'\"_logical_id\" \'204487) \'(\'\"_partition_mode\" \'\"aggregate\")) \'((DqSink \'0 $23 $25))))) $23))\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: 1765628821
  nanos: 82764000
}
tenant: "/compute"
}
2025-12-12T12:27:01.731131Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {expired_at { seconds: 1765542441 nanos: 718000000 } } SUCCESS
2025-12-12T12:27:01.731223Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudq7ufj3un8ovpbv9, Owner: d75b22cc-ded50da4-a0ea8476-6e0a8e2f2, Got CP::PingTaskResponse
2025-12-12T12:27:01.736654Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudq7ufj3un8ovpbv9, Owner: d75b22cc-ded50da4-a0ea8476-6e0a8e2f2, Request CP::PingTask with size: 201 bytes
2025-12-12T12:27:01.736725Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "d75b22cc-ded50da4-a0ea8476-6e0a8e2f2"
query_id {
  value: "ptqudq7ufj3un8ovpbv9"
}
transient_issues {
  message: "Parse Sql"
  severity: 2
  issues {
    position {
      row: 10
      column: 41
    }
    message: "Json UDF is deprecated. Please use JSON API instead"
    end_position {
      row: 10
      column: 41
    }
    issue_code: 4506
    severity: 2
  }
}
scope: "yandexcloud://my_folder"
deadline {
  seconds: 1765628821
  nanos: 82764000
}
tenant: "/compute"
}
2025-12-12T12:27:01.761055Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {expired_at { seconds: 1765542441 nanos: 747000000 } } SUCCESS
2025-12-12T12:27:01.761120Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudq7ufj3un8ovpbv9, Owner: d75b22cc-ded50da4-a0ea8476-6e0a8e2f2, Got CP::PingTaskResponse
2025-12-12T12:27:01.763399Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudq7ufj3un8ovpbv9, Owner: d75b22cc-ded50da4-a0ea8476-6e0a8e2f2, Request CP::PingTask with size: 7185 bytes
2025-12-12T12:27:01.763517Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "d75b22cc-ded50da4-a0ea8476-6e0a8e2f2"
query_id {
  value: "ptqudq7ufj3un8ovpbv9"
}
dq_graph: "\022\337\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*\362\003Z\357\003\n\010PqSource\022\340\003\n4type.googleapis.com/NYql.NPq.NProto.TDqPqTopicSource\022\247\003\n)test_match_recognize[v1-kikimr0]_v1_input\022\024ptqudq7ufj3un8ovpbv9\032\017localhost:25827\"\027\n\025cluster:default_myyds*\005local0\002@\001b\002dtb\003strj&[\"OptionalType\";[\"DataType\";\"Uint64\"]]j&[\"OptionalType\";[\"DataType\";\"String\"]]\222\001\024ptcudq7ufjfufnmne5eb\232\001\rjson_each_row\242\001m[\"StructType\";[[\"dt\";[\"OptionalType\";[\"DataType\";\"Uint64\"]]];[\"str\";[\"OptionalType\";[\"DataType\";\"String\"]]]]]\262\001\002\022\000\272\001\026\n\010cloud_id\022\nmock_cloud\272\001 \n\005scope\022\027yandexcloud://my_folder\030\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\315\213\r`\341\213\rR\000:\203\001\n*type.googleapis.com/Yql.DqsProto.TTaskMeta\022U\010\315\213\r\022A\022(88a034dc314301cb1522a933e690a4c49a7591e8\032\023dq_vanilla_job.lite \002\"\014\n\002pq\022\006\n\004\010\001\030\001H\315\213\rRClocal/RateLimiter_5958a75f-5918-4b93-a01c-15191f6a0817/rate_limiterZ)mock_cloud/my_folder/ptqudq7ufj3un8ovpbv9`\200\200\200\200 \230\001\000\300\001\001\022\203\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\315\213\r`\341\213\rR\0002\245\001z\242\001\n\006PqSink\022\227\001\n2type.googleapis.com/NYql.NPq.NProto.TDqPqTopicSink\022a\n*test_match_recognize[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\341\213\r\022A\022(88a034dc314301cb1522a933e690a4c49a7591e8\032\023dq_vanilla_job.lite \002H\341\213\rRClocal/RateLimiter_5958a75f-5918-4b93-a01c-15191f6a0817/rate_limiterZ)mock_cloud/my_folder/ptqudq7ufj3un8ovpbv9`\200\200\200\200 \230\001\000\300\001\0012qptqudq7ufj3un8ovpbv9#ptrudq7uficm40bnb33c#yandexcloud://my_folder#d75b22cc-ded50da4-a0ea8476-6e0a8e2f2#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\201%\010\341\213\r\022\372$\037<\nFlags\010Name\010Args\016Payload\000\006Udf\014Apply2\na_str\nb_str\nc_str\020dt_begin\014dt_end\006Arg\014Unwrap\nIndex\024SourceType\004dt\006str\026ToIndexDict\014Lookup\014Member\014Invoke\020Coalesce\032ListFromRange\034OrderedFlatMap\016Collect\014ToFlow\022Condense1\006Map\010Head\005\205\006\213\002\204\205\004\207\203\010\207\203\005@BF\205\000\204\205\002\203\005@\034column0\030Inputs(Parameters\034Program\013?\014)\251\000?\n2\000\205\002\000)\251\000?\0162\000\245\002)\211\002?\024\215?\022 FromFlow\000)\211\006?\"\215\205\n?\006?\006?\006?\002?\002\036\"&*.?&?\022r\000)\2114?(\215\205\004?\002?\006BF?,\213\000\206\203\004\206\205\010\203\001H\203\010?\002?\006<_yql_Classifier@_yql_MatchNumberBF\206?2\203\004\205\006\206\205\004\203\010\203\010\020From\010To?H?H\004A\004B\004C\206?2?\002?\002?\006?\006?\006\213\002\213\006\213\014\203\005@\203\010\203\010\203\014\203\014\203\014\213\014\203\005@\203\010\203\010\203\014\203\014\203\014\213\014\203\005@\203\010\203\010\203\014\203\014\203\014\203\010\206?,\206\203\005@\207\203\014\207\203\014\207\203\014\203\014\203\002\203\005@\203\002\206\205\004\203\010\203\002:>HMatchRecognizeCore\000)\211\006?.\215\205\006\203\014?\002?\006<_yql_OutOfOrderBF?\244?,(OrderedMap\000)\211\006?\246?\246?\244?\2424OrderedFilter\000)\211\020?\246\215?\010?\010\207\203d\203\004\203\004\203f\203f\203\004@TimeOrderRecover\000)\211\002?\254?\nj\000?\032\000\211\002)\251\000?\0102\000y\002)\211\004?\260\203\005@?\002V\000\003?\306\024ToIntegral)\211\004?\002?\010\203\004R\000?\304\003?\314\000\002}\002\001\201\002\003?\262\004\003?\264\000\003?\266\373#\364\003?\270\003$\364\003?\272\003\022z\370\215\002)\251\000?\2442\000m\002)\211\002?\242?\242\014Not\000)\211\004?\242?\244\203\004R\000?\344\003?\350\000\002q\002\000u\002\000\221\002)\251\000?\2442\000a\002\005?,)\211\004?\002?\244\203\004R\000?\366\003?\370\002\002i\002)\211\004?\006?\244\203\004R\000?\366\003?\001\002\004\002e\002\000\004\225\002)\251\000?,2\000]\002\013\213\000\006\000?4)\251\000?<2\0006\006\004?>\003\203\004\000\003\203\004\002\003\003?@\004)\251\000?J2\000R\006\n?L\003\203\004\006\003\203\004\010\003\203\004\000\003\203\004\002\003\203\004\004\037)\211\004?\002\207\205\002?\002\024Last0\203\004R\000)\211\002?\205\002\206?\201\002v\000)\211\006?\221\002\206?\002?\002?\201\002r\000)\211\002?\231\002\215?\002f\000)\211\014?\241\002\215?B?B?\002?\002\203\014?\002n\000)\211\002?\251\002\206?Bj\000)\211\002?\265\002\206?Bf\000)\211\006?\275\002?H?F\206?Bb\000)\211\004?H?J\203\004R\000?Q\002\003?\315\002\000\0029\002)\251\000?F2\000%\002)\211\006?\305\002?B\203\010\203\006^\000)\211\004?B?F\203\004R\000?\341\002\003?\361\002\000\0021\002)\211\006?\345\002\203\005@?D\203\010V\000\003?\001\003\006Add)\211\004?D?F\203\004R\000?\341\002\003?\021\003\002\002)\002\003?\005\003\002\005-\002\003?\351\002\004\0045\002\000=\002\000A\002\000E\002)\251\000?B2\000\001\002)\211\004?\002?:\203\004R\000)\211\n?:\207?:\203\005@\203\005@\203\004\203\0046\000)\211\004?M\003\210\203\010?:?BN\000)\211\002?i\003?<J\000?1\002\000\005\002?A\003\000\031\002\003?Q\003\000\003?U\003\000\003?Y\003,\003?]\003(\036\035\002\003?E\003\004\002!\002)\251\000?\0022\000\376\003?\255\002\000)\211\004?\002?\002?\002Z\000)\211\004?\002?:\203\004R\000)\211\n?:\207?:\203\005@\203\005@\203\004\203\0046\000)\211\004?\261\003?i\003?BN\000?u\003?A\003\000\t\002\003?\265\003\000\003?\271\003\000\003?\275\003,\003?\301\003(\036\r\002\003?\251\003\004\002\021\002?\235\003\000\025\002\020I\002\000M\002)\251\000?\0022\000\374\005?\201\002?\375\003\000\004Q\002\000U\002\003?\211\002\000\002Y\002)\211\004?\002\207\205\002?\002\024Last1\203\004R\000)\211\002?\031\004\206?\025\004v\000)\211\006?%\004\206?\002?\002?\025\004r\000)\211\002?-\004\215?\002f\000)\211\014?5\004\215?B?B?\002?\002?\255\002?\002n\000)\211\002?=\004\206?Bj\000)\211\002?E\004\206?Bf\000)\211\006?M\004?H?F\206?Bb\000)\211\004?H?J\203\004R\000?Q\002\003?]\004\004\002\352)\251\000?F2\000\340)\211\006?U\004?B\203\010?\351\002^\000)\211\004?B?F\203\004R\000?q\004\003?}\004\000\002\346)\211\006?u\004\203\005@?D?\005\003V\000\003?\215\004\006Add)\211\004?D?F\203\004R\000?q\004\003?\231\004\002\002\342?!\003\005\344?)\003\004\350\000\354\000\356\000\360)\251\000?B2\000\316)\211\004?\002?:\203\004R\000)\211\n?:\207?:\203\005@\203\005@\203\004\203\0046\000)\211\004?\315\004\210\203\010?:?BN\000)\211\002?\351\004?<J\000?1\002\000\320?\301\004\000\332\003?\321\004\000\003?\325\004\000\003?\331\004.\003?\335\004(\036\334\003?\305\004\004\002\336)\251\000?\0022\000\314?\241\003)\211\004?\002?\002?\002Z\000)\211\004?\002?:\203\004R\000)\211\n?:\207?:\203\005@\203\005@\203\004\203\0046\000)\211\004?-\005?\351\004?BN\000?\365\004?\301\004\000\322\003?1\005\000\003?5\005\000\003?9\005.\003?=\005(\036\324\003?%\005\004\002\326?\035\005\000\330\020\362\000\364)\251\000?\0022\000\312\005?\025\004?y\005\000\004\366\000\370\003?\035\004\000\002\372)\211\004?\006\207\205\002?\006\024Last2\203\004R\000)\211\002?\225\005\206?\221\005v\000)\211\006?\241\005\206?\006?\006?\221\005r\000)\211\002?\251\005\215?\006f\000)\211\014?\261\005\215?B?B?\006?\006?\255\002?\006n\000)\211\002?\271\005\206?Bj\000)\211\002?\301\005\206?Bf\000)\211\006?\311\005?H?F\206?Bb\000)\211\004?H?J\203\004R\000?Q\002\003?\331\005\000\002\270)\251\000?F2\000\256)\211\006?\321\005?B\203\010?\351\002^\000)\211\004?B?F\203\004R\000?\355\005\003?\371\005\000\002\264)\211\006?\361\005\203\005@?D?\005\003V\000\003?\t\006\006Add)\211\004?D?F\203\004R\000?\355\005\003?\025\006\002\002\260?!\003\005\262?)\003\004\266\000\272\000\274\000\276)\251\000?B2\000\234)\211\004?\006?:\203\004R\000)\211\n?:\207?:\203\005@\203\005@\203\004\203\0046\000)\211\004?I\006\210\203\010?:?BN\000)\211\002?e\006?<J\000?1\002\000\236?=\006\000\250\003?M\006\000\003?Q\006\000\003?U\0060\003?Y\006(\036\252\003?A\006\006\002\254)\251\000?\0062\000\232?\241\003)\211\004?\006?\006?\006Z\000)\211\004?\006?:\203\004R\000)\211\n?:\207?:\203\005@\203\005@\203\004\203\0046\000)\211\004?\251\006?e\006?BN\000?q\006?=\006\000\240\003?\255\006\000\003?\261\006\000\003?\265\0060\003?\271\006(\036\242\003?\241\006\006\002\244?\231\006\000\246\020\300\000\302)\251\000?\0062\000\230\005?\221\005?\365\006\000\004\304\000\306\003?\231\005\000\002\310)\211\004?\006\207\205\002?\006\024Last3\203\004R\000)\211\002?\021\007\206?\r\007v\000)\211\006?\035\007\206?\006?\006?\r\007r\000)\211\002?%\007\215?\006f\000)\211\014?-\007\215?B?B?\006?\006?\255\002?\006n\000)\211\002?5\007\206?Bj\000)\211\002?=\007\206?Bf\000)\211\006?E\007?H?F\206?Bb\000)\211\004?H?J\203\004R\000?Q\002\003?U\007\002\002\206)\251\000?F2\000|)\211\006?M\007?B\203\010?\351\002^\000)\211\004?B?F\203\004R\000?i\007\003?u\007\000\002\202)\211\006?m\007\203\005@?D?\005\003V\000\003?\205\007\006Add)\211\004?D?F\203\004R\000?i\007\003?\221\007\002\002~?!\003\005\200?)\003\004\204\000\210\000\212\000\214)\251\000?B2\000j)\211\004?\006?:\203\004R\000)\211\n?:\207?:\203\005@\203\005@\203\004\203\0046\000)\211\004?\305\007\210\203\010?:?BN\000)\211\002?\341\007?<J\000?1\002\000l?\271\007\000v\003?\311\007\000\003?\315\007\000\003?\321\0072\003?\325\007(\036x\003?\275\007\006\002z)\251\000?\0062\000h?\241\003)\211\004?\006?\006?\006Z\000)\211\004?\006?:\203\004R\000)\211\n?:\207?:\203\005@\203\005@\203\004\203\0046\000)\211\004?%\010?\341\007?BN\000?\355\007?\271\007\000n\003?)\010\000\003?-\010\000\003?1\0102\003?5\010(\036p\003?\035\010\006\002r?\025\010\000t\020\216\000\220)\251\000?\0062\000f\005?\r\007?q\010\000\004\222\000\224\003?\025\007\000\002\226)\211\004?\006\207\205\002?\006\024Last4\203\004R\000)\211\002?\215\010\206?\211\010v\000)\211\006?\231\010\206?\006?\006?\211\010r\000)\211\002?\241\010\215?\006f\000)\211\014?\251\010\215?B?B?\006?\006?\255\002?\006n\000)\211\002?\261\010\206?Bj\000)\211\002?\271\010\206?Bf\000)\211\006?\301\010?H?F\206?Bb\000)\211\004?H?J\203\004R\000?Q\002\003?\321\010\004\002T)\251\000?F2\000H)\211\006?\311\010?B\203\010?\351\002^\000)\211\004?B?F\203\004R\000?\345\010\003?\361\010\000\002N)\211\006?\351\010\203\005@?D?\005\003V\000\003?\001\t\006Add)\211\004?D?F\203\004R\000?\345\010\003?\r\t\002\002J?!\003\005L?)\003\004P\000V\000X\000Z)\251\000?B2\0004)\211\004?\006?:\203\004R\000)\211\n?:\207?:\203\005@\203\005@\203\004\203\0046\000)\211\004?A\t\210\203\010?:?BN\000)\211\002?]\t?<J\000?1\002\0008?5\t\000B\003?E\t\000\003?I\t\000\003?M\t4\003?Q\t(\036D\003?9\t\006\002F)\251\000?\0062\0002?\241\003)\211\004?\006?\006?\006Z\000)\211\004?\006?:\203\004R\000)\211\n?:\207?:\203\005@\203\005@\203\004\203\0046\000)\211\004?\241\t?]\t?BN\000?i\t?5\t\000:\003?\245\t\000\003?\251\t\000\003?\255\t4\003?\261\t(\036<\003?\231\t\006\002>?\221\t\000@\020\\\000^)\251\000?\0062\0000\005?\211\010?\355\t\000\004`\000b\003?\221\010\000\002d\013?z\013?x\013?Z\003?N\002A\003?P\002\003?R\002\003?T\001\003?V\001\003?X\000?\013?h\003?\\\002B\003?^\002\003?`\002\003?b\001\003?d\001\003?f\000?\013?v\003?j\002C\003?l\002\003?n\002\003?p\001\003?r\001\003?t\000?\007\001)\251\000?|2\000\024)\251\000?~2\000\026\006\006?\202\003\203\005@\002A\003\203\005@\002B\003\203\005@\002C\007)\211\006?\206\203\005@?\006\203\005@V\000\003?\215\n\014Equals)\211\004?\006\207?,\203\004R\000)\211\004?\235\n\210\203\010?,?|N\000)\211\002?\255\n?~J\000?m\n\000(?e\n\000*\003?\241\n\002\002,\003?\221\n\002A\005.)\211\006?\212\203\005@?\006\203\005@V\000\003?\321\n\014Equals)\211\004?\006\207?,\203\004R\000)\211\004?\341\n\210\203\010?,?|N\000)\211\002?\361\n?~J\000?m\n\000 ?e\n\000\"\003?\345\n\002\002$\003?\325\n\002B\005&)\211\006?\216\203\005@?\006\203\005@V\000\003?\025\013\014Equals)\211\004?\006\207?,\203\004R\000)\211\004?%\013\210\203\010?,?|N\000)\211\002?5\013?~J\000?m\n\000\030?e\n\000\032\003?)\013\002\002\034\003?\031\013\002C\005\036\003?\220\001\003?\222\004\003?\224\000\003?\226\000\006\n?\236\005\205\004\203\010\203\002:>\003?i\013\004\003?m\013\004\003\005\205\004\203\010\203\002:>\003?\201\013\006\003?\205\013\004\003\005\205\004\203\010\203\002:>\003?\231\013\010\003?\235\013\004\003\005\205\004\203\010\203\002:>\003?\261\013\000\003?\265\013\004\003\005\205\004\203\010\203\002:>\003?\311\013\002\003?\315\013\004\003\037lA\342\003\231\002)\251\000?&2\000\006\005?\022)\211\002?\020\203\tH\034ToBytes\000)\211\n?\361\013\207?\361\013\203\005@\203\005@\203\004\203\0046\000)\211\016?\371\013\311\n?\371\013\214(Yson2.Node\207\2144Yson2.Options\207\203\014?!\014?!\014\005\205\004\206\205\004\203\010\203\005@\002\006\203\005@\n\016\006\n?1\014\005\205\004\203\010\203\005@\002\006\003?=\014\002\003?A\014\000\003\005\205\004\203\010\203\005@\002\006\003?U\014\000\003?Y\014\000\003\005\205\004\203\010\203\005@\002\006\003?m\014\000\003?q\014\032SkipMapEntity\003\005\205\004\203\010\203\005@\002\006\003?\205\014\000\003?\211\014\024EncodeUtf8\003\005\205\004\203\010\203\005@\002\006\003?\235\014\000\003?\241\014 WriteNanAsString\003\037\003?5\014\000\003\022\010\203\004\203\005@\203\004\203\004?\021\014\207?\025\014\032\000)\211\016?\301\014\203\005@\200\203\005@\202\203\005@\203\004\203\004\026\000\003?\335\014&Yson2.SerializeJson\202\003?\341\014\000\002\003?\345\014\000\003?\351\014\024\003?\355\014R\177\014\003?\305\014\000\003?\311\014\000\003?\315\014\024\003?\321\014R)\211\014?\021\014\211\002?\021\014\205\n\207\203\005@?!\r?!\r\207\203\010?)\r\036\"&*.\022\000\203\004\203\005@\203\004\203\004?&\032\000)\211\016?1\r\203\005@\200\203\005@\202\203\005@\203\004\203\004\026\000\003?I\r\024Yson2.From\213\006\213\002?-\r?\016\213\000\003?M\r\000\002\003?Q\r\000\003?U\r\024\003?Y\rz\177\010\003?5\r\000\003?9\r\000\003?=\r\024\003?A\rz?\355\013\036\n\027?\325\014)\211\016?\025\014\311\004?\025\014?!\014?!\014\005\205\004\206\205\004\203\010\203\005@\002\006\203\005@\n\016\006\004?\245\r\005\205\004\203\010\203\005@\002\006\003?\261\r\000\003?\265\r\026AutoConvert\003\005\205\004\203\010\203\005@\002\006\003?\311\r\000\003?\315\r\014Strict\003\003\003?\251\r\000\003\022\004\203\004\203\005@\203\004\203\004\207?\255\002\207\203\014\032\000)\211\016?\355\r\203\005@\200\203\005@\202\203\005@\203\004\203\004\026\000\003?\021\016\032Yson2.Options\202\003?\025\016\000\002\003?\031\016\000\003?\035\016\024\003?!\016R\177\002\003?\361\r\000\003?\365\r\000\003?\371\r\024\003?\375\rR7?\001\016?\241\0037?\t\016\003?\005\016\001~\004^\016\003?\375\013\000\003?\001\014\000\003?\005\014\024\003?\t\0148\036\020\000\022\000\004\235\002\000\241\002\001/b\345\003\010\315\213\r\022\336\003\037\010\006Arg\004dt\006str\014Member\005\205\006\213\002\204\203\005@\205\000\204\205\004\207\203\010\207\203\005@\006\n\030Inputs(Parameters\034Program\013?\004)\251\000?\002\002\000\014\000)\251\000?\006\002\000\032)\211\002?\022\215?\020 FromFlow\000)\211\010? \215\233\004?\n?\016?\n?\016?\020$NarrowMap\000)\211\010?&\215\205\004?\n?\016\006\n?*?\n?\016$ExpandMap\000)\211\002?,\204?*\030ToFlow\000)\211\014?0\211\004?0\204\203\005@\207\203\001H\014UDF\002\203\004\203\005@\203\004\203\004?\002\030Apply2\000)\211\010?<\203\005@\200\203\005@\202\014Udf\000\003?H8ClickHouseClient.ParseFormat\213\006\213\002\204\203\005@?\006?*\003?J\252json_each_row{\"data.datetime.formatname\":\"POSIX\",\"data.timestamp.formatname\":\"POSIX\"}\002\017\016\003?>\000\003?@\000\003?B\000\003?D\000?\030\036\020\000\022)\251\000?*\002\000\006)\211\004?\n?*\203\004\016\000?j\003?l\000\002\n)\211\004?\016?*\203\004\016\000?j\003?t\002\002\010\000\024)\251\000?\n\002\000\004)\251\000?\016\002\000\002\005?\020?\200?\204\000\010\026\000\030\001/"
scope: "yandexcloud://my_folder"
deadline {
  seconds: 1765628821
  nanos: 82764000
}
tenant: "/compute"
}
2025-12-12T12:27:01.783447Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {expired_at { seconds: 1765542441 nanos: 773000000 } } SUCCESS
2025-12-12T12:27:01.783511Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudq7ufj3un8ovpbv9, Owner: d75b22cc-ded50da4-a0ea8476-6e0a8e2f2, Got CP::PingTaskResponse
2025-12-12T12:27:01.791237Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudq7ufj3un8ovpbv9, Owner: d75b22cc-ded50da4-a0ea8476-6e0a8e2f2, Request CP::PingTask with size: 310 bytes
2025-12-12T12:27:01.791309Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "d75b22cc-ded50da4-a0ea8476-6e0a8e2f2"
query_id {
  value: "ptqudq7ufj3un8ovpbv9"
}
status: RUNNING
resources {
  rate_limiter: READY
  compilation: READY
  topic_consumers_state: PREPARE
  rate_limiter_path: "local/RateLimiter_5958a75f-5918-4b93-a01c-15191f6a0817/rate_limiter"
  topic_consumers {
    database: "local"
    topic_path: "test_match_recognize[v1-kikimr0]_v1_input"
    consumer_name: "ptqudq7ufj3un8ovpbv9"
    cluster_endpoint: "localhost:25827"
    token_name: "cluster:default_myyds"
    add_bearer_to_token: true
  }
}
scope: "yandexcloud://my_folder"
deadline {
  seconds: 1765628821
  nanos: 82764000
}
tenant: "/compute"
}
2025-12-12T12:27:01.819510Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {expired_at { seconds: 1765542441 nanos: 807000000 } } SUCCESS
2025-12-12T12:27:01.819548Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudq7ufj3un8ovpbv9, Owner: d75b22cc-ded50da4-a0ea8476-6e0a8e2f2, Got CP::PingTaskResponse
2025-12-12T12:27:01.831244Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudq7ufj3un8ovpbv9, Owner: d75b22cc-ded50da4-a0ea8476-6e0a8e2f2, Request CP::PingTask with size: 310 bytes
2025-12-12T12:27:01.831324Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "d75b22cc-ded50da4-a0ea8476-6e0a8e2f2"
query_id {
  value: "ptqudq7ufj3un8ovpbv9"
}
status: RUNNING
resources {
  rate_limiter: READY
  compilation: READY
  topic_consumers_state: READY
  rate_limiter_path: "local/RateLimiter_5958a75f-5918-4b93-a01c-15191f6a0817/rate_limiter"
  topic_consumers {
    database: "local"
    topic_path: "test_match_recognize[v1-kikimr0]_v1_input"
    consumer_name: "ptqudq7ufj3un8ovpbv9"
    cluster_endpoint: "localhost:25827"
    token_name: "cluster:default_myyds"
    add_bearer_to_token: true
  }
}
scope: "yandexcloud://my_folder"
deadline {
  seconds: 1765628821
  nanos: 82764000
}
tenant: "/compute"
}
2025-12-12T12:27:01.851618Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {expired_at { seconds: 1765542441 nanos: 842000000 } } SUCCESS
2025-12-12T12:27:01.851658Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudq7ufj3un8ovpbv9, Owner: d75b22cc-ded50da4-a0ea8476-6e0a8e2f2, Got CP::PingTaskResponse
2025-12-12T12:27:01.860091Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudq7ufj3un8ovpbv9"
2025-12-12T12:27:01.860129Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:305: Resolve folder bootstrap. Folder id: my_folder Actor id: [1:7582946960993058629:2234]
2025-12-12T12:27:01.860143Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:367: Cloud id: mock_cloud Folder id: my_folder
2025-12-12T12:27:01.860157Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:91: Get quotas bootstrap. Cloud id: mock_cloud Actor id: [1:7582946960993058630:2235]
2025-12-12T12:27:01.860171Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.analyticsQuery.count IS STALE, Refreshing ...
2025-12-12T12:27:01.860177Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.cpuPercent.count IS STALE, Refreshing ...
2025-12-12T12:27:01.860182Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.streamingQuery.count IS STALE, Refreshing ...
2025-12-12T12:27:01.860250Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.cpuPercent.count=0/10000 REFRESHED
2025-12-12T12:27:01.872450Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.analyticsQuery.count=0/100 REFRESHED
2025-12-12T12:27:01.872471Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.streamingQuery.count=1/100 REFRESHED
2025-12-12T12:27:01.872489Z :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:01.872517Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:103: Cloud id: mock_cloud Quota count: 8
2025-12-12T12:27:01.872563Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudq7ufj3un8ovpbv9"
2025-12-12T12:27:01.872598Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:169: Resolve subject type bootstrap. Token: **** (B6C6F477) Actor id: [1:7582946960993058635:2240]
2025-12-12T12:27:01.872618Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:230: Subject Type: federated_account Token: **** (B6C6F477)
2025-12-12T12:27:01.872637Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudq7ufj3un8ovpbv9"
2025-12-12T12:27:01.872646Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:63: Request actor. Actor id: [1:7582946960993058636:2241]
2025-12-12T12:27:01.872669Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_queries.cpp:641: DescribeQueryRequest: {query_id: "ptqudq7ufj3un8ovpbv9"
} [root@builtin, **** (B6C6F477)] 
2025-12-12T12:27:01.878600Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: DescribeQueryRequest - DescribeQueryResult: {query { meta { common { id: "ptqudq7ufj3un8ovpbv9" created_by: "root@builtin" modified_by: "root@builtin" created_at { seconds: 1765542420 nanos: 415688000 } modified_at { seconds: 1765542420 nanos: 415688000 } revision: 1 } started_at { seconds: 1765542421 nanos: 178000000 } execute_mode: RUN status: RUNNING last_job_query_revision: 1 last_job_id: "ptjudq7ufj3uml71nrkh-ptqudq7ufj3un8ovpbv9" started_by: "root@builtin" submitted_at { seconds: 1765542420 nanos: 415688000 } } 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            pragma config.flags(\"MatchRecognizeStream\", \"auto\");\n\n            INSERT INTO myyds.`test_match_recognize[v1-kikimr0]_v1_output`\n            SELECT ToBytes(Unwrap(Json::SerializeJson(Yson::From(TableRow()))))\n            FROM (SELECT * FROM myyds.`test_match_recognize[v1-kikimr0]_v1_input`\n                WITH (\n                    format=json_each_row,\n                    SCHEMA\n                    (\n                        dt UINT64,\n                        str STRING\n                    )))\n            MATCH_RECOGNIZE(\n                ORDER BY CAST(dt as Timestamp)\n                MEASURES\n                   LAST(A.dt) as dt_begin,\n                   LAST(C.dt) as dt_end,\n                   LAST(A.str) as a_str,\n                   LAST(B.str) as b_str,\n                   LAST(C.str) as c_str\n                ONE ROW PER MATCH\n                PATTERN ( A B C )\n                DEFINE\n                    A as A.str=\'A\',\n                    B as B.str=\'B\',\n                    C as C.str=\'C\')" 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: 10 column: 41 } message: "Json UDF is deprecated. Please use JSON API instead" end_position { row: 10 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 (Configure! $5 $1 \'\"MatchRecognizeStream\" \'\"auto\"))\n(let $7 (DataSource \'\"pq\" \'\"myyds\"))\n(let $8 \'(\'(\'\"PartitionsCount\" \'1)))\n(let $9 (OptionalType (DataType \'Uint64)))\n(let $10 \'(\'dt $9))\n(let $11 (DataType \'String))\n(let $12 (OptionalType $11))\n(let $13 \'(\'str $12))\n(let $14 (StructType $10 $13))\n(let $15 (PqTopic \'\"myyds\" \'\"local\" \'\"test_match_recognize[v1-kikimr0]_v1_input\" $8 \'() $14))\n(let $16 \'(\'\"Endpoint\" \'\"localhost:25827\"))\n(let $17 \'(\'\"SharedReading\" \'0))\n(let $18 \'(\'\"AddBearerToToken\" \'1))\n(let $19 \'($16 $17 \'(\'\"ReconnectPeriod\" \'\"\") \'(\'\"Format\" \'\"...} SUCCESS
2025-12-12T12:27:01.884360Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.cpuPercent.count=0/10000 NOTIFY CHANGE
2025-12-12T12:27:01.897625Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.analyticsQuery.count=0/100 NOTIFY CHANGE
2025-12-12T12:27:01.897641Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.streamingQuery.count=1/100 NOTIFY CHANGE
2025-12-12T12:27:01.912104Z :FQ_CONTROL_PLANE_CONFIG TRACE: control_plane_config.cpp:192: LOADED TenantInfo: State NOT changed
2025-12-12T12:27:02.023751Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: d75b22cc-ded50da4-a0ea8476-6e0a8e2f4, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 68 bytes
2025-12-12T12:27:02.023841Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "d75b22cc-ded50da4-a0ea8476-6e0a8e2f4"
host: "ghrun-fhkyrtz6p4"
node_id: 1
}
2025-12-12T12:27:02.029061Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:27:02.029107Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: d75b22cc-ded50da4-a0ea8476-6e0a8e2f4, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:27:02.572914Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudq7ufj3un8ovpbv9, Owner: d75b22cc-ded50da4-a0ea8476-6e0a8e2f2, Request CP::PingTask with size: 121 bytes
2025-12-12T12:27:02.573050Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "d75b22cc-ded50da4-a0ea8476-6e0a8e2f2"
query_id {
  value: "ptqudq7ufj3un8ovpbv9"
}
state_load_mode: FROM_LAST_CHECKPOINT
disposition {
  from_last_checkpoint {
  }
}
scope: "yandexcloud://my_folder"
deadline {
  seconds: 1765628821
  nanos: 82764000
}
tenant: "/compute"
}
2025-12-12T12:27:02.593488Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {expired_at { seconds: 1765542442 nanos: 583000000 } } SUCCESS
2025-12-12T12:27:02.593519Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudq7ufj3un8ovpbv9, Owner: d75b22cc-ded50da4-a0ea8476-6e0a8e2f2, Got CP::PingTaskResponse
2025-12-12T12:27:02.821234Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudq7ufj3un8ovpbv9, Owner: d75b22cc-ded50da4-a0ea8476-6e0a8e2f2, Request CP::PingTask with size: 590 bytes
2025-12-12T12:27:02.821320Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "d75b22cc-ded50da4-a0ea8476-6e0a8e2f2"
query_id {
  value: "ptqudq7ufj3un8ovpbv9"
}
statistics: "{\"Graph=0\":{\"TaskRunner\":{\"Stage=214477\":{\"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=214497\":{\"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: 1765628821
  nanos: 82764000
}
tenant: "/compute"
}
2025-12-12T12:27:02.839363Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {expired_at { seconds: 1765542442 nanos: 831000000 } } SUCCESS
2025-12-12T12:27:02.839416Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudq7ufj3un8ovpbv9, Owner: d75b22cc-ded50da4-a0ea8476-6e0a8e2f2, Got CP::PingTaskResponse
2025-12-12T12:27:02.881257Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582946948108156592:2093]
2025-12-12T12:27:02.881293Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:02.881305Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582946948108156550:2068]
2025-12-12T12:27:02.881309Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582946948108156550:2068]
2025-12-12T12:27:02.881313Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582946948108156550:2068]
2025-12-12T12:27:02.881326Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:03.023599Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: d75b22cc-ded50da4-a0ea8476-6e0a8e2f5, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 68 bytes
2025-12-12T12:27:03.023686Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "d75b22cc-ded50da4-a0ea8476-6e0a8e2f5"
host: "ghrun-fhkyrtz6p4"
node_id: 1
}
2025-12-12T12:27:03.027370Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:27:03.027409Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: d75b22cc-ded50da4-a0ea8476-6e0a8e2f5, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:27:03.880687Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:665: Coordinator: Change global state to Started (by timeout)
2025-12-12T12:27:04.882142Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582946948108156592:2093]
2025-12-12T12:27:04.882173Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:04.882181Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582946948108156550:2068]
2025-12-12T12:27:04.882186Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582946948108156550:2068]
2025-12-12T12:27:04.882189Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582946948108156550:2068]
2025-12-12T12:27:04.882199Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:04.912522Z :FQ_CONTROL_PLANE_CONFIG TRACE: control_plane_config.cpp:192: LOADED TenantInfo: State NOT changed
2025-12-12T12:27:06.883066Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582946948108156592:2093]
2025-12-12T12:27:06.883086Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:06.883094Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582946948108156550:2068]
2025-12-12T12:27:06.883098Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582946948108156550:2068]
2025-12-12T12:27:06.883102Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582946948108156550:2068]
2025-12-12T12:27:06.883114Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:07.339531Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 6ca58679-69617f0a-85bc5868-8fd3dbeb1, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 68 bytes
2025-12-12T12:27:07.339559Z :YQ_CONTROL_PLANE_STORAGE TRACE: nodes_health_check.cpp:38: NodesHealthCheckRequest: {tenant: "/compute"
node {
  node_id: 1
  instance_id: "2eabb9a9-45cdb6aa-2b652fa2-6a73f108"
  hostname: "ghrun-fhkyrtz6p4"
  interconnect_port: 11355
  node_address: "127.0.1.1"
}
}
2025-12-12T12:27:07.339626Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "6ca58679-69617f0a-85bc5868-8fd3dbeb1"
host: "ghrun-fhkyrtz6p4"
node_id: 1
}
2025-12-12T12:27:07.351156Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:27:07.351226Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 6ca58679-69617f0a-85bc5868-8fd3dbeb1, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:27:07.362255Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: NodesHealthCheckRequest - NodesHealthCheckResult: {nodes { node_id: 1 instance_id: "2eabb9a9-45cdb6aa-2b652fa2-6a73f108" hostname: "ghrun-fhkyrtz6p4" node_address: "127.0.1.1" } } SUCCESS
2025-12-12T12:27:07.912173Z :FQ_CONTROL_PLANE_CONFIG TRACE: control_plane_config.cpp:192: LOADED TenantInfo: State NOT changed
2025-12-12T12:27:08.327394Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 6ca58679-69617f0a-85bc5868-8fd3dbeb2, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 68 bytes
2025-12-12T12:27:08.327437Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "6ca58679-69617f0a-85bc5868-8fd3dbeb2"
host: "ghrun-fhkyrtz6p4"
node_id: 1
}
2025-12-12T12:27:08.330518Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:27:08.330562Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 6ca58679-69617f0a-85bc5868-8fd3dbeb2, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:27:08.422774Z :TICKET_PARSER DEBUG: ticket_parser_impl.h:1875: Ticket **** (B6C6F477) (ipv6:[::1]:52944) has now valid token of root@builtin
2025-12-12T12:27:08.422863Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:852: GetStatusRequest: query_id: "ptqudq7ufj3un8ovpbv9"
2025-12-12T12:27:08.422899Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:305: Resolve folder bootstrap. Folder id: my_folder Actor id: [1:7582946991057829736:2268]
2025-12-12T12:27:08.422916Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:367: Cloud id: mock_cloud Folder id: my_folder
2025-12-12T12:27:08.422950Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:91: Get quotas bootstrap. Cloud id: mock_cloud Actor id: [1:7582946991057829737:2269]
2025-12-12T12:27:08.422966Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.analyticsQuery.count IS STALE, Refreshing ...
2025-12-12T12:27:08.422976Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.cpuPercent.count IS STALE, Refreshing ...
2025-12-12T12:27:08.422979Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.streamingQuery.count IS STALE, Refreshing ...
2025-12-12T12:27:08.423079Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.cpuPercent.count=0/10000 REFRESHED
2025-12-12T12:27:08.450928Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.analyticsQuery.count=0/100 REFRESHED
2025-12-12T12:27:08.450955Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.streamingQuery.count=1/100 REFRESHED
2025-12-12T12:27:08.450973Z :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:08.450982Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:103: Cloud id: mock_cloud Quota count: 8
2025-12-12T12:27:08.451022Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:852: GetStatusRequest: query_id: "ptqudq7ufj3un8ovpbv9"
2025-12-12T12:27:08.451079Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:169: Resolve subject type bootstrap. Token: **** (B6C6F477) Actor id: [1:7582946991057829742:2274]
2025-12-12T12:27:08.451107Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:230: Subject Type: federated_account Token: **** (B6C6F477)
2025-12-12T12:27:08.451154Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:852: GetStatusRequest: query_id: "ptqudq7ufj3un8ovpbv9"
2025-12-12T12:27:08.451176Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:63: Request actor. Actor id: [1:7582946991057829743:2275]
2025-12-12T12:27:08.451216Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_queries.cpp:725: GetQueryStatusRequest: {query_id: "ptqudq7ufj3un8ovpbv9"
} [root@builtin, **** (B6C6F477)] 
2025-12-12T12:27:08.455189Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.cpuPercent.count=0/10000 NOTIFY CHANGE
2025-12-12T12:27:08.476331Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.analyticsQuery.count=0/100 NOTIFY CHANGE
2025-12-12T12:27:08.476532Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.streamingQuery.count=1/100 NOTIFY CHANGE
2025-12-12T12:27:08.518034Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetQueryStatusRequest - GetQueryStatusResult: {status: RUNNING meta_revision: 10 } SUCCESS
2025-12-12T12:27:08.883150Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:599: Coordinator: Send TEvGetNodesRequest to NodesManager
2025-12-12T12:27:08.883177Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:416: Coordinator: TEvUndelivered, ev: TSystem::Undelivered
2025-12-12T12:27:08.883180Z :FQ_ROW_DISPATCHER INFO: coordinator.cpp:419: Coordinator: TEvUndelivered, from nodes manager, reason: ActorUnknown
2025-12-12T12:27:08.884996Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582946948108156592:2093]
2025-12-12T12:27:08.885030Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:08.885039Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582946948108156550:2068]
2025-12-12T12:27:08.885045Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582946948108156550:2068]
2025-12-12T12:27:08.885048Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582946948108156550:2068]
2025-12-12T12:27:08.885068Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:09.323493Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 6ca58679-69617f0a-85bc5868-8fd3dbeb3, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 68 bytes
2025-12-12T12:27:09.323545Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "6ca58679-69617f0a-85bc5868-8fd3dbeb3"
host: "ghrun-fhkyrtz6p4"
node_id: 1
}
2025-12-12T12:27:09.329978Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:27:09.330058Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 6ca58679-69617f0a-85bc5868-8fd3dbeb3, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:27:10.323815Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 6ca58679-69617f0a-85bc5868-8fd3dbeb4, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 68 bytes
2025-12-12T12:27:10.323879Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "6ca58679-69617f0a-85bc5868-8fd3dbeb4"
host: "ghrun-fhkyrtz6p4"
node_id: 1
}
2025-12-12T12:27:10.332482Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:27:10.332550Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 6ca58679-69617f0a-85bc5868-8fd3dbeb4, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:27:10.885830Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582946948108156592:2093]
2025-12-12T12:27:10.885847Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:10.885853Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582946948108156550:2068]
2025-12-12T12:27:10.885857Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582946948108156550:2068]
2025-12-12T12:27:10.885860Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582946948108156550:2068]
2025-12-12T12:27:10.885886Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:10.914673Z :FQ_CONTROL_PLANE_CONFIG TRACE: control_plane_config.cpp:192: LOADED TenantInfo: State NOT changed
2025-12-12T12:27:11.324467Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 6ca58679-69617f0a-85bc5868-8fd3dbeb5, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 68 bytes
2025-12-12T12:27:11.324533Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "6ca58679-69617f0a-85bc5868-8fd3dbeb5"
host: "ghrun-fhkyrtz6p4"
node_id: 1
}
2025-12-12T12:27:11.331437Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:27:11.331481Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 6ca58679-69617f0a-85bc5868-8fd3dbeb5, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:27:12.325898Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 6ca58679-69617f0a-85bc5868-8fd3dbeb6, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 68 bytes
2025-12-12T12:27:12.325936Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "6ca58679-69617f0a-85bc5868-8fd3dbeb6"
host: "ghrun-fhkyrtz6p4"
node_id: 1
}
2025-12-12T12:27:12.329171Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:27:12.329231Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 6ca58679-69617f0a-85bc5868-8fd3dbeb6, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:27:12.331892Z :YQ_CONTROL_PLANE_STORAGE TRACE: nodes_health_check.cpp:38: NodesHealthCheckRequest: {tenant: "/compute"
node {
  node_id: 1
  instance_id: "2eabb9a9-45cdb6aa-2b652fa2-6a73f108"
  hostname: "ghrun-fhkyrtz6p4"
  interconnect_port: 11355
  node_address: "127.0.1.1"
}
}
2025-12-12T12:27:12.340886Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: NodesHealthCheckRequest - NodesHealthCheckResult: {nodes { node_id: 1 instance_id: "2eabb9a9-45cdb6aa-2b652fa2-6a73f108" hostname: "ghrun-fhkyrtz6p4" node_address: "127.0.1.1" } } SUCCESS
2025-12-12T12:27:12.886725Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582946948108156592:2093]
2025-12-12T12:27:12.886758Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:12.886764Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582946948108156550:2068]
2025-12-12T12:27:12.886768Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582946948108156550:2068]
2025-12-12T12:27:12.886771Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582946948108156550:2068]
2025-12-12T12:27:12.886780Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:13.327561Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 6ca58679-69617f0a-85bc5868-8fd3dbeb7, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 68 bytes
2025-12-12T12:27:13.327631Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "6ca58679-69617f0a-85bc5868-8fd3dbeb7"
host: "ghrun-fhkyrtz6p4"
node_id: 1
}
2025-12-12T12:27:13.335438Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:27:13.335491Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 6ca58679-69617f0a-85bc5868-8fd3dbeb7, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:27:13.910611Z :FQ_CONTROL_PLANE_CONFIG TRACE: control_plane_config.cpp:192: LOADED TenantInfo: State NOT changed
2025-12-12T12:27:14.327220Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 6ca58679-69617f0a-85bc5868-8fd3dbeb8, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 68 bytes
2025-12-12T12:27:14.327297Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "6ca58679-69617f0a-85bc5868-8fd3dbeb8"
host: "ghrun-fhkyrtz6p4"
node_id: 1
}
2025-12-12T12:27:14.330309Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:27:14.330351Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 6ca58679-69617f0a-85bc5868-8fd3dbeb8, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:27:14.887634Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582946948108156592:2093]
2025-12-12T12:27:14.887671Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:14.887680Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582946948108156550:2068]
2025-12-12T12:27:14.887684Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582946948108156550:2068]
2025-12-12T12:27:14.887687Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582946948108156550:2068]
2025-12-12T12:27:14.887700Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:15.326207Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 6ca58679-69617f0a-85bc5868-8fd3dbeb9, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 68 bytes
2025-12-12T12:27:15.326265Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "6ca58679-69617f0a-85bc5868-8fd3dbeb9"
host: "ghrun-fhkyrtz6p4"
node_id: 1
}
2025-12-12T12:27:15.328751Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:27:15.328784Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 6ca58679-69617f0a-85bc5868-8fd3dbeb9, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:27:16.326575Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 6ca58679-69617f0a-85bc5868-8fd3dbeb10, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 69 bytes
2025-12-12T12:27:16.326652Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "6ca58679-69617f0a-85bc5868-8fd3dbeb10"
host: "ghrun-fhkyrtz6p4"
node_id: 1
}
2025-12-12T12:27:16.331385Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:27:16.331452Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 6ca58679-69617f0a-85bc5868-8fd3dbeb10, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:27:16.889102Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582946948108156592:2093]
2025-12-12T12:27:16.889121Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:16.889128Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582946948108156550:2068]
2025-12-12T12:27:16.889132Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582946948108156550:2068]
2025-12-12T12:27:16.889135Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582946948108156550:2068]
2025-12-12T12:27:16.889147Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:16.915399Z :FQ_CONTROL_PLANE_CONFIG TRACE: control_plane_config.cpp:192: LOADED TenantInfo: State NOT changed
2025-12-12T12:27:17.327110Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 6ca58679-69617f0a-85bc5868-8fd3dbeb11, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 69 bytes
2025-12-12T12:27:17.327159Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "6ca58679-69617f0a-85bc5868-8fd3dbeb11"
host: "ghrun-fhkyrtz6p4"
node_id: 1
}
2025-12-12T12:27:17.329686Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:27:17.329732Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 6ca58679-69617f0a-85bc5868-8fd3dbeb11, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:27:17.330434Z :YQ_CONTROL_PLANE_STORAGE TRACE: nodes_health_check.cpp:38: NodesHealthCheckRequest: {tenant: "/compute"
node {
  node_id: 1
  instance_id: "2eabb9a9-45cdb6aa-2b652fa2-6a73f108"
  hostname: "ghrun-fhkyrtz6p4"
  interconnect_port: 11355
  node_address: "127.0.1.1"
}
}
2025-12-12T12:27:17.338439Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: NodesHealthCheckRequest - NodesHealthCheckResult: {nodes { node_id: 1 instance_id: "2eabb9a9-45cdb6aa-2b652fa2-6a73f108" hostname: "ghrun-fhkyrtz6p4" node_address: "127.0.1.1" } } SUCCESS
2025-12-12T12:27:18.330866Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 6ca58679-69617f0a-85bc5868-8fd3dbeb12, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 69 bytes
2025-12-12T12:27:18.330927Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "6ca58679-69617f0a-85bc5868-8fd3dbeb12"
host: "ghrun-fhkyrtz6p4"
node_id: 1
}
2025-12-12T12:27:18.333765Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:27:18.333852Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 6ca58679-69617f0a-85bc5868-8fd3dbeb12, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:27:18.883274Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:416: Coordinator: TEvUndelivered, ev: TSystem::Undelivered
2025-12-12T12:27:18.883278Z :FQ_ROW_DISPATCHER INFO: coordinator.cpp:419: Coordinator: TEvUndelivered, from nodes manager, reason: ActorUnknown
2025-12-12T12:27:18.889413Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582946948108156592:2093]
2025-12-12T12:27:18.889439Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:18.889446Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582946948108156550:2068]
2025-12-12T12:27:18.889451Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582946948108156550:2068]
2025-12-12T12:27:18.889454Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582946948108156550:2068]
2025-12-12T12:27:18.889464Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:19.330966Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 6ca58679-69617f0a-85bc5868-8fd3dbeb13, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 69 bytes
2025-12-12T12:27:19.331042Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "6ca58679-69617f0a-85bc5868-8fd3dbeb13"
host: "ghrun-fhkyrtz6p4"
node_id: 1
}
2025-12-12T12:27:19.333891Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:27:19.333926Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 6ca58679-69617f0a-85bc5868-8fd3dbeb13, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:27:19.915317Z :FQ_CONTROL_PLANE_CONFIG TRACE: control_plane_config.cpp:192: LOADED TenantInfo: State NOT changed
2025-12-12T12:27:20.331360Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 6ca58679-69617f0a-85bc5868-8fd3dbeb14, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 69 bytes
2025-12-12T12:27:20.331409Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "6ca58679-69617f0a-85bc5868-8fd3dbeb14"
host: "ghrun-fhkyrtz6p4"
node_id: 1
}
2025-12-12T12:27:20.334151Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:27:20.334216Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 6ca58679-69617f0a-85bc5868-8fd3dbeb14, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:27:20.890302Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582946948108156592:2093]
2025-12-12T12:27:20.890339Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:20.890367Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582946948108156550:2068]
2025-12-12T12:27:20.890374Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582946948108156550:2068]
2025-12-12T12:27:20.890377Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582946948108156550:2068]
2025-12-12T12:27:20.890396Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:21.331981Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 6ca58679-69617f0a-85bc5868-8fd3dbeb15, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 69 bytes
2025-12-12T12:27:21.332078Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "6ca58679-69617f0a-85bc5868-8fd3dbeb15"
host: "ghrun-fhkyrtz6p4"
node_id: 1
}
2025-12-12T12:27:21.334973Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:27:21.335028Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 6ca58679-69617f0a-85bc5868-8fd3dbeb15, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:27:22.331264Z :YQ_CONTROL_PLANE_STORAGE TRACE: nodes_health_check.cpp:38: NodesHealthCheckRequest: {tenant: "/compute"
node {
  node_id: 1
  instance_id: "2eabb9a9-45cdb6aa-2b652fa2-6a73f108"
  hostname: "ghrun-fhkyrtz6p4"
  interconnect_port: 11355
  node_address: "127.0.1.1"
}
}
2025-12-12T12:27:22.335216Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 6ca58679-69617f0a-85bc5868-8fd3dbeb16, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 69 bytes
2025-12-12T12:27:22.335253Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "6ca58679-69617f0a-85bc5868-8fd3dbeb16"
host: "ghrun-fhkyrtz6p4"
node_id: 1
}
2025-12-12T12:27:22.342238Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:27:22.342321Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: NodesHealthCheckRequest - NodesHealthCheckResult: {nodes { node_id: 1 instance_id: "2eabb9a9-45cdb6aa-2b652fa2-6a73f108" hostname: "ghrun-fhkyrtz6p4" node_address: "127.0.1.1" } } SUCCESS
2025-12-12T12:27:22.342365Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 6ca58679-69617f0a-85bc5868-8fd3dbeb16, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:27:22.891205Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582946948108156592:2093]
2025-12-12T12:27:22.891230Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:22.891238Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582946948108156550:2068]
2025-12-12T12:27:22.891241Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582946948108156550:2068]
2025-12-12T12:27:22.891244Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582946948108156550:2068]
2025-12-12T12:27:22.891253Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:22.915365Z :FQ_CONTROL_PLANE_CONFIG TRACE: control_plane_config.cpp:192: LOADED TenantInfo: State NOT changed
2025-12-12T12:27:23.339275Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 6ca58679-69617f0a-85bc5868-8fd3dbeb17, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 69 bytes
2025-12-12T12:27:23.339345Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "6ca58679-69617f0a-85bc5868-8fd3dbeb17"
host: "ghrun-fhkyrtz6p4"
node_id: 1
}
2025-12-12T12:27:23.346106Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:456: Task (Query): ptqudq7ufj3un8ovpbv9 Lease TIMEOUT, RetryCounterUpdatedAt 2025-12-12T12:27:00.539439Z LastSeenAt: 2025-12-12T12:27:02.831511Z
2025-12-12T12:27:23.346131Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:463: Task (Query): ptqudq7ufj3un8ovpbv9 RetryRate: 0.9994694278 RetryCounter: 1 At: 2025-12-12T12:27:23.346059Z
2025-12-12T12:27:23.357715Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {tasks { query_id { value: "ptqudq7ufj3un8ovpbv9" } job_id { value: "ptjudq7ufj3uml71nrkh" } generation: 2 streaming: true dq_graph: "\022\337\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*\362\003Z\357\003\n\010PqSource\022\340\003\n4type.googleapis.com/NYql.NPq.NProto.TDqPqTopicSource\022\247\003\n)test_match_recognize[v1-kikimr0]_v1_input\022\024ptqudq7ufj3un8ovpbv9\032\017localhost:25827\"\027\n\025cluster:default_myyds*\005local0\002@\001b\002dtb\003strj&[\"OptionalType\";[\"DataType\";\"Uint64\"]]j&[\"OptionalType\";[\"DataType\";\"String\"]]\222\001\024ptcudq7ufjfufnmne5eb\232\001\rjson_each_row\242\001m[\"StructType\";[[\"dt\";[\"OptionalType\";[\"DataType\";\"Uint64\"]]];[\"str\";[\"OptionalType\";[\"DataType\";\"String\"]]]]]\262\001\002\022\000\272\001\026\n\010cloud_id\022\nmock_cloud\272\001 \n\005scope\022\027yandexcloud://my_folder\030\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\315\213\r`\341\213\rR\000:\203\001\n*type.googleapis.com/Yql.DqsProto.TTaskMeta\022U\010\315\213\r\022A\022(88a034dc314301cb1522a933e690a4c49a7591e8\032\023dq_vanilla_job.lite \002\"\014\n\002pq\022\006\n\004\010\001\030\001H\315\213\rRClocal/RateLimiter_5958a75f-5918-4b93-a01c-15191f6a0817/rate_limiterZ)mock_cloud/my_folder/ptqudq7ufj3un8ovpbv9`\200\200\200\200 \230\001\000\300\001\001\022\203\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\315\213\r`\341\213\rR\0002\245\001z\242\001\n\006PqSink\022\227\001\n2type.googleapis.com/NYql.NPq.NProto.TDqPqTopicSink\022a\n*test_match_recognize[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\341\213\r\022A\022(88a034dc314301cb1522a933e690a4c49a7591e8\032\023dq_vanilla_job.lite \002H\341\213\rRClocal/RateLimiter_5958a75f-5918-4b93-a01c-15191f6a0817/rate_limiterZ)mock_cloud/my_folder/ptqudq7ufj3un8ovpbv9`\200\200\200\200 \230\001\000\300\001\0012qptqudq7ufj3un8ovpbv9#ptrudq7uficm40bnb33c#yandexcloud://my_folder#d75b22cc-ded50da4-a0ea8476-6e0a8e2f2#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\201%\010\341\213\r\022\372$\037<\nFlags\010Name\010Args\016Payload\000\006Udf\014Apply2\na_str\nb_str\nc_str\020dt_begin\014dt_end\006Arg\014Unwrap\nIndex\024SourceType\004dt\006str\026ToIndexDict\014Lookup\014Member\014Invoke\020Coalesce\032ListFromRange\034OrderedFlatMap\016Collect\014ToFlow\022Condense1\006Map\010Head\005\205\006\213\002\204\205\004\207\203\010\207\203\005@BF\205\000\204\205\002\203\005@\034column0\030Inputs(Parameters\034Program\013?\014)\251\000?\n2\000\205\002\000)\251\000?\0162\000\245\002)\211\002?\024\215?\022 FromFlow\000)\211\006?\"\215\205\n?\006?\006?\006?\002?\002\036\"&*.?&?\022r\000)\2114?(\215\205\004?\002?\006BF?,\213\000\206\203\004\206\205\010\203\001H\203\010?\002?\006<_yql_Classifier@_yql_MatchNumberBF\206?2\203\004\205\006\206\205\004\203\010\203\010\020From\010To?H?H\004A\004B\004C\206?2?\002?\002?\006?\006?\006\213\002\213\006\213\014\203\005@\203\010\203\010\203\014\203\014\203\014\213\014\203\005@\203\010\203\010\203\014\203\014\203\014\213\014\203\005@\203\010\203\010\203\01...} SUCCESS
2025-12-12T12:27:23.357777Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 6ca58679-69617f0a-85bc5868-8fd3dbeb17, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:27:23.359176Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 6ca58679-69617f0a-85bc5868-8fd3dbeb18, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 69 bytes
2025-12-12T12:27:23.359238Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "6ca58679-69617f0a-85bc5868-8fd3dbeb18"
host: "ghrun-fhkyrtz6p4"
node_id: 1
}
2025-12-12T12:27:23.359755Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudq7ufj3un8ovpbv9, Owner: 6ca58679-69617f0a-85bc5868-8fd3dbeb17, Request CP::PingTask with size: 310 bytes
2025-12-12T12:27:23.359844Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "6ca58679-69617f0a-85bc5868-8fd3dbeb17"
query_id {
  value: "ptqudq7ufj3un8ovpbv9"
}
resources {
  rate_limiter: READY
  compilation: READY
  topic_consumers_state: READY
  rate_limiter_path: "local/RateLimiter_5958a75f-5918-4b93-a01c-15191f6a0817/rate_limiter"
  topic_consumers {
    database: "local"
    topic_path: "test_match_recognize[v1-kikimr0]_v1_input"
    consumer_name: "ptqudq7ufj3un8ovpbv9"
    cluster_endpoint: "localhost:25827"
    token_name: "cluster:default_myyds"
    add_bearer_to_token: true
  }
}
scope: "yandexcloud://my_folder"
deadline {
  seconds: 1765628843
  nanos: 351416000
}
tenant: "/compute"
}
2025-12-12T12:27:23.362573Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:27:23.362647Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 6ca58679-69617f0a-85bc5868-8fd3dbeb18, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:27:23.371657Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {expired_at { seconds: 1765542463 nanos: 365000000 } } SUCCESS
2025-12-12T12:27:23.371805Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudq7ufj3un8ovpbv9, Owner: 6ca58679-69617f0a-85bc5868-8fd3dbeb17, Got CP::PingTaskResponse
2025-12-12T12:27:24.198172Z :TICKET_PARSER DEBUG: ticket_parser_impl.h:1875: Ticket **** (B6C6F477) (ipv6:[::1]:52944) has now valid token of root@builtin
2025-12-12T12:27:24.198313Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:1061: ControlQueryRequest: query_id: "ptqudq7ufj3un8ovpbv9"
action: ABORT
2025-12-12T12:27:24.198371Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:305: Resolve folder bootstrap. Folder id: my_folder Actor id: [1:7582947059777306549:2344]
2025-12-12T12:27:24.198414Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:367: Cloud id: mock_cloud Folder id: my_folder
2025-12-12T12:27:24.198448Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:91: Get quotas bootstrap. Cloud id: mock_cloud Actor id: [1:7582947059777306550:2345]
2025-12-12T12:27:24.198484Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.analyticsQuery.count IS STALE, Refreshing ...
2025-12-12T12:27:24.198503Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.cpuPercent.count IS STALE, Refreshing ...
2025-12-12T12:27:24.198514Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.streamingQuery.count IS STALE, Refreshing ...
2025-12-12T12:27:24.198528Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.cpuPercent.count=0/10000 REFRESHED
2025-12-12T12:27:24.207246Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.analyticsQuery.count=0/100 REFRESHED
2025-12-12T12:27:24.207270Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.streamingQuery.count=1/100 REFRESHED
2025-12-12T12:27:24.207288Z :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:24.207299Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:103: Cloud id: mock_cloud Quota count: 8
2025-12-12T12:27:24.207348Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:1061: ControlQueryRequest: query_id: "ptqudq7ufj3un8ovpbv9"
action: ABORT
2025-12-12T12:27:24.207407Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:169: Resolve subject type bootstrap. Token: **** (B6C6F477) Actor id: [1:7582947059777306555:2350]
2025-12-12T12:27:24.207428Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:230: Subject Type: federated_account Token: **** (B6C6F477)
2025-12-12T12:27:24.207447Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:1061: ControlQueryRequest: query_id: "ptqudq7ufj3un8ovpbv9"
action: ABORT
2025-12-12T12:27:24.207462Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:63: Request actor. Actor id: [1:7582947059777306556:2351]
2025-12-12T12:27:24.207499Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_queries.cpp:1342: ControlQueryRequest: {query_id: "ptqudq7ufj3un8ovpbv9"
action: ABORT
} [root@builtin, **** (B6C6F477)] 
2025-12-12T12:27:24.207981Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.cpuPercent.count=0/10000 NOTIFY CHANGE
2025-12-12T12:27:24.223181Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.streamingQuery.count=1/100 NOTIFY CHANGE
2025-12-12T12:27:24.223197Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.analyticsQuery.count=0/100 NOTIFY CHANGE
2025-12-12T12:27:24.339401Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 6ca58679-69617f0a-85bc5868-8fd3dbeb19, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Request CP::GetTask with size: 69 bytes
2025-12-12T12:27:24.339446Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "6ca58679-69617f0a-85bc5868-8fd3dbeb19"
host: "ghrun-fhkyrtz6p4"
node_id: 1
}
2025-12-12T12:27:24.347778Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:27:24.347837Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 6ca58679-69617f0a-85bc5868-8fd3dbeb19, Host: ghrun-fhkyrtz6p4, Tenant: /compute, Got CP::GetTask Response
2025-12-12T12:27:24.397041Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudq7ufj3un8ovpbv9, Owner: 6ca58679-69617f0a-85bc5868-8fd3dbeb17, Request CP::PingTask with size: 592 bytes
2025-12-12T12:27:24.397121Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "6ca58679-69617f0a-85bc5868-8fd3dbeb17"
query_id {
  value: "ptqudq7ufj3un8ovpbv9"
}
statistics: "{\"Graph=0\":{\"TaskRunner\":{\"Stage=214477\":{\"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=214497\":{\"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: 1765628843
  nanos: 351416000
}
tenant: "/compute"
}
2025-12-12T12:27:24.400766Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: ControlQueryRequest - ControlQueryRequest: {} SUCCESS
2025-12-12T12:27:24.403106Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudq7ufj3un8ovpbv9"
2025-12-12T12:27:24.403143Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:305: Resolve folder bootstrap. Folder id: my_folder Actor id: [1:7582947059777306566:2360]
2025-12-12T12:27:24.403155Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:367: Cloud id: mock_cloud Folder id: my_folder
2025-12-12T12:27:24.403166Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:91: Get quotas bootstrap. Cloud id: mock_cloud Actor id: [1:7582947059777306567:2361]
2025-12-12T12:27:24.403181Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.analyticsQuery.count IS STALE, Refreshing ...
2025-12-12T12:27:24.403186Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.cpuPercent.count IS STALE, Refreshing ...
2025-12-12T12:27:24.403188Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.streamingQuery.count IS STALE, Refreshing ...
2025-12-12T12:27:24.403212Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.cpuPercent.count=0/10000 REFRESHED
2025-12-12T12:27:24.409457Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {action: ABORT expired_at { seconds: 1765542464 nanos: 403000000 } } SUCCESS
2025-12-12T12:27:24.409488Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudq7ufj3un8ovpbv9, Owner: 6ca58679-69617f0a-85bc5868-8fd3dbeb17, Got CP::PingTaskResponse
2025-12-12T12:27:24.409654Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.analyticsQuery.count=0/100 REFRESHED
2025-12-12T12:27:24.409671Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.streamingQuery.count=1/100 REFRESHED
2025-12-12T12:27:24.409688Z :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:24.409695Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:103: Cloud id: mock_cloud Quota count: 8
2025-12-12T12:27:24.409716Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudq7ufj3un8ovpbv9"
2025-12-12T12:27:24.409756Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:169: Resolve subject type bootstrap. Token: **** (B6C6F477) Actor id: [1:7582947059777306572:2366]
2025-12-12T12:27:24.409777Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:230: Subject Type: federated_account Token: **** (B6C6F477)
2025-12-12T12:27:24.409804Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudq7ufj3un8ovpbv9"
2025-12-12T12:27:24.409831Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:63: Request actor. Actor id: [1:7582947059777306573:2367]
2025-12-12T12:27:24.409875Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_queries.cpp:641: DescribeQueryRequest: {query_id: "ptqudq7ufj3un8ovpbv9"
} [root@builtin, **** (B6C6F477)] 
2025-12-12T12:27:24.410363Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudq7ufj3un8ovpbv9, Owner: 6ca58679-69617f0a-85bc5868-8fd3dbeb17, Request CP::PingTask with size: 117 bytes
2025-12-12T12:27:24.410421Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "6ca58679-69617f0a-85bc5868-8fd3dbeb17"
query_id {
  value: "ptqudq7ufj3un8ovpbv9"
}
status: ABORTING_BY_USER
scope: "yandexcloud://my_folder"
deadline {
  seconds: 1765628843
  nanos: 351416000
}
tenant: "/compute"
}
2025-12-12T12:27:24.412479Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: DescribeQueryRequest - DescribeQueryResult: {query { meta { common { id: "ptqudq7ufj3un8ovpbv9" created_by: "root@builtin" modified_by: "root@builtin" created_at { seconds: 1765542420 nanos: 415688000 } modified_at { seconds: 1765542444 nanos: 327497000 } revision: 2 } started_at { seconds: 1765542421 nanos: 178000000 } execute_mode: RUN status: ABORTING_BY_USER last_job_query_revision: 1 last_job_id: "ptjudq7ufj3uml71nrkh-ptqudq7ufj3un8ovpbv9" started_by: "root@builtin" aborted_by: "root@builtin" has_saved_checkpoints: true submitted_at { seconds: 1765542420 nanos: 415688000 } } 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            pragma config.flags(\"MatchRecognizeStream\", \"auto\");\n\n            INSERT INTO myyds.`test_match_recognize[v1-kikimr0]_v1_output`\n            SELECT ToBytes(Unwrap(Json::SerializeJson(Yson::From(TableRow()))))\n            FROM (SELECT * FROM myyds.`test_match_recognize[v1-kikimr0]_v1_input`\n                WITH (\n                    format=json_each_row,\n                    SCHEMA\n                    (\n                        dt UINT64,\n                        str STRING\n                    )))\n            MATCH_RECOGNIZE(\n                ORDER BY CAST(dt as Timestamp)\n                MEASURES\n                   LAST(A.dt) as dt_begin,\n                   LAST(C.dt) as dt_end,\n                   LAST(A.str) as a_str,\n                   LAST(B.str) as b_str,\n                   LAST(C.str) as c_str\n                ONE ROW PER MATCH\n                PATTERN ( A B C )\n                DEFINE\n                    A as A.str=\'A\',\n                    B as B.str=\'B\',\n                    C as C.str=\'C\')" 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: 10 column: 41 } message: "Json UDF is deprecated. Please use JSON API instead" end_position { row: 10 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 (Configure! $5 $1 \'\"MatchRecognizeStream\" \'\"auto\"))\n(let $7 (DataSource \'\"pq\" \'\"myyds\"))\n(let $8 \'(\'(\'\"PartitionsCount\" \'1)))\n(let $9 (OptionalType (DataType \'Uint64)))\n(let $10 \'(\'dt $9))\n(let $11 (DataType \'String))\n(let $12 (OptionalType $11))\n(let $13 \'(\'str $12))\n(let $14 (StructType $10 $13))\n(let $15 (PqTopic \'\"myyds\" \'\"local\" \'...} SUCCESS
2025-12-12T12:27:24.417509Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.cpuPercent.count=0/10000 NOTIFY CHANGE
2025-12-12T12:27:24.422372Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.streamingQuery.count=1/100 NOTIFY CHANGE
2025-12-12T12:27:24.427202Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.analyticsQuery.count=0/100 NOTIFY CHANGE
2025-12-12T12:27:24.429990Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {action: ABORT expired_at { seconds: 1765542464 nanos: 419000000 } } SUCCESS
2025-12-12T12:27:24.430039Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudq7ufj3un8ovpbv9, Owner: 6ca58679-69617f0a-85bc5868-8fd3dbeb17, Got CP::PingTaskResponse
2025-12-12T12:27:24.431056Z :YQL_PRIVATE_PROXY DEBUG: rate_limiter_resources.cpp:175: PrivateDeleteRateLimiterResource - QueryId: ptqudq7ufj3un8ovpbv9, Owner: 6ca58679-69617f0a-85bc5868-8fd3dbeb17, Request CP::DeleteRateLimiterResource with size: 98 bytes
2025-12-12T12:27:24.431098Z :YQ_CONTROL_PLANE_STORAGE TRACE: request_actor.h:57: DeleteRateLimiterResourceRequest: {owner_id: "6ca58679-69617f0a-85bc5868-8fd3dbeb17"
query_id {
  value: "ptqudq7ufj3un8ovpbv9"
}
scope: "yandexcloud://my_folder"
tenant: "/compute"
} 
2025-12-12T12:27:24.469906Z :YQ_CONTROL_PLANE_STORAGE DEBUG: rate_limiter_resources.cpp:74: DeleteRateLimiterResourceRequest. Got response from database: SUCCESS
2025-12-12T12:27:24.469982Z :YQ_RATE_LIMITER DEBUG: schema.cpp:71: Run delete rate limiter resource "mock_cloud/my_folder/ptqudq7ufj3un8ovpbv9" actor
2025-12-12T12:27:24.469984Z :YQ_RATE_LIMITER DEBUG: schema.cpp:113: Call delete rate limiter resource "mock_cloud/my_folder/ptqudq7ufj3un8ovpbv9"
2025-12-12T12:27:24.473889Z :YQ_RATE_LIMITER DEBUG: schema.cpp:179: Successfully deleted rate limiter resource "mock_cloud/my_folder/ptqudq7ufj3un8ovpbv9"
2025-12-12T12:27:24.473901Z :YQ_RATE_LIMITER DEBUG: schema.cpp:122: Reply for delete rate limiter resource "mock_cloud/my_folder/ptqudq7ufj3un8ovpbv9": 
2025-12-12T12:27:24.473924Z :YQ_CONTROL_PLANE_STORAGE DEBUG: rate_limiter_resources.cpp:219: Got delete response from rate limiter service
2025-12-12T12:27:24.473947Z :YQL_PRIVATE_PROXY DEBUG: rate_limiter_resources.cpp:199: PrivateDeleteRateLimiterResource - QueryId: ptqudq7ufj3un8ovpbv9, Owner: 6ca58679-69617f0a-85bc5868-8fd3dbeb17, Got CP::DeleteRateLimiterResourceResponse
2025-12-12T12:27:24.475133Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudq7ufj3un8ovpbv9, Owner: 6ca58679-69617f0a-85bc5868-8fd3dbeb17, Request CP::PingTask with size: 1173 bytes
2025-12-12T12:27:24.475284Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "6ca58679-69617f0a-85bc5868-8fd3dbeb17"
query_id {
  value: "ptqudq7ufj3un8ovpbv9"
}
result_id {
  value: "ptrudq7uet7plgdf9k5a"
}
status: ABORTED_BY_USER
issues {
  message: "ABORTED_BY_USER"
  severity: 1
}
statistics: "{\"Graph=0\":{\"Actor\":{\"ActorCreateTimeUs\":{\"sum\":\"68ms\",\"count\":2,\"avg\":\"34ms\",\"max\":\"34ms\",\"min\":\"34ms\"}},\"AllocateWorkersUs\":{\"sum\":\"35ms\",\"count\":1,\"avg\":\"35ms\",\"max\":\"35ms\",\"min\":\"35ms\"},\"ExecutionTimeUs\":{\"sum\":\"1.01s\",\"count\":1,\"avg\":\"1.01s\",\"max\":\"1.01s\",\"min\":\"1.01s\"},\"TaskRunner\":{\"Stage=214477\":{\"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=214497\":{\"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_5958a75f-5918-4b93-a01c-15191f6a0817/rate_limiter"
  topic_consumers {
    database: "local"
    topic_path: "test_match_recognize[v1-kikimr0]_v1_input"
    consumer_name: "ptqudq7ufj3un8ovpbv9"
    cluster_endpoint: "localhost:25827"
    token_name: "cluster:default_myyds"
    add_bearer_to_token: true
  }
}
scope: "yandexcloud://my_folder"
finished_at {
  seconds: 1765542444
  nanos: 409000000
}
deadline {
  seconds: 1765628843
  nanos: 351416000
}
tenant: "/compute"
}
2025-12-12T12:27:24.587407Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {action: ABORT } SUCCESS
2025-12-12T12:27:24.587453Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudq7ufj3un8ovpbv9, Owner: 6ca58679-69617f0a-85bc5868-8fd3dbeb17, Got CP::PingTaskResponse
2025-12-12T12:27:24.892158Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582946948108156592:2093]
2025-12-12T12:27:24.892182Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:27:24.892190Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582946948108156550:2068]
2025-12-12T12:27:24.892193Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582946948108156550:2068]
2025-12-12T12:27:24.892196Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582946948108156550:2068]
2025-12-12T12:27:24.892209Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:27:24.915104Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudq7ufj3un8ovpbv9"
2025-12-12T12:27:24.915141Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:305: Resolve folder bootstrap. Folder id: my_folder Actor id: [1:7582947059777306588:2381]
2025-12-12T12:27:24.915171Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:367: Cloud id: mock_cloud Folder id: my_folder
2025-12-12T12:27:24.915182Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:91: Get quotas bootstrap. Cloud id: mock_cloud Actor id: [1:7582947059777306589:2382]
2025-12-12T12:27:24.915193Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.analyticsQuery.count IS STALE, Refreshing ...
2025-12-12T12:27:24.915203Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.cpuPercent.count IS STALE, Refreshing ...
2025-12-12T12:27:24.915207Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.streamingQuery.count IS STALE, Refreshing ...
2025-12-12T12:27:24.915218Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.cpuPercent.count=0/10000 REFRESHED
2025-12-12T12:27:24.921064Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.analyticsQuery.count=0/100 REFRESHED
2025-12-12T12:27:24.921090Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.streamingQuery.count=0/100 REFRESHED
2025-12-12T12:27:24.921111Z :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:24.921118Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:103: Cloud id: mock_cloud Quota count: 8
2025-12-12T12:27:24.921140Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudq7ufj3un8ovpbv9"
2025-12-12T12:27:24.921196Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:169: Resolve subject type bootstrap. Token: **** (B6C6F477) Actor id: [1:7582947059777306594:2387]
2025-12-12T12:27:24.921219Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:230: Subject Type: federated_account Token: **** (B6C6F477)
2025-12-12T12:27:24.921249Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudq7ufj3un8ovpbv9"
2025-12-12T12:27:24.921290Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:63: Request actor. Actor id: [1:7582947059777306595:2388]
2025-12-12T12:27:24.921346Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_queries.cpp:641: DescribeQueryRequest: {query_id: "ptqudq7ufj3un8ovpbv9"
} [root@builtin, **** (B6C6F477)] 
2025-12-12T12:27:24.924798Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: DescribeQueryRequest - DescribeQueryResult: {query { meta { common { id: "ptqudq7ufj3un8ovpbv9" created_by: "root@builtin" modified_by: "root@builtin" created_at { seconds: 1765542420 nanos: 415688000 } modified_at { seconds: 1765542444 nanos: 327497000 } revision: 2 } started_at { seconds: 1765542421 nanos: 178000000 } finished_at { seconds: 1765542444 nanos: 409000000 } execute_mode: RUN status: ABORTED_BY_USER last_job_query_revision: 1 last_job_id: "ptjudq7ufj3uml71nrkh-ptqudq7ufj3un8ovpbv9" started_by: "root@builtin" aborted_by: "root@builtin" has_saved_checkpoints: true submitted_at { seconds: 1765542420 nanos: 415688000 } } 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            pragma config.flags(\"MatchRecognizeStream\", \"auto\");\n\n            INSERT INTO myyds.`test_match_recognize[v1-kikimr0]_v1_output`\n            SELECT ToBytes(Unwrap(Json::SerializeJson(Yson::From(TableRow()))))\n            FROM (SELECT * FROM myyds.`test_match_recognize[v1-kikimr0]_v1_input`\n                WITH (\n                    format=json_each_row,\n                    SCHEMA\n                    (\n                        dt UINT64,\n                        str STRING\n                    )))\n            MATCH_RECOGNIZE(\n                ORDER BY CAST(dt as Timestamp)\n                MEASURES\n                   LAST(A.dt) as dt_begin,\n                   LAST(C.dt) as dt_end,\n                   LAST(A.str) as a_str,\n                   LAST(B.str) as b_str,\n                   LAST(C.str) as c_str\n                ONE ROW PER MATCH\n                PATTERN ( A B C )\n                DEFINE\n                    A as A.str=\'A\',\n                    B as B.str=\'B\',\n                    C as C.str=\'C\')" 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: 10 column: 41 } message: "Json UDF is deprecated. Please use JSON API instead" end_position { row: 10 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 (Configure! $5 $1 \'\"MatchRecognizeStream\" \'\"auto\"))\n(let $7 (DataSource \'\"pq\" \'\"myyds\"))\n(let $8 \'(\'(\'\"PartitionsCount\" \'1)))\n(let $9 (OptionalType (DataType \'Uint64)))\n(let $10 \'(\'dt $9))\n(let $11 (DataType \'String))\n(let $12 (OptionalType $11))\n...} SUCCESS
2025-12-12T12:27:24.926642Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.cpuPercent.count=0/10000 NOTIFY CHANGE
2025-12-12T12:27:24.927420Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.analyticsQuery.count=0/100 NOTIFY CHANGE
2025-12-12T12:27:24.927460Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.streamingQuery.count=0/100 NOTIFY CHANGE
