This is an automated email from the ASF dual-hosted git repository.
zhijiang pushed a change to branch release-1.11
in repository https://gitbox.apache.org/repos/asf/flink.git.
from ab6cf40 [FLINK-18130][hive][fs-connector] File name conflict for
different jobs in filesystem/hive sink ()
add a233c0f [FLINK-18050][task][checkpointing] Use CloseableIterator to
write ResultSubpartition state
add 822e01b [FLINK-18050][task][checkpointing] Simplify
ChannelStateCheckpointWriter interface
No new revisions were added by this update.
Summary of changes:
.../channel/ChannelStateCheckpointWriter.java | 16 +++--
.../channel/ChannelStateWriteRequest.java | 22 +++++--
.../checkpoint/channel/ChannelStateWriterImpl.java | 23 +-------
...ChannelStateWriteRequestDispatcherImplTest.java | 69 ++++++++++++++++++++++
.../ChannelStateWriteRequestDispatcherTest.java | 2 +-
5 files changed, 94 insertions(+), 38 deletions(-)
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriteRequestDispatcherImplTest.java
