Apache
/
hadoop
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

YARN-4628. Display application priority in yarn top. Contributed by Bibin A Chundatt.

This commit is contained in:
Varun Vasudev 2016-02-11 11:56:09 +05:30
parent 19adb2bc64
commit 663a80031c
2 changed files with 20 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
hadoop-yarn-project/CHANGES.txt
View File

@ -125,6 +125,9 @@ Release 2.9.0 - UNRELEASED
YARN-4307. Display blacklisted nodes for AM container in the RM web UI.
(Naganarasimha G R via vvasudev)
YARN-4628. Display application priority in yarn top.
(Bibin A Chundatt via vvasudev)
OPTIMIZATIONS
BUG FIXES

18
hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/main/java/org/apache/hadoop/yarn/client/cli/TopCLI.java
View File

@ -55,6 +55,7 @@
import org.apache.hadoop.util.ToolRunner;
import org.apache.hadoop.yarn.api.protocolrecords.GetApplicationsRequest;
import org.apache.hadoop.yarn.api.records.ApplicationReport;
import org.apache.hadoop.yarn.api.records.Priority;
import org.apache.hadoop.yarn.api.records.QueueInfo;
import org.apache.hadoop.yarn.api.records.QueueStatistics;
import org.apache.hadoop.yarn.api.records.YarnApplicationState;
@ -141,7 +142,9 @@ private static class ApplicationInformation {
displayStringsMap.put(Columns.NAME, name);
queue = appReport.getQueue();
displayStringsMap.put(Columns.QUEUE, queue);
priority = 0;
Priority appPriority = appReport.getPriority();
priority = null != appPriority ? appPriority.getPriority() : 0;
displayStringsMap.put(Columns.PRIORITY, String.valueOf(priority));
usedContainers =
appReport.getApplicationResourceUsageReport().getNumUsedContainers();
displayStringsMap.put(Columns.CONT, String.valueOf(usedContainers));
@ -305,6 +308,14 @@ private static class ApplicationInformation {
return a1.name.compareTo(a2.name);
}
};
public static final Comparator<ApplicationInformation> AppPriorityComparator =
new Comparator<ApplicationInformation>() {
@Override
public int compare(ApplicationInformation a1,
ApplicationInformation a2) {
return a1.priority - a2.priority;
}
};
private static class NodesInformation {
int totalNodes;
@ -620,6 +631,8 @@ private void generateColumnInformationMap() {
"%10s", true, "Application type", "t"));
columnInformationEnumMap.put(Columns.QUEUE, new ColumnInformation("QUEUE",
"%10s", true, "Application queue", "q"));
columnInformationEnumMap.put(Columns.PRIORITY, new ColumnInformation(
"PRIOR", "%5s", true, "Application priority", "l"));
columnInformationEnumMap.put(Columns.CONT, new ColumnInformation("#CONT",
"%7s", true, "Number of containers", "c"));
columnInformationEnumMap.put(Columns.RCONT, new ColumnInformation("#RCONT",
@ -1010,6 +1023,9 @@ private void handleSortScreenKeyPress(String input) {
case "n":
comparator = AppNameComparator;
break;
case "l":
comparator = AppPriorityComparator;
break;
default:
// it wasn't a sort key
currentSortField = f;