Skip to content

Commit f807832

Browse files
committed
Log error if we can't throw it
1 parent 855f9aa commit f807832

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

core/src/main/java/org/apache/spark/shuffle/unsafe/UnsafeShuffleWriter.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -158,6 +158,9 @@ public void write(scala.collection.Iterator<Product2<K, V>> records) throws IOEx
158158
// error.
159159
if (success) {
160160
throw e;
161+
} else {
162+
logger.error("In addition to a failure during writing, we failed during " +
163+
"cleanup.", e);
161164
}
162165
}
163166
}

0 commit comments

Comments
 (0)