diff --git a/src/main/java/com/alipay/oceanbase/rpc/ObTableClient.java b/src/main/java/com/alipay/oceanbase/rpc/ObTableClient.java index 8134f9dc..0532be52 100644 --- a/src/main/java/com/alipay/oceanbase/rpc/ObTableClient.java +++ b/src/main/java/com/alipay/oceanbase/rpc/ObTableClient.java @@ -1907,7 +1907,7 @@ public ObPayload execute(ObTableParam tableParam) throws Exception { checkResult(obTable.getIp(), obTable.getPort(), request, result); return result; } - }); + }, ObReadConsistency.STRONG); } public ObPayload executeWithRetry(ObTable obTable, ObPayload request, String tableName) throws Exception {