You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by li...@apache.org on 2018/02/04 00:51:10 UTC
[07/50] [abbrv] kylin git commit: Make some hbase config items
configurable at kylin.properties
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 <ch...@kyligence.io>
Authored: Thu Jan 4 19:13:00 2018 +0800
Committer: Li Yang <li...@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);