|
@@ -2630,8 +2630,8 @@ class DFSClient implements FSConstants {
|
|
|
}
|
|
|
|
|
|
flushInternal(); // flush all data to Datanodes
|
|
|
- isClosed();
|
|
|
- closed = true;
|
|
|
+ isClosed(); // check to see if flushInternal had any exceptions
|
|
|
+ closed = true; // allow closeThreads() to showdown threads
|
|
|
|
|
|
closeThreads();
|
|
|
|
|
@@ -2653,8 +2653,6 @@ class DFSClient implements FSConstants {
|
|
|
|
|
|
long localstart = System.currentTimeMillis();
|
|
|
boolean fileComplete = false;
|
|
|
- int fileCompleteRetry = 0;
|
|
|
- final int checkFileCompleteRetry = 10;
|
|
|
while (!fileComplete) {
|
|
|
fileComplete = namenode.complete(src, clientName);
|
|
|
if (!fileComplete) {
|
|
@@ -2665,9 +2663,6 @@ class DFSClient implements FSConstants {
|
|
|
}
|
|
|
} catch (InterruptedException ie) {
|
|
|
}
|
|
|
- // after retrying for checkFileCompleteRetry times check isClosed()
|
|
|
- if ((++fileCompleteRetry % checkFileCompleteRetry) == 0)
|
|
|
- isClosed();
|
|
|
}
|
|
|
}
|
|
|
} finally {
|