falcon-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From suh...@apache.org
Subject falcon git commit: FALCON-1050 Falcon rerun is broken for timed out instances. Contributed by Suhas Vasu
Date Tue, 03 Mar 2015 07:43:55 GMT
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 <suhas.v@inmobi.com>
Authored: Tue Mar 3 13:13:31 2015 +0530
Committer: Suhas Vasu <suhas.v@inmobi.com>
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,


Mime
View raw message