(iotdb) branch master updated: Fix flaky heartbeat executor bound test (#18773)

[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 50d86cf4161 Fix flaky heartbeat executor bound test (#18773)
50d86cf4161 is described below

commit 50d86cf4161a10baff14e17593321b2ddaa5f2d3
Author: Caideyipi <87789683+caidey...@users.noreply.github.com>
AuthorDate: Wed Sep 30 09:39:29 2026 +0800

    Fix flaky heartbeat executor bound test (#18773)
---
 .../SubscriptionConsumerHeartbeatIsolationTest.java     | 17 +++++++++--------
 1 file changed, 9 insertions(+), 8 deletions(-)

diff --git 
a/iotdb-client/subscription/src/test/java/org/apache/iotdb/session/subscription/consumer/base/SubscriptionConsumerHeartbeatIsolationTest.java
 
b/iotdb-client/subscription/src/test/java/org/apache/iotdb/session/subscription/consumer/base/SubscriptionConsumerHeartbeatIsolationTest.java
index 1c7d0af6b66..842f7e7daf2 100644
--- 
a/iotdb-client/subscription/src/test/java/org/apache/iotdb/session/subscription/consumer/base/SubscriptionConsumerHeartbeatIsolationTest.java
+++ 
b/iotdb-client/subscription/src/test/java/org/apache/iotdb/session/subscription/consumer/base/SubscriptionConsumerHeartbeatIsolationTest.java
@@ -120,16 +120,17 @@ public class SubscriptionConsumerHeartbeatIsolationTest {
     final CountDownLatch releaseTasks = new CountDownLatch(1);
     final List<Future<?>> futures = new ArrayList<>();
     try {
-      for (int i = 0; i < maximumPoolSize; i++) {
-        futures.add(
-            SubscriptionExecutorServiceManager.submitProviderHeartbeat(() -> 
await(releaseTasks)));
-      }
-      for (int i = 0; i < queueCapacity; i++) {
-        futures.add(
-            SubscriptionExecutorServiceManager.submitProviderHeartbeat(() -> 
await(releaseTasks)));
+      // The executor is shared, so other heartbeat tasks may consume capacity 
concurrently.
+      for (int i = 0; i <= maximumPoolSize + queueCapacity; i++) {
+        final Future<?> future =
+            SubscriptionExecutorServiceManager.submitProviderHeartbeat(() -> 
await(releaseTasks));
+        if (Objects.isNull(future)) {
+          break;
+        }
+        futures.add(future);
       }
 
-      
Assert.assertNull(SubscriptionExecutorServiceManager.submitProviderHeartbeat(() 
-> {}));
+      Assert.assertTrue(futures.size() <= maximumPoolSize + queueCapacity);
     } finally {
       releaseTasks.countDown();
       for (final Future<?> future : futures) {