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 <[email protected]>
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))
