This is an automated email from the ASF dual-hosted git repository.
dianfu pushed a change to branch release-1.16
in repository https://gitbox.apache.org/repos/asf/flink.git
from e8507e2addb [FLINK-31305] fix error propagation bug in WriterCallback
and use TestSinkInitContext general purpose sink testing tool
add 01cdaee25cd [FLINK-31690][python] Fix KeyedCoProcessFunction to set
the current key into the context
No new revisions were added by this update.
Summary of changes:
flink-python/pyflink/datastream/tests/test_data_stream.py | 9 +++++----
.../pyflink/fn_execution/datastream/process/operations.py | 4 +++-
2 files changed, 8 insertions(+), 5 deletions(-)
