This is an automated email from the ASF dual-hosted git repository. shuwenwei pushed a commit to branch fixBug0430 in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 1bd47e3ea899788c85a90a9edcded873227fc78a Author: shuwenwei <[email protected]> AuthorDate: Thu Apr 30 16:21:02 2026 +0800 Fixed swallowed exceptions in query execution --- .../org/apache/iotdb/db/queryengine/execution/driver/DataDriver.java | 5 ++++- .../db/schemaengine/schemaregion/utils/ResourceByPathUtils.java | 1 + 2 files changed, 5 insertions(+), 1 deletion(-) diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/driver/DataDriver.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/driver/DataDriver.java index 70bf68e2f14..d4fd8d2839f 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/driver/DataDriver.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/driver/DataDriver.java @@ -31,6 +31,7 @@ import javax.annotation.concurrent.NotThreadSafe; import java.util.List; +import static com.google.common.base.Throwables.throwIfUnchecked; import static org.apache.iotdb.calc.metric.QueryExecutionMetricSet.QUERY_RESOURCE_INIT; import static org.apache.iotdb.db.storageengine.dataregion.VirtualDataRegion.UNFINISHED_QUERY_DATA_SOURCE; @@ -68,7 +69,9 @@ public class DataDriver extends Driver { "Failed to do the initialization for driver {} ", driverContext.getDriverTaskID(), t); driverContext.failed(t); blockedFuture.setException(t); - return false; + throwIfUnchecked(t); + // should never happen + throw new AssertionError(t); } } return true; diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/utils/ResourceByPathUtils.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/utils/ResourceByPathUtils.java index e0590a1410e..db79377be3b 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/utils/ResourceByPathUtils.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/utils/ResourceByPathUtils.java @@ -216,6 +216,7 @@ public abstract class ResourceByPathUtils { listRamInfo.getArrayMemCost(), listRamInfo.getRowCount(), listRamInfo.getDataTypes()); + throw ex; } finally { list.unlockQueryList(); }
