This is an automated email from the ASF dual-hosted git repository. xingtanzjr pushed a commit to branch xingtanzjr/refine_cross_selection in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 35a52849db1d6c9a79acabe7543036efb1e33798 Author: Jinrui.Zhang <[email protected]> AuthorDate: Thu Dec 22 16:08:21 2022 +0800 spotless --- .../engine/compaction/cross/rewrite/CrossCompactionTaskResource.java | 3 ++- .../engine/compaction/cross/rewrite/CrossSpaceCompactionCandidate.java | 2 +- 2 files changed, 3 insertions(+), 2 deletions(-) diff --git a/server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/rewrite/CrossCompactionTaskResource.java b/server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/rewrite/CrossCompactionTaskResource.java index 81e02b1ba7..129b7cb791 100644 --- a/server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/rewrite/CrossCompactionTaskResource.java +++ b/server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/rewrite/CrossCompactionTaskResource.java @@ -46,7 +46,8 @@ public class CrossCompactionTaskResource { return seqFiles; } - // we need to unsure the files in seqFiles is ordered by the time range, that is, it should keep the + // we need to unsure the files in seqFiles is ordered by the time range, that is, it should keep + // the // order from candidates' seq file list. public void sortSeqFiles(List<TsFileResource> seqFilesCandidates) { Map<TsFileResource, Boolean> selectedFileMap = new HashMap<>(); diff --git a/server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/rewrite/CrossSpaceCompactionCandidate.java b/server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/rewrite/CrossSpaceCompactionCandidate.java index d578a7934c..d729f92cca 100644 --- a/server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/rewrite/CrossSpaceCompactionCandidate.java +++ b/server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/rewrite/CrossSpaceCompactionCandidate.java @@ -115,7 +115,7 @@ public class CrossSpaceCompactionCandidate { // TaskResource unseqFile.markAsSelected(); nextSplit = new CrossCompactionTaskResourceSplit(unseqFile, ret); - nextUnseqFileIndex ++; + nextUnseqFileIndex++; return true; }
