diff --git a/src/main/java/com/alipay/oceanbase/rpc/ObTableClient.java b/src/main/java/com/alipay/oceanbase/rpc/ObTableClient.java index 8389d54f..9c2f27c0 100644 --- a/src/main/java/com/alipay/oceanbase/rpc/ObTableClient.java +++ b/src/main/java/com/alipay/oceanbase/rpc/ObTableClient.java @@ -2440,11 +2440,16 @@ public ObPayload execute(final ObHbaseRequest request) throws Exception { row.add("K", request.getKeys().get(keyIdx).getValue()); row.add("Q", request.getCfRows().get(0).getCells().get(0).getQ().getValue()); row.add("T", request.getCfRows().get(0).getCells().get(0).getT().getValue()); - ObTableParam tableParam = tableRoute.getTableParam(realTableName, row); - ObTable obTable = tableParam.getObTable(); - request.setTimeout(obTable.getObTableOperationTimeout()); - request.setTabletId(tableParam.getTabletId()); - return executeWithRetry(obTable, request, realTableName); + return execute(realTableName, + new OperationExecuteCallback(row, null) { + @Override + ObPayload execute(ObTableParam tableParam) throws Exception { + ObTable obTable = tableParam.getObTable(); + request.setTimeout(obTable.getObTableOperationTimeout()); + request.setTabletId(tableParam.getTabletId()); + return executeWithRetry(obTable, request, realTableName); + } + }); } }