2025-12-09T03:44:03.712781Z :GRPC_SERVER NOTICE: grpc_request_proxy_simple.cpp:161: Grpc simple request proxy started, nodeid# 1
2025-12-09T03:44:03.712818Z :GRPC_SERVER NOTICE: grpc_request_proxy_simple.cpp:161: Grpc simple request proxy started, nodeid# 1
2025-12-09T03:44:03.713018Z :YQ_TEST_CONNECTION DEBUG: test_connection.cpp:142: Starting yandex query test connection. Actor id: [1:7581698935825606042:2071]
2025-12-09T03:44:03.713020Z :YQ_CONTROL_PLANE_STORAGE INFO: ydb_control_plane_storage.cpp:50: Starting ydb control plane storage service. Actor id: [1:7581698935825606033:2062]
2025-12-09T03:44:03.713245Z :FQ_QUOTA_SERVICE INFO: quota_manager.cpp:196: STARTED
2025-12-09T03:44:03.713248Z :FQ_QUOTA_PROXY INFO: quota_proxy.cpp:90: STARTED
2025-12-09T03:44:03.713256Z :FQ_LOG_UPDATER DEBUG: log.cpp:93: Updated YQL logs priority: 8
2025-12-09T03:44:03.713260Z :FQ_LOG_UPDATER CRIT: log.cpp:55: Failed to deliver subscription request to config dispatcher.
2025-12-09T03:44:03.713270Z :FQ_CONTROL_PLANE_CONFIG DEBUG: control_plane_config.cpp:58: STARTING: [1:7581698935825606034:2063]
2025-12-09T03:44:03.713285Z :YQ_CONTROL_PLANE_PROXY DEBUG: control_plane_proxy.cpp:525: Starting yandex query control plane proxy. Actor id: [1:7581698935825606035:2064]
2025-12-09T03:44:03.713346Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:214: Bootstrap
2025-12-09T03:44:03.713348Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:217: Create sdk ydb connection
2025-12-09T03:44:03.713367Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:239: Successfully bootstrapped TStorageProxy [1:7581698935825606038:2067] with connection to localhost:8635:local
2025-12-09T03:44:03.713374Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:544: RowDispatcher: Successfully bootstrapped row dispatcher, id [1:7581698935825606039:2068], tenant /cp
2025-12-09T03:44:03.713381Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7581698935825606039:2068]
2025-12-09T03:44:03.713382Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:329: Coordinator: Add new row dispatcher to map (state 1)
2025-12-09T03:44:03.713537Z :YQ_RATE_LIMITER DEBUG: schema.cpp:71: Run create coordination node "local/RateLimiter_0d9c931a-2c72-4be3-9c55-0c708b358375/rate_limiter" actor
2025-12-09T03:44:03.713539Z :YQ_RATE_LIMITER DEBUG: schema.cpp:113: Call create coordination node "local/RateLimiter_0d9c931a-2c72-4be3-9c55-0c708b358375/rate_limiter"
2025-12-09T03:44:03.713540Z :YQ_RATE_LIMITER DEBUG: schema.cpp:411: Call create coordination node "local/RateLimiter_0d9c931a-2c72-4be3-9c55-0c708b358375/rate_limiter"
2025-12-09T03:44:03.713566Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:293: Coordinator: Successfully bootstrapped coordinator, id [1:7581698935825606080:2093], NodesManagerId [0:4705493345362661702:78], rebalancing timeout 5.000000s
2025-12-09T03:44:03.713575Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:232: TLeaderElection [1:7581698935825606082:2094] Successfully bootstrapped, local coordinator id [1:7581698935825606080:2093], tenant id cp, local mode 0, coordination node path local/cp, endpoint localhost:8635
2025-12-09T03:44:03.713582Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:637: RowDispatcher: TEvCoordinatorChangesSubscribe from [1:7581698935825606080:2093]
2025-12-09T03:44:03.715193Z :MEMORY_PROFILER NOTICE: monitor.cpp:332: Bootstrapped
2025-12-09T03:44:03.722511Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:71: Run create coordination node "local/cp" actor
2025-12-09T03:44:03.722530Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create directory "local/DbPoolStorage_0d9c931a-2c72-4be3-9c55-0c708b358375" actor
2025-12-09T03:44:03.722533Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create directory "local/DbPoolStorage_0d9c931a-2c72-4be3-9c55-0c708b358375"
2025-12-09T03:44:03.722534Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:113: Call create coordination node "local/cp"
2025-12-09T03:44:03.722535Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:383: Call create directory "local/DbPoolStorage_0d9c931a-2c72-4be3-9c55-0c708b358375"
2025-12-09T03:44:03.722540Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:411: Call create coordination node "local/cp"
2025-12-09T03:44:03.722560Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_0d9c931a-2c72-4be3-9c55-0c708b358375/pending_small" actor
2025-12-09T03:44:03.722563Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_0d9c931a-2c72-4be3-9c55-0c708b358375/queries" actor
2025-12-09T03:44:03.722581Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_0d9c931a-2c72-4be3-9c55-0c708b358375/connections" actor
2025-12-09T03:44:03.722582Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_0d9c931a-2c72-4be3-9c55-0c708b358375/bindings" actor
2025-12-09T03:44:03.722589Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_0d9c931a-2c72-4be3-9c55-0c708b358375/idempotency_keys" actor
2025-12-09T03:44:03.722597Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_0d9c931a-2c72-4be3-9c55-0c708b358375/result_sets" actor
2025-12-09T03:44:03.722616Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_0d9c931a-2c72-4be3-9c55-0c708b358375/jobs" actor
2025-12-09T03:44:03.722628Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_0d9c931a-2c72-4be3-9c55-0c708b358375/nodes" actor
2025-12-09T03:44:03.722652Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_0d9c931a-2c72-4be3-9c55-0c708b358375/quotas" actor
2025-12-09T03:44:03.722667Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_0d9c931a-2c72-4be3-9c55-0c708b358375/tenants" actor
2025-12-09T03:44:03.722674Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_0d9c931a-2c72-4be3-9c55-0c708b358375/mappings" actor
2025-12-09T03:44:03.722676Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_0d9c931a-2c72-4be3-9c55-0c708b358375/tenant_acks" actor
2025-12-09T03:44:03.722694Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_0d9c931a-2c72-4be3-9c55-0c708b358375/compute_databases" actor
2025-12-09T03:44:03.733495Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:155: Successfully created coordination node "local/cp"
2025-12-09T03:44:03.733517Z :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: 5], type: EPathTypeKesus, state: EPathStateNoChanges), source_location: ydb/core/tx/schemeshard/schemeshard__operation_create_kesus.cpp:339 }
2025-12-09T03:44:03.733535Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:345: TLeaderElection [1:7581698935825606082:2094] Coordination node successfully created
2025-12-09T03:44:03.733538Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:323: TLeaderElection [1:7581698935825606082:2094] Start session
2025-12-09T03:44:03.735156Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_0d9c931a-2c72-4be3-9c55-0c708b358375/queries". Create session OK
2025-12-09T03:44:03.735170Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_0d9c931a-2c72-4be3-9c55-0c708b358375/queries"
2025-12-09T03:44:03.735172Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_0d9c931a-2c72-4be3-9c55-0c708b358375/queries"
2025-12-09T03:44:03.735184Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_0d9c931a-2c72-4be3-9c55-0c708b358375/bindings". Create session OK
2025-12-09T03:44:03.735188Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_0d9c931a-2c72-4be3-9c55-0c708b358375/bindings"
2025-12-09T03:44:03.735190Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_0d9c931a-2c72-4be3-9c55-0c708b358375/bindings"
2025-12-09T03:44:03.735230Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_0d9c931a-2c72-4be3-9c55-0c708b358375/connections". Create session OK
2025-12-09T03:44:03.735235Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_0d9c931a-2c72-4be3-9c55-0c708b358375/connections"
2025-12-09T03:44:03.735240Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_0d9c931a-2c72-4be3-9c55-0c708b358375/connections"
2025-12-09T03:44:03.735343Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_0d9c931a-2c72-4be3-9c55-0c708b358375/result_sets". Create session OK
2025-12-09T03:44:03.735355Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_0d9c931a-2c72-4be3-9c55-0c708b358375/result_sets"
2025-12-09T03:44:03.735356Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_0d9c931a-2c72-4be3-9c55-0c708b358375/result_sets"
2025-12-09T03:44:03.735379Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created directory "local/DbPoolStorage_0d9c931a-2c72-4be3-9c55-0c708b358375"
2025-12-09T03:44:03.735387Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create directory "local/DbPoolStorage_0d9c931a-2c72-4be3-9c55-0c708b358375": { <main>: Error: Check failed: path: '/local/DbPoolStorage_0d9c931a-2c72-4be3-9c55-0c708b358375', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 54], type: EPathTypeDir, state: EPathStateNoChanges), source_location: ydb/core/tx/schemeshard/schemeshard__operation_mkdir.cpp:155 }
2025-12-09T03:44:03.735394Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_0d9c931a-2c72-4be3-9c55-0c708b358375/mappings". Create session OK
2025-12-09T03:44:03.735396Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_0d9c931a-2c72-4be3-9c55-0c708b358375/mappings"
2025-12-09T03:44:03.735398Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_0d9c931a-2c72-4be3-9c55-0c708b358375/mappings"
2025-12-09T03:44:03.735399Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_0d9c931a-2c72-4be3-9c55-0c708b358375/jobs". Create session OK
2025-12-09T03:44:03.735402Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_0d9c931a-2c72-4be3-9c55-0c708b358375/jobs"
2025-12-09T03:44:03.735403Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_0d9c931a-2c72-4be3-9c55-0c708b358375/jobs"
2025-12-09T03:44:03.735424Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_0d9c931a-2c72-4be3-9c55-0c708b358375/quotas". Create session OK
2025-12-09T03:44:03.735426Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_0d9c931a-2c72-4be3-9c55-0c708b358375/quotas"
2025-12-09T03:44:03.735427Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_0d9c931a-2c72-4be3-9c55-0c708b358375/quotas"
2025-12-09T03:44:03.735462Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_0d9c931a-2c72-4be3-9c55-0c708b358375/idempotency_keys". Create session OK
2025-12-09T03:44:03.735470Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_0d9c931a-2c72-4be3-9c55-0c708b358375/idempotency_keys"
2025-12-09T03:44:03.735471Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_0d9c931a-2c72-4be3-9c55-0c708b358375/nodes". Create session OK
2025-12-09T03:44:03.735471Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_0d9c931a-2c72-4be3-9c55-0c708b358375/idempotency_keys"
2025-12-09T03:44:03.735473Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_0d9c931a-2c72-4be3-9c55-0c708b358375/nodes"
2025-12-09T03:44:03.735474Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_0d9c931a-2c72-4be3-9c55-0c708b358375/nodes"
2025-12-09T03:44:03.735521Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_0d9c931a-2c72-4be3-9c55-0c708b358375/pending_small". Create session OK
2025-12-09T03:44:03.735523Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_0d9c931a-2c72-4be3-9c55-0c708b358375/pending_small"
2025-12-09T03:44:03.735524Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_0d9c931a-2c72-4be3-9c55-0c708b358375/pending_small"
2025-12-09T03:44:03.735539Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_0d9c931a-2c72-4be3-9c55-0c708b358375/tenants". Create session OK
2025-12-09T03:44:03.735541Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_0d9c931a-2c72-4be3-9c55-0c708b358375/tenants"
2025-12-09T03:44:03.735542Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_0d9c931a-2c72-4be3-9c55-0c708b358375/tenants"
2025-12-09T03:44:03.735569Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_0d9c931a-2c72-4be3-9c55-0c708b358375/tenant_acks". Create session OK
2025-12-09T03:44:03.735576Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_0d9c931a-2c72-4be3-9c55-0c708b358375/tenant_acks"
2025-12-09T03:44:03.735578Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_0d9c931a-2c72-4be3-9c55-0c708b358375/tenant_acks"
2025-12-09T03:44:03.735585Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_0d9c931a-2c72-4be3-9c55-0c708b358375/compute_databases". Create session OK
2025-12-09T03:44:03.735587Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_0d9c931a-2c72-4be3-9c55-0c708b358375/compute_databases"
2025-12-09T03:44:03.735588Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_0d9c931a-2c72-4be3-9c55-0c708b358375/compute_databases"
2025-12-09T03:44:03.736656Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:359: TLeaderElection [1:7581698935825606082:2094] Session successfully created
2025-12-09T03:44:03.738347Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:372: TLeaderElection [1:7581698935825606082:2094] Semaphore successfully created
2025-12-09T03:44:03.738358Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:304: TLeaderElection [1:7581698935825606082:2094] Try to acquire semaphore
2025-12-09T03:44:03.738485Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:420: TLeaderElection [1:7581698935825606082:2094] Describe semaphore
2025-12-09T03:44:03.739225Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:386: TLeaderElection [1:7581698935825606082:2094] Semaphore successfully acquired
2025-12-09T03:44:03.739305Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:469: TLeaderElection [1:7581698935825606082:2094] Semaphore successfully described: coordinator id [1:7581698935825606080:2093] generation 3
2025-12-09T03:44:03.739315Z :FQ_ROW_DISPATCHER INFO: leader_election.cpp:471: TLeaderElection [1:7581698935825606082:2094] Send TEvCoordinatorChanged to [1:7581698935825606039:2068], new coordinator id [1:7581698935825606080:2093], previous coordinator id [0:0:0]
2025-12-09T03:44:03.739332Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:569: RowDispatcher: Coordinator changed, old leader (empty maybe), new [1:7581698935825606080:2093] generation 3
2025-12-09T03:44:03.739343Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7581698935825606039:2068]
2025-12-09T03:44:03.739346Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7581698935825606039:2068]
2025-12-09T03:44:03.739349Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7581698935825606039:2068]
2025-12-09T03:44:03.739358Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:440: Coordinator: New leader [1:7581698935825606080:2093], SelfId [1:7581698935825606080:2093]
2025-12-09T03:44:03.739360Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-09T03:44:03.741883Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_0d9c931a-2c72-4be3-9c55-0c708b358375/tenants"
2025-12-09T03:44:03.741902Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_0d9c931a-2c72-4be3-9c55-0c708b358375/tenants": { <main>: Error: Check failed: path: '/local/DbPoolStorage_0d9c931a-2c72-4be3-9c55-0c708b358375/tenants', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 55], type: EPathTypeTable, state: EPathStateNoChanges), source_location: ydb/core/tx/schemeshard/schemeshard__operation_create_table.cpp:504 }
2025-12-09T03:44:03.742344Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_0d9c931a-2c72-4be3-9c55-0c708b358375/mappings"
2025-12-09T03:44:03.742351Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_0d9c931a-2c72-4be3-9c55-0c708b358375/mappings": { <main>: Error: Check failed: path: '/local/DbPoolStorage_0d9c931a-2c72-4be3-9c55-0c708b358375/mappings', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 56], type: EPathTypeTable, state: EPathStateNoChanges), source_location: ydb/core/tx/schemeshard/schemeshard__operation_create_table.cpp:504 }
2025-12-09T03:44:03.749403Z :YQ_RATE_LIMITER DEBUG: schema.cpp:155: Successfully created coordination node "local/RateLimiter_0d9c931a-2c72-4be3-9c55-0c708b358375/rate_limiter"
2025-12-09T03:44:03.749418Z :YQ_RATE_LIMITER DEBUG: schema.cpp:122: Reply for create coordination node "local/RateLimiter_0d9c931a-2c72-4be3-9c55-0c708b358375/rate_limiter": 
2025-12-09T03:44:03.767728Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_0d9c931a-2c72-4be3-9c55-0c708b358375/queries"
2025-12-09T03:44:03.767741Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_0d9c931a-2c72-4be3-9c55-0c708b358375/queries": 
2025-12-09T03:44:03.767752Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_0d9c931a-2c72-4be3-9c55-0c708b358375/result_sets"
2025-12-09T03:44:03.767758Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_0d9c931a-2c72-4be3-9c55-0c708b358375/result_sets": 
2025-12-09T03:44:03.767931Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_0d9c931a-2c72-4be3-9c55-0c708b358375/jobs"
2025-12-09T03:44:03.767951Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_0d9c931a-2c72-4be3-9c55-0c708b358375/jobs": 
2025-12-09T03:44:03.768054Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_0d9c931a-2c72-4be3-9c55-0c708b358375/bindings"
2025-12-09T03:44:03.768062Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_0d9c931a-2c72-4be3-9c55-0c708b358375/bindings": 
2025-12-09T03:44:03.768067Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_0d9c931a-2c72-4be3-9c55-0c708b358375/compute_databases"
2025-12-09T03:44:03.768071Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_0d9c931a-2c72-4be3-9c55-0c708b358375/compute_databases": 
2025-12-09T03:44:03.768161Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_0d9c931a-2c72-4be3-9c55-0c708b358375/connections"
2025-12-09T03:44:03.768168Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_0d9c931a-2c72-4be3-9c55-0c708b358375/connections": 
2025-12-09T03:44:03.768180Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_0d9c931a-2c72-4be3-9c55-0c708b358375/tenant_acks"
2025-12-09T03:44:03.768183Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_0d9c931a-2c72-4be3-9c55-0c708b358375/tenant_acks": 
2025-12-09T03:44:03.768699Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_0d9c931a-2c72-4be3-9c55-0c708b358375/nodes"
2025-12-09T03:44:03.768708Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_0d9c931a-2c72-4be3-9c55-0c708b358375/nodes": 
2025-12-09T03:44:03.768721Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_0d9c931a-2c72-4be3-9c55-0c708b358375/pending_small"
2025-12-09T03:44:03.768724Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_0d9c931a-2c72-4be3-9c55-0c708b358375/pending_small": 
2025-12-09T03:44:03.768798Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_0d9c931a-2c72-4be3-9c55-0c708b358375/quotas"
2025-12-09T03:44:03.768805Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_0d9c931a-2c72-4be3-9c55-0c708b358375/quotas": 
2025-12-09T03:44:03.768811Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_0d9c931a-2c72-4be3-9c55-0c708b358375/idempotency_keys"
2025-12-09T03:44:03.768813Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_0d9c931a-2c72-4be3-9c55-0c708b358375/idempotency_keys": 
2025-12-09T03:44:03.771939Z :FQ_CONTROL_PLANE_CONFIG DEBUG: control_plane_config.cpp:190: LOADED TenantInfo: State CHANGED at 2025-12-09T03:44:03.397641Z
2025-12-09T03:44:04.357405Z :TICKET_PARSER DEBUG: ticket_parser_impl.h:1875: Ticket **** (B6C6F477) (ipv6:[::1]:47260) has now valid token of root@builtin
2025-12-09T03:44:04.357599Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:1330: CreateConnectionRequest: content { name: "myyds" setting { data_streams { auth { none { } } endpoint: "localhost:8635" database: "local" } } acl { visibility: PRIVATE } } 
2025-12-09T03:44:04.357649Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:305: Resolve folder bootstrap. Folder id: my_folder Actor id: [1:7581698940120573436:2148]
2025-12-09T03:44:04.357683Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:367: Cloud id: mock_cloud Folder id: my_folder
2025-12-09T03:44:04.357700Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:91: Get quotas bootstrap. Cloud id: mock_cloud Actor id: [1:7581698940120573437:2149]
2025-12-09T03:44:04.357719Z :FQ_QUOTA_SERVICE DEBUG: quota_manager.cpp:255: cloud.mock_cloud NOT CASHED, Loading ...
2025-12-09T03:44:04.377558Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:441: cloud.mock_cloud {} FROM DB
2025-12-09T03:44:04.377590Z :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-09T03:44:04.377594Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.analyticsQuery.count IS STALE, Refreshing ...
2025-12-09T03:44:04.377607Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.cpuPercent.count IS STALE, Refreshing ...
2025-12-09T03:44:04.377615Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.streamingQuery.count IS STALE, Refreshing ...
2025-12-09T03:44:04.377634Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.cpuPercent.count=0/10000 REFRESHED
2025-12-09T03:44:04.409693Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.cpuPercent.count=0/10000 NOTIFY CHANGE
2025-12-09T03:44:04.422853Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.analyticsQuery.count=0/100 REFRESHED
2025-12-09T03:44:04.422881Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.streamingQuery.count=0/100 REFRESHED
2025-12-09T03:44:04.422905Z :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-09T03:44:04.422914Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:103: Cloud id: mock_cloud Quota count: 8
2025-12-09T03:44:04.423014Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:1330: CreateConnectionRequest: content { name: "myyds" setting { data_streams { auth { none { } } endpoint: "localhost:8635" database: "local" } } acl { visibility: PRIVATE } } 
2025-12-09T03:44:04.423098Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:169: Resolve subject type bootstrap. Token: **** (B6C6F477) Actor id: [1:7581698940120573443:2155]
2025-12-09T03:44:04.423133Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:230: Subject Type: federated_account Token: **** (B6C6F477)
2025-12-09T03:44:04.423188Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:1330: CreateConnectionRequest: content { name: "myyds" setting { data_streams { auth { none { } } endpoint: "localhost:8635" database: "local" } } acl { visibility: PRIVATE } } 
2025-12-09T03:44:04.423217Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:435: Create database bootstrap. CloudId: mock_cloud Scope: yandexcloud://my_folder Actor id: [1:7581698940120573444:2156]
2025-12-09T03:44:04.423344Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:1330: CreateConnectionRequest: content { name: "myyds" setting { data_streams { auth { none { } } endpoint: "localhost:8635" database: "local" } } acl { visibility: PRIVATE } } 
2025-12-09T03:44:04.423401Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:63: Request actor. Actor id: [1:7581698940120573445:2157]
2025-12-09T03:44:04.423548Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_connections.cpp:120: [yandexcloud://my_folder, root@builtin, ptcudqgd3dvg6uei38no] CreateConnectionRequest: **** (B6C6F477) content { name: "myyds" setting { data_streams { auth { none { } } endpoint: "localhost:8635" database: "local" } } acl { visibility: PRIVATE } } 
2025-12-09T03:44:04.426883Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.analyticsQuery.count=0/100 NOTIFY CHANGE
2025-12-09T03:44:04.426986Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.streamingQuery.count=0/100 NOTIFY CHANGE
2025-12-09T03:44:04.446717Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 21209065-dc9406f4-c4759fb1-7f9fe8021, Host: ghrun-syjwtgwtdu, Tenant: /compute, Request CP::GetTask with size: 68 bytes
2025-12-09T03:44:04.447227Z :YQ_CONTROL_PLANE_STORAGE TRACE: nodes_health_check.cpp:38: NodesHealthCheckRequest: {tenant: "/compute"
node {
  node_id: 1
  instance_id: "d9c0101a-43fd8d92-5e6cd6ba-653035e7"
  hostname: "ghrun-syjwtgwtdu"
  interconnect_port: 62714
  node_address: "127.0.1.1"
}
}
2025-12-09T03:44:04.447296Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "21209065-dc9406f4-c4759fb1-7f9fe8021"
host: "ghrun-syjwtgwtdu"
node_id: 1
}
2025-12-09T03:44:04.485153Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-09T03:44:04.485188Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 21209065-dc9406f4-c4759fb1-7f9fe8021, Host: ghrun-syjwtgwtdu, Tenant: /compute, Got CP::GetTask Response
2025-12-09T03:44:04.497937Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: NodesHealthCheckRequest - NodesHealthCheckResult: {nodes { node_id: 1 instance_id: "d9c0101a-43fd8d92-5e6cd6ba-653035e7" hostname: "ghrun-syjwtgwtdu" node_address: "127.0.1.1" } } SUCCESS
2025-12-09T03:44:04.686101Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: [yandexcloud://my_folder, root@builtin, ptcudqgd3dvg6uei38no] CreateConnectionRequest: {connection_id: "ptcudqgd3dvg6uei38no" } SUCCESS
2025-12-09T03:44:04.688472Z :TICKET_PARSER DEBUG: ticket_parser_impl.h:1875: Ticket **** (B6C6F477) (ipv6:[::1]:47260) has now valid token of root@builtin
2025-12-09T03:44:04.688635Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:648: CreateQueryRequest: content {
  type: STREAMING
  name: "simple"
  acl {
    visibility: PRIVATE
  }
  limits {
    execution_timeout {
    }
  }
  text: "\n            PRAGMA dq.MaxTasksPerStage=\"2\";\n\n            pragma FeatureR010=\"prototype\";\n            pragma config.flags(\"TimeOrderRecoverDelay\", \"-1000000\");\n            pragma config.flags(\"TimeOrderRecoverAhead\", \"1000000\");\n\n            INSERT INTO myyds.`test_time_order_recoverer[v1-kikimr0]_v1_output`\n            SELECT ToBytes(Unwrap(Json::SerializeJson(Yson::From(TableRow()))))\n            FROM (SELECT * FROM myyds.`test_time_order_recoverer[v1-kikimr0]_v1_input`\n                WITH (\n                    format=json_each_row,\n                    SCHEMA\n                    (\n                        dt UINT64\n                    )))\n            MATCH_RECOGNIZE(\n                ORDER BY CAST(dt as Timestamp)\n                MEASURES\n                LAST(ALL_TRUE.dt) as dt\n                ONE ROW PER MATCH\n                PATTERN ( ALL_TRUE )\n                DEFINE\n                    ALL_TRUE as True)"
  syntax: YQL_V1
}
execute_mode: RUN
idempotency_key: "0fdf3dd3-f150-43c8-b301-bde3ca7e5ccf"
2025-12-09T03:44:04.688680Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:305: Resolve folder bootstrap. Folder id: my_folder Actor id: [1:7581698940120573455:2166]
2025-12-09T03:44:04.688707Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:367: Cloud id: mock_cloud Folder id: my_folder
2025-12-09T03:44:04.688736Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:91: Get quotas bootstrap. Cloud id: mock_cloud Actor id: [1:7581698940120573456:2167]
2025-12-09T03:44:04.688758Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.analyticsQuery.count IS STALE, Refreshing ...
2025-12-09T03:44:04.688769Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.cpuPercent.count IS STALE, Refreshing ...
2025-12-09T03:44:04.688777Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.streamingQuery.count IS STALE, Refreshing ...
2025-12-09T03:44:04.688797Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.cpuPercent.count=0/10000 REFRESHED
2025-12-09T03:44:04.690553Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.analyticsQuery.count=0/100 REFRESHED
2025-12-09T03:44:04.690578Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.streamingQuery.count=0/100 REFRESHED
2025-12-09T03:44:04.690593Z :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-09T03:44:04.690600Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:103: Cloud id: mock_cloud Quota count: 8
2025-12-09T03:44:04.690657Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:648: CreateQueryRequest: content {
  type: STREAMING
  name: "simple"
  acl {
    visibility: PRIVATE
  }
  limits {
    execution_timeout {
    }
  }
  text: "\n            PRAGMA dq.MaxTasksPerStage=\"2\";\n\n            pragma FeatureR010=\"prototype\";\n            pragma config.flags(\"TimeOrderRecoverDelay\", \"-1000000\");\n            pragma config.flags(\"TimeOrderRecoverAhead\", \"1000000\");\n\n            INSERT INTO myyds.`test_time_order_recoverer[v1-kikimr0]_v1_output`\n            SELECT ToBytes(Unwrap(Json::SerializeJson(Yson::From(TableRow()))))\n            FROM (SELECT * FROM myyds.`test_time_order_recoverer[v1-kikimr0]_v1_input`\n                WITH (\n                    format=json_each_row,\n                    SCHEMA\n                    (\n                        dt UINT64\n                    )))\n            MATCH_RECOGNIZE(\n                ORDER BY CAST(dt as Timestamp)\n                MEASURES\n                LAST(ALL_TRUE.dt) as dt\n                ONE ROW PER MATCH\n                PATTERN ( ALL_TRUE )\n                DEFINE\n                    ALL_TRUE as True)"
  syntax: YQL_V1
}
execute_mode: RUN
idempotency_key: "0fdf3dd3-f150-43c8-b301-bde3ca7e5ccf"
2025-12-09T03:44:04.690732Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:169: Resolve subject type bootstrap. Token: **** (B6C6F477) Actor id: [1:7581698940120573461:2172]
2025-12-09T03:44:04.690765Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:230: Subject Type: federated_account Token: **** (B6C6F477)
2025-12-09T03:44:04.690829Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:648: CreateQueryRequest: content {
  type: STREAMING
  name: "simple"
  acl {
    visibility: PRIVATE
  }
  limits {
    execution_timeout {
    }
  }
  text: "\n            PRAGMA dq.MaxTasksPerStage=\"2\";\n\n            pragma FeatureR010=\"prototype\";\n            pragma config.flags(\"TimeOrderRecoverDelay\", \"-1000000\");\n            pragma config.flags(\"TimeOrderRecoverAhead\", \"1000000\");\n\n            INSERT INTO myyds.`test_time_order_recoverer[v1-kikimr0]_v1_output`\n            SELECT ToBytes(Unwrap(Json::SerializeJson(Yson::From(TableRow()))))\n            FROM (SELECT * FROM myyds.`test_time_order_recoverer[v1-kikimr0]_v1_input`\n                WITH (\n                    format=json_each_row,\n                    SCHEMA\n                    (\n                        dt UINT64\n                    )))\n            MATCH_RECOGNIZE(\n                ORDER BY CAST(dt as Timestamp)\n                MEASURES\n                LAST(ALL_TRUE.dt) as dt\n                ONE ROW PER MATCH\n                PATTERN ( ALL_TRUE )\n                DEFINE\n                    ALL_TRUE as True)"
  syntax: YQL_V1
}
execute_mode: RUN
idempotency_key: "0fdf3dd3-f150-43c8-b301-bde3ca7e5ccf"
2025-12-09T03:44:04.690873Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:435: Create database bootstrap. CloudId: mock_cloud Scope: yandexcloud://my_folder Actor id: [1:7581698940120573462:2173]
2025-12-09T03:44:04.690904Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:648: CreateQueryRequest: content {
  type: STREAMING
  name: "simple"
  acl {
    visibility: PRIVATE
  }
  limits {
    execution_timeout {
    }
  }
  text: "\n            PRAGMA dq.MaxTasksPerStage=\"2\";\n\n            pragma FeatureR010=\"prototype\";\n            pragma config.flags(\"TimeOrderRecoverDelay\", \"-1000000\");\n            pragma config.flags(\"TimeOrderRecoverAhead\", \"1000000\");\n\n            INSERT INTO myyds.`test_time_order_recoverer[v1-kikimr0]_v1_output`\n            SELECT ToBytes(Unwrap(Json::SerializeJson(Yson::From(TableRow()))))\n            FROM (SELECT * FROM myyds.`test_time_order_recoverer[v1-kikimr0]_v1_input`\n                WITH (\n                    format=json_each_row,\n                    SCHEMA\n                    (\n                        dt UINT64\n                    )))\n            MATCH_RECOGNIZE(\n                ORDER BY CAST(dt as Timestamp)\n                MEASURES\n                LAST(ALL_TRUE.dt) as dt\n                ONE ROW PER MATCH\n                PATTERN ( ALL_TRUE )\n                DEFINE\n                    ALL_TRUE as True)"
  syntax: YQL_V1
}
execute_mode: RUN
idempotency_key: "0fdf3dd3-f150-43c8-b301-bde3ca7e5ccf"
2025-12-09T03:44:04.690930Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:63: Request actor. Actor id: [1:7581698940120573463:2174]
2025-12-09T03:44:04.690952Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:248: Create rate limiter resource for cloud with limit 100000ms
2025-12-09T03:44:04.691000Z :YQ_RATE_LIMITER DEBUG: schema.cpp:71: Run create rate limiter resource "mock_cloud" actor
2025-12-09T03:44:04.691006Z :YQ_RATE_LIMITER DEBUG: schema.cpp:113: Call create rate limiter resource "mock_cloud"
2025-12-09T03:44:04.692818Z :YQ_RATE_LIMITER DEBUG: schema.cpp:155: Successfully created rate limiter resource "mock_cloud"
2025-12-09T03:44:04.692828Z :YQ_RATE_LIMITER DEBUG: schema.cpp:122: Reply for create rate limiter resource "mock_cloud": 
2025-12-09T03:44:04.692853Z :YQ_CONTROL_PLANE_PROXY DEBUG: request_actor.h:272: Create response from rate limiter service. Success: 1
2025-12-09T03:44:04.692930Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_queries.cpp:226: CreateQueryRequest: {content {
  type: STREAMING
  name: "simple"
  acl {
    visibility: PRIVATE
  }
  limits {
    execution_timeout {
    }
  }
  text: "\n            PRAGMA dq.MaxTasksPerStage=\"2\";\n\n            pragma FeatureR010=\"prototype\";\n            pragma config.flags(\"TimeOrderRecoverDelay\", \"-1000000\");\n            pragma config.flags(\"TimeOrderRecoverAhead\", \"1000000\");\n\n            INSERT INTO myyds.`test_time_order_recoverer[v1-kikimr0]_v1_output`\n            SELECT ToBytes(Unwrap(Json::SerializeJson(Yson::From(TableRow()))))\n            FROM (SELECT * FROM myyds.`test_time_order_recoverer[v1-kikimr0]_v1_input`\n                WITH (\n                    format=json_each_row,\n                    SCHEMA\n                    (\n                        dt UINT64\n                    )))\n            MATCH_RECOGNIZE(\n                ORDER BY CAST(dt as Timestamp)\n                MEASURES\n                LAST(ALL_TRUE.dt) as dt\n                ONE ROW PER MATCH\n                PATTERN ( ALL_TRUE )\n                DEFINE\n                    ALL_TRUE as True)"
  syntax: YQL_V1
}
execute_mode: RUN
idempotency_key: "0fdf3dd3-f150-43c8-b301-bde3ca7e5ccf"
} [root@builtin, **** (B6C6F477)] 
2025-12-09T03:44:04.694562Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.cpuPercent.count=0/10000 NOTIFY CHANGE
2025-12-09T03:44:04.696015Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.streamingQuery.count=0/100 NOTIFY CHANGE
2025-12-09T03:44:04.696038Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.analyticsQuery.count=0/100 NOTIFY CHANGE
2025-12-09T03:44:04.868838Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: CreateQueryRequest - CreateQueryResult: {query_id: "ptqudqgd3dn917ujg7bg" } SUCCESS
2025-12-09T03:44:04.871290Z :TICKET_PARSER DEBUG: ticket_parser_impl.h:1875: Ticket **** (B6C6F477) (ipv6:[::1]:47260) has now valid token of root@builtin
2025-12-09T03:44:04.871387Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudqgd3dn917ujg7bg"
2025-12-09T03:44:04.871423Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:305: Resolve folder bootstrap. Folder id: my_folder Actor id: [1:7581698940120573468:2178]
2025-12-09T03:44:04.871452Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:367: Cloud id: mock_cloud Folder id: my_folder
2025-12-09T03:44:04.871475Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:91: Get quotas bootstrap. Cloud id: mock_cloud Actor id: [1:7581698940120573469:2179]
2025-12-09T03:44:04.871500Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.analyticsQuery.count IS STALE, Refreshing ...
2025-12-09T03:44:04.871512Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.cpuPercent.count IS STALE, Refreshing ...
2025-12-09T03:44:04.871516Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.streamingQuery.count IS STALE, Refreshing ...
2025-12-09T03:44:04.871531Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.cpuPercent.count=0/10000 REFRESHED
2025-12-09T03:44:04.876340Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.cpuPercent.count=0/10000 NOTIFY CHANGE
2025-12-09T03:44:04.893686Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.analyticsQuery.count=0/100 REFRESHED
2025-12-09T03:44:04.893720Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.streamingQuery.count=1/100 REFRESHED
2025-12-09T03:44:04.893747Z :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-09T03:44:04.893757Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:103: Cloud id: mock_cloud Quota count: 8
2025-12-09T03:44:04.893789Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudqgd3dn917ujg7bg"
2025-12-09T03:44:04.893876Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:169: Resolve subject type bootstrap. Token: **** (B6C6F477) Actor id: [1:7581698940120573474:2184]
2025-12-09T03:44:04.893905Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:230: Subject Type: federated_account Token: **** (B6C6F477)
2025-12-09T03:44:04.893938Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudqgd3dn917ujg7bg"
2025-12-09T03:44:04.893981Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:63: Request actor. Actor id: [1:7581698940120573475:2185]
2025-12-09T03:44:04.894070Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_queries.cpp:641: DescribeQueryRequest: {query_id: "ptqudqgd3dn917ujg7bg"
} [root@builtin, **** (B6C6F477)] 
2025-12-09T03:44:04.899257Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.streamingQuery.count=1/100 NOTIFY CHANGE
2025-12-09T03:44:04.899292Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.analyticsQuery.count=0/100 NOTIFY CHANGE
2025-12-09T03:44:04.922894Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: DescribeQueryRequest - DescribeQueryResult: {query { meta { common { id: "ptqudqgd3dn917ujg7bg" created_by: "root@builtin" modified_by: "root@builtin" created_at { seconds: 1765251844 nanos: 692875000 } modified_at { seconds: 1765251844 nanos: 692875000 } revision: 1 } execute_mode: RUN status: STARTING last_job_query_revision: 1 last_job_id: "ptjudqgd3dn911n5hs81-ptqudqgd3dn917ujg7bg" started_by: "root@builtin" submitted_at { seconds: 1765251844 nanos: 692875000 } } content { type: STREAMING name: "simple" acl { visibility: PRIVATE } limits { execution_timeout { } } text: "\n            PRAGMA dq.MaxTasksPerStage=\"2\";\n\n            pragma FeatureR010=\"prototype\";\n            pragma config.flags(\"TimeOrderRecoverDelay\", \"-1000000\");\n            pragma config.flags(\"TimeOrderRecoverAhead\", \"1000000\");\n\n            INSERT INTO myyds.`test_time_order_recoverer[v1-kikimr0]_v1_output`\n            SELECT ToBytes(Unwrap(Json::SerializeJson(Yson::From(TableRow()))))\n            FROM (SELECT * FROM myyds.`test_time_order_recoverer[v1-kikimr0]_v1_input`\n                WITH (\n                    format=json_each_row,\n                    SCHEMA\n                    (\n                        dt UINT64\n                    )))\n            MATCH_RECOGNIZE(\n                ORDER BY CAST(dt as Timestamp)\n                MEASURES\n                LAST(ALL_TRUE.dt) as dt\n                ONE ROW PER MATCH\n                PATTERN ( ALL_TRUE )\n                DEFINE\n                    ALL_TRUE as True)" syntax: YQL_V1 } } } SUCCESS
2025-12-09T03:44:05.425246Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudqgd3dn917ujg7bg"
2025-12-09T03:44:05.425290Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:305: Resolve folder bootstrap. Folder id: my_folder Actor id: [1:7581698944415540775:2188]
2025-12-09T03:44:05.425313Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:367: Cloud id: mock_cloud Folder id: my_folder
2025-12-09T03:44:05.425340Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:91: Get quotas bootstrap. Cloud id: mock_cloud Actor id: [1:7581698944415540776:2189]
2025-12-09T03:44:05.425371Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.analyticsQuery.count IS STALE, Refreshing ...
2025-12-09T03:44:05.425384Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.cpuPercent.count IS STALE, Refreshing ...
2025-12-09T03:44:05.425394Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.streamingQuery.count IS STALE, Refreshing ...
2025-12-09T03:44:05.425412Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.cpuPercent.count=0/10000 REFRESHED
2025-12-09T03:44:05.428969Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.analyticsQuery.count=0/100 REFRESHED
2025-12-09T03:44:05.428993Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.streamingQuery.count=1/100 REFRESHED
2025-12-09T03:44:05.429012Z :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-09T03:44:05.429019Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:103: Cloud id: mock_cloud Quota count: 8
2025-12-09T03:44:05.429043Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudqgd3dn917ujg7bg"
2025-12-09T03:44:05.429093Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:169: Resolve subject type bootstrap. Token: **** (B6C6F477) Actor id: [1:7581698944415540781:2194]
2025-12-09T03:44:05.429121Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:230: Subject Type: federated_account Token: **** (B6C6F477)
2025-12-09T03:44:05.429153Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudqgd3dn917ujg7bg"
2025-12-09T03:44:05.429194Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:63: Request actor. Actor id: [1:7581698944415540782:2195]
2025-12-09T03:44:05.429240Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_queries.cpp:641: DescribeQueryRequest: {query_id: "ptqudqgd3dn917ujg7bg"
} [root@builtin, **** (B6C6F477)] 
2025-12-09T03:44:05.430382Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.cpuPercent.count=0/10000 NOTIFY CHANGE
2025-12-09T03:44:05.430951Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: DescribeQueryRequest - DescribeQueryResult: {query { meta { common { id: "ptqudqgd3dn917ujg7bg" created_by: "root@builtin" modified_by: "root@builtin" created_at { seconds: 1765251844 nanos: 692875000 } modified_at { seconds: 1765251844 nanos: 692875000 } revision: 1 } execute_mode: RUN status: STARTING last_job_query_revision: 1 last_job_id: "ptjudqgd3dn911n5hs81-ptqudqgd3dn917ujg7bg" started_by: "root@builtin" submitted_at { seconds: 1765251844 nanos: 692875000 } } content { type: STREAMING name: "simple" acl { visibility: PRIVATE } limits { execution_timeout { } } text: "\n            PRAGMA dq.MaxTasksPerStage=\"2\";\n\n            pragma FeatureR010=\"prototype\";\n            pragma config.flags(\"TimeOrderRecoverDelay\", \"-1000000\");\n            pragma config.flags(\"TimeOrderRecoverAhead\", \"1000000\");\n\n            INSERT INTO myyds.`test_time_order_recoverer[v1-kikimr0]_v1_output`\n            SELECT ToBytes(Unwrap(Json::SerializeJson(Yson::From(TableRow()))))\n            FROM (SELECT * FROM myyds.`test_time_order_recoverer[v1-kikimr0]_v1_input`\n                WITH (\n                    format=json_each_row,\n                    SCHEMA\n                    (\n                        dt UINT64\n                    )))\n            MATCH_RECOGNIZE(\n                ORDER BY CAST(dt as Timestamp)\n                MEASURES\n                LAST(ALL_TRUE.dt) as dt\n                ONE ROW PER MATCH\n                PATTERN ( ALL_TRUE )\n                DEFINE\n                    ALL_TRUE as True)" syntax: YQL_V1 } } } SUCCESS
2025-12-09T03:44:05.434583Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.analyticsQuery.count=0/100 NOTIFY CHANGE
2025-12-09T03:44:05.434631Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.streamingQuery.count=1/100 NOTIFY CHANGE
2025-12-09T03:44:05.439677Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 21209065-dc9406f4-c4759fb1-7f9fe8022, Host: ghrun-syjwtgwtdu, Tenant: /compute, Request CP::GetTask with size: 68 bytes
2025-12-09T03:44:05.439723Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "21209065-dc9406f4-c4759fb1-7f9fe8022"
host: "ghrun-syjwtgwtdu"
node_id: 1
}
2025-12-09T03:44:05.442193Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:463: Task (Query): ptqudqgd3dn917ujg7bg RetryRate: 0 RetryCounter: 0 At: 2025-12-09T03:44:04.775996Z
2025-12-09T03:44:05.544997Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {tasks { query_id { value: "ptqudqgd3dn917ujg7bg" } job_id { value: "ptjudqgd3dn911n5hs81" } generation: 1 streaming: true text: "\n            PRAGMA dq.MaxTasksPerStage=\"2\";\n\n            pragma FeatureR010=\"prototype\";\n            pragma config.flags(\"TimeOrderRecoverDelay\", \"-1000000\");\n            pragma config.flags(\"TimeOrderRecoverAhead\", \"1000000\");\n\n            INSERT INTO myyds.`test_time_order_recoverer[v1-kikimr0]_v1_output`\n            SELECT ToBytes(Unwrap(Json::SerializeJson(Yson::From(TableRow()))))\n            FROM (SELECT * FROM myyds.`test_time_order_recoverer[v1-kikimr0]_v1_input`\n                WITH (\n                    format=json_each_row,\n                    SCHEMA\n                    (\n                        dt UINT64\n                    )))\n            MATCH_RECOGNIZE(\n                ORDER BY CAST(dt as Timestamp)\n                MEASURES\n                LAST(ALL_TRUE.dt) as dt\n                ONE ROW PER MATCH\n                PATTERN ( ALL_TRUE )\n                DEFINE\n                    ALL_TRUE as True)" connection { content { name: "myyds" setting { data_streams { auth { none { } } endpoint: "localhost:8635" database: "local" } } acl { visibility: PRIVATE } } meta { id: "ptcudqgd3dvg6uei38no" created_by: "root@builtin" modified_by: "root@builtin" created_at { seconds: 1765251844 nanos: 423438000 } modified_at { seconds: 1765251844 nanos: 423438000 } 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: 1765338245 nanos: 487497000 } 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: 1765251844 nanos: 692875000 } } } SUCCESS
2025-12-09T03:44:05.545127Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 21209065-dc9406f4-c4759fb1-7f9fe8022, Host: ghrun-syjwtgwtdu, Tenant: /compute, Got CP::GetTask Response
2025-12-09T03:44:05.547103Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 21209065-dc9406f4-c4759fb1-7f9fe8023, Host: ghrun-syjwtgwtdu, Tenant: /compute, Request CP::GetTask with size: 68 bytes
2025-12-09T03:44:05.547137Z :YQL_PRIVATE_PROXY DEBUG: rate_limiter_resources.cpp:78: PrivateCreateRateLimiterResource - QueryId: ptqudqgd3dn917ujg7bg, Owner: 21209065-dc9406f4-c4759fb1-7f9fe8022, Request CP::CreateRateLimiterResource with size: 97 bytes
2025-12-09T03:44:05.547144Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "21209065-dc9406f4-c4759fb1-7f9fe8023"
host: "ghrun-syjwtgwtdu"
node_id: 1
}
2025-12-09T03:44:05.547169Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudqgd3dn917ujg7bg, Owner: 21209065-dc9406f4-c4759fb1-7f9fe8022, Request CP::PingTask with size: 129 bytes
2025-12-09T03:44:05.547225Z :YQ_CONTROL_PLANE_STORAGE TRACE: request_actor.h:57: CreateRateLimiterResourceRequest: {owner_id: "21209065-dc9406f4-c4759fb1-7f9fe8022"
query_id {
  value: "ptqudqgd3dn917ujg7bg"
}
scope: "yandexcloud://my_folder"
tenant: "/compute"
} 
2025-12-09T03:44:05.547248Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "21209065-dc9406f4-c4759fb1-7f9fe8022"
query_id {
  value: "ptqudqgd3dn917ujg7bg"
}
scope: "yandexcloud://my_folder"
started_at {
  seconds: 1765251845
  nanos: 546000000
}
deadline {
  seconds: 1765338245
  nanos: 487497000
}
tenant: "/compute"
}
2025-12-09T03:44:05.555008Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-09T03:44:05.555058Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 21209065-dc9406f4-c4759fb1-7f9fe8023, Host: ghrun-syjwtgwtdu, Tenant: /compute, Got CP::GetTask Response
2025-12-09T03:44:05.583437Z :YQ_CONTROL_PLANE_STORAGE DEBUG: rate_limiter_resources.cpp:74: CreateRateLimiterResourceRequest. Got response from database: SUCCESS
2025-12-09T03:44:05.583551Z :YQ_RATE_LIMITER DEBUG: schema.cpp:71: Run create rate limiter resource "mock_cloud/my_folder/ptqudqgd3dn917ujg7bg" actor
2025-12-09T03:44:05.583560Z :YQ_RATE_LIMITER DEBUG: schema.cpp:113: Call create rate limiter resource "mock_cloud/my_folder/ptqudqgd3dn917ujg7bg"
2025-12-09T03:44:05.584336Z :YQ_RATE_LIMITER DEBUG: schema.cpp:261: Trying to recursively create rate limiter resource "mock_cloud/my_folder"
2025-12-09T03:44:05.584346Z :YQ_RATE_LIMITER DEBUG: schema.cpp:113: Call create rate limiter resource "mock_cloud/my_folder"
2025-12-09T03:44:05.585797Z :YQ_RATE_LIMITER DEBUG: schema.cpp:244: Successfully created rate limiter resource "mock_cloud/my_folder"
2025-12-09T03:44:05.585807Z :YQ_RATE_LIMITER DEBUG: schema.cpp:113: Call create rate limiter resource "mock_cloud/my_folder/ptqudqgd3dn917ujg7bg"
2025-12-09T03:44:05.587800Z :YQ_RATE_LIMITER DEBUG: schema.cpp:155: Successfully created rate limiter resource "mock_cloud/my_folder/ptqudqgd3dn917ujg7bg"
2025-12-09T03:44:05.587816Z :YQ_RATE_LIMITER DEBUG: schema.cpp:122: Reply for create rate limiter resource "mock_cloud/my_folder/ptqudqgd3dn917ujg7bg": 
2025-12-09T03:44:05.587850Z :YQ_CONTROL_PLANE_STORAGE DEBUG: rate_limiter_resources.cpp:180: Got create response from rate limiter service
2025-12-09T03:44:05.587879Z :YQL_PRIVATE_PROXY DEBUG: rate_limiter_resources.cpp:102: PrivateCreateRateLimiterResource - QueryId: ptqudqgd3dn917ujg7bg, Owner: 21209065-dc9406f4-c4759fb1-7f9fe8022, Got CP::CreateRateLimiterResourceResponse
2025-12-09T03:44:05.711580Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7581698935825606080:2093]
2025-12-09T03:44:05.711609Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-09T03:44:05.711615Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7581698935825606039:2068]
2025-12-09T03:44:05.711620Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7581698935825606039:2068]
2025-12-09T03:44:05.711622Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7581698935825606039:2068]
2025-12-09T03:44:05.711633Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-09T03:44:05.735134Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {expired_at { seconds: 1765251865 nanos: 662000000 } } SUCCESS
2025-12-09T03:44:05.735185Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudqgd3dn917ujg7bg, Owner: 21209065-dc9406f4-c4759fb1-7f9fe8022, Got CP::PingTaskResponse
2025-12-09T03:44:05.736244Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudqgd3dn917ujg7bg, Owner: 21209065-dc9406f4-c4759fb1-7f9fe8022, Request CP::PingTask with size: 123 bytes
2025-12-09T03:44:05.736328Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "21209065-dc9406f4-c4759fb1-7f9fe8022"
query_id {
  value: "ptqudqgd3dn917ujg7bg"
}
status: RUNNING
resources {
  rate_limiter: PREPARE
  compilation: PREPARE
}
scope: "yandexcloud://my_folder"
deadline {
  seconds: 1765338245
  nanos: 487497000
}
tenant: "/compute"
}
2025-12-09T03:44:05.746245Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {expired_at { seconds: 1765251865 nanos: 741000000 } } SUCCESS
2025-12-09T03:44:05.746279Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudqgd3dn917ujg7bg, Owner: 21209065-dc9406f4-c4759fb1-7f9fe8022, Got CP::PingTaskResponse
2025-12-09T03:44:05.747209Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudqgd3dn917ujg7bg, Owner: 21209065-dc9406f4-c4759fb1-7f9fe8022, Request CP::PingTask with size: 192 bytes
2025-12-09T03:44:05.747292Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "21209065-dc9406f4-c4759fb1-7f9fe8022"
query_id {
  value: "ptqudqgd3dn917ujg7bg"
}
status: RUNNING
resources {
  rate_limiter: READY
  compilation: PREPARE
  rate_limiter_path: "local/RateLimiter_0d9c931a-2c72-4be3-9c55-0c708b358375/rate_limiter"
}
scope: "yandexcloud://my_folder"
deadline {
  seconds: 1765338245
  nanos: 487497000
}
tenant: "/compute"
}
2025-12-09T03:44:05.756346Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {expired_at { seconds: 1765251865 nanos: 751000000 } } SUCCESS
2025-12-09T03:44:05.756371Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudqgd3dn917ujg7bg, Owner: 21209065-dc9406f4-c4759fb1-7f9fe8022, Got CP::PingTaskResponse
2025-12-09T03:44:05.798422Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudqgd3dn917ujg7bg, Owner: 21209065-dc9406f4-c4759fb1-7f9fe8022, Request CP::PingTask with size: 4965 bytes
2025-12-09T03:44:05.798544Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "21209065-dc9406f4-c4759fb1-7f9fe8022"
query_id {
  value: "ptqudqgd3dn917ujg7bg"
}
ast: "(\n(let $1 (DataSource \'\"config\"))\n(let $2 (Configure! world $1 \'\"DqEngine\" \'\"force\"))\n(let $3 (Configure! $2 (DataSource \'\"dq\" \'\"$all\") \'\"Attr\" \'\"maxtasksperstage\" \'\"2\"))\n(let $4 (Configure! $3 $1 \'\"TimeOrderRecoverDelay\" \'\"-1000000\"))\n(let $5 (Configure! $4 $1 \'\"TimeOrderRecoverAhead\" \'\"1000000\"))\n(let $6 (DataSource \'\"pq\" \'\"myyds\"))\n(let $7 \'(\'(\'\"PartitionsCount\" \'1)))\n(let $8 (StructType \'(\'dt (OptionalType (DataType \'Uint64)))))\n(let $9 (PqTopic \'\"myyds\" \'\"local\" \'\"test_time_order_recoverer[v1-kikimr0]_v1_input\" $7 \'() $8))\n(let $10 \'(\'dt))\n(let $11 \'(\'\"Endpoint\" \'\"localhost:8635\"))\n(let $12 \'(\'\"SharedReading\" \'0))\n(let $13 \'(\'\"AddBearerToToken\" \'1))\n(let $14 \'($11 $12 \'(\'\"ReconnectPeriod\" \'\"\") \'(\'\"Format\" \'\"json_each_row\") \'(\'\"ReadGroup\" \'\"ptcudqgd3dvg6uei38no\") $13))\n(let $15 (SecureParam \'\"cluster:default_myyds\"))\n(let $16 (DqPqTopicSource $5 $9 $10 $14 $15 \'\"\" $8 \'\"\"))\n(let $17 (DqStage \'((DqSource $6 $16)) (lambda \'($21) (block \'(\n  (let $22 \'(\'(\'\"format\" \'\"json_each_row\") \'(\'\"formatSettings\" \'(\'(\'\"data.datetime.formatname\" \'\"POSIX\") \'(\'\"data.timestamp.formatname\" \'\"POSIX\"))) \'(\'\"settings\" \'($12))))\n  (let $23 (DqSourceWideWrap $21 $6 $8 $22))\n  (return (NarrowMap $23 (lambda \'($24) (AsStruct \'(\'dt $24)))))\n))) \'(\'(\'\"_logical_id\" \'200904))))\n(let $18 (DataSink \'\"pq\" \'\"myyds\"))\n(let $19 (PqTopic \'\"myyds\" \'\"local\" \'\"test_time_order_recoverer[v1-kikimr0]_v1_output\" $7 \'() (StructType \'(\'\"Data\" (DataType \'String)))))\n(let $20 (DqPqTopicSink $19 \'($11 $13) $15))\n(return (Commit! (DqQuery! $5 \'((DqStage \'((DqCnUnionAll (TDqOutput $17 \'0))) (lambda \'($25) (block \'(\n  (let $26 (TimeOrderRecover $25 (lambda \'($33) (SafeCast (Member $33 \'dt) (OptionalType (DataType \'Timestamp)))) (Interval \'\"-1000000\") (Interval \'\"1000000\") (Uint32 \'\"1000000\")))\n  (let $27 \'(\'\"ALL_TRUE\"))\n  (let $28 (MatchRecognizeMeasures $8 $27 $10 (lambda \'($36 $37) (block \'(\n    (let $38 (lambda \'($45) $45))\n    (let $39 (AggregationTraits $8 (lambda \'($42) (Member $42 \'dt)) (lambda \'($43 $44) (Coalesce (Member $43 \'dt) $44)) $38 $38 (lambda \'($46 $47) (Coalesce $46 $47)) $38 (Null)))\n    (return (Member (Head (Aggregate (OrderedFlatMap (OrderedFlatMap (Member $37 \'\"ALL_TRUE\") (lambda \'($40) (ListFromRange (Member $40 \'\"From\") (+ (Member $40 \'\"To\") (Uint64 \'1)) (Int64 \'1)))) (lambda \'($41) (Just (AsStruct \'(\'dt (Member (Unwrap (Lookup (ToIndexDict $36) $41)) \'dt)))))) \'() \'(\'(\'Last0 $39)) \'())) \'Last0))\n  )))))\n  (let $29 (Bool \'true))\n  (let $30 (MatchRecognizeDefines $8 $27 $27 (lambda \'($48 $49 $50) $29)))\n  (let $31 (MatchRecognizeParams $28 \'\"RowsPerMatch_OneRow\" \'(\'\"AfterMatchSkip_PastLastRow\" \'\"\") (MatchRecognizePattern \'(\'(\'\"ALL_TRUE\" \'1 \'1 \'1 \'1 \'0))) $30))\n  (let $32 (MatchRecognizeCore (OrderedFlatMap $26 (lambda \'($34) (OptionalIf (Not (Member $34 \'\"_yql_OutOfOrder\")) (AsStruct \'(\'dt (Member $34 \'dt)))))) (lambda \'($35) \'()) \'() $31 \'(\'(\'\"Streaming\" \'1))))\n  (return (FromFlow (FlatMap $32 (lambda \'($51) (block \'(\n    (let $52 (ResourceType \'\"Yson2.Node\"))\n    (let $53 \'($52 \'\"\" \'1))\n    (let $54 (ResourceType \'\"Yson2.Options\"))\n    (let $55 (OptionalType (DataType \'Bool)))\n    (let $56 (CallableType \'(\'\"4\") \'((OptionalType (DataType \'Json))) $53 \'((OptionalType $54)) \'($55 \'\"SkipMapEntity\") \'($55 \'\"EncodeUtf8\") \'($55 \'\"WriteNanAsString\")))\n    (let $57 (Udf \'\"Yson2.SerializeJson\" (Void) (VoidType) \'\"\" $56 (VoidType) \'\"\" \'()))\n    (let $58 (TupleType (TupleType $8) (StructType) (TupleType)))\n    (let $59 (CallableType \'() \'($52) \'($8)))\n    (let $60 \'(\'(\'\"strict\")))\n    (let $61 (Udf \'\"Yson2.From\" (Void) $58 \'\"\" $59 (VoidType) \'\"\" $60))\n    (let $62 (CallableType \'(\'\"2\") \'($54) \'($55 \'\"AutoConvert\") \'($55 \'\"Strict\")))\n    (let $63 (Udf \'\"Yson2.Options\" (Void) (VoidType) \'\"\" $62 (VoidType) \'\"\" $60))\n    (return (Just (AsStruct \'(\'\"column0\" (ToBytes (Unwrap (Apply $57 (Apply $61 $51) (Just (NamedApply $63 \'() (AsStruct \'(\'\"AutoConvert\" (Just (Bool \'false))) \'(\'\"Strict\" (Just $29))))))))))))\n  ))))))\n))) \'(\'(\'\"_logical_id\" \'201884) \'(\'\"_partition_mode\" \'\"aggregate\")) \'((DqSink \'0 $18 $20))))) $18))\n)\n"
plan: "{\"Detailed\":{\"Operations\":[{\"Id\":5,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[{\"Name\":\"DqSourceWideWrap\"},{\"Name\":\"NarrowMap\"}]}},{\"Id\":3,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[{\"Name\":\"TimeOrderRecover\"},{\"Name\":\"OrderedFlatMap\"},{\"Name\":\"MatchRecognizeCore\"},{\"Name\":\"FlatMap\"},{\"Name\":\"FromFlow\"}]},\"DependsOn\":[5]},{\"Id\":2,\"Name\":\"DqQuery!\",\"DependsOn\":[3]},{\"Id\":1,\"Name\":\"Commit!\",\"DependsOn\":[2]}],\"OperationRoot\":1,\"Providers\":[],\"OperationStats\":{\"Commit!\":1,\"DqQuery!\":1,\"DqStage\":2}},\"Basic\":{\"nodes\":[{\"id\":5,\"level\":1,\"name\":\"DqStage #5\",\"type\":\"op\"},{\"id\":3,\"level\":2,\"name\":\"DqStage #3\",\"type\":\"op\"},{\"id\":2,\"level\":3,\"name\":\"DqQuery!\",\"type\":\"op\"},{\"id\":1,\"level\":4,\"name\":\"Commit!\",\"type\":\"op\"}],\"links\":[{\"source\":5,\"target\":3},{\"source\":3,\"target\":2},{\"source\":2,\"target\":1}]}}"
scope: "yandexcloud://my_folder"
deadline {
  seconds: 1765338245
  nanos: 487497000
}
tenant: "/compute"
}
2025-12-09T03:44:05.807602Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {expired_at { seconds: 1765251865 nanos: 803000000 } } SUCCESS
2025-12-09T03:44:05.807635Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudqgd3dn917ujg7bg, Owner: 21209065-dc9406f4-c4759fb1-7f9fe8022, Got CP::PingTaskResponse
2025-12-09T03:44:05.808519Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudqgd3dn917ujg7bg, Owner: 21209065-dc9406f4-c4759fb1-7f9fe8022, Request CP::PingTask with size: 202 bytes
2025-12-09T03:44:05.808610Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "21209065-dc9406f4-c4759fb1-7f9fe8022"
query_id {
  value: "ptqudqgd3dn917ujg7bg"
}
transient_issues {
  message: "Parse Sql"
  severity: 2
  issues {
    position {
      row: 9
      column: 41
    }
    message: "Json UDF is deprecated. Please use JSON API instead"
    end_position {
      row: 9
      column: 41
    }
    issue_code: 4506
    severity: 2
  }
}
scope: "yandexcloud://my_folder"
deadline {
  seconds: 1765338245
  nanos: 487497000
}
tenant: "/compute"
}
2025-12-09T03:44:05.818214Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {expired_at { seconds: 1765251865 nanos: 813000000 } } SUCCESS
2025-12-09T03:44:05.818264Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudqgd3dn917ujg7bg, Owner: 21209065-dc9406f4-c4759fb1-7f9fe8022, Got CP::PingTaskResponse
2025-12-09T03:44:05.819215Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudqgd3dn917ujg7bg, Owner: 21209065-dc9406f4-c4759fb1-7f9fe8022, Request CP::PingTask with size: 4495 bytes
2025-12-09T03:44:05.819334Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "21209065-dc9406f4-c4759fb1-7f9fe8022"
query_id {
  value: "ptqudqgd3dn917ujg7bg"
}
dq_graph: "\022\207\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*\232\003Z\227\003\n\010PqSource\022\210\003\n4type.googleapis.com/NYql.NPq.NProto.TDqPqTopicSource\022\317\002\n.test_time_order_recoverer[v1-kikimr0]_v1_input\022\024ptqudqgd3dn917ujg7bg\032\016localhost:8635\"\027\n\025cluster:default_myyds*\005local0\002@\001b\002dtj&[\"OptionalType\";[\"DataType\";\"Uint64\"]]\222\001\024ptcudqgd3dvg6uei38no\232\001\rjson_each_row\242\001>[\"StructType\";[[\"dt\";[\"OptionalType\";[\"DataType\";\"Uint64\"]]]]]\262\001\002\022\000\272\001\026\n\010cloud_id\022\nmock_cloud\272\001 \n\005scope\022\027yandexcloud://my_folder\030\0012D\n@\010\001\020\240\234\001\030\001 \002*\024\n\022\t\000\000\000\000\000\000\000\000\021\000\000\000\000\001\000\000\0002\024\n\022\t\000\000\000\000\000\000\000\000\021\000\000\000\000\002\000\000\000P\001X\367\276\014`\213\277\014R\000:\203\001\n*type.googleapis.com/Yql.DqsProto.TTaskMeta\022U\010\367\276\014\022A\022(2ad8a0198ac871ab3cd73b3e9d43a8d7c87aa707\032\023dq_vanilla_job.lite \002\"\014\n\002pq\022\006\n\004\010\001\030\001H\367\276\014RClocal/RateLimiter_0d9c931a-2c72-4be3-9c55-0c708b358375/rate_limiterZ)mock_cloud/my_folder/ptqudqgd3dn917ujg7bg`\200\200\200\200 \230\001\000\300\001\001\022\207\004\010\002\022\024\n\022\t\000\000\000\000\000\000\000\000\021\000\000\000\000\000\000\000\000\032\004\010\240\215\006*D\n@\010\001\020\240\234\001\030\001 \002*\024\n\022\t\000\000\000\000\000\000\000\000\021\000\000\000\000\001\000\000\0002\024\n\022\t\000\000\000\000\000\000\000\000\021\000\000\000\000\002\000\000\000P\001X\367\276\014`\213\277\014R\0002\251\001z\246\001\n\006PqSink\022\233\001\n2type.googleapis.com/NYql.NPq.NProto.TDqPqTopicSink\022e\n/test_time_order_recoverer[v1-kikimr0]_v1_output\022\016localhost:8635\032\027\n\025cluster:default_myyds\"\005local0\0018\002:u\n*type.googleapis.com/Yql.DqsProto.TTaskMeta\022G\010\213\277\014\022A\022(2ad8a0198ac871ab3cd73b3e9d43a8d7c87aa707\032\023dq_vanilla_job.lite \002H\213\277\014RClocal/RateLimiter_0d9c931a-2c72-4be3-9c55-0c708b358375/rate_limiterZ)mock_cloud/my_folder/ptqudqgd3dn917ujg7bg`\200\200\200\200 \230\001\000\300\001\0012qptqudqgd3dn917ujg7bg#ptrudqgd3ct7r29pooqt#yandexcloud://my_folder#21209065-dc9406f4-c4759fb1-7f9fe8022#mock_cloud:\027\n\016FallbackPolicy\022\005never:\024\n\017_LiteralTimeout\022\0010:\022\n\r_TableTimeout\022\0010:\027\n\022_RowsLimitPerWrite\022\0010:\027\n\022EnableComputeActor\022\0011:\016\n\014WorkerFilter:\031\n\020ComputeActorType\022\005async:\031\n\016WatermarksMode\022\007disable:\037\n\027WatermarksGranularityMs\022\0041000:$\n\034WatermarksLateArrivalDelayMs\022\0045000:\027\n\022EnableChannelStats\022\0011:\020\n\013ExportStats\022\0011B\'\n\025cluster:default_myyds\022\016{\"no_auth\":\"\"}b\265\003\010\367\276\014\022\256\003\037\004\006Arg\004dt\005\205\006\213\002\204\203\005@\205\000\204\205\002\207\203\010\006\030Inputs(Parameters\034Program\013?\004)\251\000?\002\002\000\010\000)\251\000?\006\002\000\026)\211\002?\016\215?\014 FromFlow\000)\211\006?\034\215\233\002?\n?\n?\014$NarrowMap\000)\211\006?\"\215\205\002?\n\006?&?\n$ExpandMap\000)\211\002?(\204?&\030ToFlow\000)\211\014?,\211\004?,\204\203\005@\207\203\001H\014UDF\002\203\004\203\005@\203\004\203\004?\002\030Apply2\000)\211\010?8\203\005@\200\203\005@\202\014Udf\000\003?D8ClickHouseClient.ParseFormat\213\006\213\002\204\203\005@?\006?&\003?F\252json_each_row{\"data.datetime.formatname\":\"POSIX\",\"data.timestamp.formatname\":\"POSIX\"}\002\017\n\003?:\000\003?<\000\003?>\000\003?@\000?\024\036\014\000\016)\251\000?&\002\000\004)\211\004?\n?&\203\004\030Member\000?f\003?h\000\002\006\000\020)\251\000?\n\002\000\002\005?\014?t\000\004\022\000\024\001/b\202\021\010\213\277\014\022\373\020\037$\nFlags\010Name\010Args\016Payload\000\006Udf\014Apply2\004dt\006Arg\014Unwrap\nIndex\024SourceType\014Lookup\014Member\014Invoke\016Collect\014ToFlow\006Map\005\205\006\213\002\204\205\002\207\203\010\036\205\000\204\205\002\203\005@\034column0\030Inputs(Parameters\034Program\013?\010)\251\000?\006\"\000`\000)\251\000?\n\"\000p)\211\002?\020\215?\016 FromFlow\000)\211\006?\036\215\205\002?\002\036?\"?\016F\000)\211(?$\215\205\002?\002\036?(\213\000\206\203\004\206\205\006\203\001H\203\010?\002<_yql_Classifier@_yql_MatchNumber\036\206?.\203\004\205\002\206\205\004\203\010\203\010\020From\010To ALL_TRUE\206?.?\002\213\002\213\002\213\014\203\005@\203\010\203\010\203\014\203\014\203\014\203\010\206?(\206\203\005@\203\014\203\014\203\002\203\005@\203\002\206\205\004\203\010\203\002*.HMatchRecognizeCore\000)\211\006?*\215\205\004\203\014?\002<_yql_OutOfOrder\036?z?((OrderedMap\000)\211\006?|?|?z?x4OrderedFilter\000)\211\020?|\215?\004?\004\207\203d\203\004\203\004\203f\203f\203\004@TimeOrderRecover\000)\211\002?\202?\006B\000?\026\000b)\251\000?\004\"\000Z)\211\004?\206\203\005@?\002:\000\003?\234\024ToIntegral)\211\004?\002?\004\203\0046\000?\232\003?\242\000\002\\\001^\003?\210\002\003?\212\000\003?\214\373#\364\003?\216\003$\364\003?\220\003\022z\370d)\251\000?z\"\000T)\211\002?x?x\014Not\000)\211\004?x?z\203\0046\000?\272\003?\276\000\002V\000X\000f)\251\000?z\"\000P\005?()\211\004?\002?z\203\0046\000?\314\003?\316\002\002R\000\004h)\251\000?(\"\000N\013\213\000\006\000?0)\251\000?8\"\000\036\006\004?:\003\203\004\000\003\203\004\002\003\003?<\002)\251\000?F\"\000:\006\002?H\003\203\004\000\001)\211\004?\002\207\205\002?\002\024Last0\203\0046\000)\211\002?\001\002\206?\376\020Head\000)\211\006?\r\002\206?\002?\002?\376F\000)\211\002?\025\002\215?\002>\000)\211\014?\035\002\215?>?>?\002?\002\203\014?\002$Condense1\000)\211\002?%\002\206?>B\000)\211\002?1\002\206?>>\000)\211\006?9\002?D?B\206?>8OrderedFlatMap\000)\211\004?D?F\203\0046\000?\366\003?I\002\000\002<)\251\000?B\"\0000)\211\006?A\002?>\203\010\203\0064ListFromRange\000)\211\004?>?B\203\0046\000?]\002\003?m\002\000\0026)\211\006?a\002\203\005@?@\203\010:\000\003?}\002\006Add)\211\004?@?B\203\0046\000?]\002\003?\215\002\002\0022\003?\201\002\002\0054\003?e\002\004\0048\000>\000@\000B)\251\000?>\"\000\034)\211\004?\002?6\203\0046\000)\211\n?6\207?6\203\005@\203\005@\203\004\203\004&\000)\211\004?\311\002\210\203\010?6?>2\000)\211\002?\345\002?8,ToIndexDict\000?\346\000 ?\275\002\000*\003?\315\002\000\003?\321\002\000\003?\325\002(\003?\331\002\"\036,\003?\301\002\004\002.)\251\000?\002\"\000\032\003?)\002\000)\211\004?\002?\002?\002 Coalesce\000)\211\004?\002?6\203\0046\000)\211\n?6\207?6\203\005@\203\005@\203\004\203\004&\000)\211\004?-\003?\345\002?>2\000?\361\002?\275\002\000\"\003?1\003\000\003?5\003\000\003?9\003(\003?=\003\"\036$\003?%\003\004\002&?\031\003\000(\020D\000F)\251\000?\002\"\000\030\005?\376?y\003\000\004H\000J\003?\005\002\000\002L\013?Z\013?X\013?V\003?J\020ALL_TRUE\003?L\002\003?N\002\003?P\001\003?R\001\003?T\000?\001\001)\251\000?\\\"\000\026)\251\000?^\"\000\024\006\002?b\003\203\005@\020ALL_TRUE\001\003?d\001\003?f\001\003?h\004\003?j\000\003?l\000\006\002?t\005\205\004\203\010\203\002*.\003?\345\003\000\003?\351\003\004\003\001l\345\017j)\251\000?\"\"\000\006\005?\016)\211\002?\014\203\tH\034ToBytes\000)\211\n?\r\004\207?\r\004\203\005@\203\005@\203\004\203\004&\000)\211\016?\025\004\311\n?\025\004\214(Yson2.Node\207\2144Yson2.Options\207\203\014?=\004?=\004\005\205\004\206\205\004\203\010\203\005@\002\006\203\005@\n\016\006\n?M\004\005\205\004\203\010\203\005@\002\006\003?Y\004\002\003?]\004\000\003\005\205\004\203\010\203\005@\002\006\003?q\004\000\003?u\004\000\003\005\205\004\203\010\203\005@\002\006\003?\211\004\000\003?\215\004\032SkipMapEntity\003\005\205\004\203\010\203\005@\002\006\003?\241\004\000\003?\245\004\024EncodeUtf8\003\005\205\004\203\010\203\005@\002\006\003?\271\004\000\003?\275\004 WriteNanAsString\003\037\003?Q\004\000\003\022\010\203\004\203\005@\203\004\203\004?-\004\207?1\004\032\000)\211\016?\335\004\203\005@\200\203\005@\202\203\005@\203\004\203\004\026\000\003?\371\004&Yson2.SerializeJson\202\003?\375\004\000\002\003?\001\005\000\003?\005\005\022\003?\t\005R\177\014\003?\341\004\000\003?\345\004\000\003?\351\004\022\003?\355\004R)\211\014?-\004\211\002?-\004\205\002\207\203\010\036\022\000\203\004\203\005@\203\004\203\004?\"\032\000)\211\016?E\005\203\005@\200\203\005@\202\203\005@\203\004\203\004\026\000\003?]\005\024Yson2.From\213\006\213\002?A\005?\n\213\000\003?a\005\000\002\003?e\005\000\003?i\005\022\003?m\005z\177\010\003?I\005\000\003?M\005\000\003?Q\005\022\003?U\005z?\t\004\036\n\027?\361\004)\211\016?1\004\311\004?1\004?=\004?=\004\005\205\004\206\205\004\203\010\203\005@\002\006\203\005@\n\016\006\004?\271\005\005\205\004\203\010\203\005@\002\006\003?\305\005\000\003?\311\005\026AutoConvert\003\005\205\004\203\010\203\005@\002\006\003?\335\005\000\003?\341\005\014Strict\003\003\003?\275\005\000\003\022\004\203\004\203\005@\203\004\203\004\207?)\002\207?d\032\000)\211\016?\001\006\203\005@\200\203\005@\202\203\005@\203\004\203\004\026\000\003?!\006\032Yson2.Options\202\003?%\006\000\002\003?)\006\000\003?-\006\022\003?1\006R\177\002\003?\005\006\000\003?\t\006\000\003?\r\006\022\003?\021\006R7?\025\006?\035\0037?\031\006?\321\003~\004^\016\003?\031\004\000\003?\035\004\000\003?!\004\022\003?%\0048\036\020\000\022\000\004l\000n\001/"
scope: "yandexcloud://my_folder"
deadline {
  seconds: 1765338245
  nanos: 487497000
}
tenant: "/compute"
}
2025-12-09T03:44:05.832067Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {expired_at { seconds: 1765251865 nanos: 824000000 } } SUCCESS
2025-12-09T03:44:05.832109Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudqgd3dn917ujg7bg, Owner: 21209065-dc9406f4-c4759fb1-7f9fe8022, Got CP::PingTaskResponse
2025-12-09T03:44:05.833196Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudqgd3dn917ujg7bg, Owner: 21209065-dc9406f4-c4759fb1-7f9fe8022, Request CP::PingTask with size: 315 bytes
2025-12-09T03:44:05.833316Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "21209065-dc9406f4-c4759fb1-7f9fe8022"
query_id {
  value: "ptqudqgd3dn917ujg7bg"
}
status: RUNNING
resources {
  rate_limiter: READY
  compilation: READY
  topic_consumers_state: PREPARE
  rate_limiter_path: "local/RateLimiter_0d9c931a-2c72-4be3-9c55-0c708b358375/rate_limiter"
  topic_consumers {
    database: "local"
    topic_path: "test_time_order_recoverer[v1-kikimr0]_v1_input"
    consumer_name: "ptqudqgd3dn917ujg7bg"
    cluster_endpoint: "localhost:8635"
    token_name: "cluster:default_myyds"
    add_bearer_to_token: true
  }
}
scope: "yandexcloud://my_folder"
deadline {
  seconds: 1765338245
  nanos: 487497000
}
tenant: "/compute"
}
2025-12-09T03:44:05.844804Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {expired_at { seconds: 1765251865 nanos: 839000000 } } SUCCESS
2025-12-09T03:44:05.844853Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudqgd3dn917ujg7bg, Owner: 21209065-dc9406f4-c4759fb1-7f9fe8022, Got CP::PingTaskResponse
2025-12-09T03:44:05.848702Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudqgd3dn917ujg7bg, Owner: 21209065-dc9406f4-c4759fb1-7f9fe8022, Request CP::PingTask with size: 315 bytes
2025-12-09T03:44:05.848801Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "21209065-dc9406f4-c4759fb1-7f9fe8022"
query_id {
  value: "ptqudqgd3dn917ujg7bg"
}
status: RUNNING
resources {
  rate_limiter: READY
  compilation: READY
  topic_consumers_state: READY
  rate_limiter_path: "local/RateLimiter_0d9c931a-2c72-4be3-9c55-0c708b358375/rate_limiter"
  topic_consumers {
    database: "local"
    topic_path: "test_time_order_recoverer[v1-kikimr0]_v1_input"
    consumer_name: "ptqudqgd3dn917ujg7bg"
    cluster_endpoint: "localhost:8635"
    token_name: "cluster:default_myyds"
    add_bearer_to_token: true
  }
}
scope: "yandexcloud://my_folder"
deadline {
  seconds: 1765338245
  nanos: 487497000
}
tenant: "/compute"
}
2025-12-09T03:44:05.861320Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {expired_at { seconds: 1765251865 nanos: 855000000 } } SUCCESS
2025-12-09T03:44:05.861360Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudqgd3dn917ujg7bg, Owner: 21209065-dc9406f4-c4759fb1-7f9fe8022, Got CP::PingTaskResponse
2025-12-09T03:44:05.933458Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudqgd3dn917ujg7bg"
2025-12-09T03:44:05.933503Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:305: Resolve folder bootstrap. Folder id: my_folder Actor id: [1:7581698944415540822:2234]
2025-12-09T03:44:05.933540Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:367: Cloud id: mock_cloud Folder id: my_folder
2025-12-09T03:44:05.933566Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:91: Get quotas bootstrap. Cloud id: mock_cloud Actor id: [1:7581698944415540823:2235]
2025-12-09T03:44:05.933594Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.analyticsQuery.count IS STALE, Refreshing ...
2025-12-09T03:44:05.933607Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.cpuPercent.count IS STALE, Refreshing ...
2025-12-09T03:44:05.933610Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.streamingQuery.count IS STALE, Refreshing ...
2025-12-09T03:44:05.933639Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.cpuPercent.count=0/10000 REFRESHED
2025-12-09T03:44:05.937257Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.analyticsQuery.count=0/100 REFRESHED
2025-12-09T03:44:05.937285Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.streamingQuery.count=1/100 REFRESHED
2025-12-09T03:44:05.937308Z :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-09T03:44:05.937317Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:103: Cloud id: mock_cloud Quota count: 8
2025-12-09T03:44:05.937353Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudqgd3dn917ujg7bg"
2025-12-09T03:44:05.937405Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:169: Resolve subject type bootstrap. Token: **** (B6C6F477) Actor id: [1:7581698944415540828:2240]
2025-12-09T03:44:05.937435Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:230: Subject Type: federated_account Token: **** (B6C6F477)
2025-12-09T03:44:05.937460Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudqgd3dn917ujg7bg"
2025-12-09T03:44:05.937509Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:63: Request actor. Actor id: [1:7581698944415540829:2241]
2025-12-09T03:44:05.937573Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_queries.cpp:641: DescribeQueryRequest: {query_id: "ptqudqgd3dn917ujg7bg"
} [root@builtin, **** (B6C6F477)] 
2025-12-09T03:44:05.939209Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: DescribeQueryRequest - DescribeQueryResult: {query { meta { common { id: "ptqudqgd3dn917ujg7bg" created_by: "root@builtin" modified_by: "root@builtin" created_at { seconds: 1765251844 nanos: 692875000 } modified_at { seconds: 1765251844 nanos: 692875000 } revision: 1 } started_at { seconds: 1765251845 nanos: 546000000 } execute_mode: RUN status: RUNNING last_job_query_revision: 1 last_job_id: "ptjudqgd3dn911n5hs81-ptqudqgd3dn917ujg7bg" started_by: "root@builtin" submitted_at { seconds: 1765251844 nanos: 692875000 } } content { type: STREAMING name: "simple" acl { visibility: PRIVATE } limits { execution_timeout { } } text: "\n            PRAGMA dq.MaxTasksPerStage=\"2\";\n\n            pragma FeatureR010=\"prototype\";\n            pragma config.flags(\"TimeOrderRecoverDelay\", \"-1000000\");\n            pragma config.flags(\"TimeOrderRecoverAhead\", \"1000000\");\n\n            INSERT INTO myyds.`test_time_order_recoverer[v1-kikimr0]_v1_output`\n            SELECT ToBytes(Unwrap(Json::SerializeJson(Yson::From(TableRow()))))\n            FROM (SELECT * FROM myyds.`test_time_order_recoverer[v1-kikimr0]_v1_input`\n                WITH (\n                    format=json_each_row,\n                    SCHEMA\n                    (\n                        dt UINT64\n                    )))\n            MATCH_RECOGNIZE(\n                ORDER BY CAST(dt as Timestamp)\n                MEASURES\n                LAST(ALL_TRUE.dt) as dt\n                ONE ROW PER MATCH\n                PATTERN ( ALL_TRUE )\n                DEFINE\n                    ALL_TRUE as True)" syntax: YQL_V1 } plan { json: "{\"Detailed\":{\"Operations\":[{\"Id\":5,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[{\"Name\":\"DqSourceWideWrap\"},{\"Name\":\"NarrowMap\"}]}},{\"Id\":3,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[{\"Name\":\"TimeOrderRecover\"},{\"Name\":\"OrderedFlatMap\"},{\"Name\":\"MatchRecognizeCore\"},{\"Name\":\"FlatMap\"},{\"Name\":\"FromFlow\"}]},\"DependsOn\":[5]},{\"Id\":2,\"Name\":\"DqQuery!\",\"DependsOn\":[3]},{\"Id\":1,\"Name\":\"Commit!\",\"DependsOn\":[2]}],\"OperationRoot\":1,\"Providers\":[],\"OperationStats\":{\"Commit!\":1,\"DqQuery!\":1,\"DqStage\":2}},\"Basic\":{\"nodes\":[{\"id\":5,\"level\":1,\"name\":\"DqStage #5\",\"type\":\"op\"},{\"id\":3,\"level\":2,\"name\":\"DqStage #3\",\"type\":\"op\"},{\"id\":2,\"level\":3,\"name\":\"DqQuery!\",\"type\":\"op\"},{\"id\":1,\"level\":4,\"name\":\"Commit!\",\"type\":\"op\"}],\"links\":[{\"source\":5,\"target\":3},{\"source\":3,\"target\":2},{\"source\":2,\"target\":1}]}}" } transient_issue { message: "Parse Sql" severity: 2 issues { position { row: 9 column: 41 } message: "Json UDF is deprecated. Please use JSON API instead" end_position { row: 9 column: 41 } issue_code: 4506 severity: 2 } } ast { data: "(\n(let $1 (DataSource \'\"config\"))\n(let $2 (Configure! world $1 \'\"DqEngine\" \'\"force\"))\n(let $3 (Configure! $2 (DataSource \'\"dq\" \'\"$all\") \'\"Attr\" \'\"maxtasksperstage\" \'\"2\"))\n(let $4 (Configure! $3 $1 \'\"TimeOrderRecoverDelay\" \'\"-1000000\"))\n(let $5 (Configure! $4 $1 \'\"TimeOrderRecoverAhead\" \'\"1000000\"))\n(let $6 (DataSource \'\"pq\" \'\"myyds\"))\n(let $7 \'(\'(\'\"PartitionsCount\" \'1)))\n(let $8 (StructType \'(\'dt (OptionalType (DataType \'Uint64)))))\n(let $9 (PqTopic \'\"myyds\" \'\"local\" \'\"test_time_order_recoverer[v1-kikimr0]_v1_input\" $7 \'() $8))\n(let $10 \'(\'dt))\n(let $11 \'(\'\"Endpoint\" \'\"localhost:8635\"))\n(let $12 \'(\'\"SharedReading\" \'0))\n(let $13 \'(\'\"AddBearerToToken\" \'1))\n(let $14 \'($11 $12 \'(\'\"ReconnectPeriod\" \'\"\") \'(\'\"Format\" \'\"json_each_row\") \'(\'\"ReadGroup\" \'\"ptcudqgd3dvg6uei38no\") $13))\n(let $15 (SecureParam \'\"cluster:default_myyds\"))\n(let $16 (DqPqTopicSource $5 $9 $10 $14 $15 \'\"\" $8 \'\"\"))\n(let $17 (DqStage \'((DqSource $6 $16)) (lambda \'($21) (block \'(\n  (let $22 \'(\'(\'\"format\" \'\"json_each_row\") \'(\'\"formatSettings\" \'(\'(\'\"data.datetime.formatname\" \'\"POSIX\") \'(\'\"data.timestamp.formatname\" \'\"POSIX\"))) \'(\'\"settings\" \'($12))))\n  (let $23 (DqSourceWideWrap $21 $6 $8 $22))\n ...} SUCCESS
2025-12-09T03:44:05.939257Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.cpuPercent.count=0/10000 NOTIFY CHANGE
2025-12-09T03:44:05.942304Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.streamingQuery.count=1/100 NOTIFY CHANGE
2025-12-09T03:44:05.942331Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.analyticsQuery.count=0/100 NOTIFY CHANGE
2025-12-09T03:44:06.113460Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudqgd3dn917ujg7bg, Owner: 21209065-dc9406f4-c4759fb1-7f9fe8022, Request CP::PingTask with size: 122 bytes
2025-12-09T03:44:06.113545Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "21209065-dc9406f4-c4759fb1-7f9fe8022"
query_id {
  value: "ptqudqgd3dn917ujg7bg"
}
state_load_mode: FROM_LAST_CHECKPOINT
disposition {
  from_last_checkpoint {
  }
}
scope: "yandexcloud://my_folder"
deadline {
  seconds: 1765338245
  nanos: 487497000
}
tenant: "/compute"
}
2025-12-09T03:44:06.124230Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {expired_at { seconds: 1765251866 nanos: 119000000 } } SUCCESS
2025-12-09T03:44:06.124262Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudqgd3dn917ujg7bg, Owner: 21209065-dc9406f4-c4759fb1-7f9fe8022, Got CP::PingTaskResponse
2025-12-09T03:44:06.440199Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 21209065-dc9406f4-c4759fb1-7f9fe8024, Host: ghrun-syjwtgwtdu, Tenant: /compute, Request CP::GetTask with size: 68 bytes
2025-12-09T03:44:06.440269Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "21209065-dc9406f4-c4759fb1-7f9fe8024"
host: "ghrun-syjwtgwtdu"
node_id: 1
}
2025-12-09T03:44:06.447355Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-09T03:44:06.447393Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 21209065-dc9406f4-c4759fb1-7f9fe8024, Host: ghrun-syjwtgwtdu, Tenant: /compute, Got CP::GetTask Response
2025-12-09T03:44:06.720077Z :FQ_CONTROL_PLANE_CONFIG TRACE: control_plane_config.cpp:192: LOADED TenantInfo: State NOT changed
2025-12-09T03:44:06.855202Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudqgd3dn917ujg7bg, Owner: 21209065-dc9406f4-c4759fb1-7f9fe8022, Request CP::PingTask with size: 591 bytes
2025-12-09T03:44:06.855296Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "21209065-dc9406f4-c4759fb1-7f9fe8022"
query_id {
  value: "ptqudqgd3dn917ujg7bg"
}
statistics: "{\"Graph=0\":{\"TaskRunner\":{\"Stage=204663\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":1,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":1,\"count\":1,\"avg\":1,\"max\":1,\"min\":1}},\"Stage=204683\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":1,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":1,\"count\":1,\"avg\":1,\"max\":1,\"min\":1}},\"Stage=Total\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":2,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":2,\"count\":2,\"avg\":1,\"max\":1,\"min\":1}}}}}"
scope: "yandexcloud://my_folder"
deadline {
  seconds: 1765338245
  nanos: 487497000
}
tenant: "/compute"
}
2025-12-09T03:44:06.865645Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {expired_at { seconds: 1765251866 nanos: 860000000 } } SUCCESS
2025-12-09T03:44:06.865702Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudqgd3dn917ujg7bg, Owner: 21209065-dc9406f4-c4759fb1-7f9fe8022, Got CP::PingTaskResponse
2025-12-09T03:44:07.440670Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 21209065-dc9406f4-c4759fb1-7f9fe8025, Host: ghrun-syjwtgwtdu, Tenant: /compute, Request CP::GetTask with size: 68 bytes
2025-12-09T03:44:07.440729Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "21209065-dc9406f4-c4759fb1-7f9fe8025"
host: "ghrun-syjwtgwtdu"
node_id: 1
}
2025-12-09T03:44:07.443481Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-09T03:44:07.443517Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 21209065-dc9406f4-c4759fb1-7f9fe8025, Host: ghrun-syjwtgwtdu, Tenant: /compute, Got CP::GetTask Response
2025-12-09T03:44:07.712491Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7581698935825606080:2093]
2025-12-09T03:44:07.712513Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-09T03:44:07.712522Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7581698935825606039:2068]
2025-12-09T03:44:07.712526Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7581698935825606039:2068]
2025-12-09T03:44:07.712530Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7581698935825606039:2068]
2025-12-09T03:44:07.712540Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-09T03:44:08.711904Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:665: Coordinator: Change global state to Started (by timeout)
2025-12-09T03:44:09.164415Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 8ed2cde7-9c80fbf5-fce4b698-d3d7611d1, Host: ghrun-syjwtgwtdu, Tenant: /compute, Request CP::GetTask with size: 68 bytes
2025-12-09T03:44:09.164456Z :YQ_CONTROL_PLANE_STORAGE TRACE: nodes_health_check.cpp:38: NodesHealthCheckRequest: {tenant: "/compute"
node {
  node_id: 1
  instance_id: "c0cfbd49-4780a55d-9bf48eba-aae48d5"
  hostname: "ghrun-syjwtgwtdu"
  interconnect_port: 62714
  node_address: "127.0.1.1"
}
}
2025-12-09T03:44:09.164537Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "8ed2cde7-9c80fbf5-fce4b698-d3d7611d1"
host: "ghrun-syjwtgwtdu"
node_id: 1
}
2025-12-09T03:44:09.167442Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-09T03:44:09.167478Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 8ed2cde7-9c80fbf5-fce4b698-d3d7611d1, Host: ghrun-syjwtgwtdu, Tenant: /compute, Got CP::GetTask Response
2025-12-09T03:44:09.170105Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: NodesHealthCheckRequest - NodesHealthCheckResult: {nodes { node_id: 1 instance_id: "c0cfbd49-4780a55d-9bf48eba-aae48d5" hostname: "ghrun-syjwtgwtdu" node_address: "127.0.1.1" } } SUCCESS
2025-12-09T03:44:09.713382Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7581698935825606080:2093]
2025-12-09T03:44:09.713424Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-09T03:44:09.713431Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7581698935825606039:2068]
2025-12-09T03:44:09.713434Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7581698935825606039:2068]
2025-12-09T03:44:09.713438Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7581698935825606039:2068]
2025-12-09T03:44:09.713447Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-09T03:44:09.720609Z :FQ_CONTROL_PLANE_CONFIG TRACE: control_plane_config.cpp:192: LOADED TenantInfo: State NOT changed
2025-12-09T03:44:10.157680Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 8ed2cde7-9c80fbf5-fce4b698-d3d7611d2, Host: ghrun-syjwtgwtdu, Tenant: /compute, Request CP::GetTask with size: 68 bytes
2025-12-09T03:44:10.157732Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "8ed2cde7-9c80fbf5-fce4b698-d3d7611d2"
host: "ghrun-syjwtgwtdu"
node_id: 1
}
2025-12-09T03:44:10.160908Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-09T03:44:10.160945Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 8ed2cde7-9c80fbf5-fce4b698-d3d7611d2, Host: ghrun-syjwtgwtdu, Tenant: /compute, Got CP::GetTask Response
2025-12-09T03:44:10.213869Z :TICKET_PARSER DEBUG: ticket_parser_impl.h:1875: Ticket **** (B6C6F477) (ipv6:[::1]:47260) has now valid token of root@builtin
2025-12-09T03:44:10.214060Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:852: GetStatusRequest: query_id: "ptqudqgd3dn917ujg7bg"
2025-12-09T03:44:10.214104Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:305: Resolve folder bootstrap. Folder id: my_folder Actor id: [1:7581698965890377336:2267]
2025-12-09T03:44:10.214129Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:367: Cloud id: mock_cloud Folder id: my_folder
2025-12-09T03:44:10.214169Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:91: Get quotas bootstrap. Cloud id: mock_cloud Actor id: [1:7581698965890377337:2268]
2025-12-09T03:44:10.214201Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.analyticsQuery.count IS STALE, Refreshing ...
2025-12-09T03:44:10.214212Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.cpuPercent.count IS STALE, Refreshing ...
2025-12-09T03:44:10.214221Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.streamingQuery.count IS STALE, Refreshing ...
2025-12-09T03:44:10.214236Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.cpuPercent.count=0/10000 REFRESHED
2025-12-09T03:44:10.219314Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.analyticsQuery.count=0/100 REFRESHED
2025-12-09T03:44:10.219345Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.streamingQuery.count=1/100 REFRESHED
2025-12-09T03:44:10.219374Z :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-09T03:44:10.219386Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:103: Cloud id: mock_cloud Quota count: 8
2025-12-09T03:44:10.219420Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:852: GetStatusRequest: query_id: "ptqudqgd3dn917ujg7bg"
2025-12-09T03:44:10.219485Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:169: Resolve subject type bootstrap. Token: **** (B6C6F477) Actor id: [1:7581698965890377342:2273]
2025-12-09T03:44:10.219530Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:230: Subject Type: federated_account Token: **** (B6C6F477)
2025-12-09T03:44:10.219560Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:852: GetStatusRequest: query_id: "ptqudqgd3dn917ujg7bg"
2025-12-09T03:44:10.219602Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:63: Request actor. Actor id: [1:7581698965890377343:2274]
2025-12-09T03:44:10.219664Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_queries.cpp:725: GetQueryStatusRequest: {query_id: "ptqudqgd3dn917ujg7bg"
} [root@builtin, **** (B6C6F477)] 
2025-12-09T03:44:10.220923Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.cpuPercent.count=0/10000 NOTIFY CHANGE
2025-12-09T03:44:10.227298Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.analyticsQuery.count=0/100 NOTIFY CHANGE
2025-12-09T03:44:10.227431Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.streamingQuery.count=1/100 NOTIFY CHANGE
2025-12-09T03:44:10.263230Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetQueryStatusRequest - GetQueryStatusResult: {status: RUNNING meta_revision: 10 } SUCCESS
2025-12-09T03:44:11.160130Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 8ed2cde7-9c80fbf5-fce4b698-d3d7611d3, Host: ghrun-syjwtgwtdu, Tenant: /compute, Request CP::GetTask with size: 68 bytes
2025-12-09T03:44:11.160195Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "8ed2cde7-9c80fbf5-fce4b698-d3d7611d3"
host: "ghrun-syjwtgwtdu"
node_id: 1
}
2025-12-09T03:44:11.163739Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-09T03:44:11.163797Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 8ed2cde7-9c80fbf5-fce4b698-d3d7611d3, Host: ghrun-syjwtgwtdu, Tenant: /compute, Got CP::GetTask Response
2025-12-09T03:44:11.714261Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7581698935825606080:2093]
2025-12-09T03:44:11.714285Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-09T03:44:11.714294Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7581698935825606039:2068]
2025-12-09T03:44:11.714299Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7581698935825606039:2068]
2025-12-09T03:44:11.714301Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7581698935825606039:2068]
2025-12-09T03:44:11.714312Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-09T03:44:12.159610Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 8ed2cde7-9c80fbf5-fce4b698-d3d7611d4, Host: ghrun-syjwtgwtdu, Tenant: /compute, Request CP::GetTask with size: 68 bytes
2025-12-09T03:44:12.159676Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "8ed2cde7-9c80fbf5-fce4b698-d3d7611d4"
host: "ghrun-syjwtgwtdu"
node_id: 1
}
2025-12-09T03:44:12.162488Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-09T03:44:12.162549Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 8ed2cde7-9c80fbf5-fce4b698-d3d7611d4, Host: ghrun-syjwtgwtdu, Tenant: /compute, Got CP::GetTask Response
2025-12-09T03:44:12.721007Z :FQ_CONTROL_PLANE_CONFIG TRACE: control_plane_config.cpp:192: LOADED TenantInfo: State NOT changed
2025-12-09T03:44:13.159973Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 8ed2cde7-9c80fbf5-fce4b698-d3d7611d5, Host: ghrun-syjwtgwtdu, Tenant: /compute, Request CP::GetTask with size: 68 bytes
2025-12-09T03:44:13.160061Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "8ed2cde7-9c80fbf5-fce4b698-d3d7611d5"
host: "ghrun-syjwtgwtdu"
node_id: 1
}
2025-12-09T03:44:13.162745Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-09T03:44:13.162780Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 8ed2cde7-9c80fbf5-fce4b698-d3d7611d5, Host: ghrun-syjwtgwtdu, Tenant: /compute, Got CP::GetTask Response
2025-12-09T03:44:13.712102Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:599: Coordinator: Send TEvGetNodesRequest to NodesManager
2025-12-09T03:44:13.712122Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:416: Coordinator: TEvUndelivered, ev: TSystem::Undelivered
2025-12-09T03:44:13.712125Z :FQ_ROW_DISPATCHER INFO: coordinator.cpp:419: Coordinator: TEvUndelivered, from nodes manager, reason: ActorUnknown
2025-12-09T03:44:13.715166Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7581698935825606080:2093]
2025-12-09T03:44:13.715187Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-09T03:44:13.715196Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7581698935825606039:2068]
2025-12-09T03:44:13.715200Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7581698935825606039:2068]
2025-12-09T03:44:13.715204Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7581698935825606039:2068]
2025-12-09T03:44:13.715219Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-09T03:44:14.157563Z :YQ_CONTROL_PLANE_STORAGE TRACE: nodes_health_check.cpp:38: NodesHealthCheckRequest: {tenant: "/compute"
node {
  node_id: 1
  instance_id: "c0cfbd49-4780a55d-9bf48eba-aae48d5"
  hostname: "ghrun-syjwtgwtdu"
  interconnect_port: 62714
  node_address: "127.0.1.1"
}
}
2025-12-09T03:44:14.160271Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 8ed2cde7-9c80fbf5-fce4b698-d3d7611d6, Host: ghrun-syjwtgwtdu, Tenant: /compute, Request CP::GetTask with size: 68 bytes
2025-12-09T03:44:14.160330Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "8ed2cde7-9c80fbf5-fce4b698-d3d7611d6"
host: "ghrun-syjwtgwtdu"
node_id: 1
}
2025-12-09T03:44:14.162765Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-09T03:44:14.162802Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 8ed2cde7-9c80fbf5-fce4b698-d3d7611d6, Host: ghrun-syjwtgwtdu, Tenant: /compute, Got CP::GetTask Response
2025-12-09T03:44:14.166093Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: NodesHealthCheckRequest - NodesHealthCheckResult: {nodes { node_id: 1 instance_id: "c0cfbd49-4780a55d-9bf48eba-aae48d5" hostname: "ghrun-syjwtgwtdu" node_address: "127.0.1.1" } } SUCCESS
2025-12-09T03:44:15.161017Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 8ed2cde7-9c80fbf5-fce4b698-d3d7611d7, Host: ghrun-syjwtgwtdu, Tenant: /compute, Request CP::GetTask with size: 68 bytes
2025-12-09T03:44:15.161089Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "8ed2cde7-9c80fbf5-fce4b698-d3d7611d7"
host: "ghrun-syjwtgwtdu"
node_id: 1
}
2025-12-09T03:44:15.166516Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-09T03:44:15.166554Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 8ed2cde7-9c80fbf5-fce4b698-d3d7611d7, Host: ghrun-syjwtgwtdu, Tenant: /compute, Got CP::GetTask Response
2025-12-09T03:44:15.716086Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7581698935825606080:2093]
2025-12-09T03:44:15.716113Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-09T03:44:15.716127Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7581698935825606039:2068]
2025-12-09T03:44:15.716131Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7581698935825606039:2068]
2025-12-09T03:44:15.716134Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7581698935825606039:2068]
2025-12-09T03:44:15.716143Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-09T03:44:15.724073Z :FQ_CONTROL_PLANE_CONFIG TRACE: control_plane_config.cpp:192: LOADED TenantInfo: State NOT changed
2025-12-09T03:44:16.161532Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 8ed2cde7-9c80fbf5-fce4b698-d3d7611d8, Host: ghrun-syjwtgwtdu, Tenant: /compute, Request CP::GetTask with size: 68 bytes
2025-12-09T03:44:16.161600Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "8ed2cde7-9c80fbf5-fce4b698-d3d7611d8"
host: "ghrun-syjwtgwtdu"
node_id: 1
}
2025-12-09T03:44:16.165095Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-09T03:44:16.165143Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 8ed2cde7-9c80fbf5-fce4b698-d3d7611d8, Host: ghrun-syjwtgwtdu, Tenant: /compute, Got CP::GetTask Response
2025-12-09T03:44:17.161830Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 8ed2cde7-9c80fbf5-fce4b698-d3d7611d9, Host: ghrun-syjwtgwtdu, Tenant: /compute, Request CP::GetTask with size: 68 bytes
2025-12-09T03:44:17.161907Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "8ed2cde7-9c80fbf5-fce4b698-d3d7611d9"
host: "ghrun-syjwtgwtdu"
node_id: 1
}
2025-12-09T03:44:17.164842Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-09T03:44:17.164915Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 8ed2cde7-9c80fbf5-fce4b698-d3d7611d9, Host: ghrun-syjwtgwtdu, Tenant: /compute, Got CP::GetTask Response
2025-12-09T03:44:17.716956Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7581698935825606080:2093]
2025-12-09T03:44:17.716971Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-09T03:44:17.716979Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7581698935825606039:2068]
2025-12-09T03:44:17.716983Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7581698935825606039:2068]
2025-12-09T03:44:17.716986Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7581698935825606039:2068]
2025-12-09T03:44:17.716997Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-09T03:44:18.162393Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 8ed2cde7-9c80fbf5-fce4b698-d3d7611d10, Host: ghrun-syjwtgwtdu, Tenant: /compute, Request CP::GetTask with size: 69 bytes
2025-12-09T03:44:18.162472Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "8ed2cde7-9c80fbf5-fce4b698-d3d7611d10"
host: "ghrun-syjwtgwtdu"
node_id: 1
}
2025-12-09T03:44:18.165475Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-09T03:44:18.165507Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 8ed2cde7-9c80fbf5-fce4b698-d3d7611d10, Host: ghrun-syjwtgwtdu, Tenant: /compute, Got CP::GetTask Response
2025-12-09T03:44:18.724745Z :FQ_CONTROL_PLANE_CONFIG TRACE: control_plane_config.cpp:192: LOADED TenantInfo: State NOT changed
2025-12-09T03:44:19.157873Z :YQ_CONTROL_PLANE_STORAGE TRACE: nodes_health_check.cpp:38: NodesHealthCheckRequest: {tenant: "/compute"
node {
  node_id: 1
  instance_id: "c0cfbd49-4780a55d-9bf48eba-aae48d5"
  hostname: "ghrun-syjwtgwtdu"
  interconnect_port: 62714
  node_address: "127.0.1.1"
}
}
2025-12-09T03:44:19.162621Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 8ed2cde7-9c80fbf5-fce4b698-d3d7611d11, Host: ghrun-syjwtgwtdu, Tenant: /compute, Request CP::GetTask with size: 69 bytes
2025-12-09T03:44:19.162703Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "8ed2cde7-9c80fbf5-fce4b698-d3d7611d11"
host: "ghrun-syjwtgwtdu"
node_id: 1
}
2025-12-09T03:44:19.164963Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-09T03:44:19.164995Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 8ed2cde7-9c80fbf5-fce4b698-d3d7611d11, Host: ghrun-syjwtgwtdu, Tenant: /compute, Got CP::GetTask Response
2025-12-09T03:44:19.165474Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: NodesHealthCheckRequest - NodesHealthCheckResult: {nodes { node_id: 1 instance_id: "c0cfbd49-4780a55d-9bf48eba-aae48d5" hostname: "ghrun-syjwtgwtdu" node_address: "127.0.1.1" } } SUCCESS
2025-12-09T03:44:19.717855Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7581698935825606080:2093]
2025-12-09T03:44:19.717879Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-09T03:44:19.717888Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7581698935825606039:2068]
2025-12-09T03:44:19.717892Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7581698935825606039:2068]
2025-12-09T03:44:19.717896Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7581698935825606039:2068]
2025-12-09T03:44:19.717908Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-09T03:44:20.163148Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 8ed2cde7-9c80fbf5-fce4b698-d3d7611d12, Host: ghrun-syjwtgwtdu, Tenant: /compute, Request CP::GetTask with size: 69 bytes
2025-12-09T03:44:20.163232Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "8ed2cde7-9c80fbf5-fce4b698-d3d7611d12"
host: "ghrun-syjwtgwtdu"
node_id: 1
}
2025-12-09T03:44:20.166417Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-09T03:44:20.166456Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 8ed2cde7-9c80fbf5-fce4b698-d3d7611d12, Host: ghrun-syjwtgwtdu, Tenant: /compute, Got CP::GetTask Response
2025-12-09T03:44:21.163612Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 8ed2cde7-9c80fbf5-fce4b698-d3d7611d13, Host: ghrun-syjwtgwtdu, Tenant: /compute, Request CP::GetTask with size: 69 bytes
2025-12-09T03:44:21.163678Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "8ed2cde7-9c80fbf5-fce4b698-d3d7611d13"
host: "ghrun-syjwtgwtdu"
node_id: 1
}
2025-12-09T03:44:21.166566Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-09T03:44:21.166616Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 8ed2cde7-9c80fbf5-fce4b698-d3d7611d13, Host: ghrun-syjwtgwtdu, Tenant: /compute, Got CP::GetTask Response
2025-12-09T03:44:21.718771Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7581698935825606080:2093]
2025-12-09T03:44:21.718792Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-09T03:44:21.718808Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7581698935825606039:2068]
2025-12-09T03:44:21.718814Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7581698935825606039:2068]
2025-12-09T03:44:21.718817Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7581698935825606039:2068]
2025-12-09T03:44:21.718835Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-09T03:44:21.722347Z :FQ_CONTROL_PLANE_CONFIG TRACE: control_plane_config.cpp:192: LOADED TenantInfo: State NOT changed
2025-12-09T03:44:22.164041Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 8ed2cde7-9c80fbf5-fce4b698-d3d7611d14, Host: ghrun-syjwtgwtdu, Tenant: /compute, Request CP::GetTask with size: 69 bytes
2025-12-09T03:44:22.164121Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "8ed2cde7-9c80fbf5-fce4b698-d3d7611d14"
host: "ghrun-syjwtgwtdu"
node_id: 1
}
2025-12-09T03:44:22.167404Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-09T03:44:22.167449Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 8ed2cde7-9c80fbf5-fce4b698-d3d7611d14, Host: ghrun-syjwtgwtdu, Tenant: /compute, Got CP::GetTask Response
2025-12-09T03:44:23.164498Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 8ed2cde7-9c80fbf5-fce4b698-d3d7611d15, Host: ghrun-syjwtgwtdu, Tenant: /compute, Request CP::GetTask with size: 69 bytes
2025-12-09T03:44:23.164563Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "8ed2cde7-9c80fbf5-fce4b698-d3d7611d15"
host: "ghrun-syjwtgwtdu"
node_id: 1
}
2025-12-09T03:44:23.167454Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-09T03:44:23.167492Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 8ed2cde7-9c80fbf5-fce4b698-d3d7611d15, Host: ghrun-syjwtgwtdu, Tenant: /compute, Got CP::GetTask Response
2025-12-09T03:44:23.712492Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:416: Coordinator: TEvUndelivered, ev: TSystem::Undelivered
2025-12-09T03:44:23.712502Z :FQ_ROW_DISPATCHER INFO: coordinator.cpp:419: Coordinator: TEvUndelivered, from nodes manager, reason: ActorUnknown
2025-12-09T03:44:23.719608Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7581698935825606080:2093]
2025-12-09T03:44:23.719630Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-09T03:44:23.719639Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7581698935825606039:2068]
2025-12-09T03:44:23.719643Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7581698935825606039:2068]
2025-12-09T03:44:23.719647Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7581698935825606039:2068]
2025-12-09T03:44:23.719656Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-09T03:44:24.158010Z :YQ_CONTROL_PLANE_STORAGE TRACE: nodes_health_check.cpp:38: NodesHealthCheckRequest: {tenant: "/compute"
node {
  node_id: 1
  instance_id: "c0cfbd49-4780a55d-9bf48eba-aae48d5"
  hostname: "ghrun-syjwtgwtdu"
  interconnect_port: 62714
  node_address: "127.0.1.1"
}
}
2025-12-09T03:44:24.164850Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 8ed2cde7-9c80fbf5-fce4b698-d3d7611d16, Host: ghrun-syjwtgwtdu, Tenant: /compute, Request CP::GetTask with size: 69 bytes
2025-12-09T03:44:24.164912Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: NodesHealthCheckRequest - NodesHealthCheckResult: {nodes { node_id: 1 instance_id: "c0cfbd49-4780a55d-9bf48eba-aae48d5" hostname: "ghrun-syjwtgwtdu" node_address: "127.0.1.1" } } SUCCESS
2025-12-09T03:44:24.164916Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "8ed2cde7-9c80fbf5-fce4b698-d3d7611d16"
host: "ghrun-syjwtgwtdu"
node_id: 1
}
2025-12-09T03:44:24.167208Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-09T03:44:24.167237Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 8ed2cde7-9c80fbf5-fce4b698-d3d7611d16, Host: ghrun-syjwtgwtdu, Tenant: /compute, Got CP::GetTask Response
2025-12-09T03:44:24.722135Z :FQ_CONTROL_PLANE_CONFIG TRACE: control_plane_config.cpp:192: LOADED TenantInfo: State NOT changed
2025-12-09T03:44:25.165394Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 8ed2cde7-9c80fbf5-fce4b698-d3d7611d17, Host: ghrun-syjwtgwtdu, Tenant: /compute, Request CP::GetTask with size: 69 bytes
2025-12-09T03:44:25.165474Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "8ed2cde7-9c80fbf5-fce4b698-d3d7611d17"
host: "ghrun-syjwtgwtdu"
node_id: 1
}
2025-12-09T03:44:25.168307Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-09T03:44:25.168356Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 8ed2cde7-9c80fbf5-fce4b698-d3d7611d17, Host: ghrun-syjwtgwtdu, Tenant: /compute, Got CP::GetTask Response
2025-12-09T03:44:25.720550Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7581698935825606080:2093]
2025-12-09T03:44:25.720577Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-09T03:44:25.720585Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7581698935825606039:2068]
2025-12-09T03:44:25.720590Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7581698935825606039:2068]
2025-12-09T03:44:25.720593Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7581698935825606039:2068]
2025-12-09T03:44:25.720604Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-09T03:44:26.165835Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 8ed2cde7-9c80fbf5-fce4b698-d3d7611d18, Host: ghrun-syjwtgwtdu, Tenant: /compute, Request CP::GetTask with size: 69 bytes
2025-12-09T03:44:26.165889Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "8ed2cde7-9c80fbf5-fce4b698-d3d7611d18"
host: "ghrun-syjwtgwtdu"
node_id: 1
}
2025-12-09T03:44:26.168583Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-09T03:44:26.168632Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 8ed2cde7-9c80fbf5-fce4b698-d3d7611d18, Host: ghrun-syjwtgwtdu, Tenant: /compute, Got CP::GetTask Response
2025-12-09T03:44:27.166237Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 8ed2cde7-9c80fbf5-fce4b698-d3d7611d19, Host: ghrun-syjwtgwtdu, Tenant: /compute, Request CP::GetTask with size: 69 bytes
2025-12-09T03:44:27.166306Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "8ed2cde7-9c80fbf5-fce4b698-d3d7611d19"
host: "ghrun-syjwtgwtdu"
node_id: 1
}
2025-12-09T03:44:27.169165Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:456: Task (Query): ptqudqgd3dn917ujg7bg Lease TIMEOUT, RetryCounterUpdatedAt 2025-12-09T03:44:04.775996Z LastSeenAt: 2025-12-09T03:44:06.860416Z
2025-12-09T03:44:27.169182Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:463: Task (Query): ptqudqgd3dn917ujg7bg RetryRate: 0.9995174954 RetryCounter: 1 At: 2025-12-09T03:44:27.169124Z
2025-12-09T03:44:27.177971Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {tasks { query_id { value: "ptqudqgd3dn917ujg7bg" } job_id { value: "ptjudqgd3dn911n5hs81" } generation: 2 streaming: true dq_graph: "\022\207\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*\232\003Z\227\003\n\010PqSource\022\210\003\n4type.googleapis.com/NYql.NPq.NProto.TDqPqTopicSource\022\317\002\n.test_time_order_recoverer[v1-kikimr0]_v1_input\022\024ptqudqgd3dn917ujg7bg\032\016localhost:8635\"\027\n\025cluster:default_myyds*\005local0\002@\001b\002dtj&[\"OptionalType\";[\"DataType\";\"Uint64\"]]\222\001\024ptcudqgd3dvg6uei38no\232\001\rjson_each_row\242\001>[\"StructType\";[[\"dt\";[\"OptionalType\";[\"DataType\";\"Uint64\"]]]]]\262\001\002\022\000\272\001\026\n\010cloud_id\022\nmock_cloud\272\001 \n\005scope\022\027yandexcloud://my_folder\030\0012D\n@\010\001\020\240\234\001\030\001 \002*\024\n\022\t\000\000\000\000\000\000\000\000\021\000\000\000\000\001\000\000\0002\024\n\022\t\000\000\000\000\000\000\000\000\021\000\000\000\000\002\000\000\000P\001X\367\276\014`\213\277\014R\000:\203\001\n*type.googleapis.com/Yql.DqsProto.TTaskMeta\022U\010\367\276\014\022A\022(2ad8a0198ac871ab3cd73b3e9d43a8d7c87aa707\032\023dq_vanilla_job.lite \002\"\014\n\002pq\022\006\n\004\010\001\030\001H\367\276\014RClocal/RateLimiter_0d9c931a-2c72-4be3-9c55-0c708b358375/rate_limiterZ)mock_cloud/my_folder/ptqudqgd3dn917ujg7bg`\200\200\200\200 \230\001\000\300\001\001\022\207\004\010\002\022\024\n\022\t\000\000\000\000\000\000\000\000\021\000\000\000\000\000\000\000\000\032\004\010\240\215\006*D\n@\010\001\020\240\234\001\030\001 \002*\024\n\022\t\000\000\000\000\000\000\000\000\021\000\000\000\000\001\000\000\0002\024\n\022\t\000\000\000\000\000\000\000\000\021\000\000\000\000\002\000\000\000P\001X\367\276\014`\213\277\014R\0002\251\001z\246\001\n\006PqSink\022\233\001\n2type.googleapis.com/NYql.NPq.NProto.TDqPqTopicSink\022e\n/test_time_order_recoverer[v1-kikimr0]_v1_output\022\016localhost:8635\032\027\n\025cluster:default_myyds\"\005local0\0018\002:u\n*type.googleapis.com/Yql.DqsProto.TTaskMeta\022G\010\213\277\014\022A\022(2ad8a0198ac871ab3cd73b3e9d43a8d7c87aa707\032\023dq_vanilla_job.lite \002H\213\277\014RClocal/RateLimiter_0d9c931a-2c72-4be3-9c55-0c708b358375/rate_limiterZ)mock_cloud/my_folder/ptqudqgd3dn917ujg7bg`\200\200\200\200 \230\001\000\300\001\0012qptqudqgd3dn917ujg7bg#ptrudqgd3ct7r29pooqt#yandexcloud://my_folder#21209065-dc9406f4-c4759fb1-7f9fe8022#mock_cloud:\027\n\016FallbackPolicy\022\005never:\024\n\017_LiteralTimeout\022\0010:\022\n\r_TableTimeout\022\0010:\027\n\022_RowsLimitPerWrite\022\0010:\027\n\022EnableComputeActor\022\0011:\016\n\014WorkerFilter:\031\n\020ComputeActorType\022\005async:\031\n\016WatermarksMode\022\007disable:\037\n\027WatermarksGranularityMs\022\0041000:$\n\034WatermarksLateArrivalDelayMs\022\0045000:\027\n\022EnableChannelStats\022\0011:\020\n\013ExportStats\022\0011B\'\n\025cluster:default_myyds\022\016{\"no_auth\":\"\"}b\265\003\010\367\276\014\022\256\003\037\004\006Arg\004dt\005\205\006\213\002\204\203\005@\205\000\204\205\002\207\203\010\006\030Inputs(Parameters\034Program\013?\004)\251\000?\002\002\000\010\000)\251\000?\006\002\000\026)\211\002?\016\215?\014 FromFlow\000)\211\006?\034\215\233\002?\n?\n?\014$NarrowMap\000)\211\006?\"\215\205\002?\n\006?&?\n$ExpandMap\000)\211\002?(\204?&\030ToFlow\000)\211\014?,\211\004?,\204\203\005@\207\203\001H\014UDF\002\203\004\203\005@\203\004\203\004?\002\030Apply2\000)\211\010?8\203\005@\200\203\005@\202\014Udf\000\003?D8ClickHouseClient.ParseFormat\213\006\213\002\204\203\005@?\006?&\003?F\252json_each_row{\"data.datetime.formatname\":\"POSIX\",\"data.timestamp.formatname\":\"POSIX\"}\002\017\n\003?:\000\003?<\000\003?>\000\003?@\000?\024\036\014\000\016)\251\000?&\002\000\004)\211\004?\n?&\203\004\030Member\000?f\003?h\000\002\006\000\020)\251\000?\n\002\000\002\005?\014?t\000\004\022\000\024\001/b\202\021\010\213\277\014\022\373\020\037$\nFlags\010Name\010Args\016Payload\000\006Udf\014Apply2\004dt\006Arg\014Unwrap\nIndex\024SourceType\014Lookup\014Member\014Invoke\016Coll...} SUCCESS
2025-12-09T03:44:27.178089Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 8ed2cde7-9c80fbf5-fce4b698-d3d7611d19, Host: ghrun-syjwtgwtdu, Tenant: /compute, Got CP::GetTask Response
2025-12-09T03:44:27.179515Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 8ed2cde7-9c80fbf5-fce4b698-d3d7611d20, Host: ghrun-syjwtgwtdu, Tenant: /compute, Request CP::GetTask with size: 69 bytes
2025-12-09T03:44:27.179563Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "8ed2cde7-9c80fbf5-fce4b698-d3d7611d20"
host: "ghrun-syjwtgwtdu"
node_id: 1
}
2025-12-09T03:44:27.179798Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudqgd3dn917ujg7bg, Owner: 8ed2cde7-9c80fbf5-fce4b698-d3d7611d19, Request CP::PingTask with size: 313 bytes
2025-12-09T03:44:27.179858Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "8ed2cde7-9c80fbf5-fce4b698-d3d7611d19"
query_id {
  value: "ptqudqgd3dn917ujg7bg"
}
resources {
  rate_limiter: READY
  compilation: READY
  topic_consumers_state: READY
  rate_limiter_path: "local/RateLimiter_0d9c931a-2c72-4be3-9c55-0c708b358375/rate_limiter"
  topic_consumers {
    database: "local"
    topic_path: "test_time_order_recoverer[v1-kikimr0]_v1_input"
    consumer_name: "ptqudqgd3dn917ujg7bg"
    cluster_endpoint: "localhost:8635"
    token_name: "cluster:default_myyds"
    add_bearer_to_token: true
  }
}
scope: "yandexcloud://my_folder"
deadline {
  seconds: 1765338267
  nanos: 172928000
}
tenant: "/compute"
}
2025-12-09T03:44:27.181673Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-09T03:44:27.181707Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 8ed2cde7-9c80fbf5-fce4b698-d3d7611d20, Host: ghrun-syjwtgwtdu, Tenant: /compute, Got CP::GetTask Response
2025-12-09T03:44:27.188923Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {expired_at { seconds: 1765251887 nanos: 184000000 } } SUCCESS
2025-12-09T03:44:27.188959Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudqgd3dn917ujg7bg, Owner: 8ed2cde7-9c80fbf5-fce4b698-d3d7611d19, Got CP::PingTaskResponse
2025-12-09T03:44:27.497146Z :TICKET_PARSER DEBUG: ticket_parser_impl.h:1875: Ticket **** (B6C6F477) (ipv6:[::1]:47260) has now valid token of root@builtin
2025-12-09T03:44:27.497227Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:1061: ControlQueryRequest: query_id: "ptqudqgd3dn917ujg7bg"
action: ABORT
2025-12-09T03:44:27.497260Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:305: Resolve folder bootstrap. Folder id: my_folder Actor id: [1:7581699038904821451:2349]
2025-12-09T03:44:27.497288Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:367: Cloud id: mock_cloud Folder id: my_folder
2025-12-09T03:44:27.497315Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:91: Get quotas bootstrap. Cloud id: mock_cloud Actor id: [1:7581699038904821452:2350]
2025-12-09T03:44:27.497335Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.analyticsQuery.count IS STALE, Refreshing ...
2025-12-09T03:44:27.497345Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.cpuPercent.count IS STALE, Refreshing ...
2025-12-09T03:44:27.497350Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.streamingQuery.count IS STALE, Refreshing ...
2025-12-09T03:44:27.497367Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.cpuPercent.count=0/10000 REFRESHED
2025-12-09T03:44:27.502479Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.analyticsQuery.count=0/100 REFRESHED
2025-12-09T03:44:27.502506Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.streamingQuery.count=1/100 REFRESHED
2025-12-09T03:44:27.502530Z :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-09T03:44:27.502541Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:103: Cloud id: mock_cloud Quota count: 8
2025-12-09T03:44:27.502570Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:1061: ControlQueryRequest: query_id: "ptqudqgd3dn917ujg7bg"
action: ABORT
2025-12-09T03:44:27.502630Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:169: Resolve subject type bootstrap. Token: **** (B6C6F477) Actor id: [1:7581699038904821457:2355]
2025-12-09T03:44:27.502657Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:230: Subject Type: federated_account Token: **** (B6C6F477)
2025-12-09T03:44:27.502670Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:1061: ControlQueryRequest: query_id: "ptqudqgd3dn917ujg7bg"
action: ABORT
2025-12-09T03:44:27.502687Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:63: Request actor. Actor id: [1:7581699038904821458:2356]
2025-12-09T03:44:27.502745Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_queries.cpp:1342: ControlQueryRequest: {query_id: "ptqudqgd3dn917ujg7bg"
action: ABORT
} [root@builtin, **** (B6C6F477)] 
2025-12-09T03:44:27.503757Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.cpuPercent.count=0/10000 NOTIFY CHANGE
2025-12-09T03:44:27.507904Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.analyticsQuery.count=0/100 NOTIFY CHANGE
2025-12-09T03:44:27.507920Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.streamingQuery.count=1/100 NOTIFY CHANGE
2025-12-09T03:44:27.680484Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: ControlQueryRequest - ControlQueryRequest: {} SUCCESS
2025-12-09T03:44:27.682701Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudqgd3dn917ujg7bg"
2025-12-09T03:44:27.682741Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:305: Resolve folder bootstrap. Folder id: my_folder Actor id: [1:7581699038904821462:2359]
2025-12-09T03:44:27.682776Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:367: Cloud id: mock_cloud Folder id: my_folder
2025-12-09T03:44:27.682798Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:91: Get quotas bootstrap. Cloud id: mock_cloud Actor id: [1:7581699038904821463:2360]
2025-12-09T03:44:27.682821Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.analyticsQuery.count IS STALE, Refreshing ...
2025-12-09T03:44:27.682831Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.cpuPercent.count IS STALE, Refreshing ...
2025-12-09T03:44:27.682838Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.streamingQuery.count IS STALE, Refreshing ...
2025-12-09T03:44:27.682853Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.cpuPercent.count=0/10000 REFRESHED
2025-12-09T03:44:27.687062Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.analyticsQuery.count=0/100 REFRESHED
2025-12-09T03:44:27.687088Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.streamingQuery.count=1/100 REFRESHED
2025-12-09T03:44:27.687111Z :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-09T03:44:27.687121Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:103: Cloud id: mock_cloud Quota count: 8
2025-12-09T03:44:27.687160Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudqgd3dn917ujg7bg"
2025-12-09T03:44:27.687212Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:169: Resolve subject type bootstrap. Token: **** (B6C6F477) Actor id: [1:7581699038904821468:2365]
2025-12-09T03:44:27.687244Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:230: Subject Type: federated_account Token: **** (B6C6F477)
2025-12-09T03:44:27.687265Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudqgd3dn917ujg7bg"
2025-12-09T03:44:27.687298Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:63: Request actor. Actor id: [1:7581699038904821469:2366]
2025-12-09T03:44:27.687339Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_queries.cpp:641: DescribeQueryRequest: {query_id: "ptqudqgd3dn917ujg7bg"
} [root@builtin, **** (B6C6F477)] 
2025-12-09T03:44:27.688247Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.cpuPercent.count=0/10000 NOTIFY CHANGE
2025-12-09T03:44:27.689356Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: DescribeQueryRequest - DescribeQueryResult: {query { meta { common { id: "ptqudqgd3dn917ujg7bg" created_by: "root@builtin" modified_by: "root@builtin" created_at { seconds: 1765251844 nanos: 692875000 } modified_at { seconds: 1765251867 nanos: 609496000 } revision: 2 } started_at { seconds: 1765251845 nanos: 546000000 } execute_mode: RUN status: ABORTING_BY_USER last_job_query_revision: 1 last_job_id: "ptjudqgd3dn911n5hs81-ptqudqgd3dn917ujg7bg" started_by: "root@builtin" aborted_by: "root@builtin" has_saved_checkpoints: true submitted_at { seconds: 1765251844 nanos: 692875000 } } content { type: STREAMING name: "simple" acl { visibility: PRIVATE } limits { execution_timeout { } } text: "\n            PRAGMA dq.MaxTasksPerStage=\"2\";\n\n            pragma FeatureR010=\"prototype\";\n            pragma config.flags(\"TimeOrderRecoverDelay\", \"-1000000\");\n            pragma config.flags(\"TimeOrderRecoverAhead\", \"1000000\");\n\n            INSERT INTO myyds.`test_time_order_recoverer[v1-kikimr0]_v1_output`\n            SELECT ToBytes(Unwrap(Json::SerializeJson(Yson::From(TableRow()))))\n            FROM (SELECT * FROM myyds.`test_time_order_recoverer[v1-kikimr0]_v1_input`\n                WITH (\n                    format=json_each_row,\n                    SCHEMA\n                    (\n                        dt UINT64\n                    )))\n            MATCH_RECOGNIZE(\n                ORDER BY CAST(dt as Timestamp)\n                MEASURES\n                LAST(ALL_TRUE.dt) as dt\n                ONE ROW PER MATCH\n                PATTERN ( ALL_TRUE )\n                DEFINE\n                    ALL_TRUE as True)" syntax: YQL_V1 } plan { json: "{\"Detailed\":{\"Operations\":[{\"Id\":5,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[{\"Name\":\"DqSourceWideWrap\"},{\"Name\":\"NarrowMap\"}]}},{\"Id\":3,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[{\"Name\":\"TimeOrderRecover\"},{\"Name\":\"OrderedFlatMap\"},{\"Name\":\"MatchRecognizeCore\"},{\"Name\":\"FlatMap\"},{\"Name\":\"FromFlow\"}]},\"DependsOn\":[5]},{\"Id\":2,\"Name\":\"DqQuery!\",\"DependsOn\":[3]},{\"Id\":1,\"Name\":\"Commit!\",\"DependsOn\":[2]}],\"OperationRoot\":1,\"Providers\":[],\"OperationStats\":{\"Commit!\":1,\"DqQuery!\":1,\"DqStage\":2}},\"Basic\":{\"nodes\":[{\"id\":5,\"level\":1,\"name\":\"DqStage #5\",\"type\":\"op\"},{\"id\":3,\"level\":2,\"name\":\"DqStage #3\",\"type\":\"op\"},{\"id\":2,\"level\":3,\"name\":\"DqQuery!\",\"type\":\"op\"},{\"id\":1,\"level\":4,\"name\":\"Commit!\",\"type\":\"op\"}],\"links\":[{\"source\":5,\"target\":3},{\"source\":3,\"target\":2},{\"source\":2,\"target\":1}]}}" } transient_issue { message: "Parse Sql" severity: 2 issues { position { row: 9 column: 41 } message: "Json UDF is deprecated. Please use JSON API instead" end_position { row: 9 column: 41 } issue_code: 4506 severity: 2 } } statistics { json: "{\"Graph=0\":{\"Tasks\":{\"sum\":2,\"count\":2,\"avg\":1,\"max\":1,\"min\":1},\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":2,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"}}}" } ast { data: "(\n(let $1 (DataSource \'\"config\"))\n(let $2 (Configure! world $1 \'\"DqEngine\" \'\"force\"))\n(let $3 (Configure! $2 (DataSource \'\"dq\" \'\"$all\") \'\"Attr\" \'\"maxtasksperstage\" \'\"2\"))\n(let $4 (Configure! $3 $1 \'\"TimeOrderRecoverDelay\" \'\"-1000000\"))\n(let $5 (Configure! $4 $1 \'\"TimeOrderRecoverAhead\" \'\"1000000\"))\n(let $6 (DataSource \'\"pq\" \'\"myyds\"))\n(let $7 \'(\'(\'\"PartitionsCount\" \'1)))\n(let $8 (StructType \'(\'dt (OptionalType (DataType \'Uint64)))))\n(let $9 (PqTopic \'\"myyds\" \'\"local\" \'\"test_time_order_recoverer[v1-kikimr0]_v1_input\" $7 \'() $8))\n(let $10 \'(\'dt))\n(let $11 \'(\'\"Endpoint\" \'\"localhost:8635\"))\n(let $12 \'(\'\"SharedReading\" \'0))\n(let $13 \'(\'\"AddBearerToToken\" \'1))\n(let $14 \'($11 $12 \'(\'\"ReconnectPeriod\" \'\"\") \'(\'\"Format\" \'\"json_each_row\") \'(\'\"ReadGroup\" \'\"ptcudqgd3dvg6uei38no\") $13))\n(let $15 (SecureParam \'\"cluster:default_myyds\"))\n(let $16 (DqPqTopicSource $5 $9 $10 $14 $15 \'\"\" $8 \'\"\"))\n(let $17 (DqStage \'((DqSource $6 $16)) (lambda \'($2...} SUCCESS
2025-12-09T03:44:27.696494Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.streamingQuery.count=1/100 NOTIFY CHANGE
2025-12-09T03:44:27.696611Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.analyticsQuery.count=0/100 NOTIFY CHANGE
2025-12-09T03:44:27.721401Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7581698935825606080:2093]
2025-12-09T03:44:27.721428Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-09T03:44:27.721451Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7581698935825606039:2068]
2025-12-09T03:44:27.721462Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7581698935825606039:2068]
2025-12-09T03:44:27.721464Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7581698935825606039:2068]
2025-12-09T03:44:27.721481Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-09T03:44:27.723753Z :FQ_CONTROL_PLANE_CONFIG TRACE: control_plane_config.cpp:192: LOADED TenantInfo: State NOT changed
2025-12-09T03:44:28.168156Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 8ed2cde7-9c80fbf5-fce4b698-d3d7611d21, Host: ghrun-syjwtgwtdu, Tenant: /compute, Request CP::GetTask with size: 69 bytes
2025-12-09T03:44:28.168248Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/compute"
owner_id: "8ed2cde7-9c80fbf5-fce4b698-d3d7611d21"
host: "ghrun-syjwtgwtdu"
node_id: 1
}
2025-12-09T03:44:28.171734Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-09T03:44:28.171775Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 8ed2cde7-9c80fbf5-fce4b698-d3d7611d21, Host: ghrun-syjwtgwtdu, Tenant: /compute, Got CP::GetTask Response
2025-12-09T03:44:28.192390Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudqgd3dn917ujg7bg"
2025-12-09T03:44:28.192451Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:305: Resolve folder bootstrap. Folder id: my_folder Actor id: [1:7581699043199788773:2373]
2025-12-09T03:44:28.192476Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:367: Cloud id: mock_cloud Folder id: my_folder
2025-12-09T03:44:28.192506Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:91: Get quotas bootstrap. Cloud id: mock_cloud Actor id: [1:7581699043199788774:2374]
2025-12-09T03:44:28.192536Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.analyticsQuery.count IS STALE, Refreshing ...
2025-12-09T03:44:28.192550Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.cpuPercent.count IS STALE, Refreshing ...
2025-12-09T03:44:28.192555Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.streamingQuery.count IS STALE, Refreshing ...
2025-12-09T03:44:28.192568Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.cpuPercent.count=0/10000 REFRESHED
2025-12-09T03:44:28.196556Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.analyticsQuery.count=0/100 REFRESHED
2025-12-09T03:44:28.196586Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.streamingQuery.count=1/100 REFRESHED
2025-12-09T03:44:28.196611Z :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-09T03:44:28.196620Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:103: Cloud id: mock_cloud Quota count: 8
2025-12-09T03:44:28.196647Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudqgd3dn917ujg7bg"
2025-12-09T03:44:28.196705Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:169: Resolve subject type bootstrap. Token: **** (B6C6F477) Actor id: [1:7581699043199788779:2379]
2025-12-09T03:44:28.196740Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:230: Subject Type: federated_account Token: **** (B6C6F477)
2025-12-09T03:44:28.196785Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudqgd3dn917ujg7bg"
2025-12-09T03:44:28.196813Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:63: Request actor. Actor id: [1:7581699043199788780:2380]
2025-12-09T03:44:28.196858Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_queries.cpp:641: DescribeQueryRequest: {query_id: "ptqudqgd3dn917ujg7bg"
} [root@builtin, **** (B6C6F477)] 
2025-12-09T03:44:28.198474Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.cpuPercent.count=0/10000 NOTIFY CHANGE
2025-12-09T03:44:28.198949Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: DescribeQueryRequest - DescribeQueryResult: {query { meta { common { id: "ptqudqgd3dn917ujg7bg" created_by: "root@builtin" modified_by: "root@builtin" created_at { seconds: 1765251844 nanos: 692875000 } modified_at { seconds: 1765251867 nanos: 609496000 } revision: 2 } started_at { seconds: 1765251845 nanos: 546000000 } execute_mode: RUN status: ABORTING_BY_USER last_job_query_revision: 1 last_job_id: "ptjudqgd3dn911n5hs81-ptqudqgd3dn917ujg7bg" started_by: "root@builtin" aborted_by: "root@builtin" has_saved_checkpoints: true submitted_at { seconds: 1765251844 nanos: 692875000 } } content { type: STREAMING name: "simple" acl { visibility: PRIVATE } limits { execution_timeout { } } text: "\n            PRAGMA dq.MaxTasksPerStage=\"2\";\n\n            pragma FeatureR010=\"prototype\";\n            pragma config.flags(\"TimeOrderRecoverDelay\", \"-1000000\");\n            pragma config.flags(\"TimeOrderRecoverAhead\", \"1000000\");\n\n            INSERT INTO myyds.`test_time_order_recoverer[v1-kikimr0]_v1_output`\n            SELECT ToBytes(Unwrap(Json::SerializeJson(Yson::From(TableRow()))))\n            FROM (SELECT * FROM myyds.`test_time_order_recoverer[v1-kikimr0]_v1_input`\n                WITH (\n                    format=json_each_row,\n                    SCHEMA\n                    (\n                        dt UINT64\n                    )))\n            MATCH_RECOGNIZE(\n                ORDER BY CAST(dt as Timestamp)\n                MEASURES\n                LAST(ALL_TRUE.dt) as dt\n                ONE ROW PER MATCH\n                PATTERN ( ALL_TRUE )\n                DEFINE\n                    ALL_TRUE as True)" syntax: YQL_V1 } plan { json: "{\"Detailed\":{\"Operations\":[{\"Id\":5,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[{\"Name\":\"DqSourceWideWrap\"},{\"Name\":\"NarrowMap\"}]}},{\"Id\":3,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[{\"Name\":\"TimeOrderRecover\"},{\"Name\":\"OrderedFlatMap\"},{\"Name\":\"MatchRecognizeCore\"},{\"Name\":\"FlatMap\"},{\"Name\":\"FromFlow\"}]},\"DependsOn\":[5]},{\"Id\":2,\"Name\":\"DqQuery!\",\"DependsOn\":[3]},{\"Id\":1,\"Name\":\"Commit!\",\"DependsOn\":[2]}],\"OperationRoot\":1,\"Providers\":[],\"OperationStats\":{\"Commit!\":1,\"DqQuery!\":1,\"DqStage\":2}},\"Basic\":{\"nodes\":[{\"id\":5,\"level\":1,\"name\":\"DqStage #5\",\"type\":\"op\"},{\"id\":3,\"level\":2,\"name\":\"DqStage #3\",\"type\":\"op\"},{\"id\":2,\"level\":3,\"name\":\"DqQuery!\",\"type\":\"op\"},{\"id\":1,\"level\":4,\"name\":\"Commit!\",\"type\":\"op\"}],\"links\":[{\"source\":5,\"target\":3},{\"source\":3,\"target\":2},{\"source\":2,\"target\":1}]}}" } transient_issue { message: "Parse Sql" severity: 2 issues { position { row: 9 column: 41 } message: "Json UDF is deprecated. Please use JSON API instead" end_position { row: 9 column: 41 } issue_code: 4506 severity: 2 } } statistics { json: "{\"Graph=0\":{\"Tasks\":{\"sum\":2,\"count\":2,\"avg\":1,\"max\":1,\"min\":1},\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":2,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"}}}" } ast { data: "(\n(let $1 (DataSource \'\"config\"))\n(let $2 (Configure! world $1 \'\"DqEngine\" \'\"force\"))\n(let $3 (Configure! $2 (DataSource \'\"dq\" \'\"$all\") \'\"Attr\" \'\"maxtasksperstage\" \'\"2\"))\n(let $4 (Configure! $3 $1 \'\"TimeOrderRecoverDelay\" \'\"-1000000\"))\n(let $5 (Configure! $4 $1 \'\"TimeOrderRecoverAhead\" \'\"1000000\"))\n(let $6 (DataSource \'\"pq\" \'\"myyds\"))\n(let $7 \'(\'(\'\"PartitionsCount\" \'1)))\n(let $8 (StructType \'(\'dt (OptionalType (DataType \'Uint64)))))\n(let $9 (PqTopic \'\"myyds\" \'\"local\" \'\"test_time_order_recoverer[v1-kikimr0]_v1_input\" $7 \'() $8))\n(let $10 \'(\'dt))\n(let $11 \'(\'\"Endpoint\" \'\"localhost:8635\"))\n(let $12 \'(\'\"SharedReading\" \'0))\n(let $13 \'(\'\"AddBearerToToken\" \'1))\n(let $14 \'($11 $12 \'(\'\"ReconnectPeriod\" \'\"\") \'(\'\"Format\" \'\"json_each_row\") \'(\'\"ReadGroup\" \'\"ptcudqgd3dvg6uei38no\") $13))\n(let $15 (SecureParam \'\"cluster:default_myyds\"))\n(let $16 (DqPqTopicSource $5 $9 $10 $14 $15 \'\"\" $8 \'\"\"))\n(let $17 (DqStage \'((DqSource $6 $16)) (lambda \'($2...} SUCCESS
2025-12-09T03:44:28.202070Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.streamingQuery.count=1/100 NOTIFY CHANGE
2025-12-09T03:44:28.202147Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.analyticsQuery.count=0/100 NOTIFY CHANGE
2025-12-09T03:44:28.210004Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudqgd3dn917ujg7bg, Owner: 8ed2cde7-9c80fbf5-fce4b698-d3d7611d19, Request CP::PingTask with size: 591 bytes
2025-12-09T03:44:28.210106Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "8ed2cde7-9c80fbf5-fce4b698-d3d7611d19"
query_id {
  value: "ptqudqgd3dn917ujg7bg"
}
statistics: "{\"Graph=0\":{\"TaskRunner\":{\"Stage=204663\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":1,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":1,\"count\":1,\"avg\":1,\"max\":1,\"min\":1}},\"Stage=204683\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":1,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":1,\"count\":1,\"avg\":1,\"max\":1,\"min\":1}},\"Stage=Total\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":2,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":2,\"count\":2,\"avg\":1,\"max\":1,\"min\":1}}}}}"
scope: "yandexcloud://my_folder"
deadline {
  seconds: 1765338267
  nanos: 172928000
}
tenant: "/compute"
}
2025-12-09T03:44:28.220688Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {action: ABORT expired_at { seconds: 1765251888 nanos: 215000000 } } SUCCESS
2025-12-09T03:44:28.220727Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudqgd3dn917ujg7bg, Owner: 8ed2cde7-9c80fbf5-fce4b698-d3d7611d19, Got CP::PingTaskResponse
2025-12-09T03:44:28.221796Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudqgd3dn917ujg7bg, Owner: 8ed2cde7-9c80fbf5-fce4b698-d3d7611d19, Request CP::PingTask with size: 116 bytes
2025-12-09T03:44:28.221861Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "8ed2cde7-9c80fbf5-fce4b698-d3d7611d19"
query_id {
  value: "ptqudqgd3dn917ujg7bg"
}
status: ABORTING_BY_USER
scope: "yandexcloud://my_folder"
deadline {
  seconds: 1765338267
  nanos: 172928000
}
tenant: "/compute"
}
2025-12-09T03:44:28.235511Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {action: ABORT expired_at { seconds: 1765251888 nanos: 227000000 } } SUCCESS
2025-12-09T03:44:28.235564Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudqgd3dn917ujg7bg, Owner: 8ed2cde7-9c80fbf5-fce4b698-d3d7611d19, Got CP::PingTaskResponse
2025-12-09T03:44:28.236644Z :YQL_PRIVATE_PROXY DEBUG: rate_limiter_resources.cpp:175: PrivateDeleteRateLimiterResource - QueryId: ptqudqgd3dn917ujg7bg, Owner: 8ed2cde7-9c80fbf5-fce4b698-d3d7611d19, Request CP::DeleteRateLimiterResource with size: 98 bytes
2025-12-09T03:44:28.236706Z :YQ_CONTROL_PLANE_STORAGE TRACE: request_actor.h:57: DeleteRateLimiterResourceRequest: {owner_id: "8ed2cde7-9c80fbf5-fce4b698-d3d7611d19"
query_id {
  value: "ptqudqgd3dn917ujg7bg"
}
scope: "yandexcloud://my_folder"
tenant: "/compute"
} 
2025-12-09T03:44:28.278778Z :YQ_CONTROL_PLANE_STORAGE DEBUG: rate_limiter_resources.cpp:74: DeleteRateLimiterResourceRequest. Got response from database: SUCCESS
2025-12-09T03:44:28.278902Z :YQ_RATE_LIMITER DEBUG: schema.cpp:71: Run delete rate limiter resource "mock_cloud/my_folder/ptqudqgd3dn917ujg7bg" actor
2025-12-09T03:44:28.278911Z :YQ_RATE_LIMITER DEBUG: schema.cpp:113: Call delete rate limiter resource "mock_cloud/my_folder/ptqudqgd3dn917ujg7bg"
2025-12-09T03:44:28.281750Z :YQ_RATE_LIMITER DEBUG: schema.cpp:179: Successfully deleted rate limiter resource "mock_cloud/my_folder/ptqudqgd3dn917ujg7bg"
2025-12-09T03:44:28.281766Z :YQ_RATE_LIMITER DEBUG: schema.cpp:122: Reply for delete rate limiter resource "mock_cloud/my_folder/ptqudqgd3dn917ujg7bg": 
2025-12-09T03:44:28.281794Z :YQ_CONTROL_PLANE_STORAGE DEBUG: rate_limiter_resources.cpp:219: Got delete response from rate limiter service
2025-12-09T03:44:28.281822Z :YQL_PRIVATE_PROXY DEBUG: rate_limiter_resources.cpp:199: PrivateDeleteRateLimiterResource - QueryId: ptqudqgd3dn917ujg7bg, Owner: 8ed2cde7-9c80fbf5-fce4b698-d3d7611d19, Got CP::DeleteRateLimiterResourceResponse
2025-12-09T03:44:28.283215Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudqgd3dn917ujg7bg, Owner: 8ed2cde7-9c80fbf5-fce4b698-d3d7611d19, Request CP::PingTask with size: 1175 bytes
2025-12-09T03:44:28.283330Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "8ed2cde7-9c80fbf5-fce4b698-d3d7611d19"
query_id {
  value: "ptqudqgd3dn917ujg7bg"
}
result_id {
  value: "ptrudqgd2o923uacv6fk"
}
status: ABORTED_BY_USER
issues {
  message: "ABORTED_BY_USER"
  severity: 1
}
statistics: "{\"Graph=0\":{\"Actor\":{\"ActorCreateTimeUs\":{\"sum\":\"54ms\",\"count\":2,\"avg\":\"27ms\",\"max\":\"27ms\",\"min\":\"27ms\"}},\"AllocateWorkersUs\":{\"sum\":\"28ms\",\"count\":1,\"avg\":\"28ms\",\"max\":\"28ms\",\"min\":\"28ms\"},\"ExecutionTimeUs\":{\"sum\":\"1.01s\",\"count\":1,\"avg\":\"1.01s\",\"max\":\"1.01s\",\"min\":\"1.01s\"},\"TaskRunner\":{\"Stage=204663\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":1,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":1,\"count\":1,\"avg\":1,\"max\":1,\"min\":1}},\"Stage=204683\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":1,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":1,\"count\":1,\"avg\":1,\"max\":1,\"min\":1}},\"Stage=Total\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":2,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":2,\"count\":2,\"avg\":1,\"max\":1,\"min\":1}}},\"UniqueWorkers\":{\"sum\":1,\"count\":1,\"avg\":1,\"max\":1,\"min\":1}}}"
resources {
  rate_limiter: READY
  compilation: READY
  topic_consumers_state: READY
  rate_limiter_path: "local/RateLimiter_0d9c931a-2c72-4be3-9c55-0c708b358375/rate_limiter"
  topic_consumers {
    database: "local"
    topic_path: "test_time_order_recoverer[v1-kikimr0]_v1_input"
    consumer_name: "ptqudqgd3dn917ujg7bg"
    cluster_endpoint: "localhost:8635"
    token_name: "cluster:default_myyds"
    add_bearer_to_token: true
  }
}
scope: "yandexcloud://my_folder"
finished_at {
  seconds: 1765251868
  nanos: 221000000
}
deadline {
  seconds: 1765338267
  nanos: 172928000
}
tenant: "/compute"
}
2025-12-09T03:44:28.366723Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {action: ABORT } SUCCESS
2025-12-09T03:44:28.366762Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudqgd3dn917ujg7bg, Owner: 8ed2cde7-9c80fbf5-fce4b698-d3d7611d19, Got CP::PingTaskResponse
2025-12-09T03:44:28.701697Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudqgd3dn917ujg7bg"
2025-12-09T03:44:28.701744Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:305: Resolve folder bootstrap. Folder id: my_folder Actor id: [1:7581699043199788798:2397]
2025-12-09T03:44:28.701760Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:367: Cloud id: mock_cloud Folder id: my_folder
2025-12-09T03:44:28.701773Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:91: Get quotas bootstrap. Cloud id: mock_cloud Actor id: [1:7581699043199788799:2398]
2025-12-09T03:44:28.701789Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.analyticsQuery.count IS STALE, Refreshing ...
2025-12-09T03:44:28.701801Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.cpuPercent.count IS STALE, Refreshing ...
2025-12-09T03:44:28.701806Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.streamingQuery.count IS STALE, Refreshing ...
2025-12-09T03:44:28.701835Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.cpuPercent.count=0/10000 REFRESHED
2025-12-09T03:44:28.704170Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.analyticsQuery.count=0/100 REFRESHED
2025-12-09T03:44:28.704201Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.streamingQuery.count=0/100 REFRESHED
2025-12-09T03:44:28.704219Z :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-09T03:44:28.704236Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:103: Cloud id: mock_cloud Quota count: 8
2025-12-09T03:44:28.704262Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudqgd3dn917ujg7bg"
2025-12-09T03:44:28.704304Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:169: Resolve subject type bootstrap. Token: **** (B6C6F477) Actor id: [1:7581699043199788804:2403]
2025-12-09T03:44:28.704330Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:230: Subject Type: federated_account Token: **** (B6C6F477)
2025-12-09T03:44:28.704344Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudqgd3dn917ujg7bg"
2025-12-09T03:44:28.704353Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:63: Request actor. Actor id: [1:7581699043199788805:2404]
2025-12-09T03:44:28.704376Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_queries.cpp:641: DescribeQueryRequest: {query_id: "ptqudqgd3dn917ujg7bg"
} [root@builtin, **** (B6C6F477)] 
2025-12-09T03:44:28.706909Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: DescribeQueryRequest - DescribeQueryResult: {query { meta { common { id: "ptqudqgd3dn917ujg7bg" created_by: "root@builtin" modified_by: "root@builtin" created_at { seconds: 1765251844 nanos: 692875000 } modified_at { seconds: 1765251867 nanos: 609496000 } revision: 2 } started_at { seconds: 1765251845 nanos: 546000000 } finished_at { seconds: 1765251868 nanos: 221000000 } execute_mode: RUN status: ABORTED_BY_USER last_job_query_revision: 1 last_job_id: "ptjudqgd3dn911n5hs81-ptqudqgd3dn917ujg7bg" started_by: "root@builtin" aborted_by: "root@builtin" has_saved_checkpoints: true submitted_at { seconds: 1765251844 nanos: 692875000 } } content { type: STREAMING name: "simple" acl { visibility: PRIVATE } limits { execution_timeout { } } text: "\n            PRAGMA dq.MaxTasksPerStage=\"2\";\n\n            pragma FeatureR010=\"prototype\";\n            pragma config.flags(\"TimeOrderRecoverDelay\", \"-1000000\");\n            pragma config.flags(\"TimeOrderRecoverAhead\", \"1000000\");\n\n            INSERT INTO myyds.`test_time_order_recoverer[v1-kikimr0]_v1_output`\n            SELECT ToBytes(Unwrap(Json::SerializeJson(Yson::From(TableRow()))))\n            FROM (SELECT * FROM myyds.`test_time_order_recoverer[v1-kikimr0]_v1_input`\n                WITH (\n                    format=json_each_row,\n                    SCHEMA\n                    (\n                        dt UINT64\n                    )))\n            MATCH_RECOGNIZE(\n                ORDER BY CAST(dt as Timestamp)\n                MEASURES\n                LAST(ALL_TRUE.dt) as dt\n                ONE ROW PER MATCH\n                PATTERN ( ALL_TRUE )\n                DEFINE\n                    ALL_TRUE as True)" syntax: YQL_V1 } plan { json: "{\"Detailed\":{\"Operations\":[{\"Id\":5,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[{\"Name\":\"DqSourceWideWrap\"},{\"Name\":\"NarrowMap\"}]}},{\"Id\":3,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[{\"Name\":\"TimeOrderRecover\"},{\"Name\":\"OrderedFlatMap\"},{\"Name\":\"MatchRecognizeCore\"},{\"Name\":\"FlatMap\"},{\"Name\":\"FromFlow\"}]},\"DependsOn\":[5]},{\"Id\":2,\"Name\":\"DqQuery!\",\"DependsOn\":[3]},{\"Id\":1,\"Name\":\"Commit!\",\"DependsOn\":[2]}],\"OperationRoot\":1,\"Providers\":[],\"OperationStats\":{\"Commit!\":1,\"DqQuery!\":1,\"DqStage\":2}},\"Basic\":{\"nodes\":[{\"id\":5,\"level\":1,\"name\":\"DqStage #5\",\"type\":\"op\"},{\"id\":3,\"level\":2,\"name\":\"DqStage #3\",\"type\":\"op\"},{\"id\":2,\"level\":3,\"name\":\"DqQuery!\",\"type\":\"op\"},{\"id\":1,\"level\":4,\"name\":\"Commit!\",\"type\":\"op\"}],\"links\":[{\"source\":5,\"target\":3},{\"source\":3,\"target\":2},{\"source\":2,\"target\":1}]}}" } issue { message: "ABORTED_BY_USER" severity: 1 } transient_issue { message: "Parse Sql" severity: 2 issues { position { row: 9 column: 41 } message: "Json UDF is deprecated. Please use JSON API instead" end_position { row: 9 column: 41 } issue_code: 4506 severity: 2 } } statistics { json: "{\"Graph=0\":{\"Tasks\":{\"sum\":2,\"count\":2,\"avg\":1,\"max\":1,\"min\":1},\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":2,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"}}}" } ast { data: "(\n(let $1 (DataSource \'\"config\"))\n(let $2 (Configure! world $1 \'\"DqEngine\" \'\"force\"))\n(let $3 (Configure! $2 (DataSource \'\"dq\" \'\"$all\") \'\"Attr\" \'\"maxtasksperstage\" \'\"2\"))\n(let $4 (Configure! $3 $1 \'\"TimeOrderRecoverDelay\" \'\"-1000000\"))\n(let $5 (Configure! $4 $1 \'\"TimeOrderRecoverAhead\" \'\"1000000\"))\n(let $6 (DataSource \'\"pq\" \'\"myyds\"))\n(let $7 \'(\'(\'\"PartitionsCount\" \'1)))\n(let $8 (StructType \'(\'dt (OptionalType (DataType \'Uint64)))))\n(let $9 (PqTopic \'\"myyds\" \'\"local\" \'\"test_time_order_recoverer[v1-kikimr0]_v1_input\" $7 \'() $8))\n(let $10 \'(\'dt))\n(let $11 \'(\'\"Endpoint\" \'\"localhost:8635\"))\n(let $12 \'(\'\"SharedReading\" \'0))\n(let $13 \'(\'\"AddBearerToToken\" \'1))\n(let $14 \'($11 $12 \'(\'\"ReconnectPeriod\" \'\"\") \'(\'\"Format\" \'\"json_each_row\") \'(\'\"ReadGroup\" \'\"ptcudqgd3dvg6uei38no\") $13))\n(let $15 (SecureParam \'\"cluster:default_myyds\"))\n(let $16 (DqPqTo...} SUCCESS
2025-12-09T03:44:28.707155Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.cpuPercent.count=0/10000 NOTIFY CHANGE
2025-12-09T03:44:28.710070Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.streamingQuery.count=0/100 NOTIFY CHANGE
2025-12-09T03:44:28.710097Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.analyticsQuery.count=0/100 NOTIFY CHANGE
