flink 从 1.15.2 升级到 1.19.1 后运行测试时出现类加载问题

Question

当flink版本从1.15.2升级到1.19.1时。存在测试执行问题。我们正在使用 powermock 来模拟测试中的类 java版本1.8 电源模拟 2.0.2

错误是

org.apache.flink.util.FlinkException：无法执行作业“Flink Streaming Job”。 在 FlightRebooking.BoundLogicE2ETest.endToEndTest(E2ETest.java:93) 引起原因：java.lang.RuntimeException：org.apache.flink.runtime.client.JobInitializationException：无法启动JobMaster。 原因：org.apache.flink.runtime.client.JobInitializationException：无法启动JobMaster。 引起原因：java.util.concurrent.CompletionException：java.lang.ClassCastException：org.apache.flink.api.common.ExecutionConfig无法转换为org.apache.flink.api.common.ExecutionConfig 引起原因：java.lang.ClassCastException：org.apache.flink.api.common.ExecutionConfig无法转换为org.apache.flink.api.common.ExecutionConfig

Answer 1

如果在测试配置中引入 Powermock，Flink 似乎会出现类加载问题。 看一下这个发布的问题使用 Powermock 时的类加载问题。 Flink 提供了一个很好的测试工具，并讨论了如何模拟对象。 请查看他们的单元测试指南。