ResourceManager extends CompositeService implements Recoverable, ResourceManagerMXBean { public RMContext getRMContext() { return this.rmContext; } ResourceManager(); RMContext getRMContext(); static long getClusterTimeStamp(); String getRMLoginUser(); ZKCuratorManager createAndStartZKManager(Configuration
      config); ZKCuratorManager getZKManager(); CuratorFramework getCurator(); String getZkRootNodePassword(); static HttpServer2.Builder httpServerTemplateForRM(Configuration conf,
      final InetSocketAddress httpAddr, final InetSocketAddress httpsAddr,
      String name); @Private ClientRMService getClientRMService(); @Private ResourceScheduler getResourceScheduler(); @Private ResourceTrackerService getResourceTrackerService(); @Private ApplicationMasterService getApplicationMasterService(); @Private ApplicationACLsManager getApplicationACLsManager(); @Private QueueACLsManager getQueueACLsManager(); @Private @VisibleForTesting FederationStateStoreService getFederationStateStoreService(); @Override void recover(RMState state); static void main(String argv[]); static InetSocketAddress getBindAddress(Configuration conf); @Override boolean isSecurityEnabled(); static final int SHUTDOWN_HOOK_PRIORITY; static final int EPOCH_BIT_SHIFT; static final String UI2_WEBAPP_NAME; }
@Test public void testNodeHealthReportIsNotNull() throws Exception{ String host1 = "host1"; final int memory = 4 * 1024; NodeStatus mockNodeStatus = createMockNodeStatus(); org.apache.hadoop.yarn.server.resourcemanager.NodeManager nm1 = registerNode(host1, 1234, 2345, NetworkTopology.DEFAULT_RACK, Resources.createResource(memory, 1), mockNodeStatus); nm1.heartbeat(); nm1.heartbeat(); Collection<RMNode> values = resourceManager.getRMContext().getRMNodes().values(); for (RMNode ni : values) { assertNotNull(ni.getHealthReport()); } }