You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by ma...@apache.org on 2015/11/05 10:32:51 UTC
incubator-kylin git commit: bug fix
Repository: incubator-kylin
Updated Branches:
refs/heads/KYLIN-1126 b6f6311bc -> 74536a8e6
bug fix
Project: http://git-wip-us.apache.org/repos/asf/incubator-kylin/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-kylin/commit/74536a8e
Tree: http://git-wip-us.apache.org/repos/asf/incubator-kylin/tree/74536a8e
Diff: http://git-wip-us.apache.org/repos/asf/incubator-kylin/diff/74536a8e
Branch: refs/heads/KYLIN-1126
Commit: 74536a8e6addde7155f050f2b4c7d60e5f7b29f4
Parents: b6f6311
Author: honma <ho...@ebay.com>
Authored: Thu Nov 5 17:37:40 2015 +0800
Committer: honma <ho...@ebay.com>
Committed: Thu Nov 5 17:37:40 2015 +0800
----------------------------------------------------------------------
.../org/apache/kylin/storage/hbase/steps/HBaseCuboidWriter.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/74536a8e/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/steps/HBaseCuboidWriter.java
----------------------------------------------------------------------
diff --git a/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/steps/HBaseCuboidWriter.java b/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/steps/HBaseCuboidWriter.java
index b63b1f3..31cce7b 100644
--- a/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/steps/HBaseCuboidWriter.java
+++ b/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/steps/HBaseCuboidWriter.java
@@ -94,7 +94,7 @@ public final class HBaseCuboidWriter implements ICuboidWriter {
//TODO:shardingonstreaming
private byte[] createKey(Long cuboidId, GTRecord record) {
- if (rowKeyEncoder.getCuboidID() != cuboidId) {
+ if (rowKeyEncoder == null || rowKeyEncoder.getCuboidID() != cuboidId) {
rowKeyEncoder = AbstractRowKeyEncoder.createInstance(cubeSegment, Cuboid.findById(cubeDesc, cuboidId));
keybuf = rowKeyEncoder.createBuf();
}