Hello, Yuri's description of the issue is spot on. We are running our cluster on YARN and using Avro for serialization, exactly as described.
@Ufuk, I'm running my Cluster on YARN, 4 Task Managers with 2 slots each but this particular job has parallelism 1. @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-on-ClassCastException-when-re-submitting-a-job-tp10972p11152.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.