diff --git a/ql/src/java/org/apache/hadoop/hive/ql/exec/SerializationUtilities.java b/ql/src/java/org/apache/hadoop/hive/ql/exec/SerializationUtilities.java index b05a79e..277683e 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/exec/SerializationUtilities.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/exec/SerializationUtilities.java @@ -38,6 +38,7 @@ import org.apache.commons.lang3.tuple.Pair; import org.apache.hadoop.fs.Path; import org.apache.hadoop.hive.ql.CompilationOpContext; +import org.apache.hadoop.hive.ql.exec.vector.VectorFileSinkOperator; import org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat; import org.apache.hadoop.hive.ql.io.HiveSequenceFileOutputFormat; import org.apache.hadoop.hive.ql.io.RCFileInputFormat; @@ -233,6 +234,7 @@ public Kryo create() { kryo.register(TableDesc.class); kryo.register(UnionOperator.class); kryo.register(FileSinkOperator.class); + kryo.register(VectorFileSinkOperator.class); kryo.register(HiveIgnoreKeyTextOutputFormat.class); kryo.register(StandardConstantListObjectInspector.class); kryo.register(StandardConstantMapObjectInspector.class);