You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tr...@apache.org on 2018/09/20 13:51:29 UTC
[flink-web] 03/04: Add release 1.6.1
This is an automated email from the ASF dual-hosted git repository.
trohrmann pushed a commit to branch asf-site
in repository https://gitbox.apache.org/repos/asf/flink-web.git
commit cfc20147cc283863e74fffa766346df3e8231210
Author: Till Rohrmann <tr...@apache.org>
AuthorDate: Sat Sep 15 23:31:11 2018 +0200
Add release 1.6.1
---
_posts/2018-09-20-release-1.6.1.md | 181 +++++++++++++++++++++++++++++++++++++
downloads.md | 1 +
2 files changed, 182 insertions(+)
diff --git a/_posts/2018-09-20-release-1.6.1.md b/_posts/2018-09-20-release-1.6.1.md
new file mode 100644
index 0000000..02b42a2
--- /dev/null
+++ b/_posts/2018-09-20-release-1.6.1.md
@@ -0,0 +1,181 @@
+---
+layout: post
+title: "Apache Flink 1.6.1 Released"
+date: 2018-09-20 12:00:00
+categories: news
+---
+
+The Apache Flink community released the first bugfix version of the Apache Flink 1.6 series.
+
+This release includes 60 fixes and minor improvements for Flink 1.6.1. The list below includes a detailed list of all fixes.
+
+We highly recommend all users to upgrade to Flink 1.6.1.
+
+Updated Maven dependencies:
+
+```xml
+<dependency>
+ <groupId>org.apache.flink</groupId>
+ <artifactId>flink-java</artifactId>
+ <version>1.6.1</version>
+</dependency>
+<dependency>
+ <groupId>org.apache.flink</groupId>
+ <artifactId>flink-streaming-java_2.11</artifactId>
+ <version>1.6.1</version>
+</dependency>
+<dependency>
+ <groupId>org.apache.flink</groupId>
+ <artifactId>flink-clients_2.11</artifactId>
+ <version>1.6.1</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-9637'>FLINK-9637</a>] - Add public user documentation for TTL feature
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-10068'>FLINK-10068</a>] - Add documentation for async/RocksDB-based timers
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-10085'>FLINK-10085</a>] - Update AbstractOperatorRestoreTestBase
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-10087'>FLINK-10087</a>] - Update BucketingSinkMigrationTest
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-10089'>FLINK-10089</a>] - Update FlinkKafkaConsumerBaseMigrationTest
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-10090'>FLINK-10090</a>] - Update ContinuousFileProcessingMigrationTest
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-10091'>FLINK-10091</a>] - Update WindowOperatorMigrationTest
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-10092'>FLINK-10092</a>] - Update StatefulJobSavepointMigrationITCase
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-10109'>FLINK-10109</a>] - Add documentation for StreamingFileSink
+</li>
+</ul>
+
+<h2> Bug
+</h2>
+<ul>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-9289'>FLINK-9289</a>] - Parallelism of generated operators should have max parallism of input
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-9546'>FLINK-9546</a>] - The heartbeatTimeoutIntervalMs of HeartbeatMonitor should be larger than 0
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-9693'>FLINK-9693</a>] - Possible memory leak in jobmanager retaining archived checkpoints
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-9972'>FLINK-9972</a>] - Debug memory logging not working
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-10011'>FLINK-10011</a>] - Old job resurrected during HA failover
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-10063'>FLINK-10063</a>] - Jepsen: Automatically restart Mesos Processes
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-10101'>FLINK-10101</a>] - Mesos web ui url is missing.
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-10105'>FLINK-10105</a>] - Test failure because of jobmanager.execution.failover-strategy is outdated
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-10115'>FLINK-10115</a>] - Content-length limit is also applied to FileUploads
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-10116'>FLINK-10116</a>] - createComparator fails on case class with Unit type fields prior to the join-key
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-10141'>FLINK-10141</a>] - Reduce lock contention introduced with 1.5
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-10142'>FLINK-10142</a>] - Reduce synchronization overhead for credit notifications
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-10150'>FLINK-10150</a>] - Chained batch operators interfere with each other other
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-10151'>FLINK-10151</a>] - [State TTL] Fix false recursion call in TransformingStateTableKeyGroupPartitioner.tryAddToSource
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-10154'>FLINK-10154</a>] - Make sure we always read at least one record in KinesisConnector
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-10169'>FLINK-10169</a>] - RowtimeValidator fails with custom TimestampExtractor
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-10172'>FLINK-10172</a>] - Inconsistentcy in ExpressionParser and ExpressionDsl for order by asc/desc
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-10192'>FLINK-10192</a>] - SQL Client table visualization mode does not update correctly
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-10193'>FLINK-10193</a>] - Default RPC timeout is used when triggering savepoint via JobMasterGateway
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-10204'>FLINK-10204</a>] - StreamElementSerializer#copy broken for LatencyMarkers
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-10255'>FLINK-10255</a>] - Standby Dispatcher locks submitted JobGraphs
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-10261'>FLINK-10261</a>] - INSERT INTO does not work with ORDER BY clause
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-10267'>FLINK-10267</a>] - [State] Fix arbitrary iterator access on RocksDBMapIterator
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-10269'>FLINK-10269</a>] - Elasticsearch 6 UpdateRequest fail because of binary incompatibility
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-10283'>FLINK-10283</a>] - FileCache logs unnecessary warnings
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-10293'>FLINK-10293</a>] - RemoteStreamEnvironment does not forward port to RestClusterClient
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-10314'>FLINK-10314</a>] - Blocking calls in Execution Graph creation bring down cluster
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-10328'>FLINK-10328</a>] - Stopping the ZooKeeperSubmittedJobGraphStore should release all currently held locks
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-10329'>FLINK-10329</a>] - Fail with exception if job cannot be removed by ZooKeeperSubmittedJobGraphStore#removeJobGraph
+</li>
+</ul>
+
+<h2> New Feature
+</h2>
+<ul>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-10022'>FLINK-10022</a>] - Add metrics for input/output buffers
+</li>
+</ul>
+
+<h2> Improvement
+</h2>
+<ul>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-9013'>FLINK-9013</a>] - Document yarn.containers.vcores only being effective when adapting YARN config
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-9446'>FLINK-9446</a>] - Compatibility table not up-to-date
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-9795'>FLINK-9795</a>] - Update Mesos documentation for flip6
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-9859'>FLINK-9859</a>] - More Akka config options
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-9899'>FLINK-9899</a>] - Add more metrics to the Kinesis source connector
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-9962'>FLINK-9962</a>] - allow users to specify TimeZone in DateTimeBucketer
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-10001'>FLINK-10001</a>] - Improve Kubernetes documentation
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-10006'>FLINK-10006</a>] - Improve logging in BarrierBuffer
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-10020'>FLINK-10020</a>] - Kinesis Consumer listShards should support more recoverable exceptions
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-10082'>FLINK-10082</a>] - Initialize StringBuilder in Slf4jReporter with estimated size
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-10094'>FLINK-10094</a>] - Always backup default config for end-to-end tests
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-10110'>FLINK-10110</a>] - Harden e2e Kafka shutdown
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-10131'>FLINK-10131</a>] - Improve logging around ResultSubpartition
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-10137'>FLINK-10137</a>] - YARN: Log completed Containers
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-10164'>FLINK-10164</a>] - Add support for resuming from savepoints to StandaloneJobClusterEntrypoint
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-10170'>FLINK-10170</a>] - Support string representation for map and array types in descriptor-based Table API
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-10185'>FLINK-10185</a>] - Make ZooKeeperStateHandleStore#releaseAndTryRemove synchronous
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-10223'>FLINK-10223</a>] - TaskManagers should log their ResourceID during startup
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-10301'>FLINK-10301</a>] - Allow a custom Configuration in StreamNetworkBenchmarkEnvironment
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-10325'>FLINK-10325</a>] - [State TTL] Refactor TtlListState to use only loops, no java stream API for performance
+</li>
+</ul>
+
+<h2> Test
+</h2>
+<ul>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-10084'>FLINK-10084</a>] - Migration tests weren't updated for 1.5
+</li>
+</ul>
\ No newline at end of file
diff --git a/downloads.md b/downloads.md
index 8724c6b..9cde485 100644
--- a/downloads.md
+++ b/downloads.md
@@ -102,6 +102,7 @@ Note that the community is always open to discussing bugfix releases for even ol
All Flink releases are available via [https://archive.apache.org/dist/flink/](https://archive.apache.org/dist/flink/) including checksums and cryptographic signatures. At the time of writing, this includes the following versions:
+- Flink 1.6.1 - 2018-09-19 ([Source](https://archive.apache.org/dist/flink/flink-1.6.1/flink-1.6.1-src.tgz), [Binaries](https://archive.apache.org/dist/flink/flink-1.6.1/), [Docs]({{site.DOCS_BASE_URL}}flink-docs-release-1.6/), [Javadocs]({{site.DOCS_BASE_URL}}flink-docs-release-1.6/api/java), [ScalaDocs]({{site.DOCS_BASE_URL}}flink-docs-release-1.6/api/scala/index.html))
- Flink 1.6.0 - 2018-08-08 ([Source](https://archive.apache.org/dist/flink/flink-1.6.0/flink-1.6.0-src.tgz), [Binaries](https://archive.apache.org/dist/flink/flink-1.6.0/), [Docs]({{site.DOCS_BASE_URL}}flink-docs-release-1.6/), [Javadocs]({{site.DOCS_BASE_URL}}flink-docs-release-1.6/api/java), [ScalaDocs]({{site.DOCS_BASE_URL}}flink-docs-release-1.6/api/scala/index.html))
- Flink 1.5.4 - 2018-09-19 ([Source](https://archive.apache.org/dist/flink/flink-1.5.4/flink-1.5.4-src.tgz), [Binaries](https://archive.apache.org/dist/flink/flink-1.5.4/), [Docs]({{site.DOCS_BASE_URL}}flink-docs-release-1.5/), [Javadocs]({{site.DOCS_BASE_URL}}flink-docs-release-1.5/api/java), [ScalaDocs]({{site.DOCS_BASE_URL}}flink-docs-release-1.5/api/scala/index.html))
- Flink 1.5.3 - 2018-08-21 ([Source](https://archive.apache.org/dist/flink/flink-1.5.3/flink-1.5.3-src.tgz), [Binaries](https://archive.apache.org/dist/flink/flink-1.5.3/), [Docs]({{site.DOCS_BASE_URL}}flink-docs-release-1.5/), [Javadocs]({{site.DOCS_BASE_URL}}flink-docs-release-1.5/api/java), [ScalaDocs]({{site.DOCS_BASE_URL}}flink-docs-release-1.5/api/scala/index.html))