fix

dataroaring · Nov 4, 2023 · 96628d0 · 96628d0
1 parent 06ea35f
commit 96628d0
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java b/fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java
@@ -715,7 +715,7 @@ private void sendFragment() throws TException, RpcException, UserException {
  // For example: select * from numbers("number"="10") will generate ExchangeNode and
  // TableValuedFunctionScanNode, we should ensure TableValuedFunctionScanNode does
  // not send data until ExchangeNode is ready to receive.
- boolean twoPhaseExecution = fragments.size() >= 2;
+ boolean twoPhaseExecution = fragments.size() >= 0;
  for (PlanFragment fragment : fragments) {
  FragmentExecParams params = fragmentExecParamsMap.get(fragment.getFragmentId());