From 5aa70f70846f021b384c005b3dd3fd5ee3424d00 Mon Sep 17 00:00:00 2001
From: Stephan Ewen <sewen@apache.org>
Date: Mon, 24 Aug 2015 18:04:22 +0200
Subject: [PATCH] [FLINK-2468] [tests] Make sure StateCheckpoinedITCase
 tolerates errors before first checkpoint

---
 .../flink/test/checkpointing/StateCheckpoinedITCase.java     | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

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 2c2f2b48166..10d4d66536f 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) {
-- 
GitLab