(celeborn) branch main updated: [CELEBORN-1654] Fix flaky test TestCongestionController#testUserMetrics

[rexxiong]

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

rexxiong pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/celeborn.git


The following commit(s) were added to refs/heads/main by this push:
     new fdff49453 [CELEBORN-1654] Fix flaky test 
TestCongestionController#testUserMetrics
fdff49453 is described below

commit fdff4945312385a90575e63cf89a62c4bc88c3f0
Author: Xianming Lei <31424839+le...@users.noreply.github.com>
AuthorDate: Thu Oct 17 13:46:30 2024 +0800

    [CELEBORN-1654] Fix flaky test TestCongestionController#testUserMetrics
    
    ### What changes were proposed in this pull request?
    Fix flaky test TestCongestionController#testUserMetrics
    
    ### Why are the changes needed?
    Fix flaky test TestCongestionController#testUserMetrics
    
    ### Does this PR introduce _any_ user-facing change?
    No.
    
    ### How was this patch tested?
    Existing UTs.
    
    Closes #2814 from leixm/CELEBORN-1654.
    
    Authored-by: Xianming Lei <31424839+le...@users.noreply.github.com>
    Signed-off-by: Shuang <lvshuang....@alibaba-inc.com>
---
 .../service/deploy/worker/congestcontrol/TestCongestionController.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/worker/src/test/java/org/apache/celeborn/service/deploy/worker/congestcontrol/TestCongestionController.java
 
b/worker/src/test/java/org/apache/celeborn/service/deploy/worker/congestcontrol/TestCongestionController.java
index d824abb46..ea1da91f5 100644
--- 
a/worker/src/test/java/org/apache/celeborn/service/deploy/worker/congestcontrol/TestCongestionController.java
+++ 
b/worker/src/test/java/org/apache/celeborn/service/deploy/worker/congestcontrol/TestCongestionController.java
@@ -136,7 +136,7 @@ public class TestCongestionController {
 
     Assert.assertTrue(source.gaugeExists(WorkerSource.USER_PRODUCE_SPEED(), 
user.toMap()));
 
-    Thread.sleep(userInactiveTimeMills * 2);
+    Thread.sleep(userInactiveTimeMills * 2 + 100);
 
     Assert.assertFalse(source.gaugeExists(WorkerSource.USER_PRODUCE_SPEED(), 
user.toMap()));
     clearBufferStatus(controller);