This is an automated email from the ASF dual-hosted git repository.
mmerli 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 2a8c8c6 Add test group tags for functions and state integration tests
(#7529)
2a8c8c6 is described below
commit 2a8c8c64da43f4d5406f99dbfa8f3b8f39939d90
Author: Ali Ahmed <[email protected]>
AuthorDate: Wed Jul 15 09:33:26 2020 -0700
Add test group tags for functions and state integration tests (#7529)
Co-authored-by: Ali Ahmed <[email protected]>
---
.../integration/functions/PulsarFunctionsTest.java | 34 +++++++++++-----------
.../integration/functions/PulsarStateTest.java | 7 ++---
2 files changed, 20 insertions(+), 21 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 5b0ddf1..723cd46 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
@@ -865,16 +865,17 @@ public abstract class PulsarFunctionsTest extends
PulsarFunctionsTestBase {
}
}
- @Test(groups = "function")
+ @Test(groups = {"python_function", "function"})
public void testPythonFunctionLocalRun() throws Exception {
testFunctionLocalRun(Runtime.PYTHON);
}
- @Test(enabled = false, groups = "function")
+
+ @Test(enabled = false, groups = {"go_function", "function"})
public void testGoFunctionLocalRun() throws Exception {
testFunctionLocalRun(Runtime.GO);
}
- @Test(groups = "function")
+ @Test(groups = {"java_function", "function"})
public void testJavaFunctionLocalRun() throws Exception {
testFunctionLocalRun(Runtime.JAVA);
}
@@ -1109,7 +1110,7 @@ public abstract class PulsarFunctionsTest extends
PulsarFunctionsTestBase {
getFunctionInfoNotFound(functionName);
}
- @Test(groups="function")
+ @Test(groups = {"java_function", "function"})
public void testSlidingCountWindowTest() throws Exception {
String[] EXPECTED_RESULTS = {
"0,1,2,3,4",
@@ -1137,7 +1138,7 @@ public abstract class PulsarFunctionsTest extends
PulsarFunctionsTestBase {
testWindowFunction("sliding", EXPECTED_RESULTS);
}
- @Test(groups = "function")
+ @Test(groups = {"java_function", "function"})
public void testTumblingCountWindowTest() throws Exception {
String[] EXPECTED_RESULTS = {
"0,1,2,3,4,5,6,7,8,9",
@@ -1159,12 +1160,12 @@ public abstract class PulsarFunctionsTest extends
PulsarFunctionsTestBase {
// Test CRUD functions on different runtimes.
//
- @Test(groups = "function")
+ @Test(groups = {"python_function", "function"})
public void testPythonFunctionNegAck() throws Exception {
testFunctionNegAck(Runtime.PYTHON);
}
- @Test(groups = "function")
+ @Test(groups = {"java_function", "function"})
public void testJavaFunctionNegAck() throws Exception {
testFunctionNegAck(Runtime.JAVA);
}
@@ -1345,17 +1346,16 @@ public abstract class PulsarFunctionsTest extends
PulsarFunctionsTestBase {
checkSubscriptionsCleanup(inputTopicName);
}
- @Test(groups = "function")
+ @Test(groups = {"python_function", "function"})
public void testPythonPublishFunction() throws Exception {
testPublishFunction(Runtime.PYTHON);
}
- @Test(groups = "function")
+ @Test(groups = {"java_function", "function"})
public void testJavaPublishFunction() throws Exception {
testPublishFunction(Runtime.JAVA);
}
- @Test
public void testGoPublishFunction() throws Exception {
testPublishFunction(Runtime.GO);
}
@@ -1489,7 +1489,7 @@ public abstract class PulsarFunctionsTest extends
PulsarFunctionsTestBase {
checkSubscriptionsCleanup(inputTopicName);
}
- @Test(groups = "function")
+ @Test(groups = {"java_function", "function"})
public void testSerdeFunction() throws Exception {
testCustomSerdeFunction();
}
@@ -1536,32 +1536,32 @@ public abstract class PulsarFunctionsTest extends
PulsarFunctionsTestBase {
assertEquals(functionStatus.getInstances().get(0).getStatus().isRunning(),
true);
}
- @Test(groups = "function")
+ @Test(groups = {"python_function", "function"})
public void testPythonExclamationFunction() throws Exception {
testExclamationFunction(Runtime.PYTHON, false, false, false);
}
- @Test(groups = "function")
+ @Test(groups = {"python_function", "function"})
public void testPythonExclamationFunctionWithExtraDeps() throws Exception {
testExclamationFunction(Runtime.PYTHON, false, false, true);
}
- @Test(groups = "function")
+ @Test(groups = {"python_function", "function"})
public void testPythonExclamationZipFunction() throws Exception {
testExclamationFunction(Runtime.PYTHON, false, true, false);
}
- @Test(groups = "function")
+ @Test(groups = {"python_function", "function"})
public void testPythonExclamationTopicPatternFunction() throws Exception {
testExclamationFunction(Runtime.PYTHON, true, false, false);
}
- @Test(groups = "function")
+ @Test(groups = {"java_function", "function"})
public void testJavaExclamationFunction() throws Exception {
testExclamationFunction(Runtime.JAVA, false, false, false);
}
- @Test(groups = "function")
+ @Test(groups = {"java_function", "function"})
public void testJavaExclamationTopicPatternFunction() throws Exception {
testExclamationFunction(Runtime.JAVA, true, false, false);
}
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 2e386eb..b34895a 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
@@ -58,8 +58,7 @@ public class PulsarStateTest extends
PulsarStandaloneTestSuite {
public static final String WORDCOUNT_PYTHON_FILE = "wordcount_function.py";
-
- @Test
+ @Test(groups = {"python_state", "state", "function", "python_function"})
public void testPythonWordCountFunction() throws Exception {
String inputTopicName = "test-wordcount-py-input-" + randomName(8);
String outputTopicName = "test-wordcount-py-output-" + randomName(8);
@@ -94,7 +93,7 @@ public class PulsarStateTest extends
PulsarStandaloneTestSuite {
getFunctionInfoNotFound(functionName);
}
- @Test
+ @Test(groups = {"java_state", "state", "function", "java_function"})
public void testSourceState() throws Exception {
String outputTopicName = "test-state-source-output-" + randomName(8);
String sourceName = "test-state-source-" + randomName(8);
@@ -135,7 +134,7 @@ public class PulsarStateTest extends
PulsarStandaloneTestSuite {
getSourceInfoNotFound(sourceName);
}
- @Test
+ @Test(groups = {"java_state", "state", "function", "java_function"})
public void testSinkState() throws Exception {
String inputTopicName = "test-state-sink-input-" + randomName(8);
String sinkName = "test-state-sink-" + randomName(8);
