Home
last modified time | relevance | path

Searched refs:getJobState (Results 1 – 25 of 56) sorted by relevance

123

/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 DTestMapReduceJobControlWithMocks.java55 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 DTestMapReduceJobControl.java139 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 DTestMapReduceJobControlWithMocks.java54 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 DTestJobInProgressListener.java195 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 DTestJobKillAndFail.java54 assertEquals(job.getJobState(), JobStatus.FAILED); in testJobFailAndKill()
63 assertEquals(job.getJobState(), JobStatus.KILLED); in testJobFailAndKill()
H A DTestTrackerBlacklistAcrossJobs.java95 assertEquals("Job failed", JobStatus.SUCCEEDED, running.getJobState()); in testBlacklistAcrossJobs()
107 assertEquals("Job failed", JobStatus.SUCCEEDED, running.getJobState()); in testBlacklistAcrossJobs()
H A DTestKillSubProcesses.java99 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 DTestSetupAndCleanupFailure.java147 assertEquals(JobStatus.FAILED, job.getJobState()); in testFailCommitter()
219 assertEquals(JobStatus.SUCCEEDED, job.getJobState()); in testSetupAndCleanupKill()
H A DTestJobQueueInformation.java126 while (rJob.getJobState() != JobStatus.RUNNING) { in testJobQueues()
H A DTestJvmReuse.java122 assertEquals(JobStatus.SUCCEEDED, job.getJobState()); in validateJob()
H A DTestLostTracker.java92 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 DTestSpeculativeExecution.java211 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 DTestMRAMWithNonNormalizedCapabilities.java106 JobStatus.State.SUCCEEDED, job.getJobState()); in testJobWithNonNormalizedCapabilities()
H A DTestUberAM.java138 Assert.assertEquals(JobStatus.State.FAILED, job.getJobState()); in testFailingMapper()
H A DTestMRJobs.java229 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 DRunningJob.java134 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 DJobReport.java25 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 DRunningJob.java149 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 DJobReportPBImpl.java111 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 DTestJobCleanup.java198 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 DTestMiniMRWithDFSWithDistinctUsers.java73 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 DJob.java106 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 DJobEndNotifier.java164 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 DJobControl.java93 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 DJobControl.java92 if(j.getJobState() == state) { in getJobsIn()

123