|
@@ -2136,12 +2136,12 @@ public class DFSOutputStream extends FSOutputSummer
|
|
throw new IOException(msg);
|
|
throw new IOException(msg);
|
|
}
|
|
}
|
|
try {
|
|
try {
|
|
- Thread.sleep(localTimeout);
|
|
|
|
if (retries == 0) {
|
|
if (retries == 0) {
|
|
throw new IOException("Unable to close file because the last block"
|
|
throw new IOException("Unable to close file because the last block"
|
|
+ " does not have enough number of replicas.");
|
|
+ " does not have enough number of replicas.");
|
|
}
|
|
}
|
|
retries--;
|
|
retries--;
|
|
|
|
+ Thread.sleep(localTimeout);
|
|
localTimeout *= 2;
|
|
localTimeout *= 2;
|
|
if (Time.now() - localstart > 5000) {
|
|
if (Time.now() - localstart > 5000) {
|
|
DFSClient.LOG.info("Could not complete " + src + " retrying...");
|
|
DFSClient.LOG.info("Could not complete " + src + " retrying...");
|