This is an automated email from the ASF dual-hosted git repository.

gaoyunhaii pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from 9247bf2  [FLINK-23946][clients] Dispatcher in application mode should 
be able to recover after losing and regaining leadership.
     add 4d9ea35  [FLINK-25105][checkpoint] Enables final checkpoint by default

No new revisions were added by this update.

Summary of changes:
 .../dev/datastream/fault-tolerance/checkpointing.md | 21 +++++++++++++++------
 docs/content/docs/internals/task_lifecycle.md       |  6 +++++-
 .../execution_checkpointing_configuration.html      |  2 +-
 .../sink/ElasticsearchSinkBaseITCase.java           |  6 +-----
 .../flink/connector/kafka/sink/KafkaSinkITCase.java |  9 ++-------
 .../environment/ExecutionCheckpointingOptions.java  |  2 +-
 ...utStreamTaskChainedSourcesCheckpointingTest.java |  6 ------
 .../runtime/tasks/MultipleInputStreamTaskTest.java  |  6 ------
 .../runtime/tasks/SourceStreamTaskTest.java         | 11 +----------
 .../tasks/StreamTaskFinalCheckpointsTest.java       | 21 +--------------------
 .../streaming/runtime/tasks/StreamTaskTest.java     | 21 ++-------------------
 .../operators/lifecycle/BoundedSourceITCase.java    |  3 +--
 .../lifecycle/PartiallyFinishedSourcesITCase.java   |  3 +--
 .../flink/test/checkpointing/RescalingITCase.java   |  1 -
 14 files changed, 31 insertions(+), 87 deletions(-)

Reply via email to