2025-11-05T12:48:43.958157Z :GRPC_SERVER NOTICE: grpc_request_proxy_simple.cpp:161: Grpc simple request proxy started, nodeid# 3
2025-11-05T12:48:43.958547Z :GRPC_SERVER NOTICE: grpc_request_proxy_simple.cpp:161: Grpc simple request proxy started, nodeid# 3
2025-11-05T12:48:43.959264Z :FQ_LOG_UPDATER DEBUG: log.cpp:93: Updated YQL logs priority: 8
2025-11-05T12:48:43.959325Z :FQ_LOG_UPDATER CRIT: log.cpp:55: Failed to deliver subscription request to config dispatcher.
2025-11-05T12:48:43.959436Z :YQ_CONTROL_PLANE_STORAGE INFO: ydb_control_plane_storage.cpp:50: Starting ydb control plane storage service. Actor id: [3:7569222402647563130:2060]
2025-11-05T12:48:43.960015Z :FQ_CONTROL_PLANE_CONFIG DEBUG: control_plane_config.cpp:58: STARTING: [3:7569222402647563131:2061]
2025-11-05T12:48:43.960902Z :YQ_CONTROL_PLANE_PROXY DEBUG: control_plane_proxy.cpp:532: Starting yandex query control plane proxy. Actor id: [3:7569222402647563132:2062]
2025-11-05T12:48:43.962721Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:145: Bootstrap
2025-11-05T12:48:43.962872Z :MEMORY_PROFILER NOTICE: monitor.cpp:332: Bootstrapped
2025-11-05T12:48:43.962931Z :YQ_RATE_LIMITER INFO: quoter_service.cpp:124: Bootstraping with config: { Enabled: true ControlPlaneEnabled: true DataPlaneEnabled: true Database { Endpoint: "localhost:17646" Database: "local" TablePrefix: "RateLimiter_645030b7-4668-4291-9d92-e1b25479cb67" } Limiters { CoordinationNodePath: "rate_limiter" } }
2025-11-05T12:48:43.963140Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:165: Initialize
2025-11-05T12:48:43.985368Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:534: RowDispatcher: Successfully bootstrapped row dispatcher, id [3:7569222402647563137:2067], tenant /default
2025-11-05T12:48:43.986062Z :YQL_NODES_MANAGER INFO: nodes_manager.cpp:88: Bootstrap, InstanceId: 1dae2a4f-4043c190-8c0ecfa4-3f557ceb
2025-11-05T12:48:43.986077Z :YQL_NODES_MANAGER DEBUG: nodes_manager.cpp:310: TNodesManagerActor::ResolveSelfAddress
2025-11-05T12:48:43.986133Z :YQ_TEST_CONNECTION DEBUG: test_connection.cpp:142: Starting yandex query test connection. Actor id: [3:7569222402647563142:2072]
2025-11-05T12:48:43.986598Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: d032e364-233826fb-144ba989-a13916461, Host: ghrun-anwhr6cmha, Tenant: /default
2025-11-05T12:48:43.987011Z :FQ_QUOTA_SERVICE INFO: quota_manager.cpp:196: STARTED
2025-11-05T12:48:43.987040Z :FQ_QUOTA_PROXY INFO: quota_proxy.cpp:90: STARTED
2025-11-05T12:48:43.987315Z :YQ_RATE_LIMITER DEBUG: schema.cpp:71: Run create coordination node "local/RateLimiter_645030b7-4668-4291-9d92-e1b25479cb67/rate_limiter" actor
2025-11-05T12:48:43.987344Z :YQ_RATE_LIMITER DEBUG: schema.cpp:113: Call create coordination node "local/RateLimiter_645030b7-4668-4291-9d92-e1b25479cb67/rate_limiter"
2025-11-05T12:48:43.987361Z :YQ_RATE_LIMITER DEBUG: schema.cpp:411: Call create coordination node "local/RateLimiter_645030b7-4668-4291-9d92-e1b25479cb67/rate_limiter"
2025-11-05T12:48:43.988102Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:267: Coordinator: Successfully bootstrapped coordinator, id [3:7569222402647563223:2124], NodesManagerId [0:4705493345362661702:78]
2025-11-05T12:48:43.988185Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:231: TLeaderElection [3:7569222402647563224:2125] Successfully bootstrapped, local coordinator id [3:7569222402647563223:2124], tenant id default, local mode 0, coordination node path local/row_dispatcher/default
2025-11-05T12:48:43.990590Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create directory "local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67" actor
2025-11-05T12:48:43.990612Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create directory "local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67"
2025-11-05T12:48:43.990619Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:383: Call create directory "local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67"
2025-11-05T12:48:43.994006Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/queries" actor
2025-11-05T12:48:43.994177Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/pending_small" actor
2025-11-05T12:48:43.994258Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/connections" actor
2025-11-05T12:48:43.994405Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/bindings" actor
2025-11-05T12:48:43.994585Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:627: RowDispatcher: TEvCoordinatorChangesSubscribe from [3:7569222402647563223:2124]
2025-11-05T12:48:43.994661Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/idempotency_keys" actor
2025-11-05T12:48:43.994741Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/result_sets" actor
2025-11-05T12:48:43.994796Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/jobs" actor
2025-11-05T12:48:43.994891Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/nodes" actor
2025-11-05T12:48:43.995051Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/quotas" actor
2025-11-05T12:48:43.995222Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-11-05T12:48:43.995696Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/tenants" actor
2025-11-05T12:48:43.995779Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/tenant_acks" actor
2025-11-05T12:48:43.995894Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/mappings" actor
2025-11-05T12:48:43.996002Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:71: Run create table "local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/compute_databases" actor
2025-11-05T12:48:43.996098Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:71: Run create coordination node "local/row_dispatcher/default" actor
2025-11-05T12:48:43.996124Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:113: Call create coordination node "local/row_dispatcher/default"
2025-11-05T12:48:43.996131Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:411: Call create coordination node "local/row_dispatcher/default"
2025-11-05T12:48:44.022921Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:155: Successfully created coordination node "local/row_dispatcher/default"
2025-11-05T12:48:44.023021Z :FQ_ROW_DISPATCHER DEBUG: schema.cpp:122: Reply for create coordination node "local/row_dispatcher/default": { <main>: Error: Check failed: path: '/local/row_dispatcher/default', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 13], type: EPathTypeKesus, state: EPathStateNoChanges) }
2025-11-05T12:48:44.023116Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:344: TLeaderElection [3:7569222402647563224:2125] Coordination node successfully created
2025-11-05T12:48:44.023158Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:322: TLeaderElection [3:7569222402647563224:2125] Start session
2025-11-05T12:48:44.035640Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:358: TLeaderElection [3:7569222402647563224:2125] Session successfully created
2025-11-05T12:48:44.039189Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:371: TLeaderElection [3:7569222402647563224:2125] Semaphore successfully created
2025-11-05T12:48:44.039222Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:303: TLeaderElection [3:7569222402647563224:2125] Try to acquire semaphore
2025-11-05T12:48:44.039474Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:419: TLeaderElection [3:7569222402647563224:2125] Describe semaphore
2025-11-05T12:48:44.042551Z :FQ_ROW_DISPATCHER DEBUG: leader_election.cpp:468: TLeaderElection [3:7569222402647563224:2125] Semaphore successfully described: coordinator id [1:7569222396538089983:2138] generation 8
2025-11-05T12:48:44.042584Z :FQ_ROW_DISPATCHER INFO: leader_election.cpp:470: TLeaderElection [3:7569222402647563224:2125] Send TEvCoordinatorChanged to [3:7569222402647563137:2067], new coordinator id [1:7569222396538089983:2138], previous coordinator id [0:0:0]
2025-11-05T12:48:44.042676Z :FQ_ROW_DISPATCHER DEBUG: row_dispatcher.cpp:559: RowDispatcher: Coordinator changed, old leader (empty maybe), new [1:7569222396538089983:2138] generation 8
2025-11-05T12:48:44.042793Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:386: Coordinator: New leader [1:7569222396538089983:2138], SelfId [3:7569222402647563223:2124]
2025-11-05T12:48:44.042942Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:597: RowDispatcher: TEvUndelivered, from [1:7569222396538089983:2138], reason Disconnected
2025-11-05T12:48:44.053003Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/queries". Create session OK
2025-11-05T12:48:44.053074Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/queries"
2025-11-05T12:48:44.053091Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/queries"
2025-11-05T12:48:44.054778Z :YQ_RATE_LIMITER DEBUG: schema.cpp:155: Successfully created coordination node "local/RateLimiter_645030b7-4668-4291-9d92-e1b25479cb67/rate_limiter"
2025-11-05T12:48:44.054825Z :YQ_RATE_LIMITER DEBUG: schema.cpp:122: Reply for create coordination node "local/RateLimiter_645030b7-4668-4291-9d92-e1b25479cb67/rate_limiter": { <main>: Error: Check failed: path: '/local/RateLimiter_645030b7-4668-4291-9d92-e1b25479cb67/rate_limiter', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 172], type: EPathTypeKesus, state: EPathStateNoChanges) }
2025-11-05T12:48:44.054855Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created directory "local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67"
2025-11-05T12:48:44.054885Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create directory "local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67": { <main>: Error: Check failed: path: '/local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 166], type: EPathTypeDir, state: EPathStateNoChanges) }
2025-11-05T12:48:44.054934Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/pending_small". Create session OK
2025-11-05T12:48:44.054979Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/pending_small"
2025-11-05T12:48:44.054987Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/pending_small"
2025-11-05T12:48:44.056966Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/connections". Create session OK
2025-11-05T12:48:44.056996Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/connections"
2025-11-05T12:48:44.057004Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/connections"
2025-11-05T12:48:44.057216Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/bindings". Create session OK
2025-11-05T12:48:44.057253Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/bindings"
2025-11-05T12:48:44.057259Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/bindings"
2025-11-05T12:48:44.059069Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/idempotency_keys". Create session OK
2025-11-05T12:48:44.059124Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/idempotency_keys"
2025-11-05T12:48:44.059132Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/idempotency_keys"
2025-11-05T12:48:44.059416Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/result_sets". Create session OK
2025-11-05T12:48:44.059461Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/result_sets"
2025-11-05T12:48:44.059478Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/result_sets"
2025-11-05T12:48:44.061171Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/jobs". Create session OK
2025-11-05T12:48:44.061190Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/jobs"
2025-11-05T12:48:44.061197Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/jobs"
2025-11-05T12:48:44.061218Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/nodes". Create session OK
2025-11-05T12:48:44.061233Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/nodes"
2025-11-05T12:48:44.061236Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/nodes"
2025-11-05T12:48:44.063705Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/tenants". Create session OK
2025-11-05T12:48:44.063741Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/tenants"
2025-11-05T12:48:44.063786Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/tenants"
2025-11-05T12:48:44.063837Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/quotas". Create session OK
2025-11-05T12:48:44.063865Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/quotas"
2025-11-05T12:48:44.063876Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/quotas"
2025-11-05T12:48:44.068255Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/tenant_acks". Create session OK
2025-11-05T12:48:44.068330Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/tenant_acks"
2025-11-05T12:48:44.068346Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/tenant_acks"
2025-11-05T12:48:44.068495Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/mappings". Create session OK
2025-11-05T12:48:44.068511Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/mappings"
2025-11-05T12:48:44.068516Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/mappings"
2025-11-05T12:48:44.070486Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:293: Create table "local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/compute_databases". Create session OK
2025-11-05T12:48:44.070515Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:113: Call create table "local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/compute_databases"
2025-11-05T12:48:44.070519Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:354: Call create table "local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/compute_databases"
2025-11-05T12:48:44.070531Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-05T12:48:44.070545Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-05T12:48:44.074778Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/queries"
2025-11-05T12:48:44.074837Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/queries": { <main>: Error: Check failed: path: '/local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/queries', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 174], type: EPathTypeTable, state: EPathStateNoChanges) }
2025-11-05T12:48:44.080111Z :FQ_CONTROL_PLANE_CONFIG DEBUG: control_plane_config.cpp:190: LOADED TenantInfo: State CHANGED at 2025-11-05T12:48:38.915269Z
2025-11-05T12:48:44.080286Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/pending_small"
2025-11-05T12:48:44.080327Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/pending_small": { <main>: Error: Check failed: path: '/local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/pending_small', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 173], type: EPathTypeTable, state: EPathStateNoChanges) }
2025-11-05T12:48:44.082605Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/connections"
2025-11-05T12:48:44.082661Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/connections": { <main>: Error: Check failed: path: '/local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/connections', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 176], type: EPathTypeTable, state: EPathStateNoChanges) }
2025-11-05T12:48:44.082744Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:389: Send NodeInfo with size: 2 to DynamicNameserver
2025-11-05T12:48:44.086914Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/bindings"
2025-11-05T12:48:44.086978Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/bindings": { <main>: Error: Check failed: path: '/local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/bindings', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 175], type: EPathTypeTable, state: EPathStateNoChanges) }
2025-11-05T12:48:44.087859Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/result_sets"
2025-11-05T12:48:44.087896Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/result_sets": { <main>: Error: Check failed: path: '/local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/result_sets', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 179], type: EPathTypeTable, state: EPathStateNoChanges) }
2025-11-05T12:48:44.088966Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/idempotency_keys"
2025-11-05T12:48:44.089010Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/idempotency_keys": { <main>: Error: Check failed: path: '/local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/idempotency_keys', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 177], type: EPathTypeTable, state: EPathStateNoChanges) }
2025-11-05T12:48:44.089776Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/nodes"
2025-11-05T12:48:44.089816Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/nodes": { <main>: Error: Check failed: path: '/local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/nodes', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 181], type: EPathTypeTable, state: EPathStateNoChanges) }
2025-11-05T12:48:44.091999Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/jobs"
2025-11-05T12:48:44.092039Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/jobs": { <main>: Error: Check failed: path: '/local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/jobs', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 178], type: EPathTypeTable, state: EPathStateNoChanges) }
2025-11-05T12:48:44.092307Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/tenants"
2025-11-05T12:48:44.092364Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/tenants": { <main>: Error: Check failed: path: '/local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/tenants', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 167], type: EPathTypeTable, state: EPathStateNoChanges) }
2025-11-05T12:48:44.093691Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/quotas"
2025-11-05T12:48:44.093740Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/quotas": { <main>: Error: Check failed: path: '/local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/quotas', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 180], type: EPathTypeTable, state: EPathStateNoChanges) }
2025-11-05T12:48:44.094162Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/tenant_acks"
2025-11-05T12:48:44.094203Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/tenant_acks": { <main>: Error: Check failed: path: '/local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/tenant_acks', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 182], type: EPathTypeTable, state: EPathStateNoChanges) }
2025-11-05T12:48:44.095870Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/mappings"
2025-11-05T12:48:44.095988Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/mappings": { <main>: Error: Check failed: path: '/local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/mappings', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 168], type: EPathTypeTable, state: EPathStateNoChanges) }
2025-11-05T12:48:44.096379Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:155: Successfully created table "local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/compute_databases"
2025-11-05T12:48:44.096414Z :YQ_CONTROL_PLANE_STORAGE DEBUG: schema.cpp:122: Reply for create table "local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/compute_databases": { <main>: Error: Check failed: path: '/local/DbPoolStorage_645030b7-4668-4291-9d92-e1b25479cb67/compute_databases', error: path exist, request accepts it (id: [OwnerId: 72057594046678944, LocalPathId: 183], type: EPathTypeTable, state: EPathStateNoChanges) }
2025-11-05T12:48:44.142432Z :STREAMS_STORAGE_SERVICE INFO: storage_proxy.cpp:158: Successfully bootstrapped TStorageProxy [3:7569222402647563136:2066] with connection to localhost:17646:local
2025-11-05T12:48:44.986788Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: d032e364-233826fb-144ba989-a13916462, Host: ghrun-anwhr6cmha, Tenant: /default
2025-11-05T12:48:44.988277Z :FQ_ROW_DISPATCHER DEBUG: coordinator.cpp:542: Coordinator: Send TEvGetNodesRequest to NodesManager
2025-11-05T12:48:44.988315Z :YQL_NODES_MANAGER DEBUG: nodes_manager.cpp:300: TNodesManagerActor::TEvGetNodesRequest
2025-11-05T12:48:44.988739Z :FQ_ROW_DISPATCHER INFO: coordinator.cpp:573: Coordinator: Updated node info, node count: 3
2025-11-05T12:48:44.995005Z :FQ_QUOTA_SERVICE DEBUG: quota_manager.cpp:230: IC Peers[2]: [1, 2]
2025-11-05T12:48:45.022913Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-05T12:48:45.022934Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-05T12:48:45.986826Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:617: RowDispatcher: Send ping to [1:7569222396538089983:2138]
2025-11-05T12:48:45.986933Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1161: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-11-05T12:48:45.986983Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: d032e364-233826fb-144ba989-a13916463, Host: ghrun-anwhr6cmha, Tenant: /default
2025-11-05T12:48:46.036136Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-05T12:48:46.036174Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-05T12:48:46.987287Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: d032e364-233826fb-144ba989-a13916464, Host: ghrun-anwhr6cmha, Tenant: /default
2025-11-05T12:48:47.019789Z :FQ_CONTROL_PLANE_CONFIG TRACE: control_plane_config.cpp:192: LOADED TenantInfo: State NOT changed
2025-11-05T12:48:47.023299Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-05T12:48:47.023319Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-05T12:48:47.343032Z :INTERCONNECT ERROR: interconnect_nameserver_dynamic.cpp:61:  ICN06 Unknown nodeId: 4
2025-11-05T12:48:47.987101Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:617: RowDispatcher: Send ping to [1:7569222396538089983:2138]
2025-11-05T12:48:47.987153Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1161: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-11-05T12:48:47.987573Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: d032e364-233826fb-144ba989-a13916465, Host: ghrun-anwhr6cmha, Tenant: /default
2025-11-05T12:48:47.996406Z :INTERCONNECT WARN: interconnect_handshake.cpp:501: Handshake [3:7569222419827432449:2057] [node 1] ICH09 Neither CompatibilityInfo nor VersionTag of the peer can be validated, accepting by default
2025-11-05T12:48:47.998259Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:623: RowDispatcher: NActors::TEvents::TEvPong
2025-11-05T12:48:48.039473Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-05T12:48:48.039506Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-05T12:48:48.987818Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: d032e364-233826fb-144ba989-a13916466, Host: ghrun-anwhr6cmha, Tenant: /default
2025-11-05T12:48:48.995491Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-11-05T12:48:49.017898Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-05T12:48:49.017930Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-05T12:48:49.046676Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:389: Send NodeInfo with size: 3 to DynamicNameserver
2025-11-05T12:48:49.875372Z :INTERCONNECT WARN: interconnect_handshake.cpp:501: Handshake [3:7569222428417367049:2059] [node 4] ICH09 Neither CompatibilityInfo nor VersionTag of the peer can be validated, accepting by default
2025-11-05T12:48:49.876736Z :INTERCONNECT WARN: interconnect_handshake.cpp:501: Handshake [3:7569222428417367052:2061] [node 2] ICH09 Neither CompatibilityInfo nor VersionTag of the peer can be validated, accepting by default
2025-11-05T12:48:49.988439Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:617: RowDispatcher: Send ping to [1:7569222396538089983:2138]
2025-11-05T12:48:49.988468Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1161: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-11-05T12:48:49.988515Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: d032e364-233826fb-144ba989-a13916467, Host: ghrun-anwhr6cmha, Tenant: /default
2025-11-05T12:48:49.990901Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:623: RowDispatcher: NActors::TEvents::TEvPong
2025-11-05T12:48:49.996289Z :FQ_QUOTA_SERVICE DEBUG: quota_manager.cpp:230: IC Peers[3]: [1, 2, 4]
2025-11-05T12:48:50.005120Z :FQ_CONTROL_PLANE_CONFIG TRACE: control_plane_config.cpp:192: LOADED TenantInfo: State NOT changed
2025-11-05T12:48:50.020792Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-05T12:48:50.020823Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-05T12:48:50.988727Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: d032e364-233826fb-144ba989-a13916468, Host: ghrun-anwhr6cmha, Tenant: /default
2025-11-05T12:48:51.013610Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-05T12:48:51.013632Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-05T12:48:51.988612Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:617: RowDispatcher: Send ping to [1:7569222396538089983:2138]
2025-11-05T12:48:51.988656Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1161: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-11-05T12:48:51.988874Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: d032e364-233826fb-144ba989-a13916469, Host: ghrun-anwhr6cmha, Tenant: /default
2025-11-05T12:48:51.989380Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:623: RowDispatcher: NActors::TEvents::TEvPong
2025-11-05T12:48:52.014955Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-05T12:48:52.014994Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-05T12:48:52.989046Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: d032e364-233826fb-144ba989-a139164610, Host: ghrun-anwhr6cmha, Tenant: /default
2025-11-05T12:48:53.003450Z :FQ_CONTROL_PLANE_CONFIG TRACE: control_plane_config.cpp:192: LOADED TenantInfo: State NOT changed
2025-11-05T12:48:53.586352Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-05T12:48:53.586375Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-05T12:48:53.988770Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:617: RowDispatcher: Send ping to [1:7569222396538089983:2138]
2025-11-05T12:48:53.988856Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1161: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-11-05T12:48:53.989287Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: d032e364-233826fb-144ba989-a139164611, Host: ghrun-anwhr6cmha, Tenant: /default
2025-11-05T12:48:53.990010Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:623: RowDispatcher: NActors::TEvents::TEvPong
2025-11-05T12:48:53.995710Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-11-05T12:48:54.076867Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-05T12:48:54.076895Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-05T12:48:54.105884Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:389: Send NodeInfo with size: 3 to DynamicNameserver
2025-11-05T12:48:54.989420Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: d032e364-233826fb-144ba989-a139164612, Host: ghrun-anwhr6cmha, Tenant: /default
2025-11-05T12:48:55.013567Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-05T12:48:55.013595Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-05T12:48:55.333648Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: d032e364-233826fb-144ba989-a1391646 2025-11-05 12:48:55.333 DEBUG ydbd(pid=2844066, tid=0x00007B47068E5640) [DQ] local_worker_manager.cpp:316: {ptqudt4ugje5uamtl6f2} TLocalWorkerManager::TEvAllocateWorkersRequest 562954248388609
2025-11-05T12:48:55.333827Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: d032e364-233826fb-144ba989-a1391646 2025-11-05 12:48:55.333 DEBUG ydbd(pid=2844066, tid=0x00007B47068E5640) [DQ] local_worker_manager.cpp:376: {ptqudt4ugje5uamtl6f2} Create compute actor: async
2025-11-05T12:48:55.442127Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:134: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. Start compute actor [3:7569222454187170843:2157], task: 2
2025-11-05T12:48:55.442295Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:113: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. Use CPU quota: 1. Rate limiter resource: { "local/RateLimiter_645030b7-4668-4291-9d92-e1b25479cb67/rate_limiter", "mock_cloud/my_folder/ptqudt4ugje5uamtl6f2" }
2025-11-05T12:48:55.683870Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1074: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. Received channels info: Update { Id: 1 TransportVersion: DATA_TRANSPORT_UV_PICKLE_1_0 SrcTaskId: 1 DstTaskId: 2 SrcEndpoint { ActorId { RawX1: 7569222452372665125 RawX2: 4503603922340191 } } DstEndpoint { ActorId { RawX1: 7569222454187170843 RawX2: 4503612512274541 } } SrcStageId: 209475 DstStageId: 209492 } Update { Id: 2 TransportVersion: DATA_TRANSPORT_UV_PICKLE_1_0 SrcTaskId: 2 SrcEndpoint { ActorId { RawX1: 7569222454187170843 RawX2: 4503612512274541 } } DstEndpoint { ActorId { RawX1: 7569222452372665121 RawX2: 4503603922340187 } } }
2025-11-05T12:48:55.683909Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1081: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. Update input channelId: 1, peer: [1:7569222452372665125:2399]
2025-11-05T12:48:55.683931Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1093: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. Update output channelId: 2, peer: [1:7569222452372665121:2395]
2025-11-05T12:48:55.717301Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:197: [] Task: 2. Got TEvNewCheckpointCoordinator event: generation 1, actorId: [1:7569222452372665122:2396]
2025-11-05T12:48:55.717324Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:208: [] Task: 2. Assign checkpoint coordinator (generation = 1)
2025-11-05T12:48:55.717525Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:395: [ptqudt4ugje5uamtl6f2-0] Task: 2. Handle connected node 1
2025-11-05T12:48:55.988859Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:617: RowDispatcher: Send ping to [1:7569222396538089983:2138]
2025-11-05T12:48:55.988887Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1161: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-11-05T12:48:55.989518Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:623: RowDispatcher: NActors::TEvents::TEvPong
2025-11-05T12:48:55.989632Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: d032e364-233826fb-144ba989-a139164613, Host: ghrun-anwhr6cmha, Tenant: /default
2025-11-05T12:48:56.002680Z :FQ_CONTROL_PLANE_CONFIG TRACE: control_plane_config.cpp:192: LOADED TenantInfo: State NOT changed
2025-11-05T12:48:56.011881Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-05T12:48:56.011903Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-05T12:48:56.487052Z :KQP_COMPUTE DEBUG: dq_compute_actor_impl.h:1169: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. Got TEvRun from actor [1:7569222452372665122:2396]
2025-11-05T12:48:56.487152Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1486: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. Poll inputs
2025-11-05T12:48:56.487162Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1501: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. Poll sources
2025-11-05T12:48:56.487172Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-11-05T12:48:56.487310Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: d032e364-233826fb-144ba989-a1391646 2025-11-05 12:48:56.487 DEBUG ydbd(pid=2844066, tid=0x00007B47068E5640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Run task: 2
2025-11-05T12:48:56.487445Z :KQP_COMPUTE TRACE: dq_compute_memory_quota.h:97: TxId: ptqudt4ugje5uamtl6f2, task: 2. Peak memory usage: 2031616
2025-11-05T12:48:56.487483Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. update task runner stats
2025-11-05T12:48:56.487567Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-05T12:48:56.487581Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-05T12:48:56.487603Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:532: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. About to drain channelId: 2, hasPeer: 1, peerState:(freeSpace:1000000;inFlightBytes:0;inFlightCount:0;)
2025-11-05T12:48:56.487616Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1105: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. Ask CPU quota: 37ms
2025-11-05T12:48:56.487683Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:605: TxId: ptqudt4ugje5uamtl6f2, task: 2. no poll, channelId: 1, hasPeer: 1, finished: 0, retry: 0, lastSeqNo: 0, freeSpace: 1000000
2025-11-05T12:48:56.487987Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:129: TxId: ptqudt4ugje5uamtl6f2, task: 2. Received input for channelId: 1, seqNo: 1, size: 0, chunks: 0, watermark: 0, checkpoint: 1, finished: 0, from: [1:7569222452372665126:2399], expected seqNo: 1
2025-11-05T12:48:56.488013Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:609: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. took input
2025-11-05T12:48:56.488094Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:485: [ptqudt4ugje5uamtl6f2-0] Task: 2. [Checkpoint 1.1] Got checkpoint barrier from channel 1
2025-11-05T12:48:56.488145Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:395: SelfId: [3:7569222454187170845:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. No watermark 
2025-11-05T12:48:56.488179Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1486: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. Poll inputs
2025-11-05T12:48:56.488192Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1497: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-11-05T12:48:56.488200Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. DoExecuteImpl: 1
2025-11-05T12:48:56.488237Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:965: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. Input data push finished. Cookie: 0 Watermark: (empty maybe) Ack: 1 TakeInputChannelDataRequests: 1
2025-11-05T12:48:56.488266Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:738: TxId: ptqudt4ugje5uamtl6f2, task: 2. Sending channel data ack to channelId: 1, peer: [1:7569222452372665125:2399], from: [3:7569222454187170843:2157], freeSpace: 1000000, seqNo: 1, finished: 0
2025-11-05T12:48:56.488312Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1486: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. Poll inputs
2025-11-05T12:48:56.488317Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1497: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-11-05T12:48:56.488349Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-11-05T12:48:56.495959Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:1162: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. CPU quota delay: 8ms
2025-11-05T12:48:56.496217Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:510: SelfId: [3:7569222454187170845:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Pending 1 checkpoints to be sent
2025-11-05T12:48:56.496255Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. update task runner stats
2025-11-05T12:48:56.496382Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 1 watermark injected: (empty maybe)
2025-11-05T12:48:56.496409Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:447: [ptqudt4ugje5uamtl6f2-0] Task: 2. [Checkpoint 1.1] Performing task checkpoint
2025-11-05T12:48:56.496423Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:822: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. Save state
2025-11-05T12:48:56.496440Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:474: [ptqudt4ugje5uamtl6f2-0] Task: 2. [Checkpoint 1.1] CA state saved
2025-11-05T12:48:56.496452Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:449: [ptqudt4ugje5uamtl6f2-0] Task: 2. [Checkpoint 1.1] Injecting checkpoint barrier to outputs
2025-11-05T12:48:56.496510Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:536: [ptqudt4ugje5uamtl6f2-0] Task: 2. [Checkpoint 1.1] Task checkpoint is done. Send to storage
2025-11-05T12:48:56.496520Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-05T12:48:56.496550Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:532: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. About to drain channelId: 2, hasPeer: 1, peerState:(freeSpace:1000000;inFlightBytes:0;inFlightCount:0;)
2025-11-05T12:48:56.496587Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:366: [ptqudt4ugje5uamtl6f2-0] [1:1] Got TEvSaveTaskState: task 2
2025-11-05T12:48:56.496632Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:566: TxId: ptqudt4ugje5uamtl6f2, task: 2. SendChannelData, channelId: 2, peer: [1:7569222452372665121:2395], chunks: 0, bytes: 0, watermark: 0, checkpoint: 1, seqNo: 1, finished: 0
2025-11-05T12:48:56.496726Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudt4ugje5uamtl6f2, task: 2. no poll, channelId: 1, has inflight messages: [1], last with freeSpace: 1000000, current freeSpace: 1000000
2025-11-05T12:48:56.496754Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1486: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. Poll inputs
2025-11-05T12:48:56.496762Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1501: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. Poll sources
2025-11-05T12:48:56.496770Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-11-05T12:48:56.496920Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. update task runner stats
2025-11-05T12:48:56.496975Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-05T12:48:56.496988Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-05T12:48:56.497009Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:532: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. About to drain channelId: 2, hasPeer: 1, peerState:(freeSpace:1000000;inFlightBytes:96;inFlightCount:1;)
2025-11-05T12:48:56.497045Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudt4ugje5uamtl6f2, task: 2. no poll, channelId: 1, has inflight messages: [1], last with freeSpace: 1000000, current freeSpace: 1000000
2025-11-05T12:48:56.497425Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:179: TxId: ptqudt4ugje5uamtl6f2, task: 2. Received channel data ack for channelId: 2, seqNo: 1, lastSentSeqNo: 1, freeSpace: 67108864, early finish: 0
2025-11-05T12:48:56.497466Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:207: TxId: ptqudt4ugje5uamtl6f2, task: 2. PeerState, peerState:(freeSpace:67108864;inFlightBytes:0;inFlightCount:0;), sentSeqNo: 1, ackSeqNo: 1
2025-11-05T12:48:56.497477Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:220: TxId: ptqudt4ugje5uamtl6f2, task: 2. Resume compute actor
2025-11-05T12:48:56.497508Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1486: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. Poll inputs
2025-11-05T12:48:56.497515Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1501: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. Poll sources
2025-11-05T12:48:56.497521Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-11-05T12:48:56.497626Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: d032e364-233826fb-144ba989-a1391646 2025-11-05 12:48:56.497 DEBUG ydbd(pid=2844066, tid=0x00007B47068E5640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Run task: 2
2025-11-05T12:48:56.497689Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. update task runner stats
2025-11-05T12:48:56.497740Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-05T12:48:56.497755Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-05T12:48:56.497772Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:532: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. About to drain channelId: 2, hasPeer: 1, peerState:(freeSpace:67108864;inFlightBytes:0;inFlightCount:0;)
2025-11-05T12:48:56.497809Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudt4ugje5uamtl6f2, task: 2. no poll, channelId: 1, has inflight messages: [1], last with freeSpace: 1000000, current freeSpace: 1000000
2025-11-05T12:48:56.598654Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:390: [ptqudt4ugje5uamtl6f2-0] [1:1] TEvSaveTaskState Apply: task: 2
2025-11-05T12:48:56.598704Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:405: [ptqudt4ugje5uamtl6f2-0] [1:1] Send TEvSaveTaskStateResult: task: 2
2025-11-05T12:48:56.989795Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: d032e364-233826fb-144ba989-a139164614, Host: ghrun-anwhr6cmha, Tenant: /default
2025-11-05T12:48:57.009426Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-05T12:48:57.009447Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-05T12:48:57.988990Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:617: RowDispatcher: Send ping to [1:7569222396538089983:2138]
2025-11-05T12:48:57.989030Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1161: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-11-05T12:48:57.989648Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:623: RowDispatcher: NActors::TEvents::TEvPong
2025-11-05T12:48:57.989993Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: d032e364-233826fb-144ba989-a139164615, Host: ghrun-anwhr6cmha, Tenant: /default
2025-11-05T12:48:58.009571Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-05T12:48:58.009596Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-05T12:48:58.049645Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:129: TxId: ptqudt4ugje5uamtl6f2, task: 2. Received input for channelId: 1, seqNo: 2, size: 0, chunks: 0, watermark: 0, checkpoint: 1, finished: 0, from: [1:7569222452372665126:2399], expected seqNo: 2
2025-11-05T12:48:58.049680Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:609: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. took input
2025-11-05T12:48:58.049723Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:485: [ptqudt4ugje5uamtl6f2-0] Task: 2. [Checkpoint 1.2] Got checkpoint barrier from channel 1
2025-11-05T12:48:58.049798Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:395: SelfId: [3:7569222454187170845:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. No watermark 
2025-11-05T12:48:58.049822Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1486: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. Poll inputs
2025-11-05T12:48:58.049835Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1497: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-11-05T12:48:58.049849Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. DoExecuteImpl: 1
2025-11-05T12:48:58.049877Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:965: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. Input data push finished. Cookie: 1 Watermark: (empty maybe) Ack: 1 TakeInputChannelDataRequests: 1
2025-11-05T12:48:58.049899Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:738: TxId: ptqudt4ugje5uamtl6f2, task: 2. Sending channel data ack to channelId: 1, peer: [1:7569222452372665125:2399], from: [3:7569222454187170843:2157], freeSpace: 1000000, seqNo: 2, finished: 0
2025-11-05T12:48:58.050129Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: d032e364-233826fb-144ba989-a1391646 2025-11-05 12:48:58.050 DEBUG ydbd(pid=2844066, tid=0x00007B47068E5640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Run task: 2
2025-11-05T12:48:58.050226Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:510: SelfId: [3:7569222454187170845:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Pending 1 checkpoints to be sent
2025-11-05T12:48:58.050262Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1486: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. Poll inputs
2025-11-05T12:48:58.050274Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1497: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-11-05T12:48:58.050281Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-11-05T12:48:58.050294Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. update task runner stats
2025-11-05T12:48:58.050374Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 1 watermark injected: (empty maybe)
2025-11-05T12:48:58.050396Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:447: [ptqudt4ugje5uamtl6f2-0] Task: 2. [Checkpoint 1.2] Performing task checkpoint
2025-11-05T12:48:58.050404Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:822: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. Save state
2025-11-05T12:48:58.050416Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:474: [ptqudt4ugje5uamtl6f2-0] Task: 2. [Checkpoint 1.2] CA state saved
2025-11-05T12:48:58.050440Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:449: [ptqudt4ugje5uamtl6f2-0] Task: 2. [Checkpoint 1.2] Injecting checkpoint barrier to outputs
2025-11-05T12:48:58.050478Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:536: [ptqudt4ugje5uamtl6f2-0] Task: 2. [Checkpoint 1.2] Task checkpoint is done. Send to storage
2025-11-05T12:48:58.050488Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-05T12:48:58.050508Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:532: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. About to drain channelId: 2, hasPeer: 1, peerState:(freeSpace:67108864;inFlightBytes:0;inFlightCount:0;)
2025-11-05T12:48:58.050521Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:366: [ptqudt4ugje5uamtl6f2-0] [1:2] Got TEvSaveTaskState: task 2
2025-11-05T12:48:58.050635Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: d032e364-233826fb-144ba989-a1391646 2025-11-05 12:48:58.050 DEBUG ydbd(pid=2844066, tid=0x00007B47068E5640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Run task: 2
2025-11-05T12:48:58.050725Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:566: TxId: ptqudt4ugje5uamtl6f2, task: 2. SendChannelData, channelId: 2, peer: [1:7569222452372665121:2395], chunks: 0, bytes: 0, watermark: 0, checkpoint: 1, seqNo: 2, finished: 0
2025-11-05T12:48:58.050796Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudt4ugje5uamtl6f2, task: 2. no poll, channelId: 1, has inflight messages: [2], last with freeSpace: 1000000, current freeSpace: 1000000
2025-11-05T12:48:58.050810Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. update task runner stats
2025-11-05T12:48:58.050871Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-05T12:48:58.050879Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-05T12:48:58.050921Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:532: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. About to drain channelId: 2, hasPeer: 1, peerState:(freeSpace:67108864;inFlightBytes:96;inFlightCount:1;)
2025-11-05T12:48:58.050935Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1486: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. Poll inputs
2025-11-05T12:48:58.050943Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1501: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. Poll sources
2025-11-05T12:48:58.050953Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-11-05T12:48:58.051054Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: d032e364-233826fb-144ba989-a1391646 2025-11-05 12:48:58.050 DEBUG ydbd(pid=2844066, tid=0x00007B47068E5640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Run task: 2
2025-11-05T12:48:58.051104Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudt4ugje5uamtl6f2, task: 2. no poll, channelId: 1, has inflight messages: [2], last with freeSpace: 1000000, current freeSpace: 1000000
2025-11-05T12:48:58.051116Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. update task runner stats
2025-11-05T12:48:58.051151Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-05T12:48:58.051159Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-05T12:48:58.051169Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:532: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. About to drain channelId: 2, hasPeer: 1, peerState:(freeSpace:67108864;inFlightBytes:96;inFlightCount:1;)
2025-11-05T12:48:58.051193Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudt4ugje5uamtl6f2, task: 2. no poll, channelId: 1, has inflight messages: [2], last with freeSpace: 1000000, current freeSpace: 1000000
2025-11-05T12:48:58.051362Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:179: TxId: ptqudt4ugje5uamtl6f2, task: 2. Received channel data ack for channelId: 2, seqNo: 2, lastSentSeqNo: 2, freeSpace: 67108864, early finish: 0
2025-11-05T12:48:58.051391Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:207: TxId: ptqudt4ugje5uamtl6f2, task: 2. PeerState, peerState:(freeSpace:67108864;inFlightBytes:0;inFlightCount:0;), sentSeqNo: 2, ackSeqNo: 2
2025-11-05T12:48:58.051399Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:220: TxId: ptqudt4ugje5uamtl6f2, task: 2. Resume compute actor
2025-11-05T12:48:58.051413Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1486: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. Poll inputs
2025-11-05T12:48:58.051464Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1501: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. Poll sources
2025-11-05T12:48:58.051470Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-11-05T12:48:58.051587Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: d032e364-233826fb-144ba989-a1391646 2025-11-05 12:48:58.051 DEBUG ydbd(pid=2844066, tid=0x00007B47068E5640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Run task: 2
2025-11-05T12:48:58.051644Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. update task runner stats
2025-11-05T12:48:58.051699Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-05T12:48:58.051712Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-05T12:48:58.051729Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:532: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. About to drain channelId: 2, hasPeer: 1, peerState:(freeSpace:67108864;inFlightBytes:0;inFlightCount:0;)
2025-11-05T12:48:58.051760Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudt4ugje5uamtl6f2, task: 2. no poll, channelId: 1, has inflight messages: [2], last with freeSpace: 1000000, current freeSpace: 1000000
2025-11-05T12:48:58.062888Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:390: [ptqudt4ugje5uamtl6f2-0] [1:2] TEvSaveTaskState Apply: task: 2
2025-11-05T12:48:58.062924Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:405: [ptqudt4ugje5uamtl6f2-0] [1:2] Send TEvSaveTaskStateResult: task: 2
2025-11-05T12:48:58.756947Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:129: TxId: ptqudt4ugje5uamtl6f2, task: 2. Received input for channelId: 1, seqNo: 3, size: 0, chunks: 0, watermark: 0, checkpoint: 1, finished: 0, from: [1:7569222452372665126:2399], expected seqNo: 3
2025-11-05T12:48:58.756976Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:609: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. took input
2025-11-05T12:48:58.757016Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:485: [ptqudt4ugje5uamtl6f2-0] Task: 2. [Checkpoint 1.3] Got checkpoint barrier from channel 1
2025-11-05T12:48:58.757065Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:395: SelfId: [3:7569222454187170845:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. No watermark 
2025-11-05T12:48:58.757081Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1486: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. Poll inputs
2025-11-05T12:48:58.757121Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1497: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-11-05T12:48:58.757132Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. DoExecuteImpl: 1
2025-11-05T12:48:58.757162Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:965: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. Input data push finished. Cookie: 2 Watermark: (empty maybe) Ack: 1 TakeInputChannelDataRequests: 1
2025-11-05T12:48:58.757182Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:738: TxId: ptqudt4ugje5uamtl6f2, task: 2. Sending channel data ack to channelId: 1, peer: [1:7569222452372665125:2399], from: [3:7569222454187170843:2157], freeSpace: 1000000, seqNo: 3, finished: 0
2025-11-05T12:48:58.757335Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: d032e364-233826fb-144ba989-a1391646 2025-11-05 12:48:58.757 DEBUG ydbd(pid=2844066, tid=0x00007B47068E5640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Run task: 2
2025-11-05T12:48:58.757424Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:510: SelfId: [3:7569222454187170845:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Pending 1 checkpoints to be sent
2025-11-05T12:48:58.757451Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1486: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. Poll inputs
2025-11-05T12:48:58.757462Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1497: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-11-05T12:48:58.757468Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-11-05T12:48:58.757480Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. update task runner stats
2025-11-05T12:48:58.757578Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 1 watermark injected: (empty maybe)
2025-11-05T12:48:58.757601Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:447: [ptqudt4ugje5uamtl6f2-0] Task: 2. [Checkpoint 1.3] Performing task checkpoint
2025-11-05T12:48:58.757609Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:822: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. Save state
2025-11-05T12:48:58.757619Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:474: [ptqudt4ugje5uamtl6f2-0] Task: 2. [Checkpoint 1.3] CA state saved
2025-11-05T12:48:58.757628Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:449: [ptqudt4ugje5uamtl6f2-0] Task: 2. [Checkpoint 1.3] Injecting checkpoint barrier to outputs
2025-11-05T12:48:58.757657Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:536: [ptqudt4ugje5uamtl6f2-0] Task: 2. [Checkpoint 1.3] Task checkpoint is done. Send to storage
2025-11-05T12:48:58.757669Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-05T12:48:58.757687Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:532: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. About to drain channelId: 2, hasPeer: 1, peerState:(freeSpace:67108864;inFlightBytes:0;inFlightCount:0;)
2025-11-05T12:48:58.757718Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:366: [ptqudt4ugje5uamtl6f2-0] [1:3] Got TEvSaveTaskState: task 2
2025-11-05T12:48:58.757813Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: d032e364-233826fb-144ba989-a1391646 2025-11-05 12:48:58.757 DEBUG ydbd(pid=2844066, tid=0x00007B47068E5640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Run task: 2
2025-11-05T12:48:58.757873Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:566: TxId: ptqudt4ugje5uamtl6f2, task: 2. SendChannelData, channelId: 2, peer: [1:7569222452372665121:2395], chunks: 0, bytes: 0, watermark: 0, checkpoint: 1, seqNo: 3, finished: 0
2025-11-05T12:48:58.757928Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudt4ugje5uamtl6f2, task: 2. no poll, channelId: 1, has inflight messages: [3], last with freeSpace: 1000000, current freeSpace: 1000000
2025-11-05T12:48:58.757957Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. update task runner stats
2025-11-05T12:48:58.758016Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-05T12:48:58.758029Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-05T12:48:58.758041Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:532: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. About to drain channelId: 2, hasPeer: 1, peerState:(freeSpace:67108864;inFlightBytes:96;inFlightCount:1;)
2025-11-05T12:48:58.758064Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1486: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. Poll inputs
2025-11-05T12:48:58.758071Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1501: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. Poll sources
2025-11-05T12:48:58.758077Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-11-05T12:48:58.758206Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: d032e364-233826fb-144ba989-a1391646 2025-11-05 12:48:58.758 DEBUG ydbd(pid=2844066, tid=0x00007B47068E5640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Run task: 2
2025-11-05T12:48:58.758263Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudt4ugje5uamtl6f2, task: 2. no poll, channelId: 1, has inflight messages: [3], last with freeSpace: 1000000, current freeSpace: 1000000
2025-11-05T12:48:58.758274Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. update task runner stats
2025-11-05T12:48:58.758311Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-05T12:48:58.758322Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-05T12:48:58.758334Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:532: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. About to drain channelId: 2, hasPeer: 1, peerState:(freeSpace:67108864;inFlightBytes:96;inFlightCount:1;)
2025-11-05T12:48:58.758360Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:179: TxId: ptqudt4ugje5uamtl6f2, task: 2. Received channel data ack for channelId: 2, seqNo: 3, lastSentSeqNo: 3, freeSpace: 67108864, early finish: 0
2025-11-05T12:48:58.758381Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:207: TxId: ptqudt4ugje5uamtl6f2, task: 2. PeerState, peerState:(freeSpace:67108864;inFlightBytes:0;inFlightCount:0;), sentSeqNo: 3, ackSeqNo: 3
2025-11-05T12:48:58.758388Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:220: TxId: ptqudt4ugje5uamtl6f2, task: 2. Resume compute actor
2025-11-05T12:48:58.758412Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1486: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. Poll inputs
2025-11-05T12:48:58.758417Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1501: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. Poll sources
2025-11-05T12:48:58.758423Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-11-05T12:48:58.758442Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudt4ugje5uamtl6f2, task: 2. no poll, channelId: 1, has inflight messages: [3], last with freeSpace: 1000000, current freeSpace: 1000000
2025-11-05T12:48:58.758544Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: d032e364-233826fb-144ba989-a1391646 2025-11-05 12:48:58.758 DEBUG ydbd(pid=2844066, tid=0x00007B47068E5640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Run task: 2
2025-11-05T12:48:58.758587Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. update task runner stats
2025-11-05T12:48:58.758635Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-05T12:48:58.758646Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-05T12:48:58.758659Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:532: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. About to drain channelId: 2, hasPeer: 1, peerState:(freeSpace:67108864;inFlightBytes:0;inFlightCount:0;)
2025-11-05T12:48:58.758687Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudt4ugje5uamtl6f2, task: 2. no poll, channelId: 1, has inflight messages: [3], last with freeSpace: 1000000, current freeSpace: 1000000
2025-11-05T12:48:58.769063Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:390: [ptqudt4ugje5uamtl6f2-0] [1:3] TEvSaveTaskState Apply: task: 2
2025-11-05T12:48:58.769087Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:405: [ptqudt4ugje5uamtl6f2-0] [1:3] Send TEvSaveTaskStateResult: task: 2
2025-11-05T12:48:58.990239Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: d032e364-233826fb-144ba989-a139164616, Host: ghrun-anwhr6cmha, Tenant: /default
2025-11-05T12:48:58.995862Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:318: TNodesManagerActor::NodesHealthCheck
2025-11-05T12:48:59.018950Z :FQ_CONTROL_PLANE_CONFIG TRACE: control_plane_config.cpp:192: LOADED TenantInfo: State NOT changed
2025-11-05T12:48:59.033167Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-05T12:48:59.033191Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-05T12:48:59.059584Z :YQL_NODES_MANAGER TRACE: nodes_manager.cpp:389: Send NodeInfo with size: 3 to DynamicNameserver
2025-11-05T12:48:59.257113Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:505: cloud.mock_cloud.yq.cpuPercent.count=0/10000 UPDATE from Peer 1
2025-11-05T12:48:59.468071Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:505: cloud.mock_cloud.yq.analyticsQuery.count=0/100 UPDATE from Peer 1
2025-11-05T12:48:59.468202Z :FQ_QUOTA_SERVICE TRACE: quota_manager.cpp:505: cloud.mock_cloud.yq.streamingQuery.count=1/100 UPDATE from Peer 1
2025-11-05T12:48:59.759423Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:129: TxId: ptqudt4ugje5uamtl6f2, task: 2. Received input for channelId: 1, seqNo: 4, size: 0, chunks: 0, watermark: 0, checkpoint: 1, finished: 0, from: [1:7569222452372665126:2399], expected seqNo: 4
2025-11-05T12:48:59.759457Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:609: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. took input
2025-11-05T12:48:59.759502Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:485: [ptqudt4ugje5uamtl6f2-0] Task: 2. [Checkpoint 1.4] Got checkpoint barrier from channel 1
2025-11-05T12:48:59.759550Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:395: SelfId: [3:7569222454187170845:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. No watermark 
2025-11-05T12:48:59.759566Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1486: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. Poll inputs
2025-11-05T12:48:59.759576Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1497: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-11-05T12:48:59.759586Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. DoExecuteImpl: 1
2025-11-05T12:48:59.759611Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:965: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. Input data push finished. Cookie: 3 Watermark: (empty maybe) Ack: 1 TakeInputChannelDataRequests: 1
2025-11-05T12:48:59.759632Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:738: TxId: ptqudt4ugje5uamtl6f2, task: 2. Sending channel data ack to channelId: 1, peer: [1:7569222452372665125:2399], from: [3:7569222454187170843:2157], freeSpace: 1000000, seqNo: 4, finished: 0
2025-11-05T12:48:59.759845Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: d032e364-233826fb-144ba989-a1391646 2025-11-05 12:48:59.759 DEBUG ydbd(pid=2844066, tid=0x00007B47068E5640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Run task: 2
2025-11-05T12:48:59.759918Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:510: SelfId: [3:7569222454187170845:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Pending 1 checkpoints to be sent
2025-11-05T12:48:59.759972Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1486: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. Poll inputs
2025-11-05T12:48:59.759984Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1497: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-11-05T12:48:59.759990Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-11-05T12:48:59.760003Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. update task runner stats
2025-11-05T12:48:59.760086Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 1 watermark injected: (empty maybe)
2025-11-05T12:48:59.760106Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:447: [ptqudt4ugje5uamtl6f2-0] Task: 2. [Checkpoint 1.4] Performing task checkpoint
2025-11-05T12:48:59.760114Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:822: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. Save state
2025-11-05T12:48:59.760125Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:474: [ptqudt4ugje5uamtl6f2-0] Task: 2. [Checkpoint 1.4] CA state saved
2025-11-05T12:48:59.760135Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:449: [ptqudt4ugje5uamtl6f2-0] Task: 2. [Checkpoint 1.4] Injecting checkpoint barrier to outputs
2025-11-05T12:48:59.760165Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:536: [ptqudt4ugje5uamtl6f2-0] Task: 2. [Checkpoint 1.4] Task checkpoint is done. Send to storage
2025-11-05T12:48:59.760178Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-05T12:48:59.760198Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:532: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. About to drain channelId: 2, hasPeer: 1, peerState:(freeSpace:67108864;inFlightBytes:0;inFlightCount:0;)
2025-11-05T12:48:59.760227Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:366: [ptqudt4ugje5uamtl6f2-0] [1:4] Got TEvSaveTaskState: task 2
2025-11-05T12:48:59.760327Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: d032e364-233826fb-144ba989-a1391646 2025-11-05 12:48:59.760 DEBUG ydbd(pid=2844066, tid=0x00007B47068E5640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Run task: 2
2025-11-05T12:48:59.760399Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:566: TxId: ptqudt4ugje5uamtl6f2, task: 2. SendChannelData, channelId: 2, peer: [1:7569222452372665121:2395], chunks: 0, bytes: 0, watermark: 0, checkpoint: 1, seqNo: 4, finished: 0
2025-11-05T12:48:59.760460Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudt4ugje5uamtl6f2, task: 2. no poll, channelId: 1, has inflight messages: [4], last with freeSpace: 1000000, current freeSpace: 1000000
2025-11-05T12:48:59.760481Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. update task runner stats
2025-11-05T12:48:59.760527Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-05T12:48:59.760539Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-05T12:48:59.760559Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:532: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. About to drain channelId: 2, hasPeer: 1, peerState:(freeSpace:67108864;inFlightBytes:96;inFlightCount:1;)
2025-11-05T12:48:59.760574Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1486: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. Poll inputs
2025-11-05T12:48:59.760581Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1501: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. Poll sources
2025-11-05T12:48:59.760588Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-11-05T12:48:59.760686Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: d032e364-233826fb-144ba989-a1391646 2025-11-05 12:48:59.760 DEBUG ydbd(pid=2844066, tid=0x00007B47068E5640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Run task: 2
2025-11-05T12:48:59.760743Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudt4ugje5uamtl6f2, task: 2. no poll, channelId: 1, has inflight messages: [4], last with freeSpace: 1000000, current freeSpace: 1000000
2025-11-05T12:48:59.760755Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. update task runner stats
2025-11-05T12:48:59.760797Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-05T12:48:59.760804Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-05T12:48:59.760817Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:532: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. About to drain channelId: 2, hasPeer: 1, peerState:(freeSpace:67108864;inFlightBytes:96;inFlightCount:1;)
2025-11-05T12:48:59.760843Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudt4ugje5uamtl6f2, task: 2. no poll, channelId: 1, has inflight messages: [4], last with freeSpace: 1000000, current freeSpace: 1000000
2025-11-05T12:48:59.760943Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:179: TxId: ptqudt4ugje5uamtl6f2, task: 2. Received channel data ack for channelId: 2, seqNo: 4, lastSentSeqNo: 4, freeSpace: 67108864, early finish: 0
2025-11-05T12:48:59.760970Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:207: TxId: ptqudt4ugje5uamtl6f2, task: 2. PeerState, peerState:(freeSpace:67108864;inFlightBytes:0;inFlightCount:0;), sentSeqNo: 4, ackSeqNo: 4
2025-11-05T12:48:59.760978Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:220: TxId: ptqudt4ugje5uamtl6f2, task: 2. Resume compute actor
2025-11-05T12:48:59.760992Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1486: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. Poll inputs
2025-11-05T12:48:59.761002Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1501: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. Poll sources
2025-11-05T12:48:59.761008Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-11-05T12:48:59.761104Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: d032e364-233826fb-144ba989-a1391646 2025-11-05 12:48:59.761 DEBUG ydbd(pid=2844066, tid=0x00007B47068E5640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Run task: 2
2025-11-05T12:48:59.761150Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. update task runner stats
2025-11-05T12:48:59.761207Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-05T12:48:59.761223Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-05T12:48:59.761237Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:532: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. About to drain channelId: 2, hasPeer: 1, peerState:(freeSpace:67108864;inFlightBytes:0;inFlightCount:0;)
2025-11-05T12:48:59.761276Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudt4ugje5uamtl6f2, task: 2. no poll, channelId: 1, has inflight messages: [4], last with freeSpace: 1000000, current freeSpace: 1000000
2025-11-05T12:48:59.773623Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:390: [ptqudt4ugje5uamtl6f2-0] [1:4] TEvSaveTaskState Apply: task: 2
2025-11-05T12:48:59.773645Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:405: [ptqudt4ugje5uamtl6f2-0] [1:4] Send TEvSaveTaskStateResult: task: 2
2025-11-05T12:48:59.989117Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:617: RowDispatcher: Send ping to [1:7569222396538089983:2138]
2025-11-05T12:48:59.989151Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1161: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-11-05T12:48:59.989761Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:623: RowDispatcher: NActors::TEvents::TEvPong
2025-11-05T12:48:59.990397Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: d032e364-233826fb-144ba989-a139164617, Host: ghrun-anwhr6cmha, Tenant: /default
2025-11-05T12:49:00.012124Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-05T12:49:00.012152Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-05T12:49:00.551590Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:451: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. Got TEvStateRequest from actor [1:7569222452372665123:2397] PingCookie: 1
2025-11-05T12:49:00.551625Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. update task runner stats
2025-11-05T12:49:00.761057Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:129: TxId: ptqudt4ugje5uamtl6f2, task: 2. Received input for channelId: 1, seqNo: 5, size: 0, chunks: 0, watermark: 0, checkpoint: 1, finished: 0, from: [1:7569222452372665126:2399], expected seqNo: 5
2025-11-05T12:49:00.761083Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:609: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. took input
2025-11-05T12:49:00.761117Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:485: [ptqudt4ugje5uamtl6f2-0] Task: 2. [Checkpoint 1.5] Got checkpoint barrier from channel 1
2025-11-05T12:49:00.761155Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:395: SelfId: [3:7569222454187170845:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. No watermark 
2025-11-05T12:49:00.761167Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1486: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. Poll inputs
2025-11-05T12:49:00.761172Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1497: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-11-05T12:49:00.761179Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. DoExecuteImpl: 1
2025-11-05T12:49:00.761196Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:965: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. Input data push finished. Cookie: 4 Watermark: (empty maybe) Ack: 1 TakeInputChannelDataRequests: 1
2025-11-05T12:49:00.761210Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:738: TxId: ptqudt4ugje5uamtl6f2, task: 2. Sending channel data ack to channelId: 1, peer: [1:7569222452372665125:2399], from: [3:7569222454187170843:2157], freeSpace: 1000000, seqNo: 5, finished: 0
2025-11-05T12:49:00.761401Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: d032e364-233826fb-144ba989-a1391646 2025-11-05 12:49:00.761 DEBUG ydbd(pid=2844066, tid=0x00007B47068E5640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Run task: 2
2025-11-05T12:49:00.761475Z :DQ_TASK_RUNNER TRACE: task_runner_actor_local.cpp:510: SelfId: [3:7569222454187170845:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Pending 1 checkpoints to be sent
2025-11-05T12:49:00.761523Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1486: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. Poll inputs
2025-11-05T12:49:00.761537Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1497: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. Skip polling sources because of pending checkpoint
2025-11-05T12:49:00.761543Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-11-05T12:49:00.761557Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. update task runner stats
2025-11-05T12:49:00.761632Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 1 watermark injected: (empty maybe)
2025-11-05T12:49:00.761648Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:447: [ptqudt4ugje5uamtl6f2-0] Task: 2. [Checkpoint 1.5] Performing task checkpoint
2025-11-05T12:49:00.761656Z :KQP_COMPUTE DEBUG: dq_async_compute_actor.cpp:822: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. Save state
2025-11-05T12:49:00.761666Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:474: [ptqudt4ugje5uamtl6f2-0] Task: 2. [Checkpoint 1.5] CA state saved
2025-11-05T12:49:00.761686Z :KQP_COMPUTE TRACE: dq_compute_actor_checkpoints.cpp:449: [ptqudt4ugje5uamtl6f2-0] Task: 2. [Checkpoint 1.5] Injecting checkpoint barrier to outputs
2025-11-05T12:49:00.761710Z :KQP_COMPUTE DEBUG: dq_compute_actor_checkpoints.cpp:536: [ptqudt4ugje5uamtl6f2-0] Task: 2. [Checkpoint 1.5] Task checkpoint is done. Send to storage
2025-11-05T12:49:00.761719Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-05T12:49:00.761737Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:532: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. About to drain channelId: 2, hasPeer: 1, peerState:(freeSpace:67108864;inFlightBytes:0;inFlightCount:0;)
2025-11-05T12:49:00.761762Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:366: [ptqudt4ugje5uamtl6f2-0] [1:5] Got TEvSaveTaskState: task 2
2025-11-05T12:49:00.761860Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: d032e364-233826fb-144ba989-a1391646 2025-11-05 12:49:00.761 DEBUG ydbd(pid=2844066, tid=0x00007B47068E5640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Run task: 2
2025-11-05T12:49:00.761942Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:566: TxId: ptqudt4ugje5uamtl6f2, task: 2. SendChannelData, channelId: 2, peer: [1:7569222452372665121:2395], chunks: 0, bytes: 0, watermark: 0, checkpoint: 1, seqNo: 5, finished: 0
2025-11-05T12:49:00.761991Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudt4ugje5uamtl6f2, task: 2. no poll, channelId: 1, has inflight messages: [5], last with freeSpace: 1000000, current freeSpace: 1000000
2025-11-05T12:49:00.762006Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. update task runner stats
2025-11-05T12:49:00.762062Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-05T12:49:00.762074Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-05T12:49:00.762086Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:532: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. About to drain channelId: 2, hasPeer: 1, peerState:(freeSpace:67108864;inFlightBytes:96;inFlightCount:1;)
2025-11-05T12:49:00.762105Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1486: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. Poll inputs
2025-11-05T12:49:00.762111Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1501: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. Poll sources
2025-11-05T12:49:00.762116Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-11-05T12:49:00.762206Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: d032e364-233826fb-144ba989-a1391646 2025-11-05 12:49:00.762 DEBUG ydbd(pid=2844066, tid=0x00007B47068E5640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Run task: 2
2025-11-05T12:49:00.762259Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudt4ugje5uamtl6f2, task: 2. no poll, channelId: 1, has inflight messages: [5], last with freeSpace: 1000000, current freeSpace: 1000000
2025-11-05T12:49:00.762271Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. update task runner stats
2025-11-05T12:49:00.762312Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-05T12:49:00.762323Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-05T12:49:00.762334Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:532: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. About to drain channelId: 2, hasPeer: 1, peerState:(freeSpace:67108864;inFlightBytes:96;inFlightCount:1;)
2025-11-05T12:49:00.762360Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudt4ugje5uamtl6f2, task: 2. no poll, channelId: 1, has inflight messages: [5], last with freeSpace: 1000000, current freeSpace: 1000000
2025-11-05T12:49:00.762498Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:179: TxId: ptqudt4ugje5uamtl6f2, task: 2. Received channel data ack for channelId: 2, seqNo: 5, lastSentSeqNo: 5, freeSpace: 67108864, early finish: 0
2025-11-05T12:49:00.762520Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:207: TxId: ptqudt4ugje5uamtl6f2, task: 2. PeerState, peerState:(freeSpace:67108864;inFlightBytes:0;inFlightCount:0;), sentSeqNo: 5, ackSeqNo: 5
2025-11-05T12:49:00.762527Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:220: TxId: ptqudt4ugje5uamtl6f2, task: 2. Resume compute actor
2025-11-05T12:49:00.762538Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1486: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. Poll inputs
2025-11-05T12:49:00.762543Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:1501: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. Poll sources
2025-11-05T12:49:00.762554Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:694: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. DoExecuteImpl: 0
2025-11-05T12:49:00.762684Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: d032e364-233826fb-144ba989-a1391646 2025-11-05 12:49:00.762 DEBUG ydbd(pid=2844066, tid=0x00007B47068E5640) [DQ] tasks_runner_local.cpp:267: {TODO/2} Run task: 2
2025-11-05T12:49:00.762742Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:491: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. update task runner stats
2025-11-05T12:49:00.762801Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:758: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. Resume execution, run status: PendingInput checkpoint: 0 watermark injected: (empty maybe)
2025-11-05T12:49:00.762814Z :KQP_COMPUTE TRACE: dq_compute_actor_impl.h:393: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. ProcessOutputsState.Inflight: 0
2025-11-05T12:49:00.762828Z :KQP_COMPUTE TRACE: dq_async_compute_actor.cpp:532: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. About to drain channelId: 2, hasPeer: 1, peerState:(freeSpace:67108864;inFlightBytes:0;inFlightCount:0;)
2025-11-05T12:49:00.762897Z :KQP_COMPUTE TRACE: dq_compute_actor_channels.cpp:625: TxId: ptqudt4ugje5uamtl6f2, task: 2. no poll, channelId: 1, has inflight messages: [5], last with freeSpace: 1000000, current freeSpace: 1000000
2025-11-05T12:49:00.774056Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:390: [ptqudt4ugje5uamtl6f2-0] [1:5] TEvSaveTaskState Apply: task: 2
2025-11-05T12:49:00.774080Z :STREAMS_STORAGE_SERVICE DEBUG: storage_proxy.cpp:405: [ptqudt4ugje5uamtl6f2-0] [1:5] Send TEvSaveTaskStateResult: task: 2
2025-11-05T12:49:00.990616Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: d032e364-233826fb-144ba989-a139164618, Host: ghrun-anwhr6cmha, Tenant: /default
2025-11-05T12:49:01.024342Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-05T12:49:01.024373Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-05T12:49:01.515225Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: d032e364-233826fb-144ba989-a1391646 2025-11-05 12:49:01.515 DEBUG ydbd(pid=2844066, tid=0x00007B47068E5640) [DQ] local_worker_manager.cpp:416: TEvFreeWorkersNotify 562954248388609
2025-11-05T12:49:01.515369Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: d032e364-233826fb-144ba989-a1391646 2025-11-05 12:49:01.515 DEBUG ydbd(pid=2844066, tid=0x00007B47068E5640) [DQ] local_worker_manager.cpp:440: Free Group 562954248388609
2025-11-05T12:49:01.515989Z :KQP_COMPUTE ERROR: dq_compute_actor_impl.h:1210: SelfId: [3:7569222454187170843:2157], TxId: ptqudt4ugje5uamtl6f2, task: 2. Ctx: {}. Handle abort execution event from: [3:7569222402647563138:2068], status: UNAVAILABLE, reason: { <main>: Error: Aborted by LWM }
2025-11-05T12:49:01.516156Z :KQP_COMPUTE DEBUG: dq_compute_actor_channels.cpp:494: TxId: ptqudt4ugje5uamtl6f2, task: 2. pass away
2025-11-05T12:49:01.989258Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:617: RowDispatcher: Send ping to [1:7569222396538089983:2138]
2025-11-05T12:49:01.989301Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:1161: RowDispatcher: TEvPrivate::TEvSendStatistic
2025-11-05T12:49:01.989909Z :FQ_ROW_DISPATCHER TRACE: row_dispatcher.cpp:623: RowDispatcher: NActors::TEvents::TEvPong
2025-11-05T12:49:01.990803Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: d032e364-233826fb-144ba989-a139164619, Host: ghrun-anwhr6cmha, Tenant: /default
2025-11-05T12:49:02.004067Z :FQ_CONTROL_PLANE_CONFIG TRACE: control_plane_config.cpp:192: LOADED TenantInfo: State NOT changed
2025-11-05T12:49:02.012867Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-05T12:49:02.012891Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-05T12:49:02.990958Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:329: Request Private::GetTask, Owner: d032e364-233826fb-144ba989-a139164620, Host: ghrun-anwhr6cmha, Tenant: /default
2025-11-05T12:49:03.012977Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:254: Got GetTask response from PrivateApi
2025-11-05T12:49:03.013011Z :FQ_PENDING_FETCHER TRACE: pending_fetcher.cpp:266: Tasks count: 0
2025-11-05T12:49:03.212515Z :INTERCONNECT_NETWORK NOTICE: interconnect_tcp_input_session.cpp:712: [3 <-> 4] connection closed by peer
2025-11-05T12:49:03.246928Z :INTERCONNECT_NETWORK NOTICE: interconnect_tcp_input_session.cpp:712: [3 <-> 2] connection closed by peer
2025-11-05T12:49:03.247145Z :INTERCONNECT_NETWORK NOTICE: interconnect_tcp_input_session.cpp:712: [3 <-> 1] connection closed by peer
2025-11-05T12:49:03.248115Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: d032e364-233826fb-144ba989-a1391646 2025-11-05 12:49:03.247 DEBUG ydbd(pid=2844066, tid=0x00007B47068E5640) [DQ] local_worker_manager.cpp:257: Disconnected 1
2025-11-05T12:49:03.248292Z :YQL_PROXY DEBUG: log.cpp:64: SessionId: d032e364-233826fb-144ba989-a1391646 2025-11-05 12:49:03.248 DEBUG ydbd(pid=2844066, tid=0x00007B47068E5640) [DQ] local_worker_manager.cpp:228: Deallocate 1
