idea打包jar在集群运行FlinkWordCount.jar

Posted 2023-03-03 秃秃小丸子

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了idea打包jar在集群运行FlinkWordCount.jar相关的知识，希望对你有一定的参考价值。

首先idea打包jar(不过多讲述)
将自己打包好的jar通过xftp传入集群内(这里我是放在 /opt/module/hadoop-2.7.7/share/hadoop/mapreduce/FlinkWordCount.jar)
启动flink (yarn-session要启动集群，单机模式不必)
hadoop进入flink目录，在终端输入./bin/start-cluster.sh，启动flink
输入jps有StandaloneSessionClusterEntrypoint
TaskManagerRunner 表示启动成功
在输入 /flink-15.3/bin/flink run --class cn.edu.xmu.WordCount /opt/module/hadoop-2.7.7/share/hadoop/mapreduce/FlinkWordCount.jar
注意目录随自己的更改

以上是关于idea打包jar在集群运行FlinkWordCount.jar的主要内容，如果未能解决你的问题，请参考以下文章