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:04:56 UTC
(iotdb) branch fixFetchSchemaStatusCode-1.3 created (now 7044c459c08)
This is an automated email from the ASF dual-hosted git repository.
shuwenwei pushed a change to branch fixFetchSchemaStatusCode-1.3
in repository https://gitbox.apache.org/repos/asf/iotdb.git
at 7044c459c08 Fix the status code of fetching schema when memory is not enough
This branch includes the following new commits:
new 7044c459c08 Fix the status code of fetching schema when memory is not enough
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
(iotdb) 01/01: Fix the status code of fetching schema when memory is not enough
Posted by sh...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
shuwenwei pushed a commit to branch fixFetchSchemaStatusCode-1.3
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 7044c459c08e135d553703adf86fb62b609856fd
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 d62b5640d9d..5230ff3a95f 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
@@ -29,6 +29,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.analyze.QueryType;
@@ -298,6 +299,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);
}