Github user tgravescs commented on a diff in the pull request:
https://github.com/apache/spark/pull/23166#discussion_r237212353
--- Diff: python/pyspark/tests/test_broadcast.py ---
@@ -67,6 +67,20 @@ def test_broadcast_with_encryption(self):
def test_broadcast_no_encryption(self):
self._test_multiple_broadcasts()
+ def _test_broadcast_on_driver(self, *extra_confs):
+ conf = SparkConf()
+ for key, value in extra_confs:
+ conf.set(key, value)
+ conf.setMaster("local-cluster[2,1,1024]")
+ self.sc = SparkContext(conf=conf)
+ bs = self.sc.broadcast(value=5)
+ self.assertEqual(5, bs.value)
+
+ def test_broadcast_value_driver_no_encryption(self):
+ self._test_broadcast_on_driver()
+
+ def test_broadcast_value_driver_encryption(self):
+
self.self._test_broadcast_on_driver(("spark.io.encryption.enabled", "true"))
--- End diff --
have an extra .self here
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
