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-1924 Falcon Coordinator rerun return old workflow id
Date Fri, 22 Apr 2016 16:27:14 GMT
Repository: falcon
Updated Branches:
  refs/heads/master 12675022a -> b49056d6c


FALCON-1924 Falcon Coordinator rerun return old workflow id

Author: Praveen Adlakha <adlakha.praveen@gmail.com>

Reviewers: Pallavi<pallavi.rao@inmobi.com>, Sandeep<sandysmdl@gmail.com>, Peeyush<peeyushb@apache.org>

Closes #113 from PraveenAdlakha/1924


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

Branch: refs/heads/master
Commit: b49056d6c7a79987c3d415ac6d6037fa9f1c92b9
Parents: 1267502
Author: Praveen Adlakha <adlakha.praveen@gmail.com>
Authored: Fri Apr 22 21:57:00 2016 +0530
Committer: peeyush b <pbishnoi@hortonworks.com>
Committed: Fri Apr 22 21:57:00 2016 +0530

----------------------------------------------------------------------
 .../org/apache/falcon/workflow/engine/OozieWorkflowEngine.java   | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/falcon/blob/b49056d6/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 ab2dd5a..05d5ef9 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
@@ -873,7 +873,7 @@ public class OozieWorkflowEngine extends AbstractWorkflowEngine {
                     if (wfJob!=null) {
                         newInstance.startTime = wfJob.getStartTime();
                         newInstance.endTime = wfJob.getEndTime();
-                        newInstance.logFile = wfJob.getConsoleUrl();
+                        newInstance.logFile = coordinatorAction.getId();
                         populateInstanceActions(cluster, wfJob, newInstance);
                         newInstance.status = WorkflowStatus.valueOf(mapActionStatus(wfJob.getStatus().name()));
                         instanceList.add(newInstance);
@@ -893,7 +893,7 @@ public class OozieWorkflowEngine extends AbstractWorkflowEngine {
             status = jobInfo.getStatus().name();
             instance.startTime = jobInfo.getStartTime();
             instance.endTime = jobInfo.getEndTime();
-            instance.logFile = jobInfo.getConsoleUrl();
+            instance.logFile = coordinatorAction.getId();
             instance.runId = jobInfo.getRun();
         }
 


Mime
View raw message