The current behavior of connection cleanup is un-intuitive. The connection use to get closed only if the user called waitUntillFinish while if user did not call WUF then the connection is not closed. Hence removing the connection closing here so that the connection is only closed explicitly in close call.
[ Full content available at: https://github.com/apache/beam/pull/6537 ] This message was relayed via gitbox.apache.org for [email protected]
