We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 0f83eaa commit 48f7746Copy full SHA for 48f7746
python/pyspark/java_gateway.py
@@ -76,10 +76,7 @@ def run(self):
76
EchoOutputThread(proc.stdout).start()
77
78
# Connect to the gateway
79
- # If start_callback_server is True, it looks like callback server is not killed
80
- # process is hang up and test case does not move forward.
81
- #gateway = JavaGateway(GatewayClient(port=gateway_port), auto_convert=False, start_callback_server=True)
82
- gateway = JavaGateway(GatewayClient(port=gateway_port), auto_convert=False, start_callback_server=False)
+ gateway = JavaGateway(GatewayClient(port=gateway_port), auto_convert=False)
83
84
# Import the classes used by PySpark
85
java_import(gateway.jvm, "org.apache.spark.SparkConf")
0 commit comments