macos - 在 apache flink 中运行生成的 jar 文件

Question

目前我正在尝试运行我的第一个 flink 应用程序。我已经在 IDE 中测试了 java 文件 (KMeans.java)，它运行良好，但我无法在命令行中将此 java 文件作为 jar 运行。
使用 mvn clean package 成功创建了构建版本.
但是如果我在命令行中运行我的 jar 文件 flink run -c KMeans name.jar出现此错误消息:

The program finished with the following exception:

org.apache.flink.client.program.ProgramInvocationException: Theprogram's entry point class 'KMeans' was not found in the jar file.atorg.apache.flink.client.program.PackagedProgram.loadMainClass(PackagedProgram.java:617)atorg.apache.flink.client.program.PackagedProgram.(PackagedProgram.java:199)atorg.apache.flink.client.cli.CliFrontend.buildProgram(CliFrontend.java:856)at org.apache.flink.client.cli.CliFrontend.run(CliFrontend.java:206)atorg.apache.flink.client.cli.CliFrontend.parseParameters(CliFrontend.java:1044)atorg.apache.flink.client.cli.CliFrontend.lambda$main$11(CliFrontend.java:1120)at java.security.AccessController.doPrivileged(Native Method) atjavax.security.auth.Subject.doAs(Subject.java:422) atorg.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1754)atorg.apache.flink.runtime.security.HadoopSecurityContext.runSecured(HadoopSecurityContext.java:41)atorg.apache.flink.client.cli.CliFrontend.main(CliFrontend.java:1120)Caused by: java.lang.ClassNotFoundException: KMeans atjava.net.URLClassLoader.findClass(URLClassLoader.java:381) atjava.lang.ClassLoader.loadClass(ClassLoader.java:424) atjava.lang.ClassLoader.loadClass(ClassLoader.java:357) atjava.lang.Class.forName0(Native Method) atjava.lang.Class.forName(Class.java:348) atorg.apache.flink.client.program.PackagedProgram.loadMainClass(PackagedProgram.java:614)... 10 more

所以我查找了我生成的目标文件夹，在 classes 文件夹中有一个 KMeans.class 文件。所以我做错了吗？

Answer 1

您需要指定完整的类名，例如，org.apache.flink.examples.java.clustering.KMeans .

请注意，仅当 JAR 文件未指定要在其 list 中运行的类时，才需要使用 -c 标志。