Skip to content

distributed 模式下不能运行 #9

@jason-js

Description

@jason-js

感谢你提供的示例,distributed模式下不能运行成功,调试之后发现有三处需要修改:

  1. 入口处wc.go需要执行mapreduce.RunWorker方法,否则程序不执行。
  2. Master和Worker对外曝出的方法没有按照RPC的方法格式,如Master的Wait()、CleanupFiles()、Lock()和Unlock()方法。
  3. Worker的net.Listener监听Accept()没有Close(),导致程序一直处于阻塞状态,不能正常结束。
    PS:从你的代码中学到了更多东西,Thanks!

Metadata

Metadata

Assignees

No one assigned

    Labels

    No labels
    No labels

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions