[flink] branch master updated: [FLINK-17648][yarn] Make YarnApplicationClusterEntryPoint use the yarn.application-master.port

[kkloudas]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new 09495d1  [FLINK-17648][yarn] Make YarnApplicationClusterEntryPoint use 
the yarn.application-master.port
09495d1 is described below

commit 09495d1bb4174e4ad32e5c62ca51a564aec1dbca
Author: Kostas Kloudas <kklou...@gmail.com>
AuthorDate: Wed May 13 09:20:01 2020 +0200

    [FLINK-17648][yarn] Make YarnApplicationClusterEntryPoint use the 
yarn.application-master.port
    
    This closes #12109.
---
 .../flink/yarn/entrypoint/YarnApplicationClusterEntryPoint.java     | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git 
a/flink-yarn/src/main/java/org/apache/flink/yarn/entrypoint/YarnApplicationClusterEntryPoint.java
 
b/flink-yarn/src/main/java/org/apache/flink/yarn/entrypoint/YarnApplicationClusterEntryPoint.java
index dd1ce3b..c6e9fca 100644
--- 
a/flink-yarn/src/main/java/org/apache/flink/yarn/entrypoint/YarnApplicationClusterEntryPoint.java
+++ 
b/flink-yarn/src/main/java/org/apache/flink/yarn/entrypoint/YarnApplicationClusterEntryPoint.java
@@ -35,6 +35,7 @@ import org.apache.flink.runtime.util.JvmShutdownSafeguard;
 import org.apache.flink.runtime.util.SignalHandler;
 import org.apache.flink.util.FlinkException;
 import org.apache.flink.util.Preconditions;
+import org.apache.flink.yarn.configuration.YarnConfigOptions;
 
 import org.apache.hadoop.yarn.api.ApplicationConstants;
 
@@ -56,6 +57,11 @@ public final class YarnApplicationClusterEntryPoint extends 
ApplicationClusterEn
                super(configuration, program, 
YarnResourceManagerFactory.getInstance());
        }
 
+       @Override
+       protected String getRPCPortRange(Configuration configuration) {
+               return 
configuration.getString(YarnConfigOptions.APPLICATION_MASTER_PORT);
+       }
+
        public static void main(final String[] args) {
                // startup checks and logging
                EnvironmentInformation.logEnvironmentInfo(LOG, 
YarnApplicationClusterEntryPoint.class.getSimpleName(), args);