The following code:
val MAILBOX_SET_TYPE_INFO = object: TypeHint<List<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/