Interface ResourceManagerService

    • Method Detail

      • start

        void start()
            throws Exception
        Start the service.
        Throws:
        Exception - if the service cannot be started
      • getTerminationFuture

        CompletableFuture<Void> getTerminationFuture()
        Return termination future of the service.
        Returns:
        termination future of the service.
      • deregisterApplication

        CompletableFuture<Void> deregisterApplication​(ApplicationStatus applicationStatus,
                                                      @Nullable
                                                      String diagnostics)
        Deregister the Flink application from the resource management system by signalling the ResourceManager.
        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