File tree Expand file tree Collapse file tree 2 files changed +9
-1
lines changed Expand file tree Collapse file tree 2 files changed +9
-1
lines changed Original file line number Diff line number Diff line change @@ -102,7 +102,10 @@ def run(self):
102
102
EchoOutputThread (proc .stdout ).start ()
103
103
104
104
# Connect to the gateway
105
- gateway = JavaGateway (GatewayClient (port = gateway_port ), auto_convert = False , start_callback_server = True )
105
+ # If start_callback_server is True, it looks like callback server is not killed
106
+ # process is hang up and test case does not move forward.
107
+ #gateway = JavaGateway(GatewayClient(port=gateway_port), auto_convert=False, start_callback_server=True)
108
+ gateway = JavaGateway (GatewayClient (port = gateway_port ), auto_convert = False , start_callback_server = False )
106
109
107
110
# Import the classes used by PySpark
108
111
java_import (gateway .jvm , "org.apache.spark.SparkConf" )
Original file line number Diff line number Diff line change 18
18
import sys
19
19
from signal import signal , SIGTERM , SIGINT
20
20
21
+ import time
22
+
23
+ from pyspark .conf import SparkConf
24
+ from pyspark .files import SparkFiles
25
+ from pyspark .java_gateway import launch_gateway
21
26
from pyspark .serializers import PickleSerializer , BatchedSerializer , UTF8Deserializer
22
27
from pyspark .context import SparkContext
23
28
from pyspark .streaming .dstream import DStream
You can’t perform that action at this time.
0 commit comments