diff --git a/pkg/controllers/servicesync/servicesync.go b/pkg/controllers/servicesync/servicesync.go index f682007a6..9eb43fbdd 100644 --- a/pkg/controllers/servicesync/servicesync.go +++ b/pkg/controllers/servicesync/servicesync.go @@ -220,7 +220,7 @@ func (e *ServiceSyncer) syncServiceAndEndpoints(ctx context.Context, fromService }, Spec: corev1.ServiceSpec{ Ports: fromService.Spec.Ports, - ClusterIP: corev1.ClusterIPNone, + ClusterIP: fromService.Spec.ClusterIP, }, } diff --git a/test/e2e/servicesync/servicesync.go b/test/e2e/servicesync/servicesync.go index a181c69b8..99c0e2ab6 100644 --- a/test/e2e/servicesync/servicesync.go +++ b/test/e2e/servicesync/servicesync.go @@ -163,6 +163,7 @@ func testMapping(ctx context.Context, fromClient kubernetes.Interface, fromNames framework.ExpectEqual(toService.Spec.Selector[translate.NamespaceLabel], fromNamespace) framework.ExpectEqual(toService.Spec.Selector[translate.MarkerLabel], translate.VClusterName) framework.ExpectEqual(toService.Spec.Selector[translate.HostLabel("test")], "test") + framework.ExpectEqual(toService.Spec.ClusterIP, fromService.Spec.ClusterIP) } // check service deletion