Skip to content

Commit 6777826

Browse files
committed
fix log; add retry interval for executeWithRetries
1 parent 93bf5c6 commit 6777826

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
@@ -549,10 +549,10 @@ public void partitionExecute(ObTableSingleOpResult[] results,
549549
realTableName, lsId, ((ObTableException) ex).getErrorCode(), ex);
550550
if (obTableClient.isRetryOnChangeMasterTimes()
551551
&& (tryTimes - 1) < obTableClient.getRuntimeRetryTimes()) {
552-
logger.warn("tablename:{} ls id:{} batch ops retry while meet ObTableMasterChangeException, errorCode: {} , retry times {}",
553-
realTableName, lsId, ((ObTableException) ex).getErrorCode(),
554-
tryTimes, ex);
555552
if (ex instanceof ObTableNeedFetchAllException) {
553+
logger.warn("tablename:{} ls id:{} batch ops retry while meet ObTableNeedFetchAllException, errorCode: {} , retry times {}",
554+
realTableName, lsId, ((ObTableException) ex).getErrorCode(),
555+
tryTimes, ex);
556556
obTableClient.getOrRefreshTableEntry(realTableName, needRefreshTableEntry,
557557
obTableClient.isTableEntryRefreshIntervalWait(), true);
558558
throw ex;
@@ -677,6 +677,7 @@ private void executeWithRetries(
677677
throw e;
678678
}
679679
}
680+
Thread.sleep(obTableClient.getRuntimeRetryInterval());
680681
}
681682

682683
if (allPartitionsSuccess) {

0 commit comments

Comments
 (0)