0
我扩展了Hadoop的InputSplit
类来计算我的自定义输入分割,但是当我返回一个特定的HostIP(即datanode IP)作为字符串覆盖getLocations(),它的Map任务没有在该HostIP上执行,而是在其他某个上执行。对于没有在该特定HostIP上执行的问题,这会是什么问题?Mapper没有对Hadoop中的InputSplit的getLocations()返回的主机名执行
我扩展了Hadoop的InputSplit
类来计算我的自定义输入分割,但是当我返回一个特定的HostIP(即datanode IP)作为字符串覆盖getLocations(),它的Map任务没有在该HostIP上执行,而是在其他某个上执行。对于没有在该特定HostIP上执行的问题,这会是什么问题?Mapper没有对Hadoop中的InputSplit的getLocations()返回的主机名执行
您是否尝试从getLocations返回完全限定的名称。我遇到了类似的问题,但返回合格的名称似乎为我工作。
谢谢, Srivatsan