From 1b83354d8446e6a3c2a31854d7b7e7108089fde9 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 af6109dc2ab69..2af917efc40a3 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")