diff --git a/python/pyspark/daemon.py b/python/pyspark/daemon.py index 4c7aefd7f9922..9fde0dde0f4b4 100644 --- a/python/pyspark/daemon.py +++ b/python/pyspark/daemon.py @@ -120,7 +120,7 @@ def handle_sigchld(*args): try: ready_fds = select.select([0, listen_sock], [], [])[0] except select.error as ex: - if ex[0] == 4: + if ex[0] == EINTR: continue else: raise