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

Java NMNotYetReadyException类代码示例

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

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



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

示例1: createRetryPolicy

import org.apache.hadoop.yarn.exceptions.NMNotYetReadyException; //导入依赖的package包/类
protected static RetryPolicy createRetryPolicy(Configuration conf,
    String maxWaitTimeStr, long defMaxWaitTime,
    String connectRetryIntervalStr, long defRetryInterval) {
  long maxWaitTime = conf.getLong(maxWaitTimeStr, defMaxWaitTime);
  long retryIntervalMS =
      conf.getLong(connectRetryIntervalStr, defRetryInterval);
  if (maxWaitTime == -1) {
    // wait forever.
    return RetryPolicies.RETRY_FOREVER;
  }

  Preconditions.checkArgument(maxWaitTime > 0, "Invalid Configuration. "
      + maxWaitTimeStr + " should be a positive value.");
  Preconditions.checkArgument(retryIntervalMS > 0, "Invalid Configuration. "
      + connectRetryIntervalStr + "should be a positive value.");

  RetryPolicy retryPolicy =
      RetryPolicies.retryUpToMaximumTimeWithFixedSleep(maxWaitTime,
        retryIntervalMS, TimeUnit.MILLISECONDS);

  Map<Class<? extends Exception>, RetryPolicy> exceptionToPolicyMap =
      new HashMap<Class<? extends Exception>, RetryPolicy>();
  exceptionToPolicyMap.put(EOFException.class, retryPolicy);
  exceptionToPolicyMap.put(ConnectException.class, retryPolicy);
  exceptionToPolicyMap.put(NoRouteToHostException.class, retryPolicy);
  exceptionToPolicyMap.put(UnknownHostException.class, retryPolicy);
  exceptionToPolicyMap.put(RetriableException.class, retryPolicy);
  exceptionToPolicyMap.put(SocketException.class, retryPolicy);
  exceptionToPolicyMap.put(NMNotYetReadyException.class, retryPolicy);

  return RetryPolicies.retryByException(RetryPolicies.TRY_ONCE_THEN_FAIL,
    exceptionToPolicyMap);
}
 
开发者ID:naver,项目名称:hadoop,代码行数:34,代码来源:ServerProxy.java


示例2: createRetryPolicy

import org.apache.hadoop.yarn.exceptions.NMNotYetReadyException; //导入依赖的package包/类
protected static RetryPolicy createRetryPolicy(Configuration conf,
    String maxWaitTimeStr, long defMaxWaitTime,
    String connectRetryIntervalStr, long defRetryInterval) {
  long maxWaitTime = conf.getLong(maxWaitTimeStr, defMaxWaitTime);
  long retryIntervalMS =
      conf.getLong(connectRetryIntervalStr, defRetryInterval);

  Preconditions.checkArgument((maxWaitTime == -1 || maxWaitTime > 0),
      "Invalid Configuration. " + maxWaitTimeStr + " should be either"
          + " positive value or -1.");
  Preconditions.checkArgument(retryIntervalMS > 0, "Invalid Configuration. "
      + connectRetryIntervalStr + "should be a positive value.");

  RetryPolicy retryPolicy = null;
  if (maxWaitTime == -1) {
    // wait forever.
    retryPolicy = RetryPolicies.retryForeverWithFixedSleep(retryIntervalMS,
        TimeUnit.MILLISECONDS);
  } else {
    retryPolicy =
        RetryPolicies.retryUpToMaximumTimeWithFixedSleep(maxWaitTime,
            retryIntervalMS, TimeUnit.MILLISECONDS);
  }

  Map<Class<? extends Exception>, RetryPolicy> exceptionToPolicyMap =
      new HashMap<Class<? extends Exception>, RetryPolicy>();
  exceptionToPolicyMap.put(EOFException.class, retryPolicy);
  exceptionToPolicyMap.put(ConnectException.class, retryPolicy);
  exceptionToPolicyMap.put(NoRouteToHostException.class, retryPolicy);
  exceptionToPolicyMap.put(UnknownHostException.class, retryPolicy);
  exceptionToPolicyMap.put(RetriableException.class, retryPolicy);
  exceptionToPolicyMap.put(SocketException.class, retryPolicy);
  exceptionToPolicyMap.put(NMNotYetReadyException.class, retryPolicy);

  return RetryPolicies.retryByException(RetryPolicies.TRY_ONCE_THEN_FAIL,
    exceptionToPolicyMap);
}
 
开发者ID:aliyun-beta,项目名称:aliyun-oss-hadoop-fs,代码行数:38,代码来源:ServerProxy.java


示例3: createRetryPolicy

import org.apache.hadoop.yarn.exceptions.NMNotYetReadyException; //导入依赖的package包/类
protected static RetryPolicy createRetryPolicy(Configuration conf,
    String maxWaitTimeStr, long defMaxWaitTime,
    String connectRetryIntervalStr, long defRetryInterval) {
  long maxWaitTime = conf.getLong(maxWaitTimeStr, defMaxWaitTime);
  long retryIntervalMS =
      conf.getLong(connectRetryIntervalStr, defRetryInterval);

  Preconditions.checkArgument((maxWaitTime == -1 || maxWaitTime > 0),
      "Invalid Configuration. " + maxWaitTimeStr + " should be either"
          + " positive value or -1.");
  Preconditions.checkArgument(retryIntervalMS > 0, "Invalid Configuration. "
      + connectRetryIntervalStr + "should be a positive value.");

  RetryPolicy retryPolicy = null;
  if (maxWaitTime == -1) {
    // wait forever.
    retryPolicy = RetryPolicies.retryForeverWithFixedSleep(retryIntervalMS,
        TimeUnit.MILLISECONDS);
  } else {
    retryPolicy =
        RetryPolicies.retryUpToMaximumTimeWithFixedSleep(maxWaitTime,
            retryIntervalMS, TimeUnit.MILLISECONDS);
  }

  Map<Class<? extends Exception>, RetryPolicy> exceptionToPolicyMap =
      new HashMap<Class<? extends Exception>, RetryPolicy>();
  exceptionToPolicyMap.put(EOFException.class, retryPolicy);
  exceptionToPolicyMap.put(ConnectException.class, retryPolicy);
  exceptionToPolicyMap.put(NoRouteToHostException.class, retryPolicy);
  exceptionToPolicyMap.put(UnknownHostException.class, retryPolicy);
  exceptionToPolicyMap.put(ConnectTimeoutException.class, retryPolicy);
  exceptionToPolicyMap.put(RetriableException.class, retryPolicy);
  exceptionToPolicyMap.put(SocketException.class, retryPolicy);
  // When client got an SSLException should not retry to connect
  exceptionToPolicyMap.put(SSLException.class, RetryPolicies.TRY_ONCE_THEN_FAIL);
  exceptionToPolicyMap.put(NMNotYetReadyException.class, retryPolicy);

  return RetryPolicies.retryByException(RetryPolicies.TRY_ONCE_THEN_FAIL,
    exceptionToPolicyMap);
}
 
开发者ID:hopshadoop,项目名称:hops,代码行数:41,代码来源:ServerProxy.java


示例4: stopContainerInternal

import org.apache.hadoop.yarn.exceptions.NMNotYetReadyException; //导入依赖的package包/类
@SuppressWarnings("unchecked")
private void stopContainerInternal(NMTokenIdentifier nmTokenIdentifier,
    ContainerId containerID) throws YarnException, IOException {
  String containerIDStr = containerID.toString();
  Container container = this.context.getContainers().get(containerID);
  LOG.info("Stopping container with container Id: " + containerIDStr);
  authorizeGetAndStopContainerRequest(containerID, container, true,
    nmTokenIdentifier);

  if (container == null) {
    if (!nodeStatusUpdater.isContainerRecentlyStopped(containerID)) {
      throw RPCUtil.getRemoteException("Container " + containerIDStr
        + " is not handled by this NodeManager");
    }
  } else {
    if (container.isRecovering()) {
      throw new NMNotYetReadyException("Container " + containerIDStr
          + " is recovering, try later");
    }
    context.getNMStateStore().storeContainerKilled(containerID);
    dispatcher.getEventHandler().handle(
      new ContainerKillEvent(containerID,
          ContainerExitStatus.KILLED_BY_APPMASTER,
          "Container killed by the ApplicationMaster."));

    NMAuditLogger.logSuccess(container.getUser(),    
      AuditConstants.STOP_CONTAINER, "ContainerManageImpl", containerID
        .getApplicationAttemptId().getApplicationId(), containerID);
  }
}
 
开发者ID:hopshadoop,项目名称:hops,代码行数:31,代码来源:ContainerManagerImpl.java


示例5: testRetriesOnFailures

import org.apache.hadoop.yarn.exceptions.NMNotYetReadyException; //导入依赖的package包/类
@Test
public void testRetriesOnFailures() throws Exception {
  final ContainerManagementProtocol mockProxy =
      mock(ContainerManagementProtocol.class);
  final StartContainersResponse mockResponse =
      mock(StartContainersResponse.class);
  when(mockProxy.startContainers(any(StartContainersRequest.class)))
      .thenThrow(new NMNotYetReadyException("foo")).thenReturn(mockResponse);
  Configuration conf = new Configuration();
  conf.setInt(YarnConfiguration.RM_AM_MAX_ATTEMPTS, 1);
  conf.setInt(YarnConfiguration.CLIENT_NM_CONNECT_RETRY_INTERVAL_MS, 1);
  final DrainDispatcher dispatcher = new DrainDispatcher();
  MockRM rm = new MockRMWithCustomAMLauncher(conf, null) {
    @Override
    protected ApplicationMasterLauncher createAMLauncher() {
      return new ApplicationMasterLauncher(getRMContext()) {
        @Override
        protected Runnable createRunnableLauncher(RMAppAttempt application,
            AMLauncherEventType event) {
          return new AMLauncher(context, application, event, getConfig()) {
            @Override
            protected YarnRPC getYarnRPC() {
              YarnRPC mockRpc = mock(YarnRPC.class);

              when(mockRpc.getProxy(
                  any(Class.class),
                  any(InetSocketAddress.class),
                  any(Configuration.class)))
                  .thenReturn(mockProxy);
              return mockRpc;
            }
          };
        }
      };
    }

    @Override
    protected Dispatcher createDispatcher() {
      return dispatcher;
    }
  };
  rm.start();
  MockNM nm1 = rm.registerNode("127.0.0.1:1234", 5120);

  RMApp app = rm.submitApp(2000);
  final ApplicationAttemptId appAttemptId = app.getCurrentAppAttempt()
      .getAppAttemptId();

  // kick the scheduling
  nm1.nodeHeartbeat(true);
  dispatcher.await();

  rm.waitForState(appAttemptId, RMAppAttemptState.LAUNCHED, 500);
}
 
开发者ID:aliyun-beta,项目名称:aliyun-oss-hadoop-fs,代码行数:55,代码来源:TestApplicationMasterLauncher.java


示例6: testRetriesOnFailures

import org.apache.hadoop.yarn.exceptions.NMNotYetReadyException; //导入依赖的package包/类
@Test
public void testRetriesOnFailures() throws Exception {
  final ContainerManagementProtocol mockProxy =
      mock(ContainerManagementProtocol.class);
  final StartContainersResponse mockResponse =
      mock(StartContainersResponse.class);
  when(mockProxy.startContainers(any(StartContainersRequest.class)))
      .thenThrow(new NMNotYetReadyException("foo")).thenReturn(mockResponse);
  conf.setInt(YarnConfiguration.RM_AM_MAX_ATTEMPTS, 1);
  conf.setInt(YarnConfiguration.CLIENT_NM_CONNECT_RETRY_INTERVAL_MS, 1);
  //final DrainDispatcher dispatcher = new DrainDispatcher();
  MockRM rm = new MockRMWithCustomAMLauncher(conf, null) {
    @Override
    protected ApplicationMasterLauncher createAMLauncher() {
      return new ApplicationMasterLauncher(getRMContext()) {
        @Override
        protected Runnable createRunnableLauncher(RMAppAttempt application,
            AMLauncherEventType event) {
          return new AMLauncher(context, application, event, getConfig()) {
            @Override
            protected YarnRPC getYarnRPC() {
              YarnRPC mockRpc = mock(YarnRPC.class);

              when(mockRpc.getProxy(
                  any(Class.class),
                  any(InetSocketAddress.class),
                  any(Configuration.class)))
                  .thenReturn(mockProxy);
              return mockRpc;
            }
          };
        }
      };
    }

    /*@Override
    protected Dispatcher createDispatcher() {
      return new DrainDispatcher();
    }*/
  };
  rm.start();

  MockNM nm1 = rm.registerNode("127.0.0.1:1234", 5120);

  RMApp app = rm.submitApp(2000);
  final ApplicationAttemptId appAttemptId = app.getCurrentAppAttempt()
      .getAppAttemptId();

  // kick the scheduling
  nm1.nodeHeartbeat(true);
  //dispatcher.await();
  ((DrainDispatcher) rm.getRmDispatcher()).await();

  rm.waitForState(appAttemptId, RMAppAttemptState.LAUNCHED, 500);
}
 
开发者ID:hopshadoop,项目名称:hops,代码行数:56,代码来源:TestApplicationMasterLauncher.java



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


鲜花

握手

雷人

路过

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

请发表评论

全部评论

专题导读
上一篇:
Java FinalApplicationStatusProto类代码示例发布时间:2022-05-22
下一篇:
Java RollEditLogResponseProto类代码示例发布时间: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