This is an automated email from the ASF dual-hosted git repository. jt2594838 pushed a commit to branch add_flat_device in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 11e90b37e9c74e90c52ea16161121f72d009c029 Author: Tian Jiang <[email protected]> AuthorDate: Tue Sep 22 15:19:48 2026 +0800 tmp --- .../compaction/execute/utils/FlatDeviceCompactionUtils.java | 6 +----- .../execute/utils/writer/ReadPointCrossCompactionWriter.java | 6 +----- 2 files changed, 2 insertions(+), 10 deletions(-) diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/utils/FlatDeviceCompactionUtils.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/utils/FlatDeviceCompactionUtils.java index 791298d3c46..f73486b434b 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/utils/FlatDeviceCompactionUtils.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/utils/FlatDeviceCompactionUtils.java @@ -102,11 +102,7 @@ public class FlatDeviceCompactionUtils { } public static void updateResource( - TsFileResource resource, - IDeviceID physicalDevice, - TsBlock block, - int start, - int count) { + TsFileResource resource, IDeviceID physicalDevice, TsBlock block, int start, int count) { for (int row = start; row < start + count; row++) { resource.updateTableStartTime(physicalDevice.getTableName(), block.getTimeByIndex(row)); resource.updateTableEndTime(physicalDevice.getTableName(), block.getTimeByIndex(row)); diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/utils/writer/ReadPointCrossCompactionWriter.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/utils/writer/ReadPointCrossCompactionWriter.java index b7e2175461d..8982c528395 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/utils/writer/ReadPointCrossCompactionWriter.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/utils/writer/ReadPointCrossCompactionWriter.java @@ -147,11 +147,7 @@ public class ReadPointCrossCompactionWriter extends AbstractCrossCompactionWrite .computeIfAbsent(writer, key -> new HashMap<>()) .merge(deviceId.getTableName(), (long) (end - start), Long::sum); FlatDeviceCompactionUtils.updateResource( - targetResources.get(targetIndex), - deviceId, - block, - start, - end - start); + targetResources.get(targetIndex), deviceId, block, start, end - start); checkChunkSizeAndMayOpenANewChunk(targetFileWriters.get(targetIndex), chunkWriter, subTaskId); isDeviceExistedInTargetFiles[targetIndex] = true; isEmptyFile[targetIndex] = false;
