kylin-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From lid...@apache.org
Subject [3/8] kylin git commit: KYLIN-1323 a bug in hbase read-write separation mode
Date Tue, 24 May 2016 06:09:56 GMT
KYLIN-1323 a bug in hbase read-write separation mode


Project: http://git-wip-us.apache.org/repos/asf/kylin/repo
Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/b24b7e64
Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/b24b7e64
Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/b24b7e64

Branch: refs/heads/1.5.x-HBase1.x
Commit: b24b7e642e7c7cf06744f5329bc1aa55624b64e4
Parents: 60a7c74
Author: shaofengshi <shaofengshi@apache.org>
Authored: Fri May 20 07:33:41 2016 +0800
Committer: lidongsjtu <lidong@apache.org>
Committed: Fri May 20 02:45:03 2016 +0000

----------------------------------------------------------------------
 .../org/apache/kylin/storage/hbase/steps/CreateHTableJob.java    | 4 +---
 1 file changed, 1 insertion(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kylin/blob/b24b7e64/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/steps/CreateHTableJob.java
----------------------------------------------------------------------
diff --git a/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/steps/CreateHTableJob.java
b/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/steps/CreateHTableJob.java
index e1f8818..29bcb62 100644
--- a/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/steps/CreateHTableJob.java
+++ b/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/steps/CreateHTableJob.java
@@ -31,7 +31,6 @@ import org.apache.hadoop.fs.FileSystem;
 import org.apache.hadoop.fs.Path;
 import org.apache.hadoop.hbase.io.ImmutableBytesWritable;
 import org.apache.hadoop.io.*;
-import org.apache.hadoop.mapreduce.Reducer;
 import org.apache.hadoop.util.ReflectionUtils;
 import org.apache.hadoop.util.StringUtils;
 import org.apache.hadoop.util.ToolRunner;
@@ -49,7 +48,6 @@ import org.apache.kylin.engine.mr.HadoopUtil;
 import org.apache.kylin.engine.mr.common.AbstractHadoopJob;
 import org.apache.kylin.engine.mr.common.CubeStatsReader;
 import org.apache.kylin.engine.mr.common.CuboidShardUtil;
-import org.apache.kylin.metadata.model.DataModelDesc;
 import org.apache.kylin.metadata.model.SegmentStatusEnum;
 import org.apache.kylin.storage.hbase.HBaseConnection;
 import org.slf4j.Logger;
@@ -282,7 +280,7 @@ public class CreateHTableJob extends AbstractHadoopJob {
             return;
         }
 
-        FileSystem fs = FileSystem.get(HadoopUtil.getCurrentConfiguration());
+        FileSystem fs = FileSystem.get(HBaseConnection.getCurrentHBaseConfiguration());
         if (fs.exists(outputFolder) == false) {
             fs.mkdirs(outputFolder);
         }


Mime
View raw message