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 741a0d0 commit 64a231dCopy full SHA for 64a231d
python/pyspark/streaming/tests.py
@@ -74,7 +74,7 @@ def tearDown(self):
74
# Clean up in the JVM just in case there has been some issues in Python API
75
jStreamingContextOption = StreamingContext._jvm.SparkContext.getActive()
76
if jStreamingContextOption.nonEmpty():
77
- jStreamingContextOption.get().stop(false)
+ jStreamingContextOption.get().stop(False)
78
79
def wait_for(self, result, n):
80
start_time = time.time()
0 commit comments