all

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

@@ -126,7 +126,11 @@ object makedata_08_item2redis {
         } else if (obj.isInstanceOf[Date]) {
           result.put(r, String.valueOf(record.getDatetime(r)))
         } else {
-
+          try {
+            result.put(r, record.getString(r))
+          } catch {
+            case _ => result.put(r, String.valueOf(record.getBigint(r)))
+          }
         }
       }
     })