This is an automated email from the ASF dual-hosted git repository. mmarshall pushed a commit to branch branch-2.8 in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit c773179dcd5a16edd95714c3aa5a6c19eaa394fe Author: Nicolò Boschi <[email protected]> AuthorDate: Thu Nov 11 18:16:49 2021 +0100 Flaky Tests: AdminApiSchemaTest#testSchemaInfoApi (#12461) (cherry picked from commit b533fe5825d236415d8bf07fcaaccd8750b63271) --- .../src/test/java/org/apache/pulsar/schema/SchemaTest.java | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/schema/SchemaTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/schema/SchemaTest.java index bbea161..999b264 100644 --- a/pulsar-broker/src/test/java/org/apache/pulsar/schema/SchemaTest.java +++ b/pulsar-broker/src/test/java/org/apache/pulsar/schema/SchemaTest.java @@ -702,9 +702,12 @@ public class SchemaTest extends MockedPulsarServiceBaseTest { final Map<String, String> map = new HashMap<>(); map.put("key", null); map.put(null, "value"); // null key is not allowed for JSON, it's only for test here - ((SchemaInfoImpl)Schema.INT32.getSchemaInfo()).setProperties(map); - final Consumer<Integer> consumer = pulsarClient.newConsumer(Schema.INT32).topic(topic) + // leave INT32 instance unchanged + final Schema<Integer> integerSchema = Schema.INT32.clone(); + ((SchemaInfoImpl) integerSchema.getSchemaInfo()).setProperties(map); + + final Consumer<Integer> consumer = pulsarClient.newConsumer(integerSchema).topic(topic) .subscriptionName("sub") .subscribe(); consumer.close();
