reformat

apache · Oct 30, 2024 · ead64b9 · ead64b9
1 parent 32e9b71
commit ead64b9
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
@@ -961,8 +961,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)