Xingbo Jiang created SPARK-56575:
------------------------------------
Summary: Extract scheduleResubmit() helper to remove identical
code blocks
Key: SPARK-56575
URL: https://issues.apache.org/jira/browse/SPARK-56575
Project: Spark
Issue Type: Sub-task
Components: Spark Core
Affects Versions: 4.2.0
Reporter: Xingbo Jiang
Assignee: Xingbo Jiang
The following 5-line block appears verbatim at different locations in
DAGScheduler.scala:
```
messageScheduler.schedule(
new Runnable {
override def run(): Unit = eventProcessLoop.post(ResubmitFailedStages())
},
RESUBMIT_TIMEOUT, TimeUnit.MILLISECONDS)
```
We should extract a private helper method scheduleResubmit() and replace all
different call sites with the helper method.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
