change test file

f49d3095 · 张彦钊 · 93732d52 · f49d3095
Commit f49d3095 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
@@ -126,7 +126,7 @@ def group_redis(device_id,cid_list):
 def group_write(rdd):
-    a = rdd.groupByKey().map(lambda x: group_redis(x[0],x[1]))
+    rdd.groupByKey().map(lambda x: group_redis(x[0],x[1]))
    return "good"
 # Spark-Streaming-Kafka