Package | Description |
---|---|
org.apache.flink.runtime.jobmaster |
Modifier and Type | Method and Description |
---|---|
static JobManagerServices |
JobManagerServices.fromConfiguration(Configuration config,
HighAvailabilityServices haServices) |
Constructor and Description |
---|
JobManagerRunner(ResourceID resourceId,
JobGraph jobGraph,
Configuration configuration,
RpcService rpcService,
HighAvailabilityServices haServices,
HeartbeatServices heartbeatServices,
JobManagerServices jobManagerServices,
MetricRegistry metricRegistry,
OnCompletionActions toNotifyOnComplete,
FatalErrorHandler errorHandler)
Exceptions that occur while creating the JobManager or JobManagerRunner are directly
thrown and not reported to the given
FatalErrorHandler . |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.