Merge branch 'hotfix_1.10_4.0.x_31773' into '1.10_release_4.0.x'

[fix] kerberos_login_keyTab npe

See merge request dt-insight-engine/flinkStreamSQL!176

Author: simenliuxing

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

@@ -99,13 +99,14 @@ public void exec() throws Exception {
     }
 
     private void dumpSameKeytab(Configuration flinkConfiguration, List<File> shipFiles) {
-        String flinkKeytab = Stream
-                .of(flinkConfiguration.getString(SecurityOptions.KERBEROS_LOGIN_KEYTAB).split(File.separator))
-                .reduce((a, b) -> b)
-                .get();
-        shipFiles.removeIf(f -> f.getName().equals(flinkKeytab));
+        Optional.ofNullable(flinkConfiguration.getString(SecurityOptions.KERBEROS_LOGIN_KEYTAB))
+                .ifPresent(x ->
+                        shipFiles.removeIf(f ->
+                                f.getName().equals(Stream
+                                        .of(x.split(File.separator))
+                                        .reduce((a, b) -> b)
+                                        .get())));
     }
-
     private void appendApplicationConfig(Configuration flinkConfig, JobParamsInfo jobParamsInfo) {
         if (!StringUtils.isEmpty(jobParamsInfo.getName())) {
             flinkConfig.setString(YarnConfigOptions.APPLICATION_NAME, jobParamsInfo.getName());