This is an automated email from the ASF dual-hosted git repository.
gabriellee 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 fb8c8172d40 [fix](serial exchange) Fix wrong serial exchange condition
(#53248)
fb8c8172d40 is described below
commit fb8c8172d40aabeeb1d422b9ad474372c19cd2e2
Author: Gabriel <[email protected]>
AuthorDate: Tue Jul 15 15:21:21 2025 +0800
[fix](serial exchange) Fix wrong serial exchange condition (#53248)
---
fe/fe-core/src/main/java/org/apache/doris/planner/ExchangeNode.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/planner/ExchangeNode.java
b/fe/fe-core/src/main/java/org/apache/doris/planner/ExchangeNode.java
index 83236e95759..6369da5d6bf 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/planner/ExchangeNode.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/planner/ExchangeNode.java
@@ -176,7 +176,7 @@ public class ExchangeNode extends PlanNode {
@Override
public boolean isSerialOperator() {
return (ConnectContext.get() != null &&
ConnectContext.get().getSessionVariable().isUseSerialExchange()
- || partitionType == TPartitionType.UNPARTITIONED) && mergeInfo
!= null;
+ || partitionType == TPartitionType.UNPARTITIONED) && mergeInfo
== null;
}
@Override
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
