[ 
https://issues.apache.org/jira/browse/OOZIE-2911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Peter Cseh updated OOZIE-2911:
------------------------------
    Description: 
Original test case was:
{code}
 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);
    }
{code}

> Re-add test testWfActionKillChildJob and adapt it to OYA
> --------------------------------------------------------
>
>                 Key: OOZIE-2911
>                 URL: https://issues.apache.org/jira/browse/OOZIE-2911
>             Project: Oozie
>          Issue Type: Sub-task
>            Reporter: Peter Bacsko
>            Assignee: Peter Cseh
>         Attachments: OOZIE-2911-001.patch
>
>
> Original test case was:
> {code}
>  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);
>     }
> {code}



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)

Reply via email to