You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2019/05/10 13:03:16 UTC
[flink] 04/06: prevent concurrent checkpoints
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a commit to branch travis_jdk9_test
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 56c9710a76c6bb0c1cd421472498cf9db49b29b2
Author: Chesnay Schepler <ch...@apache.org>
AuthorDate: Thu May 9 11:50:57 2019 +0200
prevent concurrent checkpoints
---
.../apache/flink/streaming/tests/DataStreamAllroundTestJobFactory.java | 2 ++
1 file changed, 2 insertions(+)
diff --git a/flink-end-to-end-tests/flink-datastream-allround-test/src/main/java/org/apache/flink/streaming/tests/DataStreamAllroundTestJobFactory.java b/flink-end-to-end-tests/flink-datastream-allround-test/src/main/java/org/apache/flink/streaming/tests/DataStreamAllroundTestJobFactory.java
index 913d030..dac811b 100644
--- a/flink-end-to-end-tests/flink-datastream-allround-test/src/main/java/org/apache/flink/streaming/tests/DataStreamAllroundTestJobFactory.java
+++ b/flink-end-to-end-tests/flink-datastream-allround-test/src/main/java/org/apache/flink/streaming/tests/DataStreamAllroundTestJobFactory.java
@@ -251,6 +251,8 @@ public class DataStreamAllroundTestJobFactory {
env.enableCheckpointing(checkpointInterval, checkpointingMode);
+ env.getCheckpointConfig().setMinPauseBetweenCheckpoints(50);
+
boolean enableExternalizedCheckpoints = pt.getBoolean(
ENVIRONMENT_EXTERNALIZE_CHECKPOINT.key(),
ENVIRONMENT_EXTERNALIZE_CHECKPOINT.defaultValue());