You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by uc...@apache.org on 2016/12/23 15:38:42 UTC
[1/4] flink-web git commit: Use full version on front page download
button
Repository: flink-web
Updated Branches:
refs/heads/asf-site f03b28f85 -> 75729631b
Use full version on front page download button
Project: http://git-wip-us.apache.org/repos/asf/flink-web/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink-web/commit/1aa9bb15
Tree: http://git-wip-us.apache.org/repos/asf/flink-web/tree/1aa9bb15
Diff: http://git-wip-us.apache.org/repos/asf/flink-web/diff/1aa9bb15
Branch: refs/heads/asf-site
Commit: 1aa9bb15b284446e988192d506b1b238d93aa033
Parents: f03b28f
Author: Ufuk Celebi <uc...@apache.org>
Authored: Fri Dec 23 16:16:40 2016 +0100
Committer: Ufuk Celebi <uc...@apache.org>
Committed: Fri Dec 23 16:16:40 2016 +0100
----------------------------------------------------------------------
index.md | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink-web/blob/1aa9bb15/index.md
----------------------------------------------------------------------
diff --git a/index.md b/index.md
index 257bf62..16c95a5 100644
--- a/index.md
+++ b/index.md
@@ -63,7 +63,7 @@ You can **integrate** Flink easily with other well-known open source systems bot
Download the **latest stable release** and run Flink on your machine, cluster, or cloud:
<div class="text-center download-button">
- <a href="downloads.html" class="btn btn-primary" markdown="1">**Download** Apache Flink� {{ site.stable }}</a>
+ <a href="downloads.html" class="btn btn-primary" markdown="1">**Download** Apache Flink� {{ site.FLINK_VERSION_STABLE }}</a>
<a href="{{ site.github }}" class="btn btn-info" markdown="1">Apache Flink� on **GitHub**</a>
</div>
[3/4] flink-web git commit: Add 1.1.4 release post
Posted by uc...@apache.org.
Add 1.1.4 release post
Project: http://git-wip-us.apache.org/repos/asf/flink-web/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink-web/commit/e5957367
Tree: http://git-wip-us.apache.org/repos/asf/flink-web/tree/e5957367
Diff: http://git-wip-us.apache.org/repos/asf/flink-web/diff/e5957367
Branch: refs/heads/asf-site
Commit: e595736716b87d685703b8a1f2192d5056178f9e
Parents: 695f591
Author: Ufuk Celebi <uc...@apache.org>
Authored: Fri Dec 23 16:38:07 2016 +0100
Committer: Ufuk Celebi <uc...@apache.org>
Committed: Fri Dec 23 16:38:07 2016 +0100
----------------------------------------------------------------------
_posts/2016-12-21-release-1.1.4.md | 218 ++++++++++++++++++++++++++++++++
1 file changed, 218 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink-web/blob/e5957367/_posts/2016-12-21-release-1.1.4.md
----------------------------------------------------------------------
diff --git a/_posts/2016-12-21-release-1.1.4.md b/_posts/2016-12-21-release-1.1.4.md
new file mode 100644
index 0000000..7c31c05
--- /dev/null
+++ b/_posts/2016-12-21-release-1.1.4.md
@@ -0,0 +1,218 @@
+---
+layout: post
+title: "Apache Flink 1.1.4 Released"
+date: 2016-12-21 9:00:00
+categories: news
+---
+
+The Apache Flink community released the next bugfix version of the Apache Flink 1.1 series.
+
+This release includes major robustness improvements for checkpoint cleanup on failures and consumption of intermediate streams. We highly recommend all users to upgrade to Flink 1.1.4.
+
+```xml
+<dependency>
+ <groupId>org.apache.flink</groupId>
+ <artifactId>flink-java</artifactId>
+ <version>1.1.4</version>
+</dependency>
+<dependency>
+ <groupId>org.apache.flink</groupId>
+ <artifactId>flink-streaming-java_2.10</artifactId>
+ <version>1.1.4</version>
+</dependency>
+<dependency>
+ <groupId>org.apache.flink</groupId>
+ <artifactId>flink-clients_2.10</artifactId>
+ <version>1.1.4</version>
+</dependency>
+```
+
+You can find the binaries on the updated [Downloads page](http://flink.apache.org/downloads.html).
+
+## Note for RocksDB Backend Users
+
+We updated Flink's RocksDB dependency version from `4.5.1` to `4.11.2`. Between these versions some of RocksDB's internal configuration defaults changed that would affect the memory footprint of running Flink with RocksDB. Therefore, we manually reset them to the previous defaults. If you want to run with the new Rocks 4.11.2 defaults, you can do this via:
+
+```java
+RocksDBStateBackend backend = new RocksDBStateBackend("...");
+// Use the new default options. Otherwise, the default for RocksDB 4.5.1
+// `PredefinedOptions.DEFAULT_ROCKS_4_5_1` will be used.
+backend.setPredefinedOptions(PredefinedOptions.DEFAULT);
+```
+
+## Release Notes - Flink - Version 1.1.4
+
+### Sub-task
+<ul>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-4510'>FLINK-4510</a>] - Always create CheckpointCoordinator
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-4984'>FLINK-4984</a>] - Add Cancellation Barriers to BarrierTracker and BarrierBuffer
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-4985'>FLINK-4985</a>] - Report Declined/Canceled Checkpoints to Checkpoint Coordinator
+</li>
+</ul>
+
+### Bug
+<ul>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-2662'>FLINK-2662</a>] - CompilerException: "Bug: Plan generation for Unions picked a ship strategy between binary plan operators."
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-3680'>FLINK-3680</a>] - Remove or improve (not set) text in the Job Plan UI
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-3813'>FLINK-3813</a>] - YARNSessionFIFOITCase.testDetachedMode failed on Travis
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-4108'>FLINK-4108</a>] - NPE in Row.productArity
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-4506'>FLINK-4506</a>] - CsvOutputFormat defaults allowNullValues to false, even though doc and declaration says true
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-4581'>FLINK-4581</a>] - Table API throws "No suitable driver found for jdbc:calcite"
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-4586'>FLINK-4586</a>] - NumberSequenceIterator and Accumulator threading issue
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-4619'>FLINK-4619</a>] - JobManager does not answer to client when restore from savepoint fails
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-4727'>FLINK-4727</a>] - Kafka 0.9 Consumer should also checkpoint auto retrieved offsets even when no data is read
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-4862'>FLINK-4862</a>] - NPE on EventTimeSessionWindows with ContinuousEventTimeTrigger
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-4932'>FLINK-4932</a>] - Don't let ExecutionGraph fail when in state Restarting
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-4933'>FLINK-4933</a>] - ExecutionGraph.scheduleOrUpdateConsumers can fail the ExecutionGraph
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-4977'>FLINK-4977</a>] - Enum serialization does not work in all cases
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-4991'>FLINK-4991</a>] - TestTask hangs in testWatchDogInterruptsTask
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-4998'>FLINK-4998</a>] - ResourceManager fails when num task slots > Yarn vcores
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5013'>FLINK-5013</a>] - Flink Kinesis connector doesn't work on old EMR versions
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5028'>FLINK-5028</a>] - Stream Tasks must not go through clean shutdown logic on cancellation
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5038'>FLINK-5038</a>] - Errors in the "cancelTask" method prevent closeables from being closed early
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5039'>FLINK-5039</a>] - Avro GenericRecord support is broken
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5040'>FLINK-5040</a>] - Set correct input channel types with eager scheduling
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5050'>FLINK-5050</a>] - JSON.org license is CatX
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5057'>FLINK-5057</a>] - Cancellation timeouts are picked from wrong config
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5058'>FLINK-5058</a>] - taskManagerMemory attribute set wrong value in FlinkShell
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5063'>FLINK-5063</a>] - State handles are not properly cleaned up for declined or expired checkpoints
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5073'>FLINK-5073</a>] - ZooKeeperCompleteCheckpointStore executes blocking delete operation in ZooKeeper client thread
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5075'>FLINK-5075</a>] - Kinesis consumer incorrectly determines shards as newly discovered when tested against Kinesalite
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5082'>FLINK-5082</a>] - Pull ExecutionService lifecycle management out of the JobManager
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5085'>FLINK-5085</a>] - Execute CheckpointCoodinator's state discard calls asynchronously
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5114'>FLINK-5114</a>] - PartitionState update with finished execution fails
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5142'>FLINK-5142</a>] - Resource leak in CheckpointCoordinator
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5149'>FLINK-5149</a>] - ContinuousEventTimeTrigger doesn't fire at the end of the window
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5154'>FLINK-5154</a>] - Duplicate TypeSerializer when writing RocksDB Snapshot
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5158'>FLINK-5158</a>] - Handle ZooKeeperCompletedCheckpointStore exceptions in CheckpointCoordinator
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5172'>FLINK-5172</a>] - In RocksDBStateBackend, set flink-core and flink-streaming-java to "provided"
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5173'>FLINK-5173</a>] - Upgrade RocksDB dependency
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5184'>FLINK-5184</a>] - Error result of compareSerialized in RowComparator class
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5193'>FLINK-5193</a>] - Recovering all jobs fails completely if a single recovery fails
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5197'>FLINK-5197</a>] - Late JobStatusChanged messages can interfere with running jobs
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5214'>FLINK-5214</a>] - Clean up checkpoint files when failing checkpoint operation on TM
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5215'>FLINK-5215</a>] - Close checkpoint streams upon cancellation
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5216'>FLINK-5216</a>] - CheckpointCoordinator's 'minPauseBetweenCheckpoints' refers to checkpoint start rather then checkpoint completion
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5218'>FLINK-5218</a>] - Eagerly close checkpoint streams on cancellation
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5228'>FLINK-5228</a>] - LocalInputChannel re-trigger request and release deadlock
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5229'>FLINK-5229</a>] - Cleanup StreamTaskStates if a checkpoint operation of a subsequent operator fails
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5246'>FLINK-5246</a>] - Don't discard unknown checkpoint messages in the CheckpointCoordinator
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5248'>FLINK-5248</a>] - SavepointITCase doesn't catch savepoint restore failure
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5274'>FLINK-5274</a>] - LocalInputChannel throws NPE if partition reader is released
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5275'>FLINK-5275</a>] - InputChanelDeploymentDescriptors throws misleading Exception if producer failed/cancelled
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5276'>FLINK-5276</a>] - ExecutionVertex archiving can throw NPE with many previous attempts
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5285'>FLINK-5285</a>] - CancelCheckpointMarker flood when using at least once mode
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5326'>FLINK-5326</a>] - IllegalStateException: Bug in Netty consumer logic: reader queue got notified by partition about available data, but none was available
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5352'>FLINK-5352</a>] - Restore RocksDB 1.1.3 memory behavior
+</li>
+</ul>
+
+### Improvement
+<ul>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-3347'>FLINK-3347</a>] - TaskManager (or its ActorSystem) need to restart in case they notice quarantine
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-3787'>FLINK-3787</a>] - Yarn client does not report unfulfillable container constraints
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-4445'>FLINK-4445</a>] - Ignore unmatched state when restoring from savepoint
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-4715'>FLINK-4715</a>] - TaskManager should commit suicide after cancellation failure
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-4894'>FLINK-4894</a>] - Don't block on buffer request after broadcastEvent
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-4975'>FLINK-4975</a>] - Add a limit for how much data may be buffered during checkpoint alignment
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-4996'>FLINK-4996</a>] - Make CrossHint @Public
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5046'>FLINK-5046</a>] - Avoid redundant serialization when creating the TaskDeploymentDescriptor
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5123'>FLINK-5123</a>] - Add description how to do proper shading to Flink docs.
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5169'>FLINK-5169</a>] - Make consumption of input channels fair
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5192'>FLINK-5192</a>] - Provide better log config templates
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5194'>FLINK-5194</a>] - Log heartbeats on TRACE level
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5196'>FLINK-5196</a>] - Don't log InputChannelDescriptor
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5198'>FLINK-5198</a>] - Overwrite TaskState toString
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5199'>FLINK-5199</a>] - Improve logging of submitted job graph actions in HA case
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5201'>FLINK-5201</a>] - Promote loaded config properties to INFO
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5207'>FLINK-5207</a>] - Decrease HadoopFileSystem logging
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5249'>FLINK-5249</a>] - description of datastream rescaling doesn't match the figure
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5259'>FLINK-5259</a>] - wrong execution environment in retry delays example
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5278'>FLINK-5278</a>] - Improve Task and checkpoint logging
+</li>
+</ul>
+
+### New Feature
+<ul>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-4976'>FLINK-4976</a>] - Add a way to abort in flight checkpoints
+</li>
+</ul>
+
+### Task
+<ul>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-4778'>FLINK-4778</a>] - Update program example in /docs/setup/cli.md due to the change in FLINK-2021
+</li>
+</ul>
+
[4/4] flink-web git commit: Rebuild website
Posted by uc...@apache.org.
Rebuild 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/75729631
Tree: http://git-wip-us.apache.org/repos/asf/flink-web/tree/75729631
Diff: http://git-wip-us.apache.org/repos/asf/flink-web/diff/75729631
Branch: refs/heads/asf-site
Commit: 75729631b97e26a5748e6d4a32df9fcb0ae7d30a
Parents: e595736
Author: Ufuk Celebi <uc...@apache.org>
Authored: Fri Dec 23 16:38:34 2016 +0100
Committer: Ufuk Celebi <uc...@apache.org>
Committed: Fri Dec 23 16:38:34 2016 +0100
----------------------------------------------------------------------
content/blog/feed.xml | 215 ++++++++++++
content/blog/index.html | 36 +-
content/blog/page2/index.html | 35 +-
content/blog/page3/index.html | 38 ++-
content/blog/page4/index.html | 26 ++
content/downloads.html | 37 ++-
content/index.html | 10 +-
content/news/2016/12/21/release-1.1.4.html | 416 ++++++++++++++++++++++++
8 files changed, 749 insertions(+), 64 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink-web/blob/75729631/content/blog/feed.xml
----------------------------------------------------------------------
diff --git a/content/blog/feed.xml b/content/blog/feed.xml
index e1fc711..066ae2f 100644
--- a/content/blog/feed.xml
+++ b/content/blog/feed.xml
@@ -7,6 +7,221 @@
<atom:link href="http://flink.apache.org/blog/feed.xml" rel="self" type="application/rss+xml" />
<item>
+<title>Apache Flink 1.1.4 Released</title>
+<description><p>The Apache Flink community released the next bugfix version of the Apache Flink 1.1 series.</p>
+
+<p>This release includes major robustness improvements for checkpoint cleanup on failures and consumption of intermediate streams. We highly recommend all users to upgrade to Flink 1.1.4.</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.1.4<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.1.4<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.1.4<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>
+
+<h2 id="note-for-rocksdb-backend-users">Note for RocksDB Backend Users</h2>
+
+<p>We updated Flink\u2019s RocksDB dependency version from <code>4.5.1</code> to <code>4.11.2</code>. Between these versions some of RocksDB\u2019s internal configuration defaults changed that would affect the memory footprint of running Flink with RocksDB. Therefore, we manually reset them to the previous defaults. If you want to run with the new Rocks 4.11.2 defaults, you can do this via:</p>
+
+<div class="highlight"><pre><code class="language-java"><span class="n">RocksDBStateBackend</span> <span class="n">backend</span> <span class="o">=</span> <span class="k">new</span> <span class="nf">RocksDBStateBackend</span><span class="o">(</span><span class="s">&quot;...&quot;</span><span class="o">);</span>
+<span class="c1">// Use the new default options. Otherwise, the default for RocksDB 4.5.1</span>
+<span class="c1">// `PredefinedOptions.DEFAULT_ROCKS_4_5_1` will be used.</span>
+<span class="n">backend</span><span class="o">.</span><span class="na">setPredefinedOptions</span><span class="o">(</span><span class="n">PredefinedOptions</span><span class="o">.</span><span class="na">DEFAULT</span><span class="o">);</span></code></pre></div>
+
+<h2 id="release-notes---flink---version-114">Release Notes - Flink - Version 1.1.4</h2>
+
+<h3 id="sub-task">Sub-task</h3>
+<ul>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4510">FLINK-4510</a>] - Always create CheckpointCoordinator
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4984">FLINK-4984</a>] - Add Cancellation Barriers to BarrierTracker and BarrierBuffer
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4985">FLINK-4985</a>] - Report Declined/Canceled Checkpoints to Checkpoint Coordinator
+</li>
+</ul>
+
+<h3 id="bug">Bug</h3>
+<ul>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2662">FLINK-2662</a>] - CompilerException: &quot;Bug: Plan generation for Unions picked a ship strategy between binary plan operators.&quot;
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3680">FLINK-3680</a>] - Remove or improve (not set) text in the Job Plan UI
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3813">FLINK-3813</a>] - YARNSessionFIFOITCase.testDetachedMode failed on Travis
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4108">FLINK-4108</a>] - NPE in Row.productArity
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4506">FLINK-4506</a>] - CsvOutputFormat defaults allowNullValues to false, even though doc and declaration says true
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4581">FLINK-4581</a>] - Table API throws &quot;No suitable driver found for jdbc:calcite&quot;
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4586">FLINK-4586</a>] - NumberSequenceIterator and Accumulator threading issue
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4619">FLINK-4619</a>] - JobManager does not answer to client when restore from savepoint fails
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4727">FLINK-4727</a>] - Kafka 0.9 Consumer should also checkpoint auto retrieved offsets even when no data is read
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4862">FLINK-4862</a>] - NPE on EventTimeSessionWindows with ContinuousEventTimeTrigger
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4932">FLINK-4932</a>] - Don&#39;t let ExecutionGraph fail when in state Restarting
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4933">FLINK-4933</a>] - ExecutionGraph.scheduleOrUpdateConsumers can fail the ExecutionGraph
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4977">FLINK-4977</a>] - Enum serialization does not work in all cases
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4991">FLINK-4991</a>] - TestTask hangs in testWatchDogInterruptsTask
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4998">FLINK-4998</a>] - ResourceManager fails when num task slots &gt; Yarn vcores
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5013">FLINK-5013</a>] - Flink Kinesis connector doesn&#39;t work on old EMR versions
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5028">FLINK-5028</a>] - Stream Tasks must not go through clean shutdown logic on cancellation
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5038">FLINK-5038</a>] - Errors in the &quot;cancelTask&quot; method prevent closeables from being closed early
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5039">FLINK-5039</a>] - Avro GenericRecord support is broken
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5040">FLINK-5040</a>] - Set correct input channel types with eager scheduling
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5050">FLINK-5050</a>] - JSON.org license is CatX
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5057">FLINK-5057</a>] - Cancellation timeouts are picked from wrong config
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5058">FLINK-5058</a>] - taskManagerMemory attribute set wrong value in FlinkShell
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5063">FLINK-5063</a>] - State handles are not properly cleaned up for declined or expired checkpoints
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5073">FLINK-5073</a>] - ZooKeeperCompleteCheckpointStore executes blocking delete operation in ZooKeeper client thread
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5075">FLINK-5075</a>] - Kinesis consumer incorrectly determines shards as newly discovered when tested against Kinesalite
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5082">FLINK-5082</a>] - Pull ExecutionService lifecycle management out of the JobManager
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5085">FLINK-5085</a>] - Execute CheckpointCoodinator&#39;s state discard calls asynchronously
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5114">FLINK-5114</a>] - PartitionState update with finished execution fails
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5142">FLINK-5142</a>] - Resource leak in CheckpointCoordinator
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5149">FLINK-5149</a>] - ContinuousEventTimeTrigger doesn&#39;t fire at the end of the window
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5154">FLINK-5154</a>] - Duplicate TypeSerializer when writing RocksDB Snapshot
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5158">FLINK-5158</a>] - Handle ZooKeeperCompletedCheckpointStore exceptions in CheckpointCoordinator
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5172">FLINK-5172</a>] - In RocksDBStateBackend, set flink-core and flink-streaming-java to &quot;provided&quot;
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5173">FLINK-5173</a>] - Upgrade RocksDB dependency
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5184">FLINK-5184</a>] - Error result of compareSerialized in RowComparator class
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5193">FLINK-5193</a>] - Recovering all jobs fails completely if a single recovery fails
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5197">FLINK-5197</a>] - Late JobStatusChanged messages can interfere with running jobs
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5214">FLINK-5214</a>] - Clean up checkpoint files when failing checkpoint operation on TM
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5215">FLINK-5215</a>] - Close checkpoint streams upon cancellation
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5216">FLINK-5216</a>] - CheckpointCoordinator&#39;s &#39;minPauseBetweenCheckpoints&#39; refers to checkpoint start rather then checkpoint completion
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5218">FLINK-5218</a>] - Eagerly close checkpoint streams on cancellation
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5228">FLINK-5228</a>] - LocalInputChannel re-trigger request and release deadlock
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5229">FLINK-5229</a>] - Cleanup StreamTaskStates if a checkpoint operation of a subsequent operator fails
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5246">FLINK-5246</a>] - Don&#39;t discard unknown checkpoint messages in the CheckpointCoordinator
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5248">FLINK-5248</a>] - SavepointITCase doesn&#39;t catch savepoint restore failure
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5274">FLINK-5274</a>] - LocalInputChannel throws NPE if partition reader is released
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5275">FLINK-5275</a>] - InputChanelDeploymentDescriptors throws misleading Exception if producer failed/cancelled
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5276">FLINK-5276</a>] - ExecutionVertex archiving can throw NPE with many previous attempts
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5285">FLINK-5285</a>] - CancelCheckpointMarker flood when using at least once mode
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5326">FLINK-5326</a>] - IllegalStateException: Bug in Netty consumer logic: reader queue got notified by partition about available data, but none was available
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5352">FLINK-5352</a>] - Restore RocksDB 1.1.3 memory behavior
+</li>
+</ul>
+
+<h3 id="improvement">Improvement</h3>
+<ul>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3347">FLINK-3347</a>] - TaskManager (or its ActorSystem) need to restart in case they notice quarantine
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3787">FLINK-3787</a>] - Yarn client does not report unfulfillable container constraints
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4445">FLINK-4445</a>] - Ignore unmatched state when restoring from savepoint
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4715">FLINK-4715</a>] - TaskManager should commit suicide after cancellation failure
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4894">FLINK-4894</a>] - Don&#39;t block on buffer request after broadcastEvent
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4975">FLINK-4975</a>] - Add a limit for how much data may be buffered during checkpoint alignment
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4996">FLINK-4996</a>] - Make CrossHint @Public
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5046">FLINK-5046</a>] - Avoid redundant serialization when creating the TaskDeploymentDescriptor
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5123">FLINK-5123</a>] - Add description how to do proper shading to Flink docs.
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5169">FLINK-5169</a>] - Make consumption of input channels fair
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5192">FLINK-5192</a>] - Provide better log config templates
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5194">FLINK-5194</a>] - Log heartbeats on TRACE level
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5196">FLINK-5196</a>] - Don&#39;t log InputChannelDescriptor
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5198">FLINK-5198</a>] - Overwrite TaskState toString
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5199">FLINK-5199</a>] - Improve logging of submitted job graph actions in HA case
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5201">FLINK-5201</a>] - Promote loaded config properties to INFO
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5207">FLINK-5207</a>] - Decrease HadoopFileSystem logging
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5249">FLINK-5249</a>] - description of datastream rescaling doesn&#39;t match the figure
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5259">FLINK-5259</a>] - wrong execution environment in retry delays example
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5278">FLINK-5278</a>] - Improve Task and checkpoint logging
+</li>
+</ul>
+
+<h3 id="new-feature">New Feature</h3>
+<ul>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4976">FLINK-4976</a>] - Add a way to abort in flight checkpoints
+</li>
+</ul>
+
+<h3 id="task">Task</h3>
+<ul>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4778">FLINK-4778</a>] - Update program example in /docs/setup/cli.md due to the change in FLINK-2021
+</li>
+</ul>
+
+</description>
+<pubDate>Wed, 21 Dec 2016 10:00:00 +0100</pubDate>
+<link>http://flink.apache.org/news/2016/12/21/release-1.1.4.html</link>
+<guid isPermaLink="true">/news/2016/12/21/release-1.1.4.html</guid>
+</item>
+
+<item>
<title>Apache Flink in 2016: Year in Review</title>
<description><p>2016 was an exciting year for the Apache Flink� community, and the
<a href="http://flink.apache.org/news/2016/03/08/release-1.0.0.html" target="_blank">release of Flink 1.0 in March</a>
http://git-wip-us.apache.org/repos/asf/flink-web/blob/75729631/content/blog/index.html
----------------------------------------------------------------------
diff --git a/content/blog/index.html b/content/blog/index.html
index 85aa21c..af297e6 100644
--- a/content/blog/index.html
+++ b/content/blog/index.html
@@ -162,6 +162,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>
@@ -275,19 +288,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 -->
@@ -320,6 +320,16 @@
<ul id="markdown-toc">
+ <li><a href="/news/2016/12/21/release-1.1.4.html">Apache Flink 1.1.4 Released</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/news/2016/12/19/2016-year-in-review.html">Apache Flink in 2016: Year in Review</a></li>
http://git-wip-us.apache.org/repos/asf/flink-web/blob/75729631/content/blog/page2/index.html
----------------------------------------------------------------------
diff --git a/content/blog/page2/index.html b/content/blog/page2/index.html
index fccdd74..0f1ccaf 100644
--- a/content/blog/page2/index.html
+++ b/content/blog/page2/index.html
@@ -162,6 +162,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>
@@ -271,18 +284,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 -->
@@ -315,6 +316,16 @@
<ul id="markdown-toc">
+ <li><a href="/news/2016/12/21/release-1.1.4.html">Apache Flink 1.1.4 Released</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/news/2016/12/19/2016-year-in-review.html">Apache Flink in 2016: Year in Review</a></li>
http://git-wip-us.apache.org/repos/asf/flink-web/blob/75729631/content/blog/page3/index.html
----------------------------------------------------------------------
diff --git a/content/blog/page3/index.html b/content/blog/page3/index.html
index afa5d8c..0b282ee 100644
--- a/content/blog/page3/index.html
+++ b/content/blog/page3/index.html
@@ -162,6 +162,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>
@@ -285,22 +297,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\u2019s 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 -->
@@ -333,6 +329,16 @@ community last month.</p>
<ul id="markdown-toc">
+ <li><a href="/news/2016/12/21/release-1.1.4.html">Apache Flink 1.1.4 Released</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/news/2016/12/19/2016-year-in-review.html">Apache Flink in 2016: Year in Review</a></li>
http://git-wip-us.apache.org/repos/asf/flink-web/blob/75729631/content/blog/page4/index.html
----------------------------------------------------------------------
diff --git a/content/blog/page4/index.html b/content/blog/page4/index.html
index d3e2180..0d405de 100644
--- a/content/blog/page4/index.html
+++ b/content/blog/page4/index.html
@@ -162,6 +162,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\u2019s 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>
@@ -317,6 +333,16 @@ academic and open source project that Flink originates from.</p>
<ul id="markdown-toc">
+ <li><a href="/news/2016/12/21/release-1.1.4.html">Apache Flink 1.1.4 Released</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/news/2016/12/19/2016-year-in-review.html">Apache Flink in 2016: Year in Review</a></li>
http://git-wip-us.apache.org/repos/asf/flink-web/blob/75729631/content/downloads.html
----------------------------------------------------------------------
diff --git a/content/downloads.html b/content/downloads.html
index c93dbff..d3dd49e 100644
--- a/content/downloads.html
+++ b/content/downloads.html
@@ -173,7 +173,7 @@ $( document ).ready(function() {
<div class="page-toc">
<ul id="markdown-toc">
- <li><a href="#latest-stable-release-v113" id="markdown-toc-latest-stable-release-v113">Latest stable release (v1.1.3)</a> <ul>
+ <li><a href="#latest-stable-release-v114" id="markdown-toc-latest-stable-release-v114">Latest stable release (v1.1.4)</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>
@@ -184,9 +184,9 @@ $( document ).ready(function() {
</div>
-<h2 id="latest-stable-release-v113">Latest stable release (v1.1.3)</h2>
+<h2 id="latest-stable-release-v114">Latest stable release (v1.1.4)</h2>
-<p>Apache Flink� 1.1.3 is our latest stable release.</p>
+<p>Apache Flink� 1.1.4 is our latest stable release.</p>
<p>You
<a href="faq.html#do-i-have-to-install-apache-hadoop-to-use-flink">don\u2019t have to install Hadoop</a>
@@ -205,32 +205,32 @@ pick the Hadoop 1 version.</p>
<tbody>
<tr>
<th>Hadoop� 1.2.1</th>
- <td><a href="http://www.apache.org/dyn/closer.lua/flink/flink-1.1.3/flink-1.1.3-bin-hadoop1-scala_2.10.tgz" class="ga-track" id="download-hadoop1">Download</a></td>
+ <td><a href="http://www.apache.org/dyn/closer.lua/flink/flink-1.1.4/flink-1.1.4-bin-hadoop1-scala_2.10.tgz" class="ga-track" id="download-hadoop1">Download</a></td>
<td></td>
</tr>
<tr>
<th>Hadoop� 2.3.0</th>
- <td><a href="http://www.apache.org/dyn/closer.lua/flink/flink-1.1.3/flink-1.1.3-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.1.3/flink-1.1.3-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.1.4/flink-1.1.4-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.1.4/flink-1.1.4-bin-hadoop2-scala_2.11.tgz" class="ga-track" id="download-hadoop2_211">Download</a></td>
</tr>
<tr>
<th>Hadoop� 2.4.1</th>
- <td><a href="http://www.apache.org/dyn/closer.lua/flink/flink-1.1.3/flink-1.1.3-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.1.3/flink-1.1.3-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.1.4/flink-1.1.4-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.1.4/flink-1.1.4-bin-hadoop24-scala_2.11.tgz" class="ga-track" id="download-hadoop24_211">Download</a></td>
</tr>
<tr>
<th>Hadoop� 2.6.0</th>
- <td><a href="http://www.apache.org/dyn/closer.lua/flink/flink-1.1.3/flink-1.1.3-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.1.3/flink-1.1.3-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.1.4/flink-1.1.4-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.1.4/flink-1.1.4-bin-hadoop26-scala_2.11.tgz" class="ga-track" id="download-hadoop26_211">Download</a></td>
</tr>
<tr>
<th>Hadoop� 2.7.0</th>
- <td><a href="http://www.apache.org/dyn/closer.lua/flink/flink-1.1.3/flink-1.1.3-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.1.3/flink-1.1.3-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.1.4/flink-1.1.4-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.1.4/flink-1.1.4-bin-hadoop27-scala_2.11.tgz" class="ga-track" id="download-hadoop27_211">Download</a></td>
</tr>
@@ -241,8 +241,8 @@ pick the Hadoop 1 version.</p>
<div class="list-group">
<!-- Source -->
- <a href="http://www.apache.org/dyn/closer.lua/flink/flink-1.1.3/flink-1.1.3-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.1.3</strong> Source Release</h4>
+ <a href="http://www.apache.org/dyn/closer.lua/flink/flink-1.1.4/flink-1.1.4-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.1.4</strong> Source Release</h4>
<p>Review the source code or build Flink on your own, using this package</p>
</a>
</div>
@@ -252,29 +252,30 @@ pick the Hadoop 1 version.</p>
<p>You can add the following dependencies to your <code>pom.xml</code> to include Apache Flink in your project. These dependencies include a local execution environment and thus support local testing.</p>
<ul>
- <li><strong>Hadoop 1</strong>: If you want to interact with Hadoop 1, use <code>1.1.3-hadoop1</code> as the version.</li>
+ <li><strong>Hadoop 1</strong>: If you want to interact with Hadoop 1, use <code>1.1.4-hadoop1</code> as the version.</li>
<li><strong>Scala API</strong>: To use the Scala API, replace the <code>flink-java</code> artifact id with <code>flink-scala_2.10</code> and <code>flink-streaming-java_2.10</code> with <code>flink-streaming-scala_2.10</code>. For Scala 2.11 dependencies, use the suffix <code>_2.11</code> instead of <code>_2.10</code>.</li>
</ul>
<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.1.3<span class="nt"></version></span>
+ <span class="nt"><version></span>1.1.4<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.1.3<span class="nt"></version></span>
+ <span class="nt"><version></span>1.1.4<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.1.3<span class="nt"></version></span>
+ <span class="nt"><version></span>1.1.4<span class="nt"></version></span>
<span class="nt"></dependency></span></code></pre></div>
<h2 id="all-releases">All releases</h2>
<ul>
+ <li>Flink 1.1.4 - 2016-12-21 (<a href="http://archive.apache.org/dist/flink/flink-1.1.4/flink-1.1.4-src.tgz">Source</a>, <a href="http://archive.apache.org/dist/flink/flink-1.1.4/">Binaries</a>, <a href="http://ci.apache.org/projects/flink/flink-docs-release-1.1/">Docs</a>, <a href="http://ci.apache.org/projects/flink/flink-docs-release-1.1/api/java">Javadocs</a>, <a href="http://ci.apache.org/projects/flink/flink-docs-release-1.1/api/scala/index.html">ScalaDocs</a>)</li>
<li>Flink 1.1.3 - 2016-10-13 (<a href="http://archive.apache.org/dist/flink/flink-1.1.3/flink-1.1.3-src.tgz">Source</a>, <a href="http://archive.apache.org/dist/flink/flink-1.1.3/">Binaries</a>, <a href="http://ci.apache.org/projects/flink/flink-docs-release-1.1/">Docs</a>, <a href="http://ci.apache.org/projects/flink/flink-docs-release-1.1/api/java">Javadocs</a>, <a href="http://ci.apache.org/projects/flink/flink-docs-release-1.1/api/scala/index.html">ScalaDocs</a>)</li>
<li>Flink 1.1.2 - 2016-09-05 (<a href="http://archive.apache.org/dist/flink/flink-1.1.2/flink-1.1.2-src.tgz">Source</a>, <a href="http://archive.apache.org/dist/flink/flink-1.1.2/">Binaries</a>)</li>
<li>Flink 1.1.1 - 2016-08-11 (<a href="http://archive.apache.org/dist/flink/flink-1.1.1/flink-1.1.1-src.tgz">Source</a>, <a href="http://archive.apache.org/dist/flink/flink-1.1.1/">Binaries</a>)</li>
http://git-wip-us.apache.org/repos/asf/flink-web/blob/75729631/content/index.html
----------------------------------------------------------------------
diff --git a/content/index.html b/content/index.html
index ae93989..fabc1b7 100644
--- a/content/index.html
+++ b/content/index.html
@@ -217,7 +217,7 @@
<p>Download the <strong>latest stable release</strong> and run Flink on your machine, cluster, or cloud:</p>
<div class="text-center download-button">
- <a href="downloads.html" class="btn btn-primary"><strong>Download</strong> Apache Flink� 1.1</a>
+ <a href="downloads.html" class="btn btn-primary"><strong>Download</strong> Apache Flink� 1.1.4</a>
<a href="https://github.com/apache/flink" class="btn btn-info">Apache Flink� on <strong>GitHub</strong></a>
</div>
@@ -235,6 +235,10 @@
<ul class="list-group">
+ <li class="list-group-item"><span>21 Dec 2016</span> »
+ <a href="/news/2016/12/21/release-1.1.4.html">Apache Flink 1.1.4 Released</a>
+ </li>
+
<li class="list-group-item"><span>19 Dec 2016</span> »
<a href="/news/2016/12/19/2016-year-in-review.html">Apache Flink in 2016: Year in Review</a>
</li>
@@ -250,10 +254,6 @@
<li class="list-group-item"><span>24 Aug 2016</span> »
<a href="/news/2016/08/24/ff16-keynotes-panels.html">Flink Forward 2016: Announcing Schedule, Keynotes, and Panel Discussion</a>
</li>
-
- <li class="list-group-item"><span>11 Aug 2016</span> »
- <a href="/news/2016/08/11/release-1.1.1.html">Flink 1.1.1 Released</a>
- </li>
</ul>
http://git-wip-us.apache.org/repos/asf/flink-web/blob/75729631/content/news/2016/12/21/release-1.1.4.html
----------------------------------------------------------------------
diff --git a/content/news/2016/12/21/release-1.1.4.html b/content/news/2016/12/21/release-1.1.4.html
new file mode 100644
index 0000000..d2036c1
--- /dev/null
+++ b/content/news/2016/12/21/release-1.1.4.html
@@ -0,0 +1,416 @@
+<!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.1.4 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>
+
+
+ <!-- Top navbar. -->
+ <nav class="navbar navbar-default navbar-fixed-top">
+ <div class="container">
+ <!-- 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/navbar-brand-logo.jpg" width="78px" height="40px">
+ </a>
+ </div>
+ </div><!-- /.navbar-header -->
+
+ <!-- The navigation links. -->
+ <div class="collapse navbar-collapse" id="bs-example-navbar-collapse-1">
+ <ul class="nav navbar-nav">
+
+ <!-- Overview -->
+ <li><a href="/index.html">Overview</a></li>
+
+ <!-- Features -->
+ <li><a href="/features.html">Features</a></li>
+
+ <!-- Downloads -->
+ <li><a href="/downloads.html">Downloads</a></li>
+
+ <!-- FAQ -->
+ <li><a href="/faq.html">FAQ</a></li>
+
+
+ <!-- Quickstart -->
+ <li class="dropdown">
+ <a href="#" class="dropdown-toggle" data-toggle="dropdown" role="button" aria-expanded="false"><small><span class="glyphicon glyphicon-new-window"></span></small> Quickstart <span class="caret"></span></a>
+ <ul class="dropdown-menu" role="menu">
+ <li><a href="http://ci.apache.org/projects/flink/flink-docs-release-1.1/quickstart/setup_quickstart.html">Setup</a></li>
+ <li><a href="http://ci.apache.org/projects/flink/flink-docs-release-1.1/quickstart/run_example_quickstart.html">Example: Wikipedia Edit Stream</a></li>
+ <li><a href="http://ci.apache.org/projects/flink/flink-docs-release-1.1/quickstart/java_api_quickstart.html">Java API</a></li>
+ <li><a href="http://ci.apache.org/projects/flink/flink-docs-release-1.1/quickstart/scala_api_quickstart.html">Scala API</a></li>
+ </ul>
+ </li>
+
+ <!-- Documentation -->
+ <li class="dropdown">
+ <a href="" class="dropdown-toggle" data-toggle="dropdown" role="button" aria-expanded="false"><small><span class="glyphicon glyphicon-new-window"></span></small> Documentation <span class="caret"></span></a>
+ <ul class="dropdown-menu" role="menu">
+ <!-- Latest stable release -->
+ <li role="presentation" class="dropdown-header"><strong>Latest Release</strong> (Stable)</li>
+ <li><a href="http://ci.apache.org/projects/flink/flink-docs-release-1.1">1.1 Documentation</a></li>
+ <li><a href="http://ci.apache.org/projects/flink/flink-docs-release-1.1/api/java" class="active">1.1 Javadocs</a></li>
+ <li><a href="http://ci.apache.org/projects/flink/flink-docs-release-1.1/api/scala/index.html" class="active">1.1 ScalaDocs</a></li>
+
+ <!-- Snapshot docs -->
+ <li class="divider"></li>
+ <li role="presentation" class="dropdown-header"><strong>Snapshot</strong> (Development)</li>
+ <li><a href="http://ci.apache.org/projects/flink/flink-docs-release-1.2">1.2 Documentation</a></li>
+ <li><a href="http://ci.apache.org/projects/flink/flink-docs-release-1.2/api/java" class="active">1.2 Javadocs</a></li>
+ <li><a href="http://ci.apache.org/projects/flink/flink-docs-release-1.2/api/scala/index.html" class="active">1.2 ScalaDocs</a></li>
+
+ <!-- Wiki -->
+ <li class="divider"></li>
+ <li><a href="/visualizer/"><small><span class="glyphicon glyphicon-new-window"></span></small> Plan Visualizer</a></li>
+ <li><a href="https://cwiki.apache.org/confluence/display/FLINK/Apache+Flink+Home"><small><span class="glyphicon glyphicon-new-window"></span></small> Wiki</a></li>
+ </ul>
+ </li>
+
+ </ul>
+
+ <ul class="nav navbar-nav navbar-right">
+ <!-- Blog -->
+ <li class=" active hidden-md hidden-sm"><a href="/blog/">Blog</a></li>
+
+ <li class="dropdown hidden-md hidden-sm">
+ <a href="#" class="dropdown-toggle" data-toggle="dropdown" role="button" aria-expanded="false">Community <span class="caret"></span></a>
+ <ul class="dropdown-menu" role="menu">
+ <!-- Community -->
+ <li role="presentation" class="dropdown-header"><strong>Community</strong></li>
+ <li><a href="/community.html#mailing-lists">Mailing Lists</a></li>
+ <li><a href="/community.html#irc">IRC</a></li>
+ <li><a href="/community.html#stack-overflow">Stack Overflow</a></li>
+ <li><a href="/community.html#issue-tracker">Issue Tracker</a></li>
+ <li><a href="/community.html#third-party-packages">Third Party Packages</a></li>
+ <li><a href="/community.html#source-code">Source Code</a></li>
+ <li><a href="/community.html#people">People</a></li>
+ <li><a href="/poweredby.html">Powered by Flink</a></li>
+
+ <!-- Contribute -->
+ <li class="divider"></li>
+ <li role="presentation" class="dropdown-header"><strong>Contribute</strong></li>
+ <li><a href="/how-to-contribute.html">How to Contribute</a></li>
+ <li><a href="/contribute-code.html">Contribute Code</a></li>
+ <li><a href="/contribute-documentation.html">Contribute Documentation</a></li>
+ <li><a href="/improve-website.html">Improve the Website</a></li>
+ <li><a href="https://cwiki.apache.org/confluence/display/FLINK/Flink+Improvement+Proposals"><small><span class="glyphicon glyphicon-new-window"></span></small> Flink Improvement Proposals (Design Docs)</a></li>
+ </ul>
+ </li>
+
+ <li class="dropdown hidden-md hidden-sm">
+ <a href="#" class="dropdown-toggle" data-toggle="dropdown" role="button" aria-expanded="false">Project <span class="caret"></span></a>
+ <ul class="dropdown-menu" role="menu">
+ <!-- Project -->
+ <li role="presentation" class="dropdown-header"><strong>Project</strong></li>
+ <li><a href="/slides.html">Slides</a></li>
+ <li><a href="/material.html">Material</a></li>
+ <li><a href="https://twitter.com/apacheflink"><small><span class="glyphicon glyphicon-new-window"></span></small> Twitter</a></li>
+ <li><a href="https://github.com/apache/flink"><small><span class="glyphicon glyphicon-new-window"></span></small> GitHub</a></li>
+ <li><a href="https://cwiki.apache.org/confluence/display/FLINK/Apache+Flink+Home"><small><span class="glyphicon glyphicon-new-window"></span></small> Wiki</a></li>
+ </ul>
+ </li>
+ </ul>
+ </div><!-- /.navbar-collapse -->
+ </div><!-- /.container -->
+ </nav>
+
+
+ <!-- Main content. -->
+ <div class="container">
+
+
+<div class="row">
+ <div class="col-sm-8 col-sm-offset-2">
+ <div class="row">
+ <h1>Apache Flink 1.1.4 Released</h1>
+
+ <article>
+ <p>21 Dec 2016</p>
+
+<p>The Apache Flink community released the next bugfix version of the Apache Flink 1.1 series.</p>
+
+<p>This release includes major robustness improvements for checkpoint cleanup on failures and consumption of intermediate streams. We highly recommend all users to upgrade to Flink 1.1.4.</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.1.4<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.1.4<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.1.4<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>
+
+<h2 id="note-for-rocksdb-backend-users">Note for RocksDB Backend Users</h2>
+
+<p>We updated Flink\u2019s RocksDB dependency version from <code>4.5.1</code> to <code>4.11.2</code>. Between these versions some of RocksDB\u2019s internal configuration defaults changed that would affect the memory footprint of running Flink with RocksDB. Therefore, we manually reset them to the previous defaults. If you want to run with the new Rocks 4.11.2 defaults, you can do this via:</p>
+
+<div class="highlight"><pre><code class="language-java"><span class="n">RocksDBStateBackend</span> <span class="n">backend</span> <span class="o">=</span> <span class="k">new</span> <span class="nf">RocksDBStateBackend</span><span class="o">(</span><span class="s">"..."</span><span class="o">);</span>
+<span class="c1">// Use the new default options. Otherwise, the default for RocksDB 4.5.1</span>
+<span class="c1">// `PredefinedOptions.DEFAULT_ROCKS_4_5_1` will be used.</span>
+<span class="n">backend</span><span class="o">.</span><span class="na">setPredefinedOptions</span><span class="o">(</span><span class="n">PredefinedOptions</span><span class="o">.</span><span class="na">DEFAULT</span><span class="o">);</span></code></pre></div>
+
+<h2 id="release-notes---flink---version-114">Release Notes - Flink - Version 1.1.4</h2>
+
+<h3 id="sub-task">Sub-task</h3>
+<ul>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4510">FLINK-4510</a>] - Always create CheckpointCoordinator
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4984">FLINK-4984</a>] - Add Cancellation Barriers to BarrierTracker and BarrierBuffer
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4985">FLINK-4985</a>] - Report Declined/Canceled Checkpoints to Checkpoint Coordinator
+</li>
+</ul>
+
+<h3 id="bug">Bug</h3>
+<ul>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2662">FLINK-2662</a>] - CompilerException: "Bug: Plan generation for Unions picked a ship strategy between binary plan operators."
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3680">FLINK-3680</a>] - Remove or improve (not set) text in the Job Plan UI
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3813">FLINK-3813</a>] - YARNSessionFIFOITCase.testDetachedMode failed on Travis
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4108">FLINK-4108</a>] - NPE in Row.productArity
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4506">FLINK-4506</a>] - CsvOutputFormat defaults allowNullValues to false, even though doc and declaration says true
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4581">FLINK-4581</a>] - Table API throws "No suitable driver found for jdbc:calcite"
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4586">FLINK-4586</a>] - NumberSequenceIterator and Accumulator threading issue
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4619">FLINK-4619</a>] - JobManager does not answer to client when restore from savepoint fails
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4727">FLINK-4727</a>] - Kafka 0.9 Consumer should also checkpoint auto retrieved offsets even when no data is read
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4862">FLINK-4862</a>] - NPE on EventTimeSessionWindows with ContinuousEventTimeTrigger
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4932">FLINK-4932</a>] - Don't let ExecutionGraph fail when in state Restarting
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4933">FLINK-4933</a>] - ExecutionGraph.scheduleOrUpdateConsumers can fail the ExecutionGraph
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4977">FLINK-4977</a>] - Enum serialization does not work in all cases
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4991">FLINK-4991</a>] - TestTask hangs in testWatchDogInterruptsTask
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4998">FLINK-4998</a>] - ResourceManager fails when num task slots > Yarn vcores
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5013">FLINK-5013</a>] - Flink Kinesis connector doesn't work on old EMR versions
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5028">FLINK-5028</a>] - Stream Tasks must not go through clean shutdown logic on cancellation
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5038">FLINK-5038</a>] - Errors in the "cancelTask" method prevent closeables from being closed early
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5039">FLINK-5039</a>] - Avro GenericRecord support is broken
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5040">FLINK-5040</a>] - Set correct input channel types with eager scheduling
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5050">FLINK-5050</a>] - JSON.org license is CatX
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5057">FLINK-5057</a>] - Cancellation timeouts are picked from wrong config
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5058">FLINK-5058</a>] - taskManagerMemory attribute set wrong value in FlinkShell
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5063">FLINK-5063</a>] - State handles are not properly cleaned up for declined or expired checkpoints
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5073">FLINK-5073</a>] - ZooKeeperCompleteCheckpointStore executes blocking delete operation in ZooKeeper client thread
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5075">FLINK-5075</a>] - Kinesis consumer incorrectly determines shards as newly discovered when tested against Kinesalite
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5082">FLINK-5082</a>] - Pull ExecutionService lifecycle management out of the JobManager
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5085">FLINK-5085</a>] - Execute CheckpointCoodinator's state discard calls asynchronously
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5114">FLINK-5114</a>] - PartitionState update with finished execution fails
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5142">FLINK-5142</a>] - Resource leak in CheckpointCoordinator
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5149">FLINK-5149</a>] - ContinuousEventTimeTrigger doesn't fire at the end of the window
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5154">FLINK-5154</a>] - Duplicate TypeSerializer when writing RocksDB Snapshot
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5158">FLINK-5158</a>] - Handle ZooKeeperCompletedCheckpointStore exceptions in CheckpointCoordinator
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5172">FLINK-5172</a>] - In RocksDBStateBackend, set flink-core and flink-streaming-java to "provided"
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5173">FLINK-5173</a>] - Upgrade RocksDB dependency
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5184">FLINK-5184</a>] - Error result of compareSerialized in RowComparator class
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5193">FLINK-5193</a>] - Recovering all jobs fails completely if a single recovery fails
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5197">FLINK-5197</a>] - Late JobStatusChanged messages can interfere with running jobs
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5214">FLINK-5214</a>] - Clean up checkpoint files when failing checkpoint operation on TM
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5215">FLINK-5215</a>] - Close checkpoint streams upon cancellation
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5216">FLINK-5216</a>] - CheckpointCoordinator's 'minPauseBetweenCheckpoints' refers to checkpoint start rather then checkpoint completion
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5218">FLINK-5218</a>] - Eagerly close checkpoint streams on cancellation
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5228">FLINK-5228</a>] - LocalInputChannel re-trigger request and release deadlock
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5229">FLINK-5229</a>] - Cleanup StreamTaskStates if a checkpoint operation of a subsequent operator fails
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5246">FLINK-5246</a>] - Don't discard unknown checkpoint messages in the CheckpointCoordinator
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5248">FLINK-5248</a>] - SavepointITCase doesn't catch savepoint restore failure
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5274">FLINK-5274</a>] - LocalInputChannel throws NPE if partition reader is released
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5275">FLINK-5275</a>] - InputChanelDeploymentDescriptors throws misleading Exception if producer failed/cancelled
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5276">FLINK-5276</a>] - ExecutionVertex archiving can throw NPE with many previous attempts
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5285">FLINK-5285</a>] - CancelCheckpointMarker flood when using at least once mode
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5326">FLINK-5326</a>] - IllegalStateException: Bug in Netty consumer logic: reader queue got notified by partition about available data, but none was available
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5352">FLINK-5352</a>] - Restore RocksDB 1.1.3 memory behavior
+</li>
+</ul>
+
+<h3 id="improvement">Improvement</h3>
+<ul>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3347">FLINK-3347</a>] - TaskManager (or its ActorSystem) need to restart in case they notice quarantine
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3787">FLINK-3787</a>] - Yarn client does not report unfulfillable container constraints
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4445">FLINK-4445</a>] - Ignore unmatched state when restoring from savepoint
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4715">FLINK-4715</a>] - TaskManager should commit suicide after cancellation failure
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4894">FLINK-4894</a>] - Don't block on buffer request after broadcastEvent
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4975">FLINK-4975</a>] - Add a limit for how much data may be buffered during checkpoint alignment
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4996">FLINK-4996</a>] - Make CrossHint @Public
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5046">FLINK-5046</a>] - Avoid redundant serialization when creating the TaskDeploymentDescriptor
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5123">FLINK-5123</a>] - Add description how to do proper shading to Flink docs.
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5169">FLINK-5169</a>] - Make consumption of input channels fair
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5192">FLINK-5192</a>] - Provide better log config templates
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5194">FLINK-5194</a>] - Log heartbeats on TRACE level
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5196">FLINK-5196</a>] - Don't log InputChannelDescriptor
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5198">FLINK-5198</a>] - Overwrite TaskState toString
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5199">FLINK-5199</a>] - Improve logging of submitted job graph actions in HA case
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5201">FLINK-5201</a>] - Promote loaded config properties to INFO
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5207">FLINK-5207</a>] - Decrease HadoopFileSystem logging
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5249">FLINK-5249</a>] - description of datastream rescaling doesn't match the figure
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5259">FLINK-5259</a>] - wrong execution environment in retry delays example
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5278">FLINK-5278</a>] - Improve Task and checkpoint logging
+</li>
+</ul>
+
+<h3 id="new-feature">New Feature</h3>
+<ul>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4976">FLINK-4976</a>] - Add a way to abort in flight checkpoints
+</li>
+</ul>
+
+<h3 id="task">Task</h3>
+<ul>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4778">FLINK-4778</a>] - Update program example in /docs/setup/cli.md due to the change in FLINK-2021
+</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>
+
+ <hr />
+ <div class="footer text-center">
+ <p>Copyright � 2014-2016 <a href="http://apache.org">The Apache Software Foundation</a>. All Rights Reserved.</p>
+ <p>Apache Flink, Apache, 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><!-- /.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>
+
+ <!-- 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/4] flink-web git commit: Update Flink version to 1.1.4
Posted by uc...@apache.org.
Update Flink version to 1.1.4
Project: http://git-wip-us.apache.org/repos/asf/flink-web/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink-web/commit/695f591d
Tree: http://git-wip-us.apache.org/repos/asf/flink-web/tree/695f591d
Diff: http://git-wip-us.apache.org/repos/asf/flink-web/diff/695f591d
Branch: refs/heads/asf-site
Commit: 695f591ddb2f11c22065e679ae2a4d78cb35b2a8
Parents: 1aa9bb1
Author: Ufuk Celebi <uc...@apache.org>
Authored: Fri Dec 23 16:16:50 2016 +0100
Committer: Ufuk Celebi <uc...@apache.org>
Committed: Fri Dec 23 16:16:50 2016 +0100
----------------------------------------------------------------------
_config.yml | 26 +++++++++++++-------------
downloads.md | 1 +
2 files changed, 14 insertions(+), 13 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink-web/blob/695f591d/_config.yml
----------------------------------------------------------------------
diff --git a/_config.yml b/_config.yml
index 6bd5d03..dc018e6 100644
--- a/_config.yml
+++ b/_config.yml
@@ -9,9 +9,9 @@ url: http://flink.apache.org
DOCS_BASE_URL: http://ci.apache.org/projects/flink/
-FLINK_VERSION_STABLE: 1.1.3
-FLINK_VERSION_HADOOP_1_STABLE: 1.1.3-hadoop1
-FLINK_VERSION_HADOOP_2_STABLE: 1.1.3
+FLINK_VERSION_STABLE: 1.1.4
+FLINK_VERSION_HADOOP_1_STABLE: 1.1.4-hadoop1
+FLINK_VERSION_HADOOP_2_STABLE: 1.1.4
FLINK_VERSION_STABLE_SHORT: 1.1
FLINK_VERSION_LATEST: 1.2-SNAPSHOT
@@ -24,19 +24,19 @@ 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.1.3/flink-1.1.3-src.tgz
+FLINK_DOWNLOAD_URL_SOURCE: http://www.apache.org/dyn/closer.lua/flink/flink-1.1.4/flink-1.1.4-src.tgz
-FLINK_DOWNLOAD_URL_HADOOP_1_STABLE: http://www.apache.org/dyn/closer.lua/flink/flink-1.1.3/flink-1.1.3-bin-hadoop1-scala_2.10.tgz
+FLINK_DOWNLOAD_URL_HADOOP_1_STABLE: http://www.apache.org/dyn/closer.lua/flink/flink-1.1.4/flink-1.1.4-bin-hadoop1-scala_2.10.tgz
-FLINK_DOWNLOAD_URL_HADOOP_2_STABLE: http://www.apache.org/dyn/closer.lua/flink/flink-1.1.3/flink-1.1.3-bin-hadoop2-scala_2.10.tgz
-FLINK_DOWNLOAD_URL_HADOOP_24_STABLE: http://www.apache.org/dyn/closer.lua/flink/flink-1.1.3/flink-1.1.3-bin-hadoop24-scala_2.10.tgz
-FLINK_DOWNLOAD_URL_HADOOP_26_STABLE: http://www.apache.org/dyn/closer.lua/flink/flink-1.1.3/flink-1.1.3-bin-hadoop26-scala_2.10.tgz
-FLINK_DOWNLOAD_URL_HADOOP_27_STABLE: http://www.apache.org/dyn/closer.lua/flink/flink-1.1.3/flink-1.1.3-bin-hadoop27-scala_2.10.tgz
+FLINK_DOWNLOAD_URL_HADOOP_2_STABLE: http://www.apache.org/dyn/closer.lua/flink/flink-1.1.4/flink-1.1.4-bin-hadoop2-scala_2.10.tgz
+FLINK_DOWNLOAD_URL_HADOOP_24_STABLE: http://www.apache.org/dyn/closer.lua/flink/flink-1.1.4/flink-1.1.4-bin-hadoop24-scala_2.10.tgz
+FLINK_DOWNLOAD_URL_HADOOP_26_STABLE: http://www.apache.org/dyn/closer.lua/flink/flink-1.1.4/flink-1.1.4-bin-hadoop26-scala_2.10.tgz
+FLINK_DOWNLOAD_URL_HADOOP_27_STABLE: http://www.apache.org/dyn/closer.lua/flink/flink-1.1.4/flink-1.1.4-bin-hadoop27-scala_2.10.tgz
-FLINK_DOWNLOAD_URL_HADOOP_2_SCALA_211_STABLE: http://www.apache.org/dyn/closer.lua/flink/flink-1.1.3/flink-1.1.3-bin-hadoop2-scala_2.11.tgz
-FLINK_DOWNLOAD_URL_HADOOP_24_SCALA_211_STABLE: http://www.apache.org/dyn/closer.lua/flink/flink-1.1.3/flink-1.1.3-bin-hadoop24-scala_2.11.tgz
-FLINK_DOWNLOAD_URL_HADOOP_26_SCALA_211_STABLE: http://www.apache.org/dyn/closer.lua/flink/flink-1.1.3/flink-1.1.3-bin-hadoop26-scala_2.11.tgz
-FLINK_DOWNLOAD_URL_HADOOP_27_SCALA_211_STABLE: http://www.apache.org/dyn/closer.lua/flink/flink-1.1.3/flink-1.1.3-bin-hadoop27-scala_2.11.tgz
+FLINK_DOWNLOAD_URL_HADOOP_2_SCALA_211_STABLE: http://www.apache.org/dyn/closer.lua/flink/flink-1.1.4/flink-1.1.4-bin-hadoop2-scala_2.11.tgz
+FLINK_DOWNLOAD_URL_HADOOP_24_SCALA_211_STABLE: http://www.apache.org/dyn/closer.lua/flink/flink-1.1.4/flink-1.1.4-bin-hadoop24-scala_2.11.tgz
+FLINK_DOWNLOAD_URL_HADOOP_26_SCALA_211_STABLE: http://www.apache.org/dyn/closer.lua/flink/flink-1.1.4/flink-1.1.4-bin-hadoop26-scala_2.11.tgz
+FLINK_DOWNLOAD_URL_HADOOP_27_SCALA_211_STABLE: http://www.apache.org/dyn/closer.lua/flink/flink-1.1.4/flink-1.1.4-bin-hadoop27-scala_2.11.tgz
FLINK_DOWNLOAD_URL_HADOOP_1_LATEST: https://s3.amazonaws.com/flink-nightly/flink-1.2-SNAPSHOT-bin-hadoop1.tgz
FLINK_DOWNLOAD_URL_HADOOP_2_LATEST: https://s3.amazonaws.com/flink-nightly/flink-1.2-SNAPSHOT-bin-hadoop2.tgz
http://git-wip-us.apache.org/repos/asf/flink-web/blob/695f591d/downloads.md
----------------------------------------------------------------------
diff --git a/downloads.md b/downloads.md
index c51f047..e1f8efb 100644
--- a/downloads.md
+++ b/downloads.md
@@ -106,6 +106,7 @@ You can add the following dependencies to your `pom.xml` to include Apache Flink
## All releases
+- Flink 1.1.4 - 2016-12-21 ([Source](http://archive.apache.org/dist/flink/flink-1.1.4/flink-1.1.4-src.tgz), [Binaries](http://archive.apache.org/dist/flink/flink-1.1.4/), [Docs]({{site.DOCS_BASE_URL}}flink-docs-release-1.1/), [Javadocs]({{site.DOCS_BASE_URL}}flink-docs-release-1.1/api/java), [ScalaDocs]({{site.DOCS_BASE_URL}}flink-docs-release-1.1/api/scala/index.html))
- Flink 1.1.3 - 2016-10-13 ([Source](http://archive.apache.org/dist/flink/flink-1.1.3/flink-1.1.3-src.tgz), [Binaries](http://archive.apache.org/dist/flink/flink-1.1.3/), [Docs]({{site.DOCS_BASE_URL}}flink-docs-release-1.1/), [Javadocs]({{site.DOCS_BASE_URL}}flink-docs-release-1.1/api/java), [ScalaDocs]({{site.DOCS_BASE_URL}}flink-docs-release-1.1/api/scala/index.html))
- Flink 1.1.2 - 2016-09-05 ([Source](http://archive.apache.org/dist/flink/flink-1.1.2/flink-1.1.2-src.tgz), [Binaries](http://archive.apache.org/dist/flink/flink-1.1.2/))
- Flink 1.1.1 - 2016-08-11 ([Source](http://archive.apache.org/dist/flink/flink-1.1.1/flink-1.1.1-src.tgz), [Binaries](http://archive.apache.org/dist/flink/flink-1.1.1/))