You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@oozie.apache.org by "Purshotam Shah (JIRA)" <ji...@apache.org> on 2014/06/20 00:46:26 UTC

[jira] [Updated] (OOZIE-1893) Recovery service will never recover bundle action if CoordSubmitXCommand command is lost

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

Purshotam Shah updated OOZIE-1893:
----------------------------------

    Description: 
If bundle action is in prep and coord submit command is lost, bundle action will never recover bcz of below condition.

baction.getCoordId() is null in that case and isJobIdForThisServer(baction.getCoordId()) will throw NPE.

{code}
RecoveryService.runBundleRecovery()

if (baction.getCoordId() == null && baction.getStatus() != Job.Status.PREP) {
	log.error("CoordId is null for Bundle action " + baction.getBundleActionId());
	continue;
}
if (Services.get().get(JobsConcurrencyService.class).isJobIdForThisServer(baction.getCoordId())) {
}
{code}


> Recovery service will never recover bundle action if CoordSubmitXCommand command is lost
> ----------------------------------------------------------------------------------------
>
>                 Key: OOZIE-1893
>                 URL: https://issues.apache.org/jira/browse/OOZIE-1893
>             Project: Oozie
>          Issue Type: Bug
>            Reporter: Purshotam Shah
>
> If bundle action is in prep and coord submit command is lost, bundle action will never recover bcz of below condition.
> baction.getCoordId() is null in that case and isJobIdForThisServer(baction.getCoordId()) will throw NPE.
> {code}
> RecoveryService.runBundleRecovery()
> if (baction.getCoordId() == null && baction.getStatus() != Job.Status.PREP) {
> 	log.error("CoordId is null for Bundle action " + baction.getBundleActionId());
> 	continue;
> }
> if (Services.get().get(JobsConcurrencyService.class).isJobIdForThisServer(baction.getCoordId())) {
> }
> {code}



--
This message was sent by Atlassian JIRA
(v6.2#6252)