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

YarnQueueAclsException介绍

暂无

代码示例

代码示例来源：origin: pentaho/pentaho-hadoop-shims

/**
 * Submit job for the current configuration provided by this implementation.
 *
 * @return RunningJob implementation
 */
@Override public RunningJob submit() throws IOException, ClassNotFoundException, InterruptedException {
 JobClient jobClient = createJobClient();
 if ( YarnQueueAclsVerifier.verify( jobClient.getQueueAclsForCurrentUser() ) ) {
  return new RunningJobProxy( jobClient.submitJob( this ) );
 } else {
  throw new YarnQueueAclsException( BaseMessages.getString( ConfigurationProxy.class,
   "ConfigurationProxy.UserHasNoPermissions", UserGroupInformation.getCurrentUser().getUserName() ) );
 }
}

代码示例来源：origin: pentaho/pentaho-hadoop-shims

/**
 * Submit job for the current configuration provided by this implementation.
 *
 * @return RunningJob implementation
 */
@Override public RunningJob submit() throws IOException, ClassNotFoundException, InterruptedException {
 if ( YarnQueueAclsVerifier
  .verify( ( createClusterDescription( getJob().getConfiguration() ) ).getQueueAclsForCurrentUser() ) ) {
  getJob().submit();
  return new RunningJobProxyV2( getJob() );
 } else {
  throw new YarnQueueAclsException( BaseMessages.getString( ConfigurationProxy.class,
   "ConfigurationProxy.UserHasNoPermissions", UserGroupInformation.getCurrentUser().getUserName() ) );
 }
}