You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by pe...@apache.org on 2022/03/25 05:49:01 UTC
[pulsar] 11/14: [fix][txn]: fix some exception handle in transaction buffer (#14808)
This is an automated email from the ASF dual-hosted git repository.
penghui pushed a commit to branch branch-2.9
in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit 511644b3894da3ba4e984a60b11ffd0f032df729
Author: congbo <39...@users.noreply.github.com>
AuthorDate: Thu Mar 24 15:46:14 2022 +0800
[fix][txn]: fix some exception handle in transaction buffer (#14808)
(cherry picked from commit 4824912615bf85f836a72051117462471b0ab306)
---
.../transaction/buffer/impl/TopicTransactionBuffer.java | 12 ++++++------
1 file changed, 6 insertions(+), 6 deletions(-)
diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/impl/TopicTransactionBuffer.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/impl/TopicTransactionBuffer.java
index 3d6e7da..7ed656f 100644
--- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/impl/TopicTransactionBuffer.java
+++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/impl/TopicTransactionBuffer.java
@@ -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;