add log

a49a · a49a · commit db353c554510 · 2020-09-28T14:37:30.000+08:00
diff --git a/flinkx-core/src/main/java/com/dtstack/flinkx/util/FileSystemUtil.java b/flinkx-core/src/main/java/com/dtstack/flinkx/util/FileSystemUtil.java
@@ -69,6 +69,8 @@ public static void setHadoopUserName(Configuration conf){
         }
 
         try {
+            String previousUserName = UserGroupInformation.getLoginUser().getUserName();
+            LOG.info("Hadoop user from '{}' switch to '{}' with SIMPLE auth", previousUserName, hadoopUserName);
             UserGroupInformation ugi = UserGroupInformation.createRemoteUser(hadoopUserName);
             UserGroupInformation.setLoginUser(ugi);
         } catch (Exception e) {

Original file line number	Diff line number	Diff line change
`@@ -69,6 +69,8 @@ public static void setHadoopUserName(Configuration conf){`
`69`	`69`	`}`
`70`	`70`
`71`	`71`	`try {`
	`72`	`+ String previousUserName = UserGroupInformation.getLoginUser().getUserName();`
	`73`	`+ LOG.info("Hadoop user from '{}' switch to '{}' with SIMPLE auth", previousUserName, hadoopUserName);`
`72`	`74`	`UserGroupInformation ugi = UserGroupInformation.createRemoteUser(hadoopUserName);`
`73`	`75`	`UserGroupInformation.setLoginUser(ugi);`
`74`	`76`	`} catch (Exception e) {`