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

Satish Subhashrao Saley updated OOZIE-2661:
-------------------------------------------
    Attachment: OOZIE-2661-4.patch

Updated the patch with all the changes. 

> Coordinator Action status not updated when workflow job SUSPENDED
> -----------------------------------------------------------------
>
>                 Key: OOZIE-2661
>                 URL: https://issues.apache.org/jira/browse/OOZIE-2661
>             Project: Oozie
>          Issue Type: Bug
>            Reporter: Satish Subhashrao Saley
>            Assignee: Satish Subhashrao Saley
>         Attachments: OOZIE-2661-1.patch, OOZIE-2661-2.patch, 
> OOZIE-2661-3.patch, OOZIE-2661-4.patch
>
>
> It's a bug in Oozie. CoordActionCheckXCommand doesn't take care of SUSPENDED 
> state. It only handles SUCCEEDED, FAILED and KILLED.
> {code}
> protected Void execute() throws CommandException {
>         try {
>             InstrumentUtils.incrJobCounter(getName(), 1, 
> getInstrumentation());
>             Status slaStatus = null;
>             CoordinatorAction.Status initialStatus = coordAction.getStatus();
>             if (workflowJob.getStatus() == WorkflowJob.Status.SUCCEEDED) {
>                 coordAction.setStatus(CoordinatorAction.Status.SUCCEEDED);
>                 // set pending to false as the status is SUCCEEDED
>                 coordAction.setPending(0);
>                 slaStatus = Status.SUCCEEDED;
>             }
>             else {
>                 if (workflowJob.getStatus() == WorkflowJob.Status.FAILED) {
>                     coordAction.setStatus(CoordinatorAction.Status.FAILED);
>                     slaStatus = Status.FAILED;
>                     // set pending to false as the status is FAILED
>                     coordAction.setPending(0);
>                 }
>                 else {
>                     if (workflowJob.getStatus() == WorkflowJob.Status.KILLED) 
> {
>                         
> coordAction.setStatus(CoordinatorAction.Status.KILLED);
>                         slaStatus = Status.KILLED;
>                         // set pending to false as the status is KILLED
>                         coordAction.setPending(0);
>                     }
>                     else {
>                         LOG.warn("Unexpected workflow " + workflowJob.getId() 
> + " STATUS " + workflowJob.getStatus());
>                         coordAction.setLastModifiedTime(new Date());
>                         CoordActionQueryExecutor.getInstance().executeUpdate(
>                                 
> CoordActionQueryExecutor.CoordActionQuery.UPDATE_COORD_ACTION_FOR_MODIFIED_DATE,
>                                 coordAction);
>                         return null;
>                     }
>                 }
>             }
> {code}
> Thank you [~puru] for pointing it out.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Reply via email to