Github user HyukjinKwon commented on a diff in the pull request:
https://github.com/apache/spark/pull/19852#discussion_r155701675
--- Diff:
core/src/main/scala/org/apache/spark/api/python/PythonRunner.scala ---
@@ -317,10 +317,6 @@ private[spark] abstract class BasePythonRunner[IN,
OUT](
logDebug("Exception thrown after task interruption", e)
throw new
TaskKilledException(context.getKillReason().getOrElse("unknown reason"))
- case e: Exception if env.isStopped =>
--- End diff --
Note to myself: this was added in https://github.com/apache/spark/pull/2838
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
