diff --git a/coordinator/src/test/java/org/apache/uniffle/coordinator/strategy/storage/AppBalanceSelectStorageStrategyTest.java b/coordinator/src/test/java/org/apache/uniffle/coordinator/strategy/storage/AppBalanceSelectStorageStrategyTest.java index d5a8ac1dff..b14d75419b 100644 --- a/coordinator/src/test/java/org/apache/uniffle/coordinator/strategy/storage/AppBalanceSelectStorageStrategyTest.java +++ b/coordinator/src/test/java/org/apache/uniffle/coordinator/strategy/storage/AppBalanceSelectStorageStrategyTest.java @@ -125,7 +125,7 @@ public void selectStorageTest() throws Exception { } @Test - @Timeout(20) + @Timeout(30) public void storageCounterMulThreadTest() throws Exception { String remoteStoragePath = remotePath1 + Constants.COMMA_SPLIT_CHAR + remotePath2 + Constants.COMMA_SPLIT_CHAR + remotePath3; @@ -133,8 +133,6 @@ public void storageCounterMulThreadTest() throws Exception { applicationManager.getSelectStorageStrategy().detectStorage(); CountDownLatch cdl = new CountDownLatch(3); String testApp1 = "application_testAppId"; - // init detectStorageScheduler - Thread.sleep(2000); Thread pickThread1 = new Thread(() -> { for (int i = 0; i < 1000; i++) { String appId = testApp1 + i; diff --git a/coordinator/src/test/java/org/apache/uniffle/coordinator/strategy/storage/LowestIOSampleCostSelectStorageStrategyTest.java b/coordinator/src/test/java/org/apache/uniffle/coordinator/strategy/storage/LowestIOSampleCostSelectStorageStrategyTest.java index 5dae0b4ca3..2faaf53441 100644 --- a/coordinator/src/test/java/org/apache/uniffle/coordinator/strategy/storage/LowestIOSampleCostSelectStorageStrategyTest.java +++ b/coordinator/src/test/java/org/apache/uniffle/coordinator/strategy/storage/LowestIOSampleCostSelectStorageStrategyTest.java @@ -142,7 +142,7 @@ public void selectStorageTest() throws Exception { } @Test - @Timeout(20) + @Timeout(30) public void selectStorageMulThreadTest() throws Exception { String remoteStoragePath = remoteStorage1 + Constants.COMMA_SPLIT_CHAR + remoteStorage2 + Constants.COMMA_SPLIT_CHAR + remoteStorage3; @@ -150,8 +150,6 @@ public void selectStorageMulThreadTest() throws Exception { applicationManager.getSelectStorageStrategy().detectStorage(); CountDownLatch cdl = new CountDownLatch(3); String testApp1 = "application_testAppId"; - // init detectStorageScheduler - Thread.sleep(2000); Thread pickThread1 = new Thread(() -> { for (int i = 0; i < 1000; i++) { String appId = testApp1 + i;