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 2017/08/05 07:01:15 UTC
[1/2] flink-web git commit: Regenerate website
Repository: flink-web
Updated Branches:
refs/heads/asf-site c5c255321 -> 673d72c26
Regenerate website
Project: http://git-wip-us.apache.org/repos/asf/flink-web/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink-web/commit/673d72c2
Tree: http://git-wip-us.apache.org/repos/asf/flink-web/tree/673d72c2
Diff: http://git-wip-us.apache.org/repos/asf/flink-web/diff/673d72c2
Branch: refs/heads/asf-site
Commit: 673d72c26f44977c58044a01caa0468252c6fe09
Parents: 21d2a85
Author: Aljoscha Krettek <al...@gmail.com>
Authored: Sat Aug 5 08:21:12 2017 +0200
Committer: Aljoscha Krettek <al...@gmail.com>
Committed: Sat Aug 5 08:59:36 2017 +0200
----------------------------------------------------------------------
content/blog/feed.xml | 212 +++++++++++++
content/blog/index.html | 36 ++-
content/blog/page2/index.html | 36 ++-
content/blog/page3/index.html | 35 ++-
content/blog/page4/index.html | 38 ++-
content/blog/page5/index.html | 26 ++
content/downloads.html | 33 +-
content/index.html | 10 +-
content/news/2017/08/05/release-1.3.2.html | 399 ++++++++++++++++++++++++
9 files changed, 750 insertions(+), 75 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink-web/blob/673d72c2/content/blog/feed.xml
----------------------------------------------------------------------
diff --git a/content/blog/feed.xml b/content/blog/feed.xml
index fb749d9..951e87a 100644
--- a/content/blog/feed.xml
+++ b/content/blog/feed.xml
@@ -7,6 +7,218 @@
<atom:link href="http://flink.apache.org/blog/feed.xml" rel="self" type="application/rss+xml" />
<item>
+<title>Apache Flink 1.3.2 Released</title>
+<description><p>The Apache Flink community released the second bugfix version of the Apache Flink 1.3 series.</p>
+
+<p>This release includes more than 60 fixes and minor improvements for Flink 1.3.1. The list below includes a detailed list of all fixes.</p>
+
+<p>We highly recommend all users to upgrade to Flink 1.3.2.</p>
+
+<div class="alert alert-warning">
+ Important Notice:
+
+ <p>A user reported a bug in the FlinkKafkaConsumer
+ (<a href="https://issues.apache.org/jira/browse/FLINK-7143">FLINK-7143</a>) that is causing
+ incorrect partition assignment in large Kafka deployments in the presence of inconsistent broker
+ metadata. In that case multiple parallel instances of the FlinkKafkaConsumer may read from the
+ same topic partition, leading to data duplication. In Flink 1.3.2 this bug is fixed but incorrect
+ assignments from Flink 1.3.0 and 1.3.1 cannot be automatically fixed by upgrading to Flink 1.3.2
+ via a savepoint because the upgraded version would resume the wrong partition assignment from the
+ savepoint. If you believe you are affected by this bug (seeing messages from some partitions
+ duplicated) please refer to the JIRA issue for an upgrade path that works around that.</p>
+
+ <p>Before attempting the more elaborate upgrade path, we would suggest to check if you are
+ actually affected by this bug. We did not manage to reproduce it in various testing clusters and
+ according to the reporting user, it only appeared in rare cases on their very large setup. This
+ leads us to believe that most likely only a minority of setups would be affected by this bug.</p>
+</div>
+
+<p>Notable changes:</p>
+
+<ul>
+ <li>The default Kafka version for Flink Kafka Consumer 0.10 was bumped from 0.10.0.1 to 0.10.2.1.</li>
+ <li>Some default values for configurations of AWS API call behaviors in the Flink Kinesis Consumer
+ were adapted for better default consumption performance: 1) <code>SHARD_GETRECORDS_MAX</code> default changed
+ to 10,000, and 2) <code>SHARD_GETRECORDS_INTERVAL_MILLIS</code> default changed to 200ms.</li>
+</ul>
+
+<p>Updated Maven dependencies:</p>
+
+<div class="highlight"><pre><code class="language-xml"><span class="nt">&lt;dependency&gt;</span>
+ <span class="nt">&lt;groupId&gt;</span>org.apache.flink<span class="nt">&lt;/groupId&gt;</span>
+ <span class="nt">&lt;artifactId&gt;</span>flink-java<span class="nt">&lt;/artifactId&gt;</span>
+ <span class="nt">&lt;version&gt;</span>1.3.2<span class="nt">&lt;/version&gt;</span>
+<span class="nt">&lt;/dependency&gt;</span>
+<span class="nt">&lt;dependency&gt;</span>
+ <span class="nt">&lt;groupId&gt;</span>org.apache.flink<span class="nt">&lt;/groupId&gt;</span>
+ <span class="nt">&lt;artifactId&gt;</span>flink-streaming-java_2.10<span class="nt">&lt;/artifactId&gt;</span>
+ <span class="nt">&lt;version&gt;</span>1.3.2<span class="nt">&lt;/version&gt;</span>
+<span class="nt">&lt;/dependency&gt;</span>
+<span class="nt">&lt;dependency&gt;</span>
+ <span class="nt">&lt;groupId&gt;</span>org.apache.flink<span class="nt">&lt;/groupId&gt;</span>
+ <span class="nt">&lt;artifactId&gt;</span>flink-clients_2.10<span class="nt">&lt;/artifactId&gt;</span>
+ <span class="nt">&lt;version&gt;</span>1.3.2<span class="nt">&lt;/version&gt;</span>
+<span class="nt">&lt;/dependency&gt;</span></code></pre></div>
+
+<p>You can find the binaries on the updated <a href="http://flink.apache.org/downloads.html">Downloads page</a>.</p>
+
+<p>List of resolved issues:</p>
+
+<h2> Sub-task
+</h2>
+<ul>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6665">FLINK-6665</a>] - Pass a ScheduledExecutorService to the RestartStrategy
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6667">FLINK-6667</a>] - Pass a callback type to the RestartStrategy, rather than the full ExecutionGraph
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6680">FLINK-6680</a>] - App &amp; Flink migration guide: updates for the 1.3 release
+</li>
+</ul>
+
+<h2> Bug
+</h2>
+<ul>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5488">FLINK-5488</a>] - yarnClient should be closed in AbstractYarnClusterDescriptor for error conditions
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6376">FLINK-6376</a>] - when deploy flink cluster on the yarn, it is lack of hdfs delegation token.
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6541">FLINK-6541</a>] - Jar upload directory not created
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6654">FLINK-6654</a>] - missing maven dependency on &quot;flink-shaded-hadoop2-uber&quot; in flink-dist
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6655">FLINK-6655</a>] - Misleading error message when HistoryServer path is empty
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6742">FLINK-6742</a>] - Improve error message when savepoint migration fails due to task removal
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6774">FLINK-6774</a>] - build-helper-maven-plugin version not set
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6806">FLINK-6806</a>] - rocksdb is not listed as state backend in doc
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6843">FLINK-6843</a>] - ClientConnectionTest fails on travis
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6867">FLINK-6867</a>] - Elasticsearch 1.x ITCase still instable due to embedded node instability
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6918">FLINK-6918</a>] - Failing tests: ChainLengthDecreaseTest and ChainLengthIncreaseTest
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6945">FLINK-6945</a>] - TaskCancelAsyncProducerConsumerITCase.testCancelAsyncProducerAndConsumer instable test case
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6964">FLINK-6964</a>] - Fix recovery for incremental checkpoints in StandaloneCompletedCheckpointStore
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6965">FLINK-6965</a>] - Avro is missing snappy dependency
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6987">FLINK-6987</a>] - TextInputFormatTest fails when run in path containing spaces
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6996">FLINK-6996</a>] - FlinkKafkaProducer010 doesn&#39;t guarantee at-least-once semantic
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-7005">FLINK-7005</a>] - Optimization steps are missing for nested registered tables
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-7011">FLINK-7011</a>] - Instable Kafka testStartFromKafkaCommitOffsets failures on Travis
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-7025">FLINK-7025</a>] - Using NullByteKeySelector for Unbounded ProcTime NonPartitioned Over
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-7034">FLINK-7034</a>] - GraphiteReporter cannot recover from lost connection
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-7038">FLINK-7038</a>] - Several misused &quot;KeyedDataStream&quot; term in docs and Javadocs
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-7041">FLINK-7041</a>] - Deserialize StateBackend from JobCheckpointingSettings with user classloader
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-7132">FLINK-7132</a>] - Fix BulkIteration parallelism
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-7133">FLINK-7133</a>] - Fix Elasticsearch version interference
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-7137">FLINK-7137</a>] - Flink table API defaults top level fields as nullable and all nested fields within CompositeType as non-nullable
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-7143">FLINK-7143</a>] - Partition assignment for Kafka consumer is not stable
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-7154">FLINK-7154</a>] - Missing call to build CsvTableSource example
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-7158">FLINK-7158</a>] - Wrong test jar dependency in flink-clients
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-7177">FLINK-7177</a>] - DataSetAggregateWithNullValuesRule fails creating null literal for non-nullable type
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-7178">FLINK-7178</a>] - Datadog Metric Reporter Jar is Lacking Dependencies
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-7180">FLINK-7180</a>] - CoGroupStream perform checkpoint failed
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-7195">FLINK-7195</a>] - FlinkKafkaConsumer should not respect fetched partitions to filter restored partition states
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-7216">FLINK-7216</a>] - ExecutionGraph can perform concurrent global restarts to scheduling
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-7225">FLINK-7225</a>] - Cutoff exception message in StateDescriptor
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-7226">FLINK-7226</a>] - REST responses contain invalid content-encoding header
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-7231">FLINK-7231</a>] - SlotSharingGroups are not always released in time for new restarts
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-7234">FLINK-7234</a>] - Fix CombineHint documentation
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-7241">FLINK-7241</a>] - Fix YARN high availability documentation
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-7255">FLINK-7255</a>] - ListStateDescriptor example uses wrong constructor
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-7258">FLINK-7258</a>] - IllegalArgumentException in Netty bootstrap with large memory state segment size
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-7266">FLINK-7266</a>] - Don&#39;t attempt to delete parent directory on S3
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-7268">FLINK-7268</a>] - Zookeeper Checkpoint Store interacting with Incremental State Handles can lead to loss of handles
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-7281">FLINK-7281</a>] - Fix various issues in (Maven) release infrastructure
+</li>
+</ul>
+
+<h2> Improvement
+</h2>
+<ul>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6365">FLINK-6365</a>] - Adapt default values of the Kinesis connector
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6575">FLINK-6575</a>] - Disable all tests on Windows that use HDFS
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6682">FLINK-6682</a>] - Improve error message in case parallelism exceeds maxParallelism
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6789">FLINK-6789</a>] - Remove duplicated test utility reducer in optimizer
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6874">FLINK-6874</a>] - Static and transient fields ignored for POJOs
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6898">FLINK-6898</a>] - Limit size of operator component in metric name
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6937">FLINK-6937</a>] - Fix link markdown in Production Readiness Checklist doc
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6940">FLINK-6940</a>] - Clarify the effect of configuring per-job state backend
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6998">FLINK-6998</a>] - Kafka connector needs to expose metrics for failed/successful offset commits in the Kafka Consumer callback
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-7004">FLINK-7004</a>] - Switch to Travis Trusty image
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-7032">FLINK-7032</a>] - Intellij is constantly changing language level of sub projects back to 1.6
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-7069">FLINK-7069</a>] - Catch exceptions for each reporter separately
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-7149">FLINK-7149</a>] - Add checkpoint ID to &#39;sendValues()&#39; in GenericWriteAheadSink
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-7164">FLINK-7164</a>] - Extend integration tests for (externalised) checkpoints, checkpoint store
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-7174">FLINK-7174</a>] - Bump dependency of Kafka 0.10.x to the latest one
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-7211">FLINK-7211</a>] - Exclude Gelly javadoc jar from release
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-7224">FLINK-7224</a>] - Incorrect Javadoc description in all Kafka consumer versions
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-7228">FLINK-7228</a>] - Harden HistoryServerStaticFileHandlerTest
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-7233">FLINK-7233</a>] - TaskManagerHeapSizeCalculationJavaBashTest failed on Travis
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-7287">FLINK-7287</a>] - test instability in Kafka010ITCase.testCommitOffsetsToKafka
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-7290">FLINK-7290</a>] - Make release scripts modular
+</li>
+</ul>
+</description>
+<pubDate>Sat, 05 Aug 2017 11:00:00 +0200</pubDate>
+<link>http://flink.apache.org/news/2017/08/05/release-1.3.2.html</link>
+<guid isPermaLink="true">/news/2017/08/05/release-1.3.2.html</guid>
+</item>
+
+<item>
<title>A Deep Dive into Rescalable State in Apache Flink</title>
<description><p><em>Apache Flink 1.2.0, released in February 2017, introduced support for rescalable state. This post provides a detailed overview of stateful stream processing and rescalable state in Flink.</em>
<br />
http://git-wip-us.apache.org/repos/asf/flink-web/blob/673d72c2/content/blog/index.html
----------------------------------------------------------------------
diff --git a/content/blog/index.html b/content/blog/index.html
index 53bc2e1..beb2966 100644
--- a/content/blog/index.html
+++ b/content/blog/index.html
@@ -142,6 +142,19 @@
<!-- Blog posts -->
<article>
+ <h2 class="blog-title"><a href="/news/2017/08/05/release-1.3.2.html">Apache Flink 1.3.2 Released</a></h2>
+ <p>05 Aug 2017</p>
+
+ <p><p>The Apache Flink community released the second bugfix version of the Apache Flink 1.3 series.</p>
+
+</p>
+
+ <p><a href="/news/2017/08/05/release-1.3.2.html">Continue reading »</a></p>
+ </article>
+
+ <hr>
+
+ <article>
<h2 class="blog-title"><a href="/features/2017/07/04/flink-rescalable-state.html">A Deep Dive into Rescalable State in Apache Flink</a></h2>
<p>04 Jul 2017 by Stefan Richter (<a href="https://twitter.com/StefanRRichter">@StefanRRichter</a>)</p>
@@ -251,19 +264,6 @@
<hr>
- <article>
- <h2 class="blog-title"><a href="/news/2016/12/21/release-1.1.4.html">Apache Flink 1.1.4 Released</a></h2>
- <p>21 Dec 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/12/21/release-1.1.4.html">Continue reading »</a></p>
- </article>
-
- <hr>
-
<!-- Pagination links -->
@@ -296,6 +296,16 @@
<ul id="markdown-toc">
+ <li><a href="/news/2017/08/05/release-1.3.2.html">Apache Flink 1.3.2 Released</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/features/2017/07/04/flink-rescalable-state.html">A Deep Dive into Rescalable State in Apache Flink</a></li>
http://git-wip-us.apache.org/repos/asf/flink-web/blob/673d72c2/content/blog/page2/index.html
----------------------------------------------------------------------
diff --git a/content/blog/page2/index.html b/content/blog/page2/index.html
index 8971f5f..4cdd8a5 100644
--- a/content/blog/page2/index.html
+++ b/content/blog/page2/index.html
@@ -142,6 +142,19 @@
<!-- Blog posts -->
<article>
+ <h2 class="blog-title"><a href="/news/2016/12/21/release-1.1.4.html">Apache Flink 1.1.4 Released</a></h2>
+ <p>21 Dec 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/12/21/release-1.1.4.html">Continue reading »</a></p>
+ </article>
+
+ <hr>
+
+ <article>
<h2 class="blog-title"><a href="/news/2016/12/19/2016-year-in-review.html">Apache Flink in 2016: Year in Review</a></h2>
<p>19 Dec 2016 by Mike Winters</p>
@@ -255,19 +268,6 @@
<hr>
- <article>
- <h2 class="blog-title"><a href="/news/2016/04/14/flink-forward-announce.html">Flink Forward 2016 Call for Submissions Is Now Open</a></h2>
- <p>14 Apr 2016 by Aljoscha Krettek (<a href="https://twitter.com/aljoscha">@aljoscha</a>)</p>
-
- <p><p>We are happy to announce that the call for submissions for Flink Forward 2016 is now open! The conference will take place September 12-14, 2016 in Berlin, Germany, bringing together the open source stream processing community. Most Apache Flink committers will attend the conference, making it the ideal venue to learn more about the project and its roadmap and connect with the community.</p>
-
-</p>
-
- <p><a href="/news/2016/04/14/flink-forward-announce.html">Continue reading »</a></p>
- </article>
-
- <hr>
-
<!-- Pagination links -->
@@ -300,6 +300,16 @@
<ul id="markdown-toc">
+ <li><a href="/news/2017/08/05/release-1.3.2.html">Apache Flink 1.3.2 Released</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/features/2017/07/04/flink-rescalable-state.html">A Deep Dive into Rescalable State in Apache Flink</a></li>
http://git-wip-us.apache.org/repos/asf/flink-web/blob/673d72c2/content/blog/page3/index.html
----------------------------------------------------------------------
diff --git a/content/blog/page3/index.html b/content/blog/page3/index.html
index 0f034af..1298320 100644
--- a/content/blog/page3/index.html
+++ b/content/blog/page3/index.html
@@ -142,6 +142,19 @@
<!-- Blog posts -->
<article>
+ <h2 class="blog-title"><a href="/news/2016/04/14/flink-forward-announce.html">Flink Forward 2016 Call for Submissions Is Now Open</a></h2>
+ <p>14 Apr 2016 by Aljoscha Krettek (<a href="https://twitter.com/aljoscha">@aljoscha</a>)</p>
+
+ <p><p>We are happy to announce that the call for submissions for Flink Forward 2016 is now open! The conference will take place September 12-14, 2016 in Berlin, Germany, bringing together the open source stream processing community. Most Apache Flink committers will attend the conference, making it the ideal venue to learn more about the project and its roadmap and connect with the community.</p>
+
+</p>
+
+ <p><a href="/news/2016/04/14/flink-forward-announce.html">Continue reading »</a></p>
+ </article>
+
+ <hr>
+
+ <article>
<h2 class="blog-title"><a href="/news/2016/04/06/cep-monitoring.html">Introducing Complex Event Processing (CEP) with Apache Flink</a></h2>
<p>06 Apr 2016 by Till Rohrmann (<a href="https://twitter.com/stsffap">@stsffap</a>)</p>
@@ -251,18 +264,6 @@
<hr>
- <article>
- <h2 class="blog-title"><a href="/news/2015/09/16/off-heap-memory.html">Off-heap Memory in Apache Flink and the curious JIT compiler</a></h2>
- <p>16 Sep 2015 by Stephan Ewen (<a href="https://twitter.com/stephanewen">@stephanewen</a>)</p>
-
- <p><p>Running data-intensive code in the JVM and making it well-behaved is tricky. Systems that put billions of data objects naively onto the JVM heap face unpredictable OutOfMemoryErrors and Garbage Collection stalls. Of course, you still want to to keep your data in memory as much as possible, for speed and responsiveness of the processing applications. In that context, "off-heap" has become almost something like a magic word to solve these problems.</p>
-<p>In this blog post, we will look at how Flink exploits off-heap memory. The feature is part of the upcoming release, but you can try it out with the latest nightly builds. We will also give a few interesting insights into the behavior for Java's JIT compiler for highly optimized methods and loops.</p></p>
-
- <p><a href="/news/2015/09/16/off-heap-memory.html">Continue reading »</a></p>
- </article>
-
- <hr>
-
<!-- Pagination links -->
@@ -295,6 +296,16 @@
<ul id="markdown-toc">
+ <li><a href="/news/2017/08/05/release-1.3.2.html">Apache Flink 1.3.2 Released</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/features/2017/07/04/flink-rescalable-state.html">A Deep Dive into Rescalable State in Apache Flink</a></li>
http://git-wip-us.apache.org/repos/asf/flink-web/blob/673d72c2/content/blog/page4/index.html
----------------------------------------------------------------------
diff --git a/content/blog/page4/index.html b/content/blog/page4/index.html
index eff04f5..533d45b 100644
--- a/content/blog/page4/index.html
+++ b/content/blog/page4/index.html
@@ -142,6 +142,18 @@
<!-- Blog posts -->
<article>
+ <h2 class="blog-title"><a href="/news/2015/09/16/off-heap-memory.html">Off-heap Memory in Apache Flink and the curious JIT compiler</a></h2>
+ <p>16 Sep 2015 by Stephan Ewen (<a href="https://twitter.com/stephanewen">@stephanewen</a>)</p>
+
+ <p><p>Running data-intensive code in the JVM and making it well-behaved is tricky. Systems that put billions of data objects naively onto the JVM heap face unpredictable OutOfMemoryErrors and Garbage Collection stalls. Of course, you still want to to keep your data in memory as much as possible, for speed and responsiveness of the processing applications. In that context, "off-heap" has become almost something like a magic word to solve these problems.</p>
+<p>In this blog post, we will look at how Flink exploits off-heap memory. The feature is part of the upcoming release, but you can try it out with the latest nightly builds. We will also give a few interesting insights into the behavior for Java's JIT compiler for highly optimized methods and loops.</p></p>
+
+ <p><a href="/news/2015/09/16/off-heap-memory.html">Continue reading »</a></p>
+ </article>
+
+ <hr>
+
+ <article>
<h2 class="blog-title"><a href="/news/2015/09/03/flink-forward.html">Announcing Flink Forward 2015</a></h2>
<p>03 Sep 2015</p>
@@ -265,22 +277,6 @@ release is a preview release that contains known issues.</p>
<hr>
- <article>
- <h2 class="blog-title"><a href="/news/2015/03/02/february-2015-in-flink.html">February 2015 in the Flink community</a></h2>
- <p>02 Mar 2015</p>
-
- <p><p>February might be the shortest month of the year, but this does not
-mean that the Flink community has not been busy adding features to the
-system and fixing bugs. Here’s a rundown of the activity in the Flink
-community last month.</p>
-
-</p>
-
- <p><a href="/news/2015/03/02/february-2015-in-flink.html">Continue reading »</a></p>
- </article>
-
- <hr>
-
<!-- Pagination links -->
@@ -313,6 +309,16 @@ community last month.</p>
<ul id="markdown-toc">
+ <li><a href="/news/2017/08/05/release-1.3.2.html">Apache Flink 1.3.2 Released</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/features/2017/07/04/flink-rescalable-state.html">A Deep Dive into Rescalable State in Apache Flink</a></li>
http://git-wip-us.apache.org/repos/asf/flink-web/blob/673d72c2/content/blog/page5/index.html
----------------------------------------------------------------------
diff --git a/content/blog/page5/index.html b/content/blog/page5/index.html
index 9130090..bc463c0 100644
--- a/content/blog/page5/index.html
+++ b/content/blog/page5/index.html
@@ -142,6 +142,22 @@
<!-- Blog posts -->
<article>
+ <h2 class="blog-title"><a href="/news/2015/03/02/february-2015-in-flink.html">February 2015 in the Flink community</a></h2>
+ <p>02 Mar 2015</p>
+
+ <p><p>February might be the shortest month of the year, but this does not
+mean that the Flink community has not been busy adding features to the
+system and fixing bugs. Here’s a rundown of the activity in the Flink
+community last month.</p>
+
+</p>
+
+ <p><a href="/news/2015/03/02/february-2015-in-flink.html">Continue reading »</a></p>
+ </article>
+
+ <hr>
+
+ <article>
<h2 class="blog-title"><a href="/news/2015/02/09/streaming-example.html">Introducing Flink Streaming</a></h2>
<p>09 Feb 2015</p>
@@ -297,6 +313,16 @@ academic and open source project that Flink originates from.</p>
<ul id="markdown-toc">
+ <li><a href="/news/2017/08/05/release-1.3.2.html">Apache Flink 1.3.2 Released</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/features/2017/07/04/flink-rescalable-state.html">A Deep Dive into Rescalable State in Apache Flink</a></li>
http://git-wip-us.apache.org/repos/asf/flink-web/blob/673d72c2/content/downloads.html
----------------------------------------------------------------------
diff --git a/content/downloads.html b/content/downloads.html
index eff130a..e3f6186 100644
--- a/content/downloads.html
+++ b/content/downloads.html
@@ -151,7 +151,7 @@ $( document ).ready(function() {
<div class="page-toc">
<ul id="markdown-toc">
- <li><a href="#latest-stable-release-v131" id="markdown-toc-latest-stable-release-v131">Latest stable release (v1.3.1)</a> <ul>
+ <li><a href="#latest-stable-release-v132" id="markdown-toc-latest-stable-release-v132">Latest stable release (v1.3.2)</a> <ul>
<li><a href="#binaries" id="markdown-toc-binaries">Binaries</a></li>
<li><a href="#source" id="markdown-toc-source">Source</a></li>
</ul>
@@ -163,9 +163,9 @@ $( document ).ready(function() {
</div>
-<h2 id="latest-stable-release-v131">Latest stable release (v1.3.1)</h2>
+<h2 id="latest-stable-release-v132">Latest stable release (v1.3.2)</h2>
-<p>Apache Flink® 1.3.1 is our latest stable release.</p>
+<p>Apache Flink® 1.3.2 is our latest stable release.</p>
<p>An Apache Hadoop installation is
<a href="faq.html#do-i-have-to-install-apache-hadoop-to-use-flink">not required</a>
@@ -183,26 +183,26 @@ select the version matching your installed Hadoop version.</p>
<tbody>
<tr>
<th>Hadoop® 2.7</th>
- <td><a href="http://www.apache.org/dyn/closer.lua/flink/flink-1.3.1/flink-1.3.1-bin-hadoop27-scala_2.10.tgz" class="ga-track" id="download-hadoop27">Download</a></td>
- <td><a href="http://www.apache.org/dyn/closer.lua/flink/flink-1.3.1/flink-1.3.1-bin-hadoop27-scala_2.11.tgz" class="ga-track" id="download-hadoop27_211">Download</a></td>
+ <td><a href="http://www.apache.org/dyn/closer.lua/flink/flink-1.3.2/flink-1.3.2-bin-hadoop27-scala_2.10.tgz" class="ga-track" id="download-hadoop27">Download</a></td>
+ <td><a href="http://www.apache.org/dyn/closer.lua/flink/flink-1.3.2/flink-1.3.2-bin-hadoop27-scala_2.11.tgz" class="ga-track" id="download-hadoop27_211">Download</a></td>
</tr>
<tr>
<th>Hadoop® 2.6</th>
- <td><a href="http://www.apache.org/dyn/closer.lua/flink/flink-1.3.1/flink-1.3.1-bin-hadoop26-scala_2.10.tgz" class="ga-track" id="download-hadoop26">Download</a></td>
- <td><a href="http://www.apache.org/dyn/closer.lua/flink/flink-1.3.1/flink-1.3.1-bin-hadoop26-scala_2.11.tgz" class="ga-track" id="download-hadoop26_211">Download</a></td>
+ <td><a href="http://www.apache.org/dyn/closer.lua/flink/flink-1.3.2/flink-1.3.2-bin-hadoop26-scala_2.10.tgz" class="ga-track" id="download-hadoop26">Download</a></td>
+ <td><a href="http://www.apache.org/dyn/closer.lua/flink/flink-1.3.2/flink-1.3.2-bin-hadoop26-scala_2.11.tgz" class="ga-track" id="download-hadoop26_211">Download</a></td>
</tr>
<tr>
<th>Hadoop® 2.4</th>
- <td><a href="http://www.apache.org/dyn/closer.lua/flink/flink-1.3.1/flink-1.3.1-bin-hadoop24-scala_2.10.tgz" class="ga-track" id="download-hadoop24">Download</a></td>
- <td><a href="http://www.apache.org/dyn/closer.lua/flink/flink-1.3.1/flink-1.3.1-bin-hadoop24-scala_2.11.tgz" class="ga-track" id="download-hadoop24_211">Download</a></td>
+ <td><a href="http://www.apache.org/dyn/closer.lua/flink/flink-1.3.2/flink-1.3.2-bin-hadoop24-scala_2.10.tgz" class="ga-track" id="download-hadoop24">Download</a></td>
+ <td><a href="http://www.apache.org/dyn/closer.lua/flink/flink-1.3.2/flink-1.3.2-bin-hadoop24-scala_2.11.tgz" class="ga-track" id="download-hadoop24_211">Download</a></td>
</tr>
<tr>
<th>Hadoop® 2.3</th>
- <td><a href="http://www.apache.org/dyn/closer.lua/flink/flink-1.3.1/flink-1.3.1-bin-hadoop2-scala_2.10.tgz" class="ga-track" id="download-hadoop2">Download</a></td>
- <td><a href="http://www.apache.org/dyn/closer.lua/flink/flink-1.3.1/flink-1.3.1-bin-hadoop2-scala_2.11.tgz" class="ga-track" id="download-hadoop2_211">Download</a></td>
+ <td><a href="http://www.apache.org/dyn/closer.lua/flink/flink-1.3.2/flink-1.3.2-bin-hadoop2-scala_2.10.tgz" class="ga-track" id="download-hadoop2">Download</a></td>
+ <td><a href="http://www.apache.org/dyn/closer.lua/flink/flink-1.3.2/flink-1.3.2-bin-hadoop2-scala_2.11.tgz" class="ga-track" id="download-hadoop2_211">Download</a></td>
</tr>
</tbody>
</table>
@@ -211,8 +211,8 @@ select the version matching your installed Hadoop version.</p>
<div class="list-group">
<!-- Source -->
- <a href="http://www.apache.org/dyn/closer.lua/flink/flink-1.3.1/flink-1.3.1-src.tgz" class="list-group-item ga-track" id="download-source">
- <h4><span class="glyphicon glyphicon-download" aria-hidden="true"></span> <strong>Apache Flink® 1.3.1</strong> Source Release</h4>
+ <a href="http://www.apache.org/dyn/closer.lua/flink/flink-1.3.2/flink-1.3.2-src.tgz" class="list-group-item ga-track" id="download-source">
+ <h4><span class="glyphicon glyphicon-download" aria-hidden="true"></span> <strong>Apache Flink® 1.3.2</strong> Source Release</h4>
<p>Review the source code or build Flink on your own, using this package</p>
</a>
</div>
@@ -228,17 +228,17 @@ select the version matching your installed Hadoop version.</p>
<div class="highlight"><pre><code class="language-xml"><span class="nt"><dependency></span>
<span class="nt"><groupId></span>org.apache.flink<span class="nt"></groupId></span>
<span class="nt"><artifactId></span>flink-java<span class="nt"></artifactId></span>
- <span class="nt"><version></span>1.3.1<span class="nt"></version></span>
+ <span class="nt"><version></span>1.3.2<span class="nt"></version></span>
<span class="nt"></dependency></span>
<span class="nt"><dependency></span>
<span class="nt"><groupId></span>org.apache.flink<span class="nt"></groupId></span>
<span class="nt"><artifactId></span>flink-streaming-java_2.10<span class="nt"></artifactId></span>
- <span class="nt"><version></span>1.3.1<span class="nt"></version></span>
+ <span class="nt"><version></span>1.3.2<span class="nt"></version></span>
<span class="nt"></dependency></span>
<span class="nt"><dependency></span>
<span class="nt"><groupId></span>org.apache.flink<span class="nt"></groupId></span>
<span class="nt"><artifactId></span>flink-clients_2.10<span class="nt"></artifactId></span>
- <span class="nt"><version></span>1.3.1<span class="nt"></version></span>
+ <span class="nt"><version></span>1.3.2<span class="nt"></version></span>
<span class="nt"></dependency></span></code></pre></div>
<h2 id="update-policy-for-old-releases">Update Policy for old releases</h2>
@@ -250,6 +250,7 @@ select the version matching your installed Hadoop version.</p>
<h2 id="all-releases">All releases</h2>
<ul>
+ <li>Flink 1.3.2 - 2017-08-05 (<a href="http://www.apache.org/dyn/closer.lua/flink/flink-1.3.2/flink-1.3.2-src.tgz">Source</a>, <a href="http://archive.apache.org/dist/flink/flink-1.3.2/">Binaries</a>, <a href="http://ci.apache.org/projects/flink/flink-docs-release-1.3/">Docs</a>, <a href="http://ci.apache.org/projects/flink/flink-docs-release-1.3/api/java">Javadocs</a>, <a href="http://ci.apache.org/projects/flink/flink-docs-release-1.3/api/scala/index.html">ScalaDocs</a>)</li>
<li>Flink 1.3.1 - 2017-06-23 (<a href="http://www.apache.org/dyn/closer.lua/flink/flink-1.3.1/flink-1.3.1-src.tgz">Source</a>, <a href="http://archive.apache.org/dist/flink/flink-1.3.1/">Binaries</a>, <a href="http://ci.apache.org/projects/flink/flink-docs-release-1.3/">Docs</a>, <a href="http://ci.apache.org/projects/flink/flink-docs-release-1.3/api/java">Javadocs</a>, <a href="http://ci.apache.org/projects/flink/flink-docs-release-1.3/api/scala/index.html">ScalaDocs</a>)</li>
<li>Flink 1.3.0 - 2017-06-01 (<a href="http://www.apache.org/dyn/closer.lua/flink/flink-1.3.0/flink-1.3.0-src.tgz">Source</a>, <a href="http://archive.apache.org/dist/flink/flink-1.3.0/">Binaries</a>, <a href="http://ci.apache.org/projects/flink/flink-docs-release-1.3/">Docs</a>, <a href="http://ci.apache.org/projects/flink/flink-docs-release-1.3/api/java">Javadocs</a>, <a href="http://ci.apache.org/projects/flink/flink-docs-release-1.3/api/scala/index.html">ScalaDocs</a>)</li>
<li>Flink 1.2.1 - 2017-04-26 (<a href="http://www.apache.org/dyn/closer.lua/flink/flink-1.2.1/flink-1.2.1-src.tgz">Source</a>, <a href="http://archive.apache.org/dist/flink/flink-1.2.1/">Binaries</a>, <a href="http://ci.apache.org/projects/flink/flink-docs-release-1.2/">Docs</a>, <a href="http://ci.apache.org/projects/flink/flink-docs-release-1.2/api/java">Javadocs</a>, <a href="http://ci.apache.org/projects/flink/flink-docs-release-1.2/api/scala/index.html">ScalaDocs</a>)</li>
http://git-wip-us.apache.org/repos/asf/flink-web/blob/673d72c2/content/index.html
----------------------------------------------------------------------
diff --git a/content/index.html b/content/index.html
index 1f16337..f1ce212 100644
--- a/content/index.html
+++ b/content/index.html
@@ -168,6 +168,11 @@
<dl>
+ <dt> <a href="/news/2017/08/05/release-1.3.2.html">Apache Flink 1.3.2 Released</a></dt>
+ <dd><p>The Apache Flink community released the second bugfix version of the Apache Flink 1.3 series.</p>
+
+</dd>
+
<dt> <a href="/features/2017/07/04/flink-rescalable-state.html">A Deep Dive into Rescalable State in Apache Flink</a></dt>
<dd><p>A primer on stateful stream processing and an in-depth walkthrough of rescalable state in Apache Flink.</p></dd>
@@ -185,11 +190,6 @@
<dd><p>For some time, the Apache Flink community has provided scripts to build a Docker image to run Flink. Now, starting with version 1.2.1, Flink will have a <a href="https://hub.docker.com/r/_/flink/">Docker image</a> on the Docker Hub. This image is maintained by the Flink community and curated by the <a href="https://github.com/docker-library/official-images">Docker</a> team to ensure it meets the quality standards for container images of the Docker community.</p>
</dd>
-
- <dt> <a href="/news/2017/04/26/release-1.2.1.html">Apache Flink 1.2.1 Released</a></dt>
- <dd><p>The Apache Flink community released the first bugfix version of the Apache Flink 1.2 series.</p>
-
-</dd>
</dl>
http://git-wip-us.apache.org/repos/asf/flink-web/blob/673d72c2/content/news/2017/08/05/release-1.3.2.html
----------------------------------------------------------------------
diff --git a/content/news/2017/08/05/release-1.3.2.html b/content/news/2017/08/05/release-1.3.2.html
new file mode 100644
index 0000000..278963f
--- /dev/null
+++ b/content/news/2017/08/05/release-1.3.2.html
@@ -0,0 +1,399 @@
+<!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.3.2 Released</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="https://ajax.googleapis.com/ajax/libs/jquery/1.11.2/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">
+
+ <!-- Downloads -->
+ <li class=""><a class="btn btn-info" href="/downloads.html">Download Flink</a></li>
+
+ <!-- Overview -->
+ <li><a href="/index.html">Home</a></li>
+
+ <!-- Intro -->
+ <li><a href="/introduction.html">Introduction to Flink</a></li>
+
+ <!-- Use cases -->
+ <li><a href="/usecases.html">Flink Use Cases</a></li>
+
+ <!-- Powered by -->
+ <li><a href="/poweredby.html">Powered by Flink</a></li>
+
+ <!-- Ecosystem -->
+ <li><a href="/ecosystem.html">Ecosystem</a></li>
+
+ <!-- Community -->
+ <li><a href="/community.html">Community & Project Info</a></li>
+
+ <!-- Contribute -->
+ <li><a href="/how-to-contribute.html">How to Contribute</a></li>
+
+ <!-- Blog -->
+ <li class=" active hidden-md hidden-sm"><a href="/blog/"><b>Flink Blog</b></a></li>
+
+ <hr />
+
+
+
+ <!-- Documentation -->
+ <!-- <li>
+ <a href="http://ci.apache.org/projects/flink/flink-docs-release-1.3" target="_blank">Documentation <small><span class="glyphicon glyphicon-new-window"></span></small></a>
+ </li> -->
+ <li class="dropdown">
+ <a class="dropdown-toggle" data-toggle="dropdown" href="#">Documentation
+ <span class="caret"></span></a>
+ <ul class="dropdown-menu">
+ <li><a href="http://ci.apache.org/projects/flink/flink-docs-release-1.3" target="_blank">1.3 (Latest stable release) <small><span class="glyphicon glyphicon-new-window"></span></small></a></li>
+ <li><a href="http://ci.apache.org/projects/flink/flink-docs-master" target="_blank">1.4 (Snapshot) <small><span class="glyphicon glyphicon-new-window"></span></small></a></li>
+ </ul>
+ </li>
+
+ <!-- Quickstart -->
+ <li>
+ <a href="http://ci.apache.org/projects/flink/flink-docs-release-1.3/quickstart/setup_quickstart.html" target="_blank">Quickstart <small><span class="glyphicon glyphicon-new-window"></span></small></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>
+
+ </ul>
+
+
+
+ <ul class="nav navbar-nav navbar-bottom">
+ <hr />
+
+ <!-- FAQ -->
+ <li ><a href="/faq.html">Project FAQ</a></li>
+
+ <!-- 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.3.2 Released</h1>
+
+ <article>
+ <p>05 Aug 2017</p>
+
+<p>The Apache Flink community released the second bugfix version of the Apache Flink 1.3 series.</p>
+
+<p>This release includes more than 60 fixes and minor improvements for Flink 1.3.1. The list below includes a detailed list of all fixes.</p>
+
+<p>We highly recommend all users to upgrade to Flink 1.3.2.</p>
+
+<div class="alert alert-warning">
+ Important Notice:
+
+ <p>A user reported a bug in the FlinkKafkaConsumer
+ (<a href="https://issues.apache.org/jira/browse/FLINK-7143">FLINK-7143</a>) that is causing
+ incorrect partition assignment in large Kafka deployments in the presence of inconsistent broker
+ metadata. In that case multiple parallel instances of the FlinkKafkaConsumer may read from the
+ same topic partition, leading to data duplication. In Flink 1.3.2 this bug is fixed but incorrect
+ assignments from Flink 1.3.0 and 1.3.1 cannot be automatically fixed by upgrading to Flink 1.3.2
+ via a savepoint because the upgraded version would resume the wrong partition assignment from the
+ savepoint. If you believe you are affected by this bug (seeing messages from some partitions
+ duplicated) please refer to the JIRA issue for an upgrade path that works around that.</p>
+
+ <p>Before attempting the more elaborate upgrade path, we would suggest to check if you are
+ actually affected by this bug. We did not manage to reproduce it in various testing clusters and
+ according to the reporting user, it only appeared in rare cases on their very large setup. This
+ leads us to believe that most likely only a minority of setups would be affected by this bug.</p>
+</div>
+
+<p>Notable changes:</p>
+
+<ul>
+ <li>The default Kafka version for Flink Kafka Consumer 0.10 was bumped from 0.10.0.1 to 0.10.2.1.</li>
+ <li>Some default values for configurations of AWS API call behaviors in the Flink Kinesis Consumer
+ were adapted for better default consumption performance: 1) <code>SHARD_GETRECORDS_MAX</code> default changed
+ to 10,000, and 2) <code>SHARD_GETRECORDS_INTERVAL_MILLIS</code> default changed to 200ms.</li>
+</ul>
+
+<p>Updated Maven dependencies:</p>
+
+<div class="highlight"><pre><code class="language-xml"><span class="nt"><dependency></span>
+ <span class="nt"><groupId></span>org.apache.flink<span class="nt"></groupId></span>
+ <span class="nt"><artifactId></span>flink-java<span class="nt"></artifactId></span>
+ <span class="nt"><version></span>1.3.2<span class="nt"></version></span>
+<span class="nt"></dependency></span>
+<span class="nt"><dependency></span>
+ <span class="nt"><groupId></span>org.apache.flink<span class="nt"></groupId></span>
+ <span class="nt"><artifactId></span>flink-streaming-java_2.10<span class="nt"></artifactId></span>
+ <span class="nt"><version></span>1.3.2<span class="nt"></version></span>
+<span class="nt"></dependency></span>
+<span class="nt"><dependency></span>
+ <span class="nt"><groupId></span>org.apache.flink<span class="nt"></groupId></span>
+ <span class="nt"><artifactId></span>flink-clients_2.10<span class="nt"></artifactId></span>
+ <span class="nt"><version></span>1.3.2<span class="nt"></version></span>
+<span class="nt"></dependency></span></code></pre></div>
+
+<p>You can find the binaries on the updated <a href="http://flink.apache.org/downloads.html">Downloads page</a>.</p>
+
+<p>List of resolved issues:</p>
+
+<h2> Sub-task
+</h2>
+<ul>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6665">FLINK-6665</a>] - Pass a ScheduledExecutorService to the RestartStrategy
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6667">FLINK-6667</a>] - Pass a callback type to the RestartStrategy, rather than the full ExecutionGraph
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6680">FLINK-6680</a>] - App & Flink migration guide: updates for the 1.3 release
+</li>
+</ul>
+
+<h2> Bug
+</h2>
+<ul>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5488">FLINK-5488</a>] - yarnClient should be closed in AbstractYarnClusterDescriptor for error conditions
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6376">FLINK-6376</a>] - when deploy flink cluster on the yarn, it is lack of hdfs delegation token.
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6541">FLINK-6541</a>] - Jar upload directory not created
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6654">FLINK-6654</a>] - missing maven dependency on "flink-shaded-hadoop2-uber" in flink-dist
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6655">FLINK-6655</a>] - Misleading error message when HistoryServer path is empty
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6742">FLINK-6742</a>] - Improve error message when savepoint migration fails due to task removal
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6774">FLINK-6774</a>] - build-helper-maven-plugin version not set
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6806">FLINK-6806</a>] - rocksdb is not listed as state backend in doc
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6843">FLINK-6843</a>] - ClientConnectionTest fails on travis
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6867">FLINK-6867</a>] - Elasticsearch 1.x ITCase still instable due to embedded node instability
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6918">FLINK-6918</a>] - Failing tests: ChainLengthDecreaseTest and ChainLengthIncreaseTest
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6945">FLINK-6945</a>] - TaskCancelAsyncProducerConsumerITCase.testCancelAsyncProducerAndConsumer instable test case
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6964">FLINK-6964</a>] - Fix recovery for incremental checkpoints in StandaloneCompletedCheckpointStore
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6965">FLINK-6965</a>] - Avro is missing snappy dependency
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6987">FLINK-6987</a>] - TextInputFormatTest fails when run in path containing spaces
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6996">FLINK-6996</a>] - FlinkKafkaProducer010 doesn't guarantee at-least-once semantic
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-7005">FLINK-7005</a>] - Optimization steps are missing for nested registered tables
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-7011">FLINK-7011</a>] - Instable Kafka testStartFromKafkaCommitOffsets failures on Travis
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-7025">FLINK-7025</a>] - Using NullByteKeySelector for Unbounded ProcTime NonPartitioned Over
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-7034">FLINK-7034</a>] - GraphiteReporter cannot recover from lost connection
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-7038">FLINK-7038</a>] - Several misused "KeyedDataStream" term in docs and Javadocs
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-7041">FLINK-7041</a>] - Deserialize StateBackend from JobCheckpointingSettings with user classloader
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-7132">FLINK-7132</a>] - Fix BulkIteration parallelism
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-7133">FLINK-7133</a>] - Fix Elasticsearch version interference
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-7137">FLINK-7137</a>] - Flink table API defaults top level fields as nullable and all nested fields within CompositeType as non-nullable
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-7143">FLINK-7143</a>] - Partition assignment for Kafka consumer is not stable
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-7154">FLINK-7154</a>] - Missing call to build CsvTableSource example
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-7158">FLINK-7158</a>] - Wrong test jar dependency in flink-clients
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-7177">FLINK-7177</a>] - DataSetAggregateWithNullValuesRule fails creating null literal for non-nullable type
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-7178">FLINK-7178</a>] - Datadog Metric Reporter Jar is Lacking Dependencies
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-7180">FLINK-7180</a>] - CoGroupStream perform checkpoint failed
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-7195">FLINK-7195</a>] - FlinkKafkaConsumer should not respect fetched partitions to filter restored partition states
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-7216">FLINK-7216</a>] - ExecutionGraph can perform concurrent global restarts to scheduling
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-7225">FLINK-7225</a>] - Cutoff exception message in StateDescriptor
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-7226">FLINK-7226</a>] - REST responses contain invalid content-encoding header
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-7231">FLINK-7231</a>] - SlotSharingGroups are not always released in time for new restarts
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-7234">FLINK-7234</a>] - Fix CombineHint documentation
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-7241">FLINK-7241</a>] - Fix YARN high availability documentation
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-7255">FLINK-7255</a>] - ListStateDescriptor example uses wrong constructor
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-7258">FLINK-7258</a>] - IllegalArgumentException in Netty bootstrap with large memory state segment size
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-7266">FLINK-7266</a>] - Don't attempt to delete parent directory on S3
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-7268">FLINK-7268</a>] - Zookeeper Checkpoint Store interacting with Incremental State Handles can lead to loss of handles
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-7281">FLINK-7281</a>] - Fix various issues in (Maven) release infrastructure
+</li>
+</ul>
+
+<h2> Improvement
+</h2>
+<ul>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6365">FLINK-6365</a>] - Adapt default values of the Kinesis connector
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6575">FLINK-6575</a>] - Disable all tests on Windows that use HDFS
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6682">FLINK-6682</a>] - Improve error message in case parallelism exceeds maxParallelism
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6789">FLINK-6789</a>] - Remove duplicated test utility reducer in optimizer
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6874">FLINK-6874</a>] - Static and transient fields ignored for POJOs
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6898">FLINK-6898</a>] - Limit size of operator component in metric name
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6937">FLINK-6937</a>] - Fix link markdown in Production Readiness Checklist doc
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6940">FLINK-6940</a>] - Clarify the effect of configuring per-job state backend
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6998">FLINK-6998</a>] - Kafka connector needs to expose metrics for failed/successful offset commits in the Kafka Consumer callback
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-7004">FLINK-7004</a>] - Switch to Travis Trusty image
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-7032">FLINK-7032</a>] - Intellij is constantly changing language level of sub projects back to 1.6
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-7069">FLINK-7069</a>] - Catch exceptions for each reporter separately
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-7149">FLINK-7149</a>] - Add checkpoint ID to 'sendValues()' in GenericWriteAheadSink
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-7164">FLINK-7164</a>] - Extend integration tests for (externalised) checkpoints, checkpoint store
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-7174">FLINK-7174</a>] - Bump dependency of Kafka 0.10.x to the latest one
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-7211">FLINK-7211</a>] - Exclude Gelly javadoc jar from release
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-7224">FLINK-7224</a>] - Incorrect Javadoc description in all Kafka consumer versions
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-7228">FLINK-7228</a>] - Harden HistoryServerStaticFileHandlerTest
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-7233">FLINK-7233</a>] - TaskManagerHeapSizeCalculationJavaBashTest failed on Travis
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-7287">FLINK-7287</a>] - test instability in Kafka010ITCase.testCommitOffsetsToKafka
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-7290">FLINK-7290</a>] - Make release scripts modular
+</li>
+</ul>
+
+ </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-2017 <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="/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>
[2/2] flink-web git commit: Add Flink 1.3.2 release
Posted by al...@apache.org.
Add Flink 1.3.2 release
Project: http://git-wip-us.apache.org/repos/asf/flink-web/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink-web/commit/21d2a851
Tree: http://git-wip-us.apache.org/repos/asf/flink-web/tree/21d2a851
Diff: http://git-wip-us.apache.org/repos/asf/flink-web/diff/21d2a851
Branch: refs/heads/asf-site
Commit: 21d2a8512ff94e69202147401a6a1c3681b5831d
Parents: c5c2553
Author: Aljoscha Krettek <al...@gmail.com>
Authored: Sat Jul 29 07:44:56 2017 +0200
Committer: Aljoscha Krettek <al...@gmail.com>
Committed: Sat Aug 5 08:59:36 2017 +0200
----------------------------------------------------------------------
_config.yml | 22 ++--
_posts/2017-08-05-release-1.3.2.md | 212 ++++++++++++++++++++++++++++++++
downloads.md | 1 +
3 files changed, 224 insertions(+), 11 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink-web/blob/21d2a851/_config.yml
----------------------------------------------------------------------
diff --git a/_config.yml b/_config.yml
index 00fa1ee..e465f5e 100644
--- a/_config.yml
+++ b/_config.yml
@@ -9,8 +9,8 @@ url: http://flink.apache.org
DOCS_BASE_URL: http://ci.apache.org/projects/flink/
-FLINK_VERSION_STABLE: 1.3.1
-FLINK_VERSION_HADOOP_2_STABLE: 1.3.1
+FLINK_VERSION_STABLE: 1.3.2
+FLINK_VERSION_HADOOP_2_STABLE: 1.3.2
FLINK_VERSION_STABLE_SHORT: 1.3
FLINK_VERSION_LATEST: 1.4-SNAPSHOT
@@ -22,18 +22,18 @@ FLINK_GITHUB_URL: https://github.com/apache/flink
FLINK_CONTRIBUTORS_URL: https://cwiki.apache.org/confluence/display/FLINK/List+of+contributors
FLINK_GITHUB_REPO_NAME: flink
-FLINK_DOWNLOAD_URL_SOURCE: http://www.apache.org/dyn/closer.lua/flink/flink-1.3.1/flink-1.3.1-src.tgz
+FLINK_DOWNLOAD_URL_SOURCE: http://www.apache.org/dyn/closer.lua/flink/flink-1.3.2/flink-1.3.2-src.tgz
-FLINK_DOWNLOAD_URL_HADOOP_2_STABLE: http://www.apache.org/dyn/closer.lua/flink/flink-1.3.1/flink-1.3.1-bin-hadoop2-scala_2.10.tgz
-FLINK_DOWNLOAD_URL_HADOOP_24_STABLE: http://www.apache.org/dyn/closer.lua/flink/flink-1.3.1/flink-1.3.1-bin-hadoop24-scala_2.10.tgz
-FLINK_DOWNLOAD_URL_HADOOP_26_STABLE: http://www.apache.org/dyn/closer.lua/flink/flink-1.3.1/flink-1.3.1-bin-hadoop26-scala_2.10.tgz
-FLINK_DOWNLOAD_URL_HADOOP_27_STABLE: http://www.apache.org/dyn/closer.lua/flink/flink-1.3.1/flink-1.3.1-bin-hadoop27-scala_2.10.tgz
+FLINK_DOWNLOAD_URL_HADOOP_2_STABLE: http://www.apache.org/dyn/closer.lua/flink/flink-1.3.2/flink-1.3.2-bin-hadoop2-scala_2.10.tgz
+FLINK_DOWNLOAD_URL_HADOOP_24_STABLE: http://www.apache.org/dyn/closer.lua/flink/flink-1.3.2/flink-1.3.2-bin-hadoop24-scala_2.10.tgz
+FLINK_DOWNLOAD_URL_HADOOP_26_STABLE: http://www.apache.org/dyn/closer.lua/flink/flink-1.3.2/flink-1.3.2-bin-hadoop26-scala_2.10.tgz
+FLINK_DOWNLOAD_URL_HADOOP_27_STABLE: http://www.apache.org/dyn/closer.lua/flink/flink-1.3.2/flink-1.3.2-bin-hadoop27-scala_2.10.tgz
-FLINK_DOWNLOAD_URL_HADOOP_2_SCALA_211_STABLE: http://www.apache.org/dyn/closer.lua/flink/flink-1.3.1/flink-1.3.1-bin-hadoop2-scala_2.11.tgz
-FLINK_DOWNLOAD_URL_HADOOP_24_SCALA_211_STABLE: http://www.apache.org/dyn/closer.lua/flink/flink-1.3.1/flink-1.3.1-bin-hadoop24-scala_2.11.tgz
-FLINK_DOWNLOAD_URL_HADOOP_26_SCALA_211_STABLE: http://www.apache.org/dyn/closer.lua/flink/flink-1.3.1/flink-1.3.1-bin-hadoop26-scala_2.11.tgz
-FLINK_DOWNLOAD_URL_HADOOP_27_SCALA_211_STABLE: http://www.apache.org/dyn/closer.lua/flink/flink-1.3.1/flink-1.3.1-bin-hadoop27-scala_2.11.tgz
+FLINK_DOWNLOAD_URL_HADOOP_2_SCALA_211_STABLE: http://www.apache.org/dyn/closer.lua/flink/flink-1.3.2/flink-1.3.2-bin-hadoop2-scala_2.11.tgz
+FLINK_DOWNLOAD_URL_HADOOP_24_SCALA_211_STABLE: http://www.apache.org/dyn/closer.lua/flink/flink-1.3.2/flink-1.3.2-bin-hadoop24-scala_2.11.tgz
+FLINK_DOWNLOAD_URL_HADOOP_26_SCALA_211_STABLE: http://www.apache.org/dyn/closer.lua/flink/flink-1.3.2/flink-1.3.2-bin-hadoop26-scala_2.11.tgz
+FLINK_DOWNLOAD_URL_HADOOP_27_SCALA_211_STABLE: http://www.apache.org/dyn/closer.lua/flink/flink-1.3.2/flink-1.3.2-bin-hadoop27-scala_2.11.tgz
FLINK_DOWNLOAD_URL_HADOOP_1_LATEST: https://s3.amazonaws.com/flink-nightly/flink-1.4-SNAPSHOT-bin-hadoop1.tgz
FLINK_DOWNLOAD_URL_HADOOP_2_LATEST: https://s3.amazonaws.com/flink-nightly/flink-1.4-SNAPSHOT-bin-hadoop2.tgz
http://git-wip-us.apache.org/repos/asf/flink-web/blob/21d2a851/_posts/2017-08-05-release-1.3.2.md
----------------------------------------------------------------------
diff --git a/_posts/2017-08-05-release-1.3.2.md b/_posts/2017-08-05-release-1.3.2.md
new file mode 100644
index 0000000..90c5e48
--- /dev/null
+++ b/_posts/2017-08-05-release-1.3.2.md
@@ -0,0 +1,212 @@
+---
+layout: post
+title: "Apache Flink 1.3.2 Released"
+date: 2017-08-05 9:00:00
+categories: news
+---
+
+The Apache Flink community released the second bugfix version of the Apache Flink 1.3 series.
+
+This release includes more than 60 fixes and minor improvements for Flink 1.3.1. The list below includes a detailed list of all fixes.
+
+We highly recommend all users to upgrade to Flink 1.3.2.
+
+
+<div class="alert alert-warning">
+ Important Notice:
+
+ <p>A user reported a bug in the FlinkKafkaConsumer
+ (<a href="https://issues.apache.org/jira/browse/FLINK-7143">FLINK-7143</a>) that is causing
+ incorrect partition assignment in large Kafka deployments in the presence of inconsistent broker
+ metadata. In that case multiple parallel instances of the FlinkKafkaConsumer may read from the
+ same topic partition, leading to data duplication. In Flink 1.3.2 this bug is fixed but incorrect
+ assignments from Flink 1.3.0 and 1.3.1 cannot be automatically fixed by upgrading to Flink 1.3.2
+ via a savepoint because the upgraded version would resume the wrong partition assignment from the
+ savepoint. If you believe you are affected by this bug (seeing messages from some partitions
+ duplicated) please refer to the JIRA issue for an upgrade path that works around that.</p>
+
+ <p>Before attempting the more elaborate upgrade path, we would suggest to check if you are
+ actually affected by this bug. We did not manage to reproduce it in various testing clusters and
+ according to the reporting user, it only appeared in rare cases on their very large setup. This
+ leads us to believe that most likely only a minority of setups would be affected by this bug.</p>
+</div>
+
+Notable changes:
+
+ - The default Kafka version for Flink Kafka Consumer 0.10 was bumped from 0.10.0.1 to 0.10.2.1.
+ - Some default values for configurations of AWS API call behaviors in the Flink Kinesis Consumer
+ were adapted for better default consumption performance: 1) `SHARD_GETRECORDS_MAX` default changed
+ to 10,000, and 2) `SHARD_GETRECORDS_INTERVAL_MILLIS` default changed to 200ms.
+
+Updated Maven dependencies:
+
+```xml
+<dependency>
+ <groupId>org.apache.flink</groupId>
+ <artifactId>flink-java</artifactId>
+ <version>1.3.2</version>
+</dependency>
+<dependency>
+ <groupId>org.apache.flink</groupId>
+ <artifactId>flink-streaming-java_2.10</artifactId>
+ <version>1.3.2</version>
+</dependency>
+<dependency>
+ <groupId>org.apache.flink</groupId>
+ <artifactId>flink-clients_2.10</artifactId>
+ <version>1.3.2</version>
+</dependency>
+```
+
+You can find the binaries on the updated [Downloads page](http://flink.apache.org/downloads.html).
+
+List of resolved issues:
+
+<h2> Sub-task
+</h2>
+<ul>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-6665'>FLINK-6665</a>] - Pass a ScheduledExecutorService to the RestartStrategy
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-6667'>FLINK-6667</a>] - Pass a callback type to the RestartStrategy, rather than the full ExecutionGraph
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-6680'>FLINK-6680</a>] - App & Flink migration guide: updates for the 1.3 release
+</li>
+</ul>
+
+<h2> Bug
+</h2>
+<ul>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5488'>FLINK-5488</a>] - yarnClient should be closed in AbstractYarnClusterDescriptor for error conditions
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-6376'>FLINK-6376</a>] - when deploy flink cluster on the yarn, it is lack of hdfs delegation token.
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-6541'>FLINK-6541</a>] - Jar upload directory not created
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-6654'>FLINK-6654</a>] - missing maven dependency on "flink-shaded-hadoop2-uber" in flink-dist
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-6655'>FLINK-6655</a>] - Misleading error message when HistoryServer path is empty
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-6742'>FLINK-6742</a>] - Improve error message when savepoint migration fails due to task removal
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-6774'>FLINK-6774</a>] - build-helper-maven-plugin version not set
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-6806'>FLINK-6806</a>] - rocksdb is not listed as state backend in doc
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-6843'>FLINK-6843</a>] - ClientConnectionTest fails on travis
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-6867'>FLINK-6867</a>] - Elasticsearch 1.x ITCase still instable due to embedded node instability
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-6918'>FLINK-6918</a>] - Failing tests: ChainLengthDecreaseTest and ChainLengthIncreaseTest
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-6945'>FLINK-6945</a>] - TaskCancelAsyncProducerConsumerITCase.testCancelAsyncProducerAndConsumer instable test case
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-6964'>FLINK-6964</a>] - Fix recovery for incremental checkpoints in StandaloneCompletedCheckpointStore
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-6965'>FLINK-6965</a>] - Avro is missing snappy dependency
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-6987'>FLINK-6987</a>] - TextInputFormatTest fails when run in path containing spaces
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-6996'>FLINK-6996</a>] - FlinkKafkaProducer010 doesn't guarantee at-least-once semantic
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-7005'>FLINK-7005</a>] - Optimization steps are missing for nested registered tables
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-7011'>FLINK-7011</a>] - Instable Kafka testStartFromKafkaCommitOffsets failures on Travis
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-7025'>FLINK-7025</a>] - Using NullByteKeySelector for Unbounded ProcTime NonPartitioned Over
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-7034'>FLINK-7034</a>] - GraphiteReporter cannot recover from lost connection
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-7038'>FLINK-7038</a>] - Several misused "KeyedDataStream" term in docs and Javadocs
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-7041'>FLINK-7041</a>] - Deserialize StateBackend from JobCheckpointingSettings with user classloader
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-7132'>FLINK-7132</a>] - Fix BulkIteration parallelism
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-7133'>FLINK-7133</a>] - Fix Elasticsearch version interference
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-7137'>FLINK-7137</a>] - Flink table API defaults top level fields as nullable and all nested fields within CompositeType as non-nullable
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-7143'>FLINK-7143</a>] - Partition assignment for Kafka consumer is not stable
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-7154'>FLINK-7154</a>] - Missing call to build CsvTableSource example
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-7158'>FLINK-7158</a>] - Wrong test jar dependency in flink-clients
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-7177'>FLINK-7177</a>] - DataSetAggregateWithNullValuesRule fails creating null literal for non-nullable type
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-7178'>FLINK-7178</a>] - Datadog Metric Reporter Jar is Lacking Dependencies
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-7180'>FLINK-7180</a>] - CoGroupStream perform checkpoint failed
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-7195'>FLINK-7195</a>] - FlinkKafkaConsumer should not respect fetched partitions to filter restored partition states
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-7216'>FLINK-7216</a>] - ExecutionGraph can perform concurrent global restarts to scheduling
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-7225'>FLINK-7225</a>] - Cutoff exception message in StateDescriptor
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-7226'>FLINK-7226</a>] - REST responses contain invalid content-encoding header
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-7231'>FLINK-7231</a>] - SlotSharingGroups are not always released in time for new restarts
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-7234'>FLINK-7234</a>] - Fix CombineHint documentation
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-7241'>FLINK-7241</a>] - Fix YARN high availability documentation
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-7255'>FLINK-7255</a>] - ListStateDescriptor example uses wrong constructor
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-7258'>FLINK-7258</a>] - IllegalArgumentException in Netty bootstrap with large memory state segment size
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-7266'>FLINK-7266</a>] - Don't attempt to delete parent directory on S3
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-7268'>FLINK-7268</a>] - Zookeeper Checkpoint Store interacting with Incremental State Handles can lead to loss of handles
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-7281'>FLINK-7281</a>] - Fix various issues in (Maven) release infrastructure
+</li>
+</ul>
+
+<h2> Improvement
+</h2>
+<ul>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-6365'>FLINK-6365</a>] - Adapt default values of the Kinesis connector
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-6575'>FLINK-6575</a>] - Disable all tests on Windows that use HDFS
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-6682'>FLINK-6682</a>] - Improve error message in case parallelism exceeds maxParallelism
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-6789'>FLINK-6789</a>] - Remove duplicated test utility reducer in optimizer
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-6874'>FLINK-6874</a>] - Static and transient fields ignored for POJOs
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-6898'>FLINK-6898</a>] - Limit size of operator component in metric name
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-6937'>FLINK-6937</a>] - Fix link markdown in Production Readiness Checklist doc
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-6940'>FLINK-6940</a>] - Clarify the effect of configuring per-job state backend
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-6998'>FLINK-6998</a>] - Kafka connector needs to expose metrics for failed/successful offset commits in the Kafka Consumer callback
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-7004'>FLINK-7004</a>] - Switch to Travis Trusty image
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-7032'>FLINK-7032</a>] - Intellij is constantly changing language level of sub projects back to 1.6
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-7069'>FLINK-7069</a>] - Catch exceptions for each reporter separately
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-7149'>FLINK-7149</a>] - Add checkpoint ID to 'sendValues()' in GenericWriteAheadSink
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-7164'>FLINK-7164</a>] - Extend integration tests for (externalised) checkpoints, checkpoint store
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-7174'>FLINK-7174</a>] - Bump dependency of Kafka 0.10.x to the latest one
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-7211'>FLINK-7211</a>] - Exclude Gelly javadoc jar from release
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-7224'>FLINK-7224</a>] - Incorrect Javadoc description in all Kafka consumer versions
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-7228'>FLINK-7228</a>] - Harden HistoryServerStaticFileHandlerTest
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-7233'>FLINK-7233</a>] - TaskManagerHeapSizeCalculationJavaBashTest failed on Travis
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-7287'>FLINK-7287</a>] - test instability in Kafka010ITCase.testCommitOffsetsToKafka
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-7290'>FLINK-7290</a>] - Make release scripts modular
+</li>
+</ul>
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/flink-web/blob/21d2a851/downloads.md
----------------------------------------------------------------------
diff --git a/downloads.md b/downloads.md
index 7319bae..26d18a7 100644
--- a/downloads.md
+++ b/downloads.md
@@ -106,6 +106,7 @@ Note that the community is always open for discussing bugfix releases for even o
## All releases
+- Flink 1.3.2 - 2017-08-05 ([Source](http://www.apache.org/dyn/closer.lua/flink/flink-1.3.2/flink-1.3.2-src.tgz), [Binaries](http://archive.apache.org/dist/flink/flink-1.3.2/), [Docs]({{site.DOCS_BASE_URL}}flink-docs-release-1.3/), [Javadocs]({{site.DOCS_BASE_URL}}flink-docs-release-1.3/api/java), [ScalaDocs]({{site.DOCS_BASE_URL}}flink-docs-release-1.3/api/scala/index.html))
- Flink 1.3.1 - 2017-06-23 ([Source](http://www.apache.org/dyn/closer.lua/flink/flink-1.3.1/flink-1.3.1-src.tgz), [Binaries](http://archive.apache.org/dist/flink/flink-1.3.1/), [Docs]({{site.DOCS_BASE_URL}}flink-docs-release-1.3/), [Javadocs]({{site.DOCS_BASE_URL}}flink-docs-release-1.3/api/java), [ScalaDocs]({{site.DOCS_BASE_URL}}flink-docs-release-1.3/api/scala/index.html))
- Flink 1.3.0 - 2017-06-01 ([Source](http://www.apache.org/dyn/closer.lua/flink/flink-1.3.0/flink-1.3.0-src.tgz), [Binaries](http://archive.apache.org/dist/flink/flink-1.3.0/), [Docs]({{site.DOCS_BASE_URL}}flink-docs-release-1.3/), [Javadocs]({{site.DOCS_BASE_URL}}flink-docs-release-1.3/api/java), [ScalaDocs]({{site.DOCS_BASE_URL}}flink-docs-release-1.3/api/scala/index.html))
- Flink 1.2.1 - 2017-04-26 ([Source](http://www.apache.org/dyn/closer.lua/flink/flink-1.2.1/flink-1.2.1-src.tgz), [Binaries](http://archive.apache.org/dist/flink/flink-1.2.1/), [Docs]({{site.DOCS_BASE_URL}}flink-docs-release-1.2/), [Javadocs]({{site.DOCS_BASE_URL}}flink-docs-release-1.2/api/java), [ScalaDocs]({{site.DOCS_BASE_URL}}flink-docs-release-1.2/api/scala/index.html))