@Test public void runNonExistingJobConfig() throws Exception { try { mJobMaster.run(new DummyPlanConfig()); Assert.fail("cannot run non-existing job"); } catch (JobDoesNotExistException e) { Assert.assertEquals(ExceptionMessage.JOB_DEFINITION_DOES_NOT_EXIST.getMessage("dummy"), e.getMessage()); } }
public synchronized long run(JobConfig jobConfig) throws JobDoesNotExistException, ResourceExhaustedException { long jobId = getNewJobId(); run(jobConfig, jobId); return jobId; }
JobMaster extends AbstractMaster implements NoopJournaled { public synchronized long run(JobConfig jobConfig) throws JobDoesNotExistException, ResourceExhaustedException { long jobId = getNewJobId(); run(jobConfig, jobId); return jobId; } }
JobMaster extends AbstractMaster implements NoopJournaled { public synchronized long run(JobConfig jobConfig) throws JobDoesNotExistException, ResourceExhaustedException { long jobId = getNewJobId(); run(jobConfig, jobId); return jobId; } JobMaster(MasterContext masterContext, FileSystem filesystem,
      FileSystemContext fsContext, UfsManager ufsManager); }
JobMaster extends AbstractMaster implements NoopJournaled { public synchronized long run(JobConfig jobConfig) throws JobDoesNotExistException, ResourceExhaustedException { long jobId = getNewJobId(); run(jobConfig, jobId); return jobId; } 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 synchronized long run(JobConfig jobConfig) throws JobDoesNotExistException, ResourceExhaustedException { long jobId = getNewJobId(); run(jobConfig, jobId); return jobId; } 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);  }