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 1a371d9 commit e21488dCopy full SHA for e21488d
python/pyspark/streaming/context.py
@@ -189,6 +189,7 @@ def getActive(cls):
189
if activeJvmContextOption.isEmpty():
190
cls._activeContext = None
191
elif activeJvmContextOption.get().hashCode() != activePythonContextJavaId:
192
+ cls._activeContext = None
193
raise Exception("JVM's active JavaStreamingContext is not the JavaStreamingContext "
194
"backing the action Python StreamingContext. This is unexpected.")
195
return cls._activeContext
0 commit comments