You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by lh...@apache.org on 2023/10/17 18:50:25 UTC
[pulsar] branch master updated: [fix][test] Fix resource leak in TransactionCoordinatorClientTest (#21380)
This is an automated email from the ASF dual-hosted git repository.
lhotari pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/master by this push:
new cb7c98a7f56 [fix][test] Fix resource leak in TransactionCoordinatorClientTest (#21380)
cb7c98a7f56 is described below
commit cb7c98a7f56c3115a9e73bff96b8b4daac2c8180
Author: Lari Hotari <lh...@users.noreply.github.com>
AuthorDate: Tue Oct 17 21:50:16 2023 +0300
[fix][test] Fix resource leak in TransactionCoordinatorClientTest (#21380)
---
.../transaction/coordinator/TransactionMetaStoreTestBase.java | 6 ++++++
1 file changed, 6 insertions(+)
diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/broker/transaction/coordinator/TransactionMetaStoreTestBase.java b/pulsar-broker/src/test/java/org/apache/pulsar/broker/transaction/coordinator/TransactionMetaStoreTestBase.java
index eb714dd848a..7a0fb48f911 100644
--- a/pulsar-broker/src/test/java/org/apache/pulsar/broker/transaction/coordinator/TransactionMetaStoreTestBase.java
+++ b/pulsar-broker/src/test/java/org/apache/pulsar/broker/transaction/coordinator/TransactionMetaStoreTestBase.java
@@ -120,6 +120,9 @@ public abstract class TransactionMetaStoreTestBase extends TestRetrySupport {
@Override
protected void cleanup() throws Exception {
+ if (transactionCoordinatorClient != null) {
+ transactionCoordinatorClient.close();
+ }
for (PulsarAdmin admin : pulsarAdmins) {
if (admin != null) {
admin.close();
@@ -133,6 +136,9 @@ public abstract class TransactionMetaStoreTestBase extends TestRetrySupport {
service.close();
}
}
+ if (bkEnsemble != null) {
+ bkEnsemble.stop();
+ }
Mockito.reset();
}
}