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

YarnRuntimeException.<init>介绍

暂无

代码示例

代码示例来源：origin: Qihoo360/XLearning

@Override
protected void serviceInit(Configuration conf) throws Exception {
 Configuration config = new XLearningConfiguration(conf);
 config.setBoolean(Dispatcher.DISPATCHER_EXIT_ON_ERROR_KEY, true);
 // This is required for WebApps to use https if enabled.
 XLearningWebAppUtil.initialize(getConfig());
 try {
  doSecureLogin(conf);
 } catch (IOException ie) {
  throw new YarnRuntimeException("History Server Failed to login", ie);
 }
 jobHistoryService = new JobHistory();
 historyContext = (HistoryContext) jobHistoryService;
 stateStore = createStateStore(conf);
 this.jhsDTSecretManager = createJHSSecretManager(conf, stateStore);
 clientService = createHistoryClientService();
 aggLogDelService = new AggregatedLogDeletionService();
 addService(stateStore);
 addService(new HistoryServerSecretManagerService());
 addService(clientService);
 addService(aggLogDelService);
 super.serviceInit(config);
}

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

public static TaskType
  toYarn(org.apache.hadoop.mapreduce.TaskType taskType) {
 switch (taskType) {
 case MAP:
  return TaskType.MAP;
 case REDUCE:
  return TaskType.REDUCE;
 default:
  throw new YarnRuntimeException("Unrecognized task type: " + taskType);
 }
}

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

public static org.apache.hadoop.mapreduce.TaskType fromYarn(
  TaskType taskType) {
 switch (taskType) {
 case MAP:
  return org.apache.hadoop.mapreduce.TaskType.MAP;
 case REDUCE:
  return org.apache.hadoop.mapreduce.TaskType.REDUCE;
 default:
  throw new YarnRuntimeException("Unrecognized task type: " + taskType);
 }
}

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

@Override
public void setNextInterceptor(RESTRequestInterceptor next) {
 throw new YarnRuntimeException("setNextInterceptor is being called on "
   + "FederationInterceptorREST, which should be the last one "
   + "in the chain. Check if the interceptor pipeline configuration "
   + "is correct");
}

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

@Override
public void setNextInterceptor(RESTRequestInterceptor next) {
 throw new YarnRuntimeException("setNextInterceptor is being called on "
   + "DefaultRequestInterceptorREST, which should be the last one "
   + "in the chain. Check if the interceptor pipeline configuration "
   + "is correct");
}

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

@Override
public void setNextInterceptor(RequestInterceptor next) {
 throw new YarnRuntimeException(
   "setNextInterceptor is being called on FederationInterceptor. "
     + "It should always be used as the last interceptor in the chain");
}

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

protected RMProxy() {
 try {
  this.user = UserGroupInformation.getCurrentUser();
 } catch (IOException ioe) {
  throw new YarnRuntimeException("Unable to determine user", ioe);
 }
}

代码示例来源：origin: com.github.jiayuhan-it/hadoop-mapreduce-client-app

@Override
public void handle(CommitterEvent event) {
 try {
  eventQueue.put(event);
 } catch (InterruptedException e) {
  throw new YarnRuntimeException(e);
 }
}

代码示例来源：origin: io.hops/hadoop-mapreduce-client-app

@Override
public void handle(ContainerLauncherEvent event) {
 try {
  eventQueue.put(event);
 } catch (InterruptedException e) {
  throw new YarnRuntimeException(e);  // FIXME? YarnRuntimeException is "for runtime exceptions only"
 }
}

代码示例来源：origin: org.apache.hadoop/hadoop-mapreduce-client-app

@Override
public void handle(ContainerLauncherEvent event) {
 try {
  eventQueue.put(event);
 } catch (InterruptedException e) {
  throw new YarnRuntimeException(e);
 }
}

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

public static TaskType taskType(String symbol) {
 // JDK 7 supports switch on strings
 if (symbol.equals("m")) return TaskType.MAP;
 if (symbol.equals("r")) return TaskType.REDUCE;
 throw new YarnRuntimeException("Unknown task symbol: "+ symbol);
}

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

public static TaskType taskType(String symbol) {
 // JDK 7 supports switch on strings
 if (symbol.equals("m")) return TaskType.MAP;
 if (symbol.equals("r")) return TaskType.REDUCE;
 throw new YarnRuntimeException("Unknown task symbol: "+ symbol);
}

代码示例来源：origin: org.apache.hadoop/hadoop-mapreduce-client-app

@Override
 protected TaskSplitMetaInfo[] createSplits(JobImpl job, JobId jobId) {
  throw new YarnRuntimeException(EXCEPTIONMSG);
 }
};

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

FileContext getLocalFileContext(Configuration conf) {
 try {
  return FileContext.getLocalFSFileContext(conf);
 } catch (IOException e) {
  throw new YarnRuntimeException("Failed to access local fs");
 }
}

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

private void initializeLogDir(FileContext lfs, String logDir) {
 try {
  lfs.mkdir(new Path(logDir), null, true);
 } catch (FileAlreadyExistsException fe) {
  // do nothing
 } catch (IOException e) {
  String msg = "Could not initialize log dir " + logDir;
  LOG.warn(msg, e);
  throw new YarnRuntimeException(msg, e);
 }
}

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

FileContext getLocalFileContext(Configuration conf) {
 try {
  return FileContext.getLocalFSFileContext(conf);
 } catch (IOException e) {
  throw new YarnRuntimeException("Failed to access local fs");
 }
}

代码示例来源：origin: io.hops/hadoop-mapreduce-client-app

protected ApplicationMasterProtocol createSchedulerProxy() {
 final Configuration conf = getConfig();
 try {
  return ClientRMProxy.createRMProxy(conf, ApplicationMasterProtocol.class,true);
 } catch (IOException e) {
  throw new YarnRuntimeException(e);
 }
}

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

@Override
protected void serviceStart() throws Exception {
 try {
  ahsClient = AHSProxy.createAHSProxy(getConfig(),
    ApplicationHistoryProtocol.class, this.ahsAddress);
 } catch (IOException e) {
  throw new YarnRuntimeException(e);
 }
 super.serviceStart();
}

代码示例来源：origin: org.apache.hadoop/hadoop-mapreduce-client-app

private String setupTestWorkDir() {
 File testWorkDir = new File("target", this.getClass().getCanonicalName());
 try {
  FileContext.getLocalFSFileContext().delete(
    new Path(testWorkDir.getAbsolutePath()), true);
  return testWorkDir.getAbsolutePath();
 } catch (Exception e) {
  LOG.warn("Could not cleanup", e);
  throw new YarnRuntimeException("could not cleanup test dir", e);
 }
}

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

@Override
public void serviceStart() throws Exception {
 amRmTokenSecretManager.start();
 containerTokenSecretManager.start();
 nmTokenSecretManager.start();
 try {
  rmDTSecretManager.startThreads();
 } catch(IOException ie) {
  throw new YarnRuntimeException("Failed to start secret manager threads", ie);
 }
 super.serviceStart();
}