try

apache · Jul 28, 2023 · 4d89572 · 4d89572
1 parent e1b97f2
commit 4d89572
Showing 1 changed file with 1 addition and 0 deletions.
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
@@ -147,6 +147,7 @@ public void testDataPushQueue() throws Exception {
 
     Thread.sleep(15 * 1000);
     running.set(false);
+    Thread.sleep(15 * 1000);
 
     for (int i = 0; i < numWorker; i++) {
       Assert.assertArrayEquals(workerData.get(i).toArray(), tarWorkerData.get(i).toArray());