(iotdb) branch master updated: skip insertion compaction disk space check (#11959)

[haonan]

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

haonan 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 14162173e73 skip insertion compaction disk space check (#11959)
14162173e73 is described below

commit 14162173e73b0e1ba83536c7b64168d9c0f9f846
Author: shuwenwei <55970239+shuwen...@users.noreply.github.com>
AuthorDate: Tue Jan 23 17:53:16 2024 +0800

    skip insertion compaction disk space check (#11959)
---
 .../task/InsertionCrossSpaceCompactionTask.java    |  5 +++++
 .../InsertionCrossCompactionTaskResource.java      | 25 ++++++++++++++++++++++
 2 files changed, 30 insertions(+)

diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/task/InsertionCrossSpaceCompactionTask.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/task/InsertionCrossSpaceCompactionTask.java
index dcf54dff806..f4662951705 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/task/InsertionCrossSpaceCompactionTask.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/task/InsertionCrossSpaceCompactionTask.java
@@ -327,6 +327,11 @@ public class InsertionCrossSpaceCompactionTask extends 
AbstractCompactionTask {
     return false;
   }
 
+  @Override
+  public boolean isDiskSpaceCheckPassed() {
+    return true;
+  }
+
   @Override
   public long getEstimatedMemoryCost() {
     return 0;
diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/selector/utils/InsertionCrossCompactionTaskResource.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/selector/utils/InsertionCrossCompactionTaskResource.java
index 561df5079e3..2a9d51b191e 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/selector/utils/InsertionCrossCompactionTaskResource.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/selector/utils/InsertionCrossCompactionTaskResource.java
@@ -21,6 +21,9 @@ package 
org.apache.iotdb.db.storageengine.dataregion.compaction.selector.utils;
 
 import org.apache.iotdb.db.storageengine.dataregion.tsfile.TsFileResource;
 
+import java.util.ArrayList;
+import java.util.List;
+
 public class InsertionCrossCompactionTaskResource extends 
CrossCompactionTaskResource {
   public TsFileResource prevSeqFile = null;
   public TsFileResource nextSeqFile = null;
@@ -37,6 +40,28 @@ public class InsertionCrossCompactionTaskResource extends 
CrossCompactionTaskRes
     return super.getTotalSeqFileSize();
   }
 
+  @Override
+  public List<TsFileResource> getSeqFiles() {
+    List<TsFileResource> seqFiles = new ArrayList<>(2);
+    if (prevSeqFile != null) {
+      seqFiles.add(prevSeqFile);
+    }
+    if (nextSeqFile != null) {
+      seqFiles.add(nextSeqFile);
+    }
+    return seqFiles;
+  }
+
+  @Override
+  public List<TsFileResource> getUnseqFiles() {
+    List<TsFileResource> unseqFiles = new ArrayList<>(2);
+    unseqFiles.add(firstUnSeqFileInParitition);
+    if (toInsertUnSeqFile != firstUnSeqFileInParitition) {
+      unseqFiles.add(toInsertUnSeqFile);
+    }
+    return unseqFiles;
+  }
+
   @Override
   public boolean isValid() {
     return toInsertUnSeqFile != null;