[GitHub] [beam] damccorm opened a new issue, #19674: [FnApiRunner]multi-process runner does not terminate cleanly upon receiving SIGINT

[GitBox <gi...@apache.org>]

damccorm opened a new issue, #19674:
URL: https://github.com/apache/beam/issues/19674

   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:
   
   ```
   
   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
   
   ```
   
   
   Imported from Jira [BEAM-8149](https://issues.apache.org/jira/browse/BEAM-8149). Original Jira may contain additional context.
   Reported by: hannahjiang.


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: github-unsubscribe@beam.apache.org.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org