diff --git a/python/pyspark/streaming/dstream.py b/python/pyspark/streaming/dstream.py index aab514bedaa3c..1ad2e36ad21cf 100644 --- a/python/pyspark/streaming/dstream.py +++ b/python/pyspark/streaming/dstream.py @@ -474,4 +474,3 @@ def _jdstream(self): def _is_pipelinable(self): return not (self.is_cached) -