@@ -23,6 +23,7 @@ object makedata_09_user2redis_freq {
.appName(this.getClass.getName)
.getOrCreate()
val sc = spark.sparkContext
+ MyHdfsUtils.delete_hdfs_path("/dw/recommend/model/99_zhangbo_checkpoint/")
sc.setCheckpointDir("/dw/recommend/model/99_zhangbo_checkpoint/")
// 1 读取参数