You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ro...@apache.org on 2021/02/16 18:24:50 UTC
[flink-web] branch asf-site updated: Revert "Add Apache Flink
1.12.2 release"
This is an automated email from the ASF dual-hosted git repository.
roman 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 e75c703 Revert "Add Apache Flink 1.12.2 release"
e75c703 is described below
commit e75c7038662d95b2035d44af545205f5daa9c236
Author: Roman Khachatryan <kh...@gmail.com>
AuthorDate: Tue Feb 16 19:24:31 2021 +0100
Revert "Add Apache Flink 1.12.2 release"
This reverts commit 5da7ae9e1f7ee786cf1e3e209cbdb37863567f28.
---
_config.yml | 42 ++++---
_posts/2021-02-16-release-1.12.2.md | 216 ------------------------------------
q/gradle-quickstart.sh | 2 +-
q/quickstart-scala.sh | 2 +-
q/quickstart.sh | 2 +-
q/sbt-quickstart.sh | 2 +-
6 files changed, 23 insertions(+), 243 deletions(-)
diff --git a/_config.yml b/_config.yml
index 921369b..a89b83e 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.12.2
+FLINK_VERSION_STABLE: 1.12.1
FLINK_VERSION_STABLE_SHORT: "1.12"
FLINK_ISSUES_URL: https://issues.apache.org/jira/browse/FLINK
@@ -58,32 +58,32 @@ flink_releases:
-
version_short: "1.12"
binary_release:
- name: "Apache Flink 1.12.2"
+ name: "Apache Flink 1.12.1"
scala_211:
- id: "1122-download_211"
- url: "https://www.apache.org/dyn/closer.lua/flink/flink-1.12.2/flink-1.12.2-bin-scala_2.11.tgz"
- asc_url: "https://downloads.apache.org/flink/flink-1.12.2/flink-1.12.2-bin-scala_2.11.tgz.asc"
- sha512_url: "https://downloads.apache.org/flink/flink-1.12.2/flink-1.12.2-bin-scala_2.11.tgz.sha512"
+ id: "1121-download_211"
+ url: "https://www.apache.org/dyn/closer.lua/flink/flink-1.12.1/flink-1.12.1-bin-scala_2.11.tgz"
+ asc_url: "https://downloads.apache.org/flink/flink-1.12.1/flink-1.12.1-bin-scala_2.11.tgz.asc"
+ sha512_url: "https://downloads.apache.org/flink/flink-1.12.1/flink-1.12.1-bin-scala_2.11.tgz.sha512"
scala_212:
- id: "1122-download_212"
- url: "https://www.apache.org/dyn/closer.lua/flink/flink-1.12.2/flink-1.12.2-bin-scala_2.12.tgz"
- asc_url: "https://downloads.apache.org/flink/flink-1.12.2/flink-1.12.2-bin-scala_2.12.tgz.asc"
- sha512_url: "https://downloads.apache.org/flink/flink-1.12.2/flink-1.12.2-bin-scala_2.12.tgz.sha512"
+ id: "1121-download_212"
+ url: "https://www.apache.org/dyn/closer.lua/flink/flink-1.12.1/flink-1.12.1-bin-scala_2.12.tgz"
+ asc_url: "https://downloads.apache.org/flink/flink-1.12.1/flink-1.12.1-bin-scala_2.12.tgz.asc"
+ sha512_url: "https://downloads.apache.org/flink/flink-1.12.1/flink-1.12.1-bin-scala_2.12.tgz.sha512"
source_release:
- name: "Apache Flink 1.12.2"
- id: "1122-download-source"
- url: "https://www.apache.org/dyn/closer.lua/flink/flink-1.12.2/flink-1.12.2-src.tgz"
- asc_url: "https://downloads.apache.org/flink/flink-1.12.2/flink-1.12.2-src.tgz.asc"
- sha512_url: "https://downloads.apache.org/flink/flink-1.12.2/flink-1.12.2-src.tgz.sha512"
+ name: "Apache Flink 1.12.1"
+ id: "1121-download-source"
+ url: "https://www.apache.org/dyn/closer.lua/flink/flink-1.12.1/flink-1.12.1-src.tgz"
+ asc_url: "https://downloads.apache.org/flink/flink-1.12.1/flink-1.12.1-src.tgz.asc"
+ sha512_url: "https://downloads.apache.org/flink/flink-1.12.1/flink-1.12.1-src.tgz.sha512"
optional_components:
-
name: "Avro SQL Format"
category: "SQL Formats"
scala_dependent: false
- id: 1122-sql-format-avro
- url: https://repo.maven.apache.org/maven2/org/apache/flink/flink-avro/1.12.2/flink-avro-1.12.2.jar
- asc_url: https://repo.maven.apache.org/maven2/org/apache/flink/flink-avro/1.12.2/flink-avro-1.12.2.jar.asc
- sha_url: https://repo.maven.apache.org/maven2/org/apache/flink/flink-avro/1.12.2/flink-avro-1.12.2.jar.sha1
+ id: 1121-sql-format-avro
+ url: https://repo.maven.apache.org/maven2/org/apache/flink/flink-avro/1.12.1/flink-avro-1.12.1.jar
+ asc_url: https://repo.maven.apache.org/maven2/org/apache/flink/flink-avro/1.12.1/flink-avro-1.12.1.jar.asc
+ sha_url: https://repo.maven.apache.org/maven2/org/apache/flink/flink-avro/1.12.1/flink-avro-1.12.1.jar.sha1
-
version_short: "1.11"
binary_release:
@@ -206,10 +206,6 @@ component_releases:
release_archive:
flink:
- version_short: "1.12"
- version_long: 1.12.2
- release_date: 2021-02-16
- -
- version_short: "1.12"
version_long: 1.12.1
release_date: 2021-01-19
-
diff --git a/_posts/2021-02-16-release-1.12.2.md b/_posts/2021-02-16-release-1.12.2.md
deleted file mode 100644
index c2638fa..0000000
--- a/_posts/2021-02-16-release-1.12.2.md
+++ /dev/null
@@ -1,216 +0,0 @@
----
-layout: post
-title: "Apache Flink 1.12.1 Released"
-date: 2021-02-16 00:00:00
-categories: news
-authors:
-- yuan:
- name: "Yuan Mei"
-- roman:
- name: "Roman Khachatryan"
-
----
-
-The Apache Flink community released the next bugfix version of the Apache Flink 1.12 series.
-
-This release includes 79 fixes and minor improvements for Flink 1.12.1. The list below includes a detailed list of all fixes and improvements.
-
-We highly recommend all users to upgrade to Flink 1.12.2.
-
-<div class="alert alert-danger small" markdown="1">
-<b>Attention:</b>
-Using <b>unaligned checkpoints in Flink 1.12.0</b> combined with two/multiple inputs tasks or with union inputs for single input tasks can result in corrupted state.
-
-This can happen if a new checkpoint is triggered before recovery is fully completed. For state to be corrupted a task with two or more input gates must receive a checkpoint barrier exactly at the same time this tasks finishes recovering spilled in-flight data. In such case this new checkpoint can succeed, with corrupted/missing in-flight data, which will result in various deserialisation/corrupted data stream errors when someone attempts to recover from such corrupted checkpoint.
-
-Using <b>unaligned checkpoints in Flink 1.12.1</b>, a corruption may occur in the checkpoint following a declined checkpoint.
-
-A late barrier of a canceled checkpoint may lead to buffers being not written into the successive checkpoint, such that recovery is not possible. This happens, when the next checkpoint barrier arrives at a given operator before all previous barriers arrived, which can only happen after cancellation in unaligned checkpoints.
-</div>
-
-Updated Maven dependencies:
-
-```xml
-<dependency>
- <groupId>org.apache.flink</groupId>
- <artifactId>flink-java</artifactId>
- <version>1.12.2</version>
-</dependency>
-<dependency>
- <groupId>org.apache.flink</groupId>
- <artifactId>flink-streaming-java_2.11</artifactId>
- <version>1.12.2</version>
-</dependency>
-<dependency>
- <groupId>org.apache.flink</groupId>
- <artifactId>flink-clients_2.11</artifactId>
- <version>1.12.2</version>
-</dependency>
-```
-
-You can find the binaries on the updated [Downloads page]({{ site.baseurl }}/downloads.html).
-
-List of resolved issues:
-
-<h2> Sub-task
-</h2>
-<ul>
-<li>[<a href='https://issues.apache.org/jira/browse/FLINK-21070'>FLINK-21070</a>] - Overloaded aggregate functions cause converter errors
-</li>
-</ul>
-
-<h2> Bug
-</h2>
-<ul>
-<li>[<a href='https://issues.apache.org/jira/browse/FLINK-12461'>FLINK-12461</a>] - Document binary compatibility situation with Scala beyond 2.12.8
-</li>
-<li>[<a href='https://issues.apache.org/jira/browse/FLINK-16443'>FLINK-16443</a>] - Fix wrong fix for user-code CheckpointExceptions
-</li>
-<li>[<a href='https://issues.apache.org/jira/browse/FLINK-19771'>FLINK-19771</a>] - NullPointerException when accessing null array from postgres in JDBC Connector
-</li>
-<li>[<a href='https://issues.apache.org/jira/browse/FLINK-20309'>FLINK-20309</a>] - UnalignedCheckpointTestBase.execute is failed
-</li>
-<li>[<a href='https://issues.apache.org/jira/browse/FLINK-20462'>FLINK-20462</a>] - MailboxOperatorTest.testAvoidTaskStarvation
-</li>
-<li>[<a href='https://issues.apache.org/jira/browse/FLINK-20500'>FLINK-20500</a>] - UpsertKafkaTableITCase.testTemporalJoin test failed
-</li>
-<li>[<a href='https://issues.apache.org/jira/browse/FLINK-20565'>FLINK-20565</a>] - Fix typo in EXPLAIN Statements docs.
-</li>
-<li>[<a href='https://issues.apache.org/jira/browse/FLINK-20654'>FLINK-20654</a>] - Unaligned checkpoint recovery may lead to corrupted data stream
-</li>
-<li>[<a href='https://issues.apache.org/jira/browse/FLINK-20663'>FLINK-20663</a>] - Managed memory may not be released in time when operators use managed memory frequently
-</li>
-<li>[<a href='https://issues.apache.org/jira/browse/FLINK-20675'>FLINK-20675</a>] - Asynchronous checkpoint failure would not fail the job anymore
-</li>
-<li>[<a href='https://issues.apache.org/jira/browse/FLINK-20680'>FLINK-20680</a>] - Fails to call var-arg function with no parameters
-</li>
-<li>[<a href='https://issues.apache.org/jira/browse/FLINK-20798'>FLINK-20798</a>] - Using PVC as high-availability.storageDir could not work
-</li>
-<li>[<a href='https://issues.apache.org/jira/browse/FLINK-20832'>FLINK-20832</a>] - Deliver bootstrap resouces ourselves for website and documentation
-</li>
-<li>[<a href='https://issues.apache.org/jira/browse/FLINK-20848'>FLINK-20848</a>] - Kafka consumer ID is not specified correctly in new KafkaSource
-</li>
-<li>[<a href='https://issues.apache.org/jira/browse/FLINK-20913'>FLINK-20913</a>] - Improve new HiveConf(jobConf, HiveConf.class)
-</li>
-<li>[<a href='https://issues.apache.org/jira/browse/FLINK-20921'>FLINK-20921</a>] - Fix Date/Time/Timestamp in Python DataStream
-</li>
-<li>[<a href='https://issues.apache.org/jira/browse/FLINK-20933'>FLINK-20933</a>] - Config Python Operator Use Managed Memory In Python DataStream
-</li>
-<li>[<a href='https://issues.apache.org/jira/browse/FLINK-20942'>FLINK-20942</a>] - Digest of FLOAT literals throws UnsupportedOperationException
-</li>
-<li>[<a href='https://issues.apache.org/jira/browse/FLINK-20944'>FLINK-20944</a>] - Launching in application mode requesting a ClusterIP rest service type results in an Exception
-</li>
-<li>[<a href='https://issues.apache.org/jira/browse/FLINK-20947'>FLINK-20947</a>] - Idle source doesn't work when pushing watermark into the source
-</li>
-<li>[<a href='https://issues.apache.org/jira/browse/FLINK-20961'>FLINK-20961</a>] - Flink throws NullPointerException for tables created from DataStream with no assigned timestamps and watermarks
-</li>
-<li>[<a href='https://issues.apache.org/jira/browse/FLINK-20992'>FLINK-20992</a>] - Checkpoint cleanup can kill JobMaster
-</li>
-<li>[<a href='https://issues.apache.org/jira/browse/FLINK-20998'>FLINK-20998</a>] - flink-raw-1.12.jar does not exist
-</li>
-<li>[<a href='https://issues.apache.org/jira/browse/FLINK-21009'>FLINK-21009</a>] - Can not disable certain options in Elasticsearch 7 connector
-</li>
-<li>[<a href='https://issues.apache.org/jira/browse/FLINK-21013'>FLINK-21013</a>] - Blink planner does not ingest timestamp into StreamRecord
-</li>
-<li>[<a href='https://issues.apache.org/jira/browse/FLINK-21024'>FLINK-21024</a>] - Dynamic properties get exposed to job's main method if user parameters are passed
-</li>
-<li>[<a href='https://issues.apache.org/jira/browse/FLINK-21059'>FLINK-21059</a>] - KafkaSourceEnumerator does not honor consumer properties
-</li>
-<li>[<a href='https://issues.apache.org/jira/browse/FLINK-21069'>FLINK-21069</a>] - Configuration "parallelism.default" doesn't take effect for TableEnvironment#explainSql
-</li>
-<li>[<a href='https://issues.apache.org/jira/browse/FLINK-21071'>FLINK-21071</a>] - Snapshot branches running against flink-docker dev-master branch
-</li>
-<li>[<a href='https://issues.apache.org/jira/browse/FLINK-21104'>FLINK-21104</a>] - UnalignedCheckpointITCase.execute failed with "IllegalStateException"
-</li>
-<li>[<a href='https://issues.apache.org/jira/browse/FLINK-21132'>FLINK-21132</a>] - BoundedOneInput.endInput is called when taking synchronous savepoint
-</li>
-<li>[<a href='https://issues.apache.org/jira/browse/FLINK-21138'>FLINK-21138</a>] - KvStateServerHandler is not invoked with user code classloader
-</li>
-<li>[<a href='https://issues.apache.org/jira/browse/FLINK-21140'>FLINK-21140</a>] - Extract zip file dependencies before adding to PYTHONPATH
-</li>
-<li>[<a href='https://issues.apache.org/jira/browse/FLINK-21144'>FLINK-21144</a>] - KubernetesResourceManagerDriver#tryResetPodCreationCoolDown causes fatal error
-</li>
-<li>[<a href='https://issues.apache.org/jira/browse/FLINK-21155'>FLINK-21155</a>] - FileSourceTextLinesITCase.testBoundedTextFileSourceWithTaskManagerFailover does not pass
-</li>
-<li>[<a href='https://issues.apache.org/jira/browse/FLINK-21158'>FLINK-21158</a>] - wrong jvm metaspace and overhead size show in taskmanager metric page
-</li>
-<li>[<a href='https://issues.apache.org/jira/browse/FLINK-21163'>FLINK-21163</a>] - Python dependencies specified via CLI should not override the dependencies specified in configuration
-</li>
-<li>[<a href='https://issues.apache.org/jira/browse/FLINK-21169'>FLINK-21169</a>] - Kafka flink-connector-base dependency should be scope compile
-</li>
-<li>[<a href='https://issues.apache.org/jira/browse/FLINK-21208'>FLINK-21208</a>] - pyarrow exception when using window with pandas udaf
-</li>
-<li>[<a href='https://issues.apache.org/jira/browse/FLINK-21215'>FLINK-21215</a>] - Checkpoint was declined because one input stream is finished
-</li>
-<li>[<a href='https://issues.apache.org/jira/browse/FLINK-21216'>FLINK-21216</a>] - StreamPandasConversionTests Fails
-</li>
-<li>[<a href='https://issues.apache.org/jira/browse/FLINK-21225'>FLINK-21225</a>] - OverConvertRule does not consider distinct
-</li>
-<li>[<a href='https://issues.apache.org/jira/browse/FLINK-21226'>FLINK-21226</a>] - Reintroduce TableColumn.of for backwards compatibility
-</li>
-<li>[<a href='https://issues.apache.org/jira/browse/FLINK-21274'>FLINK-21274</a>] - At per-job mode, during the exit of the JobManager process, if ioExecutor exits at the end, the System.exit() method will not be executed.
-</li>
-<li>[<a href='https://issues.apache.org/jira/browse/FLINK-21277'>FLINK-21277</a>] - SQLClientSchemaRegistryITCase fails to download testcontainers/ryuk:0.3.0
-</li>
-<li>[<a href='https://issues.apache.org/jira/browse/FLINK-21312'>FLINK-21312</a>] - SavepointITCase.testStopSavepointWithBoundedInputConcurrently is unstable
-</li>
-<li>[<a href='https://issues.apache.org/jira/browse/FLINK-21323'>FLINK-21323</a>] - Stop-with-savepoint is not supported by SourceOperatorStreamTask
-</li>
-<li>[<a href='https://issues.apache.org/jira/browse/FLINK-21361'>FLINK-21361</a>] - FlinkRelMdUniqueKeys matches on AbstractCatalogTable instead of CatalogTable
-</li>
-</ul>
-
-<h2> New Feature
-</h2>
-<ul>
-<li>[<a href='https://issues.apache.org/jira/browse/FLINK-20359'>FLINK-20359</a>] - Support adding Owner Reference to Job Manager in native kubernetes setup
-</li>
-</ul>
-
-<h2> Improvement
-</h2>
-<ul>
-<li>[<a href='https://issues.apache.org/jira/browse/FLINK-9844'>FLINK-9844</a>] - PackagedProgram does not close URLClassLoader
-</li>
-<li>[<a href='https://issues.apache.org/jira/browse/FLINK-20417'>FLINK-20417</a>] - Handle "Too old resource version" exception in Kubernetes watch more gracefully
-</li>
-<li>[<a href='https://issues.apache.org/jira/browse/FLINK-20491'>FLINK-20491</a>] - Support Broadcast Operation in BATCH execution mode
-</li>
-<li>[<a href='https://issues.apache.org/jira/browse/FLINK-20517'>FLINK-20517</a>] - Support mixed keyed/non-keyed operations in BATCH execution mode
-</li>
-<li>[<a href='https://issues.apache.org/jira/browse/FLINK-20770'>FLINK-20770</a>] - Incorrect description for config option kubernetes.rest-service.exposed.type
-</li>
-<li>[<a href='https://issues.apache.org/jira/browse/FLINK-20907'>FLINK-20907</a>] - Table API documentation promotes deprecated syntax
-</li>
-<li>[<a href='https://issues.apache.org/jira/browse/FLINK-21020'>FLINK-21020</a>] - Bump Jackson to 20.10.5[.1] / 2.12.1
-</li>
-<li>[<a href='https://issues.apache.org/jira/browse/FLINK-21034'>FLINK-21034</a>] - Rework jemalloc switch to use an environment variable
-</li>
-<li>[<a href='https://issues.apache.org/jira/browse/FLINK-21035'>FLINK-21035</a>] - Deduplicate copy_plugins_if_required calls
-</li>
-<li>[<a href='https://issues.apache.org/jira/browse/FLINK-21036'>FLINK-21036</a>] - Consider removing automatic configuration fo number of slots from docker
-</li>
-<li>[<a href='https://issues.apache.org/jira/browse/FLINK-21037'>FLINK-21037</a>] - Deduplicate configuration logic in docker entrypoint
-</li>
-<li>[<a href='https://issues.apache.org/jira/browse/FLINK-21042'>FLINK-21042</a>] - Fix code example in "Aggregate Functions" section in Table UDF page
-</li>
-<li>[<a href='https://issues.apache.org/jira/browse/FLINK-21048'>FLINK-21048</a>] - Refactor documentation related to switch memory allocator
-</li>
-<li>[<a href='https://issues.apache.org/jira/browse/FLINK-21123'>FLINK-21123</a>] - Upgrade Beanutils 1.9.x to 1.9.4
-</li>
-<li>[<a href='https://issues.apache.org/jira/browse/FLINK-21164'>FLINK-21164</a>] - Jar handlers don't cleanup temporarily extracted jars
-</li>
-<li>[<a href='https://issues.apache.org/jira/browse/FLINK-21210'>FLINK-21210</a>] - ApplicationClusterEntryPoints should explicitly close PackagedProgram
-</li>
-<li>[<a href='https://issues.apache.org/jira/browse/FLINK-21381'>FLINK-21381</a>] - Kubernetes HA documentation does not state required service account and role
-</li>
-</ul>
-
-<h2> Task
-</h2>
-<ul>
-<li>[<a href='https://issues.apache.org/jira/browse/FLINK-20529'>FLINK-20529</a>] - Publish Dockerfiles for release 1.12.0
-</li>
-<li>[<a href='https://issues.apache.org/jira/browse/FLINK-20960'>FLINK-20960</a>] - Add warning in 1.12 release notes about potential corrupt data stream with unaligned checkpoint
-</li>
-</ul>
diff --git a/q/gradle-quickstart.sh b/q/gradle-quickstart.sh
index 8203eea..ae79fae 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.12.2}
+defaultFlinkVersion="${1:-1.12.1}
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 3fc12c5..6aee10d 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.12.2} \
+ -DarchetypeVersion=${1:-1.12.1} \
-DgroupId=org.myorg.quickstart \
-DartifactId=$PACKAGE \
-Dversion=0.1 \
diff --git a/q/quickstart.sh b/q/quickstart.sh
index bcb8557..96e3559 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.12.2} \
+ -DarchetypeVersion=${1:-1.12.1} \
-DgroupId=org.myorg.quickstart \
-DartifactId=$PACKAGE \
-Dversion=0.1 \
diff --git a/q/sbt-quickstart.sh b/q/sbt-quickstart.sh
index 79fecec..4db9204 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.12.2"
+defaultFlinkVersion="1.12.1"
echo "This script creates a Flink project using Scala and SBT."