org.apache.flink.runtime.entrypoint

Class JobClusterEntrypoint

java.lang.Object

org.apache.flink.runtime.entrypoint.ClusterEntrypoint

org.apache.flink.runtime.entrypoint.JobClusterEntrypoint

All Implemented Interfaces:

FatalErrorHandler

Direct Known Subclasses:

MesosJobClusterEntrypoint, YarnJobClusterEntrypoint

public abstract class JobClusterEntrypoint
extends ClusterEntrypoint

Base class for per-job cluster entry points.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.flink.runtime.entrypoint.ClusterEntrypoint

ClusterEntrypoint.ExecutionMode

Field Summary

Fields inherited from class org.apache.flink.runtime.entrypoint.ClusterEntrypoint

EXECUTION_MODE, LOG, RUNTIME_FAILURE_RETURN_CODE, STARTUP_FAILURE_RETURN_CODE, SUCCESS_RETURN_CODE

Constructor Summary

Constructors

Constructor and Description
JobClusterEntrypoint(Configuration configuration)

Method Summary

Modifier and Type	Method and Description
protected Dispatcher	createDispatcher(Configuration configuration, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, ResourceManagerGateway resourceManagerGateway, BlobServer blobServer, HeartbeatServices heartbeatServices, JobManagerMetricGroup jobManagerMetricGroup, String metricQueryServicePath, ArchivedExecutionGraphStore archivedExecutionGraphStore, FatalErrorHandler fatalErrorHandler, String restAddress, HistoryServerArchivist historyServerArchivist)
protected MiniDispatcherRestEndpoint	createRestEndpoint(Configuration configuration, LeaderGatewayRetriever<DispatcherGateway> dispatcherGatewayRetriever, LeaderGatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever, TransientBlobService transientBlobService, ExecutorService executor, MetricQueryServiceRetriever metricQueryServiceRetriever, LeaderElectionService leaderElectionService)
protected ArchivedExecutionGraphStore	createSerializableExecutionGraphStore(Configuration configuration, ScheduledExecutor scheduledExecutor)
protected abstract void	registerShutdownActions(CompletableFuture<ApplicationStatus> terminationFuture)
protected abstract JobGraph	retrieveJobGraph(Configuration configuration)

Methods inherited from class org.apache.flink.runtime.entrypoint.ClusterEntrypoint

configureFileSystems, createHaServices, createHeartbeatServices, createMetricRegistry, createResourceManager, createRpcService, getRPCPortRange, getTerminationFuture, initializeServices, installSecurityContext, loadConfiguration, onFatalError, parseArguments, runCluster, shutDownAndTerminate, startCluster, startClusterComponents, stopClusterComponents, stopClusterServices

Methods inherited from class java.lang.Object

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

Constructor Detail

JobClusterEntrypoint

public JobClusterEntrypoint(Configuration configuration)

Method Detail

createRestEndpoint

protected MiniDispatcherRestEndpoint createRestEndpoint(Configuration configuration,
                                                        LeaderGatewayRetriever<DispatcherGateway> dispatcherGatewayRetriever,
                                                        LeaderGatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever,
                                                        TransientBlobService transientBlobService,
                                                        ExecutorService executor,
                                                        MetricQueryServiceRetriever metricQueryServiceRetriever,
                                                        LeaderElectionService leaderElectionService)
                                                 throws Exception

Specified by:

createRestEndpoint in class ClusterEntrypoint

Throws:

Exception

createSerializableExecutionGraphStore

protected ArchivedExecutionGraphStore createSerializableExecutionGraphStore(Configuration configuration,
                                                                            ScheduledExecutor scheduledExecutor)

Specified by:

createSerializableExecutionGraphStore in class ClusterEntrypoint

createDispatcher

protected Dispatcher createDispatcher(Configuration configuration,
                                      RpcService rpcService,
                                      HighAvailabilityServices highAvailabilityServices,
                                      ResourceManagerGateway resourceManagerGateway,
                                      BlobServer blobServer,
                                      HeartbeatServices heartbeatServices,
                                      JobManagerMetricGroup jobManagerMetricGroup,
                                      @Nullable
                                      String metricQueryServicePath,
                                      ArchivedExecutionGraphStore archivedExecutionGraphStore,
                                      FatalErrorHandler fatalErrorHandler,
                                      @Nullable
                                      String restAddress,
                                      HistoryServerArchivist historyServerArchivist)
                               throws Exception

Specified by:

createDispatcher in class ClusterEntrypoint

Throws:

Exception

retrieveJobGraph

protected abstract JobGraph retrieveJobGraph(Configuration configuration)
                                      throws FlinkException

Throws:

FlinkException

registerShutdownActions

protected abstract void registerShutdownActions(CompletableFuture<ApplicationStatus> terminationFuture)