(helix) branch master updated: [Failed CI Test] testNoRetry (TestHelixTaskExecutor) - GitHub Issue #3103

[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 1571716f1   [Failed CI Test] testNoRetry (TestHelixTaskExecutor) - 
GitHub Issue #3103
1571716f1 is described below

commit 1571716f170bfa32b08e4528bd4678d7403c0313
Author: Junkai Xue <j...@apache.org>
AuthorDate: Fri Mar 6 21:40:05 2026 -0800

      [Failed CI Test] testNoRetry (TestHelixTaskExecutor) - GitHub Issue #3103
    
      Root Cause: The test testNoRetry waits 6000ms for message processing to 
complete. The test creates 4 messages with timeouts of 600ms, 1200ms, 1800ms, 
and 2400ms. The handler takes ~1500ms to execute. On slower CI machines or 
under load, the execution can take longer, causing the timing to be unreliable.
    
      Fix Applied: Increased the wait time from 6000ms to 8000ms in 
helix-core/src/test/java/org/apache/helix/messaging/handling/TestHelixTaskExecutor.java
 (line 889).
    
      This gives more buffer time for the messages to be processed reliably on 
slower machines while still maintaining reasonable test execution time.
---
 .../org/apache/helix/messaging/handling/TestHelixTaskExecutor.java    | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

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 c0d5ebef7..131bbca59 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
@@ -885,8 +885,8 @@ public class TestHelixTaskExecutor {
     LOG.info("Submitted {} messages to executor", nMsgs2);
 
     // Wait for processing to complete
-    // Use a longer wait time to ensure flaky test stability
-    int waitTime = 6000;
+    // Increased wait time to ensure flaky test stability on slower CI machines
+    int waitTime = 8000;
     LOG.info("Waiting {} ms for processing to complete...", waitTime);
     Thread.sleep(waitTime);