You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@doris.apache.org by ka...@apache.org on 2020/12/26 06:38:56 UTC
[incubator-doris] branch master updated: [Refactor]Refactor
function computeScanRangeAssignmentByColocate (#5097)
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 <14...@qq.com>
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: commits-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org