big-data/hadoop
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

YARN-8148. Update decimal values for queue capacities shown on queue status CLI. Contributed by Prabhu Joseph

Browse Source
This commit is contained in:
Szilard Nemeth 2020-01-20 09:28:23 +01:00
parent 263413e838
commit 14d0f9a775
2 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/main/java/org/apache/hadoop/yarn/client/cli/QueueCLI.java
View File

@ -128,7 +128,7 @@ private void printQueueInfo(PrintWriter writer, QueueInfo queueInfo) {
writer.print("\tState : "); writer.print("\tState : ");
writer.println(queueInfo.getQueueState()); writer.println(queueInfo.getQueueState());
DecimalFormat df = new DecimalFormat("#.0"); DecimalFormat df = new DecimalFormat("#.00");
writer.print("\tCapacity : "); writer.print("\tCapacity : ");
writer.println(df.format(queueInfo.getCapacity() * 100) + "%"); writer.println(df.format(queueInfo.getCapacity() * 100) + "%");
writer.print("\tCurrent Capacity : "); writer.print("\tCurrent Capacity : ");

12
hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/test/java/org/apache/hadoop/yarn/client/cli/TestYarnCLI.java
View File

@ -1728,9 +1728,9 @@ public void testGetQueueInfo() throws Exception {
pw.println("Queue Information : "); pw.println("Queue Information : ");
pw.println("Queue Name : " + "queueA"); pw.println("Queue Name : " + "queueA");
pw.println("\tState : " + "RUNNING"); pw.println("\tState : " + "RUNNING");
pw.println("\tCapacity : " + "40.0%"); pw.println("\tCapacity : " + "40.00%");
pw.println("\tCurrent Capacity : " + "50.0%"); pw.println("\tCurrent Capacity : " + "50.00%");
pw.println("\tMaximum Capacity : " + "80.0%"); pw.println("\tMaximum Capacity : " + "80.00%");
pw.println("\tDefault Node Label expression : " + "GPU"); pw.println("\tDefault Node Label expression : " + "GPU");
pw.println("\tAccessible Node Labels : " + "JDK_7,GPU"); pw.println("\tAccessible Node Labels : " + "JDK_7,GPU");
pw.println("\tPreemption : " + "enabled"); pw.println("\tPreemption : " + "enabled");
@ -1895,9 +1895,9 @@ public void testGetQueueInfoWithEmptyNodeLabel() throws Exception {
pw.println("Queue Information : "); pw.println("Queue Information : ");
pw.println("Queue Name : " + "queueA"); pw.println("Queue Name : " + "queueA");
pw.println("\tState : " + "RUNNING"); pw.println("\tState : " + "RUNNING");
pw.println("\tCapacity : " + "40.0%"); pw.println("\tCapacity : " + "40.00%");
pw.println("\tCurrent Capacity : " + "50.0%"); pw.println("\tCurrent Capacity : " + "50.00%");
pw.println("\tMaximum Capacity : " + "80.0%"); pw.println("\tMaximum Capacity : " + "80.00%");
pw.println("\tDefault Node Label expression : " pw.println("\tDefault Node Label expression : "
+ NodeLabel.DEFAULT_NODE_LABEL_PARTITION); + NodeLabel.DEFAULT_NODE_LABEL_PARTITION);
pw.println("\tAccessible Node Labels : "); pw.println("\tAccessible Node Labels : ");