change test file

b1a174bf · 张彦钊 · 90fcaaab · b1a174bf
Commit b1a174bf authored Aug 16, 2019 by 张彦钊
Hide whitespace changes
Inline Side-by-side

Showing with 3 additions and 1 deletion

monitor.py monitor.py +3 -1

No files found.
--- a/monitor.py
+++ b/monitor.py
@@ -142,6 +142,7 @@ kafkaParams = {"metadata.broker.list": "172.16.44.25:9092,172.16.44.31:9092,172.

 stream = KafkaUtils.createDirectStream(ssc, ["gm-maidian-data"], kafkaParams)
 transformstream = stream.transform(lambda x:model(x)).foreachRDD(group_write)
-transformstream.pprint()
+# transformstream.pprint()
+print(transformstream)
 ssc.start()
 ssc.awaitTermination()
\ No newline at end of file