You are viewing a plain text version of this content. The canonical link for it is here.
Posted to common-commits@hadoop.apache.org by st...@apache.org on 2022/10/11 12:26:19 UTC
[hadoop] branch branch-3.3.5 updated: HADOOP-17779: Lock File System Creator Semaphore Uninterruptibly (#3158)
This is an automated email from the ASF dual-hosted git repository.
stevel pushed a commit to branch branch-3.3.5
in repository https://gitbox.apache.org/repos/asf/hadoop.git
The following commit(s) were added to refs/heads/branch-3.3.5 by this push:
new 9b2839215b6 HADOOP-17779: Lock File System Creator Semaphore Uninterruptibly (#3158)
9b2839215b6 is described below
commit 9b2839215b6c1c933fe0c210da8e2b74a2242097
Author: belugabehr <12...@users.noreply.github.com>
AuthorDate: Tue Oct 11 06:56:32 2022 -0400
HADOOP-17779: Lock File System Creator Semaphore Uninterruptibly (#3158)
Contributed by David Mollitor.
---
.../src/main/java/org/apache/hadoop/fs/FileSystem.java | 7 +------
1 file changed, 1 insertion(+), 6 deletions(-)
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 61deb1a8de6..57eb8f11cd5 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 javax.annotation.Nonnull;
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 @@ public abstract class FileSystem extends Configured
// 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 {
---------------------------------------------------------------------
To unsubscribe, e-mail: common-commits-unsubscribe@hadoop.apache.org
For additional commands, e-mail: common-commits-help@hadoop.apache.org