[FLINK-18048] Fix --host option for standalone application cluster

This closes apache#12426.
deepfield · Jun 5, 2020 · 5834373 · 5834373
1 parent 61e6f70
commit 5834373
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 0 deletions.
diff --git a/...he/flink/container/entrypoint/StandaloneApplicationClusterConfigurationParserFactory.java b/...he/flink/container/entrypoint/StandaloneApplicationClusterConfigurationParserFactory.java
@@ -68,6 +68,7 @@ public Options getOptions() {
  options.addOption(JOB_CLASS_NAME_OPTION);
  options.addOption(JOB_ID_OPTION);
  options.addOption(DYNAMIC_PROPERTY_OPTION);
+ options.addOption(HOST_OPTION);
  options.addOption(CliFrontendParser.SAVEPOINT_PATH_OPTION);
  options.addOption(CliFrontendParser.SAVEPOINT_ALLOW_NON_RESTORED_OPTION);
 

diff --git a/...link/container/entrypoint/StandaloneApplicationClusterConfigurationParserFactoryTest.java b/...link/container/entrypoint/StandaloneApplicationClusterConfigurationParserFactoryTest.java
@@ -233,4 +233,12 @@ public void testShortOptions() throws FlinkParseException {
  assertThat(savepointRestoreSettings.allowNonRestoredState(), is(true));
  }
 
+ @Test
+ public void testHostOption() throws FlinkParseException {
+ final String hostName = "user-specified-hostname";
+ final String[] args = {"--configDir", confDirPath, "--job-classname", "foobar", "--host", hostName};
+ final StandaloneApplicationClusterConfiguration applicationClusterConfiguration = commandLineParser.parse(args);
+ assertThat(applicationClusterConfiguration.getHostname(), is(hostName));
+ }
+
 }