This is an automated email from the ASF dual-hosted git repository.
shuwenwei pushed a commit to branch cacheMetadataIndexNodeOffsetsForQuery
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to
refs/heads/cacheMetadataIndexNodeOffsetsForQuery by this push:
new c766e293df9 modify exception
c766e293df9 is described below
commit c766e293df9bab088f9ca7b794f9ff868a1ff407
Author: shuwenwei <[email protected]>
AuthorDate: Tue Jul 29 18:31:21 2025 +0800
modify exception
---
.../execution/fragment/DeviceMetadataIndexEntryCache.java | 6 ++++--
1 file changed, 4 insertions(+), 2 deletions(-)
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/fragment/DeviceMetadataIndexEntryCache.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/fragment/DeviceMetadataIndexEntryCache.java
index 5211a5b3b9c..aadacad9a5d 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/fragment/DeviceMetadataIndexEntryCache.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/fragment/DeviceMetadataIndexEntryCache.java
@@ -19,10 +19,12 @@
package org.apache.iotdb.db.queryengine.execution.fragment;
+import org.apache.iotdb.db.queryengine.exception.MemoryNotEnoughException;
import
org.apache.iotdb.db.queryengine.execution.operator.source.AbstractDataSourceOperator;
import org.apache.iotdb.db.queryengine.plan.relational.metadata.DeviceEntry;
import
org.apache.iotdb.db.storageengine.dataregion.read.control.FileReaderManager;
+import org.apache.tsfile.exception.TsFileRuntimeException;
import org.apache.tsfile.file.metadata.IDeviceID;
import org.apache.tsfile.read.TsFileSequenceReader;
import org.apache.tsfile.utils.Pair;
@@ -112,7 +114,7 @@ public class DeviceMetadataIndexEntryCache {
sortedDevices,
ioSizeRecorder);
} catch (IOException e) {
- throw new RuntimeException(e);
+ throw new TsFileRuntimeException(e);
}
});
}
@@ -148,7 +150,7 @@ public class DeviceMetadataIndexEntryCache {
context.getMemoryReservationContext().reserveMemoryCumulatively(costOfOneFile);
memoryReserved = true;
}
- } catch (Exception ignored) {
+ } catch (MemoryNotEnoughException ignored) {
return false;
}
if (cachedFileNum.compareAndSet(currentNum, currentNum + 1)) {
