[jira] [Created] (SPARK-31845) DAGSchedulerSuite: Improve and reuse completeNextStageWithFetchFailure

["jiaan.geng (Jira)" <ji...@apache.org>]

jiaan.geng created SPARK-31845:
----------------------------------

             Summary: DAGSchedulerSuite: Improve and reuse completeNextStageWithFetchFailure
                 Key: SPARK-31845
                 URL: https://issues.apache.org/jira/browse/SPARK-31845
             Project: Spark
          Issue Type: Sub-task
          Components: Spark Core
    Affects Versions: 3.1.0
            Reporter: jiaan.geng


DAGSchedulerSuite provides completeNextStageWithFetchFailure to make next stage occurs fetch failure.
But many test case uses complete directly as follows:

{code:java}
    complete(taskSets(2), Seq(
      (FetchFailed(BlockManagerId("hostA-exec2", "hostA", 12345),
        firstShuffleId, 0L, 0, 0, "ignored"),
        null)
    ))
{code}

We need to improve completeNextStageWithFetchFailure and reuse it.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

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