Skip to content

Commit 297cc81

Browse files
committed
[fix][dingo-sdk] Fix not leader retry issue
1 parent 2ec0488 commit 297cc81

File tree

1 file changed

+5
-0
lines changed

1 file changed

+5
-0
lines changed

java/dingo-sdk/src/main/java/io/dingodb/sdk/service/caller/ServiceCaller.java

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -119,6 +119,11 @@ public <REQ extends Request, RES extends Response> RES call(
119119
continue;
120120
case FAILED:
121121
handler.onFailed(request, response, options, channel.authority(), requestId);
122+
if (isPreWriteFailed && errCode == Errno.ERAFT_NOTLEADER.number) {
123+
log.error("Not leader channel: {}", channel);
124+
channel = updateChannel(channel, requestId);
125+
log.error("Not leader update channel: {}", channel);
126+
}
122127
throw new RequestErrorException(errCode, error.getErrmsg());
123128
case REFRESH:
124129
handler.onRefresh(request, response, options, channel.authority(), requestId);

0 commit comments

Comments
 (0)