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/04318ed1 Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/04318ed1 Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/04318ed1 Branch: refs/heads/1.5.x-CDH5.7 Commit: 04318ed10d758c075030b29f0a4a8a777c0f812f Parents: 445d458 Author: Li Yang <liy...@apache.org> Authored: Thu May 26 14:00:01 2016 +0800 Committer: lidongsjtu <lid...@apache.org> Committed: Mon May 30 18:10:54 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/04318ed1/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/04318ed1/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) {
