This is an automated email from the ASF dual-hosted git repository.
dataroaring pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new 3efb2809e15 [fix](cloud) Fix group commit failed because access denied
in cloud mode (#34974)
3efb2809e15 is described below
commit 3efb2809e15b5eab50805341e4842a9f148a47c9
Author: meiyi <[email protected]>
AuthorDate: Fri May 17 11:08:14 2024 +0800
[fix](cloud) Fix group commit failed because access denied in cloud mode
(#34974)
---
fe/fe-core/src/main/java/org/apache/doris/load/StreamLoadHandler.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/load/StreamLoadHandler.java
b/fe/fe-core/src/main/java/org/apache/doris/load/StreamLoadHandler.java
index 47f8ed05049..4995ed4ec20 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/load/StreamLoadHandler.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/load/StreamLoadHandler.java
@@ -120,7 +120,7 @@ public class StreamLoadHandler {
ctx.setRemoteIP(request.isSetAuthCode() ? clientAddr :
request.getUserIp());
String userName =
ClusterNamespace.getNameFromFullName(request.getUser());
- if (!Strings.isNullOrEmpty(userName)) {
+ if (!request.isSetToken() && !Strings.isNullOrEmpty(userName)) {
List<UserIdentity> currentUser = Lists.newArrayList();
try {
Env.getCurrentEnv().getAuth().checkPlainPassword(userName,
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
