flink1.18 Yarn Application 提交，有人遇见过？-[阿里云_云淘科技]

匿名 • 2024年1月9日下午12:29 • 阿里云

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集群并尝试提交应用程序。

本文来自投稿，不代表新手站长_郑州云淘科技有限公司立场，如若转载，请注明出处：https://www.cnzhanzhang.com/22097.html