Skip to content

Commit d569f4b

Browse files
authored
YQ-3557 fixed unit test KqpLimits::ComputeActorMemoryAllocationFailureQueryService with resource pools (#7873)
1 parent 8796c8a commit d569f4b

File tree

2 files changed

+5
-4
lines changed

2 files changed

+5
-4
lines changed

ydb/core/kqp/rm_service/kqp_rm_service.cpp

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -299,10 +299,9 @@ class TKqpResourceManager : public IKqpResourceManager {
299299
auto it = MemoryNamedPools.find(tx->MakePoolId());
300300
if (it != MemoryNamedPools.end()) {
301301
it->second->Release(resources.Memory);
302-
}
303-
304-
if (it->second->GetUsed() == 0) {
305-
MemoryNamedPools.erase(it);
302+
if (it->second->GetUsed() == 0) {
303+
MemoryNamedPools.erase(it);
304+
}
306305
}
307306
}
308307
}

ydb/core/kqp/ut/query/kqp_limits_ut.cpp

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -192,6 +192,8 @@ Y_UNIT_TEST_SUITE(KqpLimits) {
192192

193193
app.MutableResourceBrokerConfig()->CopyFrom(MakeResourceBrokerTestConfig(4));
194194

195+
app.MutableFeatureFlags()->SetEnableResourcePools(true);
196+
195197
TKikimrRunner kikimr(app);
196198
CreateLargeTable(kikimr, 0, 0, 0);
197199

0 commit comments

Comments
 (0)