FALCON-1154 Replication is broken. Contributed by Sowmya Ramesh
Project: http://git-wip-us.apache.org/repos/asf/falcon/repo Commit: http://git-wip-us.apache.org/repos/asf/falcon/commit/71cfc47b Tree: http://git-wip-us.apache.org/repos/asf/falcon/tree/71cfc47b Diff: http://git-wip-us.apache.org/repos/asf/falcon/diff/71cfc47b Branch: refs/heads/master Commit: 71cfc47b8ee6e9cfd8794c09748abbde44f8fd70 Parents: 0a38955 Author: Suhas Vasu <[email protected]> Authored: Thu Apr 16 21:29:33 2015 +0530 Committer: Suhas Vasu <[email protected]> Committed: Thu Apr 16 21:29:33 2015 +0530 ---------------------------------------------------------------------- CHANGES.txt | 2 ++ .../src/main/resources/hdfs-replication-workflow.xml | 4 ++++ oozie/src/main/resources/action/feed/eviction-action.xml | 4 ++++ oozie/src/main/resources/action/feed/replication-action.xml | 4 ++++ oozie/src/main/resources/action/pre-process.xml | 4 ++++ 5 files changed, 18 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/falcon/blob/71cfc47b/CHANGES.txt ---------------------------------------------------------------------- diff --git a/CHANGES.txt b/CHANGES.txt index b64cecb..859bad0 100755 --- a/CHANGES.txt +++ b/CHANGES.txt @@ -161,6 +161,8 @@ Branch: 0.6.1 (Proposed Release Version: 0.6.1) (Suhas vasu) BUG FIXES + FALCON-1154 Replication is broken (Sowmya Ramesh via Suhas Vasu) + FALCON-1159 Falcon build is broken (Suhas Vasu) FALCON-1146 feed retention policy deleted everything all the way up http://git-wip-us.apache.org/repos/asf/falcon/blob/71cfc47b/addons/recipes/hdfs-replication/src/main/resources/hdfs-replication-workflow.xml ---------------------------------------------------------------------- diff --git a/addons/recipes/hdfs-replication/src/main/resources/hdfs-replication-workflow.xml b/addons/recipes/hdfs-replication/src/main/resources/hdfs-replication-workflow.xml index 4ef8fc7..145d489 100644 --- a/addons/recipes/hdfs-replication/src/main/resources/hdfs-replication-workflow.xml +++ b/addons/recipes/hdfs-replication/src/main/resources/hdfs-replication-workflow.xml @@ -43,6 +43,10 @@ <name>oozie.action.sharelib.for.java</name> <value>distcp</value> </property> + <property> + <name>oozie.launcher.oozie.libpath</name> + <value>${wf:conf("falcon.libpath")}</value> + </property> </configuration> <main-class>org.apache.falcon.replication.FeedReplicator</main-class> <arg>-Dmapred.job.queue.name=${queueName}</arg> http://git-wip-us.apache.org/repos/asf/falcon/blob/71cfc47b/oozie/src/main/resources/action/feed/eviction-action.xml ---------------------------------------------------------------------- diff --git a/oozie/src/main/resources/action/feed/eviction-action.xml b/oozie/src/main/resources/action/feed/eviction-action.xml index 64d5793..4ab67d2 100644 --- a/oozie/src/main/resources/action/feed/eviction-action.xml +++ b/oozie/src/main/resources/action/feed/eviction-action.xml @@ -33,6 +33,10 @@ <name>oozie.action.sharelib.for.java</name> <value>hcatalog</value> </property> + <property> + <name>oozie.launcher.oozie.libpath</name> + <value>${wf:conf("falcon.libpath")}</value> + </property> </configuration> <main-class>org.apache.falcon.retention.FeedEvictor</main-class> <arg>-feedBasePath</arg> http://git-wip-us.apache.org/repos/asf/falcon/blob/71cfc47b/oozie/src/main/resources/action/feed/replication-action.xml ---------------------------------------------------------------------- diff --git a/oozie/src/main/resources/action/feed/replication-action.xml b/oozie/src/main/resources/action/feed/replication-action.xml index beedd57..ff8f4f3 100644 --- a/oozie/src/main/resources/action/feed/replication-action.xml +++ b/oozie/src/main/resources/action/feed/replication-action.xml @@ -37,6 +37,10 @@ <name>oozie.action.sharelib.for.java</name> <value>distcp</value> </property> + <property> + <name>oozie.launcher.oozie.libpath</name> + <value>${wf:conf("falcon.libpath")}</value> + </property> </configuration> <main-class>org.apache.falcon.replication.FeedReplicator</main-class> <arg>-Dfalcon.include.path=${sourceRelativePaths}</arg> http://git-wip-us.apache.org/repos/asf/falcon/blob/71cfc47b/oozie/src/main/resources/action/pre-process.xml ---------------------------------------------------------------------- diff --git a/oozie/src/main/resources/action/pre-process.xml b/oozie/src/main/resources/action/pre-process.xml index 50306e5..fc4125c 100644 --- a/oozie/src/main/resources/action/pre-process.xml +++ b/oozie/src/main/resources/action/pre-process.xml @@ -33,6 +33,10 @@ <name>oozie.action.sharelib.for.java</name> <value>hcatalog</value> </property> + <property> + <name>oozie.launcher.oozie.libpath</name> + <value>${wf:conf("falcon.libpath")}</value> + </property> </configuration> <main-class>org.apache.falcon.workflow.LateDataHandler</main-class> <arg>-out</arg>
