(iotdb) branch fixFetchSchemaStatusCode created (now f14a83f3ea0)

[sh...@apache.org]

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

shuwenwei pushed a change to branch fixFetchSchemaStatusCode
in repository https://gitbox.apache.org/repos/asf/iotdb.git


      at f14a83f3ea0 Fix the status code of fetching schema when memory is not enough

This branch includes the following new commits:

     new f14a83f3ea0 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

[sh...@apache.org]

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);
     }