[region migration] Fix exception capture processing logic apache#13034

Caideyipi · Dec 16, 2024 · 2b3c511 · 2b3c511
1 parent 56c943b
commit 2b3c511
Showing 1 changed file with 6 additions and 3 deletions.
diff --git a/.../src/main/java/org/apache/iotdb/db/queryengine/execution/executor/RegionReadExecutor.java b/.../src/main/java/org/apache/iotdb/db/queryengine/execution/executor/RegionReadExecutor.java
@@ -94,6 +94,12 @@ public RegionExecutionResult execute(
         resp.setMessage(info.getMessage());
       }
       return resp;
+    } catch (ConsensusGroupNotExistException e) {
+      LOGGER.error("Execute FragmentInstance in ConsensusGroup {} failed.", groupId, e);
+      resp.setMessage(String.format(ERROR_MSG_FORMAT, e.getMessage()));
+      resp.setNeedRetry(true);
+      resp.setStatus(new TSStatus(TSStatusCode.CONSENSUS_GROUP_NOT_EXIST.getStatusCode()));
+      return resp;
     } catch (Throwable e) {
       LOGGER.error("Execute FragmentInstance in ConsensusGroup {} failed.", groupId, e);
       resp.setMessage(String.format(ERROR_MSG_FORMAT, e.getMessage()));
@@ -104,9 +110,6 @@ public RegionExecutionResult execute(
           || t instanceof ServerNotReadyException) {
         resp.setNeedRetry(true);
         resp.setStatus(new TSStatus(TSStatusCode.RATIS_READ_UNAVAILABLE.getStatusCode()));
-      } else if (t instanceof ConsensusGroupNotExistException) {
-        resp.setNeedRetry(true);
-        resp.setStatus(new TSStatus(TSStatusCode.CONSENSUS_GROUP_NOT_EXIST.getStatusCode()));
       }
       return resp;
     }