You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by se...@apache.org on 2015/08/24 18:31:16 UTC
flink git commit: [FLINK-2468] [tests] Make sure
StateCheckpoinedITCase tolerates errors before first checkpoint
Repository: flink
Updated Branches:
refs/heads/master 9c7f76938 -> 5aa70f708
[FLINK-2468] [tests] Make sure StateCheckpoinedITCase tolerates errors before first checkpoint
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5aa70f70
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/5aa70f70
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/5aa70f70
Branch: refs/heads/master
Commit: 5aa70f70846f021b384c005b3dd3fd5ee3424d00
Parents: 9c7f769
Author: Stephan Ewen <se...@apache.org>
Authored: Mon Aug 24 18:04:22 2015 +0200
Committer: Stephan Ewen <se...@apache.org>
Committed: Mon Aug 24 18:04:22 2015 +0200
----------------------------------------------------------------------
.../apache/flink/test/checkpointing/StateCheckpoinedITCase.java | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/5aa70f70/flink-tests/src/test/java/org/apache/flink/test/checkpointing/StateCheckpoinedITCase.java
----------------------------------------------------------------------
diff --git a/flink-tests/src/test/java/org/apache/flink/test/checkpointing/StateCheckpoinedITCase.java b/flink-tests/src/test/java/org/apache/flink/test/checkpointing/StateCheckpoinedITCase.java
index 2c2f2b4..10d4d66 100644
--- a/flink-tests/src/test/java/org/apache/flink/test/checkpointing/StateCheckpoinedITCase.java
+++ b/flink-tests/src/test/java/org/apache/flink/test/checkpointing/StateCheckpoinedITCase.java
@@ -95,8 +95,9 @@ public class StateCheckpoinedITCase extends StreamFaultToleranceTestBase {
@Override
public void postSubmit() {
- assertTrue("Test inconclusive: failure occurred before first checkpoint",
- OnceFailingAggregator.wasCheckpointedBeforeFailure);
+ if (!OnceFailingAggregator.wasCheckpointedBeforeFailure) {
+ System.err.println("Test inconclusive: failure occurred before first checkpoint");
+ }
long filterSum = 0;
for (long l : StringRichFilterFunction.counts) {