diff --git a/client/src/test/java/org/apache/celeborn/client/write/DataPushQueueSuitJ.java b/client/src/test/java/org/apache/celeborn/client/write/DataPushQueueSuitJ.java
index cc2413085dc..4cdf9ad2c1a 100644
--- a/client/src/test/java/org/apache/celeborn/client/write/DataPushQueueSuitJ.java
+++ b/client/src/test/java/org/apache/celeborn/client/write/DataPushQueueSuitJ.java
@@ -146,7 +146,7 @@ public void testDataPushQueue() throws Exception {
             })
         .start();
 
-    Thread.sleep(60 * 1000);
+    Thread.sleep(15 * 1000);
     running.set(false);
 
     for (int i = 0; i < numWorker; i++) {