ClassCastException after upgrading Flink application to 1.11.2

Hi, We have upgraded an application originally written for Flink 1.9.1 with Scala 2.11 to Flink 1.11.2 with Scala 2.12.7 and we are seeing the following error at runtime. 2021-03-16 20:37:08 java.lang.RuntimeException at

Flink upgrade causes operator to lose state

Hi, We are upgrading several applications from Flink 1.9.1 to 1.11.2. Some of the applications written with Table API are not able start from savepoint after the upgrade and fail with the following error. Caused by: java.lang.IllegalStateException: Failed to rollback to checkpoint/savepoint

Re: Flink 1.11.2 test cases fail with Scala 2.12.12

Thank you! I had scala-library 2.12.8 in my dependency tree (Probably a remnant from when I was testing with Scala 2.12.8). I did the following to fix this issue. Removed scala-library 2.12.8 from my dependency tree and added the below dependency. org.scala-lang scala-library

Re: Flink 1.11.2 test cases fail with Scala 2.12.12

Thank you for the response but this error continues to happen with Scala 2.12.7. The app itself continues to compile without errors but the test cases fail with the same error. Seems to be related to https://issues.apache.org/jira/browse/FLINK-12461 I have set the Scala version in pom.xml file