falcon-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From peeyu...@apache.org
Subject falcon git commit: FALCON-1747 Falcon instance status listing is throwing error message. Contributed by Peeyush Bishnoi.
Date Wed, 27 Jan 2016 13:54:53 GMT
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 <pbishnoi@hortonworks.com>
Authored: Wed Jan 27 19:24:26 2016 +0530
Committer: peeyush b <pbishnoi@hortonworks.com>
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);
         }


Mime
View raw message