mpu 409 retry with head (#58)

Co-authored-by: alantong <[email protected]>

Author: vintmd

pom.xml

@@ -6,7 +6,7 @@
 
     <groupId>com.qcloud.cos</groupId>
     <artifactId>hadoop-cos</artifactId>
-    <version>8.0.7</version>
+    <version>8.0.8</version>
     <packaging>jar</packaging>
 
     <name>Apache Hadoop Tencent Cloud COS Support</name>

src/main/java/org/apache/hadoop/fs/CosNConfigKeys.java

@@ -12,7 +12,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-v8.0.7";
+    public static final String DEFAULT_USER_AGENT = "cos-hadoop-plugin-v8.0.8";
 
     public static final String TENCENT_EMR_VERSION_KEY = "fs.emr.version";
 

src/main/java/org/apache/hadoop/fs/CosNativeFileSystemStore.java

@@ -512,8 +512,27 @@ public int compare(PartETag o1, PartETag o2) {
                             partETagList);
             completeMultipartUploadRequest.setObjectMetadata(objectMetadata);
             return (CompleteMultipartUploadResult) this.callCOSClientWithRetry(completeMultipartUploadRequest);
+        } catch (CosServiceException cse) {
+            // 避免并发上传的问题
+            int statusCode = cse.getStatusCode();
+            if (statusCode == 409) {
+                // Check一下这个文件是否已经存在
+                FileMetadata fileMetadata = this.queryObjectMetadata(key);
+                if (null == fileMetadata) {
+                    // 如果文件不存在，则需要抛出异常
+                    handleException(cse, key);
+                }
+                LOG.warn("Upload the cos key [{}] complete mpu concurrently", key);
+            } else {
+                // 其他错误都要抛出来
+                String errMsg = String.format("Complete the multipart upload failed. " +
+                        "cos service exception, cos key: %s, upload id: %s, " +
+                        "exception: %s", key, uploadId, cse.toString());
+                handleException(new Exception(errMsg), key);
+            }
         } catch (Exception e) {
-            String errMsg = String.format("Complete the multipart upload failed. cos key: %s, upload id: %s, " +
+            String errMsg = String.format("Complete the multipart upload failed. " +
+                    "cos key: %s, upload id: %s, " +
                     "exception: %s", key, uploadId, e.toString());
             handleException(new Exception(errMsg), key);
         }