diff options
| author | Imran Rashid <irashid@cloudera.com> | 2017-03-02 16:46:01 -0800 |
|---|---|---|
| committer | Kay Ousterhout <kayousterhout@gmail.com> | 2017-03-02 16:46:01 -0800 |
| commit | 8417a7ae6c0ea3fb8dc41bc492fc9513d1ad24af (patch) | |
| tree | 47d8411d2324b6d85b85c1936588ab1b4ff3ca46 /project | |
| parent | 433d9eb6151a547af967cc1ac983a789bed60704 (diff) | |
| download | spark-8417a7ae6c0ea3fb8dc41bc492fc9513d1ad24af.tar.gz spark-8417a7ae6c0ea3fb8dc41bc492fc9513d1ad24af.tar.bz2 spark-8417a7ae6c0ea3fb8dc41bc492fc9513d1ad24af.zip | |
[SPARK-19276][CORE] Fetch Failure handling robust to user error handling
## What changes were proposed in this pull request?
Fault-tolerance in spark requires special handling of shuffle fetch
failures. The Executor would catch FetchFailedException and send a
special msg back to the driver.
However, intervening user code could intercept that exception, and wrap
it with something else. This even happens in SparkSQL. So rather than
checking the thrown exception only, we'll store the fetch failure directly
in the TaskContext, where users can't touch it.
## How was this patch tested?
Added a test case which failed before the fix. Full test suite via jenkins.
Author: Imran Rashid <irashid@cloudera.com>
Closes #16639 from squito/SPARK-19276.
Diffstat (limited to 'project')
| -rw-r--r-- | project/MimaExcludes.scala | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/project/MimaExcludes.scala b/project/MimaExcludes.scala index 511686fb4f..56b8c0b95e 100644 --- a/project/MimaExcludes.scala +++ b/project/MimaExcludes.scala @@ -55,6 +55,9 @@ object MimaExcludes { // [SPARK-14272][ML] Add logLikelihood in GaussianMixtureSummary ProblemFilters.exclude[DirectMissingMethodProblem]("org.apache.spark.ml.clustering.GaussianMixtureSummary.this"), + // [SPARK-19267] Fetch Failure handling robust to user error handling + ProblemFilters.exclude[ReversedMissingMethodProblem]("org.apache.spark.TaskContext.setFetchFailed"), + // [SPARK-19069] [CORE] Expose task 'status' and 'duration' in spark history server REST API. ProblemFilters.exclude[DirectMissingMethodProblem]("org.apache.spark.status.api.v1.TaskData.this"), ProblemFilters.exclude[DirectMissingMethodProblem]("org.apache.spark.status.api.v1.TaskData.<init>$default$10"), |