TaskManager
E711829
TaskManager is a core Apache Flink runtime component responsible for executing tasks, managing their resources, and handling data exchange between parallel processing units.
Statements (46)
| Predicate | Object |
|---|---|
| instanceOf | Apache Flink runtime component ⓘ |
| allocates |
managed memory for operators
ⓘ
network buffers for data exchange ⓘ |
| belongsTo | Flink runtime layer NERFINISHED ⓘ |
| canBe | scaled horizontally by adding more instances ⓘ |
| canHost | multiple parallel task instances ⓘ |
| communicatesWith |
JobManager
NERFINISHED
ⓘ
ResourceManager NERFINISHED ⓘ |
| executes |
Flink tasks
ⓘ
operators of Flink jobs ⓘ |
| exposes | task slots to JobManager ⓘ |
| handles |
data buffering
ⓘ
data partitioning ⓘ data shuffles ⓘ input data channels ⓘ output data channels ⓘ task failure cleanup ⓘ |
| hasRole |
executes tasks
ⓘ
handles data exchange between parallel processing units ⓘ manages task resources ⓘ |
| isControlledBy | JobManager scheduling decisions ⓘ |
| isImplementedIn |
Java
NERFINISHED
ⓘ
Scala NERFINISHED ⓘ |
| manages |
CPU resources
ⓘ
memory resources ⓘ network resources ⓘ task slots ⓘ |
| monitors | task execution health ⓘ |
| participatesIn | Flink fault tolerance mechanisms ⓘ |
| partOf | Apache Flink NERFINISHED ⓘ |
| performs |
checkpoint alignment operations
ⓘ
state handling for tasks ⓘ |
| receives | task deployment requests from JobManager ⓘ |
| registersWith | ResourceManager NERFINISHED ⓘ |
| reports |
resource usage to ResourceManager
ⓘ
task status to JobManager ⓘ |
| runs | user-defined functions in Flink jobs ⓘ |
| runsOn | Flink cluster worker node ⓘ |
| supports |
backpressure propagation
ⓘ
batch processing jobs ⓘ network-based data exchange between tasks ⓘ parallel execution of tasks ⓘ stream processing jobs ⓘ |
| uses |
Flink RPC system for coordination
ⓘ
Flink configuration for resource limits ⓘ Flink network stack ⓘ |
Referenced by (1)
Full triples — surface form annotated when it differs from this entity's canonical label.