Skip to content

Commit 21ff810

Browse files
committed
add log for batchOpsImpl
1 parent 3669d6e commit 21ff810

File tree

1 file changed

+4
-5
lines changed

1 file changed

+4
-5
lines changed

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

Lines changed: 4 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -441,12 +441,10 @@ public void partitionExecute(ObTableOperationResult[] results,
441441
tableName, partId, ((ObTableException) ex).getErrorCode(), ex);
442442
if (obTableClient.isRetryOnChangeMasterTimes()
443443
&& (tryTimes - 1) < obTableClient.getRuntimeRetryTimes()) {
444-
logger
445-
.warn(
446-
"tablename:{} partition id:{} batch ops retry while meet ObTableMasterChangeException, errorCode: {} , retry times {}",
447-
tableName, partId, ((ObTableException) ex).getErrorCode(),
448-
tryTimes, ex);
449444
if (ex instanceof ObTableNeedFetchAllException) {
445+
logger.warn("tablename:{}, partition_id: {} batch ops retry while meet ObTableNeedFetchAllException, errorCode: {} , retry times {}",
446+
tableName, subRequest.getPartitionId(),((ObTableException) ex).getErrorCode(),
447+
tryTimes, ex);
450448
// refresh table info
451449
obTableClient.getOrRefreshTableEntry(tableName, needRefreshTableEntry,
452450
obTableClient.isTableEntryRefreshIntervalWait(), true);
@@ -561,6 +559,7 @@ private void executeWithRetries(ObTableOperationResult[] results, Map.Entry<Long
561559
throw e;
562560
}
563561
}
562+
Thread.sleep(obTableClient.getRuntimeRetryInterval());
564563
}
565564

566565
if (allPartitionsSuccess) {

0 commit comments

Comments
 (0)