[kerberos][认证yarnclient]

yanxi0227 · yanxi0227 · commit 5f8eb2b46131 · 2019-12-18T03:55:18.000+08:00
diff --git a/launcher/src/main/java/com/dtstack/flink/sql/launcher/perjob/PerJobClusterClientBuilder.java b/launcher/src/main/java/com/dtstack/flink/sql/launcher/perjob/PerJobClusterClientBuilder.java
@@ -173,7 +173,7 @@ private boolean openKerberos(Properties conf){
 
     private void login(org.apache.hadoop.conf.Configuration conf, String keytab, String principal) throws IOException {
         UserGroupInformation.setConfiguration(conf);
-        UserGroupInformation.loginUserFromKeytab(keytab, principal);
+        UserGroupInformation.loginUserFromKeytab(principal, keytab);
         LOG.info("login successfully! keytab: " + keytab + "principal: " + principal);
         LOG.info("UGI: " + UserGroupInformation.getCurrentUser());
     }

Original file line number	Diff line number	Diff line change
`@@ -173,7 +173,7 @@ private boolean openKerberos(Properties conf){`
`173`	`173`
`174`	`174`	`private void login(org.apache.hadoop.conf.Configuration conf, String keytab, String principal) throws IOException {`
`175`	`175`	`UserGroupInformation.setConfiguration(conf);`
`176`		`- UserGroupInformation.loginUserFromKeytab(keytab, principal);`
	`176`	`+ UserGroupInformation.loginUserFromKeytab(principal, keytab);`
`177`	`177`	`LOG.info("login successfully! keytab: " + keytab + "principal: " + principal);`
`178`	`178`	`LOG.info("UGI: " + UserGroupInformation.getCurrentUser());`
`179`	`179`	`}`