diff --git a/udf-starter-file-aliyun-oss/src/main/java/org/itkk/udf/file/aliyun/oss/OssWarpper.java b/udf-starter-file-aliyun-oss/src/main/java/org/itkk/udf/file/aliyun/oss/OssWarpper.java index f21c733..76641fe 100644 --- a/udf-starter-file-aliyun-oss/src/main/java/org/itkk/udf/file/aliyun/oss/OssWarpper.java +++ b/udf-starter-file-aliyun-oss/src/main/java/org/itkk/udf/file/aliyun/oss/OssWarpper.java @@ -104,6 +104,10 @@ public class OssWarpper { //实例化oss对象 OSSClient client = new OSSClient(auth.getEndPoint(), auth.getAccessId(), auth.getAccessKey()); try { + //判断文件是否存在 + if (!client.doesObjectExist(path.getBucketName(), objectKey)) { + throw new ParameterValidException(objectKey + "不存在", null); + } //构造超时时间 long expireEndTime = System.currentTimeMillis() + auth.getExpireTime() * NUM_1000; Date expiration = new Date(expireEndTime);