Hi All-

  I am having trouble using the FlinkShell against a standalone HA cluster
(recovery.mode: zookeeper)

 If I remove the zookeeper conf from flink-conf.yaml and restart the
cluster, I can execute stuff from the shell just fine. (One master is
running)

  Adding back the config, and restarting, the cluster is up, with
taskmanagers registered, etc, but even when pointing the FlinkShell at the
master and its dynamically chosen port, I get an error "he program
execution failed: Communication with JobManager failed: Lost connection to
the JobManager."

Is there a requirement that multiple masters be up, or some other way to
tell FlinkShell that the cluster is a standalone HA cluster?

Thanks!
SC

Reply via email to