From 2833353d0d49245d254e57c31c70bbdba3b872ea Mon Sep 17 00:00:00 2001 From: cuidajun Date: Fri, 6 Jan 2023 13:56:49 +0800 Subject: [PATCH] fix:scheduler's health client not close (#1975) Signed-off-by: bigerous --- client/config/dynconfig_manager.go | 1 + scheduler/config/dynconfig.go | 1 + 2 files changed, 2 insertions(+) diff --git a/client/config/dynconfig_manager.go b/client/config/dynconfig_manager.go index babb4ffc7..d6eb0f9df 100644 --- a/client/config/dynconfig_manager.go +++ b/client/config/dynconfig_manager.go @@ -109,6 +109,7 @@ func (d *dynconfigManager) GetResolveSchedulerAddrs() ([]resolver.Address, error logger.Errorf("get health client %s failed: %s", addr, err.Error()) continue } + defer healthClient.Close() if err := healthClient.Check(context.Background(), &healthpb.HealthCheckRequest{}); err != nil { logger.Errorf("scheduler address %s is unreachable: %s", addr, err.Error()) diff --git a/scheduler/config/dynconfig.go b/scheduler/config/dynconfig.go index aaccae5db..d34e8b604 100644 --- a/scheduler/config/dynconfig.go +++ b/scheduler/config/dynconfig.go @@ -189,6 +189,7 @@ func (d *dynconfig) GetResolveSeedPeerAddrs() ([]resolver.Address, error) { logger.Errorf("get health client %s failed: %s", addr, err.Error()) continue } + defer healthClient.Close() if err := healthClient.Check(context.Background(), &healthpb.HealthCheckRequest{}); err != nil { logger.Errorf("seed peer address %s is unreachable: %s", addr, err.Error())