From f165ebf382658038706acbcb89f2ec5528102f45 Mon Sep 17 00:00:00 2001 From: groundwu <1175416256@qq.com> Date: Wed, 12 Jun 2024 17:43:56 +0800 Subject: [PATCH] fix: table entry do not refresh when create connection fail --- route/route_info.go | 3 +++ 1 file changed, 3 insertions(+) diff --git a/route/route_info.go b/route/route_info.go index 5b8eeb7..0589900 100644 --- a/route/route_info.go +++ b/route/route_info.go @@ -61,6 +61,9 @@ func (i *ObRouteInfo) getTableWithRetry(ctx context.Context, server *ObServerAdd for { select { case <-ctx.Done(): + err := i.refreshTableLocations(&server.tcpAddr) + log.Warn("[Runtime]", nil, "get table fail and try to refresh table location ", + log.String("server", server.String()), log.String("err", err.Error())) return nil, errors.Errorf("get table, server:%s", server.String()) default: t, ok = i.tableRoster.Get(server.tcpAddr)