This is an automated email from the ASF dual-hosted git repository.
mridulm80 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/spark.git
The following commit(s) were added to refs/heads/master by this push:
new 59fcc0f97bd5 Update DAGScheduler.scala
59fcc0f97bd5 is described below
commit 59fcc0f97bd5933a96b56dd50283fdb32603a17d
Author: WHJian <[email protected]>
AuthorDate: Sat Dec 6 02:21:27 2025 -0600
Update DAGScheduler.scala
should even to event
### What changes were proposed in this pull request?
### Why are the changes needed?
### Does this PR introduce _any_ user-facing change?
### How was this patch tested?
### Was this patch authored or co-authored using generative AI tooling?
Closes #52607 from WHJian/patch-1.
Authored-by: WHJian <[email protected]>
Signed-off-by: Mridul Muralidharan <mridul<at>gmail.com>
---
core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala
b/core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala
index 7c8bea31334b..61a1d6c53b28 100644
--- a/core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala
+++ b/core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala
@@ -1659,7 +1659,7 @@ private[spark] class DAGScheduler(
stage.makeNewStageAttempt(partitionsToCompute.size,
taskIdToLocations.values.toSeq)
// If there are tasks to execute, record the submission time of the stage.
Otherwise,
- // post the even without the submission time, which indicates that this
stage was
+ // post the event without the submission time, which indicates that this
stage was
// skipped.
if (partitionsToCompute.nonEmpty) {
stage.latestInfo.submissionTime = Some(clock.getTimeMillis())
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]