Skip to content

Commit

Permalink
fix failed test
Browse files Browse the repository at this point in the history
  • Loading branch information
wangjialing218 committed Feb 23, 2022
1 parent 871f318 commit a1b1258
Showing 1 changed file with 1 addition and 3 deletions.
Expand Up @@ -248,8 +248,6 @@ public void testBrokerAllowAutoUpdateSchemaDisabled(SchemaCompatibilityStrategy


pulsar.getConfig().setAllowAutoUpdateSchemaEnabled(false);
Policies policies = admin.namespaces().getPolicies(namespaceName.toString());
Assert.assertFalse(policies.is_allow_auto_update_schema);

ProducerBuilder<Schemas.PersonTwo> producerThreeBuilder = pulsarClient
.newProducer(Schema.AVRO(SchemaDefinition.<Schemas.PersonTwo>builder().withAlwaysAllowNull
Expand All @@ -263,7 +261,7 @@ public void testBrokerAllowAutoUpdateSchemaDisabled(SchemaCompatibilityStrategy
}

pulsar.getConfig().setAllowAutoUpdateSchemaEnabled(true);
policies = admin.namespaces().getPolicies(namespaceName.toString());
Policies policies = admin.namespaces().getPolicies(namespaceName.toString());
Assert.assertTrue(policies.is_allow_auto_update_schema);

ConsumerBuilder<Schemas.PersonTwo> comsumerBuilder = pulsarClient.newConsumer(Schema.AVRO(
Expand Down

0 comments on commit a1b1258

Please sign in to comment.