|
Standalone
提交任务
flink run -c com.dylan.wc.StreamWordCount -p 1 /usr/local/xxx.jar
停止任务
flink cancel jobid
列举正在运行任务
flink list
列举正在全部任务
flink list -a
Session Cluster
启动 yarn-session
./yarn-session.sh -n 2 -s 2 -jm 1024 -tm 1024 -nm test -d
其中：
-n(–container)：TaskManager 的数量
-s(–slots)： 每个 TaskManager 的 slot 数量，默认一个 slot 一个 core，默认每个 taskmanager 的 slot 的个数为 1，有时可以多一些 taskmanager，做冗余
-jm：JobManager 的内存（单位 MB)
-tm：每个 taskmanager 的内存（单位 MB)
-nm：yarn 的 appName(现在 yarn 的 ui 上的名字)
-d：后台执行
提交任务
/flink run -c com.dylan.wc.StreamWordCount -p 1 /usr/local/xxx.jar
停止任务
yarn application --kill application_1577588252906_0001
Per Job Cluster
flink run –m yarn-cluster -c com.dylan.wc.StreamWordCount -p 1 /usr/local/xxx.jar
停止任务
yarn application --kill application_1577588252906_0001
|