Q1马上就要结束了,最近一直在忙一些规划和总结性的东西。

这次就随便聊聊,没有什么主题。

1.5升级到1.7

因为业务上的需求,最近在准备将我们的Flink版本从1.5升级到1.7,

开发还算顺利,我们定制的各种特性也都迁移到1.7的版本上。

不过Flink社区的开发进度,总体上感觉比去年要慢了许多。

SQL化

看了不少公司在实时计算平台建设的文章,提到了很多实时任务SQL化的计划,

从我的感受来说,并没有觉得SQL化的迫切,也许是业务特点不一样吧。

目前平台上跑的几百个任务来看,用户的编写质量确实很差,

开发一个性能优异的Flink任务,需要的知识储备其实挺高的,

绝大多数业务方只能照葫芦画瓢,并没有时间去深入理解和研究。

由平台方来编写一些标准化的工具,减少粗制滥造的重复开发是很有必要的。

但工具化、配置化,不一定要是SQL化,当然公司有足够的投入另当别论。

有状态

对有状态任务的支持,是Flink相比其他实时计算框架的巨大优势。

目前,平台上的任务对State的诉求非常低,这并不是一个健康的状况。

今年Q2开始,我们会加大力度在对State的支持方面,也做一些周边的开发,

降低state的开发难度,提升性能和效率。