@@ -152,7 +152,7 @@ public Object[][] partitionedTopicProvider() {
152152 return new Object [][] { { Boolean .TRUE }, { Boolean .FALSE } };
153153 }
154154
155- @ Test
155+ @ Test ( priority = Integer . MAX_VALUE )
156156 public void testConfigChange () throws Exception {
157157 log .info ("--- Starting ReplicatorTest::testConfigChange ---" );
158158 // This test is to verify that the config change on global namespace is successfully applied in broker during
@@ -497,7 +497,7 @@ public void testCounterOfPendingMessagesCorrect() throws Exception {
497497 // Init replicator and send many messages.
498498 PulsarClient client1 = pulsar1 .getClient ();
499499 final TopicName topic = TopicName
500- .get (BrokerTestUtil .newUniqueName ("persistent://pulsar/ns1/testReplicationWithGetSchemaError " ));
500+ .get (BrokerTestUtil .newUniqueName ("persistent://pulsar/ns1/tp " ));
501501 final String subName = "my-sub" ;
502502 @ Cleanup
503503 Consumer <GenericRecord > consumer = client1 .newConsumer (Schema .AUTO_CONSUME ())
@@ -529,7 +529,7 @@ public void testReplicationWillNotStuckByIncompleteSchemaFuture() throws Excepti
529529 // Init replicator and send many messages.
530530 PulsarClient client1 = pulsar1 .getClient ();
531531 final TopicName topic = TopicName
532- .get (BrokerTestUtil .newUniqueName ("persistent://pulsar/ns1/testReplicationWithGetSchemaError " ));
532+ .get (BrokerTestUtil .newUniqueName ("persistent://pulsar/ns1/tp " ));
533533 admin1 .namespaces ().setSchemaCompatibilityStrategy ("pulsar/ns1" , SchemaCompatibilityStrategy .ALWAYS_COMPATIBLE );
534534 final String subName = "sub" ;
535535 @ Cleanup
0 commit comments