We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent f4f094c commit 741a0d0Copy full SHA for 741a0d0
python/pyspark/streaming/tests.py
@@ -76,7 +76,6 @@ def tearDown(self):
76
if jStreamingContextOption.nonEmpty():
77
jStreamingContextOption.get().stop(false)
78
79
-
80
def wait_for(self, result, n):
81
start_time = time.time()
82
while len(result) < n and time.time() - start_time < self.timeout:
0 commit comments