fix:opensearch-project#458

Zhang-jie-jun · Jan 19, 2024 · 97feadc · 97feadc
1 parent e909617
commit 97feadc
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/opensearchtransport/discovery.go b/opensearchtransport/discovery.go
@@ -194,8 +194,10 @@ func (c *Client) getNodeURL(node nodeInfo, scheme string) *url.URL {
 			host = strings.Split(addrs[0], ":")[0]
 		}
 	}
-
-	port = ports[len(ports)-1]
+	if len(port) == 0 {
+		port = ports[len(ports)-1]
+	}
+
 	u := &url.URL{
 		Scheme: scheme,
 		Host:   net.JoinHostPort(host, port),