• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    公众号
登陆 注册

Java RMNodeEvent类代码示例

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

本文整理汇总了Java中org.apache.hadoop.yarn.server.resourcemanager.rmnode.RMNodeEvent类的典型用法代码示例。如果您正苦于以下问题：Java RMNodeEvent类的具体用法？Java RMNodeEvent怎么用？Java RMNodeEvent使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。



RMNodeEvent类属于org.apache.hadoop.yarn.server.resourcemanager.rmnode包，在下文中一共展示了RMNodeEvent类的13个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: testRunningExpire

import org.apache.hadoop.yarn.server.resourcemanager.rmnode.RMNodeEvent; //导入依赖的package包/类
@Test
public void testRunningExpire() {
  RMNodeImpl node = getRunningNode();
  ClusterMetrics cm = ClusterMetrics.getMetrics();
  int initialActive = cm.getNumActiveNMs();
  int initialLost = cm.getNumLostNMs();
  int initialUnhealthy = cm.getUnhealthyNMs();
  int initialDecommissioned = cm.getNumDecommisionedNMs();
  int initialRebooted = cm.getNumRebootedNMs();
  node.handle(new RMNodeEvent(node.getNodeID(), RMNodeEventType.EXPIRE));
  Assert.assertEquals("Active Nodes", initialActive - 1, cm.getNumActiveNMs());
  Assert.assertEquals("Lost Nodes", initialLost + 1, cm.getNumLostNMs());
  Assert.assertEquals("Unhealthy Nodes",
      initialUnhealthy, cm.getUnhealthyNMs());
  Assert.assertEquals("Decommissioned Nodes",
      initialDecommissioned, cm.getNumDecommisionedNMs());
  Assert.assertEquals("Rebooted Nodes",
      initialRebooted, cm.getNumRebootedNMs());
  Assert.assertEquals(NodeState.LOST, node.getState());
}
开发者ID:naver，项目名称:hadoop，代码行数:21，代码来源:TestRMNodeTransitions.java


示例2: testUnhealthyExpire

import org.apache.hadoop.yarn.server.resourcemanager.rmnode.RMNodeEvent; //导入依赖的package包/类
@Test
public void testUnhealthyExpire() {
  RMNodeImpl node = getUnhealthyNode();
  ClusterMetrics cm = ClusterMetrics.getMetrics();
  int initialActive = cm.getNumActiveNMs();
  int initialLost = cm.getNumLostNMs();
  int initialUnhealthy = cm.getUnhealthyNMs();
  int initialDecommissioned = cm.getNumDecommisionedNMs();
  int initialRebooted = cm.getNumRebootedNMs();
  node.handle(new RMNodeEvent(node.getNodeID(), RMNodeEventType.EXPIRE));
  Assert.assertEquals("Active Nodes", initialActive, cm.getNumActiveNMs());
  Assert.assertEquals("Lost Nodes", initialLost + 1, cm.getNumLostNMs());
  Assert.assertEquals("Unhealthy Nodes",
      initialUnhealthy - 1, cm.getUnhealthyNMs());
  Assert.assertEquals("Decommissioned Nodes",
      initialDecommissioned, cm.getNumDecommisionedNMs());
  Assert.assertEquals("Rebooted Nodes",
      initialRebooted, cm.getNumRebootedNMs());
  Assert.assertEquals(NodeState.LOST, node.getState());
}
开发者ID:naver，项目名称:hadoop，代码行数:21，代码来源:TestRMNodeTransitions.java


示例3: testRunningDecommission

import org.apache.hadoop.yarn.server.resourcemanager.rmnode.RMNodeEvent; //导入依赖的package包/类
@Test
public void testRunningDecommission() {
  RMNodeImpl node = getRunningNode();
  ClusterMetrics cm = ClusterMetrics.getMetrics();
  int initialActive = cm.getNumActiveNMs();
  int initialLost = cm.getNumLostNMs();
  int initialUnhealthy = cm.getUnhealthyNMs();
  int initialDecommissioned = cm.getNumDecommisionedNMs();
  int initialRebooted = cm.getNumRebootedNMs();
  node.handle(new RMNodeEvent(node.getNodeID(),
      RMNodeEventType.DECOMMISSION));
  Assert.assertEquals("Active Nodes", initialActive - 1, cm.getNumActiveNMs());
  Assert.assertEquals("Lost Nodes", initialLost, cm.getNumLostNMs());
  Assert.assertEquals("Unhealthy Nodes",
      initialUnhealthy, cm.getUnhealthyNMs());
  Assert.assertEquals("Decommissioned Nodes",
      initialDecommissioned + 1, cm.getNumDecommisionedNMs());
  Assert.assertEquals("Rebooted Nodes",
      initialRebooted, cm.getNumRebootedNMs());
  Assert.assertEquals(NodeState.DECOMMISSIONED, node.getState());
}
开发者ID:naver，项目名称:hadoop，代码行数:22，代码来源:TestRMNodeTransitions.java


示例4: testUnhealthyDecommission

import org.apache.hadoop.yarn.server.resourcemanager.rmnode.RMNodeEvent; //导入依赖的package包/类
@Test
public void testUnhealthyDecommission() {
  RMNodeImpl node = getUnhealthyNode();
  ClusterMetrics cm = ClusterMetrics.getMetrics();
  int initialActive = cm.getNumActiveNMs();
  int initialLost = cm.getNumLostNMs();
  int initialUnhealthy = cm.getUnhealthyNMs();
  int initialDecommissioned = cm.getNumDecommisionedNMs();
  int initialRebooted = cm.getNumRebootedNMs();
  node.handle(new RMNodeEvent(node.getNodeID(),
      RMNodeEventType.DECOMMISSION));
  Assert.assertEquals("Active Nodes", initialActive, cm.getNumActiveNMs());
  Assert.assertEquals("Lost Nodes", initialLost, cm.getNumLostNMs());
  Assert.assertEquals("Unhealthy Nodes",
      initialUnhealthy - 1, cm.getUnhealthyNMs());
  Assert.assertEquals("Decommissioned Nodes",
      initialDecommissioned + 1, cm.getNumDecommisionedNMs());
  Assert.assertEquals("Rebooted Nodes",
      initialRebooted, cm.getNumRebootedNMs());
  Assert.assertEquals(NodeState.DECOMMISSIONED, node.getState());
}
开发者ID:naver，项目名称:hadoop，代码行数:22，代码来源:TestRMNodeTransitions.java


示例5: testRunningRebooting

import org.apache.hadoop.yarn.server.resourcemanager.rmnode.RMNodeEvent; //导入依赖的package包/类
@Test
public void testRunningRebooting() {
  RMNodeImpl node = getRunningNode();
  ClusterMetrics cm = ClusterMetrics.getMetrics();
  int initialActive = cm.getNumActiveNMs();
  int initialLost = cm.getNumLostNMs();
  int initialUnhealthy = cm.getUnhealthyNMs();
  int initialDecommissioned = cm.getNumDecommisionedNMs();
  int initialRebooted = cm.getNumRebootedNMs();
  node.handle(new RMNodeEvent(node.getNodeID(),
      RMNodeEventType.REBOOTING));
  Assert.assertEquals("Active Nodes", initialActive - 1, cm.getNumActiveNMs());
  Assert.assertEquals("Lost Nodes", initialLost, cm.getNumLostNMs());
  Assert.assertEquals("Unhealthy Nodes",
      initialUnhealthy, cm.getUnhealthyNMs());
  Assert.assertEquals("Decommissioned Nodes",
      initialDecommissioned, cm.getNumDecommisionedNMs());
  Assert.assertEquals("Rebooted Nodes",
      initialRebooted + 1, cm.getNumRebootedNMs());
  Assert.assertEquals(NodeState.REBOOTED, node.getState());
}
开发者ID:naver，项目名称:hadoop，代码行数:22，代码来源:TestRMNodeTransitions.java


示例6: testUnhealthyRebooting

import org.apache.hadoop.yarn.server.resourcemanager.rmnode.RMNodeEvent; //导入依赖的package包/类
@Test
public void testUnhealthyRebooting() {
  RMNodeImpl node = getUnhealthyNode();
  ClusterMetrics cm = ClusterMetrics.getMetrics();
  int initialActive = cm.getNumActiveNMs();
  int initialLost = cm.getNumLostNMs();
  int initialUnhealthy = cm.getUnhealthyNMs();
  int initialDecommissioned = cm.getNumDecommisionedNMs();
  int initialRebooted = cm.getNumRebootedNMs();
  node.handle(new RMNodeEvent(node.getNodeID(),
      RMNodeEventType.REBOOTING));
  Assert.assertEquals("Active Nodes", initialActive, cm.getNumActiveNMs());
  Assert.assertEquals("Lost Nodes", initialLost, cm.getNumLostNMs());
  Assert.assertEquals("Unhealthy Nodes",
      initialUnhealthy - 1, cm.getUnhealthyNMs());
  Assert.assertEquals("Decommissioned Nodes",
      initialDecommissioned, cm.getNumDecommisionedNMs());
  Assert.assertEquals("Rebooted Nodes",
      initialRebooted + 1, cm.getNumRebootedNMs());
  Assert.assertEquals(NodeState.REBOOTED, node.getState());
}
开发者ID:naver，项目名称:hadoop，代码行数:22，代码来源:TestRMNodeTransitions.java


示例7: unRegisterNodeManager

import org.apache.hadoop.yarn.server.resourcemanager.rmnode.RMNodeEvent; //导入依赖的package包/类
@SuppressWarnings("unchecked")
@Override
public UnRegisterNodeManagerResponse unRegisterNodeManager(
    UnRegisterNodeManagerRequest request) throws YarnException, IOException {
  UnRegisterNodeManagerResponse response = recordFactory
      .newRecordInstance(UnRegisterNodeManagerResponse.class);
  NodeId nodeId = request.getNodeId();
  RMNode rmNode = this.rmContext.getRMNodes().get(nodeId);
  if (rmNode == null) {
    LOG.info("Node not found, ignoring the unregister from node id : "
        + nodeId);
    return response;
  }
  LOG.info("Node with node id : " + nodeId
      + " has shutdown, hence unregistering the node.");
  this.nmLivelinessMonitor.unregister(nodeId);
  this.rmContext.getDispatcher().getEventHandler()
      .handle(new RMNodeEvent(nodeId, RMNodeEventType.SHUTDOWN));
  return response;
}
开发者ID:aliyun-beta，项目名称:aliyun-oss-hadoop-fs，代码行数:21，代码来源:ResourceTrackerService.java


示例8: refreshNodesGracefully

import org.apache.hadoop.yarn.server.resourcemanager.rmnode.RMNodeEvent; //导入依赖的package包/类
/**
 * Refresh the nodes gracefully
 *
 * @param conf
 * @throws IOException
 * @throws YarnException
 */
public void refreshNodesGracefully(Configuration conf) throws IOException,
    YarnException {
  refreshHostsReader(conf);
  for (Entry<NodeId, RMNode> entry:rmContext.getRMNodes().entrySet()) {
    NodeId nodeId = entry.getKey();
    if (!isValidNode(nodeId.getHost())) {
      this.rmContext.getDispatcher().getEventHandler().handle(
          new RMNodeEvent(nodeId, RMNodeEventType.GRACEFUL_DECOMMISSION));
    } else {
      // Recommissioning the nodes
      if (entry.getValue().getState() == NodeState.DECOMMISSIONING
          || entry.getValue().getState() == NodeState.DECOMMISSIONED) {
        this.rmContext.getDispatcher().getEventHandler()
            .handle(new RMNodeEvent(nodeId, RMNodeEventType.RECOMMISSION));
      }
    }
  }
}
开发者ID:aliyun-beta，项目名称:aliyun-oss-hadoop-fs，代码行数:26，代码来源:NodesListManager.java


示例9: testDecommissionOnDecommissioningNode

import org.apache.hadoop.yarn.server.resourcemanager.rmnode.RMNodeEvent; //导入依赖的package包/类
@Test
public void testDecommissionOnDecommissioningNode() {
  RMNodeImpl node = getDecommissioningNode();
  ClusterMetrics cm = ClusterMetrics.getMetrics();
  int initialActive = cm.getNumActiveNMs();
  int initialLost = cm.getNumLostNMs();
  int initialUnhealthy = cm.getUnhealthyNMs();
  int initialDecommissioned = cm.getNumDecommisionedNMs();
  int initialRebooted = cm.getNumRebootedNMs();
  int initialDecommissioning = cm.getNumDecommissioningNMs();
  node.handle(new RMNodeEvent(node.getNodeID(), RMNodeEventType.DECOMMISSION));
  Assert.assertEquals("Active Nodes", initialActive, cm.getNumActiveNMs());
  Assert.assertEquals("Lost Nodes", initialLost, cm.getNumLostNMs());
  Assert.assertEquals("Unhealthy Nodes", initialUnhealthy,
      cm.getUnhealthyNMs());
  Assert.assertEquals("Decommissioning Nodes", initialDecommissioning - 1,
      cm.getNumDecommissioningNMs());
  Assert.assertEquals("Decommissioned Nodes", initialDecommissioned + 1,
      cm.getNumDecommisionedNMs());
  Assert.assertEquals("Rebooted Nodes", initialRebooted,
      cm.getNumRebootedNMs());
  Assert.assertEquals(NodeState.DECOMMISSIONED, node.getState());
}
开发者ID:aliyun-beta，项目名称:aliyun-oss-hadoop-fs，代码行数:24，代码来源:TestRMNodeTransitions.java


示例10: testUnhealthyDecommissioning

import org.apache.hadoop.yarn.server.resourcemanager.rmnode.RMNodeEvent; //导入依赖的package包/类
@Test
public void testUnhealthyDecommissioning() {
  RMNodeImpl node = getUnhealthyNode();
  ClusterMetrics cm = ClusterMetrics.getMetrics();
  int initialActive = cm.getNumActiveNMs();
  int initialLost = cm.getNumLostNMs();
  int initialUnhealthy = cm.getUnhealthyNMs();
  int initialDecommissioned = cm.getNumDecommisionedNMs();
  int initialDecommissioning = cm.getNumDecommissioningNMs();
  int initialRebooted = cm.getNumRebootedNMs();
  node.handle(new RMNodeEvent(node.getNodeID(),
      RMNodeEventType.GRACEFUL_DECOMMISSION));
  Assert.assertEquals("Active Nodes", initialActive,
      cm.getNumActiveNMs());
  Assert.assertEquals("Lost Nodes", initialLost, cm.getNumLostNMs());
  Assert.assertEquals("Unhealthy Nodes",
      initialUnhealthy - 1, cm.getUnhealthyNMs());
  Assert.assertEquals("Decommissioned Nodes", initialDecommissioned,
      cm.getNumDecommisionedNMs());
  Assert.assertEquals("Decommissioning Nodes", initialDecommissioning + 1,
      cm.getNumDecommissioningNMs());
  Assert.assertEquals("Rebooted Nodes",
      initialRebooted, cm.getNumRebootedNMs());
  Assert.assertEquals(NodeState.DECOMMISSIONING, node.getState());
}
开发者ID:aliyun-beta，项目名称:aliyun-oss-hadoop-fs，代码行数:26，代码来源:TestRMNodeTransitions.java


示例11: setDecomissionedNMs

import org.apache.hadoop.yarn.server.resourcemanager.rmnode.RMNodeEvent; //导入依赖的package包/类
private void setDecomissionedNMs() {
  Set<String> excludeList = hostsReader.getExcludedHosts();
  for (final String host : excludeList) {
    NodeId nodeId = createUnknownNodeId(host);
    RMNodeImpl rmNode;
    if(rmContext.isDistributed()){
      rmNode= new RMNodeImplDist(nodeId,
        rmContext, host, -1, -1, new UnknownNode(host),
        Resource.newInstance(0, 0), "unknown");
    rmContext.getInactiveRMNodes().put(nodeId, rmNode);
    }else{
      rmNode= new RMNodeImplNotDist(nodeId,
        rmContext, host, -1, -1, new UnknownNode(host),
        Resource.newInstance(0, 0), "unknown");
    rmContext.getInactiveRMNodes().put(nodeId, rmNode);
    }
    rmNode.handle(new RMNodeEvent(nodeId, RMNodeEventType.DECOMMISSION));
  }
}
开发者ID:hopshadoop，项目名称:hops，代码行数:20，代码来源:NodesListManager.java


示例12: refreshNodesGracefully

import org.apache.hadoop.yarn.server.resourcemanager.rmnode.RMNodeEvent; //导入依赖的package包/类
/**
 * Refresh the nodes gracefully
 *
 * @param conf
 * @throws IOException
 * @throws YarnException
 */
public void refreshNodesGracefully(Configuration conf) throws IOException,
    YarnException {
  refreshHostsReader(conf);
  for (Entry<NodeId, RMNode> entry : rmContext.getRMNodes().entrySet()) {
    NodeId nodeId = entry.getKey();
    if (!isValidNode(nodeId.getHost())) {
      RMNodeEventType nodeEventType = isUntrackedNode(nodeId.getHost()) ?
          RMNodeEventType.SHUTDOWN : RMNodeEventType.GRACEFUL_DECOMMISSION;
      this.rmContext.getDispatcher().getEventHandler().handle(
          new RMNodeEvent(nodeId, nodeEventType));
    } else {
      // Recommissioning the nodes
      if (entry.getValue().getState() == NodeState.DECOMMISSIONING) {
        this.rmContext.getDispatcher().getEventHandler()
            .handle(new RMNodeEvent(nodeId, RMNodeEventType.RECOMMISSION));
      }
    }
  }
  updateInactiveNodes();
}
开发者ID:hopshadoop，项目名称:hops，代码行数:28，代码来源:NodesListManager.java


示例13: testDecommissioningNodeReconnect

import org.apache.hadoop.yarn.server.resourcemanager.rmnode.RMNodeEvent; //导入依赖的package包/类
@SuppressWarnings("unchecked")
@Test(timeout = 10000)
public void testDecommissioningNodeReconnect()
    throws Exception {
  MockRM rm = new MockRM();
  rm.start();
  MockNM nm1 =
      new MockNM("127.0.0.1:1234", 15120, rm.getResourceTrackerService());
  nm1.registerNode();
  rm.waitForState(nm1.getNodeId(), NodeState.RUNNING);

  rm.getRMContext().getNodesListManager().getHostsReader().
      getExcludedHosts().add("127.0.0.1");
  rm.getRMContext().getDispatcher().getEventHandler().handle(
      new RMNodeEvent(nm1.getNodeId(),
          RMNodeEventType.GRACEFUL_DECOMMISSION));
  rm.waitForState(nm1.getNodeId(), NodeState.DECOMMISSIONING);

  MockNM nm2 =
      new MockNM("127.0.0.1:1234", 15120, rm.getResourceTrackerService());
  RegisterNodeManagerResponse response = nm2.registerNode();
  // not SHUTDOWN
  Assert.assertTrue(response.getNodeAction().equals(NodeAction.NORMAL));
  rm.stop();
}
开发者ID:hopshadoop，项目名称:hops，代码行数:26，代码来源:TestNMReconnect.java



注：本文中的org.apache.hadoop.yarn.server.resourcemanager.rmnode.RMNodeEvent类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。

鲜花
握手
雷人
路过
鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
More+
上一篇：
Java SampleDescriptionBox类代码示例发布时间：2022-05-22
下一篇：
Java GetDelegationTokenRequestPBImpl类代码示例发布时间：2022-05-22
热门推荐
More+
热门话题
More+
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服（服务时间 9:00～18:00）

在线QQ客服
地址：深圳市南山区西丽大学城创智工业园
电邮：jeky_zhao#qq.com
移动电话：139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap