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/05/19 04:37:07 UTC

[flink] branch master updated (3b3ad3d -> 4ba1d37)

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 3b3ad3d  [FLINK-17594][filesystem] Support Hadoop path-based part-file writer
     add 4ba1d37  [FLINK-14255][hive] Integrate mapred record writer to hive streaming sink

No new revisions were added by this update.

Summary of changes:
 flink-connectors/flink-connector-hive/pom.xml      |  7 ++
 .../apache/flink/connectors/hive/HiveOptions.java  |  7 ++
 .../flink/connectors/hive/HiveTableFactory.java    |  2 +
 .../flink/connectors/hive/HiveTableSink.java       | 67 +++++++++++-------
 .../hive/write/HiveBulkWriterFactory.java          | 81 ++++++++++++++++++++++
 .../flink/connectors/hive/HiveTableSinkTest.java   | 53 ++++++++++----
 .../connectors/hive/TableEnvHiveConnectorTest.java | 28 ++++++--
 7 files changed, 205 insertions(+), 40 deletions(-)
 create mode 100644 flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/write/HiveBulkWriterFactory.java