Skip to content

Commit ff6b4c5

Browse files
committed
[fix] kerberos_login_keyTab npe
1 parent 75a66fb commit ff6b4c5

File tree

1 file changed

+7
-6
lines changed

1 file changed

+7
-6
lines changed

launcher/src/main/java/com/dtstack/flink/sql/launcher/executor/YarnJobClusterExecutor.java

Lines changed: 7 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -99,13 +99,14 @@ public void exec() throws Exception {
9999
}
100100

101101
private void dumpSameKeytab(Configuration flinkConfiguration, List<File> shipFiles) {
102-
String flinkKeytab = Stream
103-
.of(flinkConfiguration.getString(SecurityOptions.KERBEROS_LOGIN_KEYTAB).split(File.separator))
104-
.reduce((a, b) -> b)
105-
.get();
106-
shipFiles.removeIf(f -> f.getName().equals(flinkKeytab));
102+
Optional.ofNullable(flinkConfiguration.getString(SecurityOptions.KERBEROS_LOGIN_KEYTAB))
103+
.ifPresent(x ->
104+
shipFiles.removeIf(f ->
105+
f.getName().equals(Stream
106+
.of(x.split(File.separator))
107+
.reduce((a, b) -> b)
108+
.get())));
107109
}
108-
109110
private void appendApplicationConfig(Configuration flinkConfig, JobParamsInfo jobParamsInfo) {
110111
if (!StringUtils.isEmpty(jobParamsInfo.getName())) {
111112
flinkConfig.setString(YarnConfigOptions.APPLICATION_NAME, jobParamsInfo.getName());

0 commit comments

Comments
 (0)