Details
-
Bug
-
Status: Closed
-
Critical
-
Resolution: Won't Fix
-
None
Description
Currently, Spark Avro serializer/deserializer has a bug that it will return the same object when we call this method twice continuously. For example:
val row1: InternalRow = ...
val row2: InternalRow = ... // record2 is different with record1
val serializeredRecord1 = serialize(row1)
val serializeredRecord2 = serialize(row2)
serializeredRecord1.equals(serializeredRecord2)
That is because we use the `val` to declare the serializer/deserializer methods, so the latter's result will cover the previous one.