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 d9994b7 commit 001dfffCopy full SHA for 001dfff
python/pyspark/broadcast.py
@@ -139,7 +139,7 @@ def value(self):
139
if not hasattr(self, "_value") and self._path is not None:
140
# we only need to decrypt it here when encryption is enabled and
141
# if its on the driver, since executor decryption is handled already
142
- if self._sc._encryption_enabled:
+ if self._sc is not None and self._sc._encryption_enabled:
143
port, auth_secret = self._python_broadcast.setupDecryptionServer()
144
(decrypted_sock_file, _) = local_connect_and_auth(port, auth_secret)
145
self._python_broadcast.waitTillBroadcastDataSent()
0 commit comments