diff --git a/python/pyspark/java_gateway.py b/python/pyspark/java_gateway.py index 19c2cb85aeb2e..afcc4118bcb0e 100644 --- a/python/pyspark/java_gateway.py +++ b/python/pyspark/java_gateway.py @@ -83,7 +83,7 @@ def preexec_func(): # JVMs. Instead, we use "taskkill" with the tree-kill option "/t" to terminate all # child processes. def killChild(): - Popen(["cmd", "/c", "taskkill", "/f", "/t", "/pid", str(proc.pid)]) + Popen(["cmd", "/c", "taskkill", "/f", "/t", "/pid", str(proc.pid)]) atexit.register(killChild) # Create a thread to echo output from the GatewayServer, which is required