flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From se...@apache.org
Subject flink git commit: [FLINK-2468] [tests] Make sure StateCheckpoinedITCase tolerates errors before first checkpoint
Date Mon, 24 Aug 2015 16:31:16 GMT
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 <sewen@apache.org>
Authored: Mon Aug 24 18:04:22 2015 +0200
Committer: Stephan Ewen <sewen@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) {


Mime
View raw message