the reason for this extra flush is because we have a batch size. Once the number of messages reaches this value, we invoke flush. at the end of the window when finishbundle is invoked, there may be few messages left in the buffer (less than batch size). So we invoke flush from here as well. And for this reason we need to store the window of the message as well.
[ Full content available at: https://github.com/apache/beam/pull/5841 ] This message was relayed via gitbox.apache.org for [email protected]
