You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by kn...@apache.org on 2022/03/15 11:39:54 UTC
[flink-web] branch asf-site updated (775ff53 -> 4d2fc04)
This is an automated email from the ASF dual-hosted git repository.
knaufk pushed a change to branch asf-site
in repository https://gitbox.apache.org/repos/asf/flink-web.git.
from 775ff53 Rebuild website
new 7e863cd update quickstarts for Flink 1.14.4
new 6bcff3d update config.yaml for Flink 1.14.4
new 72b1874 [hotfix] fix release date of Flink 1.13.6
new 4d2fc04 add 1.14.4 release blog post
The 4 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
_config.yml | 35 ++++----
_posts/2022-02-18-release-1.13.6.md | 2 +-
_posts/2022-03-11-release-1.14.4.md | 169 ++++++++++++++++++++++++++++++++++++
q/gradle-quickstart.sh | 2 +-
q/quickstart-scala.sh | 2 +-
q/quickstart.sh | 2 +-
q/sbt-quickstart.sh | 2 +-
7 files changed, 193 insertions(+), 21 deletions(-)
create mode 100644 _posts/2022-03-11-release-1.14.4.md
[flink-web] 04/04: add 1.14.4 release blog post
Posted by kn...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
knaufk pushed a commit to branch asf-site
in repository https://gitbox.apache.org/repos/asf/flink-web.git
commit 4d2fc04e50cdcbecfb427effbd03d9443dfcd33c
Author: Konstantin Knauf <kn...@gmail.com>
AuthorDate: Fri Feb 25 13:26:05 2022 +0100
add 1.14.4 release blog post
---
_posts/2022-03-11-release-1.14.4.md | 169 ++++++++++++++++++++++++++++++++++++
1 file changed, 169 insertions(+)
diff --git a/_posts/2022-03-11-release-1.14.4.md b/_posts/2022-03-11-release-1.14.4.md
new file mode 100644
index 0000000..339a22f
--- /dev/null
+++ b/_posts/2022-03-11-release-1.14.4.md
@@ -0,0 +1,169 @@
+---
+layout: post
+title: "Apache Flink 1.14.4 Release Announcement"
+date: 2022-03-11T08:00:00.000Z
+categories: news
+authors:
+- knaufk:
+ name: "Konstantin Knauf"
+ twitter: "snntrable"
+
+excerpt: The Apache Flink Community is please to announce another bug fix release for Flink 1.14.
+
+---
+
+The Apache Flink Community is pleased to announce another bug fix release for Flink 1.14.
+
+This release includes 51 bug and vulnerability fixes and minor improvements for Flink 1.14.
+Below you will find a list of all bugfixes and improvements (excluding improvements to the build infrastructure and build stability). For a complete list of all changes see:
+[JIRA](https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12315522&version=12351074).
+
+We highly recommend all users to upgrade to Flink 1.14.4.
+
+# Release Artifacts
+
+## Maven Dependencies
+
+```xml
+<dependency>
+ <groupId>org.apache.flink</groupId>
+ <artifactId>flink-java</artifactId>
+ <version>1.14.4</version>
+</dependency>
+<dependency>
+ <groupId>org.apache.flink</groupId>
+ <artifactId>flink-streaming-java_2.11</artifactId>
+ <version>1.14.4</version>
+</dependency>
+<dependency>
+ <groupId>org.apache.flink</groupId>
+ <artifactId>flink-clients_2.11</artifactId>
+ <version>1.14.4</version>
+</dependency>
+```
+
+## Binaries
+
+You can find the binaries on the updated [Downloads page]({{ site.baseurl }}/downloads.html).
+
+## Docker Images
+
+* [library/flink](https://hub.docker.com/_/flink?tab=tags&page=1&name=1.14.4) (official images)
+* [apache/flink](https://hub.docker.com/r/apache/flink/tags?page=1&name=1.14.4) (ASF repository)
+
+## PyPi
+
+* [apache-flink==1.14.4](https://pypi.org/project/apache-flink/1.14.4/)
+
+# Release Notes
+
+<h2> Sub-task
+</h2>
+<ul>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-21788'>FLINK-21788</a>] - Throw PartitionNotFoundException if the partition file has been lost for blocking shuffle
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24954'>FLINK-24954</a>] - Reset read buffer request timeout on buffer recycling for sort-shuffle
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-25653'>FLINK-25653</a>] - Move buffer recycle in SortMergeSubpartitionReader out of lock to avoid deadlock
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-25654'>FLINK-25654</a>] - Remove the redundant lock in SortMergeResultPartition
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-25879'>FLINK-25879</a>] - Track used search terms in Matomo
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-25880'>FLINK-25880</a>] - Implement Matomo in Flink documentation
+</li>
+</ul>
+
+<h2> Bug
+</h2>
+<ul>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-21752'>FLINK-21752</a>] - NullPointerException on restore in PojoSerializer
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-23946'>FLINK-23946</a>] - Application mode fails fatally when being shut down
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24334'>FLINK-24334</a>] - Configuration kubernetes.flink.log.dir not working
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24407'>FLINK-24407</a>] - Pulsar connector chinese document link to Pulsar document location incorrectly.
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24607'>FLINK-24607</a>] - SourceCoordinator may miss to close SplitEnumerator when failover frequently
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-25171'>FLINK-25171</a>] - When the DDL statement was executed, the column names of the Derived Columns were not validated
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-25199'>FLINK-25199</a>] - StreamEdges are not unique in self-union, which blocks propagation of watermarks
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-25362'>FLINK-25362</a>] - Incorrect dependencies in Table Confluent/Avro docs
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-25407'>FLINK-25407</a>] - Network stack deadlock when cancellation happens during initialisation
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-25466'>FLINK-25466</a>] - TTL configuration could parse in StateTtlConfig#DISABLED
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-25486'>FLINK-25486</a>] - Perjob can not recover from checkpoint when zookeeper leader changes
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-25494'>FLINK-25494</a>] - Duplicate element serializer during DefaultOperatorStateBackendSnapshotStrategy#syncPrepareResources
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-25678'>FLINK-25678</a>] - TaskExecutorStateChangelogStoragesManager.shutdown is not thread-safe
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-25683'>FLINK-25683</a>] - wrong result if table transfrom to DataStream then window process in batch mode
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-25728'>FLINK-25728</a>] - Potential memory leaks in StreamMultipleInputProcessor
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-25732'>FLINK-25732</a>] - Dispatcher#requestMultipleJobDetails returns non-serialiable collection
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-25827'>FLINK-25827</a>] - Potential memory leaks in SourceOperator
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-25856'>FLINK-25856</a>] - Fix use of UserDefinedType in from_elements
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-25883'>FLINK-25883</a>] - The value of DEFAULT_BUNDLE_PROCESSOR_CACHE_SHUTDOWN_THRESHOLD_S is too large
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-25893'>FLINK-25893</a>] - ResourceManagerServiceImpl's lifecycle can lead to exceptions
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-25952'>FLINK-25952</a>] - Savepoint on S3 are not relocatable even if entropy injection is not enabled
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-26039'>FLINK-26039</a>] - Incorrect value getter in map unnest table function
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-26159'>FLINK-26159</a>] - Pulsar Connector: should add description MAX_FETCH_RECORD in doc to explain slow consumption
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-26160'>FLINK-26160</a>] - Pulsar Connector: stopCursor description should be changed. Connector only stop when auto discovery is disabled.
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-26187'>FLINK-26187</a>] - Chinese docs override english aliases
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-26304'>FLINK-26304</a>] - GlobalCommitter can receive failed committables
+</li>
+</ul>
+
+<h2> New Feature
+</h2>
+<ul>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-20188'>FLINK-20188</a>] - Add Documentation for new File Source
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-21407'>FLINK-21407</a>] - Clarify which sources and APIs support which formats
+</li>
+</ul>
+
+<h2> Improvement
+</h2>
+<ul>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-20830'>FLINK-20830</a>] - Add a type of HEADLESS_CLUSTER_IP for rest service type
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24880'>FLINK-24880</a>] - Error messages "OverflowError: timeout value is too large" shown when executing PyFlink jobs
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-25160'>FLINK-25160</a>] - Make doc clear: tolerable-failed-checkpoints counts consecutive failures
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-25611'>FLINK-25611</a>] - Remove CoordinatorExecutorThreadFactory thread creation guards
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-25650'>FLINK-25650</a>] - Document unaligned checkpoints performance limitations (larger records/flat map/timers/...)
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-25767'>FLINK-25767</a>] - Translation of page 'Working with State' is incomplete
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-25818'>FLINK-25818</a>] - Add explanation how Kafka Source deals with idleness when parallelism is higher then the number of partitions
+</li>
+</ul>
+
+<h2> Technical Debt
+</h2>
+<ul>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-25576'>FLINK-25576</a>] - Update com.h2database:h2 to 2.0.206
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-25785'>FLINK-25785</a>] - Update com.h2database:h2 to 2.0.210
+</li>
+</ul>
[flink-web] 02/04: update config.yaml for Flink 1.14.4
Posted by kn...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
knaufk pushed a commit to branch asf-site
in repository https://gitbox.apache.org/repos/asf/flink-web.git
commit 6bcff3df5fd7a311ca508d3bf30ad38ad83ca061
Author: Konstantin Knauf <kn...@gmail.com>
AuthorDate: Fri Feb 25 12:29:38 2022 +0100
update config.yaml for Flink 1.14.4
---
_config.yml | 33 ++++++++++++++++++---------------
1 file changed, 18 insertions(+), 15 deletions(-)
diff --git a/_config.yml b/_config.yml
index 303db11..ad04f89 100644
--- a/_config.yml
+++ b/_config.yml
@@ -9,7 +9,7 @@ url: https://flink.apache.org
DOCS_BASE_URL: https://nightlies.apache.org/flink/
-FLINK_VERSION_STABLE: 1.14.3
+FLINK_VERSION_STABLE: 1.14.4
FLINK_VERSION_STABLE_SHORT: "1.14"
FLINK_ISSUES_URL: https://issues.apache.org/jira/browse/FLINK
@@ -64,23 +64,23 @@ flink_releases:
-
version_short: "1.14"
binary_release:
- name: "Apache Flink 1.14.3"
+ name: "Apache Flink 1.14.4"
scala_211:
- id: "1142-download_211"
- url: "https://www.apache.org/dyn/closer.lua/flink/flink-1.14.3/flink-1.14.3-bin-scala_2.11.tgz"
- asc_url: "https://downloads.apache.org/flink/flink-1.14.3/flink-1.14.3-bin-scala_2.11.tgz.asc"
- sha512_url: "https://downloads.apache.org/flink/flink-1.14.3/flink-1.14.3-bin-scala_2.11.tgz.sha512"
+ id: "1144-download_211"
+ url: "https://www.apache.org/dyn/closer.lua/flink/flink-1.14.4/flink-1.14.4-bin-scala_2.11.tgz"
+ asc_url: "https://downloads.apache.org/flink/flink-1.14.4/flink-1.14.4-bin-scala_2.11.tgz.asc"
+ sha512_url: "https://downloads.apache.org/flink/flink-1.14.4/flink-1.14.4-bin-scala_2.11.tgz.sha512"
scala_212:
- id: "1142-download_212"
- url: "https://www.apache.org/dyn/closer.lua/flink/flink-1.14.3/flink-1.14.3-bin-scala_2.12.tgz"
- asc_url: "https://downloads.apache.org/flink/flink-1.14.3/flink-1.14.3-bin-scala_2.12.tgz.asc"
- sha512_url: "https://downloads.apache.org/flink/flink-1.14.3/flink-1.14.3-bin-scala_2.12.tgz.sha512"
+ id: "1144-download_212"
+ url: "https://www.apache.org/dyn/closer.lua/flink/flink-1.14.4/flink-1.14.4-bin-scala_2.12.tgz"
+ asc_url: "https://downloads.apache.org/flink/flink-1.14.4/flink-1.14.4-bin-scala_2.12.tgz.asc"
+ sha512_url: "https://downloads.apache.org/flink/flink-1.14.4/flink-1.14.4-bin-scala_2.12.tgz.sha512"
source_release:
- name: "Apache Flink 1.14.3"
- id: "1142-download-source"
- url: "https://www.apache.org/dyn/closer.lua/flink/flink-1.14.3/flink-1.14.3-src.tgz"
- asc_url: "https://downloads.apache.org/flink/flink-1.14.3/flink-1.14.3-src.tgz.asc"
- sha512_url: "https://downloads.apache.org/flink/flink-1.14.3/flink-1.14.3-src.tgz.sha512"
+ name: "Apache Flink 1.14.4"
+ id: "1144-download-source"
+ url: "https://www.apache.org/dyn/closer.lua/flink/flink-1.14.4/flink-1.14.4-src.tgz"
+ asc_url: "https://downloads.apache.org/flink/flink-1.14.4/flink-1.14.4-src.tgz.asc"
+ sha512_url: "https://downloads.apache.org/flink/flink-1.14.4/flink-1.14.4-src.tgz.sha512"
release_notes_url: "https://nightlies.apache.org/flink/flink-docs-release-1.14/release-notes/flink-1.14"
-
version_short: "1.13"
@@ -203,6 +203,9 @@ component_releases:
release_archive:
flink:
+ - version_short: "1.14"
+ version_long: 1.14.4
+ release_date: 2022-03-02
-
version_short: "1.14"
version_long: 1.14.3
[flink-web] 01/04: update quickstarts for Flink 1.14.4
Posted by kn...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
knaufk pushed a commit to branch asf-site
in repository https://gitbox.apache.org/repos/asf/flink-web.git
commit 7e863cdd90b0acf7eab4e9c3d91cb5940629846e
Author: Konstantin Knauf <kn...@gmail.com>
AuthorDate: Fri Feb 25 12:28:56 2022 +0100
update quickstarts for Flink 1.14.4
---
q/gradle-quickstart.sh | 2 +-
q/quickstart-scala.sh | 2 +-
q/quickstart.sh | 2 +-
q/sbt-quickstart.sh | 2 +-
4 files changed, 4 insertions(+), 4 deletions(-)
diff --git a/q/gradle-quickstart.sh b/q/gradle-quickstart.sh
index 68f61f0..b977c69 100755
--- a/q/gradle-quickstart.sh
+++ b/q/gradle-quickstart.sh
@@ -41,7 +41,7 @@ function mkPackage() {
defaultProjectName="quickstart"
defaultOrganization="org.myorg.quickstart"
defaultVersion="0.1-SNAPSHOT"
-defaultFlinkVersion="${1:-1.14.3}"
+defaultFlinkVersion="${1:-1.14.4}"
defaultScalaBinaryVersion="${2:-2.11}"
echo "This script creates a Flink project using Java and Gradle."
diff --git a/q/quickstart-scala.sh b/q/quickstart-scala.sh
index bd618b1..f9868ff 100755
--- a/q/quickstart-scala.sh
+++ b/q/quickstart-scala.sh
@@ -24,7 +24,7 @@ PACKAGE=quickstart
mvn archetype:generate \
-DarchetypeGroupId=org.apache.flink \
-DarchetypeArtifactId=flink-quickstart-scala \
- -DarchetypeVersion=${1:-1.14.3} \
+ -DarchetypeVersion=${1:-1.14.4} \
-DgroupId=org.myorg.quickstart \
-DartifactId=$PACKAGE \
-Dversion=0.1 \
diff --git a/q/quickstart.sh b/q/quickstart.sh
index 14e5379..0b1a988 100755
--- a/q/quickstart.sh
+++ b/q/quickstart.sh
@@ -24,7 +24,7 @@ PACKAGE=quickstart
mvn archetype:generate \
-DarchetypeGroupId=org.apache.flink \
-DarchetypeArtifactId=flink-quickstart-java \
- -DarchetypeVersion=${1:-1.14.3} \
+ -DarchetypeVersion=${1:-1.14.4} \
-DgroupId=org.myorg.quickstart \
-DartifactId=$PACKAGE \
-Dversion=0.1 \
diff --git a/q/sbt-quickstart.sh b/q/sbt-quickstart.sh
index 1c5d849..9669b7b 100755
--- a/q/sbt-quickstart.sh
+++ b/q/sbt-quickstart.sh
@@ -42,7 +42,7 @@ defaultProjectName="Flink Project"
defaultOrganization="org.example"
defaultVersion="0.1-SNAPSHOT"
defaultScalaVersion="2.12.7"
-defaultFlinkVersion="1.14.3"
+defaultFlinkVersion="1.14.4"
echo "This script creates a Flink project using Scala and SBT."
[flink-web] 03/04: [hotfix] fix release date of Flink 1.13.6
Posted by kn...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
knaufk pushed a commit to branch asf-site
in repository https://gitbox.apache.org/repos/asf/flink-web.git
commit 72b187448a1cbb90afebb5e4f1c966e0fa3fc3ad
Author: Konstantin Knauf <kn...@gmail.com>
AuthorDate: Fri Feb 25 12:30:26 2022 +0100
[hotfix] fix release date of Flink 1.13.6
---
_config.yml | 2 +-
_posts/2022-02-18-release-1.13.6.md | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/_config.yml b/_config.yml
index ad04f89..7ba6b8b 100644
--- a/_config.yml
+++ b/_config.yml
@@ -221,7 +221,7 @@ release_archive:
-
version_short: "1.13"
version_long: 1.13.6
- release_date: 2022-02-09
+ release_date: 2022-02-18
-
version_short: "1.13"
version_long: 1.13.5
diff --git a/_posts/2022-02-18-release-1.13.6.md b/_posts/2022-02-18-release-1.13.6.md
index d01b0f5..ca8b994 100644
--- a/_posts/2022-02-18-release-1.13.6.md
+++ b/_posts/2022-02-18-release-1.13.6.md
@@ -1,7 +1,7 @@
---
layout: post
title: "Apache Flink 1.13.6 Release Announcement"
-date: 2022-02-09T08:00:00.000Z
+date: 2022-02-18T08:00:00.000Z
categories: news
authors:
- knaufk: