You are viewing a plain text version of this content. The canonical link for it is here.
Posted to common-commits@hadoop.apache.org by ro...@apache.org on 2019/09/05 07:19:18 UTC
[hadoop] 03/06: YARN-9034. ApplicationCLI should have option to
take clusterId. Contributed by Rohith Sharma K S.
This is an automated email from the ASF dual-hosted git repository.
rohithsharmaks pushed a commit to branch branch-3.2
in repository https://gitbox.apache.org/repos/asf/hadoop.git
commit 0a6f90d4fc814355eea883818a646641d6a036e0
Author: Suma Shivaprasad <su...@apache.org>
AuthorDate: Wed Nov 28 00:42:00 2018 -0800
YARN-9034. ApplicationCLI should have option to take clusterId. Contributed by Rohith Sharma K S.
---
.../hadoop/yarn/client/cli/ApplicationCLI.java | 18 +++++
.../apache/hadoop/yarn/client/cli/ClusterCLI.java | 2 +
.../org/apache/hadoop/yarn/client/cli/NodeCLI.java | 2 +
.../apache/hadoop/yarn/client/cli/QueueCLI.java | 2 +-
.../org/apache/hadoop/yarn/client/cli/TopCLI.java | 1 +
.../org/apache/hadoop/yarn/client/cli/YarnCLI.java | 9 ++-
.../hadoop/yarn/client/cli/TestClusterCLI.java | 41 +++++-----
.../apache/hadoop/yarn/client/cli/TestYarnCLI.java | 89 +++++++++++-----------
.../client/api/impl/TimelineReaderClientImpl.java | 2 +
9 files changed, 93 insertions(+), 73 deletions(-)
diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/main/java/org/apache/hadoop/yarn/client/cli/ApplicationCLI.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/main/java/org/apache/hadoop/yarn/client/cli/ApplicationCLI.java
index 480ea23..71f4c13 100644
--- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/main/java/org/apache/hadoop/yarn/client/cli/ApplicationCLI.java
+++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/main/java/org/apache/hadoop/yarn/client/cli/ApplicationCLI.java
@@ -51,6 +51,7 @@ import org.apache.hadoop.yarn.api.records.Priority;
import org.apache.hadoop.yarn.api.records.SignalContainerCommand;
import org.apache.hadoop.yarn.api.records.YarnApplicationState;
import org.apache.hadoop.yarn.client.api.AppAdminClient;
+import org.apache.hadoop.yarn.conf.YarnConfiguration;
import org.apache.hadoop.yarn.exceptions.ApplicationAttemptNotFoundException;
import org.apache.hadoop.yarn.exceptions.ApplicationNotFoundException;
import org.apache.hadoop.yarn.exceptions.ContainerNotFoundException;
@@ -111,6 +112,8 @@ public class ApplicationCLI extends YarnCLI {
public static final String COMPONENTS = "components";
public static final String VERSION = "version";
public static final String STATES = "states";
+ public static final String SHELL_CMD = "shell";
+ public static final String CLUSTER_ID_OPTION = "clusterId";
private static String firstArg = null;
@@ -276,6 +279,8 @@ public class ApplicationCLI extends YarnCLI {
"the ability to finalize the upgrade automatically.");
opts.addOption(UPGRADE_CANCEL, false, "Works with -upgrade option to " +
"cancel current upgrade.");
+ opts.addOption(CLUSTER_ID_OPTION, true, "ClusterId. "
+ + "By default, it will take default cluster id from the RM");
opts.getOption(LAUNCH_CMD).setArgName("Application Name> <File Name");
opts.getOption(LAUNCH_CMD).setArgs(2);
opts.getOption(START_CMD).setArgName("Application Name");
@@ -300,6 +305,7 @@ public class ApplicationCLI extends YarnCLI {
opts.getOption(COMPONENTS).setArgs(Option.UNLIMITED_VALUES);
opts.getOption(DECOMMISSION).setArgName("Application Name");
opts.getOption(DECOMMISSION).setArgs(1);
+ opts.getOption(CLUSTER_ID_OPTION).setArgName("Cluster ID");
} else if (title != null && title.equalsIgnoreCase(APPLICATION_ATTEMPT)) {
opts.addOption(STATUS_CMD, true,
"Prints the status of the application attempt.");
@@ -307,9 +313,12 @@ public class ApplicationCLI extends YarnCLI {
"List application attempts for application.");
opts.addOption(FAIL_CMD, true, "Fails application attempt.");
opts.addOption(HELP_CMD, false, "Displays help for all commands.");
+ opts.addOption(CLUSTER_ID_OPTION, true, "ClusterId. "
+ + "By default, it will take default cluster id from the RM");
opts.getOption(STATUS_CMD).setArgName("Application Attempt ID");
opts.getOption(LIST_CMD).setArgName("Application ID");
opts.getOption(FAIL_CMD).setArgName("Application Attempt ID");
+ opts.getOption(CLUSTER_ID_OPTION).setArgName("Cluster ID");
} else if (title != null && title.equalsIgnoreCase(CONTAINER)) {
opts.addOption(STATUS_CMD, true,
"Prints the status of the container.");
@@ -353,6 +362,9 @@ public class ApplicationCLI extends YarnCLI {
" Default command is OUTPUT_THREAD_DUMP.");
opts.getOption(SIGNAL_CMD).setArgName("container ID [signal command]");
opts.getOption(SIGNAL_CMD).setArgs(3);
+ opts.addOption(CLUSTER_ID_OPTION, true, "ClusterId. "
+ + "By default, it will take default cluster id from the RM");
+ opts.getOption(CLUSTER_ID_OPTION).setArgName("Cluster ID");
}
int exitCode = -1;
@@ -377,6 +389,12 @@ public class ApplicationCLI extends YarnCLI {
}
}
+ if (cliParser.hasOption(CLUSTER_ID_OPTION)) {
+ String clusterIdStr = cliParser.getOptionValue(CLUSTER_ID_OPTION);
+ getConf().set(YarnConfiguration.RM_CLUSTER_ID, clusterIdStr);
+ }
+ createAndStartYarnClient();
+
if (cliParser.hasOption(STATUS_CMD)) {
if (hasAnyOtherCLIOptions(cliParser, opts, STATUS_CMD, APP_TYPE_CMD)) {
printUsage(title, opts);
diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/main/java/org/apache/hadoop/yarn/client/cli/ClusterCLI.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/main/java/org/apache/hadoop/yarn/client/cli/ClusterCLI.java
index 4d93949..7ead774 100644
--- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/main/java/org/apache/hadoop/yarn/client/cli/ClusterCLI.java
+++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/main/java/org/apache/hadoop/yarn/client/cli/ClusterCLI.java
@@ -100,6 +100,8 @@ public class ClusterCLI extends YarnCLI {
return exitCode;
}
+ createAndStartYarnClient();
+
if (parsedCli.hasOption(DIRECTLY_ACCESS_NODE_LABEL_STORE)) {
accessLocal = true;
}
diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/main/java/org/apache/hadoop/yarn/client/cli/NodeCLI.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/main/java/org/apache/hadoop/yarn/client/cli/NodeCLI.java
index 44e9870..6120a84 100644
--- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/main/java/org/apache/hadoop/yarn/client/cli/NodeCLI.java
+++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/main/java/org/apache/hadoop/yarn/client/cli/NodeCLI.java
@@ -107,6 +107,8 @@ public class NodeCLI extends YarnCLI {
return exitCode;
}
+ createAndStartYarnClient();
+
if (cliParser.hasOption("status")) {
if (args.length != 2) {
printUsage(opts);
diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/main/java/org/apache/hadoop/yarn/client/cli/QueueCLI.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/main/java/org/apache/hadoop/yarn/client/cli/QueueCLI.java
index 2c3dfd0..aeb3ffb 100644
--- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/main/java/org/apache/hadoop/yarn/client/cli/QueueCLI.java
+++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/main/java/org/apache/hadoop/yarn/client/cli/QueueCLI.java
@@ -69,7 +69,7 @@ public class QueueCLI extends YarnCLI {
printUsage(opts);
return -1;
}
-
+ createAndStartYarnClient();
if (cliParser.hasOption(STATUS_CMD)) {
if (args.length != 2) {
printUsage(opts);
diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/main/java/org/apache/hadoop/yarn/client/cli/TopCLI.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/main/java/org/apache/hadoop/yarn/client/cli/TopCLI.java
index aed5258..0d91806 100644
--- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/main/java/org/apache/hadoop/yarn/client/cli/TopCLI.java
+++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/main/java/org/apache/hadoop/yarn/client/cli/TopCLI.java
@@ -463,6 +463,7 @@ public class TopCLI extends YarnCLI {
LOG.error("Unable to parse options", e);
return 1;
}
+ createAndStartYarnClient();
setAppsHeader();
Thread keyboardMonitor = new KeyboardMonitor();
diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/main/java/org/apache/hadoop/yarn/client/cli/YarnCLI.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/main/java/org/apache/hadoop/yarn/client/cli/YarnCLI.java
index ac33dea..0747b63 100644
--- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/main/java/org/apache/hadoop/yarn/client/cli/YarnCLI.java
+++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/main/java/org/apache/hadoop/yarn/client/cli/YarnCLI.java
@@ -43,15 +43,18 @@ public abstract class YarnCLI extends Configured implements Tool {
public YarnCLI() {
super(new YarnConfiguration());
- client = createYarnClient();
- client.init(getConf());
- client.start();
}
protected YarnClient createYarnClient() {
return YarnClient.createYarnClient();
}
+ protected void createAndStartYarnClient() {
+ client = createYarnClient();
+ client.init(getConf());
+ client.start();
+ }
+
public void setSysOutPrintStream(PrintStream sysout) {
this.sysout = sysout;
}
diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/test/java/org/apache/hadoop/yarn/client/cli/TestClusterCLI.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/test/java/org/apache/hadoop/yarn/client/cli/TestClusterCLI.java
index 26afe6f..85aca05 100644
--- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/test/java/org/apache/hadoop/yarn/client/cli/TestClusterCLI.java
+++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/test/java/org/apache/hadoop/yarn/client/cli/TestClusterCLI.java
@@ -42,10 +42,12 @@ import org.junit.Test;
import com.google.common.collect.ImmutableSet;
public class TestClusterCLI {
+
ByteArrayOutputStream sysOutStream;
private PrintStream sysOut;
ByteArrayOutputStream sysErrStream;
private PrintStream sysErr;
+ private YarnClient client = mock(YarnClient.class);
@Before
public void setup() {
@@ -58,14 +60,10 @@ public class TestClusterCLI {
@Test
public void testGetClusterNodeLabels() throws Exception {
- YarnClient client = mock(YarnClient.class);
when(client.getClusterNodeLabels()).thenReturn(
Arrays.asList(NodeLabel.newInstance("label1"),
NodeLabel.newInstance("label2")));
- ClusterCLI cli = new ClusterCLI();
- cli.setClient(client);
- cli.setSysOutPrintStream(sysOut);
- cli.setSysErrPrintStream(sysErr);
+ ClusterCLI cli = createAndGetClusterCLI();
int rc =
cli.run(new String[] { ClusterCLI.CMD, "-" + ClusterCLI.LIST_LABELS_CMD });
@@ -80,16 +78,12 @@ public class TestClusterCLI {
@Test
public void testGetClusterNodeAttributes() throws Exception {
- YarnClient client = mock(YarnClient.class);
when(client.getClusterAttributes()).thenReturn(ImmutableSet
.of(NodeAttributeInfo.newInstance(NodeAttributeKey.newInstance("GPU"),
NodeAttributeType.STRING), NodeAttributeInfo
.newInstance(NodeAttributeKey.newInstance("CPU"),
NodeAttributeType.STRING)));
- ClusterCLI cli = new ClusterCLI();
- cli.setClient(client);
- cli.setSysOutPrintStream(sysOut);
- cli.setSysErrPrintStream(sysErr);
+ ClusterCLI cli = createAndGetClusterCLI();
int rc = cli.run(new String[] {ClusterCLI.CMD,
"-" + ClusterCLI.LIST_CLUSTER_ATTRIBUTES});
@@ -105,14 +99,10 @@ public class TestClusterCLI {
@Test
public void testGetClusterNodeLabelsWithLocalAccess() throws Exception {
- YarnClient client = mock(YarnClient.class);
when(client.getClusterNodeLabels()).thenReturn(
Arrays.asList(NodeLabel.newInstance("remote1"),
NodeLabel.newInstance("remote2")));
- ClusterCLI cli = new ClusterCLI();
- cli.setClient(client);
- cli.setSysOutPrintStream(sysOut);
- cli.setSysErrPrintStream(sysErr);
+ ClusterCLI cli = createAndGetClusterCLI();
ClusterCLI.localNodeLabelsManager = mock(CommonNodeLabelsManager.class);
when(ClusterCLI.localNodeLabelsManager.getClusterNodeLabels()).thenReturn(
Arrays.asList(NodeLabel.newInstance("local1"),
@@ -134,12 +124,8 @@ public class TestClusterCLI {
@Test
public void testGetEmptyClusterNodeLabels() throws Exception {
- YarnClient client = mock(YarnClient.class);
when(client.getClusterNodeLabels()).thenReturn(new ArrayList<NodeLabel>());
- ClusterCLI cli = new ClusterCLI();
- cli.setClient(client);
- cli.setSysOutPrintStream(sysOut);
- cli.setSysErrPrintStream(sysErr);
+ ClusterCLI cli = createAndGetClusterCLI();
int rc =
cli.run(new String[] { ClusterCLI.CMD, "-" + ClusterCLI.LIST_LABELS_CMD });
@@ -154,9 +140,7 @@ public class TestClusterCLI {
@Test
public void testHelp() throws Exception {
- ClusterCLI cli = new ClusterCLI();
- cli.setSysOutPrintStream(sysOut);
- cli.setSysErrPrintStream(sysErr);
+ ClusterCLI cli = createAndGetClusterCLI();
int rc =
cli.run(new String[] { "cluster", "--help" });
@@ -192,4 +176,15 @@ public class TestClusterCLI {
pw.close();
verify(sysOut).println(baos.toString("UTF-8"));
}
+
+ private ClusterCLI createAndGetClusterCLI() {
+ ClusterCLI cli = new ClusterCLI() {
+ @Override protected void createAndStartYarnClient() {
+ }
+ };
+ cli.setClient(client);
+ cli.setSysOutPrintStream(sysOut);
+ cli.setSysErrPrintStream(sysErr);
+ return cli;
+ }
}
\ No newline at end of file
diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/test/java/org/apache/hadoop/yarn/client/cli/TestYarnCLI.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/test/java/org/apache/hadoop/yarn/client/cli/TestYarnCLI.java
index 9b1e863..459ed1e 100644
--- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/test/java/org/apache/hadoop/yarn/client/cli/TestYarnCLI.java
+++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/test/java/org/apache/hadoop/yarn/client/cli/TestYarnCLI.java
@@ -993,10 +993,7 @@ public class TestYarnCLI {
@Test (timeout = 5000)
public void testNodesHelpCommand() throws Exception {
- NodeCLI nodeCLI = new NodeCLI();
- nodeCLI.setClient(client);
- nodeCLI.setSysOutPrintStream(sysOut);
- nodeCLI.setSysErrPrintStream(sysErr);
+ NodeCLI nodeCLI = createAndGetNodeCLI();
nodeCLI.run(new String[] {});
Assert.assertEquals(createNodeCLIHelpMessage(),
sysOutStream.toString());
@@ -1290,9 +1287,7 @@ public class TestYarnCLI {
nodeReports.addAll(getNodeReports(1, NodeState.REBOOTED));
nodeReports.addAll(getNodeReports(1, NodeState.LOST));
- NodeCLI cli = new NodeCLI();
- cli.setClient(client);
- cli.setSysOutPrintStream(sysOut);
+ NodeCLI cli = createAndGetNodeCLI();
Set<NodeState> nodeStates = new HashSet<NodeState>();
nodeStates.add(NodeState.NEW);
@@ -1545,12 +1540,9 @@ public class TestYarnCLI {
@Test
public void testNodeStatus() throws Exception {
NodeId nodeId = NodeId.newInstance("host0", 0);
- NodeCLI cli = new NodeCLI();
when(client.getNodeReports())
.thenReturn(getNodeReports(3, NodeState.RUNNING, false, false, false));
- cli.setClient(client);
- cli.setSysOutPrintStream(sysOut);
- cli.setSysErrPrintStream(sysErr);
+ NodeCLI cli = createAndGetNodeCLI();
int result = cli.run(new String[] { "-status", nodeId.toString() });
assertEquals(0, result);
verify(client).getNodeReports();
@@ -1583,12 +1575,9 @@ public class TestYarnCLI {
@Test
public void testNodeStatusWithEmptyNodeLabels() throws Exception {
NodeId nodeId = NodeId.newInstance("host0", 0);
- NodeCLI cli = new NodeCLI();
when(client.getNodeReports()).thenReturn(
getNodeReports(3, NodeState.RUNNING));
- cli.setClient(client);
- cli.setSysOutPrintStream(sysOut);
- cli.setSysErrPrintStream(sysErr);
+ NodeCLI cli = createAndGetNodeCLI();
int result = cli.run(new String[] { "-status", nodeId.toString() });
assertEquals(0, result);
verify(client).getNodeReports();
@@ -1620,12 +1609,9 @@ public class TestYarnCLI {
@Test
public void testNodeStatusWithEmptyResourceUtilization() throws Exception {
NodeId nodeId = NodeId.newInstance("host0", 0);
- NodeCLI cli = new NodeCLI();
when(client.getNodeReports())
.thenReturn(getNodeReports(3, NodeState.RUNNING, false, true, true));
- cli.setClient(client);
- cli.setSysOutPrintStream(sysOut);
- cli.setSysErrPrintStream(sysErr);
+ NodeCLI cli = createAndGetNodeCLI();
int result = cli.run(new String[] { "-status", nodeId.toString() });
assertEquals(0, result);
verify(client).getNodeReports();
@@ -1657,12 +1643,10 @@ public class TestYarnCLI {
@Test
public void testAbsentNodeStatus() throws Exception {
NodeId nodeId = NodeId.newInstance("Absenthost0", 0);
- NodeCLI cli = new NodeCLI();
+
when(client.getNodeReports()).thenReturn(
getNodeReports(0, NodeState.RUNNING));
- cli.setClient(client);
- cli.setSysOutPrintStream(sysOut);
- cli.setSysErrPrintStream(sysErr);
+ NodeCLI cli = createAndGetNodeCLI();
int result = cli.run(new String[] { "-status", nodeId.toString() });
assertEquals(0, result);
verify(client).getNodeReports();
@@ -1702,10 +1686,7 @@ public class TestYarnCLI {
createContainerCLIHelpMessage()), normalize(sysOutStream.toString()));
sysOutStream.reset();
- NodeCLI nodeCLI = new NodeCLI();
- nodeCLI.setClient(client);
- nodeCLI.setSysOutPrintStream(sysOut);
- nodeCLI.setSysErrPrintStream(sysErr);
+ NodeCLI nodeCLI = createAndGetNodeCLI();
result = nodeCLI.run(new String[] { "-status" });
Assert.assertEquals(result, -1);
Assert.assertEquals(String.format("Missing argument for options%n%1s",
@@ -1774,10 +1755,7 @@ public class TestYarnCLI {
yarnClient.init(yarnConf);
yarnClient.start();
- QueueCLI cli = new QueueCLI();
- cli.setClient(yarnClient);
- cli.setSysOutPrintStream(sysOut);
- cli.setSysErrPrintStream(sysErr);
+ QueueCLI cli = createAndGetQueueCLI(yarnClient);
sysOutStream.reset();
// Get status for the root.a queue
int result = cli.run(new String[] { "-status", "a" });
@@ -1788,10 +1766,7 @@ public class TestYarnCLI {
// In-queue preemption is disabled at the "root.a" queue level
Assert.assertTrue(queueStatusOut
.contains("Intra-queue Preemption : disabled"));
- cli = new QueueCLI();
- cli.setClient(yarnClient);
- cli.setSysOutPrintStream(sysOut);
- cli.setSysErrPrintStream(sysErr);
+ cli = createAndGetQueueCLI(yarnClient);
sysOutStream.reset();
// Get status for the root.a.a1 queue
result = cli.run(new String[] { "-status", "a1" });
@@ -1836,10 +1811,7 @@ public class TestYarnCLI {
yarnClient.init(yarnConf);
yarnClient.start();
- QueueCLI cli = new QueueCLI();
- cli.setClient(yarnClient);
- cli.setSysOutPrintStream(sysOut);
- cli.setSysErrPrintStream(sysErr);
+ QueueCLI cli = createAndGetQueueCLI(yarnClient);
sysOutStream.reset();
int result = cli.run(new String[] { "-status", "a1" });
assertEquals(0, result);
@@ -1880,10 +1852,7 @@ public class TestYarnCLI {
yarnClient.init(yarnConf);
yarnClient.start();
- QueueCLI cli = new QueueCLI();
- cli.setClient(yarnClient);
- cli.setSysOutPrintStream(sysOut);
- cli.setSysErrPrintStream(sysErr);
+ QueueCLI cli = createAndGetQueueCLI(yarnClient);
sysOutStream.reset();
int result = cli.run(new String[] { "-status", "a1" });
assertEquals(0, result);
@@ -2101,14 +2070,36 @@ public class TestYarnCLI {
}
private ApplicationCLI createAndGetAppCLI() {
- ApplicationCLI cli = new ApplicationCLI();
+ ApplicationCLI cli = new ApplicationCLI() {
+ @Override protected void createAndStartYarnClient() {
+ }
+ };
cli.setClient(client);
cli.setSysOutPrintStream(sysOut);
+ cli.setSysErrPrintStream(sysErr);
return cli;
}
-
+
private QueueCLI createAndGetQueueCLI() {
- QueueCLI cli = new QueueCLI();
+ return createAndGetQueueCLI(client);
+ }
+
+ private QueueCLI createAndGetQueueCLI(YarnClient client) {
+ QueueCLI cli = new QueueCLI() {
+ @Override protected void createAndStartYarnClient() {
+ }
+ };
+ cli.setClient(client);
+ cli.setSysOutPrintStream(sysOut);
+ cli.setSysErrPrintStream(sysErr);
+ return cli;
+ }
+
+ private NodeCLI createAndGetNodeCLI() {
+ NodeCLI cli = new NodeCLI() {
+ @Override protected void createAndStartYarnClient() {
+ }
+ };
cli.setClient(client);
cli.setSysOutPrintStream(sysOut);
cli.setSysErrPrintStream(sysErr);
@@ -2152,6 +2143,9 @@ public class TestYarnCLI {
pw.println(" deprecated, this new command");
pw.println(" 'changeQueue' performs same");
pw.println(" functionality.");
+ pw.println(" -clusterId <Cluster ID> ClusterId. By default, it will");
+ pw.println(" take default cluster id from the");
+ pw.println(" RM");
pw.println(" -component <Component Name> <Count> Works with -flex option to");
pw.println(" change the number of");
pw.println(" components/containers running");
@@ -2298,6 +2292,8 @@ public class TestYarnCLI {
ByteArrayOutputStream baos = new ByteArrayOutputStream();
PrintWriter pw = new PrintWriter(baos);
pw.println("usage: applicationattempt");
+ pw.println(" -clusterId <Cluster ID> ClusterId. By default, it will take");
+ pw.println(" default cluster id from the RM");
pw.println(" -fail <Application Attempt ID> Fails application attempt.");
pw.println(" -help Displays help for all commands.");
pw.println(" -list <Application ID> List application attempts for");
@@ -2314,6 +2310,7 @@ public class TestYarnCLI {
PrintWriter pw = new PrintWriter(baos);
pw.println("usage: container");
pw.println(" -appTypes <Types> Works with -list to specify the app type when application name is provided.");
+ pw.println(" -clusterId <Cluster ID> ClusterId. By default, it will take default cluster id from the RM ");
pw.println(" -components <arg> Works with -list to filter instances based on input comma-separated list of component names.");
pw.println(" -help Displays help for all commands.");
pw.println(" -list <Application Name or Attempt ID> List containers for application attempt when application attempt ID is provided. When application name is provided, then it finds the instances of the application based on app's own implementation, and -appTypes option must be specified unless it is the default yarn-service type. With app name, it supports optional use of -version to filter instances based on app version, -components to filter instances based on component names, [...]
diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/client/api/impl/TimelineReaderClientImpl.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/client/api/impl/TimelineReaderClientImpl.java
index b138a54..db53f93 100644
--- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/client/api/impl/TimelineReaderClientImpl.java
+++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/client/api/impl/TimelineReaderClientImpl.java
@@ -94,6 +94,8 @@ public class TimelineReaderClientImpl extends TimelineReaderClient {
conf, timelineReaderWebAppAddress, RESOURCE_URI_STR_V2);
clusterId = conf.get(YarnConfiguration.RM_CLUSTER_ID,
YarnConfiguration.DEFAULT_RM_CLUSTER_ID);
+ LOG.info("Initialized TimelineReader URI=" + baseUri + ", clusterId="
+ + clusterId);
super.serviceInit(conf);
}
---------------------------------------------------------------------
To unsubscribe, e-mail: common-commits-unsubscribe@hadoop.apache.org
For additional commands, e-mail: common-commits-help@hadoop.apache.org