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-CDH5.7 Commit: b24b7e642e7c7cf06744f5329bc1aa55624b64e4 Parents: 60a7c74 Author: shaofengshi <shaofeng...@apache.org> Authored: Fri May 20 07:33:41 2016 +0800 Committer: lidongsjtu <lid...@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); }
