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(-)