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.clusterframework.standalone | |
org.apache.flink.runtime.jobmanager.slots | |
org.apache.flink.runtime.jobmaster | |
org.apache.flink.runtime.resourcemanager | |
org.apache.flink.yarn |
Modifier and Type | Method and Description |
---|---|
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.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 |
---|---|
void |
TaskManagerGateway.stopCluster(ApplicationStatus applicationStatus,
String message)
Stop the cluster.
|
void |
ActorTaskManagerGateway.stopCluster(ApplicationStatus applicationStatus,
String message) |
Modifier and Type | Method and Description |
---|---|
void |
RpcTaskManagerGateway.stopCluster(ApplicationStatus applicationStatus,
String message) |
Modifier and Type | Method and Description |
---|---|
protected void |
StandaloneResourceManager.shutDownApplication(ApplicationStatus finalStatus,
String optionalDiagnostics) |
protected abstract void |
ResourceManager.shutDownApplication(ApplicationStatus finalStatus,
String optionalDiagnostics)
The framework specific code for shutting down the application.
|
void |
ResourceManagerGateway.shutDownCluster(ApplicationStatus finalStatus,
String optionalDiagnostics)
shutdown cluster
|
void |
ResourceManager.shutDownCluster(ApplicationStatus finalStatus,
String optionalDiagnostics)
Cleanup application and shut down cluster
|
Modifier and Type | Method and Description |
---|---|
ApplicationStatus |
YarnClusterClientV2.getApplicationStatus() |
ApplicationStatus |
YarnClusterClient.getApplicationStatus() |
ApplicationStatus |
YarnMessages.LocalStopYarnSession.status() |
Modifier and Type | Method and Description |
---|---|
protected void |
YarnFlinkApplicationMasterRunner.shutdown(ApplicationStatus status,
String msg) |
protected void |
YarnFlinkResourceManager.shutdownApplication(ApplicationStatus finalStatus,
String optionalDiagnostics) |
protected void |
YarnResourceManager.shutDownApplication(ApplicationStatus finalStatus,
String optionalDiagnostics) |
Constructor and Description |
---|
LocalStopYarnSession(ApplicationStatus status,
String diagnostics) |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.