Hi All I m battling to get the flink operator working with t Apache Flink #troubleshooting

Hi All - I'm battling to get the flink operator wo...

Richard Noble

10/12/2023, 11:01 AM

Hi All - I'm battling to get the flink operator working with the AWS application load balancer. The error I get, when describing my ingress is

Copy code

Warning  FailedDeployModel  88s   ingress  Failed deploy model due to InvalidParameter: 1 validation error(s) found.
- minimum field value of 1, CreateTargetGroupInput.Port.

From some debugging this seems to be due to my rest service being exposed using ClusterIP as opposed to LoadBalancer or NodePort. So, I've tried updating ConfigMaps, changing values and a whole bunch of other options to make that change, but I only ever get the ClusterIP set.

Copy code

interactive-rest                 ClusterIP   172.20.159.34   <none>        8081/TCP            4m7s

Anyone know what I'm missing? It feels like it should be obvious...

Richard Noble

10/12/2023, 11:04 AM

in case it helps, my values.yaml does contain:

Copy code

flink-conf.yaml: |+
    # Flink Config Overrides
    kubernetes.operator.metrics.reporter.slf4j.factory.class: org.apache.flink.metrics.slf4j.Slf4jReporterFactory
    kubernetes.operator.metrics.reporter.slf4j.interval: 5 MINUTE
    kubernetes.operator.reconcile.interval: 15 s
    kubernetes.operator.observer.progress-check.interval: 5 s
    
    kubernetes.rest-service.exposed.type: LoadBalancer

Richard Noble

10/12/2023, 4:26 PM

I have since managed to get the ClusterIP working using ALB - but I'd still be interested in why I can't change the

kubernetes.rest-service.exposed.type

using the operator

Open in Slack

Previous Next