diff --git a/controllers/flinkcluster_converter.go b/controllers/flinkcluster_converter.go index d169b9d6..ca3e75ca 100644 --- a/controllers/flinkcluster_converter.go +++ b/controllers/flinkcluster_converter.go @@ -361,7 +361,7 @@ func getDesiredJobManagerIngress( IngressRuleValue: extensionsv1beta1.IngressRuleValue{ HTTP: &extensionsv1beta1.HTTPIngressRuleValue{ Paths: []extensionsv1beta1.HTTPIngressPath{{ - Path: "/", + Path: "/*", Backend: extensionsv1beta1.IngressBackend{ ServiceName: jobManagerServiceName, ServicePort: jobManagerServiceUIPort, diff --git a/controllers/flinkcluster_converter_test.go b/controllers/flinkcluster_converter_test.go index 26e7aef0..f0032aa1 100644 --- a/controllers/flinkcluster_converter_test.go +++ b/controllers/flinkcluster_converter_test.go @@ -532,7 +532,7 @@ func TestGetDesiredClusterState(t *testing.T) { IngressRuleValue: extensionsv1beta1.IngressRuleValue{ HTTP: &extensionsv1beta1.HTTPIngressRuleValue{ Paths: []extensionsv1beta1.HTTPIngressPath{{ - Path: "/", + Path: "/*", Backend: extensionsv1beta1.IngressBackend{ ServiceName: "flinkjobcluster-sample-jobmanager", ServicePort: intstr.FromString("ui"),