We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 0cd0817 commit 32cb829Copy full SHA for 32cb829
python/pyspark/daemon.py
@@ -91,6 +91,7 @@ def cleanup_dead_children():
91
except:
92
pass
93
94
+
95
def manager():
96
# Create a new process group to corral our children
97
os.setpgid(0, 0)
@@ -153,7 +154,7 @@ def handle_sigterm(*args):
153
154
except OSError as e:
155
if e.errno in (EAGAIN, EINTR):
156
time.sleep(1)
- pid = os.fork() # error here will shutdown daemon
157
+ pid = os.fork() # error here will shutdown daemon
158
else:
159
outfile = sock.makefile('w')
160
write_int(e.errno, outfile) # Signal that the fork failed
0 commit comments