Apache Flink 1.14 新特性预览 - OSCHINA
有一定的提升。同时,在执行时候是经过分段去执行任务的,无需同时执行;在容错计算方面是根据 stage 进行容错。 Flink 1.14 的优化点主要是针对在流的执行模式下,如何去处理有限数据集。之前处理无限数据集,和现在处理有限数据集最大的区别在于引入了 "任务可能会结束" 的概念。这种情况下带来了一些新的问题,如下图: ■ 在流的执行模式下的 Checkpoint 机制 对于无限流,它的 Checkpoint 是由所有的 source 节点进行触发的,由 source 节点发送 Checkpoint Barrier ,当 Checkpoint Barrier 流过整个作业时候,同时会存储当前作业所有的 state 状态。 而在有限流的 Checkpoint 机制中,Task 是有可能提早结...阅读全文