(iotdb) branch master updated: [region migration] Enable write retry for ratis local write (#13901)

[tanxinyu]

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

tanxinyu 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 fe23762840c [region migration] Enable write retry for ratis local 
write (#13901)
fe23762840c is described below

commit fe23762840ce5be521f7dd8391ab4d9b2db23fb3
Author: Xiangpeng Hu <65238551+hxpser...@users.noreply.github.com>
AuthorDate: Fri Oct 25 09:47:30 2024 +0800

    [region migration] Enable write retry for ratis local write (#13901)
---
 .../main/java/org/apache/iotdb/consensus/ratis/RatisConsensus.java    | 4 ++++
 1 file changed, 4 insertions(+)

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
index 63e4a2588c8..4a293fb3fd4 100644
--- 
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 @@ class RatisConsensus implements IConsensus {
         if (ex != null) {
           suggestedLeader = ex.getSuggestedLeader();
         }
+      } catch (GroupMismatchException e) {
+        throw new ConsensusGroupNotExistException(groupId);
       } catch (Exception e) {
         throw new RatisRequestFailedException(e);
       }
@@ -347,6 +349,8 @@ class RatisConsensus implements IConsensus {
         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);
     }