Github user viirya commented on a diff in the pull request:
https://github.com/apache/spark/pull/21098#discussion_r182440300
--- Diff: python/pyspark/streaming/listener.py ---
@@ -23,6 +23,12 @@ class StreamingListener(object):
def __init__(self):
pass
+ def onStreamingStarted(self, streamingStarted):
--- End diff --
Although in #21057, it is mentioned that there will be an exception to be
thrown if this method is lack. However, I can't reproduce such error.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
