diff --git a/pom.xml b/pom.xml index 8fea7f91..678671b2 100644 --- a/pom.xml +++ b/pom.xml @@ -6,7 +6,7 @@ com.qcloud.cos hadoop-cos - 5.9.1 + 5.9.2 jar Apache Hadoop Tencent Qcloud COS Support diff --git a/src/main/java/org/apache/hadoop/fs/CosFileSystem.java b/src/main/java/org/apache/hadoop/fs/CosFileSystem.java index f4610e2a..b4e5bb32 100644 --- 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 index 3e65d3bc..4220e600 100644 --- 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";