diff options
| author | Holden Karau <holden@pigscanfly.ca> | 2013-03-24 16:15:32 -0700 |
|---|---|---|
| committer | Holden Karau <holden@pigscanfly.ca> | 2013-03-24 16:15:32 -0700 |
| commit | f5df729b12c80a847de0e788956b9020266ad91f (patch) | |
| tree | d5bf632ca763ab9f5f4a312c5dd4f21be2efc523 /core | |
| parent | b8949cab889da4ba0f613a17b2eef52a32476410 (diff) | |
| download | spark-f5df729b12c80a847de0e788956b9020266ad91f.tar.gz spark-f5df729b12c80a847de0e788956b9020266ad91f.tar.bz2 spark-f5df729b12c80a847de0e788956b9020266ad91f.zip | |
Explicitly catch all throwables (warning in 2.10)
Diffstat (limited to 'core')
| -rw-r--r-- | core/src/main/scala/spark/CacheManager.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/core/src/main/scala/spark/CacheManager.scala b/core/src/main/scala/spark/CacheManager.scala index c7b379a3fb..f7a2b7e802 100644 --- a/core/src/main/scala/spark/CacheManager.scala +++ b/core/src/main/scala/spark/CacheManager.scala @@ -27,7 +27,7 @@ private[spark] class CacheManager(blockManager: BlockManager) extends Logging { if (loading.contains(key)) { logInfo("Loading contains " + key + ", waiting...") while (loading.contains(key)) { - try {loading.wait()} catch {case _ =>} + try {loading.wait()} catch {case _ : Throwable =>} } logInfo("Loading no longer contains " + key + ", so returning cached result") // See whether someone else has successfully loaded it. The main way this would fail |