Package | Description |
---|---|
org.apache.flink.mesos.entrypoint | |
org.apache.flink.mesos.runtime.clusterframework | |
org.apache.flink.mesos.util |
Modifier and Type | Method and Description |
---|---|
static MesosConfiguration |
MesosEntrypointUtils.createMesosSchedulerConfiguration(Configuration flinkConfig,
String hostname)
Loads and validates the Mesos scheduler configuration.
|
Modifier and Type | Method and Description |
---|---|
static akka.actor.Props |
MesosFlinkResourceManager.createActorProps(Class<? extends MesosFlinkResourceManager> actorClass,
Configuration flinkConfig,
MesosConfiguration mesosConfig,
MesosWorkerStore workerStore,
LeaderRetrievalService leaderRetrievalService,
MesosTaskManagerParameters taskManagerParameters,
ContainerSpecification taskManagerContainerSpec,
MesosArtifactResolver artifactResolver,
org.slf4j.Logger log)
Creates the props needed to instantiate this actor.
|
Constructor and Description |
---|
LaunchableMesosWorker(MesosArtifactResolver resolver,
MesosTaskManagerParameters params,
ContainerSpecification containerSpec,
org.apache.mesos.Protos.TaskID taskID,
MesosConfiguration mesosConfiguration)
Construct a launchable Mesos worker.
|
MesosFlinkResourceManager(Configuration flinkConfig,
MesosConfiguration mesosConfig,
MesosWorkerStore workerStore,
LeaderRetrievalService leaderRetrievalService,
MesosTaskManagerParameters taskManagerParameters,
ContainerSpecification taskManagerContainerSpec,
MesosArtifactResolver artifactResolver,
int maxFailedTasks,
int numInitialTaskManagers) |
MesosResourceManager(RpcService rpcService,
String resourceManagerEndpointId,
ResourceID resourceId,
HighAvailabilityServices highAvailabilityServices,
HeartbeatServices heartbeatServices,
SlotManager slotManager,
MetricRegistry metricRegistry,
JobLeaderIdService jobLeaderIdService,
ClusterInformation clusterInformation,
FatalErrorHandler fatalErrorHandler,
Configuration flinkConfig,
MesosServices mesosServices,
MesosConfiguration mesosConfig,
MesosTaskManagerParameters taskManagerParameters,
ContainerSpecification taskManagerContainerSpec,
String webUiUrl,
JobManagerMetricGroup jobManagerMetricGroup) |
MesosResourceManagerFactory(MesosServices mesosServices,
MesosConfiguration schedulerConfiguration,
MesosTaskManagerParameters taskManagerParameters,
ContainerSpecification taskManagerContainerSpec) |
Modifier and Type | Method and Description |
---|---|
MesosConfiguration |
MesosConfiguration.withFrameworkInfo(org.apache.mesos.Protos.FrameworkInfo.Builder frameworkInfo)
Revise the configuration with updated framework info.
|
Modifier and Type | Method and Description |
---|---|
static void |
MesosConfiguration.logMesosConfig(org.slf4j.Logger log,
MesosConfiguration config)
A utility method to log relevant Mesos connection info.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.