[FLINK-3826] [tests] Fix test condition in StreamCheckpointingITCase This closes #1977
Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/91a845d0 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/91a845d0 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/91a845d0 Branch: refs/heads/master Commit: 91a845d05671ac9d1355e1c548c8e6a229043430 Parents: 3080ea4 Author: kl0u <[email protected]> Authored: Tue May 10 16:00:03 2016 +0200 Committer: Stephan Ewen <[email protected]> Committed: Tue May 17 20:50:58 2016 +0200 ---------------------------------------------------------------------- .../apache/flink/test/checkpointing/StreamCheckpointingITCase.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/91a845d0/flink-tests/src/test/java/org/apache/flink/test/checkpointing/StreamCheckpointingITCase.java ---------------------------------------------------------------------- diff --git a/flink-tests/src/test/java/org/apache/flink/test/checkpointing/StreamCheckpointingITCase.java b/flink-tests/src/test/java/org/apache/flink/test/checkpointing/StreamCheckpointingITCase.java index 27c0f80..b97e1f2 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/checkpointing/StreamCheckpointingITCase.java +++ b/flink-tests/src/test/java/org/apache/flink/test/checkpointing/StreamCheckpointingITCase.java @@ -267,7 +267,7 @@ public class StreamCheckpointingITCase extends StreamFaultToleranceTestBase { count++; if (!hasFailed && count >= failurePos) { hasFailed = true; -// throw new Exception("Test Failure"); + throw new Exception("Test Failure"); } inputCount++;
