all

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

@@ -128,7 +128,7 @@ object makedata_02_writeredis {
 
   def handleItem(record: Record, schema: TableSchema): Tuple3[String, String, Int] = {
     val videoKey = "videoid"
-    val videoid = record.getString(videoKey)
+    val videoid = record.getBigint(videoKey).toString
     val reqContext: RequestContextOffline = new RequestContextOffline()
     reqContext.putItemFeature(record)
     reqContext.featureMap.put("videoid", videoid)