This is an automated email from the ASF dual-hosted git repository.
lzljs3620320 pushed a change to branch release-1.10
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 2e96e49 [FLINK-16170][elasticsearch] Fix SearchTemplateRequest
ClassNotFoundException when using flink-sql-connector-elasticsearch7
new d33c0eb [FLINK-16647][hadoop-compatibility] Refactor HadoopUtils to
extract a possible Hadoop conf util method
new fd9d68f [FLINK-16647][hive] Hive connector should read mapred-site.xml
new 6758ee3 [FLINK-16647][table-runtime-blink][hive] Miss file extension
when inserting to hive table with compression
The 3 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:
.../connectors/hive/HiveOutputFormatFactory.java | 17 ++++---
.../flink/connectors/hive/HiveTableSink.java | 20 +++++++-
.../flink/table/catalog/hive/HiveCatalog.java | 16 ++++++-
.../flink/table/catalog/hive/client/HiveShim.java | 8 +++-
.../table/catalog/hive/client/HiveShimV100.java | 21 ++++++---
.../table/catalog/hive/client/HiveShimV110.java | 23 +++++++---
.../hive/HiveOutputFormatFactoryTest.java | 5 +-
.../connectors/hive/TableEnvHiveConnectorTest.java | 36 +++++++++++++++
.../hive/factories/HiveCatalogFactoryTest.java | 25 +++++++---
.../api/java/hadoop/mapred/utils/HadoopUtils.java | 53 +++++++++++++---------
.../sink/filesystem/OutputFileConfig.java | 4 +-
.../table/filesystem/FileSystemOutputFormat.java | 18 ++++++--
.../table/filesystem/PartitionTempFileManager.java | 18 ++++++--
13 files changed, 203 insertions(+), 61 deletions(-)
