Package | Description |
---|---|
org.apache.flink.mesos.entrypoint | |
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.clusterframework.standalone | |
org.apache.flink.runtime.dispatcher | |
org.apache.flink.runtime.entrypoint | |
org.apache.flink.runtime.jobmanager.slots | |
org.apache.flink.runtime.jobmaster | |
org.apache.flink.runtime.resourcemanager | |
org.apache.flink.yarn | |
org.apache.flink.yarn.cli | |
org.apache.flink.yarn.entrypoint |
Modifier and Type | Method and Description |
---|---|
protected void |
MesosJobClusterEntrypoint.registerShutdownActions(CompletableFuture<ApplicationStatus> terminationFuture) |
Modifier and Type | Method and Description |
---|---|
protected void |
MesosResourceManager.internalDeregisterApplication(ApplicationStatus finalStatus,
String diagnostics) |
protected void |
MesosFlinkResourceManager.shutdownApplication(ApplicationStatus finalStatus,
String optionalDiagnostics)
Called to shut down the cluster (not a failover situation).
|
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 |
---|---|
protected abstract void |
FlinkResourceManager.shutdownApplication(ApplicationStatus finalStatus,
String optionalDiagnostics)
The framework specific code for shutting down the application.
|
Modifier and Type | Method and Description |
---|---|
ApplicationStatus |
StopCluster.finalStatus() |
Constructor and Description |
---|
StopCluster(ApplicationStatus finalStatus,
String message) |
Modifier and Type | Method and Description |
---|---|
protected void |
StandaloneResourceManager.shutdownApplication(ApplicationStatus finalStatus,
String optionalDiagnostics) |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<ApplicationStatus> |
MiniDispatcher.getJobTerminationFuture() |
Modifier and Type | Method and Description |
---|---|
protected void |
ClusterEntrypoint.shutDownAndTerminate(int returnCode,
ApplicationStatus applicationStatus,
String diagnostics,
boolean cleanupHaData) |
Modifier and Type | Method and Description |
---|---|
protected abstract void |
JobClusterEntrypoint.registerShutdownActions(CompletableFuture<ApplicationStatus> terminationFuture) |
Modifier and Type | Method and Description |
---|---|
void |
ActorTaskManagerGateway.stopCluster(ApplicationStatus applicationStatus,
String message) |
void |
TaskManagerGateway.stopCluster(ApplicationStatus applicationStatus,
String message)
Stop the cluster.
|
Modifier and Type | Method and Description |
---|---|
ApplicationStatus |
JobResult.getApplicationStatus() |
Modifier and Type | Method and Description |
---|---|
JobResult.Builder |
JobResult.Builder.applicationStatus(ApplicationStatus applicationStatus) |
void |
RpcTaskManagerGateway.stopCluster(ApplicationStatus applicationStatus,
String message) |
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) |
protected void |
YarnFlinkResourceManager.shutdownApplication(ApplicationStatus finalStatus,
String optionalDiagnostics) |
Modifier and Type | Method and Description |
---|---|
ApplicationStatus |
YarnApplicationStatusMonitor.getApplicationStatusNow() |
Modifier and Type | Method and Description |
---|---|
protected void |
YarnJobClusterEntrypoint.registerShutdownActions(CompletableFuture<ApplicationStatus> terminationFuture) |
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.