Repository: flink Updated Branches: refs/heads/master d21d5d632 -> 3f4de57b1
[hotfix][tests] Implement AutoCloseable in TestHarness Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/87e5b8be Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/87e5b8be Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/87e5b8be Branch: refs/heads/master Commit: 87e5b8be38455651f3cf6275d2fedb8a8ef52bc6 Parents: d21d5d6 Author: Piotr Nowojski <piotr.nowoj...@gmail.com> Authored: Mon Aug 14 15:09:39 2017 +0200 Committer: Aljoscha Krettek <aljoscha.kret...@gmail.com> Committed: Thu Aug 24 11:29:36 2017 +0200 ---------------------------------------------------------------------- .../flink/streaming/util/AbstractStreamOperatorTestHarness.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/87e5b8be/flink-streaming-java/src/test/java/org/apache/flink/streaming/util/AbstractStreamOperatorTestHarness.java ---------------------------------------------------------------------- diff --git a/flink-streaming-java/src/test/java/org/apache/flink/streaming/util/AbstractStreamOperatorTestHarness.java b/flink-streaming-java/src/test/java/org/apache/flink/streaming/util/AbstractStreamOperatorTestHarness.java index 15802353..720346a 100644 --- a/flink-streaming-java/src/test/java/org/apache/flink/streaming/util/AbstractStreamOperatorTestHarness.java +++ b/flink-streaming-java/src/test/java/org/apache/flink/streaming/util/AbstractStreamOperatorTestHarness.java @@ -90,7 +90,7 @@ import static org.mockito.Mockito.when; /** * Base class for {@code AbstractStreamOperator} test harnesses. */ -public class AbstractStreamOperatorTestHarness<OUT> { +public class AbstractStreamOperatorTestHarness<OUT> implements AutoCloseable { protected final StreamOperator<OUT> operator;