Support for Flink 1.7.0 on Amazon EMR release 5.21.0

You can now use Apache Flink 1.7.0 on Amazon EMR release 5.21.0. Flink 1.7.0 has many new features such as the ability to change the state schema of the streaming application which allows you to change the features captured by the application without restarting it, support for a new connector to write to Kafka 2.0, and an exactly-once S3 file sink for writes to Amazon S3. Flink 1.7.0 also features several streaming SQL improvements such as support for temporal tables that tracks the history of data changes and several new built-in SQL functions to handle complex data types.

Additionally, with this release, you can use the upgraded version of Presto 0.215.

You can create an Amazon EMR cluster with the release 5.21.0 by choosing the release label “emr-5.21.0” from the AWS Management Console, AWS CLI, or SDK. You can choose Flink and Presto to install these applications when you launch your EMR cluster. Please visit the Amazon EMR documentation for more information about EMR release 5.21.0, Flink 1.7.0, and Presto 0.215.

Amazon EMR release 5.21.0 is now available in all supported regions for Amazon EMR.

You can stay up to date on EMR releases by subscribing to the RSS feed for EMR release notes. Use the RSS icon at the top of the EMR Release Guide to link the feed URL directly to your favorite feed reader.