Github user HyukjinKwon commented on a diff in the pull request:
https://github.com/apache/spark/pull/21057#discussion_r181632575
--- Diff: python/pyspark/streaming/listener.py ---
@@ -22,6 +22,10 @@ class StreamingListener(object):
def __init__(self):
Github user felixcheung commented on a diff in the pull request:
https://github.com/apache/spark/pull/21057#discussion_r181630426
--- Diff: python/pyspark/streaming/listener.py ---
@@ -22,6 +22,10 @@ class StreamingListener(object):
def __init__(self):
Github user viirya commented on a diff in the pull request:
https://github.com/apache/spark/pull/21057#discussion_r181568263
--- Diff: python/pyspark/streaming/listener.py ---
@@ -22,6 +22,10 @@ class StreamingListener(object):
def __init__(self):
pass
Github user HyukjinKwon commented on a diff in the pull request:
https://github.com/apache/spark/pull/21057#discussion_r181553378
--- Diff: python/pyspark/streaming/kafka.py ---
@@ -104,7 +104,7 @@ def createDirectStream(ssc, topics, kafkaParams,
fromOffsets=None,
Github user aviv-ebates commented on a diff in the pull request:
https://github.com/apache/spark/pull/21057#discussion_r181460539
--- Diff: python/pyspark/streaming/kafka.py ---
@@ -104,7 +104,7 @@ def createDirectStream(ssc, topics, kafkaParams,
fromOffsets=None,
Github user HyukjinKwon commented on a diff in the pull request:
https://github.com/apache/spark/pull/21057#discussion_r181299329
--- Diff: python/pyspark/streaming/kafka.py ---
@@ -104,7 +104,7 @@ def createDirectStream(ssc, topics, kafkaParams,
fromOffsets=None,
GitHub user aviv-ebates opened a pull request:
https://github.com/apache/spark/pull/21057
2 Improvements to Pyspark docs
Each of these 2 items has cost me a few hours of debugging. Hopefully, this
will stop others from having to debug the same thing.
1. Describe the
