This is an automated email from the ASF dual-hosted git repository. ejttianyu pushed a commit to branch merge_fix_OOM in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git
commit c827f515c580bef30242eda1ca7e3c691539f8d5 Author: EJTTianyu <[email protected]> AuthorDate: Wed May 20 20:18:45 2020 +0800 fix OOM for merge --- .../java/org/apache/iotdb/db/engine/merge/manage/MergeResource.java | 4 ++++ .../org/apache/iotdb/db/engine/merge/task/MergeMultiChunkTask.java | 1 + 2 files changed, 5 insertions(+) diff --git a/server/src/main/java/org/apache/iotdb/db/engine/merge/manage/MergeResource.java b/server/src/main/java/org/apache/iotdb/db/engine/merge/manage/MergeResource.java index 492e6f3..5f932bf 100644 --- a/server/src/main/java/org/apache/iotdb/db/engine/merge/manage/MergeResource.java +++ b/server/src/main/java/org/apache/iotdb/db/engine/merge/manage/MergeResource.java @@ -255,4 +255,8 @@ public class MergeResource { this.measurementSchemaMap = measurementSchemaMap; } + public void clearChunkWriterCache() { + this.chunkWriterCache.clear(); + } + } diff --git a/server/src/main/java/org/apache/iotdb/db/engine/merge/task/MergeMultiChunkTask.java b/server/src/main/java/org/apache/iotdb/db/engine/merge/task/MergeMultiChunkTask.java index 286b229..f63a5cc 100644 --- a/server/src/main/java/org/apache/iotdb/db/engine/merge/task/MergeMultiChunkTask.java +++ b/server/src/main/java/org/apache/iotdb/db/engine/merge/task/MergeMultiChunkTask.java @@ -109,6 +109,7 @@ class MergeMultiChunkTask { while (pathSelector.hasNext()) { currMergingPaths = pathSelector.next(); mergePaths(); + resource.clearChunkWriterCache(); mergedSeriesCnt += currMergingPaths.size(); logMergeProgress(); }
