You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by ka...@apache.org on 2017/06/09 09:39:49 UTC
kylin git commit: KYLIN-2647 Should get FileSystem from
HBaseConfiguration in HBaseResourceStore
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 <ka...@live.com>
Authored: Thu May 25 20:45:19 2017 +0800
Committer: kangkaisen <ka...@live.com>
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);