[pulsar] branch branch-2.11 updated: [fix][test] Fix CompactionTest.testBatchMessageWithNullValue

[zhaocong]

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

zhaocong pushed a commit to branch branch-2.11
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/branch-2.11 by this push:
     new 7334c44a990 [fix][test] Fix 
CompactionTest.testBatchMessageWithNullValue
7334c44a990 is described below

commit 7334c44a9907d5a5417e3f4d799d545a662ff3f6
Author: coderzc <zhaoc...@apache.org>
AuthorDate: Fri Aug 18 14:55:09 2023 +0800

    [fix][test] Fix CompactionTest.testBatchMessageWithNullValue
---
 .../src/test/java/org/apache/pulsar/compaction/CompactionTest.java     | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git 
a/pulsar-broker/src/test/java/org/apache/pulsar/compaction/CompactionTest.java 
b/pulsar-broker/src/test/java/org/apache/pulsar/compaction/CompactionTest.java
index 8cee20f87c7..45c7d769c0d 100644
--- 
a/pulsar-broker/src/test/java/org/apache/pulsar/compaction/CompactionTest.java
+++ 
b/pulsar-broker/src/test/java/org/apache/pulsar/compaction/CompactionTest.java
@@ -569,7 +569,8 @@ public class CompactionTest extends 
MockedPulsarServiceBaseTest {
 
 
         // compact the topic
-        compact(topic);
+        Compactor compactor = new TwoPhaseCompactor(conf, pulsarClient, bk, 
compactionScheduler);
+        compactor.compact(topic).get();
 
         // Read messages before compaction to get ids
         List<Message<byte[]>> messages = new ArrayList<>();