flink run常用参数说明
flink run参数:
| 参数 | 参数全称 | 描述 |
| -c | –class | 需要指定的main方法的类 |
| -C | –classpath | 向每个用户代码添加url,他是通过UrlClassLoader加载。url需要指定文件的schema如(file://) |
| -d | –detached | 在后台运行 |
| -p | –parallelism | job需要设置env的并行度 |
| -q | –sysoutLogging | 禁止logging输出作为标准输出。 |
| -s | –fromSavepoint | 基于savepoint保存下来的路径,进行恢复。 |
| -sae | –shutdownOnAttachedExit | 如果是前台的方式提交,当客户端中断,集群执行的job任务也会shutdown。 |
flink run -m yarn-cluster参数
| 参数 | 参数全称 | 描述 |
| -m | –jobmanager | yarn-cluster集群 |
| -yd | –yarndetached | 后台 |
| -yjm | –yarnjobManager | jobmanager的内存 |
| -ytm | –yarntaskManager | taskmanager的内存 |
| -yz | -yarnzookeeperNamespace | zookeeper命名空间 |
| -yn | –yarncontainer | TaskManager的个数 |
| -yid | –yarnapplicationId | job依附的applicationId |
| -ynm | –yarnname | application的名称 |
| -ys | –yarnslots | 分配的slots个数 |