HA jobmanagers redirect to ip address of leader instead of hostname

Hi, 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 t

Re: 答复: Flink1.6.0 submit job and got "No content to map due to end-of-input" Error

Hi, I'm running Flink 1.5.4 and all dependencies in the job rely on 1.5.4. However, I still get this error. According to the JIRA issue it should be fixed in 1.5.4 as well. Since I'm using Apache Beam to build the jar, I can't move to version 1.6.x. What could it be? Cheers, Jeroen On 07-

Re: HA jobmanagers redirect to ip address of leader instead of hostname

n Steggink On 08-Nov-18 11:40, Jeroen Steggink | knowsy wrote: Hi Till, Thanks for your reply. We are running version 1.5.4. We can't upgrade to 1.6.x because we are using Apache Beam which doesn't support 1.6.x yet. I have also made a Jira issue about this: https://issues.apac

Jars uploaded to taskmanager are deleted but not free'ed by OS

Hi, I'm having some troubles running the Flink taskmanager in a Docker container (OpenShift). The container's internal storage is filling up because the deleted jar files in blob storage are probably still in use and therefore resources are not free'ed. We are using Apache Beam to start an A

Jars uploaded to jobmanager are deleted but not free'ed by OS

Sorry, I meant the jobmanager, not the taskmanager. On 18-Apr-18 15:44, Jeroen Steggink | knowsy wrote: Hi, I'm having some troubles running the Flink taskmanager in a Docker container (OpenShift). The container's internal storage is filling up because the deleted jar files in bl