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

justinchen pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/master by this push:
     new 9ae8233091f Fixed the null error message of fetch schema failed when 
the regions is removing (#16713)
9ae8233091f is described below

commit 9ae8233091f1b655929c3343ee103389349e0d56
Author: Caideyipi <[email protected]>
AuthorDate: Fri Nov 7 18:36:50 2025 +0800

    Fixed the null error message of fetch schema failed when the regions is 
removing (#16713)
---
 .../db/queryengine/execution/executor/RegionReadExecutor.java  | 10 ++++++----
 1 file changed, 6 insertions(+), 4 deletions(-)

diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/executor/RegionReadExecutor.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/executor/RegionReadExecutor.java
index e2fb4c95988..2e63db2e2e7 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/executor/RegionReadExecutor.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/executor/RegionReadExecutor.java
@@ -100,13 +100,15 @@ public class RegionReadExecutor {
                 });
         return resp;
       }
-    } catch (ConsensusGroupNotExistException e) {
+    } catch (final ConsensusGroupNotExistException e) {
       LOGGER.warn("Execute FragmentInstance in ConsensusGroup {} failed.", 
groupId, e);
-      RegionExecutionResult resp =
+      final String errorMsg = String.format(ERROR_MSG_FORMAT, e.getMessage());
+      final RegionExecutionResult resp =
           RegionExecutionResult.create(
               false,
-              String.format(ERROR_MSG_FORMAT, e.getMessage()),
-              new 
TSStatus(TSStatusCode.CONSENSUS_GROUP_NOT_EXIST.getStatusCode()));
+              errorMsg,
+              new 
TSStatus(TSStatusCode.CONSENSUS_GROUP_NOT_EXIST.getStatusCode())
+                  .setMessage(errorMsg));
       resp.setReadNeedRetry(true);
       return resp;
     } catch (Throwable e) {

Reply via email to