diff --git a/core/src/main/java/org/apache/spark/shuffle/sort/io/LocalDiskShuffleExecutorComponents.java b/core/src/main/java/org/apache/spark/shuffle/sort/io/LocalDiskShuffleExecutorComponents.java index 861a8e623a6e..38f0a60f8b0d 100644 --- a/core/src/main/java/org/apache/spark/shuffle/sort/io/LocalDiskShuffleExecutorComponents.java +++ b/core/src/main/java/org/apache/spark/shuffle/sort/io/LocalDiskShuffleExecutorComponents.java @@ -17,6 +17,7 @@ package org.apache.spark.shuffle.sort.io; +import java.util.Collections; import java.util.Map; import java.util.Optional; @@ -57,7 +58,9 @@ public void initializeExecutor(String appId, String execId, Map throw new IllegalStateException("No blockManager available from the SparkEnv."); } blockResolver = - new IndexShuffleBlockResolver(sparkConf, blockManager, Map.of() /* Shouldn't be accessed */); + new IndexShuffleBlockResolver( + sparkConf, blockManager, Collections.emptyMap() /* Shouldn't be accessed */ + ); } @Override diff --git a/core/src/main/scala/org/apache/spark/shuffle/IndexShuffleBlockResolver.scala b/core/src/main/scala/org/apache/spark/shuffle/IndexShuffleBlockResolver.scala index 20b8d0809f32..7a76c2f97e8d 100644 --- a/core/src/main/scala/org/apache/spark/shuffle/IndexShuffleBlockResolver.scala +++ b/core/src/main/scala/org/apache/spark/shuffle/IndexShuffleBlockResolver.scala @@ -21,7 +21,7 @@ import java.io._ import java.nio.ByteBuffer import java.nio.channels.Channels import java.nio.file.Files -import java.util.{Map => JMap} +import java.util.{Collections, Map => JMap} import scala.collection.mutable.ArrayBuffer @@ -58,7 +58,7 @@ private[spark] class IndexShuffleBlockResolver( conf: SparkConf, // var for testing var _blockManager: BlockManager = null, - val taskIdMapsForShuffle: JMap[Int, OpenHashSet[Long]] = JMap.of()) + val taskIdMapsForShuffle: JMap[Int, OpenHashSet[Long]] = Collections.emptyMap()) extends ShuffleBlockResolver with Logging with MigratableResolver { diff --git a/core/src/test/java/org/apache/spark/shuffle/sort/UnsafeShuffleWriterSuite.java b/core/src/test/java/org/apache/spark/shuffle/sort/UnsafeShuffleWriterSuite.java index fac84b2e9187..d95d648c2d73 100644 --- a/core/src/test/java/org/apache/spark/shuffle/sort/UnsafeShuffleWriterSuite.java +++ b/core/src/test/java/org/apache/spark/shuffle/sort/UnsafeShuffleWriterSuite.java @@ -315,7 +315,7 @@ public void writeWithoutSpilling() throws Exception { @Test public void writeChecksumFileWithoutSpill() throws Exception { IndexShuffleBlockResolver blockResolver = - new IndexShuffleBlockResolver(conf, blockManager, Map.of()); + new IndexShuffleBlockResolver(conf, blockManager, Collections.emptyMap()); ShuffleChecksumBlockId checksumBlockId = new ShuffleChecksumBlockId(0, 0, IndexShuffleBlockResolver.NOOP_REDUCE_ID()); String checksumAlgorithm = conf.get(package$.MODULE$.SHUFFLE_CHECKSUM_ALGORITHM()); @@ -346,7 +346,7 @@ public void writeChecksumFileWithoutSpill() throws Exception { @Test public void writeChecksumFileWithSpill() throws Exception { IndexShuffleBlockResolver blockResolver = - new IndexShuffleBlockResolver(conf, blockManager, Map.of()); + new IndexShuffleBlockResolver(conf, blockManager, Collections.emptyMap()); ShuffleChecksumBlockId checksumBlockId = new ShuffleChecksumBlockId(0, 0, IndexShuffleBlockResolver.NOOP_REDUCE_ID()); String checksumAlgorithm = conf.get(package$.MODULE$.SHUFFLE_CHECKSUM_ALGORITHM());