You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flink.apache.org by lz...@apache.org on 2020/03/27 03:04:25 UTC

[flink] branch master updated (e91bbcf -> 51b1a4f)

This is an automated email from the ASF dual-hosted git repository.

lzljs3620320 pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from e91bbcf  [hotfix][python] Improve the imports to use full path when importing a PyFlink module (#11525)
     add 530943e  [FLINK-16647][hadoop-compatibility] Refactor HadoopUtils to extract a possible Hadoop conf util method
     add 7984d02  [FLINK-16647][hive] Hive connector should read mapred-site.xml
     add 51b1a4f  [FLINK-16647][table-runtime-blink][hive] Miss file extension when inserting to hive table with compression

No new revisions were added by this update.

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 | 22 +++++++++
 .../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, 189 insertions(+), 61 deletions(-)