This is an automated email from the ASF dual-hosted git repository.
thw 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 c9d07f1 Add Flink release 1.14.3
c9d07f1 is described below
commit c9d07f112643f7670f65550818e0785e07c52024
Author: martijnvisser <[email protected]>
AuthorDate: Wed Jan 12 19:44:49 2022 +0100
Add Flink release 1.14.3
---
_config.yml | 28 +--
_posts/2022-01-17-release-1.14.3.md | 331 ++++++++++++++++++++++++++++++++++++
q/gradle-quickstart.sh | 2 +-
q/quickstart-scala.sh | 2 +-
q/quickstart.sh | 2 +-
q/sbt-quickstart.sh | 2 +-
6 files changed, 351 insertions(+), 16 deletions(-)
diff --git a/_config.yml b/_config.yml
index 96224b6..41464de 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.2
+FLINK_VERSION_STABLE: 1.14.3
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.2"
+ name: "Apache Flink 1.14.3"
scala_211:
id: "1142-download_211"
- url:
"https://www.apache.org/dyn/closer.lua/flink/flink-1.14.2/flink-1.14.2-bin-scala_2.11.tgz";
- asc_url:
"https://downloads.apache.org/flink/flink-1.14.2/flink-1.14.2-bin-scala_2.11.tgz.asc";
- sha512_url:
"https://downloads.apache.org/flink/flink-1.14.2/flink-1.14.2-bin-scala_2.11.tgz.sha512";
+ 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";
scala_212:
id: "1142-download_212"
- url:
"https://www.apache.org/dyn/closer.lua/flink/flink-1.14.2/flink-1.14.2-bin-scala_2.12.tgz";
- asc_url:
"https://downloads.apache.org/flink/flink-1.14.2/flink-1.14.2-bin-scala_2.12.tgz.asc";
- sha512_url:
"https://downloads.apache.org/flink/flink-1.14.2/flink-1.14.2-bin-scala_2.12.tgz.sha512";
+ 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";
source_release:
- name: "Apache Flink 1.14.2"
+ name: "Apache Flink 1.14.3"
id: "1142-download-source"
- url:
"https://www.apache.org/dyn/closer.lua/flink/flink-1.14.2/flink-1.14.2-src.tgz";
- asc_url:
"https://downloads.apache.org/flink/flink-1.14.2/flink-1.14.2-src.tgz.asc";
- sha512_url:
"https://downloads.apache.org/flink/flink-1.14.2/flink-1.14.2-src.tgz.sha512";
+ 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";
release_notes_url:
"https://nightlies.apache.org/flink/flink-docs-release-1.14/release-notes/flink-1.14";
-
version_short: "1.13"
@@ -205,6 +205,10 @@ release_archive:
flink:
-
version_short: "1.14"
+ version_long: 1.14.3
+ release_date: 2022-01-17
+ -
+ version_short: "1.14"
version_long: 1.14.2
release_date: 2021-12-16
-
diff --git a/_posts/2022-01-17-release-1.14.3.md
b/_posts/2022-01-17-release-1.14.3.md
new file mode 100644
index 0000000..09bcb76
--- /dev/null
+++ b/_posts/2022-01-17-release-1.14.3.md
@@ -0,0 +1,331 @@
+---
+layout: post
+title: "Apache Flink 1.14.3 Release Announcement"
+date: 2022-01-17T08:00:00.000Z
+categories: news
+authors:
+- tweise:
+ name: "Thomas Weise"
+- MartijnVisser:
+ name: "Martijn Visser"
+ twitter: "martijnvisser82"
+
+The Apache Flink community released the second bugfix version of the Apache
Flink 1.14 series.
+
+---
+
+The Apache Flink community released the second bugfix version of the Apache
Flink 1.14 series.
+The first bugfix release was 1.14.2, being an emergency release due to an
Apache Log4j Zero Day (CVE-2021-44228). Flink 1.14.1 was abandoned.
+That means that this Flink release is the first bugfix release of the Flink
1.14 series which contains bugfixes not related to the mentioned CVE.
+
+This release includes 164 fixes and minor improvements for Flink 1.14.0. The
list below includes bugfixes and improvements. For a complete list of all
changes see:
+[JIRA](https://issues.apache.org/jira/secure/ReleaseNote.jspa?version=12351075&projectId=12315522).
+
+We highly recommend all users to upgrade to Flink 1.14.3.
+
+Updated Maven dependencies:
+
+```xml
+<dependency>
+ <groupId>org.apache.flink</groupId>
+ <artifactId>flink-java</artifactId>
+ <version>1.14.3</version>
+</dependency>
+<dependency>
+ <groupId>org.apache.flink</groupId>
+ <artifactId>flink-streaming-java_2.11</artifactId>
+ <version>1.14.3</version>
+</dependency>
+<dependency>
+ <groupId>org.apache.flink</groupId>
+ <artifactId>flink-clients_2.11</artifactId>
+ <version>1.14.3</version>
+</dependency>
+```
+
+You can find the binaries on the updated [Downloads page]({{ site.baseurl
}}/downloads.html).
+
+
+
+
+
+ Release Notes - Flink - Version 1.14.3
+
+<h2> Sub-task
+</h2>
+<ul>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-24355'>FLINK-24355</a>] -
Expose the flag for enabling checkpoints after tasks finish in the Web UI
+</li>
+</ul>
+
+<h2> Bug
+</h2>
+<ul>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-15987'>FLINK-15987</a>] -
SELECT 1.0e0 / 0.0e0 throws NumberFormatException
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-17914'>FLINK-17914</a>] -
HistoryServer deletes cached archives if archive listing fails
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-19142'>FLINK-19142</a>] -
Local recovery can be broken if slot hijacking happened during a full
restart
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-20195'>FLINK-20195</a>] -
Jobs endpoint returns duplicated jobs
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-20370'>FLINK-20370</a>] -
Result is wrong when sink primary key is not the same with query
+</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-21345'>FLINK-21345</a>] -
NullPointerException
LogicalCorrelateToJoinFromTemporalTableFunctionRule.scala:157
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-22113'>FLINK-22113</a>] -
UniqueKey constraint is lost with multiple sources join in SQL
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-22954'>FLINK-22954</a>] -
Don't support consuming update and delete changes when use table
function that does not contain table field
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-23614'>FLINK-23614</a>] -
The resulting scale of TRUNCATE(DECIMAL, ...) is not correct
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-23704'>FLINK-23704</a>] -
FLIP-27 sources are not generating LatencyMarkers
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-23827'>FLINK-23827</a>] -
Fix ModifiedMonotonicity inference for some node
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-23919'>FLINK-23919</a>] -
PullUpWindowTableFunctionIntoWindowAggregateRule generates invalid Calc for
Window TVF
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-24156'>FLINK-24156</a>] -
BlobServer crashes due to SocketTimeoutException in Java 11
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-24232'>FLINK-24232</a>] -
Archiving of suspended jobs prevents breaks subsequent archive attempts
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-24291'>FLINK-24291</a>] -
Decimal precision is lost when deserializing in test cases
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-24310'>FLINK-24310</a>] -
A bug in the BufferingSink example in the doc
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-24315'>FLINK-24315</a>] -
Cannot rebuild watcher thread while the K8S API server is unavailable
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-24318'>FLINK-24318</a>] -
Casting a number to boolean has different results between 'select'
fields and 'where' condition
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-24331'>FLINK-24331</a>] -
PartiallyFinishedSourcesITCase fails with "No downstream received 0
from xxx;"
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-24336'>FLINK-24336</a>] -
PyFlink TableEnvironment executes the SQL randomly MalformedURLException
with the configuration for 'pipeline.classpaths'
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-24344'>FLINK-24344</a>] -
Handling of IOExceptions when triggering checkpoints doesn't cause job
failover
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-24353'>FLINK-24353</a>] -
Bash scripts do not respect dynamic configurations when calculating memory
sizes
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-24366'>FLINK-24366</a>] -
Unnecessary/misleading error message about failing restores when tasks are
already canceled.
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-24371'>FLINK-24371</a>] -
Support SinkWriter preCommit without the need of a committer
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-24377'>FLINK-24377</a>] -
TM resource may not be properly released after heartbeat timeout
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-24380'>FLINK-24380</a>] -
Flink should handle the state transition of the pod from Pending to Failed
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-24381'>FLINK-24381</a>] -
Table API exceptions may leak sensitive configuration values
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-24401'>FLINK-24401</a>] -
TM cannot exit after Metaspace OOM
+</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-24408'>FLINK-24408</a>] -
org.codehaus.janino.InternalCompilerException: Compiling
"StreamExecValues$200": Code of method
"nextRecord(Ljava/lang/Object;)Ljava/lang/Object;" of class
"StreamExecValues$200" grows beyond 64 KB
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-24409'>FLINK-24409</a>] -
Kafka topics with periods in their names generate a constant stream of
errors
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-24431'>FLINK-24431</a>] -
[Kinesis][EFO] EAGER registration strategy does not work when job fails over
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-24432'>FLINK-24432</a>] -
RocksIteratorWrapper.seekToLast() calls the wrong RocksIterator method
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-24465'>FLINK-24465</a>] -
Wrong javadoc and documentation for buffer timeout
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-24467'>FLINK-24467</a>] -
Set min and max buffer size even if the difference less than threshold
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-24468'>FLINK-24468</a>] -
NPE when notifyNewBufferSize
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-24469'>FLINK-24469</a>] -
Incorrect calcualtion of the buffer size in case of channel data skew
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-24480'>FLINK-24480</a>] -
EqualiserCodeGeneratorTest fails on azure
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-24488'>FLINK-24488</a>] -
KafkaRecordSerializationSchemaBuilder does not forward timestamp
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-24492'>FLINK-24492</a>] -
incorrect implicit type conversion between numeric and (var)char
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-24506'>FLINK-24506</a>] -
checkpoint directory is not configurable through the Flink configuration
passed into the StreamExecutionEnvironment
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-24540'>FLINK-24540</a>] -
Fix Resource leak due to Files.list
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-24543'>FLINK-24543</a>] -
Zookeeper connection issue causes inconsistent state in Flink
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-24550'>FLINK-24550</a>] -
Can not access job information from a standby jobmanager UI
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-24551'>FLINK-24551</a>] -
BUFFER_DEBLOAT_SAMPLES property is taken from the wrong configuration
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-24552'>FLINK-24552</a>] -
Ineffective buffer debloat configuration in randomized tests
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-24563'>FLINK-24563</a>] -
Comparing timstamp_ltz with random string throws NullPointerException
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-24596'>FLINK-24596</a>] -
Bugs in sink.buffer-flush before upsert-kafka
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-24597'>FLINK-24597</a>] -
RocksdbStateBackend getKeysAndNamespaces would return duplicate data when
using MapState
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-24600'>FLINK-24600</a>] -
Duplicate 99th percentile displayed in checkpoint summary
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-24608'>FLINK-24608</a>] -
Sinks built with the unified sink framework do not receive timestamps when
used in Table API
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-24613'>FLINK-24613</a>] -
Documentation on orc supported data types is outdated
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-24647'>FLINK-24647</a>] -
ClusterUncaughtExceptionHandler does not log the exception
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-24654'>FLINK-24654</a>] -
NPE on RetractableTopNFunction when some records were cleared by state ttl
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-24662'>FLINK-24662</a>] -
PyFlink sphinx check failed with "node class 'meta' is already
registered, its visitors will be overridden"
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-24667'>FLINK-24667</a>] -
Channel state writer would fail the task directly if meeting exception
previously
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-24676'>FLINK-24676</a>] -
Schema does not match if explain insert statement with partial column
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-24678'>FLINK-24678</a>] -
Correct the metric name of map state contains latency
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-24691'>FLINK-24691</a>] -
FLINK SQL SUM() causes a precision error
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-24704'>FLINK-24704</a>] -
Exception occurs when the input record loses monotonicity on the sort key
field of UpdatableTopNFunction
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-24706'>FLINK-24706</a>] -
AkkaInvocationHandler silently ignores deserialization errors
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-24708'>FLINK-24708</a>] -
`ConvertToNotInOrInRule` has a bug which leads to wrong result
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-24728'>FLINK-24728</a>] -
Batch SQL file sink forgets to close the output stream
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-24733'>FLINK-24733</a>] -
Data loss in pulsar source when using shared mode
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-24738'>FLINK-24738</a>] -
Fail during announcing buffer size to released local channel
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-24761'>FLINK-24761</a>] -
Fix PartitionPruner code gen compile fail
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-24773'>FLINK-24773</a>] -
KafkaCommitter should fail on unknown Exception
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-24777'>FLINK-24777</a>] -
Processed (persisted) in-flight data description miss on Monitoring
Checkpointing page
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-24789'>FLINK-24789</a>] -
IllegalStateException with CheckpointCleaner being closed already
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-24792'>FLINK-24792</a>] -
OperatorCoordinatorSchedulerTest crashed JVM on AZP
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-24835'>FLINK-24835</a>] -
"group by" in the interval join will throw a exception
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-24846'>FLINK-24846</a>] -
AsyncWaitOperator fails during stop-with-savepoint
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-24858'>FLINK-24858</a>] -
TypeSerializer version mismatch during eagerly restore
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-24874'>FLINK-24874</a>] -
Dropdown menu is not properly shown in UI
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-24885'>FLINK-24885</a>] -
ProcessElement Interface parameter Collector :
java.lang.NullPointerException
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-24919'>FLINK-24919</a>] -
UnalignedCheckpointITCase hangs on Azure
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-24922'>FLINK-24922</a>] -
Fix spelling errors in the word "parallism"
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-24937'>FLINK-24937</a>] -
"kubernetes application HA test" hangs on azure
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-24938'>FLINK-24938</a>] -
Checkpoint cleaner is closed before checkpoints are discarded
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-25022'>FLINK-25022</a>] -
ClassLoader leak with ThreadLocals on the JM when submitting a job through
the REST API
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-25067'>FLINK-25067</a>] -
Correct the description of RocksDB's background threads
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-25084'>FLINK-25084</a>] -
Field names must be unique. Found duplicates
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-25091'>FLINK-25091</a>] -
Official website document FileSink orc compression attribute reference error
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-25096'>FLINK-25096</a>] -
Issue in exceptions API(/jobs/:jobid/exceptions) in flink 1.13.2
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-25126'>FLINK-25126</a>] -
FlinkKafkaInternalProducer state is not reset if transaction finalization
fails
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-25132'>FLINK-25132</a>] -
KafkaSource cannot work with object-reusing DeserializationSchema
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-25134'>FLINK-25134</a>] -
Unused RetryRule in KafkaConsumerTestBase swallows retries
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-25222'>FLINK-25222</a>] -
Remove NetworkFailureProxy used for Kafka connector tests
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-25271'>FLINK-25271</a>] -
ApplicationDispatcherBootstrapITCase.
testDispatcherRecoversAfterLosingAndRegainingLeadership failed on azure
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-25294'>FLINK-25294</a>] -
Incorrect cloudpickle import
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-25375'>FLINK-25375</a>] -
Update Log4j to 2.17.0
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-25418'>FLINK-25418</a>] -
The dir_cache is specified in the flink task. When there is no network, you
will still download the python third-party library
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-25446'>FLINK-25446</a>] -
Avoid sanity check on read bytes on DataInputStream#read(byte[])
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-25468'>FLINK-25468</a>] -
Local recovery fails if local state storage and RocksDB working directory
are not on the same volume
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-25477'>FLINK-25477</a>] -
The directory structure of the State Backends document is not standardized
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-25513'>FLINK-25513</a>] -
CoFlatMapFunction requires both two flat_maps to yield something
+</li>
+</ul>
+
+<h2> Improvement
+</h2>
+<ul>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-20443'>FLINK-20443</a>] -
ContinuousProcessingTimeTrigger doesn't fire at the end of the window
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-21467'>FLINK-21467</a>] -
Document possible recommended usage of Bounded{One/Multi}Input.endInput and
emphasize that they could be called multiple times
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-23519'>FLINK-23519</a>] -
Aggregate State Backend Latency by State Level
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-23798'>FLINK-23798</a>] -
Avoid using reflection to get filter when partition filter is enabled
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-23842'>FLINK-23842</a>] -
Add log messages for reader registrations and split requests.
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-23914'>FLINK-23914</a>] -
Make connector testing framework more verbose on test failure
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-24117'>FLINK-24117</a>] -
Remove unHandledErrorListener in ZooKeeperLeaderElectionDriver and
ZooKeeperLeaderRetrievalDriver
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-24148'>FLINK-24148</a>] -
Add bloom filter policy option in RocksDBConfiguredOptions
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-24382'>FLINK-24382</a>] -
RecordsOut metric for sinks is inaccurate
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-24437'>FLINK-24437</a>] -
Remove unhandled exception handler from CuratorFramework before closing it
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-24460'>FLINK-24460</a>] -
Rocksdb Iterator Error Handling Improvement
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-24481'>FLINK-24481</a>] -
Translate buffer debloat documenation to chinese
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-24529'>FLINK-24529</a>] -
flink sql job cannot use custom job name
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-24631'>FLINK-24631</a>] -
Avoiding directly use the labels as selector for deployment and service
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-24670'>FLINK-24670</a>] -
Restructure unaligned checkpoints documentation page to "Checkpointing
under back pressure"
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-24690'>FLINK-24690</a>] -
Clarification of buffer size threshold calculation in BufferDebloater
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-24695'>FLINK-24695</a>] -
Update how to configure unaligned checkpoints in the documentation
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-24739'>FLINK-24739</a>] -
State requirements for Flink's application mode in the documentation
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-24813'>FLINK-24813</a>] -
Improve ImplicitTypeConversionITCase
+</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-24958'>FLINK-24958</a>] -
correct the example and link for temporal table function documentation
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-24987'>FLINK-24987</a>] -
Enhance ExternalizedCheckpointCleanup enum
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-25092'>FLINK-25092</a>] -
Implement artifact cacher for Bash based Elasticsearch test
+</li>
+</ul>
+
+<h2> Technical Debt
+</h2>
+<ul>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-24367'>FLINK-24367</a>] -
Add a fallback AkkaRpcSystemLoader for tests in the IDE
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-24445'>FLINK-24445</a>] -
Move RPC System packaging to package phase
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-24455'>FLINK-24455</a>] -
FallbackAkkaRpcSystemLoader should check for maven errors
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-24513'>FLINK-24513</a>] -
AkkaRpcSystemLoader must be an ITCase
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-24559'>FLINK-24559</a>] -
flink-rpc-akka-loader does not bundle flink-rpc-akka
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-24609'>FLINK-24609</a>] -
flink-rpc-akka uses wrong Scala version property for parser-combinators
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-24859'>FLINK-24859</a>] -
Document new File formats
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-25472'>FLINK-25472</a>] -
Update to Log4j 2.17.1
+</li>
+</ul>
+
\ No newline at end of file
diff --git a/q/gradle-quickstart.sh b/q/gradle-quickstart.sh
index baa6315..68f61f0 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.2}"
+defaultFlinkVersion="${1:-1.14.3}"
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 e66bd81..bd618b1 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.2}
\
+ -DarchetypeVersion=${1:-1.14.3}
\
-DgroupId=org.myorg.quickstart \
-DartifactId=$PACKAGE
\
-Dversion=0.1
\
diff --git a/q/quickstart.sh b/q/quickstart.sh
index 7121e2f..14e5379 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.2}
\
+ -DarchetypeVersion=${1:-1.14.3}
\
-DgroupId=org.myorg.quickstart \
-DartifactId=$PACKAGE
\
-Dversion=0.1
\
diff --git a/q/sbt-quickstart.sh b/q/sbt-quickstart.sh
index 12751a5..1c5d849 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.2"
+defaultFlinkVersion="1.14.3"
echo "This script creates a Flink project using Scala and SBT."
