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 1b5574f commit 6b408a0Copy full SHA for 6b408a0
core/src/main/java/org/apache/spark/unsafe/map/BytesToBytesMap.java
@@ -395,10 +395,8 @@ public void remove() {
395
private void handleFailedDelete() {
396
// remove the spill file from disk
397
File file = spillWriters.removeFirst().getFile();
398
- if (file != null && file.exists()) {
399
- if (!file.delete()) {
400
- logger.error("Was unable to delete spill file {}", file.getAbsolutePath());
401
- }
+ if (file != null && file.exists() && !file.delete()) {
+ logger.error("Was unable to delete spill file {}", file.getAbsolutePath());
402
}
403
404
0 commit comments