2025-10-27T08:01:20.575427Z :GRPC_SERVER NOTICE: grpc_request_proxy_simple.cpp:161: Grpc simple request proxy started, nodeid# 1
2025-10-27T08:01:20.575476Z :GRPC_SERVER NOTICE: grpc_request_proxy_simple.cpp:161: Grpc simple request proxy started, nodeid# 1
2025-10-27T08:01:20.575657Z :YQ_CONTROL_PLANE_STORAGE INFO: ydb_control_plane_storage.cpp:50: Starting ydb control plane storage service. Actor id: [1:7565808577767701518:2062]
2025-10-27T08:01:20.577196Z :YQ_CONTROL_PLANE_PROXY DEBUG: control_plane_proxy.cpp:519: Starting yandex query control plane proxy. Actor id: [1:7565808577767701520:2064]
2025-10-27T08:01:20.577305Z :YQ_RATE_LIMITER INFO: quoter_service.cpp:124: Bootstraping with config: { Enabled: true ControlPlaneEnabled: true DataPlaneEnabled: true Database { Endpoint: "localhost:30711" Database: "local" TablePrefix: "RateLimiter_90e94ed0-64f3-4708-870a-5ec8d3274ff8" } Limiters { CoordinationNodePath: "rate_limiter" } }
2025-10-27T08:01:20.577417Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create directory "local/DbPoolStorage_90e94ed0-64f3-4708-870a-5ec8d3274ff8" actor
2025-10-27T08:01:20.577420Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create directory "local/DbPoolStorage_90e94ed0-64f3-4708-870a-5ec8d3274ff8"
2025-10-27T08:01:20.577422Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:383: Call create directory "local/DbPoolStorage_90e94ed0-64f3-4708-870a-5ec8d3274ff8"
2025-10-27T08:01:20.577450Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_90e94ed0-64f3-4708-870a-5ec8d3274ff8/connections" actor
2025-10-27T08:01:20.577478Z :YQL_NODES_MANAGER INFO: nodes_manager.cpp:88: Bootstrap, InstanceId: 9f50fb2a-4caaf79f-ebafdaa3-bf5ee683
2025-10-27T08:01:20.577480Z :YQL_NODES_MANAGER DEBUG: nodes_manager.cpp:310: TNodesManagerActor::ResolveSelfAddress
2025-10-27T08:01:20.577491Z :YQ_TEST_CONNECTION DEBUG: test_connection.cpp:142: Starting yandex query test connection. Actor id: [1:7565808577767701530:2074]
2025-10-27T08:01:20.577520Z :FQ_LOG_UPDATER DEBUG: log.cpp:93: Updated YQL logs priority: 8
2025-10-27T08:01:20.577523Z :FQ_LOG_UPDATER CRIT: log.cpp:55: Failed to deliver subscription request to config dispatcher.
2025-10-27T08:01:20.577558Z :FQ_QUOTA_SERVICE INFO: quota_manager.cpp:196: STARTED
2025-10-27T08:01:20.577562Z :FQ_QUOTA_PROXY INFO: quota_proxy.cpp:90: STARTED
2025-10-27T08:01:20.577567Z :FQ_CONTROL_PLANE_CONFIG DEBUG: control_plane_config.cpp:58: STARTING: [1:7565808577767701519:2063]
2025-10-27T08:01:20.577585Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_90e94ed0-64f3-4708-870a-5ec8d3274ff8/compute_databases" actor
2025-10-27T08:01:20.577595Z :YQ_RATE_LIMITER DEBUG: schema.cpp:71: Run create coordination node "local/RateLimiter_90e94ed0-64f3-4708-870a-5ec8d3274ff8/rate_limiter" actor
2025-10-27T08:01:20.577597Z :YQ_RATE_LIMITER DEBUG: schema.cpp:113: Call create coordination node "local/RateLimiter_90e94ed0-64f3-4708-870a-5ec8d3274ff8/rate_limiter"
2025-10-27T08:01:20.577599Z :YQ_RATE_LIMITER DEBUG: schema.cpp:411: Call create coordination node "local/RateLimiter_90e94ed0-64f3-4708-870a-5ec8d3274ff8/rate_limiter"
2025-10-27T08:01:20.577618Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:145: Bootstrap
2025-10-27T08:01:20.577638Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:165: Initialize
2025-10-27T08:01:20.578722Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_90e94ed0-64f3-4708-870a-5ec8d3274ff8/result_sets" actor
2025-10-27T08:01:20.578752Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_90e94ed0-64f3-4708-870a-5ec8d3274ff8/jobs" actor
2025-10-27T08:01:20.578790Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 99b92891-1f35e172-b6482f17-3ee788f1, Host: ghrun-aathosbtb4, Tenant: /default
2025-10-27T08:01:20.578802Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_90e94ed0-64f3-4708-870a-5ec8d3274ff8/tenants" actor
2025-10-27T08:01:20.578812Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_90e94ed0-64f3-4708-870a-5ec8d3274ff8/tenant_acks" actor
2025-10-27T08:01:20.578830Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_90e94ed0-64f3-4708-870a-5ec8d3274ff8/queries" actor
2025-10-27T08:01:20.578841Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:534: RowDispatcher: Successfully bootstrapped row dispatcher, id [1:7565808577767701525:2069], tenant /default
2025-10-27T08:01:20.578919Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_90e94ed0-64f3-4708-870a-5ec8d3274ff8/pending_small" actor
2025-10-27T08:01:20.578928Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_90e94ed0-64f3-4708-870a-5ec8d3274ff8/bindings" actor
2025-10-27T08:01:20.578976Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_90e94ed0-64f3-4708-870a-5ec8d3274ff8/idempotency_keys" actor
2025-10-27T08:01:20.580005Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:267: Coordinator: Successfully bootstrapped coordinator, id [1:7565808577767701574:2113], NodesManagerId [0:4705493345362661702:78]
2025-10-27T08:01:20.580022Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:231: TLeaderElection [1:7565808577767701575:2114] Successfully bootstrapped, local coordinator id [1:7565808577767701574:2113], tenant id default, local mode 0, coordination node path local/row_dispatcher/default
2025-10-27T08:01:20.580878Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_90e94ed0-64f3-4708-870a-5ec8d3274ff8/nodes" actor
2025-10-27T08:01:20.580921Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_90e94ed0-64f3-4708-870a-5ec8d3274ff8/quotas" actor
2025-10-27T08:01:20.580937Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:627: RowDispatcher: TEvCoordinatorChangesSubscribe from [1:7565808577767701574:2113]
2025-10-27T08:01:20.580943Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_90e94ed0-64f3-4708-870a-5ec8d3274ff8/mappings" actor
2025-10-27T08:01:20.580984Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-10-27T08:01:20.581643Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:71: Run create coordination node "local/row_dispatcher/default" actor
2025-10-27T08:01:20.581646Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:113: Call create coordination node "local/row_dispatcher/default"
2025-10-27T08:01:20.581649Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:411: Call create coordination node "local/row_dispatcher/default"
2025-10-27T08:01:20.582173Z :MEMORY_PROFILER NOTICE: monitor.cpp:332: Bootstrapped
2025-10-27T08:01:20.598966Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-10-27T08:01:20.598985Z :FQ_PENDING_FETCHER ERROR: pending_fetcher.cpp:259: Error with GetTask: <main>: Error: GRpc error: (14): connections to all backends failing; last error: UNKNOWN: ipv4:127.0.0.1:30981: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint localhost:30981
2025-10-27T08:01:20.599031Z :YQL_NODES_MANAGER ERROR: nodes_manager.cpp:395: ydb/core/fq/libs/actors/nodes_manager.cpp:353: TRANSPORT_UNAVAILABLE
<main>: Error: GRpc error: (14): connections to all backends failing; last error: UNKNOWN: ipv4:127.0.0.1:30981: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint localhost:30981
2025-10-27T08:01:20.622754Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_90e94ed0-64f3-4708-870a-5ec8d3274ff8/idempotency_keys". Create session OK
2025-10-27T08:01:20.622767Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_90e94ed0-64f3-4708-870a-5ec8d3274ff8/idempotency_keys"
2025-10-27T08:01:20.622770Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_90e94ed0-64f3-4708-870a-5ec8d3274ff8/idempotency_keys"
2025-10-27T08:01:20.622837Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_90e94ed0-64f3-4708-870a-5ec8d3274ff8/pending_small". Create session OK
2025-10-27T08:01:20.622846Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_90e94ed0-64f3-4708-870a-5ec8d3274ff8/pending_small"
2025-10-27T08:01:20.622848Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_90e94ed0-64f3-4708-870a-5ec8d3274ff8/pending_small"
2025-10-27T08:01:20.623045Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_90e94ed0-64f3-4708-870a-5ec8d3274ff8/tenant_acks". Create session OK
2025-10-27T08:01:20.623053Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_90e94ed0-64f3-4708-870a-5ec8d3274ff8/tenant_acks"
2025-10-27T08:01:20.623054Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_90e94ed0-64f3-4708-870a-5ec8d3274ff8/tenant_acks"
2025-10-27T08:01:20.623124Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_90e94ed0-64f3-4708-870a-5ec8d3274ff8/mappings". Create session OK
2025-10-27T08:01:20.623130Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_90e94ed0-64f3-4708-870a-5ec8d3274ff8/mappings"
2025-10-27T08:01:20.623131Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_90e94ed0-64f3-4708-870a-5ec8d3274ff8/mappings"
2025-10-27T08:01:20.623138Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_90e94ed0-64f3-4708-870a-5ec8d3274ff8/compute_databases". Create session OK
2025-10-27T08:01:20.623140Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_90e94ed0-64f3-4708-870a-5ec8d3274ff8/compute_databases"
2025-10-27T08:01:20.623141Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_90e94ed0-64f3-4708-870a-5ec8d3274ff8/compute_databases"
2025-10-27T08:01:20.623182Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_90e94ed0-64f3-4708-870a-5ec8d3274ff8/connections". Create session OK
2025-10-27T08:01:20.623188Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_90e94ed0-64f3-4708-870a-5ec8d3274ff8/bindings". Create session OK
2025-10-27T08:01:20.623189Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_90e94ed0-64f3-4708-870a-5ec8d3274ff8/connections"
2025-10-27T08:01:20.623189Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_90e94ed0-64f3-4708-870a-5ec8d3274ff8/bindings"
2025-10-27T08:01:20.623190Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_90e94ed0-64f3-4708-870a-5ec8d3274ff8/connections"
2025-10-27T08:01:20.623190Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_90e94ed0-64f3-4708-870a-5ec8d3274ff8/bindings"
2025-10-27T08:01:20.623232Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_90e94ed0-64f3-4708-870a-5ec8d3274ff8/queries". Create session OK
2025-10-27T08:01:20.623241Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_90e94ed0-64f3-4708-870a-5ec8d3274ff8/queries"
2025-10-27T08:01:20.623242Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_90e94ed0-64f3-4708-870a-5ec8d3274ff8/queries"
2025-10-27T08:01:20.623262Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_90e94ed0-64f3-4708-870a-5ec8d3274ff8/nodes". Create session OK
2025-10-27T08:01:20.623263Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_90e94ed0-64f3-4708-870a-5ec8d3274ff8/nodes"
2025-10-27T08:01:20.623264Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_90e94ed0-64f3-4708-870a-5ec8d3274ff8/nodes"
2025-10-27T08:01:20.623305Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_90e94ed0-64f3-4708-870a-5ec8d3274ff8/result_sets". Create session OK
2025-10-27T08:01:20.623311Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_90e94ed0-64f3-4708-870a-5ec8d3274ff8/result_sets"
2025-10-27T08:01:20.623313Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_90e94ed0-64f3-4708-870a-5ec8d3274ff8/result_sets"
2025-10-27T08:01:20.623332Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created directory "local/DbPoolStorage_90e94ed0-64f3-4708-870a-5ec8d3274ff8"
2025-10-27T08:01:20.623341Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create directory "local/DbPoolStorage_90e94ed0-64f3-4708-870a-5ec8d3274ff8": { <main>: Error: Check failed: path: '/local/DbPoolStorage_90e94ed0-64f3-4708-870a-5ec8d3274ff8', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 2], type: EPathTypeDir, state: EPathStateNoChanges), source_location: ydb/core/tx/schemeshard/schemeshard__operation_mkdir.cpp:155 }
2025-10-27T08:01:20.623351Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_90e94ed0-64f3-4708-870a-5ec8d3274ff8/quotas". Create session OK
2025-10-27T08:01:20.623352Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_90e94ed0-64f3-4708-870a-5ec8d3274ff8/quotas"
2025-10-27T08:01:20.623353Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_90e94ed0-64f3-4708-870a-5ec8d3274ff8/quotas"
2025-10-27T08:01:20.623357Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_90e94ed0-64f3-4708-870a-5ec8d3274ff8/jobs". Create session OK
2025-10-27T08:01:20.623358Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_90e94ed0-64f3-4708-870a-5ec8d3274ff8/jobs"
2025-10-27T08:01:20.623360Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_90e94ed0-64f3-4708-870a-5ec8d3274ff8/jobs"
2025-10-27T08:01:20.623393Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_90e94ed0-64f3-4708-870a-5ec8d3274ff8/tenants". Create session OK
2025-10-27T08:01:20.623394Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_90e94ed0-64f3-4708-870a-5ec8d3274ff8/tenants"
2025-10-27T08:01:20.623394Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_90e94ed0-64f3-4708-870a-5ec8d3274ff8/tenants"
2025-10-27T08:01:20.644771Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_90e94ed0-64f3-4708-870a-5ec8d3274ff8/tenants"
2025-10-27T08:01:20.644800Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_90e94ed0-64f3-4708-870a-5ec8d3274ff8/tenants": { <main>: Error: Check failed: path: '/local/DbPoolStorage_90e94ed0-64f3-4708-870a-5ec8d3274ff8/tenants', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 3], type: EPathTypeTable, state: EPathStateNoChanges), source_location: ydb/core/tx/schemeshard/schemeshard__operation_create_table.cpp:500 }
2025-10-27T08:01:20.647405Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_90e94ed0-64f3-4708-870a-5ec8d3274ff8/mappings"
2025-10-27T08:01:20.647421Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_90e94ed0-64f3-4708-870a-5ec8d3274ff8/mappings": { <main>: Error: Check failed: path: '/local/DbPoolStorage_90e94ed0-64f3-4708-870a-5ec8d3274ff8/mappings', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 4], type: EPathTypeTable, state: EPathStateNoChanges), source_location: ydb/core/tx/schemeshard/schemeshard__operation_create_table.cpp:500 }
2025-10-27T08:01:20.686891Z :FQ_CONTROL_PLANE_CONFIG DEBUG: control_plane_config.cpp:190: LOADED TenantInfo: State CHANGED at 2025-10-27T08:01:19.566922Z
2025-10-27T08:01:20.690041Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:155: Successfully created coordination node "local/row_dispatcher/default"
2025-10-27T08:01:20.690053Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:122: Reply for create coordination node "local/row_dispatcher/default": 
2025-10-27T08:01:20.690071Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:344: TLeaderElection [1:7565808577767701575:2114] Coordination node successfully created
2025-10-27T08:01:20.690075Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:322: TLeaderElection [1:7565808577767701575:2114] Start session
2025-10-27T08:01:20.703356Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:358: TLeaderElection [1:7565808577767701575:2114] Session successfully created
2025-10-27T08:01:20.715401Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:371: TLeaderElection [1:7565808577767701575:2114] Semaphore successfully created
2025-10-27T08:01:20.715414Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:303: TLeaderElection [1:7565808577767701575:2114] Try to acquire semaphore
2025-10-27T08:01:20.715488Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:419: TLeaderElection [1:7565808577767701575:2114] Describe semaphore
2025-10-27T08:01:20.715522Z :YQ_RATE_LIMITER DEBUG: schema.cpp:155: Successfully created coordination node "local/RateLimiter_90e94ed0-64f3-4708-870a-5ec8d3274ff8/rate_limiter"
2025-10-27T08:01:20.715526Z :YQ_RATE_LIMITER DEBUG: schema.cpp:122: Reply for create coordination node "local/RateLimiter_90e94ed0-64f3-4708-870a-5ec8d3274ff8/rate_limiter": 
2025-10-27T08:01:20.718664Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_90e94ed0-64f3-4708-870a-5ec8d3274ff8/compute_databases"
2025-10-27T08:01:20.718686Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_90e94ed0-64f3-4708-870a-5ec8d3274ff8/compute_databases": 
2025-10-27T08:01:20.718916Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_90e94ed0-64f3-4708-870a-5ec8d3274ff8/quotas"
2025-10-27T08:01:20.718919Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_90e94ed0-64f3-4708-870a-5ec8d3274ff8/quotas": 
2025-10-27T08:01:20.719005Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_90e94ed0-64f3-4708-870a-5ec8d3274ff8/jobs"
2025-10-27T08:01:20.719007Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_90e94ed0-64f3-4708-870a-5ec8d3274ff8/jobs": 
2025-10-27T08:01:20.719062Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_90e94ed0-64f3-4708-870a-5ec8d3274ff8/connections"
2025-10-27T08:01:20.719063Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_90e94ed0-64f3-4708-870a-5ec8d3274ff8/connections": 
2025-10-27T08:01:20.719116Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_90e94ed0-64f3-4708-870a-5ec8d3274ff8/bindings"
2025-10-27T08:01:20.719117Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_90e94ed0-64f3-4708-870a-5ec8d3274ff8/bindings": 
2025-10-27T08:01:20.719597Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_90e94ed0-64f3-4708-870a-5ec8d3274ff8/result_sets"
2025-10-27T08:01:20.719605Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_90e94ed0-64f3-4708-870a-5ec8d3274ff8/result_sets": 
2025-10-27T08:01:20.719754Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_90e94ed0-64f3-4708-870a-5ec8d3274ff8/idempotency_keys"
2025-10-27T08:01:20.719756Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_90e94ed0-64f3-4708-870a-5ec8d3274ff8/idempotency_keys": 
2025-10-27T08:01:20.719841Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_90e94ed0-64f3-4708-870a-5ec8d3274ff8/queries"
2025-10-27T08:01:20.719842Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_90e94ed0-64f3-4708-870a-5ec8d3274ff8/queries": 
2025-10-27T08:01:20.719911Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_90e94ed0-64f3-4708-870a-5ec8d3274ff8/pending_small"
2025-10-27T08:01:20.719913Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_90e94ed0-64f3-4708-870a-5ec8d3274ff8/pending_small": 
2025-10-27T08:01:20.719987Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_90e94ed0-64f3-4708-870a-5ec8d3274ff8/nodes"
2025-10-27T08:01:20.719989Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_90e94ed0-64f3-4708-870a-5ec8d3274ff8/nodes": 
2025-10-27T08:01:20.720381Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_90e94ed0-64f3-4708-870a-5ec8d3274ff8/tenant_acks"
2025-10-27T08:01:20.720385Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_90e94ed0-64f3-4708-870a-5ec8d3274ff8/tenant_acks": 
2025-10-27T08:01:20.720866Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:385: TLeaderElection [1:7565808577767701575:2114] Semaphore successfully acquired
2025-10-27T08:01:20.721429Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:468: TLeaderElection [1:7565808577767701575:2114] Semaphore successfully described: coordinator id [1:7565808577767701574:2113] generation 1
2025-10-27T08:01:20.721438Z :FQ_ROW_DISPATCHER INFO: leader_election.cpp:470: TLeaderElection [1:7565808577767701575:2114] Send TEvCoordinatorChanged to [1:7565808577767701525:2069], new coordinator id [1:7565808577767701574:2113], previous coordinator id [0:0:0]
2025-10-27T08:01:20.721457Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:559: RowDispatcher: Coordinator changed, old leader (empty maybe), new [1:7565808577767701574:2113] generation 1
2025-10-27T08:01:20.721468Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:314: Coordinator: TEvPing received, [1:7565808577767701525:2069]
2025-10-27T08:01:20.721473Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:317: Coordinator: Send TEvPong to [1:7565808577767701525:2069]
2025-10-27T08:01:20.721481Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:386: Coordinator: New leader [1:7565808577767701574:2113], SelfId [1:7565808577767701574:2113]
2025-10-27T08:01:20.721491Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:623: RowDispatcher: NActors::TEvents::TEvPong
2025-10-27T08:01:20.813299Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:158: Successfully bootstrapped TStorageProxy [1:7565808577767701524:2068] with connection to localhost:30711:local
2025-10-27T08:01:21.574193Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 99b92891-1f35e172-b6482f17-3ee788f2, Host: ghrun-aathosbtb4, Tenant: /default
2025-10-27T08:01:21.574214Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:542: Coordinator: Send TEvGetNodesRequest to NodesManager
2025-10-27T08:01:21.575677Z :YQL_NODES_MANAGER DEBUG: nodes_manager.cpp:300: TNodesManagerActor::TEvGetNodesRequest
2025-10-27T08:01:21.575691Z :FQ_ROW_DISPATCHER INFO: coordinator.cpp:573: Coordinator: Updated node info, node count: 0
2025-10-27T08:01:21.587493Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 99b92891-1f35e172-b6482f17-3ee788f2, Host: ghrun-aathosbtb4, Tenant: /default, Request CP::GetTask with size: 67 bytes
2025-10-27T08:01:21.588139Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/default"
owner_id: "99b92891-1f35e172-b6482f17-3ee788f2"
host: "ghrun-aathosbtb4"
node_id: 1
}
2025-10-27T08:01:21.665765Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-10-27T08:01:21.665797Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 99b92891-1f35e172-b6482f17-3ee788f2, Host: ghrun-aathosbtb4, Tenant: /default, Got CP::GetTask Response
2025-10-27T08:01:21.666181Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-10-27T08:01:21.666191Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-10-27T08:01:22.572709Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:617: RowDispatcher: Send ping to [1:7565808577767701574:2113]
2025-10-27T08:01:22.572743Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1161: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-10-27T08:01:22.572751Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:314: Coordinator: TEvPing received, [1:7565808577767701525:2069]
2025-10-27T08:01:22.572756Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:317: Coordinator: Send TEvPong to [1:7565808577767701525:2069]
2025-10-27T08:01:22.572768Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:623: RowDispatcher: NActors::TEvents::TEvPong
2025-10-27T08:01:22.574724Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 99b92891-1f35e172-b6482f17-3ee788f3, Host: ghrun-aathosbtb4, Tenant: /default
2025-10-27T08:01:22.575297Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 99b92891-1f35e172-b6482f17-3ee788f3, Host: ghrun-aathosbtb4, Tenant: /default, Request CP::GetTask with size: 67 bytes
2025-10-27T08:01:22.575339Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/default"
owner_id: "99b92891-1f35e172-b6482f17-3ee788f3"
host: "ghrun-aathosbtb4"
node_id: 1
}
2025-10-27T08:01:22.575825Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:542: Coordinator: Send TEvGetNodesRequest to NodesManager
2025-10-27T08:01:22.575848Z :YQL_NODES_MANAGER DEBUG: nodes_manager.cpp:300: TNodesManagerActor::TEvGetNodesRequest
2025-10-27T08:01:22.575853Z :FQ_ROW_DISPATCHER INFO: coordinator.cpp:573: Coordinator: Updated node info, node count: 0
2025-10-27T08:01:22.586152Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-10-27T08:01:22.586223Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 99b92891-1f35e172-b6482f17-3ee788f3, Host: ghrun-aathosbtb4, Tenant: /default, Got CP::GetTask Response
2025-10-27T08:01:22.587330Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-10-27T08:01:22.587344Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-10-27T08:01:23.575022Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 99b92891-1f35e172-b6482f17-3ee788f4, Host: ghrun-aathosbtb4, Tenant: /default
2025-10-27T08:01:23.575689Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 99b92891-1f35e172-b6482f17-3ee788f4, Host: ghrun-aathosbtb4, Tenant: /default, Request CP::GetTask with size: 67 bytes
2025-10-27T08:01:23.575729Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/default"
owner_id: "99b92891-1f35e172-b6482f17-3ee788f4"
host: "ghrun-aathosbtb4"
node_id: 1
}
2025-10-27T08:01:23.575967Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:542: Coordinator: Send TEvGetNodesRequest to NodesManager
2025-10-27T08:01:23.575984Z :YQL_NODES_MANAGER DEBUG: nodes_manager.cpp:300: TNodesManagerActor::TEvGetNodesRequest
2025-10-27T08:01:23.575992Z :FQ_ROW_DISPATCHER INFO: coordinator.cpp:573: Coordinator: Updated node info, node count: 0
2025-10-27T08:01:23.586432Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-10-27T08:01:23.586488Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 99b92891-1f35e172-b6482f17-3ee788f4, Host: ghrun-aathosbtb4, Tenant: /default, Got CP::GetTask Response
2025-10-27T08:01:23.588908Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-10-27T08:01:23.588922Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-10-27T08:01:23.597786Z :FQ_CONTROL_PLANE_CONFIG TRACE: control_plane_config.cpp:192: LOADED TenantInfo: State NOT changed
2025-10-27T08:01:24.392843Z :TICKET_PARSER DEBUG: ticket_parser_impl.h:1828: Ticket **** (B6C6F477) (ipv6:[::1]:34434) has now valid token of root@builtin
2025-10-27T08:01:24.393043Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:1315: CreateConnectionRequest: content { name: "high_rate" setting { data_streams { auth { none { } } endpoint: "localhost:30711" database: "local" } } acl { visibility: PRIVATE } } 
2025-10-27T08:01:24.393095Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:301: Resolve folder bootstrap. Folder id: my_folder Actor id: [1:7565808594947570830:2166]
2025-10-27T08:01:24.393126Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:362: Cloud id: mock_cloud Folder id: my_folder
2025-10-27T08:01:24.393151Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:88: Get quotas bootstrap. Cloud id: mock_cloud Actor id: [1:7565808594947570831:2167]
2025-10-27T08:01:24.393163Z :FQ_QUOTA_SERVICE DEBUG: quota_manager.cpp:255: cloud.mock_cloud NOT CASHED, Loading ...
2025-10-27T08:01:24.432348Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:441: cloud.mock_cloud {} FROM DB
2025-10-27T08:01:24.432386Z :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-10-27T08:01:24.432390Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.analyticsQuery.count IS STALE, Refreshing ...
2025-10-27T08:01:24.432404Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.cpuPercent.count IS STALE, Refreshing ...
2025-10-27T08:01:24.432408Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.streamingQuery.count IS STALE, Refreshing ...
2025-10-27T08:01:24.432447Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.cpuPercent.count=0/10000 REFRESHED
2025-10-27T08:01:24.481155Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.cpuPercent.count=0/10000 NOTIFY CHANGE
2025-10-27T08:01:24.494226Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.analyticsQuery.count=0/100 REFRESHED
2025-10-27T08:01:24.494254Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.streamingQuery.count=0/100 REFRESHED
2025-10-27T08:01:24.494279Z :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-10-27T08:01:24.494294Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:100: Cloud id: mock_cloud Quota count: 8
2025-10-27T08:01:24.494420Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:1315: CreateConnectionRequest: content { name: "high_rate" setting { data_streams { auth { none { } } endpoint: "localhost:30711" database: "local" } } acl { visibility: PRIVATE } } 
2025-10-27T08:01:24.494526Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:166: Resolve subject type bootstrap. Token: **** (B6C6F477) Actor id: [1:7565808594947570837:2173]
2025-10-27T08:01:24.494540Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:227: Subject Type: federated_account Token: **** (B6C6F477)
2025-10-27T08:01:24.494598Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:1315: CreateConnectionRequest: content { name: "high_rate" setting { data_streams { auth { none { } } endpoint: "localhost:30711" database: "local" } } acl { visibility: PRIVATE } } 
2025-10-27T08:01:24.494611Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:431: Create database bootstrap. CloudId: mock_cloud Scope: yandexcloud://my_folder Actor id: [1:7565808594947570838:2174]
2025-10-27T08:01:24.494657Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:1315: CreateConnectionRequest: content { name: "high_rate" setting { data_streams { auth { none { } } endpoint: "localhost:30711" database: "local" } } acl { visibility: PRIVATE } } 
2025-10-27T08:01:24.494668Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:69: Request actor. Actor id: [1:7565808594947570839:2175]
2025-10-27T08:01:24.494773Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_connections.cpp:120: [yandexcloud://my_folder, root@builtin, ptcudts2os05kjn50skg] CreateConnectionRequest: **** (B6C6F477) content { name: "high_rate" setting { data_streams { auth { none { } } endpoint: "localhost:30711" database: "local" } } acl { visibility: PRIVATE } } 
2025-10-27T08:01:24.506339Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.analyticsQuery.count=0/100 NOTIFY CHANGE
2025-10-27T08:01:24.506356Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.streamingQuery.count=0/100 NOTIFY CHANGE
2025-10-27T08:01:24.572834Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:617: RowDispatcher: Send ping to [1:7565808577767701574:2113]
2025-10-27T08:01:24.572858Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1161: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-10-27T08:01:24.572865Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:314: Coordinator: TEvPing received, [1:7565808577767701525:2069]
2025-10-27T08:01:24.572869Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:317: Coordinator: Send TEvPong to [1:7565808577767701525:2069]
2025-10-27T08:01:24.572888Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:623: RowDispatcher: NActors::TEvents::TEvPong
2025-10-27T08:01:24.574886Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 99b92891-1f35e172-b6482f17-3ee788f5, Host: ghrun-aathosbtb4, Tenant: /default
2025-10-27T08:01:24.576132Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:542: Coordinator: Send TEvGetNodesRequest to NodesManager
2025-10-27T08:01:24.576167Z :YQL_NODES_MANAGER DEBUG: nodes_manager.cpp:300: TNodesManagerActor::TEvGetNodesRequest
2025-10-27T08:01:24.576178Z :FQ_ROW_DISPATCHER INFO: coordinator.cpp:573: Coordinator: Updated node info, node count: 0
2025-10-27T08:01:24.578083Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 99b92891-1f35e172-b6482f17-3ee788f5, Host: ghrun-aathosbtb4, Tenant: /default, Request CP::GetTask with size: 67 bytes
2025-10-27T08:01:24.578134Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/default"
owner_id: "99b92891-1f35e172-b6482f17-3ee788f5"
host: "ghrun-aathosbtb4"
node_id: 1
}
2025-10-27T08:01:24.582670Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-10-27T08:01:24.582719Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 99b92891-1f35e172-b6482f17-3ee788f5, Host: ghrun-aathosbtb4, Tenant: /default, Got CP::GetTask Response
2025-10-27T08:01:24.585993Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-10-27T08:01:24.586008Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-10-27T08:01:24.846119Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: [yandexcloud://my_folder, root@builtin, ptcudts2os05kjn50skg] CreateConnectionRequest: {connection_id: "ptcudts2os05kjn50skg" } SUCCESS
2025-10-27T08:01:24.850219Z :TICKET_PARSER DEBUG: ticket_parser_impl.h:1828: Ticket **** (B6C6F477) (ipv6:[::1]:34434) has now valid token of root@builtin
2025-10-27T08:01:24.850323Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:642: CreateQueryRequest: content {
  type: STREAMING
  name: "a"
  acl {
    visibility: PRIVATE
  }
  limits {
    execution_timeout {
    }
  }
  text: "SELECT * FROM high_rate.`high_rate_input`;"
  syntax: YQL_V1
}
execute_mode: RUN
idempotency_key: "522a7821-e6dc-4bec-a701-d500431362ad"
2025-10-27T08:01:24.850362Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:301: Resolve folder bootstrap. Folder id: my_folder Actor id: [1:7565808594947570846:2181]
2025-10-27T08:01:24.850377Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:362: Cloud id: mock_cloud Folder id: my_folder
2025-10-27T08:01:24.850392Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:88: Get quotas bootstrap. Cloud id: mock_cloud Actor id: [1:7565808594947570847:2182]
2025-10-27T08:01:24.850408Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.analyticsQuery.count IS STALE, Refreshing ...
2025-10-27T08:01:24.850417Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.cpuPercent.count IS STALE, Refreshing ...
2025-10-27T08:01:24.850421Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.streamingQuery.count IS STALE, Refreshing ...
2025-10-27T08:01:24.850461Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.cpuPercent.count=0/10000 REFRESHED
2025-10-27T08:01:24.853772Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.analyticsQuery.count=0/100 REFRESHED
2025-10-27T08:01:24.853794Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.streamingQuery.count=0/100 REFRESHED
2025-10-27T08:01:24.853815Z :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-10-27T08:01:24.853872Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:100: Cloud id: mock_cloud Quota count: 8
2025-10-27T08:01:24.853916Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:642: CreateQueryRequest: content {
  type: STREAMING
  name: "a"
  acl {
    visibility: PRIVATE
  }
  limits {
    execution_timeout {
    }
  }
  text: "SELECT * FROM high_rate.`high_rate_input`;"
  syntax: YQL_V1
}
execute_mode: RUN
idempotency_key: "522a7821-e6dc-4bec-a701-d500431362ad"
2025-10-27T08:01:24.853993Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:166: Resolve subject type bootstrap. Token: **** (B6C6F477) Actor id: [1:7565808594947570852:2187]
2025-10-27T08:01:24.854014Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:227: Subject Type: federated_account Token: **** (B6C6F477)
2025-10-27T08:01:24.854039Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:642: CreateQueryRequest: content {
  type: STREAMING
  name: "a"
  acl {
    visibility: PRIVATE
  }
  limits {
    execution_timeout {
    }
  }
  text: "SELECT * FROM high_rate.`high_rate_input`;"
  syntax: YQL_V1
}
execute_mode: RUN
idempotency_key: "522a7821-e6dc-4bec-a701-d500431362ad"
2025-10-27T08:01:24.854051Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:431: Create database bootstrap. CloudId: mock_cloud Scope: yandexcloud://my_folder Actor id: [1:7565808594947570853:2188]
2025-10-27T08:01:24.854066Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:642: CreateQueryRequest: content {
  type: STREAMING
  name: "a"
  acl {
    visibility: PRIVATE
  }
  limits {
    execution_timeout {
    }
  }
  text: "SELECT * FROM high_rate.`high_rate_input`;"
  syntax: YQL_V1
}
execute_mode: RUN
idempotency_key: "522a7821-e6dc-4bec-a701-d500431362ad"
2025-10-27T08:01:24.854077Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:69: Request actor. Actor id: [1:7565808594947570854:2189]
2025-10-27T08:01:24.854091Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:253: Create rate limiter resource for cloud with limit 100000ms
2025-10-27T08:01:24.854115Z :YQ_RATE_LIMITER DEBUG: schema.cpp:71: Run create rate limiter resource "mock_cloud" actor
2025-10-27T08:01:24.854116Z :YQ_RATE_LIMITER DEBUG: schema.cpp:113: Call create rate limiter resource "mock_cloud"
2025-10-27T08:01:24.864157Z :YQ_RATE_LIMITER DEBUG: schema.cpp:155: Successfully created rate limiter resource "mock_cloud"
2025-10-27T08:01:24.864172Z :YQ_RATE_LIMITER DEBUG: schema.cpp:122: Reply for create rate limiter resource "mock_cloud": 
2025-10-27T08:01:24.864201Z :YQ_CONTROL_PLANE_PROXY DEBUG: request_actor.h:277: Create response from rate limiter service. Success: 1
2025-10-27T08:01:24.864275Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_queries.cpp:226: CreateQueryRequest: {content {
  type: STREAMING
  name: "a"
  acl {
    visibility: PRIVATE
  }
  limits {
    execution_timeout {
    }
  }
  text: "SELECT * FROM high_rate.`high_rate_input`;"
  syntax: YQL_V1
}
execute_mode: RUN
idempotency_key: "522a7821-e6dc-4bec-a701-d500431362ad"
} [root@builtin, **** (B6C6F477)] 
2025-10-27T08:01:24.877466Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.cpuPercent.count=0/10000 NOTIFY CHANGE
2025-10-27T08:01:24.883164Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.analyticsQuery.count=0/100 NOTIFY CHANGE
2025-10-27T08:01:24.886153Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.streamingQuery.count=0/100 NOTIFY CHANGE
2025-10-27T08:01:25.008706Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: CreateQueryRequest - CreateQueryResult: {query_id: "ptqudts2orksmjp91qjl" } SUCCESS
2025-10-27T08:01:25.014164Z :TICKET_PARSER DEBUG: ticket_parser_impl.h:1828: Ticket **** (B6C6F477) (ipv6:[::1]:34434) has now valid token of root@builtin
2025-10-27T08:01:25.014259Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:777: DescribeQueryRequest: query_id: "ptqudts2orksmjp91qjl"
2025-10-27T08:01:25.014307Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:301: Resolve folder bootstrap. Folder id: my_folder Actor id: [1:7565808599242538155:2193]
2025-10-27T08:01:25.014334Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:362: Cloud id: mock_cloud Folder id: my_folder
2025-10-27T08:01:25.014367Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:777: DescribeQueryRequest: query_id: "ptqudts2orksmjp91qjl"
2025-10-27T08:01:25.014435Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:166: Resolve subject type bootstrap. Token: **** (B6C6F477) Actor id: [1:7565808599242538156:2194]
2025-10-27T08:01:25.014464Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:227: Subject Type: federated_account Token: **** (B6C6F477)
2025-10-27T08:01:25.014487Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:777: DescribeQueryRequest: query_id: "ptqudts2orksmjp91qjl"
2025-10-27T08:01:25.014504Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:69: Request actor. Actor id: [1:7565808599242538157:2195]
2025-10-27T08:01:25.014545Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_queries.cpp:641: DescribeQueryRequest: {query_id: "ptqudts2orksmjp91qjl"
} [root@builtin, **** (B6C6F477)] 
2025-10-27T08:01:25.059378Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: DescribeQueryRequest - DescribeQueryResult: {query { meta { common { id: "ptqudts2orksmjp91qjl" created_by: "root@builtin" modified_by: "root@builtin" created_at { seconds: 1761552084 nanos: 864218000 } modified_at { seconds: 1761552084 nanos: 864218000 } revision: 1 } execute_mode: RUN status: STARTING last_job_query_revision: 1 last_job_id: "ptjudts2orksmdrpis4q-ptqudts2orksmjp91qjl" started_by: "root@builtin" submitted_at { seconds: 1761552084 nanos: 864218000 } } content { type: STREAMING name: "a" acl { visibility: PRIVATE } limits { execution_timeout { } } text: "SELECT * FROM high_rate.`high_rate_input`;" syntax: YQL_V1 } } } SUCCESS
2025-10-27T08:01:25.566158Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:777: DescribeQueryRequest: query_id: "ptqudts2orksmjp91qjl"
2025-10-27T08:01:25.566208Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:301: Resolve folder bootstrap. Folder id: my_folder Actor id: [1:7565808599242538161:2198]
2025-10-27T08:01:25.566225Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:362: Cloud id: mock_cloud Folder id: my_folder
2025-10-27T08:01:25.566239Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:777: DescribeQueryRequest: query_id: "ptqudts2orksmjp91qjl"
2025-10-27T08:01:25.566264Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:166: Resolve subject type bootstrap. Token: **** (B6C6F477) Actor id: [1:7565808599242538162:2199]
2025-10-27T08:01:25.566281Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:227: Subject Type: federated_account Token: **** (B6C6F477)
2025-10-27T08:01:25.566293Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:777: DescribeQueryRequest: query_id: "ptqudts2orksmjp91qjl"
2025-10-27T08:01:25.566304Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:69: Request actor. Actor id: [1:7565808599242538163:2200]
2025-10-27T08:01:25.566332Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_queries.cpp:641: DescribeQueryRequest: {query_id: "ptqudts2orksmjp91qjl"
} [root@builtin, **** (B6C6F477)] 
2025-10-27T08:01:25.573028Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-10-27T08:01:25.574802Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: DescribeQueryRequest - DescribeQueryResult: {query { meta { common { id: "ptqudts2orksmjp91qjl" created_by: "root@builtin" modified_by: "root@builtin" created_at { seconds: 1761552084 nanos: 864218000 } modified_at { seconds: 1761552084 nanos: 864218000 } revision: 1 } execute_mode: RUN status: STARTING last_job_query_revision: 1 last_job_id: "ptjudts2orksmdrpis4q-ptqudts2orksmjp91qjl" started_by: "root@builtin" submitted_at { seconds: 1761552084 nanos: 864218000 } } content { type: STREAMING name: "a" acl { visibility: PRIVATE } limits { execution_timeout { } } text: "SELECT * FROM high_rate.`high_rate_input`;" syntax: YQL_V1 } } } SUCCESS
2025-10-27T08:01:25.575058Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 99b92891-1f35e172-b6482f17-3ee788f6, Host: ghrun-aathosbtb4, Tenant: /default
2025-10-27T08:01:25.576327Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:542: Coordinator: Send TEvGetNodesRequest to NodesManager
2025-10-27T08:01:25.576356Z :YQL_NODES_MANAGER DEBUG: nodes_manager.cpp:300: TNodesManagerActor::TEvGetNodesRequest
2025-10-27T08:01:25.576364Z :FQ_ROW_DISPATCHER INFO: coordinator.cpp:573: Coordinator: Updated node info, node count: 0
2025-10-27T08:01:25.578585Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 99b92891-1f35e172-b6482f17-3ee788f6, Host: ghrun-aathosbtb4, Tenant: /default, Request CP::GetTask with size: 67 bytes
2025-10-27T08:01:25.578589Z :YQ_CONTROL_PLANE_STORAGE TRACE: nodes_health_check.cpp:38: NodesHealthCheckRequest: {tenant: "/default"
node {
  node_id: 1
  instance_id: "9f50fb2a-4caaf79f-ebafdaa3-bf5ee683"
  hostname: "ghrun-aathosbtb4"
  interconnect_port: 12750
  node_address: "127.0.1.1"
}
}
2025-10-27T08:01:25.578659Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/default"
owner_id: "99b92891-1f35e172-b6482f17-3ee788f6"
host: "ghrun-aathosbtb4"
node_id: 1
}
2025-10-27T08:01:25.600098Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:463: Task (Query): ptqudts2orksmjp91qjl RetryRate: 0 RetryCounter: 0 At: 2025-10-27T08:01:24.956106Z
2025-10-27T08:01:25.666128Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: NodesHealthCheckRequest - NodesHealthCheckResult: {nodes { node_id: 1 instance_id: "9f50fb2a-4caaf79f-ebafdaa3-bf5ee683" hostname: "ghrun-aathosbtb4" node_address: "127.0.1.1" } } SUCCESS
2025-10-27T08:01:25.673963Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:389: Send NodeInfo with size: 0 to DynamicNameserver
2025-10-27T08:01:25.798477Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {tasks { query_id { value: "ptqudts2orksmjp91qjl" } job_id { value: "ptjudts2orksmdrpis4q" } generation: 1 streaming: true text: "SELECT * FROM high_rate.`high_rate_input`;" connection { content { name: "high_rate" setting { data_streams { auth { none { } } endpoint: "localhost:30711" database: "local" } } acl { visibility: PRIVATE } } meta { id: "ptcudts2os05kjn50skg" created_by: "root@builtin" modified_by: "root@builtin" created_at { seconds: 1761552084 nanos: 494682000 } modified_at { seconds: 1761552084 nanos: 494682000 } 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: "a" deadline { seconds: 1761638485 nanos: 710106000 } 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: 1761552084 nanos: 864218000 } } } SUCCESS
2025-10-27T08:01:25.798593Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 99b92891-1f35e172-b6482f17-3ee788f6, Host: ghrun-aathosbtb4, Tenant: /default, Got CP::GetTask Response
2025-10-27T08:01:25.799250Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-10-27T08:01:25.799261Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 1
2025-10-27T08:01:25.799272Z :FQ_PENDING_FETCHER DEBUG: pending_fetcher.cpp:361: NewTask: Scope: yandexcloud://my_folder Id: ptqudts2orksmjp91qjl UserId: root@builtin AuthToken: **** (B6C6F477)
2025-10-27T08:01:25.799383Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 99b92891-1f35e172-b6482f17-3ee788f7, Host: ghrun-aathosbtb4, Tenant: /default
2025-10-27T08:01:25.799610Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:375: QueryId: ptqudts2orksmjp91qjl Start run actor. Compute state: STARTING
2025-10-27T08:01:25.799618Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:469: QueryId: ptqudts2orksmjp91qjl FillConnections
2025-10-27T08:01:25.799643Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:2334: QueryId: ptqudts2orksmjp91qjl Run actors params: { QueryId: ptqudts2orksmjp91qjl CloudId: mock_cloud UserId: root@builtin Owner: 99b92891-1f35e172-b6482f17-3ee788f6 PreviousQueryRevision: 1 Connections: 1 Bindings: 0 AccountIdSignatures: 0 QueryType: STREAMING ExecuteMode: RUN ResultId: ptrudts2oqobjmgvkjkb StateLoadMode: EMPTY StreamingDisposition: { fresh { } } Status: STARTING DqGraphs: 0 DqGraphIndex: 0 Resource.TopicConsumers: 0 }
2025-10-27T08:01:25.799657Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:571: QueryId: ptqudts2orksmjp91qjl Start rate limiter resource creator
2025-10-27T08:01:25.799668Z :FQ_PINGER TRACE: pinger.cpp:171: QueryId: ptqudts2orksmjp91qjl, Owner: 99b92891-1f35e172-b6482f17-3ee788f6 Start Pinger
2025-10-27T08:01:25.799684Z :FQ_PINGER TRACE: pinger.cpp:250: QueryId: ptqudts2orksmjp91qjl, Owner: 99b92891-1f35e172-b6482f17-3ee788f6 Forward ping request: { started_at { seconds: 1761552085 nanos: 799000000 } }
2025-10-27T08:01:25.799687Z :FQ_PINGER TRACE: pinger.cpp:393: QueryId: ptqudts2orksmjp91qjl, Owner: 99b92891-1f35e172-b6482f17-3ee788f6 Forward request Private::PingTask
2025-10-27T08:01:25.799702Z :FQ_PINGER TRACE: pinger.cpp:250: QueryId: ptqudts2orksmjp91qjl, Owner: 99b92891-1f35e172-b6482f17-3ee788f6 Forward ping request: { status: RUNNING resources { rate_limiter: PREPARE compilation: PREPARE } }
2025-10-27T08:01:25.799962Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 99b92891-1f35e172-b6482f17-3ee788f7, Host: ghrun-aathosbtb4, Tenant: /default, Request CP::GetTask with size: 67 bytes
2025-10-27T08:01:25.799990Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/default"
owner_id: "99b92891-1f35e172-b6482f17-3ee788f7"
host: "ghrun-aathosbtb4"
node_id: 1
}
2025-10-27T08:01:25.800090Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudts2orksmjp91qjl, Owner: 99b92891-1f35e172-b6482f17-3ee788f6, Request CP::PingTask with size: 128 bytes
2025-10-27T08:01:25.800146Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "99b92891-1f35e172-b6482f17-3ee788f6"
query_id {
  value: "ptqudts2orksmjp91qjl"
}
scope: "yandexcloud://my_folder"
started_at {
  seconds: 1761552085
  nanos: 799000000
}
deadline {
  seconds: 1761638485
  nanos: 710106000
}
tenant: "/default"
}
2025-10-27T08:01:25.800342Z :YQL_PRIVATE_PROXY DEBUG: rate_limiter_resources.cpp:78: PrivateCreateRateLimiterResource - QueryId: ptqudts2orksmjp91qjl, Owner: 99b92891-1f35e172-b6482f17-3ee788f6, Request CP::CreateRateLimiterResource with size: 96 bytes
2025-10-27T08:01:25.800370Z :YQ_CONTROL_PLANE_STORAGE TRACE: request_actor.h:57: CreateRateLimiterResourceRequest: {owner_id: "99b92891-1f35e172-b6482f17-3ee788f6"
query_id {
  value: "ptqudts2orksmjp91qjl"
}
scope: "yandexcloud://my_folder"
tenant: "/default"
} 
2025-10-27T08:01:25.814345Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-10-27T08:01:25.814407Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 99b92891-1f35e172-b6482f17-3ee788f7, Host: ghrun-aathosbtb4, Tenant: /default, Got CP::GetTask Response
2025-10-27T08:01:25.818063Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-10-27T08:01:25.818083Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-10-27T08:01:25.862223Z :YQ_CONTROL_PLANE_STORAGE DEBUG: rate_limiter_resources.cpp:74: CreateRateLimiterResourceRequest. Got response from database: SUCCESS
2025-10-27T08:01:25.862377Z :YQ_RATE_LIMITER DEBUG: schema.cpp:71: Run create rate limiter resource "mock_cloud/my_folder/ptqudts2orksmjp91qjl" actor
2025-10-27T08:01:25.862386Z :YQ_RATE_LIMITER DEBUG: schema.cpp:113: Call create rate limiter resource "mock_cloud/my_folder/ptqudts2orksmjp91qjl"
2025-10-27T08:01:25.866919Z :YQ_RATE_LIMITER DEBUG: schema.cpp:261: Trying to recursively create rate limiter resource "mock_cloud/my_folder"
2025-10-27T08:01:25.866931Z :YQ_RATE_LIMITER DEBUG: schema.cpp:113: Call create rate limiter resource "mock_cloud/my_folder"
2025-10-27T08:01:25.872195Z :YQ_RATE_LIMITER DEBUG: schema.cpp:244: Successfully created rate limiter resource "mock_cloud/my_folder"
2025-10-27T08:01:25.872208Z :YQ_RATE_LIMITER DEBUG: schema.cpp:113: Call create rate limiter resource "mock_cloud/my_folder/ptqudts2orksmjp91qjl"
2025-10-27T08:01:25.875837Z :YQ_RATE_LIMITER DEBUG: schema.cpp:155: Successfully created rate limiter resource "mock_cloud/my_folder/ptqudts2orksmjp91qjl"
2025-10-27T08:01:25.875865Z :YQ_RATE_LIMITER DEBUG: schema.cpp:122: Reply for create rate limiter resource "mock_cloud/my_folder/ptqudts2orksmjp91qjl": 
2025-10-27T08:01:25.875911Z :YQ_CONTROL_PLANE_STORAGE DEBUG: rate_limiter_resources.cpp:180: Got create response from rate limiter service
2025-10-27T08:01:25.875964Z :YQL_PRIVATE_PROXY DEBUG: rate_limiter_resources.cpp:102: PrivateCreateRateLimiterResource - QueryId: ptqudts2orksmjp91qjl, Owner: 99b92891-1f35e172-b6482f17-3ee788f6, Got CP::CreateRateLimiterResourceResponse
2025-10-27T08:01:25.876314Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:1477: QueryId: ptqudts2orksmjp91qjl Rate limiter resource creation finished. Success: 1
2025-10-27T08:01:25.876339Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:1967: QueryId: ptqudts2orksmjp91qjl Compiling query ...
2025-10-27T08:01:25.876395Z :FQ_PINGER TRACE: pinger.cpp:250: QueryId: ptqudts2orksmjp91qjl, Owner: 99b92891-1f35e172-b6482f17-3ee788f6 Forward ping request: { status: RUNNING resources { rate_limiter: READY compilation: PREPARE rate_limiter_path: "local/RateLimiter_90e94ed0-64f3-4708-870a-5ec8d3274ff8/rate_limiter" } }
2025-10-27T08:01:25.915690Z :YQL_PROXY TRACE: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.915 TRACE ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] yql_facade.cpp:863: Execution of [ParseSql] took 38.2ms
2025-10-27T08:01:25.915969Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.915 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [PQ] yql_pq_settings.cpp:87: Settings: clusterName = high_rate, clusterDbId = , cluster.GetEndpoint(): localhost:30711, HasEndpoint = TRUE
2025-10-27T08:01:25.916112Z :YQL_PROXY TRACE: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.916 TRACE ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] yql_facade.cpp:904: Execution of [Compile] took 396us
2025-10-27T08:01:25.916234Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.916 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [DQ] yql_dq_provider.cpp:109: OpenSession ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud
2025-10-27T08:01:25.916244Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.916 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [DQ] yql_dq_provider.cpp:112: OpenSession ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud complete in 0
2025-10-27T08:01:25.916331Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.916 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] yql_expr_optimize.cpp:671: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Execution of [ExpandApply] took 24us
2025-10-27T08:01:25.916442Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.916 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [core eval] yql_eval_expr.cpp:421: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} EvaluateExpression - start
2025-10-27T08:01:25.916558Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.916 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [core eval] yql_eval_expr.cpp:1204: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} EvaluateExpression - finish
2025-10-27T08:01:25.916792Z :YQL_PROXY INFO: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.916 INFO  ydbd(pid=1702961, tid=0x00007FF5B6E79640) [PQ] yql_pq_helpers.cpp:82: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Found cluster: high_rate
2025-10-27T08:01:25.916800Z :YQL_PROXY INFO: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.916 INFO  ydbd(pid=1702961, tid=0x00007FF5B6E79640) [PQ] yql_pq_helpers.cpp:100: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Ids to resolve: 0
2025-10-27T08:01:25.916891Z :YQL_PROXY INFO: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.916 INFO  ydbd(pid=1702961, tid=0x00007FF5B6E79640) [PQ] yql_pq_load_meta.cpp:35: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Load topic meta for: `high_rate`.`high_rate_input`
2025-10-27T08:01:25.923243Z :YDB_SDK INFO: actor.cpp:37: 2025-10-27T08:01:25.923222Z :INFO: [local] OnFederationDiscovery fall back to single mode, database=local
2025-10-27T08:01:25.927590Z :YQL_PROXY INFO: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.927 INFO  ydbd(pid=1702961, tid=0x00007FF5B6E79640) [PQ] yql_pq_datasource.cpp:88: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} RewriteIO
2025-10-27T08:01:25.927640Z :YQL_PROXY INFO: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.927 INFO  ydbd(pid=1702961, tid=0x00007FF5B6E79640) [PQ] yql_pq_datasource.cpp:88: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} RewriteIO
2025-10-27T08:01:25.927755Z :YQL_PROXY INFO: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.927 INFO  ydbd(pid=1702961, tid=0x00007FF5B6E79640) [RESULT] yql_result_provider.cpp:1415: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} RewriteIO
2025-10-27T08:01:25.928527Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.928 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] type_ann_expr.cpp:48: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Execution of [TypeAnnotationTransformer::DoTransform] took 722us
2025-10-27T08:01:25.928539Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.928 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] type_ann_expr.cpp:48: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Execution of [TypeAnnotationTransformer::DoTransform] took 1us
2025-10-27T08:01:25.928624Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.928 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] yql_expr_constraint.cpp:3307: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Execution of [ConstraintTransformer::DoTransform] took 75us
2025-10-27T08:01:25.928675Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.928 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] type_ann_expr.cpp:48: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Execution of [TypeAnnotationTransformer::DoTransform] took 0us
2025-10-27T08:01:25.928682Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.928 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] type_ann_expr.cpp:48: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Execution of [TypeAnnotationTransformer::DoTransform] took 1us
2025-10-27T08:01:25.928706Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.928 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] yql_expr_constraint.cpp:3307: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Execution of [ConstraintTransformer::DoTransform] took 17us
2025-10-27T08:01:25.928728Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.928 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] yql_expr_csee.cpp:638: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Execution of [UpdateCompletness] took 14us
2025-10-27T08:01:25.928808Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.928 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] yql_expr_csee.cpp:651: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Execution of [EliminateCommonSubExpressions] took 72us
2025-10-27T08:01:25.928922Z :YQL_PROXY TRACE: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.928 TRACE ydbd(pid=1702961, tid=0x00007FF5B6E79640) [core] yql_out_transformers.cpp:62: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} OptimizedExpr:
(
(let $1 (Configure! world (DataSource '"config") '"DqEngine" '"force"))
(let $2 (DataSink 'result))
(let $3 '"_yql_sys_create_time")
(let $4 '"_yql_sys_tsp_write_time")
(let $5 '"_yql_sys_partition_id")
(let $6 '"_yql_sys_message_group_id")
(let $7 '('('"system" $3) '('"system" $4) '('"system" $5) '('"system" '"_yql_sys_offset") '('"system" $6) '('"system" '"_yql_sys_seq_no")))
(let $8 (DataType 'String))
(let $9 '('"Data" $8))
(let $10 (PqTopic '"high_rate" '"local" '"high_rate_input" '('('"PartitionsCount" '"1")) $7 (StructType $9)))
(let $11 (DataType 'Timestamp))
(let $12 (DataType 'Uint64))
(let $13 (ResWrite! $1 $2 (Key) (RemovePrefixMembers (SqlProject (Right! (PqReadTopic! $1 (DataSource '"pq" '"high_rate") $10 (Void) '"raw" '"" (Void) '('('"data.datetime.formatname" '"POSIX") '('"data.timestamp.formatname" '"POSIX")))) '((SqlProjectStarItem (ListType (StructType $9 '($3 $11) '($6 $8) '('"_yql_sys_offset" $12) '($5 $12) '('"_yql_sys_seq_no" $12) '($4 $11))) '"" (lambda '($14) $14) '()))) '('_yql_)) '('('type) '('autoref))))
(return (Commit! (Commit! $13 $2) (DataSink '"pq" '"high_rate")))
)

2025-10-27T08:01:25.929129Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.929 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [core] yql_co_simple1.cpp:6779: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Expand SqlProject
2025-10-27T08:01:25.929200Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.929 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] type_ann_expr.cpp:48: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Execution of [TypeAnnotationTransformer::DoTransform] took 0us
2025-10-27T08:01:25.929255Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.929 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] type_ann_expr.cpp:48: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Execution of [TypeAnnotationTransformer::DoTransform] took 47us
2025-10-27T08:01:25.929273Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.929 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] yql_expr_constraint.cpp:3307: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Execution of [ConstraintTransformer::DoTransform] took 11us
2025-10-27T08:01:25.929302Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.929 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] type_ann_expr.cpp:48: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Execution of [TypeAnnotationTransformer::DoTransform] took 0us
2025-10-27T08:01:25.929310Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.929 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] type_ann_expr.cpp:48: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Execution of [TypeAnnotationTransformer::DoTransform] took 1us
2025-10-27T08:01:25.929337Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.929 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] yql_expr_constraint.cpp:3307: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Execution of [ConstraintTransformer::DoTransform] took 21us
2025-10-27T08:01:25.929353Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.929 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] yql_expr_csee.cpp:638: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Execution of [UpdateCompletness] took 10us
2025-10-27T08:01:25.929398Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.929 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] yql_expr_csee.cpp:651: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Execution of [EliminateCommonSubExpressions] took 37us
2025-10-27T08:01:25.929462Z :YQL_PROXY TRACE: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.929 TRACE ydbd(pid=1702961, tid=0x00007FF5B6E79640) [core] yql_out_transformers.cpp:62: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} OptimizedExpr:
(
(let $1 (Configure! world (DataSource '"config") '"DqEngine" '"force"))
(let $2 (DataSink 'result))
(let $3 '('('"system" '"_yql_sys_create_time") '('"system" '"_yql_sys_tsp_write_time") '('"system" '"_yql_sys_partition_id") '('"system" '"_yql_sys_offset") '('"system" '"_yql_sys_message_group_id") '('"system" '"_yql_sys_seq_no")))
(let $4 (PqTopic '"high_rate" '"local" '"high_rate_input" '('('"PartitionsCount" '"1")) $3 (StructType '('"Data" (DataType 'String)))))
(let $5 (ResWrite! $1 $2 (Key) (RemovePrefixMembers (FlatMap (Right! (PqReadTopic! $1 (DataSource '"pq" '"high_rate") $4 (Void) '"raw" '"" (Void) '('('"data.datetime.formatname" '"POSIX") '('"data.timestamp.formatname" '"POSIX")))) (lambda '($6) (AsList (FlattenMembers '('"" $6))))) '('_yql_)) '('('type) '('autoref))))
(return (Commit! (Commit! $5 $2) (DataSink '"pq" '"high_rate")))
)

2025-10-27T08:01:25.929487Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.929 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [core] yql_opt_utils.cpp:917: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Enumerate struct object for FlattenMembers
2025-10-27T08:01:25.929576Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.929 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] type_ann_expr.cpp:48: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Execution of [TypeAnnotationTransformer::DoTransform] took 0us
2025-10-27T08:01:25.929637Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.929 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] type_ann_expr.cpp:48: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Execution of [TypeAnnotationTransformer::DoTransform] took 54us
2025-10-27T08:01:25.929653Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.929 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] yql_expr_constraint.cpp:3307: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Execution of [ConstraintTransformer::DoTransform] took 7us
2025-10-27T08:01:25.929699Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.929 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] type_ann_expr.cpp:48: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Execution of [TypeAnnotationTransformer::DoTransform] took 0us
2025-10-27T08:01:25.929715Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.929 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] type_ann_expr.cpp:48: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Execution of [TypeAnnotationTransformer::DoTransform] took 0us
2025-10-27T08:01:25.929754Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.929 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] yql_expr_constraint.cpp:3307: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Execution of [ConstraintTransformer::DoTransform] took 31us
2025-10-27T08:01:25.929775Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.929 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] yql_expr_csee.cpp:638: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Execution of [UpdateCompletness] took 13us
2025-10-27T08:01:25.929839Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.929 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] yql_expr_csee.cpp:651: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Execution of [EliminateCommonSubExpressions] took 58us
2025-10-27T08:01:25.929933Z :YQL_PROXY TRACE: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.929 TRACE ydbd(pid=1702961, tid=0x00007FF5B6E79640) [core] yql_out_transformers.cpp:62: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} OptimizedExpr:
(
(let $1 (Configure! world (DataSource '"config") '"DqEngine" '"force"))
(let $2 (DataSink 'result))
(let $3 '"_yql_sys_create_time")
(let $4 '"_yql_sys_tsp_write_time")
(let $5 '"_yql_sys_partition_id")
(let $6 '"_yql_sys_message_group_id")
(let $7 '('('"system" $3) '('"system" $4) '('"system" $5) '('"system" '"_yql_sys_offset") '('"system" $6) '('"system" '"_yql_sys_seq_no")))
(let $8 (PqTopic '"high_rate" '"local" '"high_rate_input" '('('"PartitionsCount" '"1")) $7 (StructType '('"Data" (DataType 'String)))))
(let $9 (ResWrite! $1 $2 (Key) (RemovePrefixMembers (FlatMap (Right! (PqReadTopic! $1 (DataSource '"pq" '"high_rate") $8 (Void) '"raw" '"" (Void) '('('"data.datetime.formatname" '"POSIX") '('"data.timestamp.formatname" '"POSIX")))) (lambda '($10) (AsList (AsStruct '('"Data" (Member $10 '"Data")) '($3 (Member $10 $3)) '($6 (Member $10 $6)) '('"_yql_sys_offset" (Member $10 '"_yql_sys_offset")) '($5 (Member $10 $5)) '('"_yql_sys_seq_no" (Member $10 '"_yql_sys_seq_no")) '($4 (Member $10 $4)))))) '('_yql_)) '('('type) '('autoref))))
(return (Commit! (Commit! $9 $2) (DataSink '"pq" '"high_rate")))
)

2025-10-27T08:01:25.929986Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.929 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [core] yql_co_simple1.cpp:1194: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} CheckClonedStructure
2025-10-27T08:01:25.930058Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.930 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] type_ann_expr.cpp:48: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Execution of [TypeAnnotationTransformer::DoTransform] took 0us
2025-10-27T08:01:25.930092Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.930 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] type_ann_expr.cpp:48: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Execution of [TypeAnnotationTransformer::DoTransform] took 28us
2025-10-27T08:01:25.930107Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.930 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] yql_expr_constraint.cpp:3307: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Execution of [ConstraintTransformer::DoTransform] took 9us
2025-10-27T08:01:25.930132Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.930 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] type_ann_expr.cpp:48: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Execution of [TypeAnnotationTransformer::DoTransform] took 0us
2025-10-27T08:01:25.930140Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.930 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] type_ann_expr.cpp:48: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Execution of [TypeAnnotationTransformer::DoTransform] took 0us
2025-10-27T08:01:25.930161Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.930 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] yql_expr_constraint.cpp:3307: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Execution of [ConstraintTransformer::DoTransform] took 14us
2025-10-27T08:01:25.930175Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.930 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] yql_expr_csee.cpp:638: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Execution of [UpdateCompletness] took 8us
2025-10-27T08:01:25.930217Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.930 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] yql_expr_csee.cpp:651: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Execution of [EliminateCommonSubExpressions] took 35us
2025-10-27T08:01:25.930275Z :YQL_PROXY TRACE: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.930 TRACE ydbd(pid=1702961, tid=0x00007FF5B6E79640) [core] yql_out_transformers.cpp:62: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} OptimizedExpr:
(
(let $1 (Configure! world (DataSource '"config") '"DqEngine" '"force"))
(let $2 (DataSink 'result))
(let $3 '('('"system" '"_yql_sys_create_time") '('"system" '"_yql_sys_tsp_write_time") '('"system" '"_yql_sys_partition_id") '('"system" '"_yql_sys_offset") '('"system" '"_yql_sys_message_group_id") '('"system" '"_yql_sys_seq_no")))
(let $4 (PqTopic '"high_rate" '"local" '"high_rate_input" '('('"PartitionsCount" '"1")) $3 (StructType '('"Data" (DataType 'String)))))
(let $5 (ResWrite! $1 $2 (Key) (RemovePrefixMembers (FlatMap (Right! (PqReadTopic! $1 (DataSource '"pq" '"high_rate") $4 (Void) '"raw" '"" (Void) '('('"data.datetime.formatname" '"POSIX") '('"data.timestamp.formatname" '"POSIX")))) (lambda '($6) (AsList $6))) '('_yql_)) '('('type) '('autoref))))
(return (Commit! (Commit! $5 $2) (DataSink '"pq" '"high_rate")))
)

2025-10-27T08:01:25.930304Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.930 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [core] yql_co_simple1.cpp:2137: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} FlatMap with single arg AsList
2025-10-27T08:01:25.930360Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.930 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] type_ann_expr.cpp:48: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Execution of [TypeAnnotationTransformer::DoTransform] took 0us
2025-10-27T08:01:25.930389Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.930 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] type_ann_expr.cpp:48: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Execution of [TypeAnnotationTransformer::DoTransform] took 22us
2025-10-27T08:01:25.930406Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.930 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] yql_expr_constraint.cpp:3307: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Execution of [ConstraintTransformer::DoTransform] took 8us
2025-10-27T08:01:25.930435Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.930 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] type_ann_expr.cpp:48: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Execution of [TypeAnnotationTransformer::DoTransform] took 0us
2025-10-27T08:01:25.930442Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.930 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] type_ann_expr.cpp:48: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Execution of [TypeAnnotationTransformer::DoTransform] took 0us
2025-10-27T08:01:25.930463Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.930 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] yql_expr_constraint.cpp:3307: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Execution of [ConstraintTransformer::DoTransform] took 13us
2025-10-27T08:01:25.930479Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.930 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] yql_expr_csee.cpp:638: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Execution of [UpdateCompletness] took 9us
2025-10-27T08:01:25.930523Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.930 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] yql_expr_csee.cpp:651: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Execution of [EliminateCommonSubExpressions] took 37us
2025-10-27T08:01:25.930582Z :YQL_PROXY TRACE: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.930 TRACE ydbd(pid=1702961, tid=0x00007FF5B6E79640) [core] yql_out_transformers.cpp:62: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} OptimizedExpr:
(
(let $1 (Configure! world (DataSource '"config") '"DqEngine" '"force"))
(let $2 (DataSink 'result))
(let $3 '('('"system" '"_yql_sys_create_time") '('"system" '"_yql_sys_tsp_write_time") '('"system" '"_yql_sys_partition_id") '('"system" '"_yql_sys_offset") '('"system" '"_yql_sys_message_group_id") '('"system" '"_yql_sys_seq_no")))
(let $4 (PqTopic '"high_rate" '"local" '"high_rate_input" '('('"PartitionsCount" '"1")) $3 (StructType '('"Data" (DataType 'String)))))
(let $5 (ResWrite! $1 $2 (Key) (RemovePrefixMembers (FlatMap (Right! (PqReadTopic! $1 (DataSource '"pq" '"high_rate") $4 (Void) '"raw" '"" (Void) '('('"data.datetime.formatname" '"POSIX") '('"data.timestamp.formatname" '"POSIX")))) (lambda '($6) (Just $6))) '('_yql_)) '('('type) '('autoref))))
(return (Commit! (Commit! $5 $2) (DataSink '"pq" '"high_rate")))
)

2025-10-27T08:01:25.930610Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.930 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [core] yql_co_simple1.cpp:2149: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} FlatMap with Just
2025-10-27T08:01:25.930657Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.930 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] type_ann_expr.cpp:48: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Execution of [TypeAnnotationTransformer::DoTransform] took 0us
2025-10-27T08:01:25.930691Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.930 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] type_ann_expr.cpp:48: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Execution of [TypeAnnotationTransformer::DoTransform] took 26us
2025-10-27T08:01:25.930708Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.930 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] yql_expr_constraint.cpp:3307: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Execution of [ConstraintTransformer::DoTransform] took 9us
2025-10-27T08:01:25.930726Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.930 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] yql_expr_csee.cpp:638: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Execution of [UpdateCompletness] took 8us
2025-10-27T08:01:25.930767Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.930 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] yql_expr_csee.cpp:651: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Execution of [EliminateCommonSubExpressions] took 34us
2025-10-27T08:01:25.930825Z :YQL_PROXY TRACE: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.930 TRACE ydbd(pid=1702961, tid=0x00007FF5B6E79640) [core] yql_out_transformers.cpp:62: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} OptimizedExpr:
(
(let $1 (Configure! world (DataSource '"config") '"DqEngine" '"force"))
(let $2 (DataSink 'result))
(let $3 '('('"system" '"_yql_sys_create_time") '('"system" '"_yql_sys_tsp_write_time") '('"system" '"_yql_sys_partition_id") '('"system" '"_yql_sys_offset") '('"system" '"_yql_sys_message_group_id") '('"system" '"_yql_sys_seq_no")))
(let $4 (PqTopic '"high_rate" '"local" '"high_rate_input" '('('"PartitionsCount" '"1")) $3 (StructType '('"Data" (DataType 'String)))))
(let $5 (ResWrite! $1 $2 (Key) (RemovePrefixMembers (Right! (PqReadTopic! $1 (DataSource '"pq" '"high_rate") $4 (Void) '"raw" '"" (Void) '('('"data.datetime.formatname" '"POSIX") '('"data.timestamp.formatname" '"POSIX")))) '('_yql_)) '('('type) '('autoref))))
(return (Commit! (Commit! $5 $2) (DataSink '"pq" '"high_rate")))
)

2025-10-27T08:01:25.930849Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.930 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [core] yql_opt_utils.cpp:975: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Expand RemovePrefixMembers
2025-10-27T08:01:25.930902Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.930 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] type_ann_expr.cpp:48: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Execution of [TypeAnnotationTransformer::DoTransform] took 0us
2025-10-27T08:01:25.930928Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.930 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] type_ann_expr.cpp:48: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Execution of [TypeAnnotationTransformer::DoTransform] took 20us
2025-10-27T08:01:25.930948Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.930 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] yql_expr_constraint.cpp:3307: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Execution of [ConstraintTransformer::DoTransform] took 11us
2025-10-27T08:01:25.930964Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.930 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] yql_expr_csee.cpp:638: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Execution of [UpdateCompletness] took 8us
2025-10-27T08:01:25.931009Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.931 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] yql_expr_csee.cpp:651: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Execution of [EliminateCommonSubExpressions] took 37us
2025-10-27T08:01:25.931069Z :YQL_PROXY TRACE: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.931 TRACE ydbd(pid=1702961, tid=0x00007FF5B6E79640) [core] yql_out_transformers.cpp:62: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} OptimizedExpr:
(
(let $1 (Configure! world (DataSource '"config") '"DqEngine" '"force"))
(let $2 (DataSink 'result))
(let $3 '('('"system" '"_yql_sys_create_time") '('"system" '"_yql_sys_tsp_write_time") '('"system" '"_yql_sys_partition_id") '('"system" '"_yql_sys_offset") '('"system" '"_yql_sys_message_group_id") '('"system" '"_yql_sys_seq_no")))
(let $4 (PqTopic '"high_rate" '"local" '"high_rate_input" '('('"PartitionsCount" '"1")) $3 (StructType '('"Data" (DataType 'String)))))
(let $5 (ResWrite! $1 $2 (Key) (ExtractMembers (Right! (PqReadTopic! $1 (DataSource '"pq" '"high_rate") $4 (Void) '"raw" '"" (Void) '('('"data.datetime.formatname" '"POSIX") '('"data.timestamp.formatname" '"POSIX")))) '('"Data")) '('('type) '('autoref))))
(return (Commit! (Commit! $5 $2) (DataSink '"pq" '"high_rate")))
)

2025-10-27T08:01:25.931421Z :YQL_PROXY INFO: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.931 INFO  ydbd(pid=1702961, tid=0x00007FF5B6E79640) [DQ] yql_dq_recapture.cpp:110: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} DqsRecapture
2025-10-27T08:01:25.931519Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.931 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] type_ann_expr.cpp:48: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Execution of [TypeAnnotationTransformer::DoTransform] took 0us
2025-10-27T08:01:25.931592Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.931 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] type_ann_expr.cpp:48: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Execution of [TypeAnnotationTransformer::DoTransform] took 64us
2025-10-27T08:01:25.931644Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.931 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] yql_expr_constraint.cpp:3307: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Execution of [ConstraintTransformer::DoTransform] took 44us
2025-10-27T08:01:25.931668Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.931 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] yql_expr_csee.cpp:638: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Execution of [UpdateCompletness] took 15us
2025-10-27T08:01:25.931760Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.931 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] yql_expr_csee.cpp:651: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Execution of [EliminateCommonSubExpressions] took 84us
2025-10-27T08:01:25.931880Z :YQL_PROXY TRACE: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.931 TRACE ydbd(pid=1702961, tid=0x00007FF5B6E79640) [core] yql_out_transformers.cpp:62: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} OptimizedExpr:
(
(let $1 (Configure! world (DataSource '"config") '"DqEngine" '"force"))
(let $2 (DataSink 'result))
(let $3 '"_yql_sys_create_time")
(let $4 '"_yql_sys_tsp_write_time")
(let $5 '"_yql_sys_partition_id")
(let $6 '"_yql_sys_message_group_id")
(let $7 '('('"system" $3) '('"system" $4) '('"system" $5) '('"system" '"_yql_sys_offset") '('"system" $6) '('"system" '"_yql_sys_seq_no")))
(let $8 (DataType 'String))
(let $9 '('"Data" $8))
(let $10 (PqTopic '"high_rate" '"local" '"high_rate_input" '('('"PartitionsCount" '"1")) $7 (StructType $9)))
(let $11 '('"Data"))
(let $12 '('"SharedReading" '"0"))
(let $13 '('('"Endpoint" '"localhost:30711") $12 '('"ReconnectPeriod" '"") '('"Format" '"raw") '('"ReadGroup" '"ptcudts2os05kjn50skg") '('"AddBearerToToken" '"1")))
(let $14 (DataType 'Timestamp))
(let $15 (DataType 'Uint64))
(let $16 (StructType $9 '($3 $14) '($6 $8) '('"_yql_sys_offset" $15) '($5 $15) '('"_yql_sys_seq_no" $15) '($4 $14)))
(let $17 (DqPqTopicSource $1 $10 $11 $13 (SecureParam '"cluster:default_high_rate") '"" $16 '""))
(let $18 '($3 $4 $5 '"_yql_sys_offset" $6 '"_yql_sys_seq_no"))
(let $19 '('('"format" '"raw") '('"metadataColumns" $18) '('"formatSettings" '('('"data.datetime.formatname" '"POSIX") '('"data.timestamp.formatname" '"POSIX"))) '('"settings" '($12))))
(let $20 (DqSourceWrap $17 (DataSource '"pq" '"high_rate") $16 $19))
(let $21 (ResWrite! $1 $2 (Key) (ExtractMembers $20 $11) '('('type) '('autoref))))
(return (Commit! (Commit! $21 $2) (DataSink '"pq" '"high_rate")))
)

2025-10-27T08:01:25.932629Z :YQL_PROXY INFO: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.932 INFO  ydbd(pid=1702961, tid=0x00007FF5B6E79640) [PQ] yql_optimize.cpp:131: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} LogicalOptimizer-ExtractMembersOverDqWrap
2025-10-27T08:01:25.932693Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.932 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] type_ann_expr.cpp:48: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Execution of [TypeAnnotationTransformer::DoTransform] took 0us
2025-10-27T08:01:25.932738Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.932 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] type_ann_expr.cpp:48: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Execution of [TypeAnnotationTransformer::DoTransform] took 36us
2025-10-27T08:01:25.932772Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.932 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] yql_expr_constraint.cpp:3307: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Execution of [ConstraintTransformer::DoTransform] took 25us
2025-10-27T08:01:25.932790Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.932 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] yql_expr_csee.cpp:638: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Execution of [UpdateCompletness] took 10us
2025-10-27T08:01:25.932844Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.932 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] yql_expr_csee.cpp:651: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Execution of [EliminateCommonSubExpressions] took 46us
2025-10-27T08:01:25.932923Z :YQL_PROXY TRACE: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.932 TRACE ydbd(pid=1702961, tid=0x00007FF5B6E79640) [core] yql_out_transformers.cpp:62: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} OptimizedExpr:
(
(let $1 (Configure! world (DataSource '"config") '"DqEngine" '"force"))
(let $2 (DataSink 'result))
(let $3 (StructType '('"Data" (DataType 'String))))
(let $4 (PqTopic '"high_rate" '"local" '"high_rate_input" '('('"PartitionsCount" '"1")) '() $3))
(let $5 '('"SharedReading" '"0"))
(let $6 '('('"Endpoint" '"localhost:30711") $5 '('"ReconnectPeriod" '"") '('"Format" '"raw") '('"ReadGroup" '"ptcudts2os05kjn50skg") '('"AddBearerToToken" '"1")))
(let $7 (DqPqTopicSource $1 $4 '('"Data") $6 (SecureParam '"cluster:default_high_rate") '"" $3 '""))
(let $8 '('('"format" '"raw") '('"formatSettings" '('('"data.datetime.formatname" '"POSIX") '('"data.timestamp.formatname" '"POSIX"))) '('"settings" '($5))))
(let $9 (DqSourceWrap $7 (DataSource '"pq" '"high_rate") $3 $8))
(let $10 (ResWrite! $1 $2 (Key) $9 '('('type) '('autoref))))
(return (Commit! (Commit! $10 $2) (DataSink '"pq" '"high_rate")))
)

2025-10-27T08:01:25.933324Z :YQL_PROXY INFO: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.933 INFO  ydbd(pid=1702961, tid=0x00007FF5B6E79640) [DQ] yql_optimize.cpp:131: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} DqsPhy-BuildStageWithSourceWrap
2025-10-27T08:01:25.933396Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.933 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] type_ann_expr.cpp:48: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Execution of [TypeAnnotationTransformer::DoTransform] took 0us
2025-10-27T08:01:25.933486Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.933 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] type_ann_expr.cpp:48: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Execution of [TypeAnnotationTransformer::DoTransform] took 81us
2025-10-27T08:01:25.933521Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.933 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] yql_expr_constraint.cpp:3307: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Execution of [ConstraintTransformer::DoTransform] took 26us
2025-10-27T08:01:25.933561Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.933 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] type_ann_expr.cpp:48: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Execution of [TypeAnnotationTransformer::DoTransform] took 0us
2025-10-27T08:01:25.933569Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.933 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] type_ann_expr.cpp:48: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Execution of [TypeAnnotationTransformer::DoTransform] took 1us
2025-10-27T08:01:25.933593Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.933 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] yql_expr_constraint.cpp:3307: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Execution of [ConstraintTransformer::DoTransform] took 15us
2025-10-27T08:01:25.933629Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.933 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] type_ann_expr.cpp:48: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Execution of [TypeAnnotationTransformer::DoTransform] took 0us
2025-10-27T08:01:25.933637Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.933 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] type_ann_expr.cpp:48: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Execution of [TypeAnnotationTransformer::DoTransform] took 1us
2025-10-27T08:01:25.933669Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.933 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] yql_expr_constraint.cpp:3307: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Execution of [ConstraintTransformer::DoTransform] took 25us
2025-10-27T08:01:25.933692Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.933 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] yql_expr_csee.cpp:638: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Execution of [UpdateCompletness] took 15us
2025-10-27T08:01:25.933775Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.933 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] yql_expr_csee.cpp:651: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Execution of [EliminateCommonSubExpressions] took 74us
2025-10-27T08:01:25.935021Z :YQL_PROXY TRACE: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.934 TRACE ydbd(pid=1702961, tid=0x00007FF5B6E79640) [core] yql_out_transformers.cpp:62: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} OptimizedExpr:
(
(let $1 (Configure! world (DataSource '"config") '"DqEngine" '"force"))
(let $2 (DataSink 'result))
(let $3 (DataSource '"pq" '"high_rate"))
(let $4 (StructType '('"Data" (DataType 'String))))
(let $5 (PqTopic '"high_rate" '"local" '"high_rate_input" '('('"PartitionsCount" '"1")) '() $4))
(let $6 '('"SharedReading" '"0"))
(let $7 '('('"Endpoint" '"localhost:30711") $6 '('"ReconnectPeriod" '"") '('"Format" '"raw") '('"ReadGroup" '"ptcudts2os05kjn50skg") '('"AddBearerToToken" '"1")))
(let $8 (DqPqTopicSource $1 $5 '('"Data") $7 (SecureParam '"cluster:default_high_rate") '"" $4 '""))
(let $9 (DqStage '((DqSource $3 $8)) (lambda '($11) (block '(
  (let $12 '('('"format" '"raw") '('"formatSettings" '('('"data.datetime.formatname" '"POSIX") '('"data.timestamp.formatname" '"POSIX"))) '('"settings" '($6))))
  (let $13 (DqSourceWideWrap $11 $3 $4 $12))
  (return (NarrowMap $13 (lambda '($14) (AsStruct '('"Data" $14)))))
))) '('('"_logical_id" '200191))))
(let $10 (ResWrite! $1 $2 (Key) (DqCnUnionAll (TDqOutput $9 '"0")) '('('type) '('autoref))))
(return (Commit! (Commit! $10 $2) (DataSink '"pq" '"high_rate")))
)

2025-10-27T08:01:25.935873Z :YQL_PROXY TRACE: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.935 TRACE ydbd(pid=1702961, tid=0x00007FF5B6E79640) [core dq] dq_opt_phy_finalizing.cpp:488: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} DqReplicateStageMultiOutput: start traverse node #200202, Commit!
2025-10-27T08:01:25.935886Z :YQL_PROXY TRACE: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.935 TRACE ydbd(pid=1702961, tid=0x00007FF5B6E79640) [core dq] dq_opt_phy_finalizing.cpp:517: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} DqReplicateStageMultiOutput: test connection DqCnUnionAll (#200199)
2025-10-27T08:01:25.936047Z :YQL_PROXY INFO: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.936 INFO  ydbd(pid=1702961, tid=0x00007FF5B6E79640) [RESULT] yql_result_provider.cpp:771: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} ResPull
2025-10-27T08:01:25.936137Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.936 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] type_ann_expr.cpp:48: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Execution of [TypeAnnotationTransformer::DoTransform] took 0us
2025-10-27T08:01:25.936234Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.936 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] type_ann_expr.cpp:48: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Execution of [TypeAnnotationTransformer::DoTransform] took 87us
2025-10-27T08:01:25.936281Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.936 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] yql_expr_constraint.cpp:3307: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Execution of [ConstraintTransformer::DoTransform] took 37us
2025-10-27T08:01:25.936324Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.936 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] type_ann_expr.cpp:48: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Execution of [TypeAnnotationTransformer::DoTransform] took 0us
2025-10-27T08:01:25.936332Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.936 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] type_ann_expr.cpp:48: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Execution of [TypeAnnotationTransformer::DoTransform] took 0us
2025-10-27T08:01:25.936359Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.936 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] yql_expr_constraint.cpp:3307: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Execution of [ConstraintTransformer::DoTransform] took 19us
2025-10-27T08:01:25.936383Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.936 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] yql_expr_csee.cpp:638: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Execution of [UpdateCompletness] took 16us
2025-10-27T08:01:25.936461Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.936 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] yql_expr_csee.cpp:651: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Execution of [EliminateCommonSubExpressions] took 70us
2025-10-27T08:01:25.936573Z :YQL_PROXY TRACE: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.936 TRACE ydbd(pid=1702961, tid=0x00007FF5B6E79640) [core] yql_out_transformers.cpp:62: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} OptimizedExpr:
(
(let $1 (Configure! world (DataSource '"config") '"DqEngine" '"force"))
(let $2 (DataSink 'result))
(let $3 (DataSource '"pq" '"high_rate"))
(let $4 (StructType '('"Data" (DataType 'String))))
(let $5 (PqTopic '"high_rate" '"local" '"high_rate_input" '('('"PartitionsCount" '"1")) '() $4))
(let $6 '('"SharedReading" '"0"))
(let $7 '('('"Endpoint" '"localhost:30711") $6 '('"ReconnectPeriod" '"") '('"Format" '"raw") '('"ReadGroup" '"ptcudts2os05kjn50skg") '('"AddBearerToToken" '"1")))
(let $8 (DqPqTopicSource world $5 '('"Data") $7 (SecureParam '"cluster:default_high_rate") '"" $4 '""))
(let $9 (DqStage '((DqSource $3 $8)) (lambda '($12) (block '(
  (let $13 '('('"format" '"raw") '('"formatSettings" '('('"data.datetime.formatname" '"POSIX") '('"data.timestamp.formatname" '"POSIX"))) '('"settings" '($6))))
  (let $14 (DqSourceWideWrap $12 $3 $4 $13))
  (return (NarrowMap $14 (lambda '($15) (AsStruct '('"Data" $15)))))
))) '('('"_logical_id" '200191))))
(let $10 (DqStage '((DqCnUnionAll (TDqOutput $9 '"0"))) (lambda '($16) $16) '('('"_logical_id" '200224))))
(let $11 (ResPull! (Sync! $1 $1) $2 (Key) (DqCnResult (TDqOutput $10 '"0") '()) '('('type) '('autoref)) '"dq"))
(return (Commit! (Commit! $11 $2) (DataSink '"pq" '"high_rate")))
)

2025-10-27T08:01:25.936659Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.936 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [core] yql_co_simple2.cpp:325: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Simplify Sync!
2025-10-27T08:01:25.936748Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.936 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] type_ann_expr.cpp:48: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Execution of [TypeAnnotationTransformer::DoTransform] took 1us
2025-10-27T08:01:25.936772Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.936 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] type_ann_expr.cpp:48: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Execution of [TypeAnnotationTransformer::DoTransform] took 14us
2025-10-27T08:01:25.936789Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.936 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] yql_expr_constraint.cpp:3307: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Execution of [ConstraintTransformer::DoTransform] took 9us
2025-10-27T08:01:25.936812Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.936 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] yql_expr_csee.cpp:638: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Execution of [UpdateCompletness] took 14us
2025-10-27T08:01:25.936875Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.936 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] yql_expr_csee.cpp:651: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Execution of [EliminateCommonSubExpressions] took 55us
2025-10-27T08:01:25.936975Z :YQL_PROXY TRACE: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.936 TRACE ydbd(pid=1702961, tid=0x00007FF5B6E79640) [core] yql_out_transformers.cpp:62: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} OptimizedExpr:
(
(let $1 (Configure! world (DataSource '"config") '"DqEngine" '"force"))
(let $2 (DataSink 'result))
(let $3 (DataSource '"pq" '"high_rate"))
(let $4 (StructType '('"Data" (DataType 'String))))
(let $5 (PqTopic '"high_rate" '"local" '"high_rate_input" '('('"PartitionsCount" '"1")) '() $4))
(let $6 '('"SharedReading" '"0"))
(let $7 '('('"Endpoint" '"localhost:30711") $6 '('"ReconnectPeriod" '"") '('"Format" '"raw") '('"ReadGroup" '"ptcudts2os05kjn50skg") '('"AddBearerToToken" '"1")))
(let $8 (DqPqTopicSource world $5 '('"Data") $7 (SecureParam '"cluster:default_high_rate") '"" $4 '""))
(let $9 (DqStage '((DqSource $3 $8)) (lambda '($12) (block '(
  (let $13 '('('"format" '"raw") '('"formatSettings" '('('"data.datetime.formatname" '"POSIX") '('"data.timestamp.formatname" '"POSIX"))) '('"settings" '($6))))
  (let $14 (DqSourceWideWrap $12 $3 $4 $13))
  (return (NarrowMap $14 (lambda '($15) (AsStruct '('"Data" $15)))))
))) '('('"_logical_id" '200191))))
(let $10 (DqStage '((DqCnUnionAll (TDqOutput $9 '"0"))) (lambda '($16) $16) '('('"_logical_id" '200224))))
(let $11 (ResPull! $1 $2 (Key) (DqCnResult (TDqOutput $10 '"0") '()) '('('type) '('autoref)) '"dq"))
(return (Commit! (Commit! $11 $2) (DataSink '"pq" '"high_rate")))
)

2025-10-27T08:01:25.937586Z :YQL_PROXY TRACE: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.937 TRACE ydbd(pid=1702961, tid=0x00007FF5B6E79640) [core dq] dq_opt_phy_finalizing.cpp:488: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} DqReplicateStageMultiOutput: start traverse node #200245, Commit!
2025-10-27T08:01:25.937597Z :YQL_PROXY TRACE: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.937 TRACE ydbd(pid=1702961, tid=0x00007FF5B6E79640) [core dq] dq_opt_phy_finalizing.cpp:517: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} DqReplicateStageMultiOutput: test connection DqCnResult (#200233)
2025-10-27T08:01:25.937605Z :YQL_PROXY TRACE: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.937 TRACE ydbd(pid=1702961, tid=0x00007FF5B6E79640) [core dq] dq_opt_phy_finalizing.cpp:517: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} DqReplicateStageMultiOutput: test connection DqCnUnionAll (#200220)
2025-10-27T08:01:25.937871Z :YQL_PROXY INFO: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.937 INFO  ydbd(pid=1702961, tid=0x00007FF5B6E79640) [core exec] yql_execution.cpp:61: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Begin, root #200245
2025-10-27T08:01:25.937881Z :YQL_PROXY INFO: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.937 INFO  ydbd(pid=1702961, tid=0x00007FF5B6E79640) [core exec] yql_execution.cpp:74: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Collect unused nodes for root #200245, status: Ok
2025-10-27T08:01:25.937890Z :YQL_PROXY TRACE: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.937 TRACE ydbd(pid=1702961, tid=0x00007FF5B6E79640) [core exec] yql_execution.cpp:411: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} {0}, callable #200245 <Commit!>
2025-10-27T08:01:25.937898Z :YQL_PROXY TRACE: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.937 TRACE ydbd(pid=1702961, tid=0x00007FF5B6E79640) [core exec] yql_execution.cpp:411: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} {1}, callable #200244 <Commit!>
2025-10-27T08:01:25.937905Z :YQL_PROXY TRACE: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.937 TRACE ydbd(pid=1702961, tid=0x00007FF5B6E79640) [core exec] yql_execution.cpp:411: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} {2}, callable #200243 <ResPull!>
2025-10-27T08:01:25.937919Z :YQL_PROXY TRACE: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.937 TRACE ydbd(pid=1702961, tid=0x00007FF5B6E79640) [core exec] yql_execution.cpp:411: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} {3}, callable #199812 <Configure!>
2025-10-27T08:01:25.937928Z :YQL_PROXY TRACE: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.937 TRACE ydbd(pid=1702961, tid=0x00007FF5B6E79640) [core exec] yql_execution.cpp:411: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} {3}, callable #199812 <Configure!>
2025-10-27T08:01:25.937938Z :YQL_PROXY INFO: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.937 INFO  ydbd(pid=1702961, tid=0x00007FF5B6E79640) [core exec] yql_execution.cpp:630: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Node #199812<Configure!> finished execution
2025-10-27T08:01:25.937947Z :YQL_PROXY INFO: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.937 INFO  ydbd(pid=1702961, tid=0x00007FF5B6E79640) [core exec] yql_execution.cpp:647: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Node #199812<Configure!> created 0 trackable nodes: 
2025-10-27T08:01:25.937955Z :YQL_PROXY TRACE: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.937 TRACE ydbd(pid=1702961, tid=0x00007FF5B6E79640) [core exec] yql_execution.cpp:411: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} {3}, callable #200233 <DqCnResult>
2025-10-27T08:01:25.937972Z :YQL_PROXY INFO: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.937 INFO  ydbd(pid=1702961, tid=0x00007FF5B6E79640) [core exec] yql_execution.cpp:630: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Node #200233<DqCnResult> finished execution
2025-10-27T08:01:25.937979Z :YQL_PROXY INFO: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.937 INFO  ydbd(pid=1702961, tid=0x00007FF5B6E79640) [core exec] yql_execution.cpp:647: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Node #200233<DqCnResult> created 0 trackable nodes: 
2025-10-27T08:01:25.937987Z :YQL_PROXY TRACE: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.937 TRACE ydbd(pid=1702961, tid=0x00007FF5B6E79640) [core exec] yql_execution.cpp:411: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} {2}, callable #200243 <ResPull!>
2025-10-27T08:01:25.938024Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.938 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [DQ] yql_dq_exectransformer.cpp:1298: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud/#200243/#200255} Executing Pull (UniqueId=200255)
2025-10-27T08:01:25.938147Z :YQL_PROXY TRACE: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.938 TRACE ydbd(pid=1702961, tid=0x00007FF5B6E79640) [DQ] yql_dq_exectransformer.cpp:1299: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud/#200243/#200255} HandlePull (
(let $1 (DataSource '"pq" '"high_rate"))
(let $2 (StructType '('"Data" (DataType 'String))))
(let $3 (PqTopic '"high_rate" '"local" '"high_rate_input" '('('"PartitionsCount" '"1")) '() $2))
(let $4 '('"SharedReading" '"0"))
(let $5 '('('"Endpoint" '"localhost:30711") $4 '('"ReconnectPeriod" '"") '('"Format" '"raw") '('"ReadGroup" '"ptcudts2os05kjn50skg") '('"AddBearerToToken" '"1")))
(let $6 (DqPqTopicSource world $3 '('"Data") $5 (SecureParam '"cluster:default_high_rate") '"" $2 '""))
(let $7 (DqStage '((DqSource $1 $6)) (lambda '($13) (block '(
  (let $14 '('('"format" '"raw") '('"formatSettings" '('('"data.datetime.formatname" '"POSIX") '('"data.timestamp.formatname" '"POSIX"))) '('"settings" '($4))))
  (let $15 (DqSourceWideWrap $13 $1 $2 $14))
  (return (NarrowMap $15 (lambda '($16) (AsStruct '('"Data" $16)))))
))) '('('"_logical_id" '200191))))
(let $8 (DqStage '((DqCnUnionAll (TDqOutput $7 '"0"))) (lambda '($17) $17) '('('"_logical_id" '200224))))
(let $9 (DqCnResult (TDqOutput $8 '"0") '()))
(let $10 '('('type) '('autoref)))
(let $11 (Configure! world (DataSource '"config") '"DqEngine" '"force"))
(let $12 (ResPull! $11 (DataSink 'result) (Key) $9 $10 '"dq"))
(return (Pull $9 '"100000" '"1000" '"0" $10 '"0" '"" '"0" $12))
)

2025-10-27T08:01:25.938293Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.938 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] type_ann_expr.cpp:48: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud/#200243/#200255} Execution of [TypeAnnotationTransformer::DoTransform] took 6us
2025-10-27T08:01:25.938306Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.938 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] yql_expr_constraint.cpp:3307: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud/#200243/#200255} Execution of [ConstraintTransformer::DoTransform] took 4us
2025-10-27T08:01:25.938327Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.938 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] yql_expr_csee.cpp:638: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud/#200243/#200255} Execution of [UpdateCompletness] took 13us
2025-10-27T08:01:25.938385Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.938 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] yql_expr_csee.cpp:651: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud/#200243/#200255} Execution of [EliminateCommonSubExpressionsForSubGraph] took 50us
2025-10-27T08:01:25.938480Z :YQL_PROXY TRACE: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:25.938 TRACE ydbd(pid=1702961, tid=0x00007FF5B6E79640) [core peephole] yql_out_transformers.cpp:62: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud/#200243/#200255} PeepHoleOpt:
(
(let $1 (DataSource '"pq" '"high_rate"))
(let $2 (StructType '('"Data" (DataType 'String))))
(let $3 (PqTopic '"high_rate" '"local" '"high_rate_input" '('('"PartitionsCount" '"1")) '() $2))
(let $4 '('"SharedReading" '"0"))
(let $5 '('('"Endpoint" '"localhost:30711") $4 '('"ReconnectPeriod" '"") '('"Format" '"raw") '('"ReadGroup" '"ptcudts2os05kjn50skg") '('"AddBearerToToken" '"1")))
(let $6 (DqPqTopicSource world $3 '('"Data") $5 (SecureParam '"cluster:default_high_rate") '"" $2 '""))
(let $7 (DqStage '((DqSource $1 $6)) (lambda '($9) (block '(
  (let $10 '('('"format" '"raw") '('"formatSettings" '('('"data.datetime.formatname" '"POSIX") '('"data.timestamp.formatname" '"POSIX"))) '('"settings" '($4))))
  (let $11 (DqSourceWideWrap $9 $1 $2 $10))
  (return (NarrowMap $11 (lambda '($12) (AsStruct '('"Data" $12)))))
))) '('('"_logical_id" '200191))))
(let $8 (DqStage '((DqCnUnionAll (TDqOutput $7 '"0"))) (lambda '($13) $13) '('('"_logical_id" '200224))))
(return (DqCnResult (TDqOutput $8 '"0") '()))
)

2025-10-27T08:01:26.007412Z :YQL_PROXY TRACE: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:26.007 TRACE ydbd(pid=1702961, tid=0x00007FF5B6E79640) [core dq] dq_opt_phy_finalizing.cpp:488: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud/#200243/#200255} DqReplicateStageMultiOutput: start traverse node #200256, DqCnResult
2025-10-27T08:01:26.007442Z :YQL_PROXY TRACE: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:26.007 TRACE ydbd(pid=1702961, tid=0x00007FF5B6E79640) [core dq] dq_opt_phy_finalizing.cpp:517: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud/#200243/#200255} DqReplicateStageMultiOutput: test connection DqCnUnionAll (#200220)
2025-10-27T08:01:26.007567Z :YQL_PROXY TRACE: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:26.007 TRACE ydbd(pid=1702961, tid=0x00007FF5B6E79640) [core dq] dq_opt_build.cpp:235: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud/#200243/#200255} [DQ/Build/TransformConsumers] (
(let $1 (DataSource '"pq" '"high_rate"))
(let $2 (StructType '('"Data" (DataType 'String))))
(let $3 (PqTopic '"high_rate" '"local" '"high_rate_input" '('('"PartitionsCount" '"1")) '() $2))
(let $4 '('"SharedReading" '"0"))
(let $5 '('('"Endpoint" '"localhost:30711") $4 '('"ReconnectPeriod" '"") '('"Format" '"raw") '('"ReadGroup" '"ptcudts2os05kjn50skg") '('"AddBearerToToken" '"1")))
(let $6 (DqPqTopicSource world $3 '('"Data") $5 (SecureParam '"cluster:default_high_rate") '"" $2 '""))
(let $7 (DqStage '((DqSource $1 $6)) (lambda '($9) (block '(
  (let $10 '('('"format" '"raw") '('"formatSettings" '('('"data.datetime.formatname" '"POSIX") '('"data.timestamp.formatname" '"POSIX"))) '('"settings" '($4))))
  (let $11 (DqSourceWideWrap $9 $1 $2 $10))
  (return (NarrowMap $11 (lambda '($12) (AsStruct '('"Data" $12)))))
))) '('('"_logical_id" '200191))))
(let $8 (DqStage '((DqCnUnionAll (TDqOutput $7 '"0"))) (lambda '($13) $13) '('('"_logical_id" '200224))))
(return (DqCnResult (TDqOutput $8 '"0") '()))
)

2025-10-27T08:01:26.007659Z :YQL_PROXY TRACE: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:26.007 TRACE ydbd(pid=1702961, tid=0x00007FF5B6E79640) [core dq] dq_opt_build.cpp:325: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud/#200243/#200255} [DQ/Build/TransformPhysical] (
(let $1 (DataSource '"pq" '"high_rate"))
(let $2 (StructType '('"Data" (DataType 'String))))
(let $3 (PqTopic '"high_rate" '"local" '"high_rate_input" '('('"PartitionsCount" '"1")) '() $2))
(let $4 '('"SharedReading" '"0"))
(let $5 '('('"Endpoint" '"localhost:30711") $4 '('"ReconnectPeriod" '"") '('"Format" '"raw") '('"ReadGroup" '"ptcudts2os05kjn50skg") '('"AddBearerToToken" '"1")))
(let $6 (DqPqTopicSource world $3 '('"Data") $5 (SecureParam '"cluster:default_high_rate") '"" $2 '""))
(let $7 (DqStage '((DqSource $1 $6)) (lambda '($9) (block '(
  (let $10 '('('"format" '"raw") '('"formatSettings" '('('"data.datetime.formatname" '"POSIX") '('"data.timestamp.formatname" '"POSIX"))) '('"settings" '($4))))
  (let $11 (DqSourceWideWrap $9 $1 $2 $10))
  (return (NarrowMap $11 (lambda '($12) (AsStruct '('"Data" $12)))))
))) '('('"_logical_id" '200191))))
(let $8 (DqStage '((DqCnUnionAll (TDqOutput $7 '"0"))) (lambda '($13) $13) '('('"_logical_id" '200224))))
(return (DqCnResult (TDqOutput $8 '"0") '()))
)

2025-10-27T08:01:26.007729Z :YQL_PROXY TRACE: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:26.007 TRACE ydbd(pid=1702961, tid=0x00007FF5B6E79640) [core dq] dq_opt_build.cpp:363: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud/#200243/#200255}  [DQ/Build/TransformPhysical] replace stage #200229 -> #200270
2025-10-27T08:01:26.007760Z :YQL_PROXY TRACE: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:26.007 TRACE ydbd(pid=1702961, tid=0x00007FF5B6E79640) [core dq] dq_opt_build.cpp:363: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud/#200243/#200255}  [DQ/Build/TransformPhysical] replace stage #200218 -> #200285
2025-10-27T08:01:26.007935Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:26.007 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] type_ann_expr.cpp:48: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud/#200243/#200255} Execution of [TypeAnnotationTransformer::DoTransform] took 109us
2025-10-27T08:01:26.007968Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:26.007 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] yql_expr_constraint.cpp:3307: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud/#200243/#200255} Execution of [ConstraintTransformer::DoTransform] took 23us
2025-10-27T08:01:26.007976Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:26.007 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] type_ann_expr.cpp:48: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud/#200243/#200255} Execution of [TypeAnnotationTransformer::DoTransform] took 0us
2025-10-27T08:01:26.008016Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:26.008 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] yql_expr_constraint.cpp:3307: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud/#200243/#200255} Execution of [ConstraintTransformer::DoTransform] took 31us
2025-10-27T08:01:26.008024Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:26.008 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] type_ann_expr.cpp:48: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud/#200243/#200255} Execution of [TypeAnnotationTransformer::DoTransform] took 0us
2025-10-27T08:01:26.008044Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:26.008 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] yql_expr_constraint.cpp:3307: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud/#200243/#200255} Execution of [ConstraintTransformer::DoTransform] took 13us
2025-10-27T08:01:26.008068Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:26.008 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] yql_expr_csee.cpp:638: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud/#200243/#200255} Execution of [UpdateCompletness] took 15us
2025-10-27T08:01:26.008168Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:26.008 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] yql_expr_csee.cpp:651: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud/#200243/#200255} Execution of [EliminateCommonSubExpressionsForSubGraph] took 91us
2025-10-27T08:01:26.008263Z :YQL_PROXY TRACE: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:26.008 TRACE ydbd(pid=1702961, tid=0x00007FF5B6E79640) [core peephole] yql_out_transformers.cpp:62: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud/#200243/#200255} PeepHoleOpt:
(
(let $1 (DataSource '"pq" '"high_rate"))
(let $2 (StructType '('"Data" (DataType 'String))))
(let $3 (PqTopic '"high_rate" '"local" '"high_rate_input" '('('"PartitionsCount" '"1")) '() $2))
(let $4 '('"SharedReading" '"0"))
(let $5 '('('"Endpoint" '"localhost:30711") $4 '('"ReconnectPeriod" '"") '('"Format" '"raw") '('"ReadGroup" '"ptcudts2os05kjn50skg") '('"AddBearerToToken" '"1")))
(let $6 (DqPqTopicSource world $3 '('"Data") $5 (SecureParam '"cluster:default_high_rate") '"" $2 '""))
(let $7 (DqPhyStage '((DqSource $1 $6)) (lambda '($9) (block '(
  (let $10 '('('"format" '"raw") '('"formatSettings" '('('"data.datetime.formatname" '"POSIX") '('"data.timestamp.formatname" '"POSIX"))) '('"settings" '($4))))
  (let $11 (DqSourceWideWrap $9 $1 $2 $10))
  (return (FromFlow (NarrowMap $11 (lambda '($12) (AsStruct '('"Data" $12))))))
))) '('('"_logical_id" '200191) '('"_id" '"6f03bcec-69942c8f-c5731a4d-a8d42300"))))
(let $8 (DqPhyStage '((DqCnUnionAll (TDqOutput $7 '"0"))) (lambda '($13) (FromFlow (ToFlow $13))) '('('"_logical_id" '200224) '('"_id" '"f3b1e8da-48c22a4c-df8b4ab7-78b22502"))))
(return (DqCnResult (TDqOutput $8 '"0") '()))
)

2025-10-27T08:01:26.008412Z :YQL_PROXY TRACE: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:26.008 TRACE ydbd(pid=1702961, tid=0x00007FF5B6E79640) [core dq] dq_opt_build.cpp:235: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud/#200243/#200255} [DQ/Build/TransformConsumers] (
(let $1 (DataSource '"pq" '"high_rate"))
(let $2 (StructType '('"Data" (DataType 'String))))
(let $3 (PqTopic '"high_rate" '"local" '"high_rate_input" '('('"PartitionsCount" '"1")) '() $2))
(let $4 '('"SharedReading" '"0"))
(let $5 '('('"Endpoint" '"localhost:30711") $4 '('"ReconnectPeriod" '"") '('"Format" '"raw") '('"ReadGroup" '"ptcudts2os05kjn50skg") '('"AddBearerToToken" '"1")))
(let $6 (DqPqTopicSource world $3 '('"Data") $5 (SecureParam '"cluster:default_high_rate") '"" $2 '""))
(let $7 (DqPhyStage '((DqSource $1 $6)) (lambda '($9) (block '(
  (let $10 '('('"format" '"raw") '('"formatSettings" '('('"data.datetime.formatname" '"POSIX") '('"data.timestamp.formatname" '"POSIX"))) '('"settings" '($4))))
  (let $11 (DqSourceWideWrap $9 $1 $2 $10))
  (return (FromFlow (NarrowMap $11 (lambda '($12) (AsStruct '('"Data" $12))))))
))) '('('"_logical_id" '200191) '('"_id" '"6f03bcec-69942c8f-c5731a4d-a8d42300"))))
(let $8 (DqPhyStage '((DqCnUnionAll (TDqOutput $7 '"0"))) (lambda '($13) (FromFlow (ToFlow $13))) '('('"_logical_id" '200224) '('"_id" '"f3b1e8da-48c22a4c-df8b4ab7-78b22502"))))
(return (DqCnResult (TDqOutput $8 '"0") '()))
)

2025-10-27T08:01:26.008500Z :YQL_PROXY TRACE: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:26.008 TRACE ydbd(pid=1702961, tid=0x00007FF5B6E79640) [core dq] dq_opt_build.cpp:325: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud/#200243/#200255} [DQ/Build/TransformPhysical] (
(let $1 (DataSource '"pq" '"high_rate"))
(let $2 (StructType '('"Data" (DataType 'String))))
(let $3 (PqTopic '"high_rate" '"local" '"high_rate_input" '('('"PartitionsCount" '"1")) '() $2))
(let $4 '('"SharedReading" '"0"))
(let $5 '('('"Endpoint" '"localhost:30711") $4 '('"ReconnectPeriod" '"") '('"Format" '"raw") '('"ReadGroup" '"ptcudts2os05kjn50skg") '('"AddBearerToToken" '"1")))
(let $6 (DqPqTopicSource world $3 '('"Data") $5 (SecureParam '"cluster:default_high_rate") '"" $2 '""))
(let $7 (DqPhyStage '((DqSource $1 $6)) (lambda '($9) (block '(
  (let $10 '('('"format" '"raw") '('"formatSettings" '('('"data.datetime.formatname" '"POSIX") '('"data.timestamp.formatname" '"POSIX"))) '('"settings" '($4))))
  (let $11 (DqSourceWideWrap $9 $1 $2 $10))
  (return (FromFlow (NarrowMap $11 (lambda '($12) (AsStruct '('"Data" $12))))))
))) '('('"_logical_id" '200191) '('"_id" '"6f03bcec-69942c8f-c5731a4d-a8d42300"))))
(let $8 (DqPhyStage '((DqCnUnionAll (TDqOutput $7 '"0"))) (lambda '($13) (FromFlow (ToFlow $13))) '('('"_logical_id" '200224) '('"_id" '"f3b1e8da-48c22a4c-df8b4ab7-78b22502"))))
(return (DqCnResult (TDqOutput $8 '"0") '()))
)

2025-10-27T08:01:26.008862Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:26.008 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [core] yql_co_flow2.cpp:1470: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud/#200243/#200255} Drop FromFlow with ToFlow
2025-10-27T08:01:26.008917Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:26.008 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] type_ann_expr.cpp:48: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud/#200243/#200255} Execution of [TypeAnnotationTransformer::DoTransform] took 28us
2025-10-27T08:01:26.008932Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:26.008 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] yql_expr_constraint.cpp:3307: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud/#200243/#200255} Execution of [ConstraintTransformer::DoTransform] took 7us
2025-10-27T08:01:26.008939Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:26.008 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] type_ann_expr.cpp:48: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud/#200243/#200255} Execution of [TypeAnnotationTransformer::DoTransform] took 0us
2025-10-27T08:01:26.008958Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:26.008 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] yql_expr_constraint.cpp:3307: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud/#200243/#200255} Execution of [ConstraintTransformer::DoTransform] took 12us
2025-10-27T08:01:26.008979Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:26.008 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] yql_expr_csee.cpp:638: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud/#200243/#200255} Execution of [UpdateCompletness] took 13us
2025-10-27T08:01:26.009035Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:26.009 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] yql_expr_csee.cpp:651: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud/#200243/#200255} Execution of [EliminateCommonSubExpressionsForSubGraph] took 48us
2025-10-27T08:01:26.009119Z :YQL_PROXY TRACE: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:26.009 TRACE ydbd(pid=1702961, tid=0x00007FF5B6E79640) [core peephole] yql_out_transformers.cpp:62: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud/#200243/#200255} PeepHoleOpt:
(
(let $1 (DataSource '"pq" '"high_rate"))
(let $2 (StructType '('"Data" (DataType 'String))))
(let $3 (PqTopic '"high_rate" '"local" '"high_rate_input" '('('"PartitionsCount" '"1")) '() $2))
(let $4 '('"SharedReading" '"0"))
(let $5 '('('"Endpoint" '"localhost:30711") $4 '('"ReconnectPeriod" '"") '('"Format" '"raw") '('"ReadGroup" '"ptcudts2os05kjn50skg") '('"AddBearerToToken" '"1")))
(let $6 (DqPqTopicSource world $3 '('"Data") $5 (SecureParam '"cluster:default_high_rate") '"" $2 '""))
(let $7 (DqPhyStage '((DqSource $1 $6)) (lambda '($9) (block '(
  (let $10 '('('"format" '"raw") '('"formatSettings" '('('"data.datetime.formatname" '"POSIX") '('"data.timestamp.formatname" '"POSIX"))) '('"settings" '($4))))
  (let $11 (DqSourceWideWrap $9 $1 $2 $10))
  (return (FromFlow (NarrowMap $11 (lambda '($12) (AsStruct '('"Data" $12))))))
))) '('('"_logical_id" '200191) '('"_id" '"6f03bcec-69942c8f-c5731a4d-a8d42300"))))
(let $8 (DqPhyStage '((DqCnUnionAll (TDqOutput $7 '"0"))) (lambda '($13) $13) '('('"_logical_id" '200224) '('"_id" '"f3b1e8da-48c22a4c-df8b4ab7-78b22502"))))
(return (DqCnResult (TDqOutput $8 '"0") '()))
)

2025-10-27T08:01:26.009475Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:26.009 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] type_ann_expr.cpp:48: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud/#200243/#200255} Execution of [TypeAnnotationTransformer::DoTransform] took 4us
2025-10-27T08:01:26.009487Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:26.009 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] yql_expr_constraint.cpp:3307: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud/#200243/#200255} Execution of [ConstraintTransformer::DoTransform] took 3us
2025-10-27T08:01:26.009506Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:26.009 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] yql_expr_csee.cpp:638: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud/#200243/#200255} Execution of [UpdateCompletness] took 12us
2025-10-27T08:01:26.009557Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:26.009 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] yql_expr_csee.cpp:651: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud/#200243/#200255} Execution of [EliminateCommonSubExpressionsForSubGraph] took 44us
2025-10-27T08:01:26.009641Z :YQL_PROXY TRACE: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:26.009 TRACE ydbd(pid=1702961, tid=0x00007FF5B6E79640) [core peephole] yql_out_transformers.cpp:62: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud/#200243/#200255} PeepHoleOpt:
(
(let $1 (DataSource '"pq" '"high_rate"))
(let $2 (StructType '('"Data" (DataType 'String))))
(let $3 (PqTopic '"high_rate" '"local" '"high_rate_input" '('('"PartitionsCount" '"1")) '() $2))
(let $4 '('"SharedReading" '"0"))
(let $5 '('('"Endpoint" '"localhost:30711") $4 '('"ReconnectPeriod" '"") '('"Format" '"raw") '('"ReadGroup" '"ptcudts2os05kjn50skg") '('"AddBearerToToken" '"1")))
(let $6 (DqPqTopicSource world $3 '('"Data") $5 (SecureParam '"cluster:default_high_rate") '"" $2 '""))
(let $7 (DqPhyStage '((DqSource $1 $6)) (lambda '($9) (block '(
  (let $10 '('('"format" '"raw") '('"formatSettings" '('('"data.datetime.formatname" '"POSIX") '('"data.timestamp.formatname" '"POSIX"))) '('"settings" '($4))))
  (let $11 (DqSourceWideWrap $9 $1 $2 $10))
  (return (FromFlow (NarrowMap $11 (lambda '($12) (AsStruct '('"Data" $12))))))
))) '('('"_logical_id" '200191) '('"_id" '"6f03bcec-69942c8f-c5731a4d-a8d42300"))))
(let $8 (DqPhyStage '((DqCnUnionAll (TDqOutput $7 '"0"))) (lambda '($13) $13) '('('"_logical_id" '200224) '('"_id" '"f3b1e8da-48c22a4c-df8b4ab7-78b22502"))))
(return (DqCnResult (TDqOutput $8 '"0") '()))
)

2025-10-27T08:01:26.009732Z :YQL_PROXY INFO: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:26.009 INFO  ydbd(pid=1702961, tid=0x00007FF5B6E79640) [core dq] yql_dq_exectransformer.cpp:379: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud/#200243/#200255} Setting block status for stage #200191 to None
2025-10-27T08:01:26.009799Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:26.009 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] type_ann_expr.cpp:48: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud/#200243/#200255} Execution of [TypeAnnotationTransformer::DoTransform] took 35us
2025-10-27T08:01:26.009835Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:26.009 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] yql_expr_constraint.cpp:3307: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud/#200243/#200255} Execution of [ConstraintTransformer::DoTransform] took 27us
2025-10-27T08:01:26.010071Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {expired_at { seconds: 1761552086 nanos: 928000000 } } SUCCESS
2025-10-27T08:01:26.010108Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudts2orksmjp91qjl, Owner: 99b92891-1f35e172-b6482f17-3ee788f6, Got CP::PingTaskResponse
2025-10-27T08:01:26.010563Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:26.009 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] yql_expr_csee.cpp:638: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud/#200243/#200255} Execution of [UpdateCompletness] took 13us
2025-10-27T08:01:26.010675Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:26.010 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] yql_expr_csee.cpp:651: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud/#200243/#200255} Execution of [EliminateCommonSubExpressionsForSubGraph] took 93us
2025-10-27T08:01:26.010786Z :YQL_PROXY TRACE: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:26.010 TRACE ydbd(pid=1702961, tid=0x00007FF5B6E79640) [core peephole] yql_out_transformers.cpp:62: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud/#200243/#200255} PeepHoleOpt:
(
(let $1 (DataSource '"pq" '"high_rate"))
(let $2 (StructType '('"Data" (DataType 'String))))
(let $3 (PqTopic '"high_rate" '"local" '"high_rate_input" '('('"PartitionsCount" '"1")) '() $2))
(let $4 '('"SharedReading" '"0"))
(let $5 '('('"Endpoint" '"localhost:30711") $4 '('"ReconnectPeriod" '"") '('"Format" '"raw") '('"ReadGroup" '"ptcudts2os05kjn50skg") '('"AddBearerToToken" '"1")))
(let $6 (DqPqTopicSource world $3 '('"Data") $5 (SecureParam '"cluster:default_high_rate") '"" $2 '""))
(let $7 '('('"_logical_id" '200191) '('"_id" '"6f03bcec-69942c8f-c5731a4d-a8d42300") '('"_block_status" '"None")))
(let $8 (DqPhyStage '((DqSource $1 $6)) (lambda '($10) (block '(
  (let $11 '('('"format" '"raw") '('"formatSettings" '('('"data.datetime.formatname" '"POSIX") '('"data.timestamp.formatname" '"POSIX"))) '('"settings" '($4))))
  (let $12 (DqSourceWideWrap $10 $1 $2 $11))
  (return (FromFlow (NarrowMap $12 (lambda '($13) (AsStruct '('"Data" $13))))))
))) $7))
(let $9 (DqPhyStage '((DqCnUnionAll (TDqOutput $8 '"0"))) (lambda '($14) $14) '('('"_logical_id" '200224) '('"_id" '"f3b1e8da-48c22a4c-df8b4ab7-78b22502"))))
(return (DqCnResult (TDqOutput $9 '"0") '()))
)

2025-10-27T08:01:26.010882Z :YQL_PROXY INFO: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:26.010 INFO  ydbd(pid=1702961, tid=0x00007FF5B6E79640) [core dq] yql_dq_exectransformer.cpp:379: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud/#200243/#200255} Setting block status for stage #200224 to None
2025-10-27T08:01:26.010944Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:26.010 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] type_ann_expr.cpp:48: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud/#200243/#200255} Execution of [TypeAnnotationTransformer::DoTransform] took 34us
2025-10-27T08:01:26.010969Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:26.010 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] yql_expr_constraint.cpp:3307: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud/#200243/#200255} Execution of [ConstraintTransformer::DoTransform] took 17us
2025-10-27T08:01:26.010989Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:26.010 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] yql_expr_csee.cpp:638: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud/#200243/#200255} Execution of [UpdateCompletness] took 13us
2025-10-27T08:01:26.011049Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:26.011 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [perf] yql_expr_csee.cpp:651: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud/#200243/#200255} Execution of [EliminateCommonSubExpressionsForSubGraph] took 51us
2025-10-27T08:01:26.011134Z :YQL_PROXY TRACE: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:26.011 TRACE ydbd(pid=1702961, tid=0x00007FF5B6E79640) [core peephole] yql_out_transformers.cpp:62: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud/#200243/#200255} PeepHoleOpt:
(
(let $1 (DataSource '"pq" '"high_rate"))
(let $2 (StructType '('"Data" (DataType 'String))))
(let $3 (PqTopic '"high_rate" '"local" '"high_rate_input" '('('"PartitionsCount" '"1")) '() $2))
(let $4 '('"SharedReading" '"0"))
(let $5 '('('"Endpoint" '"localhost:30711") $4 '('"ReconnectPeriod" '"") '('"Format" '"raw") '('"ReadGroup" '"ptcudts2os05kjn50skg") '('"AddBearerToToken" '"1")))
(let $6 (DqPqTopicSource world $3 '('"Data") $5 (SecureParam '"cluster:default_high_rate") '"" $2 '""))
(let $7 '('"_block_status" '"None"))
(let $8 '('('"_logical_id" '200191) '('"_id" '"6f03bcec-69942c8f-c5731a4d-a8d42300") $7))
(let $9 (DqPhyStage '((DqSource $1 $6)) (lambda '($12) (block '(
  (let $13 '('('"format" '"raw") '('"formatSettings" '('('"data.datetime.formatname" '"POSIX") '('"data.timestamp.formatname" '"POSIX"))) '('"settings" '($4))))
  (let $14 (DqSourceWideWrap $12 $1 $2 $13))
  (return (FromFlow (NarrowMap $14 (lambda '($15) (AsStruct '('"Data" $15))))))
))) $8))
(let $10 '('('"_logical_id" '200224) '('"_id" '"f3b1e8da-48c22a4c-df8b4ab7-78b22502") $7))
(let $11 (DqPhyStage '((DqCnUnionAll (TDqOutput $9 '"0"))) (lambda '($16) $16) $10))
(return (DqCnResult (TDqOutput $11 '"0") '()))
)

2025-10-27T08:01:26.011379Z :YQL_PROXY TRACE: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:26.011 TRACE ydbd(pid=1702961, tid=0x00007FF5B6E79640) [DQ] yql_dq_exectransformer.cpp:2125: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud/#200243/#200255} After PeepHole
(
(let $1 (DataSource '"pq" '"high_rate"))
(let $2 (StructType '('"Data" (DataType 'String))))
(let $3 (PqTopic '"high_rate" '"local" '"high_rate_input" '('('"PartitionsCount" '"1")) '() $2))
(let $4 '('"SharedReading" '"0"))
(let $5 '('('"Endpoint" '"localhost:30711") $4 '('"ReconnectPeriod" '"") '('"Format" '"raw") '('"ReadGroup" '"ptcudts2os05kjn50skg") '('"AddBearerToToken" '"1")))
(let $6 (DqPqTopicSource world $3 '('"Data") $5 (SecureParam '"cluster:default_high_rate") '"" $2 '""))
(let $7 '('"_block_status" '"None"))
(let $8 '('('"_logical_id" '200191) '('"_id" '"6f03bcec-69942c8f-c5731a4d-a8d42300") $7))
(let $9 (DqPhyStage '((DqSource $1 $6)) (lambda '($12) (block '(
  (let $13 '('('"format" '"raw") '('"formatSettings" '('('"data.datetime.formatname" '"POSIX") '('"data.timestamp.formatname" '"POSIX"))) '('"settings" '($4))))
  (let $14 (DqSourceWideWrap $12 $1 $2 $13))
  (return (FromFlow (NarrowMap $14 (lambda '($15) (AsStruct '('"Data" $15))))))
))) $8))
(let $10 '('('"_logical_id" '200224) '('"_id" '"f3b1e8da-48c22a4c-df8b4ab7-78b22502") $7))
(let $11 (DqPhyStage '((DqCnUnionAll (TDqOutput $9 '"0"))) (lambda '($16) $16) $10))
(return (DqCnResult (TDqOutput $11 '"0") '()))
)

2025-10-27T08:01:26.011709Z :YQL_PROXY TRACE: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:26.011 TRACE ydbd(pid=1702961, tid=0x00007FF5B6E79640) [DQ] execution_planner.cpp:152: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud/#200243/#200255} Execution Plan (
(let $1 (DataSource '"pq" '"high_rate"))
(let $2 (StructType '('"Data" (DataType 'String))))
(let $3 (PqTopic '"high_rate" '"local" '"high_rate_input" '('('"PartitionsCount" '"1")) '() $2))
(let $4 '('"SharedReading" '"0"))
(let $5 '('('"Endpoint" '"localhost:30711") $4 '('"ReconnectPeriod" '"") '('"Format" '"raw") '('"ReadGroup" '"ptcudts2os05kjn50skg") '('"AddBearerToToken" '"1")))
(let $6 (DqPqTopicSource world $3 '('"Data") $5 (SecureParam '"cluster:default_high_rate") '"" $2 '""))
(let $7 '('"_block_status" '"None"))
(let $8 '('('"_logical_id" '200191) '('"_id" '"6f03bcec-69942c8f-c5731a4d-a8d42300") $7))
(let $9 (DqPhyStage '((DqSource $1 $6)) (lambda '($12) (block '(
  (let $13 '('('"format" '"raw") '('"formatSettings" '('('"data.datetime.formatname" '"POSIX") '('"data.timestamp.formatname" '"POSIX"))) '('"settings" '($4))))
  (let $14 (DqSourceWideWrap $12 $1 $2 $13))
  (return (FromFlow (NarrowMap $14 (lambda '($15) (AsStruct '('"Data" $15))))))
))) $8))
(let $10 '('('"_logical_id" '200224) '('"_id" '"f3b1e8da-48c22a4c-df8b4ab7-78b22502") $7))
(let $11 (DqPhyStage '((DqCnUnionAll (TDqOutput $9 '"0"))) (lambda '($16) $16) $10))
(return (DqCnResult (TDqOutput $11 '"0") '()))
)

2025-10-27T08:01:26.011862Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:26.011 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [PQ] yql_pq_dq_integration.cpp:53: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud/#200243/#200255} Create DQ reading partition { PartitioningParams { TopicPartitionsCount: 1 DqPartitionsCount: 1 } }
2025-10-27T08:01:26.011927Z :FQ_PINGER TRACE: pinger.cpp:338: QueryId: ptqudts2orksmjp91qjl, Owner: 99b92891-1f35e172-b6482f17-3ee788f6 Ping response success: { expired_at { seconds: 1761552086 nanos: 928000000 } }
2025-10-27T08:01:26.011941Z :FQ_PINGER TRACE: pinger.cpp:393: QueryId: ptqudts2orksmjp91qjl, Owner: 99b92891-1f35e172-b6482f17-3ee788f6 Forward request Private::PingTask
2025-10-27T08:01:26.011966Z :FQ_RUN_ACTOR TRACE: run_actor.cpp:861: QueryId: ptqudts2orksmjp91qjl Forward ping response. Success: 1. Cookie: 2
2025-10-27T08:01:26.012264Z :YQL_PROXY TRACE: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:26.012 TRACE ydbd(pid=1702961, tid=0x00007FF5B6E79640) [DQ] execution_planner.cpp:164: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud/#200243/#200255} Read stage (
(let $1 (DataSource '"pq" '"high_rate"))
(let $2 (StructType '('"Data" (DataType 'String))))
(let $3 (PqTopic '"high_rate" '"local" '"high_rate_input" '('('"PartitionsCount" '"1")) '() $2))
(let $4 '('"SharedReading" '"0"))
(let $5 '('('"Endpoint" '"localhost:30711") $4 '('"ReconnectPeriod" '"") '('"Format" '"raw") '('"ReadGroup" '"ptcudts2os05kjn50skg") '('"AddBearerToToken" '"1")))
(let $6 (DqPqTopicSource world $3 '('"Data") $5 (SecureParam '"cluster:default_high_rate") '"" $2 '""))
(let $7 '('('"_logical_id" '200191) '('"_id" '"6f03bcec-69942c8f-c5731a4d-a8d42300") '('"_block_status" '"None")))
(return (DqPhyStage '((DqSource $1 $6)) (lambda '($8) (block '(
  (let $9 '('('"format" '"raw") '('"formatSettings" '('('"data.datetime.formatname" '"POSIX") '('"data.timestamp.formatname" '"POSIX"))) '('"settings" '($4))))
  (let $10 (DqSourceWideWrap $8 $1 $2 $9))
  (return (FromFlow (NarrowMap $10 (lambda '($11) (AsStruct '('"Data" $11))))))
))) $7))
)

2025-10-27T08:01:26.012344Z :YQL_PROXY TRACE: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:26.012 TRACE ydbd(pid=1702961, tid=0x00007FF5B6E79640) [DQ] execution_planner.cpp:166: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud/#200243/#200255} Common stage (
(let $1 (DataSource '"pq" '"high_rate"))
(let $2 (StructType '('"Data" (DataType 'String))))
(let $3 (PqTopic '"high_rate" '"local" '"high_rate_input" '('('"PartitionsCount" '"1")) '() $2))
(let $4 '('"SharedReading" '"0"))
(let $5 '('('"Endpoint" '"localhost:30711") $4 '('"ReconnectPeriod" '"") '('"Format" '"raw") '('"ReadGroup" '"ptcudts2os05kjn50skg") '('"AddBearerToToken" '"1")))
(let $6 (DqPqTopicSource world $3 '('"Data") $5 (SecureParam '"cluster:default_high_rate") '"" $2 '""))
(let $7 '('"_block_status" '"None"))
(let $8 '('('"_logical_id" '200191) '('"_id" '"6f03bcec-69942c8f-c5731a4d-a8d42300") $7))
(let $9 (DqPhyStage '((DqSource $1 $6)) (lambda '($11) (block '(
  (let $12 '('('"format" '"raw") '('"formatSettings" '('('"data.datetime.formatname" '"POSIX") '('"data.timestamp.formatname" '"POSIX"))) '('"settings" '($4))))
  (let $13 (DqSourceWideWrap $11 $1 $2 $12))
  (return (FromFlow (NarrowMap $13 (lambda '($14) (AsStruct '('"Data" $14))))))
))) $8))
(let $10 '('('"_logical_id" '200224) '('"_id" '"f3b1e8da-48c22a4c-df8b4ab7-78b22502") $7))
(return (DqPhyStage '((DqCnUnionAll (TDqOutput $9 '"0"))) (lambda '($15) $15) $10))
)

2025-10-27T08:01:26.012499Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudts2orksmjp91qjl, Owner: 99b92891-1f35e172-b6482f17-3ee788f6, Request CP::PingTask with size: 122 bytes
2025-10-27T08:01:26.012574Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "99b92891-1f35e172-b6482f17-3ee788f6"
query_id {
  value: "ptqudts2orksmjp91qjl"
}
status: RUNNING
resources {
  rate_limiter: PREPARE
  compilation: PREPARE
}
scope: "yandexcloud://my_folder"
deadline {
  seconds: 1761638485
  nanos: 710106000
}
tenant: "/default"
}
2025-10-27T08:01:26.013065Z :YQL_PROXY INFO: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:26.013 INFO  ydbd(pid=1702961, tid=0x00007FF5B6E79640) [core exec] yql_execution.cpp:519: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Register async execution for node #200243
2025-10-27T08:01:26.013087Z :YQL_PROXY INFO: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:26.013 INFO  ydbd(pid=1702961, tid=0x00007FF5B6E79640) [core exec] yql_execution.cpp:89: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Finish, output #200245, status: Async
2025-10-27T08:01:26.013143Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:928: QueryId: ptqudts2orksmjp91qjl Graph (execution) with tasks: 2
2025-10-27T08:01:26.013210Z :YQL_PROXY INFO: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:26.013 INFO  ydbd(pid=1702961, tid=0x00007FF5B5E77640) [core exec] yql_execution.cpp:135: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Completed async execution for node #200243
2025-10-27T08:01:26.013242Z :YQL_PROXY INFO: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:26.013 INFO  ydbd(pid=1702961, tid=0x00007FF5B5E77640) [DQ] yql_dq_exectransformer.cpp:1514: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Execution Pull complete, duration: 0.075077s
2025-10-27T08:01:26.013306Z :YQL_PROXY INFO: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:26.013 INFO  ydbd(pid=1702961, tid=0x00007FF5B5E77640) [core exec] yql_execution.cpp:155: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} State is ExecutionComplete after apply async changes for node #200243
2025-10-27T08:01:26.013341Z :YQL_PROXY INFO: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:26.013 INFO  ydbd(pid=1702961, tid=0x00007FF5B5E77640) [core exec] yql_execution.cpp:61: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Begin, root #200245
2025-10-27T08:01:26.013349Z :YQL_PROXY INFO: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:26.013 INFO  ydbd(pid=1702961, tid=0x00007FF5B5E77640) [core exec] yql_execution.cpp:74: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Collect unused nodes for root #200245, status: Ok
2025-10-27T08:01:26.013359Z :YQL_PROXY TRACE: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:26.013 TRACE ydbd(pid=1702961, tid=0x00007FF5B5E77640) [core exec] yql_execution.cpp:411: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} {0}, callable #200245 <Commit!>
2025-10-27T08:01:26.013367Z :YQL_PROXY TRACE: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:26.013 TRACE ydbd(pid=1702961, tid=0x00007FF5B5E77640) [core exec] yql_execution.cpp:411: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} {1}, callable #200244 <Commit!>
2025-10-27T08:01:26.013387Z :YQL_PROXY INFO: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:26.013 INFO  ydbd(pid=1702961, tid=0x00007FF5B5E77640) [core exec] yql_execution.cpp:630: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Node #200244<Commit!> finished execution
2025-10-27T08:01:26.013406Z :YQL_PROXY INFO: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:26.013 INFO  ydbd(pid=1702961, tid=0x00007FF5B5E77640) [core exec] yql_execution.cpp:647: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Node #200244<Commit!> created 0 trackable nodes: 
2025-10-27T08:01:26.013423Z :YQL_PROXY TRACE: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:26.013 TRACE ydbd(pid=1702961, tid=0x00007FF5B5E77640) [core exec] yql_execution.cpp:411: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} {0}, callable #200245 <Commit!>
2025-10-27T08:01:26.013436Z :YQL_PROXY INFO: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:26.013 INFO  ydbd(pid=1702961, tid=0x00007FF5B5E77640) [core exec] yql_execution.cpp:630: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Node #200245<Commit!> finished execution
2025-10-27T08:01:26.013448Z :YQL_PROXY INFO: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:26.013 INFO  ydbd(pid=1702961, tid=0x00007FF5B5E77640) [core exec] yql_execution.cpp:647: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Node #200245<Commit!> created 0 trackable nodes: 
2025-10-27T08:01:26.013456Z :YQL_PROXY INFO: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:26.013 INFO  ydbd(pid=1702961, tid=0x00007FF5B5E77640) [core exec] yql_execution.cpp:89: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Finish, output #200245, status: Ok
2025-10-27T08:01:26.013467Z :YQL_PROXY INFO: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:26.013 INFO  ydbd(pid=1702961, tid=0x00007FF5B5E77640) [core exec] yql_execution.cpp:95: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Creating finalizing transformer, output #200245
2025-10-27T08:01:26.013878Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:911: QueryId: ptqudts2orksmjp91qjl Overall dq tasks: 2
2025-10-27T08:01:26.014010Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:758: QueryId: ptqudts2orksmjp91qjl Graph 0
2025-10-27T08:01:26.014046Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:776: QueryId: ptqudts2orksmjp91qjl Create consumer "ptqudts2orksmjp91qjl" for topic "high_rate_input"
2025-10-27T08:01:26.014154Z :FQ_PINGER TRACE: pinger.cpp:250: QueryId: ptqudts2orksmjp91qjl, Owner: 99b92891-1f35e172-b6482f17-3ee788f6 Forward ping request: { ast: "(\n(let $1 (Configure! world (DataSource \'\"config\") \'\"DqEngine\" \'\"force\"))\n(let $2 (DataSink \'result))\n(let $3 (DataSource \'\"pq\" \'\"high_rate\"))\n(let $4 (StructType \'(\'\"Data\" (DataType \'String))))\n(let $5 (PqTopic \'\"high_rate\" \'\"local\" \'\"high_rate_input\" \'(\'(\'\"PartitionsCount\" \'\"1\")) \'() $4))\n(let $6 \'(\'\"SharedReading\" \'\"0\"))\n(let $7 \'(\'(\'\"Endpoint\" \'\"localhost:30711\") $6 \'(\'\"ReconnectPeriod\" \'\"\") \'(\'\"Format\" \'\"raw\") \'(\'\"ReadGroup\" \'\"ptcudts2os05kjn50skg\") \'(\'\"AddBearerToToken\" \'\"1\")))\n(let $8 (DqPqTopicSource world $5 \'(\'\"Data\") $7 (SecureParam \'\"cluster:default_high_rate\") \'\"\" $4 \'\"\"))\n(let $9 (DqStage \'((DqSource $3 $8)) (lambda \'($12) (block \'(\n  (let $13 \'(\'(\'\"format\" \'\"raw\") \'(\'\"formatSettings\" \'(\'(\'\"data.datetime.formatname\" \'\"POSIX\") \'(\'\"data.timestamp.formatname\" \'\"POSIX\"))) \'(\'\"settings\" \'($6))))\n  (let $14 (DqSourceWideWrap $12 $3 $4 $13))\n  (return (NarrowMap $14 (lambda \'($15) (AsStruct \'(\'\"Data\" $15)))))\n))) \'(\'(\'\"_logical_id\" \'200191))))\n(let $10 (DqStage \'((DqCnUnionAll (TDqOutput $9 \'\"0\"))) (lambda \'($16) $16) \'(\'(\'\"_logical_id\" \'200224))))\n(let $11 (ResPull! $1 $2 (Key) (DqCnResult (TDqOutput $10 \'\"0\") \'()) \'(\'(\'type) \'(\'autoref)) \'\"dq\"))\n(return (Commit! (Commit! $11 $2) (DataSink \'\"pq\" \'\"high_rate\")))\n)\n" plan: "{\"Detailed\":{\"Operations\":[{\"Id\":8,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[{\"Name\":\"DqSourceWideWrap\"},{\"Name\":\"NarrowMap\"}]}},{\"Id\":6,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[]},\"DependsOn\":[8]},{\"Id\":3,\"Name\":\"ResPull!\",\"DependsOn\":[6]},{\"Id\":1,\"Name\":\"Commit!\",\"DependsOn\":[3]}],\"OperationRoot\":1,\"Providers\":[],\"OperationStats\":{\"Commit!\":1,\"DqStage\":2,\"ResPull!\":1}},\"Basic\":{\"nodes\":[{\"id\":8,\"level\":1,\"name\":\"DqStage #8\",\"type\":\"op\"},{\"id\":6,\"level\":2,\"name\":\"DqStage #6\",\"type\":\"op\"},{\"id\":3,\"level\":3,\"name\":\"ResPull!\",\"type\":\"op\"},{\"id\":1,\"level\":4,\"name\":\"Commit!\",\"type\":\"op\"}],\"links\":[{\"source\":8,\"target\":6},{\"source\":6,\"target\":3},{\"source\":3,\"target\":1}]}}" }
2025-10-27T08:01:26.014190Z :FQ_PINGER TRACE: pinger.cpp:250: QueryId: ptqudts2orksmjp91qjl, Owner: 99b92891-1f35e172-b6482f17-3ee788f6 Forward ping request: { result_set_count: 1 result_set_meta { column { name: "Data" type { type_id: STRING } } } dq_graph: "\022\316\005\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*\330\002Z\325\002\n\010PqSource\022\306\002\n4type.googleapis.com/NYql.NPq.NProto.TDqPqTopicSource\022\215\002\n\017high_rate_input\022\024ptqudts2orksmjp91qjl\032\017localhost:30711\"\033\n\031cluster:default_high_rate*\005local0\002@\001b\004Dataj\025[\"DataType\";\"String\"]\222\001\024ptcudts2os05kjn50skg\232\001\003raw\242\001/[\"StructType\";[[\"Data\";[\"DataType\";\"String\"]]]]\262\001\002\022\000\272\001\026\n\010cloud_id\022\nmock_cloud\272\001 \n\005scope\022\027yandexcloud://my_folder\030\0012B\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\000X\202\235\014`\223\235\014R\000:\203\001\n*type.googleapis.com/Yql.DqsProto.TTaskMeta\022U\010\202\235\014\022A\022(adb44c074251a1871f952a1fe07a46be1893a61c\032\023dq_vanilla_job.lite \002\"\014\n\002pq\022\006\n\004\010\001\030\001H\202\235\014RClocal/RateLimiter_90e94ed0-64f3-4708-870a-5ec8d3274ff8/rate_limiterZ)mock_cloud/my_folder/ptqudts2orksmjp91qjl`\200\200\200\200 \230\001\000\300\001\001\312\001\010/default\022\236\003\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*B\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\000X\202\235\014`\223\235\014R\00028\n4\010\002\020\240\234\001\030\002*\024\n\022\t\000\000\000\000\000\000\000\000\021\000\000\000\000\002\000\000\0002\024\n\022\t\001\000\000\000\000\000\000\000\021\000\000\000\000\001\000\000\000R\000:u\n*type.googleapis.com/Yql.DqsProto.TTaskMeta\022G\010\223\235\014\022A\022(adb44c074251a1871f952a1fe07a46be1893a61c\032\023dq_vanilla_job.lite \002H\223\235\014RClocal/RateLimiter_90e94ed0-64f3-4708-870a-5ec8d3274ff8/rate_limiterZ)mock_cloud/my_folder/ptqudts2orksmjp91qjl`\200\200\200\200 \230\001\000\300\001\001\312\001\010/default\030\001\"\r\037\000\205\002\203\005@\020Data/*\004Data2pptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud:\027\n\016FallbackPolicy\022\005never:\024\n\017_LiteralTimeout\022\0010:\022\n\r_TableTimeout\022\0010:\037\n\025_AllResultsBytesLimit\022\006100000:\032\n\022_RowsLimitPerWrite\022\0041000:\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\031cluster:default_high_rate\022\016{\"no_auth\":\"\"}bR\010\223\235\014\022L\037\002\006Arg\005\205\006\213\002\204\205\002\203\005@\020Data\205\000?\004\030Inputs(Parameters\034Program\013?\006)\251\000?\004\002\000\002\000)\251\000?\010\002\000\004?\016\001/b\202\002\010\202\235\014\022\373\001\037\004\006Arg\010Data\005\205\006\213\002\204\203\005@\205\000\204\205\002\203\005@\006\030Inputs(Parameters\034Program\013?\004)\251\000?\002\002\000\n\000)\251\000?\006\002\000\026)\211\002?\014\215?\n FromFlow\000)\211\006?\032\215\233\002?\010?\010?\n$NarrowMap\000)\211\006? \215\205\002?\010\006?$?\010$ExpandMap\000)\211\006?&\215?\000?\000?$\014Map\000)\211\002?*?\002\030ToFlow\000?\022\000\014)\251\000?\000\002\000\010\005?$?4\000\004\016)\251\000?$\002\000\004)\211\004?\010?$\203\004\030Member\000?<\003?>\000\002\006\000\020)\251\000?\010\002\000\002\005?\n?J\000\004\022\000\024\001/" }
2025-10-27T08:01:26.028990Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {expired_at { seconds: 1761552087 nanos: 23000000 } } SUCCESS
2025-10-27T08:01:26.029050Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudts2orksmjp91qjl, Owner: 99b92891-1f35e172-b6482f17-3ee788f6, Got CP::PingTaskResponse
2025-10-27T08:01:26.032156Z :FQ_PINGER TRACE: pinger.cpp:338: QueryId: ptqudts2orksmjp91qjl, Owner: 99b92891-1f35e172-b6482f17-3ee788f6 Ping response success: { expired_at { seconds: 1761552087 nanos: 23000000 } }
2025-10-27T08:01:26.032174Z :FQ_PINGER TRACE: pinger.cpp:393: QueryId: ptqudts2orksmjp91qjl, Owner: 99b92891-1f35e172-b6482f17-3ee788f6 Forward request Private::PingTask
2025-10-27T08:01:26.032200Z :FQ_RUN_ACTOR TRACE: run_actor.cpp:861: QueryId: ptqudts2orksmjp91qjl Forward ping response. Success: 1. Cookie: 0
2025-10-27T08:01:26.035102Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudts2orksmjp91qjl, Owner: 99b92891-1f35e172-b6482f17-3ee788f6, Request CP::PingTask with size: 191 bytes
2025-10-27T08:01:26.035168Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "99b92891-1f35e172-b6482f17-3ee788f6"
query_id {
  value: "ptqudts2orksmjp91qjl"
}
status: RUNNING
resources {
  rate_limiter: READY
  compilation: PREPARE
  rate_limiter_path: "local/RateLimiter_90e94ed0-64f3-4708-870a-5ec8d3274ff8/rate_limiter"
}
scope: "yandexcloud://my_folder"
deadline {
  seconds: 1761638485
  nanos: 710106000
}
tenant: "/default"
}
2025-10-27T08:01:26.046221Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {expired_at { seconds: 1761552087 nanos: 40000000 } } SUCCESS
2025-10-27T08:01:26.046304Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudts2orksmjp91qjl, Owner: 99b92891-1f35e172-b6482f17-3ee788f6, Got CP::PingTaskResponse
2025-10-27T08:01:26.046630Z :FQ_PINGER TRACE: pinger.cpp:338: QueryId: ptqudts2orksmjp91qjl, Owner: 99b92891-1f35e172-b6482f17-3ee788f6 Ping response success: { expired_at { seconds: 1761552087 nanos: 40000000 } }
2025-10-27T08:01:26.046643Z :FQ_PINGER TRACE: pinger.cpp:393: QueryId: ptqudts2orksmjp91qjl, Owner: 99b92891-1f35e172-b6482f17-3ee788f6 Forward request Private::PingTask
2025-10-27T08:01:26.046667Z :FQ_RUN_ACTOR TRACE: run_actor.cpp:861: QueryId: ptqudts2orksmjp91qjl Forward ping response. Success: 1. Cookie: 0
2025-10-27T08:01:26.047109Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudts2orksmjp91qjl, Owner: 99b92891-1f35e172-b6482f17-3ee788f6, Request CP::PingTask with size: 2030 bytes
2025-10-27T08:01:26.047176Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "99b92891-1f35e172-b6482f17-3ee788f6"
query_id {
  value: "ptqudts2orksmjp91qjl"
}
ast: "(\n(let $1 (Configure! world (DataSource \'\"config\") \'\"DqEngine\" \'\"force\"))\n(let $2 (DataSink \'result))\n(let $3 (DataSource \'\"pq\" \'\"high_rate\"))\n(let $4 (StructType \'(\'\"Data\" (DataType \'String))))\n(let $5 (PqTopic \'\"high_rate\" \'\"local\" \'\"high_rate_input\" \'(\'(\'\"PartitionsCount\" \'\"1\")) \'() $4))\n(let $6 \'(\'\"SharedReading\" \'\"0\"))\n(let $7 \'(\'(\'\"Endpoint\" \'\"localhost:30711\") $6 \'(\'\"ReconnectPeriod\" \'\"\") \'(\'\"Format\" \'\"raw\") \'(\'\"ReadGroup\" \'\"ptcudts2os05kjn50skg\") \'(\'\"AddBearerToToken\" \'\"1\")))\n(let $8 (DqPqTopicSource world $5 \'(\'\"Data\") $7 (SecureParam \'\"cluster:default_high_rate\") \'\"\" $4 \'\"\"))\n(let $9 (DqStage \'((DqSource $3 $8)) (lambda \'($12) (block \'(\n  (let $13 \'(\'(\'\"format\" \'\"raw\") \'(\'\"formatSettings\" \'(\'(\'\"data.datetime.formatname\" \'\"POSIX\") \'(\'\"data.timestamp.formatname\" \'\"POSIX\"))) \'(\'\"settings\" \'($6))))\n  (let $14 (DqSourceWideWrap $12 $3 $4 $13))\n  (return (NarrowMap $14 (lambda \'($15) (AsStruct \'(\'\"Data\" $15)))))\n))) \'(\'(\'\"_logical_id\" \'200191))))\n(let $10 (DqStage \'((DqCnUnionAll (TDqOutput $9 \'\"0\"))) (lambda \'($16) $16) \'(\'(\'\"_logical_id\" \'200224))))\n(let $11 (ResPull! $1 $2 (Key) (DqCnResult (TDqOutput $10 \'\"0\") \'()) \'(\'(\'type) \'(\'autoref)) \'\"dq\"))\n(return (Commit! (Commit! $11 $2) (DataSink \'\"pq\" \'\"high_rate\")))\n)\n"
plan: "{\"Detailed\":{\"Operations\":[{\"Id\":8,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[{\"Name\":\"DqSourceWideWrap\"},{\"Name\":\"NarrowMap\"}]}},{\"Id\":6,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[]},\"DependsOn\":[8]},{\"Id\":3,\"Name\":\"ResPull!\",\"DependsOn\":[6]},{\"Id\":1,\"Name\":\"Commit!\",\"DependsOn\":[3]}],\"OperationRoot\":1,\"Providers\":[],\"OperationStats\":{\"Commit!\":1,\"DqStage\":2,\"ResPull!\":1}},\"Basic\":{\"nodes\":[{\"id\":8,\"level\":1,\"name\":\"DqStage #8\",\"type\":\"op\"},{\"id\":6,\"level\":2,\"name\":\"DqStage #6\",\"type\":\"op\"},{\"id\":3,\"level\":3,\"name\":\"ResPull!\",\"type\":\"op\"},{\"id\":1,\"level\":4,\"name\":\"Commit!\",\"type\":\"op\"}],\"links\":[{\"source\":8,\"target\":6},{\"source\":6,\"target\":3},{\"source\":3,\"target\":1}]}}"
scope: "yandexcloud://my_folder"
deadline {
  seconds: 1761638485
  nanos: 710106000
}
tenant: "/default"
}
2025-10-27T08:01:26.057107Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {expired_at { seconds: 1761552087 nanos: 51000000 } } SUCCESS
2025-10-27T08:01:26.057186Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudts2orksmjp91qjl, Owner: 99b92891-1f35e172-b6482f17-3ee788f6, Got CP::PingTaskResponse
2025-10-27T08:01:26.057472Z :FQ_PINGER TRACE: pinger.cpp:338: QueryId: ptqudts2orksmjp91qjl, Owner: 99b92891-1f35e172-b6482f17-3ee788f6 Ping response success: { expired_at { seconds: 1761552087 nanos: 51000000 } }
2025-10-27T08:01:26.057493Z :FQ_PINGER TRACE: pinger.cpp:393: QueryId: ptqudts2orksmjp91qjl, Owner: 99b92891-1f35e172-b6482f17-3ee788f6 Forward request Private::PingTask
2025-10-27T08:01:26.057559Z :FQ_RUN_ACTOR TRACE: run_actor.cpp:861: QueryId: ptqudts2orksmjp91qjl Forward ping response. Success: 1. Cookie: 0
2025-10-27T08:01:26.057969Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudts2orksmjp91qjl, Owner: 99b92891-1f35e172-b6482f17-3ee788f6, Request CP::PingTask with size: 2135 bytes
2025-10-27T08:01:26.058051Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "99b92891-1f35e172-b6482f17-3ee788f6"
query_id {
  value: "ptqudts2orksmjp91qjl"
}
result_set_count: 1
result_set_meta {
  column {
    name: "Data"
    type {
      type_id: STRING
    }
  }
}
dq_graph: "\022\316\005\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*\330\002Z\325\002\n\010PqSource\022\306\002\n4type.googleapis.com/NYql.NPq.NProto.TDqPqTopicSource\022\215\002\n\017high_rate_input\022\024ptqudts2orksmjp91qjl\032\017localhost:30711\"\033\n\031cluster:default_high_rate*\005local0\002@\001b\004Dataj\025[\"DataType\";\"String\"]\222\001\024ptcudts2os05kjn50skg\232\001\003raw\242\001/[\"StructType\";[[\"Data\";[\"DataType\";\"String\"]]]]\262\001\002\022\000\272\001\026\n\010cloud_id\022\nmock_cloud\272\001 \n\005scope\022\027yandexcloud://my_folder\030\0012B\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\000X\202\235\014`\223\235\014R\000:\203\001\n*type.googleapis.com/Yql.DqsProto.TTaskMeta\022U\010\202\235\014\022A\022(adb44c074251a1871f952a1fe07a46be1893a61c\032\023dq_vanilla_job.lite \002\"\014\n\002pq\022\006\n\004\010\001\030\001H\202\235\014RClocal/RateLimiter_90e94ed0-64f3-4708-870a-5ec8d3274ff8/rate_limiterZ)mock_cloud/my_folder/ptqudts2orksmjp91qjl`\200\200\200\200 \230\001\000\300\001\001\312\001\010/default\022\236\003\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*B\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\000X\202\235\014`\223\235\014R\00028\n4\010\002\020\240\234\001\030\002*\024\n\022\t\000\000\000\000\000\000\000\000\021\000\000\000\000\002\000\000\0002\024\n\022\t\001\000\000\000\000\000\000\000\021\000\000\000\000\001\000\000\000R\000:u\n*type.googleapis.com/Yql.DqsProto.TTaskMeta\022G\010\223\235\014\022A\022(adb44c074251a1871f952a1fe07a46be1893a61c\032\023dq_vanilla_job.lite \002H\223\235\014RClocal/RateLimiter_90e94ed0-64f3-4708-870a-5ec8d3274ff8/rate_limiterZ)mock_cloud/my_folder/ptqudts2orksmjp91qjl`\200\200\200\200 \230\001\000\300\001\001\312\001\010/default\030\001\"\r\037\000\205\002\203\005@\020Data/*\004Data2pptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud:\027\n\016FallbackPolicy\022\005never:\024\n\017_LiteralTimeout\022\0010:\022\n\r_TableTimeout\022\0010:\037\n\025_AllResultsBytesLimit\022\006100000:\032\n\022_RowsLimitPerWrite\022\0041000:\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\031cluster:default_high_rate\022\016{\"no_auth\":\"\"}bR\010\223\235\014\022L\037\002\006Arg\005\205\006\213\002\204\205\002\203\005@\020Data\205\000?\004\030Inputs(Parameters\034Program\013?\006)\251\000?\004\002\000\002\000)\251\000?\010\002\000\004?\016\001/b\202\002\010\202\235\014\022\373\001\037\004\006Arg\010Data\005\205\006\213\002\204\203\005@\205\000\204\205\002\203\005@\006\030Inputs(Parameters\034Program\013?\004)\251\000?\002\002\000\n\000)\251\000?\006\002\000\026)\211\002?\014\215?\n FromFlow\000)\211\006?\032\215\233\002?\010?\010?\n$NarrowMap\000)\211\006? \215\205\002?\010\006?$?\010$ExpandMap\000)\211\006?&\215?\000?\000?$\014Map\000)\211\002?*?\002\030ToFlow\000?\022\000\014)\251\000?\000\002\000\010\005?$?4\000\004\016)\251\000?$\002\000\004)\211\004?\010?$\203\004\030Member\000?<\003?>\000\002\006\000\020)\251\000?\010\002\000\002\005?\n?J\000\004\022\000\024\001/"
scope: "yandexcloud://my_folder"
deadline {
  seconds: 1761638485
  nanos: 710106000
}
tenant: "/default"
}
2025-10-27T08:01:26.076598Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {expired_at { seconds: 1761552087 nanos: 68000000 } } SUCCESS
2025-10-27T08:01:26.076636Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudts2orksmjp91qjl, Owner: 99b92891-1f35e172-b6482f17-3ee788f6, Got CP::PingTaskResponse
2025-10-27T08:01:26.077056Z :FQ_PINGER TRACE: pinger.cpp:338: QueryId: ptqudts2orksmjp91qjl, Owner: 99b92891-1f35e172-b6482f17-3ee788f6 Ping response success: { expired_at { seconds: 1761552087 nanos: 68000000 } }
2025-10-27T08:01:26.077091Z :FQ_RUN_ACTOR TRACE: run_actor.cpp:861: QueryId: ptqudts2orksmjp91qjl Forward ping response. Success: 1. Cookie: 1
2025-10-27T08:01:26.077166Z :STREAMS DEBUG: read_rule_creator.cpp:240: ptqudts2orksmjp91qjl: Create read rule creation actor for `high_rate_input` [0]
2025-10-27T08:01:26.077196Z :STREAMS DEBUG: read_rule_creator.cpp:110: ptqudts2orksmjp91qjl: Make request for read rule creation for topic `high_rate_input` [0]
2025-10-27T08:01:26.077215Z :FQ_PINGER TRACE: pinger.cpp:250: QueryId: ptqudts2orksmjp91qjl, Owner: 99b92891-1f35e172-b6482f17-3ee788f6 Forward ping request: { owner_id: "99b92891-1f35e172-b6482f17-3ee788f6" query_id { value: "ptqudts2orksmjp91qjl" } status: RUNNING result_set_count: 1 result_set_meta { column { name: "Data" type { type_id: STRING } } } resources { rate_limiter: READY compilation: READY topic_consumers_state: PREPARE rate_limiter_path: "local/RateLimiter_90e94ed0-64f3-4708-870a-5ec8d3274ff8/rate_limiter" topic_consumers { database: "local" topic_path: "high_rate_input" consumer_name: "ptqudts2orksmjp91qjl" cluster_endpoint: "localhost:30711" token_name: "cluster:default_high_rate" add_bearer_to_token: true } } scope: "yandexcloud://my_folder" }
2025-10-27T08:01:26.077218Z :FQ_PINGER TRACE: pinger.cpp:393: QueryId: ptqudts2orksmjp91qjl, Owner: 99b92891-1f35e172-b6482f17-3ee788f6 Forward request Private::PingTask
2025-10-27T08:01:26.077903Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudts2orksmjp91qjl, Owner: 99b92891-1f35e172-b6482f17-3ee788f6, Request CP::PingTask with size: 305 bytes
2025-10-27T08:01:26.077974Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "99b92891-1f35e172-b6482f17-3ee788f6"
query_id {
  value: "ptqudts2orksmjp91qjl"
}
status: RUNNING
result_set_count: 1
result_set_meta {
  column {
    name: "Data"
    type {
      type_id: STRING
    }
  }
}
resources {
  rate_limiter: READY
  compilation: READY
  topic_consumers_state: PREPARE
  rate_limiter_path: "local/RateLimiter_90e94ed0-64f3-4708-870a-5ec8d3274ff8/rate_limiter"
  topic_consumers {
    database: "local"
    topic_path: "high_rate_input"
    consumer_name: "ptqudts2orksmjp91qjl"
    cluster_endpoint: "localhost:30711"
    token_name: "cluster:default_high_rate"
    add_bearer_to_token: true
  }
}
scope: "yandexcloud://my_folder"
deadline {
  seconds: 1761638485
  nanos: 710106000
}
tenant: "/default"
}
2025-10-27T08:01:26.078269Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:777: DescribeQueryRequest: query_id: "ptqudts2orksmjp91qjl"
2025-10-27T08:01:26.078317Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:301: Resolve folder bootstrap. Folder id: my_folder Actor id: [1:7565808603537505502:2242]
2025-10-27T08:01:26.078331Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:362: Cloud id: mock_cloud Folder id: my_folder
2025-10-27T08:01:26.078372Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:777: DescribeQueryRequest: query_id: "ptqudts2orksmjp91qjl"
2025-10-27T08:01:26.078445Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:166: Resolve subject type bootstrap. Token: **** (B6C6F477) Actor id: [1:7565808603537505503:2243]
2025-10-27T08:01:26.078464Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:227: Subject Type: federated_account Token: **** (B6C6F477)
2025-10-27T08:01:26.078483Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:777: DescribeQueryRequest: query_id: "ptqudts2orksmjp91qjl"
2025-10-27T08:01:26.078494Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:69: Request actor. Actor id: [1:7565808603537505504:2244]
2025-10-27T08:01:26.078528Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_queries.cpp:641: DescribeQueryRequest: {query_id: "ptqudts2orksmjp91qjl"
} [root@builtin, **** (B6C6F477)] 
2025-10-27T08:01:26.082348Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: DescribeQueryRequest - DescribeQueryResult: {query { meta { common { id: "ptqudts2orksmjp91qjl" created_by: "root@builtin" modified_by: "root@builtin" created_at { seconds: 1761552084 nanos: 864218000 } modified_at { seconds: 1761552084 nanos: 864218000 } revision: 1 } started_at { seconds: 1761552085 nanos: 799000000 } execute_mode: RUN status: RUNNING last_job_query_revision: 1 last_job_id: "ptjudts2orksmdrpis4q-ptqudts2orksmjp91qjl" started_by: "root@builtin" submitted_at { seconds: 1761552084 nanos: 864218000 } } content { type: STREAMING name: "a" acl { visibility: PRIVATE } limits { execution_timeout { } } text: "SELECT * FROM high_rate.`high_rate_input`;" syntax: YQL_V1 } plan { json: "{\"Detailed\":{\"Operations\":[{\"Id\":8,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[{\"Name\":\"DqSourceWideWrap\"},{\"Name\":\"NarrowMap\"}]}},{\"Id\":6,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[]},\"DependsOn\":[8]},{\"Id\":3,\"Name\":\"ResPull!\",\"DependsOn\":[6]},{\"Id\":1,\"Name\":\"Commit!\",\"DependsOn\":[3]}],\"OperationRoot\":1,\"Providers\":[],\"OperationStats\":{\"Commit!\":1,\"DqStage\":2,\"ResPull!\":1}},\"Basic\":{\"nodes\":[{\"id\":8,\"level\":1,\"name\":\"DqStage #8\",\"type\":\"op\"},{\"id\":6,\"level\":2,\"name\":\"DqStage #6\",\"type\":\"op\"},{\"id\":3,\"level\":3,\"name\":\"ResPull!\",\"type\":\"op\"},{\"id\":1,\"level\":4,\"name\":\"Commit!\",\"type\":\"op\"}],\"links\":[{\"source\":8,\"target\":6},{\"source\":6,\"target\":3},{\"source\":3,\"target\":1}]}}" } result_set_meta { column { name: "Data" type { type_id: STRING } } } ast { data: "(\n(let $1 (Configure! world (DataSource \'\"config\") \'\"DqEngine\" \'\"force\"))\n(let $2 (DataSink \'result))\n(let $3 (DataSource \'\"pq\" \'\"high_rate\"))\n(let $4 (StructType \'(\'\"Data\" (DataType \'String))))\n(let $5 (PqTopic \'\"high_rate\" \'\"local\" \'\"high_rate_input\" \'(\'(\'\"PartitionsCount\" \'\"1\")) \'() $4))\n(let $6 \'(\'\"SharedReading\" \'\"0\"))\n(let $7 \'(\'(\'\"Endpoint\" \'\"localhost:30711\") $6 \'(\'\"ReconnectPeriod\" \'\"\") \'(\'\"Format\" \'\"raw\") \'(\'\"ReadGroup\" \'\"ptcudts2os05kjn50skg\") \'(\'\"AddBearerToToken\" \'\"1\")))\n(let $8 (DqPqTopicSource world $5 \'(\'\"Data\") $7 (SecureParam \'\"cluster:default_high_rate\") \'\"\" $4 \'\"\"))\n(let $9 (DqStage \'((DqSource $3 $8)) (lambda \'($12) (block \'(\n  (let $13 \'(\'(\'\"format\" \'\"raw\") \'(\'\"formatSettings\" \'(\'(\'\"data.datetime.formatname\" \'\"POSIX\") \'(\'\"data.timestamp.formatname\" \'\"POSIX\"))) \'(\'\"settings\" \'($6))))\n  (let $14 (DqSourceWideWrap $12 $3 $4 $13))\n  (return (NarrowMap $14 (lambda \'($15) (AsStruct \'(\'\"Data\" $15)))))\n))) \'(\'(\'\"_logical_id\" \'200191))))\n(let $10 (DqStage \'((DqCnUnionAll (TDqOutput $9 \'\"0\"))) (lambda \'($16) $16) \'(\'(\'\"_logical_id\" \'200224))))\n(let $11 (ResPull! $1 $2 (Key) (DqCnResult (TDqOutput $10 \'\"0\") \'()) \'(\'(\'type) \'(\'autoref)) \'\"dq\"))\n(return (Commit! (Commit! $11 $2) (DataSink \'\"pq\" \'\"high_rate\")))\n)\n" } } } SUCCESS
2025-10-27T08:01:26.097224Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {expired_at { seconds: 1761552087 nanos: 82000000 } } SUCCESS
2025-10-27T08:01:26.097298Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudts2orksmjp91qjl, Owner: 99b92891-1f35e172-b6482f17-3ee788f6, Got CP::PingTaskResponse
2025-10-27T08:01:26.097768Z :FQ_PINGER TRACE: pinger.cpp:338: QueryId: ptqudts2orksmjp91qjl, Owner: 99b92891-1f35e172-b6482f17-3ee788f6 Ping response success: { expired_at { seconds: 1761552087 nanos: 82000000 } }
2025-10-27T08:01:26.097802Z :FQ_RUN_ACTOR TRACE: run_actor.cpp:861: QueryId: ptqudts2orksmjp91qjl Forward ping response. Success: 1. Cookie: 0
2025-10-27T08:01:26.104598Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:1405: QueryId: ptqudts2orksmjp91qjl Read rules creation finished. Issues: 0
2025-10-27T08:01:26.104636Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:911: QueryId: ptqudts2orksmjp91qjl Overall dq tasks: 2
2025-10-27T08:01:26.104949Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:26.104 DEBUG ydbd(pid=1702961, tid=0x00007FF5B767A640) [DQ] task_controller_impl.h:83: _AllResultsBytesLimit = 100000
2025-10-27T08:01:26.104966Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:26.104 DEBUG ydbd(pid=1702961, tid=0x00007FF5B767A640) [DQ] task_controller_impl.h:86: _RowsLimitPerWrite = 1000
2025-10-27T08:01:26.105025Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:1653: QueryId: ptqudts2orksmjp91qjl Executer: [1:7565808603537505506:2246], Controller: [1:7565808603537505509:2249], ResultIdActor: [1:7565808603537505507:2247]
2025-10-27T08:01:26.105061Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:26.105 DEBUG ydbd(pid=1702961, tid=0x00007FF5B767A640) [DQ] executer_actor.cpp:140: {ptqudts2orksmjp91qjl} TDqExecuter::OnGraph
2025-10-27T08:01:26.105081Z :YQL_PROXY INFO: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:26.105 INFO  ydbd(pid=1702961, tid=0x00007FF5B767A640) [DQ] executer_actor.cpp:157: {ptqudts2orksmjp91qjl} Trying to allocate 2 workers [EnableComputeActor=1]
2025-10-27T08:01:26.105235Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:26.105 DEBUG ydbd(pid=1702961, tid=0x00007FF5B767A640) [DQ] executer_actor.cpp:247: {ptqudts2orksmjp91qjl} Dq timeouts are set to: 0.000000s (global), 600.000000s (workers allocation fail), 30.000000s (workers allocation warn) 
2025-10-27T08:01:26.105346Z :FQ_PINGER TRACE: pinger.cpp:250: QueryId: ptqudts2orksmjp91qjl, Owner: 99b92891-1f35e172-b6482f17-3ee788f6 Forward ping request: { owner_id: "99b92891-1f35e172-b6482f17-3ee788f6" query_id { value: "ptqudts2orksmjp91qjl" } status: RUNNING result_set_count: 1 result_set_meta { column { name: "Data" type { type_id: STRING } } } resources { rate_limiter: READY compilation: READY topic_consumers_state: READY rate_limiter_path: "local/RateLimiter_90e94ed0-64f3-4708-870a-5ec8d3274ff8/rate_limiter" topic_consumers { database: "local" topic_path: "high_rate_input" consumer_name: "ptqudts2orksmjp91qjl" cluster_endpoint: "localhost:30711" token_name: "cluster:default_high_rate" add_bearer_to_token: true } } scope: "yandexcloud://my_folder" }
2025-10-27T08:01:26.105358Z :FQ_PINGER TRACE: pinger.cpp:393: QueryId: ptqudts2orksmjp91qjl, Owner: 99b92891-1f35e172-b6482f17-3ee788f6 Forward request Private::PingTask
2025-10-27T08:01:26.105380Z :FQ_RESULT_WRITER INFO: result_writer.cpp:62: TraceId: ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud Bootstrap
2025-10-27T08:01:26.106306Z :YQL_NODES_MANAGER DEBUG: nodes_manager.cpp:125: TEvAllocateWorkersResponse Nodes {
  ResourceId: 4294967297
  Worker {
    NodeId: 1
    Guid: "9f50fb2a-4caaf79f-ebafdaa3-bf5ee683,ghrun-aathosbtb4"
  }
  Worker {
    NodeId: 1
    Guid: "9f50fb2a-4caaf79f-ebafdaa3-bf5ee683,ghrun-aathosbtb4"
  }
}
2025-10-27T08:01:26.106916Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:134: SelfId: [1:7565808603537505511:2251], TxId: ptqudts2orksmjp91qjl, task: 2. Ctx: {}. Start compute actor [1:7565808603537505511:2251], task: 2
2025-10-27T08:01:26.106937Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:113: SelfId: [1:7565808603537505511:2251], TxId: ptqudts2orksmjp91qjl, task: 2. Ctx: {}. Use CPU quota: 1. Rate limiter resource: { "local/RateLimiter_90e94ed0-64f3-4708-870a-5ec8d3274ff8/rate_limiter", "mock_cloud/my_folder/ptqudts2orksmjp91qjl" }
2025-10-27T08:01:26.108885Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: 99b92891-1f35e172-b6482f17-3ee788f 2025-10-27 08:01:26.108 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [DQ] resource_allocator.cpp:141: {ptqudts2orksmjp91qjl/[1:7565808603537505510:2250]} TEvAllocateWorkersResponse 1
2025-10-27T08:01:26.108908Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: 99b92891-1f35e172-b6482f17-3ee788f 2025-10-27 08:01:26.108 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [DQ] resource_allocator.cpp:141: {ptqudts2orksmjp91qjl/[1:7565808603537505510:2250]} TEvAllocateWorkersResponse 1
2025-10-27T08:01:26.108930Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:134: SelfId: [1:7565808603537505512:2252], TxId: ptqudts2orksmjp91qjl, task: 1. Ctx: {}. Start compute actor [1:7565808603537505512:2252], task: 1
2025-10-27T08:01:26.108950Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:113: SelfId: [1:7565808603537505512:2252], TxId: ptqudts2orksmjp91qjl, task: 1. Ctx: {}. Use CPU quota: 1. Rate limiter resource: { "local/RateLimiter_90e94ed0-64f3-4708-870a-5ec8d3274ff8/rate_limiter", "mock_cloud/my_folder/ptqudts2orksmjp91qjl" }
2025-10-27T08:01:26.109018Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: 99b92891-1f35e172-b6482f17-3ee788f 2025-10-27 08:01:26.109 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [DQ] tasks_runner_local.cpp:267: {TODO/1} Build task: 1
2025-10-27T08:01:26.109091Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:26.109 DEBUG ydbd(pid=1702961, tid=0x00007FF5B5E77640) [DQ] executer_actor.cpp:358: {ptqudts2orksmjp91qjl} TDqExecuter::TEvAllocateWorkersResponse
2025-10-27T08:01:26.109103Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:26.109 DEBUG ydbd(pid=1702961, tid=0x00007FF5B5E77640) [DQ] executer_actor.cpp:384: {ptqudts2orksmjp91qjl} Allocated resource 4294967297
2025-10-27T08:01:26.109145Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:26.109 DEBUG ydbd(pid=1702961, tid=0x00007FF5B5E77640) [DQ] executer_actor.cpp:401: {ptqudts2orksmjp91qjl} WorkerInfo: Id:9f50fb2a-4caaf79f-ebafdaa3-bf5ee683,ghrun-aathosbtb4,NodeId:1,StageId:200322
2025-10-27T08:01:26.109153Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:26.109 DEBUG ydbd(pid=1702961, tid=0x00007FF5B5E77640) [DQ] executer_actor.cpp:402: {ptqudts2orksmjp91qjl} TaskInfo: 0/1
2025-10-27T08:01:26.109161Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:26.109 DEBUG ydbd(pid=1702961, tid=0x00007FF5B5E77640) [DQ] executer_actor.cpp:404: {ptqudts2orksmjp91qjl}  ObjectId: adb44c074251a1871f952a1fe07a46be1893a61c, dq_vanilla_job.lite, 
2025-10-27T08:01:26.109183Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:26.109 DEBUG ydbd(pid=1702961, tid=0x00007FF5B5E77640) [DQ] executer_actor.cpp:401: {ptqudts2orksmjp91qjl} WorkerInfo: Id:9f50fb2a-4caaf79f-ebafdaa3-bf5ee683,ghrun-aathosbtb4,NodeId:1,StageId:200339
2025-10-27T08:01:26.109190Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:26.109 DEBUG ydbd(pid=1702961, tid=0x00007FF5B5E77640) [DQ] executer_actor.cpp:402: {ptqudts2orksmjp91qjl} TaskInfo: 1/2
2025-10-27T08:01:26.109196Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:26.109 DEBUG ydbd(pid=1702961, tid=0x00007FF5B5E77640) [DQ] executer_actor.cpp:404: {ptqudts2orksmjp91qjl}  ObjectId: adb44c074251a1871f952a1fe07a46be1893a61c, dq_vanilla_job.lite, 
2025-10-27T08:01:26.109207Z :YQL_PROXY INFO: log.cpp:64: SessionId: ptqudts2orksmjp91qjl 2025-10-27 08:01:26.109 INFO  ydbd(pid=1702961, tid=0x00007FF5B5E77640) [DQ] executer_actor.cpp:415: {ptqudts2orksmjp91qjl} 2 workers allocated
2025-10-27T08:01:26.109326Z :YQL_PROXY TRACE: log.cpp:64: SessionId: ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud 2025-10-27 08:01:26.109 TRACE ydbd(pid=1702961, tid=0x00007FF5B5E77640) [DQ] task_controller_impl.h:271: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud}  [1:7565808603537505509:2249] ExportStats Summary
2025-10-27T08:01:26.109355Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud 2025-10-27 08:01:26.109 DEBUG ydbd(pid=1702961, tid=0x00007FF5B5E77640) [DQ] task_controller_impl.h:526: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Ready State: [1:7565808603537505509:2249]
2025-10-27T08:01:26.109364Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud 2025-10-27 08:01:26.109 DEBUG ydbd(pid=1702961, tid=0x00007FF5B5E77640) [DQ] task_controller_impl.h:537: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Forward: [1:7565808603537505509:2249] to [1:7565808603537505508:2248]
2025-10-27T08:01:26.109400Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:57: [ptqudts2orksmjp91qjl-0.1] TEvReadyState, streaming disposition { fresh { } }, state load mode EMPTY
2025-10-27T08:01:26.109414Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:91: [ptqudts2orksmjp91qjl-0.1] AllActors count: 2, ActorsToTrigger count: 1, ActorsToNotify count: 1, ActorsToWaitFor count: 2
2025-10-27T08:01:26.109415Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:101: [ptqudts2orksmjp91qjl-0.1] Send TEvRegisterCoordinatorRequest
2025-10-27T08:01:26.109423Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:186: [ptqudts2orksmjp91qjl-0.1] Got TEvRegisterCoordinatorRequest
2025-10-27T08:01:26.109507Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudts2orksmjp91qjl, Owner: 99b92891-1f35e172-b6482f17-3ee788f6, Request CP::PingTask with size: 305 bytes
2025-10-27T08:01:26.109586Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "99b92891-1f35e172-b6482f17-3ee788f6"
query_id {
  value: "ptqudts2orksmjp91qjl"
}
status: RUNNING
result_set_count: 1
result_set_meta {
  column {
    name: "Data"
    type {
      type_id: STRING
    }
  }
}
resources {
  rate_limiter: READY
  compilation: READY
  topic_consumers_state: READY
  rate_limiter_path: "local/RateLimiter_90e94ed0-64f3-4708-870a-5ec8d3274ff8/rate_limiter"
  topic_consumers {
    database: "local"
    topic_path: "high_rate_input"
    consumer_name: "ptqudts2orksmjp91qjl"
    cluster_endpoint: "localhost:30711"
    token_name: "cluster:default_high_rate"
    add_bearer_to_token: true
  }
}
scope: "yandexcloud://my_folder"
deadline {
  seconds: 1761638485
  nanos: 710106000
}
tenant: "/default"
}
2025-10-27T08:01:26.117971Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: 99b92891-1f35e172-b6482f17-3ee788f 2025-10-27 08:01:26.117 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [DQ] tasks_runner_local.cpp:267: {TODO/1} task: 1, program size: 36, llvm: ``.
2025-10-27T08:01:26.126561Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {expired_at { seconds: 1761552087 nanos: 117000000 } } SUCCESS
2025-10-27T08:01:26.126665Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudts2orksmjp91qjl, Owner: 99b92891-1f35e172-b6482f17-3ee788f6, Got CP::PingTaskResponse
2025-10-27T08:01:26.127319Z :YQL_PROXY TRACE: log.cpp:64: SessionId: ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud 2025-10-27 08:01:26.127 TRACE ydbd(pid=1702961, tid=0x00007FF5B767A640) [DQ] task_controller_impl.h:160: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} [1:7565808603537505509:2249] EvState TaskId: 2 State: 2 PingCookie: 0 StatusCode: UNSPECIFIED
2025-10-27T08:01:26.127328Z :YQL_PROXY TRACE: log.cpp:64: SessionId: ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud 2025-10-27 08:01:26.127 TRACE ydbd(pid=1702961, tid=0x00007FF5B767A640) [DQ] task_controller_impl.h:201: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud}  [1:7565808603537505509:2249] Executing TaskId: 2
2025-10-27T08:01:26.132813Z :FQ_PINGER TRACE: pinger.cpp:338: QueryId: ptqudts2orksmjp91qjl, Owner: 99b92891-1f35e172-b6482f17-3ee788f6 Ping response success: { expired_at { seconds: 1761552087 nanos: 117000000 } }
2025-10-27T08:01:26.132852Z :FQ_RUN_ACTOR TRACE: run_actor.cpp:861: QueryId: ptqudts2orksmjp91qjl Forward ping response. Success: 1. Cookie: 0
2025-10-27T08:01:26.152398Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:200: [ptqudts2orksmjp91qjl-0.1] Graph registered
2025-10-27T08:01:26.152414Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:202: [ptqudts2orksmjp91qjl-0.1] Send TEvRegisterCoordinatorResponse
2025-10-27T08:01:26.152457Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:118: [ptqudts2orksmjp91qjl-0.1] Got TEvRegisterCoordinatorResponse; issues: 
2025-10-27T08:01:26.152460Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:127: [ptqudts2orksmjp91qjl-0.1] Successfully registered in storage
2025-10-27T08:01:26.152463Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:128: [ptqudts2orksmjp91qjl-0.1] Send TEvNewCheckpointCoordinator to 2 actor(s)
2025-10-27T08:01:26.152476Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:336: [ptqudts2orksmjp91qjl-0.1] [1:1] Registering new checkpoint in storage
2025-10-27T08:01:26.152548Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:197: [] Task: 2. Got TEvNewCheckpointCoordinator event: generation 1, actorId: [1:7565808603537505508:2248]
2025-10-27T08:01:26.152560Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:208: [] Task: 2. Assign checkpoint coordinator (generation = 1)
2025-10-27T08:01:26.152575Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:210: [ptqudts2orksmjp91qjl-0.1] [1:1] Got TEvCreateCheckpointRequest
2025-10-27T08:01:26.168560Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: 99b92891-1f35e172-b6482f17-3ee788f 2025-10-27 08:01:26.168 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [DQ] tasks_runner_local.cpp:267: {TODO/1} Build task: 1 takes 59503 us
2025-10-27T08:01:26.168588Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: 99b92891-1f35e172-b6482f17-3ee788f 2025-10-27 08:01:26.168 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [DQ] tasks_runner_local.cpp:267: {TODO/1} Prepare task: 1
2025-10-27T08:01:26.168614Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: 99b92891-1f35e172-b6482f17-3ee788f 2025-10-27 08:01:26.168 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [DQ] tasks_runner_local.cpp:267: {TODO/1} Prepare task: 1, takes 18 us
2025-10-27T08:01:26.168698Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:197: [] Task: 1. Got TEvNewCheckpointCoordinator event: generation 1, actorId: [1:7565808603537505508:2248]
2025-10-27T08:01:26.168700Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:208: [] Task: 1. Assign checkpoint coordinator (generation = 1)
2025-10-27T08:01:26.169420Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1365: SelfId: [1:7565808603537505512:2252], TxId: ptqudts2orksmjp91qjl, task: 1. Ctx: {}. Create source for input 0 { Source { Type: "PqSource" Settings { type_url: "type.googleapis.com/NYql.NPq.NProto.TDqPqTopicSource" value: "\n\017high_rate_input\022\024ptqudts2orksmjp91qjl\032\017localhost:30711\"\033\n\031cluster:default_high_rate*\005local0\002@\001b\004Dataj\025[\"DataType\";\"String\"]\222\001\024ptcudts2os05kjn50skg\232\001\003raw\242\001/[\"StructType\";[[\"Data\";[\"DataType\";\"String\"]]]]\262\001\002\022\000\272\001\026\n\010cloud_id\022\nmock_cloud\272\001 \n\005scope\022\027yandexcloud://my_folder" } WatermarksMode: WATERMARKS_MODE_DISABLED } }
2025-10-27T08:01:26.169504Z :KQP_COMPUTE DEBUG: dq_pq_read_actor_base.cpp:153: SelfId: [0:0:0], TxId: ptqudts2orksmjp91qjl, task: 1. PQ source. SessionId: empty Watermarks enabled: 0 granularity: 0.000000s late arrival delay: 0.000000s idle: 0 idle delay: 0.000000s
2025-10-27T08:01:26.169540Z :YQL_PROXY TRACE: log.cpp:64: SessionId: ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud 2025-10-27 08:01:26.169 TRACE ydbd(pid=1702961, tid=0x00007FF5B6E79640) [DQ] task_controller_impl.h:160: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} [1:7565808603537505509:2249] EvState TaskId: 1 State: 2 PingCookie: 0 StatusCode: UNSPECIFIED
2025-10-27T08:01:26.169550Z :YQL_PROXY TRACE: log.cpp:64: SessionId: ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud 2025-10-27 08:01:26.169 TRACE ydbd(pid=1702961, tid=0x00007FF5B6E79640) [DQ] task_controller_impl.h:201: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud}  [1:7565808603537505509:2249] Executing TaskId: 1
2025-10-27T08:01:26.169563Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud 2025-10-27 08:01:26.169 DEBUG ydbd(pid=1702961, tid=0x00007FF5B6E79640) [DQ] task_controller_impl.h:561: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} Update channels
2025-10-27T08:01:26.170420Z :YQL_PROXY TRACE: log.cpp:64: SessionId: ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud 2025-10-27 08:01:26.169 TRACE ydbd(pid=1702961, tid=0x00007FF5B6E79640) [DQ] task_controller_impl.h:577: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} 1 Update { Id: 1 TransportVersion: DATA_TRANSPORT_UV_PICKLE_1_0 SrcTaskId: 1 DstTaskId: 2 SrcEndpoint { ActorId { RawX1: 7565808603537505512 RawX2: 4503603922340044 } } DstEndpoint { ActorId { RawX1: 7565808603537505511 RawX2: 4503603922340043 } } SrcStageId: 200322 DstStageId: 200339 }
2025-10-27T08:01:26.170461Z :YQL_PROXY TRACE: log.cpp:64: SessionId: ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud 2025-10-27 08:01:26.170 TRACE ydbd(pid=1702961, tid=0x00007FF5B6E79640) [DQ] task_controller_impl.h:577: {ptqudts2orksmjp91qjl#ptrudts2oqobjmgvkjkb#yandexcloud://my_folder#99b92891-1f35e172-b6482f17-3ee788f6#mock_cloud} 2 Update { Id: 1 TransportVersion: DATA_TRANSPORT_UV_PICKLE_1_0 SrcTaskId: 1 DstTaskId: 2 SrcEndpoint { ActorId { RawX1: 7565808603537505512 RawX2: 4503603922340044 } } DstEndpoint { ActorId { RawX1: 7565808603537505511 RawX2: 4503603922340043 } } SrcStageId: 200322 DstStageId: 200339 } Update { Id: 2 TransportVersion: DATA_TRANSPORT_UV_PICKLE_1_0 SrcTaskId: 2 SrcEndpoint { ActorId { RawX1: 7565808603537505511 RawX2: 4503603922340043 } } DstEndpoint { ActorId { RawX1: 7565808603537505507 RawX2: 4503603922340039 } } }
2025-10-27T08:01:26.170484Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1074: SelfId: [1:7565808603537505512:2252], TxId: ptqudts2orksmjp91qjl, task: 1. Ctx: {}. Received channels info: Update { Id: 1 TransportVersion: DATA_TRANSPORT_UV_PICKLE_1_0 SrcTaskId: 1 DstTaskId: 2 SrcEndpoint { ActorId { RawX1: 7565808603537505512 RawX2: 4503603922340044 } } DstEndpoint { ActorId { RawX1: 7565808603537505511 RawX2: 4503603922340043 } } SrcStageId: 200322 DstStageId: 200339 }
2025-10-27T08:01:26.170488Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1093: SelfId: [1:7565808603537505512:2252], TxId: ptqudts2orksmjp91qjl, task: 1. Ctx: {}. Update output channelId: 1, peer: [1:7565808603537505511:2251]
2025-10-27T08:01:26.170509Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1074: SelfId: [1:7565808603537505511:2251], TxId: ptqudts2orksmjp91qjl, task: 2. Ctx: {}. Received channels info: Update { Id: 1 TransportVersion: DATA_TRANSPORT_UV_PICKLE_1_0 SrcTaskId: 1 DstTaskId: 2 SrcEndpoint { ActorId { RawX1: 7565808603537505512 RawX2: 4503603922340044 } } DstEndpoint { ActorId { RawX1: 7565808603537505511 RawX2: 4503603922340043 } } SrcStageId: 200322 DstStageId: 200339 } Update { Id: 2 TransportVersion: DATA_TRANSPORT_UV_PICKLE_1_0 SrcTaskId: 2 SrcEndpoint { ActorId { RawX1: 7565808603537505511 RawX2: 4503603922340043 } } DstEndpoint { ActorId { RawX1: 7565808603537505507 RawX2: 4503603922340039 } } }
2025-10-27T08:01:26.170512Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1081: SelfId: [1:7565808603537505511:2251], TxId: ptqudts2orksmjp91qjl, task: 2. Ctx: {}. Update input channelId: 1, peer: [1:7565808603537505512:2252]
2025-10-27T08:01:26.170516Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1093: SelfId: [1:7565808603537505511:2251], TxId: ptqudts2orksmjp91qjl, task: 2. Ctx: {}. Update output channelId: 2, peer: [1:7565808603537505507:2247]
