You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tr...@apache.org on 2016/11/01 08:40:42 UTC
[15/50] [abbrv] flink git commit: [hotfix] Fix failing
JobManagerRunnerMockTest
[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/aac9137e
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/aac9137e
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/aac9137e
Branch: refs/heads/flip-6
Commit: aac9137e92b373645ff82f7f8e95f1f5c1f14acb
Parents: 36c3896
Author: Till Rohrmann <tr...@apache.org>
Authored: Tue Oct 4 14:27:37 2016 +0200
Committer: Till Rohrmann <tr...@apache.org>
Committed: Tue Nov 1 09:39:29 2016 +0100
----------------------------------------------------------------------
.../jobmaster/JobManagerRunnerMockTest.java | 17 +----------------
1 file changed, 1 insertion(+), 16 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/aac9137e/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 {