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

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


The following commit(s) were added to refs/heads/master by this push:
     new 2fcc203c0a fix cross compaction logs (#6504)
2fcc203c0a is described below

commit 2fcc203c0a64b90ee8229f0a62da26e59f401add
Author: 周沛辰 <[email protected]>
AuthorDate: Wed Jun 29 14:55:29 2022 +0800

    fix cross compaction logs (#6504)
    
    [IOTDB-3690]fix cross compaction logs
---
 .../compaction/cross/rewrite/CrossSpaceCompactionResource.java    | 8 --------
 .../cross/rewrite/RewriteCrossSpaceCompactionSelector.java        | 4 ++--
 2 files changed, 2 insertions(+), 10 deletions(-)

diff --git 
a/server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/rewrite/CrossSpaceCompactionResource.java
 
b/server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/rewrite/CrossSpaceCompactionResource.java
index a99133636a..ac8cbd75f0 100644
--- 
a/server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/rewrite/CrossSpaceCompactionResource.java
+++ 
b/server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/rewrite/CrossSpaceCompactionResource.java
@@ -75,15 +75,7 @@ public class CrossSpaceCompactionResource {
     return seqFiles;
   }
 
-  public void setSeqFiles(List<TsFileResource> seqFiles) {
-    this.seqFiles = seqFiles;
-  }
-
   public List<TsFileResource> getUnseqFiles() {
     return unseqFiles;
   }
-
-  public void setUnseqFiles(List<TsFileResource> unseqFiles) {
-    this.unseqFiles = unseqFiles;
-  }
 }
diff --git 
a/server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/rewrite/RewriteCrossSpaceCompactionSelector.java
 
b/server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/rewrite/RewriteCrossSpaceCompactionSelector.java
index efae44c1a5..c135da5d79 100644
--- 
a/server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/rewrite/RewriteCrossSpaceCompactionSelector.java
+++ 
b/server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/rewrite/RewriteCrossSpaceCompactionSelector.java
@@ -114,8 +114,8 @@ public class RewriteCrossSpaceCompactionSelector implements 
ICrossSpaceSelector
         LOGGER.info(
             "{} [Compaction] submit a task with {} sequence file and {} unseq 
files",
             logicalStorageGroupName + "-" + dataRegionId,
-            compactionResource.getSeqFiles().size(),
-            compactionResource.getUnseqFiles().size());
+            mergeFiles[0].size(),
+            mergeFiles[1].size());
         return Collections.singletonList(new Pair<>(mergeFiles[0], 
mergeFiles[1]));
       }
 

Reply via email to