fix test

apache · Apr 21, 2023 · 2f56e1b · 2f56e1b
1 parent 8d5da32
commit 2f56e1b
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...r-broker/src/test/java/org/apache/pulsar/broker/service/ManagedLedgerCompressionTest.java b/...r-broker/src/test/java/org/apache/pulsar/broker/service/ManagedLedgerCompressionTest.java
@@ -100,7 +100,7 @@ private void produceAndConsume(Producer<byte[]> producer,
             producer.newMessage().value("test".getBytes()).send();
         }
         for (int i = 0; i < messageCnt; i++) {
-            Message<byte[]> message = consumer.receive(1000, TimeUnit.SECONDS);
+            Message<byte[]> message = consumer.receive(1000, TimeUnit.MILLISECONDS);
             consumer.acknowledge(message);
             Assert.assertNotNull(message);
         }