You are viewing a plain text version of this content. The canonical link for it is here.

Posted to reviews@spark.apache.org by tdas <gi...@git.apache.org> on 2018/06/15 21:06:24 UTC

[GitHub] spark pull request #21571: [SPARK-24565][SS] Add API for in Structured Strea...

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: reviews-unsubscribe@spark.apache.org
For additional commands, e-mail: reviews-help@spark.apache.org