flink 提交job

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

2. 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

3. 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