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);