zhangbo 1 年之前
父節點
當前提交
e40cedca34
共有 1 個文件被更改,包括 1 次插入1 次删除
  1. 1 1
      src/main/scala/com/aliyun/odps/spark/examples/makedata/makedata_02_writeredis.scala

+ 1 - 1
src/main/scala/com/aliyun/odps/spark/examples/makedata/makedata_02_writeredis.scala

@@ -35,7 +35,7 @@ object makedata_02_writeredis {
     val partition = partitionPrefix + date
     val savePathUser = param.getOrDefault("savePathUser", "")
     val savePathVideo = param.getOrDefault("savePathVideo", "")
-    val userSampleIDs = param.getOrDefault("userSampleIDs", "").split(",").toList
+    val userSampleIDs = param.getOrDefault("userSampleIDs", "").split(",").map(_.toInt).toList
     //  /dw/recommend/model/feature/