[iotdb] branch dynamic_compaction updated: fix level compaction select

[ejttianyu]

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 73d5bf9  fix level compaction select
73d5bf9 is described below

commit 73d5bf941b1506f7fe86207c6da0a4a5d3a1d367
Author: EJTTianyu <1653503...@qq.com>
AuthorDate: Wed May 19 23:41:30 2021 +0800

    fix level compaction select
---
 .../db/engine/compaction/level/LevelCompactionTsFileManagement.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/server/src/main/java/org/apache/iotdb/db/engine/compaction/level/LevelCompactionTsFileManagement.java
 
b/server/src/main/java/org/apache/iotdb/db/engine/compaction/level/LevelCompactionTsFileManagement.java
index 9e78cb4..c09d32c 100644
--- 
a/server/src/main/java/org/apache/iotdb/db/engine/compaction/level/LevelCompactionTsFileManagement.java
+++ 
b/server/src/main/java/org/apache/iotdb/db/engine/compaction/level/LevelCompactionTsFileManagement.java
@@ -465,7 +465,7 @@ public class LevelCompactionTsFileManagement extends 
TsFileManagement {
       for (TsFileResource tsFileResource : levelRawTsFileResources) {
         if (tsFileResource.isClosed()) {
           forkedLevelTsFileResources.add(tsFileResource);
-          if (forkedLevelTsFileResources.size() > currFileNumInEachLevel) {
+          if (forkedLevelTsFileResources.size() >= currFileNumInEachLevel) {
             break;
           }
         }