Commit a57eb9eb authored by sundapeng's avatar sundapeng

[Fix-310][gateway]Configure hadoop_conf for Flink

parent 713392e5
......@@ -54,6 +54,8 @@ import com.dlink.utils.LogUtil;
**/
public abstract class YarnGateway extends AbstractGateway {
public static final String HADOOP_CONFIG = "fs.hdfs.hadoopconf";
protected YarnConfiguration yarnConfiguration;
protected YarnClient yarnClient;
......@@ -83,6 +85,10 @@ public abstract class YarnGateway extends AbstractGateway {
configuration.set(YarnConfigOptions.APPLICATION_NAME, config.getFlinkConfig().getJobName());
}
if (Asserts.isNotNullString(config.getClusterConfig().getYarnConfigPath())) {
configuration.setString(HADOOP_CONFIG, config.getClusterConfig().getYarnConfigPath());
}
if (configuration.containsKey(SecurityOptions.KERBEROS_LOGIN_KEYTAB.key())) {
try {
SecurityUtils.install(new SecurityConfiguration(configuration));
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment