Skip to content

Commit 2ec77a1

Browse files
committed
do not add suspect ip in odp mode
1 parent fee629c commit 2ec77a1

File tree

2 files changed

+8
-2
lines changed

2 files changed

+8
-2
lines changed

src/main/java/com/alipay/oceanbase/rpc/bolt/transport/ObTableConnection.java

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -116,8 +116,10 @@ private boolean connect() throws Exception {
116116
MONITOR.info(logMessage(null, "CONNECT", endpoint, System.currentTimeMillis() - start));
117117

118118
if (tries >= maxTryTimes) {
119-
RouteTableRefresher.SuspectObServer suspectAddr = new RouteTableRefresher.SuspectObServer(obTable.getObServerAddr());
120-
RouteTableRefresher.addIntoSuspectIPs(suspectAddr);
119+
if (!obTable.isOdpMode()) {
120+
RouteTableRefresher.SuspectObServer suspectAddr = new RouteTableRefresher.SuspectObServer(obTable.getObServerAddr());
121+
RouteTableRefresher.addIntoSuspectIPs(suspectAddr);
122+
}
121123
LOGGER.warn("connect failed after max " + maxTryTimes + " tries "
122124
+ TraceUtil.formatIpPort(obTable));
123125
throw new ObTableServerConnectException("connect failed after max " + maxTryTimes

src/main/java/com/alipay/oceanbase/rpc/table/ObTable.java

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -640,6 +640,10 @@ public void setIsOdpMode(boolean isOdpMode) {
640640
this.isOdpMode = isOdpMode;
641641
}
642642

643+
public boolean isOdpMode() {
644+
return this.isOdpMode;
645+
}
646+
643647
public ObServerAddr getObServerAddr() {
644648
return this.addr;
645649
}

0 commit comments

Comments
 (0)