Adding new service port to Job manager service

[rmuthupandian]

Hi,
We are trying to expose metrics vis Prometheus reporter. We added prometheus reporter and port details to flink config. We want this port to be exposed from service. But I see only below mentioned ports exposed.

flinkk8soperator/pkg/controller/flink/job_manager_controller.go

Lines 216 to 237 in f687fe5

	func getJobManagerPorts(app *v1beta1.FlinkApplication) []coreV1.ContainerPort {
	return []coreV1.ContainerPort{
	{
	Name: FlinkRPCPortName,
	ContainerPort: getRPCPort(app),
	},
	{
	Name: FlinkBlobPortName,
	ContainerPort: getBlobPort(app),
	},
	{
	Name: FlinkQueryPortName,
	ContainerPort: getQueryPort(app),
	},
	{
	Name: FlinkUIPortName,
	ContainerPort: getUIPort(app),
	},
	{
	Name: FlinkInternalMetricPortName,
	ContainerPort: getInternalMetricsQueryPort(app),
	},

Is there a way we can add additional ports to the spec. ?

[anandswaminathan]

@rmuthupandian

Why do you want the ports to be exposed in the Jobmanager service ? From what I understand, prometheus should be able to scrape metrics directly from the Kubernetes resources (pods) right. You simple just need to add annotations - details.

[rmuthupandian]

Our internal prometheus integration depends on service port to scrape metrics. Hence we have to expose the port via service only.

[anandswaminathan]

Oh interesting, it is not possible to do that from the spec.

You will have to implement - mutating admission controller webhook on your end to accomplish that.