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: reviews-unsubscr...@spark.apache.org For additional commands, e-mail: reviews-h...@spark.apache.org