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 0ab67465049..90525863e51 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
@@ -124,11 +124,15 @@ public void testDataPushQueue() throws Exception {
     }
 
     AtomicBoolean running = new AtomicBoolean(true);
+    System.out.println(System.currentTimeMillis() + " before thread start....");
     new Thread(
             () -> {
               while (running.get()) {
+                long startTs = System.currentTimeMillis();
+                System.out.println(startTs + " thread running....");
                 try {
                   ArrayList<PushTask> tasks = dataPushQueue.takePushTasks();
+                  System.out.println("task size: " + tasks.size());
                   for (int i = 0; i < tasks.size(); i++) {
                     PushTask task = tasks.get(i);
                     byte[] buffer = task.getBuffer();
@@ -139,13 +143,19 @@ public void testDataPushQueue() throws Exception {
                         reducePartitionMap.get(partitionId).hostAndPushPort());
                   }
                 } catch (IOException | InterruptedException e) {
+                  e.printStackTrace();
                   throw new RuntimeException(e);
+                } finally {
+                  System.out.println("took: " + (System.currentTimeMillis() - startTs));
                 }
               }
+              System.out.println("running is false.....");
             })
         .start();
 
+    System.out.println(System.currentTimeMillis() + " before sleep....");
     Thread.sleep(15 * 1000);
+    System.out.println(System.currentTimeMillis() + " finish sleep....");
     running.set(false);
 
     System.out.println("=====result======");