Flink实例(六十九): flink 作业提交(四)总结

  1. 独立集群提交
    # 启动集群
    bin/start-cluster.sh

    # 提交job
    ./bin/flink run  ./examples/batch/WordCount.jar  --input hdfs:/user/yuan/input/wc.count --output hdfs:/user/yuan/swwwttt
  1. 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
  1. 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
来源:简书
著作权归作者所有。商业转载请联系作者获得授权,非商业转载请注明出处。

本文来自博客园,作者:秋华,转载请注明原文链接:https://www.cnblogs.com/qiu-hua/p/13909293.html

原文地址:https://www.cnblogs.com/qiu-hua/p/13909293.html