flink 提交job

2020-08-29 本文已影响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

上一篇下一篇

猜你喜欢

热点阅读