[incubator-uniffle] branch master updated: [ISSUE-402] Flaky Test: QuorumTest#case1 (#422)

[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 877b4ed0 [ISSUE-402] Flaky Test: QuorumTest#case1  (#422)
877b4ed0 is described below

commit 877b4ed0b18dc31185a05172e45d4cccc88195b4
Author: Rembrant <61581888+rembrant...@users.noreply.github.com>
AuthorDate: Thu Dec 15 10:07:48 2022 +0800

    [ISSUE-402] Flaky Test: QuorumTest#case1  (#422)
    
    ### What changes were proposed in this pull request?
    Fix flaky test QuorumTest#case1
    
    ### Why are the changes needed?
    Improve QuorumTest#case1 integration test cases stability
    
    ### Does this PR introduce any user-facing change?
    No
    
    ### How was this patch tested?
    No need
    
    Co-authored-by: Hui.Xie.76008383 <hui....@microfocus.com>
---
 .../common/src/test/java/org/apache/uniffle/test/QuorumTest.java     | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)

diff --git 
a/integration-test/common/src/test/java/org/apache/uniffle/test/QuorumTest.java 
b/integration-test/common/src/test/java/org/apache/uniffle/test/QuorumTest.java
index dd339d7a..d46b0885 100644
--- 
a/integration-test/common/src/test/java/org/apache/uniffle/test/QuorumTest.java
+++ 
b/integration-test/common/src/test/java/org/apache/uniffle/test/QuorumTest.java
@@ -74,7 +74,7 @@ public class QuorumTest extends ShuffleReadWriteBase {
 
   public static MockedShuffleServer createServer(int id) throws Exception {
     ShuffleServerConf shuffleServerConf = getShuffleServerConf();
-    shuffleServerConf.setLong("rss.server.app.expired.withoutHeartbeat", 4000);
+    shuffleServerConf.setLong("rss.server.app.expired.withoutHeartbeat", 8000);
     shuffleServerConf.setLong("rss.server.heartbeat.interval", 5000);
     File tmpDir = Files.createTempDir();
     tmpDir.deleteOnExit();
@@ -94,8 +94,7 @@ public class QuorumTest extends ShuffleReadWriteBase {
     createCoordinatorServer(coordinatorConf);
 
     ShuffleServerConf shuffleServerConf = getShuffleServerConf();
-    shuffleServerConf.setLong("rss.server.app.expired.withoutHeartbeat", 1000);
-    shuffleServerConf.setLong("rss.server.app.expired.withoutHeartbeat", 1000);
+    shuffleServerConf.setLong("rss.server.app.expired.withoutHeartbeat", 8000);
     File tmpDir = Files.createTempDir();
     tmpDir.deleteOnExit();