Searched refs:scheduledMaps (Results 1 – 3 of 3) sorted by relevance
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-tools/hadoop-sls/src/main/java/org/apache/hadoop/yarn/sls/appmaster/ |
| H A D | MRAMSimulator.java | 76 private LinkedList<ContainerSimulator> scheduledMaps = field in MRAMSimulator
272 if (! scheduledMaps.isEmpty()) { in processResponseQueue()
273 ContainerSimulator cs = scheduledMaps.remove(); in processResponseQueue()
329 scheduledMaps.addAll(pendingMaps); in sendContainerRequest()
331 } else if (! pendingFailedMaps.isEmpty() && scheduledMaps.isEmpty()) { in sendContainerRequest()
336 scheduledMaps.addAll(pendingFailedMaps); in sendContainerRequest()
407 scheduledMaps.clear(); in lastStep()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/test/java/org/apache/hadoop/mapreduce/v2/app/rm/ |
| H A D | TestRMContainerAllocator.java | 1801 int scheduledMaps = 10;
1821 scheduledMaps, scheduledReduces,
1844 scheduledMaps, scheduledReduces,
1856 scheduledMaps, scheduledReduces,
1870 scheduledMaps, scheduledReduces,
1880 scheduledMaps = 2;
1886 scheduledMaps, scheduledReduces,
1898 scheduledMaps = 10;
1902 allocator.scheduleReduces(totalMaps, succeededMaps, scheduledMaps,
1911 allocator.scheduleReduces(totalMaps, succeededMaps, scheduledMaps,
[all …]
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/main/java/org/apache/hadoop/mapreduce/v2/app/rm/ |
| H A D | RMContainerAllocator.java | 525 int scheduledMaps, int scheduledReduces, in scheduleReduces() argument
560 if (scheduledMaps == 0 && numPendingReduces > 0) { in scheduleReduces()
575 Resources.multiply(mapResourceReqt, (scheduledMaps + assignedMaps)); in scheduleReduces()
598 mapResourceReqt, getSchedulerResourceTypes()) >= (scheduledMaps + assignedMaps)) { in scheduleReduces()
|