Details
-
Sub-task
-
Status: Closed
-
Major
-
Resolution: Fixed
-
None
-
None
-
None
Description
Original test case was:
public void testWfActionKillChildJob() throws Exception { String externalJobID = launchSleepJob(1000); String childId = launchSleepJob(1000000); WorkflowJobBean job = this.addRecordToWfJobTable(WorkflowJob.Status.KILLED, WorkflowInstance.Status.KILLED); WorkflowActionBean action = this.addRecordToWfActionTable(job.getId(), externalJobID, "1", WorkflowAction.Status.KILLED, childId); new ActionKillXCommand(action.getId()).call(); JobClient jobClient = createJobClient(); final RunningJob mrJob = jobClient.getJob(JobID.forName(childId)); waitFor(60 * 1000, new Predicate() { public boolean evaluate() throws Exception { return mrJob.isComplete(); } }); assertEquals(mrJob.getJobState(), JobStatus.KILLED); }
It was removed by OOZIE-1770's commit