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.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 |
---|---|
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.