You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by se...@apache.org on 2016/10/14 13:46:19 UTC
[37/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/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 <tr...@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 {