[fix][txn]: fix some exception handle in transaction buffer
@@ -227,8 +227,8 @@ public class TopicTransactionBuffer extends TopicTransactionBufferState implemen
completableFuture.complete(null);
}
}).exceptionally(exception -> {
- log.error("Topic {}: TransactionBuffer recover failed", this.topic.getName(), exception);
- completableFuture.completeExceptionally(exception);
+ log.error("Topic {}: TransactionBuffer recover failed", this.topic.getName(), exception.getCause());
+ completableFuture.completeExceptionally(exception.getCause());
return null;
});
return completableFuture;
@@ -305,8 +305,8 @@ public class TopicTransactionBuffer extends TopicTransactionBufferState implemen
commitMarker.release();
}
}).exceptionally(exception -> {
- log.error("Transaction {} commit on topic {}.", txnID.toString(), topic.getName(), exception);
- completableFuture.completeExceptionally(exception);
+ log.error("Transaction {} commit on topic {}.", txnID.toString(), topic.getName(), exception.getCause());
+ completableFuture.completeExceptionally(exception.getCause());
return null;
});
return completableFuture;
@@ -351,8 +351,8 @@ public class TopicTransactionBuffer extends TopicTransactionBufferState implemen
abortMarker.release();
}
}).exceptionally(exception -> {
- log.error("Transaction {} abort on topic {}.", txnID.toString(), topic.getName());
- completableFuture.completeExceptionally(exception);
+ log.error("Transaction {} abort on topic {}.", txnID.toString(), topic.getName(), exception.getCause());
+ completableFuture.completeExceptionally(exception.getCause());
return null;
});
return completableFuture;
