big-data/hadoop
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

HADOOP-17779: Lock File System Creator Semaphore Uninterruptibly (#3158)

Browse Source
This commit is contained in:
belugabehr 2022-10-11 06:56:32 -04:00 committed by GitHub
parent d14b88c698
commit 03d600fa82
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 1 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/FileSystem.java
View File

@ -21,7 +21,6 @@
import java.io.Closeable; import java.io.Closeable;
import java.io.FileNotFoundException; import java.io.FileNotFoundException;
import java.io.IOException; import java.io.IOException;
import java.io.InterruptedIOException;
import java.lang.ref.WeakReference; import java.lang.ref.WeakReference;
import java.lang.ref.ReferenceQueue; import java.lang.ref.ReferenceQueue;
import java.net.URI; import java.net.URI;
@ -3647,11 +3646,7 @@ private FileSystem getInternal(URI uri, Configuration conf, Key key)
// to construct an instance. // to construct an instance.
try (DurationInfo d = new DurationInfo(LOGGER, false, try (DurationInfo d = new DurationInfo(LOGGER, false,
"Acquiring creator semaphore for %s", uri)) { "Acquiring creator semaphore for %s", uri)) {
creatorPermits.acquire(); creatorPermits.acquireUninterruptibly();
} catch (InterruptedException e) {
// acquisition was interrupted; convert to an IOE.
throw (IOException)new InterruptedIOException(e.toString())
.initCause(e);
} }
FileSystem fsToClose = null; FileSystem fsToClose = null;
try { try {