You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by mr...@apache.org on 2021/04/13 18:31:05 UTC

[spark] branch master updated: [SPARK-35049][CORE] Remove unused MapOutputTracker in BlockStoreShuffleReader

This is an automated email from the ASF dual-hosted git repository.

mridulm80 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/spark.git


The following commit(s) were added to refs/heads/master by this push:
     new ee7d838  [SPARK-35049][CORE] Remove unused MapOutputTracker in BlockStoreShuffleReader
ee7d838 is described below

commit ee7d838aaf46f9d786e0388915b422fb78952893
Author: Angerszhuuuu <an...@gmail.com>
AuthorDate: Tue Apr 13 13:30:27 2021 -0500

    [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 <an...@gmail.com>
    Signed-off-by: Mridul Muralidharan <mridul<at>gmail.com>
---
 .../main/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 e44d96e..ea90ec41 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 {
 

---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org