Repository: kylin Updated Branches: refs/heads/v1.5.2.1-release-rc1 [created] a1d17e215
KYLIN-1739 Do not cache and reuse hadoop configuration in HadoopUtil Project: http://git-wip-us.apache.org/repos/asf/kylin/repo Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/0860934f Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/0860934f Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/0860934f Branch: refs/heads/v1.5.2.1-release-rc1 Commit: 0860934f8bf7e30256d2c59c862c63d6b77d87ed Parents: af2646b Author: Li Yang <liy...@apache.org> Authored: Thu May 26 14:00:01 2016 +0800 Committer: shaofengshi <shaofeng...@apache.org> Committed: Fri Jun 3 18:30:47 2016 +0800 ---------------------------------------------------------------------- .../src/main/java/org/apache/kylin/engine/mr/HadoopUtil.java | 3 +-- .../apache/kylin/storage/hbase/cube/v2/CubeHBaseEndpointRPC.java | 2 +- 2 files changed, 2 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kylin/blob/0860934f/engine-mr/src/main/java/org/apache/kylin/engine/mr/HadoopUtil.java ---------------------------------------------------------------------- diff --git a/engine-mr/src/main/java/org/apache/kylin/engine/mr/HadoopUtil.java b/engine-mr/src/main/java/org/apache/kylin/engine/mr/HadoopUtil.java index 9ce2bab..c638d99 100644 --- a/engine-mr/src/main/java/org/apache/kylin/engine/mr/HadoopUtil.java +++ b/engine-mr/src/main/java/org/apache/kylin/engine/mr/HadoopUtil.java @@ -41,8 +41,7 @@ public class HadoopUtil { public static Configuration getCurrentConfiguration() { if (hadoopConfig.get() == null) { Configuration conf = healSickConfig(new Configuration()); - - hadoopConfig.set(conf); + return conf; } return hadoopConfig.get(); } http://git-wip-us.apache.org/repos/asf/kylin/blob/0860934f/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/cube/v2/CubeHBaseEndpointRPC.java ---------------------------------------------------------------------- diff --git a/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/cube/v2/CubeHBaseEndpointRPC.java b/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/cube/v2/CubeHBaseEndpointRPC.java index 12b1fa8..f04d46e 100644 --- a/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/cube/v2/CubeHBaseEndpointRPC.java +++ b/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/cube/v2/CubeHBaseEndpointRPC.java @@ -90,7 +90,7 @@ public class CubeHBaseEndpointRPC extends CubeHBaseRPC { this.expectedSize = expectedSize; this.queue = new ArrayBlockingQueue<byte[]>(expectedSize); - this.timeout = HadoopUtil.getCurrentConfiguration().getInt(HConstants.HBASE_RPC_TIMEOUT_KEY, HConstants.DEFAULT_HBASE_RPC_TIMEOUT); + this.timeout = HBaseConnection.getCurrentHBaseConfiguration().getInt(HConstants.HBASE_RPC_TIMEOUT_KEY, HConstants.DEFAULT_HBASE_RPC_TIMEOUT); this.timeout *= KylinConfig.getInstanceFromEnv().getCubeVisitTimeoutTimes(); if (BackdoorToggles.getQueryTimeout() != -1) {
