[
https://issues.apache.org/jira/browse/OOZIE-2348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14744287#comment-14744287
]
Purshotam Shah commented on OOZIE-2348:
---------------------------------------
{code}
queue(new CoordPushDependencyCheckXCommand(coordAction.getId()),
nominalTime.getTime() - currentTime
.getTime()), getCoordPushCheckRequeueInterval());
{code}
Requeue logic is not correct. if current time is 23:55:00 and nominal time is
23:55:01 and coord push reueue interval is 10 min. Then command will get
requeued for 10 min which is not correct. Ditto for
CoordActionInputCheckXCommand.
> 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
> Fix For: trunk
>
> Attachments: OOZIE-2348-V1.patch, OOZIE-2348-V2.patch,
> OOZIE-2348-V2.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)
