diff --git a/fe/fe-core/src/main/java/org/apache/doris/cloud/rpc/MetaServiceProxy.java b/fe/fe-core/src/main/java/org/apache/doris/cloud/rpc/MetaServiceProxy.java index e1cb45401db6e8..81da6878ea468b 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/cloud/rpc/MetaServiceProxy.java +++ b/fe/fe-core/src/main/java/org/apache/doris/cloud/rpc/MetaServiceProxy.java @@ -286,7 +286,8 @@ private Response executeWithMetrics(String methodName, Function getVisibleVersionAsync(Cloud.GetVersionRequest request) throws RpcException { long startTime = System.currentTimeMillis(); - String methodName = "getVersion"; + String methodName = request.hasIsTableVersion() && request.getIsTableVersion() ? "getTableVersion" + : "getPartitionVersion"; MetaServiceClient client = null; if (MetricRepo.isInit && Config.isCloudMode()) { @@ -341,7 +342,9 @@ public void onFailure(Throwable t) { } public Cloud.GetVersionResponse getVersion(Cloud.GetVersionRequest request) throws RpcException { - return executeWithMetrics("getVersion", (client) -> client.getVersion(request)); + String methodName = request.hasIsTableVersion() && request.getIsTableVersion() ? "getTableVersion" + : "getPartitionVersion"; + return executeWithMetrics(methodName, (client) -> client.getVersion(request)); } public Cloud.CreateTabletsResponse createTablets(Cloud.CreateTabletsRequest request) throws RpcException {