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 2021/02/23 10:25:23 UTC

[flink] branch master updated (0235933 -> 6e5ae63)

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 0235933  [FLINK-19608][table-planner-blink] Introduce TVF based window aggregate exec node
     add 6e5ae63  [FLINK-19945][filesystem] Support sink parallelism configuration for FileSystem connector

No new revisions were added by this update.

Summary of changes:
 .../content.zh/docs/connectors/table/filesystem.md |  33 ++++-
 docs/content/docs/connectors/table/filesystem.md   |  31 ++++
 .../flink/connectors/hive/HiveTableSink.java       |   8 +-
 .../table/filesystem/FileSystemTableSinkTest.java  | 159 +++++++++++++++++++++
 ...stFileSystemTableSinkWithParallelismInBatch.out |  45 ++++++
 ...stemTableSinkWithParallelismInStreamingSql0.out |  56 ++++++++
 ...stemTableSinkWithParallelismInStreamingSql1.out |  78 ++++++++++
 .../flink/table/planner/utils/TableTestBase.scala  |   4 +
 .../flink/table/filesystem/FileSystemOptions.java  |   3 +
 .../table/filesystem/FileSystemTableFactory.java   |   1 +
 .../table/filesystem/FileSystemTableSink.java      |  45 +++++-
 .../table/filesystem/stream/StreamingSink.java     |  12 +-
 .../filesystem/TestRowDataCsvInputFormat.java      |  16 +--
 pom.xml                                            |   2 +-
 14 files changed, 462 insertions(+), 31 deletions(-)
 create mode 100644 flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/filesystem/FileSystemTableSinkTest.java
 create mode 100644 flink-table/flink-table-planner-blink/src/test/resources/explain/filesystem/testFileSystemTableSinkWithParallelismInBatch.out
 create mode 100644 flink-table/flink-table-planner-blink/src/test/resources/explain/filesystem/testFileSystemTableSinkWithParallelismInStreamingSql0.out
 create mode 100644 flink-table/flink-table-planner-blink/src/test/resources/explain/filesystem/testFileSystemTableSinkWithParallelismInStreamingSql1.out