Move testAutoSchemaFunction and testAvroSchemaFunction to Java functi…

…ons IT
apache · Sep 6, 2022 · 76a6f1c · 76a6f1c
1 parent a7f1a56
commit 76a6f1c
Show file tree

Hide file tree

Showing 2 changed files with 13 additions and 6 deletions.
diff --git a/...tion/src/test/java/org/apache/pulsar/tests/integration/functions/PulsarFunctionsTest.java b/...tion/src/test/java/org/apache/pulsar/tests/integration/functions/PulsarFunctionsTest.java
@@ -86,7 +86,6 @@
 import org.apache.pulsar.tests.integration.topologies.PulsarCluster;
 import org.assertj.core.api.Assertions;
 import org.awaitility.Awaitility;
-import org.testng.annotations.Test;
 
 /**
  * A test base for testing functions.
@@ -1260,10 +1259,9 @@ private void deleteFunction(String functionName) throws Exception {
         result.assertNoStderr();
     }
 
-    @Test(groups = "function")
-    public void testAutoSchemaFunction() throws Exception {
+    protected void testAutoSchemaFunction() throws Exception {
         String inputTopicName = "test-autoschema-input-" + randomName(8);
-        String outputTopicName = "test-autoshcema-output-" + randomName(8);
+        String outputTopicName = "test-autoschema-output-" + randomName(8);
         String functionName = "test-autoschema-fn-" + randomName(8);
         final int numMessages = 10;
 
@@ -1326,8 +1324,7 @@ private void publishAndConsumeAvroMessages(String inputTopic,
         }
     }
 
-    @Test(groups = "function")
-    public void testAvroSchemaFunction() throws Exception {
+    protected void testAvroSchemaFunction() throws Exception {
         log.info("testAvroSchemaFunction start ...");
         final String inputTopic = "test-avroschema-input-" + randomName(8);
         final String outputTopic = "test-avroschema-output-" + randomName(8);

diff --git a/...test/java/org/apache/pulsar/tests/integration/functions/java/PulsarFunctionsJavaTest.java b/...test/java/org/apache/pulsar/tests/integration/functions/java/PulsarFunctionsJavaTest.java
@@ -203,4 +203,14 @@ public void testRecordFunctionTest() throws Exception {
         testRecordFunction();
     }
 
+    @Test(groups = {"java_function", "function"})
+    public void testAutoSchemaFunctionTest() throws Exception {
+        testAutoSchemaFunction();
+    }
+
+    @Test(groups = {"java_function", "function"})
+    public void testAvroSchemaFunctionTest() throws Exception {
+        testAvroSchemaFunction();
+    }
+
 }