falcon-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From suh...@apache.org
Subject falcon git commit: FALCON-1012 Add support for MapR-FS. Contributed by Roman Slysh
Date Fri, 20 Feb 2015 08:47:15 GMT
Repository: falcon
Updated Branches:
  refs/heads/master 4b31d774d -> 9cd986efb


FALCON-1012 Add support for MapR-FS. Contributed by Roman Slysh


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

Branch: refs/heads/master
Commit: 9cd986efb04b229c844a30748ec27d0a102eb368
Parents: 4b31d77
Author: Suhas Vasu <suhas.v@inmobi.com>
Authored: Fri Feb 20 14:16:55 2015 +0530
Committer: Suhas Vasu <suhas.v@inmobi.com>
Committed: Fri Feb 20 14:16:55 2015 +0530

----------------------------------------------------------------------
 CHANGES.txt                                                      | 2 ++
 common/src/main/java/org/apache/falcon/entity/ClusterHelper.java | 3 +++
 2 files changed, 5 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/falcon/blob/9cd986ef/CHANGES.txt
----------------------------------------------------------------------
diff --git a/CHANGES.txt b/CHANGES.txt
index 97244ec..ce8e5b3 100755
--- a/CHANGES.txt
+++ b/CHANGES.txt
@@ -8,6 +8,8 @@ Trunk (Unreleased)
    FALCON-949 Force update feature (pavan kumar kolamuri via Suhas Vasu)
 
   IMPROVEMENTS
+   FALCON-1012 Add support for MapR-FS (Roman Slysh via Suhas Vasu)
+
    FALCON-774 Discontinue support for JDK 1.6 and move to 1.7. (Peeyush 
    Bishnoi via Srikanth Sundarrajan)
 

http://git-wip-us.apache.org/repos/asf/falcon/blob/9cd986ef/common/src/main/java/org/apache/falcon/entity/ClusterHelper.java
----------------------------------------------------------------------
diff --git a/common/src/main/java/org/apache/falcon/entity/ClusterHelper.java b/common/src/main/java/org/apache/falcon/entity/ClusterHelper.java
index 52b570d..6a363b6 100644
--- a/common/src/main/java/org/apache/falcon/entity/ClusterHelper.java
+++ b/common/src/main/java/org/apache/falcon/entity/ClusterHelper.java
@@ -113,6 +113,9 @@ public final class ClusterHelper {
 
     private static String getNormalizedUrl(Cluster cluster, Interfacetype type) {
         String normalizedUrl = getInterface(cluster, type).getEndpoint();
+        if (normalizedUrl.endsWith("///")){
+            return normalizedUrl;
+        }
         String normalizedPath = new Path(normalizedUrl + "/").toString();
         return normalizedPath.substring(0, normalizedPath.length() - 1);
     }


Mime
View raw message