[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 <trohrm...@apache.org>
Authored: Tue Oct 4 14:27:37 2016 +0200
Committer: Stephan Ewen <se...@apache.org>
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 {

Reply via email to