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 7d47ec70c1bada..33a4d81feaaa54 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 @@ -107,7 +107,7 @@ private MetaServiceClient getProxy() { String address = Config.meta_service_endpoint; MetaServiceClient service = serviceMap.get(address); - if (service != null && service.isNormalState()) { + if (service != null && service.isNormalState() && !service.isConnectionAgeExpired()) { return service; } @@ -126,7 +126,7 @@ private MetaServiceClient getProxy() { removedClient = service; service = null; } - if (service != null && !service.isConnectionAgeExpired()) { + if (service != null && service.isConnectionAgeExpired()) { serviceMap.remove(address); removedClient = service; service = null;