public class FetchFailed extends java.lang.Object implements TaskFailedReason, scala.Product, scala.Serializable
Constructor and Description |
---|
FetchFailed(BlockManagerId bmAddress,
int shuffleId,
int mapId,
int reduceId,
java.lang.String message) |
Modifier and Type | Method and Description |
---|---|
BlockManagerId |
bmAddress() |
abstract static boolean |
canEqual(java.lang.Object that) |
static boolean |
countTowardsTaskFailures() |
abstract static boolean |
equals(java.lang.Object that) |
int |
mapId() |
java.lang.String |
message() |
abstract static int |
productArity() |
abstract static java.lang.Object |
productElement(int n) |
static scala.collection.Iterator<java.lang.Object> |
productIterator() |
static java.lang.String |
productPrefix() |
int |
reduceId() |
int |
shuffleId() |
java.lang.String |
toErrorString()
Error message displayed in the web UI.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
countTowardsTaskFailures
public FetchFailed(BlockManagerId bmAddress, int shuffleId, int mapId, int reduceId, java.lang.String message)
public static boolean countTowardsTaskFailures()
public abstract static boolean canEqual(java.lang.Object that)
public abstract static boolean equals(java.lang.Object that)
public abstract static java.lang.Object productElement(int n)
public abstract static int productArity()
public static scala.collection.Iterator<java.lang.Object> productIterator()
public static java.lang.String productPrefix()
public BlockManagerId bmAddress()
public int shuffleId()
public int mapId()
public int reduceId()
public java.lang.String message()
public java.lang.String toErrorString()
TaskFailedReason
toErrorString
in interface TaskFailedReason