最近我正在运行一些基准测试来了解 Giraph 中的故障转移机制。
其实我很好奇;当工作中的一个工人变慢时,其他工人只会等待它。后来我在GiraphJob.java
:
// Speculative execution doesn't make sense for Giraph
giraphConfiguration.setBoolean("mapred.map.tasks.speculative.execution", false);
有谁知道为什么 Giraph 中没有启用推测执行?
谢谢