This is an automated email from the ASF dual-hosted git repository.
morningman pushed a commit to branch dev-1.0.1
in repository https://gitbox.apache.org/repos/asf/doris.git
commit 6f649184be1b95b67d54c685ae12355d24bc6f9b
Author: morningman <morning...@163.com>
AuthorDate: Wed Jun 29 20:01:38 2022 +0800
[hotfix](dev-1.0.1) fix send fragment stuck bug
This bug has been fixed in #10214
---
fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java | 6 ++++--
1 file changed, 4 insertions(+), 2 deletions(-)
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
index 75dc09b9f5..61eb8ecf00 100644
--- 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
@@ -579,9 +579,11 @@ public class Coordinator {
int profileFragmentId = 0;
long memoryLimit = queryOptions.getMemLimit();
Map<Long, BackendExecStates> beToExecStates = Maps.newHashMap();
- // If #fragments >=3, use twoPhaseExecution with
exec_plan_fragments_prepare and exec_plan_fragments_start,
+ // If #fragments >=2, use twoPhaseExecution with
exec_plan_fragments_prepare and exec_plan_fragments_start,
// else use exec_plan_fragments directly.
- boolean twoPhaseExecution = fragments.size() >= 3;
+ // we choose #fragments >=2 because in some cases
+ // we need ensure that A fragment is already prepared to receive
data before B fragment sends data.
+ boolean twoPhaseExecution = fragments.size() >= 2;
for (PlanFragment fragment : fragments) {
FragmentExecParams params =
fragmentExecParamsMap.get(fragment.getFragmentId());
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
