Hi,
I think the problem here is that the SerializationUtils don't use the correct
ClassLoader when deserialising. When running a Flink job on a cluster the user
code (from the user-code jar) is only available in the user-code ClassLoader.
If you can pass a ClassLoader to your deserialize
Hi Paolo,
do you get the ClassNotFoundException for TheGlobalModel or for another
class?
Did you maybe forget to include SerializationUtils in the classpath?
Best, Fabian
2017-07-26 16:14 GMT+02:00 Paolo Cristofanelli <
cristofanelli.pa...@gmail.com>:
> Hi,
>
> I am trying to write and read in
Hi,
I am trying to write and read in a Kafka topic a user-defined class (that
implements serializable, and all the fields are serializable).
Everything works fine when I am executing the program in the IDE or with
the mvn exec command.
When I try to execute the program in standalone mode I get
