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 2018/10/11 15:00:36 UTC
[flink] 05/06: [hotfix] Remove mocking from
ExecutionGraphRestartTest
This is an automated email from the ASF dual-hosted git repository.
trohrmann pushed a commit to branch release-1.6
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 6d9d809628b60ff446d8a3184dd23a1617c7ec2f
Author: Till Rohrmann <tr...@apache.org>
AuthorDate: Tue Oct 9 12:08:33 2018 +0200
[hotfix] Remove mocking from ExecutionGraphRestartTest
---
.../runtime/executiongraph/ExecutionGraphRestartTest.java | 12 ------------
1 file changed, 12 deletions(-)
diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/ExecutionGraphRestartTest.java b/flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/ExecutionGraphRestartTest.java
index e08baed..f7dab1c 100644
--- a/flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/ExecutionGraphRestartTest.java
+++ b/flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/ExecutionGraphRestartTest.java
@@ -90,7 +90,6 @@ import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertNotNull;
import static org.junit.Assert.assertTrue;
import static org.junit.Assert.fail;
-import static org.mockito.Mockito.spy;
/**
* Tests the restart behaviour of the {@link ExecutionGraph}.
@@ -851,14 +850,6 @@ public class ExecutionGraphRestartTest extends TestLogger {
}
private static Tuple2<ExecutionGraph, Instance> createExecutionGraph(RestartStrategy restartStrategy) throws Exception {
- return createExecutionGraph(restartStrategy, false);
- }
-
- private static Tuple2<ExecutionGraph, Instance> createSpyExecutionGraph(RestartStrategy restartStrategy) throws Exception {
- return createExecutionGraph(restartStrategy, true);
- }
-
- private static Tuple2<ExecutionGraph, Instance> createExecutionGraph(RestartStrategy restartStrategy, boolean isSpy) throws Exception {
Instance instance = ExecutionGraphTestUtils.getInstance(
new ActorTaskManagerGateway(
new SimpleActorGateway(TestingUtils.directExecutionContext())),
@@ -872,9 +863,6 @@ public class ExecutionGraphRestartTest extends TestLogger {
JobGraph jobGraph = new JobGraph("Pointwise job", sender);
ExecutionGraph eg = newExecutionGraph(restartStrategy, scheduler);
- if (isSpy) {
- eg = spy(eg);
- }
eg.attachJobGraph(jobGraph.getVerticesSortedTopologicallyFromSources());
assertEquals(JobStatus.CREATED, eg.getState());