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 <[email protected]>
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 {
