diff options
| author | ivanmorozov <ivanmorozov@yandex-team.com> | 2023-01-09 17:46:57 +0300 |
|---|---|---|
| committer | ivanmorozov <ivanmorozov@yandex-team.com> | 2023-01-09 17:46:57 +0300 |
| commit | 953cb957602ebf288f51ee3a580f78e000c8228a (patch) | |
| tree | 41451a62fe0383d1ca00ca608ece04aa0c921d99 | |
| parent | 2eb12d53403f4761132b4c7a2de6510ee0caf934 (diff) | |
| download | ydb-953cb957602ebf288f51ee3a580f78e000c8228a.tar.gz | |
temporary problem reduce
| -rw-r--r-- | ydb/core/kqp/node_service/kqp_node_service.cpp | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/ydb/core/kqp/node_service/kqp_node_service.cpp b/ydb/core/kqp/node_service/kqp_node_service.cpp index 62e171299fd..3e4e92632d3 100644 --- a/ydb/core/kqp/node_service/kqp_node_service.cpp +++ b/ydb/core/kqp/node_service/kqp_node_service.cpp @@ -178,7 +178,10 @@ private: NRm::TKqpResourcesRequest resourcesRequest; resourcesRequest.ExecutionUnits = 1; resourcesRequest.MemoryPool = NRm::EKqpMemoryPool::ScanQuery; - resourcesRequest.Memory = task.second.Memory; + + // !!!!!!!!!!!!!!!!!!!!! + // we have to allocate memory instead of reserve only. currently, this memory will not be used for request processing. + resourcesRequest.Memory = Min<double>(task.second.Memory, 1 << 19) /* 512kb limit for check that memory exists for processing with minimal requirements */; NRm::TKqpNotEnoughResources resourcesResponse; if (!ResourceManager()->AllocateResources(txId, task.first, resourcesRequest, &resourcesResponse)) { |