个人记录

src/main/scala/com/aliyun/odps/spark/examples/makedata/makedata_17_bucketDataPrint_20240617.scala

@@ -350,7 +350,7 @@ object makedata_17_bucketDataPrint_20240617 {
     if (saveV4.nonEmpty && saveV4.startsWith("/dw/recommend/model/")) {
       println("删除路径并开始数据写入:" + saveV4)
       MyHdfsUtils.delete_hdfs_path(saveV4)
-      data2.map(r => r._1 + "\t" + r._4.mkString("\t")).saveAsTextFile(saveV4, classOf[GzipCodec])
+      data2.map(r => r._1 + "\t" + r._5.mkString("\t")).saveAsTextFile(saveV4, classOf[GzipCodec])
     } else {
       println("路径不合法，无法写入:" + saveV4)
     }