KYLIN-2384 fix compile with Kyro registration
Project: http://git-wip-us.apache.org/repos/asf/kylin/repo Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/e77a848e Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/e77a848e Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/e77a848e Branch: refs/heads/master-hbase0.98 Commit: e77a848e343f2e1f9a9382e336a48c85de25212a Parents: 4dce0cf Author: Li Yang <liy...@apache.org> Authored: Tue Feb 21 10:25:52 2017 +0800 Committer: Li Yang <liy...@apache.org> Committed: Tue Feb 21 10:25:52 2017 +0800 ---------------------------------------------------------------------- .../org/apache/kylin/engine/spark/KylinKryoRegistrator.java | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kylin/blob/e77a848e/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 20b39ee..daa1053 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 @@ -18,13 +18,14 @@ package org.apache.kylin.engine.spark; -import com.esotericsoftware.kryo.Kryo; +import java.util.LinkedHashSet; +import java.util.Set; + import org.apache.spark.serializer.KryoRegistrator; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import java.util.LinkedHashSet; -import java.util.Set; +import com.esotericsoftware.kryo.Kryo; /** * Registor for registering classes and serializers to Kryo @@ -163,7 +164,7 @@ public class KylinKryoRegistrator implements KryoRegistrator { kyroClasses.add(org.apache.kylin.dict.DictionaryInfo.class); kyroClasses.add(org.apache.kylin.dict.NumberDictionary.class); kyroClasses.add(org.apache.kylin.dict.NumberDictionary2.class); - kyroClasses.add(org.apache.kylin.dict.NumberDictionaryForestBuilder.Number2BytesConverter.class); + kyroClasses.add(org.apache.kylin.dict.Number2BytesConverter.class); kyroClasses.add(org.apache.kylin.dict.StringBytesConverter.class); kyroClasses.add(org.apache.kylin.dict.TimeStrDictionary.class); kyroClasses.add(org.apache.kylin.dict.TrieDictionary.class);