[
https://issues.apache.org/jira/browse/OOZIE-1843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Purshotam Shah updated OOZIE-1843:
----------------------------------
Description:
{code}
for (CoordinatorJobBean coordJob : materializeJobs) {
if
(Services.get().get(JobsConcurrencyService.class).isJobIdForThisServer(coordJob.getId()))
{
Services.get().get(InstrumentationService.class).get()
.incr(INSTRUMENTATION_GROUP,
INSTR_MAT_JOBS_COUNTER, 1);
queueCallable(new
CoordMaterializeTransitionXCommand(coordJob.getId(), materializationWindow));
coordJob.setLastModifiedTime(new Date());
CoordJobQueryExecutor.getInstance().executeUpdate(
CoordJobQueryExecutor.CoordJobQuery.UPDATE_COORD_JOB_LAST_MODIFIED_TIME,
coordJob);
}
{code}
> Bulk update for coord last modified time for CoordMaterializeTriggerService
> ---------------------------------------------------------------------------
>
> Key: OOZIE-1843
> URL: https://issues.apache.org/jira/browse/OOZIE-1843
> Project: Oozie
> Issue Type: Bug
> Reporter: Purshotam Shah
>
> {code}
> for (CoordinatorJobBean coordJob : materializeJobs) {
> if
> (Services.get().get(JobsConcurrencyService.class).isJobIdForThisServer(coordJob.getId()))
> {
> Services.get().get(InstrumentationService.class).get()
> .incr(INSTRUMENTATION_GROUP,
> INSTR_MAT_JOBS_COUNTER, 1);
> queueCallable(new
> CoordMaterializeTransitionXCommand(coordJob.getId(), materializationWindow));
> coordJob.setLastModifiedTime(new Date());
> CoordJobQueryExecutor.getInstance().executeUpdate(
>
> CoordJobQueryExecutor.CoordJobQuery.UPDATE_COORD_JOB_LAST_MODIFIED_TIME,
> coordJob);
> }
> {code}
--
This message was sent by Atlassian JIRA
(v6.2#6252)
