Attempt to fix flaky test SimpleProducerConsumerTestStreamingDispatch…

…erTest.testRedeliveryFailOverConsumer (apache#10118) * Attempt to fix flaky test SimpleProducerConsumerTestStreamingDispatcherTest * Use constants for receive timeouts * Add delay after redeliverUnacknowledgedMessages call * Organize imports with format defined in checkstyle * Reduce flakiness in testRedeliveryOfFailedMessages * Attempt to fix flakiness in test
lujp · Apr 9, 2021 · 6629b15 · 6629b15
1 parent 31f8315
commit 6629b15
Show file tree

Hide file tree

Showing 2 changed files with 137 additions and 127 deletions.
diff --git a/...e/pulsar/broker/service/persistent/SimpleProducerConsumerTestStreamingDispatcherTest.java b/...e/pulsar/broker/service/persistent/SimpleProducerConsumerTestStreamingDispatcherTest.java
@@ -29,10 +29,9 @@
 @Test(groups = "flaky")
 public class SimpleProducerConsumerTestStreamingDispatcherTest extends SimpleProducerConsumerTest {
 
-    @BeforeMethod
     @Override
-    protected void setup() throws Exception {
-        super.setup();
+    protected void doInitConf() throws Exception {
+        super.doInitConf();
         conf.setStreamingDispatch(true);
     }
 }