2025-12-09T03:43:46.582625Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:544: RowDispatcher: Successfully bootstrapped row dispatcher, id [1:7581698863917820440:2069], tenant /default
2025-12-09T03:43:46.582646Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7581698863917820440:2069]
2025-12-09T03:43:46.582648Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:329: Coordinator: Add new row dispatcher to map (state 1)
2025-12-09T03:43:46.582882Z :GRPC_SERVER NOTICE: grpc_request_proxy_simple.cpp:161: Grpc simple request proxy started, nodeid# 1
2025-12-09T03:43:46.582921Z :GRPC_SERVER NOTICE: grpc_request_proxy_simple.cpp:161: Grpc simple request proxy started, nodeid# 1
2025-12-09T03:43:46.583147Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:293: Coordinator: Successfully bootstrapped coordinator, id [1:7581698863917820456:2081], NodesManagerId [0:4705493345362661702:78], rebalancing timeout 5.000000s
2025-12-09T03:43:46.583165Z :YQL_NODES_MANAGER INFO: nodes_manager.cpp:88: Bootstrap, InstanceId: 35c66de4-409e1c92-b6739c87-39e4782e
2025-12-09T03:43:46.583166Z :YQL_NODES_MANAGER DEBUG: nodes_manager.cpp:310: TNodesManagerActor::ResolveSelfAddress
2025-12-09T03:43:46.583172Z :FQ_CONTROL_PLANE_CONFIG DEBUG: control_plane_config.cpp:58: STARTING: [1:7581698863917820434:2063]
2025-12-09T03:43:46.583175Z :YQ_TEST_CONNECTION DEBUG: test_connection.cpp:142: Starting yandex query test connection. Actor id: [1:7581698863917820445:2074]
2025-12-09T03:43:46.583202Z :FQ_LOG_UPDATER DEBUG: log.cpp:93: Updated YQL logs priority: 8
2025-12-09T03:43:46.583215Z :FQ_LOG_UPDATER CRIT: log.cpp:55: Failed to deliver subscription request to config dispatcher.
2025-12-09T03:43:46.583388Z :FQ_QUOTA_SERVICE INFO: quota_manager.cpp:196: STARTED
2025-12-09T03:43:46.583394Z :YQ_CONTROL_PLANE_STORAGE INFO: ydb_control_plane_storage.cpp:50: Starting ydb control plane storage service. Actor id: [1:7581698863917820433:2062]
2025-12-09T03:43:46.583612Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:637: RowDispatcher: TEvCoordinatorChangesSubscribe from [1:7581698863917820456:2081]
2025-12-09T03:43:46.583630Z :YQ_CONTROL_PLANE_PROXY DEBUG: control_plane_proxy.cpp:525: Starting yandex query control plane proxy. Actor id: [1:7581698863917820435:2064]
2025-12-09T03:43:46.583690Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:232: TLeaderElection [1:7581698863917820457:2082] Successfully bootstrapped, local coordinator id [1:7581698863917820456:2081], tenant id default, local mode 0, coordination node path local/default, endpoint localhost:4888
2025-12-09T03:43:46.583747Z :YQ_RATE_LIMITER INFO: quoter_service.cpp:124: Bootstraping with config: { Enabled: true ControlPlaneEnabled: true DataPlaneEnabled: true Database { Endpoint: "localhost:4888" Database: "local" TablePrefix: "RateLimiter_b0e8c56f-8a62-42ec-8405-5b233b311755" } Limiters { CoordinationNodePath: "rate_limiter" } }
2025-12-09T03:43:46.583839Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/bindings" actor
2025-12-09T03:43:46.583859Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/idempotency_keys" actor
2025-12-09T03:43:46.583870Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/jobs" actor
2025-12-09T03:43:46.583900Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 323dda4c-6ce2c19b-118bbaa6-9f349aa61, Host: ghrun-syjwtgwtdu, Tenant: /default
2025-12-09T03:43:46.583909Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/mappings" actor
2025-12-09T03:43:46.583915Z :FQ_QUOTA_PROXY INFO: quota_proxy.cpp:90: STARTED
2025-12-09T03:43:46.583918Z :YQ_RATE_LIMITER DEBUG: schema.cpp:71: Run create coordination node "local/RateLimiter_b0e8c56f-8a62-42ec-8405-5b233b311755/rate_limiter" actor
2025-12-09T03:43:46.583920Z :YQ_RATE_LIMITER DEBUG: schema.cpp:113: Call create coordination node "local/RateLimiter_b0e8c56f-8a62-42ec-8405-5b233b311755/rate_limiter"
2025-12-09T03:43:46.583922Z :YQ_RATE_LIMITER DEBUG: schema.cpp:411: Call create coordination node "local/RateLimiter_b0e8c56f-8a62-42ec-8405-5b233b311755/rate_limiter"
2025-12-09T03:43:46.583935Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create directory "local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755" actor
2025-12-09T03:43:46.583936Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create directory "local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755"
2025-12-09T03:43:46.583938Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:383: Call create directory "local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755"
2025-12-09T03:43:46.583950Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/queries" actor
2025-12-09T03:43:46.583967Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/pending_small" actor
2025-12-09T03:43:46.583974Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:214: Bootstrap
2025-12-09T03:43:46.583976Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:217: Create sdk ydb connection
2025-12-09T03:43:46.583998Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:239: Successfully bootstrapped TStorageProxy [1:7581698863917820439:2068] with connection to localhost:4888:local
2025-12-09T03:43:46.584001Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/connections" actor
2025-12-09T03:43:46.584007Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/result_sets" actor
2025-12-09T03:43:46.584366Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/nodes" actor
2025-12-09T03:43:46.584389Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/quotas" actor
2025-12-09T03:43:46.584399Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/tenants" actor
2025-12-09T03:43:46.584411Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-12-09T03:43:46.584634Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/tenant_acks" actor
2025-12-09T03:43:46.584643Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/compute_databases" actor
2025-12-09T03:43:46.584907Z :MEMORY_PROFILER NOTICE: monitor.cpp:332: Bootstrapped
2025-12-09T03:43:46.585688Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:71: Run create coordination node "local/default" actor
2025-12-09T03:43:46.585696Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:113: Call create coordination node "local/default"
2025-12-09T03:43:46.585699Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:411: Call create coordination node "local/default"
2025-12-09T03:43:46.590688Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:43:46.590701Z :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:4963: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint localhost:4963
2025-12-09T03:43:46.590749Z :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:4963: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint localhost:4963
2025-12-09T03:43:46.596642Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:155: Successfully created coordination node "local/default"
2025-12-09T03:43:46.596657Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:122: Reply for create coordination node "local/default": { <main>: Error: Check failed: path: '/local/default', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 6], type: EPathTypeKesus, state: EPathStateNoChanges), source_location: ydb/core/tx/schemeshard/schemeshard__operation_create_kesus.cpp:339 }
2025-12-09T03:43:46.596672Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:345: TLeaderElection [1:7581698863917820457:2082] Coordination node successfully created
2025-12-09T03:43:46.596674Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:323: TLeaderElection [1:7581698863917820457:2082] Start session
2025-12-09T03:43:46.597339Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/quotas". Create session OK
2025-12-09T03:43:46.597353Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/quotas"
2025-12-09T03:43:46.597355Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/quotas"
2025-12-09T03:43:46.597366Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/jobs". Create session OK
2025-12-09T03:43:46.597372Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/jobs"
2025-12-09T03:43:46.597374Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/jobs"
2025-12-09T03:43:46.597380Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/tenants". Create session OK
2025-12-09T03:43:46.597383Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/tenants"
2025-12-09T03:43:46.597385Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/tenants"
2025-12-09T03:43:46.597502Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/result_sets". Create session OK
2025-12-09T03:43:46.597507Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created directory "local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755"
2025-12-09T03:43:46.597510Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/result_sets"
2025-12-09T03:43:46.597515Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create directory "local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755": { <main>: Error: Check failed: path: '/local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 20], type: EPathTypeDir, state: EPathStateNoChanges), source_location: ydb/core/tx/schemeshard/schemeshard__operation_mkdir.cpp:155 }
2025-12-09T03:43:46.597520Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/result_sets"
2025-12-09T03:43:46.597522Z :YQ_RATE_LIMITER DEBUG: schema.cpp:155: Successfully created coordination node "local/RateLimiter_b0e8c56f-8a62-42ec-8405-5b233b311755/rate_limiter"
2025-12-09T03:43:46.597525Z :YQ_RATE_LIMITER DEBUG: schema.cpp:122: Reply for create coordination node "local/RateLimiter_b0e8c56f-8a62-42ec-8405-5b233b311755/rate_limiter": { <main>: Error: Check failed: path: '/local/RateLimiter_b0e8c56f-8a62-42ec-8405-5b233b311755/rate_limiter', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 25], type: EPathTypeKesus, state: EPathStateNoChanges), source_location: ydb/core/tx/schemeshard/schemeshard__operation_create_kesus.cpp:339 }
2025-12-09T03:43:46.597530Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/tenant_acks". Create session OK
2025-12-09T03:43:46.597531Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/tenant_acks"
2025-12-09T03:43:46.597533Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/tenant_acks"
2025-12-09T03:43:46.597536Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/connections". Create session OK
2025-12-09T03:43:46.597537Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/connections"
2025-12-09T03:43:46.597539Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/connections"
2025-12-09T03:43:46.597583Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/mappings". Create session OK
2025-12-09T03:43:46.597584Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/mappings"
2025-12-09T03:43:46.597584Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/nodes". Create session OK
2025-12-09T03:43:46.597586Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/mappings"
2025-12-09T03:43:46.597586Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/nodes"
2025-12-09T03:43:46.597587Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/nodes"
2025-12-09T03:43:46.597820Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/pending_small". Create session OK
2025-12-09T03:43:46.597826Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/pending_small"
2025-12-09T03:43:46.597828Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/pending_small"
2025-12-09T03:43:46.598436Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/idempotency_keys". Create session OK
2025-12-09T03:43:46.598444Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/idempotency_keys"
2025-12-09T03:43:46.598446Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/idempotency_keys"
2025-12-09T03:43:46.598810Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/queries". Create session OK
2025-12-09T03:43:46.598818Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/queries"
2025-12-09T03:43:46.598819Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/queries"
2025-12-09T03:43:46.598867Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/bindings". Create session OK
2025-12-09T03:43:46.598875Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/bindings"
2025-12-09T03:43:46.598877Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/bindings"
2025-12-09T03:43:46.599400Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/compute_databases". Create session OK
2025-12-09T03:43:46.599409Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/compute_databases"
2025-12-09T03:43:46.599410Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/compute_databases"
2025-12-09T03:43:46.599574Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:359: TLeaderElection [1:7581698863917820457:2082] Session successfully created
2025-12-09T03:43:46.601571Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/quotas"
2025-12-09T03:43:46.601586Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/quotas": { <main>: Error: Check failed: path: '/local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/quotas', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 32], type: EPathTypeTable, state: EPathStateNoChanges), source_location: ydb/core/tx/schemeshard/schemeshard__operation_create_table.cpp:504 }
2025-12-09T03:43:46.601603Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/jobs"
2025-12-09T03:43:46.601613Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/jobs": { <main>: Error: Check failed: path: '/local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/jobs', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 26], type: EPathTypeTable, state: EPathStateNoChanges), source_location: ydb/core/tx/schemeshard/schemeshard__operation_create_table.cpp:504 }
2025-12-09T03:43:46.601774Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:372: TLeaderElection [1:7581698863917820457:2082] Semaphore successfully created
2025-12-09T03:43:46.601781Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:304: TLeaderElection [1:7581698863917820457:2082] Try to acquire semaphore
2025-12-09T03:43:46.601806Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:420: TLeaderElection [1:7581698863917820457:2082] Describe semaphore
2025-12-09T03:43:46.601876Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/result_sets"
2025-12-09T03:43:46.601887Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/result_sets": { <main>: Error: Check failed: path: '/local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/result_sets', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 33], type: EPathTypeTable, state: EPathStateNoChanges), source_location: ydb/core/tx/schemeshard/schemeshard__operation_create_table.cpp:504 }
2025-12-09T03:43:46.601931Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/tenants"
2025-12-09T03:43:46.601945Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/tenants": { <main>: Error: Check failed: path: '/local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/tenants', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 21], type: EPathTypeTable, state: EPathStateNoChanges), source_location: ydb/core/tx/schemeshard/schemeshard__operation_create_table.cpp:504 }
2025-12-09T03:43:46.602653Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/nodes"
2025-12-09T03:43:46.602664Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/nodes": { <main>: Error: Check failed: path: '/local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/nodes', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 30], type: EPathTypeTable, state: EPathStateNoChanges), source_location: ydb/core/tx/schemeshard/schemeshard__operation_create_table.cpp:504 }
2025-12-09T03:43:46.602670Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/tenant_acks"
2025-12-09T03:43:46.602678Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/tenant_acks": { <main>: Error: Check failed: path: '/local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/tenant_acks', 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-12-09T03:43:46.602702Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/connections"
2025-12-09T03:43:46.602709Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/connections": { <main>: Error: Check failed: path: '/local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/connections', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 28], type: EPathTypeTable, state: EPathStateNoChanges), source_location: ydb/core/tx/schemeshard/schemeshard__operation_create_table.cpp:504 }
2025-12-09T03:43:46.602753Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/mappings"
2025-12-09T03:43:46.602761Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/mappings": { <main>: Error: Check failed: path: '/local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/mappings', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 22], type: EPathTypeTable, state: EPathStateNoChanges), source_location: ydb/core/tx/schemeshard/schemeshard__operation_create_table.cpp:504 }
2025-12-09T03:43:46.602784Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/compute_databases"
2025-12-09T03:43:46.602789Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/compute_databases": { <main>: Error: Check failed: path: '/local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/compute_databases', 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-12-09T03:43:46.602804Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/bindings"
2025-12-09T03:43:46.602805Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/pending_small"
2025-12-09T03:43:46.602809Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/pending_small": { <main>: Error: Check failed: path: '/local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/pending_small', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 34], type: EPathTypeTable, state: EPathStateNoChanges), source_location: ydb/core/tx/schemeshard/schemeshard__operation_create_table.cpp:504 }
2025-12-09T03:43:46.602812Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/bindings": { <main>: Error: Check failed: path: '/local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/bindings', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 31], type: EPathTypeTable, state: EPathStateNoChanges), source_location: ydb/core/tx/schemeshard/schemeshard__operation_create_table.cpp:504 }
2025-12-09T03:43:46.602865Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/queries"
2025-12-09T03:43:46.602873Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/idempotency_keys"
2025-12-09T03:43:46.602875Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/queries": { <main>: Error: Check failed: path: '/local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/queries', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 29], type: EPathTypeTable, state: EPathStateNoChanges), source_location: ydb/core/tx/schemeshard/schemeshard__operation_create_table.cpp:504 }
2025-12-09T03:43:46.602896Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/idempotency_keys": { <main>: Error: Check failed: path: '/local/DbPoolStorage_b0e8c56f-8a62-42ec-8405-5b233b311755/idempotency_keys', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 27], type: EPathTypeTable, state: EPathStateNoChanges), source_location: ydb/core/tx/schemeshard/schemeshard__operation_create_table.cpp:504 }
2025-12-09T03:43:46.603366Z :FQ_CONTROL_PLANE_CONFIG DEBUG: control_plane_config.cpp:190: LOADED TenantInfo: State CHANGED at 2025-12-09T03:43:34.623845Z
2025-12-09T03:43:46.603976Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:386: TLeaderElection [1:7581698863917820457:2082] Semaphore successfully acquired
2025-12-09T03:43:46.604077Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:469: TLeaderElection [1:7581698863917820457:2082] Semaphore successfully described: coordinator id [1:7581698863917820456:2081] generation 3
2025-12-09T03:43:46.604086Z :FQ_ROW_DISPATCHER INFO: leader_election.cpp:471: TLeaderElection [1:7581698863917820457:2082] Send TEvCoordinatorChanged to [1:7581698863917820440:2069], new coordinator id [1:7581698863917820456:2081], previous coordinator id [0:0:0]
2025-12-09T03:43:46.604100Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:569: RowDispatcher: Coordinator changed, old leader (empty maybe), new [1:7581698863917820456:2081] generation 3
2025-12-09T03:43:46.604111Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7581698863917820440:2069]
2025-12-09T03:43:46.604114Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7581698863917820440:2069]
2025-12-09T03:43:46.604117Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7581698863917820440:2069]
2025-12-09T03:43:46.604125Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:440: Coordinator: New leader [1:7581698863917820456:2081], SelfId [1:7581698863917820456:2081]
2025-12-09T03:43:46.604134Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-09T03:43:47.580830Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 323dda4c-6ce2c19b-118bbaa6-9f349aa62, Host: ghrun-syjwtgwtdu, Tenant: /default
2025-12-09T03:43:47.589692Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 323dda4c-6ce2c19b-118bbaa6-9f349aa62, Host: ghrun-syjwtgwtdu, Tenant: /default, Request CP::GetTask with size: 68 bytes
2025-12-09T03:43:47.590368Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/default"
owner_id: "323dda4c-6ce2c19b-118bbaa6-9f349aa62"
host: "ghrun-syjwtgwtdu"
node_id: 1
}
2025-12-09T03:43:47.592986Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-09T03:43:47.593018Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 323dda4c-6ce2c19b-118bbaa6-9f349aa62, Host: ghrun-syjwtgwtdu, Tenant: /default, Got CP::GetTask Response
2025-12-09T03:43:47.593232Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:43:47.593239Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-09T03:43:47.617868Z :TICKET_PARSER DEBUG: ticket_parser_impl.h:1875: Ticket **** (B6C6F477) (ipv6:[::1]:56106) has now valid token of root@builtin
2025-12-09T03:43:47.617969Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudqgd47iklgerf2i1"
2025-12-09T03:43:47.618020Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:305: Resolve folder bootstrap. Folder id: my_folder Actor id: [1:7581698868212787993:2302]
2025-12-09T03:43:47.618042Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:367: Cloud id: mock_cloud Folder id: my_folder
2025-12-09T03:43:47.618061Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:91: Get quotas bootstrap. Cloud id: mock_cloud Actor id: [1:7581698868212787994:2303]
2025-12-09T03:43:47.618083Z :FQ_QUOTA_SERVICE DEBUG: quota_manager.cpp:255: cloud.mock_cloud NOT CASHED, Loading ...
2025-12-09T03:43:47.620368Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:441: cloud.mock_cloud {yq.analyticsQuery.count=0/100, yq.cpuPercent.count=0/10000, yq.streamingQuery.count=1/100} FROM DB
2025-12-09T03:43:47.620397Z :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=1/100} LOADED
2025-12-09T03:43:47.620400Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.analyticsQuery.count IS STALE, Refreshing ...
2025-12-09T03:43:47.620410Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.cpuPercent.count IS STALE, Refreshing ...
2025-12-09T03:43:47.620420Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.streamingQuery.count IS STALE, Refreshing ...
2025-12-09T03:43:47.620439Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.cpuPercent.count=0/10000 REFRESHED
2025-12-09T03:43:47.623325Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.analyticsQuery.count=0/100 REFRESHED
2025-12-09T03:43:47.623342Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.streamingQuery.count=1/100 REFRESHED
2025-12-09T03:43:47.623362Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:493: cloud.mock_cloud{yq.streamingQueryDurationMinutes.count=*/0, yq.queryResult.size=*/20971520, yq.analyticsQuery.count=0/100, yq.analyticsQueryDurationMinutes.count=*/1440, yq.memory.size=*/0, yq.result.size=*/0, yq.cpuPercent.count=0/10000, yq.streamingQuery.count=1/100} SEND QUOTAS
2025-12-09T03:43:47.623372Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:103: Cloud id: mock_cloud Quota count: 8
2025-12-09T03:43:47.623406Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudqgd47iklgerf2i1"
2025-12-09T03:43:47.623463Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:169: Resolve subject type bootstrap. Token: **** (B6C6F477) Actor id: [1:7581698868212788000:2309]
2025-12-09T03:43:47.623493Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:230: Subject Type: federated_account Token: **** (B6C6F477)
2025-12-09T03:43:47.623513Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudqgd47iklgerf2i1"
2025-12-09T03:43:47.623527Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:63: Request actor. Actor id: [1:7581698868212788001:2310]
2025-12-09T03:43:47.623581Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_queries.cpp:641: DescribeQueryRequest: {query_id: "ptqudqgd47iklgerf2i1"
} [root@builtin, **** (B6C6F477)] 
2025-12-09T03:43:47.625966Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.cpuPercent.count=0/10000 NOTIFY CHANGE
2025-12-09T03:43:47.626069Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: DescribeQueryRequest - DescribeQueryResult: {query { meta { common { id: "ptqudqgd47iklgerf2i1" created_by: "root@builtin" modified_by: "root@builtin" created_at { seconds: 1765251817 nanos: 581843000 } modified_at { seconds: 1765251817 nanos: 581843000 } revision: 1 } started_at { seconds: 1765251818 nanos: 422000000 } execute_mode: RUN status: RUNNING last_job_query_revision: 1 last_job_id: "ptjudqgd47ikks1vrsj4-ptqudqgd47iklgerf2i1" started_by: "root@builtin" has_saved_checkpoints: true submitted_at { seconds: 1765251817 nanos: 581843000 } } content { type: STREAMING name: "simple" acl { visibility: PRIVATE } limits { execution_timeout { } } text: "SELECT * FROM myyds_2f.`select_timings_2f_input` LIMIT 1;" syntax: YQL_V1 } plan { json: "{\"Detailed\":{\"Operations\":[{\"Id\":10,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[{\"Name\":\"DqSourceWideWrap\"},{\"Name\":\"NarrowMap\"},{\"Name\":\"Take\"}]}},{\"Id\":8,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[{\"Name\":\"Take\"}]},\"DependsOn\":[10]},{\"Id\":6,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[]},\"DependsOn\":[8]},{\"Id\":3,\"Name\":\"ResPull!\",\"DependsOn\":[6]},{\"Id\":1,\"Name\":\"Commit!\",\"DependsOn\":[3]}],\"OperationRoot\":1,\"Providers\":[],\"OperationStats\":{\"Commit!\":1,\"DqStage\":3,\"ResPull!\":1}},\"Basic\":{\"nodes\":[{\"id\":10,\"level\":1,\"name\":\"DqStage #10\",\"type\":\"op\"},{\"id\":8,\"level\":2,\"name\":\"DqStage #8\",\"type\":\"op\"},{\"id\":6,\"level\":3,\"name\":\"DqStage #6\",\"type\":\"op\"},{\"id\":3,\"level\":4,\"name\":\"ResPull!\",\"type\":\"op\"},{\"id\":1,\"level\":5,\"name\":\"Commit!\",\"type\":\"op\"}],\"links\":[{\"source\":10,\"target\":8},{\"source\":8,\"target\":6},{\"source\":6,\"target\":3},{\"source\":3,\"target\":1}]}}" } result_set_meta { column { name: "Data" type { type_id: STRING } } } ast { data: "(\n(let $1 (Configure! world (DataSource \'\"config\") \'\"DqEngine\" \'\"force\"))\n(let $2 (DataSink \'result))\n(let $3 (DataSource \'\"pq\" \'\"myyds_2f\"))\n(let $4 (StructType \'(\'\"Data\" (DataType \'String))))\n(let $5 (PqTopic \'\"myyds_2f\" \'\"local\" \'\"select_timings_2f_input\" \'(\'(\'\"PartitionsCount\" \'1)) \'() $4))\n(let $6 \'(\'\"SharedReading\" \'\"0\"))\n(let $7 \'(\'(\'\"Endpoint\" \'\"localhost:4888\") $6 \'(\'\"ReconnectPeriod\" \'\"\") \'(\'\"Format\" \'\"raw\") \'(\'\"ReadGroup\" \'\"ptcudqgd47r6f85fafmq\") \'(\'\"AddBearerToToken\" \'1)))\n(let $8 (DqPqTopicSource world $5 \'(\'\"Data\") $7 (SecureParam \'\"cluster:default_myyds_2f\") \'\"\" $4 \'\"\"))\n(let $9 (Uint64 \'1))\n(let $10 (DqStage \'((DqSource $3 $8)) (lambda \'($14) (block \'(\n  (let $15 \'(\'(\'\"format\" \'\"raw\") \'(\'\"formatSettings\" \'(\'(\'\"data.datetime.formatname\" \'\"POSIX\") \'(\'\"data.timestamp.formatname\" \'\"POSIX\"))) \'(\'\"settings\" \'($6))))\n  (let $16 (DqSourceWideWrap $14 $3 $4 $15))\n  (return (Take (NarrowMap $16 (lambda \'($17) (AsStruct \'(\'\"Data\" $17)))) $9))\n))) \'(\'(\'\"_logical_id\" \'200270))))\n(let $11 (DqStage \'((DqCnUnionAll (TDqOutput $10 \'\"0\"))) (lambda \'($18) (Take $18 $9)) \'(\'(\'\"_logical_id\" \'200283))))\n(let $12 (DqStage \'((DqCnUnionAll (TDqOutput $11 \'\"0\"))) (lambda \'($19) $19) \'(\'(\'\"_logical_id\" \'200320))))\n(let $13 (ResPull! $1 $2 (Key) (DqCnResult (TDqOutput $12 \'\"0\") \'()) \'(\'(\'type) \'(\'autoref)) \'\"dq\"))\n(return (Commit! (Commit! $13 $2) (DataSink \'\"pq\" \'\"myyds_2f\")))\n)\n" } } } SUCCESS
2025-12-09T03:43:47.629124Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.analyticsQuery.count=0/100 NOTIFY CHANGE
2025-12-09T03:43:47.629151Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.streamingQuery.count=1/100 NOTIFY CHANGE
2025-12-09T03:43:48.580219Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7581698863917820456:2081]
2025-12-09T03:43:48.580237Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-09T03:43:48.580243Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7581698863917820440:2069]
2025-12-09T03:43:48.580246Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7581698863917820440:2069]
2025-12-09T03:43:48.580247Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7581698863917820440:2069]
2025-12-09T03:43:48.580256Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-09T03:43:48.581300Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 323dda4c-6ce2c19b-118bbaa6-9f349aa63, Host: ghrun-syjwtgwtdu, Tenant: /default
2025-12-09T03:43:48.581695Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 323dda4c-6ce2c19b-118bbaa6-9f349aa63, Host: ghrun-syjwtgwtdu, Tenant: /default, Request CP::GetTask with size: 68 bytes
2025-12-09T03:43:48.581726Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/default"
owner_id: "323dda4c-6ce2c19b-118bbaa6-9f349aa63"
host: "ghrun-syjwtgwtdu"
node_id: 1
}
2025-12-09T03:43:48.583813Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-09T03:43:48.583842Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 323dda4c-6ce2c19b-118bbaa6-9f349aa63, Host: ghrun-syjwtgwtdu, Tenant: /default, Got CP::GetTask Response
2025-12-09T03:43:48.584073Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:43:48.584083Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-09T03:43:49.581746Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 323dda4c-6ce2c19b-118bbaa6-9f349aa64, Host: ghrun-syjwtgwtdu, Tenant: /default
2025-12-09T03:43:49.582189Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 323dda4c-6ce2c19b-118bbaa6-9f349aa64, Host: ghrun-syjwtgwtdu, Tenant: /default, Request CP::GetTask with size: 68 bytes
2025-12-09T03:43:49.582241Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/default"
owner_id: "323dda4c-6ce2c19b-118bbaa6-9f349aa64"
host: "ghrun-syjwtgwtdu"
node_id: 1
}
2025-12-09T03:43:49.584476Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-09T03:43:49.584501Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 323dda4c-6ce2c19b-118bbaa6-9f349aa64, Host: ghrun-syjwtgwtdu, Tenant: /default, Got CP::GetTask Response
2025-12-09T03:43:49.584744Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:43:49.584757Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-09T03:43:49.589631Z :FQ_CONTROL_PLANE_CONFIG TRACE: control_plane_config.cpp:192: LOADED TenantInfo: State NOT changed
2025-12-09T03:43:50.581156Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7581698863917820456:2081]
2025-12-09T03:43:50.581177Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-09T03:43:50.581183Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7581698863917820440:2069]
2025-12-09T03:43:50.581186Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7581698863917820440:2069]
2025-12-09T03:43:50.581189Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7581698863917820440:2069]
2025-12-09T03:43:50.581197Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-09T03:43:50.582179Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 323dda4c-6ce2c19b-118bbaa6-9f349aa65, Host: ghrun-syjwtgwtdu, Tenant: /default
2025-12-09T03:43:50.582597Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 323dda4c-6ce2c19b-118bbaa6-9f349aa65, Host: ghrun-syjwtgwtdu, Tenant: /default, Request CP::GetTask with size: 68 bytes
2025-12-09T03:43:50.582637Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/default"
owner_id: "323dda4c-6ce2c19b-118bbaa6-9f349aa65"
host: "ghrun-syjwtgwtdu"
node_id: 1
}
2025-12-09T03:43:50.585022Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-09T03:43:50.585051Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 323dda4c-6ce2c19b-118bbaa6-9f349aa65, Host: ghrun-syjwtgwtdu, Tenant: /default, Got CP::GetTask Response
2025-12-09T03:43:50.585312Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:43:50.585322Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-09T03:43:51.580577Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-12-09T03:43:51.580592Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:665: Coordinator: Change global state to Started (by timeout)
2025-12-09T03:43:51.581263Z :YQ_CONTROL_PLANE_STORAGE TRACE: nodes_health_check.cpp:38: NodesHealthCheckRequest: {tenant: "/default"
node {
  node_id: 1
  instance_id: "35c66de4-409e1c92-b6739c87-39e4782e"
  hostname: "ghrun-syjwtgwtdu"
  interconnect_port: 5184
  node_address: "127.0.1.1"
}
}
2025-12-09T03:43:51.582621Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 323dda4c-6ce2c19b-118bbaa6-9f349aa66, Host: ghrun-syjwtgwtdu, Tenant: /default
2025-12-09T03:43:51.582975Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 323dda4c-6ce2c19b-118bbaa6-9f349aa66, Host: ghrun-syjwtgwtdu, Tenant: /default, Request CP::GetTask with size: 68 bytes
2025-12-09T03:43:51.583008Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/default"
owner_id: "323dda4c-6ce2c19b-118bbaa6-9f349aa66"
host: "ghrun-syjwtgwtdu"
node_id: 1
}
2025-12-09T03:43:51.584923Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-09T03:43:51.584959Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 323dda4c-6ce2c19b-118bbaa6-9f349aa66, Host: ghrun-syjwtgwtdu, Tenant: /default, Got CP::GetTask Response
2025-12-09T03:43:51.585220Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:43:51.585229Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-09T03:43:51.587007Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: NodesHealthCheckRequest - NodesHealthCheckResult: {nodes { node_id: 1 instance_id: "35c66de4-409e1c92-b6739c87-39e4782e" hostname: "ghrun-syjwtgwtdu" node_address: "127.0.1.1" } } SUCCESS
2025-12-09T03:43:51.587323Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:389: Send NodeInfo with size: 0 to DynamicNameserver
2025-12-09T03:43:52.582033Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7581698863917820456:2081]
2025-12-09T03:43:52.582052Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-09T03:43:52.582058Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7581698863917820440:2069]
2025-12-09T03:43:52.582061Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7581698863917820440:2069]
2025-12-09T03:43:52.582063Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7581698863917820440:2069]
2025-12-09T03:43:52.582071Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-09T03:43:52.583071Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 323dda4c-6ce2c19b-118bbaa6-9f349aa67, Host: ghrun-syjwtgwtdu, Tenant: /default
2025-12-09T03:43:52.583475Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 323dda4c-6ce2c19b-118bbaa6-9f349aa67, Host: ghrun-syjwtgwtdu, Tenant: /default, Request CP::GetTask with size: 68 bytes
2025-12-09T03:43:52.583523Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/default"
owner_id: "323dda4c-6ce2c19b-118bbaa6-9f349aa67"
host: "ghrun-syjwtgwtdu"
node_id: 1
}
2025-12-09T03:43:52.585497Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-09T03:43:52.585526Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 323dda4c-6ce2c19b-118bbaa6-9f349aa67, Host: ghrun-syjwtgwtdu, Tenant: /default, Got CP::GetTask Response
2025-12-09T03:43:52.585749Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:43:52.585756Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-09T03:43:52.589827Z :FQ_CONTROL_PLANE_CONFIG TRACE: control_plane_config.cpp:192: LOADED TenantInfo: State NOT changed
2025-12-09T03:43:53.583541Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 323dda4c-6ce2c19b-118bbaa6-9f349aa68, Host: ghrun-syjwtgwtdu, Tenant: /default
2025-12-09T03:43:53.583985Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 323dda4c-6ce2c19b-118bbaa6-9f349aa68, Host: ghrun-syjwtgwtdu, Tenant: /default, Request CP::GetTask with size: 68 bytes
2025-12-09T03:43:53.584023Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/default"
owner_id: "323dda4c-6ce2c19b-118bbaa6-9f349aa68"
host: "ghrun-syjwtgwtdu"
node_id: 1
}
2025-12-09T03:43:53.585949Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-09T03:43:53.585971Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 323dda4c-6ce2c19b-118bbaa6-9f349aa68, Host: ghrun-syjwtgwtdu, Tenant: /default, Got CP::GetTask Response
2025-12-09T03:43:53.586233Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:43:53.586239Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-09T03:43:54.582932Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7581698863917820456:2081]
2025-12-09T03:43:54.582947Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-09T03:43:54.582951Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7581698863917820440:2069]
2025-12-09T03:43:54.582954Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7581698863917820440:2069]
2025-12-09T03:43:54.582956Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7581698863917820440:2069]
2025-12-09T03:43:54.582960Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-09T03:43:54.583929Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 323dda4c-6ce2c19b-118bbaa6-9f349aa69, Host: ghrun-syjwtgwtdu, Tenant: /default
2025-12-09T03:43:54.584351Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 323dda4c-6ce2c19b-118bbaa6-9f349aa69, Host: ghrun-syjwtgwtdu, Tenant: /default, Request CP::GetTask with size: 68 bytes
2025-12-09T03:43:54.584386Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/default"
owner_id: "323dda4c-6ce2c19b-118bbaa6-9f349aa69"
host: "ghrun-syjwtgwtdu"
node_id: 1
}
2025-12-09T03:43:54.586268Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-09T03:43:54.586295Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 323dda4c-6ce2c19b-118bbaa6-9f349aa69, Host: ghrun-syjwtgwtdu, Tenant: /default, Got CP::GetTask Response
2025-12-09T03:43:54.586501Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:43:54.586507Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-09T03:43:55.584429Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 323dda4c-6ce2c19b-118bbaa6-9f349aa610, Host: ghrun-syjwtgwtdu, Tenant: /default
2025-12-09T03:43:55.584860Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 323dda4c-6ce2c19b-118bbaa6-9f349aa610, Host: ghrun-syjwtgwtdu, Tenant: /default, Request CP::GetTask with size: 69 bytes
2025-12-09T03:43:55.584899Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/default"
owner_id: "323dda4c-6ce2c19b-118bbaa6-9f349aa610"
host: "ghrun-syjwtgwtdu"
node_id: 1
}
2025-12-09T03:43:55.586999Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-09T03:43:55.587026Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 323dda4c-6ce2c19b-118bbaa6-9f349aa610, Host: ghrun-syjwtgwtdu, Tenant: /default, Got CP::GetTask Response
2025-12-09T03:43:55.587226Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:43:55.587234Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-09T03:43:55.590182Z :FQ_CONTROL_PLANE_CONFIG TRACE: control_plane_config.cpp:192: LOADED TenantInfo: State NOT changed
2025-12-09T03:43:56.580765Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:599: Coordinator: Send TEvGetNodesRequest to NodesManager
2025-12-09T03:43:56.580780Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-12-09T03:43:56.580959Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:300: Received TNodesManagerActor::TEvGetNodesRequest
2025-12-09T03:43:56.580976Z :FQ_ROW_DISPATCHER INFO: coordinator.cpp:690: Coordinator: Updated node info, node count: 1
2025-12-09T03:43:56.581510Z :YQ_CONTROL_PLANE_STORAGE TRACE: nodes_health_check.cpp:38: NodesHealthCheckRequest: {tenant: "/default"
node {
  node_id: 1
  instance_id: "35c66de4-409e1c92-b6739c87-39e4782e"
  hostname: "ghrun-syjwtgwtdu"
  interconnect_port: 5184
  node_address: "127.0.1.1"
}
}
2025-12-09T03:43:56.583836Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7581698863917820456:2081]
2025-12-09T03:43:56.583856Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-09T03:43:56.583864Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7581698863917820440:2069]
2025-12-09T03:43:56.583867Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7581698863917820440:2069]
2025-12-09T03:43:56.583871Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7581698863917820440:2069]
2025-12-09T03:43:56.583879Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-09T03:43:56.584860Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 323dda4c-6ce2c19b-118bbaa6-9f349aa611, Host: ghrun-syjwtgwtdu, Tenant: /default
2025-12-09T03:43:56.585285Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 323dda4c-6ce2c19b-118bbaa6-9f349aa611, Host: ghrun-syjwtgwtdu, Tenant: /default, Request CP::GetTask with size: 69 bytes
2025-12-09T03:43:56.585342Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/default"
owner_id: "323dda4c-6ce2c19b-118bbaa6-9f349aa611"
host: "ghrun-syjwtgwtdu"
node_id: 1
}
2025-12-09T03:43:56.587083Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-09T03:43:56.587114Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 323dda4c-6ce2c19b-118bbaa6-9f349aa611, Host: ghrun-syjwtgwtdu, Tenant: /default, Got CP::GetTask Response
2025-12-09T03:43:56.587382Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:43:56.587391Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-09T03:43:56.588256Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: NodesHealthCheckRequest - NodesHealthCheckResult: {nodes { node_id: 1 instance_id: "35c66de4-409e1c92-b6739c87-39e4782e" hostname: "ghrun-syjwtgwtdu" node_address: "127.0.1.1" } } SUCCESS
2025-12-09T03:43:56.588578Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:389: Send NodeInfo with size: 0 to DynamicNameserver
2025-12-09T03:43:57.585359Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 323dda4c-6ce2c19b-118bbaa6-9f349aa612, Host: ghrun-syjwtgwtdu, Tenant: /default
2025-12-09T03:43:57.585811Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 323dda4c-6ce2c19b-118bbaa6-9f349aa612, Host: ghrun-syjwtgwtdu, Tenant: /default, Request CP::GetTask with size: 69 bytes
2025-12-09T03:43:57.585859Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/default"
owner_id: "323dda4c-6ce2c19b-118bbaa6-9f349aa612"
host: "ghrun-syjwtgwtdu"
node_id: 1
}
2025-12-09T03:43:57.588177Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-09T03:43:57.588207Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 323dda4c-6ce2c19b-118bbaa6-9f349aa612, Host: ghrun-syjwtgwtdu, Tenant: /default, Got CP::GetTask Response
2025-12-09T03:43:57.588423Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:43:57.588430Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-09T03:43:58.584758Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7581698863917820456:2081]
2025-12-09T03:43:58.584796Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-09T03:43:58.584805Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7581698863917820440:2069]
2025-12-09T03:43:58.584813Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7581698863917820440:2069]
2025-12-09T03:43:58.584816Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7581698863917820440:2069]
2025-12-09T03:43:58.584832Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-09T03:43:58.585783Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 323dda4c-6ce2c19b-118bbaa6-9f349aa613, Host: ghrun-syjwtgwtdu, Tenant: /default
2025-12-09T03:43:58.586217Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 323dda4c-6ce2c19b-118bbaa6-9f349aa613, Host: ghrun-syjwtgwtdu, Tenant: /default, Request CP::GetTask with size: 69 bytes
2025-12-09T03:43:58.586254Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/default"
owner_id: "323dda4c-6ce2c19b-118bbaa6-9f349aa613"
host: "ghrun-syjwtgwtdu"
node_id: 1
}
2025-12-09T03:43:58.588490Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-09T03:43:58.588528Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 323dda4c-6ce2c19b-118bbaa6-9f349aa613, Host: ghrun-syjwtgwtdu, Tenant: /default, Got CP::GetTask Response
2025-12-09T03:43:58.588780Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:43:58.588793Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-09T03:43:58.590399Z :FQ_CONTROL_PLANE_CONFIG TRACE: control_plane_config.cpp:192: LOADED TenantInfo: State NOT changed
2025-12-09T03:43:59.586217Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 323dda4c-6ce2c19b-118bbaa6-9f349aa614, Host: ghrun-syjwtgwtdu, Tenant: /default
2025-12-09T03:43:59.586648Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 323dda4c-6ce2c19b-118bbaa6-9f349aa614, Host: ghrun-syjwtgwtdu, Tenant: /default, Request CP::GetTask with size: 69 bytes
2025-12-09T03:43:59.586695Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/default"
owner_id: "323dda4c-6ce2c19b-118bbaa6-9f349aa614"
host: "ghrun-syjwtgwtdu"
node_id: 1
}
2025-12-09T03:43:59.588770Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:456: Task (Query): ptqudqgd47iklgerf2i1 Lease TIMEOUT, RetryCounterUpdatedAt 2025-12-09T03:43:37.660594Z LastSeenAt: 2025-12-09T03:43:38.867678Z
2025-12-09T03:43:59.588780Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:463: Task (Query): ptqudqgd47iklgerf2i1 RetryRate: 0.9997205824 RetryCounter: 1 At: 2025-12-09T03:43:59.588745Z
2025-12-09T03:43:59.595120Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {tasks { query_id { value: "ptqudqgd47iklgerf2i1" } job_id { value: "ptjudqgd47ikks1vrsj4" } generation: 2 streaming: true dq_graph: "\022\313\005\010\001\022\024\n\022\t\000\000\000\000\000\000\000\000\021\000\000\000\000\000\000\000\000\032\004\010\240\215\006*\336\002Z\333\002\n\010PqSource\022\314\002\n4type.googleapis.com/NYql.NPq.NProto.TDqPqTopicSource\022\223\002\n\027select_timings_2f_input\022\024ptqudqgd47iklgerf2i1\032\016localhost:4888\"\032\n\030cluster:default_myyds_2f*\005local0\002@\001b\004Dataj\025[\"DataType\";\"String\"]\222\001\024ptcudqgd47r6f85fafmq\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\0012D\n@\010\001\020\240\234\001\030\001 \002*\024\n\022\t\000\000\000\000\000\000\000\000\021\000\000\000\000\001\000\000\0002\024\n\022\t\000\000\000\000\000\000\000\000\021\000\000\000\000\002\000\000\000P\001X\231\236\014`\256\236\014R\000:\203\001\n*type.googleapis.com/Yql.DqsProto.TTaskMeta\022U\010\231\236\014\022A\022(2ad8a0198ac871ab3cd73b3e9d43a8d7c87aa707\032\023dq_vanilla_job.lite \002\"\014\n\002pq\022\006\n\004\010\001\030\001H\231\236\014RClocal/RateLimiter_b0e8c56f-8a62-42ec-8405-5b233b311755/rate_limiterZ)mock_cloud/my_folder/ptqudqgd47iklgerf2i1`\200\200\200\200 \230\001\000\300\001\001\022\241\003\010\002\022\024\n\022\t\000\000\000\000\000\000\000\000\021\000\000\000\000\000\000\000\000\032\004\010\240\215\006*D\n@\010\001\020\240\234\001\030\001 \002*\024\n\022\t\000\000\000\000\000\000\000\000\021\000\000\000\000\001\000\000\0002\024\n\022\t\000\000\000\000\000\000\000\000\021\000\000\000\000\002\000\000\000P\001X\231\236\014`\256\236\014R\0002D\n@\010\002\020\240\234\001\030\002 \003*\024\n\022\t\000\000\000\000\000\000\000\000\021\000\000\000\000\002\000\000\0002\024\n\022\t\000\000\000\000\000\000\000\000\021\000\000\000\000\003\000\000\000P\001X\256\236\014`\277\236\014R\000:u\n*type.googleapis.com/Yql.DqsProto.TTaskMeta\022G\010\256\236\014\022A\022(2ad8a0198ac871ab3cd73b3e9d43a8d7c87aa707\032\023dq_vanilla_job.lite \002H\256\236\014RClocal/RateLimiter_b0e8c56f-8a62-42ec-8405-5b233b311755/rate_limiterZ)mock_cloud/my_folder/ptqudqgd47iklgerf2i1`\200\200\200\200 \230\001\000\300\001\001\022\227\003\010\003\022\024\n\022\t\000\000\000\000\000\000\000\000\021\000\000\000\000\000\000\000\000\032\004\010\240\215\006*D\n@\010\002\020\240\234\001\030\002 \003*\024\n\022\t\000\000\000\000\000\000\000\000\021\000\000\000\000\002\000\000\0002\024\n\022\t\000\000\000\000\000\000\000\000\021\000\000\000\000\003\000\000\000P\001X\256\236\014`\277\236\014R\0002:\n6\010\003\020\240\234\001\030\003*\024\n\022\t\000\000\000\000\000\000\000\000\021\000\000\000\000\003\000\000\0002\024\n\022\t\001\000\000\000\000\000\000\000\021\000\000\000\000\001\000\000\000P\001R\000:u\n*type.googleapis.com/Yql.DqsProto.TTaskMeta\022G\010\277\236\014\022A\022(2ad8a0198ac871ab3cd73b3e9d43a8d7c87aa707\032\023dq_vanilla_job.lite \002H\277\236\014RClocal/RateLimiter_b0e8c56f-8a62-42ec-8405-5b233b311755/rate_limiterZ)mock_cloud/my_folder/ptqudqgd47iklgerf2i1`\200\200\200\200 \230\001\000\300\001\001\030\002\"\r\037\000\205\002\203\005@\020Data/*\004Data2qptqudqgd47iklgerf2i1#ptrudqgd46p09uqrv22g#yandexcloud://my_folder#5b0dfe77-e3652039-a7229327-b5b5424c4#mock_cloud:\027\n\016FallbackPolicy\022\005never:\024\n\017_LiteralTimeout\022\0010:\022\n\r_TableTimeout\022\0010:\037\n\025_AllResultsBytesLimit\022\006100000:\032\n\022_RowsLimitPerWrite\022\0041000:\027\n\022EnableComputeActor\022\0011:\016\n\014WorkerFilter:\031\n\020ComputeActorType\022\005async:\031\n\016WatermarksMode\022\007disable:\037\n\027WatermarksGranularityMs\022\0041000:$\n\034WatermarksLateArrivalDelayMs\022\0045000:\027\n\022EnableChannelStats\022\0011:\020\n\013ExportStats\022\0011B*\n\030cluster:default_myyds_2f\022\016{\"no_auth\":\"\"}bR\010\277\236\014\022L\037\002\006Arg\005\205\006\213\002\204\205\002\203\005@\020Data\205\000?\004\030Inputs(Parameters\034Program\013?\006)\251\000?\004\002\000\0...} SUCCESS
2025-12-09T03:43:59.595150Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 323dda4c-6ce2c19b-118bbaa6-9f349aa614, Host: ghrun-syjwtgwtdu, Tenant: /default, Got CP::GetTask Response
2025-12-09T03:43:59.595417Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:43:59.595425Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 1
2025-12-09T03:43:59.595434Z :FQ_PENDING_FETCHER DEBUG: pending_fetcher.cpp:361: NewTask: Scope: yandexcloud://my_folder Id: ptqudqgd47iklgerf2i1 UserId: root@builtin AuthToken: **** (B6C6F477)
2025-12-09T03:43:59.595541Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:375: QueryId: ptqudqgd47iklgerf2i1 Start run actor. Compute state: RUNNING
2025-12-09T03:43:59.595546Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:469: QueryId: ptqudqgd47iklgerf2i1 FillConnections
2025-12-09T03:43:59.595546Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 323dda4c-6ce2c19b-118bbaa6-9f349aa615, Host: ghrun-syjwtgwtdu, Tenant: /default
2025-12-09T03:43:59.595562Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:2333: QueryId: ptqudqgd47iklgerf2i1 Run actors params: { QueryId: ptqudqgd47iklgerf2i1 CloudId: mock_cloud UserId: root@builtin Owner: 323dda4c-6ce2c19b-118bbaa6-9f349aa614 PreviousQueryRevision: 2 Connections: 1 Bindings: 0 AccountIdSignatures: 0 QueryType: STREAMING ExecuteMode: RUN ResultId: ptrudqgd3iir1q3i5nvf StateLoadMode: FROM_LAST_CHECKPOINT StreamingDisposition: { from_last_checkpoint { } } Status: RUNNING DqGraphs: 1 DqGraphIndex: 0 Resource.TopicConsumers: 1 }
2025-12-09T03:43:59.595574Z :FQ_PINGER TRACE: pinger.cpp:171: QueryId: ptqudqgd47iklgerf2i1, Owner: 323dda4c-6ce2c19b-118bbaa6-9f349aa614 Start Pinger
2025-12-09T03:43:59.595605Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:911: QueryId: ptqudqgd47iklgerf2i1 Overall dq tasks: 3
2025-12-09T03:43:59.595645Z :FQ_PINGER TRACE: pinger.cpp:250: QueryId: ptqudqgd47iklgerf2i1, Owner: 323dda4c-6ce2c19b-118bbaa6-9f349aa614 Forward ping request: { resources { rate_limiter: READY compilation: READY topic_consumers_state: READY rate_limiter_path: "local/RateLimiter_b0e8c56f-8a62-42ec-8405-5b233b311755/rate_limiter" topic_consumers { database: "local" topic_path: "select_timings_2f_input" consumer_name: "ptqudqgd47iklgerf2i1" cluster_endpoint: "localhost:4888" token_name: "cluster:default_myyds_2f" add_bearer_to_token: true } } }
2025-12-09T03:43:59.595655Z :FQ_PINGER TRACE: pinger.cpp:393: QueryId: ptqudqgd47iklgerf2i1, Owner: 323dda4c-6ce2c19b-118bbaa6-9f349aa614 Forward request Private::PingTask
2025-12-09T03:43:59.595842Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 323dda4c-6ce2c19b-118bbaa6-9f349aa615, Host: ghrun-syjwtgwtdu, Tenant: /default, Request CP::GetTask with size: 69 bytes
2025-12-09T03:43:59.595871Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/default"
owner_id: "323dda4c-6ce2c19b-118bbaa6-9f349aa615"
host: "ghrun-syjwtgwtdu"
node_id: 1
}
2025-12-09T03:43:59.595929Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudqgd47iklgerf2i1, Owner: 323dda4c-6ce2c19b-118bbaa6-9f349aa614, Request CP::PingTask with size: 294 bytes
2025-12-09T03:43:59.595982Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "323dda4c-6ce2c19b-118bbaa6-9f349aa614"
query_id {
  value: "ptqudqgd47iklgerf2i1"
}
resources {
  rate_limiter: READY
  compilation: READY
  topic_consumers_state: READY
  rate_limiter_path: "local/RateLimiter_b0e8c56f-8a62-42ec-8405-5b233b311755/rate_limiter"
  topic_consumers {
    database: "local"
    topic_path: "select_timings_2f_input"
    consumer_name: "ptqudqgd47iklgerf2i1"
    cluster_endpoint: "localhost:4888"
    token_name: "cluster:default_myyds_2f"
    add_bearer_to_token: true
  }
}
scope: "yandexcloud://my_folder"
deadline {
  seconds: 1765338239
  nanos: 590988000
}
tenant: "/default"
}
2025-12-09T03:43:59.597429Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-09T03:43:59.597457Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 323dda4c-6ce2c19b-118bbaa6-9f349aa615, Host: ghrun-syjwtgwtdu, Tenant: /default, Got CP::GetTask Response
2025-12-09T03:43:59.597693Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:43:59.597700Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-09T03:43:59.603043Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {expired_at { seconds: 1765251859 nanos: 599000000 } } SUCCESS
2025-12-09T03:43:59.603071Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudqgd47iklgerf2i1, Owner: 323dda4c-6ce2c19b-118bbaa6-9f349aa614, Got CP::PingTaskResponse
2025-12-09T03:43:59.603315Z :FQ_PINGER TRACE: pinger.cpp:338: QueryId: ptqudqgd47iklgerf2i1, Owner: 323dda4c-6ce2c19b-118bbaa6-9f349aa614 Ping response success: { expired_at { seconds: 1765251859 nanos: 599000000 } }
2025-12-09T03:43:59.615853Z :FQ_RESULT_WRITER INFO: result_writer.cpp:62: TraceId: ptqudqgd47iklgerf2i1#ptrudqgd46p09uqrv22g#yandexcloud://my_folder#5b0dfe77-e3652039-a7229327-b5b5424c4#mock_cloud Bootstrap
2025-12-09T03:43:59.615931Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudqgd47iklgerf2i1 2025-12-09 03:43:59.615 DEBUG ydbd(pid=1648981, tid=0x00007FEE50268640) [DQ] task_controller_impl.h:83: _AllResultsBytesLimit = 100000
2025-12-09T03:43:59.615944Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudqgd47iklgerf2i1 2025-12-09 03:43:59.615 DEBUG ydbd(pid=1648981, tid=0x00007FEE50268640) [DQ] task_controller_impl.h:86: _RowsLimitPerWrite = 1000
2025-12-09T03:43:59.615997Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:1652: QueryId: ptqudqgd47iklgerf2i1 Executer: [1:7581698919752395652:2409], Controller: [1:7581698919752395661:2418], ResultIdActor: [1:7581698919752395659:2416]
2025-12-09T03:43:59.616028Z :FQ_RUN_ACTOR TRACE: run_actor.cpp:861: QueryId: ptqudqgd47iklgerf2i1 Forward ping response. Success: 1. Cookie: 0
2025-12-09T03:43:59.616033Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudqgd47iklgerf2i1 2025-12-09 03:43:59.616 DEBUG ydbd(pid=1648981, tid=0x00007FEE5126A640) [DQ] executer_actor.cpp:140: {ptqudqgd47iklgerf2i1} TDqExecuter::OnGraph
2025-12-09T03:43:59.616046Z :YQL_PROXY INFO: log.cpp:64: SessionId: ptqudqgd47iklgerf2i1 2025-12-09 03:43:59.616 INFO  ydbd(pid=1648981, tid=0x00007FEE5126A640) [DQ] executer_actor.cpp:157: {ptqudqgd47iklgerf2i1} Trying to allocate 3 workers [EnableComputeActor=1]
2025-12-09T03:43:59.617045Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudqgd47iklgerf2i1 2025-12-09 03:43:59.617 DEBUG ydbd(pid=1648981, tid=0x00007FEE5126A640) [DQ] executer_actor.cpp:247: {ptqudqgd47iklgerf2i1} Dq timeouts are set to: 0.000000s (global), 600.000000s (workers allocation fail), 30.000000s (workers allocation warn) 
2025-12-09T03:43:59.617561Z :YQL_NODES_MANAGER DEBUG: nodes_manager.cpp:125: TEvAllocateWorkersResponse Nodes {
  ResourceId: 4294967297
  Worker {
    NodeId: 1
    Guid: "35c66de4-409e1c92-b6739c87-39e4782e,ghrun-syjwtgwtdu"
  }
  Worker {
    NodeId: 1
    Guid: "35c66de4-409e1c92-b6739c87-39e4782e,ghrun-syjwtgwtdu"
  }
  Worker {
    NodeId: 1
    Guid: "35c66de4-409e1c92-b6739c87-39e4782e,ghrun-syjwtgwtdu"
  }
}
2025-12-09T03:43:59.617670Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: 323dda4c-6ce2c19b-118bbaa6-9f349aa6 2025-12-09 03:43:59.617 DEBUG ydbd(pid=1648981, tid=0x00007FEE50268640) [DQ] local_worker_manager.cpp:316: {ptqudqgd47iklgerf2i1} TLocalWorkerManager::TEvAllocateWorkersRequest 562954248388609
2025-12-09T03:43:59.617690Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: 323dda4c-6ce2c19b-118bbaa6-9f349aa6 2025-12-09 03:43:59.617 DEBUG ydbd(pid=1648981, tid=0x00007FEE50268640) [DQ] local_worker_manager.cpp:376: {ptqudqgd47iklgerf2i1} Create compute actor: async
2025-12-09T03:43:59.617800Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: 323dda4c-6ce2c19b-118bbaa6-9f349aa6 2025-12-09 03:43:59.617 DEBUG ydbd(pid=1648981, tid=0x00007FEE50268640) [DQ] local_worker_manager.cpp:316: {ptqudqgd47iklgerf2i1} TLocalWorkerManager::TEvAllocateWorkersRequest 844429225099265
2025-12-09T03:43:59.617812Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: 323dda4c-6ce2c19b-118bbaa6-9f349aa6 2025-12-09 03:43:59.617 DEBUG ydbd(pid=1648981, tid=0x00007FEE50268640) [DQ] local_worker_manager.cpp:376: {ptqudqgd47iklgerf2i1} Create compute actor: async
2025-12-09T03:43:59.617811Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:144: SelfId: [1:7581698919752395663:2420], TxId: ptqudqgd47iklgerf2i1, task: 2. Ctx: {}. Start compute actor [1:7581698919752395663:2420], task: 2
2025-12-09T03:43:59.617840Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:114: SelfId: [1:7581698919752395663:2420], TxId: ptqudqgd47iklgerf2i1, task: 2. Ctx: {}. Use CPU quota: 1. Rate limiter resource: { "local/RateLimiter_b0e8c56f-8a62-42ec-8405-5b233b311755/rate_limiter", "mock_cloud/my_folder/ptqudqgd47iklgerf2i1" }
2025-12-09T03:43:59.617860Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: 323dda4c-6ce2c19b-118bbaa6-9f349aa6 2025-12-09 03:43:59.617 DEBUG ydbd(pid=1648981, tid=0x00007FEE50268640) [DQ] local_worker_manager.cpp:316: {ptqudqgd47iklgerf2i1} TLocalWorkerManager::TEvAllocateWorkersRequest 281479271677953
2025-12-09T03:43:59.617868Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: 323dda4c-6ce2c19b-118bbaa6-9f349aa6 2025-12-09 03:43:59.617 DEBUG ydbd(pid=1648981, tid=0x00007FEE50268640) [DQ] local_worker_manager.cpp:376: {ptqudqgd47iklgerf2i1} Create compute actor: async
2025-12-09T03:43:59.617878Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:144: SelfId: [1:7581698919752395666:2421], TxId: ptqudqgd47iklgerf2i1, task: 3. Ctx: {}. Start compute actor [1:7581698919752395666:2421], task: 3
2025-12-09T03:43:59.617898Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:114: SelfId: [1:7581698919752395666:2421], TxId: ptqudqgd47iklgerf2i1, task: 3. Ctx: {}. Use CPU quota: 1. Rate limiter resource: { "local/RateLimiter_b0e8c56f-8a62-42ec-8405-5b233b311755/rate_limiter", "mock_cloud/my_folder/ptqudqgd47iklgerf2i1" }
2025-12-09T03:43:59.617904Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: 323dda4c-6ce2c19b-118bbaa6-9f349aa6 2025-12-09 03:43:59.617 DEBUG ydbd(pid=1648981, tid=0x00007FEE50268640) [DQ] resource_allocator.cpp:141: {ptqudqgd47iklgerf2i1/[1:7581698919752395662:2419]} TEvAllocateWorkersResponse 1
2025-12-09T03:43:59.617920Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudqgd47iklgerf2i1 2025-12-09 03:43:59.617 DEBUG ydbd(pid=1648981, tid=0x00007FEE50268640) [DQ] executer_actor.cpp:358: {ptqudqgd47iklgerf2i1} TDqExecuter::TEvAllocateWorkersResponse
2025-12-09T03:43:59.617937Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudqgd47iklgerf2i1 2025-12-09 03:43:59.617 DEBUG ydbd(pid=1648981, tid=0x00007FEE50268640) [DQ] executer_actor.cpp:384: {ptqudqgd47iklgerf2i1} Allocated resource 4294967297
2025-12-09T03:43:59.617959Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudqgd47iklgerf2i1 2025-12-09 03:43:59.617 DEBUG ydbd(pid=1648981, tid=0x00007FEE50268640) [DQ] executer_actor.cpp:401: {ptqudqgd47iklgerf2i1} WorkerInfo: Id:35c66de4-409e1c92-b6739c87-39e4782e,ghrun-syjwtgwtdu,NodeId:1,StageId:200473
2025-12-09T03:43:59.617967Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudqgd47iklgerf2i1 2025-12-09 03:43:59.617 DEBUG ydbd(pid=1648981, tid=0x00007FEE50268640) [DQ] executer_actor.cpp:402: {ptqudqgd47iklgerf2i1} TaskInfo: 0/1
2025-12-09T03:43:59.617970Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudqgd47iklgerf2i1 2025-12-09 03:43:59.617 DEBUG ydbd(pid=1648981, tid=0x00007FEE50268640) [DQ] executer_actor.cpp:404: {ptqudqgd47iklgerf2i1}  ObjectId: 2ad8a0198ac871ab3cd73b3e9d43a8d7c87aa707, dq_vanilla_job.lite, 
2025-12-09T03:43:59.617982Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudqgd47iklgerf2i1 2025-12-09 03:43:59.617 DEBUG ydbd(pid=1648981, tid=0x00007FEE50268640) [DQ] executer_actor.cpp:401: {ptqudqgd47iklgerf2i1} WorkerInfo: Id:35c66de4-409e1c92-b6739c87-39e4782e,ghrun-syjwtgwtdu,NodeId:1,StageId:200494
2025-12-09T03:43:59.617985Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudqgd47iklgerf2i1 2025-12-09 03:43:59.617 DEBUG ydbd(pid=1648981, tid=0x00007FEE50268640) [DQ] executer_actor.cpp:402: {ptqudqgd47iklgerf2i1} TaskInfo: 1/2
2025-12-09T03:43:59.617998Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudqgd47iklgerf2i1 2025-12-09 03:43:59.617 DEBUG ydbd(pid=1648981, tid=0x00007FEE50268640) [DQ] executer_actor.cpp:404: {ptqudqgd47iklgerf2i1}  ObjectId: 2ad8a0198ac871ab3cd73b3e9d43a8d7c87aa707, dq_vanilla_job.lite, 
2025-12-09T03:43:59.618013Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudqgd47iklgerf2i1 2025-12-09 03:43:59.618 DEBUG ydbd(pid=1648981, tid=0x00007FEE50268640) [DQ] executer_actor.cpp:401: {ptqudqgd47iklgerf2i1} WorkerInfo: Id:35c66de4-409e1c92-b6739c87-39e4782e,ghrun-syjwtgwtdu,NodeId:1,StageId:200511
2025-12-09T03:43:59.618019Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudqgd47iklgerf2i1 2025-12-09 03:43:59.618 DEBUG ydbd(pid=1648981, tid=0x00007FEE50268640) [DQ] executer_actor.cpp:402: {ptqudqgd47iklgerf2i1} TaskInfo: 2/3
2025-12-09T03:43:59.618029Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudqgd47iklgerf2i1 2025-12-09 03:43:59.618 DEBUG ydbd(pid=1648981, tid=0x00007FEE50268640) [DQ] executer_actor.cpp:404: {ptqudqgd47iklgerf2i1}  ObjectId: 2ad8a0198ac871ab3cd73b3e9d43a8d7c87aa707, dq_vanilla_job.lite, 
2025-12-09T03:43:59.618037Z :YQL_PROXY INFO: log.cpp:64: SessionId: ptqudqgd47iklgerf2i1 2025-12-09 03:43:59.618 INFO  ydbd(pid=1648981, tid=0x00007FEE50268640) [DQ] executer_actor.cpp:415: {ptqudqgd47iklgerf2i1} 3 workers allocated
2025-12-09T03:43:59.618112Z :YQL_PROXY TRACE: log.cpp:64: SessionId:  2025-12-09 03:43:59.618 TRACE ydbd(pid=1648981, tid=0x00007FEE50268640) [DQ] task_controller_impl.h:271:  [1:7581698919752395661:2418] ExportStats Summary
2025-12-09T03:43:59.618145Z :YQL_PROXY DEBUG: log.cpp:64: SessionId:  2025-12-09 03:43:59.618 DEBUG ydbd(pid=1648981, tid=0x00007FEE50268640) [DQ] task_controller_impl.h:526: Ready State: [1:7581698919752395661:2418]
2025-12-09T03:43:59.618156Z :YQL_PROXY DEBUG: log.cpp:64: SessionId:  2025-12-09 03:43:59.618 DEBUG ydbd(pid=1648981, tid=0x00007FEE50268640) [DQ] task_controller_impl.h:537: Forward: [1:7581698919752395661:2418] to [1:7581698919752395660:2417]
2025-12-09T03:43:59.618172Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:144: SelfId: [1:7581698919752395669:2422], TxId: ptqudqgd47iklgerf2i1, task: 1. Ctx: {}. Start compute actor [1:7581698919752395669:2422], task: 1
2025-12-09T03:43:59.618182Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:114: SelfId: [1:7581698919752395669:2422], TxId: ptqudqgd47iklgerf2i1, task: 1. Ctx: {}. Use CPU quota: 1. Rate limiter resource: { "local/RateLimiter_b0e8c56f-8a62-42ec-8405-5b233b311755/rate_limiter", "mock_cloud/my_folder/ptqudqgd47iklgerf2i1" }
2025-12-09T03:43:59.618207Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: 323dda4c-6ce2c19b-118bbaa6-9f349aa6 2025-12-09 03:43:59.618 DEBUG ydbd(pid=1648981, tid=0x00007FEE50268640) [DQ] tasks_runner_local.cpp:267: {TODO/1} Build task: 1
2025-12-09T03:43:59.618275Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: 323dda4c-6ce2c19b-118bbaa6-9f349aa6 2025-12-09 03:43:59.618 DEBUG ydbd(pid=1648981, tid=0x00007FEE50268640) [DQ] tasks_runner_local.cpp:267: {TODO/1} task: 1, program size: 40, llvm: ``.
2025-12-09T03:43:59.619993Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:70: [ptqudqgd47iklgerf2i1-0.2] TEvReadyState, streaming disposition { from_last_checkpoint { } }, state load mode FROM_LAST_CHECKPOINT, checkpointing period 1.000000s
2025-12-09T03:43:59.620011Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:104: [ptqudqgd47iklgerf2i1-0.2] AllActors count: 3, ActorsToTrigger count: 1, ActorsToNotify count: 1, ActorsToWaitFor count: 3
2025-12-09T03:43:59.620013Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:114: [ptqudqgd47iklgerf2i1-0.2] Send TEvRegisterCoordinatorRequest
2025-12-09T03:43:59.620036Z :YQL_PROXY TRACE: log.cpp:64: SessionId:  2025-12-09 03:43:59.620 TRACE ydbd(pid=1648981, tid=0x00007FEE5126A640) [DQ] task_controller_impl.h:160: [1:7581698919752395661:2418] EvState TaskId: 3 State: 2 PingCookie: 0 StatusCode: UNSPECIFIED
2025-12-09T03:43:59.620043Z :YQL_PROXY TRACE: log.cpp:64: SessionId:  2025-12-09 03:43:59.620 TRACE ydbd(pid=1648981, tid=0x00007FEE5126A640) [DQ] task_controller_impl.h:201:  [1:7581698919752395661:2418] Executing TaskId: 3
2025-12-09T03:43:59.620053Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:261: [ptqudqgd47iklgerf2i1-0.2] Got TEvRegisterCoordinatorRequest
2025-12-09T03:43:59.620055Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:243: StartInitialization, EnableSecureScriptExecutions: 0
2025-12-09T03:43:59.620486Z :STREAMS_STORAGE_SERVICE NOTICE: storage_proxy.cpp:585: Add to delayed
2025-12-09T03:43:59.623680Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:557: Checkpoint storage and state storage were successfully initted
2025-12-09T03:43:59.623691Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:261: [ptqudqgd47iklgerf2i1-0.2] Got TEvRegisterCoordinatorRequest
2025-12-09T03:43:59.630752Z :YQL_PROXY TRACE: log.cpp:64: SessionId:  2025-12-09 03:43:59.630 TRACE ydbd(pid=1648981, tid=0x00007FEE5126A640) [DQ] task_controller_impl.h:160: [1:7581698919752395661:2418] EvState TaskId: 2 State: 2 PingCookie: 0 StatusCode: UNSPECIFIED
2025-12-09T03:43:59.630767Z :YQL_PROXY TRACE: log.cpp:64: SessionId:  2025-12-09 03:43:59.630 TRACE ydbd(pid=1648981, tid=0x00007FEE5126A640) [DQ] task_controller_impl.h:201:  [1:7581698919752395661:2418] Executing TaskId: 2
2025-12-09T03:43:59.640606Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:279: [ptqudqgd47iklgerf2i1-0.2] Graph registered
2025-12-09T03:43:59.640614Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:281: [ptqudqgd47iklgerf2i1-0.2] Send TEvRegisterCoordinatorResponse
2025-12-09T03:43:59.640642Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:131: [ptqudqgd47iklgerf2i1-0.2] Got TEvRegisterCoordinatorResponse; issues: 
2025-12-09T03:43:59.640645Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:140: [ptqudqgd47iklgerf2i1-0.2] Successfully registered in storage
2025-12-09T03:43:59.640647Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:141: [ptqudqgd47iklgerf2i1-0.2] Send TEvNewCheckpointCoordinator to 3 actor(s)
2025-12-09T03:43:59.640661Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:149: [ptqudqgd47iklgerf2i1-0.2] Send TEvGetCheckpointsMetadataRequest; state load mode: FROM_LAST_CHECKPOINT; load graph: 0
2025-12-09T03:43:59.640693Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:197: [] Task: 3. Got TEvNewCheckpointCoordinator event: generation 2, actorId: [1:7581698919752395660:2417]
2025-12-09T03:43:59.640695Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:197: [] Task: 2. Got TEvNewCheckpointCoordinator event: generation 2, actorId: [1:7581698919752395660:2417]
2025-12-09T03:43:59.640697Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:208: [] Task: 2. Assign checkpoint coordinator (generation = 2)
2025-12-09T03:43:59.640699Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:208: [] Task: 3. Assign checkpoint coordinator (generation = 2)
2025-12-09T03:43:59.640704Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:434: [ptqudqgd47iklgerf2i1-0] Got TEvGetCheckpointsMetadataRequest
2025-12-09T03:43:59.652662Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: 323dda4c-6ce2c19b-118bbaa6-9f349aa6 2025-12-09 03:43:59.652 DEBUG ydbd(pid=1648981, tid=0x00007FEE50268640) [DQ] tasks_runner_local.cpp:267: {TODO/1} Build task: 1 takes 34423 us
2025-12-09T03:43:59.652680Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: 323dda4c-6ce2c19b-118bbaa6-9f349aa6 2025-12-09 03:43:59.652 DEBUG ydbd(pid=1648981, tid=0x00007FEE50268640) [DQ] tasks_runner_local.cpp:267: {TODO/1} Prepare task: 1
2025-12-09T03:43:59.652699Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: 323dda4c-6ce2c19b-118bbaa6-9f349aa6 2025-12-09 03:43:59.652 DEBUG ydbd(pid=1648981, tid=0x00007FEE50268640) [DQ] tasks_runner_local.cpp:267: {TODO/1} Prepare task: 1, takes 14 us
2025-12-09T03:43:59.652747Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:197: [] Task: 1. Got TEvNewCheckpointCoordinator event: generation 2, actorId: [1:7581698919752395660:2417]
2025-12-09T03:43:59.652752Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:208: [] Task: 1. Assign checkpoint coordinator (generation = 2)
2025-12-09T03:43:59.653181Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1360: SelfId: [1:7581698919752395669:2422], TxId: ptqudqgd47iklgerf2i1, task: 1. Ctx: {}. Create source for input 0 { Source { Type: "PqSource" Settings { type_url: "type.googleapis.com/NYql.NPq.NProto.TDqPqTopicSource" value: "\n\027select_timings_2f_input\022\024ptqudqgd47iklgerf2i1\032\016localhost:4888\"\032\n\030cluster:default_myyds_2f*\005local0\002@\001b\004Dataj\025[\"DataType\";\"String\"]\222\001\024ptcudqgd47r6f85fafmq\232\001\003raw\242\001/[\"StructType\";[[\"Data\";[\"DataType\";\"String\"]]]]\262\001\002\022\000\272\001\026\n\010cloud_id\022\nmock_cloud\272\001 \n\005scope\022\027yandexcloud://my_folder" } WatermarksMode: WATERMARKS_MODE_DISABLED } }
2025-12-09T03:43:59.653401Z :KQP_COMPUTE DEBUG: dq_pq_read_actor_base.cpp:153: SelfId: [0:0:0], TxId: ptqudqgd47iklgerf2i1, task: 1. PQ source. SessionId: empty Watermarks enabled: 0 granularity: 0.000000s late arrival delay: 0.000000s idle: 0 idle timeout: 0.000000s
2025-12-09T03:43:59.653428Z :YQL_PROXY TRACE: log.cpp:64: SessionId:  2025-12-09 03:43:59.653 TRACE ydbd(pid=1648981, tid=0x00007FEE50268640) [DQ] task_controller_impl.h:160: [1:7581698919752395661:2418] EvState TaskId: 1 State: 2 PingCookie: 0 StatusCode: UNSPECIFIED
2025-12-09T03:43:59.653436Z :YQL_PROXY TRACE: log.cpp:64: SessionId:  2025-12-09 03:43:59.653 TRACE ydbd(pid=1648981, tid=0x00007FEE50268640) [DQ] task_controller_impl.h:201:  [1:7581698919752395661:2418] Executing TaskId: 1
2025-12-09T03:43:59.653448Z :YQL_PROXY DEBUG: log.cpp:64: SessionId:  2025-12-09 03:43:59.653 DEBUG ydbd(pid=1648981, tid=0x00007FEE50268640) [DQ] task_controller_impl.h:561: Update channels
2025-12-09T03:43:59.653776Z :YQL_PROXY TRACE: log.cpp:64: SessionId:  2025-12-09 03:43:59.653 TRACE ydbd(pid=1648981, tid=0x00007FEE50268640) [DQ] task_controller_impl.h:577: 1 Update { Id: 1 TransportVersion: DATA_TRANSPORT_UV_PICKLE_1_0 SrcTaskId: 1 DstTaskId: 2 SrcEndpoint { ActorId { RawX1: 7581698919752395669 RawX2: 4503603922340214 } } DstEndpoint { ActorId { RawX1: 7581698919752395663 RawX2: 4503603922340212 } } WatermarksMode: WATERMARKS_MODE_DISABLED SrcStageId: 200473 DstStageId: 200494 }
2025-12-09T03:43:59.653800Z :YQL_PROXY TRACE: log.cpp:64: SessionId:  2025-12-09 03:43:59.653 TRACE ydbd(pid=1648981, tid=0x00007FEE50268640) [DQ] task_controller_impl.h:577: 2 Update { Id: 1 TransportVersion: DATA_TRANSPORT_UV_PICKLE_1_0 SrcTaskId: 1 DstTaskId: 2 SrcEndpoint { ActorId { RawX1: 7581698919752395669 RawX2: 4503603922340214 } } DstEndpoint { ActorId { RawX1: 7581698919752395663 RawX2: 4503603922340212 } } WatermarksMode: WATERMARKS_MODE_DISABLED SrcStageId: 200473 DstStageId: 200494 } Update { Id: 2 TransportVersion: DATA_TRANSPORT_UV_PICKLE_1_0 SrcTaskId: 2 DstTaskId: 3 SrcEndpoint { ActorId { RawX1: 7581698919752395663 RawX2: 4503603922340212 } } DstEndpoint { ActorId { RawX1: 7581698919752395666 RawX2: 4503603922340213 } } WatermarksMode: WATERMARKS_MODE_DISABLED SrcStageId: 200494 DstStageId: 200511 }
2025-12-09T03:43:59.653818Z :YQL_PROXY TRACE: log.cpp:64: SessionId:  2025-12-09 03:43:59.653 TRACE ydbd(pid=1648981, tid=0x00007FEE50268640) [DQ] task_controller_impl.h:577: 3 Update { Id: 2 TransportVersion: DATA_TRANSPORT_UV_PICKLE_1_0 SrcTaskId: 2 DstTaskId: 3 SrcEndpoint { ActorId { RawX1: 7581698919752395663 RawX2: 4503603922340212 } } DstEndpoint { ActorId { RawX1: 7581698919752395666 RawX2: 4503603922340213 } } WatermarksMode: WATERMARKS_MODE_DISABLED SrcStageId: 200494 DstStageId: 200511 } Update { Id: 3 TransportVersion: DATA_TRANSPORT_UV_PICKLE_1_0 SrcTaskId: 3 SrcEndpoint { ActorId { RawX1: 7581698919752395666 RawX2: 4503603922340213 } } DstEndpoint { ActorId { RawX1: 7581698919752395659 RawX2: 4503603922340208 } } WatermarksMode: WATERMARKS_MODE_DISABLED }
2025-12-09T03:43:59.653829Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1064: SelfId: [1:7581698919752395669:2422], TxId: ptqudqgd47iklgerf2i1, task: 1. Ctx: {}. Received channels info: Update { Id: 1 TransportVersion: DATA_TRANSPORT_UV_PICKLE_1_0 SrcTaskId: 1 DstTaskId: 2 SrcEndpoint { ActorId { RawX1: 7581698919752395669 RawX2: 4503603922340214 } } DstEndpoint { ActorId { RawX1: 7581698919752395663 RawX2: 4503603922340212 } } WatermarksMode: WATERMARKS_MODE_DISABLED SrcStageId: 200473 DstStageId: 200494 }
2025-12-09T03:43:59.653833Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1083: SelfId: [1:7581698919752395669:2422], TxId: ptqudqgd47iklgerf2i1, task: 1. Ctx: {}. Update output channelId: 1, peer: [1:7581698919752395663:2420]
2025-12-09T03:43:59.653834Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1064: SelfId: [1:7581698919752395666:2421], TxId: ptqudqgd47iklgerf2i1, task: 3. Ctx: {}. Received channels info: Update { Id: 2 TransportVersion: DATA_TRANSPORT_UV_PICKLE_1_0 SrcTaskId: 2 DstTaskId: 3 SrcEndpoint { ActorId { RawX1: 7581698919752395663 RawX2: 4503603922340212 } } DstEndpoint { ActorId { RawX1: 7581698919752395666 RawX2: 4503603922340213 } } WatermarksMode: WATERMARKS_MODE_DISABLED SrcStageId: 200494 DstStageId: 200511 } Update { Id: 3 TransportVersion: DATA_TRANSPORT_UV_PICKLE_1_0 SrcTaskId: 3 SrcEndpoint { ActorId { RawX1: 7581698919752395666 RawX2: 4503603922340213 } } DstEndpoint { ActorId { RawX1: 7581698919752395659 RawX2: 4503603922340208 } } WatermarksMode: WATERMARKS_MODE_DISABLED }
2025-12-09T03:43:59.653836Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1071: SelfId: [1:7581698919752395666:2421], TxId: ptqudqgd47iklgerf2i1, task: 3. Ctx: {}. Update input channelId: 2, peer: [1:7581698919752395663:2420]
2025-12-09T03:43:59.653838Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1083: SelfId: [1:7581698919752395666:2421], TxId: ptqudqgd47iklgerf2i1, task: 3. Ctx: {}. Update output channelId: 3, peer: [1:7581698919752395659:2416]
2025-12-09T03:43:59.653840Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1064: SelfId: [1:7581698919752395663:2420], TxId: ptqudqgd47iklgerf2i1, task: 2. Ctx: {}. Received channels info: Update { Id: 1 TransportVersion: DATA_TRANSPORT_UV_PICKLE_1_0 SrcTaskId: 1 DstTaskId: 2 SrcEndpoint { ActorId { RawX1: 7581698919752395669 RawX2: 4503603922340214 } } DstEndpoint { ActorId { RawX1: 7581698919752395663 RawX2: 4503603922340212 } } WatermarksMode: WATERMARKS_MODE_DISABLED SrcStageId: 200473 DstStageId: 200494 } Update { Id: 2 TransportVersion: DATA_TRANSPORT_UV_PICKLE_1_0 SrcTaskId: 2 DstTaskId: 3 SrcEndpoint { ActorId { RawX1: 7581698919752395663 RawX2: 4503603922340212 } } DstEndpoint { ActorId { RawX1: 7581698919752395666 RawX2: 4503603922340213 } } WatermarksMode: WATERMARKS_MODE_DISABLED SrcStageId: 200494 DstStageId: 200511 }
2025-12-09T03:43:59.653843Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1071: SelfId: [1:7581698919752395663:2420], TxId: ptqudqgd47iklgerf2i1, task: 2. Ctx: {}. Update input channelId: 1, peer: [1:7581698919752395669:2422]
2025-12-09T03:43:59.653845Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1083: SelfId: [1:7581698919752395663:2420], TxId: ptqudqgd47iklgerf2i1, task: 2. Ctx: {}. Update output channelId: 2, peer: [1:7581698919752395666:2421]
2025-12-09T03:43:59.679088Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:451: [ptqudqgd47iklgerf2i1-0] Send TEvGetCheckpointsMetadataResponse
2025-12-09T03:43:59.679131Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:186: [ptqudqgd47iklgerf2i1-0.2] Got TEvGetCheckpointsMetadataResponse
2025-12-09T03:43:59.679136Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:219: [ptqudqgd47iklgerf2i1-0.2] Will restore from checkpoint 1:1
2025-12-09T03:43:59.679328Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:265: [ptqudqgd47iklgerf2i1-0] Task: 2. [Checkpoint 1.1] TEvRestoreFromCheckpoint, StateLoadPlan = { StateType: STATE_TYPE_OWN }
2025-12-09T03:43:59.679336Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:265: [ptqudqgd47iklgerf2i1-0] Task: 1. [Checkpoint 1.1] TEvRestoreFromCheckpoint, StateLoadPlan = { StateType: STATE_TYPE_OWN }
2025-12-09T03:43:59.679342Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:265: [ptqudqgd47iklgerf2i1-0] Task: 3. [Checkpoint 1.1] TEvRestoreFromCheckpoint, StateLoadPlan = { StateType: STATE_TYPE_OWN }
2025-12-09T03:43:59.679346Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:508: [ptqudqgd47iklgerf2i1-0] [1:1] Got TEvGetTaskState: tasks {2}
2025-12-09T03:43:59.679351Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:519: [ptqudqgd47iklgerf2i1-0] [1:1] GetState, tasks: 2
2025-12-09T03:43:59.679375Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:508: [ptqudqgd47iklgerf2i1-0] [1:1] Got TEvGetTaskState: tasks {1}
2025-12-09T03:43:59.679376Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:519: [ptqudqgd47iklgerf2i1-0] [1:1] GetState, tasks: 1
2025-12-09T03:43:59.679383Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:508: [ptqudqgd47iklgerf2i1-0] [1:1] Got TEvGetTaskState: tasks {3}
2025-12-09T03:43:59.679384Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:519: [ptqudqgd47iklgerf2i1-0] [1:1] GetState, tasks: 3
2025-12-09T03:43:59.729515Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:654: [ptqudqgd47iklgerf2i1-0] [1:1] ListOfStates results:
2025-12-09T03:43:59.729539Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:675: [ptqudqgd47iklgerf2i1-0] [1:1] taskId 2 checkpoint id: 1:1, rows count: 1
2025-12-09T03:43:59.729547Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:901: [ptqudqgd47iklgerf2i1-0] [1:1] SkipStatesInFuture, skip 0 checkpoints
2025-12-09T03:43:59.729596Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:796: [ptqudqgd47iklgerf2i1-0] [1:1] SelectState: task_id 2, seq_no 1, blob_seq_num 0
2025-12-09T03:43:59.729807Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:654: [ptqudqgd47iklgerf2i1-0] [1:1] ListOfStates results:
2025-12-09T03:43:59.729819Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:675: [ptqudqgd47iklgerf2i1-0] [1:1] taskId 1 checkpoint id: 1:1, rows count: 1
2025-12-09T03:43:59.729823Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:901: [ptqudqgd47iklgerf2i1-0] [1:1] SkipStatesInFuture, skip 0 checkpoints
2025-12-09T03:43:59.729861Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:654: [ptqudqgd47iklgerf2i1-0] [1:1] ListOfStates results:
2025-12-09T03:43:59.729869Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:675: [ptqudqgd47iklgerf2i1-0] [1:1] taskId 3 checkpoint id: 1:1, rows count: 1
2025-12-09T03:43:59.729872Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:901: [ptqudqgd47iklgerf2i1-0] [1:1] SkipStatesInFuture, skip 0 checkpoints
2025-12-09T03:43:59.729888Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:796: [ptqudqgd47iklgerf2i1-0] [1:1] SelectState: task_id 1, seq_no 1, blob_seq_num 0
2025-12-09T03:43:59.730003Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:796: [ptqudqgd47iklgerf2i1-0] [1:1] SelectState: task_id 3, seq_no 1, blob_seq_num 0
2025-12-09T03:43:59.768429Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:410: [ptqudqgd47iklgerf2i1-0] [1:1] DeserializeState, task id 1, blob size 110
2025-12-09T03:43:59.768455Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:960: [ptqudqgd47iklgerf2i1-0] [1:1] ApplyIncrements
2025-12-09T03:43:59.768571Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:527: [ptqudqgd47iklgerf2i1-0] [{ Id: 1 Generation: 1 }] Send TEvGetTaskStateResult: tasks: {1}
2025-12-09T03:43:59.768611Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:336: [ptqudqgd47iklgerf2i1-0] Task: 1. [Checkpoint 1.1] TEvGetTaskStateResult: restoring state
2025-12-09T03:43:59.768617Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:793: SelfId: [1:7581698919752395669:2422], TxId: ptqudqgd47iklgerf2i1, task: 1. Ctx: {}. Load state
2025-12-09T03:43:59.768629Z :KQP_COMPUTE DEBUG: dq_pq_read_actor_base.cpp:153: SelfId: [0:0:0], TxId: ptqudqgd47iklgerf2i1, task: 1. PQ source. SessionId: empty Watermarks enabled: 0 granularity: 0.000000s late arrival delay: 0.000000s idle: 0 idle timeout: 0.000000s
2025-12-09T03:43:59.768641Z :KQP_COMPUTE DEBUG: dq_pq_read_actor_base.cpp:133: SelfId: [0:0:0], TxId: ptqudqgd47iklgerf2i1, task: 1. PQ source. SessionId: empty StartingMessageTs 2025-12-09T03:43:38.664000Z Restoring offset: 
2025-12-09T03:43:59.768657Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:410: [ptqudqgd47iklgerf2i1-0] [1:1] DeserializeState, task id 3, blob size 29
2025-12-09T03:43:59.768659Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:362: [ptqudqgd47iklgerf2i1-0] Task: 1. [Checkpoint 1.1] Checkpoint state restored
2025-12-09T03:43:59.768665Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:960: [ptqudqgd47iklgerf2i1-0] [1:1] ApplyIncrements
2025-12-09T03:43:59.768674Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:527: [ptqudqgd47iklgerf2i1-0] [{ Id: 1 Generation: 1 }] Send TEvGetTaskStateResult: tasks: {3}
2025-12-09T03:43:59.768680Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:297: [ptqudqgd47iklgerf2i1-0.2] [1:1] Got TEvRestoreFromCheckpointResult; taskId: 1, checkpoint: 1:1, status: OK, issues: 
2025-12-09T03:43:59.768684Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:320: [ptqudqgd47iklgerf2i1-0.2] [1:1] Task state restored, need 2 more acks
2025-12-09T03:43:59.768689Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:336: [ptqudqgd47iklgerf2i1-0] Task: 3. [Checkpoint 1.1] TEvGetTaskStateResult: restoring state
2025-12-09T03:43:59.768691Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:793: SelfId: [1:7581698919752395666:2421], TxId: ptqudqgd47iklgerf2i1, task: 3. Ctx: {}. Load state
2025-12-09T03:43:59.768698Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:362: [ptqudqgd47iklgerf2i1-0] Task: 3. [Checkpoint 1.1] Checkpoint state restored
2025-12-09T03:43:59.768704Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:297: [ptqudqgd47iklgerf2i1-0.2] [1:1] Got TEvRestoreFromCheckpointResult; taskId: 3, checkpoint: 1:1, status: OK, issues: 
2025-12-09T03:43:59.768705Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:320: [ptqudqgd47iklgerf2i1-0.2] [1:1] Task state restored, need 1 more acks
2025-12-09T03:43:59.768709Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:410: [ptqudqgd47iklgerf2i1-0] [1:1] DeserializeState, task id 2, blob size 29
2025-12-09T03:43:59.768712Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:960: [ptqudqgd47iklgerf2i1-0] [1:1] ApplyIncrements
2025-12-09T03:43:59.768717Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:527: [ptqudqgd47iklgerf2i1-0] [{ Id: 1 Generation: 1 }] Send TEvGetTaskStateResult: tasks: {2}
2025-12-09T03:43:59.768733Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:336: [ptqudqgd47iklgerf2i1-0] Task: 2. [Checkpoint 1.1] TEvGetTaskStateResult: restoring state
2025-12-09T03:43:59.768736Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:793: SelfId: [1:7581698919752395663:2420], TxId: ptqudqgd47iklgerf2i1, task: 2. Ctx: {}. Load state
2025-12-09T03:43:59.768742Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:362: [ptqudqgd47iklgerf2i1-0] Task: 2. [Checkpoint 1.1] Checkpoint state restored
2025-12-09T03:43:59.768749Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:297: [ptqudqgd47iklgerf2i1-0.2] [1:1] Got TEvRestoreFromCheckpointResult; taskId: 2, checkpoint: 1:1, status: OK, issues: 
2025-12-09T03:43:59.768751Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:320: [ptqudqgd47iklgerf2i1-0.2] [1:1] Task state restored, need 0 more acks
2025-12-09T03:43:59.768753Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:445: [ptqudqgd47iklgerf2i1-0.2] Send TEvRun to all actors
2025-12-09T03:43:59.768766Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1164: SelfId: [1:7581698919752395663:2420], TxId: ptqudqgd47iklgerf2i1, task: 2. Ctx: {}. Got TEvRun from actor [1:7581698919752395660:2417]
2025-12-09T03:43:59.768767Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1164: SelfId: [1:7581698919752395666:2421], TxId: ptqudqgd47iklgerf2i1, task: 3. Ctx: {}. Got TEvRun from actor [1:7581698919752395660:2417]
2025-12-09T03:43:59.768778Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7581698919752395666:2421], TxId: ptqudqgd47iklgerf2i1, task: 3. Ctx: {}. Poll inputs
2025-12-09T03:43:59.768780Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1164: SelfId: [1:7581698919752395669:2422], TxId: ptqudqgd47iklgerf2i1, task: 1. Ctx: {}. Got TEvRun from actor [1:7581698919752395660:2417]
2025-12-09T03:43:59.768782Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [1:7581698919752395666:2421], TxId: ptqudqgd47iklgerf2i1, task: 3. Ctx: {}. Poll sources
2025-12-09T03:43:59.768783Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7581698919752395663:2420], TxId: ptqudqgd47iklgerf2i1, task: 2. Ctx: {}. Poll inputs
2025-12-09T03:43:59.768784Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [1:7581698919752395663:2420], TxId: ptqudqgd47iklgerf2i1, task: 2. Ctx: {}. Poll sources
2025-12-09T03:43:59.768785Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [1:7581698919752395666:2421], TxId: ptqudqgd47iklgerf2i1, task: 3. Ctx: {}. DoExecuteImpl: 0
2025-12-09T03:43:59.768786Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [1:7581698919752395663:2420], TxId: ptqudqgd47iklgerf2i1, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-12-09T03:43:59.768792Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7581698919752395669:2422], TxId: ptqudqgd47iklgerf2i1, task: 1. Ctx: {}. Poll inputs
2025-12-09T03:43:59.768794Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [1:7581698919752395669:2422], TxId: ptqudqgd47iklgerf2i1, task: 1. Ctx: {}. Poll sources
2025-12-09T03:43:59.768800Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:542: SelfId: [0:0:0], TxId: ptqudqgd47iklgerf2i1, task: 1. PQ source. SessionId: empty GetAsyncInputData freeSpace = 1
2025-12-09T03:43:59.768818Z :KQP_COMPUTE DEBUG: dq_pq_read_actor.cpp:648: SelfId: [0:0:0], TxId: ptqudqgd47iklgerf2i1, task: 1. PQ source. SessionId: empty PartitionsToRead: 0
2025-12-09T03:43:59.768819Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: 323dda4c-6ce2c19b-118bbaa6-9f349aa6 2025-12-09 03:43:59.768 DEBUG ydbd(pid=1648981, tid=0x00007FEE50268640) [DQ] tasks_runner_local.cpp:267: {TODO/3} Run task: 3
2025-12-09T03:43:59.768840Z :KQP_COMPUTE TRACE: dq_compute_memory_quota.h:97: TxId: ptqudqgd47iklgerf2i1, task: 2. Peak memory usage: 2031616
2025-12-09T03:43:59.768843Z :YDB_SDK INFO: actor.cpp:37: 2025-12-09T03:43:59.768838Z :INFO: [local] [local] [bb9b2be8-5d4fd4aa-2aa5709c-8acb7c32] Starting read session
2025-12-09T03:43:59.768847Z :KQP_COMPUTE TRACE: dq_compute_memory_quota.h:97: TxId: ptqudqgd47iklgerf2i1, task: 3. Peak memory usage: 2031616
2025-12-09T03:43:59.768848Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:43:59.768845Z :DEBUG: [local] [local] [bb9b2be8-5d4fd4aa-2aa5709c-8acb7c32] Starting single session
2025-12-09T03:43:59.768850Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7581698919752395663:2420], TxId: ptqudqgd47iklgerf2i1, task: 2. Ctx: {}. update task runner stats
2025-12-09T03:43:59.768850Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7581698919752395666:2421], TxId: ptqudqgd47iklgerf2i1, task: 3. Ctx: {}. update task runner stats
2025-12-09T03:43:59.768864Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7581698919752395666:2421], TxId: ptqudqgd47iklgerf2i1, task: 3. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-09T03:43:59.768865Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7581698919752395666:2421], TxId: ptqudqgd47iklgerf2i1, task: 3. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-09T03:43:59.768865Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7581698919752395663:2420], TxId: ptqudqgd47iklgerf2i1, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-09T03:43:59.768867Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7581698919752395663:2420], TxId: ptqudqgd47iklgerf2i1, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-09T03:43:59.768868Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:534: SelfId: [1:7581698919752395666:2421], TxId: ptqudqgd47iklgerf2i1, task: 3. Ctx: {}. About to drain channelId: 3, hasPeer: 1, peerState:(freeSpace:1000000;inFlightBytes:0;inFlightCount:0;)
2025-12-09T03:43:59.768871Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:534: SelfId: [1:7581698919752395663:2420], TxId: ptqudqgd47iklgerf2i1, task: 2. Ctx: {}. About to drain channelId: 2, hasPeer: 1, peerState:(freeSpace:1000000;inFlightBytes:0;inFlightCount:0;)
2025-12-09T03:43:59.768874Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1107: SelfId: [1:7581698919752395663:2420], TxId: ptqudqgd47iklgerf2i1, task: 2. Ctx: {}. Ask CPU quota: 13ms
2025-12-09T03:43:59.768876Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:43:59.768875Z :DEBUG: [local] [local] [bb9b2be8-5d4fd4aa-2aa5709c-8acb7c32] [] In Reconnect, ReadSizeBudget = 8388608, ReadSizeServerDelta = 0
2025-12-09T03:43:59.768877Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:605: TxId: ptqudqgd47iklgerf2i1, task: 3. no poll, channelId: 2, hasPeer: 1, finished: 0, retry: 0, lastSeqNo: 0, freeSpace: 1000000
2025-12-09T03:43:59.768879Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:43:59.768878Z :DEBUG: [local] [local] [bb9b2be8-5d4fd4aa-2aa5709c-8acb7c32] [] New values: ReadSizeBudget = 8388608, ReadSizeServerDelta = 0
2025-12-09T03:43:59.768883Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:43:59.768882Z :DEBUG: [local] [local] [bb9b2be8-5d4fd4aa-2aa5709c-8acb7c32] [] Reconnecting session to cluster  in 0.000000s
2025-12-09T03:43:59.768886Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:605: TxId: ptqudqgd47iklgerf2i1, task: 2. no poll, channelId: 1, hasPeer: 1, finished: 0, retry: 0, lastSeqNo: 0, freeSpace: 1000000
2025-12-09T03:43:59.769021Z :KQP_COMPUTE INFO: dq_pq_read_actor.cpp:315: SelfId: [0:0:0], TxId: ptqudqgd47iklgerf2i1, task: 1. PQ source. SessionId: bb9b2be8-5d4fd4aa-2aa5709c-8acb7c32 CreateReadSession
2025-12-09T03:43:59.769033Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:81: SelfId: [1:7581698919752395669:2422], TxId: ptqudqgd47iklgerf2i1, task: 1. Ctx: {}. Poll async input 0. Buffer free space: 1, read from async input: 0 bytes, 0 rows, finished: 0
2025-12-09T03:43:59.769049Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [1:7581698919752395669:2422], TxId: ptqudqgd47iklgerf2i1, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-12-09T03:43:59.769082Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:43:59.769070Z :DEBUG: [local] [local] [bb9b2be8-5d4fd4aa-2aa5709c-8acb7c32] [] Successfully connected. Initializing session
2025-12-09T03:43:59.769087Z :KQP_COMPUTE TRACE: dq_compute_memory_quota.h:97: TxId: ptqudqgd47iklgerf2i1, task: 1. Peak memory usage: 2031616
2025-12-09T03:43:59.769091Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7581698919752395669:2422], TxId: ptqudqgd47iklgerf2i1, task: 1. Ctx: {}. update task runner stats
2025-12-09T03:43:59.769106Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7581698919752395669:2422], TxId: ptqudqgd47iklgerf2i1, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-09T03:43:59.769112Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7581698919752395669:2422], TxId: ptqudqgd47iklgerf2i1, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-09T03:43:59.769116Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:534: SelfId: [1:7581698919752395669:2422], TxId: ptqudqgd47iklgerf2i1, task: 1. Ctx: {}. About to drain channelId: 1, hasPeer: 1, peerState:(freeSpace:1000000;inFlightBytes:0;inFlightCount:0;)
2025-12-09T03:43:59.769118Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1107: SelfId: [1:7581698919752395669:2422], TxId: ptqudqgd47iklgerf2i1, task: 1. Ctx: {}. Ask CPU quota: 35ms
2025-12-09T03:43:59.769559Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1165: SelfId: [1:7581698919752395663:2420], TxId: ptqudqgd47iklgerf2i1, task: 2. Ctx: {}. CPU quota delay: 0ms
2025-12-09T03:43:59.769638Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1165: SelfId: [1:7581698919752395669:2422], TxId: ptqudqgd47iklgerf2i1, task: 1. Ctx: {}. CPU quota delay: 0ms
2025-12-09T03:43:59.769715Z :YDB_SDK INFO: actor.cpp:37: 2025-12-09T03:43:59.769710Z :INFO: [local] [local] [bb9b2be8-5d4fd4aa-2aa5709c-8acb7c32] [] Got InitResponse. ReadSessionId: ptqudqgd47iklgerf2i1_1_3_13678919229098613405_v1
2025-12-09T03:43:59.769724Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:43:59.769723Z :DEBUG: [local] [local] [bb9b2be8-5d4fd4aa-2aa5709c-8acb7c32] [] In ContinueReadingDataImpl, ReadSizeBudget = 8388608, ReadSizeServerDelta = 0
2025-12-09T03:43:59.769776Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:43:59.769774Z :DEBUG: [local] [local] [bb9b2be8-5d4fd4aa-2aa5709c-8acb7c32] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 8388608
2025-12-09T03:43:59.771159Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:363: SelfId: [0:0:0], TxId: ptqudqgd47iklgerf2i1, task: 1. PQ source. SessionId: bb9b2be8-5d4fd4aa-2aa5709c-8acb7c32 Source data ready
2025-12-09T03:43:59.771174Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7581698919752395669:2422], TxId: ptqudqgd47iklgerf2i1, task: 1. Ctx: {}. Poll inputs
2025-12-09T03:43:59.771176Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [1:7581698919752395669:2422], TxId: ptqudqgd47iklgerf2i1, task: 1. Ctx: {}. Poll sources
2025-12-09T03:43:59.771178Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:542: SelfId: [0:0:0], TxId: ptqudqgd47iklgerf2i1, task: 1. PQ source. SessionId: bb9b2be8-5d4fd4aa-2aa5709c-8acb7c32 GetAsyncInputData freeSpace = 1000000
2025-12-09T03:43:59.771188Z :KQP_COMPUTE DEBUG: dq_pq_read_actor.cpp:820: SelfId: [0:0:0], TxId: ptqudqgd47iklgerf2i1, task: 1. PQ source. SessionId: bb9b2be8-5d4fd4aa-2aa5709c-8acb7c32 Key: 0@ StartPartitionSessionEvent received
2025-12-09T03:43:59.771189Z :KQP_COMPUTE DEBUG: dq_pq_read_actor.cpp:827: SelfId: [0:0:0], TxId: ptqudqgd47iklgerf2i1, task: 1. PQ source. SessionId: bb9b2be8-5d4fd4aa-2aa5709c-8acb7c32 Key: 0@ Confirm StartPartitionSession with offset (NULL)
2025-12-09T03:43:59.771196Z :YDB_SDK INFO: actor.cpp:37: 2025-12-09T03:43:59.771193Z :INFO: [local] [local] [bb9b2be8-5d4fd4aa-2aa5709c-8acb7c32] [] Confirm partition stream create. Partition stream id: 1. Cluster: "-". Topic: "select_timings_2f_input". Partition: 0. Read offset: (NULL)
2025-12-09T03:43:59.771239Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:81: SelfId: [1:7581698919752395669:2422], TxId: ptqudqgd47iklgerf2i1, task: 1. Ctx: {}. Poll async input 0. Buffer free space: 1000000, read from async input: 0 bytes, 0 rows, finished: 0
2025-12-09T03:43:59.771249Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:363: SelfId: [0:0:0], TxId: ptqudqgd47iklgerf2i1, task: 1. PQ source. SessionId: bb9b2be8-5d4fd4aa-2aa5709c-8acb7c32 Source data ready
2025-12-09T03:43:59.771252Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [1:7581698919752395669:2422], TxId: ptqudqgd47iklgerf2i1, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-12-09T03:43:59.771300Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7581698919752395669:2422], TxId: ptqudqgd47iklgerf2i1, task: 1. Ctx: {}. Poll inputs
2025-12-09T03:43:59.771306Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [1:7581698919752395669:2422], TxId: ptqudqgd47iklgerf2i1, task: 1. Ctx: {}. Poll sources
2025-12-09T03:43:59.771309Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:542: SelfId: [0:0:0], TxId: ptqudqgd47iklgerf2i1, task: 1. PQ source. SessionId: bb9b2be8-5d4fd4aa-2aa5709c-8acb7c32 GetAsyncInputData freeSpace = 1000000
2025-12-09T03:43:59.771312Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:81: SelfId: [1:7581698919752395669:2422], TxId: ptqudqgd47iklgerf2i1, task: 1. Ctx: {}. Poll async input 0. Buffer free space: 1000000, read from async input: 0 bytes, 0 rows, finished: 0
2025-12-09T03:43:59.771314Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7581698919752395669:2422], TxId: ptqudqgd47iklgerf2i1, task: 1. Ctx: {}. update task runner stats
2025-12-09T03:43:59.771332Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7581698919752395669:2422], TxId: ptqudqgd47iklgerf2i1, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-09T03:43:59.771333Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7581698919752395669:2422], TxId: ptqudqgd47iklgerf2i1, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-09T03:43:59.771336Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:534: SelfId: [1:7581698919752395669:2422], TxId: ptqudqgd47iklgerf2i1, task: 1. Ctx: {}. About to drain channelId: 1, hasPeer: 1, peerState:(freeSpace:1000000;inFlightBytes:0;inFlightCount:0;)
2025-12-09T03:43:59.771337Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [1:7581698919752395669:2422], TxId: ptqudqgd47iklgerf2i1, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-12-09T03:43:59.771351Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7581698919752395669:2422], TxId: ptqudqgd47iklgerf2i1, task: 1. Ctx: {}. update task runner stats
2025-12-09T03:43:59.771355Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7581698919752395669:2422], TxId: ptqudqgd47iklgerf2i1, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-09T03:43:59.771355Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7581698919752395669:2422], TxId: ptqudqgd47iklgerf2i1, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-09T03:43:59.771357Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:534: SelfId: [1:7581698919752395669:2422], TxId: ptqudqgd47iklgerf2i1, task: 1. Ctx: {}. About to drain channelId: 1, hasPeer: 1, peerState:(freeSpace:1000000;inFlightBytes:0;inFlightCount:0;)
2025-12-09T03:44:00.585642Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7581698863917820456:2081]
2025-12-09T03:44:00.585656Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-09T03:44:00.585657Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7581698863917820440:2069]
2025-12-09T03:44:00.585662Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7581698863917820440:2069]
2025-12-09T03:44:00.585665Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7581698863917820440:2069]
2025-12-09T03:44:00.585676Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-09T03:44:00.586625Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 323dda4c-6ce2c19b-118bbaa6-9f349aa616, Host: ghrun-syjwtgwtdu, Tenant: /default
2025-12-09T03:44:00.587021Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 323dda4c-6ce2c19b-118bbaa6-9f349aa616, Host: ghrun-syjwtgwtdu, Tenant: /default, Request CP::GetTask with size: 69 bytes
2025-12-09T03:44:00.587059Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/default"
owner_id: "323dda4c-6ce2c19b-118bbaa6-9f349aa616"
host: "ghrun-syjwtgwtdu"
node_id: 1
}
2025-12-09T03:44:00.589286Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-09T03:44:00.589315Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 323dda4c-6ce2c19b-118bbaa6-9f349aa616, Host: ghrun-syjwtgwtdu, Tenant: /default, Got CP::GetTask Response
2025-12-09T03:44:00.589556Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:44:00.589562Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-09T03:44:00.618459Z :YQL_PROXY TRACE: log.cpp:64: SessionId:  2025-12-09 03:44:00.618 TRACE ydbd(pid=1648981, tid=0x00007FEE5126A640) [DQ] task_controller_impl.h:271:  [1:7581698919752395661:2418] ExportStats Summary
2025-12-09T03:44:00.618710Z :FQ_PINGER TRACE: pinger.cpp:250: QueryId: ptqudqgd47iklgerf2i1, Owner: 323dda4c-6ce2c19b-118bbaa6-9f349aa614 Forward ping request: { statistics: "{\"Graph=0\":{\"TaskRunner\":{\"Stage=200473\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":1,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":1,\"count\":1,\"avg\":1,\"max\":1,\"min\":1}},\"Stage=200494\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":1,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":1,\"count\":1,\"avg\":1,\"max\":1,\"min\":1}},\"Stage=200511\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":1,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":1,\"count\":1,\"avg\":1,\"max\":1,\"min\":1}},\"Stage=Total\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":3,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":3,\"count\":3,\"avg\":1,\"max\":1,\"min\":1}}}}}" }
2025-12-09T03:44:00.618717Z :FQ_PINGER TRACE: pinger.cpp:393: QueryId: ptqudqgd47iklgerf2i1, Owner: 323dda4c-6ce2c19b-118bbaa6-9f349aa614 Forward request Private::PingTask
2025-12-09T03:44:00.619224Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudqgd47iklgerf2i1, Owner: 323dda4c-6ce2c19b-118bbaa6-9f349aa614, Request CP::PingTask with size: 741 bytes
2025-12-09T03:44:00.619296Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "323dda4c-6ce2c19b-118bbaa6-9f349aa614"
query_id {
  value: "ptqudqgd47iklgerf2i1"
}
statistics: "{\"Graph=0\":{\"TaskRunner\":{\"Stage=200473\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":1,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":1,\"count\":1,\"avg\":1,\"max\":1,\"min\":1}},\"Stage=200494\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":1,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":1,\"count\":1,\"avg\":1,\"max\":1,\"min\":1}},\"Stage=200511\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":1,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":1,\"count\":1,\"avg\":1,\"max\":1,\"min\":1}},\"Stage=Total\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":3,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":3,\"count\":3,\"avg\":1,\"max\":1,\"min\":1}}}}}"
scope: "yandexcloud://my_folder"
deadline {
  seconds: 1765338239
  nanos: 590988000
}
tenant: "/default"
}
2025-12-09T03:44:00.628137Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {expired_at { seconds: 1765251860 nanos: 623000000 } } SUCCESS
2025-12-09T03:44:00.628161Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudqgd47iklgerf2i1, Owner: 323dda4c-6ce2c19b-118bbaa6-9f349aa614, Got CP::PingTaskResponse
2025-12-09T03:44:00.628451Z :FQ_PINGER TRACE: pinger.cpp:338: QueryId: ptqudqgd47iklgerf2i1, Owner: 323dda4c-6ce2c19b-118bbaa6-9f349aa614 Ping response success: { expired_at { seconds: 1765251860 nanos: 623000000 } }
2025-12-09T03:44:00.628476Z :FQ_RUN_ACTOR TRACE: run_actor.cpp:861: QueryId: ptqudqgd47iklgerf2i1 Forward ping response. Success: 1. Cookie: 6
2025-12-09T03:44:00.768938Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:373: [ptqudqgd47iklgerf2i1-0.2] Got TEvScheduleCheckpointing
2025-12-09T03:44:00.768956Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:349: [ptqudqgd47iklgerf2i1-0.2] [2:1] Registering new checkpoint in storage
2025-12-09T03:44:00.769063Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:288: [ptqudqgd47iklgerf2i1-0.2] [2:1] Got TEvCreateCheckpointRequest
2025-12-09T03:44:00.769107Z :YDB_SDK INFO: actor.cpp:37: 2025-12-09T03:44:00.769097Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:select_timings_2f_input:0:1:0:0
2025-12-09T03:44:00.769123Z :YDB_SDK INFO: actor.cpp:37: 2025-12-09T03:44:00.769120Z :INFO: [local] [local] [bb9b2be8-5d4fd4aa-2aa5709c-8acb7c32] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1000 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:44:00.793841Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:334: [ptqudqgd47iklgerf2i1-0.2] [2:1] Checkpoint created
2025-12-09T03:44:00.793853Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:336: [ptqudqgd47iklgerf2i1-0.2] [2:1] Send TEvCreateCheckpointResponse
2025-12-09T03:44:00.793899Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:389: [ptqudqgd47iklgerf2i1-0.2] [2:1] Got TEvCreateCheckpointResponse
2025-12-09T03:44:00.793910Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:435: [ptqudqgd47iklgerf2i1-0.2] [2:1] Checkpoint successfully created, going to inject barriers to 1 actor(s)
2025-12-09T03:44:00.793934Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:239: [ptqudqgd47iklgerf2i1-0] Task: 1. [Checkpoint 2.1] TEvInjectCheckpoint
2025-12-09T03:44:00.793949Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7581698919752395669:2422], TxId: ptqudqgd47iklgerf2i1, task: 1. Ctx: {}. Poll inputs
2025-12-09T03:44:00.793957Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1494: SelfId: [1:7581698919752395669:2422], TxId: ptqudqgd47iklgerf2i1, task: 1. Ctx: {}. Skip polling sources because of pending checkpoint
2025-12-09T03:44:00.793960Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [1:7581698919752395669:2422], TxId: ptqudqgd47iklgerf2i1, task: 1. Ctx: {}. DoExecuteImpl: 1
2025-12-09T03:44:00.794036Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:462: SelfId: [1:7581698919752395671:2422], TxId: ptqudqgd47iklgerf2i1, task: 1. Pending 1 checkpoints to be sent
2025-12-09T03:44:00.794048Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7581698919752395669:2422], TxId: ptqudqgd47iklgerf2i1, task: 1. Ctx: {}. update task runner stats
2025-12-09T03:44:00.794087Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7581698919752395669:2422], TxId: ptqudqgd47iklgerf2i1, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 1 watermark injected: (empty maybe)
2025-12-09T03:44:00.794094Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:447: [ptqudqgd47iklgerf2i1-0] Task: 1. [Checkpoint 2.1] Performing task checkpoint
2025-12-09T03:44:00.794096Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:816: SelfId: [1:7581698919752395669:2422], TxId: ptqudqgd47iklgerf2i1, task: 1. Ctx: {}. Save state
2025-12-09T03:44:00.794105Z :KQP_COMPUTE DEBUG: dq_pq_read_actor_base.cpp:94: SelfId: [0:0:0], TxId: ptqudqgd47iklgerf2i1, task: 1. PQ source. SessionId: bb9b2be8-5d4fd4aa-2aa5709c-8acb7c32 SaveState, offsets: 
2025-12-09T03:44:00.794113Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:474: [ptqudqgd47iklgerf2i1-0] Task: 1. [Checkpoint 2.1] CA state saved
2025-12-09T03:44:00.794115Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:449: [ptqudqgd47iklgerf2i1-0] Task: 1. [Checkpoint 2.1] Injecting checkpoint barrier to outputs
2025-12-09T03:44:00.794126Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:536: [ptqudqgd47iklgerf2i1-0] Task: 1. [Checkpoint 2.1] Task checkpoint is done. Send to storage
2025-12-09T03:44:00.794130Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7581698919752395669:2422], TxId: ptqudqgd47iklgerf2i1, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-09T03:44:00.794135Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:534: SelfId: [1:7581698919752395669:2422], TxId: ptqudqgd47iklgerf2i1, task: 1. Ctx: {}. About to drain channelId: 1, hasPeer: 1, peerState:(freeSpace:1000000;inFlightBytes:0;inFlightCount:0;)
2025-12-09T03:44:00.794137Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:460: [ptqudqgd47iklgerf2i1-0] [2:1] Got TEvSaveTaskState: task 1
2025-12-09T03:44:00.794154Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:566: TxId: ptqudqgd47iklgerf2i1, task: 1. SendChannelData, channelId: 1, peer: [1:7581698919752395663:2420], chunks: 0, bytes: 0, watermark: 0, checkpoint: 1, seqNo: 1, finished: 0
2025-12-09T03:44:00.794167Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7581698919752395669:2422], TxId: ptqudqgd47iklgerf2i1, task: 1. Ctx: {}. Poll inputs
2025-12-09T03:44:00.794173Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:129: TxId: ptqudqgd47iklgerf2i1, task: 2. Received input for channelId: 1, seqNo: 1, size: 0, chunks: 0, watermark: 0, checkpoint: 1, finished: 0, from: [1:7581698919752395670:2422], expected seqNo: 1
2025-12-09T03:44:00.794173Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [1:7581698919752395669:2422], TxId: ptqudqgd47iklgerf2i1, task: 1. Ctx: {}. Poll sources
2025-12-09T03:44:00.794175Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:611: SelfId: [1:7581698919752395663:2420], TxId: ptqudqgd47iklgerf2i1, task: 2. Ctx: {}. took input
2025-12-09T03:44:00.794177Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:542: SelfId: [0:0:0], TxId: ptqudqgd47iklgerf2i1, task: 1. PQ source. SessionId: bb9b2be8-5d4fd4aa-2aa5709c-8acb7c32 GetAsyncInputData freeSpace = 1000000
2025-12-09T03:44:00.794184Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:81: SelfId: [1:7581698919752395669:2422], TxId: ptqudqgd47iklgerf2i1, task: 1. Ctx: {}. Poll async input 0. Buffer free space: 1000000, read from async input: 0 bytes, 0 rows, finished: 0
2025-12-09T03:44:00.794187Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:485: [ptqudqgd47iklgerf2i1-0] Task: 2. [Checkpoint 2.1] Got checkpoint barrier from channel 1
2025-12-09T03:44:00.794192Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [1:7581698919752395669:2422], TxId: ptqudqgd47iklgerf2i1, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-12-09T03:44:00.794205Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:356: SelfId: [1:7581698919752395665:2420], TxId: ptqudqgd47iklgerf2i1, task: 2. No watermark 
2025-12-09T03:44:00.794210Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7581698919752395669:2422], TxId: ptqudqgd47iklgerf2i1, task: 1. Ctx: {}. update task runner stats
2025-12-09T03:44:00.794213Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7581698919752395663:2420], TxId: ptqudqgd47iklgerf2i1, task: 2. Ctx: {}. Poll inputs
2025-12-09T03:44:00.794214Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1494: SelfId: [1:7581698919752395663:2420], TxId: ptqudqgd47iklgerf2i1, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-12-09T03:44:00.794215Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [1:7581698919752395663:2420], TxId: ptqudqgd47iklgerf2i1, task: 2. Ctx: {}. DoExecuteImpl: 1
2025-12-09T03:44:00.794218Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7581698919752395669:2422], TxId: ptqudqgd47iklgerf2i1, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-09T03:44:00.794219Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7581698919752395669:2422], TxId: ptqudqgd47iklgerf2i1, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-09T03:44:00.794220Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:965: SelfId: [1:7581698919752395663:2420], TxId: ptqudqgd47iklgerf2i1, task: 2. Ctx: {}. Input data push finished. Cookie: 0 Watermark: (empty maybe) Ack: 1 TakeInputChannelDataRequests: 1
2025-12-09T03:44:00.794222Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:534: SelfId: [1:7581698919752395669:2422], TxId: ptqudqgd47iklgerf2i1, task: 1. Ctx: {}. About to drain channelId: 1, hasPeer: 1, peerState:(freeSpace:1000000;inFlightBytes:96;inFlightCount:1;)
2025-12-09T03:44:00.794223Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:738: TxId: ptqudqgd47iklgerf2i1, task: 2. Sending channel data ack to channelId: 1, peer: [1:7581698919752395669:2422], from: [1:7581698919752395663:2420], freeSpace: 1000000, seqNo: 1, finished: 0
2025-12-09T03:44:00.794230Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:179: TxId: ptqudqgd47iklgerf2i1, task: 1. Received channel data ack for channelId: 1, seqNo: 1, lastSentSeqNo: 1, freeSpace: 1000000, early finish: 0
2025-12-09T03:44:00.794234Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:207: TxId: ptqudqgd47iklgerf2i1, task: 1. PeerState, peerState:(freeSpace:1000000;inFlightBytes:0;inFlightCount:0;), sentSeqNo: 1, ackSeqNo: 1
2025-12-09T03:44:00.794236Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:220: TxId: ptqudqgd47iklgerf2i1, task: 1. Resume compute actor
2025-12-09T03:44:00.794239Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7581698919752395669:2422], TxId: ptqudqgd47iklgerf2i1, task: 1. Ctx: {}. Poll inputs
2025-12-09T03:44:00.794240Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [1:7581698919752395669:2422], TxId: ptqudqgd47iklgerf2i1, task: 1. Ctx: {}. Poll sources
2025-12-09T03:44:00.794242Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:542: SelfId: [0:0:0], TxId: ptqudqgd47iklgerf2i1, task: 1. PQ source. SessionId: bb9b2be8-5d4fd4aa-2aa5709c-8acb7c32 GetAsyncInputData freeSpace = 1000000
2025-12-09T03:44:00.794245Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:81: SelfId: [1:7581698919752395669:2422], TxId: ptqudqgd47iklgerf2i1, task: 1. Ctx: {}. Poll async input 0. Buffer free space: 1000000, read from async input: 0 bytes, 0 rows, finished: 0
2025-12-09T03:44:00.794248Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [1:7581698919752395669:2422], TxId: ptqudqgd47iklgerf2i1, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-12-09T03:44:00.794254Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: 323dda4c-6ce2c19b-118bbaa6-9f349aa6 2025-12-09 03:44:00.794 DEBUG ydbd(pid=1648981, tid=0x00007FEE50268640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Run task: 2
2025-12-09T03:44:00.794263Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7581698919752395669:2422], TxId: ptqudqgd47iklgerf2i1, task: 1. Ctx: {}. update task runner stats
2025-12-09T03:44:00.794269Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7581698919752395669:2422], TxId: ptqudqgd47iklgerf2i1, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-09T03:44:00.794270Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:462: SelfId: [1:7581698919752395665:2420], TxId: ptqudqgd47iklgerf2i1, task: 2. Pending 1 checkpoints to be sent
2025-12-09T03:44:00.794270Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7581698919752395669:2422], TxId: ptqudqgd47iklgerf2i1, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-09T03:44:00.794273Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:534: SelfId: [1:7581698919752395669:2422], TxId: ptqudqgd47iklgerf2i1, task: 1. Ctx: {}. About to drain channelId: 1, hasPeer: 1, peerState:(freeSpace:1000000;inFlightBytes:0;inFlightCount:0;)
2025-12-09T03:44:00.794273Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7581698919752395663:2420], TxId: ptqudqgd47iklgerf2i1, task: 2. Ctx: {}. Poll inputs
2025-12-09T03:44:00.794274Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1494: SelfId: [1:7581698919752395663:2420], TxId: ptqudqgd47iklgerf2i1, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-12-09T03:44:00.794274Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [1:7581698919752395663:2420], TxId: ptqudqgd47iklgerf2i1, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-12-09T03:44:00.794276Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7581698919752395663:2420], TxId: ptqudqgd47iklgerf2i1, task: 2. Ctx: {}. update task runner stats
2025-12-09T03:44:00.794290Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7581698919752395663:2420], TxId: ptqudqgd47iklgerf2i1, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 1 watermark injected: (empty maybe)
2025-12-09T03:44:00.794291Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:447: [ptqudqgd47iklgerf2i1-0] Task: 2. [Checkpoint 2.1] Performing task checkpoint
2025-12-09T03:44:00.794299Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:816: SelfId: [1:7581698919752395663:2420], TxId: ptqudqgd47iklgerf2i1, task: 2. Ctx: {}. Save state
2025-12-09T03:44:00.794301Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:474: [ptqudqgd47iklgerf2i1-0] Task: 2. [Checkpoint 2.1] CA state saved
2025-12-09T03:44:00.794302Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:449: [ptqudqgd47iklgerf2i1-0] Task: 2. [Checkpoint 2.1] Injecting checkpoint barrier to outputs
2025-12-09T03:44:00.794308Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:536: [ptqudqgd47iklgerf2i1-0] Task: 2. [Checkpoint 2.1] Task checkpoint is done. Send to storage
2025-12-09T03:44:00.794309Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7581698919752395663:2420], TxId: ptqudqgd47iklgerf2i1, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-09T03:44:00.794312Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:534: SelfId: [1:7581698919752395663:2420], TxId: ptqudqgd47iklgerf2i1, task: 2. Ctx: {}. About to drain channelId: 2, hasPeer: 1, peerState:(freeSpace:1000000;inFlightBytes:0;inFlightCount:0;)
2025-12-09T03:44:00.794318Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:460: [ptqudqgd47iklgerf2i1-0] [2:1] Got TEvSaveTaskState: task 2
2025-12-09T03:44:00.794324Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: 323dda4c-6ce2c19b-118bbaa6-9f349aa6 2025-12-09 03:44:00.794 DEBUG ydbd(pid=1648981, tid=0x00007FEE50268640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Run task: 2
2025-12-09T03:44:00.794330Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:566: TxId: ptqudqgd47iklgerf2i1, task: 2. SendChannelData, channelId: 2, peer: [1:7581698919752395666:2421], chunks: 0, bytes: 0, watermark: 0, checkpoint: 1, seqNo: 1, finished: 0
2025-12-09T03:44:00.794340Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudqgd47iklgerf2i1, task: 2. no poll, channelId: 1, has inflight messages: [1], last with freeSpace: 1000000, current freeSpace: 1000000
2025-12-09T03:44:00.794342Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7581698919752395663:2420], TxId: ptqudqgd47iklgerf2i1, task: 2. Ctx: {}. update task runner stats
2025-12-09T03:44:00.794345Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7581698919752395663:2420], TxId: ptqudqgd47iklgerf2i1, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-09T03:44:00.794346Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7581698919752395663:2420], TxId: ptqudqgd47iklgerf2i1, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-09T03:44:00.794348Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:534: SelfId: [1:7581698919752395663:2420], TxId: ptqudqgd47iklgerf2i1, task: 2. Ctx: {}. About to drain channelId: 2, hasPeer: 1, peerState:(freeSpace:1000000;inFlightBytes:96;inFlightCount:1;)
2025-12-09T03:44:00.794350Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7581698919752395663:2420], TxId: ptqudqgd47iklgerf2i1, task: 2. Ctx: {}. Poll inputs
2025-12-09T03:44:00.794351Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [1:7581698919752395663:2420], TxId: ptqudqgd47iklgerf2i1, task: 2. Ctx: {}. Poll sources
2025-12-09T03:44:00.794351Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [1:7581698919752395663:2420], TxId: ptqudqgd47iklgerf2i1, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-12-09T03:44:00.794364Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:129: TxId: ptqudqgd47iklgerf2i1, task: 3. Received input for channelId: 2, seqNo: 1, size: 0, chunks: 0, watermark: 0, checkpoint: 1, finished: 0, from: [1:7581698919752395664:2420], expected seqNo: 1
2025-12-09T03:44:00.794368Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:611: SelfId: [1:7581698919752395666:2421], TxId: ptqudqgd47iklgerf2i1, task: 3. Ctx: {}. took input
2025-12-09T03:44:00.794369Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: 323dda4c-6ce2c19b-118bbaa6-9f349aa6 2025-12-09 03:44:00.794 DEBUG ydbd(pid=1648981, tid=0x00007FEE50268640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Run task: 2
2025-12-09T03:44:00.794375Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudqgd47iklgerf2i1, task: 2. no poll, channelId: 1, has inflight messages: [1], last with freeSpace: 1000000, current freeSpace: 1000000
2025-12-09T03:44:00.794376Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7581698919752395663:2420], TxId: ptqudqgd47iklgerf2i1, task: 2. Ctx: {}. update task runner stats
2025-12-09T03:44:00.794379Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7581698919752395663:2420], TxId: ptqudqgd47iklgerf2i1, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-09T03:44:00.794379Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7581698919752395663:2420], TxId: ptqudqgd47iklgerf2i1, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-09T03:44:00.794381Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:534: SelfId: [1:7581698919752395663:2420], TxId: ptqudqgd47iklgerf2i1, task: 2. Ctx: {}. About to drain channelId: 2, hasPeer: 1, peerState:(freeSpace:1000000;inFlightBytes:96;inFlightCount:1;)
2025-12-09T03:44:00.794384Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:485: [ptqudqgd47iklgerf2i1-0] Task: 3. [Checkpoint 2.1] Got checkpoint barrier from channel 2
2025-12-09T03:44:00.794384Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudqgd47iklgerf2i1, task: 2. no poll, channelId: 1, has inflight messages: [1], last with freeSpace: 1000000, current freeSpace: 1000000
2025-12-09T03:44:00.794397Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:356: SelfId: [1:7581698919752395668:2421], TxId: ptqudqgd47iklgerf2i1, task: 3. No watermark 
2025-12-09T03:44:00.794400Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7581698919752395666:2421], TxId: ptqudqgd47iklgerf2i1, task: 3. Ctx: {}. Poll inputs
2025-12-09T03:44:00.794402Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1494: SelfId: [1:7581698919752395666:2421], TxId: ptqudqgd47iklgerf2i1, task: 3. Ctx: {}. Skip polling sources because of pending checkpoint
2025-12-09T03:44:00.794404Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [1:7581698919752395666:2421], TxId: ptqudqgd47iklgerf2i1, task: 3. Ctx: {}. DoExecuteImpl: 1
2025-12-09T03:44:00.794410Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:965: SelfId: [1:7581698919752395666:2421], TxId: ptqudqgd47iklgerf2i1, task: 3. Ctx: {}. Input data push finished. Cookie: 0 Watermark: (empty maybe) Ack: 1 TakeInputChannelDataRequests: 1
2025-12-09T03:44:00.794414Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:738: TxId: ptqudqgd47iklgerf2i1, task: 3. Sending channel data ack to channelId: 2, peer: [1:7581698919752395663:2420], from: [1:7581698919752395666:2421], freeSpace: 1000000, seqNo: 1, finished: 0
2025-12-09T03:44:00.794429Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:179: TxId: ptqudqgd47iklgerf2i1, task: 2. Received channel data ack for channelId: 2, seqNo: 1, lastSentSeqNo: 1, freeSpace: 1000000, early finish: 0
2025-12-09T03:44:00.794432Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:207: TxId: ptqudqgd47iklgerf2i1, task: 2. PeerState, peerState:(freeSpace:1000000;inFlightBytes:0;inFlightCount:0;), sentSeqNo: 1, ackSeqNo: 1
2025-12-09T03:44:00.794434Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:220: TxId: ptqudqgd47iklgerf2i1, task: 2. Resume compute actor
2025-12-09T03:44:00.794438Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7581698919752395663:2420], TxId: ptqudqgd47iklgerf2i1, task: 2. Ctx: {}. Poll inputs
2025-12-09T03:44:00.794439Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [1:7581698919752395663:2420], TxId: ptqudqgd47iklgerf2i1, task: 2. Ctx: {}. Poll sources
2025-12-09T03:44:00.794442Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [1:7581698919752395663:2420], TxId: ptqudqgd47iklgerf2i1, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-12-09T03:44:00.794463Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:462: SelfId: [1:7581698919752395668:2421], TxId: ptqudqgd47iklgerf2i1, task: 3. Pending 1 checkpoints to be sent
2025-12-09T03:44:00.794468Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7581698919752395666:2421], TxId: ptqudqgd47iklgerf2i1, task: 3. Ctx: {}. Poll inputs
2025-12-09T03:44:00.794469Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1494: SelfId: [1:7581698919752395666:2421], TxId: ptqudqgd47iklgerf2i1, task: 3. Ctx: {}. Skip polling sources because of pending checkpoint
2025-12-09T03:44:00.794471Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [1:7581698919752395666:2421], TxId: ptqudqgd47iklgerf2i1, task: 3. Ctx: {}. DoExecuteImpl: 0
2025-12-09T03:44:00.794473Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7581698919752395666:2421], TxId: ptqudqgd47iklgerf2i1, task: 3. Ctx: {}. update task runner stats
2025-12-09T03:44:00.794477Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7581698919752395663:2420], TxId: ptqudqgd47iklgerf2i1, task: 2. Ctx: {}. update task runner stats
2025-12-09T03:44:00.794487Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7581698919752395663:2420], TxId: ptqudqgd47iklgerf2i1, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-09T03:44:00.794489Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7581698919752395663:2420], TxId: ptqudqgd47iklgerf2i1, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-09T03:44:00.794490Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7581698919752395666:2421], TxId: ptqudqgd47iklgerf2i1, task: 3. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 1 watermark injected: (empty maybe)
2025-12-09T03:44:00.794492Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:534: SelfId: [1:7581698919752395663:2420], TxId: ptqudqgd47iklgerf2i1, task: 2. Ctx: {}. About to drain channelId: 2, hasPeer: 1, peerState:(freeSpace:1000000;inFlightBytes:0;inFlightCount:0;)
2025-12-09T03:44:00.794492Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:447: [ptqudqgd47iklgerf2i1-0] Task: 3. [Checkpoint 2.1] Performing task checkpoint
2025-12-09T03:44:00.794494Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:816: SelfId: [1:7581698919752395666:2421], TxId: ptqudqgd47iklgerf2i1, task: 3. Ctx: {}. Save state
2025-12-09T03:44:00.794496Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:474: [ptqudqgd47iklgerf2i1-0] Task: 3. [Checkpoint 2.1] CA state saved
2025-12-09T03:44:00.794497Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:449: [ptqudqgd47iklgerf2i1-0] Task: 3. [Checkpoint 2.1] Injecting checkpoint barrier to outputs
2025-12-09T03:44:00.794499Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudqgd47iklgerf2i1, task: 2. no poll, channelId: 1, has inflight messages: [1], last with freeSpace: 1000000, current freeSpace: 1000000
2025-12-09T03:44:00.794503Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:460: [ptqudqgd47iklgerf2i1-0] [2:1] Got TEvSaveTaskState: task 3
2025-12-09T03:44:00.794505Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:536: [ptqudqgd47iklgerf2i1-0] Task: 3. [Checkpoint 2.1] Task checkpoint is done. Send to storage
2025-12-09T03:44:00.794507Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7581698919752395666:2421], TxId: ptqudqgd47iklgerf2i1, task: 3. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-09T03:44:00.794510Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:534: SelfId: [1:7581698919752395666:2421], TxId: ptqudqgd47iklgerf2i1, task: 3. Ctx: {}. About to drain channelId: 3, hasPeer: 1, peerState:(freeSpace:1000000;inFlightBytes:0;inFlightCount:0;)
2025-12-09T03:44:00.794532Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:566: TxId: ptqudqgd47iklgerf2i1, task: 3. SendChannelData, channelId: 3, peer: [1:7581698919752395659:2416], chunks: 0, bytes: 0, watermark: 0, checkpoint: 1, seqNo: 1, finished: 0
2025-12-09T03:44:00.794544Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudqgd47iklgerf2i1, task: 3. no poll, channelId: 2, has inflight messages: [1], last with freeSpace: 1000000, current freeSpace: 1000000
2025-12-09T03:44:00.794546Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7581698919752395666:2421], TxId: ptqudqgd47iklgerf2i1, task: 3. Ctx: {}. update task runner stats
2025-12-09T03:44:00.794552Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7581698919752395666:2421], TxId: ptqudqgd47iklgerf2i1, task: 3. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-09T03:44:00.794554Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7581698919752395666:2421], TxId: ptqudqgd47iklgerf2i1, task: 3. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-09T03:44:00.794555Z :FQ_RESULT_WRITER TRACE: result_writer.cpp:231: TraceId: ptqudqgd47iklgerf2i1#ptrudqgd46p09uqrv22g#yandexcloud://my_folder#5b0dfe77-e3652039-a7229327-b5b5424c4#mock_cloud ChannelData Shift, Records: 0 HasError: 0 Size: 0 Rows: 0 FreeSpace: 67108864 Duration: 1.178736s AvgSpeed: 0
2025-12-09T03:44:00.794556Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:534: SelfId: [1:7581698919752395666:2421], TxId: ptqudqgd47iklgerf2i1, task: 3. Ctx: {}. About to drain channelId: 3, hasPeer: 1, peerState:(freeSpace:1000000;inFlightBytes:96;inFlightCount:1;)
2025-12-09T03:44:00.794558Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7581698919752395666:2421], TxId: ptqudqgd47iklgerf2i1, task: 3. Ctx: {}. Poll inputs
2025-12-09T03:44:00.794559Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [1:7581698919752395666:2421], TxId: ptqudqgd47iklgerf2i1, task: 3. Ctx: {}. Poll sources
2025-12-09T03:44:00.794560Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [1:7581698919752395666:2421], TxId: ptqudqgd47iklgerf2i1, task: 3. Ctx: {}. DoExecuteImpl: 0
2025-12-09T03:44:00.794564Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:179: TxId: ptqudqgd47iklgerf2i1, task: 3. Received channel data ack for channelId: 3, seqNo: 1, lastSentSeqNo: 1, freeSpace: 67108864, early finish: 0
2025-12-09T03:44:00.794567Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:207: TxId: ptqudqgd47iklgerf2i1, task: 3. PeerState, peerState:(freeSpace:67108864;inFlightBytes:0;inFlightCount:0;), sentSeqNo: 1, ackSeqNo: 1
2025-12-09T03:44:00.794568Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:220: TxId: ptqudqgd47iklgerf2i1, task: 3. Resume compute actor
2025-12-09T03:44:00.794583Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7581698919752395666:2421], TxId: ptqudqgd47iklgerf2i1, task: 3. Ctx: {}. Poll inputs
2025-12-09T03:44:00.794584Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [1:7581698919752395666:2421], TxId: ptqudqgd47iklgerf2i1, task: 3. Ctx: {}. Poll sources
2025-12-09T03:44:00.794585Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [1:7581698919752395666:2421], TxId: ptqudqgd47iklgerf2i1, task: 3. Ctx: {}. DoExecuteImpl: 0
2025-12-09T03:44:00.794588Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudqgd47iklgerf2i1, task: 3. no poll, channelId: 2, has inflight messages: [1], last with freeSpace: 1000000, current freeSpace: 1000000
2025-12-09T03:44:00.794590Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7581698919752395666:2421], TxId: ptqudqgd47iklgerf2i1, task: 3. Ctx: {}. update task runner stats
2025-12-09T03:44:00.794594Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7581698919752395666:2421], TxId: ptqudqgd47iklgerf2i1, task: 3. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-09T03:44:00.794596Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7581698919752395666:2421], TxId: ptqudqgd47iklgerf2i1, task: 3. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-09T03:44:00.794598Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:534: SelfId: [1:7581698919752395666:2421], TxId: ptqudqgd47iklgerf2i1, task: 3. Ctx: {}. About to drain channelId: 3, hasPeer: 1, peerState:(freeSpace:67108864;inFlightBytes:0;inFlightCount:0;)
2025-12-09T03:44:00.794610Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudqgd47iklgerf2i1, task: 3. no poll, channelId: 2, has inflight messages: [1], last with freeSpace: 1000000, current freeSpace: 1000000
2025-12-09T03:44:00.794617Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7581698919752395666:2421], TxId: ptqudqgd47iklgerf2i1, task: 3. Ctx: {}. update task runner stats
2025-12-09T03:44:00.794622Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7581698919752395666:2421], TxId: ptqudqgd47iklgerf2i1, task: 3. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-09T03:44:00.794623Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7581698919752395666:2421], TxId: ptqudqgd47iklgerf2i1, task: 3. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-09T03:44:00.794625Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:534: SelfId: [1:7581698919752395666:2421], TxId: ptqudqgd47iklgerf2i1, task: 3. Ctx: {}. About to drain channelId: 3, hasPeer: 1, peerState:(freeSpace:67108864;inFlightBytes:0;inFlightCount:0;)
2025-12-09T03:44:00.794629Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudqgd47iklgerf2i1, task: 3. no poll, channelId: 2, has inflight messages: [1], last with freeSpace: 1000000, current freeSpace: 1000000
2025-12-09T03:44:00.796601Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:484: [ptqudqgd47iklgerf2i1-0] [2:1] TEvSaveTaskState Apply: task: 1
2025-12-09T03:44:00.796608Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:499: [ptqudqgd47iklgerf2i1-0] [2:1] Send TEvSaveTaskStateResult: task: 1
2025-12-09T03:44:00.796651Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:466: [ptqudqgd47iklgerf2i1-0.2] [2:1] Got TEvSaveTaskStateResult; task 1, status: OK, size: 110
2025-12-09T03:44:00.796661Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:476: [ptqudqgd47iklgerf2i1-0.2] [2:1] Task state saved, need 2 more acks
2025-12-09T03:44:00.796703Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:484: [ptqudqgd47iklgerf2i1-0] [2:1] TEvSaveTaskState Apply: task: 2
2025-12-09T03:44:00.796711Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:499: [ptqudqgd47iklgerf2i1-0] [2:1] Send TEvSaveTaskStateResult: task: 2
2025-12-09T03:44:00.796749Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:466: [ptqudqgd47iklgerf2i1-0.2] [2:1] Got TEvSaveTaskStateResult; task 2, status: OK, size: 29
2025-12-09T03:44:00.796756Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:484: [ptqudqgd47iklgerf2i1-0] [2:1] TEvSaveTaskState Apply: task: 3
2025-12-09T03:44:00.796757Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:499: [ptqudqgd47iklgerf2i1-0] [2:1] Send TEvSaveTaskStateResult: task: 3
2025-12-09T03:44:00.796758Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:476: [ptqudqgd47iklgerf2i1-0.2] [2:1] Task state saved, need 1 more acks
2025-12-09T03:44:00.796779Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:466: [ptqudqgd47iklgerf2i1-0.2] [2:1] Got TEvSaveTaskStateResult; task 3, status: OK, size: 29
2025-12-09T03:44:00.796788Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:476: [ptqudqgd47iklgerf2i1-0.2] [2:1] Task state saved, need 0 more acks
2025-12-09T03:44:00.796790Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:489: [ptqudqgd47iklgerf2i1-0.2] [2:1] Got all acks, changing checkpoint status to 'PendingCommit'
2025-12-09T03:44:00.796803Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:343: [ptqudqgd47iklgerf2i1-0.2] [2:1] Got TEvSetCheckpointPendingCommitStatusRequest
2025-12-09T03:44:00.814438Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:362: [ptqudqgd47iklgerf2i1-0.2] [2:1] Status updated to 'PendingCommit'
2025-12-09T03:44:00.814448Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:364: [ptqudqgd47iklgerf2i1-0.2] [2:1] Send TEvSetCheckpointPendingCommitStatusResponse
2025-12-09T03:44:00.814473Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:501: [ptqudqgd47iklgerf2i1-0.2] [2:1] Got TEvSetCheckpointPendingCommitStatusResponse
2025-12-09T03:44:00.814477Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:516: [ptqudqgd47iklgerf2i1-0.2] [2:1] Checkpoint status changed to 'PendingCommit', committing states to 1 actor(s)
2025-12-09T03:44:00.814495Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:759: SelfId: [1:7581698919752395669:2422], TxId: ptqudqgd47iklgerf2i1, task: 1. Ctx: {}. Commit state
2025-12-09T03:44:00.814508Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:532: [ptqudqgd47iklgerf2i1-0.2] [2:1] Got TEvStateCommitted; task: 1
2025-12-09T03:44:00.814513Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:541: [ptqudqgd47iklgerf2i1-0.2] [2:1] State committed [1:7581698919752395669:2422], need 0 more acks
2025-12-09T03:44:00.814515Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:543: [ptqudqgd47iklgerf2i1-0.2] [2:1] Got all acks, changing checkpoint status to 'Completed'
2025-12-09T03:44:00.814523Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:371: [ptqudqgd47iklgerf2i1-0.2] [2:1] Got TEvCompleteCheckpointRequest
2025-12-09T03:44:00.835965Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:393: [ptqudqgd47iklgerf2i1-0.2] [2:1] Status updated to 'Completed'
2025-12-09T03:44:00.835979Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:400: [ptqudqgd47iklgerf2i1-0.2] [2:1] Send TEvCompleteCheckpointResponse
2025-12-09T03:44:00.836007Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:564: [ptqudqgd47iklgerf2i1-0.2] [2:1] Got TEvCompleteCheckpointResponse
2025-12-09T03:44:00.836013Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:579: [ptqudqgd47iklgerf2i1-0.2] [2:1] Checkpoint completed
2025-12-09T03:44:00.938211Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudqgd47iklgerf2i1"
2025-12-09T03:44:00.938242Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:305: Resolve folder bootstrap. Folder id: my_folder Actor id: [1:7581698924047362986:2436]
2025-12-09T03:44:00.938265Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:367: Cloud id: mock_cloud Folder id: my_folder
2025-12-09T03:44:00.938285Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:91: Get quotas bootstrap. Cloud id: mock_cloud Actor id: [1:7581698924047362987:2437]
2025-12-09T03:44:00.938305Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.analyticsQuery.count IS STALE, Refreshing ...
2025-12-09T03:44:00.938320Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.cpuPercent.count IS STALE, Refreshing ...
2025-12-09T03:44:00.938329Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.streamingQuery.count IS STALE, Refreshing ...
2025-12-09T03:44:00.938342Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.cpuPercent.count=0/10000 REFRESHED
2025-12-09T03:44:00.941683Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.analyticsQuery.count=0/100 REFRESHED
2025-12-09T03:44:00.941710Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.streamingQuery.count=1/100 REFRESHED
2025-12-09T03:44:00.941726Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:493: cloud.mock_cloud{yq.streamingQueryDurationMinutes.count=*/0, yq.queryResult.size=*/20971520, yq.analyticsQuery.count=0/100, yq.analyticsQueryDurationMinutes.count=*/1440, yq.memory.size=*/0, yq.result.size=*/0, yq.cpuPercent.count=0/10000, yq.streamingQuery.count=1/100} SEND QUOTAS
2025-12-09T03:44:00.941737Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:103: Cloud id: mock_cloud Quota count: 8
2025-12-09T03:44:00.941760Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudqgd47iklgerf2i1"
2025-12-09T03:44:00.941807Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:169: Resolve subject type bootstrap. Token: **** (B6C6F477) Actor id: [1:7581698924047362992:2442]
2025-12-09T03:44:00.941831Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:230: Subject Type: federated_account Token: **** (B6C6F477)
2025-12-09T03:44:00.941856Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudqgd47iklgerf2i1"
2025-12-09T03:44:00.941881Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:63: Request actor. Actor id: [1:7581698924047362993:2443]
2025-12-09T03:44:00.941922Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_queries.cpp:641: DescribeQueryRequest: {query_id: "ptqudqgd47iklgerf2i1"
} [root@builtin, **** (B6C6F477)] 
2025-12-09T03:44:00.943057Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.cpuPercent.count=0/10000 NOTIFY CHANGE
2025-12-09T03:44:00.943566Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: DescribeQueryRequest - DescribeQueryResult: {query { meta { common { id: "ptqudqgd47iklgerf2i1" created_by: "root@builtin" modified_by: "root@builtin" created_at { seconds: 1765251817 nanos: 581843000 } modified_at { seconds: 1765251817 nanos: 581843000 } revision: 1 } started_at { seconds: 1765251818 nanos: 422000000 } execute_mode: RUN status: RUNNING last_job_query_revision: 1 last_job_id: "ptjudqgd47ikks1vrsj4-ptqudqgd47iklgerf2i1" started_by: "root@builtin" has_saved_checkpoints: true submitted_at { seconds: 1765251817 nanos: 581843000 } } content { type: STREAMING name: "simple" acl { visibility: PRIVATE } limits { execution_timeout { } } text: "SELECT * FROM myyds_2f.`select_timings_2f_input` LIMIT 1;" syntax: YQL_V1 } plan { json: "{\"Detailed\":{\"Operations\":[{\"Id\":10,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[{\"Name\":\"DqSourceWideWrap\"},{\"Name\":\"NarrowMap\"},{\"Name\":\"Take\"}]}},{\"Id\":8,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[{\"Name\":\"Take\"}]},\"DependsOn\":[10]},{\"Id\":6,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[]},\"DependsOn\":[8]},{\"Id\":3,\"Name\":\"ResPull!\",\"DependsOn\":[6]},{\"Id\":1,\"Name\":\"Commit!\",\"DependsOn\":[3]}],\"OperationRoot\":1,\"Providers\":[],\"OperationStats\":{\"Commit!\":1,\"DqStage\":3,\"ResPull!\":1}},\"Basic\":{\"nodes\":[{\"id\":10,\"level\":1,\"name\":\"DqStage #10\",\"type\":\"op\"},{\"id\":8,\"level\":2,\"name\":\"DqStage #8\",\"type\":\"op\"},{\"id\":6,\"level\":3,\"name\":\"DqStage #6\",\"type\":\"op\"},{\"id\":3,\"level\":4,\"name\":\"ResPull!\",\"type\":\"op\"},{\"id\":1,\"level\":5,\"name\":\"Commit!\",\"type\":\"op\"}],\"links\":[{\"source\":10,\"target\":8},{\"source\":8,\"target\":6},{\"source\":6,\"target\":3},{\"source\":3,\"target\":1}]}}" } statistics { json: "{\"Graph=0\":{\"Tasks\":{\"sum\":3,\"count\":3,\"avg\":1,\"max\":1,\"min\":1},\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":3,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"}}}" } result_set_meta { column { name: "Data" type { type_id: STRING } } } ast { data: "(\n(let $1 (Configure! world (DataSource \'\"config\") \'\"DqEngine\" \'\"force\"))\n(let $2 (DataSink \'result))\n(let $3 (DataSource \'\"pq\" \'\"myyds_2f\"))\n(let $4 (StructType \'(\'\"Data\" (DataType \'String))))\n(let $5 (PqTopic \'\"myyds_2f\" \'\"local\" \'\"select_timings_2f_input\" \'(\'(\'\"PartitionsCount\" \'1)) \'() $4))\n(let $6 \'(\'\"SharedReading\" \'\"0\"))\n(let $7 \'(\'(\'\"Endpoint\" \'\"localhost:4888\") $6 \'(\'\"ReconnectPeriod\" \'\"\") \'(\'\"Format\" \'\"raw\") \'(\'\"ReadGroup\" \'\"ptcudqgd47r6f85fafmq\") \'(\'\"AddBearerToToken\" \'1)))\n(let $8 (DqPqTopicSource world $5 \'(\'\"Data\") $7 (SecureParam \'\"cluster:default_myyds_2f\") \'\"\" $4 \'\"\"))\n(let $9 (Uint64 \'1))\n(let $10 (DqStage \'((DqSource $3 $8)) (lambda \'($14) (block \'(\n  (let $15 \'(\'(\'\"format\" \'\"raw\") \'(\'\"formatSettings\" \'(\'(\'\"data.datetime.formatname\" \'\"POSIX\") \'(\'\"data.timestamp.formatname\" \'\"POSIX\"))) \'(\'\"settings\" \'($6))))\n  (let $16 (DqSourceWideWrap $14 $3 $4 $15))\n  (return (Take (NarrowMap $16 (lambda \'($17) (AsStruct \'(\'\"Data\" $17)))) $9))\n))) \'(\'(\'\"_logical_id\" \'200270))))\n(let $11 (DqStage \'((DqCnUnionAll (TDqOutput $10 \'\"0\"))) (lambda \'($18) (Take $18 $9)) \'(\'(\'\"_logical_id\" \'200283))))\n(let $12 (DqStage \'((DqCnUnionAll (TDqOutput $11 \'\"0\"))) (lambda \'($19) $19) \'(\'(\'\"_logical_id\" \'200320))))\n(let $13 (ResPull! $1 $2 (Key) (DqCnResult (TDqOutput $12 \'\"0\") \'()) \'(\'(\'type) \'(\'autoref)) \'\"dq\"))\n(return (Commit! (Commit! $13 $2) (DataSink \'\"pq\" \'\"myyds_2f\")))\n)\n" } } } SUCCESS
2025-12-09T03:44:00.945769Z :TICKET_PARSER DEBUG: ticket_parser_impl.h:1875: Ticket **** (B6C6F477) (ipv6:[::1]:56106) has now valid token of root@builtin
2025-12-09T03:44:00.945853Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:1061: ControlQueryRequest: query_id: "ptqudqgd47iklgerf2i1"
action: ABORT
2025-12-09T03:44:00.945884Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:305: Resolve folder bootstrap. Folder id: my_folder Actor id: [1:7581698924047362997:2446]
2025-12-09T03:44:00.945909Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:367: Cloud id: mock_cloud Folder id: my_folder
2025-12-09T03:44:00.945933Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:91: Get quotas bootstrap. Cloud id: mock_cloud Actor id: [1:7581698924047362998:2447]
2025-12-09T03:44:00.945954Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.analyticsQuery.count IS STALE, Refreshing ...
2025-12-09T03:44:00.945970Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.cpuPercent.count IS STALE, Refreshing ...
2025-12-09T03:44:00.945981Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.streamingQuery.count IS STALE, Refreshing ...
2025-12-09T03:44:00.946008Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.cpuPercent.count=0/10000 REFRESHED
2025-12-09T03:44:00.947209Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.streamingQuery.count=1/100 NOTIFY CHANGE
2025-12-09T03:44:00.947307Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.analyticsQuery.count=0/100 NOTIFY CHANGE
2025-12-09T03:44:00.948706Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.analyticsQuery.count=0/100 REFRESHED
2025-12-09T03:44:00.948724Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.streamingQuery.count=1/100 REFRESHED
2025-12-09T03:44:00.948740Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:493: cloud.mock_cloud{yq.streamingQueryDurationMinutes.count=*/0, yq.queryResult.size=*/20971520, yq.analyticsQuery.count=0/100, yq.analyticsQueryDurationMinutes.count=*/1440, yq.memory.size=*/0, yq.result.size=*/0, yq.cpuPercent.count=0/10000, yq.streamingQuery.count=1/100} SEND QUOTAS
2025-12-09T03:44:00.948748Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:103: Cloud id: mock_cloud Quota count: 8
2025-12-09T03:44:00.948769Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:1061: ControlQueryRequest: query_id: "ptqudqgd47iklgerf2i1"
action: ABORT
2025-12-09T03:44:00.948825Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:169: Resolve subject type bootstrap. Token: **** (B6C6F477) Actor id: [1:7581698924047363003:2452]
2025-12-09T03:44:00.948858Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:230: Subject Type: federated_account Token: **** (B6C6F477)
2025-12-09T03:44:00.948880Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:1061: ControlQueryRequest: query_id: "ptqudqgd47iklgerf2i1"
action: ABORT
2025-12-09T03:44:00.948907Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:63: Request actor. Actor id: [1:7581698924047363004:2453]
2025-12-09T03:44:00.948975Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_queries.cpp:1342: ControlQueryRequest: {query_id: "ptqudqgd47iklgerf2i1"
action: ABORT
} [root@builtin, **** (B6C6F477)] 
2025-12-09T03:44:00.951660Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.cpuPercent.count=0/10000 NOTIFY CHANGE
2025-12-09T03:44:00.953384Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.analyticsQuery.count=0/100 NOTIFY CHANGE
2025-12-09T03:44:00.953408Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.streamingQuery.count=1/100 NOTIFY CHANGE
2025-12-09T03:44:01.089046Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: ControlQueryRequest - ControlQueryRequest: {} SUCCESS
2025-12-09T03:44:01.090696Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudqgd47iklgerf2i1"
2025-12-09T03:44:01.090731Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:305: Resolve folder bootstrap. Folder id: my_folder Actor id: [1:7581698928342330304:2456]
2025-12-09T03:44:01.090745Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:367: Cloud id: mock_cloud Folder id: my_folder
2025-12-09T03:44:01.090762Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:91: Get quotas bootstrap. Cloud id: mock_cloud Actor id: [1:7581698928342330305:2457]
2025-12-09T03:44:01.090787Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.analyticsQuery.count IS STALE, Refreshing ...
2025-12-09T03:44:01.090799Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.cpuPercent.count IS STALE, Refreshing ...
2025-12-09T03:44:01.090811Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.streamingQuery.count IS STALE, Refreshing ...
2025-12-09T03:44:01.090822Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.cpuPercent.count=0/10000 REFRESHED
2025-12-09T03:44:01.093955Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.analyticsQuery.count=0/100 REFRESHED
2025-12-09T03:44:01.093975Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.streamingQuery.count=1/100 REFRESHED
2025-12-09T03:44:01.094002Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:493: cloud.mock_cloud{yq.streamingQueryDurationMinutes.count=*/0, yq.queryResult.size=*/20971520, yq.analyticsQuery.count=0/100, yq.analyticsQueryDurationMinutes.count=*/1440, yq.memory.size=*/0, yq.result.size=*/0, yq.cpuPercent.count=0/10000, yq.streamingQuery.count=1/100} SEND QUOTAS
2025-12-09T03:44:01.094009Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:103: Cloud id: mock_cloud Quota count: 8
2025-12-09T03:44:01.094030Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudqgd47iklgerf2i1"
2025-12-09T03:44:01.094079Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:169: Resolve subject type bootstrap. Token: **** (B6C6F477) Actor id: [1:7581698928342330310:2462]
2025-12-09T03:44:01.094108Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:230: Subject Type: federated_account Token: **** (B6C6F477)
2025-12-09T03:44:01.094120Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudqgd47iklgerf2i1"
2025-12-09T03:44:01.094146Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:63: Request actor. Actor id: [1:7581698928342330311:2463]
2025-12-09T03:44:01.094195Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_queries.cpp:641: DescribeQueryRequest: {query_id: "ptqudqgd47iklgerf2i1"
} [root@builtin, **** (B6C6F477)] 
2025-12-09T03:44:01.095856Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: DescribeQueryRequest - DescribeQueryResult: {query { meta { common { id: "ptqudqgd47iklgerf2i1" created_by: "root@builtin" modified_by: "root@builtin" created_at { seconds: 1765251817 nanos: 581843000 } modified_at { seconds: 1765251841 nanos: 40964000 } revision: 2 } started_at { seconds: 1765251818 nanos: 422000000 } execute_mode: RUN status: ABORTING_BY_USER last_job_query_revision: 1 last_job_id: "ptjudqgd47ikks1vrsj4-ptqudqgd47iklgerf2i1" started_by: "root@builtin" aborted_by: "root@builtin" has_saved_checkpoints: true submitted_at { seconds: 1765251817 nanos: 581843000 } } content { type: STREAMING name: "simple" acl { visibility: PRIVATE } limits { execution_timeout { } } text: "SELECT * FROM myyds_2f.`select_timings_2f_input` LIMIT 1;" syntax: YQL_V1 } plan { json: "{\"Detailed\":{\"Operations\":[{\"Id\":10,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[{\"Name\":\"DqSourceWideWrap\"},{\"Name\":\"NarrowMap\"},{\"Name\":\"Take\"}]}},{\"Id\":8,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[{\"Name\":\"Take\"}]},\"DependsOn\":[10]},{\"Id\":6,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[]},\"DependsOn\":[8]},{\"Id\":3,\"Name\":\"ResPull!\",\"DependsOn\":[6]},{\"Id\":1,\"Name\":\"Commit!\",\"DependsOn\":[3]}],\"OperationRoot\":1,\"Providers\":[],\"OperationStats\":{\"Commit!\":1,\"DqStage\":3,\"ResPull!\":1}},\"Basic\":{\"nodes\":[{\"id\":10,\"level\":1,\"name\":\"DqStage #10\",\"type\":\"op\"},{\"id\":8,\"level\":2,\"name\":\"DqStage #8\",\"type\":\"op\"},{\"id\":6,\"level\":3,\"name\":\"DqStage #6\",\"type\":\"op\"},{\"id\":3,\"level\":4,\"name\":\"ResPull!\",\"type\":\"op\"},{\"id\":1,\"level\":5,\"name\":\"Commit!\",\"type\":\"op\"}],\"links\":[{\"source\":10,\"target\":8},{\"source\":8,\"target\":6},{\"source\":6,\"target\":3},{\"source\":3,\"target\":1}]}}" } statistics { json: "{\"Graph=0\":{\"Tasks\":{\"sum\":3,\"count\":3,\"avg\":1,\"max\":1,\"min\":1},\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":3,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"}}}" } result_set_meta { column { name: "Data" type { type_id: STRING } } } ast { data: "(\n(let $1 (Configure! world (DataSource \'\"config\") \'\"DqEngine\" \'\"force\"))\n(let $2 (DataSink \'result))\n(let $3 (DataSource \'\"pq\" \'\"myyds_2f\"))\n(let $4 (StructType \'(\'\"Data\" (DataType \'String))))\n(let $5 (PqTopic \'\"myyds_2f\" \'\"local\" \'\"select_timings_2f_input\" \'(\'(\'\"PartitionsCount\" \'1)) \'() $4))\n(let $6 \'(\'\"SharedReading\" \'\"0\"))\n(let $7 \'(\'(\'\"Endpoint\" \'\"localhost:4888\") $6 \'(\'\"ReconnectPeriod\" \'\"\") \'(\'\"Format\" \'\"raw\") \'(\'\"ReadGroup\" \'\"ptcudqgd47r6f85fafmq\") \'(\'\"AddBearerToToken\" \'1)))\n(let $8 (DqPqTopicSource world $5 \'(\'\"Data\") $7 (SecureParam \'\"cluster:default_myyds_2f\") \'\"\" $4 \'\"\"))\n(let $9 (Uint64 \'1))\n(let $10 (DqStage \'((DqSource $3 $8)) (lambda \'($14) (block \'(\n  (let $15 \'(\'(\'\"format\" \'\"raw\") \'(\'\"formatSettings\" \'(\'(\'\"data.datetime.formatname\" \'\"POSIX\") \'(\'\"data.timestamp.formatname\" \'\"POSIX\"))) \'(\'\"settings\" \'($6))))\n  (let $16 (DqSourceWideWrap $14 $3 $4 $15))\n  (return (Take (NarrowMap $16 (lambda \'($17) (AsStruct \'(\'\"Data\" $17)))) $9))\n))) \'(\'(\'\"_logical_id\" \'200270))))\n(let $11 (DqStage \'((DqCnUnionAll (TDqOutput $10 \'\"0\"))) (lambda \'($18) (Take $18 $9)) \'(\'(\'\"_logical_id\" \'200283))))\n(let $12 (DqStage \'((DqCnUnionAll (TDqOutput $11 \'\"0\"))) (lambda \'($19) $19) \'(\'(\'\"_logical_id\" \'200320))))\n(let $13 (ResPull! $1 $2 (Key) (DqCnResult (TDqOutput $12 \'\"0\") \'()) \'(\'(\'type) \'(\'autoref)) \'\"dq\"))\n(return (Commit! (Commit! $13 $2) (DataSink \'\"pq\" \'\"myyds_2f\")))\n)\n" } } } SUCCESS
2025-12-09T03:44:01.096144Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.cpuPercent.count=0/10000 NOTIFY CHANGE
2025-12-09T03:44:01.097883Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.streamingQuery.count=1/100 NOTIFY CHANGE
2025-12-09T03:44:01.097935Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.analyticsQuery.count=0/100 NOTIFY CHANGE
2025-12-09T03:44:01.580948Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-12-09T03:44:01.581590Z :YQ_CONTROL_PLANE_STORAGE TRACE: nodes_health_check.cpp:38: NodesHealthCheckRequest: {tenant: "/default"
node {
  node_id: 1
  instance_id: "35c66de4-409e1c92-b6739c87-39e4782e"
  hostname: "ghrun-syjwtgwtdu"
  active_workers: 3
  memory_allocated: 25769803776
  interconnect_port: 5184
  node_address: "127.0.1.1"
}
}
2025-12-09T03:44:01.587120Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: 323dda4c-6ce2c19b-118bbaa6-9f349aa617, Host: ghrun-syjwtgwtdu, Tenant: /default
2025-12-09T03:44:01.587221Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: NodesHealthCheckRequest - NodesHealthCheckResult: {nodes { node_id: 1 instance_id: "35c66de4-409e1c92-b6739c87-39e4782e" hostname: "ghrun-syjwtgwtdu" active_workers: 3 memory_allocated: 25769803776 node_address: "127.0.1.1" } } SUCCESS
2025-12-09T03:44:01.587480Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: 323dda4c-6ce2c19b-118bbaa6-9f349aa617, Host: ghrun-syjwtgwtdu, Tenant: /default, Request CP::GetTask with size: 69 bytes
2025-12-09T03:44:01.587521Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/default"
owner_id: "323dda4c-6ce2c19b-118bbaa6-9f349aa617"
host: "ghrun-syjwtgwtdu"
node_id: 1
}
2025-12-09T03:44:01.587576Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:389: Send NodeInfo with size: 0 to DynamicNameserver
2025-12-09T03:44:01.589427Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-09T03:44:01.589451Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: 323dda4c-6ce2c19b-118bbaa6-9f349aa617, Host: ghrun-syjwtgwtdu, Tenant: /default, Got CP::GetTask Response
2025-12-09T03:44:01.589699Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-09T03:44:01.589708Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-09T03:44:01.590805Z :FQ_CONTROL_PLANE_CONFIG TRACE: control_plane_config.cpp:192: LOADED TenantInfo: State NOT changed
2025-12-09T03:44:01.598427Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudqgd47iklgerf2i1"
2025-12-09T03:44:01.598482Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:305: Resolve folder bootstrap. Folder id: my_folder Actor id: [1:7581698928342330322:2473]
2025-12-09T03:44:01.598511Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:367: Cloud id: mock_cloud Folder id: my_folder
2025-12-09T03:44:01.598536Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:91: Get quotas bootstrap. Cloud id: mock_cloud Actor id: [1:7581698928342330323:2474]
2025-12-09T03:44:01.598559Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.analyticsQuery.count IS STALE, Refreshing ...
2025-12-09T03:44:01.598574Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.cpuPercent.count IS STALE, Refreshing ...
2025-12-09T03:44:01.598586Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.streamingQuery.count IS STALE, Refreshing ...
2025-12-09T03:44:01.598599Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.cpuPercent.count=0/10000 REFRESHED
2025-12-09T03:44:01.602312Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.analyticsQuery.count=0/100 REFRESHED
2025-12-09T03:44:01.602359Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.streamingQuery.count=1/100 REFRESHED
2025-12-09T03:44:01.602378Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:493: cloud.mock_cloud{yq.streamingQueryDurationMinutes.count=*/0, yq.queryResult.size=*/20971520, yq.analyticsQuery.count=0/100, yq.analyticsQueryDurationMinutes.count=*/1440, yq.memory.size=*/0, yq.result.size=*/0, yq.cpuPercent.count=0/10000, yq.streamingQuery.count=1/100} SEND QUOTAS
2025-12-09T03:44:01.602393Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:103: Cloud id: mock_cloud Quota count: 8
2025-12-09T03:44:01.602427Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudqgd47iklgerf2i1"
2025-12-09T03:44:01.602475Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:169: Resolve subject type bootstrap. Token: **** (B6C6F477) Actor id: [1:7581698928342330328:2479]
2025-12-09T03:44:01.602510Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:230: Subject Type: federated_account Token: **** (B6C6F477)
2025-12-09T03:44:01.602532Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudqgd47iklgerf2i1"
2025-12-09T03:44:01.602567Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:63: Request actor. Actor id: [1:7581698928342330329:2480]
2025-12-09T03:44:01.602609Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_queries.cpp:641: DescribeQueryRequest: {query_id: "ptqudqgd47iklgerf2i1"
} [root@builtin, **** (B6C6F477)] 
2025-12-09T03:44:01.603671Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.cpuPercent.count=0/10000 NOTIFY CHANGE
2025-12-09T03:44:01.604136Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: DescribeQueryRequest - DescribeQueryResult: {query { meta { common { id: "ptqudqgd47iklgerf2i1" created_by: "root@builtin" modified_by: "root@builtin" created_at { seconds: 1765251817 nanos: 581843000 } modified_at { seconds: 1765251841 nanos: 40964000 } revision: 2 } started_at { seconds: 1765251818 nanos: 422000000 } execute_mode: RUN status: ABORTING_BY_USER last_job_query_revision: 1 last_job_id: "ptjudqgd47ikks1vrsj4-ptqudqgd47iklgerf2i1" started_by: "root@builtin" aborted_by: "root@builtin" has_saved_checkpoints: true submitted_at { seconds: 1765251817 nanos: 581843000 } } content { type: STREAMING name: "simple" acl { visibility: PRIVATE } limits { execution_timeout { } } text: "SELECT * FROM myyds_2f.`select_timings_2f_input` LIMIT 1;" syntax: YQL_V1 } plan { json: "{\"Detailed\":{\"Operations\":[{\"Id\":10,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[{\"Name\":\"DqSourceWideWrap\"},{\"Name\":\"NarrowMap\"},{\"Name\":\"Take\"}]}},{\"Id\":8,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[{\"Name\":\"Take\"}]},\"DependsOn\":[10]},{\"Id\":6,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[]},\"DependsOn\":[8]},{\"Id\":3,\"Name\":\"ResPull!\",\"DependsOn\":[6]},{\"Id\":1,\"Name\":\"Commit!\",\"DependsOn\":[3]}],\"OperationRoot\":1,\"Providers\":[],\"OperationStats\":{\"Commit!\":1,\"DqStage\":3,\"ResPull!\":1}},\"Basic\":{\"nodes\":[{\"id\":10,\"level\":1,\"name\":\"DqStage #10\",\"type\":\"op\"},{\"id\":8,\"level\":2,\"name\":\"DqStage #8\",\"type\":\"op\"},{\"id\":6,\"level\":3,\"name\":\"DqStage #6\",\"type\":\"op\"},{\"id\":3,\"level\":4,\"name\":\"ResPull!\",\"type\":\"op\"},{\"id\":1,\"level\":5,\"name\":\"Commit!\",\"type\":\"op\"}],\"links\":[{\"source\":10,\"target\":8},{\"source\":8,\"target\":6},{\"source\":6,\"target\":3},{\"source\":3,\"target\":1}]}}" } statistics { json: "{\"Graph=0\":{\"Tasks\":{\"sum\":3,\"count\":3,\"avg\":1,\"max\":1,\"min\":1},\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":3,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"}}}" } result_set_meta { column { name: "Data" type { type_id: STRING } } } ast { data: "(\n(let $1 (Configure! world (DataSource \'\"config\") \'\"DqEngine\" \'\"force\"))\n(let $2 (DataSink \'result))\n(let $3 (DataSource \'\"pq\" \'\"myyds_2f\"))\n(let $4 (StructType \'(\'\"Data\" (DataType \'String))))\n(let $5 (PqTopic \'\"myyds_2f\" \'\"local\" \'\"select_timings_2f_input\" \'(\'(\'\"PartitionsCount\" \'1)) \'() $4))\n(let $6 \'(\'\"SharedReading\" \'\"0\"))\n(let $7 \'(\'(\'\"Endpoint\" \'\"localhost:4888\") $6 \'(\'\"ReconnectPeriod\" \'\"\") \'(\'\"Format\" \'\"raw\") \'(\'\"ReadGroup\" \'\"ptcudqgd47r6f85fafmq\") \'(\'\"AddBearerToToken\" \'1)))\n(let $8 (DqPqTopicSource world $5 \'(\'\"Data\") $7 (SecureParam \'\"cluster:default_myyds_2f\") \'\"\" $4 \'\"\"))\n(let $9 (Uint64 \'1))\n(let $10 (DqStage \'((DqSource $3 $8)) (lambda \'($14) (block \'(\n  (let $15 \'(\'(\'\"format\" \'\"raw\") \'(\'\"formatSettings\" \'(\'(\'\"data.datetime.formatname\" \'\"POSIX\") \'(\'\"data.timestamp.formatname\" \'\"POSIX\"))) \'(\'\"settings\" \'($6))))\n  (let $16 (DqSourceWideWrap $14 $3 $4 $15))\n  (return (Take (NarrowMap $16 (lambda \'($17) (AsStruct \'(\'\"Data\" $17)))) $9))\n))) \'(\'(\'\"_logical_id\" \'200270))))\n(let $11 (DqStage \'((DqCnUnionAll (TDqOutput $10 \'\"0\"))) (lambda \'($18) (Take $18 $9)) \'(\'(\'\"_logical_id\" \'200283))))\n(let $12 (DqStage \'((DqCnUnionAll (TDqOutput $11 \'\"0\"))) (lambda \'($19) $19) \'(\'(\'\"_logical_id\" \'200320))))\n(let $13 (ResPull! $1 $2 (Key) (DqCnResult (TDqOutput $12 \'\"0\") \'()) \'(\'(\'type) \'(\'autoref)) \'\"dq\"))\n(return (Commit! (Commit! $13 $2) (DataSink \'\"pq\" \'\"myyds_2f\")))\n)\n" } } } SUCCESS
2025-12-09T03:44:01.607903Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.streamingQuery.count=1/100 NOTIFY CHANGE
2025-12-09T03:44:01.607943Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.analyticsQuery.count=0/100 NOTIFY CHANGE
2025-12-09T03:44:01.618930Z :YQL_PROXY TRACE: log.cpp:64: SessionId:  2025-12-09 03:44:01.618 TRACE ydbd(pid=1648981, tid=0x00007FEE5126A640) [DQ] task_controller_impl.h:271:  [1:7581698919752395661:2418] ExportStats Summary
2025-12-09T03:44:01.619162Z :FQ_PINGER TRACE: pinger.cpp:250: QueryId: ptqudqgd47iklgerf2i1, Owner: 323dda4c-6ce2c19b-118bbaa6-9f349aa614 Forward ping request: { statistics: "{\"Graph=0\":{\"TaskRunner\":{\"Stage=200473\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":1,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":1,\"count\":1,\"avg\":1,\"max\":1,\"min\":1}},\"Stage=200494\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":1,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":1,\"count\":1,\"avg\":1,\"max\":1,\"min\":1}},\"Stage=200511\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":1,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":1,\"count\":1,\"avg\":1,\"max\":1,\"min\":1}},\"Stage=Total\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":3,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":3,\"count\":3,\"avg\":1,\"max\":1,\"min\":1}}}}}" }
2025-12-09T03:44:01.619169Z :FQ_PINGER TRACE: pinger.cpp:393: QueryId: ptqudqgd47iklgerf2i1, Owner: 323dda4c-6ce2c19b-118bbaa6-9f349aa614 Forward request Private::PingTask
2025-12-09T03:44:01.619652Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudqgd47iklgerf2i1, Owner: 323dda4c-6ce2c19b-118bbaa6-9f349aa614, Request CP::PingTask with size: 741 bytes
2025-12-09T03:44:01.619734Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "323dda4c-6ce2c19b-118bbaa6-9f349aa614"
query_id {
  value: "ptqudqgd47iklgerf2i1"
}
statistics: "{\"Graph=0\":{\"TaskRunner\":{\"Stage=200473\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":1,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":1,\"count\":1,\"avg\":1,\"max\":1,\"min\":1}},\"Stage=200494\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":1,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":1,\"count\":1,\"avg\":1,\"max\":1,\"min\":1}},\"Stage=200511\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":1,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":1,\"count\":1,\"avg\":1,\"max\":1,\"min\":1}},\"Stage=Total\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":3,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":3,\"count\":3,\"avg\":1,\"max\":1,\"min\":1}}}}}"
scope: "yandexcloud://my_folder"
deadline {
  seconds: 1765338239
  nanos: 590988000
}
tenant: "/default"
}
2025-12-09T03:44:01.628473Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {action: ABORT expired_at { seconds: 1765251861 nanos: 624000000 } } SUCCESS
2025-12-09T03:44:01.628496Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudqgd47iklgerf2i1, Owner: 323dda4c-6ce2c19b-118bbaa6-9f349aa614, Got CP::PingTaskResponse
2025-12-09T03:44:01.628715Z :FQ_PINGER TRACE: pinger.cpp:338: QueryId: ptqudqgd47iklgerf2i1, Owner: 323dda4c-6ce2c19b-118bbaa6-9f349aa614 Ping response success: { action: ABORT expired_at { seconds: 1765251861 nanos: 624000000 } }
2025-12-09T03:44:01.628722Z :FQ_PINGER DEBUG: pinger.cpp:342: QueryId: ptqudqgd47iklgerf2i1, Owner: 323dda4c-6ce2c19b-118bbaa6-9f349aa614 Query action: ABORT
2025-12-09T03:44:01.628736Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:690: QueryId: ptqudqgd47iklgerf2i1 New query action received: ABORT
2025-12-09T03:44:01.628741Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:1827: QueryId: ptqudqgd47iklgerf2i1 Is about to finish query with status ABORTED_BY_USER
2025-12-09T03:44:01.628743Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:1820: QueryId: ptqudqgd47iklgerf2i1 Write finalizing status: ABORTING_BY_USER
2025-12-09T03:44:01.628749Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:528: QueryId: ptqudqgd47iklgerf2i1 Cancel running query
2025-12-09T03:44:01.628764Z :FQ_RUN_ACTOR TRACE: run_actor.cpp:880: QueryId: ptqudqgd47iklgerf2i1 Forward ping response. Success: 1. Cookie: 6
2025-12-09T03:44:01.628774Z :FQ_PINGER TRACE: pinger.cpp:250: QueryId: ptqudqgd47iklgerf2i1, Owner: 323dda4c-6ce2c19b-118bbaa6-9f349aa614 Forward ping request: { status: ABORTING_BY_USER }
2025-12-09T03:44:01.628787Z :FQ_PINGER TRACE: pinger.cpp:393: QueryId: ptqudqgd47iklgerf2i1, Owner: 323dda4c-6ce2c19b-118bbaa6-9f349aa614 Forward request Private::PingTask
2025-12-09T03:44:01.628868Z :YQL_PROXY DEBUG: log.cpp:64: SessionId:  2025-12-09 03:44:01.628 DEBUG ydbd(pid=1648981, tid=0x00007FEE5126A640) [DQ] task_controller_impl.h:130: AbortExecution from [1:7581698919752395650:2407]:ABORTED { <main>: Error: ABORTED_BY_USER }
2025-12-09T03:44:01.628882Z :YQL_PROXY DEBUG: log.cpp:64: SessionId:  2025-12-09 03:44:01.628 DEBUG ydbd(pid=1648981, tid=0x00007FEE5126A640) [DQ] task_controller_impl.h:598: OnError { <main>: Error: ABORTED_BY_USER } ABORTED
2025-12-09T03:44:01.628935Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudqgd47iklgerf2i1 2025-12-09 03:44:01.628 DEBUG ydbd(pid=1648981, tid=0x00007FEE5126A640) [DQ] executer_actor.cpp:304: {ptqudqgd47iklgerf2i1} OnFailure, status=4, issues size=1, sender=[1:7581698919752395661:2418]
2025-12-09T03:44:01.628949Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudqgd47iklgerf2i1 2025-12-09 03:44:01.628 DEBUG ydbd(pid=1648981, tid=0x00007FEE5126A640) [DQ] executer_actor.cpp:315: {ptqudqgd47iklgerf2i1} Issues: <main>: Error: ABORTED_BY_USER

2025-12-09T03:44:01.628954Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudqgd47iklgerf2i1 2025-12-09 03:44:01.628 DEBUG ydbd(pid=1648981, tid=0x00007FEE5126A640) [DQ] executer_actor.cpp:284: {ptqudqgd47iklgerf2i1} Finish with status=4 issues=<main>: Error: ABORTED_BY_USER

2025-12-09T03:44:01.629032Z :FQ_RESULT_WRITER DEBUG: result_writer.cpp:126: TraceId: ptqudqgd47iklgerf2i1#ptrudqgd46p09uqrv22g#yandexcloud://my_folder#5b0dfe77-e3652039-a7229327-b5b5424c4#mock_cloud Send response to executer
2025-12-09T03:44:01.629070Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudqgd47iklgerf2i1 2025-12-09 03:44:01.629 DEBUG ydbd(pid=1648981, tid=0x00007FEE50268640) [DQ] executer_actor.cpp:341: {ptqudqgd47iklgerf2i1} OnQueryResponse status=4 issuses_size=1
2025-12-09T03:44:01.629090Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:1396: QueryId: ptqudqgd47iklgerf2i1 TEvQueryResponse received on finish
2025-12-09T03:44:01.629095Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:1233: QueryId: ptqudqgd47iklgerf2i1 Query response CANCELLED. Result set index: 0. Issues count: 1. Rows count: 0
2025-12-09T03:44:01.629142Z :FQ_RESULT_WRITER INFO: result_writer.cpp:87: TraceId: ptqudqgd47iklgerf2i1#ptrudqgd46p09uqrv22g#yandexcloud://my_folder#5b0dfe77-e3652039-a7229327-b5b5424c4#mock_cloud FinishWrite, Records: 0 HasError: 0 Size: 0 Rows: 0 FreeSpace: 67108864 Duration: 2.013322s AvgSpeed: 0 ResultChunks.size(): 0
2025-12-09T03:44:01.629190Z :YQL_PROXY TRACE: log.cpp:64: SessionId: 323dda4c-6ce2c19b-118bbaa6-9f349aa6 2025-12-09 03:44:01.629 TRACE ydbd(pid=1648981, tid=0x00007FEE50268640) [DQ] task_controller_impl.h:271:  [1:7581698919752395661:2418] ExportStats Summary
2025-12-09T03:44:01.629229Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:657: [ptqudqgd47iklgerf2i1-0.2] PassAway
2025-12-09T03:44:01.629265Z :KQP_COMPUTE ERROR: dq_compute_actor_impl.h:1205: SelfId: [1:7581698919752395669:2422], TxId: ptqudqgd47iklgerf2i1, task: 1. Ctx: {}. Handle abort execution event from: [1:7581698863917820441:2070], status: UNAVAILABLE, reason: { <main>: Error: Aborted by LWM }
2025-12-09T03:44:01.629296Z :KQP_COMPUTE DEBUG: dq_compute_actor_channels.cpp:494: TxId: ptqudqgd47iklgerf2i1, task: 1. pass away
2025-12-09T03:44:01.629299Z :KQP_COMPUTE ERROR: dq_compute_actor_impl.h:1205: SelfId: [1:7581698919752395663:2420], TxId: ptqudqgd47iklgerf2i1, task: 2. Ctx: {}. Handle abort execution event from: [1:7581698863917820441:2070], status: UNAVAILABLE, reason: { <main>: Error: Aborted by LWM }
2025-12-09T03:44:01.629317Z :YDB_SDK INFO: actor.cpp:37: 2025-12-09T03:44:01.629312Z :INFO: [local] [local] [bb9b2be8-5d4fd4aa-2aa5709c-8acb7c32] Closing read session. Close timeout: 0.000000s
2025-12-09T03:44:01.629325Z :KQP_COMPUTE DEBUG: dq_compute_actor_channels.cpp:494: TxId: ptqudqgd47iklgerf2i1, task: 2. pass away
2025-12-09T03:44:01.629325Z :KQP_COMPUTE ERROR: dq_compute_actor_impl.h:1205: SelfId: [1:7581698919752395666:2421], TxId: ptqudqgd47iklgerf2i1, task: 3. Ctx: {}. Handle abort execution event from: [1:7581698863917820441:2070], status: UNAVAILABLE, reason: { <main>: Error: Aborted by LWM }
2025-12-09T03:44:01.629326Z :YDB_SDK INFO: actor.cpp:37: 2025-12-09T03:44:01.629324Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:select_timings_2f_input:0:1:0:0
2025-12-09T03:44:01.629332Z :YDB_SDK INFO: actor.cpp:37: 2025-12-09T03:44:01.629330Z :INFO: [local] [local] [bb9b2be8-5d4fd4aa-2aa5709c-8acb7c32] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1860 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:44:01.629343Z :KQP_COMPUTE DEBUG: dq_compute_actor_channels.cpp:494: TxId: ptqudqgd47iklgerf2i1, task: 3. pass away
2025-12-09T03:44:01.629343Z :YDB_SDK NOTICE: actor.cpp:37: 2025-12-09T03:44:01.629341Z :NOTICE: [local] [local] [bb9b2be8-5d4fd4aa-2aa5709c-8acb7c32] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Close with zero timeout " }
2025-12-09T03:44:01.629350Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-09T03:44:01.629349Z :DEBUG: [local] [local] [bb9b2be8-5d4fd4aa-2aa5709c-8acb7c32] [] Abort session to cluster
2025-12-09T03:44:01.629482Z :YDB_SDK INFO: actor.cpp:37: 2025-12-09T03:44:01.629480Z :INFO: [local] [local] [bb9b2be8-5d4fd4aa-2aa5709c-8acb7c32] Closing read session. Close timeout: 0.000000s
2025-12-09T03:44:01.629490Z :YDB_SDK INFO: actor.cpp:37: 2025-12-09T03:44:01.629489Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): -:select_timings_2f_input:0:1:0:0
2025-12-09T03:44:01.629493Z :YDB_SDK INFO: actor.cpp:37: 2025-12-09T03:44:01.629492Z :INFO: [local] [local] [bb9b2be8-5d4fd4aa-2aa5709c-8acb7c32] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1860 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-09T03:44:01.629498Z :YDB_SDK NOTICE: actor.cpp:37: 2025-12-09T03:44:01.629497Z :NOTICE: [local] [local] [bb9b2be8-5d4fd4aa-2aa5709c-8acb7c32] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-09T03:44:01.629536Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudqgd47iklgerf2i1, Owner: 323dda4c-6ce2c19b-118bbaa6-9f349aa614, Request CP::PingTask with size: 117 bytes
2025-12-09T03:44:01.629721Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "323dda4c-6ce2c19b-118bbaa6-9f349aa614"
query_id {
  value: "ptqudqgd47iklgerf2i1"
}
status: ABORTING_BY_USER
scope: "yandexcloud://my_folder"
deadline {
  seconds: 1765338239
  nanos: 590988000
}
tenant: "/default"
}
2025-12-09T03:44:01.638929Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {action: ABORT expired_at { seconds: 1765251861 nanos: 634000000 } } SUCCESS
2025-12-09T03:44:01.638956Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudqgd47iklgerf2i1, Owner: 323dda4c-6ce2c19b-118bbaa6-9f349aa614, Got CP::PingTaskResponse
2025-12-09T03:44:01.639194Z :FQ_PINGER TRACE: pinger.cpp:338: QueryId: ptqudqgd47iklgerf2i1, Owner: 323dda4c-6ce2c19b-118bbaa6-9f349aa614 Ping response success: { action: ABORT expired_at { seconds: 1765251861 nanos: 634000000 } }
2025-12-09T03:44:01.639202Z :FQ_PINGER DEBUG: pinger.cpp:342: QueryId: ptqudqgd47iklgerf2i1, Owner: 323dda4c-6ce2c19b-118bbaa6-9f349aa614 Query action: ABORT
2025-12-09T03:44:01.639217Z :FQ_RUN_ACTOR TRACE: run_actor.cpp:880: QueryId: ptqudqgd47iklgerf2i1 Forward ping response. Success: 1. Cookie: 3
2025-12-09T03:44:01.639218Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:887: QueryId: ptqudqgd47iklgerf2i1 Finalizing status is saved
2025-12-09T03:44:01.639247Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:1507: QueryId: ptqudqgd47iklgerf2i1 Start rate limiter resource deleter
2025-12-09T03:44:01.639260Z :STREAMS DEBUG: read_rule_deleter.cpp:214: ptqudqgd47iklgerf2i1: Create read rule deleter actor for `select_timings_2f_input` [0]
2025-12-09T03:44:01.639287Z :STREAMS DEBUG: read_rule_deleter.cpp:106: ptqudqgd47iklgerf2i1: Make request for read rule deletion for topic `select_timings_2f_input` [0]
2025-12-09T03:44:01.639637Z :YQL_PRIVATE_PROXY DEBUG: rate_limiter_resources.cpp:175: PrivateDeleteRateLimiterResource - QueryId: ptqudqgd47iklgerf2i1, Owner: 323dda4c-6ce2c19b-118bbaa6-9f349aa614, Request CP::DeleteRateLimiterResource with size: 98 bytes
2025-12-09T03:44:01.639676Z :YQ_CONTROL_PLANE_STORAGE TRACE: request_actor.h:57: DeleteRateLimiterResourceRequest: {owner_id: "323dda4c-6ce2c19b-118bbaa6-9f349aa614"
query_id {
  value: "ptqudqgd47iklgerf2i1"
}
scope: "yandexcloud://my_folder"
tenant: "/default"
} 
2025-12-09T03:44:01.674670Z :YQ_CONTROL_PLANE_STORAGE DEBUG: rate_limiter_resources.cpp:74: DeleteRateLimiterResourceRequest. Got response from database: SUCCESS
2025-12-09T03:44:01.674792Z :YQ_RATE_LIMITER DEBUG: schema.cpp:71: Run delete rate limiter resource "mock_cloud/my_folder/ptqudqgd47iklgerf2i1" actor
2025-12-09T03:44:01.674800Z :YQ_RATE_LIMITER DEBUG: schema.cpp:113: Call delete rate limiter resource "mock_cloud/my_folder/ptqudqgd47iklgerf2i1"
2025-12-09T03:44:01.676139Z :YQ_RATE_LIMITER DEBUG: schema.cpp:179: Successfully deleted rate limiter resource "mock_cloud/my_folder/ptqudqgd47iklgerf2i1"
2025-12-09T03:44:01.676148Z :YQ_RATE_LIMITER DEBUG: schema.cpp:122: Reply for delete rate limiter resource "mock_cloud/my_folder/ptqudqgd47iklgerf2i1": 
2025-12-09T03:44:01.676173Z :YQ_CONTROL_PLANE_STORAGE DEBUG: rate_limiter_resources.cpp:219: Got delete response from rate limiter service
2025-12-09T03:44:01.676199Z :YQL_PRIVATE_PROXY DEBUG: rate_limiter_resources.cpp:199: PrivateDeleteRateLimiterResource - QueryId: ptqudqgd47iklgerf2i1, Owner: 323dda4c-6ce2c19b-118bbaa6-9f349aa614, Got CP::DeleteRateLimiterResourceResponse
2025-12-09T03:44:01.676461Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:1498: QueryId: ptqudqgd47iklgerf2i1 Rate limiter resource deletion finished. Success: 1. Issues: 
2025-12-09T03:44:01.676472Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:1919: QueryId: ptqudqgd47iklgerf2i1 SendPingAndPassAway, FinalQueryStatus ABORTED_BY_USER
2025-12-09T03:44:01.676495Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:536: QueryId: ptqudqgd47iklgerf2i1 PassAway
2025-12-09T03:44:01.676595Z :FQ_PINGER TRACE: pinger.cpp:250: QueryId: ptqudqgd47iklgerf2i1, Owner: 323dda4c-6ce2c19b-118bbaa6-9f349aa614 Forward ping request: { result_id { value: "ptrudqgd3iir1q3i5nvf" } status: ABORTED_BY_USER issues { message: "ABORTED_BY_USER" severity: 1 } statistics: "{\"Graph=0\":{\"Actor\":{\"ActorCreateTimeUs\":{\"sum\":\"753us\",\"count\":3,\"avg\":\"251us\",\"max\":\"300us\",\"min\":\"190us\"}},\"AllocateWorkersUs\":{\"sum\":\"919us\",\"count\":1,\"avg\":\"919us\",\"max\":\"919us\",\"min\":\"919us\"},\"ExecutionTimeUs\":{\"sum\":\"2.01s\",\"count\":1,\"avg\":\"2.01s\",\"max\":\"2.01s\",\"min\":\"2.01s\"},\"TaskRunner\":{\"Stage=200473\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":1,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":1,\"count\":1,\"avg\":1,\"max\":1,\"min\":1}},\"Stage=200494\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":1,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":1,\"count\":1,\"avg\":1,\"max\":1,\"min\":1}},\"Stage=200511\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":1,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":1,\"count\":1,\"avg\":1,\"max\":1,\"min\":1}},\"Stage=Total\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":3,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":3,\"count\":3,\"avg\":1,\"max\":1,\"min\":1}}},\"UniqueWorkers\":{\"sum\":1,\"count\":1,\"avg\":1,\"max\":1,\"min\":1}}}" result_set_meta { column { name: "Data" type { type_id: STRING } } } resources { rate_limiter: READY compilation: READY topic_consumers_state: READY rate_limiter_path: "local/RateLimiter_b0e8c56f-8a62-42ec-8405-5b233b311755/rate_limiter" topic_consumers { database: "local" topic_path: "select_timings_2f_input" consumer_name: "ptqudqgd47iklgerf2i1" cluster_endpoint: "localhost:4888" token_name: "cluster:default_myyds_2f" add_bearer_to_token: true } } finished_at { seconds: 1765251841 nanos: 628000000 } }
2025-12-09T03:44:01.676604Z :FQ_PINGER TRACE: pinger.cpp:393: QueryId: ptqudqgd47iklgerf2i1, Owner: 323dda4c-6ce2c19b-118bbaa6-9f349aa614 Forward request Private::PingTask
2025-12-09T03:44:01.677011Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudqgd47iklgerf2i1, Owner: 323dda4c-6ce2c19b-118bbaa6-9f349aa614, Request CP::PingTask with size: 1329 bytes
2025-12-09T03:44:01.677109Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "323dda4c-6ce2c19b-118bbaa6-9f349aa614"
query_id {
  value: "ptqudqgd47iklgerf2i1"
}
result_id {
  value: "ptrudqgd3iir1q3i5nvf"
}
status: ABORTED_BY_USER
issues {
  message: "ABORTED_BY_USER"
  severity: 1
}
statistics: "{\"Graph=0\":{\"Actor\":{\"ActorCreateTimeUs\":{\"sum\":\"753us\",\"count\":3,\"avg\":\"251us\",\"max\":\"300us\",\"min\":\"190us\"}},\"AllocateWorkersUs\":{\"sum\":\"919us\",\"count\":1,\"avg\":\"919us\",\"max\":\"919us\",\"min\":\"919us\"},\"ExecutionTimeUs\":{\"sum\":\"2.01s\",\"count\":1,\"avg\":\"2.01s\",\"max\":\"2.01s\",\"min\":\"2.01s\"},\"TaskRunner\":{\"Stage=200473\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":1,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":1,\"count\":1,\"avg\":1,\"max\":1,\"min\":1}},\"Stage=200494\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":1,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":1,\"count\":1,\"avg\":1,\"max\":1,\"min\":1}},\"Stage=200511\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":1,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":1,\"count\":1,\"avg\":1,\"max\":1,\"min\":1}},\"Stage=Total\":{\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":3,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"},\"Tasks\":{\"sum\":3,\"count\":3,\"avg\":1,\"max\":1,\"min\":1}}},\"UniqueWorkers\":{\"sum\":1,\"count\":1,\"avg\":1,\"max\":1,\"min\":1}}}"
result_set_meta {
  column {
    name: "Data"
    type {
      type_id: STRING
    }
  }
}
resources {
  rate_limiter: READY
  compilation: READY
  topic_consumers_state: READY
  rate_limiter_path: "local/RateLimiter_b0e8c56f-8a62-42ec-8405-5b233b311755/rate_limiter"
  topic_consumers {
    database: "local"
    topic_path: "select_timings_2f_input"
    consumer_name: "ptqudqgd47iklgerf2i1"
    cluster_endpoint: "localhost:4888"
    token_name: "cluster:default_myyds_2f"
    add_bearer_to_token: true
  }
}
scope: "yandexcloud://my_folder"
finished_at {
  seconds: 1765251841
  nanos: 628000000
}
deadline {
  seconds: 1765338239
  nanos: 590988000
}
tenant: "/default"
}
2025-12-09T03:44:01.750567Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {action: ABORT } SUCCESS
2025-12-09T03:44:01.750613Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudqgd47iklgerf2i1, Owner: 323dda4c-6ce2c19b-118bbaa6-9f349aa614, Got CP::PingTaskResponse
2025-12-09T03:44:01.750891Z :FQ_PINGER TRACE: pinger.cpp:338: QueryId: ptqudqgd47iklgerf2i1, Owner: 323dda4c-6ce2c19b-118bbaa6-9f349aa614 Ping response success: { action: ABORT }
2025-12-09T03:44:01.750915Z :FQ_PINGER DEBUG: pinger.cpp:379: QueryId: ptqudqgd47iklgerf2i1, Owner: 323dda4c-6ce2c19b-118bbaa6-9f349aa614 Query finished
2025-12-09T03:44:01.750917Z :FQ_PINGER TRACE: pinger.cpp:187: QueryId: ptqudqgd47iklgerf2i1, Owner: 323dda4c-6ce2c19b-118bbaa6-9f349aa614 Stop Pinger
2025-12-09T03:44:02.106779Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudqgd47iklgerf2i1"
2025-12-09T03:44:02.106821Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:305: Resolve folder bootstrap. Folder id: my_folder Actor id: [1:7581698932637297646:2500]
2025-12-09T03:44:02.106842Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:367: Cloud id: mock_cloud Folder id: my_folder
2025-12-09T03:44:02.106860Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:91: Get quotas bootstrap. Cloud id: mock_cloud Actor id: [1:7581698932637297647:2501]
2025-12-09T03:44:02.106888Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.analyticsQuery.count IS STALE, Refreshing ...
2025-12-09T03:44:02.106906Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.cpuPercent.count IS STALE, Refreshing ...
2025-12-09T03:44:02.106926Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.streamingQuery.count IS STALE, Refreshing ...
2025-12-09T03:44:02.106934Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.cpuPercent.count=0/10000 REFRESHED
2025-12-09T03:44:02.108997Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.analyticsQuery.count=0/100 REFRESHED
2025-12-09T03:44:02.109020Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.streamingQuery.count=0/100 REFRESHED
2025-12-09T03:44:02.109047Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:493: cloud.mock_cloud{yq.streamingQueryDurationMinutes.count=*/0, yq.queryResult.size=*/20971520, yq.analyticsQuery.count=0/100, yq.analyticsQueryDurationMinutes.count=*/1440, yq.memory.size=*/0, yq.result.size=*/0, yq.cpuPercent.count=0/10000, yq.streamingQuery.count=0/100} SEND QUOTAS
2025-12-09T03:44:02.109058Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:103: Cloud id: mock_cloud Quota count: 8
2025-12-09T03:44:02.109081Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudqgd47iklgerf2i1"
2025-12-09T03:44:02.109126Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:169: Resolve subject type bootstrap. Token: **** (B6C6F477) Actor id: [1:7581698932637297652:2506]
2025-12-09T03:44:02.109162Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:230: Subject Type: federated_account Token: **** (B6C6F477)
2025-12-09T03:44:02.109186Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudqgd47iklgerf2i1"
2025-12-09T03:44:02.109202Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:63: Request actor. Actor id: [1:7581698932637297653:2507]
2025-12-09T03:44:02.109243Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_queries.cpp:641: DescribeQueryRequest: {query_id: "ptqudqgd47iklgerf2i1"
} [root@builtin, **** (B6C6F477)] 
2025-12-09T03:44:02.111407Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: DescribeQueryRequest - DescribeQueryResult: {query { meta { common { id: "ptqudqgd47iklgerf2i1" created_by: "root@builtin" modified_by: "root@builtin" created_at { seconds: 1765251817 nanos: 581843000 } modified_at { seconds: 1765251841 nanos: 40964000 } revision: 2 } started_at { seconds: 1765251818 nanos: 422000000 } finished_at { seconds: 1765251841 nanos: 628000000 } execute_mode: RUN status: ABORTED_BY_USER last_job_query_revision: 1 last_job_id: "ptjudqgd47ikks1vrsj4-ptqudqgd47iklgerf2i1" started_by: "root@builtin" aborted_by: "root@builtin" has_saved_checkpoints: true submitted_at { seconds: 1765251817 nanos: 581843000 } } content { type: STREAMING name: "simple" acl { visibility: PRIVATE } limits { execution_timeout { } } text: "SELECT * FROM myyds_2f.`select_timings_2f_input` LIMIT 1;" syntax: YQL_V1 } plan { json: "{\"Detailed\":{\"Operations\":[{\"Id\":10,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[{\"Name\":\"DqSourceWideWrap\"},{\"Name\":\"NarrowMap\"},{\"Name\":\"Take\"}]}},{\"Id\":8,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[{\"Name\":\"Take\"}]},\"DependsOn\":[10]},{\"Id\":6,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[]},\"DependsOn\":[8]},{\"Id\":3,\"Name\":\"ResPull!\",\"DependsOn\":[6]},{\"Id\":1,\"Name\":\"Commit!\",\"DependsOn\":[3]}],\"OperationRoot\":1,\"Providers\":[],\"OperationStats\":{\"Commit!\":1,\"DqStage\":3,\"ResPull!\":1}},\"Basic\":{\"nodes\":[{\"id\":10,\"level\":1,\"name\":\"DqStage #10\",\"type\":\"op\"},{\"id\":8,\"level\":2,\"name\":\"DqStage #8\",\"type\":\"op\"},{\"id\":6,\"level\":3,\"name\":\"DqStage #6\",\"type\":\"op\"},{\"id\":3,\"level\":4,\"name\":\"ResPull!\",\"type\":\"op\"},{\"id\":1,\"level\":5,\"name\":\"Commit!\",\"type\":\"op\"}],\"links\":[{\"source\":10,\"target\":8},{\"source\":8,\"target\":6},{\"source\":6,\"target\":3},{\"source\":3,\"target\":1}]}}" } issue { message: "ABORTED_BY_USER" severity: 1 } statistics { json: "{\"Graph=0\":{\"Tasks\":{\"sum\":3,\"count\":3,\"avg\":1,\"max\":1,\"min\":1},\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":3,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"}}}" } result_set_meta { column { name: "Data" type { type_id: STRING } } } ast { data: "(\n(let $1 (Configure! world (DataSource \'\"config\") \'\"DqEngine\" \'\"force\"))\n(let $2 (DataSink \'result))\n(let $3 (DataSource \'\"pq\" \'\"myyds_2f\"))\n(let $4 (StructType \'(\'\"Data\" (DataType \'String))))\n(let $5 (PqTopic \'\"myyds_2f\" \'\"local\" \'\"select_timings_2f_input\" \'(\'(\'\"PartitionsCount\" \'1)) \'() $4))\n(let $6 \'(\'\"SharedReading\" \'\"0\"))\n(let $7 \'(\'(\'\"Endpoint\" \'\"localhost:4888\") $6 \'(\'\"ReconnectPeriod\" \'\"\") \'(\'\"Format\" \'\"raw\") \'(\'\"ReadGroup\" \'\"ptcudqgd47r6f85fafmq\") \'(\'\"AddBearerToToken\" \'1)))\n(let $8 (DqPqTopicSource world $5 \'(\'\"Data\") $7 (SecureParam \'\"cluster:default_myyds_2f\") \'\"\" $4 \'\"\"))\n(let $9 (Uint64 \'1))\n(let $10 (DqStage \'((DqSource $3 $8)) (lambda \'($14) (block \'(\n  (let $15 \'(\'(\'\"format\" \'\"raw\") \'(\'\"formatSettings\" \'(\'(\'\"data.datetime.formatname\" \'\"POSIX\") \'(\'\"data.timestamp.formatname\" \'\"POSIX\"))) \'(\'\"settings\" \'($6))))\n  (let $16 (DqSourceWideWrap $14 $3 $4 $15))\n  (return (Take (NarrowMap $16 (lambda \'($17) (AsStruct \'(\'\"Data\" $17)))) $9))\n))) \'(\'(\'\"_logical_id\" \'200270))))\n(let $11 (DqStage \'((DqCnUnionAll (TDqOutput $10 \'\"0\"))) (lambda \'($18) (Take $18 $9)) \'(\'(\'\"_logical_id\" \'200283))))\n(let $12 (DqStage \'((DqCnUnionAll (TDqOutput $11 \'\"0\"))) (lambda \'($19) $19) \'(\'(\'\"_logical_id\" \'200320))))\n(let $13 (ResPull! $1 $2 (Key) (DqCnResult (TDqOutput $12 \'\"0\") \'()) \'(\'(\'type) \'(\'autoref)) \'\"dq\"))\n(return (Commit! (Commit! $13 $2) (DataSink \'\"pq\" \'\"myyds_2f\")))\n)\n" } } } SUCCESS
2025-12-09T03:44:02.112803Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.cpuPercent.count=0/10000 NOTIFY CHANGE
2025-12-09T03:44:02.113658Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudqgd47iklgerf2i1"
2025-12-09T03:44:02.113691Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:305: Resolve folder bootstrap. Folder id: my_folder Actor id: [1:7581698932637297657:2510]
2025-12-09T03:44:02.113714Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:367: Cloud id: mock_cloud Folder id: my_folder
2025-12-09T03:44:02.113734Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:91: Get quotas bootstrap. Cloud id: mock_cloud Actor id: [1:7581698932637297658:2511]
2025-12-09T03:44:02.113754Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.analyticsQuery.count IS STALE, Refreshing ...
2025-12-09T03:44:02.113763Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.cpuPercent.count IS STALE, Refreshing ...
2025-12-09T03:44:02.113771Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.streamingQuery.count IS STALE, Refreshing ...
2025-12-09T03:44:02.113792Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.cpuPercent.count=0/10000 REFRESHED
2025-12-09T03:44:02.114704Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.analyticsQuery.count=0/100 NOTIFY CHANGE
2025-12-09T03:44:02.114746Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.streamingQuery.count=0/100 NOTIFY CHANGE
2025-12-09T03:44:02.115707Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.analyticsQuery.count=0/100 REFRESHED
2025-12-09T03:44:02.115729Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.streamingQuery.count=0/100 REFRESHED
2025-12-09T03:44:02.115764Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:493: cloud.mock_cloud{yq.streamingQueryDurationMinutes.count=*/0, yq.queryResult.size=*/20971520, yq.analyticsQuery.count=0/100, yq.analyticsQueryDurationMinutes.count=*/1440, yq.memory.size=*/0, yq.result.size=*/0, yq.cpuPercent.count=0/10000, yq.streamingQuery.count=0/100} SEND QUOTAS
2025-12-09T03:44:02.115781Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:103: Cloud id: mock_cloud Quota count: 8
2025-12-09T03:44:02.115804Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudqgd47iklgerf2i1"
2025-12-09T03:44:02.115845Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:169: Resolve subject type bootstrap. Token: **** (B6C6F477) Actor id: [1:7581698932637297663:2516]
2025-12-09T03:44:02.115893Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:230: Subject Type: federated_account Token: **** (B6C6F477)
2025-12-09T03:44:02.115919Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudqgd47iklgerf2i1"
2025-12-09T03:44:02.115944Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:63: Request actor. Actor id: [1:7581698932637297664:2517]
2025-12-09T03:44:02.115989Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_queries.cpp:641: DescribeQueryRequest: {query_id: "ptqudqgd47iklgerf2i1"
} [root@builtin, **** (B6C6F477)] 
2025-12-09T03:44:02.118123Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: DescribeQueryRequest - DescribeQueryResult: {query { meta { common { id: "ptqudqgd47iklgerf2i1" created_by: "root@builtin" modified_by: "root@builtin" created_at { seconds: 1765251817 nanos: 581843000 } modified_at { seconds: 1765251841 nanos: 40964000 } revision: 2 } started_at { seconds: 1765251818 nanos: 422000000 } finished_at { seconds: 1765251841 nanos: 628000000 } execute_mode: RUN status: ABORTED_BY_USER last_job_query_revision: 1 last_job_id: "ptjudqgd47ikks1vrsj4-ptqudqgd47iklgerf2i1" started_by: "root@builtin" aborted_by: "root@builtin" has_saved_checkpoints: true submitted_at { seconds: 1765251817 nanos: 581843000 } } content { type: STREAMING name: "simple" acl { visibility: PRIVATE } limits { execution_timeout { } } text: "SELECT * FROM myyds_2f.`select_timings_2f_input` LIMIT 1;" syntax: YQL_V1 } plan { json: "{\"Detailed\":{\"Operations\":[{\"Id\":10,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[{\"Name\":\"DqSourceWideWrap\"},{\"Name\":\"NarrowMap\"},{\"Name\":\"Take\"}]}},{\"Id\":8,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[{\"Name\":\"Take\"}]},\"DependsOn\":[10]},{\"Id\":6,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[]},\"DependsOn\":[8]},{\"Id\":3,\"Name\":\"ResPull!\",\"DependsOn\":[6]},{\"Id\":1,\"Name\":\"Commit!\",\"DependsOn\":[3]}],\"OperationRoot\":1,\"Providers\":[],\"OperationStats\":{\"Commit!\":1,\"DqStage\":3,\"ResPull!\":1}},\"Basic\":{\"nodes\":[{\"id\":10,\"level\":1,\"name\":\"DqStage #10\",\"type\":\"op\"},{\"id\":8,\"level\":2,\"name\":\"DqStage #8\",\"type\":\"op\"},{\"id\":6,\"level\":3,\"name\":\"DqStage #6\",\"type\":\"op\"},{\"id\":3,\"level\":4,\"name\":\"ResPull!\",\"type\":\"op\"},{\"id\":1,\"level\":5,\"name\":\"Commit!\",\"type\":\"op\"}],\"links\":[{\"source\":10,\"target\":8},{\"source\":8,\"target\":6},{\"source\":6,\"target\":3},{\"source\":3,\"target\":1}]}}" } issue { message: "ABORTED_BY_USER" severity: 1 } statistics { json: "{\"Graph=0\":{\"Tasks\":{\"sum\":3,\"count\":3,\"avg\":1,\"max\":1,\"min\":1},\"CpuTimeUs\":{\"sum\":\"0.00s\",\"count\":3,\"avg\":\"0.00s\",\"max\":\"0.00s\",\"min\":\"0.00s\"}}}" } result_set_meta { column { name: "Data" type { type_id: STRING } } } ast { data: "(\n(let $1 (Configure! world (DataSource \'\"config\") \'\"DqEngine\" \'\"force\"))\n(let $2 (DataSink \'result))\n(let $3 (DataSource \'\"pq\" \'\"myyds_2f\"))\n(let $4 (StructType \'(\'\"Data\" (DataType \'String))))\n(let $5 (PqTopic \'\"myyds_2f\" \'\"local\" \'\"select_timings_2f_input\" \'(\'(\'\"PartitionsCount\" \'1)) \'() $4))\n(let $6 \'(\'\"SharedReading\" \'\"0\"))\n(let $7 \'(\'(\'\"Endpoint\" \'\"localhost:4888\") $6 \'(\'\"ReconnectPeriod\" \'\"\") \'(\'\"Format\" \'\"raw\") \'(\'\"ReadGroup\" \'\"ptcudqgd47r6f85fafmq\") \'(\'\"AddBearerToToken\" \'1)))\n(let $8 (DqPqTopicSource world $5 \'(\'\"Data\") $7 (SecureParam \'\"cluster:default_myyds_2f\") \'\"\" $4 \'\"\"))\n(let $9 (Uint64 \'1))\n(let $10 (DqStage \'((DqSource $3 $8)) (lambda \'($14) (block \'(\n  (let $15 \'(\'(\'\"format\" \'\"raw\") \'(\'\"formatSettings\" \'(\'(\'\"data.datetime.formatname\" \'\"POSIX\") \'(\'\"data.timestamp.formatname\" \'\"POSIX\"))) \'(\'\"settings\" \'($6))))\n  (let $16 (DqSourceWideWrap $14 $3 $4 $15))\n  (return (Take (NarrowMap $16 (lambda \'($17) (AsStruct \'(\'\"Data\" $17)))) $9))\n))) \'(\'(\'\"_logical_id\" \'200270))))\n(let $11 (DqStage \'((DqCnUnionAll (TDqOutput $10 \'\"0\"))) (lambda \'($18) (Take $18 $9)) \'(\'(\'\"_logical_id\" \'200283))))\n(let $12 (DqStage \'((DqCnUnionAll (TDqOutput $11 \'\"0\"))) (lambda \'($19) $19) \'(\'(\'\"_logical_id\" \'200320))))\n(let $13 (ResPull! $1 $2 (Key) (DqCnResult (TDqOutput $12 \'\"0\") \'()) \'(\'(\'type) \'(\'autoref)) \'\"dq\"))\n(return (Commit! (Commit! $13 $2) (DataSink \'\"pq\" \'\"myyds_2f\")))\n)\n" } } } SUCCESS
2025-12-09T03:44:02.119147Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.cpuPercent.count=0/10000 NOTIFY CHANGE
2025-12-09T03:44:02.120830Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.analyticsQuery.count=0/100 NOTIFY CHANGE
2025-12-09T03:44:02.120849Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.streamingQuery.count=0/100 NOTIFY CHANGE
