You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ji...@apache.org on 2019/07/03 01:27:17 UTC
[flink-web] branch asf-site updated: Add Apache Flink release 1.8.1
This is an automated email from the ASF dual-hosted git repository.
jincheng pushed a commit to branch asf-site
in repository https://gitbox.apache.org/repos/asf/flink-web.git
The following commit(s) were added to refs/heads/asf-site by this push:
new 70bcf43 Add Apache Flink release 1.8.1
70bcf43 is described below
commit 70bcf439500ba2565a027f2c137101268bf62027
Author: sunjincheng121 <su...@gmail.com>
AuthorDate: Mon Jun 17 16:04:54 2019 +0800
Add Apache Flink release 1.8.1
---
_config.yml | 54 ++++++-------
_posts/2019-07-02-release-1.8.1.md | 152 +++++++++++++++++++++++++++++++++++++
downloads.md | 2 +-
downloads.zh.md | 2 +-
4 files changed, 181 insertions(+), 29 deletions(-)
diff --git a/_config.yml b/_config.yml
index a209cbd..11eea16 100644
--- a/_config.yml
+++ b/_config.yml
@@ -9,7 +9,7 @@ url: https://flink.apache.org
DOCS_BASE_URL: https://ci.apache.org/projects/flink/
-FLINK_VERSION_STABLE: 1.8.0
+FLINK_VERSION_STABLE: 1.8.1
FLINK_VERSION_STABLE_SHORT: 1.8
FLINK_VERSION_LATEST: 1.9-SNAPSHOT
@@ -55,23 +55,23 @@ flink_releases:
-
version_short: 1.8
binary_release:
- name: "Apache Flink 1.8.0"
+ name: "Apache Flink 1.8.1"
scala_211:
- id: "180-download_211"
- url: "https://www.apache.org/dyn/closer.lua/flink/flink-1.8.0/flink-1.8.0-bin-scala_2.11.tgz"
- asc_url: "https://www.apache.org/dist/flink/flink-1.8.0/flink-1.8.0-bin-scala_2.11.tgz.asc"
- sha512_url: "https://www.apache.org/dist/flink/flink-1.8.0/flink-1.8.0-bin-scala_2.11.tgz.sha512"
+ id: "181-download_211"
+ url: "https://www.apache.org/dyn/closer.lua/flink/flink-1.8.1/flink-1.8.1-bin-scala_2.11.tgz"
+ asc_url: "https://www.apache.org/dist/flink/flink-1.8.1/flink-1.8.1-bin-scala_2.11.tgz.asc"
+ sha512_url: "https://www.apache.org/dist/flink/flink-1.8.1/flink-1.8.1-bin-scala_2.11.tgz.sha512"
scala_212:
- id: "180-download_212"
- url: "https://www.apache.org/dyn/closer.lua/flink/flink-1.8.0/flink-1.8.0-bin-scala_2.12.tgz"
- asc_url: "https://www.apache.org/dist/flink/flink-1.8.0/flink-1.8.0-bin-scala_2.12.tgz.asc"
- sha512_url: "https://www.apache.org/dist/flink/flink-1.8.0/flink-1.8.0-bin-scala_2.12.tgz.sha512"
+ id: "181-download_212"
+ url: "https://www.apache.org/dyn/closer.lua/flink/flink-1.8.1/flink-1.8.1-bin-scala_2.12.tgz"
+ asc_url: "https://www.apache.org/dist/flink/flink-1.8.1/flink-1.8.1-bin-scala_2.12.tgz.asc"
+ sha512_url: "https://www.apache.org/dist/flink/flink-1.8.1/flink-1.8.1-bin-scala_2.12.tgz.sha512"
source_release:
- name: "Apache Flink 1.8.0"
- id: "180-download-source"
- url: "https://www.apache.org/dyn/closer.lua/flink/flink-1.8.0/flink-1.8.0-src.tgz"
- asc_url: "https://www.apache.org/dist/flink/flink-1.8.0/flink-1.8.0-src.tgz.asc"
- sha512_url: "https://www.apache.org/dist/flink/flink-1.8.0/flink-1.8.0-src.tgz.sha512"
+ name: "Apache Flink 1.8.1"
+ id: "181-download-source"
+ url: "https://www.apache.org/dyn/closer.lua/flink/flink-1.8.1/flink-1.8.1-src.tgz"
+ asc_url: "https://www.apache.org/dist/flink/flink-1.8.1/flink-1.8.1-src.tgz.asc"
+ sha512_url: "https://www.apache.org/dist/flink/flink-1.8.1/flink-1.8.1-src.tgz.sha512"
optional_components:
-
name: "Pre-bundled Hadoop 2.4.1"
@@ -109,26 +109,26 @@ flink_releases:
name: "Avro SQL Format"
category: "SQL Formats"
scala_dependent: false
- id: 180-sql-format-avro
- url: https://repo.maven.apache.org/maven2/org/apache/flink/flink-avro/1.8.0/flink-avro-1.8.0.jar
- asc_url: https://repo.maven.apache.org/maven2/org/apache/flink/flink-avro/1.8.0/flink-avro-1.8.0.jar.asc
- sha_url: https://repo.maven.apache.org/maven2/org/apache/flink/flink-avro/1.8.0/flink-avro-1.8.0.jar.sha1
+ id: 181-sql-format-avro
+ url: https://repo.maven.apache.org/maven2/org/apache/flink/flink-avro/1.8.1/flink-avro-1.8.1.jar
+ asc_url: https://repo.maven.apache.org/maven2/org/apache/flink/flink-avro/1.8.1/flink-avro-1.8.1.jar.asc
+ sha_url: https://repo.maven.apache.org/maven2/org/apache/flink/flink-avro/1.8.1/flink-avro-1.8.1.jar.sha1
-
name: "CSV SQL Format"
category: "SQL Formats"
scala_dependent: false
- id: 180-sql-format-csv
- url: https://repo.maven.apache.org/maven2/org/apache/flink/flink-csv/1.8.0/flink-csv-1.8.0.jar
- asc_url: https://repo.maven.apache.org/maven2/org/apache/flink/flink-csv/1.8.0/flink-csv-1.8.0.jar.asc
- sha_url: https://repo.maven.apache.org/maven2/org/apache/flink/flink-csv/1.8.0/flink-csv-1.8.0.jar.sha1
+ id: 181-sql-format-csv
+ url: https://repo.maven.apache.org/maven2/org/apache/flink/flink-csv/1.8.1/flink-csv-1.8.1.jar
+ asc_url: https://repo.maven.apache.org/maven2/org/apache/flink/flink-csv/1.8.1/flink-csv-1.8.1.jar.asc
+ sha_url: https://repo.maven.apache.org/maven2/org/apache/flink/flink-csv/1.8.1/flink-csv-1.8.1.jar.sha1
-
name: "JSON SQL Format"
category: "SQL Formats"
scala_dependent: false
- id: 180-sql-format-json
- url: https://repo.maven.apache.org/maven2/org/apache/flink/flink-json/1.8.0/flink-json-1.8.0.jar
- asc_url: https://repo.maven.apache.org/maven2/org/apache/flink/flink-json/1.8.0/flink-json-1.8.0.jar.asc
- sha_url: https://repo.maven.apache.org/maven2/org/apache/flink/flink-json/1.8.0/flink-json-1.8.0.jar.sha1
+ id: 181-sql-format-json
+ url: https://repo.maven.apache.org/maven2/org/apache/flink/flink-json/1.8.1/flink-json-1.8.1.jar
+ asc_url: https://repo.maven.apache.org/maven2/org/apache/flink/flink-json/1.8.1/flink-json-1.8.1.jar.asc
+ sha_url: https://repo.maven.apache.org/maven2/org/apache/flink/flink-json/1.8.1/flink-json-1.8.1.jar.sha1
-
version_short: 1.7
binary_release:
diff --git a/_posts/2019-07-02-release-1.8.1.md b/_posts/2019-07-02-release-1.8.1.md
new file mode 100644
index 0000000..2d70fef
--- /dev/null
+++ b/_posts/2019-07-02-release-1.8.1.md
@@ -0,0 +1,152 @@
+---
+layout: post
+title: "Apache Flink 1.8.1 Released"
+date: 2019-07-02 12:00:00
+categories: news
+authors:
+- jincheng:
+ name: "Jincheng Sun"
+ twitter: "sunjincheng121"
+---
+
+The Apache Flink community released the first bugfix version of the Apache Flink 1.8 series.
+
+This release includes more than 40 fixes and minor improvements for Flink 1.8.1. The list below includes a detailed list of all improvements, sub-tasks and bug fixes.
+
+We highly recommend all users to upgrade to Flink 1.8.1.
+
+Updated Maven dependencies:
+
+```xml
+<dependency>
+ <groupId>org.apache.flink</groupId>
+ <artifactId>flink-java</artifactId>
+ <version>1.8.1</version>
+</dependency>
+<dependency>
+ <groupId>org.apache.flink</groupId>
+ <artifactId>flink-streaming-java_2.11</artifactId>
+ <version>1.8.1</version>
+</dependency>
+<dependency>
+ <groupId>org.apache.flink</groupId>
+ <artifactId>flink-clients_2.11</artifactId>
+ <version>1.8.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-10921'>FLINK-10921</a>] - Prioritize shard consumers in Kinesis Consumer by event time
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-12617'>FLINK-12617</a>] - StandaloneJobClusterEntrypoint should default to random JobID for non-HA setups
+</li>
+</ul>
+
+<h2> Bug
+</h2>
+<ul>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-9445'>FLINK-9445</a>] - scala-shell uses plain java command
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-10455'>FLINK-10455</a>] - Potential Kafka producer leak in case of failures
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-10941'>FLINK-10941</a>] - Slots prematurely released which still contain unconsumed data
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-11059'>FLINK-11059</a>] - JobMaster may continue using an invalid slot if releasing idle slot meet a timeout
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-11107'>FLINK-11107</a>] - Avoid memory stateBackend to create arbitrary folders under HA path when no checkpoint path configured
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-11897'>FLINK-11897</a>] - ExecutionGraphSuspendTest does not wait for all tasks to be submitted
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-11915'>FLINK-11915</a>] - DataInputViewStream skip returns wrong value
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-11987'>FLINK-11987</a>] - Kafka producer occasionally throws NullpointerException
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-12009'>FLINK-12009</a>] - Wrong check message about heartbeat interval for HeartbeatServices
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-12042'>FLINK-12042</a>] - RocksDBStateBackend mistakenly uses default filesystem
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-12112'>FLINK-12112</a>] - AbstractTaskManagerProcessFailureRecoveryTest process output logging does not work properly
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-12132'>FLINK-12132</a>] - The example in /docs/ops/deployment/yarn_setup.md should be updated due to the change FLINK-2021
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-12184'>FLINK-12184</a>] - HistoryServerArchiveFetcher isn't compatible with old version
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-12219'>FLINK-12219</a>] - Yarn application can't stop when flink job failed in per-job yarn cluster mode
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-12247'>FLINK-12247</a>] - fix NPE when writing an archive file to a FileSystem
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-12260'>FLINK-12260</a>] - Slot allocation failure by taskmanager registration timeout and race
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-12296'>FLINK-12296</a>] - Data loss silently in RocksDBStateBackend when more than one operator(has states) chained in a single task
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-12297'>FLINK-12297</a>] - Make ClosureCleaner recursive
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-12301'>FLINK-12301</a>] - Scala value classes inside case classes cannot be serialized anymore in Flink 1.8.0
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-12342'>FLINK-12342</a>] - Yarn Resource Manager Acquires Too Many Containers
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-12375'>FLINK-12375</a>] - flink-container job jar does not have read permissions
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-12416'>FLINK-12416</a>] - Docker build script fails on symlink creation ln -s
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-12544'>FLINK-12544</a>] - Deadlock while releasing memory and requesting segment concurrent in SpillableSubpartition
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-12547'>FLINK-12547</a>] - Deadlock when the task thread downloads jars using BlobClient
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-12646'>FLINK-12646</a>] - Use reserved IP as unrouteable IP in RestClientTest
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-12688'>FLINK-12688</a>] - Make serializer lazy initialization thread safe in StateDescriptor
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-12740'>FLINK-12740</a>] - SpillableSubpartitionTest deadlocks on Travis
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-12835'>FLINK-12835</a>] - Time conversion is wrong in ManualClock
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-12863'>FLINK-12863</a>] - Race condition between slot offerings and AllocatedSlotReport
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-12865'>FLINK-12865</a>] - State inconsistency between RM and TM on the slot status
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-12871'>FLINK-12871</a>] - Wrong SSL setup examples in docs
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-12895'>FLINK-12895</a>] - TaskManagerProcessFailureBatchRecoveryITCase.testTaskManagerProcessFailure failed on travis
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-12896'>FLINK-12896</a>] - TaskCheckpointStatisticDetailsHandler uses wrong value for JobID when archiving
+</li>
+</ul>
+
+<h2> Improvement
+</h2>
+<ul>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-11126'>FLINK-11126</a>] - Filter out AMRMToken in the TaskManager credentials
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-12137'>FLINK-12137</a>] - Add more proper explanation on flink streaming connectors
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-12169'>FLINK-12169</a>] - Improve Javadoc of MessageAcknowledgingSourceBase
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-12378'>FLINK-12378</a>] - Consolidate FileSystem Documentation
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-12391'>FLINK-12391</a>] - Add timeout to transfer.sh
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-12539'>FLINK-12539</a>] - StreamingFileSink: Make the class extendable to customize for different usecases
+</li>
+</ul>
+
+<h2> Test
+</h2>
+<ul>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-12350'>FLINK-12350</a>] - RocksDBStateBackendTest doesn't cover the incremental checkpoint code path
+</li>
+</ul>
+
+<h2> Task
+</h2>
+<ul>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-12460'>FLINK-12460</a>] - Change taskmanager.tmp.dirs to io.tmp.dirs in configuration docs
+</li>
+</ul>
+
\ No newline at end of file
diff --git a/downloads.md b/downloads.md
index 92d0b19..340e291 100644
--- a/downloads.md
+++ b/downloads.md
@@ -176,7 +176,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
-
+- Flink 1.8.1 - 2019-07-02 ([Source](https://archive.apache.org/dist/flink/flink-1.8.1/flink-1.8.1-src.tgz), [Binaries](https://archive.apache.org/dist/flink/flink-1.8.1/), [Docs]({{site.DOCS_BASE_URL}}flink-docs-release-1.8/), [Javadocs]({{site.DOCS_BASE_URL}}flink-docs-release-1.8/api/java), [ScalaDocs]({{site.DOCS_BASE_URL}}flink-docs-release-1.8/api/scala/index.html))
- Flink 1.7.2 - 2019-02-15 ([Source](https://archive.apache.org/dist/flink/flink-1.7.2/flink-1.7.2-src.tgz), [Binaries](https://archive.apache.org/dist/flink/flink-1.7.2/), [Docs]({{site.DOCS_BASE_URL}}flink-docs-release-1.7/), [Javadocs]({{site.DOCS_BASE_URL}}flink-docs-release-1.7/api/java), [ScalaDocs]({{site.DOCS_BASE_URL}}flink-docs-release-1.7/api/scala/index.html))
- Flink 1.7.1 - 2018-12-21 ([Source](https://archive.apache.org/dist/flink/flink-1.7.1/flink-1.7.1-src.tgz), [Binaries](https://archive.apache.org/dist/flink/flink-1.7.1/), [Docs]({{site.DOCS_BASE_URL}}flink-docs-release-1.7/), [Javadocs]({{site.DOCS_BASE_URL}}flink-docs-release-1.7/api/java), [ScalaDocs]({{site.DOCS_BASE_URL}}flink-docs-release-1.7/api/scala/index.html))
- Flink 1.7.0 - 2018-11-30 ([Source](https://archive.apache.org/dist/flink/flink-1.7.0/flink-1.7.0-src.tgz), [Binaries](https://archive.apache.org/dist/flink/flink-1.7.0/), [Docs]({{site.DOCS_BASE_URL}}flink-docs-release-1.7/), [Javadocs]({{site.DOCS_BASE_URL}}flink-docs-release-1.7/api/java), [ScalaDocs]({{site.DOCS_BASE_URL}}flink-docs-release-1.7/api/scala/index.html))
diff --git a/downloads.zh.md b/downloads.zh.md
index dcfe2f2..d40cf99 100644
--- a/downloads.zh.md
+++ b/downloads.zh.md
@@ -185,7 +185,7 @@ flink-docs-release-{{ flink_release.version_short }}/release-notes/flink-{{ flin
所有的 Flink 版本均可通过 [https://archive.apache.org/dist/flink/](https://archive.apache.org/dist/flink/) 获得，包括校验和加密签名。在撰写本文时，这包括以下版本：
### Flink
-
+- Flink 1.8.1 - 2019-07-02 ([Source](https://archive.apache.org/dist/flink/flink-1.8.1/flink-1.8.1-src.tgz), [Binaries](https://archive.apache.org/dist/flink/flink-1.8.1/), [Docs]({{site.DOCS_BASE_URL}}flink-docs-release-1.8/), [Javadocs]({{site.DOCS_BASE_URL}}flink-docs-release-1.8/api/java), [ScalaDocs]({{site.DOCS_BASE_URL}}flink-docs-release-1.8/api/scala/index.html))
- Flink 1.7.2 - 2019-02-15 ([Source](https://archive.apache.org/dist/flink/flink-1.7.2/flink-1.7.2-src.tgz), [Binaries](https://archive.apache.org/dist/flink/flink-1.7.2/), [Docs]({{site.DOCS_BASE_URL}}flink-docs-release-1.7/), [Javadocs]({{site.DOCS_BASE_URL}}flink-docs-release-1.7/api/java), [ScalaDocs]({{site.DOCS_BASE_URL}}flink-docs-release-1.7/api/scala/index.html))
- Flink 1.7.1 - 2018-12-21 ([Source](https://archive.apache.org/dist/flink/flink-1.7.1/flink-1.7.1-src.tgz), [Binaries](https://archive.apache.org/dist/flink/flink-1.7.1/), [Docs]({{site.DOCS_BASE_URL}}flink-docs-release-1.7/), [Javadocs]({{site.DOCS_BASE_URL}}flink-docs-release-1.7/api/java), [ScalaDocs]({{site.DOCS_BASE_URL}}flink-docs-release-1.7/api/scala/index.html))
- Flink 1.7.0 - 2018-11-30 ([Source](https://archive.apache.org/dist/flink/flink-1.7.0/flink-1.7.0-src.tgz), [Binaries](https://archive.apache.org/dist/flink/flink-1.7.0/), [Docs]({{site.DOCS_BASE_URL}}flink-docs-release-1.7/), [Javadocs]({{site.DOCS_BASE_URL}}flink-docs-release-1.7/api/java), [ScalaDocs]({{site.DOCS_BASE_URL}}flink-docs-release-1.7/api/scala/index.html))