Github user xuanyuanking commented on a diff in the pull request:
    --- Diff: core/src/main/scala/org/apache/spark/MapOutputTracker.scala ---
    @@ -213,6 +213,12 @@ private[spark] sealed trait MapOutputTrackerMessage
     private[spark] case class GetMapOutputStatuses(shuffleId: Int)
       extends MapOutputTrackerMessage
     private[spark] case object StopMapOutputTracker extends 
    +private[spark] case class CheckNoMissingPartitions(shuffleId: Int)
    --- End diff --
    Changes about MapOutputTracker same in #21293 


To unsubscribe, e-mail:
For additional commands, e-mail:

Reply via email to