We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 8fefa03 commit c98ff1dCopy full SHA for c98ff1d
core/src/main/scala/org/apache/spark/storage/DiskBlockObjectWriter.scala
@@ -280,9 +280,9 @@ private[spark] class DiskBlockObjectWriter(
280
}
281
282
/**
283
- * Reverts write metrics that haven't been committed yet and delete the file held
284
- * by current `DiskBlockObjectWriter`. Callers should invoke this function when there
285
- * are runtime exceptions in file writing process and the file is no longer needed.
+ * Reverts write metrics and delete the file held by current `DiskBlockObjectWriter`.
+ * Callers should invoke this function when there are runtime exceptions in file
+ * writing process and the file is no longer needed.
286
*/
287
def closeAndDelete(): Unit = {
288
Utils.tryWithSafeFinally {
0 commit comments