blog/BigData-Notes
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Update Storm核心概念详解.md

Browse Source
This commit is contained in:
heibaiying
2019-05-30 23:48:31 +08:00
committed by GitHub
parent 721746b410
commit 9a2b32da39
1 changed files with 1 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
notes/Storm核心概念详解.md
View File

@@ -62,7 +62,7 @@
5. **Global grouping** 5. **Global grouping**
整个Streams会进入Bolt的其中一个Task。通常会进入id最小的Task。 整个Streams会进入Bolt的其中一个Task，通常会进入id最小的Task。
6. **None grouping** 6. **None grouping**
@@ -115,11 +115,8 @@ Nimbus和Supervisor进程都被设计为**快速失败**（遇到任何意外情
Storm集群的任务构造者 ，构造Spoult或Bolt的Task实例，启动Executor线程。主要功能如下： Storm集群的任务构造者 ，构造Spoult或Bolt的Task实例，启动Executor线程。主要功能如下：
1. 根据Zookeeper上分配的Task，在本进程中启动1个或多个Executor线程，将构造好的Task实例交给Executor去运行； 1. 根据Zookeeper上分配的Task，在本进程中启动1个或多个Executor线程，将构造好的Task实例交给Executor去运行；
2. 向Zookeeper写入心跳 ； 2. 向Zookeeper写入心跳 ；
3. 维持传输队列，发送Tuple到其他的Worker ； 3. 维持传输队列，发送Tuple到其他的Worker ；
4. 若进程退出，立即在本机重启，则不影响集群运行。 4. 若进程退出，立即在本机重启，则不影响集群运行。