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