@InterfaceAudience.Public 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
Modifier and Type | Field and Description |
---|---|
(package private) List<Row> |
actions |
(package private) List<Throwable> |
exceptions |
(package private) List<String> |
hostnameAndPort |
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, toString
List<Throwable> exceptions
List<String> hostnameAndPort
public RetriesExhaustedWithDetailsException(String msg)
public RetriesExhaustedWithDetailsException(String msg, IOException e)
public int getNumExceptions()
public String getHostnamePort(int i)
public boolean mayHaveClusterIssues()
public static String pluralize(Collection<?> c)
public static String getDesc(List<Throwable> exceptions, List<? extends Row> actions, List<String> hostnamePort)
public String getExhaustiveDescription()
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.