开启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