MAPREDUCE-6639 Process hangs in LocatedFileStatusFetcher if FileSystem.get throws. Ryan Blue via stevel
This commit is contained in:
parent
d6d13ec670
commit
eab6e633ee
|
@ -175,7 +175,7 @@ public class LocatedFileStatusFetcher {
|
||||||
private void registerError(Throwable t) {
|
private void registerError(Throwable t) {
|
||||||
lock.lock();
|
lock.lock();
|
||||||
try {
|
try {
|
||||||
if (unknownError != null) {
|
if (unknownError == null) {
|
||||||
unknownError = t;
|
unknownError = t;
|
||||||
condition.signal();
|
condition.signal();
|
||||||
}
|
}
|
||||||
|
@ -368,4 +368,4 @@ public class LocatedFileStatusFetcher {
|
||||||
registerError(t);
|
registerError(t);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue