public class FetchFailed extends Object implements TaskFailedReason, scala.Product, scala.Serializable
Constructor and Description |
---|
FetchFailed(BlockManagerId bmAddress,
int shuffleId,
int mapId,
int reduceId) |
Modifier and Type | Method and Description |
---|---|
BlockManagerId |
bmAddress() |
int |
mapId() |
int |
reduceId() |
int |
shuffleId() |
String |
toErrorString()
Error message displayed in the web UI.
|
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public FetchFailed(BlockManagerId bmAddress, int shuffleId, int mapId, int reduceId)
public BlockManagerId bmAddress()
public int shuffleId()
public int mapId()
public int reduceId()
public String toErrorString()
TaskFailedReason
toErrorString
in interface TaskFailedReason