oss delete

recommend-feature-produce/src/main/java/com/tzld/piaoquan/recommend/feature/produce/VideoCleanExecutor.java

@@ -25,7 +25,7 @@ public class VideoCleanExecutor {
 
         log.info("count {}", multiFileRDD.count());
         OSSService ossService = new OSSService();
-        multiFileRDD.repartition(100).foreachPartition(s -> {
+        multiFileRDD.repartition(10).foreachPartition(s -> {
             List<String> objectNames = new ArrayList<>();
             if (s.hasNext()) {
                 String[] data = StringUtils.split(s.next(), "\t");

recommend-feature-produce/src/main/java/com/tzld/piaoquan/recommend/feature/produce/service/OSSService.java

@@ -23,7 +23,6 @@ public class OSSService implements Serializable {
         OSS ossClient = new OSSClientBuilder().build(endpoint, accessId, accessKey);
         for (String objectName : objectNames) {
             try {
-                objectName = "longvideo/transcode/video/vpc/20220919/19927351LCBOxjafmK4ppBpTCx.mp4";
                 CopyObjectRequest request = new CopyObjectRequest(bucketName, objectName, bucketName, objectName);
                 ObjectMetadata objectMetadata = new ObjectMetadata();
                 objectMetadata.setHeader("x-oss-storage-class", "DeepColdArchive");