(iotdb) branch master updated: Fixed swallowed exceptions in query execution (#17585)

[jackietien]

This is an automated email from the ASF dual-hosted git repository.

JackieTien97 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/master by this push:
     new 11a6c360fe4 Fixed swallowed exceptions in query execution (#17585)
11a6c360fe4 is described below

commit 11a6c360fe4a1d8e12a48a9d387fa82a7f2e1c59
Author: shuwenwei <55970239+shuwen...@users.noreply.github.com>
AuthorDate: Thu Apr 30 17:22:43 2026 +0800

    Fixed swallowed exceptions in query execution (#17585)
---
 .../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();
     }