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 680189d4d276f2..ccdb8006bb73d4 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 @@ -446,15 +446,11 @@ public Cloud.AlterObjStoreInfoResponse alterObjStoreInfo(Cloud.AlterObjStoreInfo public Cloud.GetRLTaskCommitAttachResponse getRLTaskCommitAttach(Cloud.GetRLTaskCommitAttachRequest request) throws RpcException { - if (metaServiceHostPort == null) { - throw new RpcException("", "cloud mode, please configure cloud_unique_id and meta_service_endpoint"); - } - TNetworkAddress metaAddress = new TNetworkAddress(metaServiceHostPort.first, metaServiceHostPort.second); try { - final MetaServiceClient client = getProxy(metaAddress); + final MetaServiceClient client = getProxy(); return client.getRLTaskCommitAttach(request); } catch (Exception e) { - throw new RpcException(metaAddress.hostname, e.getMessage(), e); + throw new RpcException("", e.getMessage(), e); } } }