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

Posted to commits@flink.apache.org by he...@apache.org on 2020/08/10 10:48:44 UTC

[flink] branch master updated (6d72cc0 -> b8d2ed7)

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

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


    from 6d72cc0  [FLINK-18688][table-planner-blink] Fix binary row writing with incorrect order in ProjectionCodeGenerator by removing for loop optimization
     add b8d2ed7  [FLINK-18766][python] Support add_sink() for Python DataStream API. (#13094)

No new revisions were added by this update.

Summary of changes:
 flink-python/pyflink/datastream/data_stream.py     | 87 +++++++++++++++++++++-
 flink-python/pyflink/datastream/functions.py       | 32 ++++++++
 .../pyflink/datastream/tests/test_data_stream.py   | 67 +++++++++--------
 .../tests/test_stream_execution_environment.py     | 14 ++--
 flink-python/pyflink/datastream/tests/test_util.py | 27 ++-----
 .../python/util/DataStreamTestCollectSink.java     | 18 +++--
 6 files changed, 176 insertions(+), 69 deletions(-)