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

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


The following commit(s) were added to 
refs/heads/reduceErrorLogWhenStoppingCompactionService by this push:
     new 304b7b44571 fix writer for compaction tests
304b7b44571 is described below

commit 304b7b445710ae7d74cf04dc5c9cd69e60193dd6
Author: shuwenwei <[email protected]>
AuthorDate: Fri Nov 14 15:16:57 2025 +0800

    fix writer for compaction tests
---
 .../dataregion/compaction/utils/CompactionTestFileWriter.java       | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git 
a/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/utils/CompactionTestFileWriter.java
 
b/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/utils/CompactionTestFileWriter.java
index fe88adfac68..42254428ef8 100644
--- 
a/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/utils/CompactionTestFileWriter.java
+++ 
b/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/utils/CompactionTestFileWriter.java
@@ -19,6 +19,8 @@
 
 package org.apache.iotdb.db.storageengine.dataregion.compaction.utils;
 
+import 
org.apache.iotdb.db.storageengine.dataregion.compaction.io.CompactionTsFileWriter;
+import 
org.apache.iotdb.db.storageengine.dataregion.compaction.schedule.constant.CompactionType;
 import org.apache.iotdb.db.storageengine.dataregion.tsfile.TsFileResource;
 
 import org.apache.tsfile.enums.TSDataType;
@@ -49,7 +51,9 @@ public class CompactionTestFileWriter implements Closeable {
 
   public CompactionTestFileWriter(TsFileResource emptyFile) throws IOException 
{
     this.resource = emptyFile;
-    fileWriter = new TsFileIOWriter(emptyFile.getTsFile());
+    fileWriter =
+        new CompactionTsFileWriter(
+            emptyFile.getTsFile(), 1024 * 1024 * 1024, 
CompactionType.INNER_SEQ_COMPACTION);
   }
 
   public IDeviceID startChunkGroup(String deviceNameWithoutParentPath) throws 
IOException {

Reply via email to