Repository: kylin Updated Branches: refs/heads/master 2b07f2915 -> a9b0b6ed3
KYLIN-2592 Fix serialization issue for distinct count in Spark cubing 2 Signed-off-by: shaofengshi <shaofeng...@apache.org> Project: http://git-wip-us.apache.org/repos/asf/kylin/repo Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/a9b0b6ed Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/a9b0b6ed Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/a9b0b6ed Branch: refs/heads/master Commit: a9b0b6ed3de04dbc2395e44dd6f7241c466a3d8b Parents: 2b07f29 Author: kangkaisen <kangkai...@live.com> Authored: Mon Jun 26 22:08:57 2017 +0800 Committer: shaofengshi <shaofeng...@apache.org> Committed: Tue Jun 27 19:17:59 2017 +0800 ---------------------------------------------------------------------- .../java/org/apache/kylin/engine/spark/KylinKryoRegistrator.java | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kylin/blob/a9b0b6ed/engine-spark/src/main/java/org/apache/kylin/engine/spark/KylinKryoRegistrator.java ---------------------------------------------------------------------- diff --git a/engine-spark/src/main/java/org/apache/kylin/engine/spark/KylinKryoRegistrator.java b/engine-spark/src/main/java/org/apache/kylin/engine/spark/KylinKryoRegistrator.java index 6011ab2..106653f 100644 --- a/engine-spark/src/main/java/org/apache/kylin/engine/spark/KylinKryoRegistrator.java +++ b/engine-spark/src/main/java/org/apache/kylin/engine/spark/KylinKryoRegistrator.java @@ -96,6 +96,7 @@ public class KylinKryoRegistrator implements KryoRegistrator { addClassQuitely(kyroClasses, "com.google.common.collect.EmptyImmutableList"); addClassQuitely(kyroClasses, "java.nio.HeapShortBuffer"); + addClassQuitely(kyroClasses, "java.nio.HeapLongBuffer"); addClassQuitely(kyroClasses, "scala.collection.immutable.Map$EmptyMap$"); addClassQuitely(kyroClasses, "org.apache.spark.sql.catalyst.expressions.GenericInternalRow"); addClassQuitely(kyroClasses, "org.apache.spark.unsafe.types.UTF8String");
