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 d8b8014aa86345c64b71445b1a361c27a1549480 Author: Aljoscha Krettek <[email protected]> AuthorDate: Tue Oct 2 11:36:07 2018 +0200 [FLINK-7811] Disambiguate ZooKeeperHAJobManagerTest for Scala 2.12 The new Scala 2.12 typechecker didn't like this. --- .../apache/flink/runtime/jobmanager/ZooKeeperHAJobManagerTest.java | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/jobmanager/ZooKeeperHAJobManagerTest.java b/flink-runtime/src/test/java/org/apache/flink/runtime/jobmanager/ZooKeeperHAJobManagerTest.java index 8e5b1b9..dc9e8f5 100644 --- a/flink-runtime/src/test/java/org/apache/flink/runtime/jobmanager/ZooKeeperHAJobManagerTest.java +++ b/flink-runtime/src/test/java/org/apache/flink/runtime/jobmanager/ZooKeeperHAJobManagerTest.java @@ -56,6 +56,7 @@ import org.junit.Test; import org.junit.rules.TemporaryFolder; import java.util.Collection; +import java.util.concurrent.Callable; import java.util.concurrent.TimeUnit; import scala.Option; @@ -152,9 +153,11 @@ public class ZooKeeperHAJobManagerTest extends TestLogger { Await.result(jobManager.ask(TestingJobManagerMessages.getWaitForBackgroundTasksToFinish(), TIMEOUT), TIMEOUT); + //noinspection RedundantCast final SubmittedJobGraph recoveredJobGraph = akka.serialization.JavaSerializer.currentSystem().withValue( - ((ExtendedActorSystem) system), - () -> otherSubmittedJobGraphStore.recoverJobGraph(jobId)); + ((ExtendedActorSystem) system), + // we need the explicit cast to disambiguate the function call + (Callable<SubmittedJobGraph>) () -> otherSubmittedJobGraphStore.recoverJobGraph(jobId)); assertThat(recoveredJobGraph, is(notNullValue()));
