[jira] [Updated] (OOZIE-2227) PartitionDependencyManagerService keeps on purging delete coord actions

[Purshotam Shah (JIRA)]

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

Purshotam Shah updated OOZIE-2227:
----------------------------------
    Description: 
Because of that PartitionDependencyManagerService takes more than 10 min to 
complete.

{code}
Long regTime = registeredCoordActionMap.get(actionId);
                if(regTime < (currentTime - timeToLive * 1000)){
                    CoordinatorActionBean caBean = null;
                    try {
                        caBean = 
CoordActionQueryExecutor.getInstance().get(CoordActionQuery.GET_COORD_ACTION_STATUS,
 actionId);
                    }
                    catch (JPAExecutorException e) {
                        LOG.warn("Error in checking coord action:" + actionId + 
"to purge, skipping", e);
                    }
                    if(caBean != null && 
!caBean.getStatus().equals(CoordinatorAction.Status.WAITING)){
                        staleActions.add(actionId);
                        actionItr.remove();
                    }

{code}

Should remove actionId if JPAExecutorException = no row found

> PartitionDependencyManagerService keeps on purging delete coord actions
> -----------------------------------------------------------------------
>
>                 Key: OOZIE-2227
>                 URL: https://issues.apache.org/jira/browse/OOZIE-2227
>             Project: Oozie
>          Issue Type: Bug
>            Reporter: Purshotam Shah
>
> Because of that PartitionDependencyManagerService takes more than 10 min to 
> complete.
> {code}
> Long regTime = registeredCoordActionMap.get(actionId);
>                 if(regTime < (currentTime - timeToLive * 1000)){
>                     CoordinatorActionBean caBean = null;
>                     try {
>                         caBean = 
> CoordActionQueryExecutor.getInstance().get(CoordActionQuery.GET_COORD_ACTION_STATUS,
>  actionId);
>                     }
>                     catch (JPAExecutorException e) {
>                         LOG.warn("Error in checking coord action:" + actionId 
> + "to purge, skipping", e);
>                     }
>                     if(caBean != null && 
> !caBean.getStatus().equals(CoordinatorAction.Status.WAITING)){
>                         staleActions.add(actionId);
>                         actionItr.remove();
>                     }
> {code}
> Should remove actionId if JPAExecutorException = no row found



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