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.entrypoint.ClusterEntrypoint         - Actor system 
> started at akka.tcp://flink@flink-jobmanager:40641
>
> Without 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:6123
>
> HA causes a random port assignment for the ResourceManager portion of the 
> JobManager.  This can be controlled by setting the 
> high-availability.jobmanager.port to a fixed port and exposing it in the 
> Kubernetes network configuration.

Attachment: signature.asc
Description: OpenPGP digital signature

Reply via email to