Uploaded image for project: 'Spark'
  1. Spark
  2. SPARK-42719

`MapOutputTracker#getMapLocation` should respect `spark.shuffle.reduceLocality.enabled`

    XMLWordPrintableJSON

Details

    • Improvement
    • Status: Resolved
    • Major
    • Resolution: Fixed
    • 3.5.0
    • 3.5.0
    • Spark Core
    • None

    Description

      Discuss as https://github.com/apache/spark/pull/40307

      getPreferredLocations in ShuffledRowRDD should return Nil at the very beginning in case spark.shuffle.reduceLocality.enabled = false (conceptually).

      This logic is pushed into MapOutputTracker though - and getPreferredLocationsForShuffle honors spark.shuffle.reduceLocality.enabled - but getMapLocation does not.

      So the fix would be to fix getMapLocation to honor the parameter.

      Attachments

        Activity

          People

            roryqi He Qi
            roryqi He Qi
            Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: