Thanks JingsongLee. You are right. I have registered all the implementation
class and it worked.
--
Sent from: http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/
Hi @Vijay Srinivasaraghavan, as far as I know, kryo need register all
implementation classes instead of abstract class or interface.
You can see the detail in
de.javakaffee.kryoserializers.guava.ImmutableMapSerializer.registerSerializers.
Maybe you can try do same thing to ExecutionConfig like
Hello,
I am using Flink 1.7.2. I wrote a small application which uses
KeyedProcessFunction to maintain application state. The state value object
is using Guava's (version 18.0.50) ImmutableMap to create a copy of the map
instance as part of its constructor.
I am using
