database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[Refactor] Refactor function getScanRangeLength (#4912)

Browse Source 
getScanRangeLength always return 1, it is no need to maintain a function like this.
This commit is contained in:
xinghuayu007
2020-11-22 20:44:11 +08:00
committed by GitHub
parent fb7f4c8791
commit 4f7c6da1f5
1 changed files with 2 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java
View File

@ -73,7 +73,6 @@ import org.apache.doris.thrift.TQueryOptions;
import org.apache.doris.thrift.TQueryType;
import org.apache.doris.thrift.TReportExecStatusParams;
import org.apache.doris.thrift.TResourceInfo;
import org.apache.doris.thrift.TScanRange;
import org.apache.doris.thrift.TScanRangeLocation;
import org.apache.doris.thrift.TScanRangeLocations;
import org.apache.doris.thrift.TScanRangeParams;
@ -1161,10 +1160,6 @@ public class Coordinator {
return value;
}
private long getScanRangeLength(final TScanRange scanRange) {
return 1;
}
private void computeColocateJoinInstanceParam(PlanFragmentId fragmentId, int parallelExecInstanceNum, FragmentExecParams params) {
Map<Integer, TNetworkAddress> bucketSeqToAddress = fragmentIdToSeqToAddressMap.get(fragmentId);
Set<Integer> scanNodeIds = fragmentIdToScanNodeIds.get(fragmentId);
@ -1295,6 +1290,7 @@ public class Coordinator {
FragmentScanRangeAssignment assignment) throws Exception {
HashMap<TNetworkAddress, Long> assignedBytesPerHost = Maps.newHashMap();
Long step = 1L;
for (TScanRangeLocations scanRangeLocations : locations) {
// assign this scan range to the host w/ the fewest assigned bytes
Long minAssignedBytes = Long.MAX_VALUE;
@ -1306,9 +1302,8 @@ public class Coordinator {
minLocation = location;
}
}
Long scanRangeLength = getScanRangeLength(scanRangeLocations.scan_range);
assignedBytesPerHost.put(minLocation.server,
assignedBytesPerHost.get(minLocation.server) + scanRangeLength);
assignedBytesPerHost.get(minLocation.server) + step);
Reference<Long> backendIdRef = new Reference<Long>();
TNetworkAddress execHostPort = SimpleScheduler.getHost(minLocation.backend_id,