(iotdb) branch master updated: Fix ACK retention recycling test initialization (#18974)

[jiangtian]

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

jt2594838 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/master by this push:
     new 212214e6ae2 Fix ACK retention recycling test initialization (#18974)
212214e6ae2 is described below

commit 212214e6ae2c3a9bc28838a65b9a3d709faa77d1
Author: Caideyipi <87789683+caidey...@users.noreply.github.com>
AuthorDate: Thu Oct 22 11:42:25 2026 +0800

    Fix ACK retention recycling test initialization (#18974)
---
 .../db/subscription/broker/consensus/ConsensusPrefetchingQueueTest.java  | 1 +
 1 file changed, 1 insertion(+)

diff --git 
a/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/subscription/broker/consensus/ConsensusPrefetchingQueueTest.java
 
b/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/subscription/broker/consensus/ConsensusPrefetchingQueueTest.java
index a8c880495c9..ba3c2a972ce 100644
--- 
a/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/subscription/broker/consensus/ConsensusPrefetchingQueueTest.java
+++ 
b/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/subscription/broker/consensus/ConsensusPrefetchingQueueTest.java
@@ -2630,6 +2630,7 @@ public class ConsensusPrefetchingQueueTest {
               }
             };
         queue.setSubscriptionMemoryManager(new SubscriptionMemoryManager(1024L 
* 1024L));
+        assertNull(queue.poll("consumer"));
         assertTrue(pendingEntries(queue).offer(createRequest(1L)));
         assertTrue(pendingEntries(queue).offer(createRequest(2L)));
         queue.drivePrefetchOnce();