提交 ab17b722 编写于 作者: U Ufuk Celebi

[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.
上级 e34ac03e
......@@ -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;
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册