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

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

commit b8e074f33826b532c28ea9bfb9d68ddfe16a5a74
Author: Tboy <techno...@apache.org>
AuthorDate: Mon Jun 28 23:12:06 2021 +0800

    Fix Flaky-test: 
[TopicFromMessageTest].[testMultiTopicConsumerBatchShortName] (#11124) (#11125)
    
    Fixes #11124 .
    
    (cherry picked from commit e647bd08fd775e513c356976bef1d82c0ac38907)
---
 .../java/org/apache/pulsar/client/impl/TopicFromMessageTest.java  | 8 ++++++--
 1 file changed, 6 insertions(+), 2 deletions(-)

diff --git 
a/pulsar-broker/src/test/java/org/apache/pulsar/client/impl/TopicFromMessageTest.java
 
b/pulsar-broker/src/test/java/org/apache/pulsar/client/impl/TopicFromMessageTest.java
index 5ad4b51..6863235 100644
--- 
a/pulsar-broker/src/test/java/org/apache/pulsar/client/impl/TopicFromMessageTest.java
+++ 
b/pulsar-broker/src/test/java/org/apache/pulsar/client/impl/TopicFromMessageTest.java
@@ -107,8 +107,12 @@ public class TopicFromMessageTest extends 
ProducerConsumerBase {
             producer1.send("foobar".getBytes());
             producer2.send("foobar".getBytes());
 
-            Assert.assertEquals(consumer.receive().getTopicName(), 
"persistent://public/default/topic1");
-            Assert.assertEquals(consumer.receive().getTopicName(), 
"persistent://public/default/topic2");
+            // We can't ensure the received order of the message.
+            String topicNameX = consumer.receive().getTopicName();
+            String topicNameY = consumer.receive().getTopicName();
+            Object[] actualTopicNames = new Object[]{topicNameX, topicNameY};
+            Object[] expectedTopicNames = new 
Object[]{"persistent://public/default/topic1", 
"persistent://public/default/topic2"};
+            Assert.assertEqualsNoOrder(actualTopicNames, expectedTopicNames);
         }
     }
 

Reply via email to