distributed-computing
distributed-computing copied to clipboard
distributed_computing include mapreduce kvstore etc.
Results
1
distributed-computing issues
Sort by
recently updated
recently updated
newest added
感谢你提供的示例,distributed模式下不能运行成功,调试之后发现有三处需要修改: 1. 入口处wc.go需要执行mapreduce.RunWorker方法,否则程序不执行。 2. Master和Worker对外曝出的方法没有按照RPC的方法格式,如Master的Wait()、CleanupFiles()、Lock()和Unlock()方法。 3. Worker的net.Listener监听Accept()没有Close(),导致程序一直处于阻塞状态,不能正常结束。 PS:从你的代码中学到了更多东西,Thanks!