This is an automated email from the ASF dual-hosted git repository.
pnowojski pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 91a0c8c [hotfix] Remove throws exception clause from
DefaultJobLeaderService#removeJob
add f1d6336 [FLINK-17552][network] Do not cache InputChannels in
UnionInputGate
add 552d84c [hotfix][network] Improve error message in
ChannelStateWriterImpl
add 35aea92 [hotfix][network] Add debug message marking end of output
recovery for unaligned checkpoints
No new revisions were added by this update.
Summary of changes:
.../checkpoint/channel/ChannelStateWriterImpl.java | 15 ++++++++++-
.../io/network/partition/ResultPartition.java | 1 +
.../network/partition/consumer/UnionInputGate.java | 19 ++++++-------
.../partition/consumer/UnionInputGateTest.java | 31 ++++++++++++++++++++++
4 files changed, 56 insertions(+), 10 deletions(-)
