/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-jobclient/src/test/java/org/apache/hadoop/mapreduce/lib/jobcontrol/ |
H A D | TestMapReduceJobControlWithMocks.java | 55 assertTrue(job1.getJobState() == ControlledJob.State.SUCCESS); in testSuccessfulJobs() 56 assertTrue(job2.getJobState() == ControlledJob.State.SUCCESS); in testSuccessfulJobs() 57 assertTrue(job3.getJobState() == ControlledJob.State.SUCCESS); in testSuccessfulJobs() 58 assertTrue(job4.getJobState() == ControlledJob.State.SUCCESS); in testSuccessfulJobs() 77 assertTrue(job1.getJobState() == ControlledJob.State.FAILED); in testFailedJob() 78 assertTrue(job2.getJobState() == ControlledJob.State.SUCCESS); in testFailedJob() 79 assertTrue(job3.getJobState() == ControlledJob.State.DEPENDENT_FAILED); in testFailedJob() 80 assertTrue(job4.getJobState() == ControlledJob.State.DEPENDENT_FAILED); in testFailedJob() 102 assertTrue(job1.getJobState() == ControlledJob.State.FAILED); in testErrorWhileSubmitting()
|
H A D | TestMapReduceJobControl.java | 139 assertTrue(cjob1.getJobState() == ControlledJob.State.FAILED); in testJobControlWithFailJob() 140 assertTrue(cjob2.getJobState() == ControlledJob.State.SUCCESS); in testJobControlWithFailJob() 141 assertTrue(cjob3.getJobState() == ControlledJob.State.DEPENDENT_FAILED); in testJobControlWithFailJob() 142 assertTrue(cjob4.getJobState() == ControlledJob.State.DEPENDENT_FAILED); in testJobControlWithFailJob() 155 while (cjob1.getJobState() != ControlledJob.State.RUNNING) { in testJobControlWithKillJob() 177 assertTrue(cjob1.getJobState() == ControlledJob.State.FAILED); in testJobControlWithKillJob() 178 assertTrue(cjob2.getJobState() == ControlledJob.State.SUCCESS); in testJobControlWithKillJob() 179 assertTrue(cjob3.getJobState() == ControlledJob.State.DEPENDENT_FAILED); in testJobControlWithKillJob() 180 assertTrue(cjob4.getJobState() == ControlledJob.State.DEPENDENT_FAILED); in testJobControlWithKillJob() 212 while (cjob1.getJobState() != ControlledJob.State.RUNNING) { in testControlledJob()
|
/dports/devel/hadoop/hadoop-1.2.1/src/test/org/apache/hadoop/mapreduce/lib/jobcontrol/ |
H A D | TestMapReduceJobControlWithMocks.java | 54 assertTrue(job1.getJobState() == ControlledJob.State.SUCCESS); in testSuccessfulJobs() 55 assertTrue(job2.getJobState() == ControlledJob.State.SUCCESS); in testSuccessfulJobs() 56 assertTrue(job3.getJobState() == ControlledJob.State.SUCCESS); in testSuccessfulJobs() 57 assertTrue(job4.getJobState() == ControlledJob.State.SUCCESS); in testSuccessfulJobs() 76 assertTrue(job1.getJobState() == ControlledJob.State.FAILED); in testFailedJob() 77 assertTrue(job2.getJobState() == ControlledJob.State.SUCCESS); in testFailedJob() 78 assertTrue(job3.getJobState() == ControlledJob.State.DEPENDENT_FAILED); in testFailedJob() 79 assertTrue(job4.getJobState() == ControlledJob.State.DEPENDENT_FAILED); in testFailedJob()
|
/dports/devel/hadoop/hadoop-1.2.1/src/test/org/apache/hadoop/mapred/ |
H A D | TestJobInProgressListener.java | 195 while (rJob2.getJobState() != JobStatus.SUCCEEDED) { in testJobQueueChanges() 199 while (rJob1.getJobState() != JobStatus.SUCCEEDED) { in testJobQueueChanges() 330 while (rJob.getJobState() != JobStatus.RUNNING) { in testJobSuccess() 340 while (rJob.getJobState() != JobStatus.SUCCEEDED) { in testJobSuccess() 398 JobStatus.KILLED, rJob.getJobState()); in testQueuedJobKill()
|
H A D | TestJobKillAndFail.java | 54 assertEquals(job.getJobState(), JobStatus.FAILED); in testJobFailAndKill() 63 assertEquals(job.getJobState(), JobStatus.KILLED); in testJobFailAndKill()
|
H A D | TestTrackerBlacklistAcrossJobs.java | 95 assertEquals("Job failed", JobStatus.SUCCEEDED, running.getJobState()); in testBlacklistAcrossJobs() 107 assertEquals("Job failed", JobStatus.SUCCEEDED, running.getJobState()); in testBlacklistAcrossJobs()
|
H A D | TestKillSubProcesses.java | 99 assertEquals(job.getJobState(), JobStatus.KILLED); in runKillingJobAndValidate() 119 assertEquals(job.getJobState(), JobStatus.FAILED); in runFailingJobAndValidate() 136 assertEquals(job.getJobState(), JobStatus.SUCCEEDED); in runSuccessfulJobAndValidate() 146 while (job.getJobState() != JobStatus.RUNNING) { in runJobAndSetProcessHandle()
|
H A D | TestSetupAndCleanupFailure.java | 147 assertEquals(JobStatus.FAILED, job.getJobState()); in testFailCommitter() 219 assertEquals(JobStatus.SUCCEEDED, job.getJobState()); in testSetupAndCleanupKill()
|
H A D | TestJobQueueInformation.java | 126 while (rJob.getJobState() != JobStatus.RUNNING) { in testJobQueues()
|
H A D | TestJvmReuse.java | 122 assertEquals(JobStatus.SUCCEEDED, job.getJobState()); in validateJob()
|
H A D | TestLostTracker.java | 92 assertEquals(JobStatus.SUCCEEDED, rJob.getJobState()); in testLostTracker()
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-jobclient/src/test/java/org/apache/hadoop/mapreduce/v2/ |
H A D | TestSpeculativeExecution.java | 211 Assert.assertEquals(JobStatus.State.SUCCEEDED, job.getJobState()); in testSpeculativeExecution() 229 Assert.assertEquals(JobStatus.State.SUCCEEDED, job.getJobState()); in testSpeculativeExecution() 251 Assert.assertEquals(JobStatus.State.SUCCEEDED, job.getJobState()); in testSpeculativeExecution()
|
H A D | TestMRAMWithNonNormalizedCapabilities.java | 106 JobStatus.State.SUCCEEDED, job.getJobState()); in testJobWithNonNormalizedCapabilities()
|
H A D | TestUberAM.java | 138 Assert.assertEquals(JobStatus.State.FAILED, job.getJobState()); in testFailingMapper()
|
H A D | TestMRJobs.java | 229 Assert.assertEquals(JobStatus.State.SUCCEEDED, job.getJobState()); in testSleepJobInternal() 405 Assert.assertEquals(JobStatus.State.SUCCEEDED, job.getJobState()); in testRandomWriter() 472 Assert.assertEquals(JobStatus.State.FAILED, job.getJobState()); in testFailingMapper() 565 Assert.assertEquals(JobStatus.State.SUCCEEDED, job.getJobState()); in testSleepJobWithSecurityOn()
|
/dports/devel/hadoop/hadoop-1.2.1/src/mapred/org/apache/hadoop/mapred/ |
H A D | RunningJob.java | 134 public int getJobState() throws IOException; in getJobState() method
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/records/ |
H A D | JobReport.java | 25 public abstract JobState getJobState(); in getJobState() method
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapred/ |
H A D | RunningJob.java | 149 public int getJobState() throws IOException; in getJobState() method
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/records/impl/pb/ |
H A D | JobReportPBImpl.java | 111 public synchronized JobState getJobState() { in getJobState() method in JobReportPBImpl 116 return convertFromProtoFormat(p.getJobState()); in getJobState()
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-jobclient/src/test/java/org/apache/hadoop/mapred/ |
H A D | TestJobCleanup.java | 198 assertEquals("Job did not fail", JobStatus.FAILED, job.getJobState()); in testFailedJob() 244 assertEquals("Job was not killed", JobStatus.KILLED, job.getJobState()); in testKilledJob()
|
H A D | TestMiniMRWithDFSWithDistinctUsers.java | 73 Assert.assertEquals("SUCCEEDED", JobStatus.getJobRunState(rj.getJobState())); in runJobAsUser()
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapred/jobcontrol/ |
H A D | Job.java | 106 State state = super.getJobState(); in getState()
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/main/java/org/apache/hadoop/mapreduce/v2/app/ |
H A D | JobEndNotifier.java | 164 userUrl = userUrl.replace(JOB_STATUS, jobReport.getJobState().toString()); in notify()
|
/dports/devel/hadoop/hadoop-1.2.1/src/mapred/org/apache/hadoop/mapreduce/lib/jobcontrol/ |
H A D | JobControl.java | 93 if(j.getJobState() == state) { in getJobsIn()
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/lib/jobcontrol/ |
H A D | JobControl.java | 92 if(j.getJobState() == state) { in getJobsIn()
|