falcon-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From shaikid...@apache.org
Subject git commit: FALCON-124 unable to schedule deleted feed. Contributed by Shwetha GS
Date Tue, 24 Dec 2013 12:48:29 GMT
Updated Branches:
  refs/heads/master 6a505a322 -> 744c2911a


FALCON-124 unable to schedule deleted feed. Contributed by Shwetha GS


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

Branch: refs/heads/master
Commit: 744c2911aa9b5916619c10b5c4993aa6c4dcb9a1
Parents: 6a505a3
Author: shaik.idris <psychidris@gmail.com>
Authored: Tue Dec 24 18:03:05 2013 +0530
Committer: shaik.idris <psychidris@gmail.com>
Committed: Tue Dec 24 18:03:05 2013 +0530

----------------------------------------------------------------------
 CHANGES.txt                                                        | 1 +
 .../org/apache/falcon/workflow/engine/OozieWorkflowEngine.java     | 2 +-
 2 files changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-falcon/blob/744c2911/CHANGES.txt
----------------------------------------------------------------------
diff --git a/CHANGES.txt b/CHANGES.txt
index bebfbf7..50198a4 100755
--- a/CHANGES.txt
+++ b/CHANGES.txt
@@ -21,6 +21,7 @@ Trunk (Unreleased)
 
     FALCON-232 mvn clean verify fails with oozie war not found. (Shwetha GS)
 
+    FALCON-124 unable to schedule deleted feed. (Shwetha GS via Shaik Idris)
 
 Release Version: 0.4-incubating
 

http://git-wip-us.apache.org/repos/asf/incubator-falcon/blob/744c2911/oozie/src/main/java/org/apache/falcon/workflow/engine/OozieWorkflowEngine.java
----------------------------------------------------------------------
diff --git a/oozie/src/main/java/org/apache/falcon/workflow/engine/OozieWorkflowEngine.java
b/oozie/src/main/java/org/apache/falcon/workflow/engine/OozieWorkflowEngine.java
index c4c46af..1ed1ff7 100644
--- a/oozie/src/main/java/org/apache/falcon/workflow/engine/OozieWorkflowEngine.java
+++ b/oozie/src/main/java/org/apache/falcon/workflow/engine/OozieWorkflowEngine.java
@@ -198,7 +198,7 @@ public class OozieWorkflowEngine extends AbstractWorkflowEngine {
             if (jobs != null) {
                 List<BundleJob> filteredJobs = new ArrayList<BundleJob>();
                 for (BundleJob job : jobs) {
-                    if (job.getStatus() != Job.Status.KILLED || job.getEndTime() == null)
{
+                    if (job.getEndTime() == null) {
                         filteredJobs.add(job);
                         LOG.debug("Found bundle " + job.getId());
                     }


Mime
View raw message