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 05a703b9fc1 [fix][test] Fix flaky 
FunctionRuntimeManagerTest.testExternallyManagedRuntimeUpdate (#25465)
05a703b9fc1 is described below

commit 05a703b9fc102e914bf8c8db5052f230f3e59120
Author: Matteo Merli <[email protected]>
AuthorDate: Mon Apr 6 20:28:40 2026 -0700

    [fix][test] Fix flaky 
FunctionRuntimeManagerTest.testExternallyManagedRuntimeUpdate (#25465)
---
 .../org/apache/pulsar/functions/worker/FunctionRuntimeManagerTest.java | 3 +++
 1 file changed, 3 insertions(+)

diff --git 
a/pulsar-functions/worker/src/test/java/org/apache/pulsar/functions/worker/FunctionRuntimeManagerTest.java
 
b/pulsar-functions/worker/src/test/java/org/apache/pulsar/functions/worker/FunctionRuntimeManagerTest.java
index b96160fa1fa..361dbad2593 100644
--- 
a/pulsar-functions/worker/src/test/java/org/apache/pulsar/functions/worker/FunctionRuntimeManagerTest.java
+++ 
b/pulsar-functions/worker/src/test/java/org/apache/pulsar/functions/worker/FunctionRuntimeManagerTest.java
@@ -742,6 +742,9 @@ public class FunctionRuntimeManagerTest {
                     
.get("worker-2").get("test-tenant/test-namespace/func-1:0"), assignment2);
             
assertNull(functionRuntimeManager.functionRuntimeInfos.get("test-tenant/test-namespace/func-1:0"));
 
+            // Clear invocations to ensure the next verify block starts fresh
+            Mockito.clearInvocations(functionActioner);
+
             /** Test transfer from other worker to me **/
 
             Assignment assignment3 = createAssignment("worker-1", function1, 
0);

Reply via email to