You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by al...@apache.org on 2019/04/10 08:25:29 UTC
[flink-web] branch asf-site updated (27d0f8e -> 8c74154)
This is an automated email from the ASF dual-hosted git repository.
aljoscha pushed a change to branch asf-site
in repository https://gitbox.apache.org/repos/asf/flink-web.git.
from 27d0f8e Rebuild website
new f6b8367 Add Flink 1.8.0 release blog post
new 8c74154 Rebuild website
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
_posts/2019-04-09-release-1.8.0.md | 253 +++++++++++++++
content/blog/feed.xml | 280 +++++++++++++++++
content/blog/index.html | 46 ++-
content/blog/page2/index.html | 42 ++-
content/blog/page3/index.html | 40 ++-
content/blog/page4/index.html | 40 ++-
content/blog/page5/index.html | 40 ++-
content/blog/page6/index.html | 40 ++-
content/blog/page7/index.html | 40 ++-
content/blog/page8/index.html | 25 ++
content/index.html | 14 +-
content/news/2019/04/09/release-1.8.0.html | 484 +++++++++++++++++++++++++++++
content/zh/index.html | 14 +-
13 files changed, 1241 insertions(+), 117 deletions(-)
create mode 100644 _posts/2019-04-09-release-1.8.0.md
create mode 100644 content/news/2019/04/09/release-1.8.0.html
[flink-web] 02/02: Rebuild website
Posted by al...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
aljoscha pushed a commit to branch asf-site
in repository https://gitbox.apache.org/repos/asf/flink-web.git
commit 8c74154ff0bbf51426ead0b13069fad67598161d
Author: Aljoscha Krettek <al...@gmail.com>
AuthorDate: Wed Apr 10 10:24:28 2019 +0200
Rebuild website
---
content/blog/feed.xml | 280 +++++++++++++++++
content/blog/index.html | 46 ++-
content/blog/page2/index.html | 42 ++-
content/blog/page3/index.html | 40 ++-
content/blog/page4/index.html | 40 ++-
content/blog/page5/index.html | 40 ++-
content/blog/page6/index.html | 40 ++-
content/blog/page7/index.html | 40 ++-
content/blog/page8/index.html | 25 ++
content/index.html | 14 +-
content/news/2019/04/09/release-1.8.0.html | 484 +++++++++++++++++++++++++++++
content/zh/index.html | 14 +-
12 files changed, 988 insertions(+), 117 deletions(-)
diff --git a/content/blog/feed.xml b/content/blog/feed.xml
index 7a5b3e3..2c75719 100644
--- a/content/blog/feed.xml
+++ b/content/blog/feed.xml
@@ -7,6 +7,286 @@
<atom:link href="https://flink.apache.org/blog/feed.xml" rel="self" type="application/rss+xml" />
<item>
+<title>Apache Flink 1.8.0 Release Announcement</title>
+<description><p>The Apache Flink community is pleased to announce Apache Flink 1.8.0. The
+latest release includes more than 420 resolved issues and some exciting
+additions to Flink that we describe in the following sections of this post.
+Please check the <a href="https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12315522&amp;version=12344274">complete changelog</a>
+for more details.</p>
+
+<p>Flink 1.8.0 is API-compatible with previous 1.x.y releases for APIs annotated
+with the <code>@Public</code> annotation. The release is available now and we encourage
+everyone to <a href="http://flink.apache.org/downloads.html">download the release</a> and
+check out the updated
+<a href="https://ci.apache.org/projects/flink/flink-docs-release-1.8/">documentation</a>.
+Feedback through the Flink <a href="http://flink.apache.org/community.html#mailing-lists">mailing
+lists</a> or
+<a href="https://issues.apache.org/jira/projects/FLINK/summary">JIRA</a> is, as always,
+very much appreciated!</p>
+
+<p>You can find the binaries on the updated <a href="http://flink.apache.org/downloads.html">Downloads page</a> on the Flink project site.</p>
+
+<div class="page-toc">
+<ul id="markdown-toc">
+ <li><a href="#new-features-and-improvements" id="markdown-toc-new-features-and-improvements">New Features and Improvements</a></li>
+ <li><a href="#important-changes" id="markdown-toc-important-changes">Important Changes</a></li>
+ <li><a href="#known-issues" id="markdown-toc-known-issues">Known Issues</a></li>
+ <li><a href="#release-notes" id="markdown-toc-release-notes">Release Notes</a></li>
+ <li><a href="#list-of-contributors" id="markdown-toc-list-of-contributors">List of Contributors</a></li>
+</ul>
+
+</div>
+
+<p>With Flink 1.8.0 we come closer to our goals of enabling fast data processing
+and building data-intensive applications for the Flink community in a seamless
+way. We do this by cleaning up and refactoring Flink under the hood to allow
+more efficient feature development in the future. This includes removal of the
+legacy runtime components that were subsumed in the major rework of Flink’s
+underlying distributed system architecture
+(<a href="https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=65147077">FLIP-6</a>)
+as well as refactorings on the Table API that prepare it for the future
+addition of the Blink enhancements
+(<a href="https://issues.apache.org/jira/browse/FLINK-11439">FLINK-11439</a>).</p>
+
+<p>Nevertheless, this release includes some important new features and bug fixes.
+The most interesting of those are highlighted below. Please consult the
+<a href="https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12315522&amp;version=12344274">complete changelog</a>
+and the <a href="https://ci.apache.org/projects/flink/flink-docs-release-1.8/release-notes/flink-1.8.html">release notes</a>
+for more details.</p>
+
+<h2 id="new-features-and-improvements">New Features and Improvements</h2>
+
+<ul>
+ <li>
+ <p><strong>Finalized State Schema Evolution Story</strong>: This release completes
+the community driven effort to provide a schema evolution story for
+user state managed by Flink. This has been an effort that spanned 2
+releases, starting from 1.7.0 with the introduction of support for
+Avro state schema evolution as well as a revamped serialization
+compatibility abstraction.</p>
+
+ <p>Flink 1.8.0 finalizes this effort by extending support for schema
+evolution to POJOs, upgrading all Flink built-in serializers to use
+the new serialization compatibility abstractions, as well as making it
+easier for advanced users who use custom state serializers to
+implement the abstractions. These different aspects for a complete
+out-of-the-box schema evolution story are explained in detail below:</p>
+
+ <ol>
+ <li>
+ <p>Support for POJO state schema evolution: The pool of data types
+that support state schema evolution has been expanded to include
+POJOs. For state types that use POJOs, you can now add or remove
+fields from your POJO while retaining backwards
+compatibility. For a full overview of the list of data types that
+now support schema evolution as well as their evolution
+specifications and limitations, please refer to the State Schema
+Evolution documentation page.</p>
+ </li>
+ <li>
+ <p>Upgrade all Flink serializers to use new serialization
+compatibility asbtractions: Back in 1.7.0, we introduced the new
+serialization compatibility abstractions <code>TypeSerializerSnapshot</code>
+and <code>TypeSerializerSchemaCompatibility</code>. Besides providing a more
+expressible API to reflect schema compatibility between the data
+stored in savepoints and the data registered at runtime, another
+important aspect about the new abstraction is that it avoids the
+need for Flink to Java-serialize the state serializer as state
+metadata in savepoints.</p>
+
+ <p>In 1.8.0, all of Flink’s built-in serializers have been upgraded to
+use the new abstractions, and therefore the serializers
+themselves are no longer Java-serialized into savepoints. This
+greatly improves interoperability of Flink savepoints, in terms
+of state schema evolvability. For example, one outcome was the
+support for POJO schema evolution, as previously mentioned
+above. Another outcome is that all composite data types supported
+by Flink (such as <code>Either</code>, Scala case classes, Flink Java
+<code>Tuple</code>s, etc.) are generally evolve-able as well when they have
+a nested evolvable type, such as a POJO. For example, the <code>MyPojo</code>
+type in <code>ValueState&lt;Tuple2&lt;Integer, MyPojo&gt;&gt;</code> or
+<code>ListState&lt;Either&lt;Integer, MyPojo&gt;&gt;</code>, which is a POJO, is allowed
+to evolve its schema.</p>
+
+ <p>For users who are using custom <code>TypeSerializer</code> implementations
+for their state serializer and are still using the outdated
+abstractions (i.e. <code>TypeSerializerConfigSnapshot</code> and
+<code>CompatiblityResult</code>), we highly recommend upgrading to the new
+abstractions to be future proof. Please refer to the Custom State
+Serialization documentation page for a detailed description on
+the new abstractions.</p>
+ </li>
+ <li>
+ <p>Provide pre-defined snapshot implementations for common
+serializers: For convenience, Flink 1.8.0 comes with two
+predefined implementations for the <code>TypeSerializerSnapshot</code> that
+make the task of implementing these new abstractions easier
+for most implementations of <code>TypeSerializer</code>s -
+<code>SimpleTypeSerializerSnapshot</code> and
+<code>CompositeTypeSerializerSnapshot</code>. This section in the
+documentation provides information on how to use these classes.</p>
+ </li>
+ </ol>
+ </li>
+ <li>
+ <p><strong>Continuous cleanup of old state based on TTL
+(<a href="https://issues.apache.org/jira/browse/FLINK-7811">FLINK-7811</a>)</strong>: We
+introduced TTL (time-to-live) for Keyed state in Flink 1.6
+(<a href="https://issues.apache.org/jira/browse/FLINK-9510">FLINK-9510</a>). This
+feature enabled cleanup and made keyed state entries inaccessible after a
+defined timeout. In addition state would now also be cleaned up when
+writing a savepoint/checkpoint.</p>
+
+ <p>Flink 1.8 introduces continuous cleanup of old entries for both the RocksDB
+state backend
+(<a href="https://issues.apache.org/jira/browse/FLINK-10471">FLINK-10471</a>) and the heap
+state backend
+(<a href="https://issues.apache.org/jira/browse/FLINK-10473">FLINK-10473</a>). This means
+that old entries (according to the TTL setting) are continuously cleaned up.</p>
+ </li>
+ <li>
+ <p><strong>SQL pattern detection with user-defined functions and
+aggregations</strong>: The support of the MATCH_RECOGNIZE clause has been
+extended by multiple features. The addition of user-defined
+functions allows for custom logic during pattern detection
+(<a href="https://issues.apache.org/jira/browse/FLINK-10597">FLINK-10597</a>),
+while adding aggregations allows for more complex CEP definitions,
+such as the following
+(<a href="https://issues.apache.org/jira/browse/FLINK-7599">FLINK-7599</a>).</p>
+
+ <div class="highlight"><pre><code>SELECT *
+FROM Ticker
+ MATCH_RECOGNIZE (
+ ORDER BY rowtime
+ MEASURES
+ AVG(A.price) AS avgPrice
+ ONE ROW PER MATCH
+ AFTER MATCH SKIP TO FIRST B
+ PATTERN (A+ B)
+ DEFINE
+ A AS AVG(A.price) &lt; 15
+ ) MR;
+</code></pre></div>
+ </li>
+ <li>
+ <p><strong>RFC-compliant CSV format (<a href="https://issues.apache.org/jira/browse/FLINK-9964">FLINK-9964</a>)</strong>: The SQL tables can now be read and written in
+an RFC-4180 standard compliant CSV table format. The format might also be
+useful for general DataStream API users.</p>
+ </li>
+ <li>
+ <p><strong>New KafkaDeserializationSchema that gives direct access to ConsumerRecord
+(<a href="https://issues.apache.org/jira/browse/FLINK-8354">FLINK-8354</a>)</strong>: For the
+Flink <code>KafkaConsumers</code>, we introduced a new <code>KafkaDeserializationSchema</code> that
+gives direct access to the Kafka <code>ConsumerRecord</code>. This now allows access to
+all data that Kafka provides for a record, including the headers. This
+subsumes the <code>KeyedSerializationSchema</code> functionality, which is deprecated but
+still available for now.</p>
+ </li>
+ <li>
+ <p><strong>Per-shard watermarking option in FlinkKinesisConsumer
+(<a href="https://issues.apache.org/jira/browse/FLINK-5697">FLINK-5697</a>)</strong>: The Kinesis
+Consumer can now emit periodic watermarks that are derived from per-shard watermarks,
+for correct event time processing with subtasks that consume multiple Kinesis shards.</p>
+ </li>
+ <li>
+ <p><strong>New consumer for DynamoDB Streams to capture table changes
+(<a href="https://issues.apache.org/jira/browse/FLINK-4582">FLINK-4582</a>)</strong>: <code>FlinkDynamoDBStreamsConsumer</code>
+is a variant of the Kinesis consumer that supports retrieval of CDC-like streams from DynamoDB tables.</p>
+ </li>
+ <li>
+ <p><strong>Support for global aggregates for subtask coordination
+(<a href="https://issues.apache.org/jira/browse/FLINK-10887">FLINK-10887</a>)</strong>:
+Designed as a solution for global source watermark tracking, <code>GlobalAggregateManager</code>
+allows sharing of information between parallel subtasks. This feature will
+be integrated into streaming connectors for watermark synchronization and
+can be used for other purposes with a user defined aggregator.</p>
+ </li>
+</ul>
+
+<h2 id="important-changes">Important Changes</h2>
+
+<ul>
+ <li>
+ <p><strong>Changes to bundling of Hadoop libraries with Flink
+(<a href="https://issues.apache.org/jira/browse/FLINK-11266">FLINK-11266</a>)</strong>:
+Convenience binaries that include hadoop are no longer released.</p>
+
+ <p>If a deployment relies on <code>flink-shaded-hadoop2</code> being included in
+<code>flink-dist</code>, then you must manually download a pre-packaged Hadoop
+jar from the optional components section of the <a href="https://flink.apache.org/downloads.html">download
+page</a> and copy it into the
+<code>/lib</code> directory. Alternatively, a Flink distribution that includes
+hadoop can be built by packaging <code>flink-dist</code> and activating the
+<code>include-hadoop</code> maven profile.</p>
+
+ <p>As hadoop is no longer included in <code>flink-dist</code> by default, specifying
+<code>-DwithoutHadoop</code> when packaging <code>flink-dist</code> no longer impacts the build.</p>
+ </li>
+ <li>
+ <p><strong>FlinkKafkaConsumer will now filter restored partitions based on topic
+specification
+(<a href="https://issues.apache.org/jira/browse/FLINK-10342">FLINK-10342</a>)</strong>:
+Starting from Flink 1.8.0, the <code>FlinkKafkaConsumer</code> now always filters out
+restored partitions that are no longer associated with a specified topic to
+subscribe to in the restored execution. This behaviour did not exist in
+previous versions of the <code>FlinkKafkaConsumer</code>. If you wish to retain the
+previous behaviour, please use the
+<code>disableFilterRestoredPartitionsWithSubscribedTopics()</code> configuration method
+on the <code>FlinkKafkaConsumer</code>.</p>
+
+ <p>Consider this example: if you had a Kafka Consumer that was consuming from
+topic <code>A</code>, you did a savepoint, then changed your Kafka consumer to instead
+consume from topic <code>B</code>, and then restarted your job from the savepoint.
+Before this change, your consumer would now consume from both topic <code>A</code> and
+<code>B</code> because it was stored in state that the consumer was consuming from topic
+<code>A</code>. With the change, your consumer would only consume from topic <code>B</code> after
+restore because it now filters the topics that are stored in state using the
+configured topics.</p>
+ </li>
+ <li>
+ <p><strong>Change in the Maven modules of Table API
+(<a href="https://issues.apache.org/jira/browse/FLINK-11064">FLINK-11064</a>)</strong>: Users
+that had a <code>flink-table</code> dependency before, need to update their
+dependencies to <code>flink-table-planner</code> and the correct dependency of
+<code>flink-table-api-*</code>, depending on whether Java or Scala is used: one of
+<code>flink-table-api-java-bridge</code> or <code>flink-table-api-scala-bridge</code>.</p>
+ </li>
+</ul>
+
+<h2 id="known-issues">Known Issues</h2>
+
+<ul>
+ <li><strong>Discarded checkpoint can cause Tasks to fail
+(<a href="https://issues.apache.org/jira/browse/FLINK-11662">FLINK-11662</a>)</strong>: There is
+a race condition that can lead to erroneous checkpoint failures. This mostly
+occurs when restarting from a savepoint or checkpoint takes a long time at the
+sources of a job. If you see random checkpointing failures that don’t seem to
+have a good explanation you might be affected. Please see the Jira issue for
+more details and a workaround for the problem.</li>
+</ul>
+
+<h2 id="release-notes">Release Notes</h2>
+
+<p>Please review the <a href="https://ci.apache.org/projects/flink/flink-docs-release-1.8/release-notes/flink-1.8.html">release
+notes</a>
+for a more detailed list of changes and new features if you plan to upgrade
+your Flink setup to Flink 1.8.</p>
+
+<h2 id="list-of-contributors">List of Contributors</h2>
+
+<p>We would like to acknowledge all community members for contributing to this
+release. Special credits go to the following members for contributing to the
+1.8.0 release (according to <code>git log --pretty="%an" release-1.7.0..release-1.8.0 | sort | uniq</code> without manual deduplication):</p>
+
+<p>Addison Higham, Aitozi, Aleksey Pak, Alexander Fedulov, Alexey Trenikhin, Aljoscha Krettek, Andrey Zagrebin, Artsem Semianenka, Asura7969, Avi, Barisa Obradovic, Benchao Li, Bo WANG, Chesnay Schepler, Congxian Qiu, Cristian, David Anderson, Dawid Wysakowicz, Dian Fu, DuBin, EAlexRojas, EronWright, Eugen Yushin, Fabian Hueske, Fokko Driesprong, Gary Yao, Hequn Cheng, Igal Shilman, Jamie Grier, JaryZhen, Jeff Zhang, Jihyun Cho, Jinhu Wu, Joerg Schad, KarmaGYZ, Kezhu Wang, Konstant [...]
+
+</description>
+<pubDate>Tue, 09 Apr 2019 14:00:00 +0200</pubDate>
+<link>https://flink.apache.org/news/2019/04/09/release-1.8.0.html</link>
+<guid isPermaLink="true">/news/2019/04/09/release-1.8.0.html</guid>
+</item>
+
+<item>
<title>Flink and Prometheus: Cloud-native monitoring of streaming applications</title>
<description><p>This blog post describes how developers can leverage Apache Flink’s built-in <a href="https://ci.apache.org/projects/flink/flink-docs-release-1.7/monitoring/metrics.html">metrics system</a> together with <a href="https://prometheus.io/">Prometheus</a> to observe and monitor streaming applications in an effective way. This is a follow-up post from my <a href="https://flink-forward.org/">Flink Forward</a&g [...]
diff --git a/content/blog/index.html b/content/blog/index.html
index 896985c..840078c 100644
--- a/content/blog/index.html
+++ b/content/blog/index.html
@@ -159,6 +159,25 @@
<!-- Blog posts -->
<article>
+ <h2 class="blog-title"><a href="/news/2019/04/09/release-1.8.0.html">Apache Flink 1.8.0 Release Announcement</a></h2>
+
+ <p>09 Apr 2019
+ Aljoscha Krettek (<a href="https://twitter.com/aljoscha">@aljoscha</a>)</p>
+
+ <p><p>The Apache Flink community is pleased to announce Apache Flink 1.8.0. The
+latest release includes more than 420 resolved issues and some exciting
+additions to Flink that we describe in the following sections of this post.
+Please check the <a href="https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12315522&version=12344274">complete changelog</a>
+for more details.</p>
+
+</p>
+
+ <p><a href="/news/2019/04/09/release-1.8.0.html">Continue reading »</a></p>
+ </article>
+
+ <hr>
+
+ <article>
<h2 class="blog-title"><a href="/features/2019/03/11/prometheus-monitoring.html">Flink and Prometheus: Cloud-native monitoring of streaming applications</a></h2>
<p>11 Mar 2019
@@ -285,23 +304,6 @@
<hr>
- <article>
- <h2 class="blog-title"><a href="/news/2018/11/30/release-1.7.0.html">Apache Flink 1.7.0 Release Announcement</a></h2>
-
- <p>30 Nov 2018
- Till Rohrmann (<a href="https://twitter.com/stsffap">@stsffap</a>)</p>
-
- <p><p>The Apache Flink community is pleased to announce Apache Flink 1.7.0.
-The latest release includes more than 420 resolved issues and some exciting additions to Flink that we describe in the following sections of this post.
-Please check the <a href="https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12315522&version=12343585">complete changelog</a> for more details.</p>
-
-</p>
-
- <p><a href="/news/2018/11/30/release-1.7.0.html">Continue reading »</a></p>
- </article>
-
- <hr>
-
<!-- Pagination links -->
@@ -334,6 +336,16 @@ Please check the <a href="https://issues.apache.org/jira/secure/ReleaseNote.jspa
<ul id="markdown-toc">
+ <li><a href="/news/2019/04/09/release-1.8.0.html">Apache Flink 1.8.0 Release Announcement</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/features/2019/03/11/prometheus-monitoring.html">Flink and Prometheus: Cloud-native monitoring of streaming applications</a></li>
diff --git a/content/blog/page2/index.html b/content/blog/page2/index.html
index d5c0266..4ce09e0 100644
--- a/content/blog/page2/index.html
+++ b/content/blog/page2/index.html
@@ -159,6 +159,23 @@
<!-- Blog posts -->
<article>
+ <h2 class="blog-title"><a href="/news/2018/11/30/release-1.7.0.html">Apache Flink 1.7.0 Release Announcement</a></h2>
+
+ <p>30 Nov 2018
+ Till Rohrmann (<a href="https://twitter.com/stsffap">@stsffap</a>)</p>
+
+ <p><p>The Apache Flink community is pleased to announce Apache Flink 1.7.0.
+The latest release includes more than 420 resolved issues and some exciting additions to Flink that we describe in the following sections of this post.
+Please check the <a href="https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12315522&version=12343585">complete changelog</a> for more details.</p>
+
+</p>
+
+ <p><a href="/news/2018/11/30/release-1.7.0.html">Continue reading »</a></p>
+ </article>
+
+ <hr>
+
+ <article>
<h2 class="blog-title"><a href="/news/2018/10/29/release-1.6.2.html">Apache Flink 1.6.2 Released</a></h2>
<p>29 Oct 2018
@@ -293,21 +310,6 @@
<hr>
- <article>
- <h2 class="blog-title"><a href="/news/2018/03/15/release-1.3.3.html">Apache Flink 1.3.3 Released</a></h2>
-
- <p>15 Mar 2018
- </p>
-
- <p><p>The Apache Flink community released the third bugfix version of the Apache Flink 1.3 series.</p>
-
-</p>
-
- <p><a href="/news/2018/03/15/release-1.3.3.html">Continue reading »</a></p>
- </article>
-
- <hr>
-
<!-- Pagination links -->
@@ -340,6 +342,16 @@
<ul id="markdown-toc">
+ <li><a href="/news/2019/04/09/release-1.8.0.html">Apache Flink 1.8.0 Release Announcement</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/features/2019/03/11/prometheus-monitoring.html">Flink and Prometheus: Cloud-native monitoring of streaming applications</a></li>
diff --git a/content/blog/page3/index.html b/content/blog/page3/index.html
index 49f67c4..7700ac0 100644
--- a/content/blog/page3/index.html
+++ b/content/blog/page3/index.html
@@ -159,6 +159,21 @@
<!-- Blog posts -->
<article>
+ <h2 class="blog-title"><a href="/news/2018/03/15/release-1.3.3.html">Apache Flink 1.3.3 Released</a></h2>
+
+ <p>15 Mar 2018
+ </p>
+
+ <p><p>The Apache Flink community released the third bugfix version of the Apache Flink 1.3 series.</p>
+
+</p>
+
+ <p><a href="/news/2018/03/15/release-1.3.3.html">Continue reading »</a></p>
+ </article>
+
+ <hr>
+
+ <article>
<h2 class="blog-title"><a href="/news/2018/03/08/release-1.4.2.html">Apache Flink 1.4.2 Released</a></h2>
<p>08 Mar 2018
@@ -290,21 +305,6 @@ what’s coming in Flink 1.4.0 as well as a preview of what the Flink community
<hr>
- <article>
- <h2 class="blog-title"><a href="/news/2017/06/23/release-1.3.1.html">Apache Flink 1.3.1 Released</a></h2>
-
- <p>23 Jun 2017
- </p>
-
- <p><p>The Apache Flink community released the first bugfix version of the Apache Flink 1.3 series.</p>
-
-</p>
-
- <p><a href="/news/2017/06/23/release-1.3.1.html">Continue reading »</a></p>
- </article>
-
- <hr>
-
<!-- Pagination links -->
@@ -337,6 +337,16 @@ what’s coming in Flink 1.4.0 as well as a preview of what the Flink community
<ul id="markdown-toc">
+ <li><a href="/news/2019/04/09/release-1.8.0.html">Apache Flink 1.8.0 Release Announcement</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/features/2019/03/11/prometheus-monitoring.html">Flink and Prometheus: Cloud-native monitoring of streaming applications</a></li>
diff --git a/content/blog/page4/index.html b/content/blog/page4/index.html
index 3b70e9e..4e88300 100644
--- a/content/blog/page4/index.html
+++ b/content/blog/page4/index.html
@@ -159,6 +159,21 @@
<!-- Blog posts -->
<article>
+ <h2 class="blog-title"><a href="/news/2017/06/23/release-1.3.1.html">Apache Flink 1.3.1 Released</a></h2>
+
+ <p>23 Jun 2017
+ </p>
+
+ <p><p>The Apache Flink community released the first bugfix version of the Apache Flink 1.3 series.</p>
+
+</p>
+
+ <p><a href="/news/2017/06/23/release-1.3.1.html">Continue reading »</a></p>
+ </article>
+
+ <hr>
+
+ <article>
<h2 class="blog-title"><a href="/news/2017/06/01/release-1.3.0.html">Apache Flink 1.3.0 Release Announcement</a></h2>
<p>01 Jun 2017 by Robert Metzger (<a href="https://twitter.com/">@rmetzger_</a>)
@@ -286,21 +301,6 @@
<hr>
- <article>
- <h2 class="blog-title"><a href="/news/2016/10/12/release-1.1.3.html">Apache Flink 1.1.3 Released</a></h2>
-
- <p>12 Oct 2016
- </p>
-
- <p><p>The Apache Flink community released the next bugfix version of the Apache Flink 1.1. series.</p>
-
-</p>
-
- <p><a href="/news/2016/10/12/release-1.1.3.html">Continue reading »</a></p>
- </article>
-
- <hr>
-
<!-- Pagination links -->
@@ -333,6 +333,16 @@
<ul id="markdown-toc">
+ <li><a href="/news/2019/04/09/release-1.8.0.html">Apache Flink 1.8.0 Release Announcement</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/features/2019/03/11/prometheus-monitoring.html">Flink and Prometheus: Cloud-native monitoring of streaming applications</a></li>
diff --git a/content/blog/page5/index.html b/content/blog/page5/index.html
index 5c7a15d..8c5af89 100644
--- a/content/blog/page5/index.html
+++ b/content/blog/page5/index.html
@@ -159,6 +159,21 @@
<!-- Blog posts -->
<article>
+ <h2 class="blog-title"><a href="/news/2016/10/12/release-1.1.3.html">Apache Flink 1.1.3 Released</a></h2>
+
+ <p>12 Oct 2016
+ </p>
+
+ <p><p>The Apache Flink community released the next bugfix version of the Apache Flink 1.1. series.</p>
+
+</p>
+
+ <p><a href="/news/2016/10/12/release-1.1.3.html">Continue reading »</a></p>
+ </article>
+
+ <hr>
+
+ <article>
<h2 class="blog-title"><a href="/news/2016/09/05/release-1.1.2.html">Apache Flink 1.1.2 Released</a></h2>
<p>05 Sep 2016
@@ -290,21 +305,6 @@
<hr>
- <article>
- <h2 class="blog-title"><a href="/news/2016/04/06/release-1.0.1.html">Flink 1.0.1 Released</a></h2>
-
- <p>06 Apr 2016
- </p>
-
- <p><p>Today, the Flink community released Flink version <strong>1.0.1</strong>, the first bugfix release of the 1.0 series.</p>
-
-</p>
-
- <p><a href="/news/2016/04/06/release-1.0.1.html">Continue reading »</a></p>
- </article>
-
- <hr>
-
<!-- Pagination links -->
@@ -337,6 +337,16 @@
<ul id="markdown-toc">
+ <li><a href="/news/2019/04/09/release-1.8.0.html">Apache Flink 1.8.0 Release Announcement</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/features/2019/03/11/prometheus-monitoring.html">Flink and Prometheus: Cloud-native monitoring of streaming applications</a></li>
diff --git a/content/blog/page6/index.html b/content/blog/page6/index.html
index 40e7455..302f929 100644
--- a/content/blog/page6/index.html
+++ b/content/blog/page6/index.html
@@ -159,6 +159,21 @@
<!-- Blog posts -->
<article>
+ <h2 class="blog-title"><a href="/news/2016/04/06/release-1.0.1.html">Flink 1.0.1 Released</a></h2>
+
+ <p>06 Apr 2016
+ </p>
+
+ <p><p>Today, the Flink community released Flink version <strong>1.0.1</strong>, the first bugfix release of the 1.0 series.</p>
+
+</p>
+
+ <p><a href="/news/2016/04/06/release-1.0.1.html">Continue reading »</a></p>
+ </article>
+
+ <hr>
+
+ <article>
<h2 class="blog-title"><a href="/news/2016/03/08/release-1.0.0.html">Announcing Apache Flink 1.0.0</a></h2>
<p>08 Mar 2016
@@ -291,21 +306,6 @@ Apache Flink started.</p>
<hr>
- <article>
- <h2 class="blog-title"><a href="/news/2015/09/01/release-0.9.1.html">Apache Flink 0.9.1 available</a></h2>
-
- <p>01 Sep 2015
- </p>
-
- <p><p>The Flink community is happy to announce that Flink 0.9.1 is now available.</p>
-
-</p>
-
- <p><a href="/news/2015/09/01/release-0.9.1.html">Continue reading »</a></p>
- </article>
-
- <hr>
-
<!-- Pagination links -->
@@ -338,6 +338,16 @@ Apache Flink started.</p>
<ul id="markdown-toc">
+ <li><a href="/news/2019/04/09/release-1.8.0.html">Apache Flink 1.8.0 Release Announcement</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/features/2019/03/11/prometheus-monitoring.html">Flink and Prometheus: Cloud-native monitoring of streaming applications</a></li>
diff --git a/content/blog/page7/index.html b/content/blog/page7/index.html
index 354958f..53fdcd4 100644
--- a/content/blog/page7/index.html
+++ b/content/blog/page7/index.html
@@ -159,6 +159,21 @@
<!-- Blog posts -->
<article>
+ <h2 class="blog-title"><a href="/news/2015/09/01/release-0.9.1.html">Apache Flink 0.9.1 available</a></h2>
+
+ <p>01 Sep 2015
+ </p>
+
+ <p><p>The Flink community is happy to announce that Flink 0.9.1 is now available.</p>
+
+</p>
+
+ <p><a href="/news/2015/09/01/release-0.9.1.html">Continue reading »</a></p>
+ </article>
+
+ <hr>
+
+ <article>
<h2 class="blog-title"><a href="/news/2015/08/24/introducing-flink-gelly.html">Introducing Gelly: Graph Processing with Apache Flink</a></h2>
<p>24 Aug 2015
@@ -303,21 +318,6 @@ and offers a new API including definition of flexible windows.</p>
<hr>
- <article>
- <h2 class="blog-title"><a href="/news/2015/02/04/january-in-flink.html">January 2015 in the Flink community</a></h2>
-
- <p>04 Feb 2015
- </p>
-
- <p><p>Happy 2015! Here is a (hopefully digestible) summary of what happened last month in the Flink community.</p>
-
-</p>
-
- <p><a href="/news/2015/02/04/january-in-flink.html">Continue reading »</a></p>
- </article>
-
- <hr>
-
<!-- Pagination links -->
@@ -350,6 +350,16 @@ and offers a new API including definition of flexible windows.</p>
<ul id="markdown-toc">
+ <li><a href="/news/2019/04/09/release-1.8.0.html">Apache Flink 1.8.0 Release Announcement</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/features/2019/03/11/prometheus-monitoring.html">Flink and Prometheus: Cloud-native monitoring of streaming applications</a></li>
diff --git a/content/blog/page8/index.html b/content/blog/page8/index.html
index fb7c7cb..5b7d2bc 100644
--- a/content/blog/page8/index.html
+++ b/content/blog/page8/index.html
@@ -159,6 +159,21 @@
<!-- Blog posts -->
<article>
+ <h2 class="blog-title"><a href="/news/2015/02/04/january-in-flink.html">January 2015 in the Flink community</a></h2>
+
+ <p>04 Feb 2015
+ </p>
+
+ <p><p>Happy 2015! Here is a (hopefully digestible) summary of what happened last month in the Flink community.</p>
+
+</p>
+
+ <p><a href="/news/2015/02/04/january-in-flink.html">Continue reading »</a></p>
+ </article>
+
+ <hr>
+
+ <article>
<h2 class="blog-title"><a href="/news/2015/01/21/release-0.8.html">Apache Flink 0.8.0 available</a></h2>
<p>21 Jan 2015
@@ -298,6 +313,16 @@ academic and open source project that Flink originates from.</p>
<ul id="markdown-toc">
+ <li><a href="/news/2019/04/09/release-1.8.0.html">Apache Flink 1.8.0 Release Announcement</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/features/2019/03/11/prometheus-monitoring.html">Flink and Prometheus: Cloud-native monitoring of streaming applications</a></li>
diff --git a/content/index.html b/content/index.html
index c8527a4..e94bb86 100644
--- a/content/index.html
+++ b/content/index.html
@@ -448,6 +448,15 @@
<dl>
+ <dt> <a href="/news/2019/04/09/release-1.8.0.html">Apache Flink 1.8.0 Release Announcement</a></dt>
+ <dd><p>The Apache Flink community is pleased to announce Apache Flink 1.8.0. The
+latest release includes more than 420 resolved issues and some exciting
+additions to Flink that we describe in the following sections of this post.
+Please check the <a href="https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12315522&version=12344274">complete changelog</a>
+for more details.</p>
+
+</dd>
+
<dt> <a href="/features/2019/03/11/prometheus-monitoring.html">Flink and Prometheus: Cloud-native monitoring of streaming applications</a></dt>
<dd>This blog post describes how developers can leverage Apache Flink's built-in metrics system together with Prometheus to observe and monitor streaming applications in an effective way.</dd>
@@ -461,11 +470,6 @@
<dd><p>The Apache Flink community released the fourth bugfix version of the Apache Flink 1.6 series.</p>
</dd>
-
- <dt> <a href="/news/2019/02/15/release-1.7.2.html">Apache Flink 1.7.2 Released</a></dt>
- <dd><p>The Apache Flink community released the second bugfix version of the Apache Flink 1.7 series.</p>
-
-</dd>
</dl>
diff --git a/content/news/2019/04/09/release-1.8.0.html b/content/news/2019/04/09/release-1.8.0.html
new file mode 100644
index 0000000..e14bf4a
--- /dev/null
+++ b/content/news/2019/04/09/release-1.8.0.html
@@ -0,0 +1,484 @@
+<!DOCTYPE html>
+<html lang="en">
+ <head>
+ <meta charset="utf-8">
+ <meta http-equiv="X-UA-Compatible" content="IE=edge">
+ <meta name="viewport" content="width=device-width, initial-scale=1">
+ <!-- The above 3 meta tags *must* come first in the head; any other head content must come *after* these tags -->
+ <title>Apache Flink: Apache Flink 1.8.0 Release Announcement</title>
+ <link rel="shortcut icon" href="/favicon.ico" type="image/x-icon">
+ <link rel="icon" href="/favicon.ico" type="image/x-icon">
+
+ <!-- Bootstrap -->
+ <link rel="stylesheet" href="https://maxcdn.bootstrapcdn.com/bootstrap/3.3.4/css/bootstrap.min.css">
+ <link rel="stylesheet" href="/css/flink.css">
+ <link rel="stylesheet" href="/css/syntax.css">
+
+ <!-- Blog RSS feed -->
+ <link href="/blog/feed.xml" rel="alternate" type="application/rss+xml" title="Apache Flink Blog: RSS feed" />
+
+ <!-- jQuery (necessary for Bootstrap's JavaScript plugins) -->
+ <!-- We need to load Jquery in the header for custom google analytics event tracking-->
+ <script src="/js/jquery.min.js"></script>
+
+ <!-- HTML5 shim and Respond.js for IE8 support of HTML5 elements and media queries -->
+ <!-- WARNING: Respond.js doesn't work if you view the page via file:// -->
+ <!--[if lt IE 9]>
+ <script src="https://oss.maxcdn.com/html5shiv/3.7.2/html5shiv.min.js"></script>
+ <script src="https://oss.maxcdn.com/respond/1.4.2/respond.min.js"></script>
+ <![endif]-->
+ </head>
+ <body>
+
+
+ <!-- Main content. -->
+ <div class="container">
+ <div class="row">
+
+
+ <div id="sidebar" class="col-sm-3">
+
+
+<!-- Top navbar. -->
+ <nav class="navbar navbar-default">
+ <!-- The logo. -->
+ <div class="navbar-header">
+ <button type="button" class="navbar-toggle collapsed" data-toggle="collapse" data-target="#bs-example-navbar-collapse-1">
+ <span class="icon-bar"></span>
+ <span class="icon-bar"></span>
+ <span class="icon-bar"></span>
+ </button>
+ <div class="navbar-logo">
+ <a href="/">
+ <img alt="Apache Flink" src="/img/flink-header-logo.svg" width="147px" height="73px">
+ </a>
+ </div>
+ </div><!-- /.navbar-header -->
+
+ <!-- The navigation links. -->
+ <div class="collapse navbar-collapse" id="bs-example-navbar-collapse-1">
+ <ul class="nav navbar-nav navbar-main">
+
+ <!-- First menu section explains visitors what Flink is -->
+
+ <!-- What is Stream Processing? -->
+ <!--
+ <li><a href="/streamprocessing1.html">What is Stream Processing?</a></li>
+ -->
+
+ <!-- What is Flink? -->
+ <li><a href="/flink-architecture.html">What is Apache Flink?</a></li>
+
+ <!-- Use cases -->
+ <li><a href="/usecases.html">Use Cases</a></li>
+
+ <!-- Powered by -->
+ <li><a href="/poweredby.html">Powered By</a></li>
+
+ <!-- FAQ -->
+ <li><a href="/faq.html">FAQ</a></li>
+
+
+ <!-- Second menu section aims to support Flink users -->
+
+ <!-- Downloads -->
+ <li><a href="/downloads.html">Downloads</a></li>
+
+ <!-- Quickstart -->
+ <li>
+ <a href="https://ci.apache.org/projects/flink/flink-docs-release-1.8/quickstart/setup_quickstart.html" target="_blank">Tutorials <small><span class="glyphicon glyphicon-new-window"></span></small></a>
+ </li>
+
+ <!-- Documentation -->
+ <li class="dropdown">
+ <a class="dropdown-toggle" data-toggle="dropdown" href="#">Documentation<span class="caret"></span></a>
+ <ul class="dropdown-menu">
+ <li><a href="https://ci.apache.org/projects/flink/flink-docs-release-1.8" target="_blank">1.8 (Latest stable release) <small><span class="glyphicon glyphicon-new-window"></span></small></a></li>
+ <li><a href="https://ci.apache.org/projects/flink/flink-docs-master" target="_blank">1.9 (Snapshot) <small><span class="glyphicon glyphicon-new-window"></span></small></a></li>
+ </ul>
+ </li>
+
+ <!-- getting help -->
+ <li><a href="/gettinghelp.html">Getting Help</a></li>
+
+ <!-- Blog -->
+ <li class="active"><a href="/blog/"><b>Flink Blog</b></a></li>
+
+
+
+ <!-- Third menu section aim to support community and contributors -->
+
+ <!-- Community -->
+ <li><a href="/community.html">Community & Project Info</a></li>
+
+ <!-- Roadmap -->
+ <li><a href="/roadmap.html">Roadmap</a></li>
+
+ <!-- Contribute -->
+ <li><a href="/how-to-contribute.html">How to Contribute</a></li>
+
+ <!-- GitHub -->
+ <li>
+ <a href="https://github.com/apache/flink" target="_blank">Flink on GitHub <small><span class="glyphicon glyphicon-new-window"></span></small></a>
+ </li>
+
+
+
+ <!-- Language Switcher -->
+ <li>
+
+
+ <a href="/zh/news/2019/04/09/release-1.8.0.html">中文版</a>
+
+
+ </li>
+
+ </ul>
+
+ <ul class="nav navbar-nav navbar-bottom">
+ <hr />
+
+ <!-- Twitter -->
+ <li><a href="https://twitter.com/apacheflink" target="_blank">@ApacheFlink <small><span class="glyphicon glyphicon-new-window"></span></small></a></li>
+
+ <!-- Visualizer -->
+ <li class=" hidden-md hidden-sm"><a href="/visualizer/" target="_blank">Plan Visualizer <small><span class="glyphicon glyphicon-new-window"></span></small></a></li>
+
+ </ul>
+ </div><!-- /.navbar-collapse -->
+ </nav>
+
+ </div>
+ <div class="col-sm-9">
+ <div class="row-fluid">
+ <div class="col-sm-12">
+ <div class="row">
+ <h1>Apache Flink 1.8.0 Release Announcement</h1>
+
+ <article>
+ <p>09 Apr 2019 Aljoscha Krettek (<a href="https://twitter.com/aljoscha">@aljoscha</a>)</p>
+
+<p>The Apache Flink community is pleased to announce Apache Flink 1.8.0. The
+latest release includes more than 420 resolved issues and some exciting
+additions to Flink that we describe in the following sections of this post.
+Please check the <a href="https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12315522&version=12344274">complete changelog</a>
+for more details.</p>
+
+<p>Flink 1.8.0 is API-compatible with previous 1.x.y releases for APIs annotated
+with the <code>@Public</code> annotation. The release is available now and we encourage
+everyone to <a href="http://flink.apache.org/downloads.html">download the release</a> and
+check out the updated
+<a href="https://ci.apache.org/projects/flink/flink-docs-release-1.8/">documentation</a>.
+Feedback through the Flink <a href="http://flink.apache.org/community.html#mailing-lists">mailing
+lists</a> or
+<a href="https://issues.apache.org/jira/projects/FLINK/summary">JIRA</a> is, as always,
+very much appreciated!</p>
+
+<p>You can find the binaries on the updated <a href="http://flink.apache.org/downloads.html">Downloads page</a> on the Flink project site.</p>
+
+<div class="page-toc">
+<ul id="markdown-toc">
+ <li><a href="#new-features-and-improvements" id="markdown-toc-new-features-and-improvements">New Features and Improvements</a></li>
+ <li><a href="#important-changes" id="markdown-toc-important-changes">Important Changes</a></li>
+ <li><a href="#known-issues" id="markdown-toc-known-issues">Known Issues</a></li>
+ <li><a href="#release-notes" id="markdown-toc-release-notes">Release Notes</a></li>
+ <li><a href="#list-of-contributors" id="markdown-toc-list-of-contributors">List of Contributors</a></li>
+</ul>
+
+</div>
+
+<p>With Flink 1.8.0 we come closer to our goals of enabling fast data processing
+and building data-intensive applications for the Flink community in a seamless
+way. We do this by cleaning up and refactoring Flink under the hood to allow
+more efficient feature development in the future. This includes removal of the
+legacy runtime components that were subsumed in the major rework of Flink’s
+underlying distributed system architecture
+(<a href="https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=65147077">FLIP-6</a>)
+as well as refactorings on the Table API that prepare it for the future
+addition of the Blink enhancements
+(<a href="https://issues.apache.org/jira/browse/FLINK-11439">FLINK-11439</a>).</p>
+
+<p>Nevertheless, this release includes some important new features and bug fixes.
+The most interesting of those are highlighted below. Please consult the
+<a href="https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12315522&version=12344274">complete changelog</a>
+and the <a href="https://ci.apache.org/projects/flink/flink-docs-release-1.8/release-notes/flink-1.8.html">release notes</a>
+for more details.</p>
+
+<h2 id="new-features-and-improvements">New Features and Improvements</h2>
+
+<ul>
+ <li>
+ <p><strong>Finalized State Schema Evolution Story</strong>: This release completes
+the community driven effort to provide a schema evolution story for
+user state managed by Flink. This has been an effort that spanned 2
+releases, starting from 1.7.0 with the introduction of support for
+Avro state schema evolution as well as a revamped serialization
+compatibility abstraction.</p>
+
+ <p>Flink 1.8.0 finalizes this effort by extending support for schema
+evolution to POJOs, upgrading all Flink built-in serializers to use
+the new serialization compatibility abstractions, as well as making it
+easier for advanced users who use custom state serializers to
+implement the abstractions. These different aspects for a complete
+out-of-the-box schema evolution story are explained in detail below:</p>
+
+ <ol>
+ <li>
+ <p>Support for POJO state schema evolution: The pool of data types
+that support state schema evolution has been expanded to include
+POJOs. For state types that use POJOs, you can now add or remove
+fields from your POJO while retaining backwards
+compatibility. For a full overview of the list of data types that
+now support schema evolution as well as their evolution
+specifications and limitations, please refer to the State Schema
+Evolution documentation page.</p>
+ </li>
+ <li>
+ <p>Upgrade all Flink serializers to use new serialization
+compatibility asbtractions: Back in 1.7.0, we introduced the new
+serialization compatibility abstractions <code>TypeSerializerSnapshot</code>
+and <code>TypeSerializerSchemaCompatibility</code>. Besides providing a more
+expressible API to reflect schema compatibility between the data
+stored in savepoints and the data registered at runtime, another
+important aspect about the new abstraction is that it avoids the
+need for Flink to Java-serialize the state serializer as state
+metadata in savepoints.</p>
+
+ <p>In 1.8.0, all of Flink’s built-in serializers have been upgraded to
+use the new abstractions, and therefore the serializers
+themselves are no longer Java-serialized into savepoints. This
+greatly improves interoperability of Flink savepoints, in terms
+of state schema evolvability. For example, one outcome was the
+support for POJO schema evolution, as previously mentioned
+above. Another outcome is that all composite data types supported
+by Flink (such as <code>Either</code>, Scala case classes, Flink Java
+<code>Tuple</code>s, etc.) are generally evolve-able as well when they have
+a nested evolvable type, such as a POJO. For example, the <code>MyPojo</code>
+type in <code>ValueState<Tuple2<Integer, MyPojo>></code> or
+<code>ListState<Either<Integer, MyPojo>></code>, which is a POJO, is allowed
+to evolve its schema.</p>
+
+ <p>For users who are using custom <code>TypeSerializer</code> implementations
+for their state serializer and are still using the outdated
+abstractions (i.e. <code>TypeSerializerConfigSnapshot</code> and
+<code>CompatiblityResult</code>), we highly recommend upgrading to the new
+abstractions to be future proof. Please refer to the Custom State
+Serialization documentation page for a detailed description on
+the new abstractions.</p>
+ </li>
+ <li>
+ <p>Provide pre-defined snapshot implementations for common
+serializers: For convenience, Flink 1.8.0 comes with two
+predefined implementations for the <code>TypeSerializerSnapshot</code> that
+make the task of implementing these new abstractions easier
+for most implementations of <code>TypeSerializer</code>s -
+<code>SimpleTypeSerializerSnapshot</code> and
+<code>CompositeTypeSerializerSnapshot</code>. This section in the
+documentation provides information on how to use these classes.</p>
+ </li>
+ </ol>
+ </li>
+ <li>
+ <p><strong>Continuous cleanup of old state based on TTL
+(<a href="https://issues.apache.org/jira/browse/FLINK-7811">FLINK-7811</a>)</strong>: We
+introduced TTL (time-to-live) for Keyed state in Flink 1.6
+(<a href="https://issues.apache.org/jira/browse/FLINK-9510">FLINK-9510</a>). This
+feature enabled cleanup and made keyed state entries inaccessible after a
+defined timeout. In addition state would now also be cleaned up when
+writing a savepoint/checkpoint.</p>
+
+ <p>Flink 1.8 introduces continuous cleanup of old entries for both the RocksDB
+state backend
+(<a href="https://issues.apache.org/jira/browse/FLINK-10471">FLINK-10471</a>) and the heap
+state backend
+(<a href="https://issues.apache.org/jira/browse/FLINK-10473">FLINK-10473</a>). This means
+that old entries (according to the TTL setting) are continuously cleaned up.</p>
+ </li>
+ <li>
+ <p><strong>SQL pattern detection with user-defined functions and
+aggregations</strong>: The support of the MATCH_RECOGNIZE clause has been
+extended by multiple features. The addition of user-defined
+functions allows for custom logic during pattern detection
+(<a href="https://issues.apache.org/jira/browse/FLINK-10597">FLINK-10597</a>),
+while adding aggregations allows for more complex CEP definitions,
+such as the following
+(<a href="https://issues.apache.org/jira/browse/FLINK-7599">FLINK-7599</a>).</p>
+
+ <div class="highlight"><pre><code>SELECT *
+FROM Ticker
+ MATCH_RECOGNIZE (
+ ORDER BY rowtime
+ MEASURES
+ AVG(A.price) AS avgPrice
+ ONE ROW PER MATCH
+ AFTER MATCH SKIP TO FIRST B
+ PATTERN (A+ B)
+ DEFINE
+ A AS AVG(A.price) < 15
+ ) MR;
+</code></pre></div>
+ </li>
+ <li>
+ <p><strong>RFC-compliant CSV format (<a href="https://issues.apache.org/jira/browse/FLINK-9964">FLINK-9964</a>)</strong>: The SQL tables can now be read and written in
+an RFC-4180 standard compliant CSV table format. The format might also be
+useful for general DataStream API users.</p>
+ </li>
+ <li>
+ <p><strong>New KafkaDeserializationSchema that gives direct access to ConsumerRecord
+(<a href="https://issues.apache.org/jira/browse/FLINK-8354">FLINK-8354</a>)</strong>: For the
+Flink <code>KafkaConsumers</code>, we introduced a new <code>KafkaDeserializationSchema</code> that
+gives direct access to the Kafka <code>ConsumerRecord</code>. This now allows access to
+all data that Kafka provides for a record, including the headers. This
+subsumes the <code>KeyedSerializationSchema</code> functionality, which is deprecated but
+still available for now.</p>
+ </li>
+ <li>
+ <p><strong>Per-shard watermarking option in FlinkKinesisConsumer
+(<a href="https://issues.apache.org/jira/browse/FLINK-5697">FLINK-5697</a>)</strong>: The Kinesis
+Consumer can now emit periodic watermarks that are derived from per-shard watermarks,
+for correct event time processing with subtasks that consume multiple Kinesis shards.</p>
+ </li>
+ <li>
+ <p><strong>New consumer for DynamoDB Streams to capture table changes
+(<a href="https://issues.apache.org/jira/browse/FLINK-4582">FLINK-4582</a>)</strong>: <code>FlinkDynamoDBStreamsConsumer</code>
+is a variant of the Kinesis consumer that supports retrieval of CDC-like streams from DynamoDB tables.</p>
+ </li>
+ <li>
+ <p><strong>Support for global aggregates for subtask coordination
+(<a href="https://issues.apache.org/jira/browse/FLINK-10887">FLINK-10887</a>)</strong>:
+Designed as a solution for global source watermark tracking, <code>GlobalAggregateManager</code>
+allows sharing of information between parallel subtasks. This feature will
+be integrated into streaming connectors for watermark synchronization and
+can be used for other purposes with a user defined aggregator.</p>
+ </li>
+</ul>
+
+<h2 id="important-changes">Important Changes</h2>
+
+<ul>
+ <li>
+ <p><strong>Changes to bundling of Hadoop libraries with Flink
+(<a href="https://issues.apache.org/jira/browse/FLINK-11266">FLINK-11266</a>)</strong>:
+Convenience binaries that include hadoop are no longer released.</p>
+
+ <p>If a deployment relies on <code>flink-shaded-hadoop2</code> being included in
+<code>flink-dist</code>, then you must manually download a pre-packaged Hadoop
+jar from the optional components section of the <a href="https://flink.apache.org/downloads.html">download
+page</a> and copy it into the
+<code>/lib</code> directory. Alternatively, a Flink distribution that includes
+hadoop can be built by packaging <code>flink-dist</code> and activating the
+<code>include-hadoop</code> maven profile.</p>
+
+ <p>As hadoop is no longer included in <code>flink-dist</code> by default, specifying
+<code>-DwithoutHadoop</code> when packaging <code>flink-dist</code> no longer impacts the build.</p>
+ </li>
+ <li>
+ <p><strong>FlinkKafkaConsumer will now filter restored partitions based on topic
+specification
+(<a href="https://issues.apache.org/jira/browse/FLINK-10342">FLINK-10342</a>)</strong>:
+Starting from Flink 1.8.0, the <code>FlinkKafkaConsumer</code> now always filters out
+restored partitions that are no longer associated with a specified topic to
+subscribe to in the restored execution. This behaviour did not exist in
+previous versions of the <code>FlinkKafkaConsumer</code>. If you wish to retain the
+previous behaviour, please use the
+<code>disableFilterRestoredPartitionsWithSubscribedTopics()</code> configuration method
+on the <code>FlinkKafkaConsumer</code>.</p>
+
+ <p>Consider this example: if you had a Kafka Consumer that was consuming from
+topic <code>A</code>, you did a savepoint, then changed your Kafka consumer to instead
+consume from topic <code>B</code>, and then restarted your job from the savepoint.
+Before this change, your consumer would now consume from both topic <code>A</code> and
+<code>B</code> because it was stored in state that the consumer was consuming from topic
+<code>A</code>. With the change, your consumer would only consume from topic <code>B</code> after
+restore because it now filters the topics that are stored in state using the
+configured topics.</p>
+ </li>
+ <li>
+ <p><strong>Change in the Maven modules of Table API
+(<a href="https://issues.apache.org/jira/browse/FLINK-11064">FLINK-11064</a>)</strong>: Users
+that had a <code>flink-table</code> dependency before, need to update their
+dependencies to <code>flink-table-planner</code> and the correct dependency of
+<code>flink-table-api-*</code>, depending on whether Java or Scala is used: one of
+<code>flink-table-api-java-bridge</code> or <code>flink-table-api-scala-bridge</code>.</p>
+ </li>
+</ul>
+
+<h2 id="known-issues">Known Issues</h2>
+
+<ul>
+ <li><strong>Discarded checkpoint can cause Tasks to fail
+(<a href="https://issues.apache.org/jira/browse/FLINK-11662">FLINK-11662</a>)</strong>: There is
+a race condition that can lead to erroneous checkpoint failures. This mostly
+occurs when restarting from a savepoint or checkpoint takes a long time at the
+sources of a job. If you see random checkpointing failures that don’t seem to
+have a good explanation you might be affected. Please see the Jira issue for
+more details and a workaround for the problem.</li>
+</ul>
+
+<h2 id="release-notes">Release Notes</h2>
+
+<p>Please review the <a href="https://ci.apache.org/projects/flink/flink-docs-release-1.8/release-notes/flink-1.8.html">release
+notes</a>
+for a more detailed list of changes and new features if you plan to upgrade
+your Flink setup to Flink 1.8.</p>
+
+<h2 id="list-of-contributors">List of Contributors</h2>
+
+<p>We would like to acknowledge all community members for contributing to this
+release. Special credits go to the following members for contributing to the
+1.8.0 release (according to <code>git log --pretty="%an" release-1.7.0..release-1.8.0 | sort | uniq</code> without manual deduplication):</p>
+
+<p>Addison Higham, Aitozi, Aleksey Pak, Alexander Fedulov, Alexey Trenikhin, Aljoscha Krettek, Andrey Zagrebin, Artsem Semianenka, Asura7969, Avi, Barisa Obradovic, Benchao Li, Bo WANG, Chesnay Schepler, Congxian Qiu, Cristian, David Anderson, Dawid Wysakowicz, Dian Fu, DuBin, EAlexRojas, EronWright, Eugen Yushin, Fabian Hueske, Fokko Driesprong, Gary Yao, Hequn Cheng, Igal Shilman, Jamie Grier, JaryZhen, Jeff Zhang, Jihyun Cho, Jinhu Wu, Joerg Schad, KarmaGYZ, Kezhu Wang, Konstantin Kna [...]
+
+
+ </article>
+ </div>
+
+ <div class="row">
+ <div id="disqus_thread"></div>
+ <script type="text/javascript">
+ /* * * CONFIGURATION VARIABLES: EDIT BEFORE PASTING INTO YOUR WEBPAGE * * */
+ var disqus_shortname = 'stratosphere-eu'; // required: replace example with your forum shortname
+
+ /* * * DON'T EDIT BELOW THIS LINE * * */
+ (function() {
+ var dsq = document.createElement('script'); dsq.type = 'text/javascript'; dsq.async = true;
+ dsq.src = '//' + disqus_shortname + '.disqus.com/embed.js';
+ (document.getElementsByTagName('head')[0] || document.getElementsByTagName('body')[0]).appendChild(dsq);
+ })();
+ </script>
+ </div>
+ </div>
+</div>
+ </div>
+ </div>
+
+ <hr />
+
+ <div class="row">
+ <div class="footer text-center col-sm-12">
+ <p>Copyright © 2014-2019 <a href="http://apache.org">The Apache Software Foundation</a>. All Rights Reserved.</p>
+ <p>Apache Flink, Flink®, Apache®, the squirrel logo, and the Apache feather logo are either registered trademarks or trademarks of The Apache Software Foundation.</p>
+ <p><a href="/privacy-policy.html">Privacy Policy</a> · <a href="/blog/feed.xml">RSS feed</a></p>
+ </div>
+ </div>
+ </div><!-- /.container -->
+
+ <!-- Include all compiled plugins (below), or include individual files as needed -->
+ <script src="https://maxcdn.bootstrapcdn.com/bootstrap/3.3.4/js/bootstrap.min.js"></script>
+ <script src="https://cdnjs.cloudflare.com/ajax/libs/jquery.matchHeight/0.7.0/jquery.matchHeight-min.js"></script>
+ <script src="/js/codetabs.js"></script>
+ <script src="/js/stickysidebar.js"></script>
+
+ <!-- Google Analytics -->
+ <script>
+ (function(i,s,o,g,r,a,m){i['GoogleAnalyticsObject']=r;i[r]=i[r]||function(){
+ (i[r].q=i[r].q||[]).push(arguments)},i[r].l=1*new Date();a=s.createElement(o),
+ m=s.getElementsByTagName(o)[0];a.async=1;a.src=g;m.parentNode.insertBefore(a,m)
+ })(window,document,'script','//www.google-analytics.com/analytics.js','ga');
+
+ ga('create', 'UA-52545728-1', 'auto');
+ ga('send', 'pageview');
+ </script>
+ </body>
+</html>
diff --git a/content/zh/index.html b/content/zh/index.html
index b137245..ef5852f 100644
--- a/content/zh/index.html
+++ b/content/zh/index.html
@@ -446,6 +446,15 @@
<dl>
+ <dt> <a href="/news/2019/04/09/release-1.8.0.html">Apache Flink 1.8.0 Release Announcement</a></dt>
+ <dd><p>The Apache Flink community is pleased to announce Apache Flink 1.8.0. The
+latest release includes more than 420 resolved issues and some exciting
+additions to Flink that we describe in the following sections of this post.
+Please check the <a href="https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12315522&version=12344274">complete changelog</a>
+for more details.</p>
+
+</dd>
+
<dt> <a href="/features/2019/03/11/prometheus-monitoring.html">Flink and Prometheus: Cloud-native monitoring of streaming applications</a></dt>
<dd>This blog post describes how developers can leverage Apache Flink's built-in metrics system together with Prometheus to observe and monitor streaming applications in an effective way.</dd>
@@ -459,11 +468,6 @@
<dd><p>The Apache Flink community released the fourth bugfix version of the Apache Flink 1.6 series.</p>
</dd>
-
- <dt> <a href="/news/2019/02/15/release-1.7.2.html">Apache Flink 1.7.2 Released</a></dt>
- <dd><p>The Apache Flink community released the second bugfix version of the Apache Flink 1.7 series.</p>
-
-</dd>
</dl>
[flink-web] 01/02: Add Flink 1.8.0 release blog post
Posted by al...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
aljoscha pushed a commit to branch asf-site
in repository https://gitbox.apache.org/repos/asf/flink-web.git
commit f6b83672ab166532a7f2a09c3cc0b530ec529c7a
Author: Aljoscha Krettek <al...@gmail.com>
AuthorDate: Wed Apr 10 10:05:03 2019 +0200
Add Flink 1.8.0 release blog post
---
_posts/2019-04-09-release-1.8.0.md | 253 +++++++++++++++++++++++++++++++++++++
1 file changed, 253 insertions(+)
diff --git a/_posts/2019-04-09-release-1.8.0.md b/_posts/2019-04-09-release-1.8.0.md
new file mode 100644
index 0000000..6ff8107
--- /dev/null
+++ b/_posts/2019-04-09-release-1.8.0.md
@@ -0,0 +1,253 @@
+---
+layout: post
+title: "Apache Flink 1.8.0 Release Announcement"
+date: 2019-4-9 12:00:00
+categories: news
+authors:
+- till:
+ name: "Aljoscha Krettek"
+ twitter: "aljoscha"
+---
+
+The Apache Flink community is pleased to announce Apache Flink 1.8.0. The
+latest release includes more than 420 resolved issues and some exciting
+additions to Flink that we describe in the following sections of this post.
+Please check the [complete changelog](https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12315522&version=12344274)
+for more details.
+
+Flink 1.8.0 is API-compatible with previous 1.x.y releases for APIs annotated
+with the `@Public` annotation. The release is available now and we encourage
+everyone to [download the release](http://flink.apache.org/downloads.html) and
+check out the updated
+[documentation](https://ci.apache.org/projects/flink/flink-docs-release-1.8/).
+Feedback through the Flink [mailing
+lists](http://flink.apache.org/community.html#mailing-lists) or
+[JIRA](https://issues.apache.org/jira/projects/FLINK/summary) is, as always,
+very much appreciated!
+
+You can find the binaries on the updated [Downloads page](http://flink.apache.org/downloads.html) on the Flink project site.
+
+{% toc %}
+
+With Flink 1.8.0 we come closer to our goals of enabling fast data processing
+and building data-intensive applications for the Flink community in a seamless
+way. We do this by cleaning up and refactoring Flink under the hood to allow
+more efficient feature development in the future. This includes removal of the
+legacy runtime components that were subsumed in the major rework of Flink's
+underlying distributed system architecture
+([FLIP-6](https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=65147077))
+as well as refactorings on the Table API that prepare it for the future
+addition of the Blink enhancements
+([FLINK-11439](https://issues.apache.org/jira/browse/FLINK-11439)).
+
+Nevertheless, this release includes some important new features and bug fixes.
+The most interesting of those are highlighted below. Please consult the
+[complete changelog](https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12315522&version=12344274)
+and the [release notes](https://ci.apache.org/projects/flink/flink-docs-release-1.8/release-notes/flink-1.8.html)
+for more details.
+
+
+## New Features and Improvements
+
+* **Finalized State Schema Evolution Story**: This release completes
+ the community driven effort to provide a schema evolution story for
+ user state managed by Flink. This has been an effort that spanned 2
+ releases, starting from 1.7.0 with the introduction of support for
+ Avro state schema evolution as well as a revamped serialization
+ compatibility abstraction.
+
+ Flink 1.8.0 finalizes this effort by extending support for schema
+ evolution to POJOs, upgrading all Flink built-in serializers to use
+ the new serialization compatibility abstractions, as well as making it
+ easier for advanced users who use custom state serializers to
+ implement the abstractions. These different aspects for a complete
+ out-of-the-box schema evolution story are explained in detail below:
+
+ 1. Support for POJO state schema evolution: The pool of data types
+ that support state schema evolution has been expanded to include
+ POJOs. For state types that use POJOs, you can now add or remove
+ fields from your POJO while retaining backwards
+ compatibility. For a full overview of the list of data types that
+ now support schema evolution as well as their evolution
+ specifications and limitations, please refer to the State Schema
+ Evolution documentation page.
+
+
+ 2. Upgrade all Flink serializers to use new serialization
+ compatibility asbtractions: Back in 1.7.0, we introduced the new
+ serialization compatibility abstractions `TypeSerializerSnapshot`
+ and `TypeSerializerSchemaCompatibility`. Besides providing a more
+ expressible API to reflect schema compatibility between the data
+ stored in savepoints and the data registered at runtime, another
+ important aspect about the new abstraction is that it avoids the
+ need for Flink to Java-serialize the state serializer as state
+ metadata in savepoints.
+
+ In 1.8.0, all of Flink's built-in serializers have been upgraded to
+ use the new abstractions, and therefore the serializers
+ themselves are no longer Java-serialized into savepoints. This
+ greatly improves interoperability of Flink savepoints, in terms
+ of state schema evolvability. For example, one outcome was the
+ support for POJO schema evolution, as previously mentioned
+ above. Another outcome is that all composite data types supported
+ by Flink (such as `Either`, Scala case classes, Flink Java
+ `Tuple`s, etc.) are generally evolve-able as well when they have
+ a nested evolvable type, such as a POJO. For example, the `MyPojo`
+ type in `ValueState<Tuple2<Integer, MyPojo>>` or
+ `ListState<Either<Integer, MyPojo>>`, which is a POJO, is allowed
+ to evolve its schema.
+
+ For users who are using custom `TypeSerializer` implementations
+ for their state serializer and are still using the outdated
+ abstractions (i.e. `TypeSerializerConfigSnapshot` and
+ `CompatiblityResult`), we highly recommend upgrading to the new
+ abstractions to be future proof. Please refer to the Custom State
+ Serialization documentation page for a detailed description on
+ the new abstractions.
+
+ 3. Provide pre-defined snapshot implementations for common
+ serializers: For convenience, Flink 1.8.0 comes with two
+ predefined implementations for the `TypeSerializerSnapshot` that
+ make the task of implementing these new abstractions easier
+ for most implementations of `TypeSerializer`s -
+ `SimpleTypeSerializerSnapshot` and
+ `CompositeTypeSerializerSnapshot`. This section in the
+ documentation provides information on how to use these classes.
+
+* **Continuous cleanup of old state based on TTL
+ ([FLINK-7811](https://issues.apache.org/jira/browse/FLINK-7811))**: We
+ introduced TTL (time-to-live) for Keyed state in Flink 1.6
+ ([FLINK-9510](https://issues.apache.org/jira/browse/FLINK-9510)). This
+ feature enabled cleanup and made keyed state entries inaccessible after a
+ defined timeout. In addition state would now also be cleaned up when
+ writing a savepoint/checkpoint.
+
+ Flink 1.8 introduces continuous cleanup of old entries for both the RocksDB
+ state backend
+ ([FLINK-10471](https://issues.apache.org/jira/browse/FLINK-10471)) and the heap
+ state backend
+ ([FLINK-10473](https://issues.apache.org/jira/browse/FLINK-10473)). This means
+ that old entries (according to the TTL setting) are continuously cleaned up.
+
+* **SQL pattern detection with user-defined functions and
+ aggregations**: The support of the MATCH_RECOGNIZE clause has been
+ extended by multiple features. The addition of user-defined
+ functions allows for custom logic during pattern detection
+ ([FLINK-10597](https://issues.apache.org/jira/browse/FLINK-10597)),
+ while adding aggregations allows for more complex CEP definitions,
+ such as the following
+ ([FLINK-7599](https://issues.apache.org/jira/browse/FLINK-7599)).
+
+ ```
+ SELECT *
+ FROM Ticker
+ MATCH_RECOGNIZE (
+ ORDER BY rowtime
+ MEASURES
+ AVG(A.price) AS avgPrice
+ ONE ROW PER MATCH
+ AFTER MATCH SKIP TO FIRST B
+ PATTERN (A+ B)
+ DEFINE
+ A AS AVG(A.price) < 15
+ ) MR;
+ ```
+
+* **RFC-compliant CSV format ([FLINK-9964](https://issues.apache.org/jira/browse/FLINK-9964))**: The SQL tables can now be read and written in
+ an RFC-4180 standard compliant CSV table format. The format might also be
+ useful for general DataStream API users.
+
+* **New KafkaDeserializationSchema that gives direct access to ConsumerRecord
+ ([FLINK-8354](https://issues.apache.org/jira/browse/FLINK-8354))**: For the
+ Flink `KafkaConsumers`, we introduced a new `KafkaDeserializationSchema` that
+ gives direct access to the Kafka `ConsumerRecord`. This now allows access to
+ all data that Kafka provides for a record, including the headers. This
+ subsumes the `KeyedSerializationSchema` functionality, which is deprecated but
+ still available for now.
+
+* **Per-shard watermarking option in FlinkKinesisConsumer
+ ([FLINK-5697](https://issues.apache.org/jira/browse/FLINK-5697))**: The Kinesis
+ Consumer can now emit periodic watermarks that are derived from per-shard watermarks,
+ for correct event time processing with subtasks that consume multiple Kinesis shards.
+
+* **New consumer for DynamoDB Streams to capture table changes
+ ([FLINK-4582](https://issues.apache.org/jira/browse/FLINK-4582))**: `FlinkDynamoDBStreamsConsumer`
+ is a variant of the Kinesis consumer that supports retrieval of CDC-like streams from DynamoDB tables.
+
+* **Support for global aggregates for subtask coordination
+ ([FLINK-10887](https://issues.apache.org/jira/browse/FLINK-10887))**:
+ Designed as a solution for global source watermark tracking, `GlobalAggregateManager`
+ allows sharing of information between parallel subtasks. This feature will
+ be integrated into streaming connectors for watermark synchronization and
+ can be used for other purposes with a user defined aggregator.
+
+## Important Changes
+
+* **Changes to bundling of Hadoop libraries with Flink
+ ([FLINK-11266](https://issues.apache.org/jira/browse/FLINK-11266))**:
+ Convenience binaries that include hadoop are no longer released.
+
+ If a deployment relies on `flink-shaded-hadoop2` being included in
+ `flink-dist`, then you must manually download a pre-packaged Hadoop
+ jar from the optional components section of the [download
+ page](https://flink.apache.org/downloads.html) and copy it into the
+ `/lib` directory. Alternatively, a Flink distribution that includes
+ hadoop can be built by packaging `flink-dist` and activating the
+ `include-hadoop` maven profile.
+
+ As hadoop is no longer included in `flink-dist` by default, specifying
+ `-DwithoutHadoop` when packaging `flink-dist` no longer impacts the build.
+
+* **FlinkKafkaConsumer will now filter restored partitions based on topic
+ specification
+ ([FLINK-10342](https://issues.apache.org/jira/browse/FLINK-10342))**:
+ Starting from Flink 1.8.0, the `FlinkKafkaConsumer` now always filters out
+ restored partitions that are no longer associated with a specified topic to
+ subscribe to in the restored execution. This behaviour did not exist in
+ previous versions of the `FlinkKafkaConsumer`. If you wish to retain the
+ previous behaviour, please use the
+ `disableFilterRestoredPartitionsWithSubscribedTopics()` configuration method
+ on the `FlinkKafkaConsumer`.
+
+ Consider this example: if you had a Kafka Consumer that was consuming from
+ topic `A`, you did a savepoint, then changed your Kafka consumer to instead
+ consume from topic `B`, and then restarted your job from the savepoint.
+ Before this change, your consumer would now consume from both topic `A` and
+ `B` because it was stored in state that the consumer was consuming from topic
+ `A`. With the change, your consumer would only consume from topic `B` after
+ restore because it now filters the topics that are stored in state using the
+ configured topics.
+
+ * **Change in the Maven modules of Table API
+ ([FLINK-11064](https://issues.apache.org/jira/browse/FLINK-11064))**: Users
+ that had a `flink-table` dependency before, need to update their
+ dependencies to `flink-table-planner` and the correct dependency of
+ `flink-table-api-*`, depending on whether Java or Scala is used: one of
+ `flink-table-api-java-bridge` or `flink-table-api-scala-bridge`.
+
+## Known Issues
+
+* **Discarded checkpoint can cause Tasks to fail
+ ([FLINK-11662](https://issues.apache.org/jira/browse/FLINK-11662))**: There is
+ a race condition that can lead to erroneous checkpoint failures. This mostly
+ occurs when restarting from a savepoint or checkpoint takes a long time at the
+ sources of a job. If you see random checkpointing failures that don't seem to
+ have a good explanation you might be affected. Please see the Jira issue for
+ more details and a workaround for the problem.
+
+
+## Release Notes
+
+Please review the [release
+notes](https://ci.apache.org/projects/flink/flink-docs-release-1.8/release-notes/flink-1.8.html)
+for a more detailed list of changes and new features if you plan to upgrade
+your Flink setup to Flink 1.8.
+
+## List of Contributors
+
+We would like to acknowledge all community members for contributing to this
+release. Special credits go to the following members for contributing to the
+1.8.0 release (according to `git log --pretty="%an" release-1.7.0..release-1.8.0 | sort | uniq` without manual deduplication):
+
+Addison Higham, Aitozi, Aleksey Pak, Alexander Fedulov, Alexey Trenikhin, Aljoscha Krettek, Andrey Zagrebin, Artsem Semianenka, Asura7969, Avi, Barisa Obradovic, Benchao Li, Bo WANG, Chesnay Schepler, Congxian Qiu, Cristian, David Anderson, Dawid Wysakowicz, Dian Fu, DuBin, EAlexRojas, EronWright, Eugen Yushin, Fabian Hueske, Fokko Driesprong, Gary Yao, Hequn Cheng, Igal Shilman, Jamie Grier, JaryZhen, Jeff Zhang, Jihyun Cho, Jinhu Wu, Joerg Schad, KarmaGYZ, Kezhu Wang, Konstantin Knauf, [...]
+