This is an automated email from the ASF dual-hosted git repository. kxiao pushed a commit to branch branch-2.0 in repository https://gitbox.apache.org/repos/asf/doris.git
commit 7b33457ce0e82c43e8c645854effba1a048b9bb7 Author: Guangdong Liu <[email protected]> AuthorDate: Sat Oct 7 20:15:25 2023 +0800 [bugfix](set_var) fix sql level exec_mem_limit does not take effect (#25043) --- fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) 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 14d720540ea..c145244f79d 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 @@ -373,7 +373,9 @@ public class Coordinator { 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); --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
