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 b47b5fd commit b6468e6Copy full SHA for b6468e6
python/pyspark/java_gateway.py
@@ -78,10 +78,7 @@ def run(self):
78
EchoOutputThread(proc.stdout).start()
79
80
# Connect to the gateway
81
- # If start_callback_server is True, it looks like callback server is not killed
82
- # process is hang up and test case does not move forward.
83
- #gateway = JavaGateway(GatewayClient(port=gateway_port), auto_convert=False, start_callback_server=True)
84
- gateway = JavaGateway(GatewayClient(port=gateway_port), auto_convert=False, start_callback_server=False)
+ gateway = JavaGateway(GatewayClient(port=gateway_port), auto_convert=False)
85
86
# Import the classes used by PySpark
87
java_import(gateway.jvm, "org.apache.spark.SparkConf")
0 commit comments