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-1558 Sla API shows pending instance although _SUCCESS directory is present. Contributed by Pragya Mittal.
Date Mon, 26 Oct 2015 20:09:22 GMT
Repository: falcon
Updated Branches:
  refs/heads/0.8 3077fa93d -> 245ebeaff


FALCON-1558 Sla API shows pending instance although _SUCCESS directory is present. Contributed
by Pragya Mittal.


Project: http://git-wip-us.apache.org/repos/asf/falcon/repo
Commit: http://git-wip-us.apache.org/repos/asf/falcon/commit/245ebeaf
Tree: http://git-wip-us.apache.org/repos/asf/falcon/tree/245ebeaf
Diff: http://git-wip-us.apache.org/repos/asf/falcon/diff/245ebeaf

Branch: refs/heads/0.8
Commit: 245ebeaff8e608340e196ea748ccc1464bed28c9
Parents: 3077fa9
Author: Ajay Yadava <ajaynsit@gmail.com>
Authored: Tue Oct 27 01:20:46 2015 +0530
Committer: Ajay Yadava <ajaynsit@gmail.com>
Committed: Tue Oct 27 01:20:46 2015 +0530

----------------------------------------------------------------------
 CHANGES.txt                                                       | 2 ++
 .../java/org/apache/falcon/service/FeedSLAMonitoringService.java  | 3 ++-
 2 files changed, 4 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/falcon/blob/245ebeaf/CHANGES.txt
----------------------------------------------------------------------
diff --git a/CHANGES.txt b/CHANGES.txt
index 9fae806..473d50f 100755
--- a/CHANGES.txt
+++ b/CHANGES.txt
@@ -75,6 +75,8 @@ Release version: 0.8
     FALCON-1403 Revisit IT cleanup and teardown(Narayan Periwal via Pallavi Rao)
 
   BUG FIXES
+    FALCON-1558 Sla API shows pending instance although _SUCCESS directory is present(Pragya
Mittal via Ajay Yadava).
+
     FALCON-1555 succeeded-post-processing action fails in Oozie uber mode (Pragya Mittal
via Pallavi Rao)
 
     FALCON-1551 Implement setWorkingDir Method in JailedFileSystem(Pavan Kolamuri via Pallavi
Rao)

http://git-wip-us.apache.org/repos/asf/falcon/blob/245ebeaf/prism/src/main/java/org/apache/falcon/service/FeedSLAMonitoringService.java
----------------------------------------------------------------------
diff --git a/prism/src/main/java/org/apache/falcon/service/FeedSLAMonitoringService.java b/prism/src/main/java/org/apache/falcon/service/FeedSLAMonitoringService.java
index 67b7985..0eae0c6 100644
--- a/prism/src/main/java/org/apache/falcon/service/FeedSLAMonitoringService.java
+++ b/prism/src/main/java/org/apache/falcon/service/FeedSLAMonitoringService.java
@@ -334,7 +334,8 @@ public final class FeedSLAMonitoringService implements ConfigurationChangeListen
                     clusterName, nominalTime);
             FeedInstanceStatus.AvailabilityStatus status = FeedHelper.getFeedInstanceStatus(feed,
clusterName,
                     nominalTime);
-            if (status == FeedInstanceStatus.AvailabilityStatus.AVAILABLE) {
+            if (status.equals(FeedInstanceStatus.AvailabilityStatus.AVAILABLE)
+                    || status.equals(FeedInstanceStatus.AvailabilityStatus.EMPTY)) {
                 LOG.debug("Feed instance(feed:{}, cluster:{}, instanceTime:{}) is available.",
feed.getName(),
                     clusterName, nominalTime);
                 return true;


Mime
View raw message