diff --git a/src/main/java/com/alipay/oceanbase/rpc/ObTableClient.java b/src/main/java/com/alipay/oceanbase/rpc/ObTableClient.java index c33fdae7..dc1a1995 100644 --- a/src/main/java/com/alipay/oceanbase/rpc/ObTableClient.java +++ b/src/main/java/com/alipay/oceanbase/rpc/ObTableClient.java @@ -2097,7 +2097,7 @@ public ObPayload executeWithRetry(ObTable obTable, ObPayload request, String tab "Rerouting return IP is {}", moveResponse.getReplica().getServer().ipToString(), move .getReplica().getServer().ipToString()); throw new ObTableRoutingWrongException(); } - } else if (result != null && result.isRoutingWrong()) { + } else if (result != null && result.isRoutingWrong() && !isOdpMode()) { logger.debug("errors happened in server and retried successfully, server ip:port is {}:{}, tableName: {}, need_refresh_meta: {}", obTable.getIp(), obTable.getPort(), tableName, result.isNeedRefreshMeta()); if (result.isNeedRefreshMeta()) { diff --git a/src/main/java/com/alipay/oceanbase/rpc/table/ObTableClientBatchOpsImpl.java b/src/main/java/com/alipay/oceanbase/rpc/table/ObTableClientBatchOpsImpl.java index ed305063..ac6c0025 100644 --- a/src/main/java/com/alipay/oceanbase/rpc/table/ObTableClientBatchOpsImpl.java +++ b/src/main/java/com/alipay/oceanbase/rpc/table/ObTableClientBatchOpsImpl.java @@ -378,7 +378,7 @@ public void partitionExecute(ObTableOperationResult[] results, .ipToString()); throw new ObTableRoutingWrongException(); } - } else if (result != null && result.isRoutingWrong()) { + } else if (result != null && result.isRoutingWrong() && !obTableClient.isOdpMode()) { logger.debug("errors happened in server and retried successfully, server ip:port is {}:{}, tableName: {}, need_refresh_meta: {}", subObTable.getIp(), subObTable.getPort(), tableName, result.isNeedRefreshMeta()); TableEntry entry = result.isNeedRefreshMeta() ? diff --git a/src/main/java/com/alipay/oceanbase/rpc/table/ObTableClientLSBatchOpsImpl.java b/src/main/java/com/alipay/oceanbase/rpc/table/ObTableClientLSBatchOpsImpl.java index 7cf2107b..fa45fcd6 100644 --- a/src/main/java/com/alipay/oceanbase/rpc/table/ObTableClientLSBatchOpsImpl.java +++ b/src/main/java/com/alipay/oceanbase/rpc/table/ObTableClientLSBatchOpsImpl.java @@ -647,7 +647,7 @@ public void partitionExecute(ObTableSingleOpResult[] results, "Rerouting return IP is {}", moveResponse.getReplica().getServer().ipToString(), move.getReplica().getServer().ipToString()); throw new ObTableRoutingWrongException(); } - } else if (result != null && result.isRoutingWrong()) { + } else if (result != null && result.isRoutingWrong() && !obTableClient.isOdpMode()) { // retry successfully in server and need to refresh client cache logger.debug("errors happened in server and retried successfully, server ip:port is {}:{}, tableName: {}, need_refresh_meta: {}", subObTable.getIp(), subObTable.getPort(), realTableName, result.isNeedRefreshMeta());