@Test public void cancelNonExistingJob() { try { mJobMaster.cancel(1); Assert.fail("cannot cancel non-existing job"); } catch (JobDoesNotExistException e) { Assert.assertEquals(ExceptionMessage.JOB_DOES_NOT_EXIST.getMessage(1), e.getMessage()); } }
public void cancel(long jobId) throws JobDoesNotExistException { PlanCoordinator planCoordinator = mPlanTracker.getCoordinator(jobId); if (planCoordinator == null) { if (!mWorkflowTracker.cancel(jobId)) { throw new JobDoesNotExistException(ExceptionMessage.JOB_DOES_NOT_EXIST.getMessage(jobId)); } return; } planCoordinator.cancel(); }
JobMaster extends AbstractMaster implements NoopJournaled { public void cancel(long jobId) throws JobDoesNotExistException { PlanCoordinator planCoordinator = mPlanTracker.getCoordinator(jobId); if (planCoordinator == null) { if (!mWorkflowTracker.cancel(jobId)) { throw new JobDoesNotExistException(ExceptionMessage.JOB_DOES_NOT_EXIST.getMessage(jobId)); } return; } planCoordinator.cancel(); } }
JobMaster extends AbstractMaster implements NoopJournaled { public void cancel(long jobId) throws JobDoesNotExistException { PlanCoordinator planCoordinator = mPlanTracker.getCoordinator(jobId); if (planCoordinator == null) { if (!mWorkflowTracker.cancel(jobId)) { throw new JobDoesNotExistException(ExceptionMessage.JOB_DOES_NOT_EXIST.getMessage(jobId)); } return; } planCoordinator.cancel(); } JobMaster(MasterContext masterContext, FileSystem filesystem,
      FileSystemContext fsContext, UfsManager ufsManager); }
JobMaster extends AbstractMaster implements NoopJournaled { public void cancel(long jobId) throws JobDoesNotExistException { PlanCoordinator planCoordinator = mPlanTracker.getCoordinator(jobId); if (planCoordinator == null) { if (!mWorkflowTracker.cancel(jobId)) { throw new JobDoesNotExistException(ExceptionMessage.JOB_DOES_NOT_EXIST.getMessage(jobId)); } return; } planCoordinator.cancel(); } JobMaster(MasterContext masterContext, FileSystem filesystem,
      FileSystemContext fsContext, UfsManager ufsManager); long getNewJobId(); @Override void start(Boolean isLeader); @Override Map<ServiceType, GrpcService> getServices(); @Override String getName(); synchronized long run(JobConfig jobConfig); synchronized void run(JobConfig jobConfig, long jobId); void cancel(long jobId); List<Long> list(); List<JobInfo> listDetailed(); List<JobInfo> failed(int limit, long before, long after); JobInfo getStatus(long jobId); JobInfo getStatus(long jobId, boolean verbose); alluxio.job.wire.JobServiceSummary getSummary(); List<JobWorkerHealth> getAllWorkerHealth(); long registerWorker(WorkerNetAddress workerNetAddress); List<WorkerInfo> getWorkerInfoList(); void setTaskPoolSize(int taskPoolSize); List<JobCommand> workerHeartbeat(JobWorkerHealth jobWorkerHealth,
      List<TaskInfo> taskInfoList); }
JobMaster extends AbstractMaster implements NoopJournaled { public void cancel(long jobId) throws JobDoesNotExistException { PlanCoordinator planCoordinator = mPlanTracker.getCoordinator(jobId); if (planCoordinator == null) { if (!mWorkflowTracker.cancel(jobId)) { throw new JobDoesNotExistException(ExceptionMessage.JOB_DOES_NOT_EXIST.getMessage(jobId)); } return; } planCoordinator.cancel(); } JobMaster(MasterContext masterContext, FileSystem filesystem,
      FileSystemContext fsContext, UfsManager ufsManager); long getNewJobId(); @Override void start(Boolean isLeader); @Override Map<ServiceType, GrpcService> getServices(); @Override String getName(); synchronized long run(JobConfig jobConfig); synchronized void run(JobConfig jobConfig, long jobId); void cancel(long jobId); List<Long> list(); List<JobInfo> listDetailed(); List<JobInfo> failed(int limit, long before, long after); JobInfo getStatus(long jobId); JobInfo getStatus(long jobId, boolean verbose); alluxio.job.wire.JobServiceSummary getSummary(); List<JobWorkerHealth> getAllWorkerHealth(); long registerWorker(WorkerNetAddress workerNetAddress); List<WorkerInfo> getWorkerInfoList(); void setTaskPoolSize(int taskPoolSize); List<JobCommand> workerHeartbeat(JobWorkerHealth jobWorkerHealth,
      List<TaskInfo> taskInfoList);  }