flink1.18 Yarn Application 提交,有人遇见过?
这个问题可能是由于Flink在提交Yarn Application时,无法找到正确的入口类导致的。请检查以下几点:
确保您的Flink程序包含一个名为org.apache.flink.runtime.entrypoint.clusterEntrypoint.ClusterEntryPoint
的入口类。这个类是Flink程序的入口点,用于启动应用程序。
如果您的程序使用了自定义的入口类,请确保它已经被正确地打包到JAR文件中,并且在Flink的配置文件中指定了正确的入口类。
检查Flink的配置文件(例如flink-conf.yaml
或flink-conf.properties
),确保yarn.application-master
和yarn.classpath
等配置项正确设置。
如果问题仍然存在,您可以尝试在Flink的配置文件中添加以下内容,以禁用自动检测入口类的功能:
yarn.application-master: yarn-cluster
yarn.classpath: true
然后重新启动Flink集群并尝试提交应用程序。
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。