skip insertion compaction disk space check (apache#11959)

SzyWilliam · Nov 22, 2024 · 813568e · 813568e
1 parent 6eb412d
commit 813568e
Show file tree

Hide file tree

Showing 2 changed files with 30 additions and 0 deletions.
diff --git a/...b/storageengine/dataregion/compaction/execute/task/InsertionCrossSpaceCompactionTask.java b/...b/storageengine/dataregion/compaction/execute/task/InsertionCrossSpaceCompactionTask.java
@@ -327,6 +327,11 @@ public boolean equalsOtherTask(AbstractCompactionTask otherTask) {
     return false;
   }
 
+  @Override
+  public boolean isDiskSpaceCheckPassed() {
+    return true;
+  }
+
   @Override
   public long getEstimatedMemoryCost() {
     return 0;

diff --git a/...rageengine/dataregion/compaction/selector/utils/InsertionCrossCompactionTaskResource.java b/...rageengine/dataregion/compaction/selector/utils/InsertionCrossCompactionTaskResource.java
@@ -21,6 +21,9 @@
 
 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 float getTotalSeqFileSize() {
     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;