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 1e9a8261c42..0dd0aa18dcf 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 @@ -93,16 +93,20 @@ import org.apache.hadoop.yarn.webapp.util.WebAppUtils; 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 + *

+ *

+ * 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 - * true in the configuration used to initialize the minicluster. - *

+ * {@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. + *

* With this property set to 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. @@ -723,8 +727,9 @@ public class MiniYARNCluster extends CompositeService { * @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 {