[FLINK-2468] [tests] Make sure StateCheckpoinedITCase tolerates errors before first checkpoint

5aa70f70 · Stephan Ewen · 9c7f7693 · 5aa70f70
隐藏空白更改
内联并排

Showing with 3 addition and 2 deletion

flink-tests/src/test/java/org/apache/flink/test/checkpointing/StateCheckpoinedITCase.java ...ache/flink/test/checkpointing/StateCheckpoinedITCase.java +3 -2

未找到文件。
--- 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) {