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