You are right that this config key is not needed in this case. The ClusterClient has been refactored between Flink 1.0 and 1.1 and the config parsing might be too strict in this case. It expects the IPC address to be set, which is not necessary as you say. It should be very easy to fix for 1.1.2. Let's confirm that it is actually a bug with Max and file an issue afterwards.
@Max: can you confirm whether this is correct? On Tue, Aug 23, 2016 at 7:24 AM, Hironori Ogibayashi <ogibaya...@gmail.com> wrote: > Hello, > > After I upgraded to 1.1.1, I am getting error when submitting job with > "flink run" > > The command and result is like this. It has been working with Flink 1.0.3. > > --- > % FLINK_CONF_DIR=~/opt/flink/conf ~/opt/flink/flink-1.1.1/bin/flink > run -c MyJob target/my-flink-job.jar > > ------------------------------------------------------------ > The program finished with the following exception: > > java.lang.RuntimeException: Failed to retrieve JobManager address > at > org.apache.flink.client.program.ClusterClient.getJobManagerAddressFromConfig(ClusterClient.java:244) > at > org.apache.flink.client.program.StandaloneClusterClient.getClusterIdentifier(StandaloneClusterClient.java:78) > at > org.apache.flink.client.CliFrontend.createClient(CliFrontend.java:887) > at org.apache.flink.client.CliFrontend.run(CliFrontend.java:237) > at > org.apache.flink.client.CliFrontend.parseParameters(CliFrontend.java:1005) > at org.apache.flink.client.CliFrontend.main(CliFrontend.java:1048) > Caused by: java.lang.IllegalArgumentException: hostname can't be null > at java.net.InetSocketAddress.checkHost(InetSocketAddress.java:149) > at java.net.InetSocketAddress.<init>(InetSocketAddress.java:216) > at > org.apache.flink.client.program.ClusterClient.getJobManagerAddressFromConfig(ClusterClient.java:242) > ... 5 more > --- > > I am using JobManager HA and I set "recovery.mode: zookeeper", > recovery.zookeeper.quorum, recovery.zookeeper.path.root is my > flink-conf.yaml. > So, the client should be able to get JobManager address from zookeeper. > If I explicitly specify JobManager address with -m option, it works. > > Am I missing something? > > Regards, > Hironori Ogibayashi
