This is an automated email from the ASF dual-hosted git repository.
kangkaisen pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-doris.git
The following commit(s) were added to refs/heads/master by this push:
new f7a325a [Refactor]Refactor function
computeScanRangeAssignmentByColocate (#5097)
f7a325a is described below
commit f7a325a08f8757b6596c490d924f1d40e9f1ee5a
Author: xinghuayu007 <[email protected]>
AuthorDate: Sat Dec 26 14:38:39 2020 +0800
[Refactor]Refactor function computeScanRangeAssignmentByColocate (#5097)
---
fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java | 5 ++---
1 file changed, 2 insertions(+), 3 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 91ec701..0f75ffd 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
@@ -1235,7 +1235,7 @@ public class Coordinator {
FragmentScanRangeAssignment assignment =
fragmentExecParamsMap.get(scanNode.getFragmentId()).scanRangeAssignment;
if (isColocateJoin(scanNode.getFragment().getPlanRoot())) {
- computeScanRangeAssignmentByColocate((OlapScanNode) scanNode,
assignment);
+ computeScanRangeAssignmentByColocate((OlapScanNode) scanNode);
} else if
(bucketShuffleJoinController.isBucketShuffleJoin(scanNode.getFragmentId().asInt(),
scanNode.getFragment().getPlanRoot())) {
bucketShuffleJoinController.computeScanRangeAssignmentByBucket((OlapScanNode)
scanNode, idToBackend, addressToBackendID);
} else {
@@ -1246,8 +1246,7 @@ public class Coordinator {
// To ensure the same bucketSeq tablet to the same execHostPort
private void computeScanRangeAssignmentByColocate(
- final OlapScanNode scanNode,
- FragmentScanRangeAssignment assignment) throws Exception {
+ final OlapScanNode scanNode) throws Exception {
if
(!fragmentIdToSeqToAddressMap.containsKey(scanNode.getFragmentId())) {
fragmentIdToSeqToAddressMap.put(scanNode.getFragmentId(), new
HashedMap());
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
