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

Java InvalidContainerRequestException类代码示例

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

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



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

示例1: checkLocalityRelaxationConflict

import org.apache.hadoop.yarn.client.api.InvalidContainerRequestException; //导入依赖的package包/类
/**
 * ContainerRequests with locality relaxation cannot be made at the same
 * priority as ContainerRequests without locality relaxation.
 */
private void checkLocalityRelaxationConflict(Priority priority,
    Collection<String> locations, boolean relaxLocality) {
  Map<String, TreeMap<Resource, ResourceRequestInfo>> remoteRequests =
      this.remoteRequestsTable.get(priority);
  if (remoteRequests == null) {
    return;
  }
  // Locality relaxation will be set to relaxLocality for all implicitly
  // requested racks. Make sure that existing rack requests match this.
  for (String location : locations) {
      TreeMap<Resource, ResourceRequestInfo> reqs =
          remoteRequests.get(location);
      if (reqs != null && !reqs.isEmpty()) {
        boolean existingRelaxLocality =
            reqs.values().iterator().next().remoteRequest.getRelaxLocality();
        if (relaxLocality != existingRelaxLocality) {
          throw new InvalidContainerRequestException("Cannot submit a "
              + "ContainerRequest asking for location " + location
              + " with locality relaxation " + relaxLocality + " when it has "
              + "already been requested with locality relaxation " + existingRelaxLocality);
        }
      }
    }
}
 
开发者ID:naver,项目名称:hadoop,代码行数:29,代码来源:AMRMClientImpl.java


示例2: testDifferentLocalityRelaxationSamePriority

import org.apache.hadoop.yarn.client.api.InvalidContainerRequestException; //导入依赖的package包/类
@Test (expected = InvalidContainerRequestException.class)
public void testDifferentLocalityRelaxationSamePriority() {
  AMRMClientImpl<ContainerRequest> client =
      new AMRMClientImpl<ContainerRequest>();
  Configuration conf = new Configuration();
  conf.setClass(
      CommonConfigurationKeysPublic.NET_TOPOLOGY_NODE_SWITCH_MAPPING_IMPL_KEY,
      MyResolver.class, DNSToSwitchMapping.class);
  client.init(conf);
  
  Resource capability = Resource.newInstance(1024, 1, 1);
  ContainerRequest request1 =
      new ContainerRequest(capability, new String[] {"host1", "host2"},
          null, Priority.newInstance(1), false);
  client.addContainerRequest(request1);
  ContainerRequest request2 =
      new ContainerRequest(capability, new String[] {"host3"},
          null, Priority.newInstance(1), true);
  client.addContainerRequest(request2);
}
 
开发者ID:naver,项目名称:hadoop,代码行数:21,代码来源:TestAMRMClientContainerRequest.java


示例3: testLocalityRelaxationDifferentLevels

import org.apache.hadoop.yarn.client.api.InvalidContainerRequestException; //导入依赖的package包/类
@Test (expected = InvalidContainerRequestException.class)
public void testLocalityRelaxationDifferentLevels() {
  AMRMClientImpl<ContainerRequest> client =
      new AMRMClientImpl<ContainerRequest>();
  Configuration conf = new Configuration();
  conf.setClass(
      CommonConfigurationKeysPublic.NET_TOPOLOGY_NODE_SWITCH_MAPPING_IMPL_KEY,
      MyResolver.class, DNSToSwitchMapping.class);
  client.init(conf);
  
  Resource capability = Resource.newInstance(1024, 1, 1);
  ContainerRequest request1 =
      new ContainerRequest(capability, new String[] {"host1", "host2"},
          null, Priority.newInstance(1), false);
  client.addContainerRequest(request1);
  ContainerRequest request2 =
      new ContainerRequest(capability, null,
          new String[] {"rack1"}, Priority.newInstance(1), true);
  client.addContainerRequest(request2);
}
 
开发者ID:naver,项目名称:hadoop,代码行数:21,代码来源:TestAMRMClientContainerRequest.java


示例4: checkNodeLabelExpression

import org.apache.hadoop.yarn.client.api.InvalidContainerRequestException; //导入依赖的package包/类
/**
 * Valid if a node label expression specified on container request is valid or
 * not
 * 
 * @param containerRequest
 */
private void checkNodeLabelExpression(T containerRequest) {
  String exp = containerRequest.getNodeLabelExpression();
  
  if (null == exp || exp.isEmpty()) {
    return;
  }

  // Don't support specifying >= 2 node labels in a node label expression now
  if (exp.contains("&&") || exp.contains("||")) {
    throw new InvalidContainerRequestException(
        "Cannot specify more than two node labels"
            + " in a single node label expression");
  }
  
  // Don't allow specify node label against ANY request
  if ((containerRequest.getRacks() != null && 
      (!containerRequest.getRacks().isEmpty()))
      || 
      (containerRequest.getNodes() != null && 
      (!containerRequest.getNodes().isEmpty()))) {
    throw new InvalidContainerRequestException(
        "Cannot specify node label with rack and node");
  }
}
 
开发者ID:aliyun-beta,项目名称:aliyun-oss-hadoop-fs,代码行数:31,代码来源:AMRMClientImpl.java


示例5: testDifferentLocalityRelaxationSamePriority

import org.apache.hadoop.yarn.client.api.InvalidContainerRequestException; //导入依赖的package包/类
@Test (expected = InvalidContainerRequestException.class)
public void testDifferentLocalityRelaxationSamePriority() {
  AMRMClientImpl<ContainerRequest> client =
      new AMRMClientImpl<ContainerRequest>();
  Configuration conf = new Configuration();
  conf.setClass(
      CommonConfigurationKeysPublic.NET_TOPOLOGY_NODE_SWITCH_MAPPING_IMPL_KEY,
      MyResolver.class, DNSToSwitchMapping.class);
  client.init(conf);
  
  Resource capability = Resource.newInstance(1024, 1);
  ContainerRequest request1 =
      new ContainerRequest(capability, new String[] {"host1", "host2"},
          null, Priority.newInstance(1), false);
  client.addContainerRequest(request1);
  ContainerRequest request2 =
      new ContainerRequest(capability, new String[] {"host3"},
          null, Priority.newInstance(1), true);
  client.addContainerRequest(request2);
}
 
开发者ID:aliyun-beta,项目名称:aliyun-oss-hadoop-fs,代码行数:21,代码来源:TestAMRMClientContainerRequest.java


示例6: testLocalityRelaxationDifferentLevels

import org.apache.hadoop.yarn.client.api.InvalidContainerRequestException; //导入依赖的package包/类
@Test (expected = InvalidContainerRequestException.class)
public void testLocalityRelaxationDifferentLevels() {
  AMRMClientImpl<ContainerRequest> client =
      new AMRMClientImpl<ContainerRequest>();
  Configuration conf = new Configuration();
  conf.setClass(
      CommonConfigurationKeysPublic.NET_TOPOLOGY_NODE_SWITCH_MAPPING_IMPL_KEY,
      MyResolver.class, DNSToSwitchMapping.class);
  client.init(conf);
  
  Resource capability = Resource.newInstance(1024, 1);
  ContainerRequest request1 =
      new ContainerRequest(capability, new String[] {"host1", "host2"},
          null, Priority.newInstance(1), false);
  client.addContainerRequest(request1);
  ContainerRequest request2 =
      new ContainerRequest(capability, null,
          new String[] {"rack1"}, Priority.newInstance(1), true);
  client.addContainerRequest(request2);
}
 
开发者ID:aliyun-beta,项目名称:aliyun-oss-hadoop-fs,代码行数:21,代码来源:TestAMRMClientContainerRequest.java


示例7: checkLocalityRelaxationConflict

import org.apache.hadoop.yarn.client.api.InvalidContainerRequestException; //导入依赖的package包/类
/**
 * ContainerRequests with locality relaxation cannot be made at the same
 * priority as ContainerRequests without locality relaxation.
 */
private void checkLocalityRelaxationConflict(Priority priority,
    Collection<String> locations, boolean relaxLocality) {
  Map<String, TreeMap<Resource, ResourceRequestInfo>> remoteRequests =
      this.remoteRequestsTable.get(priority);
  if (remoteRequests == null) {
    return;
  }
  // Locality relaxation will be set to relaxLocality for all implicitly
  // requested racks. Make sure that existing rack requests match this.
  for (String location : locations) {
      TreeMap<Resource, ResourceRequestInfo> reqs =
          remoteRequests.get(location);
      if (reqs != null && !reqs.isEmpty()
          && reqs.values().iterator().next().remoteRequest.getRelaxLocality()
          != relaxLocality) {
        throw new InvalidContainerRequestException("Cannot submit a "
            + "ContainerRequest asking for location " + location
            + " with locality relaxation " + relaxLocality + " when it has "
            + "already been requested with locality relaxation " + relaxLocality);
      }
    }
}
 
开发者ID:ict-carch,项目名称:hadoop-plus,代码行数:27,代码来源:AMRMClientImpl.java


示例8: checkNodeLabelExpression

import org.apache.hadoop.yarn.client.api.InvalidContainerRequestException; //导入依赖的package包/类
/**
 * Valid if a node label expression specified on container request is valid or
 * not
 * 
 * @param containerRequest
 */
private void checkNodeLabelExpression(T containerRequest) {
  String exp = containerRequest.getNodeLabelExpression();
  
  if (null == exp || exp.isEmpty()) {
    return;
  }

  // Don't support specifying >= 2 node labels in a node label expression now
  if (exp.contains("&&") || exp.contains("||")) {
    throw new InvalidContainerRequestException(
        "Cannot specify more than two node labels"
            + " in a single node label expression");
  }
}
 
开发者ID:naver,项目名称:hadoop,代码行数:21,代码来源:AMRMClientImpl.java


示例9: verifyAddRequestFailed

import org.apache.hadoop.yarn.client.api.InvalidContainerRequestException; //导入依赖的package包/类
private void verifyAddRequestFailed(AMRMClient<ContainerRequest> client,
    ContainerRequest request) {
  try {
    client.addContainerRequest(request);
  } catch (InvalidContainerRequestException e) {
    return;
  }
  Assert.fail();
}
 
开发者ID:naver,项目名称:hadoop,代码行数:10,代码来源:TestAMRMClient.java



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


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
Java CircleBuilder类代码示例发布时间:2022-05-22
下一篇:
Java ChatState类代码示例发布时间:2022-05-22
热门推荐
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

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

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