This is an automated email from the ASF dual-hosted git repository.
fanrui pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 01070e6f605 [FLINK-39275][docs] Fix some issues in the "Performance
Tuning" document (#27893)
new 9ce47b215fc [hotfix][network] Fix
LocalInputChannel.getBuffersInUseCount to include toBeConsumedBuffers
new 3aef0932ded [FLINK-39018][checkpoint] Support LocalInputChannel
checkpoint snapshot for recovered buffers
new cebc174ad5f [FLINK-39018][network] Fix LocalInputChannel priority
event and buffer availability for recovered buffers
new 4f192b33238 [FLINK-39018][checkpoint] Notify PriorityEvent to
downstream task even if it is blocked to ensure the checkpoint barrier can be
handled by downstream task
new d1914c63c95 [FLINK-39018][network] Buffer migration from
RecoveredInputChannel to physical channels
The 5 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:
.../network/partition/PipelinedSubpartition.java | 22 +-
.../partition/consumer/LocalInputChannel.java | 135 ++++++++-
.../consumer/LocalRecoveredInputChannel.java | 8 +-
.../partition/consumer/RecoveredInputChannel.java | 21 +-
.../partition/consumer/RemoteInputChannel.java | 48 ++-
.../consumer/RemoteRecoveredInputChannel.java | 8 +-
.../partition/consumer/SingleInputGate.java | 41 ++-
.../partition/consumer/UnknownInputChannel.java | 7 +-
...editBasedPartitionRequestClientHandlerTest.java | 4 +-
.../netty/PartitionRequestRegistrationTest.java | 4 +-
.../PipelinedSubpartitionWithReadViewTest.java | 74 +++++
.../partition/consumer/InputChannelBuilder.java | 7 +-
.../partition/consumer/LocalInputChannelTest.java | 334 +++++++++++++++++++++
.../consumer/RecoveredInputChannelTest.java | 5 +-
.../partition/consumer/RemoteInputChannelTest.java | 46 +++
.../benchmark/SingleInputGateBenchmarkFactory.java | 7 +-
16 files changed, 731 insertions(+), 40 deletions(-)
