This is an automated email from the ASF dual-hosted git repository.
1996fanrui pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 8cc54fb6ba5 [FLINK-40018][table] Throw a clear error when a PTF table
argument input cannot satisfy the required changelog mode
new 3a11fddda08 [FLINK-40016][checkpoint] Refactor
getBufferAndAvailability to return BufferAndAvailability directly
new 54707707f72 [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(-)
