Tools for starting JobManager and TaskManager processes, including the Actor Systems used to run the JobManager and TaskManager actors.
JobManager actor for execution on Yarn or Mesos.
This class describes the basic parameters for launching a TaskManager process.
Encapsulates a container specification, including artifacts, environment variables, system properties, and Flink configuration settings.
An artifact to be copied into the container.
|FlinkResourceManager<WorkerType extends ResourceIDRetrievable>||
Worker allocation steps
The status of an application.
The classes in this package are extended by the YARN and Mesos implementations to realize cluster bootstrapping and resource management with those frameworks.
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.