You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by bi...@apache.org on 2017/04/10 10:41:01 UTC
[5/8] kylin git commit: KYLIN-2537 hbase r/w bug fix
KYLIN-2537 hbase r/w bug fix
Project: http://git-wip-us.apache.org/repos/asf/kylin/repo
Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/9c82a0d0
Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/9c82a0d0
Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/9c82a0d0
Branch: refs/heads/yang22-hbase1.x
Commit: 9c82a0d0ec138efc04c5393ce475910b887ad78f
Parents: 09e7545
Author: Li Yang <li...@apache.org>
Authored: Mon Apr 10 14:12:18 2017 +0800
Committer: Li Yang <li...@apache.org>
Committed: Mon Apr 10 18:21:20 2017 +0800
----------------------------------------------------------------------
.../java/org/apache/kylin/storage/hbase/HBaseConnection.java | 7 +++++--
1 file changed, 5 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kylin/blob/9c82a0d0/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/HBaseConnection.java
----------------------------------------------------------------------
diff --git a/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/HBaseConnection.java b/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/HBaseConnection.java
index 335bfe7..d7311a9 100644
--- a/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/HBaseConnection.java
+++ b/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/HBaseConnection.java
@@ -202,10 +202,13 @@ public class HBaseConnection {
conf.setStrings(JOB_NAMENODES_TOKEN_RENEWAL_EXCLUDE, nameServices.toArray(new String[0]));
}
- public static String makeQualifiedPathInHBaseCluster(String path) {
+ public static String makeQualifiedPathInHBaseCluster(String inPath) {
+ Path path = new Path(inPath);
+ path = Path.getPathWithoutSchemeAndAuthority(path);
+
try {
FileSystem fs = FileSystem.get(getCurrentHBaseConfiguration());
- return fs.makeQualified(new Path(path)).toString();
+ return fs.makeQualified(path).toString();
} catch (IOException e) {
throw new IllegalArgumentException("Cannot create FileSystem from current hbase cluster conf", e);
}