debug info

apache · Jul 31, 2023 · e5ae5e9 · e5ae5e9
1 parent 4d89572
commit e5ae5e9
Showing 1 changed file with 22 additions and 1 deletion.
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,9 +147,30 @@ public void testDataPushQueue() throws Exception {
 
     Thread.sleep(15 * 1000);
     running.set(false);
-    Thread.sleep(15 * 1000);
+
+    System.out.println("=====result======");
+
+    for (int i = 0; i < workerData.size(); i ++) {
+      List<Integer> data = workerData.get(i);
+      System.out.print("workerData    index: " + i + ", data: ");
+      for (int j = 0; j < data.size(); j ++) {
+        System.out.print(data.get(j) + ", ");
+      }
+      System.out.println();
+    }
+
+    for (int i = 0; i < tarWorkerData.size(); i ++) {
+      List<Integer> data = tarWorkerData.get(i);
+      System.out.print("tarWorkerData index: " + i + ", data: ");
+      for (int j = 0; j < data.size(); j ++) {
+        System.out.print(data.get(j) + ", ");
+      }
+      System.out.println();
+    }
 
     for (int i = 0; i < numWorker; i++) {
+      System.out.println(i + " workerData: " + workerData.get(i).toArray().length);
+      System.out.println(i + " tarWorkerData: " + tarWorkerData.get(i).toArray().length);
       Assert.assertArrayEquals(workerData.get(i).toArray(), tarWorkerData.get(i).toArray());
     }