Flink operators (and probably their entire chain) cannot be assumed to be thread-safe. The best solution would be to use the thread that is blocking for the end of the bundle. The next best thing would be a single output background thread and synchronize after the bundle is closed. At this time that isn't the top priority though..
[ Full content available at: https://github.com/apache/beam/pull/6271 ] This message was relayed via gitbox.apache.org for [email protected]
