Hi, which version of Flink are you using?
Can you send us the complete stack trace of the error to help us understand the exact location where the issue occurs? On Wed, Apr 22, 2015 at 4:33 PM, Ventura Del Monte < venturadelmo...@gmail.com> wrote: > Hello, I am working on a flink-based deep learning library for my master's > thesis. I am experiencing this issue at the moment: I have a java class > with a transient field, so I had to write both a kryo custom serializer and > a java one. The (de)serialization needs to access another object of my > system, so if I run my software locally it works fine because the needed > object is instantiated meanwhile it crashes when I run it in a remote > environment because when the jobmanager receives the data, the object > needed for the deserialization is not present in the system. Thus, my > question is whether it is possible to let the jobmanager execute some user > code or would it be better to edit the architecture of my system in order > to avoid this kind of problem? > > Regards, > Ventura >
