Repository: kylin Updated Branches: refs/heads/master f9957f1be -> f65e8cb5e
KYLIN-2647 Should get FileSystem from HBaseConfiguration in HBaseResourceStore Project: http://git-wip-us.apache.org/repos/asf/kylin/repo Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/f65e8cb5 Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/f65e8cb5 Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/f65e8cb5 Branch: refs/heads/master Commit: f65e8cb5ef56c71d1b9c76a8b1f8b3162fa80959 Parents: f9957f1 Author: kangkaisen <[email protected]> Authored: Thu May 25 20:45:19 2017 +0800 Committer: kangkaisen <[email protected]> Committed: Fri Jun 9 17:41:46 2017 +0800 ---------------------------------------------------------------------- .../org/apache/kylin/storage/hbase/HBaseResourceStore.java | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kylin/blob/f65e8cb5/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/HBaseResourceStore.java ---------------------------------------------------------------------- diff --git a/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/HBaseResourceStore.java b/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/HBaseResourceStore.java index 615c845..ccbcde8 100644 --- a/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/HBaseResourceStore.java +++ b/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/HBaseResourceStore.java @@ -56,7 +56,6 @@ import org.apache.kylin.common.persistence.ResourceStore; import org.apache.kylin.common.persistence.StringEntity; import org.apache.kylin.common.util.Bytes; import org.apache.kylin.common.util.BytesUtil; -import org.apache.kylin.common.util.HadoopUtil; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -248,7 +247,7 @@ public class HBaseResourceStore extends ResourceStore { byte[] value = r.getValue(B_FAMILY, B_COLUMN); if (value.length == 0) { Path redirectPath = bigCellHDFSPath(resPath); - FileSystem fileSystem = HadoopUtil.getWorkingFileSystem(); + FileSystem fileSystem = FileSystem.get(HBaseConnection.getCurrentHBaseConfiguration()); try { return fileSystem.open(redirectPath); @@ -341,7 +340,7 @@ public class HBaseResourceStore extends ResourceStore { if (hdfsResourceExist) { // remove hdfs cell value Path redirectPath = bigCellHDFSPath(resPath); - FileSystem fileSystem = HadoopUtil.getWorkingFileSystem(); + FileSystem fileSystem = FileSystem.get(HBaseConnection.getCurrentHBaseConfiguration()); if (fileSystem.exists(redirectPath)) { fileSystem.delete(redirectPath, true); @@ -389,7 +388,7 @@ public class HBaseResourceStore extends ResourceStore { private Path writeLargeCellToHdfs(String resPath, byte[] largeColumn, Table table) throws IOException { Path redirectPath = bigCellHDFSPath(resPath); - FileSystem fileSystem = HadoopUtil.getWorkingFileSystem(); + FileSystem fileSystem = FileSystem.get(HBaseConnection.getCurrentHBaseConfiguration()); if (fileSystem.exists(redirectPath)) { fileSystem.delete(redirectPath, true);
