From 3bc0baa1a46f109289af797ba066863bec9cf066 Mon Sep 17 00:00:00 2001 From: kangkaisen Date: Mon, 26 Jun 2017 22:08:57 +0800 Subject: [PATCH] KYLIN-2592 Fix serialization issue for distinct count in Spark cubing 2 --- .../main/java/org/apache/kylin/engine/spark/KylinKryoRegistrator.java | 1 + 1 file changed, 1 insertion(+) 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 6011ab242..106653fdd 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"); -- 2.11.0 (Apple Git-81)