This is an automated email from the ASF dual-hosted git repository. jackietien pushed a commit to branch force_ci/object_type in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 533aa6a6053ce7bde7b9b4c020dc703d69077c1c Author: JackieTien97 <[email protected]> AuthorDate: Mon Dec 8 15:54:10 2025 +0800 Fix compile error --- .../compaction/execute/utils/MultiTsFileDeviceIterator.java | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/utils/MultiTsFileDeviceIterator.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/utils/MultiTsFileDeviceIterator.java index 75900689ca2..7b99541c006 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/utils/MultiTsFileDeviceIterator.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/utils/MultiTsFileDeviceIterator.java @@ -175,7 +175,7 @@ public class MultiTsFileDeviceIterator implements AutoCloseable { } } - public boolean hasNextDevice() { + public boolean hasNextDevice() throws IOException { boolean hasNext = false; for (TsFileDeviceIterator iterator : deviceIteratorMap.values()) { hasNext = @@ -196,7 +196,7 @@ public class MultiTsFileDeviceIterator implements AutoCloseable { * @return Pair of device full path and whether this device is aligned */ @SuppressWarnings({"squid:S135", "java:S2259"}) - public Pair<IDeviceID, Boolean> nextDevice() throws IllegalPathException { + public Pair<IDeviceID, Boolean> nextDevice() throws IllegalPathException, IOException { List<TsFileResource> toBeRemovedResources = new LinkedList<>(); Pair<IDeviceID, Boolean> minDevice = null; // get the device from source files sorted from the newest to the oldest by version @@ -275,7 +275,8 @@ public class MultiTsFileDeviceIterator implements AutoCloseable { timeseriesMetadataList, deviceIteratorMap.get(resource).getFirstMeasurementNodeOfCurrentDevice(), schemaMap.keySet(), - true); + true, + null); for (TimeseriesMetadata timeseriesMetadata : timeseriesMetadataList) { if (!schemaMap.containsKey(timeseriesMetadata.getMeasurementId()) && !timeseriesMetadata.getChunkMetadataList().isEmpty()) {
