flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From u..@apache.org
Subject flink git commit: [tests] Add TestLogger to StreamCheckpointNotifierITCase
Date Wed, 09 Mar 2016 10:33:53 GMT
Repository: flink
Updated Branches:
  refs/heads/master e34ac03e6 -> ab17b7224


[tests] Add TestLogger to StreamCheckpointNotifierITCase

Saw this one failing, but it's impossible to get any insight
from the logs, because you can't tell what is what.


Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ab17b722
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/ab17b722
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/ab17b722

Branch: refs/heads/master
Commit: ab17b7224539d2020fc873986f9417b5c2082157
Parents: e34ac03
Author: Ufuk Celebi <uce@apache.org>
Authored: Wed Mar 9 11:33:15 2016 +0100
Committer: Ufuk Celebi <uce@apache.org>
Committed: Wed Mar 9 11:33:16 2016 +0100

----------------------------------------------------------------------
 .../flink/test/checkpointing/StreamCheckpointNotifierITCase.java  | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/ab17b722/flink-tests/src/test/java/org/apache/flink/test/checkpointing/StreamCheckpointNotifierITCase.java
----------------------------------------------------------------------
diff --git a/flink-tests/src/test/java/org/apache/flink/test/checkpointing/StreamCheckpointNotifierITCase.java
b/flink-tests/src/test/java/org/apache/flink/test/checkpointing/StreamCheckpointNotifierITCase.java
index 8927f43..9b14a96 100644
--- a/flink-tests/src/test/java/org/apache/flink/test/checkpointing/StreamCheckpointNotifierITCase.java
+++ b/flink-tests/src/test/java/org/apache/flink/test/checkpointing/StreamCheckpointNotifierITCase.java
@@ -37,6 +37,7 @@ import org.apache.flink.streaming.api.operators.TwoInputStreamOperator;
 import org.apache.flink.test.util.ForkableFlinkMiniCluster;
 import org.apache.flink.util.Collector;
 
+import org.apache.flink.util.TestLogger;
 import org.junit.AfterClass;
 import org.junit.BeforeClass;
 import org.junit.Test;
@@ -70,7 +71,7 @@ import static org.junit.Assert.fail;
  * successfully completed checkpoint.
  */
 @SuppressWarnings("serial")
-public class StreamCheckpointNotifierITCase {
+public class StreamCheckpointNotifierITCase extends TestLogger {
 	
 	private static final int NUM_TASK_MANAGERS = 2;
 	private static final int NUM_TASK_SLOTS = 3;


Mime
View raw message