You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by sh...@apache.org on 2015/11/02 06:41:16 UTC

[1/2] incubator-kylin git commit: another NPE

Repository: incubator-kylin
Updated Branches:
  refs/heads/KYLIN-1112 138ad72ae -> 0f932072a


another NPE

Project: http://git-wip-us.apache.org/repos/asf/incubator-kylin/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-kylin/commit/9cf8c78a
Tree: http://git-wip-us.apache.org/repos/asf/incubator-kylin/tree/9cf8c78a
Diff: http://git-wip-us.apache.org/repos/asf/incubator-kylin/diff/9cf8c78a

Branch: refs/heads/KYLIN-1112
Commit: 9cf8c78a0fdf606da78f14e13b239a0fa4708356
Parents: 138ad72
Author: shaofengshi <sh...@apache.org>
Authored: Mon Nov 2 13:31:28 2015 +0800
Committer: shaofengshi <sh...@apache.org>
Committed: Mon Nov 2 13:31:28 2015 +0800

----------------------------------------------------------------------
 .../apache/kylin/engine/mr/invertedindex/InvertedIndexMapper.java | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/9cf8c78a/engine-mr/src/main/java/org/apache/kylin/engine/mr/invertedindex/InvertedIndexMapper.java
----------------------------------------------------------------------
diff --git a/engine-mr/src/main/java/org/apache/kylin/engine/mr/invertedindex/InvertedIndexMapper.java b/engine-mr/src/main/java/org/apache/kylin/engine/mr/invertedindex/InvertedIndexMapper.java
index 8247295..670972a 100644
--- a/engine-mr/src/main/java/org/apache/kylin/engine/mr/invertedindex/InvertedIndexMapper.java
+++ b/engine-mr/src/main/java/org/apache/kylin/engine/mr/invertedindex/InvertedIndexMapper.java
@@ -75,7 +75,8 @@ public class InvertedIndexMapper<KEYIN> extends KylinMapper<KEYIN, Object, LongW
         rec.reset();
         for (int i = 0; i < row.length; i++) {
             Object fieldValue = row[i];
-            rec.setValueString(i, fieldValue == null ? null : fieldValue.toString());
+            if (fieldValue != null)
+                rec.setValueString(i, fieldValue == null ? null : fieldValue.toString());
         }
 
         outputKey.set(rec.getTimestamp());


[2/2] incubator-kylin git commit: reduce base retries in sandbox setting

Posted by sh...@apache.org.
reduce base retries in sandbox setting

Project: http://git-wip-us.apache.org/repos/asf/incubator-kylin/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-kylin/commit/0f932072
Tree: http://git-wip-us.apache.org/repos/asf/incubator-kylin/tree/0f932072
Diff: http://git-wip-us.apache.org/repos/asf/incubator-kylin/diff/0f932072

Branch: refs/heads/KYLIN-1112
Commit: 0f932072a61bd2e3f9052dcbae2c15a23a1b38cd
Parents: 9cf8c78
Author: shaofengshi <sh...@apache.org>
Authored: Mon Nov 2 13:40:58 2015 +0800
Committer: shaofengshi <sh...@apache.org>
Committed: Mon Nov 2 13:40:58 2015 +0800

----------------------------------------------------------------------
 examples/test_case_data/sandbox/hbase-site.xml | 19 ++++++++++++++++++-
 1 file changed, 18 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/0f932072/examples/test_case_data/sandbox/hbase-site.xml
----------------------------------------------------------------------
diff --git a/examples/test_case_data/sandbox/hbase-site.xml b/examples/test_case_data/sandbox/hbase-site.xml
index 06755a8..8d763f9 100644
--- a/examples/test_case_data/sandbox/hbase-site.xml
+++ b/examples/test_case_data/sandbox/hbase-site.xml
@@ -175,5 +175,22 @@
         <name>zookeeper.znode.parent</name>
         <value>/hbase-unsecure</value>
     </property>
-
+    <property>
+        <name>hbase.client.pause</name>
+        <value>100</value>
+        <description>General client pause value.  Used mostly as value to wait
+            before running a retry of a failed get, region lookup, etc.
+            See hbase.client.retries.number for description of how we backoff from
+            this initial pause amount and how this pause works w/ retries.</description>
+    </property>
+    <property>
+        <name>hbase.client.retries.number</name>
+        <value>5</value>
+        <description>Maximum retries.  Used as maximum for all retryable
+            operations such as the getting of a cell's value, starting a row update,
+            etc.  Retry interval is a rough function based on hbase.client.pause.  At
+            first we retry at this interval but then with backoff, we pretty quickly reach
+            retrying every ten seconds.  See HConstants#RETRY_BACKOFF for how the backup
+            ramps up.  Change this setting and hbase.client.pause to suit your workload.</description>
+    </property>
 </configuration>