Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/4883#discussion_r182155763
--- Diff: docs/dev/stream/state/checkpointing.md ---
@@ -118,6 +120,9 @@
env.getCheckpointConfig.setMinPauseBetweenCheckpoints(500)
// checkpoints have
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4883
---
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/4883#discussion_r151948416
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/ExecutionConfig.java ---
@@ -150,6 +150,9 @@
/** This flag defines if we use co
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/4883#discussion_r151940619
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java
---
@@ -1041,27 +1065,27 @@ public void execute
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/4883#discussion_r146543822
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/CheckpointExceptionHandlerFactory.java
---
@@ -0,0 +1,78 @@
+/*
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/4883#discussion_r146544396
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java
---
@@ -1041,27 +1065,27 @@ public void executeCheckp
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/4883#discussion_r146543421
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/ExecutionConfig.java ---
@@ -150,6 +150,9 @@
/** This flag defines if we use compress
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/4883#discussion_r146543640
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/CheckpointConfig.java
---
@@ -231,6 +234,23 @@ public void setForce
GitHub user StefanRRichter opened a pull request:
https://github.com/apache/flink/pull/4883
[FLINK-4809] Operators should tolerate checkpoint failures.
## What is the purpose of the change
This PR implements FLINK-4809 and allows tasks to tolerate errors that
happen in thei
