|
gptkbp:instanceOf
|
Apache Flink component
|
|
gptkbp:accessibleBy
|
web UI
REST endpoint
|
|
gptkbp:allocates
|
slots to jobs
|
|
gptkbp:assignee
|
tasks to TaskManagers
|
|
gptkbp:canBe
|
standalone
clustered
highly available
replicated for fault tolerance
|
|
gptkbp:communicatesVia
|
gptkb:Flink_TaskManager
|
|
gptkbp:coordinates
|
checkpointing
savepoints
|
|
gptkbp:criticalFor
|
Flink cluster operation
|
|
gptkbp:documentedIn
|
https://nightlies.apache.org/flink/flink-docs-stable/docs/concepts/jobmanager/
|
|
gptkbp:exposedBy
|
gptkb:REST_API
web dashboard
|
|
gptkbp:hasRole
|
position
follower
|
|
https://www.w3.org/2000/01/rdf-schema#label
|
Flink JobManager
|
|
gptkbp:introducedIn
|
Apache Flink 0.6
|
|
gptkbp:maintainedBy
|
job state
|
|
gptkbp:manages
|
job lifecycle
|
|
gptkbp:monitors
|
job progress
task execution
|
|
gptkbp:numberOfLocations
|
checkpoint metadata
|
|
gptkbp:partOf
|
gptkb:Apache_Flink
|
|
gptkbp:recipient
|
job submissions
|
|
gptkbp:recoveryMethod
|
failures
|
|
gptkbp:responsibleFor
|
resource management
job scheduling
job coordination
|
|
gptkbp:runsOn
|
gptkb:Kubernetes
gptkb:YARN
gptkb:Mesos
standalone cluster
|
|
gptkbp:usedIn
|
batch processing
stream processing
|
|
gptkbp:uses
|
ZooKeeper for HA
|
|
gptkbp:writtenBy
|
gptkb:Java
gptkb:Scala
|
|
gptkbp:bfsParent
|
gptkb:Flink_Runtime
gptkb:Apache_Flink_ecosystem
|
|
gptkbp:bfsLayer
|
7
|