Skip to content

Commit c6ec777

Browse files
committed
add exception dealing in fetching odp partition meta
1 parent c946600 commit c6ec777

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
@@ -3063,6 +3063,10 @@ private TableEntry getOrFetchODPPartitionMeta(String tableName, boolean needRene
30633063
done = true;
30643064
} catch (Exception ex) {
30653065
RUNTIME.error("Fetching ODP partition meta meet exception", ex);
3066+
if (tableRowKeyElement.get(tableName) == null) {
3067+
// if the error is missing row key element, directly throw
3068+
throw ex;
3069+
}
30663070
if (ex instanceof ObTableException) {
30673071
forceRenew = true; // force ODP to fetch the latest partition meta
30683072
retryTime++;

0 commit comments

Comments
 (0)