diff --git a/notes/Flink核心概念综述.md b/notes/Flink核心概念综述.md index 47fcd48..0f2fe77 100644 --- a/notes/Flink核心概念综述.md +++ b/notes/Flink核心概念综述.md @@ -99,10 +99,6 @@ Stateful Stream Processing 是最低级别的抽象,它通过 Process Function
-染病 - - - ### 4.2 Task & SubTask 上面我们提到:TaskManagers 实际执行的是 SubTask,而不是 Task,这里解释一下两者的区别: @@ -112,8 +108,6 @@ Stateful Stream Processing 是最低级别的抽象,它通过 Process Function
- - 解释完 Task ,我们在解释一下什么是 SubTask,其准确的翻译是: *A subtask is one parallel slice of a task*,即一个 Task 可以按照其并行度拆分为多个 SubTask。如上图,source & map 具有两个并行度,KeyBy 具有两个并行度,Sink 具有一个并行度,因此整个虽然只有 3 个 Task,但是却有 5 个 SubTask。Jobmanager 负责定义和拆分这些 SubTask,并将其交给 Taskmanagers 来执行,每个 SubTask 都是一个单独的线程。 ### 4.3 资源管理