change 3

apache · Jul 16, 2024 · be0bf2f · be0bf2f
1 parent 9514e32
commit be0bf2f
Showing 1 changed file with 5 additions and 18 deletions.
diff --git a/.../main/java/org/apache/doris/common/security/authentication/HadoopSimpleAuthenticator.java b/.../main/java/org/apache/doris/common/security/authentication/HadoopSimpleAuthenticator.java
@@ -21,38 +21,25 @@
 import org.apache.logging.log4j.LogManager;
 import org.apache.logging.log4j.Logger;
 
-import java.io.IOException;
 import java.security.PrivilegedExceptionAction;
 
 public class HadoopSimpleAuthenticator implements HadoopAuthenticator {
     private static final Logger LOG = LogManager.getLogger(HadoopSimpleAuthenticator.class);
-    private final SimpleAuthenticationConfig config;
-    private UserGroupInformation ugi;
+    private final UserGroupInformation ugi;
 
     public HadoopSimpleAuthenticator(SimpleAuthenticationConfig config) {
-        this.config = config;
-    }
-
-    @Override
-    public UserGroupInformation getUGI() {
         String hadoopUserName = config.getUsername();
         if (hadoopUserName == null) {
             hadoopUserName = "hadoop";
             config.setUsername(hadoopUserName);
             LOG.debug(AuthenticationConfig.HADOOP_USER_NAME + " is unset, use default user: hadoop");
         }
-        try {
-            // get login user just for simple auth
-            ugi = UserGroupInformation.getLoginUser();
-            if (ugi.getUserName().equals(hadoopUserName)) {
-                return ugi;
-            }
-        } catch (IOException e) {
-            LOG.warn("A SecurityException occurs with simple, do login immediately.", e);
-        }
         ugi = UserGroupInformation.createRemoteUser(hadoopUserName);
-        UserGroupInformation.setLoginUser(ugi);
         LOG.debug("Login by proxy user, hadoop.username: {}", hadoopUserName);
+    }
+
+    @Override
+    public UserGroupInformation getUGI() {
         return ugi;
     }