diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java b/fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java index 9be2abb0d4..a8a08fb0e6 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java +++ b/fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java @@ -380,7 +380,9 @@ public class Coordinator implements CoordInterface { this.queryOptions.setResourceLimit(resourceLimit); } // set exec mem limit - long memLimit = Env.getCurrentEnv().getAuth().getExecMemLimit(qualifiedUser); + long maxExecMemByte = connectContext.getSessionVariable().getMaxExecMemByte(); + long memLimit = maxExecMemByte > 0 ? maxExecMemByte : + Env.getCurrentEnv().getAuth().getExecMemLimit(qualifiedUser); if (memLimit > 0) { // overwrite the exec_mem_limit from session variable; this.queryOptions.setMemLimit(memLimit);