Skip to content

Commit 46ca150

Browse files
committed
address comment
1 parent acd751c commit 46ca150

File tree

1 file changed

+1
-3
lines changed

1 file changed

+1
-3
lines changed

python/pyspark/daemon.py

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -142,10 +142,8 @@ def handle_sigchld(*args):
142142
os._exit(1)
143143
else:
144144
os._exit(0)
145-
elif pid > 0:
146-
sock.close()
147145
else:
148-
raise OSError("fork failed")
146+
sock.close()
149147

150148
except OSError as e:
151149
print >> sys.stderr, "Daemon failed to fork PySpark worker: %s" % e

0 commit comments

Comments
 (0)