Skip to content

Commit c245858

Browse files
committed
refresh table roster if obtable is null
1 parent 293353b commit c245858

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

src/main/java/com/alipay/oceanbase/rpc/ObTableClient.java

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2063,6 +2063,10 @@ public ObPair<Long, ObTableParam> getTableInternal(String tableName, TableEntry
20632063
}
20642064
addr = replica.getAddr();
20652065
obTable = tableRoster.get(addr);
2066+
if (obTable == null) {
2067+
syncRefreshMetadata();
2068+
obTable = tableRoster.get(addr);
2069+
}
20662070
if (obTable == null) {
20672071
throw new ObTableGetException("obTable is null, addr is: " + addr.getIp() + ":" + addr.getSvrPort());
20682072
}

0 commit comments

Comments
 (0)