flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From se...@apache.org
Subject [4/5] flink git commit: [FLINK-3826] [tests] Fix test condition in StreamCheckpointingITCase
Date Tue, 17 May 2016 21:44:25 GMT
[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 <kkloudas@gmail.com>
Authored: Tue May 10 16:00:03 2016 +0200
Committer: Stephan Ewen <sewen@apache.org>
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++;
 		


Mime
View raw message