[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

HA jobmanagers redirect to ip address of leader instead of hostname


I'm having some troubles with Flink jobmanagers in a HA setup within OpenShift.

I have three jobmanagers, a Zookeeper cluster and a loadbalancer (Openshift/Kubernetes Route) for the web ui / rest server on the jobmanagers. Everything works fine, as long as the loadbalancer connects to the leader. However, when the leader changes and the loadbalancer connects to a non-leader, the jobmanager redirects to a leader using the ip address of the host. Since the routing in our network is done using hostnames, it doesn't know how to find the node using the ip address and results in a timeout.

So I have a few questions:
1. Why is Flink using the ip addresses instead of the hostname which are configured in the config? Other times it does use the hostname, like the info send to Zookeeper. 2. Is there another way of coping with connections to non-leaders instead of redirects? Maybe proxying through a non-leader to the leader?