开启flink服务端：./start-cluster.sh
关闭flink服务端：./stop-cluster.sh
运行一个job:
bin/flink run -c com.atguigu.wc.StreamWordCount -p 2 jar/testXXXXX.jar --host localhost
-c: 任务的全类名。
-p：并行度
--host：模式
--port 7777
查看flink任务 : bin/flink list
查看所有flink任务 ：bin/flink list -a
删除flink任务：bin/flink cancel 任务id
使用yarn模式启动
Session Cluster
./yarn-session.sh -n 2 -s 2 -jm 1024 -tm 1024 -nm test -d
-n taskManager的数量
-s taskManager的slot的数量,默认一个slot一个core，默认每个taskmanager的slot的个数为1，有时可以多些taskmanager左冗余。
-jm 设置jobManager的大小（单位MB）
-ts 设置taskManager的大小（单位MB）
-nm yarn的appName（现在yarn的ui上的名字）
-d ：后台执行 /
提交job任务任务
./flink run -c com.atguigu.wc.StreamWC FlinkTutorial-1.0-SNAPSHOT-jar-XXX.jar --host localhost -port 7777
取消yarn-session
yarn application --kill application_123332131_4545
Per Job Cluster
不启动yarn-session，直接执行job
./flink run –m yarn-cluster -c com.atguigu.wc.StreamWordCountFlinkTutorial-1.0-SNAPSHOT-jar-with-dependencies.jar --host lcoalhost –port 7777
不同于Session Cluster 不启动yarn—session直接执行job 加-m yarn-cluster
