Repository: kylin Updated Branches: refs/heads/2.0-rc d3b30e65d -> 5f7f3a750
KYLIN-1346 Fix IllegalStateException issue in SparkCubing Project: http://git-wip-us.apache.org/repos/asf/kylin/repo Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/5f7f3a75 Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/5f7f3a75 Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/5f7f3a75 Branch: refs/heads/2.0-rc Commit: 5f7f3a7509776e61a324a974ec4e61306733f1a0 Parents: d3b30e6 Author: lidongsjtu <lid...@apache.org> Authored: Wed Jan 20 15:27:58 2016 +0800 Committer: lidongsjtu <lid...@apache.org> Committed: Wed Jan 20 15:27:58 2016 +0800 ---------------------------------------------------------------------- .../org/apache/kylin/engine/spark/cube/DefaultTupleConverter.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kylin/blob/5f7f3a75/engine-spark/src/main/java/org/apache/kylin/engine/spark/cube/DefaultTupleConverter.java ---------------------------------------------------------------------- diff --git a/engine-spark/src/main/java/org/apache/kylin/engine/spark/cube/DefaultTupleConverter.java b/engine-spark/src/main/java/org/apache/kylin/engine/spark/cube/DefaultTupleConverter.java index 6b3a82c..b932c59 100644 --- a/engine-spark/src/main/java/org/apache/kylin/engine/spark/cube/DefaultTupleConverter.java +++ b/engine-spark/src/main/java/org/apache/kylin/engine/spark/cube/DefaultTupleConverter.java @@ -84,7 +84,7 @@ public final class DefaultTupleConverter implements TupleConverter { } byte[] rowKey = rowkeyEncoder.createBuf(); - rowkeyEncoder.encode(new ByteArray(rowKeyBodyBuf), new ByteArray(rowKey)); + rowkeyEncoder.encode(new ByteArray(rowKeyBodyBuf, 0, offSet), new ByteArray(rowKey)); ByteBuffer valueBuf = getValueBuf(); valueBuf.clear();
