This document is a community maintained roadmap of the upcoming releases and features (at a high level).
The document contains only estimations, no guaranteed feature / release dates.
See also the time-based release model.
Last update: February 2016
Next scheduled release: 1.3.0
Feature freeze (branch forking): 1 May 2017 (extended to 5 May)
Code freeze (first voting RC): 15 May 2017
Release date: 26 May 2017
Release | Date | Time span (days) |
---|---|---|
0.6
| 26 Aug 2014 | |
0.7 | 04 Nov 2014 | 70 |
0.8 | 21 Jan 2015 | 78 |
0.9 | 24 Jun 2015 | 154 |
0.10 | 16 Nov 2015 | 145 |
1.0 | 08 Mar 2016 | 113 |
1.1 | 08 Aug 2016 | 153 |
1.2 | 2 Feb 2017 | 178 |
1.3 | 26 May 2017 | |
1.4 | 29 September 2017 | |
1.5 | 26 January 2018 |
Past releases
Flink 1.1 (August 2016)
- Session Windows and Allowed lateness
- Table API and SQL on Calcite
- Metrics system
- Scala API for CEP
- Graph generators and new Gelly library algorithms
- Continuous File Sources
- Kinesis Connector
- Cassandra Connector
Flink 1.2
- Dynamic Scaling / Key Groups (FLINK-3755) (Design Doc)
- Rescalable Non-Partitioned State (FLIP-8)
- Backwards compatible savepoints (FLINK-4797)
- Secure Data Access (FLINK-3930) (Design Doc)
- Queryable State (FLINK-3779)
- Async I/O (FLIP-12)
- Metrics in Webinterface (FLIP-7)
- Kafka 0.10 support (FLINK-4035)
- Table API: Group Window Aggregates (FLINK-4691, FLIP-11)
- Table API: Scalar Functions (FLINK-3097)
Flink 1.3
(Large) State Handling / Recovery:
Incremental / lightweight snapshots for checkpoints (FLINK-5053)
Asynchronous snapshots for heap-based operator state backends (FLINK-6048)
Allow upgrades to state serializers (FLINK-6178)
Recover job state at the granularity of operator (FLINK-5892)
Fine-grained recovery (beta) (FLINK-4256)
Streaming APIs:
Expose Broadcast Operator State through public APIs (FLINK-5991)
Side Outputs (FLINK-4460)
Extending AllWindow Function Metadata (FLINK-5157, FLINK-4997)
Add support for "Distributed Cache" in streaming applications (FLINK-6177)
Deployment & Tooling:
Flink History Server (FLINK-1579)
Flink automatically manages TM network buffer (FLINK-4545)
Add Datadog HTTP metrics reporter (FLINK-6013)
Add watermark monitoring to JobManager web frontend (FLINK-3427)
Table API / SQL:
Add support for Retraction in Table API / SQL (FLINK-6047)
Integrate time indicators for Table API & SQL (FLINK-5884)
Support tumbling window on streaming tables in the SQL API (FLINK-5624)
Add HBaseTableSource (FLINK-2168)
Add CUBE/ROLLUP/GROUPING SETS operator in SQL (FLINK-5303)
Connectors:
Elasticsearch 5.x supportFLINK-4988)
Implement rescalable non-partitioned state for Kinesis Connector (FLINK-4821)
Allow Kinesis Consumer to start from specific timestamp / Date (FLINK-4523)
Allow setting custom start-offsets for the Kafka consumer (FLINK-3123)
CEP library improvements:
Make CEP operators rescalable (FLINK-5420)
Late elements in side output (FLINK-6205)
Support for quantifiers (*,+,?) to CEP's pattern API (FLINK-3318)
Add support for iterative conditions (FLINK-6197)
- Gelly Library:
PageRank algorithm for directed graphs (FLINK-4896)
Add Evenly Graph Generator to Flink Gelly (FLINK-6393)
Upcoming releases
Flink 1.4
Flink 1.5