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/09/28 14:35:03 UTC
[flink] 04/08: [hotfix] Remove TaskManagerProcessEntryPoint
This is an automated email from the ASF dual-hosted git repository.
trohrmann pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 87c27e4ca82ad8ce48cef743b8da1f7845199b0e
Author: Till Rohrmann <tr...@apache.org>
AuthorDate: Mon Sep 24 09:58:23 2018 +0200
[hotfix] Remove TaskManagerProcessEntryPoint
---
...tractTaskManagerProcessFailureRecoveryTest.java | 36 ----------------------
1 file changed, 36 deletions(-)
diff --git a/flink-tests/src/test/java/org/apache/flink/test/recovery/AbstractTaskManagerProcessFailureRecoveryTest.java b/flink-tests/src/test/java/org/apache/flink/test/recovery/AbstractTaskManagerProcessFailureRecoveryTest.java
index 0962ddf..1374b70 100644
--- a/flink-tests/src/test/java/org/apache/flink/test/recovery/AbstractTaskManagerProcessFailureRecoveryTest.java
+++ b/flink-tests/src/test/java/org/apache/flink/test/recovery/AbstractTaskManagerProcessFailureRecoveryTest.java
@@ -28,7 +28,6 @@ import org.apache.flink.runtime.clusterframework.ApplicationStatus;
import org.apache.flink.runtime.clusterframework.types.ResourceID;
import org.apache.flink.runtime.entrypoint.StandaloneSessionClusterEntrypoint;
import org.apache.flink.runtime.taskexecutor.TaskManagerRunner;
-import org.apache.flink.runtime.taskmanager.TaskManager;
import org.apache.flink.runtime.testutils.CommonTestUtils;
import org.apache.flink.runtime.util.BlobServerResource;
import org.apache.flink.util.NetUtils;
@@ -304,41 +303,6 @@ public abstract class AbstractTaskManagerProcessFailureRecoveryTest extends Test
// --------------------------------------------------------------------------------------------
/**
- * The entry point for the TaskManager JVM. Simply configures and runs a TaskManager.
- */
- public static class TaskManagerProcessEntryPoint {
-
- private static final Logger LOG = LoggerFactory.getLogger(TaskManagerProcessEntryPoint.class);
-
- public static void main(String[] args) {
- try {
- int jobManagerPort = Integer.parseInt(args[0]);
-
- Configuration cfg = new Configuration();
- cfg.setString(JobManagerOptions.ADDRESS, "localhost");
- cfg.setInteger(JobManagerOptions.PORT, jobManagerPort);
- cfg.setString(TaskManagerOptions.MANAGED_MEMORY_SIZE, "4m");
- cfg.setInteger(TaskManagerOptions.NETWORK_NUM_BUFFERS, 100);
- cfg.setInteger(TaskManagerOptions.NUM_TASK_SLOTS, 2);
- cfg.setString(AkkaOptions.ASK_TIMEOUT, "100 s");
-
- TaskManager.selectNetworkInterfaceAndRunTaskManager(cfg,
- ResourceID.generate(), TaskManager.class);
-
- // wait forever
- Object lock = new Object();
- synchronized (lock) {
- lock.wait();
- }
- }
- catch (Throwable t) {
- LOG.error("Failed to start TaskManager process", t);
- System.exit(1);
- }
- }
- }
-
- /**
* The entry point for the TaskExecutor JVM. Simply configures and runs a TaskExecutor.
*/
public static class TaskExecutorProcessEntryPoint {