Github user liutang123 commented on a diff in the pull request: https://github.com/apache/spark/pull/22202#discussion_r212601673 --- Diff: core/src/test/scala/org/apache/spark/scheduler/DAGSchedulerSuite.scala --- @@ -2246,58 +2247,6 @@ class DAGSchedulerSuite extends SparkFunSuite with LocalSparkContext with TimeLi assertDataStructuresEmpty() } - test("Trigger mapstage's job listener in submitMissingTasks") { --- End diff -- Because that PR is conflict with this PR. In that PR, shuffleMapStage waits the completion of parent stages's rerun. In this PR, shuffleMapStage completes immediately when all partitions are ready.
--- --------------------------------------------------------------------- To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org For additional commands, e-mail: reviews-h...@spark.apache.org