[pulsar] branch master updated: Flaky tests: reduce SimpleProducerConsumerTest flakiness (#12420)

[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 8757c3acf34 Flaky tests: reduce SimpleProducerConsumerTest flakiness 
(#12420)
8757c3acf34 is described below

commit 8757c3acf3456af64d3f4f8ffbb3202a6c18e02a
Author: Nicolò Boschi <boschi1...@gmail.com>
AuthorDate: Fri Apr 8 13:38:43 2022 +0200

    Flaky tests: reduce SimpleProducerConsumerTest flakiness (#12420)
---
 .../org/apache/pulsar/client/api/SimpleProducerConsumerTest.java   | 7 ++++---
 1 file changed, 4 insertions(+), 3 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 fa1505f4d6f..f0e4cca9a25 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
@@ -116,9 +116,10 @@ import org.testng.annotations.Test;
 @Test(groups = "flaky")
 public class SimpleProducerConsumerTest extends ProducerConsumerBase {
     private static final Logger log = 
LoggerFactory.getLogger(SimpleProducerConsumerTest.class);
-    private static final int RECEIVE_TIMEOUT_SECONDS = 3;
-    private static final int RECEIVE_TIMEOUT_SHORT_MILLIS = 100;
-    private static final int RECEIVE_TIMEOUT_MEDIUM_MILLIS = 500;
+    private static final int TIMEOUT_MULTIPLIER = 
Integer.getInteger("SimpleProducerConsumerTest.receive.timeout.multiplier", 1);
+    private static final int RECEIVE_TIMEOUT_SECONDS = 5 * TIMEOUT_MULTIPLIER;
+    private static final int RECEIVE_TIMEOUT_SHORT_MILLIS = 200 * 
TIMEOUT_MULTIPLIER;
+    private static final int RECEIVE_TIMEOUT_MEDIUM_MILLIS = 1000 * 
TIMEOUT_MULTIPLIER;
 
     @BeforeMethod(alwaysRun = true)
     @Override