From 6087864c7b1e0558627234aabc3d85c7e830cf59 Mon Sep 17 00:00:00 2001 From: CodingCat Date: Sat, 14 Mar 2015 16:06:30 -0400 Subject: [PATCH] revise comments --- core/src/main/scala/org/apache/spark/util/Utils.scala | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) 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 {