You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flink.apache.org by kk...@apache.org on 2019/09/23 09:44:35 UTC

[flink] branch master updated (8155d46 -> adfe011)

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 8155d46  [FLINK-14150][python] Clean up the __pycache__ directories and other empty directories in flink-python source code folder before packaging.
     add adfe011  [FLINK-13864][fs-connector] Make StreamingFileSink extensible

No new revisions were added by this update.

Summary of changes:
 .../sink/filesystem/StreamingFileSink.java         | 180 ++++++++++++---------
 .../functions/sink/filesystem/BulkWriterTest.java  |  80 ++++++++-
 .../filesystem/LocalStreamingFileSinkTest.java     |  62 +++++++
 .../api/functions/sink/filesystem/TestUtils.java   | 139 ++++++++++++++--
 4 files changed, 367 insertions(+), 94 deletions(-)