This is an automated email from the ASF dual-hosted git repository.
jark pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from c4b042f [FLINK-21614][sql-client] Migrate tests to CliClientITCase
and fix bugs
add e9fc926 [FLINK-19944][hive] Support sink parallelism configuration
for Hive connector
No new revisions were added by this update.
Summary of changes:
.../content.zh/docs/connectors/table/filesystem.md | 4 +-
docs/content/docs/connectors/table/filesystem.md | 6 +--
.../connectors/hive/HiveDynamicTableFactory.java | 8 ++-
.../flink/connectors/hive/HiveTableSink.java | 28 ++++++++---
.../flink/connectors/hive/HiveTableSinkITCase.java | 49 ++++++++++++++++++
.../testHiveTableSinkWithParallelismInBatch.out | 58 ++++++++++++++++++++++
...testHiveTableSinkWithParallelismInStreaming.out | 58 ++++++++++++++++++++++
7 files changed, 197 insertions(+), 14 deletions(-)
create mode 100644
flink-connectors/flink-connector-hive/src/test/resources/explain/testHiveTableSinkWithParallelismInBatch.out
create mode 100644
flink-connectors/flink-connector-hive/src/test/resources/explain/testHiveTableSinkWithParallelismInStreaming.out
