Skip to content

Commit 93ed13a

Browse files
committed
add security config
1 parent 0a7f3f9 commit 93ed13a

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

launcher/src/main/java/com/dtstack/flink/sql/launcher/factory/YarnClusterClientFactory.java

+4
Original file line numberDiff line numberDiff line change
@@ -23,6 +23,8 @@
2323
import org.apache.flink.configuration.ConfigConstants;
2424
import org.apache.flink.configuration.Configuration;
2525
import org.apache.flink.core.fs.FileSystem;
26+
import org.apache.flink.runtime.security.SecurityConfiguration;
27+
import org.apache.flink.runtime.security.SecurityUtils;
2628
import org.apache.flink.util.FileUtils;
2729
import org.apache.flink.util.function.FunctionUtils;
2830
import org.apache.flink.yarn.YarnClientYarnClusterInformationRetriever;
@@ -54,6 +56,8 @@ public ClusterDescriptor createClusterDescriptor(String yarnConfDir, Configurati
5456
flinkConfig.setString(ConfigConstants.PATH_HADOOP_CONFIG, yarnConfDir);
5557
FileSystem.initialize(flinkConfig, null);
5658

59+
SecurityUtils.install(new SecurityConfiguration(flinkConfig));
60+
5761
YarnConfiguration yarnConf = getYarnConf(yarnConfDir);
5862
YarnClient yarnClient = YarnClient.createYarnClient();
5963
yarnClient.init(yarnConf);

0 commit comments

Comments
 (0)