diff options
| author | Mark Hamstra <markhamstra@gmail.com> | 2016-12-16 12:46:32 -0800 |
|---|---|---|
| committer | Marcelo Vanzin <vanzin@cloudera.com> | 2016-12-16 12:46:32 -0800 |
| commit | 295db8259b307cc0e7d9de44f5638c1aa7ef6047 (patch) | |
| tree | fb1fed80b1b5c0e123d479f63fc25e712f3f34fa /sql/core | |
| parent | 1169db44bc1d51e68feb6ba2552520b2d660c2c0 (diff) | |
| download | spark-295db8259b307cc0e7d9de44f5638c1aa7ef6047.tar.gz spark-295db8259b307cc0e7d9de44f5638c1aa7ef6047.tar.bz2 spark-295db8259b307cc0e7d9de44f5638c1aa7ef6047.zip | |
[SPARK-17769][CORE][SCHEDULER] Some FetchFailure refactoring
## What changes were proposed in this pull request?
Readability rewrites.
Changed order of `failedStage.failedOnFetchAndShouldAbort(task.stageAttemptId)` and `disallowStageRetryForTest` evaluation.
Stage resubmission guard condition changed from `failedStages.isEmpty` to `!failedStages.contains(failedStage)`
Log all resubmission of stages
## How was this patch tested?
existing tests
Author: Mark Hamstra <markhamstra@gmail.com>
Closes #15335 from markhamstra/SPARK-17769.
Diffstat (limited to 'sql/core')
0 files changed, 0 insertions, 0 deletions