2025-11-11T14:16:16.918323Z :GRPC_SERVER NOTICE: grpc_request_proxy_simple.cpp:161: Grpc simple request proxy started, nodeid# 1
2025-11-11T14:16:16.918387Z :GRPC_SERVER NOTICE: grpc_request_proxy_simple.cpp:161: Grpc simple request proxy started, nodeid# 1
2025-11-11T14:16:16.918597Z :FQ_LOG_UPDATER DEBUG: log.cpp:93: Updated YQL logs priority: 8
2025-11-11T14:16:16.918601Z :FQ_LOG_UPDATER CRIT: log.cpp:55: Failed to deliver subscription request to config dispatcher.
2025-11-11T14:16:16.918620Z :YQ_CONTROL_PLANE_STORAGE INFO: ydb_control_plane_storage.cpp:50: Starting ydb control plane storage service. Actor id: [1:7571471471226063732:2062]
2025-11-11T14:16:16.964143Z :FQ_CONTROL_PLANE_CONFIG DEBUG: control_plane_config.cpp:58: STARTING: [1:7571471471226063733:2063]
2025-11-11T14:16:16.964399Z :YQ_CONTROL_PLANE_PROXY DEBUG: control_plane_proxy.cpp:532: Starting yandex query control plane proxy. Actor id: [1:7571471471226063734:2064]
2025-11-11T14:16:16.964510Z :YQ_RATE_LIMITER INFO: quoter_service.cpp:124: Bootstraping with config: { Enabled: true ControlPlaneEnabled: true DataPlaneEnabled: true Database { Endpoint: "localhost:6240" Database: "local" TablePrefix: "RateLimiter_7a835054-333e-4e86-9f3d-57ea28435bbe" } Limiters { CoordinationNodePath: "rate_limiter" } }
2025-11-11T14:16:16.964650Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:188: Bootstrap
2025-11-11T14:16:16.964652Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:191: Create sdk ydb connection
2025-11-11T14:16:16.964691Z :STREAMS_STORAGE_SERVICE TRACE: storage_proxy.cpp:213: Initialize
2025-11-11T14:16:16.964738Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:534: RowDispatcher: Successfully bootstrapped row dispatcher, id [1:7571471471226063739:2069], tenant /default
2025-11-11T14:16:16.964779Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:209: Successfully bootstrapped TStorageProxy [1:7571471471226063738:2068] with connection to localhost:6240:local
2025-11-11T14:16:16.964821Z :YQ_TEST_CONNECTION DEBUG: test_connection.cpp:142: Starting yandex query test connection. Actor id: [1:7571471471226063744:2074]
2025-11-11T14:16:16.964821Z :YQL_NODES_MANAGER INFO: nodes_manager.cpp:88: Bootstrap, InstanceId: b12437ca-459036a5-a90845b7-2ea91ed0
2025-11-11T14:16:16.964823Z :YQL_NODES_MANAGER DEBUG: nodes_manager.cpp:310: TNodesManagerActor::ResolveSelfAddress
2025-11-11T14:16:16.964882Z :FQ_QUOTA_SERVICE INFO: quota_manager.cpp:196: STARTED
2025-11-11T14:16:16.964886Z :FQ_QUOTA_PROXY INFO: quota_proxy.cpp:90: STARTED
2025-11-11T14:16:16.964897Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 9e02db82-b625a9db-ce0a21a7-2b88c90b1, Host: ghrun-vb3yoermsa, Tenant: /default
2025-11-11T14:16:16.964920Z :YQ_RATE_LIMITER DEBUG: schema.cpp:71: Run create coordination node "local/RateLimiter_7a835054-333e-4e86-9f3d-57ea28435bbe/rate_limiter" actor
2025-11-11T14:16:16.964922Z :YQ_RATE_LIMITER DEBUG: schema.cpp:113: Call create coordination node "local/RateLimiter_7a835054-333e-4e86-9f3d-57ea28435bbe/rate_limiter"
2025-11-11T14:16:16.964923Z :YQ_RATE_LIMITER DEBUG: schema.cpp:411: Call create coordination node "local/RateLimiter_7a835054-333e-4e86-9f3d-57ea28435bbe/rate_limiter"
2025-11-11T14:16:16.964932Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create directory "local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe" actor
2025-11-11T14:16:16.964937Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create directory "local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe"
2025-11-11T14:16:16.964939Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/queries" actor
2025-11-11T14:16:16.964942Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:383: Call create directory "local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe"
2025-11-11T14:16:16.964947Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/pending_small" actor
2025-11-11T14:16:16.964953Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/connections" actor
2025-11-11T14:16:16.964955Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/bindings" actor
2025-11-11T14:16:16.964987Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/idempotency_keys" actor
2025-11-11T14:16:16.965009Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/result_sets" actor
2025-11-11T14:16:16.965010Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/jobs" actor
2025-11-11T14:16:16.965019Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/quotas" actor
2025-11-11T14:16:16.965019Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/nodes" actor
2025-11-11T14:16:16.965021Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/tenants" actor
2025-11-11T14:16:16.965027Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/tenant_acks" actor
2025-11-11T14:16:16.965032Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/mappings" actor
2025-11-11T14:16:16.965034Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/compute_databases" actor
2025-11-11T14:16:16.965045Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:267: Coordinator: Successfully bootstrapped coordinator, id [1:7571471471226063798:2111], NodesManagerId [0:4705493345362661702:78]
2025-11-11T14:16:16.965054Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:627: RowDispatcher: TEvCoordinatorChangesSubscribe from [1:7571471471226063798:2111]
2025-11-11T14:16:16.965056Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:232: TLeaderElection [1:7571471471226063799:2112] Successfully bootstrapped, local coordinator id [1:7571471471226063798:2111], tenant id default, local mode 0, coordination node path local/row_dispatcher/default, endpoint localhost:6240
2025-11-11T14:16:16.967321Z :MEMORY_PROFILER NOTICE: monitor.cpp:332: Bootstrapped
2025-11-11T14:16:16.968007Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-11-11T14:16:16.969779Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-11T14:16:16.969795Z :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:29734: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint localhost:29734
2025-11-11T14:16:16.969839Z :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:29734: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint localhost:29734
2025-11-11T14:16:17.049245Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:71: Run create coordination node "local/row_dispatcher/default" actor
2025-11-11T14:16:17.049258Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:113: Call create coordination node "local/row_dispatcher/default"
2025-11-11T14:16:17.049262Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:411: Call create coordination node "local/row_dispatcher/default"
2025-11-11T14:16:17.124922Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:155: Successfully created coordination node "local/row_dispatcher/default"
2025-11-11T14:16:17.124942Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:122: Reply for create coordination node "local/row_dispatcher/default": { <main>: Error: Check failed: path: '/local/row_dispatcher/default', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 12], type: EPathTypeKesus, state: EPathStateNoChanges), source_location: ydb/core/tx/schemeshard/schemeshard__operation_create_kesus.cpp:339 }
2025-11-11T14:16:17.124959Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:345: TLeaderElection [1:7571471471226063799:2112] Coordination node successfully created
2025-11-11T14:16:17.124962Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:323: TLeaderElection [1:7571471471226063799:2112] Start session
2025-11-11T14:16:17.126726Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/queries". Create session OK
2025-11-11T14:16:17.126737Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/queries"
2025-11-11T14:16:17.126740Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/queries"
2025-11-11T14:16:17.126759Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/quotas". Create session OK
2025-11-11T14:16:17.126764Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/quotas"
2025-11-11T14:16:17.126767Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/quotas"
2025-11-11T14:16:17.127099Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/pending_small". Create session OK
2025-11-11T14:16:17.127107Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/pending_small"
2025-11-11T14:16:17.127109Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/pending_small"
2025-11-11T14:16:17.127156Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/result_sets". Create session OK
2025-11-11T14:16:17.127159Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/result_sets"
2025-11-11T14:16:17.127161Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/result_sets"
2025-11-11T14:16:17.127228Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/jobs". Create session OK
2025-11-11T14:16:17.127230Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/jobs"
2025-11-11T14:16:17.127232Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/jobs"
2025-11-11T14:16:17.127236Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/nodes". Create session OK
2025-11-11T14:16:17.127237Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/nodes"
2025-11-11T14:16:17.127238Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/nodes"
2025-11-11T14:16:17.127294Z :YQ_RATE_LIMITER DEBUG: schema.cpp:155: Successfully created coordination node "local/RateLimiter_7a835054-333e-4e86-9f3d-57ea28435bbe/rate_limiter"
2025-11-11T14:16:17.127303Z :YQ_RATE_LIMITER DEBUG: schema.cpp:122: Reply for create coordination node "local/RateLimiter_7a835054-333e-4e86-9f3d-57ea28435bbe/rate_limiter": { <main>: Error: Check failed: path: '/local/RateLimiter_7a835054-333e-4e86-9f3d-57ea28435bbe/rate_limiter', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 39], type: EPathTypeKesus, state: EPathStateNoChanges), source_location: ydb/core/tx/schemeshard/schemeshard__operation_create_kesus.cpp:339 }
2025-11-11T14:16:17.127583Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/tenant_acks". Create session OK
2025-11-11T14:16:17.127591Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/tenant_acks"
2025-11-11T14:16:17.127592Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/tenant_acks"
2025-11-11T14:16:17.127674Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/mappings". Create session OK
2025-11-11T14:16:17.127678Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/mappings"
2025-11-11T14:16:17.127680Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/mappings"
2025-11-11T14:16:17.167322Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/bindings". Create session OK
2025-11-11T14:16:17.167339Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/bindings"
2025-11-11T14:16:17.167339Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/idempotency_keys". Create session OK
2025-11-11T14:16:17.167342Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/bindings"
2025-11-11T14:16:17.167344Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/idempotency_keys"
2025-11-11T14:16:17.167347Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/idempotency_keys"
2025-11-11T14:16:17.167489Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/compute_databases". Create session OK
2025-11-11T14:16:17.167492Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/compute_databases"
2025-11-11T14:16:17.167493Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/compute_databases"
2025-11-11T14:16:17.167536Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/connections". Create session OK
2025-11-11T14:16:17.167538Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/connections"
2025-11-11T14:16:17.167540Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/connections"
2025-11-11T14:16:17.167585Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/tenants". Create session OK
2025-11-11T14:16:17.167587Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/tenants"
2025-11-11T14:16:17.167588Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/tenants"
2025-11-11T14:16:17.167607Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created directory "local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe"
2025-11-11T14:16:17.167616Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create directory "local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe": { <main>: Error: Check failed: path: '/local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 34], type: EPathTypeDir, state: EPathStateNoChanges), source_location: ydb/core/tx/schemeshard/schemeshard__operation_mkdir.cpp:155 }
2025-11-11T14:16:17.167623Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/queries"
2025-11-11T14:16:17.167625Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/queries": { <main>: Error: Check failed: path: '/local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/queries', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 37], type: EPathTypeTable, state: EPathStateNoChanges), source_location: ydb/core/tx/schemeshard/schemeshard__operation_create_table.cpp:504 }
2025-11-11T14:16:17.167689Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/quotas"
2025-11-11T14:16:17.167692Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/quotas": { <main>: Error: Check failed: path: '/local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/quotas', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 41], type: EPathTypeTable, state: EPathStateNoChanges), source_location: ydb/core/tx/schemeshard/schemeshard__operation_create_table.cpp:504 }
2025-11-11T14:16:17.167743Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/pending_small"
2025-11-11T14:16:17.167751Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/pending_small": { <main>: Error: Check failed: path: '/local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/pending_small', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 40], type: EPathTypeTable, state: EPathStateNoChanges), source_location: ydb/core/tx/schemeshard/schemeshard__operation_create_table.cpp:504 }
2025-11-11T14:16:17.167852Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/jobs"
2025-11-11T14:16:17.167856Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/jobs": { <main>: Error: Check failed: path: '/local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/jobs', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 44], type: EPathTypeTable, state: EPathStateNoChanges), source_location: ydb/core/tx/schemeshard/schemeshard__operation_create_table.cpp:504 }
2025-11-11T14:16:17.167923Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/result_sets"
2025-11-11T14:16:17.167932Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/result_sets": { <main>: Error: Check failed: path: '/local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/result_sets', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 53], type: EPathTypeTable, state: EPathStateNoChanges), source_location: ydb/core/tx/schemeshard/schemeshard__operation_create_table.cpp:504 }
2025-11-11T14:16:17.167956Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/nodes"
2025-11-11T14:16:17.167960Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/nodes": { <main>: Error: Check failed: path: '/local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/nodes', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 48], type: EPathTypeTable, state: EPathStateNoChanges), source_location: ydb/core/tx/schemeshard/schemeshard__operation_create_table.cpp:504 }
2025-11-11T14:16:17.168021Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/mappings"
2025-11-11T14:16:17.168028Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/mappings": { <main>: Error: Check failed: path: '/local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/mappings', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 36], type: EPathTypeTable, state: EPathStateNoChanges), source_location: ydb/core/tx/schemeshard/schemeshard__operation_create_table.cpp:504 }
2025-11-11T14:16:17.168037Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/tenant_acks"
2025-11-11T14:16:17.168040Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/tenant_acks": { <main>: Error: Check failed: path: '/local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/tenant_acks', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 54], type: EPathTypeTable, state: EPathStateNoChanges), source_location: ydb/core/tx/schemeshard/schemeshard__operation_create_table.cpp:504 }
2025-11-11T14:16:17.168093Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:359: TLeaderElection [1:7571471471226063799:2112] Session successfully created
2025-11-11T14:16:17.169615Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:499: Checkpoint storage and state storage were successfully inited
2025-11-11T14:16:17.172242Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:372: TLeaderElection [1:7571471471226063799:2112] Semaphore successfully created
2025-11-11T14:16:17.172254Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:304: TLeaderElection [1:7571471471226063799:2112] Try to acquire semaphore
2025-11-11T14:16:17.172274Z :FQ_CONTROL_PLANE_CONFIG DEBUG: control_plane_config.cpp:190: LOADED TenantInfo: State CHANGED at 2025-11-11T14:16:01.624962Z
2025-11-11T14:16:17.172303Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:420: TLeaderElection [1:7571471471226063799:2112] Describe semaphore
2025-11-11T14:16:17.172881Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/bindings"
2025-11-11T14:16:17.172901Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/bindings": { <main>: Error: Check failed: path: '/local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/bindings', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 43], type: EPathTypeTable, state: EPathStateNoChanges), source_location: ydb/core/tx/schemeshard/schemeshard__operation_create_table.cpp:504 }
2025-11-11T14:16:17.172973Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/connections"
2025-11-11T14:16:17.172990Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/connections": { <main>: Error: Check failed: path: '/local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/connections', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 45], type: EPathTypeTable, state: EPathStateNoChanges), source_location: ydb/core/tx/schemeshard/schemeshard__operation_create_table.cpp:504 }
2025-11-11T14:16:17.173124Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/idempotency_keys"
2025-11-11T14:16:17.173150Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/idempotency_keys": { <main>: Error: Check failed: path: '/local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/idempotency_keys', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 52], type: EPathTypeTable, state: EPathStateNoChanges), source_location: ydb/core/tx/schemeshard/schemeshard__operation_create_table.cpp:504 }
2025-11-11T14:16:17.173789Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/compute_databases"
2025-11-11T14:16:17.173804Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/compute_databases": { <main>: Error: Check failed: path: '/local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/compute_databases', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 42], type: EPathTypeTable, state: EPathStateNoChanges), source_location: ydb/core/tx/schemeshard/schemeshard__operation_create_table.cpp:504 }
2025-11-11T14:16:17.228045Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/tenants"
2025-11-11T14:16:17.228064Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/tenants": { <main>: Error: Check failed: path: '/local/DbPoolStorage_7a835054-333e-4e86-9f3d-57ea28435bbe/tenants', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 35], type: EPathTypeTable, state: EPathStateNoChanges), source_location: ydb/core/tx/schemeshard/schemeshard__operation_create_table.cpp:504 }
2025-11-11T14:16:17.228173Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:386: TLeaderElection [1:7571471471226063799:2112] Semaphore successfully acquired
2025-11-11T14:16:17.228184Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:469: TLeaderElection [1:7571471471226063799:2112] Semaphore successfully described: coordinator id [1:7571471471226063798:2111] generation 3
2025-11-11T14:16:17.228188Z :FQ_ROW_DISPATCHER INFO: leader_election.cpp:471: TLeaderElection [1:7571471471226063799:2112] Send TEvCoordinatorChanged to [1:7571471471226063739:2069], new coordinator id [1:7571471471226063798:2111], previous coordinator id [0:0:0]
2025-11-11T14:16:17.228216Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:559: RowDispatcher: Coordinator changed, old leader (empty maybe), new [1:7571471471226063798:2111] generation 3
2025-11-11T14:16:17.228230Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:314: Coordinator: TEvPing received, [1:7571471471226063739:2069]
2025-11-11T14:16:17.228233Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:317: Coordinator: Send TEvPong to [1:7571471471226063739:2069]
2025-11-11T14:16:17.228240Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:386: Coordinator: New leader [1:7571471471226063798:2111], SelfId [1:7571471471226063798:2111]
2025-11-11T14:16:17.228256Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:623: RowDispatcher: NActors::TEvents::TEvPong
2025-11-11T14:16:17.916987Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 9e02db82-b625a9db-ce0a21a7-2b88c90b2, Host: ghrun-vb3yoermsa, Tenant: /default
2025-11-11T14:16:17.917011Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:542: Coordinator: Send TEvGetNodesRequest to NodesManager
2025-11-11T14:16:17.917223Z :YQL_NODES_MANAGER DEBUG: nodes_manager.cpp:300: TNodesManagerActor::TEvGetNodesRequest
2025-11-11T14:16:17.917239Z :FQ_ROW_DISPATCHER INFO: coordinator.cpp:573: Coordinator: Updated node info, node count: 0
2025-11-11T14:16:17.949727Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 9e02db82-b625a9db-ce0a21a7-2b88c90b2, Host: ghrun-vb3yoermsa, Tenant: /default, Request CP::GetTask with size: 68 bytes
2025-11-11T14:16:17.950313Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/default"
owner_id: "9e02db82-b625a9db-ce0a21a7-2b88c90b2"
host: "ghrun-vb3yoermsa"
node_id: 1
}
2025-11-11T14:16:17.955936Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-11-11T14:16:17.955980Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 9e02db82-b625a9db-ce0a21a7-2b88c90b2, Host: ghrun-vb3yoermsa, Tenant: /default, Got CP::GetTask Response
2025-11-11T14:16:17.956277Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-11T14:16:17.956288Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-11T14:16:17.997067Z :TICKET_PARSER DEBUG: ticket_parser_impl.h:1828: Ticket **** (B6C6F477) (ipv6:[::1]:42652) has now valid token of root@builtin
2025-11-11T14:16:17.997149Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:1063: ControlQueryRequest: query_id: "ptqudslmr2fr8id7ljo6"
action: ABORT
2025-11-11T14:16:17.997185Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:313: Resolve folder bootstrap. Folder id: my_folder Actor id: [1:7571471475521031159:2169]
2025-11-11T14:16:17.997206Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:375: Cloud id: mock_cloud Folder id: my_folder
2025-11-11T14:16:17.997223Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:92: Get quotas bootstrap. Cloud id: mock_cloud Actor id: [1:7571471475521031160:2170]
2025-11-11T14:16:17.997242Z :FQ_QUOTA_SERVICE DEBUG: quota_manager.cpp:255: cloud.mock_cloud NOT CASHED, Loading ...
2025-11-11T14:16:18.005646Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:441: cloud.mock_cloud {yq.analyticsQuery.count=0/100, yq.cpuPercent.count=0/10000, yq.streamingQuery.count=0/100} FROM DB
2025-11-11T14:16:18.005679Z :FQ_QUOTA_SERVICE DEBUG: quota_manager.cpp:269: 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} LOADED
2025-11-11T14:16:18.005683Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.analyticsQuery.count IS STALE, Refreshing ...
2025-11-11T14:16:18.005695Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.cpuPercent.count IS STALE, Refreshing ...
2025-11-11T14:16:18.005698Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.streamingQuery.count IS STALE, Refreshing ...
2025-11-11T14:16:18.005737Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:703: cloud.mock_cloud.yq.cpuPercent.count=0/10000 REFRESHED
2025-11-11T14:16:18.018343Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.cpuPercent.count=0/10000 NOTIFY CHANGE
2025-11-11T14:16:18.041546Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:703: cloud.mock_cloud.yq.analyticsQuery.count=0/100 REFRESHED
2025-11-11T14:16:18.041577Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:703: cloud.mock_cloud.yq.streamingQuery.count=1/100 REFRESHED
2025-11-11T14:16:18.041602Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:493: cloud.mock_cloud{yq.streamingQueryDurationMinutes.count=*/0, yq.queryResult.size=*/20971520, yq.analyticsQuery.count=0/100, yq.analyticsQueryDurationMinutes.count=*/1440, yq.memory.size=*/0, yq.result.size=*/0, yq.cpuPercent.count=0/10000, yq.streamingQuery.count=1/100} SEND QUOTAS
2025-11-11T14:16:18.041612Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:108: Cloud id: mock_cloud Quota count: 8
2025-11-11T14:16:18.041650Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:1063: ControlQueryRequest: query_id: "ptqudslmr2fr8id7ljo6"
action: ABORT
2025-11-11T14:16:18.041728Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:176: Resolve subject type bootstrap. Token: **** (B6C6F477) Actor id: [1:7571471479815998462:2176]
2025-11-11T14:16:18.041762Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:237: Subject Type: federated_account Token: **** (B6C6F477)
2025-11-11T14:16:18.041806Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:1063: ControlQueryRequest: query_id: "ptqudslmr2fr8id7ljo6"
action: ABORT
2025-11-11T14:16:18.041828Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:69: Request actor. Actor id: [1:7571471479815998463:2177]
2025-11-11T14:16:18.041872Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_queries.cpp:1342: ControlQueryRequest: {query_id: "ptqudslmr2fr8id7ljo6"
action: ABORT
} [root@builtin, **** (B6C6F477)] 
2025-11-11T14:16:18.052220Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.streamingQuery.count=1/100 NOTIFY CHANGE
2025-11-11T14:16:18.052241Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.analyticsQuery.count=0/100 NOTIFY CHANGE
2025-11-11T14:16:18.225690Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: ControlQueryRequest - ControlQueryRequest: {} SUCCESS
2025-11-11T14:16:18.227991Z :TICKET_PARSER DEBUG: ticket_parser_impl.h:1828: Ticket **** (B6C6F477) (ipv6:[::1]:42652) has now valid token of root@builtin
2025-11-11T14:16:18.228087Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:790: DescribeQueryRequest: query_id: "ptqudslmr2fr8id7ljo6"
2025-11-11T14:16:18.228126Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:313: Resolve folder bootstrap. Folder id: my_folder Actor id: [1:7571471479815998467:2180]
2025-11-11T14:16:18.228147Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:375: Cloud id: mock_cloud Folder id: my_folder
2025-11-11T14:16:18.228174Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:790: DescribeQueryRequest: query_id: "ptqudslmr2fr8id7ljo6"
2025-11-11T14:16:18.228209Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:176: Resolve subject type bootstrap. Token: **** (B6C6F477) Actor id: [1:7571471479815998468:2181]
2025-11-11T14:16:18.228256Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:237: Subject Type: federated_account Token: **** (B6C6F477)
2025-11-11T14:16:18.228295Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:790: DescribeQueryRequest: query_id: "ptqudslmr2fr8id7ljo6"
2025-11-11T14:16:18.228321Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:69: Request actor. Actor id: [1:7571471479815998469:2182]
2025-11-11T14:16:18.228357Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_queries.cpp:641: DescribeQueryRequest: {query_id: "ptqudslmr2fr8id7ljo6"
} [root@builtin, **** (B6C6F477)] 
2025-11-11T14:16:18.232847Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: DescribeQueryRequest - DescribeQueryResult: {query { meta { common { id: "ptqudslmr2fr8id7ljo6" created_by: "root@builtin" modified_by: "root@builtin" created_at { seconds: 1762870565 nanos: 540479000 } modified_at { seconds: 1762870578 nanos: 145335000 } revision: 2 } started_at { seconds: 1762870566 nanos: 498000000 } execute_mode: RUN status: ABORTING_BY_USER last_job_query_revision: 1 last_job_id: "ptjudslmr2fr7eo5vmde-ptqudslmr2fr8id7ljo6" started_by: "root@builtin" aborted_by: "root@builtin" has_saved_checkpoints: true submitted_at { seconds: 1762870565 nanos: 540479000 } } content { type: STREAMING name: "simple" acl { visibility: PRIVATE } limits { execution_timeout { } } text: "\n            PRAGMA dq.MaxTasksPerStage=\"5\";\n\n            INSERT INTO yds_1.`delete_read_rules_1_output`\n            SELECT * FROM yds_1.`delete_read_rules_1_input`;" syntax: YQL_V1 } plan { json: "{\"Detailed\":{\"Operations\":[{\"Id\":3,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[{\"Name\":\"DqSourceWideWrap\"},{\"Name\":\"NarrowMap\"}]}},{\"Id\":2,\"Name\":\"DqQuery!\",\"DependsOn\":[3]},{\"Id\":1,\"Name\":\"Commit!\",\"DependsOn\":[2]}],\"OperationRoot\":1,\"Providers\":[],\"OperationStats\":{\"Commit!\":1,\"DqQuery!\":1,\"DqStage\":1}},\"Basic\":{\"nodes\":[{\"id\":3,\"level\":1,\"name\":\"DqStage #3\",\"type\":\"op\"},{\"id\":2,\"level\":2,\"name\":\"DqQuery!\",\"type\":\"op\"},{\"id\":1,\"level\":3,\"name\":\"Commit!\",\"type\":\"op\"}],\"links\":[{\"source\":3,\"target\":2},{\"source\":2,\"target\":1}]}}" } ast { data: "(\n(let $1 (Configure! world (DataSource \'\"config\") \'\"DqEngine\" \'\"force\"))\n(let $2 (Configure! $1 (DataSource \'\"dq\" \'\"$all\") \'\"Attr\" \'\"maxtasksperstage\" \'\"5\"))\n(let $3 (DataSource \'\"pq\" \'\"yds_1\"))\n(let $4 \'(\'(\'\"PartitionsCount\" \'\"1\")))\n(let $5 (StructType \'(\'\"Data\" (DataType \'String))))\n(let $6 (PqTopic \'\"yds_1\" \'\"local\" \'\"delete_read_rules_1_input\" $4 \'() $5))\n(let $7 \'(\'\"Endpoint\" \'\"localhost:6240\"))\n(let $8 \'(\'\"SharedReading\" \'\"0\"))\n(let $9 \'(\'\"AddBearerToToken\" \'\"1\"))\n(let $10 \'($7 $8 \'(\'\"ReconnectPeriod\" \'\"\") \'(\'\"Format\" \'\"raw\") \'(\'\"ReadGroup\" \'\"ptcudslmr2rcnnsh7162\") $9))\n(let $11 (SecureParam \'\"cluster:default_yds_1\"))\n(let $12 (DqPqTopicSource $2 $6 \'(\'\"Data\") $10 $11 \'\"\" $5 \'\"\"))\n(let $13 (DataSink \'\"pq\" \'\"yds_1\"))\n(let $14 (PqTopic \'\"yds_1\" \'\"local\" \'\"delete_read_rules_1_output\" $4 \'() $5))\n(let $15 (DqPqTopicSink $14 \'($7 $9) $11))\n(return (Commit! (DqQuery! $2 \'((DqStage \'((DqSource $3 $12)) (lambda \'($16) (block \'(\n  (let $17 \'(\'(\'\"format\" \'\"raw\") \'(\'\"formatSettings\" \'(\'(\'\"data.datetime.formatname\" \'\"POSIX\") \'(\'\"data.timestamp.formatname\" \'\"POSIX\"))) \'(\'\"settings\" \'($8))))\n  (let $18 (DqSourceWideWrap $16 $3 $5 $17))\n  (return (NarrowMap $18 (lambda \'($19) (AsStruct \'(\'\"Data\" $19)))))\n))) \'(\'(\'\"_logical_id\" \'209361)) \'((DqSink \'\"0\" $13 $15))))) $13))\n)\n" } } } SUCCESS
2025-11-11T14:16:18.735864Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:790: DescribeQueryRequest: query_id: "ptqudslmr2fr8id7ljo6"
2025-11-11T14:16:18.735903Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:313: Resolve folder bootstrap. Folder id: my_folder Actor id: [1:7571471479815998473:2185]
2025-11-11T14:16:18.735928Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:375: Cloud id: mock_cloud Folder id: my_folder
2025-11-11T14:16:18.735952Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:790: DescribeQueryRequest: query_id: "ptqudslmr2fr8id7ljo6"
2025-11-11T14:16:18.736006Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:176: Resolve subject type bootstrap. Token: **** (B6C6F477) Actor id: [1:7571471479815998474:2186]
2025-11-11T14:16:18.736033Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:237: Subject Type: federated_account Token: **** (B6C6F477)
2025-11-11T14:16:18.736065Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:790: DescribeQueryRequest: query_id: "ptqudslmr2fr8id7ljo6"
2025-11-11T14:16:18.736083Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:69: Request actor. Actor id: [1:7571471479815998475:2187]
2025-11-11T14:16:18.736117Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_queries.cpp:641: DescribeQueryRequest: {query_id: "ptqudslmr2fr8id7ljo6"
} [root@builtin, **** (B6C6F477)] 
2025-11-11T14:16:18.738904Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: DescribeQueryRequest - DescribeQueryResult: {query { meta { common { id: "ptqudslmr2fr8id7ljo6" created_by: "root@builtin" modified_by: "root@builtin" created_at { seconds: 1762870565 nanos: 540479000 } modified_at { seconds: 1762870578 nanos: 145335000 } revision: 2 } started_at { seconds: 1762870566 nanos: 498000000 } execute_mode: RUN status: ABORTING_BY_USER last_job_query_revision: 1 last_job_id: "ptjudslmr2fr7eo5vmde-ptqudslmr2fr8id7ljo6" started_by: "root@builtin" aborted_by: "root@builtin" has_saved_checkpoints: true submitted_at { seconds: 1762870565 nanos: 540479000 } } content { type: STREAMING name: "simple" acl { visibility: PRIVATE } limits { execution_timeout { } } text: "\n            PRAGMA dq.MaxTasksPerStage=\"5\";\n\n            INSERT INTO yds_1.`delete_read_rules_1_output`\n            SELECT * FROM yds_1.`delete_read_rules_1_input`;" syntax: YQL_V1 } plan { json: "{\"Detailed\":{\"Operations\":[{\"Id\":3,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[{\"Name\":\"DqSourceWideWrap\"},{\"Name\":\"NarrowMap\"}]}},{\"Id\":2,\"Name\":\"DqQuery!\",\"DependsOn\":[3]},{\"Id\":1,\"Name\":\"Commit!\",\"DependsOn\":[2]}],\"OperationRoot\":1,\"Providers\":[],\"OperationStats\":{\"Commit!\":1,\"DqQuery!\":1,\"DqStage\":1}},\"Basic\":{\"nodes\":[{\"id\":3,\"level\":1,\"name\":\"DqStage #3\",\"type\":\"op\"},{\"id\":2,\"level\":2,\"name\":\"DqQuery!\",\"type\":\"op\"},{\"id\":1,\"level\":3,\"name\":\"Commit!\",\"type\":\"op\"}],\"links\":[{\"source\":3,\"target\":2},{\"source\":2,\"target\":1}]}}" } ast { data: "(\n(let $1 (Configure! world (DataSource \'\"config\") \'\"DqEngine\" \'\"force\"))\n(let $2 (Configure! $1 (DataSource \'\"dq\" \'\"$all\") \'\"Attr\" \'\"maxtasksperstage\" \'\"5\"))\n(let $3 (DataSource \'\"pq\" \'\"yds_1\"))\n(let $4 \'(\'(\'\"PartitionsCount\" \'\"1\")))\n(let $5 (StructType \'(\'\"Data\" (DataType \'String))))\n(let $6 (PqTopic \'\"yds_1\" \'\"local\" \'\"delete_read_rules_1_input\" $4 \'() $5))\n(let $7 \'(\'\"Endpoint\" \'\"localhost:6240\"))\n(let $8 \'(\'\"SharedReading\" \'\"0\"))\n(let $9 \'(\'\"AddBearerToToken\" \'\"1\"))\n(let $10 \'($7 $8 \'(\'\"ReconnectPeriod\" \'\"\") \'(\'\"Format\" \'\"raw\") \'(\'\"ReadGroup\" \'\"ptcudslmr2rcnnsh7162\") $9))\n(let $11 (SecureParam \'\"cluster:default_yds_1\"))\n(let $12 (DqPqTopicSource $2 $6 \'(\'\"Data\") $10 $11 \'\"\" $5 \'\"\"))\n(let $13 (DataSink \'\"pq\" \'\"yds_1\"))\n(let $14 (PqTopic \'\"yds_1\" \'\"local\" \'\"delete_read_rules_1_output\" $4 \'() $5))\n(let $15 (DqPqTopicSink $14 \'($7 $9) $11))\n(return (Commit! (DqQuery! $2 \'((DqStage \'((DqSource $3 $12)) (lambda \'($16) (block \'(\n  (let $17 \'(\'(\'\"format\" \'\"raw\") \'(\'\"formatSettings\" \'(\'(\'\"data.datetime.formatname\" \'\"POSIX\") \'(\'\"data.timestamp.formatname\" \'\"POSIX\"))) \'(\'\"settings\" \'($8))))\n  (let $18 (DqSourceWideWrap $16 $3 $5 $17))\n  (return (NarrowMap $18 (lambda \'($19) (AsStruct \'(\'\"Data\" $19)))))\n))) \'(\'(\'\"_logical_id\" \'209361)) \'((DqSink \'\"0\" $13 $15))))) $13))\n)\n" } } } SUCCESS
2025-11-11T14:16:18.917382Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:617: RowDispatcher: Send ping to [1:7571471471226063798:2111]
2025-11-11T14:16:18.917394Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1161: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-11-11T14:16:18.917400Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:542: Coordinator: Send TEvGetNodesRequest to NodesManager
2025-11-11T14:16:18.917405Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:314: Coordinator: TEvPing received, [1:7571471471226063739:2069]
2025-11-11T14:16:18.917407Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:317: Coordinator: Send TEvPong to [1:7571471471226063739:2069]
2025-11-11T14:16:18.917406Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 9e02db82-b625a9db-ce0a21a7-2b88c90b3, Host: ghrun-vb3yoermsa, Tenant: /default
2025-11-11T14:16:18.917430Z :YQL_NODES_MANAGER DEBUG: nodes_manager.cpp:300: TNodesManagerActor::TEvGetNodesRequest
2025-11-11T14:16:18.917437Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:623: RowDispatcher: NActors::TEvents::TEvPong
2025-11-11T14:16:18.917445Z :FQ_ROW_DISPATCHER INFO: coordinator.cpp:573: Coordinator: Updated node info, node count: 0
2025-11-11T14:16:18.917982Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 9e02db82-b625a9db-ce0a21a7-2b88c90b3, Host: ghrun-vb3yoermsa, Tenant: /default, Request CP::GetTask with size: 68 bytes
2025-11-11T14:16:18.918047Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/default"
owner_id: "9e02db82-b625a9db-ce0a21a7-2b88c90b3"
host: "ghrun-vb3yoermsa"
node_id: 1
}
2025-11-11T14:16:18.920622Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-11-11T14:16:18.920686Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 9e02db82-b625a9db-ce0a21a7-2b88c90b3, Host: ghrun-vb3yoermsa, Tenant: /default, Got CP::GetTask Response
2025-11-11T14:16:18.920981Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-11T14:16:18.920992Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-11T14:16:19.241865Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:790: DescribeQueryRequest: query_id: "ptqudslmr2fr8id7ljo6"
2025-11-11T14:16:19.241900Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:313: Resolve folder bootstrap. Folder id: my_folder Actor id: [1:7571471484110965778:2193]
2025-11-11T14:16:19.241919Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:375: Cloud id: mock_cloud Folder id: my_folder
2025-11-11T14:16:19.241961Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:790: DescribeQueryRequest: query_id: "ptqudslmr2fr8id7ljo6"
2025-11-11T14:16:19.242021Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:176: Resolve subject type bootstrap. Token: **** (B6C6F477) Actor id: [1:7571471484110965779:2194]
2025-11-11T14:16:19.242061Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:237: Subject Type: federated_account Token: **** (B6C6F477)
2025-11-11T14:16:19.242082Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:790: DescribeQueryRequest: query_id: "ptqudslmr2fr8id7ljo6"
2025-11-11T14:16:19.242110Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:69: Request actor. Actor id: [1:7571471484110965780:2195]
2025-11-11T14:16:19.242155Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_queries.cpp:641: DescribeQueryRequest: {query_id: "ptqudslmr2fr8id7ljo6"
} [root@builtin, **** (B6C6F477)] 
2025-11-11T14:16:19.244472Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: DescribeQueryRequest - DescribeQueryResult: {query { meta { common { id: "ptqudslmr2fr8id7ljo6" created_by: "root@builtin" modified_by: "root@builtin" created_at { seconds: 1762870565 nanos: 540479000 } modified_at { seconds: 1762870578 nanos: 145335000 } revision: 2 } started_at { seconds: 1762870566 nanos: 498000000 } execute_mode: RUN status: ABORTING_BY_USER last_job_query_revision: 1 last_job_id: "ptjudslmr2fr7eo5vmde-ptqudslmr2fr8id7ljo6" started_by: "root@builtin" aborted_by: "root@builtin" has_saved_checkpoints: true submitted_at { seconds: 1762870565 nanos: 540479000 } } content { type: STREAMING name: "simple" acl { visibility: PRIVATE } limits { execution_timeout { } } text: "\n            PRAGMA dq.MaxTasksPerStage=\"5\";\n\n            INSERT INTO yds_1.`delete_read_rules_1_output`\n            SELECT * FROM yds_1.`delete_read_rules_1_input`;" syntax: YQL_V1 } plan { json: "{\"Detailed\":{\"Operations\":[{\"Id\":3,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[{\"Name\":\"DqSourceWideWrap\"},{\"Name\":\"NarrowMap\"}]}},{\"Id\":2,\"Name\":\"DqQuery!\",\"DependsOn\":[3]},{\"Id\":1,\"Name\":\"Commit!\",\"DependsOn\":[2]}],\"OperationRoot\":1,\"Providers\":[],\"OperationStats\":{\"Commit!\":1,\"DqQuery!\":1,\"DqStage\":1}},\"Basic\":{\"nodes\":[{\"id\":3,\"level\":1,\"name\":\"DqStage #3\",\"type\":\"op\"},{\"id\":2,\"level\":2,\"name\":\"DqQuery!\",\"type\":\"op\"},{\"id\":1,\"level\":3,\"name\":\"Commit!\",\"type\":\"op\"}],\"links\":[{\"source\":3,\"target\":2},{\"source\":2,\"target\":1}]}}" } ast { data: "(\n(let $1 (Configure! world (DataSource \'\"config\") \'\"DqEngine\" \'\"force\"))\n(let $2 (Configure! $1 (DataSource \'\"dq\" \'\"$all\") \'\"Attr\" \'\"maxtasksperstage\" \'\"5\"))\n(let $3 (DataSource \'\"pq\" \'\"yds_1\"))\n(let $4 \'(\'(\'\"PartitionsCount\" \'\"1\")))\n(let $5 (StructType \'(\'\"Data\" (DataType \'String))))\n(let $6 (PqTopic \'\"yds_1\" \'\"local\" \'\"delete_read_rules_1_input\" $4 \'() $5))\n(let $7 \'(\'\"Endpoint\" \'\"localhost:6240\"))\n(let $8 \'(\'\"SharedReading\" \'\"0\"))\n(let $9 \'(\'\"AddBearerToToken\" \'\"1\"))\n(let $10 \'($7 $8 \'(\'\"ReconnectPeriod\" \'\"\") \'(\'\"Format\" \'\"raw\") \'(\'\"ReadGroup\" \'\"ptcudslmr2rcnnsh7162\") $9))\n(let $11 (SecureParam \'\"cluster:default_yds_1\"))\n(let $12 (DqPqTopicSource $2 $6 \'(\'\"Data\") $10 $11 \'\"\" $5 \'\"\"))\n(let $13 (DataSink \'\"pq\" \'\"yds_1\"))\n(let $14 (PqTopic \'\"yds_1\" \'\"local\" \'\"delete_read_rules_1_output\" $4 \'() $5))\n(let $15 (DqPqTopicSink $14 \'($7 $9) $11))\n(return (Commit! (DqQuery! $2 \'((DqStage \'((DqSource $3 $12)) (lambda \'($16) (block \'(\n  (let $17 \'(\'(\'\"format\" \'\"raw\") \'(\'\"formatSettings\" \'(\'(\'\"data.datetime.formatname\" \'\"POSIX\") \'(\'\"data.timestamp.formatname\" \'\"POSIX\"))) \'(\'\"settings\" \'($8))))\n  (let $18 (DqSourceWideWrap $16 $3 $5 $17))\n  (return (NarrowMap $18 (lambda \'($19) (AsStruct \'(\'\"Data\" $19)))))\n))) \'(\'(\'\"_logical_id\" \'209361)) \'((DqSink \'\"0\" $13 $15))))) $13))\n)\n" } } } SUCCESS
2025-11-11T14:16:19.746384Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:790: DescribeQueryRequest: query_id: "ptqudslmr2fr8id7ljo6"
2025-11-11T14:16:19.746435Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:313: Resolve folder bootstrap. Folder id: my_folder Actor id: [1:7571471484110965784:2198]
2025-11-11T14:16:19.746457Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:375: Cloud id: mock_cloud Folder id: my_folder
2025-11-11T14:16:19.746477Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:790: DescribeQueryRequest: query_id: "ptqudslmr2fr8id7ljo6"
2025-11-11T14:16:19.746528Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:176: Resolve subject type bootstrap. Token: **** (B6C6F477) Actor id: [1:7571471484110965785:2199]
2025-11-11T14:16:19.746557Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:237: Subject Type: federated_account Token: **** (B6C6F477)
2025-11-11T14:16:19.746585Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:790: DescribeQueryRequest: query_id: "ptqudslmr2fr8id7ljo6"
2025-11-11T14:16:19.746625Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:69: Request actor. Actor id: [1:7571471484110965786:2200]
2025-11-11T14:16:19.746661Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_queries.cpp:641: DescribeQueryRequest: {query_id: "ptqudslmr2fr8id7ljo6"
} [root@builtin, **** (B6C6F477)] 
2025-11-11T14:16:19.749231Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: DescribeQueryRequest - DescribeQueryResult: {query { meta { common { id: "ptqudslmr2fr8id7ljo6" created_by: "root@builtin" modified_by: "root@builtin" created_at { seconds: 1762870565 nanos: 540479000 } modified_at { seconds: 1762870578 nanos: 145335000 } revision: 2 } started_at { seconds: 1762870566 nanos: 498000000 } execute_mode: RUN status: ABORTING_BY_USER last_job_query_revision: 1 last_job_id: "ptjudslmr2fr7eo5vmde-ptqudslmr2fr8id7ljo6" started_by: "root@builtin" aborted_by: "root@builtin" has_saved_checkpoints: true submitted_at { seconds: 1762870565 nanos: 540479000 } } content { type: STREAMING name: "simple" acl { visibility: PRIVATE } limits { execution_timeout { } } text: "\n            PRAGMA dq.MaxTasksPerStage=\"5\";\n\n            INSERT INTO yds_1.`delete_read_rules_1_output`\n            SELECT * FROM yds_1.`delete_read_rules_1_input`;" syntax: YQL_V1 } plan { json: "{\"Detailed\":{\"Operations\":[{\"Id\":3,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[{\"Name\":\"DqSourceWideWrap\"},{\"Name\":\"NarrowMap\"}]}},{\"Id\":2,\"Name\":\"DqQuery!\",\"DependsOn\":[3]},{\"Id\":1,\"Name\":\"Commit!\",\"DependsOn\":[2]}],\"OperationRoot\":1,\"Providers\":[],\"OperationStats\":{\"Commit!\":1,\"DqQuery!\":1,\"DqStage\":1}},\"Basic\":{\"nodes\":[{\"id\":3,\"level\":1,\"name\":\"DqStage #3\",\"type\":\"op\"},{\"id\":2,\"level\":2,\"name\":\"DqQuery!\",\"type\":\"op\"},{\"id\":1,\"level\":3,\"name\":\"Commit!\",\"type\":\"op\"}],\"links\":[{\"source\":3,\"target\":2},{\"source\":2,\"target\":1}]}}" } ast { data: "(\n(let $1 (Configure! world (DataSource \'\"config\") \'\"DqEngine\" \'\"force\"))\n(let $2 (Configure! $1 (DataSource \'\"dq\" \'\"$all\") \'\"Attr\" \'\"maxtasksperstage\" \'\"5\"))\n(let $3 (DataSource \'\"pq\" \'\"yds_1\"))\n(let $4 \'(\'(\'\"PartitionsCount\" \'\"1\")))\n(let $5 (StructType \'(\'\"Data\" (DataType \'String))))\n(let $6 (PqTopic \'\"yds_1\" \'\"local\" \'\"delete_read_rules_1_input\" $4 \'() $5))\n(let $7 \'(\'\"Endpoint\" \'\"localhost:6240\"))\n(let $8 \'(\'\"SharedReading\" \'\"0\"))\n(let $9 \'(\'\"AddBearerToToken\" \'\"1\"))\n(let $10 \'($7 $8 \'(\'\"ReconnectPeriod\" \'\"\") \'(\'\"Format\" \'\"raw\") \'(\'\"ReadGroup\" \'\"ptcudslmr2rcnnsh7162\") $9))\n(let $11 (SecureParam \'\"cluster:default_yds_1\"))\n(let $12 (DqPqTopicSource $2 $6 \'(\'\"Data\") $10 $11 \'\"\" $5 \'\"\"))\n(let $13 (DataSink \'\"pq\" \'\"yds_1\"))\n(let $14 (PqTopic \'\"yds_1\" \'\"local\" \'\"delete_read_rules_1_output\" $4 \'() $5))\n(let $15 (DqPqTopicSink $14 \'($7 $9) $11))\n(return (Commit! (DqQuery! $2 \'((DqStage \'((DqSource $3 $12)) (lambda \'($16) (block \'(\n  (let $17 \'(\'(\'\"format\" \'\"raw\") \'(\'\"formatSettings\" \'(\'(\'\"data.datetime.formatname\" \'\"POSIX\") \'(\'\"data.timestamp.formatname\" \'\"POSIX\"))) \'(\'\"settings\" \'($8))))\n  (let $18 (DqSourceWideWrap $16 $3 $5 $17))\n  (return (NarrowMap $18 (lambda \'($19) (AsStruct \'(\'\"Data\" $19)))))\n))) \'(\'(\'\"_logical_id\" \'209361)) \'((DqSink \'\"0\" $13 $15))))) $13))\n)\n" } } } SUCCESS
2025-11-11T14:16:19.917865Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:542: Coordinator: Send TEvGetNodesRequest to NodesManager
2025-11-11T14:16:19.917873Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 9e02db82-b625a9db-ce0a21a7-2b88c90b4, Host: ghrun-vb3yoermsa, Tenant: /default
2025-11-11T14:16:19.917884Z :YQL_NODES_MANAGER DEBUG: nodes_manager.cpp:300: TNodesManagerActor::TEvGetNodesRequest
2025-11-11T14:16:19.917889Z :FQ_ROW_DISPATCHER INFO: coordinator.cpp:573: Coordinator: Updated node info, node count: 0
2025-11-11T14:16:19.918361Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 9e02db82-b625a9db-ce0a21a7-2b88c90b4, Host: ghrun-vb3yoermsa, Tenant: /default, Request CP::GetTask with size: 68 bytes
2025-11-11T14:16:19.918419Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/default"
owner_id: "9e02db82-b625a9db-ce0a21a7-2b88c90b4"
host: "ghrun-vb3yoermsa"
node_id: 1
}
2025-11-11T14:16:19.920923Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-11-11T14:16:19.920954Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 9e02db82-b625a9db-ce0a21a7-2b88c90b4, Host: ghrun-vb3yoermsa, Tenant: /default, Got CP::GetTask Response
2025-11-11T14:16:19.921207Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-11T14:16:19.921217Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-11T14:16:19.976329Z :FQ_CONTROL_PLANE_CONFIG TRACE: control_plane_config.cpp:192: LOADED TenantInfo: State NOT changed
2025-11-11T14:16:20.274769Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:790: DescribeQueryRequest: query_id: "ptqudslmr2fr8id7ljo6"
2025-11-11T14:16:20.274813Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:313: Resolve folder bootstrap. Folder id: my_folder Actor id: [1:7571471488405933090:2207]
2025-11-11T14:16:20.274850Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:375: Cloud id: mock_cloud Folder id: my_folder
2025-11-11T14:16:20.274891Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:790: DescribeQueryRequest: query_id: "ptqudslmr2fr8id7ljo6"
2025-11-11T14:16:20.274960Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:176: Resolve subject type bootstrap. Token: **** (B6C6F477) Actor id: [1:7571471488405933091:2208]
2025-11-11T14:16:20.274990Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:237: Subject Type: federated_account Token: **** (B6C6F477)
2025-11-11T14:16:20.275008Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:790: DescribeQueryRequest: query_id: "ptqudslmr2fr8id7ljo6"
2025-11-11T14:16:20.275030Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:69: Request actor. Actor id: [1:7571471488405933092:2209]
2025-11-11T14:16:20.275057Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_queries.cpp:641: DescribeQueryRequest: {query_id: "ptqudslmr2fr8id7ljo6"
} [root@builtin, **** (B6C6F477)] 
2025-11-11T14:16:20.281732Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: DescribeQueryRequest - DescribeQueryResult: {query { meta { common { id: "ptqudslmr2fr8id7ljo6" created_by: "root@builtin" modified_by: "root@builtin" created_at { seconds: 1762870565 nanos: 540479000 } modified_at { seconds: 1762870578 nanos: 145335000 } revision: 2 } started_at { seconds: 1762870566 nanos: 498000000 } execute_mode: RUN status: ABORTING_BY_USER last_job_query_revision: 1 last_job_id: "ptjudslmr2fr7eo5vmde-ptqudslmr2fr8id7ljo6" started_by: "root@builtin" aborted_by: "root@builtin" has_saved_checkpoints: true submitted_at { seconds: 1762870565 nanos: 540479000 } } content { type: STREAMING name: "simple" acl { visibility: PRIVATE } limits { execution_timeout { } } text: "\n            PRAGMA dq.MaxTasksPerStage=\"5\";\n\n            INSERT INTO yds_1.`delete_read_rules_1_output`\n            SELECT * FROM yds_1.`delete_read_rules_1_input`;" syntax: YQL_V1 } plan { json: "{\"Detailed\":{\"Operations\":[{\"Id\":3,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[{\"Name\":\"DqSourceWideWrap\"},{\"Name\":\"NarrowMap\"}]}},{\"Id\":2,\"Name\":\"DqQuery!\",\"DependsOn\":[3]},{\"Id\":1,\"Name\":\"Commit!\",\"DependsOn\":[2]}],\"OperationRoot\":1,\"Providers\":[],\"OperationStats\":{\"Commit!\":1,\"DqQuery!\":1,\"DqStage\":1}},\"Basic\":{\"nodes\":[{\"id\":3,\"level\":1,\"name\":\"DqStage #3\",\"type\":\"op\"},{\"id\":2,\"level\":2,\"name\":\"DqQuery!\",\"type\":\"op\"},{\"id\":1,\"level\":3,\"name\":\"Commit!\",\"type\":\"op\"}],\"links\":[{\"source\":3,\"target\":2},{\"source\":2,\"target\":1}]}}" } ast { data: "(\n(let $1 (Configure! world (DataSource \'\"config\") \'\"DqEngine\" \'\"force\"))\n(let $2 (Configure! $1 (DataSource \'\"dq\" \'\"$all\") \'\"Attr\" \'\"maxtasksperstage\" \'\"5\"))\n(let $3 (DataSource \'\"pq\" \'\"yds_1\"))\n(let $4 \'(\'(\'\"PartitionsCount\" \'\"1\")))\n(let $5 (StructType \'(\'\"Data\" (DataType \'String))))\n(let $6 (PqTopic \'\"yds_1\" \'\"local\" \'\"delete_read_rules_1_input\" $4 \'() $5))\n(let $7 \'(\'\"Endpoint\" \'\"localhost:6240\"))\n(let $8 \'(\'\"SharedReading\" \'\"0\"))\n(let $9 \'(\'\"AddBearerToToken\" \'\"1\"))\n(let $10 \'($7 $8 \'(\'\"ReconnectPeriod\" \'\"\") \'(\'\"Format\" \'\"raw\") \'(\'\"ReadGroup\" \'\"ptcudslmr2rcnnsh7162\") $9))\n(let $11 (SecureParam \'\"cluster:default_yds_1\"))\n(let $12 (DqPqTopicSource $2 $6 \'(\'\"Data\") $10 $11 \'\"\" $5 \'\"\"))\n(let $13 (DataSink \'\"pq\" \'\"yds_1\"))\n(let $14 (PqTopic \'\"yds_1\" \'\"local\" \'\"delete_read_rules_1_output\" $4 \'() $5))\n(let $15 (DqPqTopicSink $14 \'($7 $9) $11))\n(return (Commit! (DqQuery! $2 \'((DqStage \'((DqSource $3 $12)) (lambda \'($16) (block \'(\n  (let $17 \'(\'(\'\"format\" \'\"raw\") \'(\'\"formatSettings\" \'(\'(\'\"data.datetime.formatname\" \'\"POSIX\") \'(\'\"data.timestamp.formatname\" \'\"POSIX\"))) \'(\'\"settings\" \'($8))))\n  (let $18 (DqSourceWideWrap $16 $3 $5 $17))\n  (return (NarrowMap $18 (lambda \'($19) (AsStruct \'(\'\"Data\" $19)))))\n))) \'(\'(\'\"_logical_id\" \'209361)) \'((DqSink \'\"0\" $13 $15))))) $13))\n)\n" } } } SUCCESS
2025-11-11T14:16:20.783906Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:790: DescribeQueryRequest: query_id: "ptqudslmr2fr8id7ljo6"
2025-11-11T14:16:20.783957Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:313: Resolve folder bootstrap. Folder id: my_folder Actor id: [1:7571471488405933096:2212]
2025-11-11T14:16:20.783983Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:375: Cloud id: mock_cloud Folder id: my_folder
2025-11-11T14:16:20.784027Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:790: DescribeQueryRequest: query_id: "ptqudslmr2fr8id7ljo6"
2025-11-11T14:16:20.784084Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:176: Resolve subject type bootstrap. Token: **** (B6C6F477) Actor id: [1:7571471488405933097:2213]
2025-11-11T14:16:20.784120Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:237: Subject Type: federated_account Token: **** (B6C6F477)
2025-11-11T14:16:20.784161Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:790: DescribeQueryRequest: query_id: "ptqudslmr2fr8id7ljo6"
2025-11-11T14:16:20.784198Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:69: Request actor. Actor id: [1:7571471488405933098:2214]
2025-11-11T14:16:20.784249Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_queries.cpp:641: DescribeQueryRequest: {query_id: "ptqudslmr2fr8id7ljo6"
} [root@builtin, **** (B6C6F477)] 
2025-11-11T14:16:20.787185Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: DescribeQueryRequest - DescribeQueryResult: {query { meta { common { id: "ptqudslmr2fr8id7ljo6" created_by: "root@builtin" modified_by: "root@builtin" created_at { seconds: 1762870565 nanos: 540479000 } modified_at { seconds: 1762870578 nanos: 145335000 } revision: 2 } started_at { seconds: 1762870566 nanos: 498000000 } execute_mode: RUN status: ABORTING_BY_USER last_job_query_revision: 1 last_job_id: "ptjudslmr2fr7eo5vmde-ptqudslmr2fr8id7ljo6" started_by: "root@builtin" aborted_by: "root@builtin" has_saved_checkpoints: true submitted_at { seconds: 1762870565 nanos: 540479000 } } content { type: STREAMING name: "simple" acl { visibility: PRIVATE } limits { execution_timeout { } } text: "\n            PRAGMA dq.MaxTasksPerStage=\"5\";\n\n            INSERT INTO yds_1.`delete_read_rules_1_output`\n            SELECT * FROM yds_1.`delete_read_rules_1_input`;" syntax: YQL_V1 } plan { json: "{\"Detailed\":{\"Operations\":[{\"Id\":3,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[{\"Name\":\"DqSourceWideWrap\"},{\"Name\":\"NarrowMap\"}]}},{\"Id\":2,\"Name\":\"DqQuery!\",\"DependsOn\":[3]},{\"Id\":1,\"Name\":\"Commit!\",\"DependsOn\":[2]}],\"OperationRoot\":1,\"Providers\":[],\"OperationStats\":{\"Commit!\":1,\"DqQuery!\":1,\"DqStage\":1}},\"Basic\":{\"nodes\":[{\"id\":3,\"level\":1,\"name\":\"DqStage #3\",\"type\":\"op\"},{\"id\":2,\"level\":2,\"name\":\"DqQuery!\",\"type\":\"op\"},{\"id\":1,\"level\":3,\"name\":\"Commit!\",\"type\":\"op\"}],\"links\":[{\"source\":3,\"target\":2},{\"source\":2,\"target\":1}]}}" } ast { data: "(\n(let $1 (Configure! world (DataSource \'\"config\") \'\"DqEngine\" \'\"force\"))\n(let $2 (Configure! $1 (DataSource \'\"dq\" \'\"$all\") \'\"Attr\" \'\"maxtasksperstage\" \'\"5\"))\n(let $3 (DataSource \'\"pq\" \'\"yds_1\"))\n(let $4 \'(\'(\'\"PartitionsCount\" \'\"1\")))\n(let $5 (StructType \'(\'\"Data\" (DataType \'String))))\n(let $6 (PqTopic \'\"yds_1\" \'\"local\" \'\"delete_read_rules_1_input\" $4 \'() $5))\n(let $7 \'(\'\"Endpoint\" \'\"localhost:6240\"))\n(let $8 \'(\'\"SharedReading\" \'\"0\"))\n(let $9 \'(\'\"AddBearerToToken\" \'\"1\"))\n(let $10 \'($7 $8 \'(\'\"ReconnectPeriod\" \'\"\") \'(\'\"Format\" \'\"raw\") \'(\'\"ReadGroup\" \'\"ptcudslmr2rcnnsh7162\") $9))\n(let $11 (SecureParam \'\"cluster:default_yds_1\"))\n(let $12 (DqPqTopicSource $2 $6 \'(\'\"Data\") $10 $11 \'\"\" $5 \'\"\"))\n(let $13 (DataSink \'\"pq\" \'\"yds_1\"))\n(let $14 (PqTopic \'\"yds_1\" \'\"local\" \'\"delete_read_rules_1_output\" $4 \'() $5))\n(let $15 (DqPqTopicSink $14 \'($7 $9) $11))\n(return (Commit! (DqQuery! $2 \'((DqStage \'((DqSource $3 $12)) (lambda \'($16) (block \'(\n  (let $17 \'(\'(\'\"format\" \'\"raw\") \'(\'\"formatSettings\" \'(\'(\'\"data.datetime.formatname\" \'\"POSIX\") \'(\'\"data.timestamp.formatname\" \'\"POSIX\"))) \'(\'\"settings\" \'($8))))\n  (let $18 (DqSourceWideWrap $16 $3 $5 $17))\n  (return (NarrowMap $18 (lambda \'($19) (AsStruct \'(\'\"Data\" $19)))))\n))) \'(\'(\'\"_logical_id\" \'209361)) \'((DqSink \'\"0\" $13 $15))))) $13))\n)\n" } } } SUCCESS
2025-11-11T14:16:20.918346Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:617: RowDispatcher: Send ping to [1:7571471471226063798:2111]
2025-11-11T14:16:20.918357Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1161: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-11-11T14:16:20.918370Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:542: Coordinator: Send TEvGetNodesRequest to NodesManager
2025-11-11T14:16:20.918374Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 9e02db82-b625a9db-ce0a21a7-2b88c90b5, Host: ghrun-vb3yoermsa, Tenant: /default
2025-11-11T14:16:20.918380Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:314: Coordinator: TEvPing received, [1:7571471471226063739:2069]
2025-11-11T14:16:20.918384Z :YQL_NODES_MANAGER DEBUG: nodes_manager.cpp:300: TNodesManagerActor::TEvGetNodesRequest
2025-11-11T14:16:20.918384Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:317: Coordinator: Send TEvPong to [1:7571471471226063739:2069]
2025-11-11T14:16:20.918389Z :FQ_ROW_DISPATCHER INFO: coordinator.cpp:573: Coordinator: Updated node info, node count: 0
2025-11-11T14:16:20.918394Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:623: RowDispatcher: NActors::TEvents::TEvPong
2025-11-11T14:16:20.918880Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 9e02db82-b625a9db-ce0a21a7-2b88c90b5, Host: ghrun-vb3yoermsa, Tenant: /default, Request CP::GetTask with size: 68 bytes
2025-11-11T14:16:20.918935Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/default"
owner_id: "9e02db82-b625a9db-ce0a21a7-2b88c90b5"
host: "ghrun-vb3yoermsa"
node_id: 1
}
2025-11-11T14:16:20.924349Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-11-11T14:16:20.924415Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 9e02db82-b625a9db-ce0a21a7-2b88c90b5, Host: ghrun-vb3yoermsa, Tenant: /default, Got CP::GetTask Response
2025-11-11T14:16:20.924726Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-11T14:16:20.924741Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-11T14:16:21.290326Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:790: DescribeQueryRequest: query_id: "ptqudslmr2fr8id7ljo6"
2025-11-11T14:16:21.290370Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:313: Resolve folder bootstrap. Folder id: my_folder Actor id: [1:7571471492700900401:2220]
2025-11-11T14:16:21.290398Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:375: Cloud id: mock_cloud Folder id: my_folder
2025-11-11T14:16:21.290429Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:790: DescribeQueryRequest: query_id: "ptqudslmr2fr8id7ljo6"
2025-11-11T14:16:21.290477Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:176: Resolve subject type bootstrap. Token: **** (B6C6F477) Actor id: [1:7571471492700900402:2221]
2025-11-11T14:16:21.290498Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:237: Subject Type: federated_account Token: **** (B6C6F477)
2025-11-11T14:16:21.290520Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:790: DescribeQueryRequest: query_id: "ptqudslmr2fr8id7ljo6"
2025-11-11T14:16:21.290540Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:69: Request actor. Actor id: [1:7571471492700900403:2222]
2025-11-11T14:16:21.290580Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_queries.cpp:641: DescribeQueryRequest: {query_id: "ptqudslmr2fr8id7ljo6"
} [root@builtin, **** (B6C6F477)] 
2025-11-11T14:16:21.293357Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: DescribeQueryRequest - DescribeQueryResult: {query { meta { common { id: "ptqudslmr2fr8id7ljo6" created_by: "root@builtin" modified_by: "root@builtin" created_at { seconds: 1762870565 nanos: 540479000 } modified_at { seconds: 1762870578 nanos: 145335000 } revision: 2 } started_at { seconds: 1762870566 nanos: 498000000 } execute_mode: RUN status: ABORTING_BY_USER last_job_query_revision: 1 last_job_id: "ptjudslmr2fr7eo5vmde-ptqudslmr2fr8id7ljo6" started_by: "root@builtin" aborted_by: "root@builtin" has_saved_checkpoints: true submitted_at { seconds: 1762870565 nanos: 540479000 } } content { type: STREAMING name: "simple" acl { visibility: PRIVATE } limits { execution_timeout { } } text: "\n            PRAGMA dq.MaxTasksPerStage=\"5\";\n\n            INSERT INTO yds_1.`delete_read_rules_1_output`\n            SELECT * FROM yds_1.`delete_read_rules_1_input`;" syntax: YQL_V1 } plan { json: "{\"Detailed\":{\"Operations\":[{\"Id\":3,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[{\"Name\":\"DqSourceWideWrap\"},{\"Name\":\"NarrowMap\"}]}},{\"Id\":2,\"Name\":\"DqQuery!\",\"DependsOn\":[3]},{\"Id\":1,\"Name\":\"Commit!\",\"DependsOn\":[2]}],\"OperationRoot\":1,\"Providers\":[],\"OperationStats\":{\"Commit!\":1,\"DqQuery!\":1,\"DqStage\":1}},\"Basic\":{\"nodes\":[{\"id\":3,\"level\":1,\"name\":\"DqStage #3\",\"type\":\"op\"},{\"id\":2,\"level\":2,\"name\":\"DqQuery!\",\"type\":\"op\"},{\"id\":1,\"level\":3,\"name\":\"Commit!\",\"type\":\"op\"}],\"links\":[{\"source\":3,\"target\":2},{\"source\":2,\"target\":1}]}}" } ast { data: "(\n(let $1 (Configure! world (DataSource \'\"config\") \'\"DqEngine\" \'\"force\"))\n(let $2 (Configure! $1 (DataSource \'\"dq\" \'\"$all\") \'\"Attr\" \'\"maxtasksperstage\" \'\"5\"))\n(let $3 (DataSource \'\"pq\" \'\"yds_1\"))\n(let $4 \'(\'(\'\"PartitionsCount\" \'\"1\")))\n(let $5 (StructType \'(\'\"Data\" (DataType \'String))))\n(let $6 (PqTopic \'\"yds_1\" \'\"local\" \'\"delete_read_rules_1_input\" $4 \'() $5))\n(let $7 \'(\'\"Endpoint\" \'\"localhost:6240\"))\n(let $8 \'(\'\"SharedReading\" \'\"0\"))\n(let $9 \'(\'\"AddBearerToToken\" \'\"1\"))\n(let $10 \'($7 $8 \'(\'\"ReconnectPeriod\" \'\"\") \'(\'\"Format\" \'\"raw\") \'(\'\"ReadGroup\" \'\"ptcudslmr2rcnnsh7162\") $9))\n(let $11 (SecureParam \'\"cluster:default_yds_1\"))\n(let $12 (DqPqTopicSource $2 $6 \'(\'\"Data\") $10 $11 \'\"\" $5 \'\"\"))\n(let $13 (DataSink \'\"pq\" \'\"yds_1\"))\n(let $14 (PqTopic \'\"yds_1\" \'\"local\" \'\"delete_read_rules_1_output\" $4 \'() $5))\n(let $15 (DqPqTopicSink $14 \'($7 $9) $11))\n(return (Commit! (DqQuery! $2 \'((DqStage \'((DqSource $3 $12)) (lambda \'($16) (block \'(\n  (let $17 \'(\'(\'\"format\" \'\"raw\") \'(\'\"formatSettings\" \'(\'(\'\"data.datetime.formatname\" \'\"POSIX\") \'(\'\"data.timestamp.formatname\" \'\"POSIX\"))) \'(\'\"settings\" \'($8))))\n  (let $18 (DqSourceWideWrap $16 $3 $5 $17))\n  (return (NarrowMap $18 (lambda \'($19) (AsStruct \'(\'\"Data\" $19)))))\n))) \'(\'(\'\"_logical_id\" \'209361)) \'((DqSink \'\"0\" $13 $15))))) $13))\n)\n" } } } SUCCESS
2025-11-11T14:16:21.797148Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:790: DescribeQueryRequest: query_id: "ptqudslmr2fr8id7ljo6"
2025-11-11T14:16:21.797180Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:313: Resolve folder bootstrap. Folder id: my_folder Actor id: [1:7571471492700900407:2225]
2025-11-11T14:16:21.797203Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:375: Cloud id: mock_cloud Folder id: my_folder
2025-11-11T14:16:21.797252Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:790: DescribeQueryRequest: query_id: "ptqudslmr2fr8id7ljo6"
2025-11-11T14:16:21.797286Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:176: Resolve subject type bootstrap. Token: **** (B6C6F477) Actor id: [1:7571471492700900408:2226]
2025-11-11T14:16:21.797320Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:237: Subject Type: federated_account Token: **** (B6C6F477)
2025-11-11T14:16:21.797357Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:790: DescribeQueryRequest: query_id: "ptqudslmr2fr8id7ljo6"
2025-11-11T14:16:21.797381Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:69: Request actor. Actor id: [1:7571471492700900409:2227]
2025-11-11T14:16:21.797404Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_queries.cpp:641: DescribeQueryRequest: {query_id: "ptqudslmr2fr8id7ljo6"
} [root@builtin, **** (B6C6F477)] 
2025-11-11T14:16:21.801329Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: DescribeQueryRequest - DescribeQueryResult: {query { meta { common { id: "ptqudslmr2fr8id7ljo6" created_by: "root@builtin" modified_by: "root@builtin" created_at { seconds: 1762870565 nanos: 540479000 } modified_at { seconds: 1762870578 nanos: 145335000 } revision: 2 } started_at { seconds: 1762870566 nanos: 498000000 } execute_mode: RUN status: ABORTING_BY_USER last_job_query_revision: 1 last_job_id: "ptjudslmr2fr7eo5vmde-ptqudslmr2fr8id7ljo6" started_by: "root@builtin" aborted_by: "root@builtin" has_saved_checkpoints: true submitted_at { seconds: 1762870565 nanos: 540479000 } } content { type: STREAMING name: "simple" acl { visibility: PRIVATE } limits { execution_timeout { } } text: "\n            PRAGMA dq.MaxTasksPerStage=\"5\";\n\n            INSERT INTO yds_1.`delete_read_rules_1_output`\n            SELECT * FROM yds_1.`delete_read_rules_1_input`;" syntax: YQL_V1 } plan { json: "{\"Detailed\":{\"Operations\":[{\"Id\":3,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[{\"Name\":\"DqSourceWideWrap\"},{\"Name\":\"NarrowMap\"}]}},{\"Id\":2,\"Name\":\"DqQuery!\",\"DependsOn\":[3]},{\"Id\":1,\"Name\":\"Commit!\",\"DependsOn\":[2]}],\"OperationRoot\":1,\"Providers\":[],\"OperationStats\":{\"Commit!\":1,\"DqQuery!\":1,\"DqStage\":1}},\"Basic\":{\"nodes\":[{\"id\":3,\"level\":1,\"name\":\"DqStage #3\",\"type\":\"op\"},{\"id\":2,\"level\":2,\"name\":\"DqQuery!\",\"type\":\"op\"},{\"id\":1,\"level\":3,\"name\":\"Commit!\",\"type\":\"op\"}],\"links\":[{\"source\":3,\"target\":2},{\"source\":2,\"target\":1}]}}" } ast { data: "(\n(let $1 (Configure! world (DataSource \'\"config\") \'\"DqEngine\" \'\"force\"))\n(let $2 (Configure! $1 (DataSource \'\"dq\" \'\"$all\") \'\"Attr\" \'\"maxtasksperstage\" \'\"5\"))\n(let $3 (DataSource \'\"pq\" \'\"yds_1\"))\n(let $4 \'(\'(\'\"PartitionsCount\" \'\"1\")))\n(let $5 (StructType \'(\'\"Data\" (DataType \'String))))\n(let $6 (PqTopic \'\"yds_1\" \'\"local\" \'\"delete_read_rules_1_input\" $4 \'() $5))\n(let $7 \'(\'\"Endpoint\" \'\"localhost:6240\"))\n(let $8 \'(\'\"SharedReading\" \'\"0\"))\n(let $9 \'(\'\"AddBearerToToken\" \'\"1\"))\n(let $10 \'($7 $8 \'(\'\"ReconnectPeriod\" \'\"\") \'(\'\"Format\" \'\"raw\") \'(\'\"ReadGroup\" \'\"ptcudslmr2rcnnsh7162\") $9))\n(let $11 (SecureParam \'\"cluster:default_yds_1\"))\n(let $12 (DqPqTopicSource $2 $6 \'(\'\"Data\") $10 $11 \'\"\" $5 \'\"\"))\n(let $13 (DataSink \'\"pq\" \'\"yds_1\"))\n(let $14 (PqTopic \'\"yds_1\" \'\"local\" \'\"delete_read_rules_1_output\" $4 \'() $5))\n(let $15 (DqPqTopicSink $14 \'($7 $9) $11))\n(return (Commit! (DqQuery! $2 \'((DqStage \'((DqSource $3 $12)) (lambda \'($16) (block \'(\n  (let $17 \'(\'(\'\"format\" \'\"raw\") \'(\'\"formatSettings\" \'(\'(\'\"data.datetime.formatname\" \'\"POSIX\") \'(\'\"data.timestamp.formatname\" \'\"POSIX\"))) \'(\'\"settings\" \'($8))))\n  (let $18 (DqSourceWideWrap $16 $3 $5 $17))\n  (return (NarrowMap $18 (lambda \'($19) (AsStruct \'(\'\"Data\" $19)))))\n))) \'(\'(\'\"_logical_id\" \'209361)) \'((DqSink \'\"0\" $13 $15))))) $13))\n)\n" } } } SUCCESS
2025-11-11T14:16:21.916698Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-11-11T14:16:21.917523Z :YQ_CONTROL_PLANE_STORAGE TRACE: nodes_health_check.cpp:38: NodesHealthCheckRequest: {tenant: "/default"
node {
  node_id: 1
  instance_id: "b12437ca-459036a5-a90845b7-2ea91ed0"
  hostname: "ghrun-vb3yoermsa"
  interconnect_port: 13471
  node_address: "127.0.1.1"
}
}
2025-11-11T14:16:21.918762Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 9e02db82-b625a9db-ce0a21a7-2b88c90b6, Host: ghrun-vb3yoermsa, Tenant: /default
2025-11-11T14:16:21.918794Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:542: Coordinator: Send TEvGetNodesRequest to NodesManager
2025-11-11T14:16:21.918954Z :YQL_NODES_MANAGER DEBUG: nodes_manager.cpp:300: TNodesManagerActor::TEvGetNodesRequest
2025-11-11T14:16:21.918977Z :FQ_ROW_DISPATCHER INFO: coordinator.cpp:573: Coordinator: Updated node info, node count: 0
2025-11-11T14:16:21.919216Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 9e02db82-b625a9db-ce0a21a7-2b88c90b6, Host: ghrun-vb3yoermsa, Tenant: /default, Request CP::GetTask with size: 68 bytes
2025-11-11T14:16:21.919257Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/default"
owner_id: "9e02db82-b625a9db-ce0a21a7-2b88c90b6"
host: "ghrun-vb3yoermsa"
node_id: 1
}
2025-11-11T14:16:21.927526Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-11-11T14:16:21.927549Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 9e02db82-b625a9db-ce0a21a7-2b88c90b6, Host: ghrun-vb3yoermsa, Tenant: /default, Got CP::GetTask Response
2025-11-11T14:16:21.927835Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-11T14:16:21.927844Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-11T14:16:22.021654Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: NodesHealthCheckRequest - NodesHealthCheckResult: {nodes { node_id: 1 instance_id: "b12437ca-459036a5-a90845b7-2ea91ed0" hostname: "ghrun-vb3yoermsa" node_address: "127.0.1.1" } } SUCCESS
2025-11-11T14:16:22.022374Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:389: Send NodeInfo with size: 0 to DynamicNameserver
2025-11-11T14:16:22.303200Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:790: DescribeQueryRequest: query_id: "ptqudslmr2fr8id7ljo6"
2025-11-11T14:16:22.303246Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:313: Resolve folder bootstrap. Folder id: my_folder Actor id: [1:7571471496995867715:2236]
2025-11-11T14:16:22.303266Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:375: Cloud id: mock_cloud Folder id: my_folder
2025-11-11T14:16:22.303289Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:790: DescribeQueryRequest: query_id: "ptqudslmr2fr8id7ljo6"
2025-11-11T14:16:22.303311Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:176: Resolve subject type bootstrap. Token: **** (B6C6F477) Actor id: [1:7571471496995867716:2237]
2025-11-11T14:16:22.303321Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:237: Subject Type: federated_account Token: **** (B6C6F477)
2025-11-11T14:16:22.303330Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:790: DescribeQueryRequest: query_id: "ptqudslmr2fr8id7ljo6"
2025-11-11T14:16:22.303338Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:69: Request actor. Actor id: [1:7571471496995867717:2238]
2025-11-11T14:16:22.303357Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_queries.cpp:641: DescribeQueryRequest: {query_id: "ptqudslmr2fr8id7ljo6"
} [root@builtin, **** (B6C6F477)] 
2025-11-11T14:16:22.305930Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: DescribeQueryRequest - DescribeQueryResult: {query { meta { common { id: "ptqudslmr2fr8id7ljo6" created_by: "root@builtin" modified_by: "root@builtin" created_at { seconds: 1762870565 nanos: 540479000 } modified_at { seconds: 1762870578 nanos: 145335000 } revision: 2 } started_at { seconds: 1762870566 nanos: 498000000 } execute_mode: RUN status: ABORTING_BY_USER last_job_query_revision: 1 last_job_id: "ptjudslmr2fr7eo5vmde-ptqudslmr2fr8id7ljo6" started_by: "root@builtin" aborted_by: "root@builtin" has_saved_checkpoints: true submitted_at { seconds: 1762870565 nanos: 540479000 } } content { type: STREAMING name: "simple" acl { visibility: PRIVATE } limits { execution_timeout { } } text: "\n            PRAGMA dq.MaxTasksPerStage=\"5\";\n\n            INSERT INTO yds_1.`delete_read_rules_1_output`\n            SELECT * FROM yds_1.`delete_read_rules_1_input`;" syntax: YQL_V1 } plan { json: "{\"Detailed\":{\"Operations\":[{\"Id\":3,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[{\"Name\":\"DqSourceWideWrap\"},{\"Name\":\"NarrowMap\"}]}},{\"Id\":2,\"Name\":\"DqQuery!\",\"DependsOn\":[3]},{\"Id\":1,\"Name\":\"Commit!\",\"DependsOn\":[2]}],\"OperationRoot\":1,\"Providers\":[],\"OperationStats\":{\"Commit!\":1,\"DqQuery!\":1,\"DqStage\":1}},\"Basic\":{\"nodes\":[{\"id\":3,\"level\":1,\"name\":\"DqStage #3\",\"type\":\"op\"},{\"id\":2,\"level\":2,\"name\":\"DqQuery!\",\"type\":\"op\"},{\"id\":1,\"level\":3,\"name\":\"Commit!\",\"type\":\"op\"}],\"links\":[{\"source\":3,\"target\":2},{\"source\":2,\"target\":1}]}}" } ast { data: "(\n(let $1 (Configure! world (DataSource \'\"config\") \'\"DqEngine\" \'\"force\"))\n(let $2 (Configure! $1 (DataSource \'\"dq\" \'\"$all\") \'\"Attr\" \'\"maxtasksperstage\" \'\"5\"))\n(let $3 (DataSource \'\"pq\" \'\"yds_1\"))\n(let $4 \'(\'(\'\"PartitionsCount\" \'\"1\")))\n(let $5 (StructType \'(\'\"Data\" (DataType \'String))))\n(let $6 (PqTopic \'\"yds_1\" \'\"local\" \'\"delete_read_rules_1_input\" $4 \'() $5))\n(let $7 \'(\'\"Endpoint\" \'\"localhost:6240\"))\n(let $8 \'(\'\"SharedReading\" \'\"0\"))\n(let $9 \'(\'\"AddBearerToToken\" \'\"1\"))\n(let $10 \'($7 $8 \'(\'\"ReconnectPeriod\" \'\"\") \'(\'\"Format\" \'\"raw\") \'(\'\"ReadGroup\" \'\"ptcudslmr2rcnnsh7162\") $9))\n(let $11 (SecureParam \'\"cluster:default_yds_1\"))\n(let $12 (DqPqTopicSource $2 $6 \'(\'\"Data\") $10 $11 \'\"\" $5 \'\"\"))\n(let $13 (DataSink \'\"pq\" \'\"yds_1\"))\n(let $14 (PqTopic \'\"yds_1\" \'\"local\" \'\"delete_read_rules_1_output\" $4 \'() $5))\n(let $15 (DqPqTopicSink $14 \'($7 $9) $11))\n(return (Commit! (DqQuery! $2 \'((DqStage \'((DqSource $3 $12)) (lambda \'($16) (block \'(\n  (let $17 \'(\'(\'\"format\" \'\"raw\") \'(\'\"formatSettings\" \'(\'(\'\"data.datetime.formatname\" \'\"POSIX\") \'(\'\"data.timestamp.formatname\" \'\"POSIX\"))) \'(\'\"settings\" \'($8))))\n  (let $18 (DqSourceWideWrap $16 $3 $5 $17))\n  (return (NarrowMap $18 (lambda \'($19) (AsStruct \'(\'\"Data\" $19)))))\n))) \'(\'(\'\"_logical_id\" \'209361)) \'((DqSink \'\"0\" $13 $15))))) $13))\n)\n" } } } SUCCESS
2025-11-11T14:16:22.808161Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:790: DescribeQueryRequest: query_id: "ptqudslmr2fr8id7ljo6"
2025-11-11T14:16:22.808210Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:313: Resolve folder bootstrap. Folder id: my_folder Actor id: [1:7571471496995867721:2241]
2025-11-11T14:16:22.808234Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:375: Cloud id: mock_cloud Folder id: my_folder
2025-11-11T14:16:22.808273Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:790: DescribeQueryRequest: query_id: "ptqudslmr2fr8id7ljo6"
2025-11-11T14:16:22.808302Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:176: Resolve subject type bootstrap. Token: **** (B6C6F477) Actor id: [1:7571471496995867722:2242]
2025-11-11T14:16:22.808327Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:237: Subject Type: federated_account Token: **** (B6C6F477)
2025-11-11T14:16:22.808375Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:790: DescribeQueryRequest: query_id: "ptqudslmr2fr8id7ljo6"
2025-11-11T14:16:22.808400Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:69: Request actor. Actor id: [1:7571471496995867723:2243]
2025-11-11T14:16:22.808431Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_queries.cpp:641: DescribeQueryRequest: {query_id: "ptqudslmr2fr8id7ljo6"
} [root@builtin, **** (B6C6F477)] 
2025-11-11T14:16:22.815936Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: DescribeQueryRequest - DescribeQueryResult: {query { meta { common { id: "ptqudslmr2fr8id7ljo6" created_by: "root@builtin" modified_by: "root@builtin" created_at { seconds: 1762870565 nanos: 540479000 } modified_at { seconds: 1762870578 nanos: 145335000 } revision: 2 } started_at { seconds: 1762870566 nanos: 498000000 } execute_mode: RUN status: ABORTING_BY_USER last_job_query_revision: 1 last_job_id: "ptjudslmr2fr7eo5vmde-ptqudslmr2fr8id7ljo6" started_by: "root@builtin" aborted_by: "root@builtin" has_saved_checkpoints: true submitted_at { seconds: 1762870565 nanos: 540479000 } } content { type: STREAMING name: "simple" acl { visibility: PRIVATE } limits { execution_timeout { } } text: "\n            PRAGMA dq.MaxTasksPerStage=\"5\";\n\n            INSERT INTO yds_1.`delete_read_rules_1_output`\n            SELECT * FROM yds_1.`delete_read_rules_1_input`;" syntax: YQL_V1 } plan { json: "{\"Detailed\":{\"Operations\":[{\"Id\":3,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[{\"Name\":\"DqSourceWideWrap\"},{\"Name\":\"NarrowMap\"}]}},{\"Id\":2,\"Name\":\"DqQuery!\",\"DependsOn\":[3]},{\"Id\":1,\"Name\":\"Commit!\",\"DependsOn\":[2]}],\"OperationRoot\":1,\"Providers\":[],\"OperationStats\":{\"Commit!\":1,\"DqQuery!\":1,\"DqStage\":1}},\"Basic\":{\"nodes\":[{\"id\":3,\"level\":1,\"name\":\"DqStage #3\",\"type\":\"op\"},{\"id\":2,\"level\":2,\"name\":\"DqQuery!\",\"type\":\"op\"},{\"id\":1,\"level\":3,\"name\":\"Commit!\",\"type\":\"op\"}],\"links\":[{\"source\":3,\"target\":2},{\"source\":2,\"target\":1}]}}" } ast { data: "(\n(let $1 (Configure! world (DataSource \'\"config\") \'\"DqEngine\" \'\"force\"))\n(let $2 (Configure! $1 (DataSource \'\"dq\" \'\"$all\") \'\"Attr\" \'\"maxtasksperstage\" \'\"5\"))\n(let $3 (DataSource \'\"pq\" \'\"yds_1\"))\n(let $4 \'(\'(\'\"PartitionsCount\" \'\"1\")))\n(let $5 (StructType \'(\'\"Data\" (DataType \'String))))\n(let $6 (PqTopic \'\"yds_1\" \'\"local\" \'\"delete_read_rules_1_input\" $4 \'() $5))\n(let $7 \'(\'\"Endpoint\" \'\"localhost:6240\"))\n(let $8 \'(\'\"SharedReading\" \'\"0\"))\n(let $9 \'(\'\"AddBearerToToken\" \'\"1\"))\n(let $10 \'($7 $8 \'(\'\"ReconnectPeriod\" \'\"\") \'(\'\"Format\" \'\"raw\") \'(\'\"ReadGroup\" \'\"ptcudslmr2rcnnsh7162\") $9))\n(let $11 (SecureParam \'\"cluster:default_yds_1\"))\n(let $12 (DqPqTopicSource $2 $6 \'(\'\"Data\") $10 $11 \'\"\" $5 \'\"\"))\n(let $13 (DataSink \'\"pq\" \'\"yds_1\"))\n(let $14 (PqTopic \'\"yds_1\" \'\"local\" \'\"delete_read_rules_1_output\" $4 \'() $5))\n(let $15 (DqPqTopicSink $14 \'($7 $9) $11))\n(return (Commit! (DqQuery! $2 \'((DqStage \'((DqSource $3 $12)) (lambda \'($16) (block \'(\n  (let $17 \'(\'(\'\"format\" \'\"raw\") \'(\'\"formatSettings\" \'(\'(\'\"data.datetime.formatname\" \'\"POSIX\") \'(\'\"data.timestamp.formatname\" \'\"POSIX\"))) \'(\'\"settings\" \'($8))))\n  (let $18 (DqSourceWideWrap $16 $3 $5 $17))\n  (return (NarrowMap $18 (lambda \'($19) (AsStruct \'(\'\"Data\" $19)))))\n))) \'(\'(\'\"_logical_id\" \'209361)) \'((DqSink \'\"0\" $13 $15))))) $13))\n)\n" } } } SUCCESS
2025-11-11T14:16:22.919212Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:617: RowDispatcher: Send ping to [1:7571471471226063798:2111]
2025-11-11T14:16:22.919227Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1161: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-11-11T14:16:22.919231Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 9e02db82-b625a9db-ce0a21a7-2b88c90b7, Host: ghrun-vb3yoermsa, Tenant: /default
2025-11-11T14:16:22.919243Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:542: Coordinator: Send TEvGetNodesRequest to NodesManager
2025-11-11T14:16:22.919248Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:314: Coordinator: TEvPing received, [1:7571471471226063739:2069]
2025-11-11T14:16:22.919251Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:317: Coordinator: Send TEvPong to [1:7571471471226063739:2069]
2025-11-11T14:16:22.919269Z :YQL_NODES_MANAGER DEBUG: nodes_manager.cpp:300: TNodesManagerActor::TEvGetNodesRequest
2025-11-11T14:16:22.919274Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:623: RowDispatcher: NActors::TEvents::TEvPong
2025-11-11T14:16:22.919277Z :FQ_ROW_DISPATCHER INFO: coordinator.cpp:573: Coordinator: Updated node info, node count: 1
2025-11-11T14:16:22.921596Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 9e02db82-b625a9db-ce0a21a7-2b88c90b7, Host: ghrun-vb3yoermsa, Tenant: /default, Request CP::GetTask with size: 68 bytes
2025-11-11T14:16:22.921666Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/default"
owner_id: "9e02db82-b625a9db-ce0a21a7-2b88c90b7"
host: "ghrun-vb3yoermsa"
node_id: 1
}
2025-11-11T14:16:22.924130Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-11-11T14:16:22.924161Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 9e02db82-b625a9db-ce0a21a7-2b88c90b7, Host: ghrun-vb3yoermsa, Tenant: /default, Got CP::GetTask Response
2025-11-11T14:16:22.924419Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-11T14:16:22.924430Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-11T14:16:22.981625Z :FQ_CONTROL_PLANE_CONFIG TRACE: control_plane_config.cpp:192: LOADED TenantInfo: State NOT changed
2025-11-11T14:16:23.321721Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:790: DescribeQueryRequest: query_id: "ptqudslmr2fr8id7ljo6"
2025-11-11T14:16:23.321779Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:313: Resolve folder bootstrap. Folder id: my_folder Actor id: [1:7571471501290835027:2250]
2025-11-11T14:16:23.321817Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:375: Cloud id: mock_cloud Folder id: my_folder
2025-11-11T14:16:23.321845Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:790: DescribeQueryRequest: query_id: "ptqudslmr2fr8id7ljo6"
2025-11-11T14:16:23.321886Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:176: Resolve subject type bootstrap. Token: **** (B6C6F477) Actor id: [1:7571471501290835028:2251]
2025-11-11T14:16:23.321915Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:237: Subject Type: federated_account Token: **** (B6C6F477)
2025-11-11T14:16:23.321950Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:790: DescribeQueryRequest: query_id: "ptqudslmr2fr8id7ljo6"
2025-11-11T14:16:23.321973Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:69: Request actor. Actor id: [1:7571471501290835029:2252]
2025-11-11T14:16:23.322015Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_queries.cpp:641: DescribeQueryRequest: {query_id: "ptqudslmr2fr8id7ljo6"
} [root@builtin, **** (B6C6F477)] 
2025-11-11T14:16:23.324626Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: DescribeQueryRequest - DescribeQueryResult: {query { meta { common { id: "ptqudslmr2fr8id7ljo6" created_by: "root@builtin" modified_by: "root@builtin" created_at { seconds: 1762870565 nanos: 540479000 } modified_at { seconds: 1762870578 nanos: 145335000 } revision: 2 } started_at { seconds: 1762870566 nanos: 498000000 } execute_mode: RUN status: ABORTING_BY_USER last_job_query_revision: 1 last_job_id: "ptjudslmr2fr7eo5vmde-ptqudslmr2fr8id7ljo6" started_by: "root@builtin" aborted_by: "root@builtin" has_saved_checkpoints: true submitted_at { seconds: 1762870565 nanos: 540479000 } } content { type: STREAMING name: "simple" acl { visibility: PRIVATE } limits { execution_timeout { } } text: "\n            PRAGMA dq.MaxTasksPerStage=\"5\";\n\n            INSERT INTO yds_1.`delete_read_rules_1_output`\n            SELECT * FROM yds_1.`delete_read_rules_1_input`;" syntax: YQL_V1 } plan { json: "{\"Detailed\":{\"Operations\":[{\"Id\":3,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[{\"Name\":\"DqSourceWideWrap\"},{\"Name\":\"NarrowMap\"}]}},{\"Id\":2,\"Name\":\"DqQuery!\",\"DependsOn\":[3]},{\"Id\":1,\"Name\":\"Commit!\",\"DependsOn\":[2]}],\"OperationRoot\":1,\"Providers\":[],\"OperationStats\":{\"Commit!\":1,\"DqQuery!\":1,\"DqStage\":1}},\"Basic\":{\"nodes\":[{\"id\":3,\"level\":1,\"name\":\"DqStage #3\",\"type\":\"op\"},{\"id\":2,\"level\":2,\"name\":\"DqQuery!\",\"type\":\"op\"},{\"id\":1,\"level\":3,\"name\":\"Commit!\",\"type\":\"op\"}],\"links\":[{\"source\":3,\"target\":2},{\"source\":2,\"target\":1}]}}" } ast { data: "(\n(let $1 (Configure! world (DataSource \'\"config\") \'\"DqEngine\" \'\"force\"))\n(let $2 (Configure! $1 (DataSource \'\"dq\" \'\"$all\") \'\"Attr\" \'\"maxtasksperstage\" \'\"5\"))\n(let $3 (DataSource \'\"pq\" \'\"yds_1\"))\n(let $4 \'(\'(\'\"PartitionsCount\" \'\"1\")))\n(let $5 (StructType \'(\'\"Data\" (DataType \'String))))\n(let $6 (PqTopic \'\"yds_1\" \'\"local\" \'\"delete_read_rules_1_input\" $4 \'() $5))\n(let $7 \'(\'\"Endpoint\" \'\"localhost:6240\"))\n(let $8 \'(\'\"SharedReading\" \'\"0\"))\n(let $9 \'(\'\"AddBearerToToken\" \'\"1\"))\n(let $10 \'($7 $8 \'(\'\"ReconnectPeriod\" \'\"\") \'(\'\"Format\" \'\"raw\") \'(\'\"ReadGroup\" \'\"ptcudslmr2rcnnsh7162\") $9))\n(let $11 (SecureParam \'\"cluster:default_yds_1\"))\n(let $12 (DqPqTopicSource $2 $6 \'(\'\"Data\") $10 $11 \'\"\" $5 \'\"\"))\n(let $13 (DataSink \'\"pq\" \'\"yds_1\"))\n(let $14 (PqTopic \'\"yds_1\" \'\"local\" \'\"delete_read_rules_1_output\" $4 \'() $5))\n(let $15 (DqPqTopicSink $14 \'($7 $9) $11))\n(return (Commit! (DqQuery! $2 \'((DqStage \'((DqSource $3 $12)) (lambda \'($16) (block \'(\n  (let $17 \'(\'(\'\"format\" \'\"raw\") \'(\'\"formatSettings\" \'(\'(\'\"data.datetime.formatname\" \'\"POSIX\") \'(\'\"data.timestamp.formatname\" \'\"POSIX\"))) \'(\'\"settings\" \'($8))))\n  (let $18 (DqSourceWideWrap $16 $3 $5 $17))\n  (return (NarrowMap $18 (lambda \'($19) (AsStruct \'(\'\"Data\" $19)))))\n))) \'(\'(\'\"_logical_id\" \'209361)) \'((DqSink \'\"0\" $13 $15))))) $13))\n)\n" } } } SUCCESS
2025-11-11T14:16:23.826629Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:790: DescribeQueryRequest: query_id: "ptqudslmr2fr8id7ljo6"
2025-11-11T14:16:23.826674Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:313: Resolve folder bootstrap. Folder id: my_folder Actor id: [1:7571471501290835033:2255]
2025-11-11T14:16:23.826699Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:375: Cloud id: mock_cloud Folder id: my_folder
2025-11-11T14:16:23.826723Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:790: DescribeQueryRequest: query_id: "ptqudslmr2fr8id7ljo6"
2025-11-11T14:16:23.826766Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:176: Resolve subject type bootstrap. Token: **** (B6C6F477) Actor id: [1:7571471501290835034:2256]
2025-11-11T14:16:23.826820Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:237: Subject Type: federated_account Token: **** (B6C6F477)
2025-11-11T14:16:23.826854Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:790: DescribeQueryRequest: query_id: "ptqudslmr2fr8id7ljo6"
2025-11-11T14:16:23.826890Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:69: Request actor. Actor id: [1:7571471501290835035:2257]
2025-11-11T14:16:23.826952Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_queries.cpp:641: DescribeQueryRequest: {query_id: "ptqudslmr2fr8id7ljo6"
} [root@builtin, **** (B6C6F477)] 
2025-11-11T14:16:23.829613Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: DescribeQueryRequest - DescribeQueryResult: {query { meta { common { id: "ptqudslmr2fr8id7ljo6" created_by: "root@builtin" modified_by: "root@builtin" created_at { seconds: 1762870565 nanos: 540479000 } modified_at { seconds: 1762870578 nanos: 145335000 } revision: 2 } started_at { seconds: 1762870566 nanos: 498000000 } execute_mode: RUN status: ABORTING_BY_USER last_job_query_revision: 1 last_job_id: "ptjudslmr2fr7eo5vmde-ptqudslmr2fr8id7ljo6" started_by: "root@builtin" aborted_by: "root@builtin" has_saved_checkpoints: true submitted_at { seconds: 1762870565 nanos: 540479000 } } content { type: STREAMING name: "simple" acl { visibility: PRIVATE } limits { execution_timeout { } } text: "\n            PRAGMA dq.MaxTasksPerStage=\"5\";\n\n            INSERT INTO yds_1.`delete_read_rules_1_output`\n            SELECT * FROM yds_1.`delete_read_rules_1_input`;" syntax: YQL_V1 } plan { json: "{\"Detailed\":{\"Operations\":[{\"Id\":3,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[{\"Name\":\"DqSourceWideWrap\"},{\"Name\":\"NarrowMap\"}]}},{\"Id\":2,\"Name\":\"DqQuery!\",\"DependsOn\":[3]},{\"Id\":1,\"Name\":\"Commit!\",\"DependsOn\":[2]}],\"OperationRoot\":1,\"Providers\":[],\"OperationStats\":{\"Commit!\":1,\"DqQuery!\":1,\"DqStage\":1}},\"Basic\":{\"nodes\":[{\"id\":3,\"level\":1,\"name\":\"DqStage #3\",\"type\":\"op\"},{\"id\":2,\"level\":2,\"name\":\"DqQuery!\",\"type\":\"op\"},{\"id\":1,\"level\":3,\"name\":\"Commit!\",\"type\":\"op\"}],\"links\":[{\"source\":3,\"target\":2},{\"source\":2,\"target\":1}]}}" } ast { data: "(\n(let $1 (Configure! world (DataSource \'\"config\") \'\"DqEngine\" \'\"force\"))\n(let $2 (Configure! $1 (DataSource \'\"dq\" \'\"$all\") \'\"Attr\" \'\"maxtasksperstage\" \'\"5\"))\n(let $3 (DataSource \'\"pq\" \'\"yds_1\"))\n(let $4 \'(\'(\'\"PartitionsCount\" \'\"1\")))\n(let $5 (StructType \'(\'\"Data\" (DataType \'String))))\n(let $6 (PqTopic \'\"yds_1\" \'\"local\" \'\"delete_read_rules_1_input\" $4 \'() $5))\n(let $7 \'(\'\"Endpoint\" \'\"localhost:6240\"))\n(let $8 \'(\'\"SharedReading\" \'\"0\"))\n(let $9 \'(\'\"AddBearerToToken\" \'\"1\"))\n(let $10 \'($7 $8 \'(\'\"ReconnectPeriod\" \'\"\") \'(\'\"Format\" \'\"raw\") \'(\'\"ReadGroup\" \'\"ptcudslmr2rcnnsh7162\") $9))\n(let $11 (SecureParam \'\"cluster:default_yds_1\"))\n(let $12 (DqPqTopicSource $2 $6 \'(\'\"Data\") $10 $11 \'\"\" $5 \'\"\"))\n(let $13 (DataSink \'\"pq\" \'\"yds_1\"))\n(let $14 (PqTopic \'\"yds_1\" \'\"local\" \'\"delete_read_rules_1_output\" $4 \'() $5))\n(let $15 (DqPqTopicSink $14 \'($7 $9) $11))\n(return (Commit! (DqQuery! $2 \'((DqStage \'((DqSource $3 $12)) (lambda \'($16) (block \'(\n  (let $17 \'(\'(\'\"format\" \'\"raw\") \'(\'\"formatSettings\" \'(\'(\'\"data.datetime.formatname\" \'\"POSIX\") \'(\'\"data.timestamp.formatname\" \'\"POSIX\"))) \'(\'\"settings\" \'($8))))\n  (let $18 (DqSourceWideWrap $16 $3 $5 $17))\n  (return (NarrowMap $18 (lambda \'($19) (AsStruct \'(\'\"Data\" $19)))))\n))) \'(\'(\'\"_logical_id\" \'209361)) \'((DqSink \'\"0\" $13 $15))))) $13))\n)\n" } } } SUCCESS
2025-11-11T14:16:23.919647Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 9e02db82-b625a9db-ce0a21a7-2b88c90b8, Host: ghrun-vb3yoermsa, Tenant: /default
2025-11-11T14:16:23.920090Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 9e02db82-b625a9db-ce0a21a7-2b88c90b8, Host: ghrun-vb3yoermsa, Tenant: /default, Request CP::GetTask with size: 68 bytes
2025-11-11T14:16:23.920137Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/default"
owner_id: "9e02db82-b625a9db-ce0a21a7-2b88c90b8"
host: "ghrun-vb3yoermsa"
node_id: 1
}
2025-11-11T14:16:23.922946Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-11-11T14:16:23.922969Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 9e02db82-b625a9db-ce0a21a7-2b88c90b8, Host: ghrun-vb3yoermsa, Tenant: /default, Got CP::GetTask Response
2025-11-11T14:16:23.923265Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-11T14:16:23.923271Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-11T14:16:24.332240Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:790: DescribeQueryRequest: query_id: "ptqudslmr2fr8id7ljo6"
2025-11-11T14:16:24.332293Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:313: Resolve folder bootstrap. Folder id: my_folder Actor id: [1:7571471505585802338:2263]
2025-11-11T14:16:24.332314Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:375: Cloud id: mock_cloud Folder id: my_folder
2025-11-11T14:16:24.332351Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:790: DescribeQueryRequest: query_id: "ptqudslmr2fr8id7ljo6"
2025-11-11T14:16:24.332416Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:176: Resolve subject type bootstrap. Token: **** (B6C6F477) Actor id: [1:7571471505585802339:2264]
2025-11-11T14:16:24.332462Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:237: Subject Type: federated_account Token: **** (B6C6F477)
2025-11-11T14:16:24.332483Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:790: DescribeQueryRequest: query_id: "ptqudslmr2fr8id7ljo6"
2025-11-11T14:16:24.332508Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:69: Request actor. Actor id: [1:7571471505585802340:2265]
2025-11-11T14:16:24.332564Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_queries.cpp:641: DescribeQueryRequest: {query_id: "ptqudslmr2fr8id7ljo6"
} [root@builtin, **** (B6C6F477)] 
2025-11-11T14:16:24.335757Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: DescribeQueryRequest - DescribeQueryResult: {query { meta { common { id: "ptqudslmr2fr8id7ljo6" created_by: "root@builtin" modified_by: "root@builtin" created_at { seconds: 1762870565 nanos: 540479000 } modified_at { seconds: 1762870578 nanos: 145335000 } revision: 2 } started_at { seconds: 1762870566 nanos: 498000000 } execute_mode: RUN status: ABORTING_BY_USER last_job_query_revision: 1 last_job_id: "ptjudslmr2fr7eo5vmde-ptqudslmr2fr8id7ljo6" started_by: "root@builtin" aborted_by: "root@builtin" has_saved_checkpoints: true submitted_at { seconds: 1762870565 nanos: 540479000 } } content { type: STREAMING name: "simple" acl { visibility: PRIVATE } limits { execution_timeout { } } text: "\n            PRAGMA dq.MaxTasksPerStage=\"5\";\n\n            INSERT INTO yds_1.`delete_read_rules_1_output`\n            SELECT * FROM yds_1.`delete_read_rules_1_input`;" syntax: YQL_V1 } plan { json: "{\"Detailed\":{\"Operations\":[{\"Id\":3,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[{\"Name\":\"DqSourceWideWrap\"},{\"Name\":\"NarrowMap\"}]}},{\"Id\":2,\"Name\":\"DqQuery!\",\"DependsOn\":[3]},{\"Id\":1,\"Name\":\"Commit!\",\"DependsOn\":[2]}],\"OperationRoot\":1,\"Providers\":[],\"OperationStats\":{\"Commit!\":1,\"DqQuery!\":1,\"DqStage\":1}},\"Basic\":{\"nodes\":[{\"id\":3,\"level\":1,\"name\":\"DqStage #3\",\"type\":\"op\"},{\"id\":2,\"level\":2,\"name\":\"DqQuery!\",\"type\":\"op\"},{\"id\":1,\"level\":3,\"name\":\"Commit!\",\"type\":\"op\"}],\"links\":[{\"source\":3,\"target\":2},{\"source\":2,\"target\":1}]}}" } ast { data: "(\n(let $1 (Configure! world (DataSource \'\"config\") \'\"DqEngine\" \'\"force\"))\n(let $2 (Configure! $1 (DataSource \'\"dq\" \'\"$all\") \'\"Attr\" \'\"maxtasksperstage\" \'\"5\"))\n(let $3 (DataSource \'\"pq\" \'\"yds_1\"))\n(let $4 \'(\'(\'\"PartitionsCount\" \'\"1\")))\n(let $5 (StructType \'(\'\"Data\" (DataType \'String))))\n(let $6 (PqTopic \'\"yds_1\" \'\"local\" \'\"delete_read_rules_1_input\" $4 \'() $5))\n(let $7 \'(\'\"Endpoint\" \'\"localhost:6240\"))\n(let $8 \'(\'\"SharedReading\" \'\"0\"))\n(let $9 \'(\'\"AddBearerToToken\" \'\"1\"))\n(let $10 \'($7 $8 \'(\'\"ReconnectPeriod\" \'\"\") \'(\'\"Format\" \'\"raw\") \'(\'\"ReadGroup\" \'\"ptcudslmr2rcnnsh7162\") $9))\n(let $11 (SecureParam \'\"cluster:default_yds_1\"))\n(let $12 (DqPqTopicSource $2 $6 \'(\'\"Data\") $10 $11 \'\"\" $5 \'\"\"))\n(let $13 (DataSink \'\"pq\" \'\"yds_1\"))\n(let $14 (PqTopic \'\"yds_1\" \'\"local\" \'\"delete_read_rules_1_output\" $4 \'() $5))\n(let $15 (DqPqTopicSink $14 \'($7 $9) $11))\n(return (Commit! (DqQuery! $2 \'((DqStage \'((DqSource $3 $12)) (lambda \'($16) (block \'(\n  (let $17 \'(\'(\'\"format\" \'\"raw\") \'(\'\"formatSettings\" \'(\'(\'\"data.datetime.formatname\" \'\"POSIX\") \'(\'\"data.timestamp.formatname\" \'\"POSIX\"))) \'(\'\"settings\" \'($8))))\n  (let $18 (DqSourceWideWrap $16 $3 $5 $17))\n  (return (NarrowMap $18 (lambda \'($19) (AsStruct \'(\'\"Data\" $19)))))\n))) \'(\'(\'\"_logical_id\" \'209361)) \'((DqSink \'\"0\" $13 $15))))) $13))\n)\n" } } } SUCCESS
2025-11-11T14:16:24.838420Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:790: DescribeQueryRequest: query_id: "ptqudslmr2fr8id7ljo6"
2025-11-11T14:16:24.838465Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:313: Resolve folder bootstrap. Folder id: my_folder Actor id: [1:7571471505585802344:2268]
2025-11-11T14:16:24.838489Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:375: Cloud id: mock_cloud Folder id: my_folder
2025-11-11T14:16:24.838513Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:790: DescribeQueryRequest: query_id: "ptqudslmr2fr8id7ljo6"
2025-11-11T14:16:24.838577Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:176: Resolve subject type bootstrap. Token: **** (B6C6F477) Actor id: [1:7571471505585802345:2269]
2025-11-11T14:16:24.838603Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:237: Subject Type: federated_account Token: **** (B6C6F477)
2025-11-11T14:16:24.838622Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:790: DescribeQueryRequest: query_id: "ptqudslmr2fr8id7ljo6"
2025-11-11T14:16:24.838636Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:69: Request actor. Actor id: [1:7571471505585802346:2270]
2025-11-11T14:16:24.838662Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_queries.cpp:641: DescribeQueryRequest: {query_id: "ptqudslmr2fr8id7ljo6"
} [root@builtin, **** (B6C6F477)] 
2025-11-11T14:16:24.841760Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: DescribeQueryRequest - DescribeQueryResult: {query { meta { common { id: "ptqudslmr2fr8id7ljo6" created_by: "root@builtin" modified_by: "root@builtin" created_at { seconds: 1762870565 nanos: 540479000 } modified_at { seconds: 1762870578 nanos: 145335000 } revision: 2 } started_at { seconds: 1762870566 nanos: 498000000 } execute_mode: RUN status: ABORTING_BY_USER last_job_query_revision: 1 last_job_id: "ptjudslmr2fr7eo5vmde-ptqudslmr2fr8id7ljo6" started_by: "root@builtin" aborted_by: "root@builtin" has_saved_checkpoints: true submitted_at { seconds: 1762870565 nanos: 540479000 } } content { type: STREAMING name: "simple" acl { visibility: PRIVATE } limits { execution_timeout { } } text: "\n            PRAGMA dq.MaxTasksPerStage=\"5\";\n\n            INSERT INTO yds_1.`delete_read_rules_1_output`\n            SELECT * FROM yds_1.`delete_read_rules_1_input`;" syntax: YQL_V1 } plan { json: "{\"Detailed\":{\"Operations\":[{\"Id\":3,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[{\"Name\":\"DqSourceWideWrap\"},{\"Name\":\"NarrowMap\"}]}},{\"Id\":2,\"Name\":\"DqQuery!\",\"DependsOn\":[3]},{\"Id\":1,\"Name\":\"Commit!\",\"DependsOn\":[2]}],\"OperationRoot\":1,\"Providers\":[],\"OperationStats\":{\"Commit!\":1,\"DqQuery!\":1,\"DqStage\":1}},\"Basic\":{\"nodes\":[{\"id\":3,\"level\":1,\"name\":\"DqStage #3\",\"type\":\"op\"},{\"id\":2,\"level\":2,\"name\":\"DqQuery!\",\"type\":\"op\"},{\"id\":1,\"level\":3,\"name\":\"Commit!\",\"type\":\"op\"}],\"links\":[{\"source\":3,\"target\":2},{\"source\":2,\"target\":1}]}}" } ast { data: "(\n(let $1 (Configure! world (DataSource \'\"config\") \'\"DqEngine\" \'\"force\"))\n(let $2 (Configure! $1 (DataSource \'\"dq\" \'\"$all\") \'\"Attr\" \'\"maxtasksperstage\" \'\"5\"))\n(let $3 (DataSource \'\"pq\" \'\"yds_1\"))\n(let $4 \'(\'(\'\"PartitionsCount\" \'\"1\")))\n(let $5 (StructType \'(\'\"Data\" (DataType \'String))))\n(let $6 (PqTopic \'\"yds_1\" \'\"local\" \'\"delete_read_rules_1_input\" $4 \'() $5))\n(let $7 \'(\'\"Endpoint\" \'\"localhost:6240\"))\n(let $8 \'(\'\"SharedReading\" \'\"0\"))\n(let $9 \'(\'\"AddBearerToToken\" \'\"1\"))\n(let $10 \'($7 $8 \'(\'\"ReconnectPeriod\" \'\"\") \'(\'\"Format\" \'\"raw\") \'(\'\"ReadGroup\" \'\"ptcudslmr2rcnnsh7162\") $9))\n(let $11 (SecureParam \'\"cluster:default_yds_1\"))\n(let $12 (DqPqTopicSource $2 $6 \'(\'\"Data\") $10 $11 \'\"\" $5 \'\"\"))\n(let $13 (DataSink \'\"pq\" \'\"yds_1\"))\n(let $14 (PqTopic \'\"yds_1\" \'\"local\" \'\"delete_read_rules_1_output\" $4 \'() $5))\n(let $15 (DqPqTopicSink $14 \'($7 $9) $11))\n(return (Commit! (DqQuery! $2 \'((DqStage \'((DqSource $3 $12)) (lambda \'($16) (block \'(\n  (let $17 \'(\'(\'\"format\" \'\"raw\") \'(\'\"formatSettings\" \'(\'(\'\"data.datetime.formatname\" \'\"POSIX\") \'(\'\"data.timestamp.formatname\" \'\"POSIX\"))) \'(\'\"settings\" \'($8))))\n  (let $18 (DqSourceWideWrap $16 $3 $5 $17))\n  (return (NarrowMap $18 (lambda \'($19) (AsStruct \'(\'\"Data\" $19)))))\n))) \'(\'(\'\"_logical_id\" \'209361)) \'((DqSink \'\"0\" $13 $15))))) $13))\n)\n" } } } SUCCESS
2025-11-11T14:16:24.920105Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:617: RowDispatcher: Send ping to [1:7571471471226063798:2111]
2025-11-11T14:16:24.920109Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 9e02db82-b625a9db-ce0a21a7-2b88c90b9, Host: ghrun-vb3yoermsa, Tenant: /default
2025-11-11T14:16:24.920119Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1161: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-11-11T14:16:24.920128Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:314: Coordinator: TEvPing received, [1:7571471471226063739:2069]
2025-11-11T14:16:24.920132Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:317: Coordinator: Send TEvPong to [1:7571471471226063739:2069]
2025-11-11T14:16:24.920137Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:623: RowDispatcher: NActors::TEvents::TEvPong
2025-11-11T14:16:24.920638Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 9e02db82-b625a9db-ce0a21a7-2b88c90b9, Host: ghrun-vb3yoermsa, Tenant: /default, Request CP::GetTask with size: 68 bytes
2025-11-11T14:16:24.920687Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/default"
owner_id: "9e02db82-b625a9db-ce0a21a7-2b88c90b9"
host: "ghrun-vb3yoermsa"
node_id: 1
}
2025-11-11T14:16:24.923563Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-11-11T14:16:24.923615Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 9e02db82-b625a9db-ce0a21a7-2b88c90b9, Host: ghrun-vb3yoermsa, Tenant: /default, Got CP::GetTask Response
2025-11-11T14:16:24.923909Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-11T14:16:24.923918Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-11T14:16:25.344176Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:790: DescribeQueryRequest: query_id: "ptqudslmr2fr8id7ljo6"
2025-11-11T14:16:25.344217Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:313: Resolve folder bootstrap. Folder id: my_folder Actor id: [1:7571471509880769649:2276]
2025-11-11T14:16:25.344229Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:375: Cloud id: mock_cloud Folder id: my_folder
2025-11-11T14:16:25.344241Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:790: DescribeQueryRequest: query_id: "ptqudslmr2fr8id7ljo6"
2025-11-11T14:16:25.344272Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:176: Resolve subject type bootstrap. Token: **** (B6C6F477) Actor id: [1:7571471509880769650:2277]
2025-11-11T14:16:25.344288Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:237: Subject Type: federated_account Token: **** (B6C6F477)
2025-11-11T14:16:25.344300Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:790: DescribeQueryRequest: query_id: "ptqudslmr2fr8id7ljo6"
2025-11-11T14:16:25.344308Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:69: Request actor. Actor id: [1:7571471509880769651:2278]
2025-11-11T14:16:25.344331Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_queries.cpp:641: DescribeQueryRequest: {query_id: "ptqudslmr2fr8id7ljo6"
} [root@builtin, **** (B6C6F477)] 
2025-11-11T14:16:25.346808Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: DescribeQueryRequest - DescribeQueryResult: {query { meta { common { id: "ptqudslmr2fr8id7ljo6" created_by: "root@builtin" modified_by: "root@builtin" created_at { seconds: 1762870565 nanos: 540479000 } modified_at { seconds: 1762870578 nanos: 145335000 } revision: 2 } started_at { seconds: 1762870566 nanos: 498000000 } execute_mode: RUN status: ABORTING_BY_USER last_job_query_revision: 1 last_job_id: "ptjudslmr2fr7eo5vmde-ptqudslmr2fr8id7ljo6" started_by: "root@builtin" aborted_by: "root@builtin" has_saved_checkpoints: true submitted_at { seconds: 1762870565 nanos: 540479000 } } content { type: STREAMING name: "simple" acl { visibility: PRIVATE } limits { execution_timeout { } } text: "\n            PRAGMA dq.MaxTasksPerStage=\"5\";\n\n            INSERT INTO yds_1.`delete_read_rules_1_output`\n            SELECT * FROM yds_1.`delete_read_rules_1_input`;" syntax: YQL_V1 } plan { json: "{\"Detailed\":{\"Operations\":[{\"Id\":3,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[{\"Name\":\"DqSourceWideWrap\"},{\"Name\":\"NarrowMap\"}]}},{\"Id\":2,\"Name\":\"DqQuery!\",\"DependsOn\":[3]},{\"Id\":1,\"Name\":\"Commit!\",\"DependsOn\":[2]}],\"OperationRoot\":1,\"Providers\":[],\"OperationStats\":{\"Commit!\":1,\"DqQuery!\":1,\"DqStage\":1}},\"Basic\":{\"nodes\":[{\"id\":3,\"level\":1,\"name\":\"DqStage #3\",\"type\":\"op\"},{\"id\":2,\"level\":2,\"name\":\"DqQuery!\",\"type\":\"op\"},{\"id\":1,\"level\":3,\"name\":\"Commit!\",\"type\":\"op\"}],\"links\":[{\"source\":3,\"target\":2},{\"source\":2,\"target\":1}]}}" } ast { data: "(\n(let $1 (Configure! world (DataSource \'\"config\") \'\"DqEngine\" \'\"force\"))\n(let $2 (Configure! $1 (DataSource \'\"dq\" \'\"$all\") \'\"Attr\" \'\"maxtasksperstage\" \'\"5\"))\n(let $3 (DataSource \'\"pq\" \'\"yds_1\"))\n(let $4 \'(\'(\'\"PartitionsCount\" \'\"1\")))\n(let $5 (StructType \'(\'\"Data\" (DataType \'String))))\n(let $6 (PqTopic \'\"yds_1\" \'\"local\" \'\"delete_read_rules_1_input\" $4 \'() $5))\n(let $7 \'(\'\"Endpoint\" \'\"localhost:6240\"))\n(let $8 \'(\'\"SharedReading\" \'\"0\"))\n(let $9 \'(\'\"AddBearerToToken\" \'\"1\"))\n(let $10 \'($7 $8 \'(\'\"ReconnectPeriod\" \'\"\") \'(\'\"Format\" \'\"raw\") \'(\'\"ReadGroup\" \'\"ptcudslmr2rcnnsh7162\") $9))\n(let $11 (SecureParam \'\"cluster:default_yds_1\"))\n(let $12 (DqPqTopicSource $2 $6 \'(\'\"Data\") $10 $11 \'\"\" $5 \'\"\"))\n(let $13 (DataSink \'\"pq\" \'\"yds_1\"))\n(let $14 (PqTopic \'\"yds_1\" \'\"local\" \'\"delete_read_rules_1_output\" $4 \'() $5))\n(let $15 (DqPqTopicSink $14 \'($7 $9) $11))\n(return (Commit! (DqQuery! $2 \'((DqStage \'((DqSource $3 $12)) (lambda \'($16) (block \'(\n  (let $17 \'(\'(\'\"format\" \'\"raw\") \'(\'\"formatSettings\" \'(\'(\'\"data.datetime.formatname\" \'\"POSIX\") \'(\'\"data.timestamp.formatname\" \'\"POSIX\"))) \'(\'\"settings\" \'($8))))\n  (let $18 (DqSourceWideWrap $16 $3 $5 $17))\n  (return (NarrowMap $18 (lambda \'($19) (AsStruct \'(\'\"Data\" $19)))))\n))) \'(\'(\'\"_logical_id\" \'209361)) \'((DqSink \'\"0\" $13 $15))))) $13))\n)\n" } } } SUCCESS
2025-11-11T14:16:25.849014Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:790: DescribeQueryRequest: query_id: "ptqudslmr2fr8id7ljo6"
2025-11-11T14:16:25.849063Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:313: Resolve folder bootstrap. Folder id: my_folder Actor id: [1:7571471509880769655:2281]
2025-11-11T14:16:25.849093Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:375: Cloud id: mock_cloud Folder id: my_folder
2025-11-11T14:16:25.849118Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:790: DescribeQueryRequest: query_id: "ptqudslmr2fr8id7ljo6"
2025-11-11T14:16:25.849157Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:176: Resolve subject type bootstrap. Token: **** (B6C6F477) Actor id: [1:7571471509880769656:2282]
2025-11-11T14:16:25.849175Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:237: Subject Type: federated_account Token: **** (B6C6F477)
2025-11-11T14:16:25.849196Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:790: DescribeQueryRequest: query_id: "ptqudslmr2fr8id7ljo6"
2025-11-11T14:16:25.849219Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:69: Request actor. Actor id: [1:7571471509880769657:2283]
2025-11-11T14:16:25.849251Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_queries.cpp:641: DescribeQueryRequest: {query_id: "ptqudslmr2fr8id7ljo6"
} [root@builtin, **** (B6C6F477)] 
2025-11-11T14:16:25.856039Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: DescribeQueryRequest - DescribeQueryResult: {query { meta { common { id: "ptqudslmr2fr8id7ljo6" created_by: "root@builtin" modified_by: "root@builtin" created_at { seconds: 1762870565 nanos: 540479000 } modified_at { seconds: 1762870578 nanos: 145335000 } revision: 2 } started_at { seconds: 1762870566 nanos: 498000000 } execute_mode: RUN status: ABORTING_BY_USER last_job_query_revision: 1 last_job_id: "ptjudslmr2fr7eo5vmde-ptqudslmr2fr8id7ljo6" started_by: "root@builtin" aborted_by: "root@builtin" has_saved_checkpoints: true submitted_at { seconds: 1762870565 nanos: 540479000 } } content { type: STREAMING name: "simple" acl { visibility: PRIVATE } limits { execution_timeout { } } text: "\n            PRAGMA dq.MaxTasksPerStage=\"5\";\n\n            INSERT INTO yds_1.`delete_read_rules_1_output`\n            SELECT * FROM yds_1.`delete_read_rules_1_input`;" syntax: YQL_V1 } plan { json: "{\"Detailed\":{\"Operations\":[{\"Id\":3,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[{\"Name\":\"DqSourceWideWrap\"},{\"Name\":\"NarrowMap\"}]}},{\"Id\":2,\"Name\":\"DqQuery!\",\"DependsOn\":[3]},{\"Id\":1,\"Name\":\"Commit!\",\"DependsOn\":[2]}],\"OperationRoot\":1,\"Providers\":[],\"OperationStats\":{\"Commit!\":1,\"DqQuery!\":1,\"DqStage\":1}},\"Basic\":{\"nodes\":[{\"id\":3,\"level\":1,\"name\":\"DqStage #3\",\"type\":\"op\"},{\"id\":2,\"level\":2,\"name\":\"DqQuery!\",\"type\":\"op\"},{\"id\":1,\"level\":3,\"name\":\"Commit!\",\"type\":\"op\"}],\"links\":[{\"source\":3,\"target\":2},{\"source\":2,\"target\":1}]}}" } ast { data: "(\n(let $1 (Configure! world (DataSource \'\"config\") \'\"DqEngine\" \'\"force\"))\n(let $2 (Configure! $1 (DataSource \'\"dq\" \'\"$all\") \'\"Attr\" \'\"maxtasksperstage\" \'\"5\"))\n(let $3 (DataSource \'\"pq\" \'\"yds_1\"))\n(let $4 \'(\'(\'\"PartitionsCount\" \'\"1\")))\n(let $5 (StructType \'(\'\"Data\" (DataType \'String))))\n(let $6 (PqTopic \'\"yds_1\" \'\"local\" \'\"delete_read_rules_1_input\" $4 \'() $5))\n(let $7 \'(\'\"Endpoint\" \'\"localhost:6240\"))\n(let $8 \'(\'\"SharedReading\" \'\"0\"))\n(let $9 \'(\'\"AddBearerToToken\" \'\"1\"))\n(let $10 \'($7 $8 \'(\'\"ReconnectPeriod\" \'\"\") \'(\'\"Format\" \'\"raw\") \'(\'\"ReadGroup\" \'\"ptcudslmr2rcnnsh7162\") $9))\n(let $11 (SecureParam \'\"cluster:default_yds_1\"))\n(let $12 (DqPqTopicSource $2 $6 \'(\'\"Data\") $10 $11 \'\"\" $5 \'\"\"))\n(let $13 (DataSink \'\"pq\" \'\"yds_1\"))\n(let $14 (PqTopic \'\"yds_1\" \'\"local\" \'\"delete_read_rules_1_output\" $4 \'() $5))\n(let $15 (DqPqTopicSink $14 \'($7 $9) $11))\n(return (Commit! (DqQuery! $2 \'((DqStage \'((DqSource $3 $12)) (lambda \'($16) (block \'(\n  (let $17 \'(\'(\'\"format\" \'\"raw\") \'(\'\"formatSettings\" \'(\'(\'\"data.datetime.formatname\" \'\"POSIX\") \'(\'\"data.timestamp.formatname\" \'\"POSIX\"))) \'(\'\"settings\" \'($8))))\n  (let $18 (DqSourceWideWrap $16 $3 $5 $17))\n  (return (NarrowMap $18 (lambda \'($19) (AsStruct \'(\'\"Data\" $19)))))\n))) \'(\'(\'\"_logical_id\" \'209361)) \'((DqSink \'\"0\" $13 $15))))) $13))\n)\n" } } } SUCCESS
2025-11-11T14:16:25.920569Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 9e02db82-b625a9db-ce0a21a7-2b88c90b10, Host: ghrun-vb3yoermsa, Tenant: /default
2025-11-11T14:16:25.925634Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 9e02db82-b625a9db-ce0a21a7-2b88c90b10, Host: ghrun-vb3yoermsa, Tenant: /default, Request CP::GetTask with size: 69 bytes
2025-11-11T14:16:25.925713Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/default"
owner_id: "9e02db82-b625a9db-ce0a21a7-2b88c90b10"
host: "ghrun-vb3yoermsa"
node_id: 1
}
2025-11-11T14:16:25.931016Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-11-11T14:16:25.931059Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 9e02db82-b625a9db-ce0a21a7-2b88c90b10, Host: ghrun-vb3yoermsa, Tenant: /default, Got CP::GetTask Response
2025-11-11T14:16:25.931475Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-11T14:16:25.931483Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-11T14:16:25.977289Z :FQ_CONTROL_PLANE_CONFIG TRACE: control_plane_config.cpp:192: LOADED TenantInfo: State NOT changed
2025-11-11T14:16:26.358477Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:790: DescribeQueryRequest: query_id: "ptqudslmr2fr8id7ljo6"
2025-11-11T14:16:26.358510Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:313: Resolve folder bootstrap. Folder id: my_folder Actor id: [1:7571471514175736961:2290]
2025-11-11T14:16:26.358522Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:375: Cloud id: mock_cloud Folder id: my_folder
2025-11-11T14:16:26.358533Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:790: DescribeQueryRequest: query_id: "ptqudslmr2fr8id7ljo6"
2025-11-11T14:16:26.358555Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:176: Resolve subject type bootstrap. Token: **** (B6C6F477) Actor id: [1:7571471514175736962:2291]
2025-11-11T14:16:26.358571Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:237: Subject Type: federated_account Token: **** (B6C6F477)
2025-11-11T14:16:26.358591Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:790: DescribeQueryRequest: query_id: "ptqudslmr2fr8id7ljo6"
2025-11-11T14:16:26.358600Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:69: Request actor. Actor id: [1:7571471514175736963:2292]
2025-11-11T14:16:26.358624Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_queries.cpp:641: DescribeQueryRequest: {query_id: "ptqudslmr2fr8id7ljo6"
} [root@builtin, **** (B6C6F477)] 
2025-11-11T14:16:26.367821Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: DescribeQueryRequest - DescribeQueryResult: {query { meta { common { id: "ptqudslmr2fr8id7ljo6" created_by: "root@builtin" modified_by: "root@builtin" created_at { seconds: 1762870565 nanos: 540479000 } modified_at { seconds: 1762870578 nanos: 145335000 } revision: 2 } started_at { seconds: 1762870566 nanos: 498000000 } execute_mode: RUN status: ABORTING_BY_USER last_job_query_revision: 1 last_job_id: "ptjudslmr2fr7eo5vmde-ptqudslmr2fr8id7ljo6" started_by: "root@builtin" aborted_by: "root@builtin" has_saved_checkpoints: true submitted_at { seconds: 1762870565 nanos: 540479000 } } content { type: STREAMING name: "simple" acl { visibility: PRIVATE } limits { execution_timeout { } } text: "\n            PRAGMA dq.MaxTasksPerStage=\"5\";\n\n            INSERT INTO yds_1.`delete_read_rules_1_output`\n            SELECT * FROM yds_1.`delete_read_rules_1_input`;" syntax: YQL_V1 } plan { json: "{\"Detailed\":{\"Operations\":[{\"Id\":3,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[{\"Name\":\"DqSourceWideWrap\"},{\"Name\":\"NarrowMap\"}]}},{\"Id\":2,\"Name\":\"DqQuery!\",\"DependsOn\":[3]},{\"Id\":1,\"Name\":\"Commit!\",\"DependsOn\":[2]}],\"OperationRoot\":1,\"Providers\":[],\"OperationStats\":{\"Commit!\":1,\"DqQuery!\":1,\"DqStage\":1}},\"Basic\":{\"nodes\":[{\"id\":3,\"level\":1,\"name\":\"DqStage #3\",\"type\":\"op\"},{\"id\":2,\"level\":2,\"name\":\"DqQuery!\",\"type\":\"op\"},{\"id\":1,\"level\":3,\"name\":\"Commit!\",\"type\":\"op\"}],\"links\":[{\"source\":3,\"target\":2},{\"source\":2,\"target\":1}]}}" } ast { data: "(\n(let $1 (Configure! world (DataSource \'\"config\") \'\"DqEngine\" \'\"force\"))\n(let $2 (Configure! $1 (DataSource \'\"dq\" \'\"$all\") \'\"Attr\" \'\"maxtasksperstage\" \'\"5\"))\n(let $3 (DataSource \'\"pq\" \'\"yds_1\"))\n(let $4 \'(\'(\'\"PartitionsCount\" \'\"1\")))\n(let $5 (StructType \'(\'\"Data\" (DataType \'String))))\n(let $6 (PqTopic \'\"yds_1\" \'\"local\" \'\"delete_read_rules_1_input\" $4 \'() $5))\n(let $7 \'(\'\"Endpoint\" \'\"localhost:6240\"))\n(let $8 \'(\'\"SharedReading\" \'\"0\"))\n(let $9 \'(\'\"AddBearerToToken\" \'\"1\"))\n(let $10 \'($7 $8 \'(\'\"ReconnectPeriod\" \'\"\") \'(\'\"Format\" \'\"raw\") \'(\'\"ReadGroup\" \'\"ptcudslmr2rcnnsh7162\") $9))\n(let $11 (SecureParam \'\"cluster:default_yds_1\"))\n(let $12 (DqPqTopicSource $2 $6 \'(\'\"Data\") $10 $11 \'\"\" $5 \'\"\"))\n(let $13 (DataSink \'\"pq\" \'\"yds_1\"))\n(let $14 (PqTopic \'\"yds_1\" \'\"local\" \'\"delete_read_rules_1_output\" $4 \'() $5))\n(let $15 (DqPqTopicSink $14 \'($7 $9) $11))\n(return (Commit! (DqQuery! $2 \'((DqStage \'((DqSource $3 $12)) (lambda \'($16) (block \'(\n  (let $17 \'(\'(\'\"format\" \'\"raw\") \'(\'\"formatSettings\" \'(\'(\'\"data.datetime.formatname\" \'\"POSIX\") \'(\'\"data.timestamp.formatname\" \'\"POSIX\"))) \'(\'\"settings\" \'($8))))\n  (let $18 (DqSourceWideWrap $16 $3 $5 $17))\n  (return (NarrowMap $18 (lambda \'($19) (AsStruct \'(\'\"Data\" $19)))))\n))) \'(\'(\'\"_logical_id\" \'209361)) \'((DqSink \'\"0\" $13 $15))))) $13))\n)\n" } } } SUCCESS
2025-11-11T14:16:26.870407Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:790: DescribeQueryRequest: query_id: "ptqudslmr2fr8id7ljo6"
2025-11-11T14:16:26.870448Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:313: Resolve folder bootstrap. Folder id: my_folder Actor id: [1:7571471514175736967:2295]
2025-11-11T14:16:26.870479Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:375: Cloud id: mock_cloud Folder id: my_folder
2025-11-11T14:16:26.870545Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:790: DescribeQueryRequest: query_id: "ptqudslmr2fr8id7ljo6"
2025-11-11T14:16:26.870592Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:176: Resolve subject type bootstrap. Token: **** (B6C6F477) Actor id: [1:7571471514175736968:2296]
2025-11-11T14:16:26.870607Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:237: Subject Type: federated_account Token: **** (B6C6F477)
2025-11-11T14:16:26.870618Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:790: DescribeQueryRequest: query_id: "ptqudslmr2fr8id7ljo6"
2025-11-11T14:16:26.870629Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:69: Request actor. Actor id: [1:7571471514175736969:2297]
2025-11-11T14:16:26.870664Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_queries.cpp:641: DescribeQueryRequest: {query_id: "ptqudslmr2fr8id7ljo6"
} [root@builtin, **** (B6C6F477)] 
2025-11-11T14:16:26.873959Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: DescribeQueryRequest - DescribeQueryResult: {query { meta { common { id: "ptqudslmr2fr8id7ljo6" created_by: "root@builtin" modified_by: "root@builtin" created_at { seconds: 1762870565 nanos: 540479000 } modified_at { seconds: 1762870578 nanos: 145335000 } revision: 2 } started_at { seconds: 1762870566 nanos: 498000000 } execute_mode: RUN status: ABORTING_BY_USER last_job_query_revision: 1 last_job_id: "ptjudslmr2fr7eo5vmde-ptqudslmr2fr8id7ljo6" started_by: "root@builtin" aborted_by: "root@builtin" has_saved_checkpoints: true submitted_at { seconds: 1762870565 nanos: 540479000 } } content { type: STREAMING name: "simple" acl { visibility: PRIVATE } limits { execution_timeout { } } text: "\n            PRAGMA dq.MaxTasksPerStage=\"5\";\n\n            INSERT INTO yds_1.`delete_read_rules_1_output`\n            SELECT * FROM yds_1.`delete_read_rules_1_input`;" syntax: YQL_V1 } plan { json: "{\"Detailed\":{\"Operations\":[{\"Id\":3,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[{\"Name\":\"DqSourceWideWrap\"},{\"Name\":\"NarrowMap\"}]}},{\"Id\":2,\"Name\":\"DqQuery!\",\"DependsOn\":[3]},{\"Id\":1,\"Name\":\"Commit!\",\"DependsOn\":[2]}],\"OperationRoot\":1,\"Providers\":[],\"OperationStats\":{\"Commit!\":1,\"DqQuery!\":1,\"DqStage\":1}},\"Basic\":{\"nodes\":[{\"id\":3,\"level\":1,\"name\":\"DqStage #3\",\"type\":\"op\"},{\"id\":2,\"level\":2,\"name\":\"DqQuery!\",\"type\":\"op\"},{\"id\":1,\"level\":3,\"name\":\"Commit!\",\"type\":\"op\"}],\"links\":[{\"source\":3,\"target\":2},{\"source\":2,\"target\":1}]}}" } ast { data: "(\n(let $1 (Configure! world (DataSource \'\"config\") \'\"DqEngine\" \'\"force\"))\n(let $2 (Configure! $1 (DataSource \'\"dq\" \'\"$all\") \'\"Attr\" \'\"maxtasksperstage\" \'\"5\"))\n(let $3 (DataSource \'\"pq\" \'\"yds_1\"))\n(let $4 \'(\'(\'\"PartitionsCount\" \'\"1\")))\n(let $5 (StructType \'(\'\"Data\" (DataType \'String))))\n(let $6 (PqTopic \'\"yds_1\" \'\"local\" \'\"delete_read_rules_1_input\" $4 \'() $5))\n(let $7 \'(\'\"Endpoint\" \'\"localhost:6240\"))\n(let $8 \'(\'\"SharedReading\" \'\"0\"))\n(let $9 \'(\'\"AddBearerToToken\" \'\"1\"))\n(let $10 \'($7 $8 \'(\'\"ReconnectPeriod\" \'\"\") \'(\'\"Format\" \'\"raw\") \'(\'\"ReadGroup\" \'\"ptcudslmr2rcnnsh7162\") $9))\n(let $11 (SecureParam \'\"cluster:default_yds_1\"))\n(let $12 (DqPqTopicSource $2 $6 \'(\'\"Data\") $10 $11 \'\"\" $5 \'\"\"))\n(let $13 (DataSink \'\"pq\" \'\"yds_1\"))\n(let $14 (PqTopic \'\"yds_1\" \'\"local\" \'\"delete_read_rules_1_output\" $4 \'() $5))\n(let $15 (DqPqTopicSink $14 \'($7 $9) $11))\n(return (Commit! (DqQuery! $2 \'((DqStage \'((DqSource $3 $12)) (lambda \'($16) (block \'(\n  (let $17 \'(\'(\'\"format\" \'\"raw\") \'(\'\"formatSettings\" \'(\'(\'\"data.datetime.formatname\" \'\"POSIX\") \'(\'\"data.timestamp.formatname\" \'\"POSIX\"))) \'(\'\"settings\" \'($8))))\n  (let $18 (DqSourceWideWrap $16 $3 $5 $17))\n  (return (NarrowMap $18 (lambda \'($19) (AsStruct \'(\'\"Data\" $19)))))\n))) \'(\'(\'\"_logical_id\" \'209361)) \'((DqSink \'\"0\" $13 $15))))) $13))\n)\n" } } } SUCCESS
2025-11-11T14:16:26.916905Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-11-11T14:16:26.917654Z :YQ_CONTROL_PLANE_STORAGE TRACE: nodes_health_check.cpp:38: NodesHealthCheckRequest: {tenant: "/default"
node {
  node_id: 1
  instance_id: "b12437ca-459036a5-a90845b7-2ea91ed0"
  hostname: "ghrun-vb3yoermsa"
  interconnect_port: 13471
  node_address: "127.0.1.1"
}
}
2025-11-11T14:16:26.921001Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:617: RowDispatcher: Send ping to [1:7571471471226063798:2111]
2025-11-11T14:16:26.921013Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1161: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-11-11T14:16:26.921018Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 9e02db82-b625a9db-ce0a21a7-2b88c90b11, Host: ghrun-vb3yoermsa, Tenant: /default
2025-11-11T14:16:26.921021Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:314: Coordinator: TEvPing received, [1:7571471471226063739:2069]
2025-11-11T14:16:26.921023Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:317: Coordinator: Send TEvPong to [1:7571471471226063739:2069]
2025-11-11T14:16:26.921027Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:623: RowDispatcher: NActors::TEvents::TEvPong
2025-11-11T14:16:26.921708Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 9e02db82-b625a9db-ce0a21a7-2b88c90b11, Host: ghrun-vb3yoermsa, Tenant: /default, Request CP::GetTask with size: 69 bytes
2025-11-11T14:16:26.921773Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/default"
owner_id: "9e02db82-b625a9db-ce0a21a7-2b88c90b11"
host: "ghrun-vb3yoermsa"
node_id: 1
}
2025-11-11T14:16:26.923678Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-11-11T14:16:26.923712Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 9e02db82-b625a9db-ce0a21a7-2b88c90b11, Host: ghrun-vb3yoermsa, Tenant: /default, Got CP::GetTask Response
2025-11-11T14:16:26.923974Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-11T14:16:26.923987Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-11T14:16:26.930150Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: NodesHealthCheckRequest - NodesHealthCheckResult: {nodes { node_id: 1 instance_id: "b12437ca-459036a5-a90845b7-2ea91ed0" hostname: "ghrun-vb3yoermsa" node_address: "127.0.1.1" } } SUCCESS
2025-11-11T14:16:26.930520Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:389: Send NodeInfo with size: 0 to DynamicNameserver
2025-11-11T14:16:27.376702Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:790: DescribeQueryRequest: query_id: "ptqudslmr2fr8id7ljo6"
2025-11-11T14:16:27.376748Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:313: Resolve folder bootstrap. Folder id: my_folder Actor id: [1:7571471518470704275:2306]
2025-11-11T14:16:27.376770Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:375: Cloud id: mock_cloud Folder id: my_folder
2025-11-11T14:16:27.376799Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:790: DescribeQueryRequest: query_id: "ptqudslmr2fr8id7ljo6"
2025-11-11T14:16:27.376867Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:176: Resolve subject type bootstrap. Token: **** (B6C6F477) Actor id: [1:7571471518470704276:2307]
2025-11-11T14:16:27.376896Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:237: Subject Type: federated_account Token: **** (B6C6F477)
2025-11-11T14:16:27.376915Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:790: DescribeQueryRequest: query_id: "ptqudslmr2fr8id7ljo6"
2025-11-11T14:16:27.376947Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:69: Request actor. Actor id: [1:7571471518470704277:2308]
2025-11-11T14:16:27.376994Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_queries.cpp:641: DescribeQueryRequest: {query_id: "ptqudslmr2fr8id7ljo6"
} [root@builtin, **** (B6C6F477)] 
2025-11-11T14:16:27.381939Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: DescribeQueryRequest - DescribeQueryResult: {query { meta { common { id: "ptqudslmr2fr8id7ljo6" created_by: "root@builtin" modified_by: "root@builtin" created_at { seconds: 1762870565 nanos: 540479000 } modified_at { seconds: 1762870578 nanos: 145335000 } revision: 2 } started_at { seconds: 1762870566 nanos: 498000000 } execute_mode: RUN status: ABORTING_BY_USER last_job_query_revision: 1 last_job_id: "ptjudslmr2fr7eo5vmde-ptqudslmr2fr8id7ljo6" started_by: "root@builtin" aborted_by: "root@builtin" has_saved_checkpoints: true submitted_at { seconds: 1762870565 nanos: 540479000 } } content { type: STREAMING name: "simple" acl { visibility: PRIVATE } limits { execution_timeout { } } text: "\n            PRAGMA dq.MaxTasksPerStage=\"5\";\n\n            INSERT INTO yds_1.`delete_read_rules_1_output`\n            SELECT * FROM yds_1.`delete_read_rules_1_input`;" syntax: YQL_V1 } plan { json: "{\"Detailed\":{\"Operations\":[{\"Id\":3,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[{\"Name\":\"DqSourceWideWrap\"},{\"Name\":\"NarrowMap\"}]}},{\"Id\":2,\"Name\":\"DqQuery!\",\"DependsOn\":[3]},{\"Id\":1,\"Name\":\"Commit!\",\"DependsOn\":[2]}],\"OperationRoot\":1,\"Providers\":[],\"OperationStats\":{\"Commit!\":1,\"DqQuery!\":1,\"DqStage\":1}},\"Basic\":{\"nodes\":[{\"id\":3,\"level\":1,\"name\":\"DqStage #3\",\"type\":\"op\"},{\"id\":2,\"level\":2,\"name\":\"DqQuery!\",\"type\":\"op\"},{\"id\":1,\"level\":3,\"name\":\"Commit!\",\"type\":\"op\"}],\"links\":[{\"source\":3,\"target\":2},{\"source\":2,\"target\":1}]}}" } ast { data: "(\n(let $1 (Configure! world (DataSource \'\"config\") \'\"DqEngine\" \'\"force\"))\n(let $2 (Configure! $1 (DataSource \'\"dq\" \'\"$all\") \'\"Attr\" \'\"maxtasksperstage\" \'\"5\"))\n(let $3 (DataSource \'\"pq\" \'\"yds_1\"))\n(let $4 \'(\'(\'\"PartitionsCount\" \'\"1\")))\n(let $5 (StructType \'(\'\"Data\" (DataType \'String))))\n(let $6 (PqTopic \'\"yds_1\" \'\"local\" \'\"delete_read_rules_1_input\" $4 \'() $5))\n(let $7 \'(\'\"Endpoint\" \'\"localhost:6240\"))\n(let $8 \'(\'\"SharedReading\" \'\"0\"))\n(let $9 \'(\'\"AddBearerToToken\" \'\"1\"))\n(let $10 \'($7 $8 \'(\'\"ReconnectPeriod\" \'\"\") \'(\'\"Format\" \'\"raw\") \'(\'\"ReadGroup\" \'\"ptcudslmr2rcnnsh7162\") $9))\n(let $11 (SecureParam \'\"cluster:default_yds_1\"))\n(let $12 (DqPqTopicSource $2 $6 \'(\'\"Data\") $10 $11 \'\"\" $5 \'\"\"))\n(let $13 (DataSink \'\"pq\" \'\"yds_1\"))\n(let $14 (PqTopic \'\"yds_1\" \'\"local\" \'\"delete_read_rules_1_output\" $4 \'() $5))\n(let $15 (DqPqTopicSink $14 \'($7 $9) $11))\n(return (Commit! (DqQuery! $2 \'((DqStage \'((DqSource $3 $12)) (lambda \'($16) (block \'(\n  (let $17 \'(\'(\'\"format\" \'\"raw\") \'(\'\"formatSettings\" \'(\'(\'\"data.datetime.formatname\" \'\"POSIX\") \'(\'\"data.timestamp.formatname\" \'\"POSIX\"))) \'(\'\"settings\" \'($8))))\n  (let $18 (DqSourceWideWrap $16 $3 $5 $17))\n  (return (NarrowMap $18 (lambda \'($19) (AsStruct \'(\'\"Data\" $19)))))\n))) \'(\'(\'\"_logical_id\" \'209361)) \'((DqSink \'\"0\" $13 $15))))) $13))\n)\n" } } } SUCCESS
2025-11-11T14:16:27.884849Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:790: DescribeQueryRequest: query_id: "ptqudslmr2fr8id7ljo6"
2025-11-11T14:16:27.884910Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:313: Resolve folder bootstrap. Folder id: my_folder Actor id: [1:7571471518470704281:2311]
2025-11-11T14:16:27.884952Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:375: Cloud id: mock_cloud Folder id: my_folder
2025-11-11T14:16:27.884988Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:790: DescribeQueryRequest: query_id: "ptqudslmr2fr8id7ljo6"
2025-11-11T14:16:27.885041Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:176: Resolve subject type bootstrap. Token: **** (B6C6F477) Actor id: [1:7571471518470704282:2312]
2025-11-11T14:16:27.885076Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:237: Subject Type: federated_account Token: **** (B6C6F477)
2025-11-11T14:16:27.885109Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:790: DescribeQueryRequest: query_id: "ptqudslmr2fr8id7ljo6"
2025-11-11T14:16:27.885132Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:69: Request actor. Actor id: [1:7571471518470704283:2313]
2025-11-11T14:16:27.885178Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_queries.cpp:641: DescribeQueryRequest: {query_id: "ptqudslmr2fr8id7ljo6"
} [root@builtin, **** (B6C6F477)] 
2025-11-11T14:16:27.891003Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: DescribeQueryRequest - DescribeQueryResult: {query { meta { common { id: "ptqudslmr2fr8id7ljo6" created_by: "root@builtin" modified_by: "root@builtin" created_at { seconds: 1762870565 nanos: 540479000 } modified_at { seconds: 1762870578 nanos: 145335000 } revision: 2 } started_at { seconds: 1762870566 nanos: 498000000 } execute_mode: RUN status: ABORTING_BY_USER last_job_query_revision: 1 last_job_id: "ptjudslmr2fr7eo5vmde-ptqudslmr2fr8id7ljo6" started_by: "root@builtin" aborted_by: "root@builtin" has_saved_checkpoints: true submitted_at { seconds: 1762870565 nanos: 540479000 } } content { type: STREAMING name: "simple" acl { visibility: PRIVATE } limits { execution_timeout { } } text: "\n            PRAGMA dq.MaxTasksPerStage=\"5\";\n\n            INSERT INTO yds_1.`delete_read_rules_1_output`\n            SELECT * FROM yds_1.`delete_read_rules_1_input`;" syntax: YQL_V1 } plan { json: "{\"Detailed\":{\"Operations\":[{\"Id\":3,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[{\"Name\":\"DqSourceWideWrap\"},{\"Name\":\"NarrowMap\"}]}},{\"Id\":2,\"Name\":\"DqQuery!\",\"DependsOn\":[3]},{\"Id\":1,\"Name\":\"Commit!\",\"DependsOn\":[2]}],\"OperationRoot\":1,\"Providers\":[],\"OperationStats\":{\"Commit!\":1,\"DqQuery!\":1,\"DqStage\":1}},\"Basic\":{\"nodes\":[{\"id\":3,\"level\":1,\"name\":\"DqStage #3\",\"type\":\"op\"},{\"id\":2,\"level\":2,\"name\":\"DqQuery!\",\"type\":\"op\"},{\"id\":1,\"level\":3,\"name\":\"Commit!\",\"type\":\"op\"}],\"links\":[{\"source\":3,\"target\":2},{\"source\":2,\"target\":1}]}}" } ast { data: "(\n(let $1 (Configure! world (DataSource \'\"config\") \'\"DqEngine\" \'\"force\"))\n(let $2 (Configure! $1 (DataSource \'\"dq\" \'\"$all\") \'\"Attr\" \'\"maxtasksperstage\" \'\"5\"))\n(let $3 (DataSource \'\"pq\" \'\"yds_1\"))\n(let $4 \'(\'(\'\"PartitionsCount\" \'\"1\")))\n(let $5 (StructType \'(\'\"Data\" (DataType \'String))))\n(let $6 (PqTopic \'\"yds_1\" \'\"local\" \'\"delete_read_rules_1_input\" $4 \'() $5))\n(let $7 \'(\'\"Endpoint\" \'\"localhost:6240\"))\n(let $8 \'(\'\"SharedReading\" \'\"0\"))\n(let $9 \'(\'\"AddBearerToToken\" \'\"1\"))\n(let $10 \'($7 $8 \'(\'\"ReconnectPeriod\" \'\"\") \'(\'\"Format\" \'\"raw\") \'(\'\"ReadGroup\" \'\"ptcudslmr2rcnnsh7162\") $9))\n(let $11 (SecureParam \'\"cluster:default_yds_1\"))\n(let $12 (DqPqTopicSource $2 $6 \'(\'\"Data\") $10 $11 \'\"\" $5 \'\"\"))\n(let $13 (DataSink \'\"pq\" \'\"yds_1\"))\n(let $14 (PqTopic \'\"yds_1\" \'\"local\" \'\"delete_read_rules_1_output\" $4 \'() $5))\n(let $15 (DqPqTopicSink $14 \'($7 $9) $11))\n(return (Commit! (DqQuery! $2 \'((DqStage \'((DqSource $3 $12)) (lambda \'($16) (block \'(\n  (let $17 \'(\'(\'\"format\" \'\"raw\") \'(\'\"formatSettings\" \'(\'(\'\"data.datetime.formatname\" \'\"POSIX\") \'(\'\"data.timestamp.formatname\" \'\"POSIX\"))) \'(\'\"settings\" \'($8))))\n  (let $18 (DqSourceWideWrap $16 $3 $5 $17))\n  (return (NarrowMap $18 (lambda \'($19) (AsStruct \'(\'\"Data\" $19)))))\n))) \'(\'(\'\"_logical_id\" \'209361)) \'((DqSink \'\"0\" $13 $15))))) $13))\n)\n" } } } SUCCESS
2025-11-11T14:16:27.921488Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 9e02db82-b625a9db-ce0a21a7-2b88c90b12, Host: ghrun-vb3yoermsa, Tenant: /default
2025-11-11T14:16:27.922031Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 9e02db82-b625a9db-ce0a21a7-2b88c90b12, Host: ghrun-vb3yoermsa, Tenant: /default, Request CP::GetTask with size: 69 bytes
2025-11-11T14:16:27.922093Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/default"
owner_id: "9e02db82-b625a9db-ce0a21a7-2b88c90b12"
host: "ghrun-vb3yoermsa"
node_id: 1
}
2025-11-11T14:16:27.924780Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:456: Task (Query): ptqudslmr2fr8id7ljo6 Lease TIMEOUT, RetryCounterUpdatedAt 2025-11-11T14:16:05.630749Z LastSeenAt: 2025-11-11T14:16:07.034009Z
2025-11-11T14:16:27.924795Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:463: Task (Query): ptqudslmr2fr8id7ljo6 RetryRate: 0.9996751713 RetryCounter: 1 At: 2025-11-11T14:16:27.924740Z
2025-11-11T14:16:27.936477Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {tasks { query_id { value: "ptqudslmr2fr8id7ljo6" } job_id { value: "ptjudslmr2fr7eo5vmde" } generation: 2 streaming: true dq_graph: "\022\246\006\010\001\022\024\n\022\t\000\000\000\000\000\000\000\000\021\000\000\000\000\000\000\000\000\032\004\010\240\215\006*\335\002Z\332\002\n\010PqSource\022\313\002\n4type.googleapis.com/NYql.NPq.NProto.TDqPqTopicSource\022\222\002\n\031delete_read_rules_1_input\022\024ptqudslmr2fr8id7ljo6\032\016localhost:6240\"\027\n\025cluster:default_yds_1*\005local0\002@\001b\004Dataj\025[\"DataType\";\"String\"]\222\001\024ptcudslmr2rcnnsh7162\232\001\003raw\242\001/[\"StructType\";[[\"Data\";[\"DataType\";\"String\"]]]]\262\001\002\022\000\272\001\026\n\010cloud_id\022\nmock_cloud\272\001 \n\005scope\022\027yandexcloud://my_folder\030\0012\224\001z\221\001\n\006PqSink\022\206\001\n2type.googleapis.com/NYql.NPq.NProto.TDqPqTopicSink\022P\n\032delete_read_rules_1_output\022\016localhost:6240\032\027\n\025cluster:default_yds_1\"\005local0\0018\002:\203\001\n*type.googleapis.com/Yql.DqsProto.TTaskMeta\022U\010\242\344\014\022A\022(8d73c3b672aec01e659c446142c7a17d47fb7b86\032\023dq_vanilla_job.lite \002\"\014\n\002pq\022\006\n\004\010\001\030\001H\242\344\014RClocal/RateLimiter_7a835054-333e-4e86-9f3d-57ea28435bbe/rate_limiterZ)mock_cloud/my_folder/ptqudslmr2fr8id7ljo6`\200\200\200\200 \230\001\000\300\001\001\312\001\010/default2qptqudslmr2fr8id7ljo6#ptrudslmr1ijt0kkgbgt#yandexcloud://my_folder#57340387-e916efb9-64188fb0-a36a13af4#mock_cloud:\027\n\016FallbackPolicy\022\005never:\024\n\017_LiteralTimeout\022\0010:\022\n\r_TableTimeout\022\0010:\027\n\022_RowsLimitPerWrite\022\0010:\027\n\022EnableComputeActor\022\0011:\016\n\014WorkerFilter:\031\n\020ComputeActorType\022\005async:\031\n\016WatermarksMode\022\007disable:\037\n\027WatermarksGranularityMs\022\0041000:$\n\034WatermarksLateArrivalDelayMs\022\0045000:\027\n\022EnableChannelStats\022\0011:\020\n\013ExportStats\022\0011B\'\n\025cluster:default_yds_1\022\016{\"no_auth\":\"\"}b\202\002\010\242\344\014\022\373\001\037\004\006Arg\010Data\005\205\006\213\002\204\203\005@\205\000\204\205\002\203\005@\006\030Inputs(Parameters\034Program\013?\004)\251\000?\002\002\000\n\000)\251\000?\006\002\000\026)\211\002?\014\215?\n FromFlow\000)\211\006?\032\215\233\002?\010?\010?\n$NarrowMap\000)\211\006? \215\205\002?\010\006?$?\010$ExpandMap\000)\211\006?&\215?\000?\000?$\014Map\000)\211\002?*?\002\030ToFlow\000?\022\000\014)\251\000?\000\002\000\010\005?$?4\000\004\016)\251\000?$\002\000\004)\211\004?\010?$\203\004\030Member\000?<\003?>\000\002\006\000\020)\251\000?\010\002\000\002\005?\n?J\000\004\022\000\024\001/" text: "\n            PRAGMA dq.MaxTasksPerStage=\"5\";\n\n            INSERT INTO yds_1.`delete_read_rules_1_output`\n            SELECT * FROM yds_1.`delete_read_rules_1_input`;" connection { content { name: "yds_1" setting { data_streams { auth { none { } } endpoint: "localhost:6240" database: "local" } } acl { visibility: PRIVATE } } meta { id: "ptcudslmr2rcnnsh7162" created_by: "root@builtin" modified_by: "root@builtin" created_at { seconds: 1762870565 nanos: 162230000 } modified_at { seconds: 1762870565 nanos: 162230000 } revision: 1 } } user_token: "root@builtin" user_id: "root@builtin" query_type: STREAMING scope: "yandexcloud://my_folder" execute_mode: RUN state_load_mode: FROM_LAST_CHECKPOINT status: ABORTING_BY_USER sensor_labels { key: "cloud_id" value: "mock_cloud" } sensor_labels { key: "scope" value: "yandexcloud://my_folder" } query_name: "simple" deadline { seconds: 1762956987 nanos: 927732000 } disposition { from_last_checkpoint { } } result_limit: 20971520 execution_limit { } request_started_at { seconds: 1762870566 nanos: 498000000 } restart_count: 1 resources { rate_limiter: READY compilation: READY topic_consumers_state: READY rate_limiter_path: "local/RateLimiter_7a835054-333e-4e86-9f3d-57ea28435bbe/rate_limiter" topic_consumers { database: "local" topic_path: "delete_read_rules_1_input" consumer_name: "ptqudslmr2fr8id7ljo6" cluster_endpoint: "localhost:6240" token_name: "cluster:default_yds_1" add_bearer_to_token: t...} SUCCESS
2025-11-11T14:16:27.936533Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 9e02db82-b625a9db-ce0a21a7-2b88c90b12, Host: ghrun-vb3yoermsa, Tenant: /default, Got CP::GetTask Response
2025-11-11T14:16:27.936896Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-11T14:16:27.936915Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 1
2025-11-11T14:16:27.936928Z :FQ_PENDING_FETCHER DEBUG: pending_fetcher.cpp:361: NewTask: Scope: yandexcloud://my_folder Id: ptqudslmr2fr8id7ljo6 UserId: root@builtin AuthToken: **** (B6C6F477)
2025-11-11T14:16:27.937090Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:375: QueryId: ptqudslmr2fr8id7ljo6 Start run actor. Compute state: ABORTING_BY_USER
2025-11-11T14:16:27.937092Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 9e02db82-b625a9db-ce0a21a7-2b88c90b13, Host: ghrun-vb3yoermsa, Tenant: /default
2025-11-11T14:16:27.937099Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:469: QueryId: ptqudslmr2fr8id7ljo6 FillConnections
2025-11-11T14:16:27.937130Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:2333: QueryId: ptqudslmr2fr8id7ljo6 Run actors params: { QueryId: ptqudslmr2fr8id7ljo6 CloudId: mock_cloud UserId: root@builtin Owner: 9e02db82-b625a9db-ce0a21a7-2b88c90b12 PreviousQueryRevision: 2 Connections: 1 Bindings: 0 AccountIdSignatures: 0 QueryType: STREAMING ExecuteMode: RUN ResultId: ptrudslmqd4bppsnkpfn StateLoadMode: FROM_LAST_CHECKPOINT StreamingDisposition: { from_last_checkpoint { } } Status: ABORTING_BY_USER DqGraphs: 1 DqGraphIndex: 0 Resource.TopicConsumers: 1 }
2025-11-11T14:16:27.937156Z :FQ_PINGER TRACE: pinger.cpp:171: QueryId: ptqudslmr2fr8id7ljo6, Owner: 9e02db82-b625a9db-ce0a21a7-2b88c90b12 Start Pinger
2025-11-11T14:16:27.937188Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:1827: QueryId: ptqudslmr2fr8id7ljo6 Is about to finish query with status ABORTED_BY_USER
2025-11-11T14:16:27.937230Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:1508: QueryId: ptqudslmr2fr8id7ljo6 Start rate limiter resource deleter
2025-11-11T14:16:27.937238Z :STREAMS DEBUG: read_rule_deleter.cpp:214: ptqudslmr2fr8id7ljo6: Create read rule deleter actor for `delete_read_rules_1_input` [0]
2025-11-11T14:16:27.937261Z :STREAMS DEBUG: read_rule_deleter.cpp:106: ptqudslmr2fr8id7ljo6: Make request for read rule deletion for topic `delete_read_rules_1_input` [0]
2025-11-11T14:16:27.937524Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 9e02db82-b625a9db-ce0a21a7-2b88c90b13, Host: ghrun-vb3yoermsa, Tenant: /default, Request CP::GetTask with size: 69 bytes
2025-11-11T14:16:27.937573Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/default"
owner_id: "9e02db82-b625a9db-ce0a21a7-2b88c90b13"
host: "ghrun-vb3yoermsa"
node_id: 1
}
2025-11-11T14:16:27.937679Z :YQL_PRIVATE_PROXY DEBUG: rate_limiter_resources.cpp:175: PrivateDeleteRateLimiterResource - QueryId: ptqudslmr2fr8id7ljo6, Owner: 9e02db82-b625a9db-ce0a21a7-2b88c90b12, Request CP::DeleteRateLimiterResource with size: 98 bytes
2025-11-11T14:16:27.937724Z :YQ_CONTROL_PLANE_STORAGE TRACE: request_actor.h:57: DeleteRateLimiterResourceRequest: {owner_id: "9e02db82-b625a9db-ce0a21a7-2b88c90b12"
query_id {
  value: "ptqudslmr2fr8id7ljo6"
}
scope: "yandexcloud://my_folder"
tenant: "/default"
} 
2025-11-11T14:16:27.948414Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-11-11T14:16:27.948440Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 9e02db82-b625a9db-ce0a21a7-2b88c90b13, Host: ghrun-vb3yoermsa, Tenant: /default, Got CP::GetTask Response
2025-11-11T14:16:27.948739Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-11T14:16:27.948743Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-11T14:16:27.973829Z :YQ_CONTROL_PLANE_STORAGE DEBUG: rate_limiter_resources.cpp:74: DeleteRateLimiterResourceRequest. Got response from database: SUCCESS
2025-11-11T14:16:27.973966Z :YQ_RATE_LIMITER DEBUG: schema.cpp:71: Run delete rate limiter resource "mock_cloud/my_folder/ptqudslmr2fr8id7ljo6" actor
2025-11-11T14:16:27.973974Z :YQ_RATE_LIMITER DEBUG: schema.cpp:113: Call delete rate limiter resource "mock_cloud/my_folder/ptqudslmr2fr8id7ljo6"
2025-11-11T14:16:27.976145Z :YQ_RATE_LIMITER DEBUG: schema.cpp:179: Successfully deleted rate limiter resource "mock_cloud/my_folder/ptqudslmr2fr8id7ljo6"
2025-11-11T14:16:27.976155Z :YQ_RATE_LIMITER DEBUG: schema.cpp:122: Reply for delete rate limiter resource "mock_cloud/my_folder/ptqudslmr2fr8id7ljo6": 
2025-11-11T14:16:27.976178Z :YQ_CONTROL_PLANE_STORAGE DEBUG: rate_limiter_resources.cpp:219: Got delete response from rate limiter service
2025-11-11T14:16:27.976205Z :YQL_PRIVATE_PROXY DEBUG: rate_limiter_resources.cpp:199: PrivateDeleteRateLimiterResource - QueryId: ptqudslmr2fr8id7ljo6, Owner: 9e02db82-b625a9db-ce0a21a7-2b88c90b12, Got CP::DeleteRateLimiterResourceResponse
2025-11-11T14:16:27.976518Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:1499: QueryId: ptqudslmr2fr8id7ljo6 Rate limiter resource deletion finished. Success: 1. Issues: 
2025-11-11T14:16:27.976528Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:1919: QueryId: ptqudslmr2fr8id7ljo6 SendPingAndPassAway, FinalQueryStatus ABORTED_BY_USER
2025-11-11T14:16:27.976546Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:536: QueryId: ptqudslmr2fr8id7ljo6 PassAway
2025-11-11T14:16:27.976621Z :FQ_PINGER TRACE: pinger.cpp:250: QueryId: ptqudslmr2fr8id7ljo6, Owner: 9e02db82-b625a9db-ce0a21a7-2b88c90b12 Forward ping request: { result_id { } status: ABORTED_BY_USER issues { message: "ABORTED_BY_USER" severity: 1 } resources { rate_limiter: READY compilation: READY topic_consumers_state: READY rate_limiter_path: "local/RateLimiter_7a835054-333e-4e86-9f3d-57ea28435bbe/rate_limiter" topic_consumers { database: "local" topic_path: "delete_read_rules_1_input" consumer_name: "ptqudslmr2fr8id7ljo6" cluster_endpoint: "localhost:6240" token_name: "cluster:default_yds_1" add_bearer_to_token: true } } finished_at { seconds: 1762870587 nanos: 937000000 } }
2025-11-11T14:16:27.976633Z :FQ_PINGER TRACE: pinger.cpp:393: QueryId: ptqudslmr2fr8id7ljo6, Owner: 9e02db82-b625a9db-ce0a21a7-2b88c90b12 Forward request Private::PingTask
2025-11-11T14:16:27.977149Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudslmr2fr8id7ljo6, Owner: 9e02db82-b625a9db-ce0a21a7-2b88c90b12, Request CP::PingTask with size: 333 bytes
2025-11-11T14:16:27.977277Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "9e02db82-b625a9db-ce0a21a7-2b88c90b12"
query_id {
  value: "ptqudslmr2fr8id7ljo6"
}
result_id {
}
status: ABORTED_BY_USER
issues {
  message: "ABORTED_BY_USER"
  severity: 1
}
resources {
  rate_limiter: READY
  compilation: READY
  topic_consumers_state: READY
  rate_limiter_path: "local/RateLimiter_7a835054-333e-4e86-9f3d-57ea28435bbe/rate_limiter"
  topic_consumers {
    database: "local"
    topic_path: "delete_read_rules_1_input"
    consumer_name: "ptqudslmr2fr8id7ljo6"
    cluster_endpoint: "localhost:6240"
    token_name: "cluster:default_yds_1"
    add_bearer_to_token: true
  }
}
scope: "yandexcloud://my_folder"
finished_at {
  seconds: 1762870587
  nanos: 937000000
}
deadline {
  seconds: 1762956987
  nanos: 927732000
}
tenant: "/default"
}
2025-11-11T14:16:28.058829Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {action: ABORT } SUCCESS
2025-11-11T14:16:28.058868Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudslmr2fr8id7ljo6, Owner: 9e02db82-b625a9db-ce0a21a7-2b88c90b12, Got CP::PingTaskResponse
2025-11-11T14:16:28.059173Z :FQ_PINGER TRACE: pinger.cpp:338: QueryId: ptqudslmr2fr8id7ljo6, Owner: 9e02db82-b625a9db-ce0a21a7-2b88c90b12 Ping response success: { action: ABORT }
2025-11-11T14:16:28.059190Z :FQ_PINGER DEBUG: pinger.cpp:379: QueryId: ptqudslmr2fr8id7ljo6, Owner: 9e02db82-b625a9db-ce0a21a7-2b88c90b12 Query finished
2025-11-11T14:16:28.059193Z :FQ_PINGER TRACE: pinger.cpp:187: QueryId: ptqudslmr2fr8id7ljo6, Owner: 9e02db82-b625a9db-ce0a21a7-2b88c90b12 Stop Pinger
2025-11-11T14:16:28.393833Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:790: DescribeQueryRequest: query_id: "ptqudslmr2fr8id7ljo6"
2025-11-11T14:16:28.393886Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:313: Resolve folder bootstrap. Folder id: my_folder Actor id: [1:7571471522765671603:2336]
2025-11-11T14:16:28.393916Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:375: Cloud id: mock_cloud Folder id: my_folder
2025-11-11T14:16:28.393947Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:790: DescribeQueryRequest: query_id: "ptqudslmr2fr8id7ljo6"
2025-11-11T14:16:28.393987Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:176: Resolve subject type bootstrap. Token: **** (B6C6F477) Actor id: [1:7571471522765671604:2337]
2025-11-11T14:16:28.394019Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:237: Subject Type: federated_account Token: **** (B6C6F477)
2025-11-11T14:16:28.394034Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:790: DescribeQueryRequest: query_id: "ptqudslmr2fr8id7ljo6"
2025-11-11T14:16:28.394055Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:69: Request actor. Actor id: [1:7571471522765671605:2338]
2025-11-11T14:16:28.394115Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_queries.cpp:641: DescribeQueryRequest: {query_id: "ptqudslmr2fr8id7ljo6"
} [root@builtin, **** (B6C6F477)] 
2025-11-11T14:16:28.398942Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: DescribeQueryRequest - DescribeQueryResult: {query { meta { common { id: "ptqudslmr2fr8id7ljo6" created_by: "root@builtin" modified_by: "root@builtin" created_at { seconds: 1762870565 nanos: 540479000 } modified_at { seconds: 1762870578 nanos: 145335000 } revision: 2 } started_at { seconds: 1762870566 nanos: 498000000 } finished_at { seconds: 1762870587 nanos: 937000000 } execute_mode: RUN status: ABORTED_BY_USER last_job_query_revision: 1 last_job_id: "ptjudslmr2fr7eo5vmde-ptqudslmr2fr8id7ljo6" started_by: "root@builtin" aborted_by: "root@builtin" has_saved_checkpoints: true submitted_at { seconds: 1762870565 nanos: 540479000 } } content { type: STREAMING name: "simple" acl { visibility: PRIVATE } limits { execution_timeout { } } text: "\n            PRAGMA dq.MaxTasksPerStage=\"5\";\n\n            INSERT INTO yds_1.`delete_read_rules_1_output`\n            SELECT * FROM yds_1.`delete_read_rules_1_input`;" syntax: YQL_V1 } plan { json: "{\"Detailed\":{\"Operations\":[{\"Id\":3,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[{\"Name\":\"DqSourceWideWrap\"},{\"Name\":\"NarrowMap\"}]}},{\"Id\":2,\"Name\":\"DqQuery!\",\"DependsOn\":[3]},{\"Id\":1,\"Name\":\"Commit!\",\"DependsOn\":[2]}],\"OperationRoot\":1,\"Providers\":[],\"OperationStats\":{\"Commit!\":1,\"DqQuery!\":1,\"DqStage\":1}},\"Basic\":{\"nodes\":[{\"id\":3,\"level\":1,\"name\":\"DqStage #3\",\"type\":\"op\"},{\"id\":2,\"level\":2,\"name\":\"DqQuery!\",\"type\":\"op\"},{\"id\":1,\"level\":3,\"name\":\"Commit!\",\"type\":\"op\"}],\"links\":[{\"source\":3,\"target\":2},{\"source\":2,\"target\":1}]}}" } issue { message: "ABORTED_BY_USER" severity: 1 } ast { data: "(\n(let $1 (Configure! world (DataSource \'\"config\") \'\"DqEngine\" \'\"force\"))\n(let $2 (Configure! $1 (DataSource \'\"dq\" \'\"$all\") \'\"Attr\" \'\"maxtasksperstage\" \'\"5\"))\n(let $3 (DataSource \'\"pq\" \'\"yds_1\"))\n(let $4 \'(\'(\'\"PartitionsCount\" \'\"1\")))\n(let $5 (StructType \'(\'\"Data\" (DataType \'String))))\n(let $6 (PqTopic \'\"yds_1\" \'\"local\" \'\"delete_read_rules_1_input\" $4 \'() $5))\n(let $7 \'(\'\"Endpoint\" \'\"localhost:6240\"))\n(let $8 \'(\'\"SharedReading\" \'\"0\"))\n(let $9 \'(\'\"AddBearerToToken\" \'\"1\"))\n(let $10 \'($7 $8 \'(\'\"ReconnectPeriod\" \'\"\") \'(\'\"Format\" \'\"raw\") \'(\'\"ReadGroup\" \'\"ptcudslmr2rcnnsh7162\") $9))\n(let $11 (SecureParam \'\"cluster:default_yds_1\"))\n(let $12 (DqPqTopicSource $2 $6 \'(\'\"Data\") $10 $11 \'\"\" $5 \'\"\"))\n(let $13 (DataSink \'\"pq\" \'\"yds_1\"))\n(let $14 (PqTopic \'\"yds_1\" \'\"local\" \'\"delete_read_rules_1_output\" $4 \'() $5))\n(let $15 (DqPqTopicSink $14 \'($7 $9) $11))\n(return (Commit! (DqQuery! $2 \'((DqStage \'((DqSource $3 $12)) (lambda \'($16) (block \'(\n  (let $17 \'(\'(\'\"format\" \'\"raw\") \'(\'\"formatSettings\" \'(\'(\'\"data.datetime.formatname\" \'\"POSIX\") \'(\'\"data.timestamp.formatname\" \'\"POSIX\"))) \'(\'\"settings\" \'($8))))\n  (let $18 (DqSourceWideWrap $16 $3 $5 $17))\n  (return (NarrowMap $18 (lambda \'($19) (AsStruct \'(\'\"Data\" $19)))))\n))) \'(\'(\'\"_logical_id\" \'209361)) \'((DqSink \'\"0\" $13 $15))))) $13))\n)\n" } } } SUCCESS
2025-11-11T14:16:28.921895Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:617: RowDispatcher: Send ping to [1:7571471471226063798:2111]
2025-11-11T14:16:28.921914Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1161: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-11-11T14:16:28.921913Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 9e02db82-b625a9db-ce0a21a7-2b88c90b14, Host: ghrun-vb3yoermsa, Tenant: /default
2025-11-11T14:16:28.921921Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:314: Coordinator: TEvPing received, [1:7571471471226063739:2069]
2025-11-11T14:16:28.921925Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:317: Coordinator: Send TEvPong to [1:7571471471226063739:2069]
2025-11-11T14:16:28.921941Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:623: RowDispatcher: NActors::TEvents::TEvPong
2025-11-11T14:16:28.926310Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-11T14:16:28.926330Z :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.1.1:29734: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-vb3yoermsa.auto.internal:29734
2025-11-11T14:16:28.977378Z :FQ_CONTROL_PLANE_CONFIG TRACE: control_plane_config.cpp:192: LOADED TenantInfo: State NOT changed
2025-11-11T14:16:29.922364Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 9e02db82-b625a9db-ce0a21a7-2b88c90b15, Host: ghrun-vb3yoermsa, Tenant: /default
2025-11-11T14:16:29.927067Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-11T14:16:29.927090Z :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.1.1:29734: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-vb3yoermsa.auto.internal:29734
2025-11-11T14:16:30.922769Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:617: RowDispatcher: Send ping to [1:7571471471226063798:2111]
2025-11-11T14:16:30.922788Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1161: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-11-11T14:16:30.922788Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 9e02db82-b625a9db-ce0a21a7-2b88c90b16, Host: ghrun-vb3yoermsa, Tenant: /default
2025-11-11T14:16:30.922795Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:314: Coordinator: TEvPing received, [1:7571471471226063739:2069]
2025-11-11T14:16:30.922803Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:317: Coordinator: Send TEvPong to [1:7571471471226063739:2069]
2025-11-11T14:16:30.922813Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:623: RowDispatcher: NActors::TEvents::TEvPong
2025-11-11T14:16:30.927735Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-11T14:16:30.927757Z :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.1.1:29734: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint ghrun-vb3yoermsa.auto.internal:29734
