Package | Description |
---|---|
org.apache.flink.client.deployment.application | |
org.apache.flink.kubernetes | |
org.apache.flink.runtime.clusterframework |
This package contains the cluster resource management functionality.
|
org.apache.flink.runtime.dispatcher | |
org.apache.flink.runtime.dispatcher.runner | |
org.apache.flink.runtime.entrypoint | |
org.apache.flink.runtime.entrypoint.component | |
org.apache.flink.runtime.jobmaster | |
org.apache.flink.runtime.resourcemanager | |
org.apache.flink.runtime.resourcemanager.active | |
org.apache.flink.yarn | |
org.apache.flink.yarn.cli |
Modifier and Type | Method and Description |
---|---|
ApplicationStatus |
UnsuccessfulExecutionException.getStatus() |
Constructor and Description |
---|
UnsuccessfulExecutionException(JobID jobID,
ApplicationStatus status,
String message,
Throwable cause) |
Modifier and Type | Method and Description |
---|---|
void |
KubernetesResourceManagerDriver.deregisterApplication(ApplicationStatus finalStatus,
String optionalDiagnostics) |
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 | Field and Description |
---|---|
protected CompletableFuture<ApplicationStatus> |
Dispatcher.shutDownFuture |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<ApplicationStatus> |
Dispatcher.getShutDownFuture() |
Modifier and Type | Method and Description |
---|---|
default CompletableFuture<Acknowledge> |
DispatcherGateway.shutDownCluster(ApplicationStatus applicationStatus) |
CompletableFuture<Acknowledge> |
Dispatcher.shutDownCluster(ApplicationStatus applicationStatus) |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<ApplicationStatus> |
DefaultDispatcherGatewayService.getShutDownFuture() |
CompletableFuture<ApplicationStatus> |
DefaultDispatcherRunner.getShutDownFuture() |
CompletableFuture<ApplicationStatus> |
AbstractDispatcherLeaderProcess.getShutDownFuture() |
CompletableFuture<ApplicationStatus> |
AbstractDispatcherLeaderProcess.DispatcherGatewayService.getShutDownFuture() |
CompletableFuture<ApplicationStatus> |
DispatcherRunner.getShutDownFuture()
Return shut down future of this runner.
|
CompletableFuture<ApplicationStatus> |
StoppedDispatcherLeaderProcess.getShutDownFuture() |
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.stopApplication(ApplicationStatus applicationStatus,
String diagnostics)
Deregister the Flink application from the resource management system by signalling the
ResourceManager and also stop the process. |
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.
|
CompletableFuture<Void> |
ResourceManagerServiceImpl.deregisterApplication(ApplicationStatus applicationStatus,
String diagnostics) |
CompletableFuture<Void> |
ResourceManagerService.deregisterApplication(ApplicationStatus applicationStatus,
String diagnostics)
Deregister the Flink application from the resource management system by signalling the
ResourceManager . |
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 |
---|---|
void |
ResourceManagerDriver.deregisterApplication(ApplicationStatus finalStatus,
String optionalDiagnostics)
The deployment specific code to deregister the application.
|
protected void |
ActiveResourceManager.internalDeregisterApplication(ApplicationStatus finalStatus,
String optionalDiagnostics) |
Modifier and Type | Method and Description |
---|---|
void |
YarnResourceManagerDriver.deregisterApplication(ApplicationStatus finalStatus,
String optionalDiagnostics) |
Modifier and Type | Method and Description |
---|---|
ApplicationStatus |
YarnApplicationStatusMonitor.getApplicationStatusNow() |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.