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 <[email protected]> Authored: Tue Oct 27 01:20:46 2015 +0530 Committer: Ajay Yadava <[email protected]> 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;
