增加perjob初始化时可修改kerberosInfo

dujie · dujie · commit 23f74acf85f7 · 2020-08-21T13:49:44.000+08:00
diff --git a/flinkx-launcher/src/main/java/com/dtstack/flinkx/launcher/perjob/PerJobClusterClientBuilder.java b/flinkx-launcher/src/main/java/com/dtstack/flinkx/launcher/perjob/PerJobClusterClientBuilder.java
@@ -73,6 +73,9 @@ public void init(String yarnConfDir, Configuration flinkConfig, Properties userC
         }
         userConf.forEach((key, val) -> flinkConfig.setString(key.toString(), val.toString()));
         this.flinkConfig = flinkConfig;
+        if(userConf.size()>0){
+            this.kerberosInfo = new KerberosInfo(kerberosInfo.getKrb5confPath(),kerberosInfo.getKeytab(),kerberosInfo.getPrincipal(),this.flinkConfig);
+        }
         kerberosInfo.verify();
         SecurityUtils.install(new SecurityConfiguration(flinkConfig));
 

Original file line number	Diff line number	Diff line change
`@@ -73,6 +73,9 @@ public void init(String yarnConfDir, Configuration flinkConfig, Properties userC`
`73`	`73`	`}`
`74`	`74`	`userConf.forEach((key, val) -> flinkConfig.setString(key.toString(), val.toString()));`
`75`	`75`	`this.flinkConfig = flinkConfig;`
	`76`	`+ if(userConf.size()>0){`
	`77`	`+ this.kerberosInfo = new KerberosInfo(kerberosInfo.getKrb5confPath(),kerberosInfo.getKeytab(),kerberosInfo.getPrincipal(),this.flinkConfig);`
	`78`	`+ }`
`76`	`79`	`kerberosInfo.verify();`
`77`	`80`	`SecurityUtils.install(new SecurityConfiguration(flinkConfig));`
`78`	`81`