Skip to content

Commit cfe5d28

Browse files
committed
add log for batchOpsImpl
1 parent 7e2d35c commit cfe5d28

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
@@ -421,12 +421,10 @@ public void partitionExecute(ObTableOperationResult[] results,
421421
tableName, partId, ((ObTableException) ex).getErrorCode(), ex);
422422
if (obTableClient.isRetryOnChangeMasterTimes()
423423
&& (tryTimes - 1) < obTableClient.getRuntimeRetryTimes()) {
424-
logger
425-
.warn(
426-
"tablename:{} partition id:{} batch ops retry while meet ObTableMasterChangeException, errorCode: {} , retry times {}",
427-
tableName, partId, ((ObTableException) ex).getErrorCode(),
428-
tryTimes, ex);
429424
if (ex instanceof ObTableNeedFetchAllException) {
425+
logger.warn("tablename:{}, partition_id: {} batch ops retry while meet ObTableNeedFetchAllException, errorCode: {} , retry times {}",
426+
tableName, subRequest.getPartitionId(),((ObTableException) ex).getErrorCode(),
427+
tryTimes, ex);
430428
// refresh table info
431429
obTableClient.getOrRefreshTableEntry(tableName, needRefreshTableEntry,
432430
obTableClient.isTableEntryRefreshIntervalWait(), true);
@@ -541,6 +539,7 @@ private void executeWithRetries(ObTableOperationResult[] results, Map.Entry<Long
541539
throw e;
542540
}
543541
}
542+
Thread.sleep(obTableClient.getRuntimeRetryInterval());
544543
}
545544

546545
if (allPartitionsSuccess) {

0 commit comments

Comments
 (0)