- 独立集群提交
# 启动集群
bin/start-cluster.sh
# 提交job
./bin/flink run ./examples/batch/WordCount.jar --input hdfs:/user/yuan/input/wc.count --output hdfs:/user/yuan/swwwttt
- yarn session
# 启动集群
./bin/yarn-session.sh -jm 1024m -tm 4096m
# 提交job
./bin/flink run ./examples/batch/WordCount.jar --input hdfs:/user/yuan/input/wc.count --output hdfs:/user/yuan/swwwttt
- yarn single job
# 提交job
./bin/flink run -m yarn-cluster ./examples/batch/WordCount.jar --input hdfs:/user/yuan/input/
作者:程序男保姆
链接:https://www.jianshu.com/p/be1ee9b05ecd
来源:简书
著作权归作者所有。商业转载请联系作者获得授权,非商业转载请注明出处。