Skip to content

Commit 06f1a7d

Browse files
committed
add valid status check when add new obtable
1 parent 7e587c0 commit 06f1a7d

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

src/main/java/com/alipay/oceanbase/rpc/location/model/TableRoster.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -89,7 +89,8 @@ public List<ObServerAddr> refreshTablesAndGetNewServers(List<ReplicaLocation> ne
8989

9090
newServers.add(addr);
9191

92-
if (tables.containsKey(addr)) { // has ob table addr, continue
92+
// has ob table addr and this addr is valid, continue
93+
if (tables.containsKey(addr) && tables.get(addr).isValid()) {
9394
continue;
9495
}
9596

0 commit comments

Comments
 (0)