[GitHub] [spark] dbtsai commented on a change in pull request #32033: [SPARK-34939][CORE] Throw fetch failure exception when unable to deserialize broadcasted map statuses

2021-04-02 Thread GitBox
dbtsai commented on a change in pull request #32033: URL: https://github.com/apache/spark/pull/32033#discussion_r606123297 ## File path: core/src/main/scala/org/apache/spark/MapOutputTracker.scala ## @@ -953,13 +959,19 @@ private[spark] object MapOutputTracker extends Logging {

[GitHub] [spark] dbtsai commented on a change in pull request #32033: [SPARK-34939][CORE] Throw fetch failure exception when unable to deserialize broadcasted map statuses

2021-04-02 Thread GitBox
dbtsai commented on a change in pull request #32033: URL: https://github.com/apache/spark/pull/32033#discussion_r606122357 ## File path: core/src/main/scala/org/apache/spark/MapOutputTracker.scala ## @@ -843,7 +843,13 @@ private[spark] class MapOutputTrackerWorker(conf: SparkC

[GitHub] [spark] dbtsai commented on a change in pull request #32033: [SPARK-34939][CORE] Throw fetch failure exception when unable to deserialize broadcasted map statuses

2021-04-02 Thread GitBox
dbtsai commented on a change in pull request #32033: URL: https://github.com/apache/spark/pull/32033#discussion_r606122022 ## File path: core/src/main/scala/org/apache/spark/MapOutputTracker.scala ## @@ -843,7 +843,13 @@ private[spark] class MapOutputTrackerWorker(conf: SparkC