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 bce9b69c7da [fix](coordinator) Fix wrong bucket assignment (#44603)
bce9b69c7da is described below
commit bce9b69c7da60d62101516612d34707763b77bc0
Author: Gabriel <[email protected]>
AuthorDate: Tue Nov 26 20:42:39 2024 +0800
[fix](coordinator) Fix wrong bucket assignment (#44603)
follow-up : #44459
---
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 61ecaf7fc8b..3a6f6e4f840 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
@@ -2766,17 +2766,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]
