From 638480d934aac57cf65eacd4259a6309480605c1 Mon Sep 17 00:00:00 2001 From: heibaiying <31504331+heibaiying@users.noreply.github.com> Date: Tue, 5 Nov 2019 21:58:41 +0800 Subject: [PATCH] =?UTF-8?q?Update=20Flink=E6=A0=B8=E5=BF=83=E6=A6=82?= =?UTF-8?q?=E5=BF=B5=E7=BB=BC=E8=BF=B0.md?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- notes/Flink核心概念综述.md | 6 ------ 1 file changed, 6 deletions(-) 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 资源管理