[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/30517da9 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/30517da9 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/30517da9 Branch: refs/heads/flip-6 Commit: 30517da90f947cc3622d969dc788797bff7abe3c Parents: 3e4eb4f Author: Till Rohrmann <[email protected]> Authored: Tue Oct 4 14:27:37 2016 +0200 Committer: Stephan Ewen <[email protected]> Committed: Fri Oct 14 15:14:42 2016 +0200 ---------------------------------------------------------------------- .../jobmaster/JobManagerRunnerMockTest.java | 17 +---------------- 1 file changed, 1 insertion(+), 16 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/30517da9/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 {
