Repository: falcon Updated Branches: refs/heads/master 23b325221 -> f66b0b9f1
FALCON-1050 Falcon rerun is broken for timed out instances. 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/f66b0b9f Tree: http://git-wip-us.apache.org/repos/asf/falcon/tree/f66b0b9f Diff: http://git-wip-us.apache.org/repos/asf/falcon/diff/f66b0b9f Branch: refs/heads/master Commit: f66b0b9f16c2228ea0c14a2245236f9d319a4744 Parents: 23b3252 Author: Suhas Vasu <[email protected]> Authored: Tue Mar 3 13:13:31 2015 +0530 Committer: Suhas Vasu <[email protected]> Committed: Tue Mar 3 13:13:31 2015 +0530 ---------------------------------------------------------------------- CHANGES.txt | 3 +++ .../org/apache/falcon/workflow/engine/OozieWorkflowEngine.java | 2 +- 2 files changed, 4 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/falcon/blob/f66b0b9f/CHANGES.txt ---------------------------------------------------------------------- diff --git a/CHANGES.txt b/CHANGES.txt index e4e182d..f79bd8c 100755 --- a/CHANGES.txt +++ b/CHANGES.txt @@ -89,6 +89,9 @@ Trunk (Unreleased) (Suhas vasu) BUG FIXES + FALCON-1050 Falcon rerun is broken for timed out instances + (Suhas Vasu) + FALCON-1045 Falcon rerun is broken in trunk (Suhas Vasu) FALCON-973 Add LogMover Service for yarn http://git-wip-us.apache.org/repos/asf/falcon/blob/f66b0b9f/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 fc95e61..169856c 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 @@ -809,7 +809,7 @@ public class OozieWorkflowEngine extends AbstractWorkflowEngine { private void reRunCoordAction(String cluster, CoordinatorAction coordinatorAction) throws FalconException { try { OozieClient client = OozieClientFactory.get(cluster); - client.reRunCoord(coordinatorAction.getJobId(), RestConstants.JOB_COORD_ACTION_RERUN, + client.reRunCoord(coordinatorAction.getJobId(), RestConstants.JOB_COORD_SCOPE_ACTION, Integer.toString(coordinatorAction.getActionNumber()), true, true); assertCoordActionStatus(cluster, coordinatorAction.getId(), org.apache.oozie.client.CoordinatorAction.Status.RUNNING,
