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 <[email protected]> Authored: Fri Feb 20 14:16:55 2015 +0530 Committer: Suhas Vasu <[email protected]> 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); }
