This is an automated email from the ASF dual-hosted git repository. aljoscha pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit 578ae73dbe9467af2a44f79a7557c4f2118c0afc Author: Aljoscha Krettek <[email protected]> AuthorDate: Tue Oct 2 10:19:57 2018 +0200 [FLINK-7811] Add use ForkJoinPool from Java package for Scala 2.12 support Scala 2.12 doesn't have ForkJoinPool there anymore. --- .../flink/test/runtime/minicluster/LocalFlinkMiniClusterITCase.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/flink-tests/src/test/java/org/apache/flink/test/runtime/minicluster/LocalFlinkMiniClusterITCase.java b/flink-tests/src/test/java/org/apache/flink/test/runtime/minicluster/LocalFlinkMiniClusterITCase.java index 66a811a..47bb21c 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/runtime/minicluster/LocalFlinkMiniClusterITCase.java +++ b/flink-tests/src/test/java/org/apache/flink/test/runtime/minicluster/LocalFlinkMiniClusterITCase.java @@ -39,12 +39,12 @@ import java.lang.reflect.Field; import java.util.Arrays; import java.util.HashSet; import java.util.Set; +import java.util.concurrent.ForkJoinPool; import java.util.concurrent.TimeoutException; import scala.concurrent.Await; import scala.concurrent.ExecutionContext$; import scala.concurrent.duration.Duration; -import scala.concurrent.forkjoin.ForkJoinPool; import scala.concurrent.impl.ExecutionContextImpl; import static org.junit.Assert.fail;
