Java 类org.apache.hadoop.mapreduce.v2.api.protocolrecords.KillJobResponse 实例源码

项目：hadoop 文件：MRClientService.java

@SuppressWarnings("unchecked")
@Override
public KillJobResponse killJob(KillJobRequest request) 
  throws IOException {
  JobId jobId = request.getJobId();
  UserGroupInformation callerUGI = UserGroupInformation.getCurrentUser();
  String message = "Kill job " + jobId + " received from " + callerUGI
      + " at " + Server.getRemoteAddress();
  LOG.info(message);
  verifyAndGetJob(jobId, JobACL.MODIFY_JOB, false);
  appContext.getEventHandler().handle(
      new JobDiagnosticsUpdateEvent(jobId, message));
  appContext.getEventHandler().handle(
      new JobEvent(jobId, JobEventType.JOB_KILL));
  KillJobResponse response = 
    recordFactory.newRecordInstance(KillJobResponse.class);
  return response;
}

项目：aliyun-oss-hadoop-fs 文件：MRClientService.java

@SuppressWarnings("unchecked")
@Override
public KillJobResponse killJob(KillJobRequest request) 
  throws IOException {
  JobId jobId = request.getJobId();
  UserGroupInformation callerUGI = UserGroupInformation.getCurrentUser();
  String message = "Kill job " + jobId + " received from " + callerUGI
      + " at " + Server.getRemoteAddress();
  LOG.info(message);
  verifyAndGetJob(jobId, JobACL.MODIFY_JOB, false);
  appContext.getEventHandler().handle(
      new JobDiagnosticsUpdateEvent(jobId, message));
  appContext.getEventHandler().handle(
      new JobEvent(jobId, JobEventType.JOB_KILL));
  KillJobResponse response = 
    recordFactory.newRecordInstance(KillJobResponse.class);
  return response;
}

项目：big-c 文件：MRClientService.java

@SuppressWarnings("unchecked")
@Override
public KillJobResponse killJob(KillJobRequest request) 
  throws IOException {
  JobId jobId = request.getJobId();
  UserGroupInformation callerUGI = UserGroupInformation.getCurrentUser();
  String message = "Kill job " + jobId + " received from " + callerUGI
      + " at " + Server.getRemoteAddress();
  LOG.info(message);
  verifyAndGetJob(jobId, JobACL.MODIFY_JOB, false);
  appContext.getEventHandler().handle(
      new JobDiagnosticsUpdateEvent(jobId, message));
  appContext.getEventHandler().handle(
      new JobEvent(jobId, JobEventType.JOB_KILL));
  KillJobResponse response = 
    recordFactory.newRecordInstance(KillJobResponse.class);
  return response;
}

项目：hadoop-2.6.0-cdh5.4.3 文件：MRClientService.java

@SuppressWarnings("unchecked")
@Override
public KillJobResponse killJob(KillJobRequest request) 
  throws IOException {
  JobId jobId = request.getJobId();
  UserGroupInformation callerUGI = UserGroupInformation.getCurrentUser();
  String message = "Kill job " + jobId + " received from " + callerUGI
      + " at " + Server.getRemoteAddress();
  LOG.info(message);
  verifyAndGetJob(jobId, JobACL.MODIFY_JOB);
  appContext.getEventHandler().handle(
      new JobDiagnosticsUpdateEvent(jobId, message));
  appContext.getEventHandler().handle(
      new JobEvent(jobId, JobEventType.JOB_KILL));
  KillJobResponse response = 
    recordFactory.newRecordInstance(KillJobResponse.class);
  return response;
}

项目：hadoop-plus 文件：MRClientService.java

@SuppressWarnings("unchecked")
@Override
public KillJobResponse killJob(KillJobRequest request) 
  throws IOException {
  JobId jobId = request.getJobId();
  String message = "Kill Job received from client " + jobId;
  LOG.info(message);
 verifyAndGetJob(jobId, true);
  appContext.getEventHandler().handle(
      new JobDiagnosticsUpdateEvent(jobId, message));
  appContext.getEventHandler().handle(
      new JobEvent(jobId, JobEventType.JOB_KILL));
  KillJobResponse response = 
    recordFactory.newRecordInstance(KillJobResponse.class);
  return response;
}

项目：FlexMap 文件：MRClientService.java

@SuppressWarnings("unchecked")
@Override
public KillJobResponse killJob(KillJobRequest request) 
  throws IOException {
  JobId jobId = request.getJobId();
  UserGroupInformation callerUGI = UserGroupInformation.getCurrentUser();
  String message = "Kill job " + jobId + " received from " + callerUGI
      + " at " + Server.getRemoteAddress();
  LOG.info(message);
  verifyAndGetJob(jobId, JobACL.MODIFY_JOB);
  appContext.getEventHandler().handle(
      new JobDiagnosticsUpdateEvent(jobId, message));
  appContext.getEventHandler().handle(
      new JobEvent(jobId, JobEventType.JOB_KILL));
  KillJobResponse response = 
    recordFactory.newRecordInstance(KillJobResponse.class);
  return response;
}

项目：hops 文件：MRClientService.java

@SuppressWarnings("unchecked")
@Override
public KillJobResponse killJob(KillJobRequest request) 
  throws IOException {
  JobId jobId = request.getJobId();
  UserGroupInformation callerUGI = UserGroupInformation.getCurrentUser();
  String message = "Kill job " + jobId + " received from " + callerUGI
      + " at " + Server.getRemoteAddress();
  LOG.info(message);
  verifyAndGetJob(jobId, JobACL.MODIFY_JOB, false);
  appContext.getEventHandler().handle(
      new JobDiagnosticsUpdateEvent(jobId, message));
  appContext.getEventHandler().handle(
      new JobEvent(jobId, JobEventType.JOB_KILL));
  KillJobResponse response = 
    recordFactory.newRecordInstance(KillJobResponse.class);
  return response;
}

项目：hadoop-TCP 文件：MRClientService.java

@SuppressWarnings("unchecked")
@Override
public KillJobResponse killJob(KillJobRequest request) 
  throws IOException {
  JobId jobId = request.getJobId();
  UserGroupInformation callerUGI = UserGroupInformation.getCurrentUser();
  String message = "Kill job " + jobId + " received from " + callerUGI
      + " at " + Server.getRemoteAddress();
  LOG.info(message);
  verifyAndGetJob(jobId, JobACL.MODIFY_JOB);
  appContext.getEventHandler().handle(
      new JobDiagnosticsUpdateEvent(jobId, message));
  appContext.getEventHandler().handle(
      new JobEvent(jobId, JobEventType.JOB_KILL));
  KillJobResponse response = 
    recordFactory.newRecordInstance(KillJobResponse.class);
  return response;
}

项目：hardfs 文件：MRClientService.java

@SuppressWarnings("unchecked")
@Override
public KillJobResponse killJob(KillJobRequest request) 
  throws IOException {
  JobId jobId = request.getJobId();
  UserGroupInformation callerUGI = UserGroupInformation.getCurrentUser();
  String message = "Kill job " + jobId + " received from " + callerUGI
      + " at " + Server.getRemoteAddress();
  LOG.info(message);
  verifyAndGetJob(jobId, JobACL.MODIFY_JOB);
  appContext.getEventHandler().handle(
      new JobDiagnosticsUpdateEvent(jobId, message));
  appContext.getEventHandler().handle(
      new JobEvent(jobId, JobEventType.JOB_KILL));
  KillJobResponse response = 
    recordFactory.newRecordInstance(KillJobResponse.class);
  return response;
}

项目：hadoop-on-lustre2 文件：MRClientService.java

@SuppressWarnings("unchecked")
@Override
public KillJobResponse killJob(KillJobRequest request) 
  throws IOException {
  JobId jobId = request.getJobId();
  UserGroupInformation callerUGI = UserGroupInformation.getCurrentUser();
  String message = "Kill job " + jobId + " received from " + callerUGI
      + " at " + Server.getRemoteAddress();
  LOG.info(message);
  verifyAndGetJob(jobId, JobACL.MODIFY_JOB);
  appContext.getEventHandler().handle(
      new JobDiagnosticsUpdateEvent(jobId, message));
  appContext.getEventHandler().handle(
      new JobEvent(jobId, JobEventType.JOB_KILL));
  KillJobResponse response = 
    recordFactory.newRecordInstance(KillJobResponse.class);
  return response;
}

项目：hadoop 文件：NotRunningJob.java

@Override
public KillJobResponse killJob(KillJobRequest request)
    throws IOException {
  KillJobResponse resp =
    recordFactory.newRecordInstance(KillJobResponse.class);
  return resp;
}

项目：hadoop 文件：MRClientProtocolPBServiceImpl.java

@Override
public KillJobResponseProto killJob(RpcController controller,
    KillJobRequestProto proto) throws ServiceException {
  KillJobRequest request = new KillJobRequestPBImpl(proto);
  try {
    KillJobResponse response = real.killJob(request);
    return ((KillJobResponsePBImpl)response).getProto();
  } catch (IOException e) {
    throw new ServiceException(e);
  }
}

项目：hadoop 文件：MRClientProtocolPBClientImpl.java

@Override
public KillJobResponse killJob(KillJobRequest request)
    throws IOException {
  KillJobRequestProto requestProto = ((KillJobRequestPBImpl)request).getProto();
  try {
    return new KillJobResponsePBImpl(proxy.killJob(null, requestProto));
  } catch (ServiceException e) {
    throw unwrapAndThrowException(e);
  }
}

项目：aliyun-oss-hadoop-fs 文件：NotRunningJob.java

@Override
public KillJobResponse killJob(KillJobRequest request)
    throws IOException {
  KillJobResponse resp =
    recordFactory.newRecordInstance(KillJobResponse.class);
  return resp;
}

项目：aliyun-oss-hadoop-fs 文件：MRClientProtocolPBServiceImpl.java

@Override
public KillJobResponseProto killJob(RpcController controller,
    KillJobRequestProto proto) throws ServiceException {
  KillJobRequest request = new KillJobRequestPBImpl(proto);
  try {
    KillJobResponse response = real.killJob(request);
    return ((KillJobResponsePBImpl)response).getProto();
  } catch (IOException e) {
    throw new ServiceException(e);
  }
}

项目：aliyun-oss-hadoop-fs 文件：MRClientProtocolPBClientImpl.java

@Override
public KillJobResponse killJob(KillJobRequest request)
    throws IOException {
  KillJobRequestProto requestProto = ((KillJobRequestPBImpl)request).getProto();
  try {
    return new KillJobResponsePBImpl(proxy.killJob(null, requestProto));
  } catch (ServiceException e) {
    throw unwrapAndThrowException(e);
  }
}

项目：big-c 文件：NotRunningJob.java

@Override
public KillJobResponse killJob(KillJobRequest request)
    throws IOException {
  KillJobResponse resp =
    recordFactory.newRecordInstance(KillJobResponse.class);
  return resp;
}

项目：big-c 文件：MRClientProtocolPBServiceImpl.java

@Override
public KillJobResponseProto killJob(RpcController controller,
    KillJobRequestProto proto) throws ServiceException {
  KillJobRequest request = new KillJobRequestPBImpl(proto);
  try {
    KillJobResponse response = real.killJob(request);
    return ((KillJobResponsePBImpl)response).getProto();
  } catch (IOException e) {
    throw new ServiceException(e);
  }
}

项目：big-c 文件：MRClientProtocolPBClientImpl.java

@Override
public KillJobResponse killJob(KillJobRequest request)
    throws IOException {
  KillJobRequestProto requestProto = ((KillJobRequestPBImpl)request).getProto();
  try {
    return new KillJobResponsePBImpl(proxy.killJob(null, requestProto));
  } catch (ServiceException e) {
    throw unwrapAndThrowException(e);
  }
}

项目：hadoop-2.6.0-cdh5.4.3 文件：NotRunningJob.java

@Override
public KillJobResponse killJob(KillJobRequest request)
    throws IOException {
  KillJobResponse resp =
    recordFactory.newRecordInstance(KillJobResponse.class);
  return resp;
}

项目：hadoop-2.6.0-cdh5.4.3 文件：MRClientProtocolPBServiceImpl.java

@Override
public KillJobResponseProto killJob(RpcController controller,
    KillJobRequestProto proto) throws ServiceException {
  KillJobRequest request = new KillJobRequestPBImpl(proto);
  try {
    KillJobResponse response = real.killJob(request);
    return ((KillJobResponsePBImpl)response).getProto();
  } catch (IOException e) {
    throw new ServiceException(e);
  }
}

项目：hadoop-2.6.0-cdh5.4.3 文件：MRClientProtocolPBClientImpl.java

@Override
public KillJobResponse killJob(KillJobRequest request)
    throws IOException {
  KillJobRequestProto requestProto = ((KillJobRequestPBImpl)request).getProto();
  try {
    return new KillJobResponsePBImpl(proxy.killJob(null, requestProto));
  } catch (ServiceException e) {
    throw unwrapAndThrowException(e);
  }
}

项目：hadoop-plus 文件：NotRunningJob.java

@Override
public KillJobResponse killJob(KillJobRequest request)
    throws IOException {
  KillJobResponse resp =
    recordFactory.newRecordInstance(KillJobResponse.class);
  return resp;
}

项目：hadoop-plus 文件：MRClientProtocolPBServiceImpl.java

@Override
public KillJobResponseProto killJob(RpcController controller,
    KillJobRequestProto proto) throws ServiceException {
  KillJobRequest request = new KillJobRequestPBImpl(proto);
  try {
    KillJobResponse response = real.killJob(request);
    return ((KillJobResponsePBImpl)response).getProto();
  } catch (IOException e) {
    throw new ServiceException(e);
  }
}

项目：hadoop-plus 文件：MRClientProtocolPBClientImpl.java

@Override
public KillJobResponse killJob(KillJobRequest request)
    throws IOException {
  KillJobRequestProto requestProto = ((KillJobRequestPBImpl)request).getProto();
  try {
    return new KillJobResponsePBImpl(proxy.killJob(null, requestProto));
  } catch (ServiceException e) {
    throw unwrapAndThrowException(e);
  }
}

项目：FlexMap 文件：NotRunningJob.java

@Override
public KillJobResponse killJob(KillJobRequest request)
    throws IOException {
  KillJobResponse resp =
    recordFactory.newRecordInstance(KillJobResponse.class);
  return resp;
}

项目：FlexMap 文件：MRClientProtocolPBServiceImpl.java

@Override
public KillJobResponseProto killJob(RpcController controller,
    KillJobRequestProto proto) throws ServiceException {
  KillJobRequest request = new KillJobRequestPBImpl(proto);
  try {
    KillJobResponse response = real.killJob(request);
    return ((KillJobResponsePBImpl)response).getProto();
  } catch (IOException e) {
    throw new ServiceException(e);
  }
}

项目：FlexMap 文件：MRClientProtocolPBClientImpl.java

@Override
public KillJobResponse killJob(KillJobRequest request)
    throws IOException {
  KillJobRequestProto requestProto = ((KillJobRequestPBImpl)request).getProto();
  try {
    return new KillJobResponsePBImpl(proxy.killJob(null, requestProto));
  } catch (ServiceException e) {
    throw unwrapAndThrowException(e);
  }
}

项目：hops 文件：NotRunningJob.java

@Override
public KillJobResponse killJob(KillJobRequest request)
    throws IOException {
  KillJobResponse resp =
    recordFactory.newRecordInstance(KillJobResponse.class);
  return resp;
}

项目：hops 文件：MRClientProtocolPBServiceImpl.java

@Override
public KillJobResponseProto killJob(RpcController controller,
    KillJobRequestProto proto) throws ServiceException {
  KillJobRequest request = new KillJobRequestPBImpl(proto);
  try {
    KillJobResponse response = real.killJob(request);
    return ((KillJobResponsePBImpl)response).getProto();
  } catch (IOException e) {
    throw new ServiceException(e);
  }
}

项目：hops 文件：MRClientProtocolPBClientImpl.java

@Override
public KillJobResponse killJob(KillJobRequest request)
    throws IOException {
  KillJobRequestProto requestProto = ((KillJobRequestPBImpl)request).getProto();
  try {
    return new KillJobResponsePBImpl(proxy.killJob(null, requestProto));
  } catch (ServiceException e) {
    throw unwrapAndThrowException(e);
  }
}

项目：jumbune 文件：MRCommunicator.java

/**
 * Kill the job, given the jobId
 * @param jobId
 * @return
 * @throws IOException
 */
public boolean killJob(JobId jobId) throws IOException{
    KillJobRequestProto proto = KillJobRequestProto.getDefaultInstance();
    KillJobRequest request = new KillJobRequestPBImpl(proto);
    request.setJobId(jobId);
    KillJobResponse killJobResponse = proxy.killJob(request);
    if(killJobResponse!=null){
        return true;
    }
    return false;
}

项目：hadoop-TCP 文件：NotRunningJob.java

@Override
public KillJobResponse killJob(KillJobRequest request)
    throws IOException {
  KillJobResponse resp =
    recordFactory.newRecordInstance(KillJobResponse.class);
  return resp;
}

项目：hadoop-TCP 文件：MRClientProtocolPBServiceImpl.java

@Override
public KillJobResponseProto killJob(RpcController controller,
    KillJobRequestProto proto) throws ServiceException {
  KillJobRequest request = new KillJobRequestPBImpl(proto);
  try {
    KillJobResponse response = real.killJob(request);
    return ((KillJobResponsePBImpl)response).getProto();
  } catch (IOException e) {
    throw new ServiceException(e);
  }
}

项目：hadoop-TCP 文件：MRClientProtocolPBClientImpl.java

@Override
public KillJobResponse killJob(KillJobRequest request)
    throws IOException {
  KillJobRequestProto requestProto = ((KillJobRequestPBImpl)request).getProto();
  try {
    return new KillJobResponsePBImpl(proxy.killJob(null, requestProto));
  } catch (ServiceException e) {
    throw unwrapAndThrowException(e);
  }
}

项目：hardfs 文件：NotRunningJob.java

@Override
public KillJobResponse killJob(KillJobRequest request)
    throws IOException {
  KillJobResponse resp =
    recordFactory.newRecordInstance(KillJobResponse.class);
  return resp;
}

项目：hardfs 文件：MRClientProtocolPBServiceImpl.java

@Override
public KillJobResponseProto killJob(RpcController controller,
    KillJobRequestProto proto) throws ServiceException {
  KillJobRequest request = new KillJobRequestPBImpl(proto);
  try {
    KillJobResponse response = real.killJob(request);
    return ((KillJobResponsePBImpl)response).getProto();
  } catch (IOException e) {
    throw new ServiceException(e);
  }
}

项目：hardfs 文件：MRClientProtocolPBClientImpl.java

@Override
public KillJobResponse killJob(KillJobRequest request)
    throws IOException {
  KillJobRequestProto requestProto = ((KillJobRequestPBImpl)request).getProto();
  try {
    return new KillJobResponsePBImpl(proxy.killJob(null, requestProto));
  } catch (ServiceException e) {
    throw unwrapAndThrowException(e);
  }
}

项目：hadoop-on-lustre2 文件：NotRunningJob.java

@Override
public KillJobResponse killJob(KillJobRequest request)
    throws IOException {
  KillJobResponse resp =
    recordFactory.newRecordInstance(KillJobResponse.class);
  return resp;
}

项目：hadoop-on-lustre2 文件：MRClientProtocolPBServiceImpl.java

@Override
public KillJobResponseProto killJob(RpcController controller,
    KillJobRequestProto proto) throws ServiceException {
  KillJobRequest request = new KillJobRequestPBImpl(proto);
  try {
    KillJobResponse response = real.killJob(request);
    return ((KillJobResponsePBImpl)response).getProto();
  } catch (IOException e) {
    throw new ServiceException(e);
  }
}