You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by li...@apache.org on 2020/05/13 17:54:30 UTC

[flink-web] 01/03: Add Apache Flink release 1.10.1

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 <li...@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&#39;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 &quot;Best Practices&quot; section from Application Development Section
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-16131'>FLINK-16131</a>] -         Translate &quot;Amazon S3&quot; page of &quot;File Systems&quot; 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 &quot;Job leader ... lost leadership&quot; 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&#39;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 &quot;disableGenericTypes()&quot;
+</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&#39;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 &quot;taskmanager.cpu.cores&quot;.
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-16113'>FLINK-16113</a>] -         ExpressionReducer shouldn&#39;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 &#39;maxRetryTimes&#39; can not work in JDBCUpsertTableSink
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-16301'>FLINK-16301</a>] -         Annoying &quot;Cannot find FunctionDefinition&quot; 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&#39;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 &#39;java.io.NotSerializableException&#39;
+</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&#39;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 &quot;Query Configuration&quot;
+</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 &lt; 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 &quot;minikube&quot;
+</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 &quot;/licenses&quot;
+</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&#39;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&#39;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&#39;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 &quot;python&quot; 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&#39;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 &quot;GROUPING SETS&quot; and &quot;CUBE&quot; 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>
+