Github user srowen commented on a diff in the pull request:
https://github.com/apache/spark/pull/19307#discussion_r140210769
--- Diff: core/src/main/scala/org/apache/spark/deploy/worker/Worker.scala
---
@@ -450,10 +450,9 @@ private[deploy] class Worker(
}
}(cleanupThreadExecutor)
- cleanupFuture.onFailure {
- case e: Throwable =>
- logError("App dir cleanup failed: " + e.getMessage, e)
- }(cleanupThreadExecutor)
+ cleanupFuture.failed.foreach(e =>
--- End diff --
onFailure, onSuccess are deprecated in 2.12. This should be equivalent in
2.11+2.12
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
