Github user tdas commented on a diff in the pull request:
https://github.com/apache/spark/pull/21571#discussion_r195861903
--- Diff: python/pyspark/java_gateway.py ---
@@ -145,3 +145,26 @@ def do_server_auth(conn, auth_secret):
if reply != "ok":
conn.close()
raise Exception("Unexpected reply from iterator server.")
+
+
+def ensure_callback_server_started(gw):
--- End diff --
This was copied verbatim from python streaming/context.py
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
