change test file

ee1676ba · 张彦钊 · b1a174bf · ee1676ba
Commit ee1676ba authored Aug 16, 2019 by 张彦钊
Show whitespace changes
Inline Side-by-side

Showing with 1 addition and 1 deletion

monitor.py monitor.py +1 -1

No files found.
--- a/monitor.py
+++ b/monitor.py
@@ -127,7 +127,7 @@ def group_redis(device_id,cid_list):

 def group_write(rdd):
    rdd.groupByKey().map(lambda x,y:group_redis(x,y))
-    return good
+    return "good"

 # Spark-Streaming-Kafka
 sc = SparkContext(conf=SparkConf().setMaster("spark://nvwa01:7077").setAppName("filter").set("spark.io.compression.codec", "lzf"))