java.lang.IncompatibleClassChangeError在群集上运行Flink table-api程序时

Question

我试图在本地群集上运行我的Flink table-api程序，在此我收到此错误，但在我的IDE不能正常工作的地方，我试图使提供的依赖项范围/编译没有任何区别。

java.lang.IncompatibleClassChangeError: Found interface org.apache.flink.table.api.java.StreamTableEnvironment, but class was expected

我正在使用Flink 1.8.0

任何人都可以在这里帮助我吗？预先感谢。

Answer 1

您确定在依赖项和集群中使用的版本一致吗？诸如此类的异常通常表示混合使用了不同的Flink版本。