[doris] branch master updated: [fix](session-variable) repeat_max_num should be forwarded (#15840)

[yiguolei]

This is an automated email from the ASF dual-hosted git repository.

yiguolei 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 ea0ef0d880 [fix](session-variable) repeat_max_num should be forwarded 
(#15840)
ea0ef0d880 is described below

commit ea0ef0d880432eef807f12661ae0c80349178cf7
Author: Mingyu Chen <morning...@163.com>
AuthorDate: Thu Jan 12 10:51:35 2023 +0800

    [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.
---
 fe/fe-core/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);


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org