Skip to content

Commit e4c12b7

Browse files
committed
do not refresh tableEntry if require_rerouting is true in odp mode
1 parent 7e587c0 commit e4c12b7

File tree

3 files changed

+3
-3
lines changed

3 files changed

+3
-3
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2097,7 +2097,7 @@ public ObPayload executeWithRetry(ObTable obTable, ObPayload request, String tab
20972097
"Rerouting return IP is {}", moveResponse.getReplica().getServer().ipToString(), move .getReplica().getServer().ipToString());
20982098
throw new ObTableRoutingWrongException();
20992099
}
2100-
} else if (result != null && result.isRoutingWrong()) {
2100+
} else if (result != null && result.isRoutingWrong() && !isOdpMode()) {
21012101
logger.debug("errors happened in server and retried successfully, server ip:port is {}:{}, tableName: {}, need_refresh_meta: {}",
21022102
obTable.getIp(), obTable.getPort(), tableName, result.isNeedRefreshMeta());
21032103
if (result.isNeedRefreshMeta()) {

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -378,7 +378,7 @@ public void partitionExecute(ObTableOperationResult[] results,
378378
.ipToString());
379379
throw new ObTableRoutingWrongException();
380380
}
381-
} else if (result != null && result.isRoutingWrong()) {
381+
} else if (result != null && result.isRoutingWrong() && !obTableClient.isOdpMode()) {
382382
logger.debug("errors happened in server and retried successfully, server ip:port is {}:{}, tableName: {}, need_refresh_meta: {}",
383383
subObTable.getIp(), subObTable.getPort(), tableName, result.isNeedRefreshMeta());
384384
TableEntry entry = result.isNeedRefreshMeta() ?

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -647,7 +647,7 @@ public void partitionExecute(ObTableSingleOpResult[] results,
647647
"Rerouting return IP is {}", moveResponse.getReplica().getServer().ipToString(), move.getReplica().getServer().ipToString());
648648
throw new ObTableRoutingWrongException();
649649
}
650-
} else if (result != null && result.isRoutingWrong()) {
650+
} else if (result != null && result.isRoutingWrong() && !obTableClient.isOdpMode()) {
651651
// retry successfully in server and need to refresh client cache
652652
logger.debug("errors happened in server and retried successfully, server ip:port is {}:{}, tableName: {}, need_refresh_meta: {}",
653653
subObTable.getIp(), subObTable.getPort(), realTableName, result.isNeedRefreshMeta());

0 commit comments

Comments
 (0)