This is an automated email from the ASF dual-hosted git repository.
morningman pushed a commit to branch branch-2.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.0 by this push:
new eec95dde5a3 [fix](kerberos) fix kerberos ugi login method (#36241)
eec95dde5a3 is described below
commit eec95dde5a3744ae6138cb28bcb663896f8fcf65
Author: slothever <[email protected]>
AuthorDate: Sun Jun 16 23:13:03 2024 +0800
[fix](kerberos) fix kerberos ugi login method (#36241)
introduced from https://github.com/apache/doris/pull/30595
---
.../hudi-scanner/src/main/java/org/apache/doris/hudi/Utils.java | 8 +++++---
.../java/org/apache/doris/catalog/HiveMetaStoreClientHelper.java | 7 +++++--
2 files changed, 10 insertions(+), 5 deletions(-)
diff --git
a/fe/be-java-extensions/hudi-scanner/src/main/java/org/apache/doris/hudi/Utils.java
b/fe/be-java-extensions/hudi-scanner/src/main/java/org/apache/doris/hudi/Utils.java
index 9c4d3f2da4b..f1fcb9d2bcc 100644
---
a/fe/be-java-extensions/hudi-scanner/src/main/java/org/apache/doris/hudi/Utils.java
+++
b/fe/be-java-extensions/hudi-scanner/src/main/java/org/apache/doris/hudi/Utils.java
@@ -60,11 +60,13 @@ public class Utils {
}
} else {
String hadoopUserName = conf.get(Constants.HADOOP_USER_NAME);
- if (hadoopUserName != null) {
- return UserGroupInformation.createRemoteUser(hadoopUserName);
+ if (hadoopUserName == null) {
+ hadoopUserName = "hadoop";
}
+ UserGroupInformation ugi =
UserGroupInformation.createRemoteUser(hadoopUserName);
+ UserGroupInformation.setLoginUser(ugi);
+ return ugi;
}
- return null;
}
public static long getCurrentProcId() {
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/catalog/HiveMetaStoreClientHelper.java
b/fe/fe-core/src/main/java/org/apache/doris/catalog/HiveMetaStoreClientHelper.java
index 40264f47e95..cf228e8f321 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/catalog/HiveMetaStoreClientHelper.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/catalog/HiveMetaStoreClientHelper.java
@@ -929,9 +929,12 @@ public class HiveMetaStoreClientHelper {
}
} else {
String hadoopUserName = conf.get(HdfsResource.HADOOP_USER_NAME);
- if (hadoopUserName != null) {
- ugi = UserGroupInformation.createRemoteUser(hadoopUserName);
+ if (hadoopUserName == null) {
+ hadoopUserName = "hadoop";
+ LOG.debug(HdfsResource.HADOOP_USER_NAME + " is unset, use
default user: hadoop");
}
+ ugi = UserGroupInformation.createRemoteUser(hadoopUserName);
+ UserGroupInformation.setLoginUser(ugi);
}
return ugi;
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
