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: Sep 10, 2024

See more details (feature freeze, estimated release date, ...) about the upcoming release on the corresponding release page linked below.

ReleaseDateTime span (days)Announcement Blogpost URLMinor Releases
2.0 Release



1.20 Release2 Aug 2024137https://flink.apache.org/2024/08/02/announcing-the-release-of-apache-flink-1.20/
1.19 Release18 Mar 2024144https://flink.apache.org/2024/03/18/announcing-the-release-of-apache-flink-1.19/1.19.1
1.1826 Oct 2023217https://flink.apache.org/2023/10/24/announcing-the-release-of-apache-flink-1.18/1.18.1
1.1723 Mar 2023146https://flink.apache.org/2023/03/23/announcing-the-release-of-apache-flink-1.17/1.17.1, 1.17.2
1.1628 Oct 2022176https://flink.apache.org/news/2022/10/28/1.16-announcement.html1.16.1, 1.16.2, 1.16.3
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.2, 1.12.3, 1.12.4, 1.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