fix: table entry do not refresh when create connection fail

oceanbase · Jun 12, 2024 · f165ebf · f165ebf
1 parent 6541a94
commit f165ebf
Showing 1 changed file with 3 additions and 0 deletions.
diff --git 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)