Github user srowen commented on a diff in the pull request:
https://github.com/apache/spark/pull/21930#discussion_r206605419
--- Diff: core/src/main/scala/org/apache/spark/TaskContext.scala ---
@@ -123,7 +123,7 @@ abstract class TaskContext extends Serializable {
*
* Exceptions thrown by the listener will result in failure of the task.
*/
- def addTaskCompletionListener(f: (TaskContext) => Unit): TaskContext = {
+ def addTaskCompletionListener[U](f: (TaskContext) => U): TaskContext = {
--- End diff --
OK, if it's binary- and source-compatible with existing user programs for
2.11 users, that's fine. Bets are off for 2.12 users anyway.
When the release notes are crafted for 2.4, we'll want to mention this JIRA
(I'll tag it) and issues like this.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
