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

Posted to commits@flink.apache.org by di...@apache.org on 2021/03/31 15:44:50 UTC

[flink] branch master updated (dd1d187 -> 0bf6891)

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

dianfu pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from dd1d187  [hotfix][network] Recycle all buffers before failing releaseAllBuffers
     add 0bf6891  [FLINK-22070][python] Support FileSink in PyFlink DataStream API

No new revisions were added by this update.

Summary of changes:
 flink-python/pyflink/common/serialization.py       |  36 ++-
 flink-python/pyflink/datastream/connectors.py      | 269 +++++++++++++++------
 flink-python/pyflink/datastream/data_stream.py     |  13 +
 .../pyflink/datastream/tests/test_connectors.py    |  63 ++++-
 ...st_stream_execution_environment_completeness.py |   2 +-
 5 files changed, 281 insertions(+), 102 deletions(-)