Fix flaky test CompactionReaderImplTest(wait until the consumerFutur…

…e completes) (#19238)
apache · Jan 16, 2023 · f23363c · f23363c
1 parent 246c270
commit f23363c
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/client/impl/CompactionReaderImplTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/client/impl/CompactionReaderImplTest.java
@@ -77,9 +77,11 @@ public void test() throws Exception {
             producer.newMessage().key("key:" + i).value("value" + i).send();
         }
 
+        var consumerFuture = new CompletableFuture();
         @Cleanup
         CompactionReaderImpl<String> reader = CompactionReaderImpl
-                .create((PulsarClientImpl) pulsarClient, Schema.STRING, topic, new CompletableFuture(), null);
+                .create((PulsarClientImpl) pulsarClient, Schema.STRING, topic, consumerFuture, null);
+        consumerFuture.join();
 
         ConsumerBase consumerBase = spy(reader.getConsumer());
         FieldUtils.writeDeclaredField(