Skip to content

Commit babeabd

Browse files
committed
remove testing output
1 parent d6b23cc commit babeabd

File tree

4 files changed

+0
-4
lines changed

4 files changed

+0
-4
lines changed

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

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -817,7 +817,6 @@ private <T> T executeMutation(String tableName, MutationExecuteCallback<T> callb
817817
// if the cause is that ODP partition meta have expired, try to fetch new one
818818
if (ex instanceof ObTablePartitionChangeException
819819
&& ((ObTablePartitionChangeException) ex).getErrorCode() == OB_ERR_KV_ROUTE_ENTRY_EXPIRE.errorCode) {
820-
System.out.println("odp partition changed.");
821820
needRenew = true;
822821
} else {
823822
throw ex;

src/main/java/com/alipay/oceanbase/rpc/protocol/payload/impl/execute/query/AbstractQueryStreamResult.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -163,7 +163,6 @@ protected ObPayload commonExecute(ObTableClient client, Logger logger,
163163
e.getMessage(), tryTimes);
164164
if (e instanceof ObTablePartitionChangeException
165165
&& ((ObTablePartitionChangeException) e).getErrorCode() == ResultCodes.OB_ERR_KV_ROUTE_ENTRY_EXPIRE.errorCode) {
166-
System.out.println("odp partition changed.");
167166
odpNeedRenew = true;
168167
} else {
169168
throw e;

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

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -352,7 +352,6 @@ public void partitionExecute(ObTableOperationResult[] results,
352352
tryTimes);
353353
if (ex instanceof ObTablePartitionChangeException
354354
&& ((ObTablePartitionChangeException) ex).getErrorCode() == ResultCodes.OB_ERR_KV_ROUTE_ENTRY_EXPIRE.errorCode) {
355-
System.out.println("odp partition changed");
356355
odpNeedRenew = true;
357356
} else {
358357
throw ex;

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

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -470,7 +470,6 @@ public void partitionExecute(ObTableSingleOpResult[] results,
470470
"tablename: {}, errMsg: {}", tableName, ex.getMessage());
471471
if (ex instanceof ObTablePartitionChangeException &&
472472
((ObTablePartitionChangeException) ex).getErrorCode() == ResultCodes.OB_ERR_KV_ROUTE_ENTRY_EXPIRE.errorCode) {
473-
System.out.println("odp partition changed.");
474473
odpNeedRenew = true;
475474
}
476475
else {

0 commit comments

Comments
 (0)