From 7c587902ddd9383f7dc8de0615011e025e387fc2 Mon Sep 17 00:00:00 2001 From: Weijie Guo Date: Tue, 13 Aug 2024 17:31:49 +0800 Subject: [PATCH] format --- .../celeborn/client/commit/MapPartitionCommitHandler.scala | 4 +++- 1 file changed, 3 insertions(+), 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 index ceb89d53f52..9b3e6c39c86 100644 --- 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)