We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
2 parents c8da1b6 + 69333a8 commit fb88021Copy full SHA for fb88021
ydb/core/kqp/rm_service/kqp_rm_service.cpp
@@ -435,9 +435,11 @@ class TKqpResourceManager : public IKqpResourceManager {
435
Y_DEBUG_ABORT_UNLESS(Counters->RmMemory->Val() >= 0);
436
} // with_lock (txBucket.Lock)
437
438
- with_lock (Lock) {
439
- ScanQueryMemoryResource.Release(releaseScanQueryMemory);
440
- } // with_lock (Lock)
+ if (releaseScanQueryMemory > 0) {
+ with_lock (Lock) {
+ ScanQueryMemoryResource.Release(releaseScanQueryMemory);
441
+ } // with_lock (Lock)
442
+ }
443
444
LOG_AS_D("TxId: " << txId << ", taskId: " << taskId << ". Released resources, "
445
<< "ScanQueryMemory: " << releaseScanQueryMemory << ", "
0 commit comments