Modifier and Type | Method and Description |
---|---|
protected Configuration |
AbstractCustomCommandLine.applyCommandLineOptionsToConfiguration(org.apache.commons.cli.CommandLine commandLine)
Override configuration settings by specified command line options.
|
StandaloneClusterDescriptor |
DefaultCLI.createClusterDescriptor(org.apache.commons.cli.CommandLine commandLine) |
ClusterDescriptor<T> |
CustomCommandLine.createClusterDescriptor(org.apache.commons.cli.CommandLine commandLine)
Create a
ClusterDescriptor from the given configuration, configuration directory
and the command line. |
LegacyStandaloneClusterDescriptor |
LegacyCLI.createClusterDescriptor(org.apache.commons.cli.CommandLine commandLine) |
ClusterSpecification |
CustomCommandLine.getClusterSpecification(org.apache.commons.cli.CommandLine commandLine)
Returns the
ClusterSpecification specified by the configuration and the command
line options. |
protected void |
CliFrontend.modify(String[] args) |
Modifier and Type | Class and Description |
---|---|
class |
ClusterDeploymentException
Class which indicates a problem when deploying a Flink cluster.
|
class |
ClusterRetrieveException
Exception which indicates that a cluster could not be retrieved.
|
Modifier and Type | Method and Description |
---|---|
void |
LegacyStandaloneClusterDescriptor.killCluster(StandaloneClusterId clusterId) |
void |
StandaloneClusterDescriptor.killCluster(StandaloneClusterId clusterId) |
void |
ClusterDescriptor.killCluster(T clusterId)
Terminates the cluster with the given cluster id.
|
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 |
---|---|
CompletableFuture<Acknowledge> |
ClusterClient.disposeSavepoint(String savepointPath) |
akka.actor.ActorSystem |
ClusterClient.LazyActorSystemLoader.get()
Creates a new ActorSystem or returns an existing one.
|
ActorGateway |
ClusterClient.getJobManagerGateway()
Returns the
ActorGateway of the current job manager leader using
the LeaderRetrievalService . |
CompletableFuture<String> |
ClusterClient.triggerSavepoint(JobID jobId,
String savepointDirectory)
Triggers a savepoint for the job identified by the job id.
|
Modifier and Type | Method and Description |
---|---|
protected JobGraph |
MesosJobClusterEntrypoint.retrieveJobGraph(Configuration configuration) |
Modifier and Type | Class and Description |
---|---|
class |
UnknownLocationException
Exception to fail Future if the Task Manager on which the
Client Proxy is running on, does not know the location
of a requested state. |
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 | Class and Description |
---|---|
class |
CheckpointTriggerException
Exceptions which indicate that a checkpoint triggering has failed.
|
Modifier and Type | Method and Description |
---|---|
static void |
Checkpoints.disposeSavepoint(String pointer,
Configuration configuration,
ClassLoader classLoader,
org.slf4j.Logger logger) |
static void |
Checkpoints.disposeSavepoint(String pointer,
StateBackend stateBackend,
ClassLoader classLoader) |
Modifier and Type | Method and Description |
---|---|
static void |
MasterHooks.close(Collection<MasterTriggerRestoreHook<?>> hooks,
org.slf4j.Logger log)
Closes the master hooks.
|
static void |
MasterHooks.reset(Collection<MasterTriggerRestoreHook<?>> hooks,
org.slf4j.Logger log)
Resets the master hooks.
|
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) |
Modifier and Type | Class and Description |
---|---|
class |
NoResourceAvailableException |
Modifier and Type | Class and Description |
---|---|
class |
SlotException
Base class for slot related exceptions.
|
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 . |
class |
JobMasterException
Base class for
JobMaster related exceptions. |
class |
JobNotFinishedException
Exception indicating that a Flink job has not been finished.
|
Modifier and Type | Class and Description |
---|---|
class |
JobModificationException
Base class for all exception which originate from a failed job modification.
|
Modifier and Type | Class and Description |
---|---|
class |
LeaderRetrievalException
This exception is thrown by the
LeaderRetrievalUtils when
the method retrieveLeaderGateway fails to retrieve the current leader's gateway. |
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 |
NotFoundException
A special exception that indicates that an element was not found and that the
request should be answered with a
404 return code. |
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 | Method and Description |
---|---|
void |
BackPressureStatsTracker.shutDown()
Shuts the BackPressureStatsTracker down.
|
Modifier and Type | Class and Description |
---|---|
class |
ConversionException
Exception which is thrown if an input cannot be 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.
|
Modifier and Type | Method and Description |
---|---|
void |
TaskManagerServices.shutDown()
Shuts the
TaskExecutor services down. |
Constructor and Description |
---|
LeaderConnectionInfo(String address,
UUID leaderSessionID) |
Modifier and Type | Method and Description |
---|---|
static WebMonitorExtension |
WebMonitorUtils.loadWebSubmissionExtension(GatewayRetriever<? extends DispatcherGateway> leaderRetriever,
CompletableFuture<String> restAddressFuture,
Time timeout,
Map<String,String> responseHeaders,
Path uploadDir,
Executor executor,
Configuration configuration)
Loads the
WebMonitorExtension which enables web submission. |
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 | Method and Description |
---|---|
static <X> X |
InterpreterUtils.deserializeFunction(RuntimeContext context,
byte[] serFun)
Deserialize the given python function.
|
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 |
---|---|
T |
OptionalFailure.get() |
Modifier and Type | Method and Description |
---|---|
void |
AbstractYarnClusterDescriptor.killCluster(org.apache.hadoop.yarn.api.records.ApplicationId applicationId) |
Modifier and Type | Method and Description |
---|---|
protected Configuration |
FlinkYarnSessionCli.applyCommandLineOptionsToConfiguration(org.apache.commons.cli.CommandLine commandLine) |
AbstractYarnClusterDescriptor |
FlinkYarnSessionCli.createClusterDescriptor(org.apache.commons.cli.CommandLine commandLine) |
ClusterSpecification |
FlinkYarnSessionCli.getClusterSpecification(org.apache.commons.cli.CommandLine commandLine) |
int |
FlinkYarnSessionCli.run(String[] args) |
Constructor and Description |
---|
FlinkYarnSessionCli(Configuration configuration,
String configurationDirectory,
String shortPrefix,
String longPrefix) |
FlinkYarnSessionCli(Configuration configuration,
String configurationDirectory,
String shortPrefix,
String longPrefix,
boolean acceptInteractiveInput) |
Modifier and Type | Method and Description |
---|---|
protected JobGraph |
YarnJobClusterEntrypoint.retrieveJobGraph(Configuration configuration) |
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.