You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@oozie.apache.org by "Purshotam Shah (JIRA)" <ji...@apache.org> on 2014/05/16 12:59:51 UTC
[jira] [Updated] (OOZIE-1843) Bulk update for coord last modified
time for CoordMaterializeTriggerService
[ 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)