all

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

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