[incubator-uniffle] branch master updated: [#1254] fix(test): Fix the flaky test RssShuffleTest. (#1255)

[roryqi]

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

roryqi pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-uniffle.git


The following commit(s) were added to refs/heads/master by this push:
     new c4f31388 [#1254] fix(test): Fix the flaky test RssShuffleTest. (#1255)
c4f31388 is described below

commit c4f31388c8d9afdd91c6d026f929758fac9f8f11
Author: zhengchenyu <zhengcheny...@163.com>
AuthorDate: Mon Oct 23 14:55:10 2023 +0800

    [#1254] fix(test): Fix the flaky test RssShuffleTest. (#1255)
    
    ### What changes were proposed in this pull request?
    As title.
    
    ### Why are the changes needed?
    
    Fix: #1254
    
    ### Does this PR introduce _any_ user-facing change?
    
    No.
    
    ### How was this patch tested?
    
    unit test
---
 .../runtime/library/common/shuffle/orderedgrouped/RssShuffleTest.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/client-tez/src/test/java/org/apache/tez/runtime/library/common/shuffle/orderedgrouped/RssShuffleTest.java
 
b/client-tez/src/test/java/org/apache/tez/runtime/library/common/shuffle/orderedgrouped/RssShuffleTest.java
index 40a63761..b352f101 100644
--- 
a/client-tez/src/test/java/org/apache/tez/runtime/library/common/shuffle/orderedgrouped/RssShuffleTest.java
+++ 
b/client-tez/src/test/java/org/apache/tez/runtime/library/common/shuffle/orderedgrouped/RssShuffleTest.java
@@ -122,9 +122,9 @@ public class RssShuffleTest {
       conf.setLong(Constants.TEZ_RUNTIME_TASK_MEMORY, 300000L);
       RssShuffle shuffle = new RssShuffle(inputContext, conf, 1, 3000000L, 0, 
APPATTEMPT_ID);
       try {
-        shuffle.run();
         ShuffleScheduler scheduler = shuffle.rssScheduler;
         assertFalse(scheduler.isShutdown());
+        shuffle.run();
 
         // killSelf() would invoke close(). Internally Shuffle --> 
merge.close() --> finalMerge()
         // gets called. In MergeManager::finalMerge(), it would throw illegal 
argument exception