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 2026/09/14 09:56:38 UTC
(pulsar) 09/15: [fix][test] Allow for CLI startup in function integration tests (#26564)
This is an automated email from the ASF dual-hosted git repository.
lhotari pushed a commit to branch branch-4.2
in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit 775373cebf27bfbc0804bf303b0e7389ed7624a4
Author: Lari Hotari <lh...@users.noreply.github.com>
AuthorDate: Sun Sep 13 18:16:08 2026 +0300
[fix][test] Allow for CLI startup in function integration tests (#26564)
(cherry picked from commit 376073550aee0fd788b1ad7194c4cdd1677acbcd)
---
.../pulsar/tests/integration/functions/PulsarFunctionsTest.java | 3 ++-
.../apache/pulsar/tests/integration/functions/PulsarStateTest.java | 6 ++++--
2 files changed, 6 insertions(+), 3 deletions(-)
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 82418d9d9dc7..68da7de1aa31 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
@@ -1365,9 +1365,10 @@ public abstract class PulsarFunctionsTest extends PulsarFunctionsTestBase {
private void getFunctionStatus(String functionName, int numMessages, boolean checkRestarts, int parallelism)
throws Exception {
+ // Each status check starts the admin CLI; allow for startup and command completion on busy CI runners.
Awaitility.await()
.pollInterval(Duration.ofSeconds(1))
- .atMost(Duration.ofSeconds(15))
+ .atMost(Duration.ofSeconds(30))
.ignoreExceptions()
.untilAsserted(() ->
doGetFunctionStatus(functionName, numMessages, checkRestarts, parallelism));
diff --git a/tests/integration/src/test/java/org/apache/pulsar/tests/integration/functions/PulsarStateTest.java b/tests/integration/src/test/java/org/apache/pulsar/tests/integration/functions/PulsarStateTest.java
index 9d2510e61030..9d1dc809f374 100644
--- a/tests/integration/src/test/java/org/apache/pulsar/tests/integration/functions/PulsarStateTest.java
+++ b/tests/integration/src/test/java/org/apache/pulsar/tests/integration/functions/PulsarStateTest.java
@@ -149,7 +149,8 @@ public abstract class PulsarStateTest extends PulsarStandaloneTestSuite {
getFunctionInfoNotFound(functionName);
}
- @Test(groups = {"python_state", "state", "function", "python_function"})
+ // Both passes launch many admin CLI JVMs to verify state operations and cleanup after deletion.
+ @Test(groups = {"python_state", "state", "function", "python_function"}, timeOut = 600_000)
public void testPythonWordCountFunction() throws Exception {
if (PulsarMetadataStateStoreProviderImpl.class.getName().equals(stateStoreProvider)) {
// python function doesn't support metadata state store yet
@@ -163,7 +164,8 @@ public abstract class PulsarStateTest extends PulsarStandaloneTestSuite {
doTestPythonWordCountFunction(functionName);
}
- @Test(groups = {"java_state", "state", "function", "java_function"})
+ // Both passes launch many admin CLI JVMs to verify state operations and cleanup after deletion.
+ @Test(groups = {"java_state", "state", "function", "java_function"}, timeOut = 600_000)
public void testJavaWordCountFunction() throws Exception {
String functionName = "test-wordcount-java-fn-" + randomName(8);
doTestJavaWordCountFunction(functionName);