minor, fix massin coprocessor issue
Project: http://git-wip-us.apache.org/repos/asf/kylin/repo Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/6dcac61c Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/6dcac61c Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/6dcac61c Branch: refs/heads/1.5.x-HBase1.x Commit: 6dcac61c67a2bf0ddf42dc23fcc315e64bad830a Parents: 30f7a1c Author: lidongsjtu <lid...@apache.org> Authored: Wed May 4 18:45:51 2016 +0800 Committer: lidongsjtu <lid...@apache.org> Committed: Wed May 4 18:45:51 2016 +0800 ---------------------------------------------------------------------- .../hbase/cube/v2/filter/MassInValueProviderImpl.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kylin/blob/6dcac61c/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/cube/v2/filter/MassInValueProviderImpl.java ---------------------------------------------------------------------- diff --git a/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/cube/v2/filter/MassInValueProviderImpl.java b/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/cube/v2/filter/MassInValueProviderImpl.java index 47a14eb..78958ad 100644 --- a/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/cube/v2/filter/MassInValueProviderImpl.java +++ b/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/cube/v2/filter/MassInValueProviderImpl.java @@ -27,12 +27,12 @@ import org.apache.commons.io.IOUtils; import org.apache.commons.lang.StringUtils; import org.apache.hadoop.fs.FileSystem; import org.apache.hadoop.fs.Path; +import org.apache.hadoop.hbase.HBaseConfiguration; import org.apache.kylin.common.util.ByteArray; import org.apache.kylin.common.util.Pair; import org.apache.kylin.dimension.DimensionEncoding; import org.apache.kylin.metadata.filter.UDF.MassInValueProvider; import org.apache.kylin.metadata.filter.function.Functions; -import org.apache.kylin.storage.hbase.HBaseConnection; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -65,8 +65,8 @@ public class MassInValueProviderImpl implements MassInValueProvider { FileSystem fileSystem = null; try { synchronized (hdfs_caches) { - - fileSystem = FileSystem.get(HBaseConnection.getCurrentHBaseConfiguration()); + + fileSystem = FileSystem.get(HBaseConfiguration.create()); long modificationTime = fileSystem.getFileStatus(new Path(filterResourceIdentifier)).getModificationTime(); Pair<Long, Set<ByteArray>> cached = hdfs_caches.getIfPresent(filterResourceIdentifier); @@ -99,7 +99,7 @@ public class MassInValueProviderImpl implements MassInValueProvider { logger.info("Mass In values constructed after " + stopwatch.elapsedMillis() + " millis, containing " + ret.size() + " entries"); } - + } catch (IOException e) { throw new RuntimeException("error when loading the mass in values", e); }