Skip to content

Commit 1723dc7

Browse files
committed
fix log; add retry interval for executeWithRetries
1 parent 0b01393 commit 1723dc7

File tree

1 file changed

+4
-3
lines changed

1 file changed

+4
-3
lines changed

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

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -527,10 +527,10 @@ public void partitionExecute(ObTableSingleOpResult[] results,
527527
realTableName, lsId, ((ObTableException) ex).getErrorCode(), ex);
528528
if (obTableClient.isRetryOnChangeMasterTimes()
529529
&& (tryTimes - 1) < obTableClient.getRuntimeRetryTimes()) {
530-
logger.warn("tablename:{} ls id:{} batch ops retry while meet ObTableMasterChangeException, errorCode: {} , retry times {}",
531-
realTableName, lsId, ((ObTableException) ex).getErrorCode(),
532-
tryTimes, ex);
533530
if (ex instanceof ObTableNeedFetchAllException) {
531+
logger.warn("tablename:{} ls id:{} batch ops retry while meet ObTableNeedFetchAllException, errorCode: {} , retry times {}",
532+
realTableName, lsId, ((ObTableException) ex).getErrorCode(),
533+
tryTimes, ex);
534534
obTableClient.getOrRefreshTableEntry(realTableName, needRefreshTableEntry,
535535
obTableClient.isTableEntryRefreshIntervalWait(), true);
536536
throw ex;
@@ -655,6 +655,7 @@ private void executeWithRetries(
655655
throw e;
656656
}
657657
}
658+
Thread.sleep(obTableClient.getRuntimeRetryInterval());
658659
}
659660

660661
if (allPartitionsSuccess) {

0 commit comments

Comments
 (0)