diff --git a/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/FileSystem.java b/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/FileSystem.java index 61deb1a8de..57eb8f11cd 100644 --- a/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/FileSystem.java +++ b/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/FileSystem.java @@ -21,7 +21,6 @@ import java.io.Closeable; import java.io.FileNotFoundException; import java.io.IOException; -import java.io.InterruptedIOException; import java.lang.ref.WeakReference; import java.lang.ref.ReferenceQueue; import java.net.URI; @@ -3657,11 +3656,7 @@ private FileSystem getInternal(URI uri, Configuration conf, Key key) // to construct an instance. try (DurationInfo d = new DurationInfo(LOGGER, false, "Acquiring creator semaphore for %s", uri)) { - creatorPermits.acquire(); - } catch (InterruptedException e) { - // acquisition was interrupted; convert to an IOE. - throw (IOException)new InterruptedIOException(e.toString()) - .initCause(e); + creatorPermits.acquireUninterruptibly(); } FileSystem fsToClose = null; try {