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 2025/08/12 03:03:54 UTC
(iotdb) 01/01: Fix the status code of fetching schema when memory is not enough
This is an automated email from the ASF dual-hosted git repository.
shuwenwei pushed a commit to branch fixFetchSchemaStatusCode
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit f14a83f3ea0ca5a5df15bda09a36264f040ae474
Author: shuwenwei <s1...@gmail.com>
AuthorDate: Tue Aug 12 11:03:33 2025 +0800
Fix the status code of fetching schema when memory is not enough
---
.../db/queryengine/plan/analyze/schema/ClusterSchemaFetchExecutor.java | 3 +++
1 file changed, 3 insertions(+)
diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/schema/ClusterSchemaFetchExecutor.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/schema/ClusterSchemaFetchExecutor.java
index b959e05e1c5..637516ef83a 100644
--- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/schema/ClusterSchemaFetchExecutor.java
+++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/schema/ClusterSchemaFetchExecutor.java
@@ -31,6 +31,7 @@ import org.apache.iotdb.db.conf.IoTDBDescriptor;
import org.apache.iotdb.db.protocol.session.SessionManager;
import org.apache.iotdb.db.queryengine.common.MPPQueryContext;
import org.apache.iotdb.db.queryengine.common.schematree.ClusterSchemaTree;
+import org.apache.iotdb.db.queryengine.exception.MemoryNotEnoughException;
import org.apache.iotdb.db.queryengine.plan.Coordinator;
import org.apache.iotdb.db.queryengine.plan.analyze.ClusterPartitionFetcher;
import org.apache.iotdb.db.queryengine.plan.execution.ExecutionResult;
@@ -326,6 +327,8 @@ class ClusterSchemaFetchExecutor {
throw new RuntimeException(
new MetadataException("Failed to fetch schema because of unrecognized data"));
}
+ } catch (MemoryNotEnoughException e) {
+ throw e;
} catch (Exception e) {
throw new RuntimeException(e);
}