@InterfaceAudience.Public @InterfaceStability.Stable public class RetriesExhaustedWithDetailsException extends RetriesExhaustedException
RetriesExhaustedException
is thrown when we have more information about which rows were causing which
exceptions on what servers. You can call mayHaveClusterIssues()
and if the result is false, you have input error problems, otherwise you
may have cluster issues. You can iterate over the causes, rows and last
known server addresses via getNumExceptions() and
getCause(int), getRow(int) and getHostnamePort(int).RetriesExhaustedException.ThrowableWithExtraContext| Constructor and Description |
|---|
RetriesExhaustedWithDetailsException(List<Throwable> exceptions,
List<Row> actions,
List<String> hostnameAndPort) |
RetriesExhaustedWithDetailsException(String msg) |
RetriesExhaustedWithDetailsException(String msg,
IOException e) |
| Modifier and Type | Method and Description |
|---|---|
static Map<String,Integer> |
classifyExs(List<Throwable> ths) |
Throwable |
getCause(int i) |
List<Throwable> |
getCauses() |
static String |
getDesc(List<Throwable> exceptions,
List<? extends Row> actions,
List<String> hostnamePort) |
static String |
getDesc(Map<String,Integer> classificaton) |
String |
getExhaustiveDescription() |
String |
getHostnamePort(int i) |
int |
getNumExceptions() |
Row |
getRow(int i) |
boolean |
mayHaveClusterIssues() |
static String |
pluralize(Collection<?> c) |
static String |
pluralize(int c) |
addSuppressed, fillInStackTrace, getCause, getLocalizedMessage, getMessage, getStackTrace, getSuppressed, initCause, printStackTrace, printStackTrace, printStackTrace, setStackTrace, toStringpublic RetriesExhaustedWithDetailsException(String msg)
public RetriesExhaustedWithDetailsException(String msg, IOException e)
public int getNumExceptions()
public Throwable getCause(int i)
public Row getRow(int i)
public String getHostnamePort(int i)
public boolean mayHaveClusterIssues()
public static String pluralize(Collection<?> c)
public static String pluralize(int c)
public static String getDesc(List<Throwable> exceptions, List<? extends Row> actions, List<String> hostnamePort)
public String getExhaustiveDescription()
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.