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/06/09 09:14:11 UTC

[flink] branch release-1.11 updated (822e01b -> 21ffa8f)

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 822e01b  [FLINK-18050][task][checkpointing] Simplify ChannelStateCheckpointWriter interface
     add 21ffa8f  [FLINK-18181][fs-connector] StreamingFileCommitter should not use fs modification time for proc committer

No new revisions were added by this update.

Summary of changes:
 docs/dev/table/connectors/filesystem.md            |  2 +
 docs/dev/table/connectors/filesystem.zh.md         |  2 +
 .../flink/connectors/hive/HiveTableSink.java       |  6 +-
 .../table/filesystem/FileSystemTableSink.java      | 10 ++-
 .../table/filesystem/PartitionCommitPolicy.java    |  5 +-
 .../filesystem/stream/PartitionCommitTrigger.java  | 63 ++++--------------
 .../stream/PartitionTimeCommitTigger.java          | 40 +++++++++++-
 .../filesystem/stream/ProcTimeCommitTigger.java    | 74 +++++++++++++++-------
 .../filesystem/stream/StreamingFileCommitter.java  | 20 ++++--
 9 files changed, 131 insertions(+), 91 deletions(-)