(iotdb) branch dev/1.3 updated: [to dev/1.3] Fixed swallowed exceptions in query execution

[jackietien]

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

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


The following commit(s) were added to refs/heads/dev/1.3 by this push:
     new 04e668426c4 [to dev/1.3] Fixed swallowed exceptions in query execution
04e668426c4 is described below

commit 04e668426c4d33b7010397d499363035122d1f9f
Author: shuwenwei <55970239+shuwen...@users.noreply.github.com>
AuthorDate: Thu Apr 30 17:23:00 2026 +0800

    [to dev/1.3] 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 c9c41f5b993..6caad1a175d 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.db.queryengine.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 f3ada63d96f..c64d32c1e32 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
@@ -209,6 +209,7 @@ public abstract class ResourceByPathUtils {
           listRamInfo.getArrayMemCost(),
           listRamInfo.getRowCount(),
           listRamInfo.getDataTypes());
+      throw ex;
     } finally {
       list.unlockQueryList();
     }