[hotfix] [tests] Let BucketingSink extend TestLogger
Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/dd14bdf5 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/dd14bdf5 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/dd14bdf5 Branch: refs/heads/master Commit: dd14bdf568dc603a0449bfc3f9a8f936140d239b Parents: 8f9dbec Author: Till Rohrmann <[email protected]> Authored: Thu Jan 18 15:02:36 2018 +0100 Committer: Till Rohrmann <[email protected]> Committed: Fri Jan 26 13:49:47 2018 +0100 ---------------------------------------------------------------------- .../streaming/connectors/fs/bucketing/BucketingSinkTest.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/dd14bdf5/flink-connectors/flink-connector-filesystem/src/test/java/org/apache/flink/streaming/connectors/fs/bucketing/BucketingSinkTest.java ---------------------------------------------------------------------- diff --git a/flink-connectors/flink-connector-filesystem/src/test/java/org/apache/flink/streaming/connectors/fs/bucketing/BucketingSinkTest.java b/flink-connectors/flink-connector-filesystem/src/test/java/org/apache/flink/streaming/connectors/fs/bucketing/BucketingSinkTest.java index d6852ef..6fa0713 100644 --- a/flink-connectors/flink-connector-filesystem/src/test/java/org/apache/flink/streaming/connectors/fs/bucketing/BucketingSinkTest.java +++ b/flink-connectors/flink-connector-filesystem/src/test/java/org/apache/flink/streaming/connectors/fs/bucketing/BucketingSinkTest.java @@ -34,6 +34,7 @@ import org.apache.flink.streaming.util.AbstractStreamOperatorTestHarness; import org.apache.flink.streaming.util.OneInputStreamOperatorTestHarness; import org.apache.flink.util.NetUtils; import org.apache.flink.util.OperatingSystem; +import org.apache.flink.util.TestLogger; import org.apache.avro.Schema; import org.apache.avro.file.DataFileConstants; @@ -70,7 +71,7 @@ import java.util.Map; /** * Tests for the {@link BucketingSink}. */ -public class BucketingSinkTest { +public class BucketingSinkTest extends TestLogger { @ClassRule public static TemporaryFolder tempFolder = new TemporaryFolder();
