fix npe and load local keytab file

DTStack · Apr 8, 2020 · cdde2a6 · cdde2a6
1 parent 548a245
commit cdde2a6
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 1 deletion.
diff --git a/flinkx-core/src/main/java/com/dtstack/flinkx/authenticate/KerberosUtil.java b/flinkx-core/src/main/java/com/dtstack/flinkx/authenticate/KerberosUtil.java
@@ -226,6 +226,11 @@ public static String getPrincipalFileName(Map<String, Object> config) {
             throw new RuntimeException("[principalFile]必须指定");
         }
 
+        boolean useLocalFile = MapUtils.getBooleanValue(config, KEY_USE_LOCAL_FILE);
+        if (useLocalFile) {
+            return fileName;
+        }
+
         if (fileName.contains(SP)) {
             fileName = fileName.substring(fileName.lastIndexOf(SP) + 1);
         }

diff --git a/flinkx-core/src/main/java/com/dtstack/flinkx/inputformat/BaseRichInputFormat.java b/flinkx-core/src/main/java/com/dtstack/flinkx/inputformat/BaseRichInputFormat.java
@@ -71,7 +71,7 @@ public abstract class BaseRichInputFormat extends org.apache.flink.api.common.io
 
     protected FormatState formatState;
 
-    protected TestConfig testConfig;
+    protected TestConfig testConfig = TestConfig.defaultConfig();
 
     protected transient BaseMetric inputMetric;