Skip to content

Commit 8739c22

Browse files
committed
add log for batchOpsImpl
1 parent 62181d1 commit 8739c22

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
@@ -438,12 +438,10 @@ public void partitionExecute(ObTableOperationResult[] results,
438438
tableName, partId, ((ObTableException) ex).getErrorCode(), ex);
439439
if (obTableClient.isRetryOnChangeMasterTimes()
440440
&& (tryTimes - 1) < obTableClient.getRuntimeRetryTimes()) {
441-
logger
442-
.warn(
443-
"tablename:{} partition id:{} batch ops retry while meet ObTableMasterChangeException, errorCode: {} , retry times {}",
444-
tableName, partId, ((ObTableException) ex).getErrorCode(),
445-
tryTimes, ex);
446441
if (ex instanceof ObTableNeedFetchAllException) {
442+
logger.warn("tablename:{}, partition_id: {} batch ops retry while meet ObTableNeedFetchAllException, errorCode: {} , retry times {}",
443+
tableName, subRequest.getPartitionId(),((ObTableException) ex).getErrorCode(),
444+
tryTimes, ex);
447445
// refresh table info
448446
obTableClient.getOrRefreshTableEntry(tableName, needRefreshTableEntry,
449447
obTableClient.isTableEntryRefreshIntervalWait(), true);
@@ -558,6 +556,7 @@ private void executeWithRetries(ObTableOperationResult[] results, Map.Entry<Long
558556
throw e;
559557
}
560558
}
559+
Thread.sleep(obTableClient.getRuntimeRetryInterval());
561560
}
562561

563562
if (allPartitionsSuccess) {

0 commit comments

Comments
 (0)