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

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


    from 4753030c886 [FLINK-39384][python] Fix Java errors when trying to load 
or compile a CompiledPlan
     new 0a2040c8085 [FLINK-40016][checkpoint] Refactor 
getBufferAndAvailability to return BufferAndAvailability directly
     new ad50a307283 [FLINK-40016][checkpoint] Prevent recovered buffers from 
being persisted twice in LocalInputChannel

The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.


Summary of changes:
 .../partition/consumer/LocalInputChannel.java      | 34 ++++++++-------
 .../partition/consumer/LocalInputChannelTest.java  | 48 ++++++++++++++++++++++
 2 files changed, 64 insertions(+), 18 deletions(-)

Reply via email to