fix:opensearch-project#458

Zhang-jie-jun · Jan 19, 2024 · e909617 · e909617
1 parent b06ce74
commit e909617
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/opensearchtransport/discovery.go b/opensearchtransport/discovery.go
@@ -180,6 +180,7 @@ func (c *Client) getNodeURL(node nodeInfo, scheme string) *url.URL {
 	var (
 		host string
 		port string
+		err  error
 
 		addrs = strings.Split(node.HTTP.PublishAddress, "/")
 		ports = strings.Split(node.HTTP.PublishAddress, ":")
@@ -188,7 +189,10 @@ func (c *Client) getNodeURL(node nodeInfo, scheme string) *url.URL {
 	if len(addrs) > 1 {
 		host = addrs[0]
 	} else {
-		host, _, _ = net.SplitHostPort(addrs[0])
+		host, port, err = net.SplitHostPort(addrs[0])
+		if err != nil {
+			host = strings.Split(addrs[0], ":")[0]
+		}
 	}
 
 	port = ports[len(ports)-1]