TEPHRA-114: TransactionServiceClient to log thrift exceptions stacktraces at debug level
diff --git a/tephra-core/src/main/java/co/cask/tephra/distributed/TransactionServiceClient.java b/tephra-core/src/main/java/co/cask/tephra/distributed/TransactionServiceClient.java
index 6f5c81c..8550670 100644
--- a/tephra-core/src/main/java/co/cask/tephra/distributed/TransactionServiceClient.java
+++ b/tephra-core/src/main/java/co/cask/tephra/distributed/TransactionServiceClient.java
@@ -234,12 +234,15 @@
// retry strategy is exceeded, throw an operation exception
String message =
"Thrift error for " + operation + ": " + te.getMessage();
- LOG.error(message, te);
+ LOG.error(message);
+ LOG.debug(message, te);
throw new Exception(message, te);
} else {
// call retry strategy before retrying
retryStrategy.beforeRetry();
- LOG.info("Retrying " + operation.getName() + " after Thrift error.", te);
+ String msg = "Retrying " + operation.getName() + " after Thrift error: " + te.getMessage();
+ LOG.info(msg);
+ LOG.debug(msg, te);
}
} finally {
