开发者社区> 问答> 正文

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

目前我正在尝试运行我的第一个flink应用程序。我已经在IDE中测试了java文件(KMeans.java)它工作得很好但是我无法处理这个java文件在命令行中作为jar运行。已成功创建构建mvn clean package。但是,如果我在命令行中运行我的jar文件,flink run -c KMeans name.jar 则会显示以下错误消息:

该程序以以下异常结束:

org.apache.flink.client.program.ProgramInvocationException:在jar文件中找不到程序的入口点类'KMeans'。org.apache.flink.client.program.PackagedProgram.loadMainClass(PackagedProgram.java:617)位于org.apache.fack.client.client的org.apache.flink.client.program.PackagedProgram。(PackagedProgram.java:199)。 cli.CliFrontend.buildProgram(CliFrontend.java:856)atg.apache.flink.client.cli.CliFrontend.run(CliFrontend.java:206)at org.apache.flink.client.cli.CliFrontend.parseParameters(CliFrontend。 java:1044)at org.apache.flink.client.cli.CliFrontend.lambda $ main $ 11(CliFrontend.java:1120)at java.security.AccessController.doPrivileged(Native Method)at javax.security.auth.Subject.doAs (Subject.java:422)位于org.apache.hadoop.security.UserGroupInformation。

所以我查找了生成的目标文件夹,并在classes文件夹中有一个KMeans.class文件。所以我这样做错了?

展开
收起
flink小助手 2018-12-10 13:13:41 7113 0
1 条回答
写回答
取消 提交回答
  • flink小助手会定期更新直播回顾等资料和文章干货,还整合了大家在钉群提出的有关flink的问题及回答。

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

    请注意,如果JAR文件未指定要在其清单中运行的类,则只需使用-c标志

    2019-07-17 23:19:11
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Flink CDC Meetup PPT - 龚中强 立即下载
Flink CDC Meetup PPT - 王赫 立即下载
Flink CDC Meetup PPT - 覃立辉 立即下载

相关镜像