我已经延长了期限 InputSplit 类来计算我的自定义输入拆分,但是,当返回一个特定的hostip(即datanode ip)作为重写的getlocations()的字符串时,它的Map任务没有在该hostip上执行,而是在其他hostip上执行。不在该特定hostip上执行会有什么问题?
InputSplit
ivqmmu1c1#
您是否尝试从getlocations返回完全限定名。我也面临着类似的问题,但返回限定名似乎对我有用。谢谢,斯里瓦桑
1条答案
按热度按时间ivqmmu1c1#
您是否尝试从getlocations返回完全限定名。我也面临着类似的问题,但返回限定名似乎对我有用。
谢谢,斯里瓦桑