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);
             }

Reply via email to