diff --git a/fs_brokers/apache_hdfs_broker/src/main/java/org/apache/doris/broker/hdfs/FileSystemManager.java b/fs_brokers/apache_hdfs_broker/src/main/java/org/apache/doris/broker/hdfs/FileSystemManager.java index 1d377b1c41..076c09cd3c 100644 --- a/fs_brokers/apache_hdfs_broker/src/main/java/org/apache/doris/broker/hdfs/FileSystemManager.java +++ b/fs_brokers/apache_hdfs_broker/src/main/java/org/apache/doris/broker/hdfs/FileSystemManager.java @@ -335,7 +335,7 @@ public class FileSystemManager { conf.set(FS_HDFS_IMPL_DISABLE_CACHE, "true"); FileSystem dfsFileSystem = null; if (authentication.equals(AUTHENTICATION_SIMPLE) && - properties.containsKey(USER_NAME_KEY)) { + properties.containsKey(USER_NAME_KEY) && !Strings.isNullOrEmpty(username)) { // Use the specified 'username' as the login name UserGroupInformation ugi = UserGroupInformation.createRemoteUser(username); dfsFileSystem = ugi.doAs(new PrivilegedExceptionAction() {