From e54fd581f4e624239e4d1da743402c467009923c Mon Sep 17 00:00:00 2001
From: Seth Saperstein <99828679+sethsaperstein-lyft@users.noreply.github.com>
Date: Wed, 10 Jan 2024 13:30:15 -0800
Subject: [PATCH] Headless Service (#299)

## overview
Change services to headless service as ClusterIP is not required. Apache
OSS operator also uses headless services.
---
 integ/test.sh                                  | 2 +-
 pkg/controller/flink/job_manager_controller.go | 7 +++++--
 2 files changed, 6 insertions(+), 3 deletions(-)

diff --git a/integ/test.sh b/integ/test.sh
index aa25375f..0a8b997c 100755
--- a/integ/test.sh
+++ b/integ/test.sh
@@ -6,4 +6,4 @@ export INTEGRATION=true
 export OPERATOR_IMAGE=flinkk8soperator:local
 
 cd $(dirname "$0")
-go test -p 1 -timeout 40m -check.vv IntegSuite
+go test -p 1 -timeout 60m -check.vv IntegSuite
diff --git a/pkg/controller/flink/job_manager_controller.go b/pkg/controller/flink/job_manager_controller.go
index a3f71807..3fd8a521 100644
--- a/pkg/controller/flink/job_manager_controller.go
+++ b/pkg/controller/flink/job_manager_controller.go
@@ -221,8 +221,11 @@ func FetchJobManagerServiceCreateObj(app *v1beta1.FlinkApplication, selector str
 			Labels: GetCommonAppLabels(app),
 		},
 		Spec: coreV1.ServiceSpec{
-			Ports:    getJobManagerServicePorts(app),
-			Selector: serviceLabels,
+			Ports:      getJobManagerServicePorts(app),
+			Selector:   serviceLabels,
+			Type:       coreV1.ServiceTypeClusterIP,
+			ClusterIP:  "None",
+			ClusterIPs: []string{},
 		},
 	}
 }