change test file

26896489 · 张彦钊 · f9d84467 · 26896489
Commit 26896489 authored Aug 16, 2019 by 张彦钊
Hide 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
@@ -128,7 +128,7 @@ def group_redis(x):


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