本文将概述即将发布的Apache Flink 1.2.0新功能。在Apache Flink 1.1+版本上，社区主要的集中点在操作性（Operations）、生态系统（Ecosystem）、更广泛的用户（Broader Audience）以及应用特性（Application Features）等方面的开发。各个模块的开发主要包括了如下的方向：

而Flink 1.2版本对以下的方面进行了提升，其中动态扩展（Dynamic Scaling）和可查询状态（Queryable State）又是本版本的重中之重。

动态扩展（Dynamic Scaling）和可查询状态（Queryable State）

这个是Apache Flink 1.2.0版本的功能的重中之重，后面会重点介绍。

安全以及身份认证（Security / Authentication）

大数据框架的安全一直是一个比较头疼的问题，而在Apache Flink 1.2中，社区对Flink的安全以及身份认证做了比较多的工作，此特性的开发主要由美国信息存储资讯科技公司-易安信(EMC)贡献，主要包括：

1、数据访问授权，主要基于Kerberos实现；

2、Flink进程之间的通信数据进行加密，所有的通信（包括RPC, 数据交换, Web UI等等）都通过SSL进行连接；

3、此外，本版本还防止了恶意用户侵入到Flink作业（hook into Flink jobs）。

集群管理（Cluster Management）

大家应该知道，直到Apache Flink 1.1.x，内置支持的集群管理主要包括：Standalone和Flink on Yarn。但是我们也都知道，Apache Mesos也是一款很不错的开源分布式资源管理框架；虽然我们可以自己做一些修改能让Flink运行在Apache Mesos之上，但是怎么能够和内置支持方便性来比较呢？为此，社区在 FLINK-1984 引入了Flink on Mesos特性，我们得感谢EMC公司的贡献！

在将来（Apache Flink 1.2之后），阿里巴巴和 dataartisans 公司将联合努力为Flink提供与各种集群管理器无缝互操作的功能，比如Docker。

指标监控（Metrics）

如果你使用过Apache Spark，你肯定知道Apache Spark的WEB UI提供了诸如 Input Rate、Scheduling Delay、Processing Time以及Total Delay的图形展示功能，极大方便了用户的使用和监控。不过别羡慕了，Apache Flink 1.2开始，内置也会在WEB UI监控的页面提供各种图形监控如下：

增强Savepoint 和 Checkpoint的健壮性

主要包括：

1、从检查点恢复作业；

2、使用较旧的检查点（Checkpoint）从失败中恢复；

3、忽略失败的Checkpoints；

4、向后兼容。

Table API 和 Stream SQL

其他新功能

1、支持Kafka 0.10

2、Bucketing Sink: divides output into different file w.r.t. user logic

3、Detached execution: first step in programatically controlled job

4、异步IO操作：外部系统非阻塞查询

5、可扩展性，鲁棒性改进以及一些错误修复。