Repository: falcon Updated Branches: refs/heads/0.9 f3cfe690c -> 1d7a4a015
FALCON-1747 Falcon instance status listing is throwing error message. Contributed by Peeyush Bishnoi. Project: http://git-wip-us.apache.org/repos/asf/falcon/repo Commit: http://git-wip-us.apache.org/repos/asf/falcon/commit/1d7a4a01 Tree: http://git-wip-us.apache.org/repos/asf/falcon/tree/1d7a4a01 Diff: http://git-wip-us.apache.org/repos/asf/falcon/diff/1d7a4a01 Branch: refs/heads/0.9 Commit: 1d7a4a01586ecc56703a44d278d1656848fe2514 Parents: f3cfe69 Author: peeyush b <[email protected]> Authored: Wed Jan 27 19:24:26 2016 +0530 Committer: peeyush b <[email protected]> Committed: Wed Jan 27 19:24:26 2016 +0530 ---------------------------------------------------------------------- CHANGES.txt | 2 ++ .../org/apache/falcon/resource/AbstractInstanceManager.java | 5 +++++ 2 files changed, 7 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/falcon/blob/1d7a4a01/CHANGES.txt ---------------------------------------------------------------------- diff --git a/CHANGES.txt b/CHANGES.txt index d4aa15d..f4d029f 100755 --- a/CHANGES.txt +++ b/CHANGES.txt @@ -106,6 +106,8 @@ Release Version: 0.9 OPTIMIZATIONS BUG FIXES + FALCON-1747 Falcon instance status listing is throwing error message (Peeyush Bishnoi) + FALCON-1758 APIs fail when oozie workflow entries are deleted (Pavan Kolamuri via Pallavi Rao) FALCON-1754 JobCompletionService throws FalconException (Pallavi Rao) http://git-wip-us.apache.org/repos/asf/falcon/blob/1d7a4a01/prism/src/main/java/org/apache/falcon/resource/AbstractInstanceManager.java ---------------------------------------------------------------------- diff --git a/prism/src/main/java/org/apache/falcon/resource/AbstractInstanceManager.java b/prism/src/main/java/org/apache/falcon/resource/AbstractInstanceManager.java index 2225c09..cde3ea0 100644 --- a/prism/src/main/java/org/apache/falcon/resource/AbstractInstanceManager.java +++ b/prism/src/main/java/org/apache/falcon/resource/AbstractInstanceManager.java @@ -920,6 +920,11 @@ public abstract class AbstractInstanceManager extends AbstractEntityManager { } start = new Date(startMillis); + if (start.after(end)) { + LOG.warn("Calculated start date : {} crossed end date : {} setting it to " + + "entity start date", start, end); + start = clusterStartDate; + } } else { start = EntityUtil.parseDateUTC(startStr); }
