public class YarnJobClusterEntrypoint extends JobClusterEntrypoint
Modifier and Type | Field and Description |
---|---|
static String |
JOB_GRAPH_FILE_PATH
The job graph file path.
|
LOG, RUNTIME_FAILURE_RETURN_CODE, STARTUP_FAILURE_RETURN_CODE, SUCCESS_RETURN_CODE
Constructor and Description |
---|
YarnJobClusterEntrypoint(Configuration configuration,
String workingDirectory) |
Modifier and Type | Method and Description |
---|---|
protected ResourceManager<?> |
createResourceManager(Configuration configuration,
ResourceID resourceId,
RpcService rpcService,
HighAvailabilityServices highAvailabilityServices,
HeartbeatServices heartbeatServices,
MetricRegistry metricRegistry,
FatalErrorHandler fatalErrorHandler) |
protected SecurityContext |
installSecurityContext(Configuration configuration) |
static void |
main(String[] args) |
protected JobGraph |
retrieveJobGraph(Configuration configuration) |
createJobManagerRunner, startClusterComponents, stopClusterComponents
configureFileSystems, createHaServices, createHeartbeatServices, createMetricRegistry, createRpcService, getTerminationFuture, initializeServices, loadConfiguration, onFatalError, parseArguments, runCluster, shutDown, startCluster
public static final String JOB_GRAPH_FILE_PATH
public YarnJobClusterEntrypoint(Configuration configuration, String workingDirectory)
protected SecurityContext installSecurityContext(Configuration configuration) throws Exception
installSecurityContext
in class ClusterEntrypoint
Exception
protected ResourceManager<?> createResourceManager(Configuration configuration, ResourceID resourceId, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, HeartbeatServices heartbeatServices, MetricRegistry metricRegistry, FatalErrorHandler fatalErrorHandler) throws Exception
createResourceManager
in class JobClusterEntrypoint
Exception
protected JobGraph retrieveJobGraph(Configuration configuration) throws FlinkException
retrieveJobGraph
in class JobClusterEntrypoint
FlinkException
public static void main(String[] args)
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.