[iotdb] branch dynamic_compaction updated: hitter modify

[ej...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

ejttianyu pushed a commit to branch dynamic_compaction
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/dynamic_compaction by this push:
     new 5215111  hitter modify
5215111 is described below

commit 52151110ea7b661944a86d3e75b5ff24f5cc74b1
Author: EJTTianyu <16...@qq.com>
AuthorDate: Wed May 12 21:49:46 2021 +0800

    hitter modify
---
 .../compaction/level/hitter/HitterLevelCompactionTsFileManagement.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/server/src/main/java/org/apache/iotdb/db/engine/compaction/level/hitter/HitterLevelCompactionTsFileManagement.java b/server/src/main/java/org/apache/iotdb/db/engine/compaction/level/hitter/HitterLevelCompactionTsFileManagement.java
index 59192e1..7787c77 100644
--- a/server/src/main/java/org/apache/iotdb/db/engine/compaction/level/hitter/HitterLevelCompactionTsFileManagement.java
+++ b/server/src/main/java/org/apache/iotdb/db/engine/compaction/level/hitter/HitterLevelCompactionTsFileManagement.java
@@ -223,7 +223,7 @@ public class HitterLevelCompactionTsFileManagement extends LevelCompactionTsFile
     try {
       logger.info("{} start to filter compaction condition", storageGroupName);
       for (int i = 0; i < seqLevelNum - 1; i++) {
-        if (mergeResources.get(i).size() >= firstLevelNum * Math.pow(sizeRatio, i)) {
+        if (mergeResources.get(i).size() >= seqFileNumInEachLevel) {
           List<TsFileResource> toMergeTsFiles = mergeResources.get(i);
           logger.info("{} [Hitter Compaction] merge level-{}'s {} TsFiles to next level",
               storageGroupName, i, toMergeTsFiles.size());