Repository: flink Updated Branches: refs/heads/master bcf5f4648 -> b849da14c
[hotfix] [tests] Minor style fix in FlinkTestBase Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b849da14 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/b849da14 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/b849da14 Branch: refs/heads/master Commit: b849da14c1c50073e4c8bf460c654647808e29ae Parents: ad52a5f Author: Stephan Ewen <[email protected]> Authored: Tue May 31 12:37:30 2016 +0200 Committer: Stephan Ewen <[email protected]> Committed: Tue May 31 16:39:56 2016 +0200 ---------------------------------------------------------------------- .../src/test/scala/org/apache/flink/test/util/FlinkTestBase.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/b849da14/flink-test-utils/src/test/scala/org/apache/flink/test/util/FlinkTestBase.scala ---------------------------------------------------------------------- diff --git a/flink-test-utils/src/test/scala/org/apache/flink/test/util/FlinkTestBase.scala b/flink-test-utils/src/test/scala/org/apache/flink/test/util/FlinkTestBase.scala index 715bc55..1f00c7e 100644 --- a/flink-test-utils/src/test/scala/org/apache/flink/test/util/FlinkTestBase.scala +++ b/flink-test-utils/src/test/scala/org/apache/flink/test/util/FlinkTestBase.scala @@ -67,7 +67,7 @@ trait FlinkTestBase extends BeforeAndAfter { } after { - cluster.map(c => TestBaseUtils.stopCluster(c, TestBaseUtils.DEFAULT_TIMEOUT)) + cluster.foreach(c => TestBaseUtils.stopCluster(c, TestBaseUtils.DEFAULT_TIMEOUT)) } }
