From ea0ef0d880432eef807f12661ae0c80349178cf7 Mon Sep 17 00:00:00 2001 From: Mingyu Chen Date: Thu, 12 Jan 2023 10:51:35 +0800 Subject: [PATCH] [fix](session-variable) repeat_max_num should be forwarded (#15840) repeat_max_num should be forwarded to master, or stmt like: insert into tbl values(repeat("a", 1000)) will not be affected by this session variable. --- .../src/main/java/org/apache/doris/qe/SessionVariable.java | 2 +- fe/fe-core/src/main/java/org/apache/doris/qe/VariableMgr.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/SessionVariable.java b/fe/fe-core/src/main/java/org/apache/doris/qe/SessionVariable.java index 2c9390185d..01b368b26b 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/qe/SessionVariable.java +++ b/fe/fe-core/src/main/java/org/apache/doris/qe/SessionVariable.java @@ -647,7 +647,7 @@ public class SessionVariable implements Serializable, Writable { @VariableMgr.VarAttr(name = ENABLE_SHARE_HASH_TABLE_FOR_BROADCAST_JOIN) public boolean enableShareHashTableForBroadcastJoin = true; - @VariableMgr.VarAttr(name = REPEAT_MAX_NUM) + @VariableMgr.VarAttr(name = REPEAT_MAX_NUM, needForward = true) public int repeatMaxNum = 10000; @VariableMgr.VarAttr(name = GROUP_CONCAT_MAX_LEN) diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/VariableMgr.java b/fe/fe-core/src/main/java/org/apache/doris/qe/VariableMgr.java index 36468bc6f7..3a5e50ff2e 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/qe/VariableMgr.java +++ b/fe/fe-core/src/main/java/org/apache/doris/qe/VariableMgr.java @@ -418,7 +418,7 @@ public class VariableMgr { } } - private static String getValue(SessionVariable var, String name, SetType setType) throws AnalysisException { + private static String getValue(SessionVariable var, String name, SetType setType) throws AnalysisException { VarContext ctx = ctxByVarName.get(name); if (ctx == null) { ErrorReport.reportAnalysisException(ErrorCode.ERR_UNKNOWN_SYSTEM_VARIABLE, name);