[Improvement] Add more logs about data flush

apache · Jan 13, 2023 · accfa3a · accfa3a
1 parent f4048fc
commit accfa3a
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 1 deletion.
diff --git a/server/src/main/java/org/apache/uniffle/server/ShuffleDataFlushEvent.java b/server/src/main/java/org/apache/uniffle/server/ShuffleDataFlushEvent.java
@@ -158,6 +158,9 @@ public String toString() {
         + ", appId=" + appId
         + ", shuffleId=" + shuffleId
         + ", startPartition=" + startPartition
-        + ", endPartition=" + endPartition;
+        + ", endPartition=" + endPartition
+        + ", retryTimes=" + retryTimes
+        + ", underStorage=" + underStorage.getClass().getSimpleName()
+        + ", isPended=" + isPended;
   }
 }
diff --git a/server/src/main/java/org/apache/uniffle/server/ShuffleFlushManager.java b/server/src/main/java/org/apache/uniffle/server/ShuffleFlushManager.java
@@ -165,6 +165,7 @@ private void flushToFile(ShuffleDataFlushEvent event) {
 
         Storage storage = storageManager.selectStorage(event);
         if (storage == null) {
+          LOG.error("Storage selected is null and this should not happen. event: {}", event);
           break;
         }