Apache Flink 1.2已经宣布发布，新增特性包括动态缩放功能、安全性、可查询状态等等。本次发布解决了650个问题，维持了与所有公开API的兼容性，以及针对Apache Kafka 0.10和Apache Mesos的支持。
Flink的动态缩放允许更改流式作业的并行度或者工作操作符。此功能能够从带有不同并行度的保存点恢复作业并且相应地通过上下缩放方式提升流式管道的操作管理能力，最小化停机时间到几秒钟。当前Flink支持类似于Kafka消费者、窗口操作以及自定义用户状态这样的操作符。
针对安全性，添加了对外部服务使用Kerberos进行身份认证支持。Flink支持验证ZooKeeper、kafka、HDFS以及YARN。实验基于SSL协议的通信线也被新增用于Flink执行者之间传输加密信息。
可查询状态实验特征通过API暴露了操作符的关键状态。这种方式是很有意义的，这样就在不需要向一个数据存储器写入状态数据的情况下，就可以提供流式管道的心跳状态。这种状态可以使用一个线程安全的异步QueryableStateClient查询，并且也提供了一些工具用于处理操作符实现和客户端两者的序列化状态。
Apache kafka 0.10也支持作为数据源和数据池。Kafka 0.10连接器可以随着Flink内部事件时间消费和生产消息。Kafka消费者可以以Kafka消息时间戳作为事件时间发出数据，但是不会通过发出watermark（一种衡量事件时间进展方式）方式增加时间。
Apache Mesos此次也被作为部署选项增加进来。Flink也支持DC/OS部署，并且Marathon业务流程平台可以被提升运行高可用的Flink集群-Marathon将所有的Flink组件作为Mesos任务，在整个集群运行，无论什么时候Flink主节点失败了，其他的节点就会启动。状态（运行任务）被保存在ZooKeeper并从中恢复。
Table API此次也得到了提升。Window aggregations被三种不同的模式支持：tumbling windows、sliding windows以及session (gap) windows。所有的模式支持事件时间和处理时间windowing。Tumbling和sliding模式也支持行计数windowing。Flink的Table API和SQL提供了针对POJO字段访问的试验访问方式，并且扩展了内置函数的支持队列。
(文章来源:InfoQ)