This is an automated email from the ASF dual-hosted git repository.
zhijiang pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 44af789 [FLINK-16350] Support Zookeeper 3.5 in
test_ha_per_job_cluster_datastream.sh
add ed7b0b1 [FLINK-18050][task][checkpointing] Use CloseableIterator to
write ResultSubpartition state
add f2dd4b8 [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
