From 9a2b32da39d13f25d617d047520f59a447d36bb9 Mon Sep 17 00:00:00 2001 From: heibaiying <31504331+heibaiying@users.noreply.github.com> Date: Thu, 30 May 2019 23:48:31 +0800 Subject: [PATCH] =?UTF-8?q?Update=20Storm=E6=A0=B8=E5=BF=83=E6=A6=82?= =?UTF-8?q?=E5=BF=B5=E8=AF=A6=E8=A7=A3.md?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- notes/Storm核心概念详解.md | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) diff --git a/notes/Storm核心概念详解.md b/notes/Storm核心概念详解.md index 1263f35..0462eb5 100644 --- a/notes/Storm核心概念详解.md +++ b/notes/Storm核心概念详解.md @@ -62,7 +62,7 @@ 5. **Global grouping** - 整个Streams会进入Bolt的其中一个Task。通常会进入id最小的Task。 + 整个Streams会进入Bolt的其中一个Task,通常会进入id最小的Task。 6. **None grouping** @@ -115,11 +115,8 @@ Nimbus和Supervisor进程都被设计为**快速失败**(遇到任何意外情 Storm集群的任务构造者 ,构造Spoult或Bolt的Task实例,启动Executor线程。主要功能如下: 1. 根据Zookeeper上分配的Task,在本进程中启动1个或多个Executor线程,将构造好的Task实例交给Executor去运行; - 2. 向Zookeeper写入心跳 ; - 3. 维持传输队列,发送Tuple到其他的Worker ; - 4. 若进程退出,立即在本机重启,则不影响集群运行。