[flink] branch release-1.10 updated: [FLINK-18048] Fix --host option for standalone job cluster

[kkloudas]

This is an automated email from the ASF dual-hosted git repository.

kkloudas pushed a commit to branch release-1.10
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/release-1.10 by this push:
     new 855f799  [FLINK-18048] Fix --host option for standalone job cluster
855f799 is described below

commit 855f799d9919348619f17cfcb4d6544dc02afdfb
Author: wangyang0918 <danrtsey...@alibaba-inc.com>
AuthorDate: Mon Jun 1 19:40:14 2020 +0800

    [FLINK-18048] Fix --host option for standalone job cluster
    
    This closes #12495.
---
 .../StandaloneJobClusterConfigurationParserFactory.java           | 1 +
 .../StandaloneJobClusterConfigurationParserFactoryTest.java       | 8 ++++++++
 2 files changed, 9 insertions(+)

diff --git 
a/flink-container/src/main/java/org/apache/flink/container/entrypoint/StandaloneJobClusterConfigurationParserFactory.java
 
b/flink-container/src/main/java/org/apache/flink/container/entrypoint/StandaloneJobClusterConfigurationParserFactory.java
index a99e277..ea03313 100644
--- 
a/flink-container/src/main/java/org/apache/flink/container/entrypoint/StandaloneJobClusterConfigurationParserFactory.java
+++ 
b/flink-container/src/main/java/org/apache/flink/container/entrypoint/StandaloneJobClusterConfigurationParserFactory.java
@@ -68,6 +68,7 @@ public class StandaloneJobClusterConfigurationParserFactory 
implements ParserRes
                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/flink-container/src/test/java/org/apache/flink/container/entrypoint/StandaloneJobClusterConfigurationParserFactoryTest.java
 
b/flink-container/src/test/java/org/apache/flink/container/entrypoint/StandaloneJobClusterConfigurationParserFactoryTest.java
index 4a72d3a..ad1cdb5 100644
--- 
a/flink-container/src/test/java/org/apache/flink/container/entrypoint/StandaloneJobClusterConfigurationParserFactoryTest.java
+++ 
b/flink-container/src/test/java/org/apache/flink/container/entrypoint/StandaloneJobClusterConfigurationParserFactoryTest.java
@@ -178,4 +178,12 @@ public class 
StandaloneJobClusterConfigurationParserFactoryTest extends TestLogg
                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 StandaloneJobClusterConfiguration 
applicationClusterConfiguration = commandLineParser.parse(args);
+               assertThat(applicationClusterConfiguration.getHostname(), 
is(hostName));
+       }
+
 }