falcon-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From pall...@apache.org
Subject falcon git commit: FALCON-1484 Find Bundles fails in case of hadoop namenode moving to HA(Contributed by Sandeep Samudrala)
Date Wed, 23 Sep 2015 11:36:28 GMT
Repository: falcon
Updated Branches:
  refs/heads/master 8600e9465 -> cf492300e


FALCON-1484 Find Bundles fails in case of hadoop namenode moving to HA(Contributed by Sandeep
Samudrala)


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

Branch: refs/heads/master
Commit: cf492300e77d627b3ecfa0f4b469e3f4ff78b146
Parents: 8600e94
Author: Pallavi Rao <pallavi.rao@inmobi.com>
Authored: Wed Sep 23 17:06:13 2015 +0530
Committer: Pallavi Rao <pallavi.rao@inmobi.com>
Committed: Wed Sep 23 17:06:13 2015 +0530

----------------------------------------------------------------------
 CHANGES.txt                                                      | 2 ++
 .../org/apache/falcon/workflow/engine/OozieWorkflowEngine.java   | 4 +++-
 2 files changed, 5 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/falcon/blob/cf492300/CHANGES.txt
----------------------------------------------------------------------
diff --git a/CHANGES.txt b/CHANGES.txt
index 5a7c46e..a54fbcf 100755
--- a/CHANGES.txt
+++ b/CHANGES.txt
@@ -35,6 +35,8 @@ Trunk (Unreleased)
     FALCON-1403 Revisit IT cleanup and teardown(Narayan Periwal via Pallavi Rao)
 
   BUG FIXES
+    FALCON-1484 Find Bundles fails in case of hadoop namenode moving to HA(Sandeep Samudrala
via Pallavi Rao)
+
     FALCON-1343 Fix validation of read/write endpoints in ClusterEntityParser(Balu Vellanki
via Ajay Yadava)
 
     FALCON-1373 HiveDR does not work when job is run on destination cluster(Balu Vellanki
via Ajay Yadava)

http://git-wip-us.apache.org/repos/asf/falcon/blob/cf492300/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 0441f7c..6660af1 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
@@ -328,7 +328,9 @@ public class OozieWorkflowEngine extends AbstractWorkflowEngine {
                 + "=" + EntityUtil.getWorkflowName(entity) + ";", 0, 256);
             if (jobs != null) {
                 for (BundleJob job : jobs) {
-                    if (EntityUtil.isStagingPath(cluster, entity, new Path(job.getAppPath())))
{
+                    // Path is extracted twice as to handle changes in hadoop configurations
for nameservices.
+                    if (EntityUtil.isStagingPath(cluster, entity,
+                            new Path((new Path(job.getAppPath())).toUri().getPath()))) {
                         //Load bundle as coord info is not returned in getBundleJobsInfo()
                         BundleJob bundle = getBundleInfo(clusterName, job.getId());
                         filteredJobs.add(bundle);


Mime
View raw message