org.apache.flink.runtime.entrypoint.component

Class DispatcherResourceManagerComponent

java.lang.Object

org.apache.flink.runtime.entrypoint.component.DispatcherResourceManagerComponent

All Implemented Interfaces:

AutoCloseable, AutoCloseableAsync

public class DispatcherResourceManagerComponent
extends Object
implements AutoCloseableAsync

Component which starts a Dispatcher, ResourceManager and WebMonitorEndpoint in the same process.

Method Summary

Modifier and Type	Method and Description
CompletableFuture<Void>	closeAsync() Trigger the closing of the resource and return the corresponding close future.
CompletableFuture<ApplicationStatus>	getShutDownFuture()
CompletableFuture<Void>	stopApplication(ApplicationStatus applicationStatus, String diagnostics) Deregister the Flink application from the resource management system by signalling the ResourceManager and also stop the process.
CompletableFuture<Void>	stopProcess() Close the web monitor and cluster components.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.flink.util.AutoCloseableAsync

close

Method Detail

getShutDownFuture

public final CompletableFuture<ApplicationStatus> getShutDownFuture()

stopApplication

public CompletableFuture<Void> stopApplication(ApplicationStatus applicationStatus,
                                               @Nullable
                                               String diagnostics)

Deregister the Flink application from the resource management system by signalling the ResourceManager and also stop the process.

Parameters:

applicationStatus - to terminate the application with

diagnostics - additional information about the shut down, can be null

Returns:

Future which is completed once the shut down

stopProcess

public CompletableFuture<Void> stopProcess()

Close the web monitor and cluster components. This method will not deregister the Flink application from the resource management and only stop the process.

Returns:

Future which is completed once the shut down

closeAsync

public CompletableFuture<Void> closeAsync()

Description copied from interface: AutoCloseableAsync

Trigger the closing of the resource and return the corresponding close future.

Specified by:

closeAsync in interface AutoCloseableAsync

Returns:

Future which is completed once the resource has been closed