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 10:57:01 UTC
[hadoop] branch trunk 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 trunk
in repository https://gitbox.apache.org/repos/asf/hadoop.git
The following commit(s) were added to refs/heads/trunk by this push:
new 03d600fa822 HADOOP-17779: Lock File System Creator Semaphore Uninterruptibly (#3158)
03d600fa822 is described below
commit 03d600fa82203a930bcc13c1d682d2d6096a3c10
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)
---
.../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 0bc419b0353..7582488e7f9 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;
@@ -3647,11 +3646,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