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 <u...@apache.org> Authored: Wed Mar 9 11:33:15 2016 +0100 Committer: Ufuk Celebi <u...@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;
