diff --git a/common/remote/rpc/rpc_client.go b/common/remote/rpc/rpc_client.go
index 65b17c12..634eacf2 100644
--- a/common/remote/rpc/rpc_client.go
+++ b/common/remote/rpc/rpc_client.go
@@ -413,6 +413,7 @@ func (r *RpcClient) reconnect(serverInfo ServerInfo, onRequestFail bool) {
 	if onRequestFail && r.sendHealthCheck() {
 		logger.Infof("%s server check success, currentServer is %+v", r.name, r.currentConnection.getServerInfo())
 		atomic.StoreInt32((*int32)(&r.rpcClientStatus), (int32)(RUNNING))
+		r.notifyConnectionChange(CONNECTED)
 		return
 	}
 	var (