This is an automated email from the ASF dual-hosted git repository.
liyu pushed a commit to branch asf-site
in repository https://gitbox.apache.org/repos/asf/flink-web.git
commit 61b3e95a39e3fdb345c5d7be2fac9a41048eb3cb
Author: Yu Li <l...@apache.org>
AuthorDate: Sat Apr 25 01:34:23 2020 +0800
Add Apache Flink release 1.10.1
---
_config.yml | 58 +++---
_posts/2020-05-12-release-1.10.1.md | 382 ++++++++++++++++++++++++++++++++++++
2 files changed, 413 insertions(+), 27 deletions(-)
diff --git a/_config.yml b/_config.yml
index 876e449..8ba0d26 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.10.0
+FLINK_VERSION_STABLE: 1.10.1
FLINK_VERSION_STABLE_SHORT: "1.10"
FLINK_ISSUES_URL: https://issues.apache.org/jira/browse/FLINK
@@ -58,48 +58,48 @@ flink_releases:
-
version_short: "1.10"
binary_release:
- name: "Apache Flink 1.10.0"
+ name: "Apache Flink 1.10.1"
scala_211:
- id: "1100-download_211"
- url:
"https://www.apache.org/dyn/closer.lua/flink/flink-1.10.0/flink-1.10.0-bin-scala_2.11.tgz";
- asc_url:
"https://downloads.apache.org/flink/flink-1.10.0/flink-1.10.0-bin-scala_2.11.tgz.asc";
- sha512_url:
"https://downloads.apache.org/flink/flink-1.10.0/flink-1.10.0-bin-scala_2.11.tgz.sha512";
+ id: "1101-download_211"
+ url:
"https://www.apache.org/dyn/closer.lua/flink/flink-1.10.1/flink-1.10.1-bin-scala_2.11.tgz";
+ asc_url:
"https://downloads.apache.org/flink/flink-1.10.1/flink-1.10.1-bin-scala_2.11.tgz.asc";
+ sha512_url:
"https://downloads.apache.org/flink/flink-1.10.1/flink-1.10.1-bin-scala_2.11.tgz.sha512";
scala_212:
- id: "1100-download_212"
- url:
"https://www.apache.org/dyn/closer.lua/flink/flink-1.10.0/flink-1.10.0-bin-scala_2.12.tgz";
- asc_url:
"https://downloads.apache.org/flink/flink-1.10.0/flink-1.10.0-bin-scala_2.12.tgz.asc";
- sha512_url:
"https://downloads.apache.org/flink/flink-1.10.0/flink-1.10.0-bin-scala_2.12.tgz.sha512";
+ id: "1101-download_212"
+ url:
"https://www.apache.org/dyn/closer.lua/flink/flink-1.10.1/flink-1.10.1-bin-scala_2.12.tgz";
+ asc_url:
"https://downloads.apache.org/flink/flink-1.10.1/flink-1.10.1-bin-scala_2.12.tgz.asc";
+ sha512_url:
"https://downloads.apache.org/flink/flink-1.10.1/flink-1.10.1-bin-scala_2.12.tgz.sha512";
source_release:
- name: "Apache Flink 1.10.0"
- id: "1100-download-source"
- url:
"https://www.apache.org/dyn/closer.lua/flink/flink-1.10.0/flink-1.10.0-src.tgz";
- asc_url:
"https://downloads.apache.org/flink/flink-1.10.0/flink-1.10.0-src.tgz.asc";
- sha512_url:
"https://downloads.apache.org/flink/flink-1.10.0/flink-1.10.0-src.tgz.sha512";
+ name: "Apache Flink 1.10.1"
+ id: "1101-download-source"
+ url:
"https://www.apache.org/dyn/closer.lua/flink/flink-1.10.1/flink-1.10.1-src.tgz";
+ asc_url:
"https://downloads.apache.org/flink/flink-1.10.1/flink-1.10.1-src.tgz.asc";
+ sha512_url:
"https://downloads.apache.org/flink/flink-1.10.1/flink-1.10.1-src.tgz.sha512";
optional_components:
-
name: "Avro SQL Format"
category: "SQL Formats"
scala_dependent: false
- id: 1100-sql-format-avro
- url:
https://repo.maven.apache.org/maven2/org/apache/flink/flink-avro/1.10.0/flink-avro-1.10.0.jar
- asc_url:
https://repo.maven.apache.org/maven2/org/apache/flink/flink-avro/1.10.0/flink-avro-1.10.0.jar.asc
- sha_url:
https://repo.maven.apache.org/maven2/org/apache/flink/flink-avro/1.10.0/flink-avro-1.10.0.jar.sha1
+ id: 1101-sql-format-avro
+ url:
https://repo.maven.apache.org/maven2/org/apache/flink/flink-avro/1.10.1/flink-avro-1.10.1.jar
+ asc_url:
https://repo.maven.apache.org/maven2/org/apache/flink/flink-avro/1.10.1/flink-avro-1.10.1.jar.asc
+ sha_url:
https://repo.maven.apache.org/maven2/org/apache/flink/flink-avro/1.10.1/flink-avro-1.10.1.jar.sha1
-
name: "CSV SQL Format"
category: "SQL Formats"
scala_dependent: false
- id: 1100-sql-format-csv
- url:
https://repo.maven.apache.org/maven2/org/apache/flink/flink-csv/1.10.0/flink-csv-1.10.0.jar
- asc_url:
https://repo.maven.apache.org/maven2/org/apache/flink/flink-csv/1.10.0/flink-csv-1.10.0.jar.asc
- sha_url:
https://repo.maven.apache.org/maven2/org/apache/flink/flink-csv/1.10.0/flink-csv-1.10.0.jar.sha1
+ id: 1101-sql-format-csv
+ url:
https://repo.maven.apache.org/maven2/org/apache/flink/flink-csv/1.10.1/flink-csv-1.10.1.jar
+ asc_url:
https://repo.maven.apache.org/maven2/org/apache/flink/flink-csv/1.10.1/flink-csv-1.10.1.jar.asc
+ sha_url:
https://repo.maven.apache.org/maven2/org/apache/flink/flink-csv/1.10.1/flink-csv-1.10.1.jar.sha1
-
name: "JSON SQL Format"
category: "SQL Formats"
scala_dependent: false
- id: 1100-sql-format-json
- url:
https://repo.maven.apache.org/maven2/org/apache/flink/flink-json/1.10.0/flink-json-1.10.0.jar
- asc_url:
https://repo.maven.apache.org/maven2/org/apache/flink/flink-json/1.10.0/flink-json-1.10.0.jar.asc
- sha_url:
https://repo.maven.apache.org/maven2/org/apache/flink/flink-json/1.10.0/flink-json-1.10.0.jar.sha1
+ id: 1101-sql-format-json
+ url:
https://repo.maven.apache.org/maven2/org/apache/flink/flink-json/1.10.1/flink-json-1.10.1.jar
+ asc_url:
https://repo.maven.apache.org/maven2/org/apache/flink/flink-json/1.10.1/flink-json-1.10.1.jar.asc
+ sha_url:
https://repo.maven.apache.org/maven2/org/apache/flink/flink-json/1.10.1/flink-json-1.10.1.jar.sha1
-
version_short: 1.9
binary_release:
@@ -194,6 +194,10 @@ release_archive:
flink:
-
version_short: "1.10"
+ version_long: 1.10.1
+ release_date: 2020-05-12
+ -
+ version_short: "1.10"
version_long: 1.10.0
release_date: 2020-02-11
-
diff --git a/_posts/2020-05-12-release-1.10.1.md
b/_posts/2020-05-12-release-1.10.1.md
new file mode 100644
index 0000000..bcfe4be
--- /dev/null
+++ b/_posts/2020-05-12-release-1.10.1.md
@@ -0,0 +1,382 @@
+---
+layout: post
+title: "Apache Flink 1.10.1 Released"
+date: 2020-05-12 12:00:00
+categories: news
+authors:
+- liyu:
+ name: "Yu Li"
+ twitter: "LiyuApache"
+---
+
+The Apache Flink community released the first bugfix version of the Apache
Flink 1.10 series.
+
+This release includes 158 fixes and minor improvements for Flink 1.10.0. The
list below includes a detailed list of all fixes and improvements.
+
+We highly recommend all users to upgrade to Flink 1.10.1.
+
+Updated Maven dependencies:
+
+```xml
+<dependency>
+ <groupId>org.apache.flink</groupId>
+ <artifactId>flink-java</artifactId>
+ <version>1.10.1</version>
+</dependency>
+<dependency>
+ <groupId>org.apache.flink</groupId>
+ <artifactId>flink-streaming-java_2.11</artifactId>
+ <version>1.10.1</version>
+</dependency>
+<dependency>
+ <groupId>org.apache.flink</groupId>
+ <artifactId>flink-clients_2.11</artifactId>
+ <version>1.10.1</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-14126'>FLINK-14126</a>] -
Elasticsearch Xpack Machine Learning doesn't support ARM
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-15143'>FLINK-15143</a>] -
Create document for FLIP-49 TM memory model and configuration guide
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-15561'>FLINK-15561</a>] -
Unify Kerberos credentials checking
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-15790'>FLINK-15790</a>] -
Make FlinkKubeClient and its implementations asynchronous
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-15817'>FLINK-15817</a>] -
Kubernetes Resource leak while deployment exception happens
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16049'>FLINK-16049</a>] -
Remove outdated "Best Practices" section from Application
Development Section
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16131'>FLINK-16131</a>] -
Translate "Amazon S3" page of "File Systems" into
Chinese
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16389'>FLINK-16389</a>] -
Bump Kafka 0.10 to 0.10.2.2
+</li>
+</ul>
+
+<h2> Bug
+</h2>
+<ul>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-2336'>FLINK-2336</a>] -
ArrayIndexOufOBoundsException in TypeExtractor when mapping
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-10918'>FLINK-10918</a>] -
incremental Keyed state with RocksDB throws cannot create directory error
in windows
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-11193'>FLINK-11193</a>] -
Rocksdb timer service factory configuration option is not settable per job
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-13483'>FLINK-13483</a>] -
PrestoS3FileSystemITCase.testDirectoryListing fails on Travis
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-14038'>FLINK-14038</a>] -
ExecutionGraph deploy failed due to akka timeout
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-14311'>FLINK-14311</a>] -
Streaming File Sink end-to-end test failed on Travis
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-14316'>FLINK-14316</a>] -
Stuck in "Job leader ... lost leadership" error
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-15417'>FLINK-15417</a>] -
Remove the docker volume or mount when starting Mesos e2e cluster
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-15669'>FLINK-15669</a>] -
SQL client can't cancel flink job
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-15772'>FLINK-15772</a>] -
Shaded Hadoop S3A with credentials provider end-to-end test fails on travis
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-15811'>FLINK-15811</a>] -
StreamSourceOperatorWatermarksTest.testNoMaxWatermarkOnAsyncCancel fails on
Travis
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-15812'>FLINK-15812</a>] -
HistoryServer archiving is done in Dispatcher main thread
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-15838'>FLINK-15838</a>] -
Dangling CountDownLatch.await(timeout)
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-15852'>FLINK-15852</a>] -
Job is submitted to the wrong session cluster
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-15904'>FLINK-15904</a>] -
Make Kafka Consumer work with activated "disableGenericTypes()"
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-15936'>FLINK-15936</a>] -
TaskExecutorTest#testSlotAcceptance deadlocks
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-15953'>FLINK-15953</a>] -
Job Status is hard to read for some Statuses
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16013'>FLINK-16013</a>] -
List and map config options could not be parsed correctly
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16014'>FLINK-16014</a>] -
S3 plugin ClassNotFoundException SAXParser
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16025'>FLINK-16025</a>] -
Service could expose blob server port mismatched with JM Container
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16026'>FLINK-16026</a>] -
Travis failed due to python setup
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16047'>FLINK-16047</a>] -
Blink planner produces wrong aggregate results with state clean up
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16067'>FLINK-16067</a>] -
Flink's CalciteParser swallows error position information
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16068'>FLINK-16068</a>] -
table with keyword-escaped columns and computed_column_expression columns
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16070'>FLINK-16070</a>] -
Blink planner can not extract correct unique key for UpsertStreamTableSink
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16108'>FLINK-16108</a>] -
StreamSQLExample is failed if running in blink planner
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16111'>FLINK-16111</a>] -
Kubernetes deployment does not respect "taskmanager.cpu.cores".
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16113'>FLINK-16113</a>] -
ExpressionReducer shouldn't escape the reduced string value
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16115'>FLINK-16115</a>] -
Aliyun oss filesystem could not work with plugin mechanism
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16139'>FLINK-16139</a>] -
Co-location constraints are not reset on task recovery in DefaultScheduler
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16161'>FLINK-16161</a>] -
Statistics zero should be unknown in HiveCatalog
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16170'>FLINK-16170</a>] -
SearchTemplateRequest ClassNotFoundException when use
flink-sql-connector-elasticsearch7
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16220'>FLINK-16220</a>] -
JsonRowSerializationSchema throws cast exception : NullNode cannot be cast
to ArrayNode
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16231'>FLINK-16231</a>] -
Hive connector is missing jdk.tools exclusion against Hive 2.x.x
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16234'>FLINK-16234</a>] -
Fix unstable cases in StreamingJobGraphGeneratorTest
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16241'>FLINK-16241</a>] -
Remove the license and notice file in flink-ml-lib module on release-1.10
branch
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16242'>FLINK-16242</a>] -
BinaryGeneric serialization error cause checkpoint failure
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16262'>FLINK-16262</a>] -
Class loader problem with FlinkKafkaProducer.Semantic.EXACTLY_ONCE and
usrlib directory
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16269'>FLINK-16269</a>] -
Generic type can not be matched when convert table to stream.
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16281'>FLINK-16281</a>] -
parameter 'maxRetryTimes' can not work in JDBCUpsertTableSink
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16301'>FLINK-16301</a>] -
Annoying "Cannot find FunctionDefinition" messages with SQL for
f_proctime or =
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16308'>FLINK-16308</a>] -
SQL connector download links are broken
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16313'>FLINK-16313</a>] -
flink-state-processor-api: surefire execution unstable on Azure
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16331'>FLINK-16331</a>] -
Remove source licenses for old WebUI
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16345'>FLINK-16345</a>] -
Computed column can not refer time attribute column
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16360'>FLINK-16360</a>] -
connector on hive 2.0.1 don't support type conversion from STRING to
VARCHAR
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16371'>FLINK-16371</a>] -
HadoopCompressionBulkWriter fails with
'java.io.NotSerializableException'
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16373'>FLINK-16373</a>] -
EmbeddedLeaderService: IllegalStateException: The RPC connection is already
closed
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16413'>FLINK-16413</a>] -
Reduce hive source parallelism when limit push down
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16414'>FLINK-16414</a>] -
create udaf/udtf function using sql casuing ValidationException: SQL
validation failed. null
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16433'>FLINK-16433</a>] -
TableEnvironmentImpl doesn't clear buffered operations when it fails to
translate the operation
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16435'>FLINK-16435</a>] -
Replace since decorator with versionadd to mark the version an API was
introduced
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16467'>FLINK-16467</a>] -
MemorySizeTest#testToHumanReadableString() is not portable
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16526'>FLINK-16526</a>] -
Fix exception when computed column expression references a keyword column
name
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16541'>FLINK-16541</a>] -
Document of table.exec.shuffle-mode is incorrect
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16550'>FLINK-16550</a>] -
HadoopS3* tests fail with NullPointerException exceptions
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16560'>FLINK-16560</a>] -
Forward Configuration in PackagedProgramUtils#getPipelineFromProgram
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16567'>FLINK-16567</a>] -
Get the API error of the StreamQueryConfig on Page "Query
Configuration"
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16573'>FLINK-16573</a>] -
Kinesis consumer does not properly shutdown RecordFetcher threads
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16576'>FLINK-16576</a>] -
State inconsistency on restore with memory state backends
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16626'>FLINK-16626</a>] -
Prevent REST handler from being closed more than once
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16632'>FLINK-16632</a>] -
SqlDateTimeUtils#toSqlTimestamp(String, String) may yield incorrect result
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16635'>FLINK-16635</a>] -
Incompatible okio dependency in flink-metrics-influxdb module
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16646'>FLINK-16646</a>] -
flink read orc file throw a NullPointerException
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16647'>FLINK-16647</a>] -
Miss file extension when inserting to hive table with compression
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16652'>FLINK-16652</a>] -
BytesColumnVector should init buffer in Hive 3.x
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16662'>FLINK-16662</a>] -
Blink Planner failed to generate JobGraph for POJO DataStream converting to
Table (Cannot determine simple type name)
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16664'>FLINK-16664</a>] -
Unable to set DataStreamSource parallelism to default (-1)
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16675'>FLINK-16675</a>] -
TableEnvironmentITCase. testClearOperation fails on travis nightly build
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16684'>FLINK-16684</a>] -
StreamingFileSink builder does not work with Scala
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16696'>FLINK-16696</a>] -
Savepoint trigger documentation is insufficient
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16703'>FLINK-16703</a>] -
AkkaRpcActor state machine does not record transition to terminating state.
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16705'>FLINK-16705</a>] -
LocalExecutor tears down MiniCluster before client can retrieve JobResult
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16718'>FLINK-16718</a>] -
KvStateServerHandlerTest leaks Netty ByteBufs
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16727'>FLINK-16727</a>] -
Fix cast exception when having time point literal as parameters
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16732'>FLINK-16732</a>] -
Failed to call Hive UDF with constant return value
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16740'>FLINK-16740</a>] -
OrcSplitReaderUtil::logicalTypeToOrcType fails to create decimal type with
precision < 10
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16759'>FLINK-16759</a>] -
HiveModuleTest failed to compile on release-1.10
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16767'>FLINK-16767</a>] -
Failed to read Hive table with RegexSerDe
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16771'>FLINK-16771</a>] -
NPE when filtering by decimal column
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16821'>FLINK-16821</a>] -
Run Kubernetes test failed with invalid named "minikube"
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16822'>FLINK-16822</a>] -
The config set by SET command does not work
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16825'>FLINK-16825</a>] -
PrometheusReporterEndToEndITCase should rely on path returned by
DownloadCache
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16836'>FLINK-16836</a>] -
Losing leadership does not clear rpc connection in JobManagerLeaderListener
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16860'>FLINK-16860</a>] -
Failed to push filter into OrcTableSource when upgrading to 1.9.2
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16888'>FLINK-16888</a>] -
Re-add jquery license file under "/licenses"
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16901'>FLINK-16901</a>] -
Flink Kinesis connector NOTICE should have contents of AWS KPL's
THIRD_PARTY_NOTICES file manually merged in
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16913'>FLINK-16913</a>] -
ReadableConfigToConfigurationAdapter#getEnum throws
UnsupportedOperationException
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16916'>FLINK-16916</a>] -
The logic of NullableSerializer#copy is wrong
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16944'>FLINK-16944</a>] -
Compile error in. DumpCompiledPlanTest and PreviewPlanDumpTest
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16980'>FLINK-16980</a>] -
Python UDF doesn't work with protobuf 3.6.1
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16981'>FLINK-16981</a>] -
flink-runtime tests are crashing the JVM on Java11 because of PowerMock
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-17062'>FLINK-17062</a>] -
Fix the conversion from Java row type to Python row type
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-17066'>FLINK-17066</a>] -
Update pyarrow version bounds less than 0.14.0
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-17093'>FLINK-17093</a>] -
Python UDF doesn't work when the input column is from composite field
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-17107'>FLINK-17107</a>] -
CheckpointCoordinatorConfiguration#isExactlyOnce() is inconsistent with
StreamConfig#getCheckpointMode()
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-17114'>FLINK-17114</a>] -
When the pyflink job runs in local mode and the command "python"
points to Python 2.7, the startup of the Python UDF worker will fail.
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-17124'>FLINK-17124</a>] -
The PyFlink Job runs into infinite loop if the Python UDF imports job code
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-17152'>FLINK-17152</a>] -
FunctionDefinitionUtil generate wrong resultType and acc type of
AggregateFunctionDefinition
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-17308'>FLINK-17308</a>] -
ExecutionGraphCache cachedExecutionGraphs not cleanup cause OOM Bug
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-17313'>FLINK-17313</a>] -
Validation error when insert decimal/varchar with precision into sink using
TypeInformation of row
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-17334'>FLINK-17334</a>] -
Flink does not support HIVE UDFs with primitive return types
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-17338'>FLINK-17338</a>] -
LocalExecutorITCase.testBatchQueryCancel test timeout
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-17359'>FLINK-17359</a>] -
Entropy key is not resolved if flink-s3-fs-hadoop is added as a plugin
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-17403'>FLINK-17403</a>] -
Fix invalid classpath in BashJavaUtilsITCase
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-17471'>FLINK-17471</a>] -
Move LICENSE and NOTICE files to root directory of python distribution
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-17483'>FLINK-17483</a>] -
Update flink-sql-connector-elasticsearch7 NOTICE file to correctly reflect
bundled dependencies
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-17496'>FLINK-17496</a>] -
Performance regression with amazon-kinesis-producer 0.13.1 in Flink 1.10.x
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-17499'>FLINK-17499</a>] -
LazyTimerService used to register timers via State Processing API
incorrectly mixes event time timers with processing time timers
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-17514'>FLINK-17514</a>] -
TaskCancelerWatchdog does not kill TaskManager
+</li>
+</ul>
+
+<h2> New Feature
+</h2>
+<ul>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-17275'>FLINK-17275</a>] -
Add core training exercises
+</li>
+</ul>
+
+<h2> Improvement
+</h2>
+<ul>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-9656'>FLINK-9656</a>] -
Environment java opts for flink run
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-15094'>FLINK-15094</a>] -
Warning about using private constructor of java.nio.DirectByteBuffer in
Java 11
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-15584'>FLINK-15584</a>] -
Give nested data type of ROWs in ValidationException
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-15616'>FLINK-15616</a>] -
Move boot error messages from python-udf-boot.log to taskmanager's log
file
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-15989'>FLINK-15989</a>] -
Rewrap OutOfMemoryError in allocateUnpooledOffHeap with better message
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16018'>FLINK-16018</a>] -
Improve error reporting when submitting batch job (instead of
AskTimeoutException)
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16125'>FLINK-16125</a>] -
Make zookeeper.connect optional for Kafka connectors
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16167'>FLINK-16167</a>] -
Update documentation about python shell execution
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16191'>FLINK-16191</a>] -
Improve error message on Windows when RocksDB Paths are too long
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16280'>FLINK-16280</a>] -
Fix sample code errors in the documentation about elasticsearch connector
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16288'>FLINK-16288</a>] -
Setting the TTL for discarding task pods on Kubernetes.
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16293'>FLINK-16293</a>] -
Document using plugins in Kubernetes
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16343'>FLINK-16343</a>] -
Improve exception message when reading an unbounded source in batch mode
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16406'>FLINK-16406</a>] -
Increase default value for JVM Metaspace to minimise its OutOfMemoryError
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16538'>FLINK-16538</a>] -
Restructure Python Table API documentation
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16604'>FLINK-16604</a>] -
Column key in JM configuration is too narrow
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16683'>FLINK-16683</a>] -
Remove scripts for starting Flink on Windows
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16697'>FLINK-16697</a>] -
Disable JMX rebinding
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16763'>FLINK-16763</a>] -
Should not use BatchTableEnvironment for Python UDF in the document of
flink-1.10
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16772'>FLINK-16772</a>] -
Bump derby to 10.12.1.1+ or exclude it
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16790'>FLINK-16790</a>] -
enables the interpretation of backslash escapes
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16862'>FLINK-16862</a>] -
Remove example url in quickstarts
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16874'>FLINK-16874</a>] -
Respect the dynamic options when calculating memory options in
taskmanager.sh
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16942'>FLINK-16942</a>] -
ES 5 sink should allow users to select netty transport client
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-17065'>FLINK-17065</a>] -
Add documentation about the Python versions supported for PyFlink
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-17125'>FLINK-17125</a>] -
Add a Usage Notes Page to Answer Common Questions Encountered by PyFlink
Users
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-17254'>FLINK-17254</a>] -
Improve the PyFlink documentation and examples to use SQL DDL for
source/sink definition
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-17276'>FLINK-17276</a>] -
Add checkstyle to training exercises
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-17277'>FLINK-17277</a>] -
Apply IntelliJ recommendations to training exercises
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-17278'>FLINK-17278</a>] -
Add Travis to the training exercises
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-17279'>FLINK-17279</a>] -
Use gradle build scans for training exercises
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-17316'>FLINK-17316</a>] -
Have HourlyTips solutions use TumblingEventTimeWindows.of
+</li>
+</ul>
+
+<h2> Task
+</h2>
+<ul>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-15741'>FLINK-15741</a>] -
Fix TTL docs after enabling RocksDB compaction filter by default (needs
Chinese translation)
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-15933'>FLINK-15933</a>] -
update content of how generic table schema is stored in hive via HiveCatalog
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-15991'>FLINK-15991</a>] -
Create Chinese documentation for FLIP-49 TM memory model
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16004'>FLINK-16004</a>] -
Exclude flink-rocksdb-state-memory-control-test jars from the dist
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16454'>FLINK-16454</a>] -
Update the copyright year in NOTICE files
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16530'>FLINK-16530</a>] -
Add documentation about "GROUPING SETS" and "CUBE"
support in streaming mode
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16592'>FLINK-16592</a>] -
The doc of Streaming File Sink has a mistake of grammar
+</li>
+</ul>
+
