Github user redsanket commented on a diff in the pull request:
https://github.com/apache/spark/pull/23166#discussion_r237250388
--- Diff: python/pyspark/broadcast.py ---
@@ -134,7 +137,15 @@ def value(self):
""" Return the broadcasted value
"""
if not hasattr(self, "_value") and self._path is not None:
- self._value = self.load_from_path(self._path)
+ # we only need to decrypt it here when encryption is enabled
and
--- End diff --
sorry yeah i thought hasattr would take of that my bad earlier had the
check self._sc is not None, will add it back in load_from_path
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
