[opt] set position 0 when object not exist

Author: FlechazoW

aws/aws-sink/src/main/java/com/dtstack/flink/sql/sink/aws/util/AwsManager.java

@@ -69,17 +69,6 @@ public static AmazonS3Client initClient(String accessKey,
         return client;
     }
 
-    /**
-     * 关闭s3 客户端
-     *
-     * @param client s3 client
-     */
-    public static void closeClient(AmazonS3Client client) {
-        if (Objects.nonNull(client)) {
-            client.shutdown();
-        }
-    }
-
     /**
      * 创建bucket
      *
@@ -150,7 +139,19 @@ public static void setBucketAccessControl(AmazonS3Client client,
         client.setBucketAcl(request);
     }
 
+    /**
+     * 获取当前 Object 字节位数，如果 Object 不存在，那么返回 0
+     *
+     * @param bucket     bucket
+     * @param objectName object name
+     * @param client     client
+     * @return object bytes 位数
+     */
     public static long getObjectPosition(String bucket, String objectName, AmazonS3Client client) {
+        if (!client.doesObjectExist(bucket, objectName)) {
+            return 0;
+        }
+
         S3Object object = client.getObject(bucket, objectName);
         ObjectMetadata objectMetadata = object.getObjectMetadata();
         return objectMetadata.getContentLength();