Re: How to set jobmanager.rpc.address in TaskManger node in HA cluster

Cool, thanks for letting us know that you figured it out and what it was! > On 7. Jul 2017, at 05:52, Mu Kong wrote: > > Sorry. I didn't put high-availability: zookeeper in taskmangers' > flink-config.yml. > After I fixed this, everything went well. > > On Fri, Jul 7,

Re: How to set jobmanager.rpc.address in TaskManger node in HA cluster

Sorry. I didn't put high-availability: zookeeper in taskmangers' flink-config.yml. After I fixed this, everything went well. On Fri, Jul 7, 2017 at 11:08 AM, Mu Kong wrote: > Hi all, > > I'm trying setup an HA Flink cluster with 3 job managers and 3 task > managers. >

How to set jobmanager.rpc.address in TaskManger node in HA cluster

Hi all, I'm trying setup an HA Flink cluster with 3 job managers and 3 task managers. After executing start-cluster.sh, 3 job managers are normally started. However, the task managers are still down due to an exception showed below: org.apache.flink.util.ConfigurationException: Config parameter