You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by da...@apache.org on 2022/07/07 21:56:59 UTC
[flink-web] branch asf-site updated: Release flink 1.15.1 (#554)
This is an automated email from the ASF dual-hosted git repository.
danderson 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 4d3aef182 Release flink 1.15.1 (#554)
4d3aef182 is described below
commit 4d3aef182a12c170dc195b787762ad84412eb714
Author: David Anderson <da...@alpinegizmo.com>
AuthorDate: Thu Jul 7 17:56:52 2022 -0400
Release flink 1.15.1 (#554)
---
_config.yml | 26 ++---
_posts/2022-07-06-release-1.15.1.md | 191 ++++++++++++++++++++++++++++++++++++
q/gradle-quickstart.sh | 2 +-
q/quickstart-scala.sh | 2 +-
q/quickstart.sh | 2 +-
q/sbt-quickstart.sh | 2 +-
6 files changed, 210 insertions(+), 15 deletions(-)
diff --git a/_config.yml b/_config.yml
index fd350318e..2e31e8c14 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.15.0
+FLINK_VERSION_STABLE: 1.15.1
FLINK_VERSION_STABLE_SHORT: "1.15"
FLINK_ISSUES_URL: https://issues.apache.org/jira/browse/FLINK
@@ -75,18 +75,18 @@ FLINK_TABLE_STORE_GITHUB_REPO_NAME: flink-table-store
flink_releases:
- version_short: "1.15"
binary_release:
- name: "Apache Flink 1.15.0"
+ name: "Apache Flink 1.15.1"
scala_212:
- id: "1150-download_212"
- url: "https://www.apache.org/dyn/closer.lua/flink/flink-1.15.0/flink-1.15.0-bin-scala_2.12.tgz"
- asc_url: "https://downloads.apache.org/flink/flink-1.15.0/flink-1.15.0-bin-scala_2.12.tgz.asc"
- sha512_url: "https://downloads.apache.org/flink/flink-1.15.0/flink-1.15.0-bin-scala_2.12.tgz.sha512"
+ id: "1151-download_212"
+ url: "https://www.apache.org/dyn/closer.lua/flink/flink-1.15.1/flink-1.15.1-bin-scala_2.12.tgz"
+ asc_url: "https://downloads.apache.org/flink/flink-1.15.1/flink-1.15.1-bin-scala_2.12.tgz.asc"
+ sha512_url: "https://downloads.apache.org/flink/flink-1.15.1/flink-1.15.1-bin-scala_2.12.tgz.sha512"
source_release:
- name: "Apache Flink 1.15.0"
- id: "1150-download-source"
- url: "https://www.apache.org/dyn/closer.lua/flink/flink-1.15.0/flink-1.15.0-src.tgz"
- asc_url: "https://downloads.apache.org/flink/flink-1.15.0/flink-1.15.0-src.tgz.asc"
- sha512_url: "https://downloads.apache.org/flink/flink-1.15.0/flink-1.15.0-src.tgz.sha512"
+ name: "Apache Flink 1.15.1"
+ id: "1151-download-source"
+ url: "https://www.apache.org/dyn/closer.lua/flink/flink-1.15.1/flink-1.15.1-src.tgz"
+ asc_url: "https://downloads.apache.org/flink/flink-1.15.1/flink-1.15.1-src.tgz.asc"
+ sha512_url: "https://downloads.apache.org/flink/flink-1.15.1/flink-1.15.1-src.tgz.sha512"
release_notes_url: "https://nightlies.apache.org/flink/flink-docs-release-1.15/release-notes/flink-1.15"
-
version_short: "1.14"
@@ -283,6 +283,10 @@ component_releases:
release_archive:
flink:
- version_short: "1.15"
+ version_long: 1.15.1
+ release_date: 2022-07-06
+ -
+ version_short: "1.15"
version_long: 1.15.0
release_date: 2022-05-05
-
diff --git a/_posts/2022-07-06-release-1.15.1.md b/_posts/2022-07-06-release-1.15.1.md
new file mode 100644
index 000000000..ffdc85501
--- /dev/null
+++ b/_posts/2022-07-06-release-1.15.1.md
@@ -0,0 +1,191 @@
+---
+layout: post
+title: "Apache Flink 1.15.1 Release Announcement"
+date: 2022-07-06T08:00:00.000Z
+categories: news
+authors:
+- david:
+ name: "David Anderson"
+ twitter: "alpinegizmo"
+
+excerpt: The Apache Flink Community is pleased to announce a bug fix release for Flink 1.15.
+
+---
+
+The Apache Flink Community is pleased to announce the first bug fix release of the Flink 1.15 series.
+
+This release includes 62 bug fixes, vulnerability fixes, and minor improvements for Flink 1.15.
+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=12351546).
+
+We highly recommend all users upgrade to Flink 1.15.1.
+
+# Release Artifacts
+
+## Maven Dependencies
+
+```xml
+<dependency>
+ <groupId>org.apache.flink</groupId>
+ <artifactId>flink-java</artifactId>
+ <version>1.15.1</version>
+</dependency>
+<dependency>
+ <groupId>org.apache.flink</groupId>
+ <artifactId>flink-streaming-java</artifactId>
+ <version>1.15.1</version>
+</dependency>
+<dependency>
+ <groupId>org.apache.flink</groupId>
+ <artifactId>flink-clients</artifactId>
+ <version>1.15.1</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.15.1) (official images)
+* [apache/flink](https://hub.docker.com/r/apache/flink/tags?page=1&name=1.15.1) (ASF repository)
+
+## PyPi
+
+* [apache-flink==1.15.1](https://pypi.org/project/apache-flink/1.15.1/)
+
+# Release Notes
+
+The community is aware of two issues that were introduced with 1.15.0 that remain unresolved. Efforts are underway to fix these issues for Flink 1.15.2:
+
+<ul>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-28060'>FLINK-28060</a>] - Kafka commit on checkpointing fails repeatedly after a broker restart
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-28322'>FLINK-28322</a>] - DataStreamScanProvider's new method is not compatible
+</li>
+</ul>
+
+<h2> Bug
+</h2>
+<ul>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-22984'>FLINK-22984</a>] - UnsupportedOperationException when using Python UDF to generate watermark
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24491'>FLINK-24491</a>] - ExecutionGraphInfo may not be archived when the dispatcher terminates
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24735'>FLINK-24735</a>] - SQL client crashes with `Cannot add expression of different type to set`
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-26645'>FLINK-26645</a>] - Pulsar Source subscribe to a single topic partition will consume all partitions from that topic
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-27041'>FLINK-27041</a>] - KafkaSource in batch mode failing if any topic partition is empty
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-27140'>FLINK-27140</a>] - Move JobResultStore dirty entry creation into ioExecutor
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-27174'>FLINK-27174</a>] - Non-null check for bootstrapServers field is incorrect in KafkaSink
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-27218'>FLINK-27218</a>] - Serializer in OperatorState has not been updated when new Serializers are NOT incompatible
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-27223'>FLINK-27223</a>] - State access doesn't work as expected when cache size is set to 0
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-27247'>FLINK-27247</a>] - ScalarOperatorGens.numericCasting is not compatible with legacy behavior
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-27255'>FLINK-27255</a>] - Flink-avro does not support serialization and deserialization of avro schema longer than 65535 characters
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-27282'>FLINK-27282</a>] - Fix the bug of wrong positions mapping in RowCoder
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-27367'>FLINK-27367</a>] - SQL CAST between INT and DATE is broken
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-27368'>FLINK-27368</a>] - SQL CAST(' 1 ' as BIGINT) returns wrong result
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-27409'>FLINK-27409</a>] - Cleanup stale slot allocation record when the resource requirement of a job is empty
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-27418'>FLINK-27418</a>] - Flink SQL TopN result is wrong
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-27420'>FLINK-27420</a>] - Suspended SlotManager fails to re-register metrics when started again
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-27465'>FLINK-27465</a>] - AvroRowDeserializationSchema.convertToTimestamp fails with negative nano seconds
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-27487'>FLINK-27487</a>] - KafkaMetricWrappers do incorrect cast
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-27545'>FLINK-27545</a>] - Update examples in PyFlink shell
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-27563'>FLINK-27563</a>] - Resource Providers - Yarn doc page has minor display error
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-27606'>FLINK-27606</a>] - CompileException when using UDAF with merge() method
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-27676'>FLINK-27676</a>] - Output records from on_timer are behind the triggering watermark in PyFlink
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-27683'>FLINK-27683</a>] - Insert into (column1, column2) Values(.....) fails with SQL hints
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-27711'>FLINK-27711</a>] - Correct the typo of set_topics_pattern by changing it to set_topic_pattern for Pulsar Connector
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-27733'>FLINK-27733</a>] - Rework on_timer output behind watermark bug fix
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-27734'>FLINK-27734</a>] - Not showing checkpoint interval properly in WebUI when checkpoint is disabled
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-27760'>FLINK-27760</a>] - NPE is thrown when executing PyFlink jobs in batch mode
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-27762'>FLINK-27762</a>] - Kafka WakeupException during handling splits changes
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-27797'>FLINK-27797</a>] - PythonTableUtils.getCollectionInputFormat cannot correctly handle None values
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-27848'>FLINK-27848</a>] - ZooKeeperLeaderElectionDriver keeps writing leader information, using up zxid
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-27881'>FLINK-27881</a>] - The key(String) in PulsarMessageBuilder returns null
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-27890'>FLINK-27890</a>] - SideOutputExample.java fails
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-27910'>FLINK-27910</a>] - FileSink not enforcing rolling policy if started from scratch
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-27933'>FLINK-27933</a>] - Savepoint status cannot be queried from standby jobmanager
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-27955'>FLINK-27955</a>] - PyFlink installation failure on Windows OS
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-27999'>FLINK-27999</a>] - NoSuchMethodError when using Hive 3 dialect
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-28018'>FLINK-28018</a>] - the start index to create empty splits in BinaryInputFormat#createInputSplits is inappropriate
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-28019'>FLINK-28019</a>] - Error in RetractableTopNFunction when retracting a stale record with state ttl enabled
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-28114'>FLINK-28114</a>] - The path of the Python client interpreter could not point to an archive file in distributed file system
+</li>
+</ul>
+
+<h2> Improvement
+</h2>
+<ul>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24586'>FLINK-24586</a>] - SQL functions should return STRING instead of VARCHAR(2000)
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-26788'>FLINK-26788</a>] - AbstractDeserializationSchema should add cause when throwing a FlinkRuntimeException
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-26909'>FLINK-26909</a>] - Allow setting parallelism to -1 from CLI
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-27064'>FLINK-27064</a>] - Centralize ArchUnit rules for production code
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-27480'>FLINK-27480</a>] - KafkaSources sharing the groupId might lead to InstanceAlreadyExistException warning
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-27534'>FLINK-27534</a>] - Apply scalafmt to 1.15 branch
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-27776'>FLINK-27776</a>] - Throw exception when UDAF used in sliding window does not implement merge method in PyFlink
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-27935'>FLINK-27935</a>] - Add Pyflink example of create temporary view document
+</li>
+</ul>
+
+<h2> Technical Debt
+</h2>
+<ul>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-25694'>FLINK-25694</a>] - Upgrade Presto to resolve GSON/Alluxio Vulnerability
+</li>
+</ul>
+
+<h2> Sub-task
+</h2>
+<ul>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-26052'>FLINK-26052</a>] - Update chinese documentation regarding FLIP-203
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-26588'>FLINK-26588</a>] - Translate the new SQL CAST documentation to Chinese
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-27382'>FLINK-27382</a>] - Make Job mode wait with cluster shutdown until the cleanup is done
+</li>
+</ul>
diff --git a/q/gradle-quickstart.sh b/q/gradle-quickstart.sh
index 189b40397..d98c655e8 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.15.0}"
+defaultFlinkVersion="${1:-1.15.1}"
# flink-docs-master/docs/dev/datastream/project-configuration/#gradle
# passes the scala version prefixed with a _, e.g.: _2.12
scalaBinaryVersionFromCmdArg="${2/_/}"
diff --git a/q/quickstart-scala.sh b/q/quickstart-scala.sh
index bf850e39e..aabe9f276 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.15.0} \
+ -DarchetypeVersion=${1:-1.15.1} \
-DgroupId=org.myorg.quickstart \
-DartifactId=$PACKAGE \
-Dversion=0.1 \
diff --git a/q/quickstart.sh b/q/quickstart.sh
index 98db0ddcc..026eaee8b 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.15.0} \
+ -DarchetypeVersion=${1:-1.15.1} \
-DgroupId=org.myorg.quickstart \
-DartifactId=$PACKAGE \
-Dversion=0.1 \
diff --git a/q/sbt-quickstart.sh b/q/sbt-quickstart.sh
index a77d723dd..46f24dc94 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.15.0"
+defaultFlinkVersion="1.15.1"
echo "This script creates a Flink project using Scala and SBT."