提交 09495d1b 编写于 作者: K Kostas Kloudas

[FLINK-17648][yarn] Make YarnApplicationClusterEntryPoint use the yarn.application-master.port

This closes #12109.
上级 80f4afbb
......@@ -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);
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册