Re: How to get help on ClassCastException when re-submitting a job

Quick update: I've closed the issue after confirming that Yuri's workaround fixed it for us. -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/How-to-get-help-on-ClassCastException-when-re-submitting-a-job-tp10972p11374.html Sen

Re: How to get help on ClassCastException when re-submitting a job

050.n4.nabble.com/How-to-get-help- > on-ClassCastException-when-re-submitting-a-job-tp10972p11277.html > Sent from the Apache Flink User Mailing List archive. mailing list archive > at Nabble.com. >

Re: How to get help on ClassCastException when re-submitting a job

Issue reported: https://issues.apache.org/jira/browse/FLINK-5633 Sorry for taking so long -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/How-to-get-help-on-ClassCastException-when-re-submitting-a-job-tp10972p11277.html Sent from the

Re: How to get help on ClassCastException when re-submitting a job

gt; > @Yuri, I'll test your fix as soon as I can and report back. > > @Fabian, do you still want me to open the issue? > > Cheers, > > > > -- > View this message in context: http://apache-flink-user- > mailing-list-archive.2336050.n4.nabble.com/How-to-get-help-

Re: How to get help on ClassCastException when re-submitting a job

our fix as soon as I can and report back. @Fabian, do you still want me to open the issue? Cheers, -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/How-to-get-help-on-ClassCastException-when-re-submitting-a-job-tp10972p11152.html Sent from t

Re: How to get help on ClassCastException when re-submitting a job

For my case I tracked down the culprit. It's been Avro indeed. I'm providing details below, since I believe the pattern is pretty common for such issues. In YARN setup there are several sources where classes are loaded from: Flink lib directory, YARN lib directories, user code. The first two sourc

Re: How to get help on ClassCastException when re-submitting a job

Hi! I think Yury pointed out the correct diagnosis. Caching the classes across multiple jobs in the same session can cause these types of issues. For YARN single-job deployments, Flink 1.2 will not to any dynamic classloading any more, but start with everything in the application classpath. For Y

Re: How to get help on ClassCastException when re-submitting a job

@Giuliano: any updates? Very curious to figure out what's causing this. As Fabian said, this is most likely a class loading issue. Judging from the stack trace, you are not running with YARN but a standalone cluster. Is that correct? Class loading wise nothing changed between Flink 1.1 and Flink 1.

Re: How to get help on ClassCastException when re-submitting a job

Hi, I'd like to chime in since I've faced the same issue running Flink 1.1.4. I have a long-running YARN session which I use to run multiple streaming jobs concurrently. Once after cancelling and resubmitting the job I saw the "X cannot be cast to X" ClassCastException exception in logs. I restart

Re: How to get help on ClassCastException when re-submitting a job

Hi Guiliano, thanks for bringing up this issue. A "ClassCastException: X cannot be cast to X" often points to a classloader issue. So it might actually be a bug in Flink. I assume you submit the same application (same jar file) with the same command right? Did you cancel the job before resubmitti

How to get help on ClassCastException when re-submitting a job

Hello, I need some guidance on how to report a bug. I’m testing version 1.2 on my local cluster and the first time I submit the job everything works but whenever I re-submit the same job it fails with org.apache.flink.client.program.ProgramInvocationException: The program execution failed: J