We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 3b498e1 commit b349649Copy full SHA for b349649
python/pyspark/java_gateway.py
@@ -102,10 +102,7 @@ def run(self):
102
EchoOutputThread(proc.stdout).start()
103
104
# Connect to the gateway
105
- # If start_callback_server is True, it looks like callback server is not killed
106
- # process is hang up and test case does not move forward.
107
- #gateway = JavaGateway(GatewayClient(port=gateway_port), auto_convert=False, start_callback_server=True)
108
- gateway = JavaGateway(GatewayClient(port=gateway_port), auto_convert=False, start_callback_server=False)
+ gateway = JavaGateway(GatewayClient(port=gateway_port), auto_convert=False)
109
110
# Import the classes used by PySpark
111
java_import(gateway.jvm, "org.apache.spark.SparkConf")
0 commit comments