开发者社区 > 大数据与机器学习 > 实时计算 Flink > 正文

windows环境下IDEA本地通过java API 向yarn上提交Flink per_job 任

windows环境下IDEA本地通过java API 向yarn上提交Flink per_job 任务失败,jobmanager.err 里面显示: Error: Could not find or load main class org.apache.flink.yarn.entrypoint.YarnJobClusterEntrypoint

哪位大佬知道是为什么 ?

展开
收起
大圣东游 2023-02-24 12:31:25 1385 0
5 条回答
写回答
取消 提交回答
  • 我遇到过同样的问题,当我处于绝望的时候,看到有人在linux或者mac上运行成功了,在windows上运行一直加载不到主类。
    https://github.com/zhangjun0x01/bigdata-examples/issues/10
    具体请参考这篇回复。 解决了我一天的研究,后期准备把环境切到linux开发。

    2023-10-17 19:19:04
    赞同 展开评论 打赏
  • 你的maven配置问题吧,没指定main。

    此答案来自钉钉群“【2】Apache Flink China 社区”

    2023-02-25 08:05:16
    赞同 展开评论 打赏
  • 从事java行业9年至今,热爱技术,热爱以博文记录日常工作,csdn博主,座右铭是:让技术不再枯燥,让每一位技术人爱上技术

    这个问题应该就是classpath的问题,我在网上找到了一篇跟你问题类似的博客,https://blog.csdn.net/Sunzhongwei1988/article/details/105691069/ 你可以看一下是否能解决你的问题

    2023-02-24 15:40:44
    赞同 展开评论 打赏
  • 网站:http://ixiancheng.cn/ 微信订阅号:小马哥学JAVA

    报错是路径配置错误导致的,具体的解决方案,可以参考: 1.创建本节点的资源存放目录(包括日志目录)以及设置对应的工作目录; 2.在工作目录下生成default_container_executor.sh 脚本; 3.在工作目录下生成launch_container.sh脚本; 4.执行default_container_executor.sh 脚本; 5.最后如果执行没有任何异常,则直接返回0;

    2023-02-24 14:52:55
    赞同 展开评论 打赏
  • CSDN博客专家,51CTO博主专家,多知名企业认证讲师&签约作者&培训讲师,特邀作者等,华为云专家,资深测试开发专家,金牌面试官,职场面试培训及规划师。

    【回答】

    这应该是你的 ClassPath 问题导致,

    解决方案:根据日志,来排查源码,

    2023-02-24 14:02:07
    赞同 展开评论 打赏

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

相关产品

  • 实时计算 Flink版
  • 相关电子书

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