Something is wrong with the bookkeeping of processes in `ProcessManager`.

If I repeat a pipeline run before the environment was cleaned up (which would 
happen after 30s?), the process manager will find that a process with the id 
already exists, and fail.

```
Caused by: java.lang.IllegalStateException: There was already a process running 
with id 1
        at 
org.apache.beam.runners.fnexecution.environment.ProcessManager.runCommand(ProcessManager.java:78)
```


[ 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