This is an automated email from the ASF dual-hosted git repository.
gabriellee pushed a commit to branch branch-3.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-3.0 by this push:
new 123edb61192 branch-3.0: [fix](coordinator) Fix wrong bucket assignment
#44603 (#44636)
123edb61192 is described below
commit 123edb61192e66ec7ba2801e466d9dd9d79a7a8f
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Wed Nov 27 09:58:02 2024 +0800
branch-3.0: [fix](coordinator) Fix wrong bucket assignment #44603 (#44636)
Cherry-picked from #44603
Co-authored-by: Gabriel <[email protected]>
---
fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java | 9 +++++----
1 file changed, 5 insertions(+), 4 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 ca8a397bd5a..833fec1b5a0 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
@@ -2770,17 +2770,18 @@ public class Coordinator implements CoordInterface {
.addAll(nodeScanRange.getValue());
}
}
- params.instanceExecParams.add(instanceParam);
+ List<FInstanceExecParam> instanceExecParams = new
ArrayList<>();
+ instanceExecParams.add(instanceParam);
for (int i = 1; i < parallelExecInstanceNum; i++) {
- params.instanceExecParams.add(new FInstanceExecParam(
+ instanceExecParams.add(new FInstanceExecParam(
null, addressScanRange.getKey(), 0, params));
}
int index = 0;
for (Pair<Integer, Map<Integer, List<TScanRangeParams>>>
nodeScanRangeMap : scanRange) {
- params.instanceExecParams.get(index %
params.instanceExecParams.size())
- .addBucketSeq(nodeScanRangeMap.first);
+ instanceExecParams.get(index %
instanceExecParams.size()).addBucketSeq(nodeScanRangeMap.first);
index++;
}
+ params.instanceExecParams.addAll(instanceExecParams);
} else {
int expectedInstanceNum = 1;
if (parallelExecInstanceNum > 1) {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
