KryoSerializer is used for List type instead of ListSerializer

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

KryoSerializer is used for List type instead of ListSerializer

spoganshev
The following code:

val MAILBOX_SET_TYPE_INFO = object: TypeHint<List&lt;Mailbox>>() {}.typeInfo
val env = StreamExecutionEnvironment.getExecutionEnvironment()
println(MAILBOX_SET_TYPE_INFO.createSerializer(env.config))

prints:

org.apache.flink.api.java.typeutils.runtime.kryo.KryoSerializer@2c39e53

While there exists a specialized ListSerializer. Why is Kryo used in this
case?



--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/