[
https://issues.apache.org/jira/browse/OOZIE-2228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Purshotam Shah updated OOZIE-2228:
----------------------------------
Description:
{code}
@NamedQuery(name = "GET_BUNDLE_IDS_FOR_STATUS_TRANSIT", query = "select
DISTINCT w.id from BundleActionBean a , BundleJobBean w where
a.lastModifiedTimestamp >= :lastModifiedTime and w.id = a.bundleId and
(w.statusStr = 'RUNNING' OR w.statusStr = 'RUNNINGWITHERROR' OR w.statusStr =
'PAUSED' OR w.statusStr = 'PAUSEDWITHERROR' OR w.pending = 1)"),
{code}
Can be reproduced easily.
1. suspend coord, bundle goes to suspend by StatusTransitService.
2. resume coord, bundle remains in suspend state.
was:
{code}
@NamedQuery(name = "GET_BUNDLE_IDS_FOR_STATUS_TRANSIT", query = "select
DISTINCT w.id from BundleActionBean a , BundleJobBean w where
a.lastModifiedTimestamp >= :lastModifiedTime and w.id = a.bundleId and
(w.statusStr = 'RUNNING' OR w.statusStr = 'RUNNINGWITHERROR' OR w.statusStr =
'PAUSED' OR w.statusStr = 'PAUSEDWITHERROR' OR w.pending = 1)"),
{code}
Can be reproduced easily.
1. suspend coord, bundle goes to suspend by StatusTransitService.
2. resume coord, bundle remains in suspend state.
> Statustransit service doesn't pick bundle with suspend status
> -------------------------------------------------------------
>
> Key: OOZIE-2228
> URL: https://issues.apache.org/jira/browse/OOZIE-2228
> Project: Oozie
> Issue Type: Bug
> Reporter: Purshotam Shah
>
> {code}
> @NamedQuery(name = "GET_BUNDLE_IDS_FOR_STATUS_TRANSIT", query = "select
> DISTINCT w.id from BundleActionBean a , BundleJobBean w where
> a.lastModifiedTimestamp >= :lastModifiedTime and w.id = a.bundleId and
> (w.statusStr = 'RUNNING' OR w.statusStr = 'RUNNINGWITHERROR' OR w.statusStr =
> 'PAUSED' OR w.statusStr = 'PAUSEDWITHERROR' OR w.pending = 1)"),
> {code}
> Can be reproduced easily.
> 1. suspend coord, bundle goes to suspend by StatusTransitService.
> 2. resume coord, bundle remains in suspend state.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
