|
@@ -21,7 +21,7 @@ public class VideoCleanExecutor {
|
|
|
.setAppName("VideoCleanExecutor");
|
|
|
JavaSparkContext jsc = new JavaSparkContext(sparkConf);
|
|
|
|
|
|
- JavaRDD<String> multiFileRDD = jsc.textFile("/dyp/oss/video_clean/part-00000");
|
|
|
+ JavaRDD<String> multiFileRDD = jsc.textFile("/dyp/oss/video_clean/part-00001");
|
|
|
|
|
|
log.info("count {}", multiFileRDD.count());
|
|
|
OSSService ossService = new OSSService();
|