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 {