flink 提交job
作者:
程序男保姆 | 来源:发表于
2020-08-29 18:01 被阅读0次
- 独立集群提交
# 启动集群
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/wc.count --output hdfs:/user/yuan/swwwttt
本文标题：flink 提交job
本文链接：https://www.haomeiwen.com/subject/pjjjsktx.html
网友评论