You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tr...@apache.org on 2018/01/26 14:41:28 UTC
[02/16] flink git commit: [hotfix] [tests] Let BucketingSink extend
TestLogger
[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 <tr...@apache.org>
Authored: Thu Jan 18 15:02:36 2018 +0100
Committer: Till Rohrmann <tr...@apache.org>
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();