Fix the problem in fetching user info when the flink application doesn't have hadoop dependencies.

Davidhua1996 · Davidhua1996 · commit 770072f91402 · 2022-10-24T17:30:50.000+08:00
diff --git a/streamis-jobmanager/streamis-job-log/flink-streamis-log-collector/src/main/java/com/webank/wedatasphere/streamis/jobmanager/log/collector/flink/FlinkStreamisConfigAutowired.java b/streamis-jobmanager/streamis-job-log/flink-streamis-log-collector/src/main/java/com/webank/wedatasphere/streamis/jobmanager/log/collector/flink/FlinkStreamisConfigAutowired.java
@@ -60,7 +60,7 @@ public StreamisLogAppenderConfig logAppenderConfig(StreamisLogAppenderConfig.Bui
         }
         String hadoopUser = EnvironmentInformation.getHadoopUser();
         if (hadoopUser.equals("<no hadoop dependency found>") || hadoopUser.equals("<unknown>")){
-            hadoopUser = "";
+            hadoopUser = System.getProperty("user.name");
         }
         return builder.setRpcConnTimeout(this.configuration.getInteger(LOG_RPC_CONN_TIMEOUT))
                 .setRpcSocketTimeout(this.configuration.getInteger(LOG_RPC_SOCKET_TIMEOUT))

Original file line number	Diff line number	Diff line change
`@@ -60,7 +60,7 @@ public StreamisLogAppenderConfig logAppenderConfig(StreamisLogAppenderConfig.Bui`
`60`	`60`	`}`
`61`	`61`	`String hadoopUser = EnvironmentInformation.getHadoopUser();`
`62`	`62`	`if (hadoopUser.equals("<no hadoop dependency found>") \|\| hadoopUser.equals("<unknown>")){`
`63`		`- hadoopUser = "";`
	`63`	`+ hadoopUser = System.getProperty("user.name");`
`64`	`64`	`}`
`65`	`65`	`return builder.setRpcConnTimeout(this.configuration.getInteger(LOG_RPC_CONN_TIMEOUT))`
`66`	`66`	`.setRpcSocketTimeout(this.configuration.getInteger(LOG_RPC_SOCKET_TIMEOUT))`