all

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

@@ -106,7 +106,7 @@ object makedata_02_writeredis {
         val redisFormat = new util.HashMap[String, String]
         row.foreach {
           case (key, value, _) =>
-            if (key.nonEmpty) {
+            if (key.nonEmpty && value != null && value.nonEmpty) {
               redisFormat.put(videoRedisKeyPrefix + key, value)
             }
         }