参数介绍

./bin/flink run -t yarn-session \
  -Dyarn.application.id=application_XXXX_YY \
  ./examples/streaming/TopSpeedWindowing.jar
  
  
 ./bin/flink run -t yarn-per-job 
  --detached ./examples/streaming/TopSpeedWindowing.jar
  
  
 ./bin/flink run-application -t yarn-application 
 ./examples/streaming/TopSpeedWindowing.jar
 
 
yn(实际) = Math.ceil(p/ys)
ys(总共) = yn(实际) * ys(指定)
ys(使用) = p(指定)
flink run 
-c,--class Flink应用程序的入口
-C,--classpath 指定所有节点都可以访问到的url,可用于多个应用程序都需要的工具类加载
-d,--detached 是否使用分离模式，就是提交任务,cli是否退出,加了-d参数,cli会退出
-n,--allowNonRestoredState 允许跳过无法还原的savepoint。比如删除了代码中的部分operator
-p,--parallelism 执行并行度
-s,--fromSavepoint 从savepoint恢复任务
-sae,--shutdownOnAttachedExit 以attached模式提交，客户端退出的时候关闭集群
flink yarn-cluster 模式
-d,--detached 是否使用分离模式
-m,--jobmanager 指定提交的jobmanager
-yat,--yarnapplicationType 设置yarn应用的类型
-yD 使用给定属性的值
-yd,--yarndetached 使用yarn分离模式
-yh,--yarnhelp yarn session的帮助
-yid,--yarnapplicationId 挂到正在运行的yarnsession上
-yj,--yarnjar Flink jar文件的路径
-yjm,--yarnjobManagerMemory jobmanager的内存(单位M)
-ynl,--yarnnodeLabel 指定 YARN 应用程序 YARN 节点标签
-ynm,--yarnname 自定义yarn应用名称
-yq,--yarnquery 显示yarn的可用资源
-yqu,--yarnqueue 指定yarn队列
-ys,--yarnslots 指定每个taskmanager的slots数
-yt,--yarnship 在指定目录中传输文件
-ytm,--yarntaskManagerMemory 每个taskmanager的内存
-yz,--yarnzookeeperNamespace 用来创建ha的zk子路径的命名空间
-z,--zookeeperNamespace 用来创建ha的zk子路径的命名空间