Description
CoordChangeXCommand.java
if (jobStatus != null) { coordJob.setStatus(jobStatus); LOG.info("Coord status is changed to " + jobStatus + " from " + prevStatus); if (jobStatus.equals(CoordinatorJob.Status.RUNNING)) { coordJob.setPending(); if (coordJob.getNextMaterializedTime() != null && coordJob.getEndTime().after(coordJob.getNextMaterializedTime())) { coordJob.resetDoneMaterialization(); } } else if (jobStatus.equals(CoordinatorJob.Status.IGNORED)) { coordJob.resetPending(); coordJob.setDoneMaterialization(); } }
If the job was killed without creating any action, then coordJob.getNextMaterializedTime() will be null and change command will not reset done materialization.
Attachments
Attachments
Issue Links
- links to