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