flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From trohrm...@apache.org
Subject [15/50] [abbrv] flink git commit: [hotfix] Fix failing JobManagerRunnerMockTest
Date Tue, 01 Nov 2016 08:40:42 GMT
[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 <trohrmann@apache.org>
Authored: Tue Oct 4 14:27:37 2016 +0200
Committer: Till Rohrmann <trohrmann@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 {


Mime
View raw message