[hotfix] Fix failing JobManagerRunnerMockTest
Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/85424c13 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/85424c13 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/85424c13 Branch: refs/heads/flip-6 Commit: 85424c135faed89fea19135b4439225de9bf665a Parents: 8906439 Author: Till Rohrmann <trohrm...@apache.org> Authored: Tue Oct 4 14:27:37 2016 +0200 Committer: Till Rohrmann <trohrm...@apache.org> Committed: Thu Oct 6 13:38:47 2016 +0200 ---------------------------------------------------------------------- .../jobmaster/JobManagerRunnerMockTest.java | 17 +---------------- 1 file changed, 1 insertion(+), 16 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/85424c13/flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/JobManagerRunnerMockTest.java ---------------------------------------------------------------------- diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/JobManagerRunnerMockTest.java b/flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/JobManagerRunnerMockTest.java index 3a769bb..f8a0b6a 100644 --- a/flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/JobManagerRunnerMockTest.java +++ b/flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/JobManagerRunnerMockTest.java @@ -131,21 +131,6 @@ public class JobManagerRunnerMockTest { } @Test - public void testJobFinishedByOtherBeforeGrantLeadership() throws Exception { - runner.start(); - - when(submittedJobGraphStore.contains(any(JobID.class))).thenReturn(false); - runner.grantLeadership(UUID.randomUUID()); - - // runner should shutdown automatic and informed the job completion - verify(leaderElectionService).stop(); - verify(jobManager).shutDown(); - - assertTrue(jobCompletion.isJobFinished()); - assertTrue(jobCompletion.isJobFinishedByOther()); - } - - @Test public void testJobFinished() throws Exception { runner.start(); @@ -211,7 +196,7 @@ public class JobManagerRunnerMockTest { UUID leaderSessionID2 = UUID.randomUUID(); runner.grantLeadership(leaderSessionID2); - verify(jobManagerGateway, times(2)).startJob(leaderSessionID2); + verify(jobManagerGateway).startJob(leaderSessionID2); } private static class TestingOnCompletionActions implements OnCompletionActions {
