Skip to content

Commit 05900c8

Browse files
committed
add debug log
1 parent 96a1e06 commit 05900c8

File tree

2 files changed

+6
-5
lines changed

2 files changed

+6
-5
lines changed

src/main/java/com/alipay/oceanbase/rpc/ObTableClient.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -485,8 +485,8 @@ private <T> T execute(String tableName, TableExecuteCallback<T> callback, ObServ
485485
}
486486
tableParam = getTableParamWithRoute(tableName, rowKey, route);
487487
}
488-
logger.debug("tableName: {}, tableParam obTable ip:port is {}:{}",
489-
tableName, tableParam.getObTable().getIp(), tableParam.getObTable().getPort());
488+
logger.debug("tableName: {}, tableParam obTable ip:port is {}:{}, ls_id: {}, tablet_id: {}",
489+
tableName, tableParam.getObTable().getIp(), tableParam.getObTable().getPort(), tableParam.getLsId(), tableParam.getTabletId());
490490
T t = callback.execute(tableParam);
491491
resetExecuteContinuousFailureCount(tableName);
492492
return t;
@@ -704,8 +704,8 @@ private <T> T execute(String tableName, OperationExecuteCallback<T> callback,
704704
throw new ObTableException("RowKey or scan range is null");
705705
}
706706
}
707-
logger.debug("tableName: {}, tableParam obTable ip:port is {}:{}",
708-
tableName, tableParam.getObTable().getIp(), tableParam.getObTable().getPort());
707+
logger.debug("tableName: {}, tableParam obTable ip:port is {}:{}, ls_id: {}, tablet_id: {}",
708+
tableName, tableParam.getObTable().getIp(), tableParam.getObTable().getPort(), tableParam.getLsId(), tableParam.getTabletId());
709709
T t = callback.execute(tableParam);
710710
resetExecuteContinuousFailureCount(tableName);
711711
return t;

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

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -534,6 +534,7 @@ public void partitionExecute(ObTableSingleOpResult[] results,
534534
Map.Entry<Long, TabletOperationsMap> lsOperation)
535535
throws Exception {
536536
long lsId = lsOperation.getKey();
537+
logger.debug("ls batch lsId: {}", lsId);
537538
TabletOperationsMap tabletOperationsMap = lsOperation.getValue();
538539
if (tabletOperationsMap.isEmpty()) {
539540
logger.warn("the size of tablet operations in ls operation is zero");
@@ -675,7 +676,7 @@ public void partitionExecute(ObTableSingleOpResult[] results,
675676
}
676677
} else if (ex instanceof ObTableException) {
677678
if (((ObTableException) ex).isNeedRefreshTableEntry()) {
678-
logger.warn("meet need refresh exception, errCode: {}, ls id: {}, errMsg: {}", ((ObTableException) ex).getErrorCode(), lsId, ex.getMessage());
679+
logger.warn("meet need refresh exception, errCode: {}, ls id: {}, table_id: {}, errMsg: {}", ((ObTableException) ex).getErrorCode(), lsId, tableId, ex.getMessage());
679680
if ((((ObTableException) ex).getErrorCode() == ResultCodes.OB_TABLE_NOT_EXIST.errorCode ||
680681
((ObTableException) ex).getErrorCode() == ResultCodes.OB_SCHEMA_ERROR.errorCode)
681682
&& obTableClient.isTableGroupName(tableName)

0 commit comments

Comments
 (0)