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个数 |