all

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

@@ -86,7 +86,7 @@ object makedata_02_writeredis {
 
   def handleUser(record: Record, schema: TableSchema): util.ArrayList[String] = {
     val feature = RecommRedisFeatureConstructor.constructUserFeature(record)
-    val key = String.format("user_info_%s", feature.getKey)
+    val key = String.format("user_info_%s", feature.getUid)
     val value = feature.getValue
     val kv = new util.ArrayList[String](2)
     kv.add(key)