add back _sc condition check

apache · Nov 28, 2018 · 001dfff · 001dfff
1 parent d9994b7
commit 001dfff
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/python/pyspark/broadcast.py b/python/pyspark/broadcast.py
@@ -139,7 +139,7 @@ def value(self):
         if not hasattr(self, "_value") and self._path is not None:
             # we only need to decrypt it here when encryption is enabled and
             # if its on the driver, since executor decryption is handled already
-            if self._sc._encryption_enabled:
+            if self._sc is not None and self._sc._encryption_enabled:
                 port, auth_secret = self._python_broadcast.setupDecryptionServer()
                 (decrypted_sock_file, _) = local_connect_and_auth(port, auth_secret)
                 self._python_broadcast.waitTillBroadcastDataSent()