Skip to content

Commit c234aa7

Browse files
committed
fix log; add retry interval for executeWithRetries
1 parent ba5fa12 commit c234aa7

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
@@ -566,10 +566,10 @@ public void partitionExecute(ObTableSingleOpResult[] results,
566566
realTableName, lsId, ((ObTableException) ex).getErrorCode(), ex);
567567
if (obTableClient.isRetryOnChangeMasterTimes()
568568
&& (tryTimes - 1) < obTableClient.getRuntimeRetryTimes()) {
569-
logger.warn("tablename:{} ls id:{} batch ops retry while meet ObTableMasterChangeException, errorCode: {} , retry times {}",
570-
realTableName, lsId, ((ObTableException) ex).getErrorCode(),
571-
tryTimes, ex);
572569
if (ex instanceof ObTableNeedFetchAllException) {
570+
logger.warn("tablename:{} ls id:{} batch ops retry while meet ObTableNeedFetchAllException, errorCode: {} , retry times {}",
571+
realTableName, lsId, ((ObTableException) ex).getErrorCode(),
572+
tryTimes, ex);
573573
obTableClient.getOrRefreshTableEntry(realTableName, needRefreshTableEntry,
574574
obTableClient.isTableEntryRefreshIntervalWait(), true);
575575
throw ex;
@@ -694,6 +694,7 @@ private void executeWithRetries(
694694
throw e;
695695
}
696696
}
697+
Thread.sleep(obTableClient.getRuntimeRetryInterval());
697698
}
698699

699700
if (allPartitionsSuccess) {

0 commit comments

Comments
 (0)