2025-12-12T12:28:02.888428Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:544: RowDispatcher: Successfully bootstrapped row dispatcher, id [1:7582947224032167780:2069], tenant /default
2025-12-12T12:28:02.888449Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582947224032167780:2069]
2025-12-12T12:28:02.888459Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:329: Coordinator: Add new row dispatcher to map (state 1)
2025-12-12T12:28:02.888726Z :GRPC_SERVER NOTICE: grpc_request_proxy_simple.cpp:161: Grpc simple request proxy started, nodeid# 1
2025-12-12T12:28:02.888780Z :GRPC_SERVER NOTICE: grpc_request_proxy_simple.cpp:161: Grpc simple request proxy started, nodeid# 1
2025-12-12T12:28:02.888972Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:293: Coordinator: Successfully bootstrapped coordinator, id [1:7582947224032167796:2081], NodesManagerId [0:4705493345362661702:78], rebalancing timeout 5.000000s
2025-12-12T12:28:02.889003Z :YQL_NODES_MANAGER INFO: nodes_manager.cpp:88: Bootstrap, InstanceId: 9c39f647-483a1f20-71f8e79f-23682a90
2025-12-12T12:28:02.889005Z :YQL_NODES_MANAGER DEBUG: nodes_manager.cpp:310: TNodesManagerActor::ResolveSelfAddress
2025-12-12T12:28:02.889019Z :YQ_TEST_CONNECTION DEBUG: test_connection.cpp:142: Starting yandex query test connection. Actor id: [1:7582947224032167785:2074]
2025-12-12T12:28:02.889020Z :FQ_CONTROL_PLANE_CONFIG DEBUG: control_plane_config.cpp:58: STARTING: [1:7582947224032167774:2063]
2025-12-12T12:28:02.889069Z :FQ_LOG_UPDATER DEBUG: log.cpp:93: Updated YQL logs priority: 8
2025-12-12T12:28:02.889076Z :FQ_LOG_UPDATER CRIT: log.cpp:55: Failed to deliver subscription request to config dispatcher.
2025-12-12T12:28:02.889332Z :FQ_QUOTA_SERVICE INFO: quota_manager.cpp:196: STARTED
2025-12-12T12:28:02.889343Z :YQ_CONTROL_PLANE_STORAGE INFO: ydb_control_plane_storage.cpp:50: Starting ydb control plane storage service. Actor id: [1:7582947224032167773:2062]
2025-12-12T12:28:02.889451Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:637: RowDispatcher: TEvCoordinatorChangesSubscribe from [1:7582947224032167796:2081]
2025-12-12T12:28:02.889512Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:232: TLeaderElection [1:7582947224032167797:2082] Successfully bootstrapped, local coordinator id [1:7582947224032167796:2081], tenant id default, local mode 0, coordination node path local/default, endpoint localhost:17898
2025-12-12T12:28:02.889672Z :YQ_CONTROL_PLANE_PROXY DEBUG: control_plane_proxy.cpp:525: Starting yandex query control plane proxy. Actor id: [1:7582947224032167775:2064]
2025-12-12T12:28:02.889805Z :YQ_RATE_LIMITER INFO: quoter_service.cpp:124: Bootstraping with config: { Enabled: true ControlPlaneEnabled: true DataPlaneEnabled: true Database { Endpoint: "localhost:17898" Database: "local" TablePrefix: "RateLimiter_bd2c75ef-0dc5-438a-9afc-97add3f721ac" } Limiters { CoordinationNodePath: "rate_limiter" } }
2025-12-12T12:28:02.889994Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/bindings" actor
2025-12-12T12:28:02.890021Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/idempotency_keys" actor
2025-12-12T12:28:02.890030Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/result_sets" actor
2025-12-12T12:28:02.890038Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/jobs" actor
2025-12-12T12:28:02.890090Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: a3e078ee-1e6d1476-94764c3c-6e3032831, Host: ghrun-fhkyrtz6p4, Tenant: /default
2025-12-12T12:28:02.890103Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/mappings" actor
2025-12-12T12:28:02.890111Z :FQ_QUOTA_PROXY INFO: quota_proxy.cpp:90: STARTED
2025-12-12T12:28:02.890115Z :YQ_RATE_LIMITER DEBUG: schema.cpp:71: Run create coordination node "local/RateLimiter_bd2c75ef-0dc5-438a-9afc-97add3f721ac/rate_limiter" actor
2025-12-12T12:28:02.890116Z :YQ_RATE_LIMITER DEBUG: schema.cpp:113: Call create coordination node "local/RateLimiter_bd2c75ef-0dc5-438a-9afc-97add3f721ac/rate_limiter"
2025-12-12T12:28:02.890118Z :YQ_RATE_LIMITER DEBUG: schema.cpp:411: Call create coordination node "local/RateLimiter_bd2c75ef-0dc5-438a-9afc-97add3f721ac/rate_limiter"
2025-12-12T12:28:02.890134Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create directory "local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac" actor
2025-12-12T12:28:02.890135Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create directory "local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac"
2025-12-12T12:28:02.890138Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:383: Call create directory "local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac"
2025-12-12T12:28:02.890151Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/queries" actor
2025-12-12T12:28:02.890159Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/pending_small" actor
2025-12-12T12:28:02.890170Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:214: Bootstrap
2025-12-12T12:28:02.890172Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:217: Create sdk ydb connection
2025-12-12T12:28:02.890203Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:239: Successfully bootstrapped TStorageProxy [1:7582947224032167779:2068] with connection to localhost:17898:local
2025-12-12T12:28:02.890205Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/connections" actor
2025-12-12T12:28:02.891727Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/nodes" actor
2025-12-12T12:28:02.891757Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/quotas" actor
2025-12-12T12:28:02.891772Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-12-12T12:28:02.891994Z :MEMORY_PROFILER NOTICE: monitor.cpp:332: Bootstrapped
2025-12-12T12:28:02.892039Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/tenants" actor
2025-12-12T12:28:02.892075Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/tenant_acks" actor
2025-12-12T12:28:02.892084Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/compute_databases" actor
2025-12-12T12:28:02.893029Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:71: Run create coordination node "local/default" actor
2025-12-12T12:28:02.893039Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:113: Call create coordination node "local/default"
2025-12-12T12:28:02.893042Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:411: Call create coordination node "local/default"
2025-12-12T12:28:02.898846Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:28:02.898867Z :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:16645: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint localhost:16645
2025-12-12T12:28:02.898927Z :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:16645: Failed to connect to remote host: Connection refused
<main>: Error: Grpc error response on endpoint localhost:16645
2025-12-12T12:28:02.910688Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:155: Successfully created coordination node "local/default"
2025-12-12T12:28:02.910709Z :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: 8], type: EPathTypeKesus, state: EPathStateNoChanges), source_location: ydb/core/tx/schemeshard/schemeshard__operation_create_kesus.cpp:339 }
2025-12-12T12:28:02.910728Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:345: TLeaderElection [1:7582947224032167797:2082] Coordination node successfully created
2025-12-12T12:28:02.910731Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:323: TLeaderElection [1:7582947224032167797:2082] Start session
2025-12-12T12:28:02.911889Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/result_sets". Create session OK
2025-12-12T12:28:02.911900Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/result_sets"
2025-12-12T12:28:02.911903Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/result_sets"
2025-12-12T12:28:02.912007Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/pending_small". Create session OK
2025-12-12T12:28:02.912020Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/pending_small"
2025-12-12T12:28:02.912022Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/pending_small"
2025-12-12T12:28:02.912075Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/nodes". Create session OK
2025-12-12T12:28:02.912085Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/nodes"
2025-12-12T12:28:02.912087Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/nodes"
2025-12-12T12:28:02.912103Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/mappings". Create session OK
2025-12-12T12:28:02.912106Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/mappings"
2025-12-12T12:28:02.912108Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/mappings"
2025-12-12T12:28:02.912166Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/connections". Create session OK
2025-12-12T12:28:02.912175Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/connections"
2025-12-12T12:28:02.912177Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/connections"
2025-12-12T12:28:02.912201Z :YQ_RATE_LIMITER DEBUG: schema.cpp:155: Successfully created coordination node "local/RateLimiter_bd2c75ef-0dc5-438a-9afc-97add3f721ac/rate_limiter"
2025-12-12T12:28:02.912217Z :YQ_RATE_LIMITER DEBUG: schema.cpp:122: Reply for create coordination node "local/RateLimiter_bd2c75ef-0dc5-438a-9afc-97add3f721ac/rate_limiter": { <main>: Error: Check failed: path: '/local/RateLimiter_bd2c75ef-0dc5-438a-9afc-97add3f721ac/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-12T12:28:02.912223Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created directory "local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac"
2025-12-12T12:28:02.912227Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create directory "local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac": { <main>: Error: Check failed: path: '/local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac', 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-12T12:28:02.912236Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/tenant_acks". Create session OK
2025-12-12T12:28:02.912238Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/tenant_acks"
2025-12-12T12:28:02.912239Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/tenant_acks"
2025-12-12T12:28:02.912263Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/compute_databases". Create session OK
2025-12-12T12:28:02.912265Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/idempotency_keys". Create session OK
2025-12-12T12:28:02.912266Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/idempotency_keys"
2025-12-12T12:28:02.912268Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/idempotency_keys"
2025-12-12T12:28:02.912272Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/compute_databases"
2025-12-12T12:28:02.912274Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/compute_databases"
2025-12-12T12:28:02.912286Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/queries". Create session OK
2025-12-12T12:28:02.912287Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/queries"
2025-12-12T12:28:02.912288Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/queries"
2025-12-12T12:28:02.913537Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/jobs". Create session OK
2025-12-12T12:28:02.913548Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/quotas". Create session OK
2025-12-12T12:28:02.913550Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/jobs"
2025-12-12T12:28:02.913551Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/quotas"
2025-12-12T12:28:02.913552Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/jobs"
2025-12-12T12:28:02.913554Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/quotas"
2025-12-12T12:28:02.913553Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/bindings". Create session OK
2025-12-12T12:28:02.913556Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/bindings"
2025-12-12T12:28:02.913558Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/bindings"
2025-12-12T12:28:02.913622Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/tenants". Create session OK
2025-12-12T12:28:02.913624Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/tenants"
2025-12-12T12:28:02.913625Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/tenants"
2025-12-12T12:28:02.913632Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:359: TLeaderElection [1:7582947224032167797:2082] Session successfully created
2025-12-12T12:28:02.917222Z :FQ_CONTROL_PLANE_CONFIG DEBUG: control_plane_config.cpp:190: LOADED TenantInfo: State CHANGED at 2025-12-12T12:27:25.421719Z
2025-12-12T12:28:02.917262Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/result_sets"
2025-12-12T12:28:02.917273Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/result_sets": { <main>: Error: Check failed: path: '/local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/result_sets', 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-12T12:28:02.917307Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/pending_small"
2025-12-12T12:28:02.917315Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/pending_small": { <main>: Error: Check failed: path: '/local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/pending_small', 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-12T12:28:02.917446Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/mappings"
2025-12-12T12:28:02.917458Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/mappings": { <main>: Error: Check failed: path: '/local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/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-12T12:28:02.918678Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:372: TLeaderElection [1:7582947224032167797:2082] Semaphore successfully created
2025-12-12T12:28:02.918691Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:304: TLeaderElection [1:7582947224032167797:2082] Try to acquire semaphore
2025-12-12T12:28:02.918736Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:420: TLeaderElection [1:7582947224032167797:2082] Describe semaphore
2025-12-12T12:28:02.918904Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/nodes"
2025-12-12T12:28:02.918919Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/nodes": { <main>: Error: Check failed: path: '/local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/nodes', 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-12T12:28:02.918923Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/idempotency_keys"
2025-12-12T12:28:02.918933Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/idempotency_keys": { <main>: Error: Check failed: path: '/local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/idempotency_keys', 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-12T12:28:02.918936Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/connections"
2025-12-12T12:28:02.918946Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/connections": { <main>: Error: Check failed: path: '/local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/connections', 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-12T12:28:02.919063Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/compute_databases"
2025-12-12T12:28:02.919067Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/compute_databases": { <main>: Error: Check failed: path: '/local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/compute_databases', 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-12T12:28:02.919077Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/tenant_acks"
2025-12-12T12:28:02.919082Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/tenant_acks": { <main>: Error: Check failed: path: '/local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/tenant_acks', 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-12T12:28:02.919111Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/quotas"
2025-12-12T12:28:02.919116Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/quotas": { <main>: Error: Check failed: path: '/local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/quotas', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 33], type: EPathTypeTable, state: EPathStateNoChanges), source_location: ydb/core/tx/schemeshard/schemeshard__operation_create_table.cpp:504 }
2025-12-12T12:28:02.919127Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/jobs"
2025-12-12T12:28:02.919131Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/jobs": { <main>: Error: Check failed: path: '/local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/jobs', 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-12T12:28:02.919133Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/queries"
2025-12-12T12:28:02.919137Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/queries": { <main>: Error: Check failed: path: '/local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/queries', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 32], type: EPathTypeTable, state: EPathStateNoChanges), source_location: ydb/core/tx/schemeshard/schemeshard__operation_create_table.cpp:504 }
2025-12-12T12:28:02.919387Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/tenants"
2025-12-12T12:28:02.919392Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/tenants": { <main>: Error: Check failed: path: '/local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/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-12T12:28:02.919410Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/bindings"
2025-12-12T12:28:02.919415Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/bindings": { <main>: Error: Check failed: path: '/local/DbPoolStorage_bd2c75ef-0dc5-438a-9afc-97add3f721ac/bindings', 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-12T12:28:02.921462Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:386: TLeaderElection [1:7582947224032167797:2082] Semaphore successfully acquired
2025-12-12T12:28:02.921482Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:469: TLeaderElection [1:7582947224032167797:2082] Semaphore successfully described: coordinator id [1:7582947224032167796:2081] generation 3
2025-12-12T12:28:02.921489Z :FQ_ROW_DISPATCHER INFO: leader_election.cpp:471: TLeaderElection [1:7582947224032167797:2082] Send TEvCoordinatorChanged to [1:7582947224032167780:2069], new coordinator id [1:7582947224032167796:2081], previous coordinator id [0:0:0]
2025-12-12T12:28:02.921502Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:569: RowDispatcher: Coordinator changed, old leader (empty maybe), new [1:7582947224032167796:2081] generation 3
2025-12-12T12:28:02.921514Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582947224032167780:2069]
2025-12-12T12:28:02.921518Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582947224032167780:2069]
2025-12-12T12:28:02.921521Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582947224032167780:2069]
2025-12-12T12:28:02.921532Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:440: Coordinator: New leader [1:7582947224032167796:2081], SelfId [1:7582947224032167796:2081]
2025-12-12T12:28:02.921538Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:28:03.887430Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: a3e078ee-1e6d1476-94764c3c-6e3032832, Host: ghrun-fhkyrtz6p4, Tenant: /default
2025-12-12T12:28:03.897652Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: a3e078ee-1e6d1476-94764c3c-6e3032832, Host: ghrun-fhkyrtz6p4, Tenant: /default, Request CP::GetTask with size: 68 bytes
2025-12-12T12:28:03.898423Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/default"
owner_id: "a3e078ee-1e6d1476-94764c3c-6e3032832"
host: "ghrun-fhkyrtz6p4"
node_id: 1
}
2025-12-12T12:28:03.903282Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:456: Task (Query): ptqudq7ueohsakh1jitp Lease TIMEOUT, RetryCounterUpdatedAt 2025-12-12T12:27:28.359474Z LastSeenAt: 2025-12-12T12:27:30.017347Z
2025-12-12T12:28:03.903294Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:463: Task (Query): ptqudq7ueohsakh1jitp RetryRate: 0.9996162331 RetryCounter: 1 At: 2025-12-12T12:28:03.903237Z
2025-12-12T12:28:03.914652Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {tasks { query_id { value: "ptqudq7ueohsakh1jitp" } job_id { value: "ptjudq7ueohs9so9lloj" } generation: 2 streaming: true dq_graph: "\022\314\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*\337\002Z\334\002\n\010PqSource\022\315\002\n4type.googleapis.com/NYql.NPq.NProto.TDqPqTopicSource\022\224\002\n\027select_timings_2f_input\022\024ptqudq7ueohsakh1jitp\032\017localhost:17898\"\032\n\030cluster:default_myyds_2f*\005local0\002@\001b\004Dataj\025[\"DataType\";\"String\"]\222\001\024ptcudq7ueos1oh23eroc\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(88a034dc314301cb1522a933e690a4c49a7591e8\032\023dq_vanilla_job.lite \002\"\014\n\002pq\022\006\n\004\010\001\030\001H\231\236\014RClocal/RateLimiter_bd2c75ef-0dc5-438a-9afc-97add3f721ac/rate_limiterZ)mock_cloud/my_folder/ptqudq7ueohsakh1jitp`\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(88a034dc314301cb1522a933e690a4c49a7591e8\032\023dq_vanilla_job.lite \002H\256\236\014RClocal/RateLimiter_bd2c75ef-0dc5-438a-9afc-97add3f721ac/rate_limiterZ)mock_cloud/my_folder/ptqudq7ueohsakh1jitp`\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(88a034dc314301cb1522a933e690a4c49a7591e8\032\023dq_vanilla_job.lite \002H\277\236\014RClocal/RateLimiter_bd2c75ef-0dc5-438a-9afc-97add3f721ac/rate_limiterZ)mock_cloud/my_folder/ptqudq7ueohsakh1jitp`\200\200\200\200 \230\001\000\300\001\001\030\002\"\r\037\000\205\002\203\005@\020Data/*\004Data2qptqudq7ueohsakh1jitp#ptrudq7uendlvjl8uec8#yandexcloud://my_folder#33f11377-82a623ae-c7a05f13-2bb1c0ee4#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\":\"\"}b\216\001\010\256\236\014\022\207\001\037\002\006Arg\005\205\006\213\002\204\205\002\203\005@\020Data\205\000\204?\002\030Inputs(Parameters\034Program\013?\006)\251...} SUCCESS
2025-12-12T12:28:03.914706Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: a3e078ee-1e6d1476-94764c3c-6e3032832, Host: ghrun-fhkyrtz6p4, Tenant: /default, Got CP::GetTask Response
2025-12-12T12:28:03.915354Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:28:03.915370Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 1
2025-12-12T12:28:03.915628Z :FQ_PENDING_FETCHER DEBUG: pending_fetcher.cpp:361: NewTask: Scope: yandexcloud://my_folder Id: ptqudq7ueohsakh1jitp UserId: root@builtin AuthToken: **** (B6C6F477)
2025-12-12T12:28:03.915829Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:375: QueryId: ptqudq7ueohsakh1jitp Start run actor. Compute state: RUNNING
2025-12-12T12:28:03.915830Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: a3e078ee-1e6d1476-94764c3c-6e3032833, Host: ghrun-fhkyrtz6p4, Tenant: /default
2025-12-12T12:28:03.915840Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:469: QueryId: ptqudq7ueohsakh1jitp FillConnections
2025-12-12T12:28:03.915876Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:2333: QueryId: ptqudq7ueohsakh1jitp Run actors params: { QueryId: ptqudq7ueohsakh1jitp CloudId: mock_cloud UserId: root@builtin Owner: a3e078ee-1e6d1476-94764c3c-6e3032832 PreviousQueryRevision: 2 Connections: 1 Bindings: 0 AccountIdSignatures: 0 QueryType: STREAMING ExecuteMode: RUN ResultId: ptrudq7udmi32nubqa05 StateLoadMode: FROM_LAST_CHECKPOINT StreamingDisposition: { from_last_checkpoint { } } Status: RUNNING DqGraphs: 1 DqGraphIndex: 0 Resource.TopicConsumers: 1 }
2025-12-12T12:28:03.915918Z :FQ_PINGER TRACE: pinger.cpp:171: QueryId: ptqudq7ueohsakh1jitp, Owner: a3e078ee-1e6d1476-94764c3c-6e3032832 Start Pinger
2025-12-12T12:28:03.915958Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:911: QueryId: ptqudq7ueohsakh1jitp Overall dq tasks: 3
2025-12-12T12:28:03.916013Z :FQ_PINGER TRACE: pinger.cpp:250: QueryId: ptqudq7ueohsakh1jitp, Owner: a3e078ee-1e6d1476-94764c3c-6e3032832 Forward ping request: { resources { rate_limiter: READY compilation: READY topic_consumers_state: READY rate_limiter_path: "local/RateLimiter_bd2c75ef-0dc5-438a-9afc-97add3f721ac/rate_limiter" topic_consumers { database: "local" topic_path: "select_timings_2f_input" consumer_name: "ptqudq7ueohsakh1jitp" cluster_endpoint: "localhost:17898" token_name: "cluster:default_myyds_2f" add_bearer_to_token: true } } }
2025-12-12T12:28:03.916028Z :FQ_PINGER TRACE: pinger.cpp:393: QueryId: ptqudq7ueohsakh1jitp, Owner: a3e078ee-1e6d1476-94764c3c-6e3032832 Forward request Private::PingTask
2025-12-12T12:28:03.916284Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: a3e078ee-1e6d1476-94764c3c-6e3032833, Host: ghrun-fhkyrtz6p4, Tenant: /default, Request CP::GetTask with size: 68 bytes
2025-12-12T12:28:03.916366Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/default"
owner_id: "a3e078ee-1e6d1476-94764c3c-6e3032833"
host: "ghrun-fhkyrtz6p4"
node_id: 1
}
2025-12-12T12:28:03.916529Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudq7ueohsakh1jitp, Owner: a3e078ee-1e6d1476-94764c3c-6e3032832, Request CP::PingTask with size: 294 bytes
2025-12-12T12:28:03.916611Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "a3e078ee-1e6d1476-94764c3c-6e3032832"
query_id {
  value: "ptqudq7ueohsakh1jitp"
}
resources {
  rate_limiter: READY
  compilation: READY
  topic_consumers_state: READY
  rate_limiter_path: "local/RateLimiter_bd2c75ef-0dc5-438a-9afc-97add3f721ac/rate_limiter"
  topic_consumers {
    database: "local"
    topic_path: "select_timings_2f_input"
    consumer_name: "ptqudq7ueohsakh1jitp"
    cluster_endpoint: "localhost:17898"
    token_name: "cluster:default_myyds_2f"
    add_bearer_to_token: true
  }
}
scope: "yandexcloud://my_folder"
deadline {
  seconds: 1765628883
  nanos: 907314000
}
tenant: "/default"
}
2025-12-12T12:28:03.919249Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:28:03.919283Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: a3e078ee-1e6d1476-94764c3c-6e3032833, Host: ghrun-fhkyrtz6p4, Tenant: /default, Got CP::GetTask Response
2025-12-12T12:28:03.919582Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:28:03.919596Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:28:03.930571Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {expired_at { seconds: 1765542503 nanos: 925000000 } } SUCCESS
2025-12-12T12:28:03.930601Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudq7ueohsakh1jitp, Owner: a3e078ee-1e6d1476-94764c3c-6e3032832, Got CP::PingTaskResponse
2025-12-12T12:28:03.930776Z :TICKET_PARSER DEBUG: ticket_parser_impl.h:1875: Ticket **** (B6C6F477) (ipv6:[::1]:52076) has now valid token of root@builtin
2025-12-12T12:28:03.930862Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudq7ueohsakh1jitp"
2025-12-12T12:28:03.930916Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:305: Resolve folder bootstrap. Folder id: my_folder Actor id: [1:7582947228327135303:2272]
2025-12-12T12:28:03.930916Z :FQ_PINGER TRACE: pinger.cpp:338: QueryId: ptqudq7ueohsakh1jitp, Owner: a3e078ee-1e6d1476-94764c3c-6e3032832 Ping response success: { expired_at { seconds: 1765542503 nanos: 925000000 } }
2025-12-12T12:28:03.930935Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:367: Cloud id: mock_cloud Folder id: my_folder
2025-12-12T12:28:03.930951Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:91: Get quotas bootstrap. Cloud id: mock_cloud Actor id: [1:7582947228327135304:2273]
2025-12-12T12:28:03.930970Z :FQ_QUOTA_SERVICE DEBUG: quota_manager.cpp:255: cloud.mock_cloud NOT CASHED, Loading ...
2025-12-12T12:28:03.933412Z :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-12T12:28:03.933457Z :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-12T12:28:03.933462Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.analyticsQuery.count IS STALE, Refreshing ...
2025-12-12T12:28:03.933475Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.cpuPercent.count IS STALE, Refreshing ...
2025-12-12T12:28:03.933479Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.streamingQuery.count IS STALE, Refreshing ...
2025-12-12T12:28:03.933505Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.cpuPercent.count=0/10000 REFRESHED
2025-12-12T12:28:03.937854Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.analyticsQuery.count=0/100 REFRESHED
2025-12-12T12:28:03.937888Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.streamingQuery.count=1/100 REFRESHED
2025-12-12T12:28:03.937908Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:493: cloud.mock_cloud{yq.streamingQueryDurationMinutes.count=*/0, yq.queryResult.size=*/20971520, yq.analyticsQuery.count=0/100, yq.analyticsQueryDurationMinutes.count=*/1440, yq.memory.size=*/0, yq.result.size=*/0, yq.cpuPercent.count=0/10000, yq.streamingQuery.count=1/100} SEND QUOTAS
2025-12-12T12:28:03.937919Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:103: Cloud id: mock_cloud Quota count: 8
2025-12-12T12:28:03.937945Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudq7ueohsakh1jitp"
2025-12-12T12:28:03.938013Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:169: Resolve subject type bootstrap. Token: **** (B6C6F477) Actor id: [1:7582947228327135310:2279]
2025-12-12T12:28:03.938036Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:230: Subject Type: federated_account Token: **** (B6C6F477)
2025-12-12T12:28:03.938055Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudq7ueohsakh1jitp"
2025-12-12T12:28:03.938067Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:63: Request actor. Actor id: [1:7582947228327135311:2280]
2025-12-12T12:28:03.938126Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_queries.cpp:641: DescribeQueryRequest: {query_id: "ptqudq7ueohsakh1jitp"
} [root@builtin, **** (B6C6F477)] 
2025-12-12T12:28:03.940028Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.cpuPercent.count=0/10000 NOTIFY CHANGE
2025-12-12T12:28:03.941626Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: DescribeQueryRequest - DescribeQueryResult: {query { meta { common { id: "ptqudq7ueohsakh1jitp" created_by: "root@builtin" modified_by: "root@builtin" created_at { seconds: 1765542448 nanos: 270904000 } modified_at { seconds: 1765542448 nanos: 270904000 } revision: 1 } started_at { seconds: 1765542449 nanos: 457000000 } execute_mode: RUN status: RUNNING last_job_query_revision: 1 last_job_id: "ptjudq7ueohs9so9lloj-ptqudq7ueohsakh1jitp" started_by: "root@builtin" has_saved_checkpoints: true submitted_at { seconds: 1765542448 nanos: 270904000 } } 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:17898\") $6 \'(\'\"ReconnectPeriod\" \'\"\") \'(\'\"Format\" \'\"raw\") \'(\'\"ReadGroup\" \'\"ptcudq7ueos1oh23eroc\") \'(\'\"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-12T12:28:03.944018Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.analyticsQuery.count=0/100 NOTIFY CHANGE
2025-12-12T12:28:03.944894Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.streamingQuery.count=1/100 NOTIFY CHANGE
2025-12-12T12:28:03.948779Z :FQ_RESULT_WRITER INFO: result_writer.cpp:62: TraceId: ptqudq7ueohsakh1jitp#ptrudq7uendlvjl8uec8#yandexcloud://my_folder#33f11377-82a623ae-c7a05f13-2bb1c0ee4#mock_cloud Bootstrap
2025-12-12T12:28:03.948895Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudq7ueohsakh1jitp 2025-12-12 12:28:03.948 DEBUG ydbd(pid=1226733, tid=0x00007F147A303640) [DQ] task_controller_impl.h:83: _AllResultsBytesLimit = 100000
2025-12-12T12:28:03.948918Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudq7ueohsakh1jitp 2025-12-12 12:28:03.948 DEBUG ydbd(pid=1226733, tid=0x00007F147A303640) [DQ] task_controller_impl.h:86: _RowsLimitPerWrite = 1000
2025-12-12T12:28:03.948997Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:1652: QueryId: ptqudq7ueohsakh1jitp Executer: [1:7582947228327135294:2264], Controller: [1:7582947228327135317:2286], ResultIdActor: [1:7582947228327135315:2284]
2025-12-12T12:28:03.949032Z :FQ_RUN_ACTOR TRACE: run_actor.cpp:861: QueryId: ptqudq7ueohsakh1jitp Forward ping response. Success: 1. Cookie: 0
2025-12-12T12:28:03.949040Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudq7ueohsakh1jitp 2025-12-12 12:28:03.949 DEBUG ydbd(pid=1226733, tid=0x00007F1478B00640) [DQ] executer_actor.cpp:140: {ptqudq7ueohsakh1jitp} TDqExecuter::OnGraph
2025-12-12T12:28:03.949058Z :YQL_PROXY INFO: log.cpp:64: SessionId: ptqudq7ueohsakh1jitp 2025-12-12 12:28:03.949 INFO  ydbd(pid=1226733, tid=0x00007F1478B00640) [DQ] executer_actor.cpp:157: {ptqudq7ueohsakh1jitp} Trying to allocate 3 workers [EnableComputeActor=1]
2025-12-12T12:28:03.950371Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudq7ueohsakh1jitp 2025-12-12 12:28:03.950 DEBUG ydbd(pid=1226733, tid=0x00007F1478B00640) [DQ] executer_actor.cpp:247: {ptqudq7ueohsakh1jitp} Dq timeouts are set to: 0.000000s (global), 600.000000s (workers allocation fail), 30.000000s (workers allocation warn) 
2025-12-12T12:28:03.951061Z :YQL_NODES_MANAGER DEBUG: nodes_manager.cpp:125: TEvAllocateWorkersResponse Nodes {
  ResourceId: 4294967297
  Worker {
    NodeId: 1
    Guid: "9c39f647-483a1f20-71f8e79f-23682a90,ghrun-fhkyrtz6p4"
  }
  Worker {
    NodeId: 1
    Guid: "9c39f647-483a1f20-71f8e79f-23682a90,ghrun-fhkyrtz6p4"
  }
  Worker {
    NodeId: 1
    Guid: "9c39f647-483a1f20-71f8e79f-23682a90,ghrun-fhkyrtz6p4"
  }
}
2025-12-12T12:28:03.951623Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:144: SelfId: [1:7582947228327135321:2290], TxId: ptqudq7ueohsakh1jitp, task: 1. Ctx: {}. Start compute actor [1:7582947228327135321:2290], task: 1
2025-12-12T12:28:03.951645Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:114: SelfId: [1:7582947228327135321:2290], TxId: ptqudq7ueohsakh1jitp, task: 1. Ctx: {}. Use CPU quota: 1. Rate limiter resource: { "local/RateLimiter_bd2c75ef-0dc5-438a-9afc-97add3f721ac/rate_limiter", "mock_cloud/my_folder/ptqudq7ueohsakh1jitp" }
2025-12-12T12:28:03.951781Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:144: SelfId: [1:7582947228327135319:2288], TxId: ptqudq7ueohsakh1jitp, task: 2. Ctx: {}. Start compute actor [1:7582947228327135319:2288], task: 2
2025-12-12T12:28:03.951805Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:114: SelfId: [1:7582947228327135319:2288], TxId: ptqudq7ueohsakh1jitp, task: 2. Ctx: {}. Use CPU quota: 1. Rate limiter resource: { "local/RateLimiter_bd2c75ef-0dc5-438a-9afc-97add3f721ac/rate_limiter", "mock_cloud/my_folder/ptqudq7ueohsakh1jitp" }
2025-12-12T12:28:03.951883Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: a3e078ee-1e6d1476-94764c3c-6e303283 2025-12-12 12:28:03.951 DEBUG ydbd(pid=1226733, tid=0x00007F147A303640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Build task: 2
2025-12-12T12:28:03.951963Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: a3e078ee-1e6d1476-94764c3c-6e303283 2025-12-12 12:28:03.951 DEBUG ydbd(pid=1226733, tid=0x00007F147A303640) [DQ] tasks_runner_local.cpp:267: {TODO/2} task: 2, program size: 16, llvm: ``.
2025-12-12T12:28:03.952322Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:144: SelfId: [1:7582947228327135320:2289], TxId: ptqudq7ueohsakh1jitp, task: 3. Ctx: {}. Start compute actor [1:7582947228327135320:2289], task: 3
2025-12-12T12:28:03.952346Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:114: SelfId: [1:7582947228327135320:2289], TxId: ptqudq7ueohsakh1jitp, task: 3. Ctx: {}. Use CPU quota: 1. Rate limiter resource: { "local/RateLimiter_bd2c75ef-0dc5-438a-9afc-97add3f721ac/rate_limiter", "mock_cloud/my_folder/ptqudq7ueohsakh1jitp" }
2025-12-12T12:28:03.956575Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudq7ueohsakh1jitp 2025-12-12 12:28:03.956 DEBUG ydbd(pid=1226733, tid=0x00007F147B305640) [DQ] executer_actor.cpp:358: {ptqudq7ueohsakh1jitp} TDqExecuter::TEvAllocateWorkersResponse
2025-12-12T12:28:03.956595Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudq7ueohsakh1jitp 2025-12-12 12:28:03.956 DEBUG ydbd(pid=1226733, tid=0x00007F147B305640) [DQ] executer_actor.cpp:384: {ptqudq7ueohsakh1jitp} Allocated resource 4294967297
2025-12-12T12:28:03.956664Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudq7ueohsakh1jitp 2025-12-12 12:28:03.956 DEBUG ydbd(pid=1226733, tid=0x00007F147B305640) [DQ] executer_actor.cpp:401: {ptqudq7ueohsakh1jitp} WorkerInfo: Id:9c39f647-483a1f20-71f8e79f-23682a90,ghrun-fhkyrtz6p4,NodeId:1,StageId:200473
2025-12-12T12:28:03.956671Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudq7ueohsakh1jitp 2025-12-12 12:28:03.956 DEBUG ydbd(pid=1226733, tid=0x00007F147B305640) [DQ] executer_actor.cpp:402: {ptqudq7ueohsakh1jitp} TaskInfo: 0/1
2025-12-12T12:28:03.956677Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudq7ueohsakh1jitp 2025-12-12 12:28:03.956 DEBUG ydbd(pid=1226733, tid=0x00007F147B305640) [DQ] executer_actor.cpp:404: {ptqudq7ueohsakh1jitp}  ObjectId: 88a034dc314301cb1522a933e690a4c49a7591e8, dq_vanilla_job.lite, 
2025-12-12T12:28:03.956699Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudq7ueohsakh1jitp 2025-12-12 12:28:03.956 DEBUG ydbd(pid=1226733, tid=0x00007F147B305640) [DQ] executer_actor.cpp:401: {ptqudq7ueohsakh1jitp} WorkerInfo: Id:9c39f647-483a1f20-71f8e79f-23682a90,ghrun-fhkyrtz6p4,NodeId:1,StageId:200494
2025-12-12T12:28:03.956705Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudq7ueohsakh1jitp 2025-12-12 12:28:03.956 DEBUG ydbd(pid=1226733, tid=0x00007F147B305640) [DQ] executer_actor.cpp:402: {ptqudq7ueohsakh1jitp} TaskInfo: 1/2
2025-12-12T12:28:03.956710Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudq7ueohsakh1jitp 2025-12-12 12:28:03.956 DEBUG ydbd(pid=1226733, tid=0x00007F147B305640) [DQ] executer_actor.cpp:404: {ptqudq7ueohsakh1jitp}  ObjectId: 88a034dc314301cb1522a933e690a4c49a7591e8, dq_vanilla_job.lite, 
2025-12-12T12:28:03.956727Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudq7ueohsakh1jitp 2025-12-12 12:28:03.956 DEBUG ydbd(pid=1226733, tid=0x00007F147B305640) [DQ] executer_actor.cpp:401: {ptqudq7ueohsakh1jitp} WorkerInfo: Id:9c39f647-483a1f20-71f8e79f-23682a90,ghrun-fhkyrtz6p4,NodeId:1,StageId:200511
2025-12-12T12:28:03.956733Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudq7ueohsakh1jitp 2025-12-12 12:28:03.956 DEBUG ydbd(pid=1226733, tid=0x00007F147B305640) [DQ] executer_actor.cpp:402: {ptqudq7ueohsakh1jitp} TaskInfo: 2/3
2025-12-12T12:28:03.956738Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudq7ueohsakh1jitp 2025-12-12 12:28:03.956 DEBUG ydbd(pid=1226733, tid=0x00007F147B305640) [DQ] executer_actor.cpp:404: {ptqudq7ueohsakh1jitp}  ObjectId: 88a034dc314301cb1522a933e690a4c49a7591e8, dq_vanilla_job.lite, 
2025-12-12T12:28:03.956748Z :YQL_PROXY INFO: log.cpp:64: SessionId: ptqudq7ueohsakh1jitp 2025-12-12 12:28:03.956 INFO  ydbd(pid=1226733, tid=0x00007F147B305640) [DQ] executer_actor.cpp:415: {ptqudq7ueohsakh1jitp} 3 workers allocated
2025-12-12T12:28:03.956826Z :YQL_PROXY TRACE: log.cpp:64: SessionId:  2025-12-12 12:28:03.956 TRACE ydbd(pid=1226733, tid=0x00007F147B305640) [DQ] task_controller_impl.h:160: [1:7582947228327135317:2286] EvState TaskId: 3 State: 2 PingCookie: 0 StatusCode: UNSPECIFIED
2025-12-12T12:28:03.956834Z :YQL_PROXY TRACE: log.cpp:64: SessionId:  2025-12-12 12:28:03.956 TRACE ydbd(pid=1226733, tid=0x00007F147B305640) [DQ] task_controller_impl.h:201:  [1:7582947228327135317:2286] Executing TaskId: 3
2025-12-12T12:28:03.956945Z :YQL_PROXY TRACE: log.cpp:64: SessionId:  2025-12-12 12:28:03.956 TRACE ydbd(pid=1226733, tid=0x00007F147B305640) [DQ] task_controller_impl.h:271:  [1:7582947228327135317:2286] ExportStats Summary
2025-12-12T12:28:03.956978Z :YQL_PROXY DEBUG: log.cpp:64: SessionId:  2025-12-12 12:28:03.956 DEBUG ydbd(pid=1226733, tid=0x00007F147B305640) [DQ] task_controller_impl.h:526: Ready State: [1:7582947228327135317:2286]
2025-12-12T12:28:03.956984Z :YQL_PROXY DEBUG: log.cpp:64: SessionId:  2025-12-12 12:28:03.956 DEBUG ydbd(pid=1226733, tid=0x00007F147B305640) [DQ] task_controller_impl.h:537: Forward: [1:7582947228327135317:2286] to [1:7582947228327135316:2285]
2025-12-12T12:28:03.957031Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:70: [ptqudq7ueohsakh1jitp-0.2] TEvReadyState, streaming disposition { from_last_checkpoint { } }, state load mode FROM_LAST_CHECKPOINT, checkpointing period 1.000000s
2025-12-12T12:28:03.957045Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:104: [ptqudq7ueohsakh1jitp-0.2] AllActors count: 3, ActorsToTrigger count: 1, ActorsToNotify count: 1, ActorsToWaitFor count: 3
2025-12-12T12:28:03.957047Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:114: [ptqudq7ueohsakh1jitp-0.2] Send TEvRegisterCoordinatorRequest
2025-12-12T12:28:03.957060Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:261: [ptqudq7ueohsakh1jitp-0.2] Got TEvRegisterCoordinatorRequest
2025-12-12T12:28:03.957062Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:243: StartInitialization, EnableSecureScriptExecutions: 0
2025-12-12T12:28:03.957661Z :STREAMS_STORAGE_SERVICE NOTICE: storage_proxy.cpp:585: Add to delayed
2025-12-12T12:28:03.962799Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:557: Checkpoint storage and state storage were successfully initted
2025-12-12T12:28:03.962818Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:261: [ptqudq7ueohsakh1jitp-0.2] Got TEvRegisterCoordinatorRequest
2025-12-12T12:28:03.966906Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: a3e078ee-1e6d1476-94764c3c-6e303283 2025-12-12 12:28:03.966 DEBUG ydbd(pid=1226733, tid=0x00007F147A303640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Build task: 2 takes 14974 us
2025-12-12T12:28:03.966927Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: a3e078ee-1e6d1476-94764c3c-6e303283 2025-12-12 12:28:03.966 DEBUG ydbd(pid=1226733, tid=0x00007F147A303640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Prepare task: 2
2025-12-12T12:28:03.966951Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: a3e078ee-1e6d1476-94764c3c-6e303283 2025-12-12 12:28:03.966 DEBUG ydbd(pid=1226733, tid=0x00007F147A303640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Prepare task: 2, takes 16 us
2025-12-12T12:28:03.967045Z :YQL_PROXY TRACE: log.cpp:64: SessionId:  2025-12-12 12:28:03.967 TRACE ydbd(pid=1226733, tid=0x00007F147A303640) [DQ] task_controller_impl.h:160: [1:7582947228327135317:2286] EvState TaskId: 2 State: 2 PingCookie: 0 StatusCode: UNSPECIFIED
2025-12-12T12:28:03.967059Z :YQL_PROXY TRACE: log.cpp:64: SessionId:  2025-12-12 12:28:03.967 TRACE ydbd(pid=1226733, tid=0x00007F147A303640) [DQ] task_controller_impl.h:201:  [1:7582947228327135317:2286] Executing TaskId: 2
2025-12-12T12:28:03.988854Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:279: [ptqudq7ueohsakh1jitp-0.2] Graph registered
2025-12-12T12:28:03.988866Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:281: [ptqudq7ueohsakh1jitp-0.2] Send TEvRegisterCoordinatorResponse
2025-12-12T12:28:03.988910Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:131: [ptqudq7ueohsakh1jitp-0.2] Got TEvRegisterCoordinatorResponse; issues: 
2025-12-12T12:28:03.988913Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:140: [ptqudq7ueohsakh1jitp-0.2] Successfully registered in storage
2025-12-12T12:28:03.988916Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:141: [ptqudq7ueohsakh1jitp-0.2] Send TEvNewCheckpointCoordinator to 3 actor(s)
2025-12-12T12:28:03.988936Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:149: [ptqudq7ueohsakh1jitp-0.2] Send TEvGetCheckpointsMetadataRequest; state load mode: FROM_LAST_CHECKPOINT; load graph: 0
2025-12-12T12:28:03.988991Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:197: [] Task: 3. Got TEvNewCheckpointCoordinator event: generation 2, actorId: [1:7582947228327135316:2285]
2025-12-12T12:28:03.988998Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:208: [] Task: 3. Assign checkpoint coordinator (generation = 2)
2025-12-12T12:28:03.989009Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:434: [ptqudq7ueohsakh1jitp-0] Got TEvGetCheckpointsMetadataRequest
2025-12-12T12:28:03.989030Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:197: [] Task: 2. Got TEvNewCheckpointCoordinator event: generation 2, actorId: [1:7582947228327135316:2285]
2025-12-12T12:28:03.989033Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:208: [] Task: 2. Assign checkpoint coordinator (generation = 2)
2025-12-12T12:28:04.005112Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:197: [] Task: 1. Got TEvNewCheckpointCoordinator event: generation 2, actorId: [1:7582947228327135316:2285]
2025-12-12T12:28:04.005129Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:208: [] Task: 1. Assign checkpoint coordinator (generation = 2)
2025-12-12T12:28:04.005903Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1360: SelfId: [1:7582947228327135321:2290], TxId: ptqudq7ueohsakh1jitp, 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\024ptqudq7ueohsakh1jitp\032\017localhost:17898\"\032\n\030cluster:default_myyds_2f*\005local0\002@\001b\004Dataj\025[\"DataType\";\"String\"]\222\001\024ptcudq7ueos1oh23eroc\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-12T12:28:04.006308Z :KQP_COMPUTE DEBUG: dq_pq_read_actor_base.cpp:153: SelfId: [0:0:0], TxId: ptqudq7ueohsakh1jitp, 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-12T12:28:04.006370Z :YQL_PROXY TRACE: log.cpp:64: SessionId:  2025-12-12 12:28:04.006 TRACE ydbd(pid=1226733, tid=0x00007F1478B00640) [DQ] task_controller_impl.h:160: [1:7582947228327135317:2286] EvState TaskId: 1 State: 2 PingCookie: 0 StatusCode: UNSPECIFIED
2025-12-12T12:28:04.006385Z :YQL_PROXY TRACE: log.cpp:64: SessionId:  2025-12-12 12:28:04.006 TRACE ydbd(pid=1226733, tid=0x00007F1478B00640) [DQ] task_controller_impl.h:201:  [1:7582947228327135317:2286] Executing TaskId: 1
2025-12-12T12:28:04.006404Z :YQL_PROXY DEBUG: log.cpp:64: SessionId:  2025-12-12 12:28:04.006 DEBUG ydbd(pid=1226733, tid=0x00007F1478B00640) [DQ] task_controller_impl.h:561: Update channels
2025-12-12T12:28:04.006983Z :YQL_PROXY TRACE: log.cpp:64: SessionId:  2025-12-12 12:28:04.006 TRACE ydbd(pid=1226733, tid=0x00007F1478B00640) [DQ] task_controller_impl.h:577: 1 Update { Id: 1 TransportVersion: DATA_TRANSPORT_UV_PICKLE_1_0 SrcTaskId: 1 DstTaskId: 2 SrcEndpoint { ActorId { RawX1: 7582947228327135321 RawX2: 4503603922340082 } } DstEndpoint { ActorId { RawX1: 7582947228327135319 RawX2: 4503603922340080 } } WatermarksMode: WATERMARKS_MODE_DISABLED SrcStageId: 200473 DstStageId: 200494 }
2025-12-12T12:28:04.007055Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1064: SelfId: [1:7582947228327135321:2290], TxId: ptqudq7ueohsakh1jitp, task: 1. Ctx: {}. Received channels info: Update { Id: 1 TransportVersion: DATA_TRANSPORT_UV_PICKLE_1_0 SrcTaskId: 1 DstTaskId: 2 SrcEndpoint { ActorId { RawX1: 7582947228327135321 RawX2: 4503603922340082 } } DstEndpoint { ActorId { RawX1: 7582947228327135319 RawX2: 4503603922340080 } } WatermarksMode: WATERMARKS_MODE_DISABLED SrcStageId: 200473 DstStageId: 200494 }
2025-12-12T12:28:04.007060Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1083: SelfId: [1:7582947228327135321:2290], TxId: ptqudq7ueohsakh1jitp, task: 1. Ctx: {}. Update output channelId: 1, peer: [1:7582947228327135319:2288]
2025-12-12T12:28:04.007106Z :YQL_PROXY TRACE: log.cpp:64: SessionId:  2025-12-12 12:28:04.007 TRACE ydbd(pid=1226733, tid=0x00007F1478B00640) [DQ] task_controller_impl.h:577: 2 Update { Id: 1 TransportVersion: DATA_TRANSPORT_UV_PICKLE_1_0 SrcTaskId: 1 DstTaskId: 2 SrcEndpoint { ActorId { RawX1: 7582947228327135321 RawX2: 4503603922340082 } } DstEndpoint { ActorId { RawX1: 7582947228327135319 RawX2: 4503603922340080 } } 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: 7582947228327135319 RawX2: 4503603922340080 } } DstEndpoint { ActorId { RawX1: 7582947228327135320 RawX2: 4503603922340081 } } WatermarksMode: WATERMARKS_MODE_DISABLED SrcStageId: 200494 DstStageId: 200511 }
2025-12-12T12:28:04.007139Z :YQL_PROXY TRACE: log.cpp:64: SessionId:  2025-12-12 12:28:04.007 TRACE ydbd(pid=1226733, tid=0x00007F1478B00640) [DQ] task_controller_impl.h:577: 3 Update { Id: 2 TransportVersion: DATA_TRANSPORT_UV_PICKLE_1_0 SrcTaskId: 2 DstTaskId: 3 SrcEndpoint { ActorId { RawX1: 7582947228327135319 RawX2: 4503603922340080 } } DstEndpoint { ActorId { RawX1: 7582947228327135320 RawX2: 4503603922340081 } } WatermarksMode: WATERMARKS_MODE_DISABLED SrcStageId: 200494 DstStageId: 200511 } Update { Id: 3 TransportVersion: DATA_TRANSPORT_UV_PICKLE_1_0 SrcTaskId: 3 SrcEndpoint { ActorId { RawX1: 7582947228327135320 RawX2: 4503603922340081 } } DstEndpoint { ActorId { RawX1: 7582947228327135315 RawX2: 4503603922340076 } } WatermarksMode: WATERMARKS_MODE_DISABLED }
2025-12-12T12:28:04.007175Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1064: SelfId: [1:7582947228327135320:2289], TxId: ptqudq7ueohsakh1jitp, task: 3. Ctx: {}. Received channels info: Update { Id: 2 TransportVersion: DATA_TRANSPORT_UV_PICKLE_1_0 SrcTaskId: 2 DstTaskId: 3 SrcEndpoint { ActorId { RawX1: 7582947228327135319 RawX2: 4503603922340080 } } DstEndpoint { ActorId { RawX1: 7582947228327135320 RawX2: 4503603922340081 } } WatermarksMode: WATERMARKS_MODE_DISABLED SrcStageId: 200494 DstStageId: 200511 } Update { Id: 3 TransportVersion: DATA_TRANSPORT_UV_PICKLE_1_0 SrcTaskId: 3 SrcEndpoint { ActorId { RawX1: 7582947228327135320 RawX2: 4503603922340081 } } DstEndpoint { ActorId { RawX1: 7582947228327135315 RawX2: 4503603922340076 } } WatermarksMode: WATERMARKS_MODE_DISABLED }
2025-12-12T12:28:04.007184Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1071: SelfId: [1:7582947228327135320:2289], TxId: ptqudq7ueohsakh1jitp, task: 3. Ctx: {}. Update input channelId: 2, peer: [1:7582947228327135319:2288]
2025-12-12T12:28:04.007186Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1064: SelfId: [1:7582947228327135319:2288], TxId: ptqudq7ueohsakh1jitp, task: 2. Ctx: {}. Received channels info: Update { Id: 1 TransportVersion: DATA_TRANSPORT_UV_PICKLE_1_0 SrcTaskId: 1 DstTaskId: 2 SrcEndpoint { ActorId { RawX1: 7582947228327135321 RawX2: 4503603922340082 } } DstEndpoint { ActorId { RawX1: 7582947228327135319 RawX2: 4503603922340080 } } 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: 7582947228327135319 RawX2: 4503603922340080 } } DstEndpoint { ActorId { RawX1: 7582947228327135320 RawX2: 4503603922340081 } } WatermarksMode: WATERMARKS_MODE_DISABLED SrcStageId: 200494 DstStageId: 200511 }
2025-12-12T12:28:04.007188Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1083: SelfId: [1:7582947228327135320:2289], TxId: ptqudq7ueohsakh1jitp, task: 3. Ctx: {}. Update output channelId: 3, peer: [1:7582947228327135315:2284]
2025-12-12T12:28:04.007191Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1071: SelfId: [1:7582947228327135319:2288], TxId: ptqudq7ueohsakh1jitp, task: 2. Ctx: {}. Update input channelId: 1, peer: [1:7582947228327135321:2290]
2025-12-12T12:28:04.007196Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1083: SelfId: [1:7582947228327135319:2288], TxId: ptqudq7ueohsakh1jitp, task: 2. Ctx: {}. Update output channelId: 2, peer: [1:7582947228327135320:2289]
2025-12-12T12:28:04.046736Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:451: [ptqudq7ueohsakh1jitp-0] Send TEvGetCheckpointsMetadataResponse
2025-12-12T12:28:04.046805Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:186: [ptqudq7ueohsakh1jitp-0.2] Got TEvGetCheckpointsMetadataResponse
2025-12-12T12:28:04.046816Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:219: [ptqudq7ueohsakh1jitp-0.2] Will restore from checkpoint 1:1
2025-12-12T12:28:04.047092Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:265: [ptqudq7ueohsakh1jitp-0] Task: 3. [Checkpoint 1.1] TEvRestoreFromCheckpoint, StateLoadPlan = { StateType: STATE_TYPE_OWN }
2025-12-12T12:28:04.047105Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:265: [ptqudq7ueohsakh1jitp-0] Task: 2. [Checkpoint 1.1] TEvRestoreFromCheckpoint, StateLoadPlan = { StateType: STATE_TYPE_OWN }
2025-12-12T12:28:04.047117Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:508: [ptqudq7ueohsakh1jitp-0] [1:1] Got TEvGetTaskState: tasks {3}
2025-12-12T12:28:04.047124Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:519: [ptqudq7ueohsakh1jitp-0] [1:1] GetState, tasks: 3
2025-12-12T12:28:04.047143Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:265: [ptqudq7ueohsakh1jitp-0] Task: 1. [Checkpoint 1.1] TEvRestoreFromCheckpoint, StateLoadPlan = { StateType: STATE_TYPE_OWN }
2025-12-12T12:28:04.047165Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:508: [ptqudq7ueohsakh1jitp-0] [1:1] Got TEvGetTaskState: tasks {2}
2025-12-12T12:28:04.047166Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:519: [ptqudq7ueohsakh1jitp-0] [1:1] GetState, tasks: 2
2025-12-12T12:28:04.047174Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:508: [ptqudq7ueohsakh1jitp-0] [1:1] Got TEvGetTaskState: tasks {1}
2025-12-12T12:28:04.047175Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:519: [ptqudq7ueohsakh1jitp-0] [1:1] GetState, tasks: 1
2025-12-12T12:28:04.121700Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:654: [ptqudq7ueohsakh1jitp-0] [1:1] ListOfStates results:
2025-12-12T12:28:04.121729Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:675: [ptqudq7ueohsakh1jitp-0] [1:1] taskId 3 checkpoint id: 1:1, rows count: 1
2025-12-12T12:28:04.121737Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:901: [ptqudq7ueohsakh1jitp-0] [1:1] SkipStatesInFuture, skip 0 checkpoints
2025-12-12T12:28:04.121803Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:654: [ptqudq7ueohsakh1jitp-0] [1:1] ListOfStates results:
2025-12-12T12:28:04.121808Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:675: [ptqudq7ueohsakh1jitp-0] [1:1] taskId 1 checkpoint id: 1:1, rows count: 1
2025-12-12T12:28:04.121811Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:901: [ptqudq7ueohsakh1jitp-0] [1:1] SkipStatesInFuture, skip 0 checkpoints
2025-12-12T12:28:04.121841Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:654: [ptqudq7ueohsakh1jitp-0] [1:1] ListOfStates results:
2025-12-12T12:28:04.121847Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:675: [ptqudq7ueohsakh1jitp-0] [1:1] taskId 2 checkpoint id: 1:1, rows count: 1
2025-12-12T12:28:04.121850Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:901: [ptqudq7ueohsakh1jitp-0] [1:1] SkipStatesInFuture, skip 0 checkpoints
2025-12-12T12:28:04.121878Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:796: [ptqudq7ueohsakh1jitp-0] [1:1] SelectState: task_id 3, seq_no 1, blob_seq_num 0
2025-12-12T12:28:04.122107Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:796: [ptqudq7ueohsakh1jitp-0] [1:1] SelectState: task_id 1, seq_no 1, blob_seq_num 0
2025-12-12T12:28:04.122188Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:796: [ptqudq7ueohsakh1jitp-0] [1:1] SelectState: task_id 2, seq_no 1, blob_seq_num 0
2025-12-12T12:28:04.184149Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:410: [ptqudq7ueohsakh1jitp-0] [1:1] DeserializeState, task id 3, blob size 29
2025-12-12T12:28:04.184180Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:960: [ptqudq7ueohsakh1jitp-0] [1:1] ApplyIncrements
2025-12-12T12:28:04.184327Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:527: [ptqudq7ueohsakh1jitp-0] [{ Id: 1 Generation: 1 }] Send TEvGetTaskStateResult: tasks: {3}
2025-12-12T12:28:04.184374Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:336: [ptqudq7ueohsakh1jitp-0] Task: 3. [Checkpoint 1.1] TEvGetTaskStateResult: restoring state
2025-12-12T12:28:04.184386Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:793: SelfId: [1:7582947228327135320:2289], TxId: ptqudq7ueohsakh1jitp, task: 3. Ctx: {}. Load state
2025-12-12T12:28:04.184406Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:410: [ptqudq7ueohsakh1jitp-0] [1:1] DeserializeState, task id 2, blob size 29
2025-12-12T12:28:04.184406Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:362: [ptqudq7ueohsakh1jitp-0] Task: 3. [Checkpoint 1.1] Checkpoint state restored
2025-12-12T12:28:04.184414Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:960: [ptqudq7ueohsakh1jitp-0] [1:1] ApplyIncrements
2025-12-12T12:28:04.184421Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:527: [ptqudq7ueohsakh1jitp-0] [{ Id: 1 Generation: 1 }] Send TEvGetTaskStateResult: tasks: {2}
2025-12-12T12:28:04.184424Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:297: [ptqudq7ueohsakh1jitp-0.2] [1:1] Got TEvRestoreFromCheckpointResult; taskId: 3, checkpoint: 1:1, status: OK, issues: 
2025-12-12T12:28:04.184427Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:320: [ptqudq7ueohsakh1jitp-0.2] [1:1] Task state restored, need 2 more acks
2025-12-12T12:28:04.184433Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:336: [ptqudq7ueohsakh1jitp-0] Task: 2. [Checkpoint 1.1] TEvGetTaskStateResult: restoring state
2025-12-12T12:28:04.184436Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:793: SelfId: [1:7582947228327135319:2288], TxId: ptqudq7ueohsakh1jitp, task: 2. Ctx: {}. Load state
2025-12-12T12:28:04.184445Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:362: [ptqudq7ueohsakh1jitp-0] Task: 2. [Checkpoint 1.1] Checkpoint state restored
2025-12-12T12:28:04.184469Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:410: [ptqudq7ueohsakh1jitp-0] [1:1] DeserializeState, task id 1, blob size 111
2025-12-12T12:28:04.184469Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:297: [ptqudq7ueohsakh1jitp-0.2] [1:1] Got TEvRestoreFromCheckpointResult; taskId: 2, checkpoint: 1:1, status: OK, issues: 
2025-12-12T12:28:04.184473Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:320: [ptqudq7ueohsakh1jitp-0.2] [1:1] Task state restored, need 1 more acks
2025-12-12T12:28:04.184477Z :STREAMS_STORAGE_SERVICE DEBUG: ydb_state_storage.cpp:960: [ptqudq7ueohsakh1jitp-0] [1:1] ApplyIncrements
2025-12-12T12:28:04.184483Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:527: [ptqudq7ueohsakh1jitp-0] [{ Id: 1 Generation: 1 }] Send TEvGetTaskStateResult: tasks: {1}
2025-12-12T12:28:04.184498Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:336: [ptqudq7ueohsakh1jitp-0] Task: 1. [Checkpoint 1.1] TEvGetTaskStateResult: restoring state
2025-12-12T12:28:04.184500Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:793: SelfId: [1:7582947228327135321:2290], TxId: ptqudq7ueohsakh1jitp, task: 1. Ctx: {}. Load state
2025-12-12T12:28:04.184515Z :KQP_COMPUTE DEBUG: dq_pq_read_actor_base.cpp:153: SelfId: [0:0:0], TxId: ptqudq7ueohsakh1jitp, 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-12T12:28:04.184529Z :KQP_COMPUTE DEBUG: dq_pq_read_actor_base.cpp:133: SelfId: [0:0:0], TxId: ptqudq7ueohsakh1jitp, task: 1. PQ source. SessionId: empty StartingMessageTs 2025-12-12T12:27:29.800000Z Restoring offset: 
2025-12-12T12:28:04.184541Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:362: [ptqudq7ueohsakh1jitp-0] Task: 1. [Checkpoint 1.1] Checkpoint state restored
2025-12-12T12:28:04.184548Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:297: [ptqudq7ueohsakh1jitp-0.2] [1:1] Got TEvRestoreFromCheckpointResult; taskId: 1, checkpoint: 1:1, status: OK, issues: 
2025-12-12T12:28:04.184550Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:320: [ptqudq7ueohsakh1jitp-0.2] [1:1] Task state restored, need 0 more acks
2025-12-12T12:28:04.184554Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:445: [ptqudq7ueohsakh1jitp-0.2] Send TEvRun to all actors
2025-12-12T12:28:04.184567Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1164: SelfId: [1:7582947228327135321:2290], TxId: ptqudq7ueohsakh1jitp, task: 1. Ctx: {}. Got TEvRun from actor [1:7582947228327135316:2285]
2025-12-12T12:28:04.184570Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1164: SelfId: [1:7582947228327135320:2289], TxId: ptqudq7ueohsakh1jitp, task: 3. Ctx: {}. Got TEvRun from actor [1:7582947228327135316:2285]
2025-12-12T12:28:04.184578Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7582947228327135321:2290], TxId: ptqudq7ueohsakh1jitp, task: 1. Ctx: {}. Poll inputs
2025-12-12T12:28:04.184579Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7582947228327135320:2289], TxId: ptqudq7ueohsakh1jitp, task: 3. Ctx: {}. Poll inputs
2025-12-12T12:28:04.184580Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [1:7582947228327135321:2290], TxId: ptqudq7ueohsakh1jitp, task: 1. Ctx: {}. Poll sources
2025-12-12T12:28:04.184582Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [1:7582947228327135320:2289], TxId: ptqudq7ueohsakh1jitp, task: 3. Ctx: {}. Poll sources
2025-12-12T12:28:04.184584Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:542: SelfId: [0:0:0], TxId: ptqudq7ueohsakh1jitp, task: 1. PQ source. SessionId: empty GetAsyncInputData freeSpace = 1
2025-12-12T12:28:04.184584Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [1:7582947228327135320:2289], TxId: ptqudq7ueohsakh1jitp, task: 3. Ctx: {}. DoExecuteImpl: 0
2025-12-12T12:28:04.184591Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1164: SelfId: [1:7582947228327135319:2288], TxId: ptqudq7ueohsakh1jitp, task: 2. Ctx: {}. Got TEvRun from actor [1:7582947228327135316:2285]
2025-12-12T12:28:04.184602Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7582947228327135319:2288], TxId: ptqudq7ueohsakh1jitp, task: 2. Ctx: {}. Poll inputs
2025-12-12T12:28:04.184604Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [1:7582947228327135319:2288], TxId: ptqudq7ueohsakh1jitp, task: 2. Ctx: {}. Poll sources
2025-12-12T12:28:04.184606Z :KQP_COMPUTE DEBUG: dq_pq_read_actor.cpp:648: SelfId: [0:0:0], TxId: ptqudq7ueohsakh1jitp, task: 1. PQ source. SessionId: empty PartitionsToRead: 0
2025-12-12T12:28:04.184607Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [1:7582947228327135319:2288], TxId: ptqudq7ueohsakh1jitp, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-12-12T12:28:04.184636Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:28:04.184631Z :INFO: [local] [local] [20b35d4a-59a85a4d-2d260c31-4c4c7312] Starting read session
2025-12-12T12:28:04.184641Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:28:04.184639Z :DEBUG: [local] [local] [20b35d4a-59a85a4d-2d260c31-4c4c7312] Starting single session
2025-12-12T12:28:04.184672Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: a3e078ee-1e6d1476-94764c3c-6e303283 2025-12-12 12:28:04.184 DEBUG ydbd(pid=1226733, tid=0x00007F147A303640) [DQ] tasks_runner_local.cpp:267: {TODO/3} Run task: 3
2025-12-12T12:28:04.184677Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:28:04.184674Z :DEBUG: [local] [local] [20b35d4a-59a85a4d-2d260c31-4c4c7312] [] In Reconnect, ReadSizeBudget = 8388608, ReadSizeServerDelta = 0
2025-12-12T12:28:04.184681Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:28:04.184680Z :DEBUG: [local] [local] [20b35d4a-59a85a4d-2d260c31-4c4c7312] [] New values: ReadSizeBudget = 8388608, ReadSizeServerDelta = 0
2025-12-12T12:28:04.184684Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:28:04.184683Z :DEBUG: [local] [local] [20b35d4a-59a85a4d-2d260c31-4c4c7312] [] Reconnecting session to cluster  in 0.000000s
2025-12-12T12:28:04.184701Z :KQP_COMPUTE TRACE: dq_compute_memory_quota.h:97: TxId: ptqudq7ueohsakh1jitp, task: 2. Peak memory usage: 2031616
2025-12-12T12:28:04.184702Z :KQP_COMPUTE TRACE: dq_compute_memory_quota.h:97: TxId: ptqudq7ueohsakh1jitp, task: 3. Peak memory usage: 2031616
2025-12-12T12:28:04.184707Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7582947228327135319:2288], TxId: ptqudq7ueohsakh1jitp, task: 2. Ctx: {}. update task runner stats
2025-12-12T12:28:04.184711Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7582947228327135320:2289], TxId: ptqudq7ueohsakh1jitp, task: 3. Ctx: {}. update task runner stats
2025-12-12T12:28:04.184727Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7582947228327135319:2288], TxId: ptqudq7ueohsakh1jitp, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-12T12:28:04.184731Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7582947228327135319:2288], TxId: ptqudq7ueohsakh1jitp, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:28:04.184737Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:534: SelfId: [1:7582947228327135319:2288], TxId: ptqudq7ueohsakh1jitp, task: 2. Ctx: {}. About to drain channelId: 2, hasPeer: 1, peerState:(freeSpace:1000000;inFlightBytes:0;inFlightCount:0;)
2025-12-12T12:28:04.184743Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1107: SelfId: [1:7582947228327135319:2288], TxId: ptqudq7ueohsakh1jitp, task: 2. Ctx: {}. Ask CPU quota: 15ms
2025-12-12T12:28:04.184745Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7582947228327135320:2289], TxId: ptqudq7ueohsakh1jitp, task: 3. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-12T12:28:04.184748Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7582947228327135320:2289], TxId: ptqudq7ueohsakh1jitp, task: 3. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:28:04.184752Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:534: SelfId: [1:7582947228327135320:2289], TxId: ptqudq7ueohsakh1jitp, task: 3. Ctx: {}. About to drain channelId: 3, hasPeer: 1, peerState:(freeSpace:1000000;inFlightBytes:0;inFlightCount:0;)
2025-12-12T12:28:04.184759Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:605: TxId: ptqudq7ueohsakh1jitp, task: 2. no poll, channelId: 1, hasPeer: 1, finished: 0, retry: 0, lastSeqNo: 0, freeSpace: 1000000
2025-12-12T12:28:04.184765Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:605: TxId: ptqudq7ueohsakh1jitp, task: 3. no poll, channelId: 2, hasPeer: 1, finished: 0, retry: 0, lastSeqNo: 0, freeSpace: 1000000
2025-12-12T12:28:04.184918Z :KQP_COMPUTE INFO: dq_pq_read_actor.cpp:315: SelfId: [0:0:0], TxId: ptqudq7ueohsakh1jitp, task: 1. PQ source. SessionId: 20b35d4a-59a85a4d-2d260c31-4c4c7312 CreateReadSession
2025-12-12T12:28:04.184925Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:81: SelfId: [1:7582947228327135321:2290], TxId: ptqudq7ueohsakh1jitp, task: 1. Ctx: {}. Poll async input 0. Buffer free space: 1, read from async input: 0 bytes, 0 rows, finished: 0
2025-12-12T12:28:04.184946Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [1:7582947228327135321:2290], TxId: ptqudq7ueohsakh1jitp, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-12-12T12:28:04.184973Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:28:04.184952Z :DEBUG: [local] [local] [20b35d4a-59a85a4d-2d260c31-4c4c7312] [] Successfully connected. Initializing session
2025-12-12T12:28:04.185005Z :KQP_COMPUTE TRACE: dq_compute_memory_quota.h:97: TxId: ptqudq7ueohsakh1jitp, task: 1. Peak memory usage: 2031616
2025-12-12T12:28:04.185010Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7582947228327135321:2290], TxId: ptqudq7ueohsakh1jitp, task: 1. Ctx: {}. update task runner stats
2025-12-12T12:28:04.185029Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7582947228327135321:2290], TxId: ptqudq7ueohsakh1jitp, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-12T12:28:04.185031Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7582947228327135321:2290], TxId: ptqudq7ueohsakh1jitp, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:28:04.185035Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:534: SelfId: [1:7582947228327135321:2290], TxId: ptqudq7ueohsakh1jitp, task: 1. Ctx: {}. About to drain channelId: 1, hasPeer: 1, peerState:(freeSpace:1000000;inFlightBytes:0;inFlightCount:0;)
2025-12-12T12:28:04.185039Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1107: SelfId: [1:7582947228327135321:2290], TxId: ptqudq7ueohsakh1jitp, task: 1. Ctx: {}. Ask CPU quota: 55ms
2025-12-12T12:28:04.185899Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1165: SelfId: [1:7582947228327135319:2288], TxId: ptqudq7ueohsakh1jitp, task: 2. Ctx: {}. CPU quota delay: 1ms
2025-12-12T12:28:04.186004Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1165: SelfId: [1:7582947228327135321:2290], TxId: ptqudq7ueohsakh1jitp, task: 1. Ctx: {}. CPU quota delay: 0ms
2025-12-12T12:28:04.186129Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:28:04.186122Z :INFO: [local] [local] [20b35d4a-59a85a4d-2d260c31-4c4c7312] [] Got InitResponse. ReadSessionId: ptqudq7ueohsakh1jitp_1_3_3429617226706092172_v1
2025-12-12T12:28:04.186141Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:28:04.186139Z :DEBUG: [local] [local] [20b35d4a-59a85a4d-2d260c31-4c4c7312] [] In ContinueReadingDataImpl, ReadSizeBudget = 8388608, ReadSizeServerDelta = 0
2025-12-12T12:28:04.186223Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:28:04.186221Z :DEBUG: [local] [local] [20b35d4a-59a85a4d-2d260c31-4c4c7312] [] After sending read request: ReadSizeBudget = 0, ReadSizeServerDelta = 8388608
2025-12-12T12:28:04.188268Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:363: SelfId: [0:0:0], TxId: ptqudq7ueohsakh1jitp, task: 1. PQ source. SessionId: 20b35d4a-59a85a4d-2d260c31-4c4c7312 Source data ready
2025-12-12T12:28:04.188291Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7582947228327135321:2290], TxId: ptqudq7ueohsakh1jitp, task: 1. Ctx: {}. Poll inputs
2025-12-12T12:28:04.188295Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [1:7582947228327135321:2290], TxId: ptqudq7ueohsakh1jitp, task: 1. Ctx: {}. Poll sources
2025-12-12T12:28:04.188300Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:542: SelfId: [0:0:0], TxId: ptqudq7ueohsakh1jitp, task: 1. PQ source. SessionId: 20b35d4a-59a85a4d-2d260c31-4c4c7312 GetAsyncInputData freeSpace = 1000000
2025-12-12T12:28:04.188314Z :KQP_COMPUTE DEBUG: dq_pq_read_actor.cpp:820: SelfId: [0:0:0], TxId: ptqudq7ueohsakh1jitp, task: 1. PQ source. SessionId: 20b35d4a-59a85a4d-2d260c31-4c4c7312 Key: 0@ StartPartitionSessionEvent received
2025-12-12T12:28:04.188318Z :KQP_COMPUTE DEBUG: dq_pq_read_actor.cpp:827: SelfId: [0:0:0], TxId: ptqudq7ueohsakh1jitp, task: 1. PQ source. SessionId: 20b35d4a-59a85a4d-2d260c31-4c4c7312 Key: 0@ Confirm StartPartitionSession with offset (NULL)
2025-12-12T12:28:04.188330Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:28:04.188326Z :INFO: [local] [local] [20b35d4a-59a85a4d-2d260c31-4c4c7312] [] Confirm partition stream create. Partition stream id: 1. Cluster: "-". Topic: "select_timings_2f_input". Partition: 0. Read offset: (NULL)
2025-12-12T12:28:04.188384Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:81: SelfId: [1:7582947228327135321:2290], TxId: ptqudq7ueohsakh1jitp, task: 1. Ctx: {}. Poll async input 0. Buffer free space: 1000000, read from async input: 0 bytes, 0 rows, finished: 0
2025-12-12T12:28:04.188408Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:363: SelfId: [0:0:0], TxId: ptqudq7ueohsakh1jitp, task: 1. PQ source. SessionId: 20b35d4a-59a85a4d-2d260c31-4c4c7312 Source data ready
2025-12-12T12:28:04.188412Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [1:7582947228327135321:2290], TxId: ptqudq7ueohsakh1jitp, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-12-12T12:28:04.188463Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7582947228327135321:2290], TxId: ptqudq7ueohsakh1jitp, task: 1. Ctx: {}. Poll inputs
2025-12-12T12:28:04.188464Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [1:7582947228327135321:2290], TxId: ptqudq7ueohsakh1jitp, task: 1. Ctx: {}. Poll sources
2025-12-12T12:28:04.188468Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:542: SelfId: [0:0:0], TxId: ptqudq7ueohsakh1jitp, task: 1. PQ source. SessionId: 20b35d4a-59a85a4d-2d260c31-4c4c7312 GetAsyncInputData freeSpace = 1000000
2025-12-12T12:28:04.188471Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:81: SelfId: [1:7582947228327135321:2290], TxId: ptqudq7ueohsakh1jitp, task: 1. Ctx: {}. Poll async input 0. Buffer free space: 1000000, read from async input: 0 bytes, 0 rows, finished: 0
2025-12-12T12:28:04.188475Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7582947228327135321:2290], TxId: ptqudq7ueohsakh1jitp, task: 1. Ctx: {}. update task runner stats
2025-12-12T12:28:04.188503Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7582947228327135321:2290], TxId: ptqudq7ueohsakh1jitp, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-12T12:28:04.188506Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7582947228327135321:2290], TxId: ptqudq7ueohsakh1jitp, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:28:04.188511Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:534: SelfId: [1:7582947228327135321:2290], TxId: ptqudq7ueohsakh1jitp, task: 1. Ctx: {}. About to drain channelId: 1, hasPeer: 1, peerState:(freeSpace:1000000;inFlightBytes:0;inFlightCount:0;)
2025-12-12T12:28:04.188514Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [1:7582947228327135321:2290], TxId: ptqudq7ueohsakh1jitp, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-12-12T12:28:04.188534Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7582947228327135321:2290], TxId: ptqudq7ueohsakh1jitp, task: 1. Ctx: {}. update task runner stats
2025-12-12T12:28:04.188540Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7582947228327135321:2290], TxId: ptqudq7ueohsakh1jitp, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-12T12:28:04.188541Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7582947228327135321:2290], TxId: ptqudq7ueohsakh1jitp, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:28:04.188545Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:534: SelfId: [1:7582947228327135321:2290], TxId: ptqudq7ueohsakh1jitp, task: 1. Ctx: {}. About to drain channelId: 1, hasPeer: 1, peerState:(freeSpace:1000000;inFlightBytes:0;inFlightCount:0;)
2025-12-12T12:28:04.886829Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:627: RowDispatcher: Send ping to [1:7582947224032167796:2081]
2025-12-12T12:28:04.886853Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1174: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-12-12T12:28:04.886861Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:356: Coordinator: TEvPing received, [1:7582947224032167780:2069]
2025-12-12T12:28:04.886864Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:299: Coordinator: UpdateKnownRowDispatchers [1:7582947224032167780:2069]
2025-12-12T12:28:04.886867Z :FQ_ROW_DISPATCHER TRACE: coordinator.cpp:359: Coordinator: Send TEvPong to [1:7582947224032167780:2069]
2025-12-12T12:28:04.886878Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:633: RowDispatcher: NActors::TEvents::TEvPong
2025-12-12T12:28:04.887876Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: a3e078ee-1e6d1476-94764c3c-6e3032834, Host: ghrun-fhkyrtz6p4, Tenant: /default
2025-12-12T12:28:04.891224Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: a3e078ee-1e6d1476-94764c3c-6e3032834, Host: ghrun-fhkyrtz6p4, Tenant: /default, Request CP::GetTask with size: 68 bytes
2025-12-12T12:28:04.891290Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/default"
owner_id: "a3e078ee-1e6d1476-94764c3c-6e3032834"
host: "ghrun-fhkyrtz6p4"
node_id: 1
}
2025-12-12T12:28:04.894417Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:28:04.894460Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: a3e078ee-1e6d1476-94764c3c-6e3032834, Host: ghrun-fhkyrtz6p4, Tenant: /default, Got CP::GetTask Response
2025-12-12T12:28:04.894747Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:28:04.894771Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:28:04.957562Z :YQL_PROXY TRACE: log.cpp:64: SessionId:  2025-12-12 12:28:04.957 TRACE ydbd(pid=1226733, tid=0x00007F147B305640) [DQ] task_controller_impl.h:271:  [1:7582947228327135317:2286] ExportStats Summary
2025-12-12T12:28:04.957815Z :FQ_PINGER TRACE: pinger.cpp:250: QueryId: ptqudq7ueohsakh1jitp, Owner: a3e078ee-1e6d1476-94764c3c-6e3032832 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-12T12:28:04.957825Z :FQ_PINGER TRACE: pinger.cpp:393: QueryId: ptqudq7ueohsakh1jitp, Owner: a3e078ee-1e6d1476-94764c3c-6e3032832 Forward request Private::PingTask
2025-12-12T12:28:04.958628Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudq7ueohsakh1jitp, Owner: a3e078ee-1e6d1476-94764c3c-6e3032832, Request CP::PingTask with size: 740 bytes
2025-12-12T12:28:04.958749Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "a3e078ee-1e6d1476-94764c3c-6e3032832"
query_id {
  value: "ptqudq7ueohsakh1jitp"
}
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: 1765628883
  nanos: 907314000
}
tenant: "/default"
}
2025-12-12T12:28:04.971890Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {expired_at { seconds: 1765542504 nanos: 965000000 } } SUCCESS
2025-12-12T12:28:04.971942Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudq7ueohsakh1jitp, Owner: a3e078ee-1e6d1476-94764c3c-6e3032832, Got CP::PingTaskResponse
2025-12-12T12:28:04.972363Z :FQ_PINGER TRACE: pinger.cpp:338: QueryId: ptqudq7ueohsakh1jitp, Owner: a3e078ee-1e6d1476-94764c3c-6e3032832 Ping response success: { expired_at { seconds: 1765542504 nanos: 965000000 } }
2025-12-12T12:28:04.972396Z :FQ_RUN_ACTOR TRACE: run_actor.cpp:861: QueryId: ptqudq7ueohsakh1jitp Forward ping response. Success: 1. Cookie: 6
2025-12-12T12:28:05.184792Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:373: [ptqudq7ueohsakh1jitp-0.2] Got TEvScheduleCheckpointing
2025-12-12T12:28:05.184817Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:349: [ptqudq7ueohsakh1jitp-0.2] [2:1] Registering new checkpoint in storage
2025-12-12T12:28:05.184956Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:288: [ptqudq7ueohsakh1jitp-0.2] [2:1] Got TEvCreateCheckpointRequest
2025-12-12T12:28:05.187168Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:28:05.187154Z :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-12T12:28:05.187193Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:28:05.187191Z :INFO: [local] [local] [20b35d4a-59a85a4d-2d260c31-4c4c7312] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1002 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:28:05.220489Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:334: [ptqudq7ueohsakh1jitp-0.2] [2:1] Checkpoint created
2025-12-12T12:28:05.220502Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:336: [ptqudq7ueohsakh1jitp-0.2] [2:1] Send TEvCreateCheckpointResponse
2025-12-12T12:28:05.220556Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:389: [ptqudq7ueohsakh1jitp-0.2] [2:1] Got TEvCreateCheckpointResponse
2025-12-12T12:28:05.220563Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:435: [ptqudq7ueohsakh1jitp-0.2] [2:1] Checkpoint successfully created, going to inject barriers to 1 actor(s)
2025-12-12T12:28:05.220595Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:239: [ptqudq7ueohsakh1jitp-0] Task: 1. [Checkpoint 2.1] TEvInjectCheckpoint
2025-12-12T12:28:05.220610Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7582947228327135321:2290], TxId: ptqudq7ueohsakh1jitp, task: 1. Ctx: {}. Poll inputs
2025-12-12T12:28:05.220613Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1494: SelfId: [1:7582947228327135321:2290], TxId: ptqudq7ueohsakh1jitp, task: 1. Ctx: {}. Skip polling sources because of pending checkpoint
2025-12-12T12:28:05.220616Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [1:7582947228327135321:2290], TxId: ptqudq7ueohsakh1jitp, task: 1. Ctx: {}. DoExecuteImpl: 1
2025-12-12T12:28:05.220709Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:462: SelfId: [1:7582947228327135323:2290], TxId: ptqudq7ueohsakh1jitp, task: 1. Pending 1 checkpoints to be sent
2025-12-12T12:28:05.220727Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7582947228327135321:2290], TxId: ptqudq7ueohsakh1jitp, task: 1. Ctx: {}. update task runner stats
2025-12-12T12:28:05.220767Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7582947228327135321:2290], TxId: ptqudq7ueohsakh1jitp, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 1 watermark injected: (empty maybe)
2025-12-12T12:28:05.220770Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:447: [ptqudq7ueohsakh1jitp-0] Task: 1. [Checkpoint 2.1] Performing task checkpoint
2025-12-12T12:28:05.220773Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:816: SelfId: [1:7582947228327135321:2290], TxId: ptqudq7ueohsakh1jitp, task: 1. Ctx: {}. Save state
2025-12-12T12:28:05.220784Z :KQP_COMPUTE DEBUG: dq_pq_read_actor_base.cpp:94: SelfId: [0:0:0], TxId: ptqudq7ueohsakh1jitp, task: 1. PQ source. SessionId: 20b35d4a-59a85a4d-2d260c31-4c4c7312 SaveState, offsets: 
2025-12-12T12:28:05.220794Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:474: [ptqudq7ueohsakh1jitp-0] Task: 1. [Checkpoint 2.1] CA state saved
2025-12-12T12:28:05.220797Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:449: [ptqudq7ueohsakh1jitp-0] Task: 1. [Checkpoint 2.1] Injecting checkpoint barrier to outputs
2025-12-12T12:28:05.220808Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:536: [ptqudq7ueohsakh1jitp-0] Task: 1. [Checkpoint 2.1] Task checkpoint is done. Send to storage
2025-12-12T12:28:05.220811Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7582947228327135321:2290], TxId: ptqudq7ueohsakh1jitp, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:28:05.220819Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:534: SelfId: [1:7582947228327135321:2290], TxId: ptqudq7ueohsakh1jitp, task: 1. Ctx: {}. About to drain channelId: 1, hasPeer: 1, peerState:(freeSpace:1000000;inFlightBytes:0;inFlightCount:0;)
2025-12-12T12:28:05.220834Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:566: TxId: ptqudq7ueohsakh1jitp, task: 1. SendChannelData, channelId: 1, peer: [1:7582947228327135319:2288], chunks: 0, bytes: 0, watermark: 0, checkpoint: 1, seqNo: 1, finished: 0
2025-12-12T12:28:05.220851Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7582947228327135321:2290], TxId: ptqudq7ueohsakh1jitp, task: 1. Ctx: {}. Poll inputs
2025-12-12T12:28:05.220859Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [1:7582947228327135321:2290], TxId: ptqudq7ueohsakh1jitp, task: 1. Ctx: {}. Poll sources
2025-12-12T12:28:05.220864Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:542: SelfId: [0:0:0], TxId: ptqudq7ueohsakh1jitp, task: 1. PQ source. SessionId: 20b35d4a-59a85a4d-2d260c31-4c4c7312 GetAsyncInputData freeSpace = 1000000
2025-12-12T12:28:05.220873Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:81: SelfId: [1:7582947228327135321:2290], TxId: ptqudq7ueohsakh1jitp, task: 1. Ctx: {}. Poll async input 0. Buffer free space: 1000000, read from async input: 0 bytes, 0 rows, finished: 0
2025-12-12T12:28:05.220884Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:460: [ptqudq7ueohsakh1jitp-0] [2:1] Got TEvSaveTaskState: task 1
2025-12-12T12:28:05.220894Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [1:7582947228327135321:2290], TxId: ptqudq7ueohsakh1jitp, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-12-12T12:28:05.220911Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7582947228327135321:2290], TxId: ptqudq7ueohsakh1jitp, task: 1. Ctx: {}. update task runner stats
2025-12-12T12:28:05.220918Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7582947228327135321:2290], TxId: ptqudq7ueohsakh1jitp, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-12T12:28:05.220920Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7582947228327135321:2290], TxId: ptqudq7ueohsakh1jitp, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:28:05.220925Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:534: SelfId: [1:7582947228327135321:2290], TxId: ptqudq7ueohsakh1jitp, task: 1. Ctx: {}. About to drain channelId: 1, hasPeer: 1, peerState:(freeSpace:1000000;inFlightBytes:96;inFlightCount:1;)
2025-12-12T12:28:05.220939Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:129: TxId: ptqudq7ueohsakh1jitp, task: 2. Received input for channelId: 1, seqNo: 1, size: 0, chunks: 0, watermark: 0, checkpoint: 1, finished: 0, from: [1:7582947228327135322:2290], expected seqNo: 1
2025-12-12T12:28:05.220942Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:611: SelfId: [1:7582947228327135319:2288], TxId: ptqudq7ueohsakh1jitp, task: 2. Ctx: {}. took input
2025-12-12T12:28:05.220956Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:485: [ptqudq7ueohsakh1jitp-0] Task: 2. [Checkpoint 2.1] Got checkpoint barrier from channel 1
2025-12-12T12:28:05.220967Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:356: SelfId: [1:7582947228327135325:2288], TxId: ptqudq7ueohsakh1jitp, task: 2. No watermark 
2025-12-12T12:28:05.220969Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7582947228327135319:2288], TxId: ptqudq7ueohsakh1jitp, task: 2. Ctx: {}. Poll inputs
2025-12-12T12:28:05.220970Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1494: SelfId: [1:7582947228327135319:2288], TxId: ptqudq7ueohsakh1jitp, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-12-12T12:28:05.220972Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [1:7582947228327135319:2288], TxId: ptqudq7ueohsakh1jitp, task: 2. Ctx: {}. DoExecuteImpl: 1
2025-12-12T12:28:05.220977Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:965: SelfId: [1:7582947228327135319:2288], TxId: ptqudq7ueohsakh1jitp, task: 2. Ctx: {}. Input data push finished. Cookie: 0 Watermark: (empty maybe) Ack: 1 TakeInputChannelDataRequests: 1
2025-12-12T12:28:05.220981Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:738: TxId: ptqudq7ueohsakh1jitp, task: 2. Sending channel data ack to channelId: 1, peer: [1:7582947228327135321:2290], from: [1:7582947228327135319:2288], freeSpace: 1000000, seqNo: 1, finished: 0
2025-12-12T12:28:05.221010Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:462: SelfId: [1:7582947228327135325:2288], TxId: ptqudq7ueohsakh1jitp, task: 2. Pending 1 checkpoints to be sent
2025-12-12T12:28:05.221014Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7582947228327135319:2288], TxId: ptqudq7ueohsakh1jitp, task: 2. Ctx: {}. Poll inputs
2025-12-12T12:28:05.221015Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1494: SelfId: [1:7582947228327135319:2288], TxId: ptqudq7ueohsakh1jitp, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-12-12T12:28:05.221017Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [1:7582947228327135319:2288], TxId: ptqudq7ueohsakh1jitp, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-12-12T12:28:05.221018Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7582947228327135319:2288], TxId: ptqudq7ueohsakh1jitp, task: 2. Ctx: {}. update task runner stats
2025-12-12T12:28:05.221033Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7582947228327135319:2288], TxId: ptqudq7ueohsakh1jitp, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 1 watermark injected: (empty maybe)
2025-12-12T12:28:05.221041Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:447: [ptqudq7ueohsakh1jitp-0] Task: 2. [Checkpoint 2.1] Performing task checkpoint
2025-12-12T12:28:05.221042Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:816: SelfId: [1:7582947228327135319:2288], TxId: ptqudq7ueohsakh1jitp, task: 2. Ctx: {}. Save state
2025-12-12T12:28:05.221044Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:474: [ptqudq7ueohsakh1jitp-0] Task: 2. [Checkpoint 2.1] CA state saved
2025-12-12T12:28:05.221045Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:449: [ptqudq7ueohsakh1jitp-0] Task: 2. [Checkpoint 2.1] Injecting checkpoint barrier to outputs
2025-12-12T12:28:05.221059Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:536: [ptqudq7ueohsakh1jitp-0] Task: 2. [Checkpoint 2.1] Task checkpoint is done. Send to storage
2025-12-12T12:28:05.221060Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7582947228327135319:2288], TxId: ptqudq7ueohsakh1jitp, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:28:05.221064Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:534: SelfId: [1:7582947228327135319:2288], TxId: ptqudq7ueohsakh1jitp, task: 2. Ctx: {}. About to drain channelId: 2, hasPeer: 1, peerState:(freeSpace:1000000;inFlightBytes:0;inFlightCount:0;)
2025-12-12T12:28:05.221079Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:566: TxId: ptqudq7ueohsakh1jitp, task: 2. SendChannelData, channelId: 2, peer: [1:7582947228327135320:2289], chunks: 0, bytes: 0, watermark: 0, checkpoint: 1, seqNo: 1, finished: 0
2025-12-12T12:28:05.221086Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudq7ueohsakh1jitp, task: 2. no poll, channelId: 1, has inflight messages: [1], last with freeSpace: 1000000, current freeSpace: 1000000
2025-12-12T12:28:05.221088Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7582947228327135319:2288], TxId: ptqudq7ueohsakh1jitp, task: 2. Ctx: {}. update task runner stats
2025-12-12T12:28:05.221093Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7582947228327135319:2288], TxId: ptqudq7ueohsakh1jitp, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-12T12:28:05.221094Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7582947228327135319:2288], TxId: ptqudq7ueohsakh1jitp, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:28:05.221096Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:534: SelfId: [1:7582947228327135319:2288], TxId: ptqudq7ueohsakh1jitp, task: 2. Ctx: {}. About to drain channelId: 2, hasPeer: 1, peerState:(freeSpace:1000000;inFlightBytes:96;inFlightCount:1;)
2025-12-12T12:28:05.221099Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7582947228327135319:2288], TxId: ptqudq7ueohsakh1jitp, task: 2. Ctx: {}. Poll inputs
2025-12-12T12:28:05.221100Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [1:7582947228327135319:2288], TxId: ptqudq7ueohsakh1jitp, task: 2. Ctx: {}. Poll sources
2025-12-12T12:28:05.221101Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [1:7582947228327135319:2288], TxId: ptqudq7ueohsakh1jitp, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-12-12T12:28:05.221113Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudq7ueohsakh1jitp, task: 2. no poll, channelId: 1, has inflight messages: [1], last with freeSpace: 1000000, current freeSpace: 1000000
2025-12-12T12:28:05.221115Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7582947228327135319:2288], TxId: ptqudq7ueohsakh1jitp, task: 2. Ctx: {}. update task runner stats
2025-12-12T12:28:05.221119Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7582947228327135319:2288], TxId: ptqudq7ueohsakh1jitp, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-12T12:28:05.221120Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7582947228327135319:2288], TxId: ptqudq7ueohsakh1jitp, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:28:05.221122Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:534: SelfId: [1:7582947228327135319:2288], TxId: ptqudq7ueohsakh1jitp, task: 2. Ctx: {}. About to drain channelId: 2, hasPeer: 1, peerState:(freeSpace:1000000;inFlightBytes:96;inFlightCount:1;)
2025-12-12T12:28:05.221126Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudq7ueohsakh1jitp, task: 2. no poll, channelId: 1, has inflight messages: [1], last with freeSpace: 1000000, current freeSpace: 1000000
2025-12-12T12:28:05.221132Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:129: TxId: ptqudq7ueohsakh1jitp, task: 3. Received input for channelId: 2, seqNo: 1, size: 0, chunks: 0, watermark: 0, checkpoint: 1, finished: 0, from: [1:7582947228327135324:2288], expected seqNo: 1
2025-12-12T12:28:05.221134Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:611: SelfId: [1:7582947228327135320:2289], TxId: ptqudq7ueohsakh1jitp, task: 3. Ctx: {}. took input
2025-12-12T12:28:05.221143Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:485: [ptqudq7ueohsakh1jitp-0] Task: 3. [Checkpoint 2.1] Got checkpoint barrier from channel 2
2025-12-12T12:28:05.221150Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:356: SelfId: [1:7582947228327135327:2289], TxId: ptqudq7ueohsakh1jitp, task: 3. No watermark 
2025-12-12T12:28:05.221152Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7582947228327135320:2289], TxId: ptqudq7ueohsakh1jitp, task: 3. Ctx: {}. Poll inputs
2025-12-12T12:28:05.221153Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1494: SelfId: [1:7582947228327135320:2289], TxId: ptqudq7ueohsakh1jitp, task: 3. Ctx: {}. Skip polling sources because of pending checkpoint
2025-12-12T12:28:05.221154Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [1:7582947228327135320:2289], TxId: ptqudq7ueohsakh1jitp, task: 3. Ctx: {}. DoExecuteImpl: 1
2025-12-12T12:28:05.221158Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:965: SelfId: [1:7582947228327135320:2289], TxId: ptqudq7ueohsakh1jitp, task: 3. Ctx: {}. Input data push finished. Cookie: 0 Watermark: (empty maybe) Ack: 1 TakeInputChannelDataRequests: 1
2025-12-12T12:28:05.221160Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:738: TxId: ptqudq7ueohsakh1jitp, task: 3. Sending channel data ack to channelId: 2, peer: [1:7582947228327135319:2288], from: [1:7582947228327135320:2289], freeSpace: 1000000, seqNo: 1, finished: 0
2025-12-12T12:28:05.221179Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:462: SelfId: [1:7582947228327135327:2289], TxId: ptqudq7ueohsakh1jitp, task: 3. Pending 1 checkpoints to be sent
2025-12-12T12:28:05.221182Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7582947228327135320:2289], TxId: ptqudq7ueohsakh1jitp, task: 3. Ctx: {}. Poll inputs
2025-12-12T12:28:05.221183Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1494: SelfId: [1:7582947228327135320:2289], TxId: ptqudq7ueohsakh1jitp, task: 3. Ctx: {}. Skip polling sources because of pending checkpoint
2025-12-12T12:28:05.221185Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [1:7582947228327135320:2289], TxId: ptqudq7ueohsakh1jitp, task: 3. Ctx: {}. DoExecuteImpl: 0
2025-12-12T12:28:05.221200Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7582947228327135320:2289], TxId: ptqudq7ueohsakh1jitp, task: 3. Ctx: {}. update task runner stats
2025-12-12T12:28:05.221212Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7582947228327135320:2289], TxId: ptqudq7ueohsakh1jitp, task: 3. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 1 watermark injected: (empty maybe)
2025-12-12T12:28:05.221214Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:447: [ptqudq7ueohsakh1jitp-0] Task: 3. [Checkpoint 2.1] Performing task checkpoint
2025-12-12T12:28:05.221215Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:816: SelfId: [1:7582947228327135320:2289], TxId: ptqudq7ueohsakh1jitp, task: 3. Ctx: {}. Save state
2025-12-12T12:28:05.221217Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:474: [ptqudq7ueohsakh1jitp-0] Task: 3. [Checkpoint 2.1] CA state saved
2025-12-12T12:28:05.221219Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:449: [ptqudq7ueohsakh1jitp-0] Task: 3. [Checkpoint 2.1] Injecting checkpoint barrier to outputs
2025-12-12T12:28:05.221225Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:536: [ptqudq7ueohsakh1jitp-0] Task: 3. [Checkpoint 2.1] Task checkpoint is done. Send to storage
2025-12-12T12:28:05.221227Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7582947228327135320:2289], TxId: ptqudq7ueohsakh1jitp, task: 3. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:28:05.221230Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:534: SelfId: [1:7582947228327135320:2289], TxId: ptqudq7ueohsakh1jitp, task: 3. Ctx: {}. About to drain channelId: 3, hasPeer: 1, peerState:(freeSpace:1000000;inFlightBytes:0;inFlightCount:0;)
2025-12-12T12:28:05.221242Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:566: TxId: ptqudq7ueohsakh1jitp, task: 3. SendChannelData, channelId: 3, peer: [1:7582947228327135315:2284], chunks: 0, bytes: 0, watermark: 0, checkpoint: 1, seqNo: 1, finished: 0
2025-12-12T12:28:05.221247Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudq7ueohsakh1jitp, task: 3. no poll, channelId: 2, has inflight messages: [1], last with freeSpace: 1000000, current freeSpace: 1000000
2025-12-12T12:28:05.221249Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7582947228327135320:2289], TxId: ptqudq7ueohsakh1jitp, task: 3. Ctx: {}. update task runner stats
2025-12-12T12:28:05.221253Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7582947228327135320:2289], TxId: ptqudq7ueohsakh1jitp, task: 3. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-12T12:28:05.221254Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7582947228327135320:2289], TxId: ptqudq7ueohsakh1jitp, task: 3. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:28:05.221257Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:534: SelfId: [1:7582947228327135320:2289], TxId: ptqudq7ueohsakh1jitp, task: 3. Ctx: {}. About to drain channelId: 3, hasPeer: 1, peerState:(freeSpace:1000000;inFlightBytes:96;inFlightCount:1;)
2025-12-12T12:28:05.221259Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7582947228327135320:2289], TxId: ptqudq7ueohsakh1jitp, task: 3. Ctx: {}. Poll inputs
2025-12-12T12:28:05.221260Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [1:7582947228327135320:2289], TxId: ptqudq7ueohsakh1jitp, task: 3. Ctx: {}. Poll sources
2025-12-12T12:28:05.221261Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [1:7582947228327135320:2289], TxId: ptqudq7ueohsakh1jitp, task: 3. Ctx: {}. DoExecuteImpl: 0
2025-12-12T12:28:05.221272Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudq7ueohsakh1jitp, task: 3. no poll, channelId: 2, has inflight messages: [1], last with freeSpace: 1000000, current freeSpace: 1000000
2025-12-12T12:28:05.221274Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7582947228327135320:2289], TxId: ptqudq7ueohsakh1jitp, task: 3. Ctx: {}. update task runner stats
2025-12-12T12:28:05.221278Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7582947228327135320:2289], TxId: ptqudq7ueohsakh1jitp, task: 3. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-12T12:28:05.221279Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7582947228327135320:2289], TxId: ptqudq7ueohsakh1jitp, task: 3. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:28:05.221281Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:534: SelfId: [1:7582947228327135320:2289], TxId: ptqudq7ueohsakh1jitp, task: 3. Ctx: {}. About to drain channelId: 3, hasPeer: 1, peerState:(freeSpace:1000000;inFlightBytes:96;inFlightCount:1;)
2025-12-12T12:28:05.221284Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudq7ueohsakh1jitp, task: 3. no poll, channelId: 2, has inflight messages: [1], last with freeSpace: 1000000, current freeSpace: 1000000
2025-12-12T12:28:05.221288Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:179: TxId: ptqudq7ueohsakh1jitp, task: 2. Received channel data ack for channelId: 2, seqNo: 1, lastSentSeqNo: 1, freeSpace: 1000000, early finish: 0
2025-12-12T12:28:05.221292Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:207: TxId: ptqudq7ueohsakh1jitp, task: 2. PeerState, peerState:(freeSpace:1000000;inFlightBytes:0;inFlightCount:0;), sentSeqNo: 1, ackSeqNo: 1
2025-12-12T12:28:05.221294Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:220: TxId: ptqudq7ueohsakh1jitp, task: 2. Resume compute actor
2025-12-12T12:28:05.221297Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7582947228327135319:2288], TxId: ptqudq7ueohsakh1jitp, task: 2. Ctx: {}. Poll inputs
2025-12-12T12:28:05.221299Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [1:7582947228327135319:2288], TxId: ptqudq7ueohsakh1jitp, task: 2. Ctx: {}. Poll sources
2025-12-12T12:28:05.221300Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [1:7582947228327135319:2288], TxId: ptqudq7ueohsakh1jitp, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-12-12T12:28:05.221310Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7582947228327135319:2288], TxId: ptqudq7ueohsakh1jitp, task: 2. Ctx: {}. update task runner stats
2025-12-12T12:28:05.221314Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7582947228327135319:2288], TxId: ptqudq7ueohsakh1jitp, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-12T12:28:05.221315Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7582947228327135319:2288], TxId: ptqudq7ueohsakh1jitp, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:28:05.221318Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:534: SelfId: [1:7582947228327135319:2288], TxId: ptqudq7ueohsakh1jitp, task: 2. Ctx: {}. About to drain channelId: 2, hasPeer: 1, peerState:(freeSpace:1000000;inFlightBytes:0;inFlightCount:0;)
2025-12-12T12:28:05.221322Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudq7ueohsakh1jitp, task: 2. no poll, channelId: 1, has inflight messages: [1], last with freeSpace: 1000000, current freeSpace: 1000000
2025-12-12T12:28:05.221333Z :FQ_RESULT_WRITER TRACE: result_writer.cpp:231: TraceId: ptqudq7ueohsakh1jitp#ptrudq7uendlvjl8uec8#yandexcloud://my_folder#33f11377-82a623ae-c7a05f13-2bb1c0ee4#mock_cloud ChannelData Shift, Records: 0 HasError: 0 Size: 0 Rows: 0 FreeSpace: 67108864 Duration: 1.272583s AvgSpeed: 0
2025-12-12T12:28:05.221339Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:179: TxId: ptqudq7ueohsakh1jitp, task: 3. Received channel data ack for channelId: 3, seqNo: 1, lastSentSeqNo: 1, freeSpace: 67108864, early finish: 0
2025-12-12T12:28:05.221341Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:207: TxId: ptqudq7ueohsakh1jitp, task: 3. PeerState, peerState:(freeSpace:67108864;inFlightBytes:0;inFlightCount:0;), sentSeqNo: 1, ackSeqNo: 1
2025-12-12T12:28:05.221342Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:220: TxId: ptqudq7ueohsakh1jitp, task: 3. Resume compute actor
2025-12-12T12:28:05.221344Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7582947228327135320:2289], TxId: ptqudq7ueohsakh1jitp, task: 3. Ctx: {}. Poll inputs
2025-12-12T12:28:05.221345Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [1:7582947228327135320:2289], TxId: ptqudq7ueohsakh1jitp, task: 3. Ctx: {}. Poll sources
2025-12-12T12:28:05.221346Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:698: SelfId: [1:7582947228327135320:2289], TxId: ptqudq7ueohsakh1jitp, task: 3. Ctx: {}. DoExecuteImpl: 0
2025-12-12T12:28:05.221355Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7582947228327135320:2289], TxId: ptqudq7ueohsakh1jitp, task: 3. Ctx: {}. update task runner stats
2025-12-12T12:28:05.221360Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7582947228327135320:2289], TxId: ptqudq7ueohsakh1jitp, task: 3. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-12T12:28:05.221361Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7582947228327135320:2289], TxId: ptqudq7ueohsakh1jitp, task: 3. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:28:05.221364Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:534: SelfId: [1:7582947228327135320:2289], TxId: ptqudq7ueohsakh1jitp, task: 3. Ctx: {}. About to drain channelId: 3, hasPeer: 1, peerState:(freeSpace:67108864;inFlightBytes:0;inFlightCount:0;)
2025-12-12T12:28:05.221368Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudq7ueohsakh1jitp, task: 3. no poll, channelId: 2, has inflight messages: [1], last with freeSpace: 1000000, current freeSpace: 1000000
2025-12-12T12:28:05.221372Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:179: TxId: ptqudq7ueohsakh1jitp, task: 1. Received channel data ack for channelId: 1, seqNo: 1, lastSentSeqNo: 1, freeSpace: 1000000, early finish: 0
2025-12-12T12:28:05.221374Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:207: TxId: ptqudq7ueohsakh1jitp, task: 1. PeerState, peerState:(freeSpace:1000000;inFlightBytes:0;inFlightCount:0;), sentSeqNo: 1, ackSeqNo: 1
2025-12-12T12:28:05.221375Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:220: TxId: ptqudq7ueohsakh1jitp, task: 1. Resume compute actor
2025-12-12T12:28:05.221377Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1483: SelfId: [1:7582947228327135321:2290], TxId: ptqudq7ueohsakh1jitp, task: 1. Ctx: {}. Poll inputs
2025-12-12T12:28:05.221379Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1498: SelfId: [1:7582947228327135321:2290], TxId: ptqudq7ueohsakh1jitp, task: 1. Ctx: {}. Poll sources
2025-12-12T12:28:05.221382Z :KQP_COMPUTE TRACE: dq_pq_read_actor.cpp:542: SelfId: [0:0:0], TxId: ptqudq7ueohsakh1jitp, task: 1. PQ source. SessionId: 20b35d4a-59a85a4d-2d260c31-4c4c7312 GetAsyncInputData freeSpace = 1000000
2025-12-12T12:28:05.221385Z :KQP_COMPUTE TRACE: dq_compute_actor_async_input_helper.h:81: SelfId: [1:7582947228327135321:2290], TxId: ptqudq7ueohsakh1jitp, task: 1. Ctx: {}. Poll async input 0. Buffer free space: 1000000, read from async input: 0 bytes, 0 rows, finished: 0
2025-12-12T12:28:05.221389Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:844: SelfId: [1:7582947228327135321:2290], TxId: ptqudq7ueohsakh1jitp, task: 1. Ctx: {}. Send TEvContinueRun on OnAsyncInputPushFinished
2025-12-12T12:28:05.221400Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:493: SelfId: [1:7582947228327135321:2290], TxId: ptqudq7ueohsakh1jitp, task: 1. Ctx: {}. update task runner stats
2025-12-12T12:28:05.221408Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:762: SelfId: [1:7582947228327135321:2290], TxId: ptqudq7ueohsakh1jitp, task: 1. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-12-12T12:28:05.221410Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:406: SelfId: [1:7582947228327135321:2290], TxId: ptqudq7ueohsakh1jitp, task: 1. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-12-12T12:28:05.221411Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:534: SelfId: [1:7582947228327135321:2290], TxId: ptqudq7ueohsakh1jitp, task: 1. Ctx: {}. About to drain channelId: 1, hasPeer: 1, peerState:(freeSpace:1000000;inFlightBytes:0;inFlightCount:0;)
2025-12-12T12:28:05.221420Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:460: [ptqudq7ueohsakh1jitp-0] [2:1] Got TEvSaveTaskState: task 2
2025-12-12T12:28:05.221454Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:460: [ptqudq7ueohsakh1jitp-0] [2:1] Got TEvSaveTaskState: task 3
2025-12-12T12:28:05.225065Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:484: [ptqudq7ueohsakh1jitp-0] [2:1] TEvSaveTaskState Apply: task: 1
2025-12-12T12:28:05.225079Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:499: [ptqudq7ueohsakh1jitp-0] [2:1] Send TEvSaveTaskStateResult: task: 1
2025-12-12T12:28:05.225125Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:484: [ptqudq7ueohsakh1jitp-0] [2:1] TEvSaveTaskState Apply: task: 2
2025-12-12T12:28:05.225126Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:499: [ptqudq7ueohsakh1jitp-0] [2:1] Send TEvSaveTaskStateResult: task: 2
2025-12-12T12:28:05.225164Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:484: [ptqudq7ueohsakh1jitp-0] [2:1] TEvSaveTaskState Apply: task: 3
2025-12-12T12:28:05.225165Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:499: [ptqudq7ueohsakh1jitp-0] [2:1] Send TEvSaveTaskStateResult: task: 3
2025-12-12T12:28:05.225224Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:466: [ptqudq7ueohsakh1jitp-0.2] [2:1] Got TEvSaveTaskStateResult; task 1, status: OK, size: 111
2025-12-12T12:28:05.225229Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:476: [ptqudq7ueohsakh1jitp-0.2] [2:1] Task state saved, need 2 more acks
2025-12-12T12:28:05.225232Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:466: [ptqudq7ueohsakh1jitp-0.2] [2:1] Got TEvSaveTaskStateResult; task 3, status: OK, size: 29
2025-12-12T12:28:05.225234Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:476: [ptqudq7ueohsakh1jitp-0.2] [2:1] Task state saved, need 1 more acks
2025-12-12T12:28:05.225236Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:466: [ptqudq7ueohsakh1jitp-0.2] [2:1] Got TEvSaveTaskStateResult; task 2, status: OK, size: 29
2025-12-12T12:28:05.225238Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:476: [ptqudq7ueohsakh1jitp-0.2] [2:1] Task state saved, need 0 more acks
2025-12-12T12:28:05.225240Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:489: [ptqudq7ueohsakh1jitp-0.2] [2:1] Got all acks, changing checkpoint status to 'PendingCommit'
2025-12-12T12:28:05.225256Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:343: [ptqudq7ueohsakh1jitp-0.2] [2:1] Got TEvSetCheckpointPendingCommitStatusRequest
2025-12-12T12:28:05.254028Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:362: [ptqudq7ueohsakh1jitp-0.2] [2:1] Status updated to 'PendingCommit'
2025-12-12T12:28:05.254042Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:364: [ptqudq7ueohsakh1jitp-0.2] [2:1] Send TEvSetCheckpointPendingCommitStatusResponse
2025-12-12T12:28:05.254088Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:501: [ptqudq7ueohsakh1jitp-0.2] [2:1] Got TEvSetCheckpointPendingCommitStatusResponse
2025-12-12T12:28:05.254095Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:516: [ptqudq7ueohsakh1jitp-0.2] [2:1] Checkpoint status changed to 'PendingCommit', committing states to 1 actor(s)
2025-12-12T12:28:05.254127Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:759: SelfId: [1:7582947228327135321:2290], TxId: ptqudq7ueohsakh1jitp, task: 1. Ctx: {}. Commit state
2025-12-12T12:28:05.254145Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:532: [ptqudq7ueohsakh1jitp-0.2] [2:1] Got TEvStateCommitted; task: 1
2025-12-12T12:28:05.254159Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:541: [ptqudq7ueohsakh1jitp-0.2] [2:1] State committed [1:7582947228327135321:2290], need 0 more acks
2025-12-12T12:28:05.254161Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:543: [ptqudq7ueohsakh1jitp-0.2] [2:1] Got all acks, changing checkpoint status to 'Completed'
2025-12-12T12:28:05.254174Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:371: [ptqudq7ueohsakh1jitp-0.2] [2:1] Got TEvCompleteCheckpointRequest
2025-12-12T12:28:05.284067Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:393: [ptqudq7ueohsakh1jitp-0.2] [2:1] Status updated to 'Completed'
2025-12-12T12:28:05.284081Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:400: [ptqudq7ueohsakh1jitp-0.2] [2:1] Send TEvCompleteCheckpointResponse
2025-12-12T12:28:05.284144Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:564: [ptqudq7ueohsakh1jitp-0.2] [2:1] Got TEvCompleteCheckpointResponse
2025-12-12T12:28:05.284155Z :STREAMS_CHECKPOINT_COORDINATOR INFO: checkpoint_coordinator.cpp:579: [ptqudq7ueohsakh1jitp-0.2] [2:1] Checkpoint completed
2025-12-12T12:28:05.533770Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudq7ueohsakh1jitp"
2025-12-12T12:28:05.533821Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:305: Resolve folder bootstrap. Folder id: my_folder Actor id: [1:7582947236917069938:2304]
2025-12-12T12:28:05.533858Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:367: Cloud id: mock_cloud Folder id: my_folder
2025-12-12T12:28:05.533892Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:91: Get quotas bootstrap. Cloud id: mock_cloud Actor id: [1:7582947236917069939:2305]
2025-12-12T12:28:05.533933Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.analyticsQuery.count IS STALE, Refreshing ...
2025-12-12T12:28:05.533955Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.cpuPercent.count IS STALE, Refreshing ...
2025-12-12T12:28:05.533973Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.streamingQuery.count IS STALE, Refreshing ...
2025-12-12T12:28:05.534009Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.cpuPercent.count=0/10000 REFRESHED
2025-12-12T12:28:05.538936Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.analyticsQuery.count=0/100 REFRESHED
2025-12-12T12:28:05.538970Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.streamingQuery.count=1/100 REFRESHED
2025-12-12T12:28:05.539042Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:493: cloud.mock_cloud{yq.streamingQueryDurationMinutes.count=*/0, yq.queryResult.size=*/20971520, yq.analyticsQuery.count=0/100, yq.analyticsQueryDurationMinutes.count=*/1440, yq.memory.size=*/0, yq.result.size=*/0, yq.cpuPercent.count=0/10000, yq.streamingQuery.count=1/100} SEND QUOTAS
2025-12-12T12:28:05.539064Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:103: Cloud id: mock_cloud Quota count: 8
2025-12-12T12:28:05.539102Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudq7ueohsakh1jitp"
2025-12-12T12:28:05.539157Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:169: Resolve subject type bootstrap. Token: **** (B6C6F477) Actor id: [1:7582947236917069944:2310]
2025-12-12T12:28:05.539196Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:230: Subject Type: federated_account Token: **** (B6C6F477)
2025-12-12T12:28:05.539240Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudq7ueohsakh1jitp"
2025-12-12T12:28:05.539282Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:63: Request actor. Actor id: [1:7582947236917069945:2311]
2025-12-12T12:28:05.539350Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_queries.cpp:641: DescribeQueryRequest: {query_id: "ptqudq7ueohsakh1jitp"
} [root@builtin, **** (B6C6F477)] 
2025-12-12T12:28:05.540345Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.cpuPercent.count=0/10000 NOTIFY CHANGE
2025-12-12T12:28:05.541532Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: DescribeQueryRequest - DescribeQueryResult: {query { meta { common { id: "ptqudq7ueohsakh1jitp" created_by: "root@builtin" modified_by: "root@builtin" created_at { seconds: 1765542448 nanos: 270904000 } modified_at { seconds: 1765542448 nanos: 270904000 } revision: 1 } started_at { seconds: 1765542449 nanos: 457000000 } execute_mode: RUN status: RUNNING last_job_query_revision: 1 last_job_id: "ptjudq7ueohs9so9lloj-ptqudq7ueohsakh1jitp" started_by: "root@builtin" has_saved_checkpoints: true submitted_at { seconds: 1765542448 nanos: 270904000 } } 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:17898\") $6 \'(\'\"ReconnectPeriod\" \'\"\") \'(\'\"Format\" \'\"raw\") \'(\'\"ReadGroup\" \'\"ptcudq7ueos1oh23eroc\") \'(\'\"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-12T12:28:05.544048Z :TICKET_PARSER DEBUG: ticket_parser_impl.h:1875: Ticket **** (B6C6F477) (ipv6:[::1]:52076) has now valid token of root@builtin
2025-12-12T12:28:05.544125Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:1061: ControlQueryRequest: query_id: "ptqudq7ueohsakh1jitp"
action: ABORT
2025-12-12T12:28:05.544159Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:305: Resolve folder bootstrap. Folder id: my_folder Actor id: [1:7582947236917069949:2314]
2025-12-12T12:28:05.544171Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:367: Cloud id: mock_cloud Folder id: my_folder
2025-12-12T12:28:05.544183Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:91: Get quotas bootstrap. Cloud id: mock_cloud Actor id: [1:7582947236917069950:2315]
2025-12-12T12:28:05.544196Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.analyticsQuery.count IS STALE, Refreshing ...
2025-12-12T12:28:05.544203Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.cpuPercent.count IS STALE, Refreshing ...
2025-12-12T12:28:05.544208Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.streamingQuery.count IS STALE, Refreshing ...
2025-12-12T12:28:05.544268Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.cpuPercent.count=0/10000 REFRESHED
2025-12-12T12:28:05.545697Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.analyticsQuery.count=0/100 NOTIFY CHANGE
2025-12-12T12:28:05.545745Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.streamingQuery.count=1/100 NOTIFY CHANGE
2025-12-12T12:28:05.549302Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.analyticsQuery.count=0/100 REFRESHED
2025-12-12T12:28:05.549347Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.streamingQuery.count=1/100 REFRESHED
2025-12-12T12:28:05.549376Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:493: cloud.mock_cloud{yq.streamingQueryDurationMinutes.count=*/0, yq.queryResult.size=*/20971520, yq.analyticsQuery.count=0/100, yq.analyticsQueryDurationMinutes.count=*/1440, yq.memory.size=*/0, yq.result.size=*/0, yq.cpuPercent.count=0/10000, yq.streamingQuery.count=1/100} SEND QUOTAS
2025-12-12T12:28:05.549392Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:103: Cloud id: mock_cloud Quota count: 8
2025-12-12T12:28:05.549421Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:1061: ControlQueryRequest: query_id: "ptqudq7ueohsakh1jitp"
action: ABORT
2025-12-12T12:28:05.549498Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:169: Resolve subject type bootstrap. Token: **** (B6C6F477) Actor id: [1:7582947236917069955:2320]
2025-12-12T12:28:05.549538Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:230: Subject Type: federated_account Token: **** (B6C6F477)
2025-12-12T12:28:05.549579Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:1061: ControlQueryRequest: query_id: "ptqudq7ueohsakh1jitp"
action: ABORT
2025-12-12T12:28:05.549633Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:63: Request actor. Actor id: [1:7582947236917069956:2321]
2025-12-12T12:28:05.549710Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_queries.cpp:1342: ControlQueryRequest: {query_id: "ptqudq7ueohsakh1jitp"
action: ABORT
} [root@builtin, **** (B6C6F477)] 
2025-12-12T12:28:05.551800Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.cpuPercent.count=0/10000 NOTIFY CHANGE
2025-12-12T12:28:05.557332Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.streamingQuery.count=1/100 NOTIFY CHANGE
2025-12-12T12:28:05.557592Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.analyticsQuery.count=0/100 NOTIFY CHANGE
2025-12-12T12:28:05.782678Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: ControlQueryRequest - ControlQueryRequest: {} SUCCESS
2025-12-12T12:28:05.784783Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudq7ueohsakh1jitp"
2025-12-12T12:28:05.784829Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:305: Resolve folder bootstrap. Folder id: my_folder Actor id: [1:7582947236917069960:2324]
2025-12-12T12:28:05.784866Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:367: Cloud id: mock_cloud Folder id: my_folder
2025-12-12T12:28:05.784921Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:91: Get quotas bootstrap. Cloud id: mock_cloud Actor id: [1:7582947236917069961:2325]
2025-12-12T12:28:05.784969Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.analyticsQuery.count IS STALE, Refreshing ...
2025-12-12T12:28:05.784987Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.cpuPercent.count IS STALE, Refreshing ...
2025-12-12T12:28:05.784993Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.streamingQuery.count IS STALE, Refreshing ...
2025-12-12T12:28:05.785007Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.cpuPercent.count=0/10000 REFRESHED
2025-12-12T12:28:05.789512Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.analyticsQuery.count=0/100 REFRESHED
2025-12-12T12:28:05.789556Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.streamingQuery.count=1/100 REFRESHED
2025-12-12T12:28:05.789583Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:493: cloud.mock_cloud{yq.streamingQueryDurationMinutes.count=*/0, yq.queryResult.size=*/20971520, yq.analyticsQuery.count=0/100, yq.analyticsQueryDurationMinutes.count=*/1440, yq.memory.size=*/0, yq.result.size=*/0, yq.cpuPercent.count=0/10000, yq.streamingQuery.count=1/100} SEND QUOTAS
2025-12-12T12:28:05.789609Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:103: Cloud id: mock_cloud Quota count: 8
2025-12-12T12:28:05.789651Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudq7ueohsakh1jitp"
2025-12-12T12:28:05.789725Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:169: Resolve subject type bootstrap. Token: **** (B6C6F477) Actor id: [1:7582947236917069966:2330]
2025-12-12T12:28:05.789785Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:230: Subject Type: federated_account Token: **** (B6C6F477)
2025-12-12T12:28:05.789836Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudq7ueohsakh1jitp"
2025-12-12T12:28:05.789879Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:63: Request actor. Actor id: [1:7582947236917069967:2331]
2025-12-12T12:28:05.789933Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_queries.cpp:641: DescribeQueryRequest: {query_id: "ptqudq7ueohsakh1jitp"
} [root@builtin, **** (B6C6F477)] 
2025-12-12T12:28:05.791182Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.cpuPercent.count=0/10000 NOTIFY CHANGE
2025-12-12T12:28:05.792161Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: DescribeQueryRequest - DescribeQueryResult: {query { meta { common { id: "ptqudq7ueohsakh1jitp" created_by: "root@builtin" modified_by: "root@builtin" created_at { seconds: 1765542448 nanos: 270904000 } modified_at { seconds: 1765542485 nanos: 695112000 } revision: 2 } started_at { seconds: 1765542449 nanos: 457000000 } execute_mode: RUN status: ABORTING_BY_USER last_job_query_revision: 1 last_job_id: "ptjudq7ueohs9so9lloj-ptqudq7ueohsakh1jitp" started_by: "root@builtin" aborted_by: "root@builtin" has_saved_checkpoints: true submitted_at { seconds: 1765542448 nanos: 270904000 } } 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:17898\") $6 \'(\'\"ReconnectPeriod\" \'\"\") \'(\'\"Format\" \'\"raw\") \'(\'\"ReadGroup\" \'\"ptcudq7ueos1oh23eroc\") \'(\'\"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-12T12:28:05.795474Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.analyticsQuery.count=0/100 NOTIFY CHANGE
2025-12-12T12:28:05.795570Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.streamingQuery.count=1/100 NOTIFY CHANGE
2025-12-12T12:28:05.888276Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: a3e078ee-1e6d1476-94764c3c-6e3032835, Host: ghrun-fhkyrtz6p4, Tenant: /default
2025-12-12T12:28:05.888925Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:86: PrivateGetTask - Owner: a3e078ee-1e6d1476-94764c3c-6e3032835, Host: ghrun-fhkyrtz6p4, Tenant: /default, Request CP::GetTask with size: 68 bytes
2025-12-12T12:28:05.889019Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_get.cpp:388: GetTaskRequest: {tenant: "/default"
owner_id: "a3e078ee-1e6d1476-94764c3c-6e3032835"
host: "ghrun-fhkyrtz6p4"
node_id: 1
}
2025-12-12T12:28:05.892253Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: GetTaskRequest - GetTaskResult: {} SUCCESS
2025-12-12T12:28:05.892314Z :YQL_PRIVATE_PROXY DEBUG: task_get.cpp:93: PrivateGetTask - Owner: a3e078ee-1e6d1476-94764c3c-6e3032835, Host: ghrun-fhkyrtz6p4, Tenant: /default, Got CP::GetTask Response
2025-12-12T12:28:05.892603Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-12-12T12:28:05.892613Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-12-12T12:28:05.897280Z :FQ_CONTROL_PLANE_CONFIG TRACE: control_plane_config.cpp:192: LOADED TenantInfo: State NOT changed
2025-12-12T12:28:05.957995Z :YQL_PROXY TRACE: log.cpp:64: SessionId:  2025-12-12 12:28:05.957 TRACE ydbd(pid=1226733, tid=0x00007F147B305640) [DQ] task_controller_impl.h:271:  [1:7582947228327135317:2286] ExportStats Summary
2025-12-12T12:28:05.958224Z :FQ_PINGER TRACE: pinger.cpp:250: QueryId: ptqudq7ueohsakh1jitp, Owner: a3e078ee-1e6d1476-94764c3c-6e3032832 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-12T12:28:05.958231Z :FQ_PINGER TRACE: pinger.cpp:393: QueryId: ptqudq7ueohsakh1jitp, Owner: a3e078ee-1e6d1476-94764c3c-6e3032832 Forward request Private::PingTask
2025-12-12T12:28:05.958992Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudq7ueohsakh1jitp, Owner: a3e078ee-1e6d1476-94764c3c-6e3032832, Request CP::PingTask with size: 740 bytes
2025-12-12T12:28:05.959086Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "a3e078ee-1e6d1476-94764c3c-6e3032832"
query_id {
  value: "ptqudq7ueohsakh1jitp"
}
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: 1765628883
  nanos: 907314000
}
tenant: "/default"
}
2025-12-12T12:28:05.972848Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {action: ABORT expired_at { seconds: 1765542505 nanos: 966000000 } } SUCCESS
2025-12-12T12:28:05.972897Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudq7ueohsakh1jitp, Owner: a3e078ee-1e6d1476-94764c3c-6e3032832, Got CP::PingTaskResponse
2025-12-12T12:28:05.973294Z :FQ_PINGER TRACE: pinger.cpp:338: QueryId: ptqudq7ueohsakh1jitp, Owner: a3e078ee-1e6d1476-94764c3c-6e3032832 Ping response success: { action: ABORT expired_at { seconds: 1765542505 nanos: 966000000 } }
2025-12-12T12:28:05.973302Z :FQ_PINGER DEBUG: pinger.cpp:342: QueryId: ptqudq7ueohsakh1jitp, Owner: a3e078ee-1e6d1476-94764c3c-6e3032832 Query action: ABORT
2025-12-12T12:28:05.973332Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:690: QueryId: ptqudq7ueohsakh1jitp New query action received: ABORT
2025-12-12T12:28:05.973338Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:1827: QueryId: ptqudq7ueohsakh1jitp Is about to finish query with status ABORTED_BY_USER
2025-12-12T12:28:05.973342Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:1820: QueryId: ptqudq7ueohsakh1jitp Write finalizing status: ABORTING_BY_USER
2025-12-12T12:28:05.973355Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:528: QueryId: ptqudq7ueohsakh1jitp Cancel running query
2025-12-12T12:28:05.973379Z :FQ_RUN_ACTOR TRACE: run_actor.cpp:880: QueryId: ptqudq7ueohsakh1jitp Forward ping response. Success: 1. Cookie: 6
2025-12-12T12:28:05.973386Z :FQ_PINGER TRACE: pinger.cpp:250: QueryId: ptqudq7ueohsakh1jitp, Owner: a3e078ee-1e6d1476-94764c3c-6e3032832 Forward ping request: { status: ABORTING_BY_USER }
2025-12-12T12:28:05.973390Z :FQ_PINGER TRACE: pinger.cpp:393: QueryId: ptqudq7ueohsakh1jitp, Owner: a3e078ee-1e6d1476-94764c3c-6e3032832 Forward request Private::PingTask
2025-12-12T12:28:05.973540Z :YQL_PROXY DEBUG: log.cpp:64: SessionId:  2025-12-12 12:28:05.973 DEBUG ydbd(pid=1226733, tid=0x00007F1478B00640) [DQ] task_controller_impl.h:130: AbortExecution from [1:7582947228327135292:2262]:ABORTED { <main>: Error: ABORTED_BY_USER }
2025-12-12T12:28:05.973561Z :YQL_PROXY DEBUG: log.cpp:64: SessionId:  2025-12-12 12:28:05.973 DEBUG ydbd(pid=1226733, tid=0x00007F1478B00640) [DQ] task_controller_impl.h:598: OnError { <main>: Error: ABORTED_BY_USER } ABORTED
2025-12-12T12:28:05.973644Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudq7ueohsakh1jitp 2025-12-12 12:28:05.973 DEBUG ydbd(pid=1226733, tid=0x00007F1478B00640) [DQ] executer_actor.cpp:304: {ptqudq7ueohsakh1jitp} OnFailure, status=4, issues size=1, sender=[1:7582947228327135317:2286]
2025-12-12T12:28:05.973662Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudq7ueohsakh1jitp 2025-12-12 12:28:05.973 DEBUG ydbd(pid=1226733, tid=0x00007F1478B00640) [DQ] executer_actor.cpp:315: {ptqudq7ueohsakh1jitp} Issues: <main>: Error: ABORTED_BY_USER

2025-12-12T12:28:05.973672Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudq7ueohsakh1jitp 2025-12-12 12:28:05.973 DEBUG ydbd(pid=1226733, tid=0x00007F1478B00640) [DQ] executer_actor.cpp:284: {ptqudq7ueohsakh1jitp} Finish with status=4 issues=<main>: Error: ABORTED_BY_USER

2025-12-12T12:28:05.973740Z :FQ_RESULT_WRITER DEBUG: result_writer.cpp:126: TraceId: ptqudq7ueohsakh1jitp#ptrudq7uendlvjl8uec8#yandexcloud://my_folder#33f11377-82a623ae-c7a05f13-2bb1c0ee4#mock_cloud Send response to executer
2025-12-12T12:28:05.973763Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: ptqudq7ueohsakh1jitp 2025-12-12 12:28:05.973 DEBUG ydbd(pid=1226733, tid=0x00007F1478B00640) [DQ] executer_actor.cpp:341: {ptqudq7ueohsakh1jitp} OnQueryResponse status=4 issuses_size=1
2025-12-12T12:28:05.973784Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:1396: QueryId: ptqudq7ueohsakh1jitp TEvQueryResponse received on finish
2025-12-12T12:28:05.973795Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:1233: QueryId: ptqudq7ueohsakh1jitp Query response CANCELLED. Result set index: 0. Issues count: 1. Rows count: 0
2025-12-12T12:28:05.973809Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: a3e078ee-1e6d1476-94764c3c-6e303283 2025-12-12 12:28:05.973 DEBUG ydbd(pid=1226733, tid=0x00007F147A303640) [DQ] resource_allocator.cpp:228: {ptqudq7ueohsakh1jitp/[1:7582947228327135318:2287]} TEvFreeWorkersNotify 281479271677953
2025-12-12T12:28:05.973828Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: a3e078ee-1e6d1476-94764c3c-6e303283 2025-12-12 12:28:05.973 DEBUG ydbd(pid=1226733, tid=0x00007F147A303640) [DQ] resource_allocator.cpp:228: {ptqudq7ueohsakh1jitp/[1:7582947228327135318:2287]} TEvFreeWorkersNotify 562954248388609
2025-12-12T12:28:05.973838Z :FQ_RESULT_WRITER INFO: result_writer.cpp:87: TraceId: ptqudq7ueohsakh1jitp#ptrudq7uendlvjl8uec8#yandexcloud://my_folder#33f11377-82a623ae-c7a05f13-2bb1c0ee4#mock_cloud FinishWrite, Records: 0 HasError: 0 Size: 0 Rows: 0 FreeSpace: 67108864 Duration: 2.025081s AvgSpeed: 0 ResultChunks.size(): 0
2025-12-12T12:28:05.973840Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: a3e078ee-1e6d1476-94764c3c-6e303283 2025-12-12 12:28:05.973 DEBUG ydbd(pid=1226733, tid=0x00007F147A303640) [DQ] resource_allocator.cpp:228: {ptqudq7ueohsakh1jitp/[1:7582947228327135318:2287]} TEvFreeWorkersNotify 844429225099265
2025-12-12T12:28:05.973848Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: a3e078ee-1e6d1476-94764c3c-6e303283 2025-12-12 12:28:05.973 DEBUG ydbd(pid=1226733, tid=0x00007F147A303640) [DQ] resource_allocator.cpp:235: {ptqudq7ueohsakh1jitp/[1:7582947228327135318:2287]} TEvFreeWorkersNotify 4294967297 (failed)
2025-12-12T12:28:05.973906Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: a3e078ee-1e6d1476-94764c3c-6e303283 2025-12-12 12:28:05.973 DEBUG ydbd(pid=1226733, tid=0x00007F147A303640) [DQ] local_worker_manager.cpp:416: TEvFreeWorkersNotify 281479271677953
2025-12-12T12:28:05.973918Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: a3e078ee-1e6d1476-94764c3c-6e303283 2025-12-12 12:28:05.973 DEBUG ydbd(pid=1226733, tid=0x00007F147A303640) [DQ] local_worker_manager.cpp:440: Free Group 281479271677953
2025-12-12T12:28:05.973930Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: a3e078ee-1e6d1476-94764c3c-6e303283 2025-12-12 12:28:05.973 DEBUG ydbd(pid=1226733, tid=0x00007F147A303640) [DQ] local_worker_manager.cpp:416: TEvFreeWorkersNotify 562954248388609
2025-12-12T12:28:05.973936Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: a3e078ee-1e6d1476-94764c3c-6e303283 2025-12-12 12:28:05.973 DEBUG ydbd(pid=1226733, tid=0x00007F147A303640) [DQ] local_worker_manager.cpp:440: Free Group 562954248388609
2025-12-12T12:28:05.973944Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: a3e078ee-1e6d1476-94764c3c-6e303283 2025-12-12 12:28:05.973 DEBUG ydbd(pid=1226733, tid=0x00007F147A303640) [DQ] local_worker_manager.cpp:416: TEvFreeWorkersNotify 844429225099265
2025-12-12T12:28:05.973950Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: a3e078ee-1e6d1476-94764c3c-6e303283 2025-12-12 12:28:05.973 DEBUG ydbd(pid=1226733, tid=0x00007F147A303640) [DQ] local_worker_manager.cpp:440: Free Group 844429225099265
2025-12-12T12:28:05.973965Z :STREAMS_CHECKPOINT_COORDINATOR DEBUG: checkpoint_coordinator.cpp:657: [ptqudq7ueohsakh1jitp-0.2] PassAway
2025-12-12T12:28:05.974007Z :KQP_COMPUTE ERROR: dq_compute_actor_impl.h:1205: SelfId: [1:7582947228327135321:2290], TxId: ptqudq7ueohsakh1jitp, task: 1. Ctx: {}. Handle abort execution event from: [1:7582947224032167781:2070], status: UNAVAILABLE, reason: { <main>: Error: Aborted by LWM }
2025-12-12T12:28:05.974032Z :KQP_COMPUTE ERROR: dq_compute_actor_impl.h:1205: SelfId: [1:7582947228327135320:2289], TxId: ptqudq7ueohsakh1jitp, task: 3. Ctx: {}. Handle abort execution event from: [1:7582947224032167781:2070], status: UNAVAILABLE, reason: { <main>: Error: Aborted by LWM }
2025-12-12T12:28:05.974049Z :KQP_COMPUTE ERROR: dq_compute_actor_impl.h:1205: SelfId: [1:7582947228327135319:2288], TxId: ptqudq7ueohsakh1jitp, task: 2. Ctx: {}. Handle abort execution event from: [1:7582947224032167781:2070], status: UNAVAILABLE, reason: { <main>: Error: Aborted by LWM }
2025-12-12T12:28:05.974054Z :KQP_COMPUTE DEBUG: dq_compute_actor_channels.cpp:494: TxId: ptqudq7ueohsakh1jitp, task: 1. pass away
2025-12-12T12:28:05.974079Z :KQP_COMPUTE DEBUG: dq_compute_actor_channels.cpp:494: TxId: ptqudq7ueohsakh1jitp, task: 3. pass away
2025-12-12T12:28:05.974079Z :KQP_COMPUTE DEBUG: dq_compute_actor_channels.cpp:494: TxId: ptqudq7ueohsakh1jitp, task: 2. pass away
2025-12-12T12:28:05.974085Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:28:05.974081Z :INFO: [local] [local] [20b35d4a-59a85a4d-2d260c31-4c4c7312] Closing read session. Close timeout: 0.000000s
2025-12-12T12:28:05.974095Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:28:05.974094Z :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-12T12:28:05.974103Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:28:05.974101Z :INFO: [local] [local] [20b35d4a-59a85a4d-2d260c31-4c4c7312] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1789 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:28:05.974119Z :YDB_SDK NOTICE: actor.cpp:37: 2025-12-12T12:28:05.974117Z :NOTICE: [local] [local] [20b35d4a-59a85a4d-2d260c31-4c4c7312] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Close with zero timeout " }
2025-12-12T12:28:05.974132Z :YDB_SDK DEBUG: actor.cpp:37: 2025-12-12T12:28:05.974129Z :DEBUG: [local] [local] [20b35d4a-59a85a4d-2d260c31-4c4c7312] [] Abort session to cluster
2025-12-12T12:28:05.974371Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:28:05.974367Z :INFO: [local] [local] [20b35d4a-59a85a4d-2d260c31-4c4c7312] Closing read session. Close timeout: 0.000000s
2025-12-12T12:28:05.974384Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:28:05.974382Z :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-12T12:28:05.974390Z :YDB_SDK INFO: actor.cpp:37: 2025-12-12T12:28:05.974388Z :INFO: [local] [local] [20b35d4a-59a85a4d-2d260c31-4c4c7312] Counters: { Errors: 0 CurrentSessionLifetimeMs: 1789 BytesRead: 0 MessagesRead: 0 BytesReadCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T12:28:05.974398Z :YDB_SDK NOTICE: actor.cpp:37: 2025-12-12T12:28:05.974396Z :NOTICE: [local] [local] [20b35d4a-59a85a4d-2d260c31-4c4c7312] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
2025-12-12T12:28:05.974681Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudq7ueohsakh1jitp, Owner: a3e078ee-1e6d1476-94764c3c-6e3032832, Request CP::PingTask with size: 116 bytes
2025-12-12T12:28:05.974754Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "a3e078ee-1e6d1476-94764c3c-6e3032832"
query_id {
  value: "ptqudq7ueohsakh1jitp"
}
status: ABORTING_BY_USER
scope: "yandexcloud://my_folder"
deadline {
  seconds: 1765628883
  nanos: 907314000
}
tenant: "/default"
}
2025-12-12T12:28:05.986528Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {action: ABORT expired_at { seconds: 1765542505 nanos: 980000000 } } SUCCESS
2025-12-12T12:28:05.986567Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudq7ueohsakh1jitp, Owner: a3e078ee-1e6d1476-94764c3c-6e3032832, Got CP::PingTaskResponse
2025-12-12T12:28:05.987062Z :FQ_PINGER TRACE: pinger.cpp:338: QueryId: ptqudq7ueohsakh1jitp, Owner: a3e078ee-1e6d1476-94764c3c-6e3032832 Ping response success: { action: ABORT expired_at { seconds: 1765542505 nanos: 980000000 } }
2025-12-12T12:28:05.987075Z :FQ_PINGER DEBUG: pinger.cpp:342: QueryId: ptqudq7ueohsakh1jitp, Owner: a3e078ee-1e6d1476-94764c3c-6e3032832 Query action: ABORT
2025-12-12T12:28:05.987101Z :FQ_RUN_ACTOR TRACE: run_actor.cpp:880: QueryId: ptqudq7ueohsakh1jitp Forward ping response. Success: 1. Cookie: 3
2025-12-12T12:28:05.987103Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:887: QueryId: ptqudq7ueohsakh1jitp Finalizing status is saved
2025-12-12T12:28:05.987160Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:1507: QueryId: ptqudq7ueohsakh1jitp Start rate limiter resource deleter
2025-12-12T12:28:05.987178Z :STREAMS DEBUG: read_rule_deleter.cpp:214: ptqudq7ueohsakh1jitp: Create read rule deleter actor for `select_timings_2f_input` [0]
2025-12-12T12:28:05.987220Z :STREAMS DEBUG: read_rule_deleter.cpp:106: ptqudq7ueohsakh1jitp: Make request for read rule deletion for topic `select_timings_2f_input` [0]
2025-12-12T12:28:05.987729Z :YQL_PRIVATE_PROXY DEBUG: rate_limiter_resources.cpp:175: PrivateDeleteRateLimiterResource - QueryId: ptqudq7ueohsakh1jitp, Owner: a3e078ee-1e6d1476-94764c3c-6e3032832, Request CP::DeleteRateLimiterResource with size: 97 bytes
2025-12-12T12:28:05.987775Z :YQ_CONTROL_PLANE_STORAGE TRACE: request_actor.h:57: DeleteRateLimiterResourceRequest: {owner_id: "a3e078ee-1e6d1476-94764c3c-6e3032832"
query_id {
  value: "ptqudq7ueohsakh1jitp"
}
scope: "yandexcloud://my_folder"
tenant: "/default"
} 
2025-12-12T12:28:06.030397Z :YQ_CONTROL_PLANE_STORAGE DEBUG: rate_limiter_resources.cpp:74: DeleteRateLimiterResourceRequest. Got response from database: SUCCESS
2025-12-12T12:28:06.030584Z :YQ_RATE_LIMITER DEBUG: schema.cpp:71: Run delete rate limiter resource "mock_cloud/my_folder/ptqudq7ueohsakh1jitp" actor
2025-12-12T12:28:06.030590Z :YQ_RATE_LIMITER DEBUG: schema.cpp:113: Call delete rate limiter resource "mock_cloud/my_folder/ptqudq7ueohsakh1jitp"
2025-12-12T12:28:06.040001Z :YQ_RATE_LIMITER DEBUG: schema.cpp:179: Successfully deleted rate limiter resource "mock_cloud/my_folder/ptqudq7ueohsakh1jitp"
2025-12-12T12:28:06.040019Z :YQ_RATE_LIMITER DEBUG: schema.cpp:122: Reply for delete rate limiter resource "mock_cloud/my_folder/ptqudq7ueohsakh1jitp": 
2025-12-12T12:28:06.040058Z :YQ_CONTROL_PLANE_STORAGE DEBUG: rate_limiter_resources.cpp:219: Got delete response from rate limiter service
2025-12-12T12:28:06.040088Z :YQL_PRIVATE_PROXY DEBUG: rate_limiter_resources.cpp:199: PrivateDeleteRateLimiterResource - QueryId: ptqudq7ueohsakh1jitp, Owner: a3e078ee-1e6d1476-94764c3c-6e3032832, Got CP::DeleteRateLimiterResourceResponse
2025-12-12T12:28:06.040441Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:1498: QueryId: ptqudq7ueohsakh1jitp Rate limiter resource deletion finished. Success: 1. Issues: 
2025-12-12T12:28:06.040462Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:1919: QueryId: ptqudq7ueohsakh1jitp SendPingAndPassAway, FinalQueryStatus ABORTED_BY_USER
2025-12-12T12:28:06.040498Z :FQ_RUN_ACTOR DEBUG: run_actor.cpp:536: QueryId: ptqudq7ueohsakh1jitp PassAway
2025-12-12T12:28:06.040636Z :FQ_PINGER TRACE: pinger.cpp:250: QueryId: ptqudq7ueohsakh1jitp, Owner: a3e078ee-1e6d1476-94764c3c-6e3032832 Forward ping request: { result_id { value: "ptrudq7udmi32nubqa05" } status: ABORTED_BY_USER issues { message: "ABORTED_BY_USER" severity: 1 } statistics: "{\"Graph=0\":{\"Actor\":{\"ActorCreateTimeUs\":{\"sum\":\"1ms\",\"count\":3,\"avg\":\"475us\",\"max\":\"482us\",\"min\":\"467us\"}},\"AllocateWorkersUs\":{\"sum\":\"6ms\",\"count\":1,\"avg\":\"6ms\",\"max\":\"6ms\",\"min\":\"6ms\"},\"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_bd2c75ef-0dc5-438a-9afc-97add3f721ac/rate_limiter" topic_consumers { database: "local" topic_path: "select_timings_2f_input" consumer_name: "ptqudq7ueohsakh1jitp" cluster_endpoint: "localhost:17898" token_name: "cluster:default_myyds_2f" add_bearer_to_token: true } } finished_at { seconds: 1765542485 nanos: 973000000 } }
2025-12-12T12:28:06.040643Z :FQ_PINGER TRACE: pinger.cpp:393: QueryId: ptqudq7ueohsakh1jitp, Owner: a3e078ee-1e6d1476-94764c3c-6e3032832 Forward request Private::PingTask
2025-12-12T12:28:06.041202Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:85: PrivatePingTask - QueryId: ptqudq7ueohsakh1jitp, Owner: a3e078ee-1e6d1476-94764c3c-6e3032832, Request CP::PingTask with size: 1319 bytes
2025-12-12T12:28:06.041353Z :YQ_CONTROL_PLANE_STORAGE TRACE: task_ping.cpp:651: PingTaskRequest: {owner_id: "a3e078ee-1e6d1476-94764c3c-6e3032832"
query_id {
  value: "ptqudq7ueohsakh1jitp"
}
result_id {
  value: "ptrudq7udmi32nubqa05"
}
status: ABORTED_BY_USER
issues {
  message: "ABORTED_BY_USER"
  severity: 1
}
statistics: "{\"Graph=0\":{\"Actor\":{\"ActorCreateTimeUs\":{\"sum\":\"1ms\",\"count\":3,\"avg\":\"475us\",\"max\":\"482us\",\"min\":\"467us\"}},\"AllocateWorkersUs\":{\"sum\":\"6ms\",\"count\":1,\"avg\":\"6ms\",\"max\":\"6ms\",\"min\":\"6ms\"},\"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_bd2c75ef-0dc5-438a-9afc-97add3f721ac/rate_limiter"
  topic_consumers {
    database: "local"
    topic_path: "select_timings_2f_input"
    consumer_name: "ptqudq7ueohsakh1jitp"
    cluster_endpoint: "localhost:17898"
    token_name: "cluster:default_myyds_2f"
    add_bearer_to_token: true
  }
}
scope: "yandexcloud://my_folder"
finished_at {
  seconds: 1765542485
  nanos: 973000000
}
deadline {
  seconds: 1765628883
  nanos: 907314000
}
tenant: "/default"
}
2025-12-12T12:28:06.132769Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: PingTaskRequest - PingTaskResult: {action: ABORT } SUCCESS
2025-12-12T12:28:06.132836Z :YQL_PRIVATE_PROXY DEBUG: task_ping.cpp:105: PrivatePingTask - QueryId: ptqudq7ueohsakh1jitp, Owner: a3e078ee-1e6d1476-94764c3c-6e3032832, Got CP::PingTaskResponse
2025-12-12T12:28:06.133236Z :FQ_PINGER TRACE: pinger.cpp:338: QueryId: ptqudq7ueohsakh1jitp, Owner: a3e078ee-1e6d1476-94764c3c-6e3032832 Ping response success: { action: ABORT }
2025-12-12T12:28:06.133259Z :FQ_PINGER DEBUG: pinger.cpp:379: QueryId: ptqudq7ueohsakh1jitp, Owner: a3e078ee-1e6d1476-94764c3c-6e3032832 Query finished
2025-12-12T12:28:06.133262Z :FQ_PINGER TRACE: pinger.cpp:187: QueryId: ptqudq7ueohsakh1jitp, Owner: a3e078ee-1e6d1476-94764c3c-6e3032832 Stop Pinger
2025-12-12T12:28:06.294968Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudq7ueohsakh1jitp"
2025-12-12T12:28:06.295035Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:305: Resolve folder bootstrap. Folder id: my_folder Actor id: [1:7582947241212037288:2355]
2025-12-12T12:28:06.295051Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:367: Cloud id: mock_cloud Folder id: my_folder
2025-12-12T12:28:06.295080Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:91: Get quotas bootstrap. Cloud id: mock_cloud Actor id: [1:7582947241212037289:2356]
2025-12-12T12:28:06.295098Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.analyticsQuery.count IS STALE, Refreshing ...
2025-12-12T12:28:06.295107Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.cpuPercent.count IS STALE, Refreshing ...
2025-12-12T12:28:06.295111Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.streamingQuery.count IS STALE, Refreshing ...
2025-12-12T12:28:06.295156Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.cpuPercent.count=0/10000 REFRESHED
2025-12-12T12:28:06.297850Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.analyticsQuery.count=0/100 REFRESHED
2025-12-12T12:28:06.297873Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.streamingQuery.count=0/100 REFRESHED
2025-12-12T12:28:06.297904Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:493: cloud.mock_cloud{yq.streamingQueryDurationMinutes.count=*/0, yq.queryResult.size=*/20971520, yq.analyticsQuery.count=0/100, yq.analyticsQueryDurationMinutes.count=*/1440, yq.memory.size=*/0, yq.result.size=*/0, yq.cpuPercent.count=0/10000, yq.streamingQuery.count=0/100} SEND QUOTAS
2025-12-12T12:28:06.297917Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:103: Cloud id: mock_cloud Quota count: 8
2025-12-12T12:28:06.297943Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudq7ueohsakh1jitp"
2025-12-12T12:28:06.298004Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:169: Resolve subject type bootstrap. Token: **** (B6C6F477) Actor id: [1:7582947241212037294:2361]
2025-12-12T12:28:06.298034Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:230: Subject Type: federated_account Token: **** (B6C6F477)
2025-12-12T12:28:06.298064Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudq7ueohsakh1jitp"
2025-12-12T12:28:06.298124Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:63: Request actor. Actor id: [1:7582947241212037295:2362]
2025-12-12T12:28:06.298200Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_queries.cpp:641: DescribeQueryRequest: {query_id: "ptqudq7ueohsakh1jitp"
} [root@builtin, **** (B6C6F477)] 
2025-12-12T12:28:06.300647Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: DescribeQueryRequest - DescribeQueryResult: {query { meta { common { id: "ptqudq7ueohsakh1jitp" created_by: "root@builtin" modified_by: "root@builtin" created_at { seconds: 1765542448 nanos: 270904000 } modified_at { seconds: 1765542485 nanos: 695112000 } revision: 2 } started_at { seconds: 1765542449 nanos: 457000000 } finished_at { seconds: 1765542485 nanos: 973000000 } execute_mode: RUN status: ABORTED_BY_USER last_job_query_revision: 1 last_job_id: "ptjudq7ueohs9so9lloj-ptqudq7ueohsakh1jitp" started_by: "root@builtin" aborted_by: "root@builtin" has_saved_checkpoints: true submitted_at { seconds: 1765542448 nanos: 270904000 } } 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:17898\") $6 \'(\'\"ReconnectPeriod\" \'\"\") \'(\'\"Format\" \'\"raw\") \'(\'\"ReadGroup\" \'\"ptcudq7ueos1oh23eroc\") \'(\'\"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-12T12:28:06.303199Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudq7ueohsakh1jitp"
2025-12-12T12:28:06.303238Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:305: Resolve folder bootstrap. Folder id: my_folder Actor id: [1:7582947241212037299:2365]
2025-12-12T12:28:06.303253Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:367: Cloud id: mock_cloud Folder id: my_folder
2025-12-12T12:28:06.303260Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.cpuPercent.count=0/10000 NOTIFY CHANGE
2025-12-12T12:28:06.303274Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:91: Get quotas bootstrap. Cloud id: mock_cloud Actor id: [1:7582947241212037300:2366]
2025-12-12T12:28:06.303299Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.analyticsQuery.count IS STALE, Refreshing ...
2025-12-12T12:28:06.303310Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.cpuPercent.count IS STALE, Refreshing ...
2025-12-12T12:28:06.303318Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:291: cloud.mock_cloud.yq.streamingQuery.count IS STALE, Refreshing ...
2025-12-12T12:28:06.303332Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.cpuPercent.count=0/10000 REFRESHED
2025-12-12T12:28:06.303744Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.streamingQuery.count=0/100 NOTIFY CHANGE
2025-12-12T12:28:06.303806Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.analyticsQuery.count=0/100 NOTIFY CHANGE
2025-12-12T12:28:06.305322Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.analyticsQuery.count=0/100 REFRESHED
2025-12-12T12:28:06.305341Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:707: cloud.mock_cloud.yq.streamingQuery.count=0/100 REFRESHED
2025-12-12T12:28:06.305362Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:493: cloud.mock_cloud{yq.streamingQueryDurationMinutes.count=*/0, yq.queryResult.size=*/20971520, yq.analyticsQuery.count=0/100, yq.analyticsQueryDurationMinutes.count=*/1440, yq.memory.size=*/0, yq.result.size=*/0, yq.cpuPercent.count=0/10000, yq.streamingQuery.count=0/100} SEND QUOTAS
2025-12-12T12:28:06.305373Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:103: Cloud id: mock_cloud Quota count: 8
2025-12-12T12:28:06.305399Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudq7ueohsakh1jitp"
2025-12-12T12:28:06.305442Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:169: Resolve subject type bootstrap. Token: **** (B6C6F477) Actor id: [1:7582947241212037305:2371]
2025-12-12T12:28:06.305467Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:230: Subject Type: federated_account Token: **** (B6C6F477)
2025-12-12T12:28:06.305504Z :YQ_CONTROL_PLANE_PROXY TRACE: control_plane_proxy.cpp:784: DescribeQueryRequest: query_id: "ptqudq7ueohsakh1jitp"
2025-12-12T12:28:06.305542Z :YQ_CONTROL_PLANE_PROXY TRACE: request_actor.h:63: Request actor. Actor id: [1:7582947241212037306:2372]
2025-12-12T12:28:06.305587Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_queries.cpp:641: DescribeQueryRequest: {query_id: "ptqudq7ueohsakh1jitp"
} [root@builtin, **** (B6C6F477)] 
2025-12-12T12:28:06.308243Z :YQ_CONTROL_PLANE_STORAGE TRACE: ydb_control_plane_storage_impl.h:788: DescribeQueryRequest - DescribeQueryResult: {query { meta { common { id: "ptqudq7ueohsakh1jitp" created_by: "root@builtin" modified_by: "root@builtin" created_at { seconds: 1765542448 nanos: 270904000 } modified_at { seconds: 1765542485 nanos: 695112000 } revision: 2 } started_at { seconds: 1765542449 nanos: 457000000 } finished_at { seconds: 1765542485 nanos: 973000000 } execute_mode: RUN status: ABORTED_BY_USER last_job_query_revision: 1 last_job_id: "ptjudq7ueohs9so9lloj-ptqudq7ueohsakh1jitp" started_by: "root@builtin" aborted_by: "root@builtin" has_saved_checkpoints: true submitted_at { seconds: 1765542448 nanos: 270904000 } } 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:17898\") $6 \'(\'\"ReconnectPeriod\" \'\"\") \'(\'\"Format\" \'\"raw\") \'(\'\"ReadGroup\" \'\"ptcudq7ueos1oh23eroc\") \'(\'\"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-12T12:28:06.309686Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.cpuPercent.count=0/10000 NOTIFY CHANGE
2025-12-12T12:28:06.316227Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.analyticsQuery.count=0/100 NOTIFY CHANGE
2025-12-12T12:28:06.316501Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:510: cloud.mock_cloud.yq.streamingQuery.count=0/100 NOTIFY CHANGE
