diff --git a/fe/fe-core/src/main/java/org/apache/doris/mysql/privilege/Auth.java b/fe/fe-core/src/main/java/org/apache/doris/mysql/privilege/Auth.java index 59ff2da6be..cd47128bee 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/mysql/privilege/Auth.java +++ b/fe/fe-core/src/main/java/org/apache/doris/mysql/privilege/Auth.java @@ -61,6 +61,7 @@ import org.apache.doris.persist.LdapInfo; import org.apache.doris.persist.PrivInfo; import org.apache.doris.qe.ConnectContext; import org.apache.doris.resource.Tag; +import org.apache.doris.resource.workloadgroup.WorkloadGroupMgr; import org.apache.doris.thrift.TPrivilegeStatus; import com.google.common.base.Joiner; @@ -386,6 +387,11 @@ public class Auth implements Writable { readLock(); try { Set roles = getRolesByUserWithLdap(currentUser); + // currently stream load not support ip based auth, so normal should not auth temporary + // need remove later + if (WorkloadGroupMgr.DEFAULT_GROUP_NAME.equals(workloadGroupName)) { + return true; + } for (Role role : roles) { if (role.checkWorkloadGroupPriv(workloadGroupName, wanted)) { return true;