Author: ecn
Date: Tue Apr 23 14:05:54 2013
New Revision: 1470971
URL: http://svn.apache.org/r1470971
Log:
ACCUMULO-1328 make the retry time for recoverLease() configurable
Modified:
accumulo/branches/1.5/server/src/main/java/org/apache/accumulo/server/master/recovery/RecoveryManager.java
Modified:
accumulo/branches/1.5/server/src/main/java/org/apache/accumulo/server/master/recovery/RecoveryManager.java
URL:
http://svn.apache.org/viewvc/accumulo/branches/1.5/server/src/main/java/org/apache/accumulo/server/master/recovery/RecoveryManager.java?rev=1470971&r1=1470970&r2=1470971&view=diff
==============================================================================
---
accumulo/branches/1.5/server/src/main/java/org/apache/accumulo/server/master/recovery/RecoveryManager.java
(original)
+++
accumulo/branches/1.5/server/src/main/java/org/apache/accumulo/server/master/recovery/RecoveryManager.java
Tue Apr 23 14:05:54 2013
@@ -85,7 +85,7 @@ public class RecoveryManager {
if (localFs instanceof TraceFileSystem)
localFs = ((TraceFileSystem) localFs).getImplementation();
- long time = closer.close(localFs, getSource(host, filename));
+ long time = closer.close(master, localFs, getSource(host, filename));
if (time > 0) {
executor.schedule(this, time, TimeUnit.MILLISECONDS);