diff --git a/test/e2e/framework/service/jig.go b/test/e2e/framework/service/jig.go index 033652aa699..f8c6da7a540 100644 --- a/test/e2e/framework/service/jig.go +++ b/test/e2e/framework/service/jig.go @@ -1026,24 +1026,8 @@ func (j *TestJig) CheckServiceReachability(svc *v1.Service, pod *v1.Pod) error { } } -// CreateServicePods creates a replication controller with the label same as service. Service listens to HTTP. +// CreateServicePods creates a replication controller with the label same as service. Service listens to TCP and UDP. func (j *TestJig) CreateServicePods(replica int) error { - config := testutils.RCConfig{ - Client: j.Client, - Name: j.Name, - Image: framework.ServeHostnameImage, - Command: []string{"/agnhost", "serve-hostname"}, - Namespace: j.Namespace, - Labels: j.Labels, - PollInterval: 3 * time.Second, - Timeout: framework.PodReadyBeforeTimeout, - Replicas: replica, - } - return e2erc.RunRC(config) -} - -// CreateTCPUDPServicePods creates a replication controller with the label same as service. Service listens to TCP and UDP. -func (j *TestJig) CreateTCPUDPServicePods(replica int) error { config := testutils.RCConfig{ Client: j.Client, Name: j.Name, diff --git a/test/e2e/network/service.go b/test/e2e/network/service.go index 9f668c52e89..3bed313b6a3 100644 --- a/test/e2e/network/service.go +++ b/test/e2e/network/service.go @@ -1228,7 +1228,7 @@ var _ = SIGDescribe("Services", func() { }) framework.ExpectNoError(err) - err = jig.CreateTCPUDPServicePods(2) + err = jig.CreateServicePods(2) framework.ExpectNoError(err) execPod := e2epod.CreateExecPodOrFail(cs, ns, "execpod", nil) err = jig.CheckServiceReachability(nodePortService, execPod)