all

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

@@ -93,7 +93,7 @@ object makedata_09_user2redis {
           })
           (mid, resultNew.toString())
         })
-      userData = userData.leftOuterJoin(midRdd.map(r=> (r, 1))).map(r=> (r._1, r._2._1))
+      userData = userData.join(midRdd.map(r=> (r, 1))).map(r=> (r._1, r._2._1))
 
       if (userSampleIDs.nonEmpty){
         val IDs = userSampleIDs.split(",").filter(_.nonEmpty).map(_.toInt).toList