falcon-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ajayyad...@apache.org
Subject falcon git commit: FALCON-1606 Process schedule fails in some cases in case of NativeScheduler. Contributed by Pavan Kumar Kolamuri.
Date Fri, 20 Nov 2015 03:38:36 GMT
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 <ajay.yadav@inmobi.com>
Authored: Fri Nov 20 09:06:06 2015 +0530
Committer: Ajay Yadav <ajay.yadav@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(),


Mime
View raw message