You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by sh...@apache.org on 2026/04/30 08:21:25 UTC
(iotdb) 01/01: Fixed swallowed exceptions in query execution
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 <s1...@gmail.com>
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();
}