@SuppressWarnings("unchecked") @Override public KillTaskResponse killTask(KillTaskRequest request) throws IOException { TaskId taskId = request.getTaskId(); UserGroupInformation callerUGI = UserGroupInformation.getCurrentUser(); String message = "Kill task " + taskId + " received from " + callerUGI + " at " + Server.getRemoteAddress(); LOG.info(message); verifyAndGetTask(taskId, JobACL.MODIFY_JOB); appContext.getEventHandler().handle( new TaskEvent(taskId, TaskEventType.T_KILL)); KillTaskResponse response = recordFactory.newRecordInstance(KillTaskResponse.class); return response; }
@Override public KillTaskResponse killTask(KillTaskRequest request) throws IOException { KillTaskResponse resp = recordFactory.newRecordInstance(KillTaskResponse.class); return resp; }
@Override public KillTaskResponseProto killTask(RpcController controller, KillTaskRequestProto proto) throws ServiceException { KillTaskRequest request = new KillTaskRequestPBImpl(proto); try { KillTaskResponse response = real.killTask(request); return ((KillTaskResponsePBImpl)response).getProto(); } catch (IOException e) { throw new ServiceException(e); } }
@Override public KillTaskResponse killTask(KillTaskRequest request) throws IOException { KillTaskRequestProto requestProto = ((KillTaskRequestPBImpl)request).getProto(); try { return new KillTaskResponsePBImpl(proxy.killTask(null, requestProto)); } catch (ServiceException e) { throw unwrapAndThrowException(e); } }
@SuppressWarnings("unchecked") @Override public KillTaskResponse killTask(KillTaskRequest request) throws IOException { TaskId taskId = request.getTaskId(); String message = "Kill task received from client " + taskId; LOG.info(message); verifyAndGetTask(taskId, true); appContext.getEventHandler().handle( new TaskEvent(taskId, TaskEventType.T_KILL)); KillTaskResponse response = recordFactory.newRecordInstance(KillTaskResponse.class); return response; }