@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; }
@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; }
@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; }
@Override public KillJobResponse killJob(KillJobRequest request) throws IOException { KillJobResponse resp = recordFactory.newRecordInstance(KillJobResponse.class); return resp; }
@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); } }
@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); } }
/** * 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; }