reformat

apache · Nov 11, 2024 · 2d18124 · 2d18124
1 parent d2f7d33
commit 2d18124
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/master/src/main/scala/org/apache/celeborn/service/deploy/master/Master.scala b/master/src/main/scala/org/apache/celeborn/service/deploy/master/Master.scala
@@ -947,8 +947,10 @@ private[celeborn] class Master(
         .asScala.map { case (worker, slots) => worker.toUniqueId() -> slots }.asJava,
       requestSlots.requestId)
 
-    logInfo(s"Offer slots successfully for $numReducers reducers $numPartitions grouped reducers of $shuffleKey" +
-      s" on ${slots.size()} workers.")
+    logInfo(
+      s"Offer slots successfully for $numReducers reducers $numPartitions grouped reducers of $shuffleKey" +
+        s" on ${slots.size()} workers.")
+    logInfo(s"group nums $numMapTaskGroups")
 
     val workersNotSelected = availableWorkers.asScala.filter(!slots.containsKey(_))
     val offerSlotsExtraSize = Math.min(conf.masterSlotAssignExtraSlots, workersNotSelected.size)