diff options
| -rw-r--r-- | python/pyspark/daemon.py | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/python/pyspark/daemon.py b/python/pyspark/daemon.py index b2f226a55e..5eb1c63bf2 100644 --- a/python/pyspark/daemon.py +++ b/python/pyspark/daemon.py @@ -103,6 +103,7 @@ def worker(listen_sock): if os.fork() == 0: # Leave the worker pool signal.signal(SIGHUP, SIG_DFL) + signal.signal(SIGCHLD, SIG_DFL) listen_sock.close() # Read the socket using fdopen instead of socket.makefile() because the latter # seems to be very slow; note that we need to dup() the file descriptor because |