diff --git a/core/src/main/scala/org/apache/spark/util/Utils.scala b/core/src/main/scala/org/apache/spark/util/Utils.scala index f7b8f0ba7767f..0d7c5cf2d27a7 100644 --- a/core/src/main/scala/org/apache/spark/util/Utils.scala +++ b/core/src/main/scala/org/apache/spark/util/Utils.scala @@ -1156,8 +1156,7 @@ private[spark] object Utils extends Logging { } /** - * Execute a block of code that evaluates to Unit, forwarding any uncaught exceptions to the - * default UncaughtExceptionHandler + * Execute a block of code that evaluates to Unit, stop SparkContext is any uncaught exception */ def tryOrStopSparkContext(sc: SparkContext)(block: => Unit) { try {