(helix) branch master updated: Extend time for flaky test TestHelixTaskExecutor 1. Increased maxWaitTime from 10000ms to 30000ms (30 seconds) 2. Added 1000ms sleep before starting to poll - gives executor time to receive and queue messages

[jxue]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new 428604b44 Extend time for flaky test TestHelixTaskExecutor   1. 
Increased maxWaitTime from 10000ms to 30000ms (30 seconds)   2. Added 1000ms 
sleep before starting to poll - gives executor time to receive and queue 
messages
428604b44 is described below

commit 428604b4419ec1ddf00796ab8ad9e844007f1072
Author: Junkai Xue <j...@apache.org>
AuthorDate: Wed Mar 11 23:00:38 2026 -0700

    Extend time for flaky test TestHelixTaskExecutor
      1. Increased maxWaitTime from 10000ms to 30000ms (30 seconds)
      2. Added 1000ms sleep before starting to poll - gives executor time to 
receive and queue messages
---
 .../org/apache/helix/messaging/handling/TestHelixTaskExecutor.java  | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git 
a/helix-core/src/test/java/org/apache/helix/messaging/handling/TestHelixTaskExecutor.java
 
b/helix-core/src/test/java/org/apache/helix/messaging/handling/TestHelixTaskExecutor.java
index 131bbca59..959565d89 100644
--- 
a/helix-core/src/test/java/org/apache/helix/messaging/handling/TestHelixTaskExecutor.java
+++ 
b/helix-core/src/test/java/org/apache/helix/messaging/handling/TestHelixTaskExecutor.java
@@ -989,8 +989,12 @@ public class TestHelixTaskExecutor {
     executor.onMessage("someInstance", msgList, changeContext);
     LOG.info("Submitted {} messages to executor", msgList.size());
 
+    // Give executor time to receive and queue messages before starting to poll
+    Thread.sleep(1000);
+
     // Wait for processing to stabilize - poll until counts stop changing
-    int maxWaitTime = 10000;
+    // Increased maxWaitTime to 30 seconds for flaky test stability
+    int maxWaitTime = 30000;
     int pollInterval = 500;
     int stableCount = 0;
     int lastCancelCount = -1;