You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@accumulo.apache.org by ec...@apache.org on 2013/03/04 21:38:36 UTC
svn commit: r1452496 -
/accumulo/branches/1.5/server/src/main/java/org/apache/accumulo/server/tabletserver/TabletServer.java
Author: ecn
Date: Mon Mar 4 20:38:35 2013
New Revision: 1452496
URL: http://svn.apache.org/r1452496
Log:
ACCUMULO-1147 remove missing file warning
Modified:
accumulo/branches/1.5/server/src/main/java/org/apache/accumulo/server/tabletserver/TabletServer.java
Modified: accumulo/branches/1.5/server/src/main/java/org/apache/accumulo/server/tabletserver/TabletServer.java
URL: http://svn.apache.org/viewvc/accumulo/branches/1.5/server/src/main/java/org/apache/accumulo/server/tabletserver/TabletServer.java?rev=1452496&r1=1452495&r2=1452496&view=diff
==============================================================================
--- accumulo/branches/1.5/server/src/main/java/org/apache/accumulo/server/tabletserver/TabletServer.java (original)
+++ accumulo/branches/1.5/server/src/main/java/org/apache/accumulo/server/tabletserver/TabletServer.java Mon Mar 4 20:38:35 2013
@@ -2095,9 +2095,13 @@ public class TabletServer extends Abstra
Path sourcePath = new Path(source);
if (!trash.moveToTrash(sourcePath) && !fs.delete(sourcePath, true))
log.warn("Failed to delete walog " + source);
- Path recoveryPath = new Path(Constants.getRecoveryDir(acuConf), filename);
- if (trash.moveToTrash(recoveryPath) || fs.delete(recoveryPath, true))
- log.info("Deleted any recovery log " + filename);
+ Path recoveryPath = new Path(Constants.getRecoveryDir(acuConf), filename);
+ try {
+ if (trash.moveToTrash(recoveryPath) || fs.delete(recoveryPath, true))
+ log.info("Deleted any recovery log " + filename);
+ } catch (FileNotFoundException ex) {
+ // ignore
+ }
}
} catch (IOException e) {