@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.