(pulsar) branch master updated: [fix][test] Fix flaky PulsarFunctionsJavaThreadTest by adding retry to getFunctionStats (#25472)

[zixuan]

This is an automated email from the ASF dual-hosted git repository.

zixuan 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 0d0d6fbff4b [fix][test] Fix flaky PulsarFunctionsJavaThreadTest by 
adding retry to getFunctionStats (#25472)
0d0d6fbff4b is described below

commit 0d0d6fbff4b60167b74fdf91890601e7d7fa0cd2
Author: Matteo Merli <mme...@apache.org>
AuthorDate: Mon Apr 6 19:55:51 2026 -0700

    [fix][test] Fix flaky PulsarFunctionsJavaThreadTest by adding retry to 
getFunctionStats (#25472)
---
 .../pulsar/tests/integration/functions/PulsarFunctionsTest.java   | 8 ++++++++
 1 file changed, 8 insertions(+)

diff --git 
a/tests/integration/src/test/java/org/apache/pulsar/tests/integration/functions/PulsarFunctionsTest.java
 
b/tests/integration/src/test/java/org/apache/pulsar/tests/integration/functions/PulsarFunctionsTest.java
index 0d45bfcb9ed..4b74d846b27 100644
--- 
a/tests/integration/src/test/java/org/apache/pulsar/tests/integration/functions/PulsarFunctionsTest.java
+++ 
b/tests/integration/src/test/java/org/apache/pulsar/tests/integration/functions/PulsarFunctionsTest.java
@@ -1251,6 +1251,14 @@ public abstract class PulsarFunctionsTest extends 
PulsarFunctionsTestBase {
     }
 
     private void getFunctionStats(String functionName, int numMessages) throws 
Exception {
+        Awaitility.await()
+                .pollInterval(Duration.ofSeconds(1))
+                .atMost(Duration.ofSeconds(15))
+                .ignoreExceptions()
+                .untilAsserted(() -> doGetFunctionStats(functionName, 
numMessages));
+    }
+
+    private void doGetFunctionStats(String functionName, int numMessages) 
throws Exception {
         ContainerExecResult result = pulsarCluster.getAnyWorker().execCmd(
                 PulsarCluster.ADMIN_SCRIPT,
                 "functions",