You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by li...@apache.org on 2017/04/17 11:44:02 UTC
[02/17] 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/a997dd66
Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/a997dd66
Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/a997dd66
Branch: refs/heads/2.0.x-hbase0.98
Commit: a997dd66c52a3111157bcd366f0de041b616f4e1
Parents: a2c4be6
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 17:19:44 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/a997dd66/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 73f31c5..7e2cefc 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
@@ -196,10 +196,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);
}