Class BasicContainerLauncher
java.lang.Object
org.apache.storm.daemon.supervisor.ContainerLauncher
org.apache.storm.daemon.supervisor.BasicContainerLauncher
Launch containers with no security using standard java commands.
-
Field Summary
-
Constructor Summary
ConstructorDescriptionBasicContainerLauncher
(Map<String, Object> conf, String supervisorId, int supervisorPort, ResourceIsolationInterface resourceIsolationManager, StormMetricsRegistry metricsRegistry, ContainerMemoryTracker containerMemoryTracker) -
Method Summary
Modifier and TypeMethodDescriptionlaunchContainer
(int port, LocalAssignment assignment, LocalState state) Launch a container in a given slot.recoverContainer
(int port, LocalAssignment assignment, LocalState state) Recover a container for a running process.recoverContainer
(String workerId, LocalState localState) Try to recover a container using just the worker ID.Methods inherited from class org.apache.storm.daemon.supervisor.ContainerLauncher
make
-
Field Details
-
resourceIsolationManager
-
-
Constructor Details
-
BasicContainerLauncher
public BasicContainerLauncher(Map<String, Object> conf, String supervisorId, int supervisorPort, ResourceIsolationInterface resourceIsolationManager, StormMetricsRegistry metricsRegistry, ContainerMemoryTracker containerMemoryTracker) throws IOException- Throws:
IOException
-
-
Method Details
-
launchContainer
public Container launchContainer(int port, LocalAssignment assignment, LocalState state) throws IOException Description copied from class:ContainerLauncher
Launch a container in a given slot.- Specified by:
launchContainer
in classContainerLauncher
- Parameters:
port
- the port to run this onassignment
- what to launchstate
- the current state of the supervisor- Returns:
- The container that can be used to manager the processes.
- Throws:
IOException
- on any error
-
recoverContainer
public Container recoverContainer(int port, LocalAssignment assignment, LocalState state) throws IOException Description copied from class:ContainerLauncher
Recover a container for a running process.- Specified by:
recoverContainer
in classContainerLauncher
- Parameters:
port
- the port the assignment is running onassignment
- the assignment that was launchedstate
- the current state of the supervisor- Returns:
- The container that can be used to manage the processes.
- Throws:
IOException
- on any error
-
recoverContainer
Description copied from class:ContainerLauncher
Try to recover a container using just the worker ID. The result is really only useful for killing the container and so is returning a Killable. Even if a Container is returned do not case the result to Container because only the Killable APIs are guaranteed to work.- Specified by:
recoverContainer
in classContainerLauncher
- Parameters:
workerId
- the id of the worker to uselocalState
- the state of the running supervisor- Returns:
- a Killable that can be used to kill the underlying container.
- Throws:
IOException
- on any error
-