Hi Shridhar,
the exception indicates that something is wrong with the object
serialization. Kryo is unable to serialize the given object.
It might help to
1) register a custom Kryo serializer in the ExecutionConfig or
2 ) pass dedicated type information using the types from
All,
We are getting the exception, copied at the end of this post. The exception
is thrown when a new flink job is submitted; when Flink tries to restore
the previous state.
Environment:
Flink version: 1.10.1
State persistence: Hadoop 3.3
Zookeeper 3.5.8
Parallelism: 4
The code
