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 e3e414273476f7..8f95c0489054fd 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 @@ -635,6 +635,7 @@ private void sendFragment() throws TException, RpcException, UserException { beToExecStates.putIfAbsent(execState.backend.getId(), states); } states.addState(execState); + ++backendIdx; } profileFragmentId += 1; } // end for fragments