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/07/13 11:37:36 UTC

[flink] branch release-1.13 updated (2c455f3 -> c1f30ee)

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

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


    from 2c455f3  [FLINK-22766][connector/kafka] Report offsets and Kafka consumer metrics in Flink metric group
     add c1f30ee  [FLINK-23368][python] Fix the wrong mapping of state cache in PyFlink

No new revisions were added by this update.

Summary of changes:
 .../pyflink/datastream/tests/test_data_stream.py   | 44 ++++++++++++++--------
 flink-python/pyflink/fn_execution/state_impl.py    |  4 +-
 2 files changed, 31 insertions(+), 17 deletions(-)