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

Posted to commits@flink.apache.org by hx...@apache.org on 2021/02/26 02:06:29 UTC

[flink] branch master updated (6d2a05a -> 1939e9b)

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

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


    from 6d2a05a  [FLINK-21503][tests] Fix unstable UnalignedCheckpointCompatibilityITCase
     add 1939e9b  [FLINK-21114][python] Add ReducingState and corresponding StateDescriptor for Python DataStream API

No new revisions were added by this update.

Summary of changes:
 flink-python/pyflink/datastream/functions.py       | 14 +++++-
 flink-python/pyflink/datastream/state.py           | 49 +++++++++++++++++++-
 .../pyflink/datastream/tests/test_data_stream.py   | 33 +++++++++++++-
 flink-python/pyflink/fn_execution/operations.py    |  6 ++-
 flink-python/pyflink/fn_execution/state_impl.py    | 52 +++++++++++++++++++++-
 5 files changed, 147 insertions(+), 7 deletions(-)