diff --git a/flink-core/src/test/java/org/apache/flink/api/common/io/SequentialFormatTestBase.java b/flink-core/src/test/java/org/apache/flink/api/common/io/SequentialFormatTestBase.java index 3e4697ab87419..91f80e8b6188b 100644 --- a/flink-core/src/test/java/org/apache/flink/api/common/io/SequentialFormatTestBase.java +++ b/flink-core/src/test/java/org/apache/flink/api/common/io/SequentialFormatTestBase.java @@ -33,6 +33,7 @@ import org.apache.flink.core.fs.Path; import org.apache.flink.core.memory.DataOutputView; import org.apache.flink.core.memory.OutputViewDataOutputStreamWrapper; +import org.apache.flink.util.TestLogger; import org.junit.After; import org.junit.Assert; import org.junit.Before; @@ -42,7 +43,7 @@ /** * Test base for {@link org.apache.flink.api.common.io.BinaryInputFormat} and {@link org.apache.flink.api.common.io.BinaryOutputFormat}. */ -public abstract class SequentialFormatTestBase { +public abstract class SequentialFormatTestBase extends TestLogger { public class InputSplitSorter implements Comparator { @Override diff --git a/flink-core/src/test/java/org/apache/flink/api/common/typeutils/ComparatorTestBase.java b/flink-core/src/test/java/org/apache/flink/api/common/typeutils/ComparatorTestBase.java index bc5c6b6dd31a5..782c402f1addf 100644 --- a/flink-core/src/test/java/org/apache/flink/api/common/typeutils/ComparatorTestBase.java +++ b/flink-core/src/test/java/org/apache/flink/api/common/typeutils/ComparatorTestBase.java @@ -29,6 +29,7 @@ import org.apache.flink.core.memory.DataInputView; import org.apache.flink.core.memory.DataOutputView; import org.apache.flink.core.memory.MemorySegment; +import org.apache.flink.util.TestLogger; import org.junit.Assert; import org.junit.Test; @@ -37,7 +38,7 @@ * * @param */ -public abstract class ComparatorTestBase { +public abstract class ComparatorTestBase extends TestLogger { // Same as in the NormalizedKeySorter private static final int DEFAULT_MAX_NORMALIZED_KEY_LEN = 8; diff --git a/flink-core/src/test/java/org/apache/flink/api/common/typeutils/SerializerTestBase.java b/flink-core/src/test/java/org/apache/flink/api/common/typeutils/SerializerTestBase.java index 998ae1218d789..ea91e56fa7c91 100644 --- a/flink-core/src/test/java/org/apache/flink/api/common/typeutils/SerializerTestBase.java +++ b/flink-core/src/test/java/org/apache/flink/api/common/typeutils/SerializerTestBase.java @@ -31,6 +31,7 @@ import java.io.IOException; import java.util.Arrays; +import org.apache.flink.util.TestLogger; import org.junit.Assert; import org.apache.commons.lang3.SerializationException; @@ -47,7 +48,7 @@ * (JodaTime DataTime) with the default KryoSerializer used to pass this test but the * internal state would be corrupt, which becomes evident when toString is called. */ -public abstract class SerializerTestBase { +public abstract class SerializerTestBase extends TestLogger { protected abstract TypeSerializer createSerializer(); diff --git a/flink-core/src/test/java/org/apache/flink/configuration/ConfigurationTest.java b/flink-core/src/test/java/org/apache/flink/configuration/ConfigurationTest.java index 33dde3d72c4c1..e3b75b67e8e59 100644 --- a/flink-core/src/test/java/org/apache/flink/configuration/ConfigurationTest.java +++ b/flink-core/src/test/java/org/apache/flink/configuration/ConfigurationTest.java @@ -25,18 +25,18 @@ import org.apache.flink.core.testutils.CommonTestUtils; +import org.apache.flink.util.TestLogger; import org.junit.Test; /** * This class contains test for the configuration package. In particular, the serialization of {@link Configuration} * objects is tested. */ -public class ConfigurationTest { +public class ConfigurationTest extends TestLogger { private static final byte[] EMPTY_BYTES = new byte[0]; private static final long TOO_LONG = Integer.MAX_VALUE + 10L; private static final double TOO_LONG_DOUBLE = Double.MAX_VALUE; - /** * This test checks the serialization/deserialization of configuration objects. diff --git a/flink-core/src/test/java/org/apache/flink/configuration/GlobalConfigurationTest.java b/flink-core/src/test/java/org/apache/flink/configuration/GlobalConfigurationTest.java index f207f783d67e2..41e97b206cb36 100644 --- a/flink-core/src/test/java/org/apache/flink/configuration/GlobalConfigurationTest.java +++ b/flink-core/src/test/java/org/apache/flink/configuration/GlobalConfigurationTest.java @@ -27,13 +27,14 @@ import java.lang.reflect.Field; import org.apache.flink.core.testutils.CommonTestUtils; +import org.apache.flink.util.TestLogger; import org.junit.Before; import org.junit.Test; /** * This class contains tests for the global configuration (parsing configuration directory information). */ -public class GlobalConfigurationTest { +public class GlobalConfigurationTest extends TestLogger { @Before public void resetSingleton() throws SecurityException, NoSuchFieldException, IllegalArgumentException, diff --git a/flink-core/src/test/java/org/apache/flink/configuration/UnmodifiableConfigurationTest.java b/flink-core/src/test/java/org/apache/flink/configuration/UnmodifiableConfigurationTest.java index 3ea52b89ec4ea..386d03bc4b8ac 100644 --- a/flink-core/src/test/java/org/apache/flink/configuration/UnmodifiableConfigurationTest.java +++ b/flink-core/src/test/java/org/apache/flink/configuration/UnmodifiableConfigurationTest.java @@ -23,6 +23,7 @@ import static org.junit.Assert.assertTrue; import static org.junit.Assert.fail; +import org.apache.flink.util.TestLogger; import org.junit.Test; import java.lang.reflect.InvocationTargetException; @@ -34,7 +35,7 @@ * This class verifies that the Unmodifiable Configuration class overrides all setter methods in * Configuration. */ -public class UnmodifiableConfigurationTest { +public class UnmodifiableConfigurationTest extends TestLogger { @Test public void testOverrideAddMethods() { diff --git a/flink-core/src/test/java/org/apache/flink/types/parser/ParserTestBase.java b/flink-core/src/test/java/org/apache/flink/types/parser/ParserTestBase.java index 94fe327d5d1c1..b979a38503e1a 100644 --- a/flink-core/src/test/java/org/apache/flink/types/parser/ParserTestBase.java +++ b/flink-core/src/test/java/org/apache/flink/types/parser/ParserTestBase.java @@ -26,13 +26,14 @@ import java.lang.reflect.InvocationTargetException; import java.lang.reflect.Method; +import org.apache.flink.util.TestLogger; import org.junit.Test; /** * */ -public abstract class ParserTestBase { +public abstract class ParserTestBase extends TestLogger { public abstract String[] getValidTestValues(); diff --git a/flink-core/src/test/java/org/apache/flink/util/AbstractIDTest.java b/flink-core/src/test/java/org/apache/flink/util/AbstractIDTest.java index 8c7e8b54ce8cd..8de3b94680891 100644 --- a/flink-core/src/test/java/org/apache/flink/util/AbstractIDTest.java +++ b/flink-core/src/test/java/org/apache/flink/util/AbstractIDTest.java @@ -30,7 +30,7 @@ /** * This class contains tests for the {@link org.apache.flink.util.AbstractID} class. */ -public class AbstractIDTest { +public class AbstractIDTest extends TestLogger { /** * Tests the serialization/deserialization of an abstract ID. */ diff --git a/flink-core/src/test/java/org/apache/flink/util/InstantiationUtilTest.java b/flink-core/src/test/java/org/apache/flink/util/InstantiationUtilTest.java index aded919360c72..f9500b00683da 100644 --- a/flink-core/src/test/java/org/apache/flink/util/InstantiationUtilTest.java +++ b/flink-core/src/test/java/org/apache/flink/util/InstantiationUtilTest.java @@ -35,7 +35,7 @@ import static org.junit.Assert.assertTrue; import static org.junit.Assert.fail; -public class InstantiationUtilTest { +public class InstantiationUtilTest extends TestLogger { @Test public void testInstantiationOfStringValue() { diff --git a/flink-core/src/test/java/org/apache/flink/util/NumberSequenceIteratorTest.java b/flink-core/src/test/java/org/apache/flink/util/NumberSequenceIteratorTest.java index 6698167bf1fe4..edaeb7a6658a4 100644 --- a/flink-core/src/test/java/org/apache/flink/util/NumberSequenceIteratorTest.java +++ b/flink-core/src/test/java/org/apache/flink/util/NumberSequenceIteratorTest.java @@ -24,7 +24,7 @@ import org.junit.Test; -public class NumberSequenceIteratorTest { +public class NumberSequenceIteratorTest extends TestLogger { @Test public void testSplitRegular() { diff --git a/flink-core/src/test/java/org/apache/flink/util/SimpleStringUtilsTest.java b/flink-core/src/test/java/org/apache/flink/util/SimpleStringUtilsTest.java index 9794fa371609c..98f8574ec70af 100644 --- a/flink-core/src/test/java/org/apache/flink/util/SimpleStringUtilsTest.java +++ b/flink-core/src/test/java/org/apache/flink/util/SimpleStringUtilsTest.java @@ -28,7 +28,7 @@ import org.junit.Test; -public class SimpleStringUtilsTest { +public class SimpleStringUtilsTest extends TestLogger { @Test public void testToLowerCaseConverting() { diff --git a/flink-core/src/test/java/org/apache/flink/util/StringUtilsTest.java b/flink-core/src/test/java/org/apache/flink/util/StringUtilsTest.java index b580fc6c8234e..3f6b16d03e3ea 100644 --- a/flink-core/src/test/java/org/apache/flink/util/StringUtilsTest.java +++ b/flink-core/src/test/java/org/apache/flink/util/StringUtilsTest.java @@ -24,7 +24,7 @@ import org.apache.flink.util.StringUtils; import org.junit.Test; -public class StringUtilsTest { +public class StringUtilsTest extends TestLogger { @Test public void testControlCharacters() { diff --git a/flink-core/src/test/java/org/apache/flink/util/TestLogger.java b/flink-core/src/test/java/org/apache/flink/util/TestLogger.java new file mode 100644 index 0000000000000..49d0f0fc64281 --- /dev/null +++ b/flink-core/src/test/java/org/apache/flink/util/TestLogger.java @@ -0,0 +1,59 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +package org.apache.flink.util; + +import org.junit.Rule; +import org.junit.rules.TestRule; +import org.junit.rules.TestWatcher; +import org.junit.runner.Description; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; + +/** + * Adds automatic test name logging. Every test which wants to log which test is currently + * executed and why it failed, simply has to extend this class. + */ +public class TestLogger { + protected final Logger log = LoggerFactory.getLogger(getClass()); + + @Rule + public TestRule watchman = new TestWatcher() { + + @Override + public void starting(Description description) { + log.info("================================================================================"); + log.info("Test {} is running.", description); + log.info("--------------------------------------------------------------------------------"); + } + + @Override + public void succeeded(Description description) { + log.info("--------------------------------------------------------------------------------"); + log.info("Test {} successfully run.", description); + log.info("================================================================================"); + } + + @Override + public void failed(Throwable e, Description description) { + log.error("--------------------------------------------------------------------------------"); + log.error("Test {} failed with:\n{}", description, StringUtils.stringifyException(e)); + log.error("================================================================================"); + } + }; +} diff --git a/flink-java/src/test/java/org/apache/flink/api/java/typeutils/runtime/tuple/base/TuplePairComparatorTestBase.java b/flink-java/src/test/java/org/apache/flink/api/java/typeutils/runtime/tuple/base/TuplePairComparatorTestBase.java index 17f85c9b44910..1d414d8e57e2e 100644 --- a/flink-java/src/test/java/org/apache/flink/api/java/typeutils/runtime/tuple/base/TuplePairComparatorTestBase.java +++ b/flink-java/src/test/java/org/apache/flink/api/java/typeutils/runtime/tuple/base/TuplePairComparatorTestBase.java @@ -24,6 +24,7 @@ import org.apache.flink.api.common.typeutils.TypePairComparator; import org.apache.flink.api.java.tuple.Tuple; import org.apache.flink.api.java.tuple.Tuple2; +import org.apache.flink.util.TestLogger; import org.junit.Test; /** @@ -32,7 +33,7 @@ * @param * @param */ -public abstract class TuplePairComparatorTestBase { +public abstract class TuplePairComparatorTestBase extends TestLogger { protected abstract TypePairComparator createComparator(boolean ascending); diff --git a/flink-optimizer/pom.xml b/flink-optimizer/pom.xml index 868ca3a703270..512c415ecd991 100644 --- a/flink-optimizer/pom.xml +++ b/flink-optimizer/pom.xml @@ -41,6 +41,14 @@ under the License. ${project.version} + + org.apache.flink + flink-core + ${project.version} + test-jar + test + + org.apache.flink flink-runtime diff --git a/flink-optimizer/src/test/java/org/apache/flink/optimizer/util/CompilerTestBase.java b/flink-optimizer/src/test/java/org/apache/flink/optimizer/util/CompilerTestBase.java index 35c50d3434d55..b4c39a5ed49c7 100644 --- a/flink-optimizer/src/test/java/org/apache/flink/optimizer/util/CompilerTestBase.java +++ b/flink-optimizer/src/test/java/org/apache/flink/optimizer/util/CompilerTestBase.java @@ -38,6 +38,7 @@ import org.apache.flink.optimizer.plan.PlanNode; import org.apache.flink.optimizer.plan.SingleInputPlanNode; import org.apache.flink.util.OperatingSystem; +import org.apache.flink.util.TestLogger; import org.apache.flink.util.Visitor; import org.junit.Before; @@ -46,7 +47,7 @@ * of a program and to fetch the nodes in an optimizer plan that correspond * the the node in the program plan. */ -public abstract class CompilerTestBase implements java.io.Serializable { +public abstract class CompilerTestBase extends TestLogger implements java.io.Serializable { private static final long serialVersionUID = 1L; diff --git a/flink-runtime/pom.xml b/flink-runtime/pom.xml index 065467fce6118..6dc8d42b68960 100644 --- a/flink-runtime/pom.xml +++ b/flink-runtime/pom.xml @@ -45,6 +45,14 @@ under the License. ${project.version} + + org.apache.flink + flink-core + ${project.version} + test-jar + test + + org.apache.flink flink-java diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/SubpartitionTestBase.java b/flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/SubpartitionTestBase.java index a41a01354cee6..cb0069b10e517 100644 --- a/flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/SubpartitionTestBase.java +++ b/flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/SubpartitionTestBase.java @@ -19,6 +19,7 @@ package org.apache.flink.runtime.io.network.partition; import org.apache.flink.runtime.io.network.buffer.Buffer; +import org.apache.flink.util.TestLogger; import org.junit.Test; import static org.junit.Assert.assertFalse; @@ -27,7 +28,7 @@ /** * Basic subpartition behaviour tests. */ -public abstract class SubpartitionTestBase { +public abstract class SubpartitionTestBase extends TestLogger { /** * Return the subpartition to be tested. diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/operators/testutils/DriverTestBase.java b/flink-runtime/src/test/java/org/apache/flink/runtime/operators/testutils/DriverTestBase.java index 642ac7dbc3b63..e4aad981a4ac2 100644 --- a/flink-runtime/src/test/java/org/apache/flink/runtime/operators/testutils/DriverTestBase.java +++ b/flink-runtime/src/test/java/org/apache/flink/runtime/operators/testutils/DriverTestBase.java @@ -27,6 +27,7 @@ import org.apache.flink.api.common.ExecutionConfig; import org.apache.flink.runtime.taskmanager.TaskManagerRuntimeInfo; +import org.apache.flink.util.TestLogger; import org.junit.Assert; import org.apache.flink.api.common.functions.Function; import org.apache.flink.api.common.functions.util.FunctionUtils; @@ -53,7 +54,7 @@ import org.junit.runners.Parameterized; @RunWith(Parameterized.class) -public class DriverTestBase implements PactTaskContext { +public class DriverTestBase extends TestLogger implements PactTaskContext { protected static final long DEFAULT_PER_SORT_MEM = 16 * 1024 * 1024; diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/operators/testutils/TaskTestBase.java b/flink-runtime/src/test/java/org/apache/flink/runtime/operators/testutils/TaskTestBase.java index c7be7a5b894ad..c04d051fb387a 100644 --- a/flink-runtime/src/test/java/org/apache/flink/runtime/operators/testutils/TaskTestBase.java +++ b/flink-runtime/src/test/java/org/apache/flink/runtime/operators/testutils/TaskTestBase.java @@ -36,12 +36,13 @@ import org.apache.flink.types.Record; import org.apache.flink.util.InstantiationUtil; import org.apache.flink.util.MutableObjectIterator; +import org.apache.flink.util.TestLogger; import org.junit.After; import org.junit.Assert; import java.util.List; -public abstract class TaskTestBase { +public abstract class TaskTestBase extends TestLogger { protected long memorySize = 0; diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/operators/testutils/UnaryOperatorTestBase.java b/flink-runtime/src/test/java/org/apache/flink/runtime/operators/testutils/UnaryOperatorTestBase.java index 20edc20a2065b..9600e5a7bce88 100644 --- a/flink-runtime/src/test/java/org/apache/flink/runtime/operators/testutils/UnaryOperatorTestBase.java +++ b/flink-runtime/src/test/java/org/apache/flink/runtime/operators/testutils/UnaryOperatorTestBase.java @@ -40,6 +40,7 @@ import org.apache.flink.util.Collector; import org.apache.flink.util.MutableObjectIterator; +import org.apache.flink.util.TestLogger; import org.junit.After; import org.junit.Assert; import org.junit.runner.RunWith; @@ -51,7 +52,7 @@ import java.util.List; @RunWith(Parameterized.class) -public class UnaryOperatorTestBase implements PactTaskContext { +public class UnaryOperatorTestBase extends TestLogger implements PactTaskContext { protected static final long DEFAULT_PER_SORT_MEM = 16 * 1024 * 1024; diff --git a/flink-test-utils/pom.xml b/flink-test-utils/pom.xml index 4bb51ef5d0b02..1eb5ff2597265 100644 --- a/flink-test-utils/pom.xml +++ b/flink-test-utils/pom.xml @@ -50,6 +50,12 @@ under the License. flink-runtime ${project.version} + + org.apache.flink + flink-core + ${project.version} + test-jar + org.apache.flink flink-runtime diff --git a/flink-test-utils/src/main/java/org/apache/flink/test/util/TestBaseUtils.java b/flink-test-utils/src/main/java/org/apache/flink/test/util/TestBaseUtils.java index cd6d3b21b1ef3..9068fcc213d6f 100644 --- a/flink-test-utils/src/main/java/org/apache/flink/test/util/TestBaseUtils.java +++ b/flink-test-utils/src/main/java/org/apache/flink/test/util/TestBaseUtils.java @@ -32,6 +32,7 @@ import org.apache.flink.runtime.StreamingMode; import org.apache.flink.runtime.testingUtils.TestingTaskManagerMessages; import org.apache.flink.runtime.testingUtils.TestingUtils; +import org.apache.flink.util.TestLogger; import org.apache.hadoop.fs.FileSystem; import org.junit.Assert; import org.slf4j.Logger; @@ -66,7 +67,7 @@ import java.util.regex.Matcher; import java.util.regex.Pattern; -public class TestBaseUtils { +public class TestBaseUtils extends TestLogger { private static final Logger LOG = LoggerFactory.getLogger(TestBaseUtils.class); diff --git a/flink-tests/src/test/java/org/apache/flink/test/cancelling/CancellingTestBase.java b/flink-tests/src/test/java/org/apache/flink/test/cancelling/CancellingTestBase.java index 1502110ece220..088ea4d6ed8bc 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/cancelling/CancellingTestBase.java +++ b/flink-tests/src/test/java/org/apache/flink/test/cancelling/CancellingTestBase.java @@ -26,6 +26,7 @@ import org.apache.flink.runtime.client.JobCancellationException; import org.apache.flink.runtime.messages.JobManagerMessages; import org.apache.flink.test.util.ForkableFlinkMiniCluster; +import org.apache.flink.util.TestLogger; import org.junit.Assert; import org.slf4j.Logger; @@ -45,7 +46,7 @@ /** * */ -public abstract class CancellingTestBase { +public abstract class CancellingTestBase extends TestLogger { private static final Logger LOG = LoggerFactory.getLogger(CancellingTestBase.class); diff --git a/flink-tests/src/test/java/org/apache/flink/test/checkpointing/StreamFaultToleranceTestBase.java b/flink-tests/src/test/java/org/apache/flink/test/checkpointing/StreamFaultToleranceTestBase.java index 8920cf2fa2077..59f24b054d7dd 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/checkpointing/StreamFaultToleranceTestBase.java +++ b/flink-tests/src/test/java/org/apache/flink/test/checkpointing/StreamFaultToleranceTestBase.java @@ -23,6 +23,7 @@ import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment; import org.apache.flink.test.util.ForkableFlinkMiniCluster; +import org.apache.flink.util.TestLogger; import org.junit.AfterClass; import org.junit.BeforeClass; import org.junit.Test; @@ -34,7 +35,7 @@ /** * Test base for fault tolerant streaming programs */ -public abstract class StreamFaultToleranceTestBase { +public abstract class StreamFaultToleranceTestBase extends TestLogger { protected static final int NUM_TASK_MANAGERS = 2; protected static final int NUM_TASK_SLOTS = 3; diff --git a/flink-tests/src/test/scala/org/apache/flink/api/scala/completeness/ScalaAPICompletenessTestBase.scala b/flink-tests/src/test/scala/org/apache/flink/api/scala/completeness/ScalaAPICompletenessTestBase.scala index 0df4589deba24..d1055d0286589 100644 --- a/flink-tests/src/test/scala/org/apache/flink/api/scala/completeness/ScalaAPICompletenessTestBase.scala +++ b/flink-tests/src/test/scala/org/apache/flink/api/scala/completeness/ScalaAPICompletenessTestBase.scala @@ -19,6 +19,7 @@ package org.apache.flink.api.scala.completeness import java.lang.reflect.Method +import org.apache.flink.util.TestLogger import org.junit.Assert._ import org.junit.Test @@ -32,7 +33,7 @@ import scala.language.existentials * * Note: This is inspired by the JavaAPICompletenessChecker from Spark. */ -abstract class ScalaAPICompletenessTestBase { +abstract class ScalaAPICompletenessTestBase extends TestLogger { /** * Determines whether a method is excluded by name. diff --git a/flink-tests/src/test/scala/org/apache/flink/api/scala/runtime/tuple/base/PairComparatorTestBase.scala b/flink-tests/src/test/scala/org/apache/flink/api/scala/runtime/tuple/base/PairComparatorTestBase.scala index d3d52b0dac9f5..5d154f5ae337c 100644 --- a/flink-tests/src/test/scala/org/apache/flink/api/scala/runtime/tuple/base/PairComparatorTestBase.scala +++ b/flink-tests/src/test/scala/org/apache/flink/api/scala/runtime/tuple/base/PairComparatorTestBase.scala @@ -17,6 +17,7 @@ */ package org.apache.flink.api.scala.runtime.tuple.base +import org.apache.flink.util.TestLogger import org.junit.Assert.assertTrue import org.junit.Assert.fail import org.apache.flink.api.common.typeutils.TypePairComparator @@ -25,7 +26,7 @@ import org.junit.Test /** * Abstract test base for PairComparators. */ -abstract class PairComparatorTestBase[T, R] { +abstract class PairComparatorTestBase[T, R] extends TestLogger { protected def createComparator(ascending: Boolean): TypePairComparator[T, R] protected def getSortedTestData: (Array[T], Array[R]) diff --git a/flink-yarn-tests/src/main/java/org/apache/flink/yarn/YarnTestBase.java b/flink-yarn-tests/src/main/java/org/apache/flink/yarn/YarnTestBase.java index 2d227000f03e4..4399f191e96f8 100644 --- a/flink-yarn-tests/src/main/java/org/apache/flink/yarn/YarnTestBase.java +++ b/flink-yarn-tests/src/main/java/org/apache/flink/yarn/YarnTestBase.java @@ -22,6 +22,7 @@ import org.apache.flink.client.CliFrontend; import org.apache.flink.client.FlinkYarnSessionCli; import org.apache.flink.test.util.TestBaseUtils; +import org.apache.flink.util.TestLogger; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.service.Service; import org.apache.hadoop.yarn.api.records.ApplicationReport; @@ -69,7 +70,7 @@ * * The test is not thread-safe. Parallel execution of tests is not possible! */ -public abstract class YarnTestBase { +public abstract class YarnTestBase extends TestLogger { private static final Logger LOG = LoggerFactory.getLogger(YarnTestBase.class); protected final static PrintStream originalStdout = System.out;