0

我已经扩展了InputSplitHadoop 的类来计算我的自定义输入拆分，但是当我返回一个特定的 HostIP（即数据节点 IP）作为覆盖的getLocations()的字符串时，它的 Map Task 并没有在该 HostIP 上执行，而是它正在执行在其他一些上。不在该特定 HostIP 上执行会出现什么问题？

4

1 回答 1

0

您是否尝试从 getLocations 返回完全限定名称。我遇到了类似的问题，但返回限定名似乎对我有用。

谢谢， 斯里瓦桑

于 2016-08-16T16:02:10.827 回答