This is an automated email from the ASF dual-hosted git repository. ejttianyu pushed a commit to branch hitter_compaction_mto_master in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 38565cbb145fc407f6a0d586f4fdff567561f3e6 Author: EJTTianyu <[email protected]> AuthorDate: Tue Apr 27 20:57:22 2021 +0800 fix writeByDeserializeMerge rate limiter --- .../apache/iotdb/db/engine/compaction/utils/CompactionUtils.java | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/server/src/main/java/org/apache/iotdb/db/engine/compaction/utils/CompactionUtils.java b/server/src/main/java/org/apache/iotdb/db/engine/compaction/utils/CompactionUtils.java index 9bc3ce2..85ee1ce 100644 --- a/server/src/main/java/org/apache/iotdb/db/engine/compaction/utils/CompactionUtils.java +++ b/server/src/main/java/org/apache/iotdb/db/engine/compaction/utils/CompactionUtils.java @@ -186,7 +186,13 @@ public class CompactionUtils { targetResource.updateEndTime(device, timeValuePair.getTimestamp()); } // wait for limit write - MergeManager.mergeRateLimiterAcquire(compactionRateLimiter, chunkWriter.getCurrentChunkSize()); + if (chunkWriter.getCurrentChunkSize() == 0) { + MergeManager + .mergeRateLimiterAcquire(compactionRateLimiter, chunkWriter.estimateMaxSeriesMemSize()); + } else { + MergeManager + .mergeRateLimiterAcquire(compactionRateLimiter, chunkWriter.getCurrentChunkSize()); + } chunkWriter.writeToFileWriter(writer); }
