This is an automated email from the ASF dual-hosted git repository.
kkloudas pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from efa4d18 [minor][python] Minor code cleanup
add c619a18 [FLINK-19510][sink][fs] Support processing time policicies in
FileSink
No new revisions were added by this update.
Summary of changes:
.../apache/flink/connector/file/sink/FileSink.java | 31 +++++-
.../connector/file/sink/writer/FileWriter.java | 39 ++++++-
.../file/sink/writer/FileWriterBucket.java | 23 +++-
.../file/sink/writer/FileWriterBucketTest.java | 49 +++++++--
.../connector/file/sink/writer/FileWriterTest.java | 118 ++++++++++++++++++++-
.../functions/sink/filesystem/RollingPolicy.java | 2 +-
6 files changed, 242 insertions(+), 20 deletions(-)
