windows环境下IDEA本地通过java API 向yarn上提交Flink per_job 任务失败,jobmanager.err 里面显示: Error: Could not find or load main class org.apache.flink.yarn.entrypoint.YarnJobClusterEntrypoint
哪位大佬知道是为什么 ?
我遇到过同样的问题,当我处于绝望的时候,看到有人在linux或者mac上运行成功了,在windows上运行一直加载不到主类。
https://github.com/zhangjun0x01/bigdata-examples/issues/10
具体请参考这篇回复。 解决了我一天的研究,后期准备把环境切到linux开发。
这个问题应该就是classpath的问题,我在网上找到了一篇跟你问题类似的博客,https://blog.csdn.net/Sunzhongwei1988/article/details/105691069/ 你可以看一下是否能解决你的问题
报错是路径配置错误导致的,具体的解决方案,可以参考: 1.创建本节点的资源存放目录(包括日志目录)以及设置对应的工作目录; 2.在工作目录下生成default_container_executor.sh 脚本; 3.在工作目录下生成launch_container.sh脚本; 4.执行default_container_executor.sh 脚本; 5.最后如果执行没有任何异常,则直接返回0;
【回答】
这应该是你的 ClassPath 问题导致,
解决方案:根据日志,来排查源码,
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。