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/c8c65294 Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/c8c65294 Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/c8c65294 Branch: refs/heads/2.x-staging Commit: c8c6529414cd28019dc92c719bdc9f69b22674c6 Parents: 1902da8 Author: lidongsjtu <lid...@apache.org> Authored: Wed Jan 20 15:27:58 2016 +0800 Committer: lidongsjtu <lid...@apache.org> Committed: Wed Jan 20 15:34:20 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/c8c65294/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 9c1d681..8da1519 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 @@ -83,7 +83,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();
