|
@@ -23,7 +23,7 @@ public class VideoCleanExecutor {
|
|
|
|
|
|
JavaRDD<String> multiFileRDD = jsc.textFile("/dyp/oss/video_clean/part-00000");
|
|
|
|
|
|
- log.info("count {}", multiFileRDD.count())
|
|
|
+ log.info("count {}", multiFileRDD.count());
|
|
|
|
|
|
multiFileRDD.repartition(100).foreachPartition(s -> {
|
|
|
List<String> objectNames = new ArrayList<>();
|