You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2019/06/19 14:20:39 UTC
[flink] branch master updated: [FLINK-12264][runtime] Remove unused
methods in ExecutionGraphTestUtils
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new bc9c7a3 [FLINK-12264][runtime] Remove unused methods in ExecutionGraphTestUtils
bc9c7a3 is described below
commit bc9c7a3561feb6c9b918377ce6ce1e40638245ce
Author: leesf <49...@qq.com>
AuthorDate: Wed Jun 19 22:20:28 2019 +0800
[FLINK-12264][runtime] Remove unused methods in ExecutionGraphTestUtils
---
.../executiongraph/ExecutionGraphTestUtils.java | 19 -------------------
1 file changed, 19 deletions(-)
diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/ExecutionGraphTestUtils.java b/flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/ExecutionGraphTestUtils.java
index 691bc00..5ba8263 100644
--- a/flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/ExecutionGraphTestUtils.java
+++ b/flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/ExecutionGraphTestUtils.java
@@ -27,16 +27,12 @@ import org.apache.flink.metrics.groups.UnregisteredMetricsGroup;
import org.apache.flink.runtime.akka.AkkaUtils;
import org.apache.flink.runtime.blob.VoidBlobWriter;
import org.apache.flink.runtime.checkpoint.StandaloneCheckpointRecoveryFactory;
-import org.apache.flink.runtime.clusterframework.types.ResourceID;
import org.apache.flink.runtime.execution.ExecutionState;
import org.apache.flink.runtime.executiongraph.failover.FailoverRegion;
import org.apache.flink.runtime.executiongraph.restart.NoRestartStrategy;
import org.apache.flink.runtime.executiongraph.restart.RestartStrategy;
import org.apache.flink.runtime.executiongraph.utils.SimpleAckingTaskManagerGateway;
import org.apache.flink.runtime.executiongraph.utils.SimpleSlotProvider;
-import org.apache.flink.runtime.instance.HardwareDescription;
-import org.apache.flink.runtime.instance.Instance;
-import org.apache.flink.runtime.instance.InstanceID;
import org.apache.flink.runtime.jobgraph.JobGraph;
import org.apache.flink.runtime.jobgraph.JobStatus;
import org.apache.flink.runtime.jobgraph.JobVertex;
@@ -45,7 +41,6 @@ import org.apache.flink.runtime.jobgraph.tasks.AbstractInvokable;
import org.apache.flink.runtime.jobmanager.slots.TaskManagerGateway;
import org.apache.flink.runtime.jobmaster.LogicalSlot;
import org.apache.flink.runtime.jobmaster.slotpool.SlotProvider;
-import org.apache.flink.runtime.taskmanager.TaskManagerLocation;
import org.apache.flink.runtime.testingUtils.TestingUtils;
import org.apache.flink.runtime.testtasks.NoOpInvokable;
import org.apache.flink.runtime.testutils.DirectScheduledExecutorService;
@@ -57,7 +52,6 @@ import org.slf4j.LoggerFactory;
import javax.annotation.Nullable;
import java.lang.reflect.Field;
-import java.net.InetAddress;
import java.time.Duration;
import java.util.List;
import java.util.concurrent.CompletableFuture;
@@ -433,19 +427,6 @@ public class ExecutionGraphTestUtils {
// utility mocking methods
// ------------------------------------------------------------------------
- public static Instance getInstance(final TaskManagerGateway gateway) throws Exception {
- return getInstance(gateway, 1);
- }
-
- public static Instance getInstance(final TaskManagerGateway gateway, final int numberOfSlots) throws Exception {
- ResourceID resourceID = ResourceID.generate();
- HardwareDescription hardwareDescription = new HardwareDescription(4, 2L*1024*1024*1024, 1024*1024*1024, 512*1024*1024);
- InetAddress address = InetAddress.getByName("127.0.0.1");
- TaskManagerLocation connection = new TaskManagerLocation(resourceID, address, 10001);
-
- return new Instance(gateway, connection, new InstanceID(), hardwareDescription, numberOfSlots);
- }
-
public static JobVertex createJobVertex(String task1, int numTasks, Class<NoOpInvokable> invokable) {
JobVertex groupVertex = new JobVertex(task1);
groupVertex.setInvokableClass(invokable);