diff --git a/python/pyspark/java_gateway.py b/python/pyspark/java_gateway.py index d32beef9b860c..d7e7bbf806544 100644 --- a/python/pyspark/java_gateway.py +++ b/python/pyspark/java_gateway.py @@ -102,10 +102,7 @@ def run(self): EchoOutputThread(proc.stdout).start() # Connect to the gateway - # If start_callback_server is True, it looks like callback server is not killed - # process is hang up and test case does not move forward. - #gateway = JavaGateway(GatewayClient(port=gateway_port), auto_convert=False, start_callback_server=True) - gateway = JavaGateway(GatewayClient(port=gateway_port), auto_convert=False, start_callback_server=False) + gateway = JavaGateway(GatewayClient(port=gateway_port), auto_convert=False) # Import the classes used by PySpark java_import(gateway.jvm, "org.apache.spark.SparkConf")