diff --git a/python/pyspark/daemon.py b/python/pyspark/daemon.py index b2f226a55ec1367042b92aff861472c06f90c98a..5eb1c63bf206bbc397c81d086a230942443eb846 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