Hyno11 2022-04-08 17:24 采纳率: 57.1%
浏览 53
已结题

Flink on Yarn -- Session-cluster模式

问题遇到的现象和发生背景

Session-cluster模式能够正常 RUNNING
但是提交任务总是失败

问题相关代码,请勿粘贴截图

[hadoop@master ~]$ yarn-session.sh -n 1 -s 2 -jm 1024 -tm 1024 -nm session-cluster -d

[hadoop@master ~]$ flink run -c com.dylan.wc.StreamWordCount -p 1 /usr/local/src/flink/examples/batch/WordCount.jar
这里报错

运行结果及报错内容
2022-04-08 17:16:01,801 INFO  org.apache.flink.yarn.cli.FlinkYarnSessionCli                 - Found Yarn properties file under /tmp/.yarn-properties-hadoop.
2022-04-08 17:16:01,801 INFO  org.apache.flink.yarn.cli.FlinkYarnSessionCli                 - Found Yarn properties file under /tmp/.yarn-properties-hadoop.

------------------------------------------------------------
 The program finished with the following exception:

org.apache.flink.client.program.ProgramInvocationException: The program's entry point class 'com.dylan.wc.StreamWordCount' was not found in the jar file.
        at org.apache.flink.client.program.PackagedProgram.loadMainClass(PackagedProgram.java:422)
        at org.apache.flink.client.program.PackagedProgram.<init>(PackagedProgram.java:146)
        at org.apache.flink.client.program.PackagedProgram.<init>(PackagedProgram.java:68)
        at org.apache.flink.client.program.PackagedProgram$Builder.build(PackagedProgram.java:590)
        at org.apache.flink.client.cli.CliFrontend.buildProgram(CliFrontend.java:705)
        at org.apache.flink.client.cli.CliFrontend.run(CliFrontend.java:200)
        at org.apache.flink.client.cli.CliFrontend.parseParameters(CliFrontend.java:895)
        at org.apache.flink.client.cli.CliFrontend.lambda$main$10(CliFrontend.java:968)
        at java.security.AccessController.doPrivileged(Native Method)
        at javax.security.auth.Subject.doAs(Subject.java:422)
        at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1754)
        at org.apache.flink.runtime.security.HadoopSecurityContext.runSecured(HadoopSecurityContext.java:41)
        at org.apache.flink.client.cli.CliFrontend.main(CliFrontend.java:968)
Caused by: java.lang.ClassNotFoundException: com.dylan.wc.StreamWordCount
        at java.net.URLClassLoader.findClass(URLClassLoader.java:381)
        at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
        at org.apache.flink.util.ChildFirstClassLoader.loadClass(ChildFirstClassLoader.java:69)
        at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
        at java.lang.Class.forName0(Native Method)
        at java.lang.Class.forName(Class.java:348)
        at org.apache.flink.client.program.PackagedProgram.loadMainClass(PackagedProgram.java:420)
        ... 12 more


我的解答思路和尝试过的方法

img

img

我想要达到的结果

Session-cluster模式下提交任务

  • 写回答

1条回答 默认 最新

  • Tomshidi 2022-04-08 17:30
    关注

    检查com.dylan.wc.StreamWordCount这个类路径是否正确

    本回答被题主选为最佳回答 , 对您是否有帮助呢?
    评论

报告相同问题?

问题事件

  • 系统已结题 4月17日
  • 已采纳回答 4月9日
  • 创建了问题 4月8日

悬赏问题

  • ¥15 如何用Thoony写ESP32温湿度检测无源蜂鸣器报警代码?
  • ¥20 部件内部的CT图像数据集
  • ¥15 Visual studio调用动态库
  • ¥15 双目摄像头标定后的校准文件
  • ¥15 powerbi矩阵增加度量值后出现对应关系错乱
  • ¥30 频率分析法分析绘制奈奎斯特图、波特图
  • ¥15 弹出来一万个系统找不到指定的文件框框,怎么解决
  • ¥15 ADS生成的微带线为什么是蓝色空心的
  • ¥15 求一下解题思路,完全不懂
  • ¥15 tensorflow