Package | Description |
---|---|
org.apache.flink.mesos.runtime.clusterframework | |
org.apache.flink.runtime.clusterframework |
This package contains the cluster resource management functionality.
|
org.apache.flink.runtime.clusterframework.messages |
This package contains the actor messages that are sent between the
cluster resource framework and the JobManager, as well as the generic
messages sent between the cluster resource framework and the client.
|
org.apache.flink.runtime.dispatcher | |
org.apache.flink.runtime.entrypoint | |
org.apache.flink.runtime.entrypoint.component | |
org.apache.flink.runtime.jobmaster | |
org.apache.flink.runtime.resourcemanager | |
org.apache.flink.yarn | |
org.apache.flink.yarn.cli |
Modifier and Type | Method and Description |
---|---|
protected void |
MesosResourceManager.internalDeregisterApplication(ApplicationStatus finalStatus,
String diagnostics) |
Modifier and Type | Method and Description |
---|---|
static ApplicationStatus |
ApplicationStatus.fromJobStatus(JobStatus jobStatus)
Derives the ApplicationStatus that should be used for a job that resulted in the given
job status.
|
static ApplicationStatus |
ApplicationStatus.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static ApplicationStatus[] |
ApplicationStatus.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
ApplicationStatus |
StopCluster.finalStatus() |
Constructor and Description |
---|
StopCluster(ApplicationStatus finalStatus,
String message) |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<ApplicationStatus> |
MiniDispatcher.getJobTerminationFuture() |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<ApplicationStatus> |
ClusterEntrypoint.getTerminationFuture() |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<ApplicationStatus> |
DispatcherResourceManagerComponent.getShutDownFuture() |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<Void> |
DispatcherResourceManagerComponent.deregisterApplicationAndClose(ApplicationStatus applicationStatus,
String diagnostics)
Deregister the Flink application from the resource management system by signalling
the
ResourceManager . |
Modifier and Type | Method and Description |
---|---|
ApplicationStatus |
JobResult.getApplicationStatus() |
Modifier and Type | Method and Description |
---|---|
JobResult.Builder |
JobResult.Builder.applicationStatus(ApplicationStatus applicationStatus) |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<Acknowledge> |
ResourceManagerGateway.deregisterApplication(ApplicationStatus finalStatus,
String diagnostics)
Deregister Flink from the underlying resource management system.
|
CompletableFuture<Acknowledge> |
ResourceManager.deregisterApplication(ApplicationStatus finalStatus,
String diagnostics)
Cleanup application and shut down cluster.
|
protected abstract void |
ResourceManager.internalDeregisterApplication(ApplicationStatus finalStatus,
String optionalDiagnostics)
The framework specific code to deregister the application.
|
protected void |
StandaloneResourceManager.internalDeregisterApplication(ApplicationStatus finalStatus,
String diagnostics) |
Modifier and Type | Method and Description |
---|---|
protected void |
YarnResourceManager.internalDeregisterApplication(ApplicationStatus finalStatus,
String diagnostics) |
Modifier and Type | Method and Description |
---|---|
ApplicationStatus |
YarnApplicationStatusMonitor.getApplicationStatusNow() |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.