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/17 09:00:07 UTC

[flink] branch master updated (8044b47 -> 445398c)

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 8044b47  [hoxfix] Fix various typos
     add 445398c  [FLINK-18966][python] Support key_by() on ConnectedStreams for Python DataStream API (#13153)

No new revisions were added by this update.

Summary of changes:
 flink-python/pyflink/datastream/data_stream.py     | 33 ++++++++++++++---
 .../pyflink/datastream/tests/test_data_stream.py   | 42 ++++++++++++++++++++++
 ...eamTwoInputPythonStatelessFunctionOperator.java | 41 ++++++++++++++++++---
 3 files changed, 108 insertions(+), 8 deletions(-)