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 2022/09/12 10:47:27 UTC
[pulsar] branch master updated: [fix][flaky-test]PulsarFunctionTlsTest.testFunctionsCreation (#17546)
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 7f1fe776fcb [fix][flaky-test]PulsarFunctionTlsTest.testFunctionsCreation (#17546)
7f1fe776fcb is described below
commit 7f1fe776fcb4b54b6ed4ebcb9b24296b1ebeefed
Author: fengyubiao <yu...@streamnative.io>
AuthorDate: Mon Sep 12 18:47:15 2022 +0800
[fix][flaky-test]PulsarFunctionTlsTest.testFunctionsCreation (#17546)
---
.../apache/pulsar/functions/worker/PulsarFunctionTlsTest.java | 10 +++++++++-
1 file changed, 9 insertions(+), 1 deletion(-)
diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/functions/worker/PulsarFunctionTlsTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/functions/worker/PulsarFunctionTlsTest.java
index e7c6dddc9b2..3aaf914b9eb 100644
--- a/pulsar-broker/src/test/java/org/apache/pulsar/functions/worker/PulsarFunctionTlsTest.java
+++ b/pulsar-broker/src/test/java/org/apache/pulsar/functions/worker/PulsarFunctionTlsTest.java
@@ -182,13 +182,21 @@ public class PulsarFunctionTlsTest {
if (pulsarAdmins[i] != null) {
pulsarAdmins[i].close();
}
+ }
+ for (int i = 0; i < BROKER_COUNT; i++) {
if (fnWorkerServices[i] != null) {
fnWorkerServices[i].stop();
}
+ }
+ for (int i = 0; i < BROKER_COUNT; i++) {
+ if (pulsarServices[i] != null) {
+ pulsarServices[i].getLoadManager().get().stop();
+ }
+ }
+ for (int i = 0; i < BROKER_COUNT; i++) {
if (pulsarServices[i] != null) {
pulsarServices[i].close();
}
-
}
bkEnsemble.stop();
} finally {