You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by sh...@apache.org on 2025/11/14 07:17:11 UTC
(iotdb) branch reduceErrorLogWhenStoppingCompactionService updated: fix writer for compaction tests
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 <s1...@gmail.com>
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 {