Package | Description |
---|---|
org.apache.flink.client.deployment | |
org.apache.flink.client.program | |
org.apache.flink.mesos.entrypoint | |
org.apache.flink.runtime | |
org.apache.flink.runtime.checkpoint.hooks | |
org.apache.flink.runtime.client | |
org.apache.flink.runtime.dispatcher | |
org.apache.flink.runtime.entrypoint | |
org.apache.flink.runtime.jobmanager.scheduler | |
org.apache.flink.runtime.jobmaster | |
org.apache.flink.runtime.messages |
This package contains the messages that are sent between actors, like the
JobManager and
TaskManager to coordinate the distributed operations. |
org.apache.flink.runtime.rest.handler | |
org.apache.flink.runtime.rest.messages | |
org.apache.flink.runtime.rest.util | |
org.apache.flink.runtime.webmonitor.history | |
org.apache.flink.streaming.api.checkpoint | |
org.apache.flink.streaming.connectors.kafka | |
org.apache.flink.util | |
org.apache.flink.yarn.entrypoint |
Modifier and Type | Class and Description |
---|---|
class |
ClusterDeploymentException
Class which indicates a problem when deploying a Flink cluster.
|
Modifier and Type | Class and Description |
---|---|
class |
ProgramMissingJobException
Exception used to indicate that no job was executed during the invocation of a Flink program.
|
Modifier and Type | Method and Description |
---|---|
akka.actor.ActorSystem |
ClusterClient.LazyActorSystemLoader.get()
Creates a new ActorSystem or returns an existing one.
|
Modifier and Type | Method and Description |
---|---|
protected JobGraph |
MesosJobClusterEntrypoint.retrieveJobGraph(Configuration configuration) |
Modifier and Type | Class and Description |
---|---|
class |
JobException
Indicates that a job has failed.
|
class |
StoppingException
Indicates that a job is not stoppable.
|
Modifier and Type | Method and Description |
---|---|
static void |
MasterHooks.restoreMasterHooks(Map<String,MasterTriggerRestoreHook<?>> masterHooks,
Collection<MasterState> states,
long checkpointId,
boolean allowUnmatchedState,
org.slf4j.Logger log)
Calls the restore method given checkpoint master hooks and passes the given master
state to them where state with a matching name is found.
|
static List<MasterState> |
MasterHooks.triggerMasterHooks(Collection<MasterTriggerRestoreHook<?>> hooks,
long checkpointId,
long timestamp,
Executor executor,
Time timeout)
Triggers all given master hooks and returns state objects for each hook that
produced a state.
|
Modifier and Type | Class and Description |
---|---|
class |
JobCancellationException
An exception which is thrown by the JobClient if a job is aborted as a result of a user
cancellation.
|
class |
JobClientActorConnectionTimeoutException
Exception which is thrown when the
JobClientActor wants to submit a job to
the job manager but has not found one after a given timeout interval. |
class |
JobClientActorRegistrationTimeoutException
Exception which is thrown by the
JobClientActor if it has not heard back from the job
manager after it has attempted to register for a job within a given timeout interval. |
class |
JobClientActorSubmissionTimeoutException
Exception which is thrown by the
JobClientActor if it has not heard back from the job
manager after it has submitted a job to it within a given timeout interval. |
class |
JobExecutionException
This exception is the base exception for all exceptions that denote any failure during
the execution of a job.
|
class |
JobRetrievalException
Exception used to indicate that a job couldn't be retrieved from the JobManager
|
class |
JobSubmissionException
This exception denotes an error while submitting a job to the JobManager
|
class |
JobTimeoutException
An exception which is thrown by the JobClient if the job manager is no longer reachable.
|
Modifier and Type | Class and Description |
---|---|
class |
DispatcherException
Base class for
Dispatcher related exceptions. |
Modifier and Type | Method and Description |
---|---|
protected abstract JobGraph |
JobClusterEntrypoint.retrieveJobGraph(Configuration configuration) |
protected void |
ClusterEntrypoint.shutDown(boolean cleanupHaData) |
Modifier and Type | Class and Description |
---|---|
class |
NoResourceAvailableException |
Modifier and Type | Class and Description |
---|---|
class |
ExecutionGraphException
Exceptions thrown by operations on the
ExecutionGraph by the JobMaster . |
class |
JobManagerException
Base exception thrown by the
JobMaster . |
Modifier and Type | Class and Description |
---|---|
class |
FlinkJobNotFoundException
Exception indicating that we could not find a Flink job with the given job ID.
|
Modifier and Type | Class and Description |
---|---|
class |
HandlerRequestException
Base class for all
HandlerRequest related exceptions. |
class |
RestHandlerException
An exception that is thrown if the failure of a REST operation was detected by a handler.
|
Modifier and Type | Class and Description |
---|---|
class |
ConversionException
Exception which is thrown if an input cannot converted into the requested type.
|
Modifier and Type | Class and Description |
---|---|
class |
RestClientException
An exception that is thrown if the failure of a REST operation was detected on the client.
|
Constructor and Description |
---|
HistoryServer(Configuration config) |
HistoryServer(Configuration config,
CountDownLatch numFinishedPolls) |
Modifier and Type | Method and Description |
---|---|
void |
ExternallyInducedSource.CheckpointTrigger.triggerCheckpoint(long checkpointId)
Triggers a checkpoint.
|
Modifier and Type | Class and Description |
---|---|
class |
FlinkKafka011Exception
Exception used by
FlinkKafkaProducer011 and FlinkKafkaConsumer011 . |
Modifier and Type | Class and Description |
---|---|
class |
ConfigurationException
Exception which occurs when creating a configuration object fails.
|
class |
DynamicCodeLoadingException
An exception that is thrown if the dynamic instantiation of code fails.
|
class |
StateMigrationException
Base class for state migration related exceptions
|
Modifier and Type | Method and Description |
---|---|
protected JobGraph |
YarnJobClusterEntrypoint.retrieveJobGraph(Configuration configuration) |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.