You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@falcon.apache.org by pe...@apache.org on 2016/04/22 18:27:14 UTC
falcon git commit: FALCON-1924 Falcon Coordinator rerun return old
workflow id
Repository: falcon
Updated Branches:
refs/heads/master 12675022a -> b49056d6c
FALCON-1924 Falcon Coordinator rerun return old workflow id
Author: Praveen Adlakha <ad...@gmail.com>
Reviewers: Pallavi<pa...@inmobi.com>, Sandeep<sa...@gmail.com>, Peeyush<pe...@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 <ad...@gmail.com>
Authored: Fri Apr 22 21:57:00 2016 +0530
Committer: peeyush b <pb...@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();
}