[
https://issues.apache.org/jira/browse/OOZIE-2348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14724399#comment-14724399
]
Rohini Palaniswamy commented on OOZIE-2348:
-------------------------------------------
{code}
+ else if (caction.getStatus() ==
CoordinatorActionBean.Status.READY) {
+ if (caction.getExternalId() != null) {
+ readyJobs.add(caction.getJobId());
+ }
+ }
{code}
is not correct. Need to remove the externalId != null check. Can you also
delete CoordActionsGetReadyGroupbyJobIDJPAExecutor and
CoordActionsGetForRecoveryJPAExecutor classes?
> Recovery service keeps on recovering coord action of suspended jobs
> -------------------------------------------------------------------
>
> Key: OOZIE-2348
> URL: https://issues.apache.org/jira/browse/OOZIE-2348
> Project: Oozie
> Issue Type: Bug
> Reporter: Purshotam Shah
> Assignee: Purshotam Shah
> Attachments: OOZIE-2348-V1.patch
>
>
> {code}
> @NamedQuery(name = "GET_READY_ACTIONS_GROUP_BY_JOBID", query =
> "select a.jobId, min(a.lastModifiedTimestamp) from CoordinatorActionBean a
> where a.statusStr = 'READY' group by a.jobId having
> min(a.lastModifiedTimestamp) < :lastModifiedTime"),
> @NamedQuery(name = "GET_COORD_ACTIONS_WAITING_SUBMITTED_OLDER_THAN",
> query = "select a.id, a.jobId, a.statusStr, a.externalId,
> a.pushMissingDependencies from CoordinatorActionBean a where (a.statusStr =
> 'WAITING' OR a.statusStr = 'SUBMITTED') AND a.lastModifiedTimestamp <=
> :lastModifiedTime"),
> {code}
> Even if job is suspended, Recovery service will keep on queuing ready,
> waiting, ready command.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
