运行命令如下
./flink[OPTIONS] [ARGUMENTS]
The following actions are available:
Action "run" compiles and runs a program.
| 命令 |
注释 |
| -c,--class |
程序的入口(main method or getplan()).只有在jar程序的manifest中没有指定class |
| -n,--allowNonRestoredState |
允许跳过那些不能保存的 savepoint状态。你需要允许此项，假如你从程序中移除了程序的一部分算子，当savepoint已经触发了。 |
| -s,--fromSavepoint |
savepoint保存的地方。比如 hdfs:///flink/savepoint-1537 |
Action "cancel" cancels a running program.
Syntax: cancel [OPTIONS]
"cancel" action options:
| 命令 |
注释 |
| -s,--withSavepoint |
触发savepoint和取消job。 target directory是可选的。如果没有指定directory，默认的文件目录会使用(state.savepoints.dir) |
Action "savepoint" triggers savepoints for a running job or disposes existing ones.对一个正在运行的job触发savepoint操作
| 命令 |
注释 |
| -d,--dispose |
处理savepoint的路径 |
| -j,--jarfile |
Flink程序的jar文件 |
| -yid,--yarnapplicationId （只在yarn模式下有用） |
Attach to running YARN session |
【Flink总结-运行命令参数分析】Syntax: savepoint [OPTIONS] []
"savepoint" action options:
| 命令 |
注释 |
| -d,--dispose |
处理savepoint的路径 |
| -j,--jarfile |
Flink程序的jar文件 |
| -yid,--yarnapplicationId （只在yarn模式下有用） |
Attach to running YARN session |
推荐阅读
