You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by kk...@apache.org on 2020/05/13 11:00:48 UTC
[flink] branch master updated: [FLINK-17648][yarn] Make
YarnApplicationClusterEntryPoint use the yarn.application-master.port
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 <kk...@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);