You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@falcon.apache.org by aj...@apache.org on 2015/11/20 04:38:36 UTC
falcon git commit: FALCON-1606 Process schedule fails in some cases
in case of NativeScheduler. Contributed by Pavan Kumar Kolamuri.
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 <aj...@inmobi.com>
Authored: Fri Nov 20 09:06:06 2015 +0530
Committer: Ajay Yadav <aj...@inmobi.com>
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(),