Interface | Description |
---|---|
JobGraphStore |
JobGraph instances for recovery. |
JobGraphStore.JobGraphListener |
A listener for
JobGraph instances. |
JobGraphStoreFactory |
Factory for
JobGraphStore . |
JobGraphWriter |
Allows to store and remove job graphs.
|
OnCompletionActions |
Interface for completion actions once a Flink job has reached
a terminal state.
|
Class | Description |
---|---|
HaServicesJobGraphStoreFactory |
JobGraphStoreFactory implementation which creates a JobGraphStore
using the provided HighAvailabilityServices . |
StandaloneJobGraphStore |
JobGraph instances for JobManagers running in HighAvailabilityMode.NONE . |
ZooKeeperJobGraphStore |
JobGraph instances for JobManagers running in HighAvailabilityMode.ZOOKEEPER . |
Enum | Description |
---|---|
HighAvailabilityMode |
High availability mode for Flink's cluster execution.
|
ThrowingJobGraphWriter |
JobGraphWriter implementation which does not allow to store
JobGraph . |
Exception | Description |
---|---|
PartitionProducerDisposedException |
Exception returned to a TaskManager on JobMaster requesting partition state,
if the producer of a partition has been disposed.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.