BryanCutler commented on a change in pull request #23337:
[SPARK-26019][PYSPARK] Allow insecure py4j gateways
URL: https://github.com/apache/spark/pull/23337#discussion_r243726636
##########
File path: python/pyspark/java_gateway.py
##########
@@ -41,8 +41,20 @@ def launch_gateway(conf=None):
"""
launch jvm gateway
:param conf: spark configuration passed to spark-submit
- :return:
+ :return: a JVM gateway
"""
+ return _launch_gateway(conf)
+
+
+def _launch_gateway(conf=None, insecure=False):
+ """
+ launch jvm gateway
+ :param conf: spark configuration passed to spark-submit
+ :param insecure: True to create an insecure gateway; only for testing
+ :return: a JVM gateway
+ """
+ if insecure and not os.environ.get("SPARK_TESTING", "0") == "1":
+ raise Exception("creating insecure gateways is only for testing")
Review comment:
Same here, maybe `raise ValueError`
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
With regards,
Apache Git Services
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
