public final class StandaloneJobClusterEntryPoint extends JobClusterEntrypoint
JobClusterEntrypoint
which is started with a job in a predefined
location.ClusterEntrypoint.ExecutionMode
EXECUTION_MODE, LOG, RUNTIME_FAILURE_RETURN_CODE, STARTUP_FAILURE_RETURN_CODE, SUCCESS_RETURN_CODE
Modifier and Type | Method and Description |
---|---|
protected ResourceManager<?> |
createResourceManager(Configuration configuration,
ResourceID resourceId,
RpcService rpcService,
HighAvailabilityServices highAvailabilityServices,
HeartbeatServices heartbeatServices,
MetricRegistry metricRegistry,
FatalErrorHandler fatalErrorHandler,
ClusterInformation clusterInformation,
String webInterfaceUrl,
JobManagerMetricGroup jobManagerMetricGroup) |
static void |
main(String[] args) |
protected void |
registerShutdownActions(CompletableFuture<ApplicationStatus> terminationFuture) |
protected JobGraph |
retrieveJobGraph(Configuration configuration) |
createDispatcher, createRestEndpoint, createSerializableExecutionGraphStore
configureFileSystems, createHaServices, createHeartbeatServices, createMetricRegistry, createRpcService, getRPCPortRange, getTerminationFuture, initializeServices, installSecurityContext, loadConfiguration, onFatalError, parseArguments, runCluster, shutDownAndTerminate, startCluster, startClusterComponents, stopClusterComponents, stopClusterServices
protected JobGraph retrieveJobGraph(Configuration configuration) throws FlinkException
retrieveJobGraph
in class JobClusterEntrypoint
FlinkException
protected void registerShutdownActions(CompletableFuture<ApplicationStatus> terminationFuture)
registerShutdownActions
in class JobClusterEntrypoint
protected ResourceManager<?> createResourceManager(Configuration configuration, ResourceID resourceId, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, HeartbeatServices heartbeatServices, MetricRegistry metricRegistry, FatalErrorHandler fatalErrorHandler, ClusterInformation clusterInformation, @Nullable String webInterfaceUrl, JobManagerMetricGroup jobManagerMetricGroup) throws Exception
createResourceManager
in class ClusterEntrypoint
Exception
public static void main(String[] args)
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.