fix: Bounded IO 线程池拒绝策略修正

修正Bounded IO 线程池在等待新任务加入被中断时，抛出 Reject 异常
tencentyun · Jan 29, 2021 · 078ce98 · 078ce98
1 parent 5fef461
commit 078ce98
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 2 deletions.
diff --git a/pom.xml b/pom.xml
@@ -6,7 +6,7 @@
 
     <groupId>com.qcloud.cos</groupId>
     <artifactId>hadoop-cos</artifactId>
-    <version>5.9.1</version>
+    <version>5.9.2</version>
     <packaging>jar</packaging>
 
     <name>Apache Hadoop Tencent Qcloud COS Support</name>

diff --git a/src/main/java/org/apache/hadoop/fs/CosFileSystem.java b/src/main/java/org/apache/hadoop/fs/CosFileSystem.java
@@ -141,7 +141,12 @@ public void rejectedExecution(Runnable r,
                             } catch (InterruptedException e) {
                                 LOG.error("put a io task into the download " +
                                         "thread pool occurs an exception.", e);
+                                throw new RejectedExecutionException(
+                                        "Putting the io task failed due to the interruption", e);
                             }
+                        } else {
+                            LOG.error("The bounded io thread pool has been shutdown.");
+                            throw new RejectedExecutionException("The bounded io thread pool has been shutdown");
                         }
                     }
                 }

diff --git a/src/main/java/org/apache/hadoop/fs/CosNConfigKeys.java b/src/main/java/org/apache/hadoop/fs/CosNConfigKeys.java
@@ -10,7 +10,7 @@
 @InterfaceStability.Unstable
 public class CosNConfigKeys extends CommonConfigurationKeys {
     public static final String USER_AGENT = "fs.cosn.user.agent";
-    public static final String DEFAULT_USER_AGENT = "cos-hadoop-plugin-v5.9.1";
+    public static final String DEFAULT_USER_AGENT = "cos-hadoop-plugin-v5.9.2";
 
     public static final String TENCENT_EMR_VERSION_KEY = "fs.emr.version";