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: October 31, 2022


Next scheduled major/minor release: 1.17.0
Feature freeze (branch forking):  January 31, 2023
Code freeze (first voting RC):  TBD
Release dateTBD


ReleaseDateTime span (days)Announcement Blogpost URLMinor Releases
1.17tbd


1.1628 Oct 2022176https://flink.apache.org/news/2022/10/28/1.16-announcement.html1.16.1
1.155 May 2022218https://flink.apache.org/news/2022/05/05/1.15-announcement.html1.15.1, 1.15.2, 1.15.3
1.1429 Sep 2021149https://flink.apache.org/news/2021/09/29/release-1.14.0.html1.14.1, 1.14.21, 1.14.3, 1.14.4, 1.14.5
1.1303 May 2021144https://flink.apache.org/news/2021/05/03/release-1.13.0.html1.13.1, 1.13.2, 1.13.3, 1.13.4, 1.13.51
1.1210 Dec 2020157https://flink.apache.org/news/2020/12/10/release-1.12.0.html1.12.1, 1.12.21.12.31.12.41.12.5, 1.12.6, 1.12.71
1.1106 Jul 2020146https://flink.apache.org/news/2020/07/06/release-1.11.0.html1.11.1, 1.11.2, 1.11.3, 1.11.4, 1.11.5, 1.11.61
1.1011 Feb 2020173https://flink.apache.org/news/2020/02/11/release-1.10.0.html1.10.1, 1.10.2, 1.10.3
1.922 Aug 2019135https://flink.apache.org/news/2019/08/22/release-1.9.0.html1.9.1, 1.9.2
1.809 Apr 2019130https://flink.apache.org/news/2019/04/09/release-1.8.0.html1.8.1, 1.8.2, 1.8.3
1.730 Nov 2018113https://flink.apache.org/news/2018/11/30/release-1.7.0.html1.7.1, 1.7.2
1.609 Aug 2018195https://flink.apache.org/news/2018/08/09/release-1.6.0.html1.6.1, 1.6.2, 1.6.3, 1.6.4
1.526 Jan 2018119https://flink.apache.org/news/2018/05/25/release-1.5.0.html1.5.1, 1.5.2, 1.5.3, 1.5.4, 1.5.5, 1.5.6
1.429 Sep 2017126https://flink.apache.org/news/2017/12/12/release-1.4.0.html1.4.1, 1.4.2
1.326 May 2017119https://flink.apache.org/news/2017/06/01/release-1.3.0.html1.3.1, 1.3.2, 1.3.3

1.2

02 Feb 2017178https://flink.apache.org/news/2017/02/06/release-1.2.0.html1.2.1
1.108 Aug 2016153https://flink.apache.org/news/2016/08/08/release-1.1.0.html1.1.1, 1.1.2, 1.1.3, 1.1.4
1.008 Mar 2016113https://flink.apache.org/news/2016/03/08/release-1.0.0.html1.0.1, 1.0.2, 1.0.3
0.1016 Nov 2015145https://flink.apache.org/news/2015/11/16/release-0.10.0.html0.10.1, 0.10.2
0.924 Jun 2015154https://flink.apache.org/news/2015/06/24/announcing-apache-flink-0.9.0-release.html0.9.1
0.821 Jan 201578https://flink.apache.org/news/2015/01/21/release-0.8.html
0.704 Nov 201470https://flink.apache.org/news/2014/11/04/release-0.7.0.html

0.6

26 Aug 2014
https://flink.apache.org/news/2014/08/26/release-0.6.html0.6.1

1 These releases were considered emergency releases connected to the Log4j Zero Day vulnerability (CVE-2021-44228; see related Flink Blog Post)

ARCHIVE

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

Flink 1.3

  • (Large) State Handling / Recovery:

  • Streaming APIs:

  • 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:

    • Support for Retraction in Table API / SQL (FLINK-6047)

    • Support for non-windowed aggregations in streaming Table API / SQL (FLINK-6216)
    • Support for append, upsert and retraction StreamTableSinks (FLINK-6093)
    • Integrate time indicators for Table API & SQL (FLINK-5884)

    • Support for group windows in (batch + streaming) SQL (TUMBLE, HOP, SESSION) (FLINK-6261,FLINK-6011)
    • Support for OVER windows in streaming Table API and SQL (FLINK-4557)
    • Support for QueryConfig for streaming queries to specify state retention interval (FLINK-6491)
    • Support for user-defined aggregation functions (FLINK-5564)
    • Support for standard deviation and variance aggregation functions (FLINK-4604)
    • Support for TableSources with filter push down (FLINK-3849,

    • Support for external catalogs (FLINK-5570)

    • Add KafkaAvroTableSource (FLINK-3871)
    • Add HBaseTableSource (FLINK-2168)

    • Add CUBE/ROLLUP/GROUPING SETS operator in batch SQL (FLINK-5303)

    • Support for DISTINCT GROUP BY aggregates for batch SQL (FLINK-3849)
    • Add flink-table.jar to ./opt folder (FLINK-6247)
    • Support for more scalar functions (SIN, COS, TAN, DEGREES, PI etc.) (FLINK-6112)
  • Connectors:
    • Elasticsearch 5.x support (FLINK-4988)

    • Implement rescalable non-partitioned state for Kinesis Connector (FLINK-4821)

    • Transparent shard discovery for Kinesis Consumer (FLINK-4577)
    • Allow Kinesis Consumer to start from specific timestamp / Date (FLINK-4523)

    • Allow setting custom start-offsets for the Kafka consumer (FLINK-3123)

    • Allow out-opt from offset committing for the Kafka consumer (FLINK-3398)

  • CEP library improvements:

  • Gelly Library:
    • Unified driver for running Gelly examples (FLINK-4949)
    • PageRank algorithm for directed graphs (FLINK-4896)

    • Add Circulant and Echo graph generators (FLINK-6393)

Flink 1.13

You can find a list of planned features for the 1.13 release in this Wiki page.


  • No labels