> btw I noticed that after job server shutdown, launched processes still stick 
> around and don't exit

Please see the latest version of the PR from yesterday. I revised the shutdown 
logic to eventually kill  processes if they don't stop gracefully. In your code 
you're using the old version. Also, I've added a ShutdownHook to kill running 
processes in case the JVM shuts down prematurely.

@tweise @angoenka I've removed the singleton ProcessManager and instantiate it 
per `ProcessEnvironmentFactory` which should get rid of the duplicate worker 
ids you were seeing @tweise.

@tweise For the IO, I've enabled inheriting IO when the log level is set to 
DEBUG. That should help with debugging process startup problems.

[ Full content available at: https://github.com/apache/beam/pull/6287 ]
This message was relayed via gitbox.apache.org for [email protected]

Reply via email to