Update BlockManager.scala

JoshRosen · web-flow · commit 47f9636b3f98 · 2016-09-14T16:25:33.000-07:00
diff --git a/core/src/main/scala/org/apache/spark/storage/BlockManager.scala b/core/src/main/scala/org/apache/spark/storage/BlockManager.scala
@@ -878,6 +878,8 @@ private[spark] class BlockManager(
       }
       res
     } finally {
+      // This cleanup is performed in a finally block rather than a `catch` to avoid having to
+      // catch and properly re-throw InterruptedException.
       if (exceptionWasThrown) {
         logWarning(s"Putting block $blockId failed due to an exception")
         // If an exception was thrown then it's possible that the code in `putBody` has already

Original file line number	Diff line number	Diff line change
`@@ -878,6 +878,8 @@ private[spark] class BlockManager(`
`878`	`878`	`}`
`879`	`879`	`res`
`880`	`880`	`} finally {`
	`881`	+ // This cleanup is performed in a finally block rather than a `catch` to avoid having to
	`882`	`+ // catch and properly re-throw InterruptedException.`
`881`	`883`	`if (exceptionWasThrown) {`
`882`	`884`	`logWarning(s"Putting block $blockId failed due to an exception")`
`883`	`885`	// If an exception was thrown then it's possible that the code in `putBody` has already