diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-tests/src/test/java/org/apache/hadoop/yarn/server/MiniYARNCluster.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-tests/src/test/java/org/apache/hadoop/yarn/server/MiniYARNCluster.java index de4e22d..2e4c3b8 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-tests/src/test/java/org/apache/hadoop/yarn/server/MiniYARNCluster.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-tests/src/test/java/org/apache/hadoop/yarn/server/MiniYARNCluster.java @@ -96,16 +96,19 @@ import com.google.common.annotations.VisibleForTesting; /** + *
* Embedded Yarn minicluster for testcases that need to interact with a cluster. - *
+ * + ** In a real cluster, resource request matching is done using the hostname, and * by default Yarn minicluster works in the exact same way as a real cluster. - *
+ * + *
* If a testcase needs to use multiple nodes and exercise resource request
* matching to a specific node, then the property
- * {@YarnConfiguration.RM_SCHEDULER_INCLUDE_PORT_IN_NODE_NAME} should be set
+ * {@value org.apache.hadoop.yarn.conf.YarnConfiguration#RM_SCHEDULER_INCLUDE_PORT_IN_NODE_NAME} should be set
* true in the configuration used to initialize the minicluster.
- *
true, the matching will be done using
* the hostname:port of the namenodes. In such case, the AM must
* do resource request using hostname:port as the location.
@@ -733,8 +736,8 @@ protected ContainerManagerImpl createContainerManager(Context context,
* @param timeout Time to wait (sleeps in 10 ms intervals) in milliseconds.
* @return true if all NodeManagers connect to the (Active)
* ResourceManager, false otherwise.
- * @throws YarnException
- * @throws InterruptedException
+ * @throws YarnException if there is no active RM
+ * @throws InterruptedException if any thread has interrupted the current thread.
*/
public boolean waitForNodeManagersToConnect(long timeout)
throws YarnException, InterruptedException {