924060929 commented on code in PR #63366:
URL: https://github.com/apache/doris/pull/63366#discussion_r3259594757
##########
fe/fe-core/src/main/java/org/apache/doris/qe/SessionVariable.java:
##########
@@ -1598,6 +1600,12 @@ public enum IgnoreSplitType {
"Whether to enable local shuffle on pipelineX engine."},
needForward = true)
private boolean enableLocalShuffle = true;
+ @VarAttrDef.VarAttr(
+ name = ENABLE_LOCAL_SHUFFLE_PLANNER, fuzzy = false, varType =
VariableAnnotation.EXPERIMENTAL,
+ description = {"是否在FE规划Local Shuffle",
+ "Whether to plan local shuffle in frontend"}, needForward
= true)
+ private boolean enableLocalShufflePlanner = true;
+
Review Comment:
Our deployment process upgrades BE before FE, so during a rolling upgrade an
old BE never receives `LOCAL_EXCHANGE_NODE` from a new FE — the new thrift node
type is only sent after all BEs in the cluster have been upgraded. Keeping the
default `true` is intentional so we get the FE planner enabled out of the box
once the rollout completes. If you have a deployment topology that flips this
order, please set `enable_local_shuffle_planner=false` in fe.conf or via SQL
and the legacy BE path stays bit-for-bit identical to the old behavior.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
