You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@falcon.apache.org by sh...@apache.org on 2014/01/06 07:33:47 UTC
git commit: FALCON-241 The job logs are not copied during
Post-Processing step in Replication workflows. Contributed by Suhas Vasu
Updated Branches:
refs/heads/master dfe20ee7a -> 8472f129f
FALCON-241 The job logs are not copied during Post-Processing step in Replication workflows. Contributed by Suhas Vasu
Project: http://git-wip-us.apache.org/repos/asf/incubator-falcon/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-falcon/commit/8472f129
Tree: http://git-wip-us.apache.org/repos/asf/incubator-falcon/tree/8472f129
Diff: http://git-wip-us.apache.org/repos/asf/incubator-falcon/diff/8472f129
Branch: refs/heads/master
Commit: 8472f129f00013ab5a3c621fd091d1d0452af729
Parents: dfe20ee
Author: Shwetha GS <sh...@gmail.com>
Authored: Mon Jan 6 12:03:39 2014 +0530
Committer: Shwetha GS <sh...@gmail.com>
Committed: Mon Jan 6 12:03:39 2014 +0530
----------------------------------------------------------------------
CHANGES.txt | 3 +++
oozie/src/main/java/org/apache/falcon/logging/LogMover.java | 9 ++++++++-
2 files changed, 11 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-falcon/blob/8472f129/CHANGES.txt
----------------------------------------------------------------------
diff --git a/CHANGES.txt b/CHANGES.txt
index 299d9bf..f6a6cff 100755
--- a/CHANGES.txt
+++ b/CHANGES.txt
@@ -15,6 +15,9 @@ Trunk (Unreleased)
OPTIMIZATIONS
BUG FIXES
+ FALCON-241 The job logs are not copied during Post-Processing step in Replication workflows.
+ (Suhas Vasu via Shwetha GS)
+
FALCON-106 Falcon compilation fails for hadoop-2 profile. (Shwetha GS
via Srikanth Sundarrajan)
http://git-wip-us.apache.org/repos/asf/incubator-falcon/blob/8472f129/oozie/src/main/java/org/apache/falcon/logging/LogMover.java
----------------------------------------------------------------------
diff --git a/oozie/src/main/java/org/apache/falcon/logging/LogMover.java b/oozie/src/main/java/org/apache/falcon/logging/LogMover.java
index e8a85c6..afdc36d 100644
--- a/oozie/src/main/java/org/apache/falcon/logging/LogMover.java
+++ b/oozie/src/main/java/org/apache/falcon/logging/LogMover.java
@@ -95,7 +95,14 @@ public class LogMover extends Configured implements Tool {
|| notUserWorkflowEngineIsOozie(args.userWorkflowEngine)) {
// if replication wf or PIG Process
copyOozieLog(client, fs, path, jobInfo.getId());
- copyTTlogs(fs, path, jobInfo.getActions().get(2));
+
+ List<WorkflowAction> workflowActions = jobInfo.getActions();
+ for (int i=0; i < workflowActions.size(); i++) {
+ if (workflowActions.get(i).getName().equals("replication")) {
+ copyTTlogs(fs, path, jobInfo.getActions().get(i));
+ break;
+ }
+ }
} else {
// if process wf with oozie engine
String subflowId = jobInfo.getExternalId();