在EMR上部署flink应用程序时出错

Question

在EMR上部署flink应用程序时出现此错误

Exception in thread "main" java.lang.NoClassDefFoundError: org/apache/flink/api/common/serialization/DeserializationSchema
    at java.lang.Class.forName0(Native Method)
    at java.lang.Class.forName(Class.java:348)
    at org.apache.hadoop.util.RunJar.run(RunJar.java:232)

不过，当我在本地集群上部署时，它工作得很好。我在EMR版本5.28.0上使用flink 1.9.0

Answer 1

这个问题可以与多个不同的事情联系在一起。需要检查的内容包括：

Flink in依赖项与EMR上的Flink之间的

1. 版本不匹配。
2. 应提供Flink的核心依赖项。不会与群集上可用的依赖项发生冲突。

Answer 2

您的JDK版本是什么？有没有可能是环境出了问题？我认为JDK版本很可能不匹配。