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/6cf78bcf Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/6cf78bcf Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/6cf78bcf Branch: refs/heads/sync Commit: 6cf78bcf10070910c7fd2a3eca888b7723e369fb Parents: b10eb7c Author: nichunen <chunen...@kyligence.io> Authored: Thu Jan 4 19:13:00 2018 +0800 Committer: Li Yang <liy...@apache.org> Committed: Fri Jan 26 17:32:46 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/6cf78bcf/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 cfe6fe2..761bb9a 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/6cf78bcf/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);
