Repository: falcon Updated Branches: refs/heads/master 12675022a -> b49056d6c
FALCON-1924 Falcon Coordinator rerun return old workflow id Author: Praveen Adlakha <[email protected]> Reviewers: Pallavi<[email protected]>, Sandeep<[email protected]>, Peeyush<[email protected]> 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 <[email protected]> Authored: Fri Apr 22 21:57:00 2016 +0530 Committer: peeyush b <[email protected]> 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(); }
