From b349649b0739c51f92d760345083556474e24156 Mon Sep 17 00:00:00 2001 From: giwa Date: Sat, 2 Aug 2014 20:40:36 -0700 Subject: [PATCH] Removed the waste line --- python/pyspark/java_gateway.py | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) 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")