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]));
}