Flink(1.13) 执行模式(Execution Mode)

Flink从 1.12.0 上对 流式API 新增一项特性:可以根据你的使用情况和Job的特点, 可以选择不同的运行时执行模式(runtime execution modes).

流式API的传统执行模式我们称之为 STREAMING 执行模式, 这种模式一般用于无界流, 需要持续的在线处理

1.12.0新增了一个 BATCH 执行模式, 这种执行模式在执行方式上类似于MapReduce框架. 这种执行模式一般用于有界数据.

默认是使用的 STREAMING 执行模式

BATCH 执行模式 仅仅用于有界数据 , 而 STREAMING 执行模式可以用在 有界数据和无界数据 .

一个公用的规则就是: 当你处理的数据是 有界 的就应该 使用BATCH执行模式 , 因为它更加高效. 当你的数据是 无界 的, 则必须 使用STREAMING 执行模式 , 因为只有这种模式才能处理持续的数据流.

执行模式有3个选择可配:

批处理与流处理的区别：

有界与无界的理解：

程序比较简单，就没加注释

结果

结果

执行模式所支持的模式：

转换成批处理

结果

注意：

有以下三种模式。

1、设计模式：可以进行界面设计和代码编写，程序打开就是设计模式。

2、执行模式：程序处于运行状态，可以查看代码，但不能修改，【运行】-【开始】或【F5】。

3、中断模式：程序处于挂起状态，可以查看修改代码，【运行】-【中断】或“Ctrl+Break”。

---