Repository: falcon Updated Branches: refs/heads/master 9dd0b27e5 -> 103dfaa08
FALCON-1045 Falcon rerun is broken in trunk. Contributed by Suhas Vasu Project: http://git-wip-us.apache.org/repos/asf/falcon/repo Commit: http://git-wip-us.apache.org/repos/asf/falcon/commit/103dfaa0 Tree: http://git-wip-us.apache.org/repos/asf/falcon/tree/103dfaa0 Diff: http://git-wip-us.apache.org/repos/asf/falcon/diff/103dfaa0 Branch: refs/heads/master Commit: 103dfaa086a6c3139085ff15359199e68a45c8a9 Parents: 9dd0b27 Author: Suhas Vasu <[email protected]> Authored: Wed Feb 25 14:16:08 2015 +0530 Committer: Suhas Vasu <[email protected]> Committed: Wed Feb 25 14:16:08 2015 +0530 ---------------------------------------------------------------------- CHANGES.txt | 2 ++ .../org/apache/falcon/workflow/engine/OozieWorkflowEngine.java | 2 +- 2 files changed, 3 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/falcon/blob/103dfaa0/CHANGES.txt ---------------------------------------------------------------------- diff --git a/CHANGES.txt b/CHANGES.txt index 959e4a2..e4e182d 100755 --- a/CHANGES.txt +++ b/CHANGES.txt @@ -89,6 +89,8 @@ Trunk (Unreleased) (Suhas vasu) BUG FIXES + FALCON-1045 Falcon rerun is broken in trunk (Suhas Vasu) + FALCON-973 Add LogMover Service for yarn (pavan kumar kolamuri via Suhas Vasu) http://git-wip-us.apache.org/repos/asf/falcon/blob/103dfaa0/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 fd1cdac..fc95e61 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 @@ -1317,7 +1317,7 @@ public class OozieWorkflowEngine extends AbstractWorkflowEngine { } //if user has set any of these oozie rerun properties then force rerun flag is ignored if (!jobprops.contains(OozieClient.RERUN_FAIL_NODES) && !jobprops.contains(OozieClient.RERUN_SKIP_NODES)) { - jobprops.put(OozieClient.RERUN_FAIL_NODES, !isForced); + jobprops.put(OozieClient.RERUN_FAIL_NODES, String.valueOf(!isForced)); } jobprops.remove(OozieClient.COORDINATOR_APP_PATH); jobprops.remove(OozieClient.BUNDLE_APP_PATH);
