From 39eeb02ed68598678bad17134ca47b3b05571c57 Mon Sep 17 00:00:00 2001 From: CodingCat Date: Mon, 20 Oct 2014 15:57:32 -0400 Subject: [PATCH] call tryOrExit instead of logUncaughtExceptions in ContextCleaner.keepCleaning --- core/src/main/scala/org/apache/spark/ContextCleaner.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/core/src/main/scala/org/apache/spark/ContextCleaner.scala b/core/src/main/scala/org/apache/spark/ContextCleaner.scala index ede1e23f4fcc5..bc84dd33ab42e 100644 --- a/core/src/main/scala/org/apache/spark/ContextCleaner.scala +++ b/core/src/main/scala/org/apache/spark/ContextCleaner.scala @@ -130,7 +130,7 @@ private[spark] class ContextCleaner(sc: SparkContext) extends Logging { } /** Keep cleaning RDD, shuffle, and broadcast state. */ - private def keepCleaning(): Unit = Utils.logUncaughtExceptions { + private def keepCleaning(): Unit = Utils.tryOrExit { while (!stopped) { try { val reference = Option(referenceQueue.remove(ContextCleaner.REF_QUEUE_POLL_TIMEOUT))