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/27 08:29:03 UTC

[flink] branch release-1.11 updated (23d4675 -> fe1b533)

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

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


    from 23d4675  [FLINK-17756][table] Drop table/view shouldn't take effect on each other
     add 83c0eab  [FLINK-17934][fs-connector] StreamingFileWriter should set chainingStrategy
     add fe1b533  [FLINK-17934][fs-connector] Add listener to Buckets and remove listener for BucketsBuilder

No new revisions were added by this update.

Summary of changes:
 .../flink/connectors/hive/HiveTableSink.java       |  7 +---
 .../HadoopPathBasedBulkFormatBuilder.java          | 13 ------
 .../sink/filesystem/BucketLifeCycleListener.java   |  4 +-
 .../api/functions/sink/filesystem/Buckets.java     | 12 +++---
 .../sink/filesystem/StreamingFileSink.java         | 18 ---------
 .../sink/filesystem/BucketAssignerITCases.java     |  1 -
 .../api/functions/sink/filesystem/BucketsTest.java | 17 ++++----
 .../sink/filesystem/RollingPolicyTest.java         |  1 -
 .../table/filesystem/FileSystemTableSink.java      | 12 ++----
 .../filesystem/stream/InactiveBucketListener.java  | 46 ----------------------
 .../filesystem/stream/StreamingFileWriter.java     | 30 +++++++++-----
 11 files changed, 41 insertions(+), 120 deletions(-)
 delete mode 100644 flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/filesystem/stream/InactiveBucketListener.java