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

baodi pushed a commit to branch branch-2.10
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/branch-2.10 by this push:
     new ad59b797e23 Fix unit test for cherry-picked 573bf6d
ad59b797e23 is described below

commit ad59b797e23a20d8ac1f2f57974040e501c29c63
Author: Baodi Shi <[email protected]>
AuthorDate: Fri May 17 09:06:38 2024 +0800

    Fix unit test for cherry-picked 573bf6d
---
 .../java/org/apache/pulsar/broker/admin/AdminApiSchemaTest.java     | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git 
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/AdminApiSchemaTest.java
 
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/AdminApiSchemaTest.java
index 4d545d141eb..83d41e0bb1f 100644
--- 
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/AdminApiSchemaTest.java
+++ 
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/AdminApiSchemaTest.java
@@ -28,6 +28,7 @@ import static org.testng.Assert.assertNotEquals;
 import static org.testng.Assert.assertTrue;
 import static org.testng.Assert.fail;
 import com.google.common.collect.Sets;
+import java.util.Arrays;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
@@ -420,11 +421,10 @@ public class AdminApiSchemaTest extends 
MockedPulsarServiceBaseTest {
 
     @Test
     public void testCompatibilityWithEmpty() throws Exception {
-        List<Schema<?>> checkSchemas = List.of(
+        List<Schema<?>> checkSchemas = Arrays.asList(
                 Schema.STRING,
                 
Schema.JSON(SchemaDefinition.builder().withPojo(Foo.class).withProperties(PROPS).build()),
-                
Schema.AVRO(SchemaDefinition.builder().withPojo(Foo.class).withProperties(PROPS).build()),
-                Schema.KeyValue(Schema.STRING, Schema.STRING)
+                
Schema.AVRO(SchemaDefinition.builder().withPojo(Foo.class).withProperties(PROPS).build())
         );
         for (Schema<?> schema : checkSchemas) {
             SchemaInfo schemaInfo = schema.getSchemaInfo();

Reply via email to