Log error if we can't throw it

maropu · Jun 23, 2015 · f807832 · f807832
1 parent 855f9aa
commit f807832
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/core/src/main/java/org/apache/spark/shuffle/unsafe/UnsafeShuffleWriter.java b/core/src/main/java/org/apache/spark/shuffle/unsafe/UnsafeShuffleWriter.java
@@ -158,6 +158,9 @@ public void write(scala.collection.Iterator<Product2<K, V>> records) throws IOEx
           // error.
           if (success) {
             throw e;
+          } else {
+            logger.error("In addition to a failure during writing, we failed during " +
+                         "cleanup.", e);
           }
         }
       }