You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by pn...@apache.org on 2020/06/22 15:52:50 UTC
[flink] branch master updated (6d52d04 -> 755025c)
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 6d52d04 [FLINK-18372][runtime] Fix NPE problem when a slot is offered before JM is connected to a RM
add 59979b2 [hotfix][config] Remove CheckpointConfig#enableUnalignedCheckpoints without parameters.
add 755025c [FLINK-18403][checkpointing] Ensure that unaligned checkpointing is only activated for EXACTLY_ONCE.
No new revisions were added by this update.
Summary of changes:
.../tests/StatefulStreamJobUpgradeTestProgram.java | 2 +-
.../api/environment/CheckpointConfig.java | 15 ----------
.../api/graph/StreamingJobGraphGenerator.java | 7 ++++-
.../streaming/runtime/io/InputProcessorUtil.java | 4 +++
.../api/graph/StreamingJobGraphGeneratorTest.java | 32 ++++++++++++++++++++++
.../checkpointing/UnalignedCheckpointITCase.java | 2 +-
6 files changed, 44 insertions(+), 18 deletions(-)