From 7be57849a14189bcf222753fff49a2322c7482ea Mon Sep 17 00:00:00 2001 From: thegreatzhang Date: Tue, 14 May 2024 23:12:11 +0800 Subject: [PATCH] biwu --- content/posts/map-reduce.md | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/content/posts/map-reduce.md b/content/posts/map-reduce.md index 46f8af4..7456636 100644 --- a/content/posts/map-reduce.md +++ b/content/posts/map-reduce.md @@ -44,7 +44,7 @@ type TaskMetadata struct { ``` ## MapReduce 的执行流程 -1. Coordinator 启动，并初始化，监听 Worker 的RPC请求。同时要启动一个goroutine 检查超时的任务，超时的任务要重新插入人物队列。 +1. Coordinator 启动，并初始化，监听 Worker 的RPC请求。同时要启动一个goroutine 检查超时的任务，超时的任务要重新插入任务队列。 * 两种RPC, 一个是Worker请求任务的RPC, 还有一个是Worker完成任务的通知的RPC 2. Worker 启动，向 Coordinator 请求任务，根据返回的 task 的 Phase (Map/Reduce/Exit/Wait) 分别进行下一步操作 * Map 阶段：读取输入文件，调用用户提供的 Map 函数，生成中间文件，然后向 Coordinator 通知任务完成 @@ -52,4 +52,4 @@ type TaskMetadata struct { * Exit 阶段：直接 return * Wait 阶段：sleep 5 s 3. Coordinator 每次收到 Worker 完成任务的通知，除了进行状态的更新，都会检查是否所有任务都已经完成，如果是，就进入下一个阶段 -4. 最终 Coordinator 到达 Exit Phase, 退出 \ No newline at end of file +4. 最终 Coordinator 到达 Exit Phase, 退出