to be compatible with scala 2.11

apache · Apr 18, 2024 · f220fcd · f220fcd
1 parent f7e0999
commit f220fcd
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/client/src/main/scala/org/apache/celeborn/client/ChangePartitionManager.scala b/client/src/main/scala/org/apache/celeborn/client/ChangePartitionManager.scala
@@ -161,9 +161,11 @@ class ChangePartitionManager(
       var newEntry = false
       val set = requests.computeIfAbsent(
         partitionId,
-        (_: Integer) => {
-          newEntry = true
-          new util.HashSet[ChangePartitionRequest]()
+        new java.util.function.Function[Integer, util.Set[ChangePartitionRequest]] {
+          override def apply(t: Integer): util.Set[ChangePartitionRequest] = {
+            newEntry = true
+            new util.HashSet[ChangePartitionRequest]()
+          }
         })
 
       if (newEntry) {