scala - Flink Word Count Example 缺少一个库

Question

我正在尝试使用 Flink 运行示例程序。我使用

下载了示例项目

mvn archetype:generate -DarchetypeGroupId=org.apache.flink -DarchetypeArtifactId=flink-quickstart-scala -DarchetypeVersion=0.8.1

然后我在终端上运行了下面的命令

mvn package && java -cp target/test-1.0-SNAPSHOT.jar adfin.WordCount

出现如下错误

Exception in thread "main" java.lang.NoClassDefFoundError: org/apache/flink/api/common/typeinfo/TypeInformation at adfin.WordCount.main(WordCount.scala) Caused by: java.lang.ClassNotFoundException: org.apache.flink.api.common.typeinfo.TypeInformation at java.net.URLClassLoader.findClass(URLClassLoader.java:381) at java.lang.ClassLoader.loadClass(ClassLoader.java:424) at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:331) at java.lang.ClassLoader.loadClass(ClassLoader.java:357)

我尝试将库从默认的 0.8.1 更新到 1.0.0，但这并没有改变任何东西。我想我可能需要添加一个额外的 jar 。有人可以帮忙吗？

Answer 1

示例项目的 Maven 配置在 provided 范围内使用 flink 依赖项。使用 mvn package 命令编译的 jar 文件被构建为提交给 flink 集群，而不是在独立模式下运行，因此它不包含 flink jar(因此 NoClassDefFoundError异常)。将 flink 库包含到您的类路径中，您的命令将正常运行。