[pulsar] branch master updated: [fix][broker] Fix flaky test - testClusterMigrationWithReplica… (#20379)

[lhotari]

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

lhotari 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 aff4a1c7edb [fix][broker] Fix flaky test - 
testClusterMigrationWithReplica… (#20379)
aff4a1c7edb is described below

commit aff4a1c7edbf019d17795c7a67b1d0f0e701d118
Author: vineeth1995 <vineethreddypo...@gmail.com>
AuthorDate: Wed May 24 08:05:58 2023 -0700

    [fix][broker] Fix flaky test - testClusterMigrationWithReplica… (#20379)
---
 .../java/org/apache/pulsar/broker/service/ClusterMigrationTest.java   | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ClusterMigrationTest.java
 
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ClusterMigrationTest.java
index df4f66c43d2..469e155d409 100644
--- 
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ClusterMigrationTest.java
+++ 
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ClusterMigrationTest.java
@@ -458,8 +458,8 @@ public class ClusterMigrationTest {
         retryStrategically((test) -> !topic1.isReplicationBacklogExist(), 10, 
1000);
         assertFalse(topic1.isReplicationBacklogExist());
 
-        // verify that the producer1 is now is now connected to migrated 
cluster "r2" since backlog is cleared.
-        retryStrategically((test) -> topic2.getProducers().size()==2, 10, 500);
+        producer1.send("test".getBytes());
+        // verify that the producer1 is now connected to migrated cluster "r2" 
since backlog is cleared.
         assertEquals(topic2.getProducers().size(), 2);
     }