format

apache · Aug 13, 2024 · 7c58790 · 7c58790
1 parent d310f70
commit 7c58790
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/client/src/main/scala/org/apache/celeborn/client/commit/MapPartitionCommitHandler.scala b/client/src/main/scala/org/apache/celeborn/client/commit/MapPartitionCommitHandler.scala
@@ -237,7 +237,9 @@ class MapPartitionCommitHandler(
       partitionLocations: Array[PartitionLocation]): Unit = {
     super.registerShuffle(shuffleId, numMappers, hasSegments, partitionLocations)
     pendingGetLocationContexts.synchronized {
-      pendingGetLocationContexts.computeIfAbsent(shuffleId, (k: Int) => new util.HashSet[RpcCallContext])
+      pendingGetLocationContexts.computeIfAbsent(
+        shuffleId,
+        (k: Int) => new util.HashSet[RpcCallContext])
       shuffleNumMappers.put(shuffleId, numMappers)
       shuffleHasSegments.put(shuffleId, hasSegments)
       processPendingGetLocationContexts(shuffleId, partitionLocations)