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/ >
