Flink字数统计示例缺少库

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

我收到以下错误

线程“主要”中的异常java.lang.NoClassDefFoundError：adfin.WordCount.main（WordCount.scala）处的org / apache / flink / api / common / typeinfo / TypeInformation造成原因：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），位于java.lang.ClassLoader.loadClass（ClassLoader.java:357）

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

Answer 1

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