This is an automated email from the ASF dual-hosted git repository.
jark pushed a change to branch release-1.16
in repository https://gitbox.apache.org/repos/asf/flink.git
from 22086c67a6a [FLINK-29324][Connectors/Kinesis] Fix NPE for Kinesis
connector when closing (#20853)
new 82ab2918e99 [FLINK-29185][hive] Fix ClassNotFoundException for CREATE
TEMPORARY FUNCTION USING JAR with Hive dialect
new 9e16d54b9ea [FLINK-29045][hive] Optimize error message in Flink SQL
Client and Gateway when try to use Hive Dialect
new bff0985aef4 [FLINK-29222][hive] Fix wrong behavior for Hive's load
data inpath
new d4d855a3c08 [FLINK-29191][hive] fix Hive dialect can't get value for
the variables set by set command
The 4 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../delegation/hive/HiveOperationExecutor.java | 15 ++++++----
.../table/planner/delegation/hive/HiveParser.java | 20 ++++++++-----
.../delegation/hive/copy/HiveSetProcessor.java | 21 ++++++++-----
.../hive/parse/HiveParserDDLSemanticAnalyzer.java | 9 ++++--
.../flink/connectors/hive/HiveDialectITCase.java | 35 +++++++++++-----------
.../connectors/hive/HiveDialectQueryITCase.java | 13 ++++++--
.../client/gateway/context/SessionContext.java | 11 +++++++
.../flink-sql-client/src/test/resources/sql/set.q | 24 +++++++++++++++
.../gateway/service/context/SessionContext.java | 34 ++++++++++++++-------
.../flink/table/catalog/FunctionCatalog.java | 2 +-
10 files changed, 130 insertions(+), 54 deletions(-)
