Hi, A ClassNotFoundException should not be expected behavior. Can you post the stacktrace of the exception?
We had a few issues in the past where Flink didn't use the correct classloader. So this would not be an unusual bug. Thanks, Fabian 2017-12-07 10:44 GMT+01:00 Tugdual Grall <tugd...@gmail.com>: > ok > > On Thu, Dec 7, 2017 at 10:35 AM, romain.jln <romain....@gmail.com> wrote: > >> Hi all, >> >> I am experiencing some problems with a custom source that I have >> implemented. I am getting some ClassNotFoundException randomly during the >> execution of the job meanwhile the fat jar submitted to Flink contains the >> given classes. >> >> After several hours of investigation, I think I have been able to narrow >> down the potential cause. >> >> Currently, it seems that the thread executing the cancel method of my >> source >> function is not using the normal FlinkUserCodeClassLoader but rather the >> AppClassLoader which seems to cause those ClassNotFoundExceptions. >> >> I wanted to know if this behaviour was expected or if it was actually a >> bug. >> >> Thanks ! >> >> >> >> -- >> Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4. >> nabble.com/ >> > >
