Make some hbase config items configurable at kylin.properties
Project: http://git-wip-us.apache.org/repos/asf/kylin/repo Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/8e8d71b9 Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/8e8d71b9 Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/8e8d71b9 Branch: refs/heads/sync Commit: 8e8d71b99a340831512f7ca34cbc0098a190f1f6 Parents: 2ef3d49 Author: nichunen <chunen...@kyligence.io> Authored: Thu Jan 4 19:13:00 2018 +0800 Committer: Li Yang <liy...@apache.org> Committed: Fri Jan 26 22:54:58 2018 +0800 ---------------------------------------------------------------------- .../java/org/apache/kylin/common/KylinConfigBase.java | 12 ++++++++++++ .../apache/kylin/storage/hbase/HBaseResourceStore.java | 6 +++--- 2 files changed, 15 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kylin/blob/8e8d71b9/core-common/src/main/java/org/apache/kylin/common/KylinConfigBase.java ---------------------------------------------------------------------- diff --git a/core-common/src/main/java/org/apache/kylin/common/KylinConfigBase.java b/core-common/src/main/java/org/apache/kylin/common/KylinConfigBase.java index 4c8a3f8..8efd260 100644 --- a/core-common/src/main/java/org/apache/kylin/common/KylinConfigBase.java +++ b/core-common/src/main/java/org/apache/kylin/common/KylinConfigBase.java @@ -358,6 +358,18 @@ abstract public class KylinConfigBase implements Serializable { return Boolean.parseBoolean(getOptional("kylin.metadata.check-copy-on-write", "false")); } + public String getHbaseClientScannerTimeoutPeriod() { + return getOptional("kylin.metadata.hbase-client-scanner-timeout-period", "10000"); + } + + public String getHbaseRpcTimeout() { + return getOptional("kylin.metadata.hbase-rpc-timeout", "5000"); + } + + public String getHbaseClientRetriesNumber() { + return getOptional("kylin.metadata.hbase-client-retries-number", "1"); + } + // ============================================================================ // DICTIONARY & SNAPSHOT // ============================================================================ http://git-wip-us.apache.org/repos/asf/kylin/blob/8e8d71b9/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/HBaseResourceStore.java ---------------------------------------------------------------------- diff --git a/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/HBaseResourceStore.java b/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/HBaseResourceStore.java index 433a03c..1f83e3e 100644 --- a/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/HBaseResourceStore.java +++ b/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/HBaseResourceStore.java @@ -99,9 +99,9 @@ public class HBaseResourceStore extends ResourceStore { // control timeout for prompt error report Map<String, String> newParams = new LinkedHashMap<>(); - newParams.put("hbase.client.scanner.timeout.period", "10000"); - newParams.put("hbase.rpc.timeout", "5000"); - newParams.put("hbase.client.retries.number", "1"); + newParams.put("hbase.client.scanner.timeout.period", kylinConfig.getHbaseClientScannerTimeoutPeriod()); + newParams.put("hbase.rpc.timeout", kylinConfig.getHbaseRpcTimeout()); + newParams.put("hbase.client.retries.number", kylinConfig.getHbaseClientRetriesNumber()); newParams.putAll(url.getAllParameters()); return url.copy(newParams);
