Interface | Description |
---|---|
OnCompletionActions | |
SubmittedJobGraphStore |
SubmittedJobGraph instances for recovery. |
SubmittedJobGraphStore.SubmittedJobGraphListener |
A listener for
SubmittedJobGraph instances. |
Class | Description |
---|---|
JobInfo |
Utility class to store job information on the
JobManager . |
JobInfo$ | |
JobManager |
The job manager is responsible for receiving Flink jobs, scheduling the tasks, gathering the
job status and managing the task managers.
|
JobManager$ |
Job Manager companion object.
|
JobManagerCliOptions |
The command line parameters passed to the JobManager.
|
MemoryArchivist |
Actor which stores terminated Flink jobs.
|
StandaloneSubmittedJobGraphStore |
SubmittedJobGraph instances for JobManagers running in HighAvailabilityMode.NONE . |
SubmittedJobGraph | |
ZooKeeperSubmittedJobGraphStore |
SubmittedJobGraph instances for JobManagers running in HighAvailabilityMode.ZOOKEEPER . |
Enum | Description |
---|---|
HighAvailabilityMode |
High availability mode for Flink's cluster execution.
|
JobManagerMode |
The startup mode for the JobManager.
|
Exception | Description |
---|---|
PartitionProducerDisposedException |
Exception returned to a TaskManager on
JobManagerMessages.RequestPartitionProducerState
if the producer of a partition has been disposed. |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.