Modifier and Type | Method and Description |
---|---|
Configuration |
CustomCommandLine.toConfiguration(org.apache.commons.cli.CommandLine commandLine)
Materializes the command line arguments in the given
CommandLine to a Configuration and returns it. |
Configuration |
AbstractCustomCommandLine.toConfiguration(org.apache.commons.cli.CommandLine commandLine) |
Configuration |
DefaultCLI.toConfiguration(org.apache.commons.cli.CommandLine commandLine) |
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 |
StandaloneClusterDescriptor.killCluster(StandaloneClusterId clusterId) |
void |
ClusterDescriptor.killCluster(T clusterId)
Terminates the cluster with the given cluster id.
|
Modifier and Type | Class and Description |
---|---|
class |
ApplicationExecutionException
A
FlinkException thrown in case something during application execution went wrong. |
class |
UnsuccessfulExecutionException
Exception that signals the failure of an application with a given
ApplicationStatus . |
Modifier and Type | Method and Description |
---|---|
PackagedProgram |
ClassPathPackagedProgramRetriever.getPackagedProgram() |
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)
Dispose the savepoint under the given path.
|
PackagedProgram |
PackagedProgramRetriever.getPackagedProgram()
Retrieve the
PackagedProgram . |
Modifier and Type | Method and Description |
---|---|
void |
KubernetesClusterDescriptor.killCluster(String clusterId) |
Modifier and Type | Class and Description |
---|---|
class |
KubernetesException
Kubernetes related checked exceptions.
|
class |
KubernetesTooOldResourceVersionException
Kubernetes too old resource version exception.
|
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.
|
Modifier and Type | Method and Description |
---|---|
static void |
Checkpoints.disposeSavepoint(String pointer,
CheckpointStorage checkpointStorage,
ClassLoader classLoader) |
static void |
Checkpoints.disposeSavepoint(String pointer,
Configuration configuration,
ClassLoader classLoader,
org.slf4j.Logger logger) |
Modifier and Type | Method and Description |
---|---|
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.
|
Modifier and Type | Class and Description |
---|---|
class |
DuplicateJobSubmissionException
Exception which is returned upon job submission if the submitted job is currently being executed.
|
class |
JobCancellationException
An exception which is thrown by the JobClient if a job is aborted as a result of a user
cancellation.
|
class |
JobExecutionException
This exception is the base exception for all exceptions that denote any failure during the
execution of a job.
|
class |
JobInitializationException
An exception indicating that the job has failed in the INITIALIZING job status.
|
class |
JobSubmissionException
This exception denotes an error while submitting a job to the JobManager.
|
Modifier and Type | Method and Description |
---|---|
static void |
ClientUtils.extractAndUploadJobGraphFiles(JobGraph jobGraph,
SupplierWithException<BlobClient,IOException> clientSupplier)
Extracts all files required for the execution from the given
JobGraph and uploads
them using the BlobClient from the given Supplier . |
static void |
ClientUtils.uploadJobGraphFiles(JobGraph jobGraph,
Collection<Path> userJars,
Collection<Tuple2<String,Path>> userArtifacts,
SupplierWithException<BlobClient,IOException> clientSupplier)
Uploads the given jars and artifacts required for the execution of the given
JobGraph
using the BlobClient from the given Supplier . |
Modifier and Type | Class and Description |
---|---|
class |
DispatcherException
Base class for
Dispatcher related exceptions. |
class |
UnavailableDispatcherOperationException
Exception indicating that a Dispatcher operation is temporarily unavailable.
|
Modifier and Type | Class and Description |
---|---|
class |
ClusterEntrypointException
Exceptions thrown by the
ClusterEntrypoint . |
class |
FlinkParseException
Exception which indicates that the parsing of command line arguments failed.
|
Modifier and Type | Method and Description |
---|---|
JobGraph |
FileJobGraphRetriever.retrieveJobGraph(Configuration configuration) |
JobGraph |
JobGraphRetriever.retrieveJobGraph(Configuration configuration)
Retrieve the
JobGraph . |
Modifier and Type | Method and Description |
---|---|
void |
AbstractInvokable.dispatchOperatorEvent(OperatorID operator,
SerializedValue<OperatorEvent> event) |
Modifier and Type | Class and Description |
---|---|
class |
NoResourceAvailableException
Indicates resource allocation failures.
|
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 |
LeaderElectionException
This exception is thrown by the
LeaderElectionDriver when LeaderElectionDriver.writeLeaderInformation(org.apache.flink.runtime.leaderelection.LeaderInformation) failed or some unexpected changes to the leader
storage. |
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 |
TaskNotRunningException
An exception indicating that a target task is not running.
|
Modifier and Type | Class and Description |
---|---|
class |
PossibleInconsistentStateException
PossibleInconsistentStateException represents errors that might have lead to an
inconsistent state within the HA resources. |
static class |
StateHandleStore.AlreadyExistException
The key already exists in ConfigMap or the Zookeeper node already exists.
|
static class |
StateHandleStore.NotExistException
The key does not exist in ConfigMap or the Zookeeper node does not exists.
|
Modifier and Type | Class and Description |
---|---|
class |
ResourceManagerException
Base class for
ResourceManager exceptions. |
class |
UnfulfillableSlotRequestException
Exception denoting that a slot request can not be fulfilled by any slot in the cluster.
|
class |
UnknownTaskExecutorException
Exception denoting that a requested
TaskExecutor could not be found. |
Modifier and Type | Class and Description |
---|---|
class |
SlotManagerException
Base class for exceptions thrown by the
SlotManager . |
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 |
---|---|
static void |
HandlerUtils.transferFile(org.apache.flink.shaded.netty4.io.netty.channel.ChannelHandlerContext ctx,
File file,
org.apache.flink.shaded.netty4.io.netty.handler.codec.http.HttpRequest httpRequest) |
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 |
---|---|
CompletableFuture<CoordinationResponse> |
AdaptiveScheduler.deliverCoordinationRequestToCoordinator(OperatorID operator,
CoordinationRequest request) |
void |
AdaptiveScheduler.deliverOperatorEventToCoordinator(ExecutionAttemptID taskExecution,
OperatorID operator,
OperatorEvent evt) |
Modifier and Type | Method and Description |
---|---|
static ShuffleServiceFactory<?,?,?> |
ShuffleServiceLoader.loadShuffleServiceFactory(Configuration configuration) |
Modifier and Type | Method and Description |
---|---|
void |
TaskManagerServices.shutDown()
Shuts the
TaskExecutor services down. |
Modifier and Type | Method and Description |
---|---|
void |
Task.deliverOperatorEvent(OperatorID operator,
SerializedValue<OperatorEvent> evt)
Dispatches an operator event to the invokable task.
|
Modifier and Type | Method and Description |
---|---|
static Configuration |
FlinkConfigLoader.loadConfiguration(String[] args) |
static void |
BashJavaUtils.main(String[] args) |
Modifier and Type | Method and Description |
---|---|
static WebMonitorExtension |
WebMonitorUtils.loadWebSubmissionExtension(GatewayRetriever<? extends DispatcherGateway> leaderRetriever,
Time timeout,
Map<String,String> responseHeaders,
CompletableFuture<String> localAddressFuture,
Path uploadDir,
Executor executor,
Configuration configuration)
Loads the
WebMonitorExtension which enables web submission. |
Constructor and Description |
---|
HistoryServer(Configuration config) |
HistoryServer(Configuration config,
java.util.function.Consumer<HistoryServerArchiveFetcher.ArchiveEvent> jobArchiveEventListener)
Creates HistoryServer instance.
|
Modifier and Type | Method and Description |
---|---|
void |
JobVertexStatsTracker.shutDown()
Shuts the
JobVertexStatsTracker down. |
Modifier and Type | Method and Description |
---|---|
void |
ExternallyInducedSource.CheckpointTrigger.triggerCheckpoint(long checkpointId)
Triggers a checkpoint.
|
Modifier and Type | Class and Description |
---|---|
class |
FlinkKafkaException
Exception used by
FlinkKafkaProducer and FlinkKafkaConsumer . |
Modifier and Type | Method and Description |
---|---|
void |
OperatorChain.dispatchOperatorEvent(OperatorID operator,
SerializedValue<OperatorEvent> event) |
void |
StreamTask.dispatchOperatorEvent(OperatorID operator,
SerializedValue<OperatorEvent> event) |
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() |
static <T> T |
InstantiationUtil.instantiate(String className,
Class<T> targetType,
ClassLoader classLoader)
Creates a new instance of the given class name and type using the provided
ClassLoader . |
Modifier and Type | Method and Description |
---|---|
int |
YarnClusterInformationRetriever.getMaxVcores()
Get the maximum number of vcores supported by the Yarn cluster.
|
int |
YarnClientYarnClusterInformationRetriever.getMaxVcores() |
static List<org.apache.hadoop.fs.Path> |
Utils.getQualifiedRemoteSharedPaths(Configuration configuration,
org.apache.hadoop.yarn.conf.YarnConfiguration yarnConfiguration) |
void |
YarnClusterDescriptor.killCluster(org.apache.hadoop.yarn.api.records.ApplicationId applicationId) |
Modifier and Type | Method and Description |
---|---|
int |
FlinkYarnSessionCli.run(String[] args) |
Configuration |
FlinkYarnSessionCli.toConfiguration(org.apache.commons.cli.CommandLine commandLine) |
Constructor and Description |
---|
FlinkYarnSessionCli(Configuration configuration,
ClusterClientServiceLoader clusterClientServiceLoader,
String configurationDirectory,
String shortPrefix,
String longPrefix,
boolean acceptInteractiveInput) |
FlinkYarnSessionCli(Configuration configuration,
String configurationDirectory,
String shortPrefix,
String longPrefix) |
FlinkYarnSessionCli(Configuration configuration,
String configurationDirectory,
String shortPrefix,
String longPrefix,
boolean acceptInteractiveInput) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.