[pulsar] branch master updated: Move testAutoSchemaFunction and testAvroSchemaFunction to Java functions IT (#17372)

[eo...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

eolivelli 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 c50a1e451d0 Move testAutoSchemaFunction and testAvroSchemaFunction to Java functions IT (#17372)
c50a1e451d0 is described below

commit c50a1e451d0e144e4ae1eaa56b8fe358aaebbb29
Author: Christophe Bornet <cb...@hotmail.com>
AuthorDate: Tue Sep 13 18:03:53 2022 +0200

    Move testAutoSchemaFunction and testAvroSchemaFunction to Java functions IT (#17372)
---
 .../tests/integration/functions/PulsarFunctionsTest.java       |  9 +++------
 .../integration/functions/java/PulsarFunctionsJavaTest.java    | 10 ++++++++++
 2 files changed, 13 insertions(+), 6 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 908d95784d6..83a43d2adfa 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
@@ -86,7 +86,6 @@ import org.apache.pulsar.tests.integration.topologies.FunctionRuntimeType;
 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 @@ public abstract class PulsarFunctionsTest extends PulsarFunctionsTestBase {
         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 @@ public abstract class PulsarFunctionsTest extends PulsarFunctionsTestBase {
         }
     }
 
-    @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/tests/integration/src/test/java/org/apache/pulsar/tests/integration/functions/java/PulsarFunctionsJavaTest.java b/tests/integration/src/test/java/org/apache/pulsar/tests/integration/functions/java/PulsarFunctionsJavaTest.java
index 13ae7253b36..923870cabb5 100644
--- a/tests/integration/src/test/java/org/apache/pulsar/tests/integration/functions/java/PulsarFunctionsJavaTest.java
+++ b/tests/integration/src/test/java/org/apache/pulsar/tests/integration/functions/java/PulsarFunctionsJavaTest.java
@@ -203,4 +203,14 @@ public abstract class PulsarFunctionsJavaTest extends PulsarFunctionsTest {
         testRecordFunction();
     }
 
+    @Test(groups = {"java_function", "function"})
+    public void testAutoSchemaFunctionTest() throws Exception {
+        testAutoSchemaFunction();
+    }
+
+    @Test(groups = {"java_function", "function"})
+    public void testAvroSchemaFunctionTest() throws Exception {
+        testAvroSchemaFunction();
+    }
+
 }