java.lang.IncompatibleClassChangeError 当 运行 Flink table-api 集群上的程序

java.lang.IncompatibleClassChangeError When run Flink table-api program on cluster

我正在尝试 运行 我的 Flink table-api 程序在本地集群上,在那里我得到了这个错误,但在我的 IDE 中却没有,它可以正常工作,我试图使提供的依赖范围/编译没有区别。

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

我正在使用 Flink 1.8.0

有人可以帮我吗?提前致谢。

您确定您在依赖项和集群中使用的是一致的版本吗?像这样的异常通常表示混合了不同的 Flink 版本。