You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ar...@apache.org on 2021/04/29 13:41:01 UTC
[flink-web] branch asf-site updated: Fixed missing pages
This is an automated email from the ASF dual-hosted git repository.
arvid 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 cfa9d5d Fixed missing pages
cfa9d5d is described below
commit cfa9d5d7769a696bd2d226e4a3c5ed75489d5196
Author: Arvid Heise <ar...@ververica.com>
AuthorDate: Thu Apr 29 15:39:29 2021 +0200
Fixed missing pages
---
_posts/2021-04-29-release-1.12.3.md | 200 +++++++++++++
content/news/2021/04/29/release-1.12.3.html | 442 ++++++++++++++++++++++++++++
2 files changed, 642 insertions(+)
diff --git a/_posts/2021-04-29-release-1.12.3.md b/_posts/2021-04-29-release-1.12.3.md
new file mode 100644
index 0000000..53eb745
--- /dev/null
+++ b/_posts/2021-04-29-release-1.12.3.md
@@ -0,0 +1,200 @@
+---
+layout: post
+title: "Apache Flink 1.12.3 Released"
+date: 2021-04-29 00:00:00
+categories: news
+authors:
+- yuan:
+ name: "Arvid Heise"
+
+---
+
+The Apache Flink community released the next bugfix version of the Apache Flink 1.12 series.
+
+This release includes 73 fixes and minor improvements for Flink 1.12.2. The list below includes a detailed list of all fixes and improvements.
+
+We highly recommend all users to upgrade to Flink 1.12.3.
+
+Updated Maven dependencies:
+
+```xml
+<dependency>
+ <groupId>org.apache.flink</groupId>
+ <artifactId>flink-java</artifactId>
+ <version>1.12.3</version>
+</dependency>
+<dependency>
+ <groupId>org.apache.flink</groupId>
+ <artifactId>flink-streaming-java_2.11</artifactId>
+ <version>1.12.3</version>
+</dependency>
+<dependency>
+ <groupId>org.apache.flink</groupId>
+ <artifactId>flink-clients_2.11</artifactId>
+ <version>1.12.3</version>
+</dependency>
+```
+
+You can find the binaries on the updated [Downloads page]({{ site.baseurl }}/downloads.html).
+
+
+List of resolved issues:
+
+<h2> Bug
+</h2>
+<ul>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-18071'>FLINK-18071</a>] - CoordinatorEventsExactlyOnceITCase.checkListContainsSequence fails on CI
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-20547'>FLINK-20547</a>] - Batch job fails due to the exception in network stack
+</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-20722'>FLINK-20722</a>] - HiveTableSink should copy the record when converting RowData to Row
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-20752'>FLINK-20752</a>] - FailureRateRestartBackoffTimeStrategy allows one less restart than configured
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-20761'>FLINK-20761</a>] - Cannot read hive table/partition whose location path contains comma
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-20977'>FLINK-20977</a>] - USE DATABASE & USE CATALOG fails with quoted identifiers containing characters to be escaped in Flink SQL client
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-21008'>FLINK-21008</a>] - Residual HA related Kubernetes ConfigMaps and ZooKeeper nodes when cluster entrypoint received SIGTERM in shutdown
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-21012'>FLINK-21012</a>] - AvroFileFormatFactory uses non-deserializable lambda function
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-21133'>FLINK-21133</a>] - FLIP-27 Source does not work with synchronous savepoint
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-21148'>FLINK-21148</a>] - YARNSessionFIFOSecuredITCase cannot connect to BlobServer
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-21159'>FLINK-21159</a>] - KafkaSourceEnumerator not sending NoMoreSplitsEvent to unassigned reader
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-21178'>FLINK-21178</a>] - Task failure will not trigger master hook's reset()
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-21289'>FLINK-21289</a>] - Application mode ignores the pipeline.classpaths configuration
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-21387'>FLINK-21387</a>] - DispatcherTest.testInvalidCallDuringInitialization times out on azp
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-21388'>FLINK-21388</a>] - Parquet DECIMAL logical type is not properly supported in ParquetSchemaConverter
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-21431'>FLINK-21431</a>] - UpsertKafkaTableITCase.testTemporalJoin hang
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-21434'>FLINK-21434</a>] - When UDAF return ROW type, and the number of fields is more than 14, the crash happend
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-21497'>FLINK-21497</a>] - JobLeaderIdService completes leader future despite no leader being elected
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-21515'>FLINK-21515</a>] - SourceStreamTaskTest.testStopWithSavepointShouldNotInterruptTheSource is failing
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-21518'>FLINK-21518</a>] - CheckpointCoordinatorTest.testMinCheckpointPause fails fatally on AZP
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-21523'>FLINK-21523</a>] - ArrayIndexOutOfBoundsException occurs while run a hive streaming job with partitioned table source
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-21535'>FLINK-21535</a>] - UnalignedCheckpointITCase.execute failed with "OutOfMemoryError: Java heap space"
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-21550'>FLINK-21550</a>] - ZooKeeperHaServicesTest.testSimpleClose fail
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-21552'>FLINK-21552</a>] - The managed memory was not released if exception was thrown in createPythonExecutionEnvironment
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-21606'>FLINK-21606</a>] - TaskManager connected to invalid JobManager leading to TaskSubmissionException
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-21609'>FLINK-21609</a>] - SimpleRecoveryITCaseBase.testRestartMultipleTimes fails on azure
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-21654'>FLINK-21654</a>] - YARNSessionCapacitySchedulerITCase.testStartYarnSessionClusterInQaTeamQueue fail because of NullPointerException
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-21661'>FLINK-21661</a>] - SHARD_GETRECORDS_INTERVAL_MILLIS wrong use?
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-21685'>FLINK-21685</a>] - Flink JobManager failed to restart from checkpoint in kubernetes HA setup
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-21691'>FLINK-21691</a>] - KafkaSource fails with NPE when setting it up
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-21707'>FLINK-21707</a>] - Job is possible to hang when restarting a FINISHED task with POINTWISE BLOCKING consumers
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-21710'>FLINK-21710</a>] - FlinkRelMdUniqueKeys gets incorrect result on TableScan after project push-down
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-21725'>FLINK-21725</a>] - DataTypeExtractor extracts wrong fields ordering for Tuple12
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-21733'>FLINK-21733</a>] - WatermarkAssigner incorrectly recomputing the rowtime index which may cause ArrayIndexOutOfBoundsException
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-21746'>FLINK-21746</a>] - flink sql fields in row access error about scalarfunction
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-21753'>FLINK-21753</a>] - Cycle references between memory manager and gc cleaner action
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-21817'>FLINK-21817</a>] - New Kafka Source might break subtask and split assignment upon rescale
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-21833'>FLINK-21833</a>] - TemporalRowTimeJoinOperator.java will lead to the state expansion by short-life-cycle & huge RowData, although config idle.state.retention.time
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-21889'>FLINK-21889</a>] - source:canal-cdc , sink:upsert-kafka, print "select * from sinkTable", throw NullException
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-21922'>FLINK-21922</a>] - The method partition_by in Over doesn't work for expression dsl
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-21933'>FLINK-21933</a>] - [kinesis][efo] EFO consumer treats interrupts as retryable exceptions
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-21941'>FLINK-21941</a>] - testSavepointRescalingOutPartitionedOperatorStateList fail
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-21942'>FLINK-21942</a>] - KubernetesLeaderRetrievalDriver not closed after terminated which lead to connection leak
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-21944'>FLINK-21944</a>] - AbstractArrowPythonAggregateFunctionOperator.dispose should consider whether arrowSerializer is null
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-21969'>FLINK-21969</a>] - PythonTimestampsAndWatermarksOperator emitted the Long.MAX_VALUE watermark before emitting all the data
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-21980'>FLINK-21980</a>] - ZooKeeperRunningJobsRegistry creates an empty znode
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-21986'>FLINK-21986</a>] - taskmanager native memory not release timely after restart
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-21992'>FLINK-21992</a>] - Fix availability notification in UnionInputGate
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-21996'>FLINK-21996</a>] - Transient RPC failure without TaskManager failure can lead to split assignment loss
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-22006'>FLINK-22006</a>] - Could not run more than 20 jobs in a native K8s session when K8s HA enabled
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-22024'>FLINK-22024</a>] - Maven: Entry has not been leased from this pool / fix for release 1.12
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-22053'>FLINK-22053</a>] - NumberSequenceSource causes fatal exception when less splits than parallelism.
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-22055'>FLINK-22055</a>] - RPC main thread executor may schedule commands with wrong time unit of delay
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-22061'>FLINK-22061</a>] - The DEFAULT_NON_SPLITTABLE_FILE_ENUMERATOR defined in FileSource should points to NonSplittingRecursiveEnumerator
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-22081'>FLINK-22081</a>] - Entropy key not resolved if flink-s3-fs-hadoop is added as a plugin
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-22082'>FLINK-22082</a>] - Nested projection push down doesn't work for data such as row(array(row))
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-22124'>FLINK-22124</a>] - The job finished without any exception if error was thrown during state access
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-22172'>FLINK-22172</a>] - Fix the bug of shared resource among Python Operators of the same slot is not released
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-22184'>FLINK-22184</a>] - Rest client shutdown on failure runs in netty thread
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-22191'>FLINK-22191</a>] - PyFlinkStreamUserDefinedFunctionTests.test_udf_in_join_condition_2 fail due to NPE
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-22327'>FLINK-22327</a>] - NPE exception happens if it throws exception in finishBundle during job shutdown
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-22339'>FLINK-22339</a>] - Fix some encoding exceptions were not thrown in cython coders
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-22345'>FLINK-22345</a>] - CoordinatorEventsExactlyOnceITCase hangs on azure
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-22385'>FLINK-22385</a>] - Type mismatch in NetworkBufferPool
+</li>
+</ul>
+
+<h2> Improvement
+</h2>
+<ul>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-20533'>FLINK-20533</a>] - Add histogram support to Datadog reporter
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-21382'>FLINK-21382</a>] - Standalone K8s documentation does not explain usage of standby JobManagers
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-21521'>FLINK-21521</a>] - Pretty print K8s specifications
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-21690'>FLINK-21690</a>] - remove redundant tolerableCheckpointFailureNumber setting in CheckpointConfig
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-21735'>FLINK-21735</a>] - Harden JobMaster#updateTaskExecutionState()
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-22051'>FLINK-22051</a>] - Better document the distinction between stop-with-savepoint and stop-with-savepoint-with-drain
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-22142'>FLINK-22142</a>] - Remove console logging for Kafka connector for AZP runs
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-22208'>FLINK-22208</a>] - Bump snappy-java to 1.1.5+
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-22297'>FLINK-22297</a>] - Perform early check to ensure that the length of the result is the same as the input for Pandas UDF
+</li>
+</ul>
+
\ No newline at end of file
diff --git a/content/news/2021/04/29/release-1.12.3.html b/content/news/2021/04/29/release-1.12.3.html
new file mode 100644
index 0000000..e4d0b58
--- /dev/null
+++ b/content/news/2021/04/29/release-1.12.3.html
@@ -0,0 +1,442 @@
+<!DOCTYPE html>
+<html lang="en">
+ <head>
+ <meta charset="utf-8">
+ <meta http-equiv="X-UA-Compatible" content="IE=edge">
+ <meta name="viewport" content="width=device-width, initial-scale=1">
+ <!-- The above 3 meta tags *must* come first in the head; any other head content must come *after* these tags -->
+ <title>Apache Flink: Apache Flink 1.12.3 Released</title>
+ <link rel="shortcut icon" href="/favicon.ico" type="image/x-icon">
+ <link rel="icon" href="/favicon.ico" type="image/x-icon">
+
+ <!-- Bootstrap -->
+ <link rel="stylesheet" href="/css/bootstrap.min.css">
+ <link rel="stylesheet" href="/css/flink.css">
+ <link rel="stylesheet" href="/css/syntax.css">
+
+ <!-- Blog RSS feed -->
+ <link href="/blog/feed.xml" rel="alternate" type="application/rss+xml" title="Apache Flink Blog: RSS feed" />
+
+ <!-- jQuery (necessary for Bootstrap's JavaScript plugins) -->
+ <!-- We need to load Jquery in the header for custom google analytics event tracking-->
+ <script src="/js/jquery.min.js"></script>
+
+ <!-- HTML5 shim and Respond.js for IE8 support of HTML5 elements and media queries -->
+ <!-- WARNING: Respond.js doesn't work if you view the page via file:// -->
+ <!--[if lt IE 9]>
+ <script src="https://oss.maxcdn.com/html5shiv/3.7.2/html5shiv.min.js"></script>
+ <script src="https://oss.maxcdn.com/respond/1.4.2/respond.min.js"></script>
+ <![endif]-->
+ </head>
+ <body>
+
+
+ <!-- Main content. -->
+ <div class="container">
+ <div class="row">
+
+
+ <div id="sidebar" class="col-sm-3">
+
+
+<!-- Top navbar. -->
+ <nav class="navbar navbar-default">
+ <!-- The logo. -->
+ <div class="navbar-header">
+ <button type="button" class="navbar-toggle collapsed" data-toggle="collapse" data-target="#bs-example-navbar-collapse-1">
+ <span class="icon-bar"></span>
+ <span class="icon-bar"></span>
+ <span class="icon-bar"></span>
+ </button>
+ <div class="navbar-logo">
+ <a href="/">
+ <img alt="Apache Flink" src="/img/flink-header-logo.svg" width="147px" height="73px">
+ </a>
+ </div>
+ </div><!-- /.navbar-header -->
+
+ <!-- The navigation links. -->
+ <div class="collapse navbar-collapse" id="bs-example-navbar-collapse-1">
+ <ul class="nav navbar-nav navbar-main">
+
+ <!-- First menu section explains visitors what Flink is -->
+
+ <!-- What is Stream Processing? -->
+ <!--
+ <li><a href="/streamprocessing1.html">What is Stream Processing?</a></li>
+ -->
+
+ <!-- What is Flink? -->
+ <li><a href="/flink-architecture.html">What is Apache Flink?</a></li>
+
+
+
+ <!-- What is Stateful Functions? -->
+
+ <li><a href="/stateful-functions.html">What is Stateful Functions?</a></li>
+
+ <!-- Use cases -->
+ <li><a href="/usecases.html">Use Cases</a></li>
+
+ <!-- Powered by -->
+ <li><a href="/poweredby.html">Powered By</a></li>
+
+
+
+ <!-- Second menu section aims to support Flink users -->
+
+ <!-- Downloads -->
+ <li><a href="/downloads.html">Downloads</a></li>
+
+ <!-- Getting Started -->
+ <li class="dropdown">
+ <a class="dropdown-toggle" data-toggle="dropdown" href="#">Getting Started<span class="caret"></span></a>
+ <ul class="dropdown-menu">
+ <li><a href="https://ci.apache.org/projects/flink/flink-docs-release-1.12/try-flink/index.html" target="_blank">With Flink <small><span class="glyphicon glyphicon-new-window"></span></small></a></li>
+ <li><a href="https://ci.apache.org/projects/flink/flink-statefun-docs-release-3.0/getting-started/project-setup.html" target="_blank">With Flink Stateful Functions <small><span class="glyphicon glyphicon-new-window"></span></small></a></li>
+ <li><a href="/training.html">Training Course</a></li>
+ </ul>
+ </li>
+
+ <!-- Documentation -->
+ <li class="dropdown">
+ <a class="dropdown-toggle" data-toggle="dropdown" href="#">Documentation<span class="caret"></span></a>
+ <ul class="dropdown-menu">
+ <li><a href="https://ci.apache.org/projects/flink/flink-docs-release-1.12" target="_blank">Flink 1.12 (Latest stable release) <small><span class="glyphicon glyphicon-new-window"></span></small></a></li>
+ <li><a href="https://ci.apache.org/projects/flink/flink-docs-master" target="_blank">Flink Master (Latest Snapshot) <small><span class="glyphicon glyphicon-new-window"></span></small></a></li>
+ <li><a href="https://ci.apache.org/projects/flink/flink-statefun-docs-release-3.0" target="_blank">Flink Stateful Functions 3.0 (Latest stable release) <small><span class="glyphicon glyphicon-new-window"></span></small></a></li>
+ <li><a href="https://ci.apache.org/projects/flink/flink-statefun-docs-master" target="_blank">Flink Stateful Functions Master (Latest Snapshot) <small><span class="glyphicon glyphicon-new-window"></span></small></a></li>
+ </ul>
+ </li>
+
+ <!-- getting help -->
+ <li><a href="/gettinghelp.html">Getting Help</a></li>
+
+ <!-- Blog -->
+ <li class="active"><a href="/blog/"><b>Flink Blog</b></a></li>
+
+
+ <!-- Flink-packages -->
+ <li>
+ <a href="https://flink-packages.org" target="_blank">flink-packages.org <small><span class="glyphicon glyphicon-new-window"></span></small></a>
+ </li>
+
+
+ <!-- Third menu section aim to support community and contributors -->
+
+ <!-- Community -->
+ <li><a href="/community.html">Community & Project Info</a></li>
+
+ <!-- Roadmap -->
+ <li><a href="/roadmap.html">Roadmap</a></li>
+
+ <!-- Contribute -->
+ <li><a href="/contributing/how-to-contribute.html">How to Contribute</a></li>
+
+
+ <!-- GitHub -->
+ <li>
+ <a href="https://github.com/apache/flink" target="_blank">Flink on GitHub <small><span class="glyphicon glyphicon-new-window"></span></small></a>
+ </li>
+
+
+
+ <!-- Language Switcher -->
+ <li>
+
+
+ <!-- link to the Chinese home page when current is blog page -->
+ <a href="/zh">中文版</a>
+
+
+ </li>
+
+ </ul>
+
+ <style>
+ .smalllinks:link {
+ display: inline-block !important; background: none; padding-top: 0px; padding-bottom: 0px; padding-right: 0px; min-width: 75px;
+ }
+ </style>
+
+ <ul class="nav navbar-nav navbar-bottom">
+ <hr />
+
+ <!-- Twitter -->
+ <li><a href="https://twitter.com/apacheflink" target="_blank">@ApacheFlink <small><span class="glyphicon glyphicon-new-window"></span></small></a></li>
+
+ <!-- Visualizer -->
+ <li class=" hidden-md hidden-sm"><a href="/visualizer/" target="_blank">Plan Visualizer <small><span class="glyphicon glyphicon-new-window"></span></small></a></li>
+
+ <li >
+ <a href="/security.html">Flink Security</a>
+ </li>
+
+ <hr />
+
+ <li><a href="https://apache.org" target="_blank">Apache Software Foundation <small><span class="glyphicon glyphicon-new-window"></span></small></a></li>
+
+ <li>
+
+ <a class="smalllinks" href="https://www.apache.org/licenses/" target="_blank">License</a> <small><span class="glyphicon glyphicon-new-window"></span></small>
+
+ <a class="smalllinks" href="https://www.apache.org/security/" target="_blank">Security</a> <small><span class="glyphicon glyphicon-new-window"></span></small>
+
+ <a class="smalllinks" href="https://www.apache.org/foundation/sponsorship.html" target="_blank">Donate</a> <small><span class="glyphicon glyphicon-new-window"></span></small>
+
+ <a class="smalllinks" href="https://www.apache.org/foundation/thanks.html" target="_blank">Thanks</a> <small><span class="glyphicon glyphicon-new-window"></span></small>
+ </li>
+
+ </ul>
+ </div><!-- /.navbar-collapse -->
+ </nav>
+
+ </div>
+ <div class="col-sm-9">
+ <div class="row-fluid">
+ <div class="col-sm-12">
+ <div class="row">
+ <h1>Apache Flink 1.12.3 Released</h1>
+ <p><i></i></p>
+
+ <article>
+ <p>29 Apr 2021 Arvid Heise </p>
+
+<p>The Apache Flink community released the next bugfix version of the Apache Flink 1.12 series.</p>
+
+<p>This release includes 73 fixes and minor improvements for Flink 1.12.2. The list below includes a detailed list of all fixes and improvements.</p>
+
+<p>We highly recommend all users to upgrade to Flink 1.12.3.</p>
+
+<p>Updated Maven dependencies:</p>
+
+<div class="highlight"><pre><code class="language-xml"><span class="nt"><dependency></span>
+ <span class="nt"><groupId></span>org.apache.flink<span class="nt"></groupId></span>
+ <span class="nt"><artifactId></span>flink-java<span class="nt"></artifactId></span>
+ <span class="nt"><version></span>1.12.3<span class="nt"></version></span>
+<span class="nt"></dependency></span>
+<span class="nt"><dependency></span>
+ <span class="nt"><groupId></span>org.apache.flink<span class="nt"></groupId></span>
+ <span class="nt"><artifactId></span>flink-streaming-java_2.11<span class="nt"></artifactId></span>
+ <span class="nt"><version></span>1.12.3<span class="nt"></version></span>
+<span class="nt"></dependency></span>
+<span class="nt"><dependency></span>
+ <span class="nt"><groupId></span>org.apache.flink<span class="nt"></groupId></span>
+ <span class="nt"><artifactId></span>flink-clients_2.11<span class="nt"></artifactId></span>
+ <span class="nt"><version></span>1.12.3<span class="nt"></version></span>
+<span class="nt"></dependency></span></code></pre></div>
+
+<p>You can find the binaries on the updated <a href="/downloads.html">Downloads page</a>.</p>
+
+<p>List of resolved issues:</p>
+
+<h2> Bug
+</h2>
+<ul>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-18071">FLINK-18071</a>] - CoordinatorEventsExactlyOnceITCase.checkListContainsSequence fails on CI
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20547">FLINK-20547</a>] - Batch job fails due to the exception in network stack
+</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-20722">FLINK-20722</a>] - HiveTableSink should copy the record when converting RowData to Row
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20752">FLINK-20752</a>] - FailureRateRestartBackoffTimeStrategy allows one less restart than configured
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20761">FLINK-20761</a>] - Cannot read hive table/partition whose location path contains comma
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20977">FLINK-20977</a>] - USE DATABASE & USE CATALOG fails with quoted identifiers containing characters to be escaped in Flink SQL client
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-21008">FLINK-21008</a>] - Residual HA related Kubernetes ConfigMaps and ZooKeeper nodes when cluster entrypoint received SIGTERM in shutdown
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-21012">FLINK-21012</a>] - AvroFileFormatFactory uses non-deserializable lambda function
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-21133">FLINK-21133</a>] - FLIP-27 Source does not work with synchronous savepoint
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-21148">FLINK-21148</a>] - YARNSessionFIFOSecuredITCase cannot connect to BlobServer
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-21159">FLINK-21159</a>] - KafkaSourceEnumerator not sending NoMoreSplitsEvent to unassigned reader
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-21178">FLINK-21178</a>] - Task failure will not trigger master hook's reset()
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-21289">FLINK-21289</a>] - Application mode ignores the pipeline.classpaths configuration
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-21387">FLINK-21387</a>] - DispatcherTest.testInvalidCallDuringInitialization times out on azp
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-21388">FLINK-21388</a>] - Parquet DECIMAL logical type is not properly supported in ParquetSchemaConverter
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-21431">FLINK-21431</a>] - UpsertKafkaTableITCase.testTemporalJoin hang
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-21434">FLINK-21434</a>] - When UDAF return ROW type, and the number of fields is more than 14, the crash happend
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-21497">FLINK-21497</a>] - JobLeaderIdService completes leader future despite no leader being elected
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-21515">FLINK-21515</a>] - SourceStreamTaskTest.testStopWithSavepointShouldNotInterruptTheSource is failing
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-21518">FLINK-21518</a>] - CheckpointCoordinatorTest.testMinCheckpointPause fails fatally on AZP
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-21523">FLINK-21523</a>] - ArrayIndexOutOfBoundsException occurs while run a hive streaming job with partitioned table source
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-21535">FLINK-21535</a>] - UnalignedCheckpointITCase.execute failed with "OutOfMemoryError: Java heap space"
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-21550">FLINK-21550</a>] - ZooKeeperHaServicesTest.testSimpleClose fail
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-21552">FLINK-21552</a>] - The managed memory was not released if exception was thrown in createPythonExecutionEnvironment
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-21606">FLINK-21606</a>] - TaskManager connected to invalid JobManager leading to TaskSubmissionException
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-21609">FLINK-21609</a>] - SimpleRecoveryITCaseBase.testRestartMultipleTimes fails on azure
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-21654">FLINK-21654</a>] - YARNSessionCapacitySchedulerITCase.testStartYarnSessionClusterInQaTeamQueue fail because of NullPointerException
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-21661">FLINK-21661</a>] - SHARD_GETRECORDS_INTERVAL_MILLIS wrong use?
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-21685">FLINK-21685</a>] - Flink JobManager failed to restart from checkpoint in kubernetes HA setup
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-21691">FLINK-21691</a>] - KafkaSource fails with NPE when setting it up
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-21707">FLINK-21707</a>] - Job is possible to hang when restarting a FINISHED task with POINTWISE BLOCKING consumers
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-21710">FLINK-21710</a>] - FlinkRelMdUniqueKeys gets incorrect result on TableScan after project push-down
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-21725">FLINK-21725</a>] - DataTypeExtractor extracts wrong fields ordering for Tuple12
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-21733">FLINK-21733</a>] - WatermarkAssigner incorrectly recomputing the rowtime index which may cause ArrayIndexOutOfBoundsException
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-21746">FLINK-21746</a>] - flink sql fields in row access error about scalarfunction
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-21753">FLINK-21753</a>] - Cycle references between memory manager and gc cleaner action
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-21817">FLINK-21817</a>] - New Kafka Source might break subtask and split assignment upon rescale
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-21833">FLINK-21833</a>] - TemporalRowTimeJoinOperator.java will lead to the state expansion by short-life-cycle & huge RowData, although config idle.state.retention.time
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-21889">FLINK-21889</a>] - source:canal-cdc , sink:upsert-kafka, print "select * from sinkTable", throw NullException
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-21922">FLINK-21922</a>] - The method partition_by in Over doesn't work for expression dsl
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-21933">FLINK-21933</a>] - [kinesis][efo] EFO consumer treats interrupts as retryable exceptions
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-21941">FLINK-21941</a>] - testSavepointRescalingOutPartitionedOperatorStateList fail
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-21942">FLINK-21942</a>] - KubernetesLeaderRetrievalDriver not closed after terminated which lead to connection leak
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-21944">FLINK-21944</a>] - AbstractArrowPythonAggregateFunctionOperator.dispose should consider whether arrowSerializer is null
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-21969">FLINK-21969</a>] - PythonTimestampsAndWatermarksOperator emitted the Long.MAX_VALUE watermark before emitting all the data
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-21980">FLINK-21980</a>] - ZooKeeperRunningJobsRegistry creates an empty znode
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-21986">FLINK-21986</a>] - taskmanager native memory not release timely after restart
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-21992">FLINK-21992</a>] - Fix availability notification in UnionInputGate
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-21996">FLINK-21996</a>] - Transient RPC failure without TaskManager failure can lead to split assignment loss
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-22006">FLINK-22006</a>] - Could not run more than 20 jobs in a native K8s session when K8s HA enabled
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-22024">FLINK-22024</a>] - Maven: Entry has not been leased from this pool / fix for release 1.12
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-22053">FLINK-22053</a>] - NumberSequenceSource causes fatal exception when less splits than parallelism.
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-22055">FLINK-22055</a>] - RPC main thread executor may schedule commands with wrong time unit of delay
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-22061">FLINK-22061</a>] - The DEFAULT_NON_SPLITTABLE_FILE_ENUMERATOR defined in FileSource should points to NonSplittingRecursiveEnumerator
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-22081">FLINK-22081</a>] - Entropy key not resolved if flink-s3-fs-hadoop is added as a plugin
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-22082">FLINK-22082</a>] - Nested projection push down doesn't work for data such as row(array(row))
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-22124">FLINK-22124</a>] - The job finished without any exception if error was thrown during state access
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-22172">FLINK-22172</a>] - Fix the bug of shared resource among Python Operators of the same slot is not released
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-22184">FLINK-22184</a>] - Rest client shutdown on failure runs in netty thread
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-22191">FLINK-22191</a>] - PyFlinkStreamUserDefinedFunctionTests.test_udf_in_join_condition_2 fail due to NPE
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-22327">FLINK-22327</a>] - NPE exception happens if it throws exception in finishBundle during job shutdown
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-22339">FLINK-22339</a>] - Fix some encoding exceptions were not thrown in cython coders
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-22345">FLINK-22345</a>] - CoordinatorEventsExactlyOnceITCase hangs on azure
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-22385">FLINK-22385</a>] - Type mismatch in NetworkBufferPool
+</li>
+</ul>
+
+<h2> Improvement
+</h2>
+<ul>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20533">FLINK-20533</a>] - Add histogram support to Datadog reporter
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-21382">FLINK-21382</a>] - Standalone K8s documentation does not explain usage of standby JobManagers
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-21521">FLINK-21521</a>] - Pretty print K8s specifications
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-21690">FLINK-21690</a>] - remove redundant tolerableCheckpointFailureNumber setting in CheckpointConfig
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-21735">FLINK-21735</a>] - Harden JobMaster#updateTaskExecutionState()
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-22051">FLINK-22051</a>] - Better document the distinction between stop-with-savepoint and stop-with-savepoint-with-drain
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-22142">FLINK-22142</a>] - Remove console logging for Kafka connector for AZP runs
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-22208">FLINK-22208</a>] - Bump snappy-java to 1.1.5+
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-22297">FLINK-22297</a>] - Perform early check to ensure that the length of the result is the same as the input for Pandas UDF
+</li>
+</ul>
+
+
+ </article>
+ </div>
+
+ <div class="row">
+ <div id="disqus_thread"></div>
+ <script type="text/javascript">
+ /* * * CONFIGURATION VARIABLES: EDIT BEFORE PASTING INTO YOUR WEBPAGE * * */
+ var disqus_shortname = 'stratosphere-eu'; // required: replace example with your forum shortname
+
+ /* * * DON'T EDIT BELOW THIS LINE * * */
+ (function() {
+ var dsq = document.createElement('script'); dsq.type = 'text/javascript'; dsq.async = true;
+ dsq.src = '//' + disqus_shortname + '.disqus.com/embed.js';
+ (document.getElementsByTagName('head')[0] || document.getElementsByTagName('body')[0]).appendChild(dsq);
+ })();
+ </script>
+ </div>
+ </div>
+</div>
+ </div>
+ </div>
+
+ <hr />
+
+ <div class="row">
+ <div class="footer text-center col-sm-12">
+ <p>Copyright © 2014-2021 <a href="http://apache.org">The Apache Software Foundation</a>. All Rights Reserved.</p>
+ <p>Apache Flink, Flink®, Apache®, the squirrel logo, and the Apache feather logo are either registered trademarks or trademarks of The Apache Software Foundation.</p>
+ <p><a href="/privacy-policy.html">Privacy Policy</a> · <a href="/blog/feed.xml">RSS feed</a></p>
+ </div>
+ </div>
+ </div><!-- /.container -->
+
+ <!-- Include all compiled plugins (below), or include individual files as needed -->
+ <script src="/js/jquery.matchHeight-min.js"></script>
+ <script src="/js/bootstrap.min.js"></script>
+ <script src="/js/codetabs.js"></script>
+ <script src="/js/stickysidebar.js"></script>
+
+ <!-- Google Analytics -->
+ <script>
+ (function(i,s,o,g,r,a,m){i['GoogleAnalyticsObject']=r;i[r]=i[r]||function(){
+ (i[r].q=i[r].q||[]).push(arguments)},i[r].l=1*new Date();a=s.createElement(o),
+ m=s.getElementsByTagName(o)[0];a.async=1;a.src=g;m.parentNode.insertBefore(a,m)
+ })(window,document,'script','//www.google-analytics.com/analytics.js','ga');
+
+ ga('create', 'UA-52545728-1', 'auto');
+ ga('send', 'pageview');
+ </script>
+ </body>
+</html>