From a97bb8dec4007fb0d56b8eca30b74850e819dea4 Mon Sep 17 00:00:00 2001 From: Luwei <814383175@qq.com> Date: Wed, 11 Sep 2024 14:39:51 +0800 Subject: [PATCH] [fix](cloud) fix the issue that FE's periodic reconnection to MS RPC is ineffective --- .../java/org/apache/doris/cloud/rpc/MetaServiceProxy.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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;