Repository: kylin Updated Branches: refs/heads/master c21dca5c7 -> 444013b4b
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/c96f8274 Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/c96f8274 Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/c96f8274 Branch: refs/heads/master Commit: c96f8274a40782d1b9b151edeb48a37d5149f88c Parents: c21dca5 Author: shaofengshi <shaofeng...@apache.org> Authored: Fri May 20 07:33:41 2016 +0800 Committer: shaofengshi <shaofeng...@apache.org> Committed: Fri May 20 07:34:39 2016 +0800 ---------------------------------------------------------------------- .../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/c96f8274/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); }
