Flink 2016年度回顾

Posted 2021-04-13 Flink

Flink官网最近发布了2016年度回顾，有些内容在之前PPT解读中已经提及过，就不多说了。

点击“阅读原文”查看官网回顾原文。

列举一下，已经被提上日程（甚至部分有可能会在17年初跟随1.2版本发布）的改进计划：

• A new Flink deployment and process model（一个新的Flink部署与处理模型）：这个改进对应“FLIP-6”，它可以确保Flink支持更多的部署类型与集群管理器，使得其尽可能顺利地运行在任何环境中。

• Dynamic scaling（动态扩展）：针对键-值状态以及非分区的状态，以使得它们都能够在横向扩展与纵向扩展时被分割、合并。

• Asynchronous I/O（异步I/O）：对应“FLIP-12”，它能够使得I/O访问花费更少的时间，而不会增加复杂度或者额外的检查点协调要求。

• Enhancements to the window evictor（对窗口驱逐器的改进与增强）：对应“FLIP-4”，就如何从窗口中驱逐元素，给予用户更多的控制灵活度。

• Fined-grained recovery from task failures（以更细小的粒度从任务失败中恢复）：对应“FLIP-1”，仅在真正需要重启时才重启恢复，构建可缓存的中间结果。

• Unified checkpoints and savepoints（统一检查点和保存点）：对应“FLIP-10”，允许保存点被自动触发，这对于程序为了处理错误而进行的更新很重要，因为保存点允许用户修改作业和Flink的版本，而检查点则只能被用来恢复相同的作业。

• Table API window aggregations（Table API 窗口聚合）：对应“FLIP-11”，在流和批处理的table上支持group-window以及row-window聚合。

• Side inputs（侧边输入）：用来对一个主要的（高吞吐的）流与另一个或多个静态的（或者很少变更的）输入进行join提供支持。

---

---