Thank you for reminding that the `tryFinishCurrentBufferBuilder()` will also be called by `broadcastEvent()`, so I prefer keeping the current mode. :)
I indeed run the benchmark in my local machine and it is actually not very stable sometimes. I will try to update the latest codes covering all the above modifications during weekends. :) [ Full content available at: https://github.com/apache/flink/pull/6417 ] This message was relayed via gitbox.apache.org for [email protected]
