From ee7d838aaf46f9d786e0388915b422fb78952893 Mon Sep 17 00:00:00 2001 From: Angerszhuuuu Date: Tue, 13 Apr 2021 13:30:27 -0500 Subject: [PATCH] [SPARK-35049][CORE] Remove unused MapOutputTracker in BlockStoreShuffleReader ### What changes were proposed in this pull request? Remove unused MapOutputTracker in BlockStoreShuffleReader ### Why are the changes needed? Remove unused MapOutputTracker in BlockStoreShuffleReader ### Does this PR introduce _any_ user-facing change? No ### How was this patch tested? Not need Closes #32148 from AngersZhuuuu/SPARK-35049. Authored-by: Angerszhuuuu Signed-off-by: Mridul Muralidharan gmail.com> --- .../scala/org/apache/spark/shuffle/BlockStoreShuffleReader.scala | 1 - 1 file changed, 1 deletion(-) diff --git a/core/src/main/scala/org/apache/spark/shuffle/BlockStoreShuffleReader.scala b/core/src/main/scala/org/apache/spark/shuffle/BlockStoreShuffleReader.scala index e44d96e273..ea90ec41fb 100644 --- a/core/src/main/scala/org/apache/spark/shuffle/BlockStoreShuffleReader.scala +++ b/core/src/main/scala/org/apache/spark/shuffle/BlockStoreShuffleReader.scala @@ -35,7 +35,6 @@ private[spark] class BlockStoreShuffleReader[K, C]( readMetrics: ShuffleReadMetricsReporter, serializerManager: SerializerManager = SparkEnv.get.serializerManager, blockManager: BlockManager = SparkEnv.get.blockManager, - mapOutputTracker: MapOutputTracker = SparkEnv.get.mapOutputTracker, shouldBatchFetch: Boolean = false) extends ShuffleReader[K, C] with Logging {