-
Notifications
You must be signed in to change notification settings - Fork 28.2k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
[SPARK-5316] [CORE] DAGScheduler may make shuffleToMapStage leak if getParentStages failes #4105
Conversation
…etParentStages failes
Test build #25759 has finished for PR 4105 at commit
|
This is reasonable, but it doesn't handle |
@YanTangZhai When will |
DAGScheduler may make shuffleToMapStage leak if getParentStages failes.
If getParentStages has exception for example input path does not exist, DAGScheduler would fail to handle job submission, while shuffleToMapStage may be put some records when getParentStages. However these records in shuffleToMapStage aren't going to be cleaned.
A simple job as follows: