From 27bfa9ab3a610e072c011fd88ee4684cea6ceb76 Mon Sep 17 00:00:00 2001 From: tedyu Date: Wed, 23 Sep 2015 10:01:28 +0100 Subject: [SPARK-10721] Log warning when file deletion fails Author: tedyu Closes #8843 from tedyu/master. --- .../spark/network/shuffle/ExternalShuffleBlockResolver.java | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) (limited to 'network') diff --git a/network/shuffle/src/main/java/org/apache/spark/network/shuffle/ExternalShuffleBlockResolver.java b/network/shuffle/src/main/java/org/apache/spark/network/shuffle/ExternalShuffleBlockResolver.java index c5f93bb47f..0d4dd6afac 100644 --- a/network/shuffle/src/main/java/org/apache/spark/network/shuffle/ExternalShuffleBlockResolver.java +++ b/network/shuffle/src/main/java/org/apache/spark/network/shuffle/ExternalShuffleBlockResolver.java @@ -114,10 +114,14 @@ public class ExternalShuffleBlockResolver { "recover state for existing applications", registeredExecutorFile, e); if (registeredExecutorFile.isDirectory()) { for (File f : registeredExecutorFile.listFiles()) { - f.delete(); + if (!f.delete()) { + logger.warn("error deleting {}", f.getPath()); + } } } - registeredExecutorFile.delete(); + if (!registeredExecutorFile.delete()) { + logger.warn("error deleting {}", registeredExecutorFile.getPath()); + } options.createIfMissing(true); try { tmpDb = JniDBFactory.factory.open(registeredExecutorFile, options); -- cgit v1.2.3