From f4b5327ec7be9173ddfd00a05412bf65081e4088 Mon Sep 17 00:00:00 2001 From: "github-actions[bot]" <41898282+github-actions[bot]@users.noreply.github.com> Date: Mon, 13 Jan 2025 21:41:42 +0800 Subject: [PATCH] branch-2.1: [fix](session var) add need forward for batch_size #46871 (#46894) Cherry-picked from #46871 Co-authored-by: qiye --- .../src/main/java/org/apache/doris/qe/SessionVariable.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 7049fc6413..a65f750d6d 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 @@ -903,7 +903,7 @@ public class SessionVariable implements Serializable, Writable { public boolean haveQueryCache = false; // 4096 minus 16 + 16 bytes padding that in padding pod array - @VariableMgr.VarAttr(name = BATCH_SIZE, fuzzy = true, checker = "checkBatchSize") + @VariableMgr.VarAttr(name = BATCH_SIZE, fuzzy = true, checker = "checkBatchSize", needForward = true) public int batchSize = 4064; @VariableMgr.VarAttr(name = DISABLE_STREAMING_PREAGGREGATIONS, fuzzy = true)