Flink从1.15.2升级至1.19.1后测试执行出现类加载问题

问题描述 #

将Flink版本从1.15.2升级到1.19.1后，测试执行抛出异常。测试环境为Java 1.8、PowerMock 2.0.2，使用PowerMock进行类Mock操作，报错信息如下：

org.apache.flink.util.FlinkException: Failed to execute job 'Flink Streaming Job'.
at flightRebooking.BoundLogicE2ETest.endToEndTest(E2ETest.java:93)
Caused by: java.lang.RuntimeException: org.apache.flink.runtime.client.JobInitializationException: Could not start the JobMaster.
Caused by: org.apache.flink.runtime.client.JobInitializationException: Could not start the JobMaster.
Caused by: java.util.concurrent.CompletionException: java.lang.ClassCastException: org.apache.flink.api.common.ExecutionConfig cannot be cast to org.apache.flink.api.common.ExecutionConfig
Caused by: java.lang.ClassCastException: org.apache.flink.api.common.ExecutionConfig cannot be cast to org.apache.flink.api.common.ExecutionConfig

问题根因 #

这种"相同类无法转换"的异常，本质是类加载器不一致导致的：
PowerMock通过自定义类加载器加载被Mock的类及相关依赖，而Flink 1.19.x版本调整了内部类加载机制，使得ExecutionConfig类被PowerMock的类加载器和Flink自身的类加载器分别加载。即便类的全限定名完全相同，JVM会因类加载器不同将它们视为不同类型，从而抛出类型转换异常。

解决方案 #

• 排除Flink核心类被PowerMock拦截：在测试类上添加@PowerMockIgnore("org.apache.flink.*")，让PowerMock不对Flink相关类使用自定义类加载器，避免类加载冲突。如果只想精确排除ExecutionConfig，可以写成@PowerMockIgnore("org.apache.flink.api.common.ExecutionConfig")。
• 升级PowerMock版本：PowerMock 2.0.2发布时间较早，对新版Flink的类加载场景适配不足。尝试升级到PowerMock 2.0.9或更高兼容Java 1.8的版本，新版本通常修复了更多类加载相关的兼容性问题。
• 替换测试方案：尽量避免Mock Flink核心类，改用Flink官方提供的MiniCluster等测试工具编写集成测试，从根源上规避PowerMock与Flink类加载器的冲突。

内容的提问来源于stack exchange，提问作者Hasintha Samith Randika