From f36bd174fab5051f0d3861f978e4064fc587827b Mon Sep 17 00:00:00 2001 From: cuirunxing-hub Date: Sat, 7 Aug 2021 14:26:02 +0800 Subject: fix target kubeletendpoint port in metrics request,the edgecore kubeletedgepoint should be stable of 10350,not the cloudside kubeletenpoint port of node Signed-off-by: cuirunxing-hub --- cloud/pkg/cloudstream/containermetrics_connection.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/cloud/pkg/cloudstream/containermetrics_connection.go b/cloud/pkg/cloudstream/containermetrics_connection.go index 4b4421b58..7122b58e8 100644 --- a/cloud/pkg/cloudstream/containermetrics_connection.go +++ b/cloud/pkg/cloudstream/containermetrics_connection.go @@ -21,11 +21,12 @@ import ( "fmt" "io" "net" - "strings" + "strconv" "github.com/emicklei/go-restful" "k8s.io/klog/v2" + "github.com/kubeedge/kubeedge/common/constants" "github.com/kubeedge/kubeedge/pkg/stream" ) @@ -74,9 +75,8 @@ func (ms *ContainerMetricsConnection) SendConnection() (stream.EdgedConnection, URL: *ms.r.Request.URL, Header: ms.r.Request.Header, } - targetPort := strings.Split(ms.r.Request.Host, ":")[1] connector.URL.Scheme = httpScheme - connector.URL.Host = net.JoinHostPort(defaultServerHost, targetPort) + connector.URL.Host = net.JoinHostPort(defaultServerHost, strconv.Itoa(constants.ServerPort)) m, err := connector.CreateConnectMessage() if err != nil { return nil, err -- cgit v1.2.3