public interface ResourceManagerService extends AutoCloseableAsync
ResourceManager
.Modifier and Type | Method and Description |
---|---|
CompletableFuture<Void> |
deregisterApplication(ApplicationStatus applicationStatus,
String diagnostics)
Deregister the Flink application from the resource management system by signalling the
ResourceManager . |
CompletableFuture<Void> |
getTerminationFuture()
Return termination future of the service.
|
void |
start()
Start the service.
|
close, closeAsync
void start() throws Exception
Exception
- if the service cannot be startedCompletableFuture<Void> getTerminationFuture()
CompletableFuture<Void> deregisterApplication(ApplicationStatus applicationStatus, @Nullable String diagnostics)
ResourceManager
.applicationStatus
- to terminate the application withdiagnostics
- additional information about the shut down, can be null
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.