org.apache.hadoop.yarn.util.YarnVersionInfo类的使用及代码示例

x33g5p2x  于2022-02-05 转载在 其他  
字(14.5k)|赞(0)|评价(0)|浏览(155)

本文整理了Java中org.apache.hadoop.yarn.util.YarnVersionInfo类的一些代码示例，展示了YarnVersionInfo类的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。YarnVersionInfo类的具体详情如下：
包路径：org.apache.hadoop.yarn.util.YarnVersionInfo
类名称：YarnVersionInfo

YarnVersionInfo介绍

[英]This class finds the package info for Yarn.
[中]此类查找纱线的包装信息。

代码示例

代码示例来源：origin: org.apache.hadoop/hadoop-yarn-common

public static TimelineAbout createTimelineAbout(String about) {
 TimelineAbout tsInfo = new TimelineAbout(about);
 tsInfo.setHadoopBuildVersion(VersionInfo.getBuildVersion());
 tsInfo.setHadoopVersion(VersionInfo.getVersion());
 tsInfo.setHadoopVersionBuiltOn(VersionInfo.getDate());
 tsInfo.setTimelineServiceBuildVersion(YarnVersionInfo.getBuildVersion());
 tsInfo.setTimelineServiceVersion(YarnVersionInfo.getVersion());
 tsInfo.setTimelineServiceVersionBuiltOn(YarnVersionInfo.getDate());
 return tsInfo;
}

代码示例来源：origin: io.hops/hadoop-yarn-common

/**
  * Test the yarn version info routines.
  * @throws IOException
  */
 @Test
 public void versionInfoGenerated() throws IOException {

  // can't easily know what the correct values are going to be so just
  // make sure they aren't Unknown
  assertTrue("getVersion returned Unknown", !YarnVersionInfo.getVersion().equals("Unknown"));
  assertTrue("getUser returned Unknown", !YarnVersionInfo.getUser().equals("Unknown"));
  assertTrue("getUrl returned Unknown", !YarnVersionInfo.getUrl().equals("Unknown"));
  assertTrue("getSrcChecksum returned Unknown", !YarnVersionInfo.getSrcChecksum().equals("Unknown"));

  // these could be Unknown if the VersionInfo generated from code not in svn or git
  // so just check that they return something
  assertNotNull("getRevision returned null", YarnVersionInfo.getRevision());
  assertNotNull("getBranch returned null", YarnVersionInfo.getBranch());

  assertTrue("getBuildVersion check doesn't contain: source checksum",
        YarnVersionInfo.getBuildVersion().contains("source checksum"));

 }
}

代码示例来源：origin: org.apache.hadoop/hadoop-yarn-common

public static void main(String[] args) {
  LOG.debug("version: "+ getVersion());
  System.out.println("YARN " + getVersion());
  System.out.println("Subversion " + getUrl() + " -r " + getRevision());
  System.out.println("Compiled by " + getUser() + " on " + getDate());
  System.out.println("From source with checksum " + getSrcChecksum());
 }
}

代码示例来源：origin: org.apache.hadoop/hadoop-yarn-server-resourcemanager

public MockNM(String nodeIdStr, Resource capability,
  ResourceTrackerService resourceTracker) {
 this(nodeIdStr, capability, resourceTracker,
   YarnVersionInfo.getVersion());
}

代码示例来源：origin: ch.cern.hadoop/hadoop-yarn-common

public static void main(String[] args) {
  LOG.debug("version: "+ getVersion());
  System.out.println("Yarn " + getVersion());
  System.out.println("Subversion " + getUrl() + " -r " + getRevision());
  System.out.println("Compiled by " + getUser() + " on " + getDate());
  System.out.println("From source with checksum " + getSrcChecksum());
 }
}

代码示例来源：origin: org.apache.hadoop/hadoop-yarn-server-resourcemanager

public MockNM(String nodeIdStr, int memory, int vcores,
  ResourceTrackerService resourceTracker) {
 this(nodeIdStr, memory, vcores, resourceTracker,
   YarnVersionInfo.getVersion());
}

代码示例来源：origin: org.apache.hadoop/hadoop-yarn-server-resourcemanager

public ClusterInfo(ResourceManager rm) {
 long ts = ResourceManager.getClusterTimeStamp();
 this.id = ts;
 this.state = rm.getServiceState();
 this.haState = rm.getRMContext().getHAServiceState();
 this.rmStateStoreName = rm.getRMContext().getStateStore().getClass()
   .getName();
 this.startedOn = ts;
 this.resourceManagerVersion = YarnVersionInfo.getVersion();
 this.resourceManagerBuildVersion = YarnVersionInfo.getBuildVersion();
 this.resourceManagerVersionBuiltOn = YarnVersionInfo.getDate();
 this.hadoopVersion = VersionInfo.getVersion();
 this.hadoopBuildVersion = VersionInfo.getBuildVersion();
 this.hadoopVersionBuiltOn = VersionInfo.getDate();
 this.haZooKeeperConnectionState =
   rm.getRMContext().getHAZookeeperConnectionState();
}

代码示例来源：origin: ch.cern.hadoop/hadoop-yarn-common

/**
  * Test the yarn version info routines.
  * @throws IOException
  */
 @Test
 public void versionInfoGenerated() throws IOException {

  // can't easily know what the correct values are going to be so just
  // make sure they aren't Unknown
  assertTrue("getVersion returned Unknown", !YarnVersionInfo.getVersion().equals("Unknown"));
  assertTrue("getUser returned Unknown", !YarnVersionInfo.getUser().equals("Unknown"));
  assertTrue("getUrl returned Unknown", !YarnVersionInfo.getUrl().equals("Unknown"));
  assertTrue("getSrcChecksum returned Unknown", !YarnVersionInfo.getSrcChecksum().equals("Unknown"));

  // these could be Unknown if the VersionInfo generated from code not in svn or git
  // so just check that they return something
  assertNotNull("getRevision returned null", YarnVersionInfo.getRevision());
  assertNotNull("getBranch returned null", YarnVersionInfo.getBranch());

  assertTrue("getBuildVersion check doesn't contain: source checksum",
        YarnVersionInfo.getBuildVersion().contains("source checksum"));

 }
}

代码示例来源：origin: com.github.jiayuhan-it/hadoop-yarn-common

public static void main(String[] args) {
  LOG.debug("version: "+ getVersion());
  System.out.println("Yarn " + getVersion());
  System.out.println("Subversion " + getUrl() + " -r " + getRevision());
  System.out.println("Compiled by " + getUser() + " on " + getDate());
  System.out.println("From source with checksum " + getSrcChecksum());
 }
}

代码示例来源：origin: ch.cern.hadoop/hadoop-yarn-server-resourcemanager

public MockNM(String nodeIdStr, int memory, int vcores,
  ResourceTrackerService resourceTracker) {
 this(nodeIdStr, memory, vcores, resourceTracker, YarnVersionInfo.getVersion());
}

代码示例来源：origin: ch.cern.hadoop/hadoop-yarn-server-resourcemanager

public ClusterInfo(ResourceManager rm) {
 long ts = ResourceManager.getClusterTimeStamp();
 this.id = ts;
 this.state = rm.getServiceState();
 this.haState = rm.getRMContext().getHAServiceState();
 this.rmStateStoreName = rm.getRMContext().getStateStore().getClass()
   .getName();
 this.startedOn = ts;
 this.resourceManagerVersion = YarnVersionInfo.getVersion();
 this.resourceManagerBuildVersion = YarnVersionInfo.getBuildVersion();
 this.resourceManagerVersionBuiltOn = YarnVersionInfo.getDate();
 this.hadoopVersion = VersionInfo.getVersion();
 this.hadoopBuildVersion = VersionInfo.getBuildVersion();
 this.hadoopVersionBuiltOn = VersionInfo.getDate();
 this.haZooKeeperConnectionState =
   rm.getRMContext().getRMAdminService().getHAZookeeperConnectionState();
}

代码示例来源：origin: org.apache.hadoop/hadoop-yarn-common

/**
  * Test the yarn version info routines.
  * @throws IOException
  */
 @Test
 public void versionInfoGenerated() throws IOException {

  // can't easily know what the correct values are going to be so just
  // make sure they aren't Unknown
  assertNotEquals("getVersion returned Unknown",
    "Unknown", YarnVersionInfo.getVersion());
  assertNotEquals("getUser returned Unknown",
    "Unknown", YarnVersionInfo.getUser());
  assertNotEquals("getSrcChecksum returned Unknown",
    "Unknown", YarnVersionInfo.getSrcChecksum());

  // these could be Unknown if the VersionInfo generated from code not in svn or git
  // so just check that they return something
  assertNotNull("getUrl returned null", YarnVersionInfo.getUrl());
  assertNotNull("getRevision returned null", YarnVersionInfo.getRevision());
  assertNotNull("getBranch returned null", YarnVersionInfo.getBranch());

  assertTrue("getBuildVersion check doesn't contain: source checksum",
        YarnVersionInfo.getBuildVersion().contains("source checksum"));

 }
}

代码示例来源：origin: org.apache.hadoop/hadoop-yarn-server-nodemanager

@Override
protected void serviceStart() throws Exception {
 // NodeManager is the last service to start, so NodeId is available.
 this.nodeId = this.context.getNodeId();
 LOG.info("Node ID assigned is : " + this.nodeId);
 this.httpPort = this.context.getHttpPort();
 this.nodeManagerVersionId = YarnVersionInfo.getVersion();
 try {
  // Registration has to be in start so that ContainerManager can get the
  // perNM tokens needed to authenticate ContainerTokens.
  this.resourceTracker = getRMClient();
  registerWithRM();
  super.serviceStart();
  startStatusUpdater();
 } catch (Exception e) {
  String errorMessage = "Unexpected error starting NodeStatusUpdater";
  LOG.error(errorMessage, e);
  throw new YarnRuntimeException(e);
 }
}

代码示例来源：origin: com.github.jiayuhan-it/hadoop-yarn-server-resourcemanager

public ClusterInfo(ResourceManager rm) {
 long ts = ResourceManager.getClusterTimeStamp();
 this.id = ts;
 this.state = rm.getServiceState();
 this.haState = rm.getRMContext().getHAServiceState();
 this.rmStateStoreName = rm.getRMContext().getStateStore().getClass()
   .getName();
 this.startedOn = ts;
 this.resourceManagerVersion = YarnVersionInfo.getVersion();
 this.resourceManagerBuildVersion = YarnVersionInfo.getBuildVersion();
 this.resourceManagerVersionBuiltOn = YarnVersionInfo.getDate();
 this.hadoopVersion = VersionInfo.getVersion();
 this.hadoopBuildVersion = VersionInfo.getBuildVersion();
 this.hadoopVersionBuiltOn = VersionInfo.getDate();
 this.haZooKeeperConnectionState =
   rm.getRMContext().getRMAdminService().getHAZookeeperConnectionState();
}

代码示例来源：origin: io.hops/hadoop-yarn-server-nodemanager

@Override
protected void serviceStart() throws Exception {
 // NodeManager is the last service to start, so NodeId is available.
 this.nodeId = this.context.getNodeId();
 LOG.info("Node ID assigned is : " + this.nodeId);
 this.httpPort = this.context.getHttpPort();
 this.nodeManagerVersionId = YarnVersionInfo.getVersion();
 try {
  // Registration has to be in start so that ContainerManager can get the
  // perNM tokens needed to authenticate ContainerTokens.
  this.resourceTracker = getRMClient();
  registerWithRM();
  super.serviceStart();
  startStatusUpdater();
 } catch (Exception e) {
  String errorMessage = "Unexpected error starting NodeStatusUpdater";
  LOG.error(errorMessage, e);
  throw new YarnRuntimeException(e);
 }
}

代码示例来源：origin: ch.cern.hadoop/hadoop-yarn-server-nodemanager

public NodeInfo(final Context context, final ResourceView resourceView) {
 this.id = context.getNodeId().toString();
 this.nodeHostName = context.getNodeId().getHost();
 this.totalVmemAllocatedContainersMB = resourceView
   .getVmemAllocatedForContainers() / BYTES_IN_MB;
 this.vmemCheckEnabled = resourceView.isVmemCheckEnabled();
 this.totalPmemAllocatedContainersMB = resourceView
   .getPmemAllocatedForContainers() / BYTES_IN_MB;
 this.pmemCheckEnabled = resourceView.isPmemCheckEnabled();
 this.totalVCoresAllocatedContainers = resourceView
   .getVCoresAllocatedForContainers();
 this.nodeHealthy = context.getNodeHealthStatus().getIsNodeHealthy();
 this.lastNodeUpdateTime = context.getNodeHealthStatus()
   .getLastHealthReportTime();
 this.healthReport = context.getNodeHealthStatus().getHealthReport();
 this.nodeManagerVersion = YarnVersionInfo.getVersion();
 this.nodeManagerBuildVersion = YarnVersionInfo.getBuildVersion();
 this.nodeManagerVersionBuiltOn = YarnVersionInfo.getDate();
 this.hadoopVersion = VersionInfo.getVersion();
 this.hadoopBuildVersion = VersionInfo.getBuildVersion();
 this.hadoopVersionBuiltOn = VersionInfo.getDate();
}

代码示例来源：origin: ch.cern.hadoop/hadoop-yarn-server-nodemanager

@Override
protected void serviceStart() throws Exception {
 // NodeManager is the last service to start, so NodeId is available.
 this.nodeId = this.context.getNodeId();
 this.httpPort = this.context.getHttpPort();
 this.nodeManagerVersionId = YarnVersionInfo.getVersion();
 try {
  // Registration has to be in start so that ContainerManager can get the
  // perNM tokens needed to authenticate ContainerTokens.
  this.resourceTracker = getRMClient();
  registerWithRM();
  super.serviceStart();
  startStatusUpdater();
 } catch (Exception e) {
  String errorMessage = "Unexpected error starting NodeStatusUpdater";
  LOG.error(errorMessage, e);
  throw new YarnRuntimeException(e);
 }
}

代码示例来源：origin: com.github.jiayuhan-it/hadoop-yarn-server-nodemanager

public NodeInfo(final Context context, final ResourceView resourceView) {
 this.id = context.getNodeId().toString();
 this.nodeHostName = context.getNodeId().getHost();
 this.totalVmemAllocatedContainersMB = resourceView
   .getVmemAllocatedForContainers() / BYTES_IN_MB;
 this.vmemCheckEnabled = resourceView.isVmemCheckEnabled();
 this.totalPmemAllocatedContainersMB = resourceView
   .getPmemAllocatedForContainers() / BYTES_IN_MB;
 this.pmemCheckEnabled = resourceView.isPmemCheckEnabled();
 this.totalVCoresAllocatedContainers = resourceView
   .getVCoresAllocatedForContainers();
 this.nodeHealthy = context.getNodeHealthStatus().getIsNodeHealthy();
 this.lastNodeUpdateTime = context.getNodeHealthStatus()
   .getLastHealthReportTime();
 this.healthReport = context.getNodeHealthStatus().getHealthReport();
 this.nodeManagerVersion = YarnVersionInfo.getVersion();
 this.nodeManagerBuildVersion = YarnVersionInfo.getBuildVersion();
 this.nodeManagerVersionBuiltOn = YarnVersionInfo.getDate();
 this.hadoopVersion = VersionInfo.getVersion();
 this.hadoopBuildVersion = VersionInfo.getBuildVersion();
 this.hadoopVersionBuiltOn = VersionInfo.getDate();
}

代码示例来源：origin: com.github.jiayuhan-it/hadoop-yarn-server-nodemanager

@Override
protected void serviceStart() throws Exception {
 // NodeManager is the last service to start, so NodeId is available.
 this.nodeId = this.context.getNodeId();
 this.httpPort = this.context.getHttpPort();
 this.nodeManagerVersionId = YarnVersionInfo.getVersion();
 try {
  // Registration has to be in start so that ContainerManager can get the
  // perNM tokens needed to authenticate ContainerTokens.
  this.resourceTracker = getRMClient();
  registerWithRM();
  super.serviceStart();
  startStatusUpdater();
 } catch (Exception e) {
  String errorMessage = "Unexpected error starting NodeStatusUpdater";
  LOG.error(errorMessage, e);
  throw new YarnRuntimeException(e);
 }
}

代码示例来源：origin: io.hops/hadoop-yarn-server-nodemanager

public NodeInfo(final Context context, final ResourceView resourceView) {
 this.id = context.getNodeId().toString();
 this.nodeHostName = context.getNodeId().getHost();
 this.totalVmemAllocatedContainersMB = resourceView
   .getVmemAllocatedForContainers() / BYTES_IN_MB;
 this.vmemCheckEnabled = resourceView.isVmemCheckEnabled();
 this.totalPmemAllocatedContainersMB = resourceView
   .getPmemAllocatedForContainers() / BYTES_IN_MB;
 this.pmemCheckEnabled = resourceView.isPmemCheckEnabled();
 this.totalVCoresAllocatedContainers = resourceView
   .getVCoresAllocatedForContainers();
 this.totalGPUsAllocatedContainers = resourceView
   .getGPUsAllocatedForContainers();
 this.nodeHealthy = context.getNodeHealthStatus().getIsNodeHealthy();
 this.lastNodeUpdateTime = context.getNodeHealthStatus()
   .getLastHealthReportTime();
 this.healthReport = context.getNodeHealthStatus().getHealthReport();
 this.nodeManagerVersion = YarnVersionInfo.getVersion();
 this.nodeManagerBuildVersion = YarnVersionInfo.getBuildVersion();
 this.nodeManagerVersionBuiltOn = YarnVersionInfo.getDate();
 this.hadoopVersion = VersionInfo.getVersion();
 this.hadoopBuildVersion = VersionInfo.getBuildVersion();
 this.hadoopVersionBuiltOn = VersionInfo.getDate();
 this.nmStartupTime = NodeManager.getNMStartupTime();
}

内容来源于网络，如有侵权，请联系作者删除！

YarnVersionInfo

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com