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

以下命令我得到了以下错误

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，但这并没有改变任何东西。我想可能会有一个额外的瓶子，我不得不添加。任何人都可以帮忙吗？

Answer 1

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