We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent aa68ea4 commit ac5baeaCopy full SHA for ac5baea
core/src/main/scala/org/apache/spark/TaskContext.scala
@@ -77,8 +77,6 @@ class TaskContext(
77
/**
78
* Add a listener in the form of a Scala closure to be executed on task completion.
79
* This will be called in all situation - success, failure, or cancellation.
80
- * Exceptions in callbacks are however not thrown back upstream, i.e. tasks won't marked as
81
- * failed even if completion callbacks fail to execute.
82
*
83
* An example use is for HadoopRDD to register a callback to close the input stream.
84
*/
0 commit comments