org.apache.flink.runtime.jobmaster

Class JobManagerSharedServices

java.lang.Object

org.apache.flink.runtime.jobmaster.JobManagerSharedServices

public class JobManagerSharedServices
extends Object

Utility class which holds all auxiliary shared services used by the JobMaster. Consequently, the JobMaster should never shut these services down.

Constructor Summary

Constructors

Constructor and Description
JobManagerSharedServices(ScheduledExecutorService scheduledExecutorService, LibraryCacheManager libraryCacheManager, BackPressureRequestCoordinator backPressureSampleCoordinator, BackPressureStatsTracker backPressureStatsTracker, BlobWriter blobWriter)

Method Summary

Modifier and Type	Method and Description
static JobManagerSharedServices	fromConfiguration(Configuration config, BlobServer blobServer, FatalErrorHandler fatalErrorHandler)
BackPressureStatsTracker	getBackPressureStatsTracker()
BlobWriter	getBlobWriter()
LibraryCacheManager	getLibraryCacheManager()
ScheduledExecutorService	getScheduledExecutorService()
void	shutdown() Shutdown the JobMaster services.

Methods inherited from class java.lang.Object

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

Constructor Detail

JobManagerSharedServices

public JobManagerSharedServices(ScheduledExecutorService scheduledExecutorService,
                                LibraryCacheManager libraryCacheManager,
                                BackPressureRequestCoordinator backPressureSampleCoordinator,
                                BackPressureStatsTracker backPressureStatsTracker,
                                @Nonnull
                                BlobWriter blobWriter)

Method Detail

getScheduledExecutorService

public ScheduledExecutorService getScheduledExecutorService()

getLibraryCacheManager

public LibraryCacheManager getLibraryCacheManager()

getBackPressureStatsTracker

public BackPressureStatsTracker getBackPressureStatsTracker()

getBlobWriter

@Nonnull
public BlobWriter getBlobWriter()

shutdown

public void shutdown()
              throws Exception

Shutdown the JobMaster services.

This method makes sure all services are closed or shut down, even when an exception occurred in the shutdown of one component. The first encountered exception is thrown, with successive exceptions added as suppressed exceptions.

Throws:

Exception - The first Exception encountered during shutdown.

fromConfiguration

public static JobManagerSharedServices fromConfiguration(Configuration config,
                                                         BlobServer blobServer,
                                                         FatalErrorHandler fatalErrorHandler)