[region migration] Enable write retry for ratis local write (#13901) (#…

…13913) (cherry picked from commit fe23762)
apache · Oct 25, 2024 · 64bf6d8 · 64bf6d8
1 parent cc2764f
commit 64bf6d8
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/ratis/RatisConsensus.java b/iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/ratis/RatisConsensus.java
@@ -332,6 +332,8 @@ && waitUntilLeaderReady(raftGroupId)) {
         if (ex != null) {
           suggestedLeader = ex.getSuggestedLeader();
         }
+      } catch (GroupMismatchException e) {
+        throw new ConsensusGroupNotExistException(groupId);
       } catch (Exception e) {
         throw new RatisRequestFailedException(e);
       }
@@ -347,6 +349,8 @@ && waitUntilLeaderReady(raftGroupId)) {
         throw new RatisRequestFailedException(reply.getException());
       }
       writeResult = Utils.deserializeFrom(reply.getMessage().getContent().asReadOnlyByteBuffer());
+    } catch (GroupMismatchException e) {
+      throw new ConsensusGroupNotExistException(groupId);
     } catch (Exception e) {
       throw new RatisRequestFailedException(e);
     }