[pulsar] branch master updated: [improve] [test] Improve timeout problem at SimpleProducerConsumerTest#testRedeliveryFailOverConsumer. (#15404)

[technoboy]

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

technoboy 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 7d06b5f00d8 [improve] [test] Improve timeout problem at 
SimpleProducerConsumerTest#testRedeliveryFailOverConsumer. (#15404)
7d06b5f00d8 is described below

commit 7d06b5f00d8c981c4b7d18f3833018cc03893e02
Author: Yan Zhao <horizo...@apache.org>
AuthorDate: Wed May 4 10:25:47 2022 +0800

    [improve] [test] Improve timeout problem at 
SimpleProducerConsumerTest#testRedeliveryFailOverConsumer. (#15404)
---
 .../apache/pulsar/client/api/SimpleProducerConsumerTest.java  | 11 ++---------
 1 file changed, 2 insertions(+), 9 deletions(-)

diff --git 
a/pulsar-broker/src/test/java/org/apache/pulsar/client/api/SimpleProducerConsumerTest.java
 
b/pulsar-broker/src/test/java/org/apache/pulsar/client/api/SimpleProducerConsumerTest.java
index 47cfdc08698..77634436c6d 100644
--- 
a/pulsar-broker/src/test/java/org/apache/pulsar/client/api/SimpleProducerConsumerTest.java
+++ 
b/pulsar-broker/src/test/java/org/apache/pulsar/client/api/SimpleProducerConsumerTest.java
@@ -2425,9 +2425,9 @@ public class SimpleProducerConsumerTest extends 
ProducerConsumerBase {
         Producer<byte[]> producer = 
pulsarClient.newProducer().topic("persistent://my-property/my-ns/unacked-topic")
                 .create();
 
-        // (1) First round to produce-consume messages
+        // (1) send all message at once
         int consumeMsgInParts = 4;
-        for (int i = 0; i < receiverQueueSize; i++) {
+        for (int i = 0; i < receiverQueueSize * 2; i++) {
             String message = "my-message-" + i;
             producer.send(message.getBytes());
         }
@@ -2467,13 +2467,6 @@ public class SimpleProducerConsumerTest extends 
ProducerConsumerBase {
         consumer.redeliverUnacknowledgedMessages();
         Thread.sleep(1000L);
 
-        // (2) Second round to produce-consume messages
-        for (int i = 0; i < receiverQueueSize; i++) {
-            String message = "my-message-" + i;
-            producer.send(message.getBytes());
-        }
-        producer.flush();
-
         int remainingMsgs = (2 * receiverQueueSize) - (2 * consumeMsgInParts);
         messages1.clear();
         for (int i = 0; i < remainingMsgs; i++) {