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 e97f8a9881cdaf..a7248119177474 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 @@ -840,7 +840,7 @@ public class SessionVariable implements Serializable, Writable { public String timeZone = TimeUtils.getSystemTimeZone().getID(); @VariableMgr.VarAttr(name = PARALLEL_EXCHANGE_INSTANCE_NUM) - public int exchangeInstanceParallel = -1; + public int exchangeInstanceParallel = 100; @VariableMgr.VarAttr(name = SQL_SAFE_UPDATES) public int sqlSafeUpdates = 0;