[ https://issues.apache.org/jira/browse/BEAM-8149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17174661#comment-17174661 ]
Beam JIRA Bot commented on BEAM-8149: ------------------------------------- This issue is P2 but has been unassigned without any comment for 60 days so it has been labeled "stale-P2". If this issue is still affecting you, we care! Please comment and remove the label. Otherwise, in 14 days the issue will be moved to P3. Please see https://beam.apache.org/contribute/jira-priorities/ for a detailed explanation of what these priorities mean. > [FnApiRunner]multi-process runner does not terminate cleanly upon receiving > SIGINT > ---------------------------------------------------------------------------------- > > Key: BEAM-8149 > URL: https://issues.apache.org/jira/browse/BEAM-8149 > Project: Beam > Issue Type: Bug > Components: sdk-py-core > Affects Versions: 2.15.0 > Reporter: Hannah Jiang > Priority: P2 > Labels: stale-P2 > > The multi-process runner does not handle SIGINT gracefully. To reproduce, run > wordcount.py using the "Run with multiprocessing mode" instructions from the > first comment in BEAM-3645 (in Python 3). > Expected: wordcount terminates gracefully when Ctrl-C is pressed during > pipeline execution (similarly to default direct runner) > Actual: wordcount hangs forever after printing the following once per worker: > {code} > Exception in thread run_worker: > Traceback (most recent call last): > File "/usr/lib/python3.6/threading.py", line 916, in _bootstrap_inner > self.run() > File "/usr/lib/python3.6/threading.py", line 864, in run > self._target(*self._args, **self._kwargs) > File > "/usr/local/google/home/yifanmai/venv/wordcount/lib/python3.6/site-packages/apache_beam/runners/portability/local_job_service.py", > line 216, in run > 'Worker subprocess exited with return code %s' % p.returncode) > RuntimeError: Worker subprocess exited with return code 1 > {code} -- This message was sent by Atlassian Jira (v8.3.4#803005)