You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ja...@apache.org on 2020/06/17 02:07:07 UTC
[flink] branch master updated (4a775af -> e2db1dc)
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 4a775af [hotfix][docs] Fix broken link
add 7ce45b5 [FLINK-18086][tests] Support to set standard inputs for AutoClosableProcess
add 06d96b5 [FLINK-18086][e2e] Migrate SQLClientKafkaITCase to use DDL and new options to create tables
add ca1f764 [FLINK-18302][sql-cli] Fix SQL client uses wrong class loader when execute INSERT statements
add e2db1dc [FLINK-18303][filesystem][hive] Fix Filesystem connector doesn't flush part files after rolling interval
No new revisions were added by this update.
Summary of changes:
docs/dev/table/connectors/filesystem.md | 13 +-
docs/dev/table/connectors/filesystem.zh.md | 13 +-
.../flink/connectors/hive/HiveTableSink.java | 8 +-
.../flink-end-to-end-tests-common-kafka/pom.xml | 17 ---
.../tests/util/kafka/SQLClientKafkaITCase.java | 159 +++++++++------------
.../src/test/resources/kafka_e2e.sql | 75 ++++++++++
.../test/resources/kafka_json_source_schema.yaml | 138 ------------------
.../flink/tests/util/AutoClosableProcess.java | 53 +++++--
.../flink/tests/util/flink/FlinkDistribution.java | 8 +-
.../flink/tests/util/flink/SQLJobSubmission.java | 24 ++--
.../table/client/gateway/local/LocalExecutor.java | 34 +++--
.../client/gateway/local/LocalExecutorITCase.java | 30 ++--
.../gateway/utils/TestUserClassLoaderJar.java | 90 ++++++++++++
.../flink/table/filesystem/FileSystemOptions.java | 11 +-
.../table/filesystem/FileSystemTableSink.java | 14 +-
15 files changed, 382 insertions(+), 305 deletions(-)
create mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/test/resources/kafka_e2e.sql
delete mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/test/resources/kafka_json_source_schema.yaml
create mode 100644 flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/gateway/utils/TestUserClassLoaderJar.java