我在Flink文档中看到了这一行,但无法弄清楚“分离模式”的含义。请帮忙。谢谢。
在分离模式下运行示例程序:
./bin/flink run -d ./examples/batch/WordCount.jar
Run Code Online (Sandbox Code Playgroud)
Flink CLI以阻止或分离模式运行作业。在阻止模式下,CliFrontend(客户端)进程保持运行,阻止,等待作业完成的状态-之后将打印出一些信息。在下面的示例中,我运行了一个流作业,几秒钟后我从WebUI取消了该作业:
$ flink run target/oscon-1.0-SNAPSHOT.jar
Starting execution of program
Program execution finished
Job with JobID b02da01c30585bfbc86a23446559987f has finished.
Job Runtime: 8673 ms
Run Code Online (Sandbox Code Playgroud)
如果您以阻止模式运行,则可以根据需要杀死CliFrontend(例如,使用ctrl-C),并且该作业不会受到影响,只要它已运行得足以将作业提交给群集即可。
在分离模式下,CliFrontend将作业提交到群集,然后立即退出。
| 归档时间: |
|
| 查看次数: |
627 次 |
| 最近记录: |