Skip to content

Commit 41c796d

Browse files
committed
fix retry for meeting ObTableNotExists when query tableGroup
1 parent 7305dd8 commit 41c796d

File tree

1 file changed

+9
-0
lines changed

1 file changed

+9
-0
lines changed

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

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2389,6 +2389,15 @@ public ObPayload execute(final ObTableAbstractOperationRequest request) throws E
23892389
} else {
23902390
if (ex instanceof ObTableException &&
23912391
(((ObTableException) ex).isNeedRefreshTableEntry() || ((ObTableException) ex).isNeedRetryError())) {
2392+
if (ex instanceof ObTableNotExistException) {
2393+
String logMessage = String.format(
2394+
"exhaust retry while meet TableNotExist Exception, table name: %s, errorCode: %d",
2395+
request.getTableName(),
2396+
((ObTableException) ex).getErrorCode()
2397+
);
2398+
logger.warn(logMessage, ex);
2399+
throw ex;
2400+
}
23922401
logger.warn(
23932402
"tablename:{} partition id:{} batch ops refresh table while meet ObTableMasterChangeException, errorCode: {}",
23942403
request.getTableName(), routeTabletId, ((ObTableException) ex).getErrorCode(), ex);

0 commit comments

Comments
 (0)