Re: TaskManagers cannot contact JobManager in Kubernetes when JobManager HA is enabled

2018-11-08 Thread Dawid Wysakowicz
Hi John, Glad you resolved the issue. Also thanks for sharing the solution with ML! Best, Dawid On 01/11/2018 16:22, John Stone wrote: > I've managed to resolve the issue. With HA enabled, you will see this > message in the logs: > > 2018-11-01 13:38:52,467 INFO > org.apache.flink.runtime.e

Re: TaskManagers cannot contact JobManager in Kubernetes when JobManager HA is enabled

2018-11-01 Thread John Stone
I've managed to resolve the issue. With HA enabled, you will see this message in the logs: 2018-11-01 13:38:52,467 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - Actor system started at akka.tcp://flink@flink-jobmanager:40641 Without HA enabled, you will see this messag

TaskManagers cannot contact JobManager in Kubernetes when JobManager HA is enabled

2018-10-31 Thread John Stone
I have successfully managed to deploy a Flink cluster in Kubernetes without JobManager high availability. Everything works great. The moment I enable high availability, TaskManagers fail to contact the JobManager. My configurations and logs are below. Can someone point me in the correct dir