change test file

monitor.py

@@ -45,7 +45,7 @@ def filter_na(x):
 def model(rdd):
     try:
         rdd = rdd.filter(lambda x:Json(x)).repartition(10).map(lambda x:get_data(x))\
-            .filter(lambda x:filter_na(x)).map(lambda x:write_redis(x[0],x[1]))
+            .map(lambda x:write_redis(x[0],x[1]))
         return  rdd
     except:
         print("fail")