


yarn资源也够 ,代码在软件里面也可以运行成功,怎么解决,求帮助,实在没办法,搞不懂
关注以下回复引自免费微信小程序:皆我百晓生。 如问题解决,还请采纳。如仍有疑问,请回复留言或私信博主,以便获得更精准的帮助。
首先,你需要确保你的FLINK集群已经正确配置了MYSQL和HADOOP的连接信息,并且它们是可用的。此外,你还需要确保你的JAVA环境(特别是MAVEN或GRADLE)已正确安装并配置为支持YARN调度。
如果上述步骤都正常,那么你可以尝试以下步骤来解决这个问题:
检查FLINK是否正在运行:在命令行中运行JPS以查看FLINK进程。这应该会显示你的FLINK实例。
确保MYSQL和HADOOP的启动文件路径正确:大多数情况下,这些文件位于你的项目根目录下的BIN子目录下。如果你的文件位置不同,可能需要修改它。
检查HADOOP的配置文件:通常,HADOOP的配置文件位于你的HDFS主端点的/ETC/HADOOP/CONF目录下。你可以在HADOOP的配置文件中找到关于YARN的设置,例如DFS.REPLICATION、MASTER等。
检查MYSQL的配置文件:大多数情况下,MYSQL的配置文件位于你的数据库主端点的/ETC/MY.CNF或/ETC/MYSQL.CONF文件中。这取决于你的MYSQL版本。
检查你的FLINK集群是否处于正确的状态:在FLINK的控制台窗口中,检查你的FLINK实例的状态。这可能包括查看它的在线状态、启动状态、健康状态等。
检查你的JAVA环境是否已正确安装并配置为支持YARN调度:如果你使用的JAVA环境不是默认的YARN环境,那么你应该先将它配置为支持YARN。这可以通过使用YARN的工具进行,或者通过在你的JVM选项中添加-XMSYARN.MEMORY_SIZE和-XMXYARN.MEMORY_SIZE参数。
如果以上步骤都无法解决问题,可能是由于其他原因导致的错误。在这种情况下,你应该查阅FLINK的技术文档,看看是否有任何特定的问题或错误提示。