You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ma...@apache.org on 2022/07/13 14:38:04 UTC
[iotdb] branch IOTDB-3164 updated: reset reject when release memory
This is an automated email from the ASF dual-hosted git repository.
marklau99 pushed a commit to branch IOTDB-3164
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/IOTDB-3164 by this push:
new eed4168624 reset reject when release memory
eed4168624 is described below
commit eed4168624b942482ba2f0c2e08ebd00a6a139e2
Author: Liu Xuxin <li...@outlook.com>
AuthorDate: Wed Jul 13 22:37:58 2022 +0800
reset reject when release memory
---
.../org/apache/iotdb/db/rescon/memory/WriteMemoryController.java | 8 ++++++++
1 file changed, 8 insertions(+)
diff --git a/server/src/main/java/org/apache/iotdb/db/rescon/memory/WriteMemoryController.java b/server/src/main/java/org/apache/iotdb/db/rescon/memory/WriteMemoryController.java
index 84dfabf760..45315f4479 100644
--- a/server/src/main/java/org/apache/iotdb/db/rescon/memory/WriteMemoryController.java
+++ b/server/src/main/java/org/apache/iotdb/db/rescon/memory/WriteMemoryController.java
@@ -65,6 +65,14 @@ public class WriteMemoryController extends MemoryController<TsFileProcessor> {
return success;
}
+ @Override
+ public void releaseMemory(long size) {
+ super.releaseMemory(size);
+ if (memoryUsage.get() < REJECT_THRESHOLD) {
+ rejected = false;
+ }
+ }
+
public boolean isRejected() {
return rejected;
}