Repository: falcon Updated Branches: refs/heads/master ea8c26efa -> 7953e8aec
FALCON-1606 Process schedule fails in some cases in case of NativeScheduler. Contributed by Pavan Kumar Kolamuri. Project: http://git-wip-us.apache.org/repos/asf/falcon/repo Commit: http://git-wip-us.apache.org/repos/asf/falcon/commit/7953e8ae Tree: http://git-wip-us.apache.org/repos/asf/falcon/tree/7953e8ae Diff: http://git-wip-us.apache.org/repos/asf/falcon/diff/7953e8ae Branch: refs/heads/master Commit: 7953e8aecf02b873aa3227f00bf61800cfeb7170 Parents: ea8c26e Author: Ajay Yadav <[email protected]> Authored: Fri Nov 20 09:06:06 2015 +0530 Committer: Ajay Yadav <[email protected]> Committed: Fri Nov 20 09:06:06 2015 +0530 ---------------------------------------------------------------------- CHANGES.txt | 2 ++ .../org/apache/falcon/notification/service/impl/AlarmService.java | 2 +- 2 files changed, 3 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/falcon/blob/7953e8ae/CHANGES.txt ---------------------------------------------------------------------- diff --git a/CHANGES.txt b/CHANGES.txt index 9177529..b0f2f89 100755 --- a/CHANGES.txt +++ b/CHANGES.txt @@ -35,6 +35,8 @@ Trunk (Unreleased) OPTIMIZATIONS BUG FIXES + FALCON-1606 Process schedule fails in some cases in case of NativeScheduler(Pavan Kumar Kolamuri via Ajay Yadava) + FALCON-1605 Instance API is not working as expected in case of Native Scheduler(Pavan Kumar Kolamuri via Ajay Yadava) FALCON-1603 FeedHelperTest::testGetDateFromPath fails in some environments(Balu Vellanki via Ajay Yadava) http://git-wip-us.apache.org/repos/asf/falcon/blob/7953e8ae/scheduler/src/main/java/org/apache/falcon/notification/service/impl/AlarmService.java ---------------------------------------------------------------------- diff --git a/scheduler/src/main/java/org/apache/falcon/notification/service/impl/AlarmService.java b/scheduler/src/main/java/org/apache/falcon/notification/service/impl/AlarmService.java index cccdeac..115f310 100644 --- a/scheduler/src/main/java/org/apache/falcon/notification/service/impl/AlarmService.java +++ b/scheduler/src/main/java/org/apache/falcon/notification/service/impl/AlarmService.java @@ -109,7 +109,7 @@ public class AlarmService implements FalconNotificationService { } } // All past events have been scheduled. Nothing to schedule in the future. - if (request.getEndTime().isBefore(currentTime)) { + if (request.getEndTime().isBefore(nextStartTime)) { return; } LOG.debug("Scheduling to trigger events from {} to {} with frequency {}", nextStartTime, request.getEndTime(),
