- LOG.warn("Tx: {} Error during phase {}, starting Abort", transaction.getIdentifier(), phase, t);
- final Exception e;
- if(t instanceof NoShardLeaderException || t instanceof ShardLeaderNotRespondingException) {
- e = new DataStoreUnavailableException(t.getMessage(), t);
- } else if (t instanceof Exception) {
- e = (Exception)t;
- } else {
- e = new RuntimeException("Unexpected error occurred", t);
- }
-
- final TransactionCommitFailedException clientException = exMapper.apply(e);
+ LOG.warn("Tx: {} Error during phase {}, starting Abort", transaction.getIdentifier(), phase, throwable);