JobManager
E711828
JobManager is the central coordination component in Apache Flink responsible for managing job execution, resource allocation, and task scheduling across the cluster.
Statements (48)
| Predicate | Object |
|---|---|
| instanceOf |
Flink component
ⓘ
cluster coordination component ⓘ |
| allocatesResourcesTo | TaskManagers ⓘ |
| assigns | task slots ⓘ |
| belongsTo | Flink runtime ⓘ |
| communicatesWith | TaskManagers ⓘ |
| coordinates |
TaskManagers
ⓘ
checkpoint barriers ⓘ global checkpoints ⓘ |
| creates | execution graphs from job graphs ⓘ |
| environment |
batch processing
ⓘ
distributed data processing ⓘ stream processing ⓘ |
| exposes |
Flink web UI endpoints
ⓘ
REST API ⓘ |
| handles |
job cancellation
ⓘ
job restarts ⓘ job submission ⓘ task failures ⓘ |
| implementedIn |
Java
NERFINISHED
ⓘ
Scala NERFINISHED ⓘ |
| maintains |
checkpoint metadata
ⓘ
job status ⓘ |
| manages |
Flink jobs
ⓘ
execution graphs ⓘ |
| monitors | task execution state ⓘ |
| partOf | Apache Flink NERFINISHED ⓘ |
| persists | high-availability metadata (in HA setups) ⓘ |
| receives | job graphs ⓘ |
| relatedTo |
Flink cluster
ⓘ
ResourceManager NERFINISHED ⓘ TaskManager NERFINISHED ⓘ |
| responsibleFor |
checkpoint coordination
ⓘ
failure recovery coordination ⓘ job execution coordination ⓘ job lifecycle management ⓘ resource allocation ⓘ savepoint coordination ⓘ task scheduling ⓘ |
| roleInArchitecture | central coordination component ⓘ |
| runsIn | Flink master process ⓘ |
| schedules |
task deployments
ⓘ
tasks ⓘ |
| stores | job metadata ⓘ |
| usedBy | Flink job clients ⓘ |
| uses |
resource manager
ⓘ
scheduler ⓘ slot pool ⓘ |
Referenced by (1)
Full triples — surface form annotated when it differs from this entity's canonical label.