Przeglądaj źródła

MAPREDUCE-6639 Process hangs in LocatedFileStatusFetcher if FileSystem.get throws. Ryan Blue via stevel

Steve Loughran 9 lat temu
rodzic
commit
7eddecd357

+ 2 - 2
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapred/LocatedFileStatusFetcher.java

@@ -175,7 +175,7 @@ public class LocatedFileStatusFetcher {
   private void registerError(Throwable t) {
     lock.lock();
     try {
-      if (unknownError != null) {
+      if (unknownError == null) {
         unknownError = t;
         condition.signal();
       }
@@ -368,4 +368,4 @@ public class LocatedFileStatusFetcher {
       registerError(t);
     }
   }
-}
+}